amrwb: Remove AMR-WB parser and decoder and rename encoder plugin from amrwb to amrwbenc

Partially fixes bug #584890.
This commit is contained in:
Iago Toral 2009-07-27 19:55:27 +02:00 committed by Sebastian Dröge
parent ffe90f81a4
commit 29e3908032
18 changed files with 95 additions and 1445 deletions

View file

@ -450,12 +450,12 @@ AG_GST_CHECK_FEATURE(ASSRENDER, [ASS/SSA renderer], assrender, [
AC_SUBST(ASSRENDER_CFLAGS) AC_SUBST(ASSRENDER_CFLAGS)
AC_SUBST(ASSRENDER_LIBS) AC_SUBST(ASSRENDER_LIBS)
dnl *** amrwb *** dnl *** amrwb-enc ***
translit(dnm, m, l) AM_CONDITIONAL(USE_AMRWB, true) translit(dnm, m, l) AM_CONDITIONAL(USE_AMRWB, true)
AG_GST_CHECK_FEATURE(AMRWB, [amrwb library], amrwb, [ AG_GST_CHECK_FEATURE(AMRWB, [amrwb library], amrwbenc, [
AG_GST_CHECK_LIBHEADER(AMRWB, amrwb, AG_GST_CHECK_LIBHEADER(AMRWB, amrwb,
GP3D_IF_decode, , GP3E_IF_encode, ,
amrwb/dec.h, amrwb/enc.h,
AMRWB_LIBS="-lamrwb" AMRWB_LIBS="-lamrwb"
AC_SUBST(AMRWB_LIBS)) AC_SUBST(AMRWB_LIBS))
]) ])
@ -1707,7 +1707,7 @@ tests/examples/shapewipe/Makefile
tests/examples/switch/Makefile tests/examples/switch/Makefile
tests/icles/Makefile tests/icles/Makefile
ext/alsaspdif/Makefile ext/alsaspdif/Makefile
ext/amrwb/Makefile ext/amrwbenc/Makefile
ext/assrender/Makefile ext/assrender/Makefile
ext/apexsink/Makefile ext/apexsink/Makefile
ext/bz2/Makefile ext/bz2/Makefile

View file

@ -89,9 +89,7 @@ EXAMPLE_CFILES = \
$(top_srcdir)/ext/directfb/dfb-example.c $(top_srcdir)/ext/directfb/dfb-example.c
EXTRA_HFILES = \ EXTRA_HFILES = \
$(top_srcdir)/ext/amrwb/gstamrwbdec.h \ $(top_srcdir)/ext/amrwbenc/gstamrwbenc.h \
$(top_srcdir)/ext/amrwb/gstamrwbenc.h \
$(top_srcdir)/ext/amrwb/gstamrwbparse.h \
$(top_srcdir)/ext/celt/gstceltdec.h \ $(top_srcdir)/ext/celt/gstceltdec.h \
$(top_srcdir)/ext/celt/gstceltenc.h \ $(top_srcdir)/ext/celt/gstceltenc.h \
$(top_srcdir)/ext/dc1394/gstdc1394.h \ $(top_srcdir)/ext/dc1394/gstdc1394.h \

View file

@ -19,10 +19,7 @@
<title>gst-plugins-bad Elements</title> <title>gst-plugins-bad Elements</title>
<xi:include href="xml/element-aacparse.xml" /> <xi:include href="xml/element-aacparse.xml" />
<xi:include href="xml/element-amrparse.xml" /> <xi:include href="xml/element-amrparse.xml" />
<xi:include href="xml/element-amrwbdec.xml" />
<xi:include href="xml/element-amrwbenc.xml" /> <xi:include href="xml/element-amrwbenc.xml" />
<xi:include href="xml/element-amrwbparse.xml" />
<xi:include href="xml/element-amrwbparse.xml" />
<xi:include href="xml/element-autoconvert.xml" /> <xi:include href="xml/element-autoconvert.xml" />
<xi:include href="xml/element-camerabin.xml" /> <xi:include href="xml/element-camerabin.xml" />
<xi:include href="xml/element-capssetter.xml" /> <xi:include href="xml/element-capssetter.xml" />
@ -100,7 +97,7 @@
<xi:include href="xml/plugin-autoconvert.xml" /> <xi:include href="xml/plugin-autoconvert.xml" />
<xi:include href="xml/plugin-legacyresample.xml" /> <xi:include href="xml/plugin-legacyresample.xml" />
<xi:include href="xml/plugin-alsaspdif.xml" /> <xi:include href="xml/plugin-alsaspdif.xml" />
<xi:include href="xml/plugin-amrwb.xml" /> <xi:include href="xml/plugin-amrwbenc.xml" />
<xi:include href="xml/plugin-bayer.xml" /> <xi:include href="xml/plugin-bayer.xml" />
<xi:include href="xml/plugin-bz2.xml" /> <xi:include href="xml/plugin-bz2.xml" />
<xi:include href="xml/plugin-camerabin.xml" /> <xi:include href="xml/plugin-camerabin.xml" />

View file

@ -26,20 +26,6 @@ GST_TYPE_AMRPARSE
gst_amrparse_get_type gst_amrparse_get_type
</SECTION> </SECTION>
<SECTION>
<FILE>element-amrwbdec</FILE>
<TITLE>amrwbdec</TITLE>
GstAmrwbDec
<SUBSECTION Standard>
GstAmrwbDecClass
GST_AMRWBDEC
GST_AMRWBDEC_CLASS
GST_IS_AMRWBDEC
GST_IS_AMRWBDEC_CLASS
GST_TYPE_AMRWBDEC
gst_amrwbdec_get_type
</SECTION>
<SECTION> <SECTION>
<FILE>element-amrwbenc</FILE> <FILE>element-amrwbenc</FILE>
<TITLE>amrwbenc</TITLE> <TITLE>amrwbenc</TITLE>
@ -54,20 +40,6 @@ GST_TYPE_AMRWBENC
gst_amrwbenc_get_type gst_amrwbenc_get_type
</SECTION> </SECTION>
<SECTION>
<FILE>element-amrwbparse</FILE>
<TITLE>amrwbparse</TITLE>
GstAmrwbParse
<SUBSECTION Standard>
GstAmrwbParseClass
GST_AMRWBPARSE
GST_AMRWBPARSE_CLASS
GST_IS_AMRWBPARSE
GST_IS_AMRWBPARSE_CLASS
GST_TYPE_AMRWBPARSE
gst_amrwbparse_get_type
</SECTION>
<SECTION> <SECTION>
<FILE>element-audioparse</FILE> <FILE>element-audioparse</FILE>
<TITLE>audioparse</TITLE> <TITLE>audioparse</TITLE>

View file

@ -1,76 +0,0 @@
<plugin>
<name>amrwb</name>
<description>Adaptive Multi-Rate Wide-Band</description>
<filename>../../ext/amrwb/.libs/libgstamrwb.so</filename>
<basename>libgstamrwb.so</basename>
<version>0.10.13.1</version>
<license>unknown</license>
<source>gst-plugins-bad</source>
<package>GStreamer Bad Plug-ins git/prerelease</package>
<origin>http://gstreamer.freedesktop.org</origin>
<elements>
<element>
<name>amrwbdec</name>
<longname>AMR-WB audio decoder</longname>
<class>Codec/Decoder/Audio</class>
<description>Adaptive Multi-Rate Wideband audio decoder</description>
<author>Renato Araujo &lt;renato.filho@indt.org.br&gt;</author>
<pads>
<caps>
<name>src</name>
<direction>source</direction>
<presence>always</presence>
<details>audio/x-raw-int, width=(int)16, depth=(int)16, signed=(boolean)true, endianness=(int)1234, rate=(int)16000, channels=(int)1</details>
</caps>
<caps>
<name>sink</name>
<direction>sink</direction>
<presence>always</presence>
<details>audio/AMR-WB, rate=(int)16000, channels=(int)1</details>
</caps>
</pads>
</element>
<element>
<name>amrwbenc</name>
<longname>AMR-WB audio encoder</longname>
<class>Codec/Encoder/Audio</class>
<description>Adaptive Multi-Rate Wideband audio encoder</description>
<author>Renato Araujo &lt;renato.filho@indt.org.br&gt;</author>
<pads>
<caps>
<name>src</name>
<direction>source</direction>
<presence>always</presence>
<details>audio/AMR-WB, rate=(int)16000, channels=(int)1</details>
</caps>
<caps>
<name>sink</name>
<direction>sink</direction>
<presence>always</presence>
<details>audio/x-raw-int, width=(int)16, depth=(int)16, signed=(boolean)true, endianness=(int)1234, rate=(int)16000, channels=(int)1</details>
</caps>
</pads>
</element>
<element>
<name>amrwbparse</name>
<longname>AMR-WB audio stream parser</longname>
<class>Codec/Parser/Audio</class>
<description>Adaptive Multi-Rate WideBand audio parser</description>
<author>Renato Filho &lt;renato.filho@indt.org.br&gt;</author>
<pads>
<caps>
<name>src</name>
<direction>source</direction>
<presence>always</presence>
<details>audio/AMR-WB, rate=(int)16000, channels=(int)1</details>
</caps>
<caps>
<name>sink</name>
<direction>sink</direction>
<presence>always</presence>
<details>audio/x-amr-wb-sh</details>
</caps>
</pads>
</element>
</elements>
</plugin>

View file

@ -0,0 +1,34 @@
<plugin>
<name>amrwbenc</name>
<description>Adaptive Multi-Rate Wide-Band Encoder</description>
<filename>../../ext/amrwb/.libs/libgstamrwbenc.so</filename>
<basename>libgstamrwbenc.so</basename>
<version>0.10.12.1</version>
<license>unknown</license>
<source>gst-plugins-bad</source>
<package>GStreamer Bad Plug-ins git/prerelease</package>
<origin>Unknown package origin</origin>
<elements>
<element>
<name>amrwbenc</name>
<longname>AMR-WB audio encoder</longname>
<class>Codec/Encoder/Audio</class>
<description>Adaptive Multi-Rate Wideband audio encoder</description>
<author>Renato Araujo &lt;renato.filho@indt.org.br&gt;</author>
<pads>
<caps>
<name>src</name>
<direction>source</direction>
<presence>always</presence>
<details>audio/AMR-WB, rate=(int)16000, channels=(int)1</details>
</caps>
<caps>
<name>sink</name>
<direction>sink</direction>
<presence>always</presence>
<details>audio/x-raw-int, width=(int)16, depth=(int)16, signed=(boolean)true, endianness=(int)1234, rate=(int)16000, channels=(int)1</details>
</caps>
</pads>
</element>
</elements>
</plugin>

View file

@ -11,7 +11,7 @@ ASSRENDER_DIR =
endif endif
if USE_AMRWB if USE_AMRWB
AMRWB_DIR = amrwb AMRWB_DIR = amrwbenc
else else
AMRWB_DIR = AMRWB_DIR =
endif endif
@ -402,7 +402,7 @@ SUBDIRS=\
DIST_SUBDIRS = \ DIST_SUBDIRS = \
alsaspdif \ alsaspdif \
amrwb \ amrwbenc \
assrender \ assrender \
apexsink \ apexsink \
bz2 \ bz2 \

View file

@ -1,18 +0,0 @@
plugin_LTLIBRARIES = libgstamrwb.la
libgstamrwb_la_SOURCES = \
gstamrwb.c \
gstamrwbdec.c \
gstamrwbenc.c \
gstamrwbparse.c
libgstamrwb_la_CFLAGS = $(GST_CFLAGS) $(AMRWB_CFLAGS)
libgstamrwb_la_LIBADD = $(GST_BASE_LIBS) $(AMRWB_LIBS)
libgstamrwb_la_LDFLAGS = $(GST_PLUGIN_LDFLAGS)
libgstamrwb_la_LIBTOOLFLAGS = --tag=disable-static
noinst_HEADERS = \
gstamrwbdec.h \
gstamrwbenc.h \
gstamrwbparse.h

View file

@ -1,372 +0,0 @@
/* GStreamer Adaptive Multi-Rate Narrow-Band (AMR-NB) plugin
* Copyright (C) 2004 Ronald Bultje <rbultje@ronald.bitfreak.net>
*
* 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.
*/
/**
* SECTION:element-amrwbdec
* @see_also: #GstAmrwbEnc, #GstAmrwbParse
*
* AMR wideband decoder based on the
* <ulink url="http://www.penguin.cz/~utx/amr">reference codec implementation</ulink>.
*
* <refsect2>
* <title>Example launch line</title>
* |[
* gst-launch filesrc location=abc.amr ! amrwbparse ! amrwbdec ! audioresample ! audioconvert ! alsasink
* ]|
* </refsect2>
*/
#ifdef HAVE_CONFIG_H
#include "config.h"
#endif
#include "gstamrwbdec.h"
static GstStaticPadTemplate sink_template = GST_STATIC_PAD_TEMPLATE ("sink",
GST_PAD_SINK,
GST_PAD_ALWAYS,
GST_STATIC_CAPS ("audio/AMR-WB, "
"rate = (int) 16000, " "channels = (int) 1")
);
static GstStaticPadTemplate src_template = GST_STATIC_PAD_TEMPLATE ("src",
GST_PAD_SRC,
GST_PAD_ALWAYS,
GST_STATIC_CAPS ("audio/x-raw-int, "
"width = (int) 16, "
"depth = (int) 16, "
"signed = (boolean) TRUE, "
"endianness = (int) BYTE_ORDER, "
"rate = (int) 16000, " "channels = (int) 1")
);
GST_DEBUG_CATEGORY_STATIC (gst_amrwbdec_debug);
#define GST_CAT_DEFAULT gst_amrwbdec_debug
extern const UWord8 block_size[];
static gboolean gst_amrwbdec_event (GstPad * pad, GstEvent * event);
static GstFlowReturn gst_amrwbdec_chain (GstPad * pad, GstBuffer * buffer);
static gboolean gst_amrwbdec_setcaps (GstPad * pad, GstCaps * caps);
static GstStateChangeReturn gst_amrwbdec_state_change (GstElement * element,
GstStateChange transition);
static void gst_amrwbdec_finalize (GObject * object);
#define _do_init(bla) \
GST_DEBUG_CATEGORY_INIT (gst_amrwbdec_debug, "amrwbdec", 0, "AMR-WB audio decoder");
GST_BOILERPLATE_FULL (GstAmrwbDec, gst_amrwbdec, GstElement, GST_TYPE_ELEMENT,
_do_init);
static void
gst_amrwbdec_base_init (gpointer klass)
{
GstElementClass *element_class = GST_ELEMENT_CLASS (klass);
GstElementDetails details = GST_ELEMENT_DETAILS ("AMR-WB audio decoder",
"Codec/Decoder/Audio",
"Adaptive Multi-Rate Wideband audio decoder",
"Renato Araujo <renato.filho@indt.org.br>");
gst_element_class_add_pad_template (element_class,
gst_static_pad_template_get (&sink_template));
gst_element_class_add_pad_template (element_class,
gst_static_pad_template_get (&src_template));
gst_element_class_set_details (element_class, &details);
}
static void
gst_amrwbdec_class_init (GstAmrwbDecClass * klass)
{
GObjectClass *object_class = G_OBJECT_CLASS (klass);
GstElementClass *element_class = GST_ELEMENT_CLASS (klass);
object_class->finalize = gst_amrwbdec_finalize;
element_class->change_state = GST_DEBUG_FUNCPTR (gst_amrwbdec_state_change);
}
static void
gst_amrwbdec_init (GstAmrwbDec * amrwbdec, GstAmrwbDecClass * klass)
{
/* create the sink pad */
amrwbdec->sinkpad = gst_pad_new_from_static_template (&sink_template, "sink");
gst_pad_set_setcaps_function (amrwbdec->sinkpad, gst_amrwbdec_setcaps);
gst_pad_set_event_function (amrwbdec->sinkpad, gst_amrwbdec_event);
gst_pad_set_chain_function (amrwbdec->sinkpad, gst_amrwbdec_chain);
gst_element_add_pad (GST_ELEMENT (amrwbdec), amrwbdec->sinkpad);
/* create the src pad */
amrwbdec->srcpad = gst_pad_new_from_static_template (&src_template, "src");
gst_pad_use_fixed_caps (amrwbdec->srcpad);
gst_element_add_pad (GST_ELEMENT (amrwbdec), amrwbdec->srcpad);
amrwbdec->adapter = gst_adapter_new ();
/* init rest */
amrwbdec->handle = NULL;
amrwbdec->channels = 0;
amrwbdec->rate = 0;
amrwbdec->duration = 0;
amrwbdec->ts = -1;
}
static void
gst_amrwbdec_finalize (GObject * object)
{
GstAmrwbDec *amrwbdec;
amrwbdec = GST_AMRWBDEC (object);
gst_adapter_clear (amrwbdec->adapter);
g_object_unref (amrwbdec->adapter);
G_OBJECT_CLASS (parent_class)->finalize (object);
}
static gboolean
gst_amrwbdec_setcaps (GstPad * pad, GstCaps * caps)
{
GstStructure *structure;
GstAmrwbDec *amrwbdec;
GstCaps *copy;
amrwbdec = GST_AMRWBDEC (gst_pad_get_parent (pad));
structure = gst_caps_get_structure (caps, 0);
/* get channel count */
gst_structure_get_int (structure, "channels", &amrwbdec->channels);
gst_structure_get_int (structure, "rate", &amrwbdec->rate);
/* create reverse caps */
copy = gst_caps_new_simple ("audio/x-raw-int",
"channels", G_TYPE_INT, amrwbdec->channels,
"width", G_TYPE_INT, 16,
"depth", G_TYPE_INT, 16,
"endianness", G_TYPE_INT, G_BYTE_ORDER,
"rate", G_TYPE_INT, amrwbdec->rate, "signed", G_TYPE_BOOLEAN, TRUE, NULL);
amrwbdec->duration = gst_util_uint64_scale_int (GST_SECOND, L_FRAME16k,
amrwbdec->rate * amrwbdec->channels);
gst_pad_set_caps (amrwbdec->srcpad, copy);
gst_caps_unref (copy);
gst_object_unref (amrwbdec);
return TRUE;
}
static gboolean
gst_amrwbdec_event (GstPad * pad, GstEvent * event)
{
GstAmrwbDec *amrwbdec;
gboolean ret = TRUE;
amrwbdec = GST_AMRWBDEC (gst_pad_get_parent (pad));
switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_FLUSH_START:
ret = gst_pad_push_event (amrwbdec->srcpad, event);
break;
case GST_EVENT_FLUSH_STOP:
ret = gst_pad_push_event (amrwbdec->srcpad, event);
gst_adapter_clear (amrwbdec->adapter);
amrwbdec->ts = -1;
break;
case GST_EVENT_EOS:
gst_adapter_clear (amrwbdec->adapter);
ret = gst_pad_push_event (amrwbdec->srcpad, event);
break;
case GST_EVENT_NEWSEGMENT:
{
GstFormat format;
gdouble rate, arate;
gint64 start, stop, time;
gboolean update;
gst_event_parse_new_segment_full (event, &update, &rate, &arate, &format,
&start, &stop, &time);
/* we need time for now */
if (format != GST_FORMAT_TIME)
goto newseg_wrong_format;
GST_DEBUG_OBJECT (amrwbdec,
"newsegment: update %d, rate %g, arate %g, start %" GST_TIME_FORMAT
", stop %" GST_TIME_FORMAT ", time %" GST_TIME_FORMAT,
update, rate, arate, GST_TIME_ARGS (start), GST_TIME_ARGS (stop),
GST_TIME_ARGS (time));
/* now configure the values */
gst_segment_set_newsegment_full (&amrwbdec->segment, update,
rate, arate, format, start, stop, time);
ret = gst_pad_push_event (amrwbdec->srcpad, event);
}
break;
default:
ret = gst_pad_push_event (amrwbdec->srcpad, event);
break;
}
done:
gst_object_unref (amrwbdec);
return ret;
/* ERRORS */
newseg_wrong_format:
{
GST_DEBUG_OBJECT (amrwbdec, "received non TIME newsegment");
goto done;
}
}
static GstFlowReturn
gst_amrwbdec_chain (GstPad * pad, GstBuffer * buffer)
{
GstAmrwbDec *amrwbdec;
GstFlowReturn ret = GST_FLOW_OK;
amrwbdec = GST_AMRWBDEC (gst_pad_get_parent (pad));
if (amrwbdec->rate == 0 || amrwbdec->channels == 0)
goto not_negotiated;
/* discontinuity, don't combine samples before and after the
* DISCONT */
if (GST_BUFFER_FLAG_IS_SET (buffer, GST_BUFFER_FLAG_DISCONT)) {
gst_adapter_clear (amrwbdec->adapter);
amrwbdec->ts = -1;
amrwbdec->discont = TRUE;
}
/* take latest timestamp, FIXME timestamp is the one of the
* first buffer in the adapter. */
if (GST_BUFFER_TIMESTAMP_IS_VALID (buffer))
amrwbdec->ts = GST_BUFFER_TIMESTAMP (buffer);
gst_adapter_push (amrwbdec->adapter, buffer);
while (TRUE) {
GstBuffer *out;
const guint8 *data;
gint block, mode;
/* need to peek data to get the size */
if (gst_adapter_available (amrwbdec->adapter) < 1)
break;
data = gst_adapter_peek (amrwbdec->adapter, 1);
/* get size */
mode = (data[0] >> 3) & 0x0F;
block = block_size[mode];
GST_DEBUG_OBJECT (amrwbdec, "mode %d, block %d", mode, block);
if (!block || gst_adapter_available (amrwbdec->adapter) < block)
break;
/* the library seems to write into the source data, hence the copy. */
data = gst_adapter_take (amrwbdec->adapter, block);
/* get output */
out = gst_buffer_new_and_alloc (sizeof (gint16) * L_FRAME16k);
GST_BUFFER_DURATION (out) = amrwbdec->duration;
GST_BUFFER_TIMESTAMP (out) = amrwbdec->ts;
if (amrwbdec->ts != -1)
amrwbdec->ts += amrwbdec->duration;
if (amrwbdec->discont) {
GST_BUFFER_FLAG_SET (out, GST_BUFFER_FLAG_DISCONT);
amrwbdec->discont = FALSE;
}
gst_buffer_set_caps (out, GST_PAD_CAPS (amrwbdec->srcpad));
/* decode */
D_IF_decode (amrwbdec->handle, (UWord8 *) data,
(Word16 *) GST_BUFFER_DATA (out), _good_frame);
g_free ((gpointer) data);
/* send out */
ret = gst_pad_push (amrwbdec->srcpad, out);
}
gst_object_unref (amrwbdec);
return ret;
/* ERRORS */
not_negotiated:
{
GST_ELEMENT_ERROR (amrwbdec, STREAM, TYPE_NOT_FOUND, (NULL),
("Decoder is not initialized"));
gst_object_unref (amrwbdec);
return GST_FLOW_NOT_NEGOTIATED;
}
}
static GstStateChangeReturn
gst_amrwbdec_state_change (GstElement * element, GstStateChange transition)
{
GstAmrwbDec *amrwbdec;
GstStateChangeReturn ret;
amrwbdec = GST_AMRWBDEC (element);
switch (transition) {
case GST_STATE_CHANGE_NULL_TO_READY:
if (!(amrwbdec->handle = D_IF_init ()))
goto init_failed;
break;
case GST_STATE_CHANGE_READY_TO_PAUSED:
gst_adapter_clear (amrwbdec->adapter);
amrwbdec->rate = 0;
amrwbdec->channels = 0;
amrwbdec->ts = -1;
amrwbdec->discont = TRUE;
gst_segment_init (&amrwbdec->segment, GST_FORMAT_TIME);
break;
default:
break;
}
ret = GST_ELEMENT_CLASS (parent_class)->change_state (element, transition);
switch (transition) {
case GST_STATE_CHANGE_READY_TO_NULL:
D_IF_exit (amrwbdec->handle);
break;
default:
break;
}
return ret;
/* ERRORS */
init_failed:
{
GST_ELEMENT_ERROR (amrwbdec, LIBRARY, INIT, (NULL),
("Failed to open AMR Decoder"));
return GST_STATE_CHANGE_FAILURE;
}
}

View file

@ -1,78 +0,0 @@
/* GStreamer Adaptive Multi-Rate Wide-Band (AMR-WB) plugin
* Copyright (C) 2006 Edgard Lima <edgard.lima@indt.org.br>
*
* 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.
*/
#ifndef __GST_AMRWBDEC_H__
#define __GST_AMRWBDEC_H__
#include <gst/gst.h>
#include <gst/base/gstadapter.h>
#include <amrwb/typedef.h>
#include <amrwb/dec_if.h>
#include <amrwb/if_rom.h>
G_BEGIN_DECLS
#define GST_TYPE_AMRWBDEC \
(gst_amrwbdec_get_type())
#define GST_AMRWBDEC(obj) \
(G_TYPE_CHECK_INSTANCE_CAST((obj), GST_TYPE_AMRWBDEC, GstAmrwbDec))
#define GST_AMRWBDEC_CLASS(klass) \
(G_TYPE_CHECK_CLASS_CAST((klass), GST_TYPE_AMRWBDEC, GstAmrwbDecClass))
#define GST_IS_AMRWBDEC(obj) \
(G_TYPE_CHECK_INSTANCE_TYPE((obj), GST_TYPE_AMRWBDEC))
#define GST_IS_AMRWBDEC_CLASS(klass) \
(G_TYPE_CHECK_CLASS_TYPE((klass), GST_TYPE_AMRWBDEC))
typedef struct _GstAmrwbDec GstAmrwbDec;
typedef struct _GstAmrwbDecClass GstAmrwbDecClass;
/**
* GstAmrwbDec:
*
* Opaque data structure.
*/
struct _GstAmrwbDec {
GstElement element;
/* pads */
GstPad *sinkpad, *srcpad;
guint64 ts;
GstAdapter *adapter;
/* library handle */
void *handle;
/* output settings */
gint channels, rate;
gint duration;
GstSegment segment;
gboolean discont;
};
struct _GstAmrwbDecClass {
GstElementClass parent_class;
};
GType gst_amrwbdec_get_type (void);
G_END_DECLS
#endif /* __GST_AMRWBDEC_H__ */

View file

@ -1,767 +0,0 @@
/* GStreamer Adaptive Multi-Rate Wide-Band (AMR-WB) plugin
* Copyright (C) 2006 Edgard Lima <edgard.lima@indt.org.br>
*
* 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.
*/
/**
* SECTION:element-amrwbparse
* @see_also: #GstAmrwbDec, #GstAmrwbEnc
*
* This is an AMR wideband parser.
*
* <refsect2>
* <title>Example launch line</title>
* |[
* gst-launch filesrc location=abc.amr ! amrwbparse ! amrwbdec ! audioresample ! audioconvert ! alsasink
* ]|
* </refsect2>
*/
#ifdef HAVE_CONFIG_H
#include "config.h"
#endif
#include <string.h>
#include "gstamrwbparse.h"
static GstStaticPadTemplate src_template = GST_STATIC_PAD_TEMPLATE ("src",
GST_PAD_SRC,
GST_PAD_ALWAYS,
GST_STATIC_CAPS ("audio/AMR-WB, "
"rate = (int) 16000, " "channels = (int) 1")
);
static GstStaticPadTemplate sink_template = GST_STATIC_PAD_TEMPLATE ("sink",
GST_PAD_SINK,
GST_PAD_ALWAYS,
GST_STATIC_CAPS ("audio/x-amr-wb-sh")
);
GST_DEBUG_CATEGORY_STATIC (gst_amrwbparse_debug);
#define GST_CAT_DEFAULT gst_amrwbparse_debug
extern const UWord8 block_size[];
#define AMRWB_HEADER_SIZE 9
#define AMRWB_HEADER_STR "#!AMR-WB\n"
static void gst_amrwbparse_base_init (gpointer klass);
static void gst_amrwbparse_class_init (GstAmrwbParseClass * klass);
static void gst_amrwbparse_init (GstAmrwbParse * amrwbparse,
GstAmrwbParseClass * klass);
static const GstQueryType *gst_amrwbparse_querytypes (GstPad * pad);
static gboolean gst_amrwbparse_query (GstPad * pad, GstQuery * query);
static gboolean gst_amrwbparse_sink_event (GstPad * pad, GstEvent * event);
static gboolean gst_amrwbparse_src_event (GstPad * pad, GstEvent * event);
static GstFlowReturn gst_amrwbparse_chain (GstPad * pad, GstBuffer * buffer);
static void gst_amrwbparse_loop (GstPad * pad);
static gboolean gst_amrwbparse_sink_activate (GstPad * sinkpad);
static gboolean gst_amrwbparse_sink_activate_pull (GstPad * sinkpad,
gboolean active);
static gboolean gst_amrwbparse_sink_activate_push (GstPad * sinkpad,
gboolean active);
static GstStateChangeReturn gst_amrwbparse_state_change (GstElement * element,
GstStateChange transition);
static void gst_amrwbparse_finalize (GObject * object);
#define _do_init(bla) \
GST_DEBUG_CATEGORY_INIT (gst_amrwbparse_debug, "amrwbparse", 0, "AMR-WB audio stream parser");
GST_BOILERPLATE_FULL (GstAmrwbParse, gst_amrwbparse, GstElement,
GST_TYPE_ELEMENT, _do_init);
static void
gst_amrwbparse_base_init (gpointer klass)
{
GstElementClass *element_class = GST_ELEMENT_CLASS (klass);
GstElementDetails details = GST_ELEMENT_DETAILS ("AMR-WB audio stream parser",
"Codec/Parser/Audio",
"Adaptive Multi-Rate WideBand audio parser",
"Renato Filho <renato.filho@indt.org.br>");
gst_element_class_add_pad_template (element_class,
gst_static_pad_template_get (&sink_template));
gst_element_class_add_pad_template (element_class,
gst_static_pad_template_get (&src_template));
gst_element_class_set_details (element_class, &details);
}
static void
gst_amrwbparse_class_init (GstAmrwbParseClass * klass)
{
GObjectClass *object_class = G_OBJECT_CLASS (klass);
GstElementClass *element_class = GST_ELEMENT_CLASS (klass);
object_class->finalize = gst_amrwbparse_finalize;
element_class->change_state = GST_DEBUG_FUNCPTR (gst_amrwbparse_state_change);
}
static void
gst_amrwbparse_init (GstAmrwbParse * amrwbparse, GstAmrwbParseClass * klass)
{
/* create the sink pad */
amrwbparse->sinkpad =
gst_pad_new_from_static_template (&sink_template, "sink");
gst_pad_set_chain_function (amrwbparse->sinkpad,
GST_DEBUG_FUNCPTR (gst_amrwbparse_chain));
gst_pad_set_event_function (amrwbparse->sinkpad,
GST_DEBUG_FUNCPTR (gst_amrwbparse_sink_event));
gst_pad_set_activate_function (amrwbparse->sinkpad,
gst_amrwbparse_sink_activate);
gst_pad_set_activatepull_function (amrwbparse->sinkpad,
gst_amrwbparse_sink_activate_pull);
gst_pad_set_activatepush_function (amrwbparse->sinkpad,
gst_amrwbparse_sink_activate_push);
gst_element_add_pad (GST_ELEMENT (amrwbparse), amrwbparse->sinkpad);
/* create the src pad */
amrwbparse->srcpad = gst_pad_new_from_static_template (&src_template, "src");
gst_pad_set_event_function (amrwbparse->srcpad,
GST_DEBUG_FUNCPTR (gst_amrwbparse_src_event));
gst_pad_set_query_function (amrwbparse->srcpad,
GST_DEBUG_FUNCPTR (gst_amrwbparse_query));
gst_pad_set_query_type_function (amrwbparse->srcpad,
GST_DEBUG_FUNCPTR (gst_amrwbparse_querytypes));
gst_element_add_pad (GST_ELEMENT (amrwbparse), amrwbparse->srcpad);
amrwbparse->adapter = gst_adapter_new ();
/* init rest */
amrwbparse->ts = 0;
}
static void
gst_amrwbparse_finalize (GObject * object)
{
GstAmrwbParse *amrwbparse;
amrwbparse = GST_AMRWBPARSE (object);
gst_adapter_clear (amrwbparse->adapter);
g_object_unref (amrwbparse->adapter);
G_OBJECT_CLASS (parent_class)->finalize (object);
}
static const GstQueryType *
gst_amrwbparse_querytypes (GstPad * pad)
{
static const GstQueryType list[] = {
GST_QUERY_POSITION,
GST_QUERY_DURATION,
0
};
return list;
}
static gboolean
gst_amrwbparse_query (GstPad * pad, GstQuery * query)
{
GstAmrwbParse *amrwbparse;
gboolean res = TRUE;
amrwbparse = GST_AMRWBPARSE (gst_pad_get_parent (pad));
switch (GST_QUERY_TYPE (query)) {
case GST_QUERY_POSITION:
{
GstFormat format;
gint64 cur;
gst_query_parse_position (query, &format, NULL);
if (format != GST_FORMAT_TIME) {
res = FALSE;
break;
}
cur = amrwbparse->ts;
gst_query_set_position (query, GST_FORMAT_TIME, cur);
res = TRUE;
break;
}
case GST_QUERY_DURATION:
{
GstFormat format;
gint64 tot;
GstPad *peer;
gst_query_parse_duration (query, &format, NULL);
if (format != GST_FORMAT_TIME) {
res = FALSE;
break;
}
tot = -1;
res = FALSE;
peer = gst_pad_get_peer (amrwbparse->sinkpad);
if (peer) {
GstFormat pformat;
gint64 ptot;
pformat = GST_FORMAT_BYTES;
res = gst_pad_query_duration (peer, &pformat, &ptot);
if (res && amrwbparse->block) {
tot = gst_util_uint64_scale_int (ptot, 20 * GST_MSECOND,
amrwbparse->block);
}
gst_object_unref (GST_OBJECT (peer));
}
gst_query_set_duration (query, GST_FORMAT_TIME, tot);
res = TRUE;
break;
}
default:
res = gst_pad_query_default (pad, query);
break;
}
gst_object_unref (amrwbparse);
return res;
}
static gboolean
gst_amrwbparse_handle_pull_seek (GstAmrwbParse * amrwbparse, GstPad * pad,
GstEvent * event)
{
GstFormat format;
gdouble rate;
GstSeekFlags flags;
GstSeekType cur_type, stop_type;
gint64 cur, stop;
gint64 byte_cur = -1, byte_stop = -1;
gboolean flush;
gst_event_parse_seek (event, &rate, &format, &flags, &cur_type, &cur,
&stop_type, &stop);
GST_DEBUG_OBJECT (amrwbparse, "Performing seek to %" GST_TIME_FORMAT,
GST_TIME_ARGS (cur));
/* For any format other than TIME, see if upstream handles
* it directly or fail. For TIME, try upstream, but do it ourselves if
* it fails upstream */
if (format != GST_FORMAT_TIME) {
return gst_pad_push_event (amrwbparse->sinkpad, event);
} else {
if (gst_pad_push_event (amrwbparse->sinkpad, event))
return TRUE;
}
flush = flags & GST_SEEK_FLAG_FLUSH;
/* send flush start */
if (flush)
gst_pad_push_event (amrwbparse->sinkpad, gst_event_new_flush_start ());
/* we only handle FLUSH seeks at the moment */
else
return FALSE;
/* grab streaming lock, this should eventually be possible, either
* because the task is paused or our streaming thread stopped
* because our peer is flushing. */
GST_PAD_STREAM_LOCK (amrwbparse->sinkpad);
/* Convert the TIME to the appropriate BYTE position at which to resume
* decoding. */
cur = cur / (20 * GST_MSECOND) * (20 * GST_MSECOND);
if (cur != -1)
byte_cur = amrwbparse->block * (cur / 20 / GST_MSECOND) + AMRWB_HEADER_SIZE;
if (stop != -1)
byte_stop =
amrwbparse->block * (stop / 20 / GST_MSECOND) + AMRWB_HEADER_SIZE;
amrwbparse->offset = byte_cur;
amrwbparse->ts = cur;
GST_DEBUG_OBJECT (amrwbparse, "Seeking to byte range %" G_GINT64_FORMAT
" to %" G_GINT64_FORMAT, byte_cur, cur);
/* and prepare to continue streaming */
/* send flush stop, peer will accept data and events again. We
* are not yet providing data as we still have the STREAM_LOCK. */
gst_pad_push_event (amrwbparse->sinkpad, gst_event_new_flush_stop ());
gst_pad_push_event (amrwbparse->srcpad, gst_event_new_new_segment (FALSE,
rate, format, cur, -1, cur));
/* and restart the task in case it got paused explicitely or by
* the FLUSH_START event we pushed out. */
gst_pad_start_task (amrwbparse->sinkpad,
(GstTaskFunction) gst_amrwbparse_loop, amrwbparse->sinkpad);
/* and release the lock again so we can continue streaming */
GST_PAD_STREAM_UNLOCK (amrwbparse->sinkpad);
return TRUE;
}
static gboolean
gst_amrwbparse_handle_push_seek (GstAmrwbParse * amrwbparse, GstPad * pad,
GstEvent * event)
{
GstFormat format;
gdouble rate;
GstSeekFlags flags;
GstSeekType cur_type, stop_type;
gint64 cur, stop;
gint64 byte_cur = -1, byte_stop = -1;
gst_event_parse_seek (event, &rate, &format, &flags, &cur_type, &cur,
&stop_type, &stop);
GST_DEBUG_OBJECT (amrwbparse, "Performing seek to %" GST_TIME_FORMAT,
GST_TIME_ARGS (cur));
/* For any format other than TIME, see if upstream handles
* it directly or fail. For TIME, try upstream, but do it ourselves if
* it fails upstream */
if (format != GST_FORMAT_TIME) {
return gst_pad_push_event (amrwbparse->sinkpad, event);
} else {
if (gst_pad_push_event (amrwbparse->sinkpad, event))
return TRUE;
}
/* Convert the TIME to the appropriate BYTE position at which to resume
* decoding. */
cur = cur / (20 * GST_MSECOND) * (20 * GST_MSECOND);
if (cur != -1)
byte_cur = amrwbparse->block * (cur / 20 / GST_MSECOND) + AMRWB_HEADER_SIZE;
if (stop != -1)
byte_stop =
amrwbparse->block * (stop / 20 / GST_MSECOND) + AMRWB_HEADER_SIZE;
amrwbparse->ts = cur;
GST_DEBUG_OBJECT (amrwbparse, "Seeking to byte range %" G_GINT64_FORMAT
" to %" G_GINT64_FORMAT, byte_cur, byte_stop);
/* Send BYTE based seek upstream */
event = gst_event_new_seek (rate, GST_FORMAT_BYTES, flags, cur_type,
byte_cur, stop_type, byte_stop);
return gst_pad_push_event (amrwbparse->sinkpad, event);
}
static gboolean
gst_amrwbparse_src_event (GstPad * pad, GstEvent * event)
{
GstAmrwbParse *amrwbparse = GST_AMRWBPARSE (gst_pad_get_parent (pad));
gboolean res;
GST_DEBUG_OBJECT (amrwbparse, "handling event %d", GST_EVENT_TYPE (event));
switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_SEEK:
if (amrwbparse->seek_handler)
res = amrwbparse->seek_handler (amrwbparse, pad, event);
else
res = FALSE;
break;
default:
res = gst_pad_push_event (amrwbparse->sinkpad, event);
break;
}
gst_object_unref (amrwbparse);
return res;
}
/*
* Data reading.
*/
static gboolean
gst_amrwbparse_sink_event (GstPad * pad, GstEvent * event)
{
GstAmrwbParse *amrwbparse;
gboolean res;
amrwbparse = GST_AMRWBPARSE (gst_pad_get_parent (pad));
GST_LOG ("handling event %d", GST_EVENT_TYPE (event));
switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_FLUSH_START:
res = gst_pad_push_event (amrwbparse->srcpad, event);
break;
case GST_EVENT_FLUSH_STOP:
gst_adapter_clear (amrwbparse->adapter);
gst_segment_init (&amrwbparse->segment, GST_FORMAT_TIME);
res = gst_pad_push_event (amrwbparse->srcpad, event);
break;
case GST_EVENT_EOS:
res = gst_pad_push_event (amrwbparse->srcpad, event);
break;
case GST_EVENT_NEWSEGMENT:
{
/* eat for now, we send a newsegment at start with infinite
* duration. */
gst_event_unref (event);
res = TRUE;
break;
}
default:
res = gst_pad_push_event (amrwbparse->srcpad, event);
break;
}
gst_object_unref (amrwbparse);
return res;
}
/* streaming mode */
static GstFlowReturn
gst_amrwbparse_chain (GstPad * pad, GstBuffer * buffer)
{
GstAmrwbParse *amrwbparse;
GstFlowReturn res = GST_FLOW_OK;
gint mode;
const guint8 *data;
GstBuffer *out;
GstClockTime timestamp;
amrwbparse = GST_AMRWBPARSE (gst_pad_get_parent (pad));
timestamp = GST_BUFFER_TIMESTAMP (buffer);
if (GST_CLOCK_TIME_IS_VALID (timestamp)) {
GST_DEBUG_OBJECT (amrwbparse, "Lock on timestamp %" GST_TIME_FORMAT,
GST_TIME_ARGS (timestamp));
amrwbparse->ts = timestamp;
}
gst_adapter_push (amrwbparse->adapter, buffer);
/* init */
if (amrwbparse->need_header) {
GstEvent *segev;
GstCaps *caps;
if (gst_adapter_available (amrwbparse->adapter) < AMRWB_HEADER_SIZE)
goto done;
data = gst_adapter_peek (amrwbparse->adapter, AMRWB_HEADER_SIZE);
if (memcmp (data, AMRWB_HEADER_STR, AMRWB_HEADER_SIZE) != 0)
goto done;
gst_adapter_flush (amrwbparse->adapter, AMRWB_HEADER_SIZE);
amrwbparse->need_header = FALSE;
caps = gst_caps_new_simple ("audio/AMR-WB",
"rate", G_TYPE_INT, 16000, "channels", G_TYPE_INT, 1, NULL);
gst_pad_set_caps (amrwbparse->srcpad, caps);
gst_caps_unref (caps);
GST_DEBUG_OBJECT (amrwbparse, "Sending first segment");
segev = gst_event_new_new_segment_full (FALSE, 1.0, 1.0,
GST_FORMAT_TIME, 0, -1, 0);
gst_pad_push_event (amrwbparse->srcpad, segev);
}
while (TRUE) {
if (gst_adapter_available (amrwbparse->adapter) < 1)
break;
data = gst_adapter_peek (amrwbparse->adapter, 1);
/* get size */
mode = (data[0] >> 3) & 0x0F;
amrwbparse->block = block_size[mode] + 1; /* add one for the mode */
if (gst_adapter_available (amrwbparse->adapter) < amrwbparse->block)
break;
out = gst_buffer_new_and_alloc (amrwbparse->block);
data = gst_adapter_peek (amrwbparse->adapter, amrwbparse->block);
memcpy (GST_BUFFER_DATA (out), data, amrwbparse->block);
/* timestamp, all constants that won't overflow */
GST_BUFFER_DURATION (out) = GST_SECOND * L_FRAME16k / 16000;
GST_BUFFER_TIMESTAMP (out) = amrwbparse->ts;
if (GST_CLOCK_TIME_IS_VALID (amrwbparse->ts))
amrwbparse->ts += GST_BUFFER_DURATION (out);
gst_buffer_set_caps (out, GST_PAD_CAPS (amrwbparse->srcpad));
GST_DEBUG_OBJECT (amrwbparse, "Pushing %d bytes of data",
amrwbparse->block);
res = gst_pad_push (amrwbparse->srcpad, out);
gst_adapter_flush (amrwbparse->adapter, amrwbparse->block);
}
done:
gst_object_unref (amrwbparse);
return res;
}
static gboolean
gst_amrwbparse_pull_header (GstAmrwbParse * amrwbparse)
{
GstBuffer *buffer;
GstFlowReturn ret;
guint8 *data;
gint size;
ret = gst_pad_pull_range (amrwbparse->sinkpad, G_GUINT64_CONSTANT (0),
AMRWB_HEADER_SIZE, &buffer);
if (ret != GST_FLOW_OK)
return FALSE;
data = GST_BUFFER_DATA (buffer);
size = GST_BUFFER_SIZE (buffer);
if (size < AMRWB_HEADER_SIZE)
goto not_enough;
if (memcmp (data, AMRWB_HEADER_STR, AMRWB_HEADER_SIZE))
goto no_header;
gst_buffer_unref (buffer);
amrwbparse->offset = AMRWB_HEADER_SIZE;
return TRUE;
not_enough:
{
gst_buffer_unref (buffer);
return FALSE;
}
no_header:
{
gst_buffer_unref (buffer);
return FALSE;
}
}
/* random access mode, could just read a fixed size buffer and push it to
* the chain function but we don't... */
static void
gst_amrwbparse_loop (GstPad * pad)
{
GstAmrwbParse *amrwbparse;
GstBuffer *buffer;
guint8 *data;
gint size;
gint block, mode;
GstFlowReturn ret = GST_FLOW_OK;
amrwbparse = GST_AMRWBPARSE (GST_PAD_PARENT (pad));
/* init */
if (G_UNLIKELY (amrwbparse->need_header)) {
GstCaps *caps;
if (!gst_amrwbparse_pull_header (amrwbparse)) {
GST_ELEMENT_ERROR (amrwbparse, STREAM, WRONG_TYPE, (NULL), (NULL));
GST_LOG_OBJECT (amrwbparse, "could not read header");
goto need_pause;
}
caps = gst_caps_new_simple ("audio/AMR-WB",
"rate", G_TYPE_INT, 16000, "channels", G_TYPE_INT, 1, NULL);
gst_pad_set_caps (amrwbparse->srcpad, caps);
gst_caps_unref (caps);
GST_DEBUG_OBJECT (amrwbparse, "Sending newsegment event");
gst_pad_push_event (amrwbparse->srcpad,
gst_event_new_new_segment_full (FALSE, 1.0, 1.0,
GST_FORMAT_TIME, 0, -1, 0));
amrwbparse->need_header = FALSE;
}
ret =
gst_pad_pull_range (amrwbparse->sinkpad, amrwbparse->offset, 1, &buffer);
if (ret == GST_FLOW_UNEXPECTED)
goto eos;
else if (ret != GST_FLOW_OK)
goto need_pause;
data = GST_BUFFER_DATA (buffer);
size = GST_BUFFER_SIZE (buffer);
/* EOS */
if (size < 1) {
gst_buffer_unref (buffer);
goto eos;
}
/* get size */
mode = (data[0] >> 3) & 0x0F;
block = block_size[mode]; /* add one for the mode */
gst_buffer_unref (buffer);
ret = gst_pad_pull_range (amrwbparse->sinkpad,
amrwbparse->offset, block, &buffer);
if (ret == GST_FLOW_UNEXPECTED)
goto eos;
else if (ret != GST_FLOW_OK)
goto need_pause;
amrwbparse->offset += block;
/* output */
GST_BUFFER_DURATION (buffer) = GST_SECOND * L_FRAME16k / 16000;
GST_BUFFER_TIMESTAMP (buffer) = amrwbparse->ts;
gst_buffer_set_caps (buffer,
(GstCaps *) gst_pad_get_pad_template_caps (amrwbparse->srcpad));
ret = gst_pad_push (amrwbparse->srcpad, buffer);
if (ret != GST_FLOW_OK) {
GST_DEBUG_OBJECT (amrwbparse, "Flow: %s", gst_flow_get_name (ret));
if (GST_FLOW_IS_FATAL (ret)) {
GST_ELEMENT_ERROR (amrwbparse, STREAM, FAILED, (NULL), /* _("Internal data flow error.")), */
("streaming task paused, reason: %s", gst_flow_get_name (ret)));
gst_pad_push_event (pad, gst_event_new_eos ());
}
goto need_pause;
}
amrwbparse->ts += GST_BUFFER_DURATION (buffer);
return;
need_pause:
{
GST_LOG_OBJECT (amrwbparse, "pausing task");
gst_pad_pause_task (pad);
return;
}
eos:
{
GST_LOG_OBJECT (amrwbparse, "pausing task %d", ret);
gst_pad_push_event (amrwbparse->srcpad, gst_event_new_eos ());
gst_pad_pause_task (pad);
return;
}
}
static gboolean
gst_amrwbparse_sink_activate (GstPad * sinkpad)
{
gboolean result = FALSE;
GstAmrwbParse *amrwbparse;
amrwbparse = GST_AMRWBPARSE (gst_pad_get_parent (sinkpad));
if (gst_pad_check_pull_range (sinkpad)) {
GST_DEBUG ("Trying to activate in pull mode");
amrwbparse->seekable = TRUE;
amrwbparse->ts = 0;
result = gst_pad_activate_pull (sinkpad, TRUE);
} else {
GST_DEBUG ("Try to activate in push mode");
amrwbparse->seekable = FALSE;
result = gst_pad_activate_push (sinkpad, TRUE);
}
gst_object_unref (amrwbparse);
return result;
}
static gboolean
gst_amrwbparse_sink_activate_push (GstPad * sinkpad, gboolean active)
{
GstAmrwbParse *amrwbparse = GST_AMRWBPARSE (gst_pad_get_parent (sinkpad));
if (active) {
amrwbparse->seek_handler = gst_amrwbparse_handle_push_seek;
} else {
amrwbparse->seek_handler = NULL;
}
gst_object_unref (amrwbparse);
return TRUE;
}
static gboolean
gst_amrwbparse_sink_activate_pull (GstPad * sinkpad, gboolean active)
{
gboolean result;
GstAmrwbParse *amrwbparse;
amrwbparse = GST_AMRWBPARSE (gst_pad_get_parent (sinkpad));
if (active) {
amrwbparse->seek_handler = gst_amrwbparse_handle_pull_seek;
result = gst_pad_start_task (sinkpad,
(GstTaskFunction) gst_amrwbparse_loop, sinkpad);
} else {
amrwbparse->seek_handler = NULL;
result = gst_pad_stop_task (sinkpad);
}
gst_object_unref (amrwbparse);
return result;
}
static GstStateChangeReturn
gst_amrwbparse_state_change (GstElement * element, GstStateChange transition)
{
GstAmrwbParse *amrwbparse;
GstStateChangeReturn ret;
amrwbparse = GST_AMRWBPARSE (element);
switch (transition) {
case GST_STATE_CHANGE_NULL_TO_READY:
break;
case GST_STATE_CHANGE_READY_TO_PAUSED:
amrwbparse->need_header = TRUE;
amrwbparse->ts = -1;
amrwbparse->block = 0;
gst_segment_init (&amrwbparse->segment, GST_FORMAT_TIME);
break;
default:
break;
}
ret = GST_ELEMENT_CLASS (parent_class)->change_state (element, transition);
switch (transition) {
case GST_STATE_CHANGE_PAUSED_TO_READY:
break;
case GST_STATE_CHANGE_READY_TO_NULL:
break;
default:
break;
}
return ret;
}

