gstreamer/testsuite/schedulers/143777-2.c
Wim Taymans 77d9b2648d testsuite/schedulers/: Added cleanup code to testcase 143777-2.
Original commit message from CVS:
* testsuite/schedulers/143777-2.c: (main):
* testsuite/schedulers/147713.c: (handoff_src), (handoff_sink),
(main):
* testsuite/schedulers/Makefile.am:
Added cleanup code to testcase 143777-2.
Added testcase to show bug 147713, does not really show the
deadlock as I can't figure out how to trigger it, but it does
demonstrate bad ordering in the scheduler.
2004-07-16 15:45:29 +00:00

61 lines
1.7 KiB
C

#include <gst/gst.h>
int
main (int argc, char **argv)
{
GstElement *src, *sink, *enc, *tee;
GstElement *pipeline;
int i;
gst_init (&argc, &argv);
pipeline = gst_element_factory_make ("pipeline", "pipeline");
src = gst_element_factory_make ("fakesrc", "src");
g_assert (src);
tee = gst_element_factory_make ("tee", "tee1");
g_assert (tee);
enc = gst_element_factory_make ("identity", "enc");
g_assert (enc);
sink = gst_element_factory_make ("fakesink", "sink");
g_assert (sink);
gst_bin_add_many (GST_BIN (pipeline), src, tee, enc, sink, NULL);
if (!gst_element_link_many (src, tee, enc, sink, NULL))
g_assert_not_reached ();
if (gst_element_set_state (pipeline, GST_STATE_PLAYING) != GST_STATE_SUCCESS)
g_assert_not_reached ();
for (i = 0; i < 5; i++) {
if (!gst_bin_iterate (GST_BIN (pipeline)))
g_assert_not_reached ();
g_print ("%d\n", i);
}
if (gst_element_set_state (pipeline, GST_STATE_PAUSED) != GST_STATE_SUCCESS)
g_assert_not_reached ();
gst_element_unlink_many (tee, enc, sink, NULL);
gst_bin_remove_many (GST_BIN (pipeline), enc, sink, NULL);
enc = gst_element_factory_make ("identity", "enc");
g_assert (enc);
sink = gst_element_factory_make ("fakesink", "sink");
g_assert (sink);
gst_bin_add_many (GST_BIN (pipeline), enc, sink, NULL);
if (!gst_element_link_many (tee, enc, sink, NULL))
g_assert_not_reached ();
if (gst_element_set_state (pipeline, GST_STATE_PLAYING) != GST_STATE_SUCCESS)
g_assert_not_reached ();
for (i = 5; i < 10; i++) {
if (!gst_bin_iterate (GST_BIN (pipeline)))
g_assert_not_reached ();
g_print ("%d\n", i);
}
g_print ("cleaning up...\n");
gst_object_unref (GST_OBJECT (pipeline));
g_print ("done.\n");
return 0;
}