mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-12-18 14:26:43 +00:00
Code Issues 1 Projects Releases Wiki Activity

tests: Fix multiqueue test for latest commits.

Browse source 
The problem lies in the fact that multiqueue will now operate somewhat
similarly to the flow aggregation logic of demuxers and therefore
will stopp whenever all downstream pads return NOT_LINKED and/or
UNEXPECTED and there's no more buffers to push.

The latest commits should not affect any regular use-case, but the bug
report will be kept open so the previous behaviour can be re-established
if needed.

Fixes #609486
This commit is contained in:
Edward Hervey 2010-02-10 14:40:17 +01:00
parent 4e0b2dc832
commit 5a0cdc7001
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
tests/check/elements/multiqueue.c
View file

@ -479,13 +479,14 @@ run_output_order_test (gint n_linked)
/* Wait while the buffers are processed */ /* Wait while the buffers are processed */
g_mutex_lock (mutex); g_mutex_lock (mutex);
while (eos_seen < 5) { /* We wait until EOS has been pushed on all linked pads */
while (eos_seen < n_linked) {
g_cond_wait (cond, mutex); g_cond_wait (cond, mutex);
} }
g_mutex_unlock (mutex); g_mutex_unlock (mutex);
/* Clean up */ /* Clean up */
for (i = 0; i < 5; i++) { for (i = 0; i < NPADS; i++) {
GstPad *mq_input = gst_pad_get_peer (inputpads[i]); GstPad *mq_input = gst_pad_get_peer (inputpads[i]);
gst_pad_unlink (inputpads[i], mq_input); gst_pad_unlink (inputpads[i], mq_input);