mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-01-04 06:29:31 +00:00
Code Issues 1 Projects Releases Wiki Activity

tests: add test that triggers deadlock in state change of queue

Browse source 
When receiving FLASH_STOP in a state transition to READY, a queue
element can end up with an active task that will never end.

https://bugzilla.gnome.org/show_bug.cgi?id=734688
This commit is contained in:
Linus Svensson 2014-08-20 12:55:51 +02:00 committed by Tim-Philipp Müller
parent 93d8679b00
commit ae74a1a83a
1 changed files with 44 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

44
tests/check/elements/queue.c
View file

@ -894,6 +894,49 @@ GST_START_TEST (test_queries_while_flushing)
GST_END_TEST; GST_END_TEST;
static gpointer
push_event_thread_func (gpointer data)
{
GstEvent *event;
event = GST_EVENT (data);
GST_DEBUG ("pushing event %p on pad %p", event, mysrcpad);
gst_pad_push_event (mysrcpad, event);
return NULL;
}
GST_START_TEST (test_state_change_when_flushing)
{
GstEvent *event;
GThread *thread;
mysinkpad = gst_check_setup_sink_pad (queue, &sinktemplate);
gst_pad_set_active (mysinkpad, TRUE);
fail_unless (gst_element_set_state (queue, GST_STATE_PAUSED) ==
GST_STATE_CHANGE_SUCCESS);
event = gst_event_new_flush_start ();
gst_pad_push_event (mysrcpad, event);
event = gst_event_new_flush_stop (TRUE);
thread = g_thread_new ("send event", push_event_thread_func, event);
GST_DEBUG ("changing state to READY");
fail_unless (gst_element_set_state (queue, GST_STATE_READY) ==
GST_STATE_CHANGE_SUCCESS);
GST_DEBUG ("state changed");
g_thread_join (thread);
fail_unless (gst_element_set_state (queue, GST_STATE_NULL) ==
GST_STATE_CHANGE_SUCCESS);
}
GST_END_TEST;
static Suite * static Suite *
queue_suite (void) queue_suite (void)
{ {
@ -909,6 +952,7 @@ queue_suite (void)
tcase_add_test (tc_chain, test_time_level); tcase_add_test (tc_chain, test_time_level);
tcase_add_test (tc_chain, test_time_level_task_not_started); tcase_add_test (tc_chain, test_time_level_task_not_started);
tcase_add_test (tc_chain, test_queries_while_flushing); tcase_add_test (tc_chain, test_queries_while_flushing);
tcase_add_test (tc_chain, test_state_change_when_flushing);
#if 0 #if 0
tcase_add_test (tc_chain, test_newsegment); tcase_add_test (tc_chain, test_newsegment);
#endif #endif