View file

@ -1,77 +0,0 @@
/* GStreamer Adaptive Multi-Rate Wide-Band (AMR-WB) plugin
* Copyright (C) 2006 Edgard Lima <edgard.lima@indt.org.br>
*
* 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.
*/
#ifndef __GST_AMRWBPARSE_H__
#define __GST_AMRWBPARSE_H__
#include <gst/gst.h>
#include <gst/base/gstadapter.h>
#include <amrwb/typedef.h>
#include <amrwb/dec_if.h>
#include <amrwb/if_rom.h>
G_BEGIN_DECLS
#define GST_TYPE_AMRWBPARSE \
(gst_amrwbparse_get_type())
#define GST_AMRWBPARSE(obj) \
(G_TYPE_CHECK_INSTANCE_CAST((obj), GST_TYPE_AMRWBPARSE, GstAmrwbParse))
#define GST_AMRWBPARSE_CLASS(klass) \
(G_TYPE_CHECK_CLASS_CAST((klass), GST_TYPE_AMRWBPARSE, GstAmrwbParseClass))
#define GST_IS_AMRWBPARSE(obj) \
(G_TYPE_CHECK_INSTANCE_TYPE((obj), GST_TYPE_AMRWBPARSE))
#define GST_IS_AMRWBPARSE_CLASS(klass) \
(G_TYPE_CHECK_CLASS_TYPE((klass), GST_TYPE_AMRWBPARSE))
typedef struct _GstAmrwbParse GstAmrwbParse;
typedef struct _GstAmrwbParseClass GstAmrwbParseClass;
typedef gboolean (*GstAmrwbSeekHandler) (GstAmrwbParse * amrwbparse, GstPad * pad,
GstEvent * event);
struct _GstAmrwbParse {
GstElement element;
/* pads */
GstPad *sinkpad, *srcpad;
GstAdapter *adapter;
gboolean seekable;
gboolean need_header;
gint64 offset;
gint block;
GstAmrwbSeekHandler seek_handler;
guint64 ts;
/* for seeking etc */
GstSegment segment;
};
struct _GstAmrwbParseClass {
GstElementClass parent_class;
};
GType gst_amrwbparse_get_type (void);
G_END_DECLS
#endif /* __GST_AMRWBPARSE_H__ */

