diff -r 29ecd5cb86b3 -r d43ce56a1534 gstreamer_core/tsrc/check/elements/gstqueue/src/gstqueue.c --- a/gstreamer_core/tsrc/check/elements/gstqueue/src/gstqueue.c Tue Jul 06 14:35:10 2010 +0300 +++ b/gstreamer_core/tsrc/check/elements/gstqueue/src/gstqueue.c Wed Aug 18 10:04:13 2010 +0300 @@ -324,13 +324,13 @@ /* pushing gives away my reference ... */ gst_pad_push (mysrcpad, gst_buffer_ref (buffer3)); - //g_mutex_lock (check_mutex); + g_mutex_lock (check_mutex); /* start the src-task briefly leak buffer3 */ gst_pad_set_active (mysinkpad, TRUE); - //g_cond_wait (check_cond, check_mutex); - //g_mutex_unlock (check_mutex); + g_cond_wait (check_cond, check_mutex); + g_mutex_unlock (check_mutex); /// wait for second thread to read buffer. - sleep(2); + //sleep(2); gst_pad_set_active (mysinkpad, FALSE); GST_DEBUG ("stopping"); @@ -416,12 +416,12 @@ /* pushing gives away my reference ... */ gst_pad_push (mysrcpad, buffer3); - //g_mutex_lock (check_mutex); + g_mutex_lock (check_mutex); /* start the src-task briefly and leak buffer1 */ gst_pad_set_active (mysinkpad, TRUE); - //g_cond_wait (check_cond, check_mutex); - //g_mutex_unlock (check_mutex); - sleep(2); + g_cond_wait (check_cond, check_mutex); + g_mutex_unlock (check_mutex); + //sleep(2); gst_pad_set_active (mysinkpad, FALSE); GST_DEBUG ("stopping");