/* * Siren Decoder Gst Element * * @author: Youness Alaoui * * 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 "gstsirendec.h" #include GST_DEBUG_CATEGORY (sirendec_debug); #define GST_CAT_DEFAULT (sirendec_debug) /* elementfactory information */ static const GstElementDetails gst_siren_dec_details = GST_ELEMENT_DETAILS ( "Siren Decoder element", "Codec/Decoder/Audio ", "Decode streams encoded with the Siren7 codec into 16bit PCM", "Youness Alaoui "); static GstStaticPadTemplate sinktemplate = GST_STATIC_PAD_TEMPLATE ("sink", GST_PAD_SINK, GST_PAD_ALWAYS, GST_STATIC_CAPS ("audio/x-siren, " "dct-length = (int) 320")); static GstStaticPadTemplate srctemplate = GST_STATIC_PAD_TEMPLATE ("src", GST_PAD_SRC, GST_PAD_ALWAYS, GST_STATIC_CAPS ("audio/x-raw-int, " "width = (int) 16, " "depth = (int) 16, " "endianness = (int) 1234, " "signed = (boolean) true, " "rate = (int) 16000, " "channels = (int) 1")); /* signals and args */ enum { /* FILL ME */ LAST_SIGNAL }; enum { ARG_0, }; static void gst_siren_dec_dispose (GObject *object); static GstFlowReturn gst_siren_dec_transform (GstBaseTransform *trans, GstBuffer *inbuf, GstBuffer *outbuf); static gboolean gst_siren_dec_transform_size (GstBaseTransform *trans, GstPadDirection direction, GstCaps *caps, guint size, GstCaps *othercaps, guint *othersize); static GstCaps * gst_siren_dec_transform_caps (GstBaseTransform * base, GstPadDirection direction, GstCaps * caps); static gboolean gst_siren_dec_start (GstBaseTransform *trans); static gboolean gst_siren_dec_stop (GstBaseTransform *trans); static void _do_init (GType type) { GST_DEBUG_CATEGORY_INIT (sirendec_debug, "sirendec", 0, "sirendec"); } GST_BOILERPLATE_FULL (GstSirenDec, gst_siren_dec, GstBaseTransform, GST_TYPE_BASE_TRANSFORM, _do_init); static void gst_siren_dec_base_init (gpointer klass) { GstElementClass *element_class = GST_ELEMENT_CLASS (klass); 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_siren_dec_details); } static void gst_siren_dec_class_init (GstSirenDecClass *klass) { GObjectClass *gobject_class; GstBaseTransformClass *gstbasetransform_class; gobject_class = (GObjectClass *) klass; gstbasetransform_class = (GstBaseTransformClass *) klass; GST_DEBUG ("Initializing Class"); gobject_class->dispose = GST_DEBUG_FUNCPTR (gst_siren_dec_dispose); gstbasetransform_class->transform = GST_DEBUG_FUNCPTR (gst_siren_dec_transform); gstbasetransform_class->transform_caps = GST_DEBUG_FUNCPTR (gst_siren_dec_transform_caps); gstbasetransform_class->transform_size = GST_DEBUG_FUNCPTR (gst_siren_dec_transform_size); gstbasetransform_class->start = GST_DEBUG_FUNCPTR (gst_siren_dec_start); gstbasetransform_class->stop = GST_DEBUG_FUNCPTR (gst_siren_dec_stop); parent_class = g_type_class_peek_parent (klass); GST_DEBUG ("Class Init done"); } static void gst_siren_dec_init (GstSirenDec *dec, GstSirenDecClass *klass) { GST_DEBUG_OBJECT (dec, "Initializing"); dec->decoder = NULL; dec->adapter = gst_adapter_new (); GST_DEBUG_OBJECT (dec, "Init done"); } static void gst_siren_dec_dispose (GObject *object) { GstSirenDec *dec = GST_SIREN_DEC (object); GST_DEBUG_OBJECT (dec, "Disposing"); if (dec->decoder) { Siren7_CloseDecoder (dec->decoder); dec->decoder = NULL; } if (dec->adapter) { g_object_unref (dec->adapter); dec->adapter = NULL; } G_OBJECT_CLASS (parent_class)->dispose (object); } static gboolean gst_siren_dec_start (GstBaseTransform *trans) { GstSirenDec *dec = GST_SIREN_DEC (trans); GST_DEBUG ("Start"); if (dec->decoder) { Siren7_CloseDecoder (dec->decoder); dec->decoder = NULL; } dec->decoder = Siren7_NewDecoder (16000); gst_adapter_clear (dec->adapter); return dec->decoder != NULL; } static gboolean gst_siren_dec_stop (GstBaseTransform *trans) { GstSirenDec *dec = GST_SIREN_DEC (trans); GST_DEBUG ("Stop"); if (dec->decoder) { Siren7_CloseDecoder (dec->decoder); dec->decoder = NULL; } gst_adapter_clear (dec->adapter); return TRUE; } static gboolean gst_siren_dec_transform_size (GstBaseTransform *trans, GstPadDirection direction, GstCaps *caps, guint size, GstCaps *othercaps, guint *othersize) { GstSirenDec *dec = GST_SIREN_DEC (trans); GstStructure *structure = NULL; const gchar *in_name = NULL; const gchar *out_name = NULL; gboolean decoding; if (caps != NULL && othercaps != NULL) { structure = gst_caps_get_structure (caps, 0); in_name = gst_structure_get_name (structure); structure = gst_caps_get_structure (othercaps, 0); out_name = gst_structure_get_name (structure); } GST_DEBUG ("Transform size from caps '%s' to '%s'", in_name, out_name); if (in_name == NULL || out_name == NULL) { if (direction == GST_PAD_SINK) decoding = TRUE; else decoding = FALSE; } else if (strcmp (in_name, "audio/x-raw-int") == 0 && strcmp (out_name, "audio/x-siren") == 0 ) { decoding = FALSE; } else if (strcmp (in_name, "audio/x-siren") == 0 && strcmp (out_name, "audio/x-raw-int") == 0 ) { decoding = TRUE; } else { GST_DEBUG ("Unknown in/out caps"); return FALSE; } if (decoding) { size += gst_adapter_available (dec->adapter); *othersize = size * 16; *othersize -= *othersize % 640; if ((size * 16) % 640 > 0) *othersize+= 640; } else { *othersize = size / 16; *othersize -= *othersize % 40; if ((size / 16) % 40 > 0) *othersize+= 40; } GST_DEBUG ("Transform size %d to %d", size, *othersize); return TRUE; } static GstCaps * gst_siren_dec_transform_caps (GstBaseTransform * base, GstPadDirection direction, GstCaps * caps) { GstCaps *othercaps = NULL; GST_DEBUG ("Transforming caps"); if (direction == GST_PAD_SINK) { return gst_static_pad_template_get_caps (&srctemplate); } else if (direction == GST_PAD_SRC) { return gst_static_pad_template_get_caps (&sinktemplate); } GST_DEBUG ("Transform caps"); return othercaps; } static GstFlowReturn gst_siren_dec_transform (GstBaseTransform *trans, GstBuffer *inbuf, GstBuffer *outbuf) { GstSirenDec *dec = GST_SIREN_DEC (trans); GstFlowReturn ret = GST_FLOW_OK; guint8 *data = NULL; gint offset = 0; gint decode_ret = 0; GST_LOG_OBJECT (dec, "Transform"); if (dec->decoder == NULL) { GST_DEBUG ("Siren decoder not set"); return GST_FLOW_WRONG_STATE; } if (dec->adapter == NULL) { GST_DEBUG ("Adapter not set"); return GST_FLOW_UNEXPECTED; } gst_buffer_ref (inbuf); gst_adapter_push (dec->adapter, inbuf); GST_LOG_OBJECT (dec,"Received buffer of size %d with adapter of size : %d", GST_BUFFER_SIZE (inbuf), gst_adapter_available (dec->adapter)); data = GST_BUFFER_DATA (outbuf); offset = 0; while((gst_adapter_available (dec->adapter) >= 40) && (offset + 640 <= GST_BUFFER_SIZE (outbuf)) && ret == GST_FLOW_OK) { GST_DEBUG ("Decoding frame"); decode_ret = Siren7_DecodeFrame (dec->decoder, (guint8 *) gst_adapter_peek (dec->adapter, 40), data + offset); if (decode_ret != 0) { GST_ERROR_OBJECT (dec, "Siren7_DecodeFrame returned %d", decode_ret); ret = GST_FLOW_ERROR; } gst_adapter_flush (dec->adapter, 40); offset += 640; } GST_LOG_OBJECT (dec, "Finished decoding : %d", offset); if (offset != GST_BUFFER_SIZE (outbuf)) { GST_ERROR_OBJECT (dec, "didn't decode enough : offfset (%d) != BUFFER_SIZE (%d)", offset, GST_BUFFER_SIZE (outbuf)); return GST_FLOW_ERROR; } return ret; } gboolean gst_siren_dec_plugin_init (GstPlugin *plugin) { return gst_element_register (plugin, "sirendec", GST_RANK_MARGINAL, GST_TYPE_SIREN_DEC); }