View file

@ -0,0 +1,11 @@
[_presets_]
version=0.10
element-name=GstAmrwbEnc
[enhance-size]
_meta/comment=Maximize compression, lowest bitrate
band-mode=0
[enhance-quality]
_meta/comment=Maximize quality, highest bitrate
band-mode=8

19
ext/amrwbenc/Makefile.am Normal file
View file

@ -0,0 +1,19 @@
plugin_LTLIBRARIES = libgstamrwbenc.la
libgstamrwbenc_la_SOURCES = \
gstamrwb.c \
gstamrwbenc.c
libgstamrwbenc_la_CFLAGS = $(GST_CFLAGS) $(AMRWB_CFLAGS)
libgstamrwbenc_la_LIBADD = $(GST_BASE_LIBS) $(AMRWB_LIBS)
libgstamrwbenc_la_LDFLAGS = $(GST_PLUGIN_LDFLAGS)
libgstamrwbenc_la_LIBTOOLFLAGS = --tag=disable-static
noinst_HEADERS = \
gstamrwbenc.h
presetdir = $(datadir)/gstreamer-$(GST_MAJORMINOR)/presets
preset_DATA = GstAmrwbEnc.prs
EXTRA_DIST = $(preset_DATA)

View file

@ -1,7 +1,7 @@
Compiling AMRWB codec: Compiling AMRWB encoder:
====================== ========================
To compile the amrwb codec, you need to download the source code from To compile the amrwb encoder, you need to download the source code from
"http://www.3gpp.org/ftp/Specs/html-info/26204.htm" and uncompress the "http://www.3gpp.org/ftp/Specs/html-info/26204.htm" and uncompress the
files inside an amrwb-code directory; files inside an amrwb-code directory;

