FaSTTUBe/GST-Tensordecoder-ov_ep
61
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

imagefreeze: Return GST_FLOW_UNEXPECTED when getting a second buffer

Browse Source 
This prevents upstream from pushing many useless buffers and makes
it go into EOS state.
This commit is contained in:
Sebastian Dröge 2010-08-11 08:46:14 +02:00
parent 134b1f0eee
commit dffab828c6
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
gst/imagefreeze/gstimagefreeze.c
View File

@ -332,8 +332,8 @@ gst_image_freeze_sink_bufferalloc (GstPad * pad, guint64 offset, guint size,
GST_ERROR_OBJECT (pad, "Allocating buffer failed: %s", GST_ERROR_OBJECT (pad, "Allocating buffer failed: %s",
gst_flow_get_name (ret)); gst_flow_get_name (ret));
} else { } else {
/* In this case GstPad will allocate a buffer for us */ /* Let upstream go EOS if we already have a buffer */
ret = GST_FLOW_OK; ret = GST_FLOW_UNEXPECTED;
} }
gst_object_unref (self); gst_object_unref (self);
@ -687,14 +687,13 @@ static GstFlowReturn
gst_image_freeze_sink_chain (GstPad * pad, GstBuffer * buffer) gst_image_freeze_sink_chain (GstPad * pad, GstBuffer * buffer)
{ {
GstImageFreeze *self = GST_IMAGE_FREEZE (GST_PAD_PARENT (pad)); GstImageFreeze *self = GST_IMAGE_FREEZE (GST_PAD_PARENT (pad));
GstFlowReturn ret = GST_FLOW_OK;
GST_OBJECT_LOCK (self); GST_OBJECT_LOCK (self);
if (self->buffer) { if (self->buffer) {
GST_DEBUG_OBJECT (pad, "Already have a buffer, dropping"); GST_DEBUG_OBJECT (pad, "Already have a buffer, dropping");
gst_buffer_unref (buffer); gst_buffer_unref (buffer);
GST_OBJECT_UNLOCK (self); GST_OBJECT_UNLOCK (self);
return ret; return GST_FLOW_UNEXPECTED;
} }
self->buffer = buffer; self->buffer = buffer;
@ -702,7 +701,7 @@ gst_image_freeze_sink_chain (GstPad * pad, GstBuffer * buffer)
gst_pad_start_task (self->srcpad, (GstTaskFunction) gst_image_freeze_src_loop, gst_pad_start_task (self->srcpad, (GstTaskFunction) gst_image_freeze_src_loop,
self->srcpad); self->srcpad);
return ret; return GST_FLOW_OK;
} }
static void static void