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

Direct events to the event handler for non event-ware elements. pass the event to the chain function for event aware ...

Browse source 
Original commit message from CVS:
Direct events to the event handler for non event-ware elements.
pass the event to the chain function for event aware elements.
This commit is contained in:
Wim Taymans 2001-11-14 21:11:05 +00:00
parent 2f60d799a4
commit dc435fc930
1 changed files with 12 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
gst/gstscheduler.c
View file

@ -71,11 +71,17 @@ gst_schedule_chain_wrapper (int argc,char *argv[])
if (GST_RPAD_DIRECTION (realpad) == GST_PAD_SINK) { if (GST_RPAD_DIRECTION (realpad) == GST_PAD_SINK) {
GstBuffer *buf; GstBuffer *buf;
GST_DEBUG (GST_CAT_DATAFLOW,"pulling a buffer from %s:%s\n", name, GST_PAD_NAME (pad)); GST_DEBUG (GST_CAT_DATAFLOW,"pulling data from %s:%s\n", name, GST_PAD_NAME (pad));
buf = gst_pad_pull (pad); buf = gst_pad_pull (pad);
GST_DEBUG (GST_CAT_DATAFLOW,"calling chain function of %s:%s\n", name, GST_PAD_NAME (pad)); if (buf) {
if (buf) if (GST_IS_EVENT (buf) && !GST_ELEMENT_IS_EVENT_AWARE (element)) {
GST_RPAD_CHAINFUNC(realpad) (pad,buf); gst_pad_event_default (pad, GST_EVENT (buf));
}
else {
GST_DEBUG (GST_CAT_DATAFLOW,"calling chain function of %s:%s\n", name, GST_PAD_NAME (pad));
GST_RPAD_CHAINFUNC(realpad) (pad, buf);
}
}
GST_DEBUG (GST_CAT_DATAFLOW,"calling chain function of %s:%s done\n", name, GST_PAD_NAME (pad)); GST_DEBUG (GST_CAT_DATAFLOW,"calling chain function of %s:%s done\n", name, GST_PAD_NAME (pad));
} }
} }
@ -214,6 +220,7 @@ gst_schedule_gethandler_proxy (GstPad *pad)
// now grab the buffer from the pen, clear the pen, and return the buffer // now grab the buffer from the pen, clear the pen, and return the buffer
buf = GST_RPAD_BUFPEN(pad); buf = GST_RPAD_BUFPEN(pad);
GST_RPAD_BUFPEN(pad) = NULL; GST_RPAD_BUFPEN(pad) = NULL;
return buf; return buf;
} }
@ -1492,6 +1499,7 @@ GST_DEBUG(GST_CAT_SCHEDULING,"there are %d elements in this chain\n",chain->num_
GST_INFO (GST_CAT_DATAFLOW,"NO ENTRY INTO CHAIN!"); GST_INFO (GST_CAT_DATAFLOW,"NO ENTRY INTO CHAIN!");
gst_schedule_show(sched); gst_schedule_show(sched);
//eos = TRUE; //eos = TRUE;
//gst_element_set_state (GST_ELEMENT (bin), GST_STATE_PAUSED);
} }
} else { } else {
GST_INFO (GST_CAT_DATAFLOW,"NO ENABLED ELEMENTS IN CHAIN!!"); GST_INFO (GST_CAT_DATAFLOW,"NO ENABLED ELEMENTS IN CHAIN!!");
@ -1518,7 +1526,6 @@ gst_schedule_show(sched);
pads = entry->pads; pads = entry->pads;
while (pads) { while (pads) {
pad = GST_PAD (pads->data); pad = GST_PAD (pads->data);
if (GST_RPAD_DIRECTION(pad) == GST_PAD_SRC) {
GST_DEBUG (GST_CAT_DATAFLOW,"calling getfunc of %s:%s\n",GST_DEBUG_PAD_NAME(pad)); GST_DEBUG (GST_CAT_DATAFLOW,"calling getfunc of %s:%s\n",GST_DEBUG_PAD_NAME(pad));
if (GST_REAL_PAD(pad)->getfunc == NULL) if (GST_REAL_PAD(pad)->getfunc == NULL)
fprintf(stderr, "error, no getfunc in \"%s\"\n", GST_ELEMENT_NAME (entry)); fprintf(stderr, "error, no getfunc in \"%s\"\n", GST_ELEMENT_NAME (entry));