mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2024-12-24 17:20:36 +00:00
caps refcounting fixes for float2int fixed wrt setting of caps on int pad with dynamic number of sink pads in float2i...
Original commit message from CVS: * caps refcounting fixes for float2int * fixed wrt setting of caps on int pad with dynamic number of sink pads in float2int * added libsndfile plugin (currently only the src is implemented) - currently only float output, noninterleaved is implemented
This commit is contained in:
parent
c7cc73bfaa
commit
4a65aa251d
5 changed files with 770 additions and 4 deletions
16
configure.ac
16
configure.ac
|
@ -425,10 +425,10 @@ GST_CHECK_FEATURE(XVIDEO, [X11 XVideo extensions], xvideosink, [
|
|||
CFLAGS=$X_CFLAGS
|
||||
|
||||
dnl check for PIC static lib
|
||||
GST_CHECK_LIBHEADER(XVIDEO, Xv_pic, XvQueryExtension, $X_LIBS $X_PRE_LIBS -lXext -lX11 $X_EXTRA_LIBS, X11/extensions/Xvlib.h, XVIDEO_LIBS="-lXv_pic -lXext")
|
||||
GST_CHECK_LIBHEADER(XVIDEO, Xv_pic, XvQueryExtension, $X_LIBS $X_PRE_LIBS -lXext -lX11 $X_EXTRA_LIBS, X11/extensions/Xv.h, XVIDEO_LIBS="-lXv_pic -lXext")
|
||||
if test x$HAVE_XVIDEO = xno; then
|
||||
dnl PIC lib not found, check for regular lib
|
||||
GST_CHECK_LIBHEADER(XVIDEO, Xv, XvQueryExtension, $X_LIBS $X_PRE_LIBS -lXext -lX11 $X_EXTRA_LIBS, X11/extensions/Xvlib.h, XVIDEO_LIBS="-lXv -lXext")
|
||||
GST_CHECK_LIBHEADER(XVIDEO, Xv, XvQueryExtension, $X_LIBS $X_PRE_LIBS -lXext -lX11 $X_EXTRA_LIBS, X11/extensions/Xv.h, XVIDEO_LIBS="-lXv -lXext")
|
||||
fi
|
||||
AC_SUBST(XVIDEO_LIBS)
|
||||
|
||||
|
@ -495,8 +495,7 @@ GST_CHECK_FEATURE(AUDIOFILE, [audiofile], afsink afsrc, [
|
|||
GST_CHECK_CONFIGPROG(AUDIOFILE, audiofile-config)
|
||||
dnl we need this function
|
||||
AC_CHECK_LIB(audiofile, afOpenVirtualFile, , HAVE_AUDIOFILE="no")
|
||||
fi
|
||||
])
|
||||
fi])
|
||||
|
||||
dnl *** CDParanoia ***
|
||||
translit(dnm, m, l) AM_CONDITIONAL(USE_CDPARANOIA, true)
|
||||
|
@ -928,6 +927,14 @@ GST_CHECK_FEATURE(LIBPNG, [snapshot plug-in], snapshot, [
|
|||
AC_SUBST(LIBPNG_LIBS)
|
||||
])
|
||||
|
||||
dnl *** sndfile ***
|
||||
translit(dnm, m, l) AM_CONDITIONAL(USE_SNDFILE, true)
|
||||
GST_CHECK_FEATURE(SNDFILE, [sndfile plug-in], sfsrc sfsink, [
|
||||
PKG_CHECK_MODULES(SNDFILE, sndfile >= 1.0.0, HAVE_SNDFILE="yes", HAVE_SNDFILE="no")
|
||||
AC_SUBST(SNDFILE_CFLAGS)
|
||||
AC_SUBST(SNDFILE_LIBS)
|
||||
])
|
||||
|
||||
dnl *** swfdec ***
|
||||
translit(dnm, m, l) AM_CONDITIONAL(USE_SWFDEC, true)
|
||||
GST_CHECK_FEATURE(SWFDEC, [swfdec plug-in], swfdec, [
|
||||
|
@ -1270,6 +1277,7 @@ ext/shout2/Makefile
|
|||
ext/sidplay/Makefile
|
||||
ext/smoothwave/Makefile
|
||||
ext/snapshot/Makefile
|
||||
ext/sndfile/Makefile
|
||||
ext/swfdec/Makefile
|
||||
ext/vorbis/Makefile
|
||||
ext/tarkin/Makefile
|
||||
|
|
|
@ -214,6 +214,12 @@ else
|
|||
SMOOTHWAVE_DIR=
|
||||
endif
|
||||
|
||||
if USE_SNDFILE
|
||||
SNDFILE_DIR=sndfile
|
||||
else
|
||||
SNDFILE_DIR=
|
||||
endif
|
||||
|
||||
if USE_SWFDEC
|
||||
SWFDEC_DIR=swfdec
|
||||
else
|
||||
|
|
10
ext/sndfile/Makefile.am
Normal file
10
ext/sndfile/Makefile.am
Normal file
|
@ -0,0 +1,10 @@
|
|||
plugindir = $(libdir)/gstreamer-@GST_MAJORMINOR@
|
||||
|
||||
plugin_LTLIBRARIES = libgstsndfile.la
|
||||
|
||||
libgstsndfile_la_SOURCES = gstsf.c
|
||||
libgstsndfile_la_CFLAGS = $(GST_CFLAGS) $(SNDFILE_CFLAGS)
|
||||
libgstsndfile_la_LIBADD = $(SNDFILE_LIBS)
|
||||
libgstsndfile_la_LDFLAGS = $(GST_PLUGIN_LDFLAGS)
|
||||
|
||||
noinst_HEADERS = gstsf.h
|
626
ext/sndfile/gstsf.c
Normal file
626
ext/sndfile/gstsf.c
Normal file
|
@ -0,0 +1,626 @@
|
|||
/* 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.
|
||||
*/
|
||||
|
||||
|
||||
#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 (0, "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
|
||||
};
|
116
ext/sndfile/gstsf.h
Normal file
116
ext/sndfile/gstsf.h
Normal file
|
@ -0,0 +1,116 @@
|
|||
/* 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.
|
||||
*/
|
||||
|
||||
|
||||
#ifndef __GST_SFSINK_H__
|
||||
#define __GST_SFSINK_H__
|
||||
|
||||
|
||||
#include <config.h>
|
||||
#include <gst/gst.h>
|
||||
#include <sndfile.h>
|
||||
|
||||
|
||||
G_BEGIN_DECLS
|
||||
|
||||
|
||||
#define GST_TYPE_SF \
|
||||
(gst_sf_get_type())
|
||||
#define GST_SF(obj) \
|
||||
(G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_SF,GstSF))
|
||||
#define GST_SF_CLASS(klass) \
|
||||
(G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_SF,GstSFClass))
|
||||
#define GST_IS_SF(obj) \
|
||||
(G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_SF))
|
||||
#define GST_IS_SF_CLASS(obj) \
|
||||
(G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_SF))
|
||||
|
||||
#define GST_TYPE_SFSRC \
|
||||
(gst_sfsrc_get_type())
|
||||
#define GST_SFSRC(obj) \
|
||||
(G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_SFSRC,GstSF))
|
||||
#define GST_SFSRC_CLASS(klass) \
|
||||
(G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_SFSRC,GstSFClass))
|
||||
#define GST_IS_SFSRC(obj) \
|
||||
(G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_SFSRC))
|
||||
#define GST_IS_SFSRC_CLASS(obj) \
|
||||
(G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_SFSRC))
|
||||
|
||||
#define GST_TYPE_SFSINK \
|
||||
(gst_sfsink_get_type())
|
||||
#define GST_SFSINK(obj) \
|
||||
(G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_SFSINK,GstSF))
|
||||
#define GST_SFSINK_CLASS(klass) \
|
||||
(G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_SFSINK,GstSFClass))
|
||||
#define GST_IS_SFSINK(obj) \
|
||||
(G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_SFSINK))
|
||||
#define GST_IS_SFSINK_CLASS(obj) \
|
||||
(G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_SFSINK))
|
||||
|
||||
typedef struct _GstSF GstSF;
|
||||
typedef struct _GstSFClass GstSFClass;
|
||||
|
||||
typedef enum {
|
||||
GST_SF_OPEN = GST_ELEMENT_FLAG_LAST,
|
||||
GST_SF_FLAG_LAST = GST_ELEMENT_FLAG_LAST + 2,
|
||||
} GstSFlags;
|
||||
|
||||
typedef struct {
|
||||
GstPad *pad;
|
||||
gint num;
|
||||
gboolean caps_set;
|
||||
} GstSFChannel;
|
||||
|
||||
#define GST_SF_CHANNEL(l) ((GstSFChannel*)l->data)
|
||||
|
||||
struct _GstSF {
|
||||
GstElement element;
|
||||
GList *channels;
|
||||
|
||||
gchar *filename;
|
||||
SNDFILE *file;
|
||||
void *buffer;
|
||||
|
||||
gboolean loop;
|
||||
gboolean create_pads;
|
||||
gint channelcount;
|
||||
gint numchannels;
|
||||
gint format_major;
|
||||
gint format_subtype;
|
||||
gint format;
|
||||
gint rate;
|
||||
};
|
||||
|
||||
struct _GstSFClass {
|
||||
GstElementClass parent_class;
|
||||
};
|
||||
|
||||
GType gst_sf_get_type (void);
|
||||
GType gst_sfsrc_get_type (void);
|
||||
GType gst_sfsink_get_type (void);
|
||||
|
||||
|
||||
G_END_DECLS
|
||||
|
||||
|
||||
#endif /* __GST_SFSINK_H__ */
|
Loading…
Reference in a new issue