diff --git a/tests/check/elements/adder.c b/tests/check/elements/adder.c index 61cfbe3f3c..b5969f47b3 100644 --- a/tests/check/elements/adder.c +++ b/tests/check/elements/adder.c @@ -31,6 +31,7 @@ #include #include +#include static GMainLoop *main_loop; @@ -100,6 +101,8 @@ GST_START_TEST (test_event) GstBus *bus; GstEvent *seek_event; gboolean res; + GstPad *srcpad; + GstStreamConsistency *consist; GST_INFO ("preparing test"); @@ -126,6 +129,10 @@ GST_START_TEST (test_event) res = gst_element_link (adder, sink); fail_unless (res == TRUE, NULL); + srcpad = gst_element_get_static_pad (adder, "src"); + consist = gst_consistency_checker_new (srcpad); + gst_object_unref (srcpad); + seek_event = gst_event_new_seek (1.0, GST_FORMAT_TIME, GST_SEEK_FLAG_SEGMENT | GST_SEEK_FLAG_FLUSH, GST_SEEK_TYPE_SET, (GstClockTime) 0, @@ -167,6 +174,7 @@ GST_START_TEST (test_event) /* cleanup */ g_main_loop_unref (main_loop); + gst_consistency_checker_free (consist); gst_object_unref (G_OBJECT (bus)); gst_object_unref (G_OBJECT (bin)); } @@ -224,6 +232,8 @@ GST_START_TEST (test_play_twice) GstElement *bin, *src1, *src2, *adder, *sink; GstBus *bus; gboolean res; + GstPad *srcpad; + GstStreamConsistency *consist; GST_INFO ("preparing test"); @@ -247,6 +257,10 @@ GST_START_TEST (test_play_twice) res = gst_element_link (adder, sink); fail_unless (res == TRUE, NULL); + srcpad = gst_element_get_static_pad (adder, "src"); + consist = gst_consistency_checker_new (srcpad); + gst_object_unref (srcpad); + play_seek_event = gst_event_new_seek (1.0, GST_FORMAT_TIME, GST_SEEK_FLAG_SEGMENT | GST_SEEK_FLAG_FLUSH, GST_SEEK_TYPE_SET, (GstClockTime) 0, @@ -291,6 +305,7 @@ GST_START_TEST (test_play_twice) /* cleanup */ g_main_loop_unref (main_loop); + gst_consistency_checker_free (consist); gst_event_ref (play_seek_event); gst_object_unref (G_OBJECT (bus)); gst_object_unref (G_OBJECT (bin)); @@ -304,6 +319,8 @@ GST_START_TEST (test_play_twice_then_add_and_play_again) GstBus *bus; gboolean res; gint i; + GstPad *srcpad; + GstStreamConsistency *consist; GST_INFO ("preparing test"); @@ -320,6 +337,10 @@ GST_START_TEST (test_play_twice_then_add_and_play_again) sink = gst_element_factory_make ("fakesink", "sink"); gst_bin_add_many (GST_BIN (bin), src1, src2, adder, sink, NULL); + srcpad = gst_element_get_static_pad (adder, "src"); + consist = gst_consistency_checker_new (srcpad); + gst_object_unref (srcpad); + res = gst_element_link (src1, adder); fail_unless (res == TRUE, NULL); res = gst_element_link (src2, adder); @@ -380,6 +401,8 @@ GST_START_TEST (test_play_twice_then_add_and_play_again) res = gst_element_link (src3, adder); fail_unless (res == TRUE, NULL); } + + gst_consistency_checker_reset (consist); } res = gst_element_set_state (bin, GST_STATE_NULL); @@ -388,6 +411,7 @@ GST_START_TEST (test_play_twice_then_add_and_play_again) /* cleanup */ g_main_loop_unref (main_loop); gst_event_ref (play_seek_event); + gst_consistency_checker_free (consist); gst_object_unref (G_OBJECT (bus)); gst_object_unref (G_OBJECT (bin)); } @@ -419,7 +443,9 @@ GST_START_TEST (test_live_seeking) GstElement *bin, *src1, *src2, *ac1, *ac2, *adder, *sink; GstBus *bus; gboolean res; + GstPad *srcpad; gint i; + GstStreamConsistency *consist; GST_INFO ("preparing test"); main_loop = NULL; @@ -483,6 +509,12 @@ GST_START_TEST (test_live_seeking) g_signal_connect (bus, "message::eos", (GCallback) test_live_seeking_eos_message_received, bin); + srcpad = gst_element_get_static_pad (adder, "src"); + consist = gst_consistency_checker_new (srcpad); + gst_object_unref (srcpad); + + GST_INFO ("starting test"); + /* run it twice */ for (i = 0; i < 2; i++) { @@ -518,6 +550,8 @@ GST_START_TEST (test_live_seeking) res = gst_element_set_state (bin, GST_STATE_NULL); fail_unless (res != GST_STATE_CHANGE_FAILURE, NULL); + + gst_consistency_checker_reset (consist); } /* cleanup */ @@ -538,6 +572,8 @@ GST_START_TEST (test_add_pad) { GstElement *bin, *src1, *src2, *adder, *sink; GstBus *bus; + GstPad *srcpad; + GstStreamConsistency *consist; gboolean res; GST_INFO ("preparing test"); @@ -563,6 +599,10 @@ GST_START_TEST (test_add_pad) res = gst_element_link (adder, sink); fail_unless (res == TRUE, NULL); + srcpad = gst_element_get_static_pad (adder, "src"); + consist = gst_consistency_checker_new (srcpad); + gst_object_unref (srcpad); + main_loop = g_main_loop_new (NULL, FALSE); g_signal_connect (bus, "message::segment-done", (GCallback) message_received, bin); @@ -614,8 +654,9 @@ GST_START_TEST (test_remove_pad) { GstElement *bin, *src, *adder, *sink; GstBus *bus; - GstPad *pad; + GstPad *pad, *srcpad; gboolean res; + GstStreamConsistency *consist; GST_INFO ("preparing test"); @@ -640,6 +681,10 @@ GST_START_TEST (test_remove_pad) pad = gst_element_get_request_pad (adder, "sink%d"); fail_if (pad == NULL, NULL); + srcpad = gst_element_get_static_pad (adder, "src"); + consist = gst_consistency_checker_new (srcpad); + gst_object_unref (srcpad); + main_loop = g_main_loop_new (NULL, FALSE); g_signal_connect (bus, "message::segment-done", (GCallback) message_received, bin);