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).
This commit is contained in:
Ronald S. Bultje 2005-02-08 13:50:44 +00:00
parent 4eaa28d2a0
commit eb3c38de8c
3 changed files with 9 additions and 0 deletions

View file

@ -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> 2005-02-08 Thomas Vander Stichele <thomas at apestaart dot org>
* configure.ac: * configure.ac:

View file

@ -657,6 +657,7 @@ restart:
GstScheduler *sched; GstScheduler *sched;
GST_CAT_DEBUG_OBJECT (queue_dataflow, queue, "interrupted"); GST_CAT_DEBUG_OBJECT (queue_dataflow, queue, "interrupted");
queue->interrupt = FALSE;
GST_QUEUE_MUTEX_UNLOCK; GST_QUEUE_MUTEX_UNLOCK;
sched = gst_pad_get_scheduler (queue->sinkpad); sched = gst_pad_get_scheduler (queue->sinkpad);
if (!sched || gst_scheduler_interrupt (sched, GST_ELEMENT (queue))) { if (!sched || gst_scheduler_interrupt (sched, GST_ELEMENT (queue))) {
@ -783,6 +784,7 @@ restart:
GstScheduler *sched; GstScheduler *sched;
GST_CAT_DEBUG_OBJECT (queue_dataflow, queue, "interrupted"); GST_CAT_DEBUG_OBJECT (queue_dataflow, queue, "interrupted");
queue->interrupt = FALSE;
GST_QUEUE_MUTEX_UNLOCK; GST_QUEUE_MUTEX_UNLOCK;
sched = gst_pad_get_scheduler (queue->srcpad); sched = gst_pad_get_scheduler (queue->srcpad);
if (!sched || gst_scheduler_interrupt (sched, GST_ELEMENT (queue))) if (!sched || gst_scheduler_interrupt (sched, GST_ELEMENT (queue)))

View file

@ -657,6 +657,7 @@ restart:
GstScheduler *sched; GstScheduler *sched;
GST_CAT_DEBUG_OBJECT (queue_dataflow, queue, "interrupted"); GST_CAT_DEBUG_OBJECT (queue_dataflow, queue, "interrupted");
queue->interrupt = FALSE;
GST_QUEUE_MUTEX_UNLOCK; GST_QUEUE_MUTEX_UNLOCK;
sched = gst_pad_get_scheduler (queue->sinkpad); sched = gst_pad_get_scheduler (queue->sinkpad);
if (!sched || gst_scheduler_interrupt (sched, GST_ELEMENT (queue))) { if (!sched || gst_scheduler_interrupt (sched, GST_ELEMENT (queue))) {
@ -783,6 +784,7 @@ restart:
GstScheduler *sched; GstScheduler *sched;
GST_CAT_DEBUG_OBJECT (queue_dataflow, queue, "interrupted"); GST_CAT_DEBUG_OBJECT (queue_dataflow, queue, "interrupted");
queue->interrupt = FALSE;
GST_QUEUE_MUTEX_UNLOCK; GST_QUEUE_MUTEX_UNLOCK;
sched = gst_pad_get_scheduler (queue->srcpad); sched = gst_pad_get_scheduler (queue->srcpad);
if (!sched || gst_scheduler_interrupt (sched, GST_ELEMENT (queue))) if (!sched || gst_scheduler_interrupt (sched, GST_ELEMENT (queue)))