diff --git a/common b/common index e400d0fc27..bca2dfba7b 160000 --- a/common +++ b/common @@ -1 +1 @@ -Subproject commit e400d0fc2780dac2ee516286893d4f312d065f86 +Subproject commit bca2dfba7bfc36020b5ba26b640ebde4cc76a5f0 diff --git a/gst/schedulers/gstbasicscheduler.c b/gst/schedulers/gstbasicscheduler.c index b91061cc2e..04cab05e63 100644 --- a/gst/schedulers/gstbasicscheduler.c +++ b/gst/schedulers/gstbasicscheduler.c @@ -320,25 +320,29 @@ gst_basic_scheduler_chain_wrapper (int argc, char *argv[]) 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; - 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); if (buf) { if (GST_IS_EVENT (buf) && !GST_ELEMENT_IS_EVENT_AWARE (element)) { gst_pad_send_event (pad, GST_EVENT (buf)); } else { - GST_DEBUG (GST_CAT_DATAFLOW, "calling chain function of %s:%s %p", name, - GST_PAD_NAME (pad), buf); + GST_DEBUG (GST_CAT_DATAFLOW, "calling chain function of %s:%s %p", + name, GST_PAD_NAME (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)); + GST_FLAG_UNSET (element, GST_ELEMENT_COTHREAD_STOPPING); /* due to oddities in the cothreads code, when this function returns it will