mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-07-10 16:45:55 +00:00
Code Issues 1 Projects Releases Wiki Activity

tests: Add tests for dtmfsrc

Browse source
This commit is contained in:
Olivier Crête 2013-02-27 18:56:50 -05:00
parent 0233eb9f79
commit ab2a342f42
1 changed files with 130 additions and 20 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

150
tests/check/elements/dtmf.c
View file

@ -239,7 +239,7 @@ GST_STATIC_PAD_TEMPLATE ("sink",
"maxptime = (uint) 20, encoding-name = (string) \"TELEPHONE-EVENT\"")
);
GstElement *rtpdtmfsrc;
GstElement *dtmfsrc;
GstPad *sink;
GstClock *testclock;
GstBus *bus;
@ -302,61 +302,64 @@ check_rtp_buffer (GstClockTime ts, GstClockTime duration, gboolean start,
gst_buffer_unref (buffer);
}
gint method;
static void
setup_rtpdtmfsrc (void)
{
testclock = gst_test_clock_new ();
bus = gst_bus_new ();
rtpdtmfsrc = gst_check_setup_element ("rtpdtmfsrc");
sink = gst_check_setup_sink_pad (rtpdtmfsrc, &rtp_dtmf_sink_template);
gst_element_set_bus (rtpdtmfsrc, bus);
fail_unless (gst_element_set_clock (rtpdtmfsrc, testclock));
method = 1;
dtmfsrc = gst_check_setup_element ("rtpdtmfsrc");
sink = gst_check_setup_sink_pad (dtmfsrc, &rtp_dtmf_sink_template);
gst_element_set_bus (dtmfsrc, bus);
fail_unless (gst_element_set_clock (dtmfsrc, testclock));
gst_pad_set_active (sink, TRUE);
fail_unless (gst_element_set_state (rtpdtmfsrc, GST_STATE_PLAYING) ==
fail_unless (gst_element_set_state (dtmfsrc, GST_STATE_PLAYING) ==
GST_STATE_CHANGE_SUCCESS);
}
static void
teardown_rtpdtmfsrc (void)
teardown_dtmfsrc (void)
{
gst_object_unref (testclock);
gst_pad_set_active (sink, FALSE);
gst_element_set_bus (rtpdtmfsrc, NULL);
gst_element_set_bus (dtmfsrc, NULL);
gst_object_unref (bus);
gst_check_teardown_sink_pad (rtpdtmfsrc);
gst_check_teardown_element (rtpdtmfsrc);
gst_check_teardown_sink_pad (dtmfsrc);
gst_check_teardown_element (dtmfsrc);
}
GST_START_TEST (test_rtpdtmfsrc_invalid_events)
GST_START_TEST (test_dtmfsrc_invalid_events)
{
GstStructure *s;
/* Missing start */
s = gst_structure_new ("dtmf-event",
"type", G_TYPE_INT, 1, "number", G_TYPE_INT, 3,
"method", G_TYPE_INT, 1, "volume", G_TYPE_INT, 8, NULL);
"method", G_TYPE_INT, method, "volume", G_TYPE_INT, 8, NULL);
fail_unless (gst_pad_push_event (sink,
gst_event_new_custom (GST_EVENT_CUSTOM_UPSTREAM, s)) == FALSE);
/* Missing volume */
s = gst_structure_new ("dtmf-event",
"type", G_TYPE_INT, 1, "number", G_TYPE_INT, 3,
"method", G_TYPE_INT, 1, "start", G_TYPE_BOOLEAN, TRUE, NULL);
"method", G_TYPE_INT, method, "start", G_TYPE_BOOLEAN, TRUE, NULL);
fail_unless (gst_pad_push_event (sink,
gst_event_new_custom (GST_EVENT_CUSTOM_UPSTREAM, s)) == FALSE);
/* Missing number */
s = gst_structure_new ("dtmf-event",
"type", G_TYPE_INT, 1, "method", G_TYPE_INT, 1,
"type", G_TYPE_INT, 1, "method", G_TYPE_INT, method,
"volume", G_TYPE_INT, 8, "start", G_TYPE_BOOLEAN, TRUE, NULL);
fail_unless (gst_pad_push_event (sink,
gst_event_new_custom (GST_EVENT_CUSTOM_UPSTREAM, s)) == FALSE);
/* Missing type */
s = gst_structure_new ("dtmf-event",
"number", G_TYPE_INT, 3, "method", G_TYPE_INT, 1,
"number", G_TYPE_INT, 3, "method", G_TYPE_INT, method,
"volume", G_TYPE_INT, 8, "start", G_TYPE_BOOLEAN, TRUE, NULL);
fail_unless (gst_pad_push_event (sink,
gst_event_new_custom (GST_EVENT_CUSTOM_UPSTREAM, s)) == FALSE);
@ -364,12 +367,12 @@ GST_START_TEST (test_rtpdtmfsrc_invalid_events)
/* Stop before start */
s = gst_structure_new ("dtmf-event",
"type", G_TYPE_INT, 1, "number", G_TYPE_INT, 3,
"method", G_TYPE_INT, 1, "volume", G_TYPE_INT, 8,
"method", G_TYPE_INT, method, "volume", G_TYPE_INT, 8,
"start", G_TYPE_BOOLEAN, FALSE, NULL);
fail_unless (gst_pad_push_event (sink,
gst_event_new_custom (GST_EVENT_CUSTOM_UPSTREAM, s)) == FALSE);
gst_element_set_state (rtpdtmfsrc, GST_STATE_NULL);
gst_element_set_state (dtmfsrc, GST_STATE_NULL);
}
GST_END_TEST;
@ -390,6 +393,7 @@ GST_START_TEST (test_rtpdtmfsrc_min_duration)
fail_unless (gst_pad_push_event (sink,
gst_event_new_custom (GST_EVENT_CUSTOM_UPSTREAM,
gst_structure_copy (s))));
check_no_dtmf_event_message (bus);
gst_test_clock_wait_for_next_pending_id (GST_TEST_CLOCK (testclock), NULL);
fail_unless (buffers == NULL);
id = gst_test_clock_process_next_clock_id (GST_TEST_CLOCK (testclock));
@ -448,7 +452,107 @@ GST_START_TEST (test_rtpdtmfsrc_min_duration)
gst_caps_unref (caps);
gst_caps_unref (expected_caps);
gst_element_set_state (rtpdtmfsrc, GST_STATE_NULL);
gst_element_set_state (dtmfsrc, GST_STATE_NULL);
check_no_dtmf_event_message (bus);
}
GST_END_TEST;
static GstStaticPadTemplate audio_dtmfsrc_sink_template =
GST_STATIC_PAD_TEMPLATE ("sink",
GST_PAD_SINK,
GST_PAD_ALWAYS,
GST_STATIC_CAPS ("audio/x-raw, "
"format = (string) \"" GST_AUDIO_NE (S16) "\", "
"rate = (int) 8003, " "channels = (int) 1")
);
static void
setup_dtmfsrc (void)
{
testclock = gst_test_clock_new ();
bus = gst_bus_new ();
method = 2;
dtmfsrc = gst_check_setup_element ("dtmfsrc");
sink = gst_check_setup_sink_pad (dtmfsrc, &audio_dtmfsrc_sink_template);
gst_element_set_bus (dtmfsrc, bus);
fail_unless (gst_element_set_clock (dtmfsrc, testclock));
gst_pad_set_active (sink, TRUE);
fail_unless (gst_element_set_state (dtmfsrc, GST_STATE_PLAYING) ==
GST_STATE_CHANGE_SUCCESS);
}
GST_START_TEST (test_dtmfsrc_min_duration)
{
GstStructure *s;
GstClockID id;
GstClockTime timestamp = 0;
GstCaps *expected_caps, *caps;
guint interval;
g_object_get (dtmfsrc, "interval", &interval, NULL);
fail_unless (interval == 50);
/* Minimum duration dtmf */
gst_test_clock_set_time (GST_TEST_CLOCK (testclock), 0);
s = gst_structure_new ("dtmf-event",
"type", G_TYPE_INT, 1, "number", G_TYPE_INT, 3,
"method", G_TYPE_INT, 2, "volume", G_TYPE_INT, 8,
"start", G_TYPE_BOOLEAN, TRUE, NULL);
fail_unless (gst_pad_push_event (sink,
gst_event_new_custom (GST_EVENT_CUSTOM_UPSTREAM,
gst_structure_copy (s))));
gst_test_clock_wait_for_next_pending_id (GST_TEST_CLOCK (testclock), NULL);
id = gst_test_clock_process_next_clock_id (GST_TEST_CLOCK (testclock));
fail_unless (gst_clock_id_get_time (id) == 0);
gst_clock_id_unref (id);
gst_structure_set_name (s, "dtmf-event-processed");
check_message_structure (s);
s = gst_structure_new ("dtmf-event",
"type", G_TYPE_INT, 1, "method", G_TYPE_INT, 2,
"start", G_TYPE_BOOLEAN, FALSE, NULL);
fail_unless (gst_pad_push_event (sink,
gst_event_new_custom (GST_EVENT_CUSTOM_UPSTREAM,
gst_structure_copy (s))));
for (timestamp = interval * GST_MSECOND;
timestamp < (MIN_PULSE_DURATION + MIN_INTER_DIGIT_INTERVAL) *
GST_MSECOND; timestamp += GST_MSECOND * interval) {
gst_test_clock_wait_for_next_pending_id (GST_TEST_CLOCK (testclock), NULL);
gst_test_clock_advance_time (GST_TEST_CLOCK (testclock),
interval * GST_MSECOND);
id = gst_test_clock_process_next_clock_id (GST_TEST_CLOCK (testclock));
fail_unless (gst_clock_id_get_time (id) == timestamp);
gst_clock_id_unref (id);
}
gst_structure_set_name (s, "dtmf-event-processed");
check_message_structure (s);
check_buffers_duration ((MIN_PULSE_DURATION + MIN_INTER_DIGIT_INTERVAL) *
GST_MSECOND);
fail_unless (gst_test_clock_peek_id_count (GST_TEST_CLOCK (testclock)) == 0);
/* caps check */
expected_caps = gst_caps_new_simple ("audio/x-raw",
"format", G_TYPE_STRING, GST_AUDIO_NE (S16),
"rate", G_TYPE_INT, 8003, "channels", G_TYPE_INT, 1, NULL);
caps = gst_pad_get_current_caps (sink);
fail_unless (gst_caps_can_intersect (caps, expected_caps));
gst_caps_unref (caps);
gst_caps_unref (expected_caps);
gst_element_set_state (dtmfsrc, GST_STATE_NULL);
check_no_dtmf_event_message (bus);
}
@ -466,11 +570,17 @@ dtmf_suite (void)
suite_add_tcase (s, tc);
tc = tcase_create ("rtpdtmfsrc");
tcase_add_checked_fixture (tc, setup_rtpdtmfsrc, teardown_rtpdtmfsrc);
tcase_add_test (tc, test_rtpdtmfsrc_invalid_events);
tcase_add_checked_fixture (tc, setup_rtpdtmfsrc, teardown_dtmfsrc);
tcase_add_test (tc, test_dtmfsrc_invalid_events);
tcase_add_test (tc, test_rtpdtmfsrc_min_duration);
suite_add_tcase (s, tc);
tc = tcase_create ("dtmfsrc");
tcase_add_checked_fixture (tc, setup_dtmfsrc, teardown_dtmfsrc);
tcase_add_test (tc, test_dtmfsrc_invalid_events);
tcase_add_test (tc, test_dtmfsrc_min_duration);
suite_add_tcase (s, tc);
return s;
}