mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-26 11:41:09 +00:00
Code Issues 1 Projects Releases Wiki Activity

Test program for simple queue operations. Good for testing thread/cothread interations.

Browse source 
Original commit message from CVS:
Test program for simple queue operations.  Good for testing thread/cothread
interations.
This commit is contained in:
Erik Walthinsen 2000-12-08 20:31:40 +00:00
parent cd24b35b70
commit 1aed13ae6b
2 changed files with 54 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
tests/Makefile.am
View file

@ -1,4 +1,4 @@
noinst_PROGRAMS = init loadall simplefake states caps noinst_PROGRAMS = init loadall simplefake states caps queue
LDADD = $(GLIB_LIBS) $(GTK_LIBS) $(top_builddir)/gst/libgst.la LDADD = $(GLIB_LIBS) $(GTK_LIBS) $(top_builddir)/gst/libgst.la
CFLAGS = -Wall CFLAGS = -Wall

53
tests/queue.c Normal file
View file

@ -0,0 +1,53 @@
#include <gst/gst.h>
int main(int argc,char *argv[]) {
GstBin *pipeline,*thr1,*thr2;
GstElement *src,*queue,*sink;
int i;
gst_init(&argc,&argv);
pipeline = GST_BIN(gst_pipeline_new("pipeline"));
g_return_val_if_fail(1,pipeline != NULL);
// thr1 = GST_BIN(gst_thread_new("thr1"));
thr1 = gst_bin_new("thr1");
g_return_val_if_fail(2,thr1 != NULL);
// thr2 = GST_BIN(gst_thread_new("thr2"));
thr2 = gst_bin_new("thr2");
g_return_val_if_fail(3,thr2 != NULL);
fprintf(stderr,"QUEUE: fakesrc\n");
src = gst_elementfactory_make("fakesrc","src");
g_return_val_if_fail(4,src != NULL);
fprintf(stderr,"QUEUE: queue\n");
queue = gst_elementfactory_make("queue","queue");
g_return_val_if_fail(4,queue != NULL);
fprintf(stderr,"QUEUE: fakesink\n");
sink = gst_elementfactory_make("fakesink","sink");
g_return_val_if_fail(5,sink != NULL);
fprintf(stderr,"QUEUE: have elements\n");
gst_bin_add(thr1,src);
fprintf(stderr,"QUEUE: added src to thr1\n");
gst_element_add_ghost_pad(GST_ELEMENT(thr1),gst_element_get_pad(src,"src"));
// gst_bin_use_cothreads(thr1,TRUE);
gst_bin_add(thr2,sink);
fprintf(stderr,"QUEUE: added sink to thr2\n");
gst_element_add_ghost_pad(GST_ELEMENT(thr2),gst_element_get_pad(sink,"sink"));
gst_bin_use_cothreads(thr2,TRUE);
fprintf(stderr,"QUEUE: filled in threads\n");
gst_bin_add(pipeline,GST_ELEMENT(thr1));
gst_bin_add(pipeline,GST_ELEMENT(queue));
gst_bin_add(pipeline,GST_ELEMENT(thr2));
gst_element_connect(thr1,"src",queue,"sink");
gst_element_connect(queue,"src",thr2,"sink");
printf("QUEUE: constructed outer pipeline\n");
gst_element_set_state(GST_ELEMENT(pipeline),GST_STATE_PLAYING);
if (GST_STATE(src) != GST_STATE_PLAYING) fprintf(stderr,"error: state not set\n");
fprintf(stderr,"\n\n");
gst_bin_iterate(thr1);
fprintf(stderr,"\n\n");
gst_bin_iterate(thr2);
}