gstreamer_core/tsrc/check/elements/gstqueue/src/gstqueue.c
changeset 16 8e837d1bf446
parent 0 0e761a78d257
child 9 2a0f36a70380
--- a/gstreamer_core/tsrc/check/elements/gstqueue/src/gstqueue.c	Wed Mar 24 17:58:42 2010 -0500
+++ b/gstreamer_core/tsrc/check/elements/gstqueue/src/gstqueue.c	Wed Mar 24 18:04:17 2010 -0500
@@ -33,11 +33,20 @@
 
 void create_xml(int result)
 {
+
     if(result)
+    {
         assert_failed = 1;
-    
+    } 
+
     testResultXml(xmlfile);
     close_log_file();
+
+    if(result)
+    {
+        exit (-1);
+    }    
+
 }
 
 #include "libgstreamer_wsd_solution.h" 
@@ -315,12 +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);
   gst_pad_set_active (mysinkpad, FALSE);
 
   GST_DEBUG ("stopping");
@@ -406,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);
-
+  //g_cond_wait (check_cond, check_mutex);
+  //g_mutex_unlock (check_mutex);
+  sleep(2);
   gst_pad_set_active (mysinkpad, FALSE);
 
   GST_DEBUG ("stopping");