From: Ronald S. Bultje <rbultje@ronald.bitfreak.net>
Date: Tue, 8 Feb 2005 13:50:44 +0000 (+0000)
Subject: gst/gstqueue.c: Release interrupt after handling (#166250).
X-Git-Tag: BRANCH-GSTREAMER-0_6-ROOT~15
X-Git-Url: http://review.tizen.org/git/?a=commitdiff_plain;h=eb3c38de8ca878f86513a6a0757787e1e3bc4b71;p=platform%2Fupstream%2Fgstreamer.git

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
--- 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
--- 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
--- 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)))