/* GStreamer * Copyright (C) 1999,2000 Erik Walthinsen * 2000 Wim Taymans * 2005 Wim Taymans * 2005 David Schleef * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Library General Public * License as published by the Free Software Foundation; either * version 2 of the License, or (at your option) any later version. * * This library is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * Library General Public License for more details. * * You should have received a copy of the GNU Library General Public * License along with this library; if not, write to the * Free Software Foundation, Inc., 59 Temple Place - Suite 330, * Boston, MA 02111-1307, USA. */ #ifdef HAVE_CONFIG_H #include "config.h" #endif #include "../gst-i18n-lib.h" #include #include static GstElementDetails gst_capsfilter_details = GST_ELEMENT_DETAILS ("CapsFilter", "Generic", "Pass data without modification, limiting formats", "David Schleef "); #define GST_TYPE_CAPSFILTER \ (gst_capsfilter_get_type()) #define GST_CAPSFILTER(obj) \ (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_CAPSFILTER,GstCapsFilter)) #define GST_CAPSFILTER_CLASS(klass) \ (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_CAPSFILTER,GstCapsFilterClass)) #define GST_IS_CAPSFILTER(obj) \ (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_CAPSFILTER)) #define GST_IS_CAPSFILTER_CLASS(obj) \ (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_CAPSFILTER)) typedef struct _GstCapsFilter GstCapsFilter; typedef struct _GstCapsFilterClass GstCapsFilterClass; struct _GstCapsFilter { GstBaseTransform trans; GstCaps *filter_caps; }; struct _GstCapsFilterClass { GstBaseTransformClass trans_class; }; GType gst_capsfilter_get_type (void); enum { PROP_0, PROP_FILTER_CAPS }; static GstStaticPadTemplate sinktemplate = GST_STATIC_PAD_TEMPLATE ("sink", GST_PAD_SINK, GST_PAD_ALWAYS, GST_STATIC_CAPS_ANY); static GstStaticPadTemplate srctemplate = GST_STATIC_PAD_TEMPLATE ("src", GST_PAD_SRC, GST_PAD_ALWAYS, GST_STATIC_CAPS_ANY); GST_DEBUG_CATEGORY_STATIC (gst_capsfilter_debug); #define GST_CAT_DEFAULT gst_capsfilter_debug #define _do_init(bla) \ GST_DEBUG_CATEGORY_INIT (gst_capsfilter_debug, "capsfilter", 0, \ "capsfilter element"); GST_BOILERPLATE_FULL (GstCapsFilter, gst_capsfilter, GstBaseTransform, GST_TYPE_BASE_TRANSFORM, _do_init); static void gst_capsfilter_set_property (GObject * object, guint prop_id, const GValue * value, GParamSpec * pspec); static void gst_capsfilter_get_property (GObject * object, guint prop_id, GValue * value, GParamSpec * pspec); static void gst_capsfilter_dispose (GObject * object); static GstCaps *gst_capsfilter_transform_caps (GstBaseTransform * base, GstPadDirection direction, GstCaps * caps); static GstFlowReturn gst_capsfilter_transform_ip (GstBaseTransform * base, GstBuffer * buf); static GstFlowReturn gst_capsfilter_prepare_buf (GstBaseTransform * trans, GstBuffer * input, gint size, GstCaps * caps, GstBuffer ** buf); static void gst_capsfilter_base_init (gpointer g_class) { GstElementClass *element_class = GST_ELEMENT_CLASS (g_class); gst_element_class_add_pad_template (element_class, gst_static_pad_template_get (&srctemplate)); gst_element_class_add_pad_template (element_class, gst_static_pad_template_get (&sinktemplate)); gst_element_class_set_details (element_class, &gst_capsfilter_details); } static void gst_capsfilter_class_init (GstCapsFilterClass * klass) { GObjectClass *gobject_class; GstBaseTransformClass *trans_class; gobject_class = (GObjectClass *) klass; gobject_class->set_property = gst_capsfilter_set_property; gobject_class->get_property = gst_capsfilter_get_property; gobject_class->dispose = gst_capsfilter_dispose; g_object_class_install_property (G_OBJECT_CLASS (klass), PROP_FILTER_CAPS, g_param_spec_boxed ("caps", _("Filter caps"), _("Restrict the possible allowed capabilities (NULL means ANY)"), GST_TYPE_CAPS, G_PARAM_READWRITE)); trans_class = (GstBaseTransformClass *) klass; trans_class->transform_caps = gst_capsfilter_transform_caps; trans_class->transform_ip = gst_capsfilter_transform_ip; trans_class->prepare_output_buffer = gst_capsfilter_prepare_buf; } static void gst_capsfilter_init (GstCapsFilter * filter, GstCapsFilterClass * g_class) { filter->filter_caps = gst_caps_new_any (); } static void gst_capsfilter_set_property (GObject * object, guint prop_id, const GValue * value, GParamSpec * pspec) { GstCapsFilter *capsfilter = GST_CAPSFILTER (object); switch (prop_id) { case PROP_FILTER_CAPS:{ GstCaps *new_caps; GstCaps *old_caps; const GstCaps *new_caps_val = gst_value_get_caps (value); if (new_caps_val == NULL) { new_caps = gst_caps_new_any (); } else { new_caps = gst_caps_copy (new_caps_val); } old_caps = capsfilter->filter_caps; capsfilter->filter_caps = new_caps; gst_caps_unref (old_caps); GST_DEBUG_OBJECT (capsfilter, "set new caps %" GST_PTR_FORMAT, new_caps); /* FIXME: Need to activate these caps on the pads */ break; } default: G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec); break; } } static void gst_capsfilter_get_property (GObject * object, guint prop_id, GValue * value, GParamSpec * pspec) { GstCapsFilter *capsfilter = GST_CAPSFILTER (object); switch (prop_id) { case PROP_FILTER_CAPS: gst_value_set_caps (value, capsfilter->filter_caps); break; default: G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec); break; } } static void gst_capsfilter_dispose (GObject * object) { GstCapsFilter *filter = GST_CAPSFILTER (object); gst_caps_replace (&filter->filter_caps, NULL); G_OBJECT_CLASS (parent_class)->dispose (object); } static GstCaps * gst_capsfilter_transform_caps (GstBaseTransform * base, GstPadDirection direction, GstCaps * caps) { GstCapsFilter *capsfilter = GST_CAPSFILTER (base); GstCaps *ret; ret = gst_caps_intersect (caps, capsfilter->filter_caps); return ret; } static GstFlowReturn gst_capsfilter_transform_ip (GstBaseTransform * base, GstBuffer * buf) { /* No actual work here. It's all done in the prepare output buffer * func. */ return GST_FLOW_OK; } /* Output buffer preparation... if the buffer has no caps, and * our allowed output caps is fixed, then give the caps to the * buffer. * This ensures that outgoing buffers have caps if we can, so * that pipelines like: * gst-launch filesrc location=rawsamples.raw ! * audio/x-raw-int,width=16,depth=16,rate=48000,channels=2, * endianness=4321,signed='(boolean)'true ! alsasink * will work. */ static GstFlowReturn gst_capsfilter_prepare_buf (GstBaseTransform * trans, GstBuffer * input, gint size, GstCaps * caps, GstBuffer ** buf) { if (GST_BUFFER_CAPS (input) != NULL) { /* Output buffer already has caps */ GST_DEBUG_OBJECT (trans, "Input buffer already has caps"); gst_buffer_ref (input); *buf = input; } else { /* Buffer has no caps. See if the output pad only supports fixed caps */ GstCaps *out_caps; out_caps = GST_PAD_CAPS (trans->srcpad); if (out_caps != NULL) { gst_caps_ref (out_caps); } else { out_caps = gst_pad_get_allowed_caps (trans->srcpad); g_return_val_if_fail (out_caps != NULL, GST_FLOW_ERROR); } if (gst_caps_is_fixed (out_caps) && !gst_caps_is_empty (out_caps)) { GST_DEBUG_OBJECT (trans, "Have fixed output caps %" GST_PTR_FORMAT " to apply to buffer with no caps", out_caps); if (gst_buffer_is_writable (input)) { gst_buffer_ref (input); *buf = input; } else { GST_DEBUG_OBJECT (trans, "Creating sub-buffer and setting caps"); *buf = gst_buffer_create_sub (input, 0, GST_BUFFER_SIZE (input)); } GST_BUFFER_CAPS (*buf) = out_caps; if (GST_PAD_CAPS (trans->srcpad) == NULL) gst_pad_set_caps (trans->srcpad, out_caps); } else { gst_caps_unref (out_caps); } } return GST_FLOW_OK; }