FaSTTUBe/GST-Tensordecoder-ov_ep
37
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

[MOVED FROM GST-P-FARSIGHT] Unlock liveadder empty buffer gcond on flush

Browse Source 
20080421032614-3e2dc-4ed29e1583ff684338ba5d7611f60b1a7eaff563.gz
This commit is contained in:
Olivier Crete 2008-04-21 03:26:14 +00:00 committed by Edward Hervey
parent 244bf6f250
commit 341a88cd04
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
gst/liveadder/liveadder.c
View File

@ -452,6 +452,8 @@ gst_live_adder_flush_start (GstLiveAdder * adder)
* locking streaming thread. */ * locking streaming thread. */
if (adder->clock_id) if (adder->clock_id)
gst_clock_id_unschedule (adder->clock_id); gst_clock_id_unschedule (adder->clock_id);
g_cond_broadcast (adder->not_empty_cond);
GST_OBJECT_UNLOCK (adder); GST_OBJECT_UNLOCK (adder);
} }
@ -1029,12 +1031,12 @@ gst_live_adder_loop (gpointer data)
for (;;) for (;;)
{ {
if (adder->srcresult != GST_FLOW_OK)
goto flushing;
if (!g_queue_is_empty (adder->buffers)) if (!g_queue_is_empty (adder->buffers))
break; break;
if (check_eos_locked (adder)) if (check_eos_locked (adder))
goto eos; goto eos;
if (adder->srcresult != GST_FLOW_OK)
goto flushing;
g_cond_wait (adder->not_empty_cond, GST_OBJECT_GET_LOCK(adder)); g_cond_wait (adder->not_empty_cond, GST_OBJECT_GET_LOCK(adder));
} }