mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-02-23 14:36:24 +00:00
Code Issues 1 Projects Releases Wiki Activity

level: add a test for continous timestamps

Browse source 
A test that checks that msg[n].ts + msg[n].dur == msg[n+1].ts.
This commit is contained in:
Stefan Sauer 2013-05-31 18:13:02 +02:00
parent db29522a43
commit 19b23d3b90
1 changed files with 58 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

60
tests/check/elements/level.c
View file

@ -397,7 +397,7 @@ GST_START_TEST (test_message_on_eos)
GST_END_TEST; GST_END_TEST;
GST_START_TEST (test_message_interval) GST_START_TEST (test_message_count)
{ {
GstElement *level; GstElement *level;
GstBuffer *inbuffer, *outbuffer; GstBuffer *inbuffer, *outbuffer;
@ -445,6 +445,61 @@ GST_START_TEST (test_message_interval)
GST_END_TEST; GST_END_TEST;
GST_START_TEST (test_message_timestamps)
{
GstElement *level;
GstBuffer *inbuffer, *outbuffer;
GstBus *bus;
GstMessage *message;
const GstStructure *structure;
GstClockTime ts1, dur1, ts2;
level = setup_level ();
g_object_set (level, "message", TRUE, "interval", GST_SECOND / 20, NULL);
fail_unless (gst_element_set_state (level,
GST_STATE_PLAYING) == GST_STATE_CHANGE_SUCCESS,
"could not set to playing");
/* create a fake 0.1 sec buffer with a half-amplitude block signal */
inbuffer = create_buffer (16536, 16536);
/* create a bus to get the level message on */
bus = gst_bus_new ();
gst_element_set_bus (level, bus);
/* pushing gives away my reference ... */
fail_unless (gst_pad_push (mysrcpad, inbuffer) == GST_FLOW_OK);
/* ... but it ends up being collected on the global buffer list */
fail_unless_equals_int (g_list_length (buffers), 1);
fail_if ((outbuffer = (GstBuffer *) buffers->data) == NULL);
fail_unless (inbuffer == outbuffer);
/* check that timestamp + duration is contigous to the next timestamp */
message = gst_bus_poll (bus, GST_MESSAGE_ELEMENT, -1);
structure = gst_message_get_structure (message);
gst_structure_get_clock_time (structure, "timestamp", &ts1);
gst_structure_get_clock_time (structure, "duration", &dur1);
gst_message_unref (message);
message = gst_bus_poll (bus, GST_MESSAGE_ELEMENT, -1);
structure = gst_message_get_structure (message);
gst_structure_get_clock_time (structure, "timestamp", &ts2);
gst_message_unref (message);
fail_unless_equals_int64 (ts1 + dur1, ts2);
gst_element_set_bus (level, NULL);
ASSERT_OBJECT_REFCOUNT (bus, "bus", 1);
gst_object_unref (bus);
gst_buffer_unref (outbuffer);
fail_unless (gst_element_set_state (level,
GST_STATE_NULL) == GST_STATE_CHANGE_SUCCESS, "could not set to null");
ASSERT_OBJECT_REFCOUNT (level, "level", 1);
cleanup_level (level);
}
GST_END_TEST;
static Suite * static Suite *
level_suite (void) level_suite (void)
@ -456,7 +511,8 @@ level_suite (void)
tcase_add_test (tc_chain, test_int16); tcase_add_test (tc_chain, test_int16);
tcase_add_test (tc_chain, test_int16_panned); tcase_add_test (tc_chain, test_int16_panned);
tcase_add_test (tc_chain, test_message_on_eos); tcase_add_test (tc_chain, test_message_on_eos);
tcase_add_test (tc_chain, test_message_interval); tcase_add_test (tc_chain, test_message_count);
tcase_add_test (tc_chain, test_message_timestamps);
return s; return s;
} }