diff options
| -rw-r--r-- | tests/check/elements/queue2.c | 64 |
1 files changed, 64 insertions, 0 deletions
diff --git a/tests/check/elements/queue2.c b/tests/check/elements/queue2.c index 4970f0349..f5839f20e 100644 --- a/tests/check/elements/queue2.c +++ b/tests/check/elements/queue2.c @@ -341,6 +341,69 @@ GST_START_TEST (test_overrun) GST_END_TEST; +static GstPadProbeReturn +block_callback (GstPad * pad, GstPadProbeInfo * info, gpointer user_data) +{ + return GST_PAD_PROBE_OK; +} + +GST_START_TEST (test_percent_overflow) +{ + GstElement *queue2; + GstBuffer *buffer; + GstPad *sinkpad, *srcpad; + gulong block_probe; + guint64 i; + guint64 current_level_time; + GstSegment segment; + + queue2 = gst_element_factory_make ("queue2", NULL); + sinkpad = gst_element_get_static_pad (queue2, "sink"); + srcpad = gst_element_get_static_pad (queue2, "src"); + + block_probe = gst_pad_add_probe (srcpad, + GST_PAD_PROBE_TYPE_BLOCK | GST_PAD_PROBE_TYPE_BUFFER, + block_callback, NULL, NULL); + + g_object_set (queue2, "use-buffering", TRUE, + "use-rate-estimate", FALSE, + "max-size-buffers", 0, + "max-size-time", 2 * GST_SECOND, "max-size-bytes", 0, NULL); + + gst_pad_activate_mode (srcpad, GST_PAD_MODE_PUSH, TRUE); + gst_element_set_state (queue2, GST_STATE_PAUSED); + + gst_segment_init (&segment, GST_FORMAT_TIME); + segment.start = 0; + segment.time = 0; + segment.position = 0; + gst_pad_send_event (sinkpad, gst_event_new_stream_start ("test")); + gst_pad_send_event (sinkpad, gst_event_new_segment (&segment)); + + /* push 2 seconds of data with valid but excessively high timestamps */ + for (i = 0; i < 20; i++) { + buffer = gst_buffer_new_and_alloc (1024); + GST_BUFFER_PTS (buffer) = + G_GUINT64_CONSTANT (18446744071709551616) + i * (GST_SECOND / 10); + GST_BUFFER_DTS (buffer) = + G_GUINT64_CONSTANT (18446744071709551616) + i * (GST_SECOND / 10); + GST_BUFFER_DURATION (buffer) = (GST_SECOND / 10); + fail_unless (gst_pad_chain (sinkpad, buffer) == GST_FLOW_OK); + } + + g_object_get (queue2, "current-level-time", ¤t_level_time, NULL); + + gst_pad_remove_probe (srcpad, block_probe); + + gst_element_set_state (queue2, GST_STATE_NULL); + + gst_object_unref (sinkpad); + gst_object_unref (srcpad); + gst_object_unref (queue2); +} + +GST_END_TEST; + static Suite * queue2_suite (void) { @@ -354,6 +417,7 @@ queue2_suite (void) tcase_add_test (tc_chain, test_simple_shutdown_while_running); tcase_add_test (tc_chain, test_simple_shutdown_while_running_ringbuffer); tcase_add_test (tc_chain, test_filled_read); + tcase_add_test (tc_chain, test_percent_overflow); tcase_add_test (tc_chain, test_overrun); return s; } |