mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-01-31 11:32:38 +00:00
Code Issues 1 Projects Releases Wiki Activity

fsvalve: Use do the alloc_buffer function in the valve

Browse source 
20071219005739-3e2dc-2a0fdfa2f38f03ab4791fe5c4ab85e8790113683.gz
This commit is contained in:
Olivier Crete 2007-12-19 00:57:39 +00:00 committed by Tim-Philipp Müller
parent 67c6adaf31
commit 6db2a426c1
2 changed files with 41 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

43
plugins/elements/gstvalve.c
View file

@ -74,10 +74,11 @@ static void gst_valve_get_property (GObject *object,
guint prop_id, GValue *value, GParamSpec *pspec); guint prop_id, GValue *value, GParamSpec *pspec);
static void gst_valve_dispose (GObject *object); static void gst_valve_dispose (GObject *object);
static GstFlowReturn static GstFlowReturn gst_valve_transform_ip (GstBaseTransform *trans,
gst_valve_transform_ip (GstBaseTransform *trans, GstBuffer *buf); GstBuffer *buf);
static gboolean static gboolean gst_valve_event (GstBaseTransform *trans, GstEvent *event);
gst_valve_event (GstBaseTransform *trans, GstEvent *event); static GstFlowReturn gst_valve_buffer_alloc (GstPad * pad, guint64 offset,
guint size, GstCaps * caps, GstBuffer ** buf);
static void static void
@ -139,6 +140,14 @@ gst_valve_init (GstValve *valve, GstValveClass *klass)
valve->drop = 0; valve->drop = 0;
valve->original_allocfunc =
GST_BASE_TRANSFORM (valve)->sinkpad->bufferallocfunc;
gst_pad_set_bufferalloc_function (
GST_BASE_TRANSFORM (valve)->sinkpad,
GST_DEBUG_FUNCPTR(gst_valve_buffer_alloc));
#if GST_VERSION_MINOR >= 10 && GST_VERSION_MICRO >= 13 #if GST_VERSION_MINOR >= 10 && GST_VERSION_MICRO >= 13
gst_base_transform_set_passthrough ((GstBaseTransform *)valve, TRUE); gst_base_transform_set_passthrough ((GstBaseTransform *)valve, TRUE);
#endif #endif
@ -223,6 +232,32 @@ gst_valve_event (GstBaseTransform *trans, GstEvent *event)
return ret; return ret;
} }
static GstFlowReturn
gst_valve_buffer_alloc (GstPad * pad, guint64 offset, guint size,
GstCaps * caps, GstBuffer ** buf)
{
GstValve *valve = GST_VALVE (gst_pad_get_parent_element (pad));
GstFlowReturn ret = GST_FLOW_OK;
GST_OBJECT_LOCK (GST_OBJECT (valve));
if (valve->drop)
{
*buf = gst_buffer_new_and_alloc (size);
GST_BUFFER_OFFSET (*buf) = offset;
gst_buffer_set_caps (*buf, caps);
}
else
{
ret = valve->original_allocfunc (pad, offset, size, caps, buf);
}
GST_OBJECT_UNLOCK (GST_OBJECT (valve));
gst_object_unref (valve);
return ret;
}
gboolean gboolean
gst_valve_plugin_init (GstPlugin *plugin) gst_valve_plugin_init (GstPlugin *plugin)
{ {

2
plugins/elements/gstvalve.h
View file

@ -54,6 +54,8 @@ struct _GstValve
gboolean drop; gboolean drop;
GstPadBufferAllocFunction original_allocfunc;
/*< private > */ /*< private > */
gpointer _gst_reserved[GST_PADDING]; gpointer _gst_reserved[GST_PADDING];
}; };