kohrokho
/
ALVR-IPv6
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat(server): ✨ Expose total video latency in the webserver

This commit is contained in:
Riccardo Zaglia 2023-09-14 15:53:17 +08:00
parent 254d06c197
commit 45141c1c99
2 changed files with 19 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
alvr/server/src/statistics.rs
View File

@ -303,6 +303,10 @@ impl StatisticsManager {
}
}
pub fn video_pipeline_latency_average(&self) -> Duration {
self.total_pipeline_latency_average.get_average()
}
pub fn tracker_pose_time_offset(&self) -> Duration {
// This is the opposite of the client's StatisticsManager::tracker_prediction_offset().
self.steamvr_pipeline_latency

18
alvr/server/src/web_server.rs
View File

@ -1,7 +1,7 @@
use crate::{
bindings::FfiButtonValue, connection::ClientDisconnectRequest, DECODER_CONFIG,
DISCONNECT_CLIENT_NOTIFIER, FILESYSTEM_LAYOUT, SERVER_DATA_MANAGER, VIDEO_MIRROR_SENDER,
VIDEO_RECORDING_FILE,
DISCONNECT_CLIENT_NOTIFIER, FILESYSTEM_LAYOUT, SERVER_DATA_MANAGER, STATISTICS_MANAGER,
VIDEO_MIRROR_SENDER, VIDEO_RECORDING_FILE,
};
use alvr_common::{
anyhow::{self, Result},
@ -14,7 +14,7 @@ use bytes::Buf;
use futures::SinkExt;
use headers::HeaderMapExt;
use hyper::{
header::{HeaderValue, ACCESS_CONTROL_ALLOW_ORIGIN, CACHE_CONTROL, CONTENT_TYPE},
header::{self, HeaderValue, ACCESS_CONTROL_ALLOW_ORIGIN, CACHE_CONTROL, CONTENT_TYPE},
service, Body, Request, Response, StatusCode,
};
use serde::de::DeserializeOwned;
@ -244,6 +244,18 @@ async fn http_api(
reply(StatusCode::OK)?
}
// Latency in ms
"/api/average-video-latency" => {
let latency = if let Some(manager) = &*STATISTICS_MANAGER.lock() {
manager.video_pipeline_latency_average().as_millis()
} else {
0
};
Response::builder()
.header(header::CONTENT_TYPE, "application/json")
.body(latency.to_string().into())?
}
"/api/ping" => reply(StatusCode::OK)?,
other_uri => {
if other_uri.contains("..") {