FaSTTUBe/GST-Tensordecoder-ov_ep
37
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

mad: port to 0.11

Browse Source
This commit is contained in:
Wim Taymans 2011-04-19 19:24:23 +02:00
parent 98729bc82c
commit edb17b4601
1 changed files with 37 additions and 36 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

73
ext/mad/gstmad.c
View File

@ -111,7 +111,8 @@ static GstIndex *gst_mad_get_index (GstElement * element);
static GstTagList *gst_mad_id3_to_tag_list (const struct id3_tag *tag); static GstTagList *gst_mad_id3_to_tag_list (const struct id3_tag *tag);
#endif #endif
GST_BOILERPLATE (GstMad, gst_mad, GstElement, GST_TYPE_ELEMENT); #define gst_mad_parent_class parent_class
G_DEFINE_TYPE (GstMad, gst_mad, GST_TYPE_ELEMENT);
/* /*
#define GST_TYPE_MAD_LAYER (gst_mad_layer_get_type()) #define GST_TYPE_MAD_LAYER (gst_mad_layer_get_type())
@ -174,20 +175,6 @@ gst_mad_emphasis_get_type (void)
return mad_emphasis_type; return mad_emphasis_type;
} }
static void
gst_mad_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 (&mad_sink_template_factory));
gst_element_class_add_pad_template (element_class,
gst_static_pad_template_get (&mad_src_template_factory));
gst_element_class_set_details_simple (element_class, "mad mp3 decoder",
"Codec/Decoder/Audio",
"Uses mad code to decode mp3 streams", "Wim Taymans <wim@fluendo.com>");
}
static void static void
gst_mad_class_init (GstMadClass * klass) gst_mad_class_init (GstMadClass * klass)
{ {
@ -197,16 +184,10 @@ gst_mad_class_init (GstMadClass * klass)
gobject_class = (GObjectClass *) klass; gobject_class = (GObjectClass *) klass;
gstelement_class = (GstElementClass *) klass; gstelement_class = (GstElementClass *) klass;
parent_class = g_type_class_peek_parent (klass);
gobject_class->set_property = gst_mad_set_property; gobject_class->set_property = gst_mad_set_property;
gobject_class->get_property = gst_mad_get_property; gobject_class->get_property = gst_mad_get_property;
gobject_class->dispose = gst_mad_dispose; gobject_class->dispose = gst_mad_dispose;
gstelement_class->change_state = gst_mad_change_state;
gstelement_class->set_index = gst_mad_set_index;
gstelement_class->get_index = gst_mad_get_index;
/* init properties */ /* init properties */
/* currently, string representations are used, we might want to change that */ /* currently, string representations are used, we might want to change that */
/* FIXME: descriptions need to be more technical, /* FIXME: descriptions need to be more technical,
@ -218,6 +199,19 @@ gst_mad_class_init (GstMadClass * klass)
g_param_spec_boolean ("ignore-crc", "Ignore CRC", "Ignore CRC errors", g_param_spec_boolean ("ignore-crc", "Ignore CRC", "Ignore CRC errors",
TRUE, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS)); TRUE, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
gstelement_class->change_state = gst_mad_change_state;
gstelement_class->set_index = gst_mad_set_index;
gstelement_class->get_index = gst_mad_get_index;
gst_element_class_add_pad_template (gstelement_class,
gst_static_pad_template_get (&mad_sink_template_factory));
gst_element_class_add_pad_template (gstelement_class,
gst_static_pad_template_get (&mad_src_template_factory));
gst_element_class_set_details_simple (gstelement_class, "mad mp3 decoder",
"Codec/Decoder/Audio",
"Uses mad code to decode mp3 streams", "Wim Taymans <wim@fluendo.com>");
/* register tags */ /* register tags */
#define GST_TAG_LAYER "layer" #define GST_TAG_LAYER "layer"
#define GST_TAG_MODE "mode" #define GST_TAG_MODE "mode"
@ -237,7 +231,7 @@ gst_mad_class_init (GstMadClass * klass)
} }
static void static void
gst_mad_init (GstMad * mad, GstMadClass * klass) gst_mad_init (GstMad * mad)
{ {
GstPadTemplate *template; GstPadTemplate *template;
@ -1327,7 +1321,7 @@ gst_mad_flush_decode (GstMad * mad)
GST_DEBUG_OBJECT (mad, "pushing buffer %p of size %u, " GST_DEBUG_OBJECT (mad, "pushing buffer %p of size %u, "
"time %" GST_TIME_FORMAT ", dur %" GST_TIME_FORMAT, buf, "time %" GST_TIME_FORMAT ", dur %" GST_TIME_FORMAT, buf,
GST_BUFFER_SIZE (buf), GST_TIME_ARGS (GST_BUFFER_TIMESTAMP (buf)), gst_buffer_get_size (buf), GST_TIME_ARGS (GST_BUFFER_TIMESTAMP (buf)),
GST_TIME_ARGS (GST_BUFFER_DURATION (buf))); GST_TIME_ARGS (GST_BUFFER_DURATION (buf)));
res = gst_pad_push (mad->srcpad, buf); res = gst_pad_push (mad->srcpad, buf);
@ -1361,7 +1355,7 @@ gst_mad_chain_reverse (GstMad * mad, GstBuffer * buf)
if (G_LIKELY (buf)) { if (G_LIKELY (buf)) {
GST_DEBUG_OBJECT (mad, "gathering buffer %p of size %u, " GST_DEBUG_OBJECT (mad, "gathering buffer %p of size %u, "
"time %" GST_TIME_FORMAT ", dur %" GST_TIME_FORMAT, buf, "time %" GST_TIME_FORMAT ", dur %" GST_TIME_FORMAT, buf,
GST_BUFFER_SIZE (buf), GST_TIME_ARGS (GST_BUFFER_TIMESTAMP (buf)), gst_buffer_get_size (buf), GST_TIME_ARGS (GST_BUFFER_TIMESTAMP (buf)),
GST_TIME_ARGS (GST_BUFFER_DURATION (buf))); GST_TIME_ARGS (GST_BUFFER_DURATION (buf)));
/* add buffer to gather queue */ /* add buffer to gather queue */
@ -1375,8 +1369,8 @@ static GstFlowReturn
gst_mad_chain (GstPad * pad, GstBuffer * buffer) gst_mad_chain (GstPad * pad, GstBuffer * buffer)
{ {
GstMad *mad; GstMad *mad;
guint8 *data; guint8 *data, *bdata;
glong size, tempsize; gsize bsize, size, tempsize;
gboolean new_pts = FALSE; gboolean new_pts = FALSE;
gboolean discont; gboolean discont;
GstClockTime timestamp; GstClockTime timestamp;
@ -1425,8 +1419,10 @@ gst_mad_chain (GstPad * pad, GstBuffer * buffer)
GST_DEBUG ("last_ts %" GST_TIME_FORMAT, GST_TIME_ARGS (mad->last_ts)); GST_DEBUG ("last_ts %" GST_TIME_FORMAT, GST_TIME_ARGS (mad->last_ts));
/* handle data */ /* handle data */
data = GST_BUFFER_DATA (buffer); bdata = gst_buffer_map (buffer, &bsize, NULL, GST_MAP_READ);
size = GST_BUFFER_SIZE (buffer);
data = bdata;
size = bsize;
tempsize = mad->tempsize; tempsize = mad->tempsize;
@ -1685,7 +1681,8 @@ gst_mad_chain (GstPad * pad, GstBuffer * buffer)
to skip and send the remaining pcm samples */ to skip and send the remaining pcm samples */
GstBuffer *outbuffer = NULL; GstBuffer *outbuffer = NULL;
gint32 *outdata; gpointer odata;
gsize osize;
mad_fixed_t const *left_ch, *right_ch; mad_fixed_t const *left_ch, *right_ch;
if (mad->need_newsegment) { if (mad->need_newsegment) {
@ -1725,7 +1722,7 @@ gst_mad_chain (GstPad * pad, GstBuffer * buffer)
goto skip_frame; goto skip_frame;
} }
if (GST_BUFFER_SIZE (outbuffer) != nsamples * mad->channels * 4) { if (gst_buffer_get_size (outbuffer) != nsamples * mad->channels * 4) {
gst_buffer_unref (outbuffer); gst_buffer_unref (outbuffer);
outbuffer = gst_buffer_new_and_alloc (nsamples * mad->channels * 4); outbuffer = gst_buffer_new_and_alloc (nsamples * mad->channels * 4);
@ -1736,8 +1733,6 @@ gst_mad_chain (GstPad * pad, GstBuffer * buffer)
left_ch = mad->synth.pcm.samples[0]; left_ch = mad->synth.pcm.samples[0];
right_ch = mad->synth.pcm.samples[1]; right_ch = mad->synth.pcm.samples[1];
outdata = (gint32 *) GST_BUFFER_DATA (outbuffer);
GST_DEBUG ("mad out timestamp %" GST_TIME_FORMAT " dur: %" GST_DEBUG ("mad out timestamp %" GST_TIME_FORMAT " dur: %"
GST_TIME_FORMAT, GST_TIME_ARGS (time_offset), GST_TIME_FORMAT, GST_TIME_ARGS (time_offset),
GST_TIME_ARGS (time_duration)); GST_TIME_ARGS (time_duration));
@ -1747,21 +1742,26 @@ gst_mad_chain (GstPad * pad, GstBuffer * buffer)
GST_BUFFER_OFFSET (outbuffer) = mad->total_samples; GST_BUFFER_OFFSET (outbuffer) = mad->total_samples;
GST_BUFFER_OFFSET_END (outbuffer) = mad->total_samples + nsamples; GST_BUFFER_OFFSET_END (outbuffer) = mad->total_samples + nsamples;
odata = gst_buffer_map (outbuffer, &osize, NULL, GST_MAP_WRITE);
/* output sample(s) in 16-bit signed native-endian PCM */ /* output sample(s) in 16-bit signed native-endian PCM */
if (mad->channels == 1) { if (mad->channels == 1) {
gint count = nsamples; gint count = nsamples;
gint32 *ptr = odata;
while (count--) { while (count--) {
*outdata++ = scale (*left_ch++) & 0xffffffff; *ptr++ = scale (*left_ch++) & 0xffffffff;
} }
} else { } else {
gint count = nsamples; gint count = nsamples;
gint32 *ptr = odata;
while (count--) { while (count--) {
*outdata++ = scale (*left_ch++) & 0xffffffff; *ptr++ = scale (*left_ch++) & 0xffffffff;
*outdata++ = scale (*right_ch++) & 0xffffffff; *ptr++ = scale (*right_ch++) & 0xffffffff;
} }
} }
gst_buffer_unmap (outbuffer, odata, osize);
if ((outbuffer = gst_audio_buffer_clip (outbuffer, &mad->segment, if ((outbuffer = gst_audio_buffer_clip (outbuffer, &mad->segment,
mad->rate, 4 * mad->channels))) { mad->rate, 4 * mad->channels))) {
@ -1836,6 +1836,7 @@ gst_mad_chain (GstPad * pad, GstBuffer * buffer)
result = GST_FLOW_OK; result = GST_FLOW_OK;
end: end:
gst_buffer_unmap (buffer, bdata, bsize);
gst_buffer_unref (buffer); gst_buffer_unref (buffer);
return result; return result;
@ -1887,7 +1888,7 @@ gst_mad_change_state (GstElement * element, GstStateChange transition)
break; break;
} }
ret = parent_class->change_state (element, transition); ret = GST_ELEMENT_CLASS (parent_class)->change_state (element, transition);
switch (transition) { switch (transition) {
case GST_STATE_CHANGE_PLAYING_TO_PAUSED: case GST_STATE_CHANGE_PLAYING_TO_PAUSED: