mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-12-28 03:00:35 +00:00
Code Issues 1 Projects Releases Wiki Activity

omx: Don't handle disabling/enabling ports exactly like flushing

Browse source 
Otherwise we might abort a flush operation in another thread when
enabling/disabling ports, leading to deadlocks sometimes.

https://bugzilla.gnome.org/show_bug.cgi?id=730989
This commit is contained in:
Sebastian Dröge 2014-05-31 15:12:05 +02:00
parent bf7e6109d9
commit 190adce125
1 changed files with 7 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

21
omx/gstomx.c
View file

@ -1398,9 +1398,10 @@ gst_omx_port_release_buffer (GstOMXPort * port, GstOMXBuffer * buf)
goto done;
}
if (port->flushing) {
GST_DEBUG_OBJECT (comp->parent, "%s port %u is flushing, not releasing "
"buffer", comp->name, port->index);
if (port->flushing || port->disabled_pending || !port->port_def.bEnabled) {
GST_DEBUG_OBJECT (comp->parent,
"%s port %u is flushing or disabled, not releasing " "buffer",
comp->name, port->index);
g_queue_push_tail (&port->pending_buffers, buf);
gst_omx_component_send_message (comp, NULL);
goto done;
@ -1857,13 +1858,6 @@ gst_omx_port_set_enabled_unlocked (GstOMXPort * port, gboolean enabled)
else
port->disabled_pending = TRUE;
if (!enabled) {
/* This is also like flushing, i.e. all buffers are returned
* by the component and no new buffers should be passed to
* the component anymore */
port->flushing = TRUE;
}
if (enabled)
err =
OMX_SendCommand (comp->handle, OMX_CommandPortEnable, port->index,
@ -2013,9 +2007,9 @@ gst_omx_port_populate_unlocked (GstOMXPort * port)
gst_omx_component_handle_messages (comp);
if (port->flushing) {
GST_DEBUG_OBJECT (comp->parent, "%s port %u is flushing", comp->name,
port->index);
if (port->flushing || port->disabled_pending || !port->port_def.bEnabled) {
GST_DEBUG_OBJECT (comp->parent, "%s port %u is flushing or disabled",
comp->name, port->index);
err = OMX_ErrorIncorrectStateOperation;
goto done;
}
@ -2146,7 +2140,6 @@ gst_omx_port_wait_enabled_unlocked (GstOMXPort * port, GstClockTime timeout)
err = last_error;
} else {
if (enabled) {
port->flushing = FALSE;
/* Reset EOS flag */
port->eos = FALSE;
}