mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-04-26 04:26:14 +00:00
Code Issues 1 Projects Releases Wiki Activity

store src and sink pads in slists to get ready for the src1,src2\!sink1,sink2 syntax

Browse source 
Original commit message from CVS:
store src and sink pads in slists to get ready for the src1,src2\!sink1,sink2 syntax
This commit is contained in:
Steve Baker 2001-06-09 11:43:58 +00:00
parent 42d724726c
commit 76544d6da3
2 changed files with 68 additions and 53 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

119
gst/gstparse.c
View file

@ -107,7 +107,8 @@ gst_parse_launch_cmdline(int argc,char *argv[],GstBin *parent,gst_parse_priv *pr
gint len; gint len;
gchar *ptr; gchar *ptr;
gchar *sinkpadname = NULL, *srcpadname = NULL; gchar *sinkpadname = NULL, *srcpadname = NULL;
GstPad *sinkpad = NULL, *srcpad = NULL; GstPad *temppad;
GSList *sinkpads = NULL, *srcpads = NULL;
GList *pads; GList *pads;
gint elementcount = 0; gint elementcount = 0;
gint retval = 0; gint retval = 0;
@ -163,33 +164,38 @@ gst_parse_launch_cmdline(int argc,char *argv[],GstBin *parent,gst_parse_priv *pr
GST_DEBUG(0,"have srcpad %s, sinkpad %s\n",srcpadname,sinkpadname); GST_DEBUG(0,"have srcpad %s, sinkpad %s\n",srcpadname,sinkpadname);
srcpad = NULL; g_slist_free(srcpads);
srcpads = NULL;
// if the srcpadname doesn't have any commas in it, find an actual pad // if the srcpadname doesn't have any commas in it, find an actual pad
if (!srcpadname || !strchr(srcpadname,',')) { if (!srcpadname || !strchr(srcpadname,',')) {
if (srcpadname != NULL) { if (srcpadname != NULL) {
srcpad = gst_element_get_pad(previous,srcpadname); if ((temppad = gst_element_get_pad(previous,srcpadname))){
if (!srcpad) { srcpads = g_slist_append(srcpads,temppad);
srcpad = gst_element_request_pad_by_name(previous,srcpadname);
} }
if (!srcpad) { else if ((temppad = gst_element_request_pad_by_name(previous,srcpadname))) {
srcpads = g_slist_append(srcpads,temppad);
}
if (!srcpads) {
GST_DEBUG(0,"NO SUCH pad %s in element %s\n",srcpadname,GST_ELEMENT_NAME(previous)); GST_DEBUG(0,"NO SUCH pad %s in element %s\n",srcpadname,GST_ELEMENT_NAME(previous));
} }
} }
else if (srcpad == NULL) { else {
// check through the list to find the first sink pad // check through the list to find the first sink pad
GST_DEBUG(0,"CHECKING through element %s for pad named %s\n",GST_ELEMENT_NAME(previous),srcpadname); GST_DEBUG(0,"CHECKING through element %s for pad named %s\n",GST_ELEMENT_NAME(previous),srcpadname);
pads = gst_element_get_pad_list(previous); pads = gst_element_get_pad_list(previous);
while (pads) { while (pads) {
srcpad = GST_PAD(pads->data); temppad = GST_PARSE_LISTPAD(pads);
GST_DEBUG(0,"have pad %s:%s\n",GST_DEBUG_PAD_NAME(srcpad)); GST_DEBUG(0,"have pad %s:%s\n",GST_DEBUG_PAD_NAME(temppad));
if (GST_IS_GHOST_PAD(srcpad)) GST_DEBUG(0,"it's a ghost pad\n"); if (GST_IS_GHOST_PAD(temppad)) GST_DEBUG(0,"it's a ghost pad\n");
if (gst_pad_get_direction (temppad) == GST_PAD_SRC){
srcpads = g_slist_append(srcpads,temppad);
break;
}
pads = g_list_next (pads); pads = g_list_next (pads);
if (gst_pad_get_direction (srcpad) == GST_PAD_SRC) break;
srcpad = NULL;
} }
if (!srcpad) GST_DEBUG(0,"error, can't find a src pad!!!\n"); if (!srcpads) GST_DEBUG(0,"error, can't find a src pad!!!\n");
else GST_DEBUG(0,"have src pad %s:%s\n",GST_DEBUG_PAD_NAME(srcpad)); else GST_DEBUG(0,"have src pad %s:%s\n",GST_DEBUG_PAD_NAME(GST_PARSE_LISTPAD(srcpads)));
} }
} }
@ -249,53 +255,60 @@ if (GST_IS_GHOST_PAD(srcpad)) GST_DEBUG(0,"it's a ghost pad\n");
gst_bin_add (GST_BIN (parent), element); gst_bin_add (GST_BIN (parent), element);
elementcount++; elementcount++;
if (srcpad != NULL || srcpadname != NULL) { if (srcpads != NULL || srcpadname != NULL) {
if (srcpad) if (srcpads)
DEBUG("need to connect to srcpad %s:%s\n",GST_DEBUG_PAD_NAME(srcpad)); GST_DEBUG(0, "need to connect to srcpad %s:%s\n",GST_DEBUG_PAD_NAME(GST_PARSE_LISTPAD(srcpads)));
sinkpad = NULL; g_slist_free(sinkpads);
sinkpads = NULL;
if (sinkpadname != NULL){ if (sinkpadname != NULL){
sinkpad = gst_element_get_pad(element,sinkpadname); if ((temppad = gst_element_get_pad(element,sinkpadname))){
sinkpads = g_slist_append(sinkpads,temppad);
if (!sinkpad) { }
sinkpad = gst_element_request_pad_by_name(element,sinkpadname); else if ((temppad = gst_element_request_pad_by_name(element,sinkpadname))) {
sinkpads = g_slist_append(sinkpads,temppad);
} }
} }
else {
if (!sinkpad) {
// check through the list to find the first sink pad // check through the list to find the first sink pad
pads = gst_element_get_pad_list(element); pads = gst_element_get_pad_list(element);
while (pads) { while (pads) {
sinkpad = GST_PAD(pads->data); temppad = GST_PAD(pads->data);
pads = g_list_next (pads); pads = g_list_next (pads);
if (gst_pad_get_direction (sinkpad) == GST_PAD_SINK) break; if (gst_pad_get_direction (temppad) == GST_PAD_SINK){
sinkpad = NULL; sinkpads = g_slist_append(sinkpads,temppad);
break;
}
} }
} }
if (!sinkpad) DEBUG("error, can't find a sink pad!!!\n"); if (!sinkpads) DEBUG("error, can't find a sink pad!!!\n");
else DEBUG("have sink pad %s:%s\n",GST_DEBUG_PAD_NAME(sinkpad)); else DEBUG("have sink pad %s:%s\n",GST_DEBUG_PAD_NAME(GST_PARSE_LISTPAD(sinkpads)));
if (!srcpad) { if (!srcpads) {
dyn_connect *connect = g_malloc (sizeof (dyn_connect)); dyn_connect *connect = g_malloc (sizeof (dyn_connect));
connect->srcpadname = srcpadname; connect->srcpadname = srcpadname;
connect->target = sinkpad; connect->target = GST_PARSE_LISTPAD(sinkpads);
GST_DEBUG(0,"SETTING UP dynamic connection %s:%s and %s:%s\n",gst_element_get_name (previous), GST_DEBUG(0,"SETTING UP dynamic connection %s:%s and %s:%s\n",gst_element_get_name (previous),
srcpadname,GST_DEBUG_PAD_NAME(sinkpad)); srcpadname,GST_DEBUG_PAD_NAME(GST_PARSE_LISTPAD(sinkpads)));
gtk_signal_connect (GTK_OBJECT (previous), "new_pad", dynamic_connect, connect); gtk_signal_connect (GTK_OBJECT (previous), "new_pad", dynamic_connect, connect);
gtk_signal_connect (GTK_OBJECT (previous), "new_ghost_pad", dynamic_connect, connect); gtk_signal_connect (GTK_OBJECT (previous), "new_ghost_pad", dynamic_connect, connect);
} }
else { else {
GST_DEBUG(0,"CONNECTING %s:%s and %s:%s\n",GST_DEBUG_PAD_NAME(srcpad),GST_DEBUG_PAD_NAME(sinkpad)); GST_DEBUG(0,"CONNECTING %s:%s and %s:%s\n",GST_DEBUG_PAD_NAME(GST_PARSE_LISTPAD(srcpads)),
gst_pad_connect(srcpad,sinkpad); GST_DEBUG_PAD_NAME(GST_PARSE_LISTPAD(sinkpads)));
gst_pad_connect(GST_PARSE_LISTPAD(srcpads),GST_PARSE_LISTPAD(sinkpads));
} }
sinkpad = NULL; g_slist_free(srcpads);
srcpad = NULL; srcpads = NULL;
g_slist_free(sinkpads);
sinkpads = NULL;
} }
@ -312,14 +325,14 @@ if (GST_IS_GHOST_PAD(srcpad)) GST_DEBUG(0,"it's a ghost pad\n");
GST_ELEMENT_NAME(element),GST_ELEMENT_NAME(GST_ELEMENT(parent))); GST_ELEMENT_NAME(element),GST_ELEMENT_NAME(GST_ELEMENT(parent)));
pads = gst_element_get_pad_list (element); pads = gst_element_get_pad_list (element);
while (pads) { while (pads) {
sinkpad = GST_PAD (pads->data); temppad = GST_PAD (pads->data);
pads = g_list_next (pads); pads = g_list_next (pads);
if (!sinkpad) DEBUG("much oddness, pad doesn't seem to exist\n"); if (!temppad) DEBUG("much oddness, pad doesn't seem to exist\n");
else if (gst_pad_get_direction (sinkpad) == GST_PAD_SINK) { else if (gst_pad_get_direction (temppad) == GST_PAD_SINK) {
gst_element_add_ghost_pad (GST_ELEMENT (parent), sinkpad, gst_element_add_ghost_pad (GST_ELEMENT (parent), temppad,
g_strdup_printf("%s-ghost",GST_PAD_NAME(sinkpad))); g_strdup_printf("%s-ghost",GST_PAD_NAME(temppad)));
GST_DEBUG(0,"GHOSTED %s:%s to %s as %s-ghost\n", GST_DEBUG(0,"GHOSTED %s:%s to %s as %s-ghost\n",
GST_DEBUG_PAD_NAME(sinkpad),GST_ELEMENT_NAME(GST_ELEMENT(parent)),GST_PAD_NAME(sinkpad)); GST_DEBUG_PAD_NAME(temppad),GST_ELEMENT_NAME(GST_ELEMENT(parent)),GST_PAD_NAME(temppad));
} }
} }
} }
@ -337,14 +350,14 @@ g_strdup_printf("%s-ghost",GST_PAD_NAME(sinkpad)));
GST_ELEMENT_NAME(prevelement),GST_ELEMENT_NAME(GST_ELEMENT(parent))); GST_ELEMENT_NAME(prevelement),GST_ELEMENT_NAME(GST_ELEMENT(parent)));
pads = gst_element_get_pad_list (prevelement); pads = gst_element_get_pad_list (prevelement);
while (pads) { while (pads) {
srcpad = GST_PAD (pads->data); temppad = GST_PAD (pads->data);
pads = g_list_next (pads); pads = g_list_next (pads);
if (!srcpad) DEBUG("much oddness, pad doesn't seem to exist\n"); if (!temppad) DEBUG("much oddness, pad doesn't seem to exist\n");
else if (gst_pad_get_direction (srcpad) == GST_PAD_SRC) { else if (gst_pad_get_direction (temppad) == GST_PAD_SRC) {
gst_element_add_ghost_pad (GST_ELEMENT (parent), srcpad, gst_element_add_ghost_pad (GST_ELEMENT (parent), temppad,
g_strdup_printf("%s-ghost",GST_PAD_NAME(srcpad))); g_strdup_printf("%s-ghost",GST_PAD_NAME(temppad)));
GST_DEBUG(0,"GHOSTED %s:%s to %s as %s-ghost\n", GST_DEBUG(0,"GHOSTED %s:%s to %s as %s-ghost\n",
GST_DEBUG_PAD_NAME(srcpad),GST_ELEMENT_NAME (parent),GST_PAD_NAME(srcpad)); GST_DEBUG_PAD_NAME(temppad),GST_ELEMENT_NAME (parent),GST_PAD_NAME(temppad));
} }
} }
} }

2
gst/gstparse.h
View file

@ -25,6 +25,8 @@
#include <gst/gstbin.h> #include <gst/gstbin.h>
#define GST_PARSE_LISTPAD(list) ((GstPad*)(list->data))
gint gst_parse_launch (const gchar *cmdline, GstBin *parent); gint gst_parse_launch (const gchar *cmdline, GstBin *parent);
#endif /* __GST_PARSE_H__ */ #endif /* __GST_PARSE_H__ */