From b7b63ff4cdd9e7c48dd84473c2da072d7626ebfd Mon Sep 17 00:00:00 2001 From: Wim Taymans Date: Wed, 5 Jun 2002 18:10:07 +0000 Subject: [PATCH] Make sure we interrupt the right scheduler on the right pad. Original commit message from CVS: Make sure we interrupt the right scheduler on the right pad. --- gst/gstqueue.c | 4 ++-- plugins/elements/gstqueue.c | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/gst/gstqueue.c b/gst/gstqueue.c index e42dfe0..f2ca083 100644 --- a/gst/gstqueue.c +++ b/gst/gstqueue.c @@ -370,7 +370,7 @@ restart: if (queue->interrupt) { GST_DEBUG_ELEMENT (GST_CAT_DATAFLOW, queue, "interrupted!!"); g_mutex_unlock (queue->qlock); - if (gst_element_interrupt (GST_ELEMENT (queue))) + if (gst_scheduler_interrupt (GST_RPAD_SCHED (queue->sinkpad), GST_ELEMENT (queue))) return; goto restart; } @@ -456,7 +456,7 @@ restart: if (queue->interrupt) { GST_DEBUG_ELEMENT (GST_CAT_DATAFLOW, queue, "interrupted!!"); g_mutex_unlock (queue->qlock); - if (gst_element_interrupt (GST_ELEMENT (queue))) + if (gst_scheduler_interrupt (GST_RPAD_SCHED (queue->srcpad), GST_ELEMENT (queue))) return NULL; goto restart; } diff --git a/plugins/elements/gstqueue.c b/plugins/elements/gstqueue.c index e42dfe0..f2ca083 100644 --- a/plugins/elements/gstqueue.c +++ b/plugins/elements/gstqueue.c @@ -370,7 +370,7 @@ restart: if (queue->interrupt) { GST_DEBUG_ELEMENT (GST_CAT_DATAFLOW, queue, "interrupted!!"); g_mutex_unlock (queue->qlock); - if (gst_element_interrupt (GST_ELEMENT (queue))) + if (gst_scheduler_interrupt (GST_RPAD_SCHED (queue->sinkpad), GST_ELEMENT (queue))) return; goto restart; } @@ -456,7 +456,7 @@ restart: if (queue->interrupt) { GST_DEBUG_ELEMENT (GST_CAT_DATAFLOW, queue, "interrupted!!"); g_mutex_unlock (queue->qlock); - if (gst_element_interrupt (GST_ELEMENT (queue))) + if (gst_scheduler_interrupt (GST_RPAD_SCHED (queue->srcpad), GST_ELEMENT (queue))) return NULL; goto restart; } -- 2.7.4