From eb3c38de8ca878f86513a6a0757787e1e3bc4b71 Mon Sep 17 00:00:00 2001
From: "Ronald S. Bultje" <rbultje@ronald.bitfreak.net>
Date: Tue, 8 Feb 2005 13:50:44 +0000
Subject: [PATCH] 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).
---
 ChangeLog                   | 5 +++++
 gst/gstqueue.c              | 2 ++
 plugins/elements/gstqueue.c | 2 ++
 3 files changed, 9 insertions(+)

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