mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-09-29 15:22:17 +00:00
Code Issues 1 Projects Releases Wiki Activity

basesink: drain on allocation query

Browse source 
Allows buffers to be reclaimed when caps is to be renegotiated so
that bufferpools can be stopped. As the allocation query is
serialized all buffers have been already drained from the pipeline,
except this last_sample one.

https://bugzilla.gnome.org/show_bug.cgi?id=682770
This commit is contained in:
Thiago Santos 2015-03-13 18:53:11 +00:00
parent 901fea5985
commit 5e15d4aa60
1 changed files with 14 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
libs/gst/base/gstbasesink.c
View file

@ -4805,6 +4805,18 @@ default_element_query (GstElement * element, GstQuery * query)
return res;
}
static void
gst_base_sink_drain (GstBaseSink * basesink)
{
GstBuffer *old;
GST_OBJECT_LOCK (basesink);
if ((old = basesink->priv->last_buffer))
basesink->priv->last_buffer = gst_buffer_copy_deep (old);
GST_OBJECT_UNLOCK (basesink);
if (old)
gst_buffer_unref (old);
}
static gboolean
gst_base_sink_default_query (GstBaseSink * basesink, GstQuery * query)
@ -4817,6 +4829,7 @@ gst_base_sink_default_query (GstBaseSink * basesink, GstQuery * query)
switch (GST_QUERY_TYPE (query)) {
case GST_QUERY_ALLOCATION:
{
gst_base_sink_drain (basesink);
if (bclass->propose_allocation)
res = bclass->propose_allocation (basesink, query);
else
@ -4853,14 +4866,7 @@ gst_base_sink_default_query (GstBaseSink * basesink, GstQuery * query)
}
case GST_QUERY_DRAIN:
{
GstBuffer *old;
GST_OBJECT_LOCK (basesink);
if ((old = basesink->priv->last_buffer))
basesink->priv->last_buffer = gst_buffer_copy_deep (old);
GST_OBJECT_UNLOCK (basesink);
if (old)
gst_buffer_unref (old);
gst_base_sink_drain (basesink);
res = TRUE;
break;
}