Added a thread test case.
Original commit message from CVS:
Added a thread test case.
diff --git a/tests/old/testsuite/threads/Makefile.am b/tests/old/testsuite/threads/Makefile.am
new file mode 100644
index 0000000..276a239
--- /dev/null
+++ b/tests/old/testsuite/threads/Makefile.am
@@ -0,0 +1,9 @@
+testprogs = thread
+
+TESTS = $(testprogs)
+
+check_PROGRAMS = $(testprogs)
+
+# we have nothing but apps here, we can do this safely
+thread_LDADD = $(GST_LIBS)
+thread_CFLAGS = $(GST_CFLAGS) $(GNOME_CFLAGS) $(XML_CFLAGS)
diff --git a/tests/old/testsuite/threads/thread.c b/tests/old/testsuite/threads/thread.c
new file mode 100644
index 0000000..9ef9fc2
--- /dev/null
+++ b/tests/old/testsuite/threads/thread.c
@@ -0,0 +1,112 @@
+#include <gst/gst.h>
+
+void
+usage (void)
+{
+ g_print ("usage: thread <testnum> \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, *thread;
+
+ src = gst_elementfactory_make ("fakesrc", "src");
+ sink = gst_elementfactory_make ("fakesink", "sink");
+ queue = gst_elementfactory_make ("queue", "queue");
+ thread = gst_elementfactory_make ("thread", "thread");
+
+ gst_element_connect (src, "src", queue, "sink");
+ gst_element_connect (queue, "src", sink, "sink");
+
+ gst_bin_add (GST_BIN (pipeline), src);
+ gst_bin_add (GST_BIN (pipeline), queue);
+ gst_bin_add (GST_BIN (pipeline), thread);
+
+ gst_bin_add (GST_BIN (thread), sink);
+
+ g_object_set (G_OBJECT (src), "num_buffers", 5, NULL);
+}
+
+void
+change_state (GstElement *element, GstBuffer *buf, GstElement *pipeline)
+{
+ gst_element_set_state (pipeline, GST_STATE_NULL);
+}
+
+gint
+main (gint argc, gchar *argv[])
+{
+ GstElement *pipeline;
+ gint testnum;
+
+ gst_init (&argc, &argv);
+
+ if (argc < 2) {
+ usage();
+ return 0;
+ }
+
+ testnum = atoi (argv[1]);
+
+ pipeline = gst_pipeline_new ("main_pipeline");
+ construct_pipeline (pipeline);
+
+ if (testnum == 1) {
+ g_print ("stress test state changes...\n");
+
+ gst_element_set_state (pipeline, GST_STATE_NULL);
+ gst_element_set_state (pipeline, GST_STATE_READY);
+ gst_element_set_state (pipeline, GST_STATE_NULL);
+ gst_element_set_state (pipeline, GST_STATE_PAUSED);
+ gst_element_set_state (pipeline, GST_STATE_READY);
+ gst_element_set_state (pipeline, GST_STATE_PAUSED);
+ gst_element_set_state (pipeline, GST_STATE_PLAYING);
+ gst_element_set_state (pipeline, GST_STATE_PAUSED);
+ gst_element_set_state (pipeline, GST_STATE_PLAYING);
+ gst_element_set_state (pipeline, GST_STATE_READY);
+ 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)));
+ gst_element_set_state (pipeline, GST_STATE_NULL);
+ }
+ if (testnum == 3) {
+ gst_element_set_state (pipeline, GST_STATE_PLAYING);
+ g_print ("running2 ...\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 ("running3 ...\n");
+ for (run = 0; run < 3; run++) {
+ gst_bin_iterate (GST_BIN (pipeline));
+ }
+ gst_element_set_state (pipeline, GST_STATE_NULL);
+ }
+ if (testnum == 5) {
+ GstElement *sink;
+
+ sink = gst_bin_get_by_name (GST_BIN (pipeline), "sink");
+
+ g_signal_connect (G_OBJECT (sink), "handoff", change_state, pipeline);
+ gst_element_set_state (pipeline, GST_STATE_PLAYING);
+ g_print ("running3 ...\n");
+ while (gst_bin_iterate (GST_BIN (pipeline)));
+ gst_element_set_state (pipeline, GST_STATE_NULL);
+ }
+
+ return 0;
+}
diff --git a/testsuite/threads/Makefile.am b/testsuite/threads/Makefile.am
new file mode 100644
index 0000000..276a239
--- /dev/null
+++ b/testsuite/threads/Makefile.am
@@ -0,0 +1,9 @@
+testprogs = thread
+
+TESTS = $(testprogs)
+
+check_PROGRAMS = $(testprogs)
+
+# we have nothing but apps here, we can do this safely
+thread_LDADD = $(GST_LIBS)
+thread_CFLAGS = $(GST_CFLAGS) $(GNOME_CFLAGS) $(XML_CFLAGS)
diff --git a/testsuite/threads/thread.c b/testsuite/threads/thread.c
new file mode 100644
index 0000000..9ef9fc2
--- /dev/null
+++ b/testsuite/threads/thread.c
@@ -0,0 +1,112 @@
+#include <gst/gst.h>
+
+void
+usage (void)
+{
+ g_print ("usage: thread <testnum> \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, *thread;
+
+ src = gst_elementfactory_make ("fakesrc", "src");
+ sink = gst_elementfactory_make ("fakesink", "sink");
+ queue = gst_elementfactory_make ("queue", "queue");
+ thread = gst_elementfactory_make ("thread", "thread");
+
+ gst_element_connect (src, "src", queue, "sink");
+ gst_element_connect (queue, "src", sink, "sink");
+
+ gst_bin_add (GST_BIN (pipeline), src);
+ gst_bin_add (GST_BIN (pipeline), queue);
+ gst_bin_add (GST_BIN (pipeline), thread);
+
+ gst_bin_add (GST_BIN (thread), sink);
+
+ g_object_set (G_OBJECT (src), "num_buffers", 5, NULL);
+}
+
+void
+change_state (GstElement *element, GstBuffer *buf, GstElement *pipeline)
+{
+ gst_element_set_state (pipeline, GST_STATE_NULL);
+}
+
+gint
+main (gint argc, gchar *argv[])
+{
+ GstElement *pipeline;
+ gint testnum;
+
+ gst_init (&argc, &argv);
+
+ if (argc < 2) {
+ usage();
+ return 0;
+ }
+
+ testnum = atoi (argv[1]);
+
+ pipeline = gst_pipeline_new ("main_pipeline");
+ construct_pipeline (pipeline);
+
+ if (testnum == 1) {
+ g_print ("stress test state changes...\n");
+
+ gst_element_set_state (pipeline, GST_STATE_NULL);
+ gst_element_set_state (pipeline, GST_STATE_READY);
+ gst_element_set_state (pipeline, GST_STATE_NULL);
+ gst_element_set_state (pipeline, GST_STATE_PAUSED);
+ gst_element_set_state (pipeline, GST_STATE_READY);
+ gst_element_set_state (pipeline, GST_STATE_PAUSED);
+ gst_element_set_state (pipeline, GST_STATE_PLAYING);
+ gst_element_set_state (pipeline, GST_STATE_PAUSED);
+ gst_element_set_state (pipeline, GST_STATE_PLAYING);
+ gst_element_set_state (pipeline, GST_STATE_READY);
+ 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)));
+ gst_element_set_state (pipeline, GST_STATE_NULL);
+ }
+ if (testnum == 3) {
+ gst_element_set_state (pipeline, GST_STATE_PLAYING);
+ g_print ("running2 ...\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 ("running3 ...\n");
+ for (run = 0; run < 3; run++) {
+ gst_bin_iterate (GST_BIN (pipeline));
+ }
+ gst_element_set_state (pipeline, GST_STATE_NULL);
+ }
+ if (testnum == 5) {
+ GstElement *sink;
+
+ sink = gst_bin_get_by_name (GST_BIN (pipeline), "sink");
+
+ g_signal_connect (G_OBJECT (sink), "handoff", change_state, pipeline);
+ gst_element_set_state (pipeline, GST_STATE_PLAYING);
+ g_print ("running3 ...\n");
+ while (gst_bin_iterate (GST_BIN (pipeline)));
+ gst_element_set_state (pipeline, GST_STATE_NULL);
+ }
+
+ return 0;
+}
