tests: port to the new GLib thread API

This commit is contained in:
Mark Nauwelaerts 2012-09-12 12:54:07 +02:00
parent 35441abcde
commit 536276eee1
3 changed files with 15 additions and 12 deletions

View file

@ -93,10 +93,10 @@ GST_START_TEST (test_all_waves)
GST_STATE_PLAYING) == GST_STATE_CHANGE_SUCCESS, GST_STATE_PLAYING) == GST_STATE_CHANGE_SUCCESS,
"could not set to playing"); "could not set to playing");
g_mutex_lock (check_mutex); g_mutex_lock (&check_mutex);
while (g_list_length (buffers) < 10) while (g_list_length (buffers) < 10)
g_cond_wait (check_cond, check_mutex); g_cond_wait (&check_cond, &check_mutex);
g_mutex_unlock (check_mutex); g_mutex_unlock (&check_mutex);
gst_element_set_state (audiotestsrc, GST_STATE_READY); gst_element_set_state (audiotestsrc, GST_STATE_READY);

View file

@ -585,9 +585,10 @@ GST_START_TEST (test_video_waits_for_text)
* newsegment event to arrive); we spawn a background thread to send such * newsegment event to arrive); we spawn a background thread to send such
* a newsegment event after a second or so so we get back control */ * a newsegment event after a second or so so we get back control */
thread = thread =
g_thread_create (test_video_waits_for_text_send_text_newsegment_thread, g_thread_try_new ("gst-check",
NULL, FALSE, NULL); test_video_waits_for_text_send_text_newsegment_thread, NULL, NULL);
fail_unless (thread != NULL); fail_unless (thread != NULL);
g_thread_unref (thread);
GST_LOG ("pushing video buffer 3"); GST_LOG ("pushing video buffer 3");
fail_unless (gst_pad_push (myvideosrcpad, inbuffer) == GST_FLOW_OK); fail_unless (gst_pad_push (myvideosrcpad, inbuffer) == GST_FLOW_OK);
@ -614,9 +615,10 @@ GST_START_TEST (test_video_waits_for_text)
* text buffer (or a newsegment event) to arrive; we spawn a background * text buffer (or a newsegment event) to arrive; we spawn a background
* thread to shut down the element while it's waiting to make sure that * thread to shut down the element while it's waiting to make sure that
* works ok */ * works ok */
thread = g_thread_create (test_video_waits_for_text_shutdown_element, thread = g_thread_try_new ("gst-check",
textoverlay, FALSE, NULL); test_video_waits_for_text_shutdown_element, textoverlay, NULL);
fail_unless (thread != NULL); fail_unless (thread != NULL);
g_thread_unref (thread);
GST_LOG ("pushing video buffer 4"); GST_LOG ("pushing video buffer 4");
fail_unless (gst_pad_push (myvideosrcpad, inbuffer) == GST_FLOW_FLUSHING); fail_unless (gst_pad_push (myvideosrcpad, inbuffer) == GST_FLOW_FLUSHING);
@ -681,9 +683,10 @@ GST_START_TEST (test_render_continuity)
GST_STATE_PLAYING) == GST_STATE_CHANGE_SUCCESS, GST_STATE_PLAYING) == GST_STATE_CHANGE_SUCCESS,
"could not set to playing"); "could not set to playing");
thread = g_thread_create (test_render_continuity_push_video_buffers_thread, thread = g_thread_try_new ("gst-check",
NULL, FALSE, NULL); test_render_continuity_push_video_buffers_thread, NULL, NULL);
fail_unless (thread != NULL); fail_unless (thread != NULL);
g_thread_unref (thread);
caps = gst_caps_new_simple ("text/x-raw", "format", G_TYPE_STRING, "utf8", caps = gst_caps_new_simple ("text/x-raw", "format", G_TYPE_STRING, "utf8",
NULL); NULL);

View file

@ -100,12 +100,12 @@ GST_START_TEST (test_all_patterns)
GST_STATE_PLAYING) == GST_STATE_CHANGE_SUCCESS, GST_STATE_PLAYING) == GST_STATE_CHANGE_SUCCESS,
"could not set to playing"); "could not set to playing");
g_mutex_lock (check_mutex); g_mutex_lock (&check_mutex);
while (g_list_length (buffers) < 10) { while (g_list_length (buffers) < 10) {
GST_DEBUG_OBJECT (videotestsrc, "Waiting for more buffers"); GST_DEBUG_OBJECT (videotestsrc, "Waiting for more buffers");
g_cond_wait (check_cond, check_mutex); g_cond_wait (&check_cond, &check_mutex);
} }
g_mutex_unlock (check_mutex); g_mutex_unlock (&check_mutex);
gst_element_set_state (videotestsrc, GST_STATE_READY); gst_element_set_state (videotestsrc, GST_STATE_READY);