mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-06-07 07:58:51 +00:00
Code Issues 1 Projects Releases Wiki Activity

queue2: Implement gst_event_full_func handling

Browse source 
Same as we do for queue
This commit is contained in:
Edward Hervey 2016-10-08 13:54:42 +02:00 committed by Edward Hervey
parent ede686c39b
commit ace418d226
1 changed files with 10 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
plugins/elements/gstqueue2.c
View file

@ -278,8 +278,8 @@ static GstFlowReturn gst_queue2_chain_list (GstPad * pad, GstObject * parent,
static GstFlowReturn gst_queue2_push_one (GstQueue2 * queue); static GstFlowReturn gst_queue2_push_one (GstQueue2 * queue);
static void gst_queue2_loop (GstPad * pad); static void gst_queue2_loop (GstPad * pad);
static gboolean gst_queue2_handle_sink_event (GstPad * pad, GstObject * parent, static GstFlowReturn gst_queue2_handle_sink_event (GstPad * pad,
GstEvent * event); GstObject * parent, GstEvent * event);
static gboolean gst_queue2_handle_sink_query (GstPad * pad, GstObject * parent, static gboolean gst_queue2_handle_sink_query (GstPad * pad, GstObject * parent,
GstQuery * query); GstQuery * query);
@ -477,7 +477,7 @@ gst_queue2_init (GstQueue2 * queue)
GST_DEBUG_FUNCPTR (gst_queue2_chain_list)); GST_DEBUG_FUNCPTR (gst_queue2_chain_list));
gst_pad_set_activatemode_function (queue->sinkpad, gst_pad_set_activatemode_function (queue->sinkpad,
GST_DEBUG_FUNCPTR (gst_queue2_sink_activate_mode)); GST_DEBUG_FUNCPTR (gst_queue2_sink_activate_mode));
gst_pad_set_event_function (queue->sinkpad, gst_pad_set_event_full_function (queue->sinkpad,
GST_DEBUG_FUNCPTR (gst_queue2_handle_sink_event)); GST_DEBUG_FUNCPTR (gst_queue2_handle_sink_event));
gst_pad_set_query_function (queue->sinkpad, gst_pad_set_query_function (queue->sinkpad,
GST_DEBUG_FUNCPTR (gst_queue2_handle_sink_query)); GST_DEBUG_FUNCPTR (gst_queue2_handle_sink_query));
@ -2453,7 +2453,7 @@ no_item:
} }
} }
static gboolean static GstFlowReturn
gst_queue2_handle_sink_event (GstPad * pad, GstObject * parent, gst_queue2_handle_sink_event (GstPad * pad, GstObject * parent,
GstEvent * event) GstEvent * event)
{ {
@ -2584,7 +2584,9 @@ gst_queue2_handle_sink_event (GstPad * pad, GstObject * parent,
} }
break; break;
} }
return ret; if (ret == FALSE)
return GST_FLOW_ERROR;
return GST_FLOW_OK;
/* ERRORS */ /* ERRORS */
out_flushing: out_flushing:
@ -2592,14 +2594,14 @@ out_flushing:
GST_DEBUG_OBJECT (queue, "refusing event, we are flushing"); GST_DEBUG_OBJECT (queue, "refusing event, we are flushing");
GST_QUEUE2_MUTEX_UNLOCK (queue); GST_QUEUE2_MUTEX_UNLOCK (queue);
gst_event_unref (event); gst_event_unref (event);
return FALSE; return GST_FLOW_FLUSHING;
} }
out_eos: out_eos:
{ {
GST_DEBUG_OBJECT (queue, "refusing event, we are EOS"); GST_DEBUG_OBJECT (queue, "refusing event, we are EOS");
GST_QUEUE2_MUTEX_UNLOCK (queue); GST_QUEUE2_MUTEX_UNLOCK (queue);
gst_event_unref (event); gst_event_unref (event);
return FALSE; return GST_FLOW_EOS;
} }
out_flow_error: out_flow_error:
{ {
@ -2608,7 +2610,7 @@ out_flow_error:
gst_flow_get_name (queue->srcresult)); gst_flow_get_name (queue->srcresult));
GST_QUEUE2_MUTEX_UNLOCK (queue); GST_QUEUE2_MUTEX_UNLOCK (queue);
gst_event_unref (event); gst_event_unref (event);
return FALSE; return queue->srcresult;
} }
} }