gstreamer_core/tsrc/check/elements/gstqueue/src/gstqueue.c
changeset 27 d43ce56a1534
parent 9 2a0f36a70380
--- 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");