--- 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");