flow_ret = GST_FLOW_EOS;
}
g_mutex_unlock (&self->drain_lock);
-
self->downstream_flow_ret = flow_ret;
+ /* Here we fallback and pause the task for the EOS case */
if (flow_ret != GST_FLOW_OK)
goto flow_error;
g_mutex_unlock (&self->drain_lock);
self->downstream_flow_ret = flow_ret;
+ /* Here we fallback and pause the task for the EOS case */
if (flow_ret != GST_FLOW_OK)
goto flow_error;
g_mutex_unlock (&self->drain_lock);
self->downstream_flow_ret = flow_ret;
+ /* Here we fallback and pause the task for the EOS case */
if (flow_ret != GST_FLOW_OK)
goto flow_error;