mirrors/gstreamer-rs
mirrors/gstreamer-rs
1
1
Fork 1
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer-rs.git synced 2024-11-25 11:01:10 +00:00
Code Issues Projects Releases Wiki Activity

utils: streamproducer: update appsrc latency upon appsink latency event

Browse source 
Part-of: <https://gitlab.freedesktop.org/gstreamer/gstreamer-rs/-/merge_requests/1560>
This commit is contained in:
juan.adarve 2024-10-17 15:11:52 -05:00 committed by GStreamer Marge Bot
parent cfa9ea2dc7
commit 45e3358497
1 changed files with 2 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
gstreamer-utils/src/streamproducer.rs
View file

@ -349,6 +349,7 @@ impl StreamProducer {
.is_ok() .is_ok()
|| latency_updated || latency_updated
{ {
gst::info!(CAT, obj = appsink, "setting new latency: {latency}");
consumer.appsrc.set_latency(latency, gst::ClockTime::NONE); consumer.appsrc.set_latency(latency, gst::ClockTime::NONE);
} }
} }
@ -626,6 +627,7 @@ impl<'a> From<&'a gst_app::AppSink> for StreamProducer {
let latency = event.latency(); let latency = event.latency();
let mut consumers = consumers.lock().unwrap(); let mut consumers = consumers.lock().unwrap();
consumers.current_latency = Some(latency); consumers.current_latency = Some(latency);
consumers.latency_updated = true;
gst::PadProbeReturn::Ok gst::PadProbeReturn::Ok
} }