summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorLinus Svensson <linussn@axis.com>2014-08-20 12:55:51 +0200
committerTim-Philipp Müller <tim@centricular.com>2014-08-23 12:03:38 +0100
commitae74a1a83a8a5034c37da283d6176c3abab4b3cc (patch)
treecf3811dde51d76fb5ffa6f06880ce3fda4050f8c
parent93d8679b00c1402aaf44f37bb67487d1a3d0ffc4 (diff)
tests: add test that triggers deadlock in state change of queue
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
-rw-r--r--tests/check/elements/queue.c44
1 files changed, 44 insertions, 0 deletions
diff --git a/tests/check/elements/queue.c b/tests/check/elements/queue.c
index 9a2ebcf8b2..9556cdaf8b 100644
--- a/tests/check/elements/queue.c
+++ b/tests/check/elements/queue.c
@@ -894,6 +894,49 @@ GST_START_TEST (test_queries_while_flushing)
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 *
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_task_not_started);
tcase_add_test (tc_chain, test_queries_while_flushing);
+ tcase_add_test (tc_chain, test_state_change_when_flushing);
#if 0
tcase_add_test (tc_chain, test_newsegment);
#endif