diff options
Diffstat (limited to 'omx/gstomx_base_src.c')
| -rw-r--r-- | omx/gstomx_base_src.c | 586 |
1 files changed, 272 insertions, 314 deletions
diff --git a/omx/gstomx_base_src.c b/omx/gstomx_base_src.c index 37b29f9..b83a52d 100644 --- a/omx/gstomx_base_src.c +++ b/omx/gstomx_base_src.c @@ -22,402 +22,362 @@ #include "gstomx_base_src.h" #include "gstomx.h" -#include <string.h> /* for memcpy */ +#include <string.h> /* for memcpy */ enum { - ARG_NUM_OUTPUT_BUFFERS = GSTOMX_NUM_COMMON_PROP, + ARG_NUM_OUTPUT_BUFFERS = GSTOMX_NUM_COMMON_PROP, }; -GSTOMX_BOILERPLATE (GstOmxBaseSrc, gst_omx_base_src, GstBaseSrc, GST_TYPE_BASE_SRC); +GSTOMX_BOILERPLATE (GstOmxBaseSrc, gst_omx_base_src, GstBaseSrc, + GST_TYPE_BASE_SRC); static void -setup_ports (GstOmxBaseSrc *self) +setup_ports (GstOmxBaseSrc * self) { - /* Input port configuration. */ - g_omx_port_setup (self->out_port); + /* Input port configuration. */ + g_omx_port_setup (self->out_port); - if (self->setup_ports) - { - self->setup_ports (self); - } + if (self->setup_ports) { + self->setup_ports (self); + } } static gboolean -start (GstBaseSrc *gst_base) +start (GstBaseSrc * gst_base) { - GstOmxBaseSrc *self; + GstOmxBaseSrc *self; - self = GST_OMX_BASE_SRC (gst_base); + self = GST_OMX_BASE_SRC (gst_base); - GST_LOG_OBJECT (self, "begin"); + GST_LOG_OBJECT (self, "begin"); - if (self->gomx->omx_error) - return GST_STATE_CHANGE_FAILURE; + if (self->gomx->omx_error) + return GST_STATE_CHANGE_FAILURE; - GST_LOG_OBJECT (self, "end"); + GST_LOG_OBJECT (self, "end"); - return TRUE; + return TRUE; } static gboolean -stop (GstBaseSrc *gst_base) +stop (GstBaseSrc * gst_base) { - GstOmxBaseSrc *self; + GstOmxBaseSrc *self; - self = GST_OMX_BASE_SRC (gst_base); + self = GST_OMX_BASE_SRC (gst_base); - GST_LOG_OBJECT (self, "begin"); + GST_LOG_OBJECT (self, "begin"); - g_omx_core_stop (self->gomx); - g_omx_core_unload (self->gomx); + g_omx_core_stop (self->gomx); + g_omx_core_unload (self->gomx); - if (self->gomx->omx_error) - return GST_STATE_CHANGE_FAILURE; + if (self->gomx->omx_error) + return GST_STATE_CHANGE_FAILURE; - GST_LOG_OBJECT (self, "end"); + GST_LOG_OBJECT (self, "end"); - return TRUE; + return TRUE; } static void -finalize (GObject *obj) +finalize (GObject * obj) { - GstOmxBaseSrc *self; + GstOmxBaseSrc *self; - self = GST_OMX_BASE_SRC (obj); + self = GST_OMX_BASE_SRC (obj); - g_omx_core_free (self->gomx); + g_omx_core_free (self->gomx); - G_OBJECT_CLASS (parent_class)->finalize (obj); + G_OBJECT_CLASS (parent_class)->finalize (obj); } static GstFlowReturn -create (GstBaseSrc *gst_base, - guint64 offset, - guint length, - GstBuffer **ret_buf) +create (GstBaseSrc * gst_base, + guint64 offset, guint length, GstBuffer ** ret_buf) { - GOmxCore *gomx; - GOmxPort *out_port; - GstOmxBaseSrc *self; - GstFlowReturn ret = GST_FLOW_OK; + GOmxCore *gomx; + GOmxPort *out_port; + GstOmxBaseSrc *self; + GstFlowReturn ret = GST_FLOW_OK; - self = GST_OMX_BASE_SRC (gst_base); + self = GST_OMX_BASE_SRC (gst_base); - gomx = self->gomx; + gomx = self->gomx; - GST_LOG_OBJECT (self, "begin"); + GST_LOG_OBJECT (self, "begin"); - GST_LOG_OBJECT (self, "state: %d", gomx->omx_state); + GST_LOG_OBJECT (self, "state: %d", gomx->omx_state); - if (gomx->omx_state == OMX_StateLoaded) - { - GST_INFO_OBJECT (self, "omx: prepare"); + if (gomx->omx_state == OMX_StateLoaded) { + GST_INFO_OBJECT (self, "omx: prepare"); - setup_ports (self); - g_omx_core_prepare (self->gomx); + setup_ports (self); + g_omx_core_prepare (self->gomx); + } + + out_port = self->out_port; + + while (out_port->enabled) { + switch (gomx->omx_state) { + case OMX_StateIdle: + { + GST_INFO_OBJECT (self, "omx: play"); + g_omx_core_start (gomx); + } + break; + default: + break; } - out_port = self->out_port; + switch (gomx->omx_state) { + case OMX_StateExecuting: + /* OK */ + break; + default: + GST_ERROR_OBJECT (self, "Whoa! very wrong"); + break; + } - while (out_port->enabled) { - switch (gomx->omx_state) - { - case OMX_StateIdle: - { - GST_INFO_OBJECT (self, "omx: play"); - g_omx_core_start (gomx); - } - break; - default: - break; - } + OMX_BUFFERHEADERTYPE *omx_buffer; - switch (gomx->omx_state) - { - case OMX_StateExecuting: - /* OK */ - break; - default: - GST_ERROR_OBJECT (self, "Whoa! very wrong"); - break; - } + GST_LOG_OBJECT (self, "request_buffer"); + omx_buffer = g_omx_port_request_buffer (out_port); - { - OMX_BUFFERHEADERTYPE *omx_buffer; + if (omx_buffer) { + GST_DEBUG_OBJECT (self, "omx_buffer: size=%lu, len=%lu, offset=%lu", + omx_buffer->nAllocLen, omx_buffer->nFilledLen, omx_buffer->nOffset); - GST_LOG_OBJECT (self, "request_buffer"); - omx_buffer = g_omx_port_request_buffer (out_port); + if (omx_buffer->nFlags & OMX_BUFFERFLAG_EOS) { + GST_INFO_OBJECT (self, "got eos"); + g_omx_core_set_done (gomx); + break; + } - if (omx_buffer) - { - GST_DEBUG_OBJECT (self, "omx_buffer: size=%lu, len=%lu, offset=%lu", - omx_buffer->nAllocLen, omx_buffer->nFilledLen, omx_buffer->nOffset); + if (omx_buffer->nFilledLen > 0) { + GstBuffer *buf; - if (omx_buffer->nFlags & OMX_BUFFERFLAG_EOS) - { - GST_INFO_OBJECT (self, "got eos"); - g_omx_core_set_done (gomx); - break; - } + if (out_port->enabled) { + GstCaps *caps = NULL; - if (omx_buffer->nFilledLen > 0) - { - GstBuffer *buf; + caps = gst_pad_get_negotiated_caps (gst_base->srcpad); - if (out_port->enabled) - { - GstCaps *caps = NULL; + if (!caps) { + /** @todo We shouldn't be doing this. */ + GST_WARNING_OBJECT (self, "somebody didn't do his work"); + gomx->settings_changed_cb (gomx); + } else { + GST_LOG_OBJECT (self, "caps already fixed"); + gst_caps_unref (caps); + } + } - caps = gst_pad_get_negotiated_caps (gst_base->srcpad); + buf = omx_buffer->pAppPrivate; - if (!caps) - { - /** @todo We shouldn't be doing this. */ - GST_WARNING_OBJECT (self, "somebody didn't do his work"); - gomx->settings_changed_cb (gomx); - } - else - { - GST_LOG_OBJECT (self, "caps already fixed"); - gst_caps_unref (caps); - } - } - - buf = omx_buffer->pAppPrivate; - - if (buf && !(omx_buffer->nFlags & OMX_BUFFERFLAG_EOS)) - { - GST_BUFFER_SIZE (buf) = omx_buffer->nFilledLen; + if (buf && !(omx_buffer->nFlags & OMX_BUFFERFLAG_EOS)) { + GST_BUFFER_SIZE (buf) = omx_buffer->nFilledLen; #if 0 - if (self->use_timestamps) - { - GST_BUFFER_TIMESTAMP (buf) = omx_buffer->nTimeStamp * (GST_SECOND / OMX_TICKS_PER_SECOND); - } + if (self->use_timestamps) { + GST_BUFFER_TIMESTAMP (buf) = + omx_buffer->nTimeStamp * (GST_SECOND / OMX_TICKS_PER_SECOND); + } #endif - omx_buffer->pAppPrivate = NULL; - omx_buffer->pBuffer = NULL; - omx_buffer->nFilledLen = 0; - - *ret_buf = buf; - - gst_buffer_unref (buf); - } - else - { - /* This is only meant for the first OpenMAX buffers, - * which need to be pre-allocated. */ - /* Also for the very last one. */ - gst_pad_alloc_buffer_and_set_caps (gst_base->srcpad, - GST_BUFFER_OFFSET_NONE, - omx_buffer->nFilledLen, - GST_PAD_CAPS (gst_base->srcpad), - &buf); - - if (buf) - { - GST_WARNING_OBJECT (self, "couldn't zero-copy"); - memcpy (GST_BUFFER_DATA (buf), omx_buffer->pBuffer + omx_buffer->nOffset, omx_buffer->nFilledLen); + omx_buffer->pAppPrivate = NULL; + omx_buffer->pBuffer = NULL; + omx_buffer->nFilledLen = 0; + + *ret_buf = buf; + + gst_buffer_unref (buf); + } else { + /* This is only meant for the first OpenMAX buffers, + * which need to be pre-allocated. */ + /* Also for the very last one. */ + gst_pad_alloc_buffer_and_set_caps (gst_base->srcpad, + GST_BUFFER_OFFSET_NONE, + omx_buffer->nFilledLen, GST_PAD_CAPS (gst_base->srcpad), &buf); + + if (buf) { + GST_WARNING_OBJECT (self, "couldn't zero-copy"); + memcpy (GST_BUFFER_DATA (buf), + omx_buffer->pBuffer + omx_buffer->nOffset, + omx_buffer->nFilledLen); #if 0 - if (self->use_timestamps) - { - GST_BUFFER_TIMESTAMP (buf) = omx_buffer->nTimeStamp * (GST_SECOND / OMX_TICKS_PER_SECOND); - } + if (self->use_timestamps) { + GST_BUFFER_TIMESTAMP (buf) = + omx_buffer->nTimeStamp * (GST_SECOND / + OMX_TICKS_PER_SECOND); + } #endif - omx_buffer->nFilledLen = 0; - g_free (omx_buffer->pBuffer); - omx_buffer->pBuffer = NULL; - - *ret_buf = buf; - } - else - { - GST_ERROR_OBJECT (self, "whoa!"); - } - } - - if (!omx_buffer->pBuffer) - { - GstBuffer *new_buf; - GstFlowReturn result; - - GST_LOG_OBJECT (self, "allocate buffer"); - result = gst_pad_alloc_buffer_and_set_caps (gst_base->srcpad, - GST_BUFFER_OFFSET_NONE, - omx_buffer->nAllocLen, - GST_PAD_CAPS (gst_base->srcpad), - &new_buf); - - if (result == GST_FLOW_OK) - { - gst_buffer_ref (new_buf); - omx_buffer->pAppPrivate = new_buf; - - omx_buffer->pBuffer = GST_BUFFER_DATA (new_buf); - omx_buffer->nAllocLen = GST_BUFFER_SIZE (new_buf); - } - else - { - GST_WARNING_OBJECT (self, "could not allocate buffer"); - omx_buffer->pBuffer = g_malloc (omx_buffer->nAllocLen); - } - } - - GST_LOG_OBJECT (self, "release_buffer"); - g_omx_port_release_buffer (out_port, omx_buffer); - break; - } - else - { - GST_WARNING_OBJECT (self, "empty buffer"); - GST_LOG_OBJECT (self, "release_buffer"); - g_omx_port_release_buffer (out_port, omx_buffer); - continue; - } + omx_buffer->nFilledLen = 0; + g_free (omx_buffer->pBuffer); + omx_buffer->pBuffer = NULL; + + *ret_buf = buf; + } else { + GST_ERROR_OBJECT (self, "whoa!"); } - else - { - GST_WARNING_OBJECT (self, "null buffer"); - /* ret = GST_FLOW_ERROR; */ - break; + } + + if (!omx_buffer->pBuffer) { + GstBuffer *new_buf; + GstFlowReturn result; + + GST_LOG_OBJECT (self, "allocate buffer"); + result = gst_pad_alloc_buffer_and_set_caps (gst_base->srcpad, + GST_BUFFER_OFFSET_NONE, + omx_buffer->nAllocLen, + GST_PAD_CAPS (gst_base->srcpad), &new_buf); + + if (result == GST_FLOW_OK) { + gst_buffer_ref (new_buf); + omx_buffer->pAppPrivate = new_buf; + + omx_buffer->pBuffer = GST_BUFFER_DATA (new_buf); + omx_buffer->nAllocLen = GST_BUFFER_SIZE (new_buf); + } else { + GST_WARNING_OBJECT (self, "could not allocate buffer"); + omx_buffer->pBuffer = g_malloc (omx_buffer->nAllocLen); } + } + + GST_LOG_OBJECT (self, "release_buffer"); + g_omx_port_release_buffer (out_port, omx_buffer); + break; + } else { + GST_WARNING_OBJECT (self, "empty buffer"); + GST_LOG_OBJECT (self, "release_buffer"); + g_omx_port_release_buffer (out_port, omx_buffer); + continue; } + } else { + GST_WARNING_OBJECT (self, "null buffer"); + /* ret = GST_FLOW_ERROR; */ + break; + } } + } - if (!out_port->enabled) - { - GST_WARNING_OBJECT (self, "done"); - ret = GST_FLOW_UNEXPECTED; - } + if (!out_port->enabled) { + GST_WARNING_OBJECT (self, "done"); + ret = GST_FLOW_UNEXPECTED; + } - GST_LOG_OBJECT (self, "end"); + GST_LOG_OBJECT (self, "end"); - return ret; + return ret; } static gboolean -handle_event (GstBaseSrc *gst_base, - GstEvent *event) +handle_event (GstBaseSrc * gst_base, GstEvent * event) { - GstOmxBaseSrc *self; + GstOmxBaseSrc *self; - self = GST_OMX_BASE_SRC (gst_base); + self = GST_OMX_BASE_SRC (gst_base); - GST_LOG_OBJECT (self, "begin"); + GST_LOG_OBJECT (self, "begin"); - GST_DEBUG_OBJECT (self, "event: %s", GST_EVENT_TYPE_NAME (event)); + GST_DEBUG_OBJECT (self, "event: %s", GST_EVENT_TYPE_NAME (event)); - switch (GST_EVENT_TYPE (event)) - { - case GST_EVENT_EOS: - /* Close the output port. */ - g_omx_core_set_done (self->gomx); - break; + switch (GST_EVENT_TYPE (event)) { + case GST_EVENT_EOS: + /* Close the output port. */ + g_omx_core_set_done (self->gomx); + break; - case GST_EVENT_NEWSEGMENT: - break; + case GST_EVENT_NEWSEGMENT: + break; - default: - break; - } + default: + break; + } - GST_LOG_OBJECT (self, "end"); + GST_LOG_OBJECT (self, "end"); - return TRUE; + return TRUE; } static void -set_property (GObject *obj, - guint prop_id, - const GValue *value, - GParamSpec *pspec) +set_property (GObject * obj, + guint prop_id, const GValue * value, GParamSpec * pspec) { - GstOmxBaseSrc *self; + GstOmxBaseSrc *self; - self = GST_OMX_BASE_SRC (obj); + self = GST_OMX_BASE_SRC (obj); - switch (prop_id) + switch (prop_id) { + case ARG_NUM_OUTPUT_BUFFERS: { - case ARG_NUM_OUTPUT_BUFFERS: - { - OMX_PARAM_PORTDEFINITIONTYPE param; - OMX_HANDLETYPE omx_handle = self->gomx->omx_handle; - OMX_U32 nBufferCountActual; + OMX_PARAM_PORTDEFINITIONTYPE param; + OMX_HANDLETYPE omx_handle = self->gomx->omx_handle; + OMX_U32 nBufferCountActual; - if (G_UNLIKELY (omx_handle)) - { - GST_WARNING_OBJECT (self, "no component"); - break; - } + if (G_UNLIKELY (omx_handle)) { + GST_WARNING_OBJECT (self, "no component"); + break; + } - nBufferCountActual = g_value_get_uint (value); + nBufferCountActual = g_value_get_uint (value); - G_OMX_INIT_PARAM (param); + G_OMX_INIT_PARAM (param); - param.nPortIndex = self->out_port->port_index; - OMX_GetParameter (omx_handle, OMX_IndexParamPortDefinition, ¶m); + param.nPortIndex = self->out_port->port_index; + OMX_GetParameter (omx_handle, OMX_IndexParamPortDefinition, ¶m); - if (nBufferCountActual < param.nBufferCountMin) - { - GST_ERROR_OBJECT (self, "buffer count %lu is less than minimum %lu", - nBufferCountActual, param.nBufferCountMin); - return; - } + if (nBufferCountActual < param.nBufferCountMin) { + GST_ERROR_OBJECT (self, "buffer count %lu is less than minimum %lu", + nBufferCountActual, param.nBufferCountMin); + return; + } - param.nBufferCountActual = nBufferCountActual; + param.nBufferCountActual = nBufferCountActual; - OMX_SetParameter (omx_handle, OMX_IndexParamPortDefinition, ¶m); - } - break; - default: - G_OBJECT_WARN_INVALID_PROPERTY_ID (obj, prop_id, pspec); - break; + OMX_SetParameter (omx_handle, OMX_IndexParamPortDefinition, ¶m); } + break; + default: + G_OBJECT_WARN_INVALID_PROPERTY_ID (obj, prop_id, pspec); + break; + } } static void -get_property (GObject *obj, - guint prop_id, - GValue *value, - GParamSpec *pspec) +get_property (GObject * obj, guint prop_id, GValue * value, GParamSpec * pspec) { - GstOmxBaseSrc *self; + GstOmxBaseSrc *self; - self = GST_OMX_BASE_SRC (obj); + self = GST_OMX_BASE_SRC (obj); - if (gstomx_get_property_helper (self->gomx, prop_id, value)) - return; + if (gstomx_get_property_helper (self->gomx, prop_id, value)) + return; - switch (prop_id) + switch (prop_id) { + case ARG_NUM_OUTPUT_BUFFERS: { - case ARG_NUM_OUTPUT_BUFFERS: - { - OMX_PARAM_PORTDEFINITIONTYPE param; - OMX_HANDLETYPE omx_handle = self->gomx->omx_handle; + OMX_PARAM_PORTDEFINITIONTYPE param; + OMX_HANDLETYPE omx_handle = self->gomx->omx_handle; - if (G_UNLIKELY (!omx_handle)) - { - GST_WARNING_OBJECT (self, "no component"); - g_value_set_uint (value, 0); - break; - } + if (G_UNLIKELY (!omx_handle)) { + GST_WARNING_OBJECT (self, "no component"); + g_value_set_uint (value, 0); + break; + } - G_OMX_INIT_PARAM (param); + G_OMX_INIT_PARAM (param); - param.nPortIndex = self->out_port->port_index; - OMX_GetParameter (omx_handle, OMX_IndexParamPortDefinition, ¶m); + param.nPortIndex = self->out_port->port_index; + OMX_GetParameter (omx_handle, OMX_IndexParamPortDefinition, ¶m); - g_value_set_uint (value, param.nBufferCountActual); - } - break; - default: - G_OBJECT_WARN_INVALID_PROPERTY_ID (obj, prop_id, pspec); - break; + g_value_set_uint (value, param.nBufferCountActual); } + break; + default: + G_OBJECT_WARN_INVALID_PROPERTY_ID (obj, prop_id, pspec); + break; + } } static void @@ -426,48 +386,46 @@ type_base_init (gpointer g_class) } static void -type_class_init (gpointer g_class, - gpointer class_data) +type_class_init (gpointer g_class, gpointer class_data) { - GObjectClass *gobject_class; - GstBaseSrcClass *gst_base_src_class; + GObjectClass *gobject_class; + GstBaseSrcClass *gst_base_src_class; - gobject_class = G_OBJECT_CLASS (g_class); - gst_base_src_class = GST_BASE_SRC_CLASS (g_class); + gobject_class = G_OBJECT_CLASS (g_class); + gst_base_src_class = GST_BASE_SRC_CLASS (g_class); - gobject_class->finalize = finalize; + gobject_class->finalize = finalize; - gst_base_src_class->start = start; - gst_base_src_class->stop = stop; - gst_base_src_class->event = handle_event; - gst_base_src_class->create = create; + gst_base_src_class->start = start; + gst_base_src_class->stop = stop; + gst_base_src_class->event = handle_event; + gst_base_src_class->create = create; - /* Properties stuff */ - { - gobject_class->set_property = set_property; - gobject_class->get_property = get_property; + /* Properties stuff */ + { + gobject_class->set_property = set_property; + gobject_class->get_property = get_property; - gstomx_install_property_helper (gobject_class); + gstomx_install_property_helper (gobject_class); - g_object_class_install_property (gobject_class, ARG_NUM_OUTPUT_BUFFERS, - g_param_spec_uint ("output-buffers", "Output buffers", - "The number of OMX output buffers", - 1, 10, 4, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS)); - } + g_object_class_install_property (gobject_class, ARG_NUM_OUTPUT_BUFFERS, + g_param_spec_uint ("output-buffers", "Output buffers", + "The number of OMX output buffers", + 1, 10, 4, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS)); + } } static void -type_instance_init (GTypeInstance *instance, - gpointer g_class) +type_instance_init (GTypeInstance * instance, gpointer g_class) { - GstOmxBaseSrc *self; + GstOmxBaseSrc *self; - self = GST_OMX_BASE_SRC (instance); + self = GST_OMX_BASE_SRC (instance); - GST_LOG_OBJECT (self, "begin"); + GST_LOG_OBJECT (self, "begin"); - self->gomx = gstomx_core_new (self, G_TYPE_FROM_CLASS (g_class)); - self->out_port = g_omx_core_new_port (self->gomx, 1); + self->gomx = gstomx_core_new (self, G_TYPE_FROM_CLASS (g_class)); + self->out_port = g_omx_core_new_port (self->gomx, 1); - GST_LOG_OBJECT (self, "end"); + GST_LOG_OBJECT (self, "end"); } |