mirror of
https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs.git
synced 2024-11-28 22:41:02 +00:00
livesync: Report latency query results when handling latency query too
Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs/-/merge_requests/1739>
This commit is contained in:
parent
dee0e32dde
commit
87b72f768b
1 changed files with 20 additions and 1 deletions
|
@ -814,9 +814,28 @@ impl LiveSync {
|
||||||
let mut state = self.state.lock();
|
let mut state = self.state.lock();
|
||||||
let latency = state.latency;
|
let latency = state.latency;
|
||||||
|
|
||||||
let (_live, min, max) = q.result();
|
let (live, min, max) = q.result();
|
||||||
|
|
||||||
|
gst::debug!(
|
||||||
|
CAT,
|
||||||
|
imp = self,
|
||||||
|
"Upstream latency query response: live {} min {} max {}",
|
||||||
|
live,
|
||||||
|
min,
|
||||||
|
max.display()
|
||||||
|
);
|
||||||
|
|
||||||
q.set(true, min + latency, max.map(|max| max + latency));
|
q.set(true, min + latency, max.map(|max| max + latency));
|
||||||
|
|
||||||
|
gst::debug!(
|
||||||
|
CAT,
|
||||||
|
imp = self,
|
||||||
|
"Reporting latency: live {} min {} max {}",
|
||||||
|
live,
|
||||||
|
min + latency,
|
||||||
|
max.map(|max| max + latency).display()
|
||||||
|
);
|
||||||
|
|
||||||
state.upstream_latency = Some(min);
|
state.upstream_latency = Some(min);
|
||||||
true
|
true
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue