mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-01-11 01:45:33 +00:00
Code Issues 1 Projects Releases Wiki Activity

Iterate until we find the real pad when creating a ghostpad make a copy of the event in the default dispatcher.

Browse source 
Original commit message from CVS:
Iterate until we find the real pad when creating a ghostpad
make a copy of the event in the default dispatcher.
This commit is contained in:
Wim Taymans 2002-02-23 14:02:29 +00:00
parent b792a2af1f
commit 2bcb002772
1 changed files with 10 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
gst/gstpad.c
View file

@ -2233,13 +2233,20 @@ gst_ghost_pad_new (gchar *name,
GstPad *pad) GstPad *pad)
{ {
GstGhostPad *ghostpad; GstGhostPad *ghostpad;
GstRealPad *realpad;
g_return_val_if_fail (name != NULL, NULL); g_return_val_if_fail (name != NULL, NULL);
g_return_val_if_fail (GST_IS_PAD (pad), NULL); g_return_val_if_fail (GST_IS_PAD (pad), NULL);
ghostpad = g_object_new (gst_ghost_pad_get_type () ,NULL); ghostpad = g_object_new (gst_ghost_pad_get_type () ,NULL);
gst_pad_set_name (GST_PAD (ghostpad), name); gst_pad_set_name (GST_PAD (ghostpad), name);
GST_GPAD_REALPAD (ghostpad) = GST_PAD_REALIZE (pad);
realpad = (GstRealPad *) pad;
while (!GST_IS_REAL_PAD (realpad)) {
realpad = GST_PAD_REALIZE (realpad);
}
GST_GPAD_REALPAD (ghostpad) = realpad;
GST_PAD_PADTEMPLATE (ghostpad) = GST_PAD_PADTEMPLATE (pad); GST_PAD_PADTEMPLATE (ghostpad) = GST_PAD_PADTEMPLATE (pad);
/* add ourselves to the real pad's list of ghostpads */ /* add ourselves to the real pad's list of ghostpads */
@ -2264,12 +2271,12 @@ gst_pad_event_default_dispatch (GstPad *pad, GstElement *element, GstEvent *even
/* for all pads in the opposite direction that are connected */ /* for all pads in the opposite direction that are connected */
if (GST_PAD_DIRECTION (eventpad) != GST_PAD_DIRECTION (pad) && GST_PAD_IS_CONNECTED (eventpad)) { if (GST_PAD_DIRECTION (eventpad) != GST_PAD_DIRECTION (pad) && GST_PAD_IS_CONNECTED (eventpad)) {
if (GST_PAD_DIRECTION (eventpad) == GST_PAD_SRC) { if (GST_PAD_DIRECTION (eventpad) == GST_PAD_SRC) {
gst_pad_push (eventpad, GST_BUFFER (gst_event_new (GST_EVENT_TYPE (event)))); gst_pad_push (eventpad, GST_BUFFER (gst_event_copy (event)));
} }
else { else {
GstPad *peerpad = GST_PAD_CAST (GST_RPAD_PEER (eventpad)); GstPad *peerpad = GST_PAD_CAST (GST_RPAD_PEER (eventpad));
gst_pad_send_event (peerpad, gst_event_new (GST_EVENT_TYPE (event))); gst_pad_send_event (peerpad, gst_event_copy (event));
} }
} }
} }
@ -2293,14 +2300,12 @@ gst_pad_event_default (GstPad *pad, GstEvent *event)
case GST_EVENT_EOS: case GST_EVENT_EOS:
gst_element_set_eos (element); gst_element_set_eos (element);
gst_pad_event_default_dispatch (pad, element, event); gst_pad_event_default_dispatch (pad, element, event);
gst_event_free (event);
/* we have to try to schedule another element because this one is disabled */ /* we have to try to schedule another element because this one is disabled */
gst_element_yield (element); gst_element_yield (element);
break; break;
case GST_EVENT_FLUSH: case GST_EVENT_FLUSH:
default: default:
gst_pad_event_default_dispatch (pad, element, event); gst_pad_event_default_dispatch (pad, element, event);
gst_event_free (event);
break; break;
} }
} }