diff options
| -rw-r--r-- | omx/gstomx.c | 11 | ||||
| -rw-r--r-- | omx/gstomx.h | 1 | ||||
| -rw-r--r-- | omx/gstomxbufferpool.c | 2 |
3 files changed, 13 insertions, 1 deletions
diff --git a/omx/gstomx.c b/omx/gstomx.c index 3c0953b..121e97c 100644 --- a/omx/gstomx.c +++ b/omx/gstomx.c @@ -2554,6 +2554,17 @@ gst_omx_port_wait_buffers_released (GstOMXPort * port, GstClockTime timeout) return err; } +void +gst_omx_port_requeue_buffer (GstOMXPort * port, GstOMXBuffer * buf) +{ + g_mutex_lock (&port->comp->lock); + g_queue_push_tail (&port->pending_buffers, buf); + g_mutex_unlock (&port->comp->lock); + + /* awake gst_omx_port_acquire_buffer() */ + gst_omx_component_send_message (port->comp, NULL); +} + /* NOTE: Uses comp->lock and comp->messages_lock */ OMX_ERRORTYPE gst_omx_port_set_enabled (GstOMXPort * port, gboolean enabled) diff --git a/omx/gstomx.h b/omx/gstomx.h index d61303c..4b61343 100644 --- a/omx/gstomx.h +++ b/omx/gstomx.h @@ -461,6 +461,7 @@ OMX_ERRORTYPE gst_omx_port_use_eglimages (GstOMXPort *port, const GList *ima OMX_ERRORTYPE gst_omx_port_deallocate_buffers (GstOMXPort *port); OMX_ERRORTYPE gst_omx_port_populate (GstOMXPort *port); OMX_ERRORTYPE gst_omx_port_wait_buffers_released (GstOMXPort * port, GstClockTime timeout); +void gst_omx_port_requeue_buffer (GstOMXPort * port, GstOMXBuffer * buf); OMX_ERRORTYPE gst_omx_port_mark_reconfigured (GstOMXPort * port); diff --git a/omx/gstomxbufferpool.c b/omx/gstomxbufferpool.c index 910f3ff..9700cd6 100644 --- a/omx/gstomxbufferpool.c +++ b/omx/gstomxbufferpool.c @@ -669,7 +669,7 @@ gst_omx_buffer_pool_release_buffer (GstBufferPool * bpool, GstBuffer * buffer) gst_omx_error_to_string (err), err)); } } else if (pool->port->port_def.eDir == OMX_DirInput) { - g_queue_push_tail (&pool->port->pending_buffers, omx_buf); + gst_omx_port_requeue_buffer (pool->port, omx_buf); } } } |