mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-12-22 16:26:39 +00:00
Code Issues 1 Projects Releases Wiki Activity

tests: multiqueue: Check we get CREATE+ENTER stream-statuses when adding pads

Browse source 
https://bugzilla.gnome.org/show_bug.cgi?id=756867
This commit is contained in:
Jan Alexander Steffens (heftig) 2017-12-15 09:43:40 +01:00 committed by Tim-Philipp Müller
parent b17d03cb0a
commit 67a9ec6878
1 changed files with 64 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

64
tests/check/elements/multiqueue.c
View file

@ -1595,6 +1595,68 @@ GST_START_TEST (test_initial_events_nodelay)
GST_END_TEST;
static void
check_for_stream_status_msg (GstElement * pipeline, GstElement * multiqueue,
GstStreamStatusType expected_type)
{
GEnumClass *klass;
const gchar *expected_nick, *nick;
GstMessage *msg;
GstStreamStatusType type;
GstElement *owner;
klass = g_type_class_ref (GST_TYPE_STREAM_STATUS_TYPE);
expected_nick = g_enum_get_value (klass, expected_type)->value_nick;
GST_LOG ("waiting for stream-status %s message", expected_nick);
msg = gst_bus_poll (GST_ELEMENT_BUS (pipeline),
GST_MESSAGE_STREAM_STATUS | GST_MESSAGE_ERROR, -1);
fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_ERROR,
"Expected stream-status message, got error message");
gst_message_parse_stream_status (msg, &type, &owner);
nick = g_enum_get_value (klass, type)->value_nick;
fail_unless (owner == multiqueue,
"Got incorrect owner: %" GST_PTR_FORMAT " expected: %" GST_PTR_FORMAT,
owner, multiqueue);
fail_unless (type == expected_type,
"Got incorrect type: %s expected: %s", nick, expected_nick);
gst_message_unref (msg);
g_type_class_unref (klass);
}
GST_START_TEST (test_stream_status_messages)
{
GstElement *pipe, *mq;
GstPad *pad;
pipe = gst_pipeline_new ("pipeline");
mq = gst_element_factory_make ("multiqueue", NULL);
gst_bin_add (GST_BIN (pipe), mq);
pad = gst_element_get_request_pad (mq, "sink_%u");
gst_object_unref (pad);
gst_element_set_state (pipe, GST_STATE_PAUSED);
check_for_stream_status_msg (pipe, mq, GST_STREAM_STATUS_TYPE_CREATE);
check_for_stream_status_msg (pipe, mq, GST_STREAM_STATUS_TYPE_ENTER);
pad = gst_element_get_request_pad (mq, "sink_%u");
gst_object_unref (pad);
check_for_stream_status_msg (pipe, mq, GST_STREAM_STATUS_TYPE_CREATE);
check_for_stream_status_msg (pipe, mq, GST_STREAM_STATUS_TYPE_ENTER);
gst_element_set_state (pipe, GST_STATE_NULL);
gst_object_unref (pipe);
}
GST_END_TEST;
static Suite *
multiqueue_suite (void)
{
@ -1625,6 +1687,8 @@ multiqueue_suite (void)
tcase_add_test (tc_chain, test_buffering_with_none_pts);
tcase_add_test (tc_chain, test_initial_events_nodelay);
tcase_add_test (tc_chain, test_stream_status_messages);
return s;
}