diff options
Diffstat (limited to 'sys/oss/gstossgst.c')
| -rw-r--r-- | sys/oss/gstossgst.c | 459 |
1 files changed, 0 insertions, 459 deletions
diff --git a/sys/oss/gstossgst.c b/sys/oss/gstossgst.c deleted file mode 100644 index 0b42185d..00000000 --- a/sys/oss/gstossgst.c +++ /dev/null @@ -1,459 +0,0 @@ -/* GStreamer - * Copyright (C) 1999,2000 Erik Walthinsen <omega@cse.ogi.edu> - * 2000 Wim Taymans <wim.taymans@chello.be> - * - * gstossgst.c: - * - * 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 <sys/types.h> -#include <sys/stat.h> -#include <sys/ioctl.h> -#include <fcntl.h> -#include <sys/soundcard.h> -#include <unistd.h> -#include <errno.h> -#include <stdlib.h> - -#include "gstossgst.h" - -#include "gstosshelper.h" - -static GstElementDetails gst_ossgst_details = GST_ELEMENT_DETAILS ( - "Audio Wrapper (OSS)", - "Source/Audio", - "Hijacks /dev/dsp to get the output of OSS apps into GStreamer", - "Wim Taymans <wim.taymans@chello.be>" -); - -static void gst_ossgst_base_init (gpointer g_class); -static void gst_ossgst_class_init (GstOssGstClass *klass); -static void gst_ossgst_init (GstOssGst *ossgst); - -static GstElementStateReturn gst_ossgst_change_state (GstElement *element); - -static void gst_ossgst_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec); -static void gst_ossgst_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec); - -static GstData* gst_ossgst_get (GstPad *pad); - -/* OssGst signals and args */ -enum { - LAST_SIGNAL -}; - -enum { - ARG_0, - ARG_MUTE, - ARG_PROGRAM, - /* FILL ME */ -}; - -static GstPadTemplate* -ossgst_src_factory (void) -{ - return - gst_pad_template_new ( - "src", - GST_PAD_SRC, - GST_PAD_ALWAYS, - gst_caps_new ( - "ossgst_src", - "audio/x-raw-int", - gst_props_new ( - "endianness", GST_PROPS_INT (G_BYTE_ORDER), - "signed", GST_PROPS_LIST ( - GST_PROPS_BOOLEAN (FALSE), - GST_PROPS_BOOLEAN (TRUE) - ), - "width", GST_PROPS_LIST ( - GST_PROPS_INT (8), - GST_PROPS_INT (16) - ), - "depth", GST_PROPS_LIST ( - GST_PROPS_INT (8), - GST_PROPS_INT (16) - ), - "rate", GST_PROPS_INT_RANGE (8000, 48000), - "channels", GST_PROPS_INT_RANGE (1, 2), - NULL)), - gst_caps_new ( - "ossgst_src", - "audio/x-mulaw", - gst_props_new ( - "rate", GST_PROPS_INT_RANGE (8000, 48000), - "channels", GST_PROPS_INT_RANGE (1, 2), - NULL)), - gst_caps_new ( - "ossgst_src", - "audio/x-alaw", - gst_props_new ( - "rate", GST_PROPS_INT_RANGE (8000, 48000), - "channels", GST_PROPS_INT_RANGE (1, 2), - NULL)), - NULL); -} - - -static GstElementClass *parent_class = NULL; -static GstPadTemplate *gst_ossgst_src_template; - -gchar *__gst_oss_plugin_dir = NULL; - -GType -gst_ossgst_get_type (void) -{ - static GType ossgst_type = 0; - - if (!ossgst_type) { - static const GTypeInfo ossgst_info = { - sizeof(GstOssGstClass), - gst_ossgst_base_init, - NULL, - (GClassInitFunc)gst_ossgst_class_init, - NULL, - NULL, - sizeof(GstOssGst), - 0, - (GInstanceInitFunc)gst_ossgst_init, - }; - ossgst_type = g_type_register_static (GST_TYPE_ELEMENT, "GstOssGst", &ossgst_info, 0); - } - - return ossgst_type; -} - -static void -gst_ossgst_base_init (gpointer g_class) -{ - GstElementClass *element_class = GST_ELEMENT_CLASS (g_class); - - gst_element_class_set_details (element_class, &gst_ossgst_details); - gst_element_class_add_pad_template (element_class, GST_PAD_TEMPLATE_GET (ossgst_src_factory)); -} -static void -gst_ossgst_class_init (GstOssGstClass *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(G_OBJECT_CLASS(klass), ARG_MUTE, - g_param_spec_boolean("mute","mute","mute", - TRUE,G_PARAM_READWRITE)); /* CHECKME */ - g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_PROGRAM, - g_param_spec_string("command","command","command", - NULL, G_PARAM_READWRITE)); /* CHECKME */ - - gobject_class->set_property = gst_ossgst_set_property; - gobject_class->get_property = gst_ossgst_get_property; - - gstelement_class->change_state = gst_ossgst_change_state; -} - -static void -gst_ossgst_init (GstOssGst *ossgst) -{ - ossgst->srcpad = gst_pad_new_from_template (gst_ossgst_src_template, "src"); - gst_element_add_pad (GST_ELEMENT (ossgst), ossgst->srcpad); - - gst_pad_set_get_function (ossgst->srcpad, gst_ossgst_get); - - ossgst->command = NULL; -} - -static GstCaps* -gst_ossgst_format_to_caps (gint format, gint stereo, gint rate) -{ - GstCaps *caps = NULL; - gint law = 0; - gulong endianness = G_BYTE_ORDER; - gboolean is_signed = TRUE; - gint width = 16; - gboolean supported = TRUE; - - GST_DEBUG ("have format 0x%08x %d %d", format, stereo, rate); - - switch (format) { - case AFMT_MU_LAW: - law = 1; - break; - case AFMT_A_LAW: - law = 2; - break; - case AFMT_U8: - width = 8; - is_signed = FALSE; - break; - case AFMT_S16_LE: - width = 16; - endianness = G_LITTLE_ENDIAN; - is_signed = TRUE; - break; - case AFMT_S16_BE: - endianness = G_BIG_ENDIAN; - width = 16; - is_signed = TRUE; - break; - case AFMT_S8: - width = 8; - is_signed = TRUE; - break; - case AFMT_U16_LE: - width = 16; - endianness = G_LITTLE_ENDIAN; - is_signed = FALSE; - break; - case AFMT_U16_BE: - width = 16; - endianness = G_BIG_ENDIAN; - is_signed = FALSE; - break; - case AFMT_IMA_ADPCM: - case AFMT_MPEG: -#ifdef AFMT_AC3 - case AFMT_AC3: -#endif - default: - supported = FALSE; - break; - } - - if (supported) { - switch (law) { - case 0: - caps = gst_caps_new ( - "ossgst_caps", - "audio/x-raw-int", - gst_props_new ( - "endianness", GST_PROPS_INT (endianness), - "signed", GST_PROPS_BOOLEAN (is_signed), - "width", GST_PROPS_INT (width), - "depth", GST_PROPS_INT (width), - "rate", GST_PROPS_INT (rate), - "channels", GST_PROPS_INT (stereo?2:1), - NULL)); - break; - case 1: - caps = gst_caps_new ( - "ossgst_caps", - "audio/x-mulaw", - gst_props_new ( - "rate", GST_PROPS_INT (rate), - "channels", GST_PROPS_INT (stereo?2:1), - NULL)); - break; - case 2: - caps = gst_caps_new ( - "ossgst_caps", - "audio/x-alaw", - gst_props_new ( - "rate", GST_PROPS_INT (rate), - "channels", GST_PROPS_INT (stereo?2:1), - NULL)); - break; - } - } - else { - g_warning ("gstossgst: program tried to use unsupported format %x\n", format); - } - - return caps; -} - -static GstData* -gst_ossgst_get (GstPad *pad) -{ - GstOssGst *ossgst; - GstBuffer *buf = NULL; - command cmd; - gboolean have_data = FALSE; - - g_return_val_if_fail (pad != NULL, NULL); - g_return_val_if_fail (GST_IS_PAD (pad), NULL); - - /* this has to be an audio buffer */ - ossgst = GST_OSSGST (gst_pad_get_parent (pad)); - - while (!have_data) { - /* read the command */ - read (ossgst->fdout[0], &cmd, sizeof (command)); - - switch (cmd.id) { - case CMD_DATA: - buf = gst_buffer_new (); - GST_BUFFER_SIZE (buf) = cmd.cmd.length; - GST_BUFFER_DATA (buf) = g_malloc (GST_BUFFER_SIZE (buf)); - - GST_BUFFER_SIZE (buf) = read (ossgst->fdout[0], GST_BUFFER_DATA (buf), GST_BUFFER_SIZE (buf)); - have_data = TRUE; - break; - case CMD_FORMAT: - { - GstCaps *caps; - - caps = gst_ossgst_format_to_caps (cmd.cmd.format.format, - cmd.cmd.format.stereo, - cmd.cmd.format.rate); - - gst_pad_try_set_caps (ossgst->srcpad, caps); - } - break; - default: - break; - } - } - - return GST_DATA (buf); -} - -static void -gst_ossgst_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec) -{ - GstOssGst *ossgst; - - /* it's not null if we got it, but it might not be ours */ - g_return_if_fail (GST_IS_OSSGST (object)); - - ossgst = GST_OSSGST (object); - - switch (prop_id) { - case ARG_MUTE: - ossgst->mute = g_value_get_boolean (value); - break; - case ARG_PROGRAM: - if (ossgst->command) - g_free (ossgst->command); - ossgst->command = g_strdup (g_value_get_string (value)); - break; - default: - break; - } -} - -static void -gst_ossgst_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec) -{ - GstOssGst *ossgst; - - /* it's not null if we got it, but it might not be ours */ - g_return_if_fail (GST_IS_OSSGST (object)); - - ossgst = GST_OSSGST (object); - - switch (prop_id) { - case ARG_MUTE: - g_value_set_boolean (value, ossgst->mute); - break; - case ARG_PROGRAM: - g_value_set_string (value, ossgst->command); - break; - default: - break; - } -} - -static gboolean -gst_ossgst_spawn_process (GstOssGst *ossgst) -{ - static gchar *ld_preload; - - pipe(ossgst->fdin); - pipe(ossgst->fdout); - - GST_DEBUG ("about to fork"); - - if((ossgst->childpid = fork()) == -1) - { - perror("fork"); - gst_element_error(GST_ELEMENT(ossgst),"forking"); - return FALSE; - } - GST_DEBUG ("forked %d", ossgst->childpid); - - if(ossgst->childpid == 0) - { - gchar **args; - - GST_DEBUG ("fork command %d", ossgst->childpid); - - ld_preload = getenv ("LD_PRELOAD"); - - if (ld_preload == NULL) { - ld_preload = ""; - } - - ld_preload = g_strconcat (ld_preload, " ", __gst_oss_plugin_dir, G_DIR_SEPARATOR_S, - "libgstosshelper.so", NULL); - - setenv ("LD_PRELOAD", ld_preload, TRUE); - - /* child */ - dup2(ossgst->fdin[0], HELPER_MAGIC_IN); /* set the childs input stream */ - dup2(ossgst->fdout[1], HELPER_MAGIC_OUT); /* set the childs output stream */ - - /* split the arguments */ - args = g_strsplit (ossgst->command, " ", 0); - - execvp(args[0], args); - - /* will only reach if error */ - perror("exec"); - gst_element_error(GST_ELEMENT(ossgst),"starting child process"); - return FALSE; - - } - GST_FLAG_SET(ossgst,GST_OSSGST_OPEN); - - return TRUE; -} - -static gboolean -gst_ossgst_kill_process (GstOssGst *ossgst) -{ - return TRUE; -} - -static GstElementStateReturn -gst_ossgst_change_state (GstElement *element) -{ - g_return_val_if_fail (GST_IS_OSSGST (element), FALSE); - - if (GST_STATE_PENDING (element) == GST_STATE_NULL) { - if (GST_FLAG_IS_SET (element, GST_OSSGST_OPEN)) - gst_ossgst_kill_process (GST_OSSGST (element)); - } else { - if (!GST_FLAG_IS_SET (element, GST_OSSGST_OPEN)) { - if (!gst_ossgst_spawn_process (GST_OSSGST (element))) { - return GST_STATE_FAILURE; - } - } - } - - if (GST_ELEMENT_CLASS (parent_class)->change_state) - return GST_ELEMENT_CLASS (parent_class)->change_state (element); - return GST_STATE_SUCCESS; -} - |