gstreamer/ext/sndfile/gstsf.c
Benjamin Otte f4a7caa418 compatibility fix for new GST_DEBUG stuff.
Original commit message from CVS:
compatibility fix for new GST_DEBUG stuff.
Includes fixes for missing includes for config.h and unistd.h

I only ensured for plugins I can build that they work, so if some of them are still broken, you gotta fix them yourselves unfortunately.
2003-06-29 19:46:13 +00:00

629 lines
18 KiB
C

/* GStreamer
* Copyright (C) 1999,2000 Erik Walthinsen <omega@cse.ogi.edu>
* 2000 Wim Taymans <wtay@chello.be>
* 2003 Andy Wingo <wingo at pobox dot com>
*
* gstsf.c: libsndfile plugin for GStreamer
*
* 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/gst.h>
#include <string.h>
#include "gstsf.h"
static GstElementDetails sfsrc_details = {
"Sndfile Source",
"Source/Audio",
"LGPL",
"Read audio streams from disk using libsndfile",
VERSION,
"Andy Wingo <wingo at pobox dot com>",
"(C) 2003"
};
static GstElementDetails sfsink_details = {
"Sndfile Sink",
"Sink/Audio",
"LGPL",
"Write audio streams to disk using libsndfile",
VERSION,
"Andy Wingo <wingo at pobox dot com>",
"(C) 2003"
};
enum {
ARG_0,
ARG_LOCATION,
ARG_MAJOR_TYPE,
ARG_MINOR_TYPE,
ARG_LOOP,
ARG_CREATE_PADS
};
#define GST_SF_BUF_BYTES 2048
#define GST_SF_BUF_FRAMES (GST_SF_BUF_BYTES / sizeof(float))
GST_PAD_TEMPLATE_FACTORY (sf_src_factory,
"src%d",
GST_PAD_SRC,
GST_PAD_REQUEST,
GST_CAPS_NEW (
"sf_src",
"audio/raw",
"rate", GST_PROPS_INT_RANGE (1, G_MAXINT),
"format", GST_PROPS_STRING ("float"),
"layout", GST_PROPS_STRING ("gfloat"),
"intercept", GST_PROPS_FLOAT(0.0),
"slope", GST_PROPS_FLOAT(1.0),
"channels", GST_PROPS_INT (1)
)
);
GST_PAD_TEMPLATE_FACTORY (sf_sink_factory,
"sink%d",
GST_PAD_SINK,
GST_PAD_REQUEST,
GST_CAPS_NEW (
"sf_sink",
"audio/raw",
"rate", GST_PROPS_INT_RANGE (1, G_MAXINT),
"format", GST_PROPS_STRING ("float"),
"layout", GST_PROPS_STRING ("gfloat"),
"intercept", GST_PROPS_FLOAT(0.0),
"slope", GST_PROPS_FLOAT(1.0),
"channels", GST_PROPS_INT (1)
)
);
#define GST_TYPE_SF_MAJOR_TYPES (gst_sf_major_types_get_type())
static GType
gst_sf_major_types_get_type (void)
{
static GType sf_major_types_type = 0;
static GEnumValue *sf_major_types = NULL;
if (!sf_major_types_type)
{
SF_FORMAT_INFO format_info;
int k, count ;
sf_command (NULL, SFC_GET_FORMAT_MAJOR_COUNT, &count, sizeof (int)) ;
sf_major_types = g_new0 (GEnumValue, count + 1);
for (k = 0 ; k < count ; k++) {
format_info.format = k ;
sf_command (NULL, SFC_GET_FORMAT_MAJOR, &format_info, sizeof (format_info));
sf_major_types[k].value = format_info.format;
sf_major_types[k].value_name = g_strdup (format_info.name);
sf_major_types[k].value_nick = g_strdup (format_info.extension);
/* Irritatingly enough, there exist major_types with the same extension. Let's
just hope that sndfile gives us the list in alphabetical order, as it
currently does. */
if (k > 0 && strcmp (sf_major_types[k].value_nick, sf_major_types[k-1].value_nick) == 0) {
g_free (sf_major_types[k].value_nick);
sf_major_types[k].value_nick = g_strconcat (sf_major_types[k-1].value_nick, "-",
sf_major_types[k].value_name, NULL);
g_strcanon (sf_major_types[k].value_nick,
G_CSET_A_2_Z G_CSET_a_2_z G_CSET_DIGITS "-", '-');
}
}
sf_major_types_type = g_enum_register_static ("GstSndfileMajorTypes", sf_major_types);
}
return sf_major_types_type;
}
#define GST_TYPE_SF_MINOR_TYPES (gst_sf_minor_types_get_type())
static GType
gst_sf_minor_types_get_type (void)
{
static GType sf_minor_types_type = 0;
static GEnumValue *sf_minor_types = NULL;
if (!sf_minor_types_type)
{
SF_FORMAT_INFO format_info;
int k, count ;
sf_command (NULL, SFC_GET_FORMAT_SUBTYPE_COUNT, &count, sizeof (int)) ;
sf_minor_types = g_new0 (GEnumValue, count + 1);
for (k = 0 ; k < count ; k++) {
format_info.format = k ;
sf_command (NULL, SFC_GET_FORMAT_SUBTYPE, &format_info, sizeof (format_info));
sf_minor_types[k].value = format_info.format;
sf_minor_types[k].value_name = g_strdup (format_info.name);
sf_minor_types[k].value_nick = g_ascii_strdown (format_info.name, -1);
g_strcanon (sf_minor_types[k].value_nick, G_CSET_a_2_z G_CSET_DIGITS "-", '-');
}
sf_minor_types_type = g_enum_register_static ("GstSndfileMinorTypes", sf_minor_types);
}
return sf_minor_types_type;
}
static void gst_sf_class_init (GstSFClass *klass);
static void gst_sf_init (GstSF *this);
static gboolean gst_sf_open_file (GstSF *this);
static void gst_sf_close_file (GstSF *this);
static void gst_sf_loop (GstElement *element);
static void gst_sf_set_property (GObject *object, guint prop_id, const GValue *value,
GParamSpec *pspec);
static void gst_sf_get_property (GObject *object, guint prop_id, GValue *value,
GParamSpec *pspec);
static GstPad* gst_sf_request_new_pad (GstElement *element, GstPadTemplate *templ,
const gchar *unused);
static GstElementStateReturn gst_sf_change_state (GstElement *element);
static GstPadLinkReturn gst_sf_link (GstPad *pad, GstCaps *caps);
static GstElementClass *parent_class = NULL;
GType
gst_sf_get_type (void)
{
static GType sf_type = 0;
if (!sf_type) {
static const GTypeInfo sf_info = {
sizeof (GstSFClass), NULL,
NULL,
(GClassInitFunc)NULL, /* don't even initialize the class */
NULL,
NULL,
sizeof (GstSF),
0,
(GInstanceInitFunc)NULL /* abstract base class */
};
sf_type = g_type_register_static (GST_TYPE_ELEMENT, "GstSF", &sf_info, 0);
}
return sf_type;
}
GType
gst_sfsrc_get_type (void)
{
static GType sfsrc_type = 0;
if (!sfsrc_type) {
static const GTypeInfo sfsrc_info = {
sizeof (GstSFClass), NULL,
NULL,
(GClassInitFunc) gst_sf_class_init,
NULL,
NULL,
sizeof (GstSF),
0,
(GInstanceInitFunc) gst_sf_init,
};
sfsrc_type = g_type_register_static (GST_TYPE_SF, "GstSFSrc", &sfsrc_info, 0);
}
return sfsrc_type;
}
GType
gst_sfsink_get_type (void)
{
static GType sfsink_type = 0;
if (!sfsink_type) {
static const GTypeInfo sfsink_info = {
sizeof (GstSFClass), NULL,
NULL,
(GClassInitFunc) gst_sf_class_init,
NULL,
NULL,
sizeof (GstSF),
0,
(GInstanceInitFunc) gst_sf_init,
};
sfsink_type = g_type_register_static (GST_TYPE_SF, "GstSFSink", &sfsink_info, 0);
}
return sfsink_type;
}
static void
gst_sf_class_init (GstSFClass *klass)
{
GObjectClass *gobject_class;
GstElementClass *gstelement_class;
GParamSpec *pspec;
gobject_class = (GObjectClass*)klass;
gstelement_class = (GstElementClass*)klass;
/* although this isn't really the parent class, that's ok; GstSF doesn't
override any methods */
parent_class = g_type_class_ref (GST_TYPE_ELEMENT);
gst_element_class_install_std_props (gstelement_class, "location",
ARG_LOCATION, G_PARAM_READWRITE, NULL);
pspec = g_param_spec_enum
("major-type", "Major type", "Major output type", GST_TYPE_SF_MAJOR_TYPES,
SF_FORMAT_WAV, G_PARAM_READWRITE | G_PARAM_CONSTRUCT);
g_object_class_install_property (gobject_class, ARG_MAJOR_TYPE, pspec);
pspec = g_param_spec_enum
("minor-type", "Minor type", "Minor output type", GST_TYPE_SF_MINOR_TYPES,
SF_FORMAT_FLOAT, G_PARAM_READWRITE | G_PARAM_CONSTRUCT);
g_object_class_install_property (gobject_class, ARG_MINOR_TYPE, pspec);
if (G_TYPE_FROM_CLASS (klass) == GST_TYPE_SFSRC) {
pspec = g_param_spec_boolean ("loop", "Loop?", "Loop the output?",
FALSE, G_PARAM_READWRITE | G_PARAM_CONSTRUCT);
g_object_class_install_property (gobject_class, ARG_LOOP, pspec);
pspec = g_param_spec_boolean ("create-pads", "Create pads?", "Create one pad for each channel in the sound file?",
TRUE, G_PARAM_READWRITE | G_PARAM_CONSTRUCT);
g_object_class_install_property (gobject_class, ARG_CREATE_PADS, pspec);
}
gobject_class->set_property = gst_sf_set_property;
gobject_class->get_property = gst_sf_get_property;
gstelement_class->change_state = gst_sf_change_state;
gstelement_class->request_new_pad = gst_sf_request_new_pad;
}
static void
gst_sf_init (GstSF *this)
{
gst_element_set_loop_function (GST_ELEMENT (this), gst_sf_loop);
}
static GstPad*
gst_sf_request_new_pad (GstElement *element, GstPadTemplate *templ,
const gchar *unused)
{
gchar *name;
GstSF *this;
GstSFChannel *channel;
this = GST_SF (element);
channel = g_new0 (GstSFChannel, 1);
if (templ->direction == GST_PAD_SINK) {
/* we have an SFSink */
name = g_strdup_printf ("sink%d", this->channelcount);
this->numchannels++;
if (this->file) {
gst_sf_close_file (this);
gst_sf_open_file (this);
}
} else {
/* we have an SFSrc */
name = g_strdup_printf ("src%d", this->channelcount);
}
channel->pad = gst_pad_new_from_template (templ, name);
gst_element_add_pad (GST_ELEMENT (this), channel->pad);
gst_pad_set_link_function (channel->pad, gst_sf_link);
this->channels = g_list_append (this->channels, channel);
this->channelcount++;
GST_DEBUG ("sf added pad %s\n", name);
g_free (name);
return channel->pad;
}
static GstPadLinkReturn
gst_sf_link (GstPad *pad, GstCaps *caps)
{
GstSF *this = (GstSF*)GST_OBJECT_PARENT (pad);
gst_caps_get_int (caps, "rate", &this->rate);
return GST_PAD_LINK_OK;
}
static void
gst_sf_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec)
{
GstSF *this = GST_SF (object);
switch (prop_id) {
case ARG_LOCATION:
if (GST_FLAG_IS_SET (object, GST_SF_OPEN))
gst_sf_close_file (this);
if (this->filename)
g_free (this->filename);
if (g_value_get_string (value))
this->filename = g_strdup (g_value_get_string (value));
else
this->filename = NULL;
if (this->filename)
gst_sf_open_file (this);
break;
case ARG_MAJOR_TYPE:
this->format_major = g_value_get_enum (value);
break;
case ARG_MINOR_TYPE:
this->format_subtype = g_value_get_enum (value);
break;
case ARG_LOOP:
this->loop = g_value_get_boolean (value);
break;
case ARG_CREATE_PADS:
this->create_pads = g_value_get_boolean (value);
if (this->file && this->create_pads) {
int i;
for (i=g_list_length (this->channels); i<this->numchannels; i++)
gst_element_get_request_pad ((GstElement*)this, "src%d");
}
break;
default:
break;
}
}
static void
gst_sf_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec)
{
GstSF *this = GST_SF (object);
switch (prop_id) {
case ARG_LOCATION:
g_value_set_string (value, this->filename);
break;
case ARG_MAJOR_TYPE:
g_value_set_enum (value, this->format_major);
break;
case ARG_MINOR_TYPE:
g_value_set_enum (value, this->format_subtype);
break;
case ARG_LOOP:
g_value_set_boolean (value, this->loop);
break;
case ARG_CREATE_PADS:
g_value_set_boolean (value, this->create_pads);
break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break;
}
}
static gboolean
gst_sf_open_file (GstSF *this)
{
int mode;
SF_INFO info;
g_return_val_if_fail (!GST_FLAG_IS_SET (this, GST_SF_OPEN), FALSE);
if (!this->filename) {
gst_element_error (GST_ELEMENT (this), "sndfile::location was not set");
return FALSE;
}
if (GST_IS_SFSRC (this)) {
mode = SFM_READ;
info.format = 0;
} else {
mode = SFM_WRITE;
this->format = this->format_major | this->format_subtype;
info.samplerate = this->rate;
info.channels = this->numchannels;
info.format = this->format;
if (!sf_format_check (&info)) {
gst_element_error (GST_ELEMENT (this),
g_strdup_printf ("Input parameters (rate:%d, channels:%d, format:%x) invalid",
info.samplerate, info.channels, info.format));
return FALSE;
}
}
this->file = sf_open (this->filename, mode, &info);
if (!this->file) {
gst_element_error (GST_ELEMENT (this),
g_strdup_printf ("could not open file \"%s\": %s",
this->filename, sf_strerror (NULL)));
return FALSE;
}
if (GST_IS_SFSRC (this)) {
GList *l = NULL;
/* the number of channels in the file can be different than the number of
* pads */
this->numchannels = info.channels;
this->rate = info.samplerate;
if (this->create_pads) {
int i;
for (i=g_list_length (this->channels); i<this->numchannels; i++)
gst_element_get_request_pad ((GstElement*)this, "src%d");
}
for (l=this->channels; l; l=l->next)
/* queue the need to set caps */
GST_SF_CHANNEL (l)->caps_set = FALSE;
}
this->buffer = g_malloc (this->numchannels * GST_SF_BUF_BYTES);
GST_FLAG_SET (this, GST_SF_OPEN);
return TRUE;
}
static void
gst_sf_close_file (GstSF *this)
{
int err = 0;
g_return_if_fail (GST_FLAG_IS_SET (this, GST_SF_OPEN));
if ((err = sf_close (this->file)))
gst_element_error (GST_ELEMENT (this),
g_strdup_printf ("sndfile: could not close file \"%s\": %s",
this->filename, sf_error_number (err)));
else
GST_FLAG_UNSET (this, GST_SF_OPEN);
this->file = NULL;
if (this->buffer)
g_free (this->buffer);
this->buffer = NULL;
}
static void
gst_sf_loop (GstElement *element)
{
GstSF *this;
GList *l = NULL;
this = (GstSF*)element;
if (this->channels == NULL) {
gst_element_error (element, "You must connect at least one pad to soundfile elements.");
return;
}
if (!GST_FLAG_IS_SET (this, GST_SF_OPEN))
if (!gst_sf_open_file (this))
return; /* we've already set gst_element_error */
if (GST_IS_SFSRC (this)) {
sf_count_t read;
gint i, j;
int eos = 0;
int nchannels = this->numchannels;
GstSFChannel *channel = NULL;
gfloat *data;
gfloat *buf = this->buffer;
GstBuffer *out;
read = sf_readf_float (this->file, buf, GST_SF_BUF_FRAMES);
if (read < GST_SF_BUF_FRAMES)
eos = 1;
if (read)
for (i=0,l=this->channels; l; l=l->next,i++) {
channel = GST_SF_CHANNEL (l);
/* don't push on disconnected pads -- useful for ::create-pads=TRUE*/
if (!GST_PAD_PEER (channel->pad))
continue;
if (!channel->caps_set) {
GstCaps *caps = GST_PAD_CAPS (GST_SF_CHANNEL (l)->pad);
if (!caps)
caps = gst_caps_copy
(GST_PAD_TEMPLATE_CAPS (GST_PAD_PAD_TEMPLATE (GST_SF_CHANNEL (l)->pad)));
gst_caps_set (caps, "rate", GST_PROPS_INT (this->rate), NULL);
/* we know it's fixed, yo. */
GST_CAPS_FLAG_SET (caps, GST_CAPS_FIXED);
if (!gst_pad_try_set_caps (GST_SF_CHANNEL (l)->pad, caps)) {
gst_element_error (GST_ELEMENT (this),
g_strdup_printf ("Opened file with sample rate %d, but could not set caps",
this->rate));
sf_close (this->file);
this->file = NULL;
g_free (this->buffer);
this->buffer = NULL;
return;
}
channel->caps_set = TRUE;
}
out = gst_buffer_new_and_alloc (read * sizeof(float));
data = (gfloat*)GST_BUFFER_DATA (out);
for (j=0; j<read; j++)
data[j] = buf[j * nchannels + i % nchannels];
gst_pad_push (channel->pad, out);
}
if (eos) {
if (this->loop) {
sf_seek (this->file, (sf_count_t)0, SEEK_SET);
eos = 0;
} else {
for (l=this->channels; l; l=l->next)
gst_pad_push (GST_SF_CHANNEL (l)->pad, gst_event_new (GST_EVENT_EOS));
gst_element_set_eos (element);
}
}
} else {
/* unimplemented */
}
}
static GstElementStateReturn
gst_sf_change_state (GstElement *element)
{
g_return_val_if_fail (GST_IS_SF (element), GST_STATE_FAILURE);
/* if going to NULL then close the file */
if (GST_STATE_PENDING (element) == GST_STATE_NULL)
if (GST_FLAG_IS_SET (element, GST_SF_OPEN))
gst_sf_close_file (GST_SF (element));
if (GST_ELEMENT_CLASS (parent_class)->change_state)
return GST_ELEMENT_CLASS (parent_class)->change_state (element);
return GST_STATE_SUCCESS;
}
static gboolean
plugin_init (GModule *module, GstPlugin *plugin)
{
GstElementFactory *factory;
factory = gst_element_factory_new ("sfsrc", GST_TYPE_SFSRC,
&sfsrc_details);
g_return_val_if_fail (factory != NULL, FALSE);
gst_element_factory_add_pad_template (factory, GST_PAD_TEMPLATE_GET (sf_src_factory));
gst_plugin_add_feature (plugin, GST_PLUGIN_FEATURE (factory));
factory = gst_element_factory_new ("sfsink", GST_TYPE_SFSINK,
&sfsink_details);
g_return_val_if_fail (factory != NULL, FALSE);
gst_element_factory_add_pad_template (factory, GST_PAD_TEMPLATE_GET (sf_sink_factory));
gst_plugin_add_feature (plugin, GST_PLUGIN_FEATURE (factory));
return TRUE;
}
GstPluginDesc plugin_desc = {
GST_VERSION_MAJOR,
GST_VERSION_MINOR,
"gstsf",
plugin_init
};