gst/gstqueue.c: Release interrupt after handling (#166250).

Original commit message from CVS:
* gst/gstqueue.c: (gst_queue_chain), (gst_queue_get):
Release interrupt after handling (#166250).

diff --git a/ChangeLog b/ChangeLog
index 9d7fb57..46b076b 100644 (file)
--- a/ChangeLog
+++ b/ChangeLog
@@ -1,3 +1,8 @@
+2005-02-08  Ronald S. Bultje  <rbultje@ronald.bitfreak.net>
+
+       * gst/gstqueue.c: (gst_queue_chain), (gst_queue_get):
+         Release interrupt after handling (#166250).
+
 2005-02-08  Thomas Vander Stichele  <thomas at apestaart dot org>
 
        * configure.ac:

diff --git a/gst/gstqueue.c b/gst/gstqueue.c
index 2386634..b9ade24 100644 (file)
--- a/gst/gstqueue.c
+++ b/gst/gstqueue.c
@@ -657,6 +657,7 @@ restart:
             GstScheduler *sched;
 
             GST_CAT_DEBUG_OBJECT (queue_dataflow, queue, "interrupted");
+            queue->interrupt = FALSE;
             GST_QUEUE_MUTEX_UNLOCK;
             sched = gst_pad_get_scheduler (queue->sinkpad);
             if (!sched || gst_scheduler_interrupt (sched, GST_ELEMENT (queue))) {
@@ -783,6 +784,7 @@ restart:
         GstScheduler *sched;
 
         GST_CAT_DEBUG_OBJECT (queue_dataflow, queue, "interrupted");
+        queue->interrupt = FALSE;
         GST_QUEUE_MUTEX_UNLOCK;
         sched = gst_pad_get_scheduler (queue->srcpad);
         if (!sched || gst_scheduler_interrupt (sched, GST_ELEMENT (queue)))

diff --git a/plugins/elements/gstqueue.c b/plugins/elements/gstqueue.c
index 2386634..b9ade24 100644 (file)
--- a/plugins/elements/gstqueue.c
+++ b/plugins/elements/gstqueue.c
@@ -657,6 +657,7 @@ restart:
             GstScheduler *sched;
 
             GST_CAT_DEBUG_OBJECT (queue_dataflow, queue, "interrupted");
+            queue->interrupt = FALSE;
             GST_QUEUE_MUTEX_UNLOCK;
             sched = gst_pad_get_scheduler (queue->sinkpad);
             if (!sched || gst_scheduler_interrupt (sched, GST_ELEMENT (queue))) {
@@ -783,6 +784,7 @@ restart:
         GstScheduler *sched;
 
         GST_CAT_DEBUG_OBJECT (queue_dataflow, queue, "interrupted");
+        queue->interrupt = FALSE;
         GST_QUEUE_MUTEX_UNLOCK;
         sched = gst_pad_get_scheduler (queue->srcpad);
         if (!sched || gst_scheduler_interrupt (sched, GST_ELEMENT (queue)))