mirrors/gst-plugins-rs
mirrors/gst-plugins-rs
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs.git synced 2024-06-23 00:20:34 +00:00
Code Issues Projects Releases Wiki Activity

proxy: signal the pending queue in ProxySrc.start()

Browse source 
If the proxy sink has already queued buffers in the shared
context pending queue and is waiting for space in the data
queue, we should signal that space is available when creating
it!
This commit is contained in:
Mathieu Duponchelle 2020-01-29 23:36:54 +01:00
parent 53e948b8da
commit bcae2423f5
1 changed files with 6 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
gst-plugin-threadshare/src/proxy.rs
View file

@ -311,7 +311,7 @@ struct ProxySinkPadHandler(Arc<ProxySinkPadHandlerInner>);
impl ProxySinkPadHandler {
fn new(proxy_ctx: ProxyContext) -> Self {
ProxySinkPadHandler(Arc::new(ProxySinkPadHandlerInner {
proxy_ctx: proxy_ctx,
proxy_ctx,
flush_rx: sync::Mutex::new(None),
}))
}
@ -1272,6 +1272,11 @@ impl ProxySrc {
.clone();
dataqueue.start().await;
let mut shared_ctx = state.proxy_ctx().unwrap().lock_shared().await;
if let Some(ref mut pending_queue) = shared_ctx.pending_queue {
pending_queue.notify_more_queue_space();
}
ProxySrcPadHandler::start_task(self.src_pad.as_ref(), element, dataqueue).await;
gst_debug!(SRC_CAT, obj: element, "Started");