View file

@ -1,4 +1,4 @@
/* GStreamer Adaptive Multi-Rate Wide-Band (AMR-WB) plugin /* GStreamer Adaptive Multi-Rate Wide-Band (AMR-WB) Encoder plugin
* Copyright (C) 2006 Edgard Lima <edgard.lima@indt.org.br> * Copyright (C) 2006 Edgard Lima <edgard.lima@indt.org.br>
* *
* This library is free software; you can redistribute it and/or * This library is free software; you can redistribute it and/or
@ -21,25 +21,19 @@
#include "config.h" #include "config.h"
#endif #endif
#include "gstamrwbdec.h"
#include "gstamrwbenc.h" #include "gstamrwbenc.h"
#include "gstamrwbparse.h"
static gboolean static gboolean
plugin_init (GstPlugin * plugin) plugin_init (GstPlugin * plugin)
{ {
return gst_element_register (plugin, "amrwbdec", return gst_element_register (plugin, "amrwbenc",
GST_RANK_PRIMARY, GST_TYPE_AMRWBDEC) &&
gst_element_register (plugin, "amrwbparse",
GST_RANK_PRIMARY, GST_TYPE_AMRWBPARSE) &&
gst_element_register (plugin, "amrwbenc",
GST_RANK_NONE, GST_TYPE_AMRWBENC); GST_RANK_NONE, GST_TYPE_AMRWBENC);
} }
GST_PLUGIN_DEFINE (GST_VERSION_MAJOR, GST_PLUGIN_DEFINE (GST_VERSION_MAJOR,
GST_VERSION_MINOR, GST_VERSION_MINOR,
"amrwb", "amrwbenc",
"Adaptive Multi-Rate Wide-Band", "Adaptive Multi-Rate Wide-Band Encoder",
plugin_init, VERSION, GST_LICENSE_UNKNOWN, GST_PACKAGE_NAME, plugin_init, VERSION, GST_LICENSE_UNKNOWN, GST_PACKAGE_NAME,
GST_PACKAGE_ORIGIN); GST_PACKAGE_ORIGIN);

View file

@ -116,8 +116,21 @@ static gboolean gst_amrwbenc_setcaps (GstPad * pad, GstCaps * caps);
static GstStateChangeReturn gst_amrwbenc_state_change (GstElement * element, static GstStateChangeReturn gst_amrwbenc_state_change (GstElement * element,
GstStateChange transition); GstStateChange transition);
#define _do_init(bla) \ static void
GST_DEBUG_CATEGORY_INIT (gst_amrwbenc_debug, "amrwbenc", 0, "AMR-WB audio encoder"); _do_init (GType object_type)
{
const GInterfaceInfo preset_interface_info = {
NULL, /* interface init */
NULL, /* interface finalize */
NULL /* interface_data */
};
g_type_add_interface_static (object_type, GST_TYPE_PRESET,
&preset_interface_info);
GST_DEBUG_CATEGORY_INIT (gst_amrnbenc_debug, "amrwbenc", 0,
"AMR-WB audio encoder");
}
GST_BOILERPLATE_FULL (GstAmrwbEnc, gst_amrwbenc, GstElement, GST_TYPE_ELEMENT, GST_BOILERPLATE_FULL (GstAmrwbEnc, gst_amrwbenc, GstElement, GST_TYPE_ELEMENT,
_do_init); _do_init);