mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2024-12-30 04:00:37 +00:00
96 lines
2.3 KiB
C
96 lines
2.3 KiB
C
|
#include <string.h>
|
||
|
|
#include <unistd.h>
|
||
|
|
#include <gst/gst.h>
|
||
|
|
|
||
|
|
static GstElement *src1, *sink1;
|
||
|
|
static gboolean need_src1 = TRUE;
|
||
|
|
static gint iter = 0;
|
||
|
|
|
||
|
|
static void
|
||
|
|
object_deep_notify (GObject * object, GstObject * orig,
|
||
|
|
GParamSpec * pspec, gchar ** excluded_props)
|
||
|
|
{
|
||
|
|
GValue value = { 0, }; /* the important thing is that value.type = 0 */
|
||
|
|
gchar *str = NULL;
|
||
|
|
|
||
|
|
if (strcmp (pspec->name, "last-message") != 0)
|
||
|
|
return;
|
||
|
|
|
||
|
|
if (GST_ELEMENT (orig) != src1 && GST_ELEMENT (orig) != sink1)
|
||
|
|
return;
|
||
|
|
|
||
|
|
g_value_init (&value, G_PARAM_SPEC_VALUE_TYPE (pspec));
|
||
|
|
g_object_get_property (G_OBJECT (orig), pspec->name, &value);
|
||
|
|
|
||
|
|
str = g_strdup_value_contents (&value);
|
||
|
|
g_value_unset (&value);
|
||
|
|
|
||
|
|
if (strstr (str, "E (type:") != NULL) {
|
||
|
|
g_free (str);
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
if (iter++ == 100) {
|
||
|
|
g_print (".");
|
||
|
|
iter = 0;
|
||
|
|
}
|
||
|
|
g_free (str);
|
||
|
|
if (need_src1 && GST_ELEMENT (orig) != src1) {
|
||
|
|
g_assert_not_reached ();
|
||
|
|
} else if (!need_src1 && GST_ELEMENT (orig) != sink1) {
|
||
|
|
g_assert_not_reached ();
|
||
|
|
}
|
||
|
|
need_src1 = !need_src1;
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
int
|
||
|
|
main (int argc, char **argv)
|
||
|
|
{
|
||
|
|
GstElement *thread1, *thread2, *pipeline;
|
||
|
|
GstElement *src2, *sink2;
|
||
|
|
|
||
|
|
gst_init (&argc, &argv);
|
||
|
|
|
||
|
|
pipeline = gst_element_factory_make ("pipeline", "pipeline");
|
||
|
|
thread1 = gst_element_factory_make ("thread", "thread1");
|
||
|
|
g_assert (thread1);
|
||
|
|
|
||
|
|
src1 = gst_element_factory_make ("fakesrc", "src1");
|
||
|
|
g_assert (src1);
|
||
|
|
sink1 = gst_element_factory_make ("fakesink", "sink1");
|
||
|
|
g_assert (sink1);
|
||
|
|
|
||
|
|
thread2 = gst_element_factory_make ("thread", "thread2");
|
||
|
|
g_assert (thread2);
|
||
|
|
|
||
|
|
src2 = gst_element_factory_make ("fakesrc", "src2");
|
||
|
|
g_assert (src2);
|
||
|
|
sink2 = gst_element_factory_make ("fakesink", "sink2");
|
||
|
|
g_assert (sink2);
|
||
|
|
|
||
|
|
gst_bin_add_many (GST_BIN (thread1), src1, sink1, NULL);
|
||
|
|
gst_bin_add_many (GST_BIN (thread2), src2, sink2, NULL);
|
||
|
|
|
||
|
|
gst_bin_add (GST_BIN (pipeline), thread1);
|
||
|
|
gst_bin_add (GST_BIN (pipeline), thread2);
|
||
|
|
|
||
|
|
g_signal_connect (G_OBJECT (pipeline), "deep_notify",
|
||
|
|
G_CALLBACK (object_deep_notify), NULL);
|
||
|
|
|
||
|
|
if (!gst_element_link_many (src1, sink1, NULL))
|
||
|
|
g_assert_not_reached ();
|
||
|
|
|
||
|
|
if (!gst_element_link_many (src2, sink2, NULL))
|
||
|
|
g_assert_not_reached ();
|
||
|
|
|
||
|
|
/* run a bit */
|
||
|
|
if (gst_element_set_state (pipeline, GST_STATE_PLAYING) != GST_STATE_SUCCESS)
|
||
|
|
g_assert_not_reached ();
|
||
|
|
|
||
|
|
sleep (10000);
|
||
|
|
g_print ("done\n");
|
||
|
|
|
||
|
|
return 0;
|
||
|
|
}
|