Superseeded by vorbisfile
Original commit message from CVS: Superseeded by vorbisfile
This commit is contained in:
Ronald S. Bultje
parent
cb63bf4789
commit
d4d7574625
@ -1,549 +0,0 @@
|
|||||||
/* GStreamer
|
|
||||||
* Copyright (C) <1999> Erik Walthinsen <omega@cse.ogi.edu>
|
|
||||||
*
|
|
||||||
* 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 <string.h>
|
|
||||||
#include <sys/soundcard.h>
|
|
||||||
|
|
||||||
#include <vorbisdec.h>
|
|
||||||
|
|
||||||
|
|
||||||
extern GstPadTemplate *gst_vorbisdec_src_template, *gst_vorbisdec_sink_template;
|
|
||||||
|
|
||||||
/* elementfactory information */
|
|
||||||
GstElementDetails vorbisdec_details =
|
|
||||||
{
|
|
||||||
"Ogg Vorbis decoder",
|
|
||||||
"Codec/Audio/Decoder",
|
|
||||||
"LGPL",
|
|
||||||
"Decodes OGG Vorbis audio",
|
|
||||||
VERSION,
|
|
||||||
"Monty <monty@xiph.org>, "
|
|
||||||
"Wim Taymans <wim.taymans@chello.be>",
|
|
||||||
"(C) 2000",
|
|
||||||
};
|
|
||||||
|
|
||||||
/* VorbisDec signals and args */
|
|
||||||
enum
|
|
||||||
{
|
|
||||||
/* FILL ME */
|
|
||||||
LAST_SIGNAL
|
|
||||||
};
|
|
||||||
|
|
||||||
enum
|
|
||||||
{
|
|
||||||
ARG_0,
|
|
||||||
ARG_COMMENT,
|
|
||||||
ARG_VENDOR,
|
|
||||||
ARG_VERSION,
|
|
||||||
ARG_CHANNELS,
|
|
||||||
ARG_SAMPLERATE,
|
|
||||||
ARG_BITRATE_UPPER,
|
|
||||||
ARG_BITRATE_NOMINAL,
|
|
||||||
ARG_BITRATE_LOWER,
|
|
||||||
ARG_BITRATE_WINDOW,
|
|
||||||
};
|
|
||||||
|
|
||||||
static void gst_vorbisdec_class_init (VorbisDecClass *klass);
|
|
||||||
static void gst_vorbisdec_init (VorbisDec *vorbisdec);
|
|
||||||
|
|
||||||
static void gst_vorbisdec_get_property (GObject *object, guint prop_id,
|
|
||||||
GValue *value, GParamSpec *pspec);
|
|
||||||
|
|
||||||
static void gst_vorbisdec_loop (GstElement *element);
|
|
||||||
|
|
||||||
static GstElementClass *parent_class = NULL;
|
|
||||||
/*static guint gst_vorbisdec_signals[LAST_SIGNAL] = { 0 }; */
|
|
||||||
|
|
||||||
GType
|
|
||||||
vorbisdec_get_type (void)
|
|
||||||
{
|
|
||||||
static GType vorbisdec_type = 0;
|
|
||||||
|
|
||||||
if (!vorbisdec_type) {
|
|
||||||
static const GTypeInfo vorbisdec_info = {
|
|
||||||
sizeof (VorbisDecClass),
|
|
||||||
NULL,
|
|
||||||
NULL,
|
|
||||||
(GClassInitFunc) gst_vorbisdec_class_init,
|
|
||||||
NULL,
|
|
||||||
NULL,
|
|
||||||
sizeof (VorbisDec),
|
|
||||||
0,
|
|
||||||
(GInstanceInitFunc) gst_vorbisdec_init,
|
|
||||||
};
|
|
||||||
|
|
||||||
vorbisdec_type = g_type_register_static (GST_TYPE_ELEMENT, "VorbisDec", &vorbisdec_info, 0);
|
|
||||||
}
|
|
||||||
return vorbisdec_type;
|
|
||||||
}
|
|
||||||
|
|
||||||
static void
|
|
||||||
gst_vorbisdec_class_init (VorbisDecClass * klass)
|
|
||||||
{
|
|
||||||
GObjectClass *gobject_class;
|
|
||||||
GstElementClass *gstelement_class;
|
|
||||||
|
|
||||||
gobject_class = (GObjectClass*) klass;
|
|
||||||
gstelement_class = (GstElementClass *) klass;
|
|
||||||
|
|
||||||
parent_class = g_type_class_ref (GST_TYPE_ELEMENT);
|
|
||||||
|
|
||||||
g_object_class_install_property (gobject_class, ARG_COMMENT,
|
|
||||||
g_param_spec_string ("comment", "Comment", "The comment tags for this vorbis stream",
|
|
||||||
"", G_PARAM_READABLE));
|
|
||||||
g_object_class_install_property (gobject_class, ARG_VENDOR,
|
|
||||||
g_param_spec_string ("vendor", "Vendor", "The vendor for this vorbis stream",
|
|
||||||
"", G_PARAM_READABLE));
|
|
||||||
g_object_class_install_property (gobject_class, ARG_VERSION,
|
|
||||||
g_param_spec_int ("version", "Version", "The version",
|
|
||||||
0, G_MAXINT, 0, G_PARAM_READABLE));
|
|
||||||
g_object_class_install_property (gobject_class, ARG_CHANNELS,
|
|
||||||
g_param_spec_int ("channels", "Channels", "The number of channels",
|
|
||||||
0, G_MAXINT, 0, G_PARAM_READABLE));
|
|
||||||
g_object_class_install_property (gobject_class, ARG_SAMPLERATE,
|
|
||||||
g_param_spec_int ("samplerate", "Sample Rate", "The samplerate",
|
|
||||||
0, G_MAXINT, 0, G_PARAM_READABLE));
|
|
||||||
g_object_class_install_property (gobject_class, ARG_BITRATE_UPPER,
|
|
||||||
g_param_spec_int ("bitrate_upper", "bitrate_upper", "bitrate_upper",
|
|
||||||
0, G_MAXINT, 0, G_PARAM_READABLE));
|
|
||||||
g_object_class_install_property (gobject_class, ARG_BITRATE_NOMINAL,
|
|
||||||
g_param_spec_int ("bitrate_nominal", "bitrate_nominal", "bitrate_nominal",
|
|
||||||
0, G_MAXINT, 0, G_PARAM_READABLE));
|
|
||||||
g_object_class_install_property (gobject_class, ARG_BITRATE_LOWER,
|
|
||||||
g_param_spec_int ("bitrate_lower", "bitrate_lower", "bitrate_lower",
|
|
||||||
0, G_MAXINT, 0, G_PARAM_READABLE));
|
|
||||||
g_object_class_install_property (gobject_class, ARG_BITRATE_WINDOW,
|
|
||||||
g_param_spec_int ("bitrate_window", "bitrate_window", "bitrate_window",
|
|
||||||
0, G_MAXINT, 0, G_PARAM_READABLE));
|
|
||||||
|
|
||||||
gobject_class->get_property = gst_vorbisdec_get_property;
|
|
||||||
}
|
|
||||||
|
|
||||||
static void
|
|
||||||
gst_vorbisdec_init (VorbisDec * vorbisdec)
|
|
||||||
{
|
|
||||||
vorbisdec->sinkpad = gst_pad_new_from_template (gst_vorbisdec_sink_template, "sink");
|
|
||||||
gst_element_add_pad (GST_ELEMENT (vorbisdec), vorbisdec->sinkpad);
|
|
||||||
|
|
||||||
gst_element_set_loop_function (GST_ELEMENT (vorbisdec), gst_vorbisdec_loop);
|
|
||||||
vorbisdec->srcpad = gst_pad_new_from_template (gst_vorbisdec_src_template, "src");
|
|
||||||
gst_element_add_pad (GST_ELEMENT (vorbisdec), vorbisdec->srcpad);
|
|
||||||
|
|
||||||
ogg_sync_init (&vorbisdec->oy); /* Now we can read pages */
|
|
||||||
vorbisdec->convsize = 4096;
|
|
||||||
vorbisdec->total_out = 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
static GstBuffer *
|
|
||||||
gst_vorbisdec_pull (VorbisDec * vorbisdec, ogg_sync_state * oy)
|
|
||||||
{
|
|
||||||
GstBuffer *buf;
|
|
||||||
|
|
||||||
do {
|
|
||||||
GST_DEBUG ("vorbisdec: pull ");
|
|
||||||
|
|
||||||
buf = gst_pad_pull (vorbisdec->sinkpad);
|
|
||||||
|
|
||||||
if (GST_IS_EVENT (buf)) {
|
|
||||||
switch (GST_EVENT_TYPE (buf)) {
|
|
||||||
case GST_EVENT_FLUSH:
|
|
||||||
ogg_sync_reset (oy);
|
|
||||||
case GST_EVENT_EOS:
|
|
||||||
gst_pad_event_default (vorbisdec->sinkpad, GST_EVENT (buf));
|
|
||||||
buf = NULL;
|
|
||||||
goto end;
|
|
||||||
default:
|
|
||||||
gst_pad_event_default (vorbisdec->sinkpad, GST_EVENT (buf));
|
|
||||||
}
|
|
||||||
buf = NULL;
|
|
||||||
}
|
|
||||||
} while (buf == NULL);
|
|
||||||
|
|
||||||
end:
|
|
||||||
GST_DEBUG ("vorbisdec: pull done");
|
|
||||||
|
|
||||||
return buf;
|
|
||||||
}
|
|
||||||
|
|
||||||
static void
|
|
||||||
gst_vorbisdec_loop (GstElement * element)
|
|
||||||
{
|
|
||||||
VorbisDec *vorbisdec;
|
|
||||||
GstBuffer *buf;
|
|
||||||
GstBuffer *outbuf;
|
|
||||||
|
|
||||||
ogg_sync_state oy; /* sync and verify incoming physical bitstream */
|
|
||||||
ogg_stream_state os; /* take physical pages, weld into a logical
|
|
||||||
stream of packets */
|
|
||||||
ogg_page og; /* one Ogg bitstream page. Vorbis packets are inside */
|
|
||||||
ogg_packet op; /* one raw packet of data for decode */
|
|
||||||
|
|
||||||
vorbis_dsp_state vd; /* central working state for the packet->PCM decoder */
|
|
||||||
vorbis_block vb; /* local working space for packet->PCM decode */
|
|
||||||
|
|
||||||
char *buffer;
|
|
||||||
int bytes;
|
|
||||||
|
|
||||||
g_return_if_fail (element != NULL);
|
|
||||||
g_return_if_fail (GST_IS_VORBISDEC (element));
|
|
||||||
|
|
||||||
vorbisdec = GST_VORBISDEC (element);
|
|
||||||
|
|
||||||
/********** Decode setup ************/
|
|
||||||
ogg_sync_init (&oy); /* Now we can read pages */
|
|
||||||
|
|
||||||
while (1) { /* we repeat if the bitstream is chained */
|
|
||||||
int eos = 0;
|
|
||||||
int i;
|
|
||||||
|
|
||||||
/* grab some data at the head of the stream. We want the first page
|
|
||||||
(which is guaranteed to be small and only contain the Vorbis
|
|
||||||
stream initial header) We need the first page to get the stream
|
|
||||||
serialno. */
|
|
||||||
|
|
||||||
/* submit a 4k block to libvorbis' Ogg layer */
|
|
||||||
buf = gst_vorbisdec_pull (vorbisdec, &oy);
|
|
||||||
if (!buf) {
|
|
||||||
eos = 1;
|
|
||||||
GST_DEBUG ("vorbisdec: pulled NULL");
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
|
|
||||||
bytes = GST_BUFFER_SIZE (buf);
|
|
||||||
buffer = ogg_sync_buffer (&oy, bytes);
|
|
||||||
memcpy (buffer, GST_BUFFER_DATA (buf), bytes);
|
|
||||||
gst_buffer_unref (buf);
|
|
||||||
|
|
||||||
ogg_sync_wrote (&oy, bytes);
|
|
||||||
|
|
||||||
/* Get the first page. */
|
|
||||||
if (ogg_sync_pageout (&oy, &og) != 1) {
|
|
||||||
/* error case. Must not be Vorbis data */
|
|
||||||
gst_element_error (element, "input does not appear to be an Ogg bitstream.");
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
|
|
||||||
/* Get the serial number and set up the rest of decode. */
|
|
||||||
/* serialno first; use it to set up a logical stream */
|
|
||||||
ogg_stream_init (&os, ogg_page_serialno (&og));
|
|
||||||
|
|
||||||
/* extract the initial header from the first page and verify that the
|
|
||||||
Ogg bitstream is in fact Vorbis data */
|
|
||||||
|
|
||||||
/* I handle the initial header first instead of just having the code
|
|
||||||
read all three Vorbis headers at once because reading the initial
|
|
||||||
header is an easy way to identify a Vorbis bitstream and it's
|
|
||||||
useful to see that functionality seperated out. */
|
|
||||||
|
|
||||||
vorbis_info_init (&vorbisdec->vi);
|
|
||||||
vorbis_comment_init (&vorbisdec->vc);
|
|
||||||
if (ogg_stream_pagein (&os, &og) < 0) {
|
|
||||||
/* error; stream version mismatch perhaps */
|
|
||||||
g_warning ("Error reading first page of Ogg bitstream data.\n");
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (ogg_stream_packetout (&os, &op) != 1) {
|
|
||||||
/* no page? must not be vorbis */
|
|
||||||
g_warning ("Error reading initial header packet.\n");
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (vorbis_synthesis_headerin (&vorbisdec->vi, &vorbisdec->vc, &op) < 0) {
|
|
||||||
/* error case; not a vorbis header */
|
|
||||||
g_warning ("This Ogg bitstream does not contain Vorbis audio data.\n");
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
/* At this point, we're sure we're Vorbis. We've set up the logical
|
|
||||||
(Ogg) bitstream decoder. Get the comment and codebook headers and
|
|
||||||
set up the Vorbis decoder */
|
|
||||||
|
|
||||||
/* The next two packets in order are the comment and codebook headers.
|
|
||||||
They're likely large and may span multiple pages. Thus we reead
|
|
||||||
and submit data until we get our two pacakets, watching that no
|
|
||||||
pages are missing. If a page is missing, error out; losing a
|
|
||||||
header page is the only place where missing data is fatal. */
|
|
||||||
|
|
||||||
i = 0;
|
|
||||||
while (i < 2) {
|
|
||||||
while (i < 2) {
|
|
||||||
int result = ogg_sync_pageout (&oy, &og);
|
|
||||||
|
|
||||||
if (result == 0)
|
|
||||||
break; /* Need more data */
|
|
||||||
/* Don't complain about missing or corrupt data yet. We'll
|
|
||||||
catch it at the packet output phase */
|
|
||||||
if (result == 1) {
|
|
||||||
ogg_stream_pagein (&os, &og); /* we can ignore any errors here
|
|
||||||
as they'll also become apparent
|
|
||||||
at packetout */
|
|
||||||
while (i < 2) {
|
|
||||||
result = ogg_stream_packetout (&os, &op);
|
|
||||||
if (result == 0)
|
|
||||||
break;
|
|
||||||
if (result == -1) {
|
|
||||||
/* Uh oh; data at some point was corrupted or missing!
|
|
||||||
We can't tolerate that in a header. Die. */
|
|
||||||
g_warning ("Corrupt secondary header. expect trouble\n");
|
|
||||||
}
|
|
||||||
vorbis_synthesis_headerin (&vorbisdec->vi, &vorbisdec->vc, &op);
|
|
||||||
i++;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
gst_element_yield (GST_ELEMENT (vorbisdec));
|
|
||||||
|
|
||||||
buf = gst_vorbisdec_pull (vorbisdec, &oy);
|
|
||||||
if (!buf)
|
|
||||||
goto end;
|
|
||||||
bytes = GST_BUFFER_SIZE (buf);
|
|
||||||
buffer = ogg_sync_buffer (&oy, bytes);
|
|
||||||
memcpy (buffer, GST_BUFFER_DATA (buf), bytes);
|
|
||||||
gst_buffer_unref (buf);
|
|
||||||
|
|
||||||
if (bytes == 0 && i < 2) {
|
|
||||||
g_warning ("End of file before finding all Vorbis headers! expect trouble..\n");
|
|
||||||
}
|
|
||||||
ogg_sync_wrote (&oy, bytes);
|
|
||||||
}
|
|
||||||
|
|
||||||
/* Throw the comments plus a few lines about the bitstream we're
|
|
||||||
decoding */
|
|
||||||
{
|
|
||||||
char **ptr = vorbisdec->vc.user_comments;
|
|
||||||
|
|
||||||
while (*ptr) {
|
|
||||||
/* FIXME parse comments */
|
|
||||||
++ptr;
|
|
||||||
}
|
|
||||||
g_object_freeze_notify (G_OBJECT (vorbisdec));
|
|
||||||
g_object_notify (G_OBJECT (vorbisdec), "comment");
|
|
||||||
g_object_notify (G_OBJECT (vorbisdec), "vendor");
|
|
||||||
g_object_notify (G_OBJECT (vorbisdec), "version");
|
|
||||||
g_object_notify (G_OBJECT (vorbisdec), "channels");
|
|
||||||
g_object_notify (G_OBJECT (vorbisdec), "rate");
|
|
||||||
g_object_notify (G_OBJECT (vorbisdec), "bitrate_upper");
|
|
||||||
g_object_notify (G_OBJECT (vorbisdec), "bitrate_nominal");
|
|
||||||
g_object_notify (G_OBJECT (vorbisdec), "bitrate_lower");
|
|
||||||
g_object_notify (G_OBJECT (vorbisdec), "bitrate_window");
|
|
||||||
g_object_thaw_notify (G_OBJECT (vorbisdec));
|
|
||||||
}
|
|
||||||
|
|
||||||
gst_pad_try_set_caps (vorbisdec->srcpad,
|
|
||||||
GST_CAPS_NEW ("vorbisdec_src",
|
|
||||||
"audio/raw",
|
|
||||||
"format", GST_PROPS_STRING ("int"),
|
|
||||||
"law", GST_PROPS_INT (0),
|
|
||||||
"endianness", GST_PROPS_INT (G_BYTE_ORDER),
|
|
||||||
"signed", GST_PROPS_BOOLEAN (TRUE),
|
|
||||||
"width", GST_PROPS_INT (16),
|
|
||||||
"depth", GST_PROPS_INT (16),
|
|
||||||
"rate", GST_PROPS_INT (vorbisdec->vi.rate),
|
|
||||||
"channels", GST_PROPS_INT (vorbisdec->vi.channels)
|
|
||||||
));
|
|
||||||
|
|
||||||
vorbisdec->convsize = 4096 / vorbisdec->vi.channels;
|
|
||||||
|
|
||||||
/* OK, got and parsed all three headers. Initialize the Vorbis
|
|
||||||
packet->PCM decoder. */
|
|
||||||
vorbis_synthesis_init (&vd, &vorbisdec->vi); /* central decode state */
|
|
||||||
vorbis_block_init (&vd, &vb); /* local state for most of the decode
|
|
||||||
so multiple block decodes can
|
|
||||||
proceed in parallel. We could init
|
|
||||||
multiple vorbis_block structures
|
|
||||||
for vd here */
|
|
||||||
|
|
||||||
/* The rest is just a straight decode loop until end of stream */
|
|
||||||
while (!eos) {
|
|
||||||
while (!eos) {
|
|
||||||
int result = ogg_sync_pageout (&oy, &og);
|
|
||||||
|
|
||||||
if (result == 0)
|
|
||||||
break; /* need more data */
|
|
||||||
if (result == -1) { /* missing or corrupt data at this page position */
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
ogg_stream_pagein (&os, &og); /* can safely ignore errors at
|
|
||||||
this point */
|
|
||||||
while (1) {
|
|
||||||
result = ogg_stream_packetout (&os, &op);
|
|
||||||
|
|
||||||
if (result == 0)
|
|
||||||
break; /* need more data */
|
|
||||||
if (result == -1) { /* missing or corrupt data at this page position */
|
|
||||||
/* no reason to complain; already complained above */
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
/* we have a packet. Decode it */
|
|
||||||
float **pcm;
|
|
||||||
int samples;
|
|
||||||
|
|
||||||
if (vorbis_synthesis (&vb, &op) == 0) /* test for success! */
|
|
||||||
vorbis_synthesis_blockin (&vd, &vb);
|
|
||||||
|
|
||||||
/*
|
|
||||||
**pcm is a multichannel double vector. In stereo, for
|
|
||||||
example, pcm[0] is left, and pcm[1] is right. samples is
|
|
||||||
the size of each channel. Convert the float values
|
|
||||||
(-1.<=range<=1.) to whatever PCM format and write it out */
|
|
||||||
|
|
||||||
while ((samples = vorbis_synthesis_pcmout (&vd, &pcm)) > 0) {
|
|
||||||
int j;
|
|
||||||
int clipflag = 0;
|
|
||||||
int bout = (samples < vorbisdec->convsize ? samples : vorbisdec->convsize);
|
|
||||||
|
|
||||||
|
|
||||||
outbuf = gst_buffer_new ();
|
|
||||||
GST_BUFFER_DATA (outbuf) = g_malloc (2 * vorbisdec->vi.channels * bout);
|
|
||||||
GST_BUFFER_SIZE (outbuf) = 2 * vorbisdec->vi.channels * bout;
|
|
||||||
GST_BUFFER_TIMESTAMP (outbuf) = vorbisdec->total_out * GST_SECOND / vorbisdec->vi.rate;
|
|
||||||
|
|
||||||
vorbisdec->total_out += bout;
|
|
||||||
|
|
||||||
/* convert doubles to 16 bit signed ints (host order) and
|
|
||||||
interleave */
|
|
||||||
for (i = 0; i < vorbisdec->vi.channels; i++) {
|
|
||||||
int16_t *ptr = ((int16_t *) GST_BUFFER_DATA (outbuf)) + i;
|
|
||||||
float *mono = pcm[i];
|
|
||||||
|
|
||||||
for (j = 0; j < bout; j++) {
|
|
||||||
int val = mono[j] * 32767.;
|
|
||||||
|
|
||||||
/* might as well guard against clipping */
|
|
||||||
if (val > 32767) {
|
|
||||||
val = 32767;
|
|
||||||
clipflag = 1;
|
|
||||||
}
|
|
||||||
if (val < -32768) {
|
|
||||||
val = -32768;
|
|
||||||
clipflag = 1;
|
|
||||||
}
|
|
||||||
*ptr = val;
|
|
||||||
ptr += vorbisdec->vi.channels;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
GST_DEBUG ("vorbisdec: push");
|
|
||||||
gst_pad_push (vorbisdec->srcpad, outbuf);
|
|
||||||
GST_DEBUG ("vorbisdec: push done");
|
|
||||||
|
|
||||||
vorbis_synthesis_read (&vd, bout); /* tell libvorbis how
|
|
||||||
many samples we
|
|
||||||
actually consumed */
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (ogg_page_eos (&og)) {
|
|
||||||
eos = 1;
|
|
||||||
GST_DEBUG ("vorbisdec: page_eos");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (!eos) {
|
|
||||||
gst_element_yield (GST_ELEMENT (vorbisdec));
|
|
||||||
|
|
||||||
buf = gst_vorbisdec_pull (vorbisdec, &oy);
|
|
||||||
if (buf) {
|
|
||||||
bytes = GST_BUFFER_SIZE (buf);
|
|
||||||
buffer = ogg_sync_buffer (&oy, bytes);
|
|
||||||
memcpy (buffer, GST_BUFFER_DATA (buf), bytes);
|
|
||||||
gst_buffer_unref (buf);
|
|
||||||
|
|
||||||
ogg_sync_wrote (&oy, bytes);
|
|
||||||
if (bytes == 0) {
|
|
||||||
eos = 1;
|
|
||||||
GST_DEBUG ("vorbisdec: wrote 0 bytes");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
eos = 1;
|
|
||||||
GST_DEBUG ("vorbisdec: pulled NULL");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
GST_DEBUG ("vorbisdec: eos flag set");
|
|
||||||
/* clean up this logical bitstream; before exit we see if we're
|
|
||||||
followed by another [chained] */
|
|
||||||
|
|
||||||
ogg_stream_clear (&os);
|
|
||||||
|
|
||||||
/* ogg_page and ogg_packet structs always point to storage in
|
|
||||||
libvorbis. They're never freed or manipulated directly */
|
|
||||||
|
|
||||||
vorbis_block_clear (&vb);
|
|
||||||
vorbis_dsp_clear (&vd);
|
|
||||||
vorbis_info_clear (&vorbisdec->vi); /* must be called last */
|
|
||||||
}
|
|
||||||
end:
|
|
||||||
GST_DEBUG ("vorbisdec: in end");
|
|
||||||
|
|
||||||
gst_pad_push (vorbisdec->srcpad, GST_BUFFER (gst_event_new (GST_EVENT_EOS)));
|
|
||||||
gst_element_set_eos (GST_ELEMENT (vorbisdec));
|
|
||||||
|
|
||||||
/* OK, clean up the framer */
|
|
||||||
ogg_sync_clear (&oy);
|
|
||||||
|
|
||||||
/* FIXME: this might be wrong, or deprecated, so please let me know */
|
|
||||||
gst_element_set_eos (element);
|
|
||||||
}
|
|
||||||
|
|
||||||
static void
|
|
||||||
gst_vorbisdec_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec)
|
|
||||||
{
|
|
||||||
VorbisDec *vorbisdec;
|
|
||||||
|
|
||||||
g_return_if_fail (GST_IS_VORBISDEC (object));
|
|
||||||
|
|
||||||
vorbisdec = GST_VORBISDEC (object);
|
|
||||||
|
|
||||||
switch (prop_id) {
|
|
||||||
case ARG_COMMENT:
|
|
||||||
g_value_set_string (value, "comment");
|
|
||||||
break;
|
|
||||||
case ARG_VENDOR:
|
|
||||||
g_value_set_string (value, vorbisdec->vc.vendor);
|
|
||||||
break;
|
|
||||||
case ARG_VERSION:
|
|
||||||
g_value_set_int (value, vorbisdec->vi.version);
|
|
||||||
break;
|
|
||||||
case ARG_CHANNELS:
|
|
||||||
g_value_set_int (value, vorbisdec->vi.channels);
|
|
||||||
break;
|
|
||||||
case ARG_SAMPLERATE:
|
|
||||||
g_value_set_int (value, vorbisdec->vi.rate);
|
|
||||||
break;
|
|
||||||
case ARG_BITRATE_UPPER:
|
|
||||||
g_value_set_int (value, vorbisdec->vi.bitrate_upper);
|
|
||||||
break;
|
|
||||||
case ARG_BITRATE_NOMINAL:
|
|
||||||
g_value_set_int (value, vorbisdec->vi.bitrate_nominal);
|
|
||||||
break;
|
|
||||||
case ARG_BITRATE_LOWER:
|
|
||||||
g_value_set_int (value, vorbisdec->vi.bitrate_lower);
|
|
||||||
break;
|
|
||||||
case ARG_BITRATE_WINDOW:
|
|
||||||
g_value_set_int (value, vorbisdec->vi.bitrate_window);
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,83 +0,0 @@
|
|||||||
/* GStreamer
|
|
||||||
* Copyright (C) <1999> Erik Walthinsen <omega@cse.ogi.edu>
|
|
||||||
*
|
|
||||||
* 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 __VORBISDEC_H__
|
|
||||||
#define __VORBISDEC_H__
|
|
||||||
|
|
||||||
|
|
||||||
#include <config.h>
|
|
||||||
#include <gst/gst.h>
|
|
||||||
|
|
||||||
#include <vorbis/codec.h>
|
|
||||||
|
|
||||||
#ifdef __cplusplus
|
|
||||||
extern "C" {
|
|
||||||
#endif /* __cplusplus */
|
|
||||||
|
|
||||||
|
|
||||||
#define GST_TYPE_VORBISDEC \
|
|
||||||
(vorbisdec_get_type())
|
|
||||||
#define GST_VORBISDEC(obj) \
|
|
||||||
(G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_VORBISDEC,VorbisDec))
|
|
||||||
#define GST_VORBISDEC_CLASS(klass) \
|
|
||||||
(G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_VORBISDEC,VorbisDecClass))
|
|
||||||
#define GST_IS_VORBISDEC(obj) \
|
|
||||||
(G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_VORBISDEC))
|
|
||||||
#define GST_IS_VORBISDEC_CLASS(obj) \
|
|
||||||
(G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_VORBISDEC))
|
|
||||||
|
|
||||||
typedef struct _VorbisDec VorbisDec;
|
|
||||||
typedef struct _VorbisDecClass VorbisDecClass;
|
|
||||||
|
|
||||||
struct _VorbisDec {
|
|
||||||
GstElement element;
|
|
||||||
|
|
||||||
GstPad *sinkpad,*srcpad;
|
|
||||||
|
|
||||||
ogg_sync_state oy; /* sync and verify incoming physical bitstream */
|
|
||||||
ogg_stream_state os; /* take physical pages, weld into a logical
|
|
||||||
stream of packets */
|
|
||||||
ogg_page og; /* one Ogg bitstream page. Vorbis packets are inside */
|
|
||||||
ogg_packet op; /* one raw packet of data for decode */
|
|
||||||
|
|
||||||
vorbis_info vi; /* struct that stores all the static vorbis bitstream
|
|
||||||
settings */
|
|
||||||
vorbis_comment vc; /* struct that stores all the bitstream user comments */
|
|
||||||
vorbis_dsp_state vd; /* central working state for the packet->PCM decoder */
|
|
||||||
vorbis_block vb; /* local working space for packet->PCM decode */
|
|
||||||
|
|
||||||
gboolean eos;
|
|
||||||
int16_t convsize;
|
|
||||||
guint64 total_out;
|
|
||||||
};
|
|
||||||
|
|
||||||
struct _VorbisDecClass {
|
|
||||||
GstElementClass parent_class;
|
|
||||||
};
|
|
||||||
|
|
||||||
GType vorbisdec_get_type(void);
|
|
||||||
|
|
||||||
|
|
||||||
#ifdef __cplusplus
|
|
||||||
}
|
|
||||||
#endif /* __cplusplus */
|
|
||||||
|
|
||||||
|
|
||||||
#endif /* __VORBISDEC_H__ */
|
|
||||||
Loading…
x
Reference in New Issue
Block a user