mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2024-11-30 05:31:15 +00:00
nicer looking
Original commit message from CVS: nicer looking
This commit is contained in:
parent
ae32b9a352
commit
de527dd234
2 changed files with 10 additions and 6 deletions
2
common
2
common
|
@ -1 +1 @@
|
||||||
Subproject commit e400d0fc2780dac2ee516286893d4f312d065f86
|
Subproject commit bca2dfba7bfc36020b5ba26b640ebde4cc76a5f0
|
|
@ -320,25 +320,29 @@ gst_basic_scheduler_chain_wrapper (int argc, char *argv[])
|
||||||
|
|
||||||
realpad = GST_REAL_PAD_CAST (pad);
|
realpad = GST_REAL_PAD_CAST (pad);
|
||||||
|
|
||||||
if (GST_RPAD_DIRECTION (realpad) == GST_PAD_SINK && GST_PAD_IS_USABLE (realpad)) {
|
if (GST_RPAD_DIRECTION (realpad) == GST_PAD_SINK &&
|
||||||
|
GST_PAD_IS_USABLE (realpad)) {
|
||||||
GstBuffer *buf;
|
GstBuffer *buf;
|
||||||
|
|
||||||
GST_DEBUG (GST_CAT_DATAFLOW, "pulling data from %s:%s", name, GST_PAD_NAME (pad));
|
GST_DEBUG (GST_CAT_DATAFLOW, "pulling data from %s:%s", name,
|
||||||
|
GST_PAD_NAME (pad));
|
||||||
buf = gst_pad_pull (pad);
|
buf = gst_pad_pull (pad);
|
||||||
if (buf) {
|
if (buf) {
|
||||||
if (GST_IS_EVENT (buf) && !GST_ELEMENT_IS_EVENT_AWARE (element)) {
|
if (GST_IS_EVENT (buf) && !GST_ELEMENT_IS_EVENT_AWARE (element)) {
|
||||||
gst_pad_send_event (pad, GST_EVENT (buf));
|
gst_pad_send_event (pad, GST_EVENT (buf));
|
||||||
}
|
}
|
||||||
else {
|
else {
|
||||||
GST_DEBUG (GST_CAT_DATAFLOW, "calling chain function of %s:%s %p", name,
|
GST_DEBUG (GST_CAT_DATAFLOW, "calling chain function of %s:%s %p",
|
||||||
GST_PAD_NAME (pad), buf);
|
name, GST_PAD_NAME (pad), buf);
|
||||||
GST_RPAD_CHAINFUNC (realpad) (pad, buf);
|
GST_RPAD_CHAINFUNC (realpad) (pad, buf);
|
||||||
GST_DEBUG (GST_CAT_DATAFLOW, "calling chain function of element %s done", name);
|
GST_DEBUG (GST_CAT_DATAFLOW,
|
||||||
|
"calling chain function of element %s done", name);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
} while (!GST_ELEMENT_IS_COTHREAD_STOPPING (element));
|
} while (!GST_ELEMENT_IS_COTHREAD_STOPPING (element));
|
||||||
|
|
||||||
GST_FLAG_UNSET (element, GST_ELEMENT_COTHREAD_STOPPING);
|
GST_FLAG_UNSET (element, GST_ELEMENT_COTHREAD_STOPPING);
|
||||||
|
|
||||||
/* due to oddities in the cothreads code, when this function returns it will
|
/* due to oddities in the cothreads code, when this function returns it will
|
||||||
|
|
Loading…
Reference in a new issue