mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-06-16 21:10:37 +00:00
Code Issues 1 Projects Releases Wiki Activity

Added test for dynamic reconfiguration of pipelines triggered by padprobes

Browse source 
Original commit message from CVS:
Added test for dynamic reconfiguration of pipelines triggered by padprobes
This commit is contained in:
Wim Taymans 2003-02-27 21:07:31 +00:00
parent ecb6dd6c6a
commit ed085dd930
3 changed files with 87 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
tests/probes/.gitignore vendored Normal file
View file

@ -0,0 +1 @@
probetest

5
tests/probes/Makefile.am Normal file
View file

@ -0,0 +1,5 @@
noinst_PROGRAMS = probetest
LDADD = $(GST_LIBS)
AM_CFLAGS = $(GST_CFLAGS)

81
tests/probes/probetest.c Normal file
View file

@ -0,0 +1,81 @@
#include <gst/gst.h>
static GstElement *src1, *src2, *sink, *pipeline, *bin;
static gint state = 0;
static gboolean
notify (GstProbe *probe, GstData **data, gpointer user_data)
{
switch (state) {
case 0:
if (GST_BUFFER_TIMESTAMP (*data) == 10) {
gst_element_set_state (GST_ELEMENT (bin), GST_STATE_PAUSED);
gst_element_unlink_pads (GST_ELEMENT (src1), "src", sink, "sink");
gst_bin_add (GST_BIN (bin), src2);
gst_bin_remove (GST_BIN (bin), src1);
gst_element_link_pads (GST_ELEMENT (src2), "src", sink, "sink");
gst_element_set_state (GST_ELEMENT (bin), GST_STATE_PLAYING);
state++;
gst_data_unref (*data);
return FALSE;
}
break;
case 1:
GST_BUFFER_TIMESTAMP (*data) = GST_BUFFER_TIMESTAMP (*data) + 10;
if (GST_BUFFER_TIMESTAMP (*data) == 20) {
gst_data_unref (*data);
*data = GST_DATA (gst_event_new (GST_EVENT_EOS));
gst_element_set_state (src2, GST_STATE_PAUSED);
return TRUE;
}
break;
default:
break;
}
return TRUE;
}
int
main (int argc, gchar *argv[])
{
gst_init (&argc, &argv);
pipeline = gst_pipeline_new ("main_pipeline");
bin = gst_bin_new ("control");
src1 = gst_element_factory_make ("fakesrc", "src1");
src2 = gst_element_factory_make ("fakesrc", "src2");
gst_bin_add (GST_BIN (bin), src1);
sink = gst_element_factory_make ("fakesink", "sink");
gst_bin_add (GST_BIN (pipeline), sink);
gst_bin_add (GST_BIN (pipeline), bin);
gst_element_link_pads (GST_ELEMENT (src1), "src", sink, "sink");
g_signal_connect (pipeline, "deep_notify", G_CALLBACK (gst_element_default_deep_notify), NULL);
g_signal_connect (pipeline, "error", G_CALLBACK (gst_element_default_error), NULL);
gst_pad_add_probe (gst_element_get_pad (src1, "src"),
gst_probe_new (FALSE,
notify,
NULL));
gst_pad_add_probe (gst_element_get_pad (src2, "src"),
gst_probe_new (FALSE,
notify,
NULL));
gst_element_set_state (GST_ELEMENT (pipeline), GST_STATE_PLAYING);
while (gst_bin_iterate (GST_BIN (pipeline)));
gst_element_set_state (GST_ELEMENT (pipeline), GST_STATE_NULL);
gst_object_unref (GST_OBJECT (pipeline));
return 0;
}