mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2024-11-26 03:31:05 +00:00
5905655ead
Original commit message from CVS: * gst/gstthread.c: (gst_thread_dispose), (gst_thread_sync), (gst_thread_change_state), (gst_thread_child_state_change), (gst_thread_main_loop): * gst/gstthread.h: * testsuite/threads/Makefile.am: * testsuite/threads/queue.c: * testsuite/threads/thread.c: (construct_pipeline), (change_state), (main): * testsuite/threads/threadc.c: (construct_pipeline): * testsuite/threads/threadd.c: (main): * testsuite/threads/threade.c: (main): * testsuite/threads/threadf.c: Reworked the GstThread implementation, make more operations threadsafe and more reliable. Moved testcases from the failing to the working list.
127 lines
3.7 KiB
C
127 lines
3.7 KiB
C
#include <gst/gst.h>
|
|
|
|
/*
|
|
* FIXME:
|
|
* these tests should have a maximum run length, so that they get killed
|
|
* if they lock up, which they're bound to do.
|
|
*/
|
|
|
|
void
|
|
usage (void)
|
|
{
|
|
g_print ("compile this test with TESTNUM defined.\n"
|
|
" available TESTNUMs: \n"
|
|
" 1: stress test state change \n"
|
|
" 2: iterate once \n"
|
|
" 3: iterate twice \n"
|
|
" 4: state change while running \n"
|
|
" 5: state change in thread context\n");
|
|
}
|
|
|
|
static void
|
|
construct_pipeline (GstElement * pipeline)
|
|
{
|
|
GstElement *src, *sink, *queue, *identity, *thread;
|
|
|
|
src = gst_element_factory_make ("fakesrc", NULL);
|
|
sink = gst_element_factory_make ("fakesink", "sink");
|
|
identity = gst_element_factory_make ("identity", NULL);
|
|
queue = gst_element_factory_make ("queue", NULL);
|
|
thread = gst_element_factory_make ("thread", NULL);
|
|
|
|
gst_element_link_many (src, queue, identity, sink, NULL);
|
|
|
|
gst_bin_add_many (GST_BIN (pipeline), src, queue, thread, NULL);
|
|
gst_bin_add_many (GST_BIN (thread), identity, sink, NULL);
|
|
|
|
g_object_set (G_OBJECT (src), "num_buffers", 5, NULL);
|
|
//g_object_set (sink, "signal-handoffs", TRUE, NULL);
|
|
}
|
|
|
|
void
|
|
change_state (GstElement * element, GstBuffer * buf, GstPad * pad,
|
|
GstElement * pipeline)
|
|
{
|
|
gst_element_set_state (pipeline, GST_STATE_NULL);
|
|
}
|
|
|
|
int
|
|
main (gint argc, gchar * argv[])
|
|
{
|
|
GstElement *pipeline;
|
|
|
|
gst_init (&argc, &argv);
|
|
|
|
#ifndef TESTNUM
|
|
usage ();
|
|
return -1;
|
|
#endif
|
|
|
|
pipeline = gst_pipeline_new ("main_pipeline");
|
|
construct_pipeline (pipeline);
|
|
|
|
if (TESTNUM == 1) {
|
|
g_print ("thread test 1: stress test state changes...\n");
|
|
|
|
g_print ("NULL\n");
|
|
gst_element_set_state (pipeline, GST_STATE_NULL);
|
|
g_print ("READY\n");
|
|
gst_element_set_state (pipeline, GST_STATE_READY);
|
|
g_print ("NULL\n");
|
|
gst_element_set_state (pipeline, GST_STATE_NULL);
|
|
g_print ("PAUSED\n");
|
|
gst_element_set_state (pipeline, GST_STATE_PAUSED);
|
|
g_print ("READY\n");
|
|
gst_element_set_state (pipeline, GST_STATE_READY);
|
|
g_print ("PAUSED\n");
|
|
gst_element_set_state (pipeline, GST_STATE_PAUSED);
|
|
g_print ("PLAYING\n");
|
|
gst_element_set_state (pipeline, GST_STATE_PLAYING);
|
|
/* element likely hits EOS and does a state transition to PAUSED */
|
|
g_print ("READY\n");
|
|
gst_element_set_state (pipeline, GST_STATE_READY);
|
|
g_print ("NULL\n");
|
|
gst_element_set_state (pipeline, GST_STATE_NULL);
|
|
}
|
|
|
|
if (TESTNUM == 2 || TESTNUM == 3) {
|
|
gst_element_set_state (pipeline, GST_STATE_PLAYING);
|
|
g_print ("running ...\n");
|
|
while (gst_bin_iterate (GST_BIN (pipeline)));
|
|
g_print ("done ...\n");
|
|
gst_element_set_state (pipeline, GST_STATE_NULL);
|
|
}
|
|
if (TESTNUM == 3) {
|
|
gst_element_set_state (pipeline, GST_STATE_PLAYING);
|
|
g_print ("running ...\n");
|
|
while (gst_bin_iterate (GST_BIN (pipeline)));
|
|
gst_element_set_state (pipeline, GST_STATE_NULL);
|
|
}
|
|
if (TESTNUM == 4) {
|
|
gint run;
|
|
|
|
gst_element_set_state (pipeline, GST_STATE_PLAYING);
|
|
g_print ("running ...\n");
|
|
for (run = 0; run < 3; run++) {
|
|
gst_bin_iterate (GST_BIN (pipeline));
|
|
}
|
|
gst_element_set_state (pipeline, GST_STATE_NULL);
|
|
}
|
|
if (TESTNUM == 5) {
|
|
/* I don't think this test is supposed to work */
|
|
GstElement *sink;
|
|
|
|
sink = gst_bin_get_by_name (GST_BIN (pipeline), "sink");
|
|
g_assert (sink);
|
|
|
|
g_signal_connect (G_OBJECT (sink), "handoff",
|
|
G_CALLBACK (change_state), pipeline);
|
|
gst_element_set_state (pipeline, GST_STATE_PLAYING);
|
|
g_print ("running ...\n");
|
|
while (gst_bin_iterate (GST_BIN (pipeline)));
|
|
g_print ("stopping ...\n");
|
|
gst_element_set_state (pipeline, GST_STATE_NULL);
|
|
}
|
|
|
|
return 0;
|
|
}
|