This is a megapatch with the following changes:
[platform/upstream/gstreamer.git] / plugins / elements / gstaudiosrc.c
1 /* GStreamer
2  * Copyright (C) 1999,2000 Erik Walthinsen <omega@cse.ogi.edu>
3  *                    2000 Wim Taymans <wtay@chello.be>
4  *
5  * gstaudiosrc.c: 
6  *
7  * This library is free software; you can redistribute it and/or
8  * modify it under the terms of the GNU Library General Public
9  * License as published by the Free Software Foundation; either
10  * version 2 of the License, or (at your option) any later version.
11  *
12  * This library is distributed in the hope that it will be useful,
13  * but WITHOUT ANY WARRANTY; without even the implied warranty of
14  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
15  * Library General Public License for more details.
16  *
17  * You should have received a copy of the GNU Library General Public
18  * License along with this library; if not, write to the
19  * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
20  * Boston, MA 02111-1307, USA.
21  */
22
23 #include <sys/types.h>
24 #include <sys/stat.h>
25 #include <fcntl.h>
26 #include <sys/soundcard.h>
27 #include <sys/ioctl.h>
28 #include <unistd.h>
29
30 #include <gstaudiosrc.h>
31
32
33 GstElementDetails gst_audiosrc_details = {
34   "Audio (OSS) Source",
35   "Source/Audio",
36   "Read from the sound card",
37   VERSION,
38   "Erik Walthinsen <omega@cse.ogi.edu>",
39   "(C) 1999",
40 };
41
42
43 /* AudioSrc signals and args */
44 enum {
45   /* FILL ME */
46   LAST_SIGNAL
47 };
48
49 enum {
50   ARG_0,
51   ARG_BYTESPERREAD,
52   ARG_CUROFFSET,
53   ARG_FORMAT,
54   ARG_CHANNELS,
55   ARG_FREQUENCY,
56 };
57
58
59 static void                     gst_audiosrc_class_init         (GstAudioSrcClass *klass);
60 static void                     gst_audiosrc_init               (GstAudioSrc *audiosrc);
61
62 static void                     gst_audiosrc_set_arg            (GtkObject *object, GtkArg *arg, guint id);
63 static void                     gst_audiosrc_get_arg            (GtkObject *object, GtkArg *arg, guint id);
64 static GstElementStateReturn    gst_audiosrc_change_state       (GstElement *element);
65
66 static void                     gst_audiosrc_close_audio        (GstAudioSrc *src);
67 static gboolean                 gst_audiosrc_open_audio         (GstAudioSrc *src);
68 static void                     gst_audiosrc_sync_parms         (GstAudioSrc *audiosrc);
69
70 static GstBuffer *              gst_audiosrc_get                (GstPad *pad);
71
72 static GstElementClass *parent_class = NULL;
73 //static guint gst_audiosrc_signals[LAST_SIGNAL] = { 0 };
74
75 GtkType
76 gst_audiosrc_get_type (void) 
77 {
78   static GtkType audiosrc_type = 0;
79
80   if (!audiosrc_type) {
81     static const GtkTypeInfo audiosrc_info = {
82       "GstAudioSrc",
83       sizeof(GstAudioSrc),
84       sizeof(GstAudioSrcClass),
85       (GtkClassInitFunc)gst_audiosrc_class_init,
86       (GtkObjectInitFunc)gst_audiosrc_init,
87       (GtkArgSetFunc)gst_audiosrc_set_arg,
88       (GtkArgGetFunc)gst_audiosrc_get_arg,
89       (GtkClassInitFunc)NULL,
90     };
91     audiosrc_type = gtk_type_unique (GST_TYPE_ELEMENT, &audiosrc_info);
92   }
93   return audiosrc_type;
94 }
95
96 static void
97 gst_audiosrc_class_init (GstAudioSrcClass *klass) 
98 {
99   GtkObjectClass *gtkobject_class;
100   GstElementClass *gstelement_class;
101
102   gtkobject_class = (GtkObjectClass*)klass;
103   gstelement_class = (GstElementClass*)klass;
104
105   parent_class = gtk_type_class (GST_TYPE_ELEMENT);
106
107   gtk_object_add_arg_type ("GstAudioSrc::bytes_per_read", GTK_TYPE_ULONG,
108                            GTK_ARG_READWRITE, ARG_BYTESPERREAD);
109   gtk_object_add_arg_type ("GstAudioSrc::curoffset", GTK_TYPE_ULONG,
110                            GTK_ARG_READABLE, ARG_CUROFFSET);
111   gtk_object_add_arg_type ("GstAudioSrc::format", GTK_TYPE_INT,
112                            GTK_ARG_READWRITE, ARG_FORMAT);
113   gtk_object_add_arg_type ("GstAudioSrc::channels", GTK_TYPE_INT,
114                            GTK_ARG_READWRITE, ARG_CHANNELS);
115   gtk_object_add_arg_type ("GstAudioSrc::frequency", GTK_TYPE_INT,
116                            GTK_ARG_READWRITE, ARG_FREQUENCY);
117
118   gtkobject_class->set_arg = gst_audiosrc_set_arg;
119   gtkobject_class->get_arg = gst_audiosrc_get_arg;
120
121   gstelement_class->change_state = gst_audiosrc_change_state;
122 }
123
124 static void 
125 gst_audiosrc_init (GstAudioSrc *audiosrc) 
126 {
127   audiosrc->srcpad = gst_pad_new ("src", GST_PAD_SRC);
128   gst_pad_set_get_function(audiosrc->srcpad,gst_audiosrc_get);
129   gst_element_add_pad (GST_ELEMENT (audiosrc), audiosrc->srcpad);
130
131   audiosrc->fd = -1;
132
133 //  audiosrc->meta = (MetaAudioRaw *)gst_meta_new();
134 //  audiosrc->meta->format = AFMT_S16_LE;
135 //  audiosrc->meta->channels = 2;
136 //  audiosrc->meta->frequency = 44100;
137 //  audiosrc->meta->bps = 4;
138
139   audiosrc->bytes_per_read = 4096;
140   audiosrc->curoffset = 0;
141   audiosrc->seq = 0;
142 }
143
144 static GstBuffer *
145 gst_audiosrc_get (GstPad *pad)
146 {
147   GstAudioSrc *src;
148   GstBuffer *buf;
149   glong readbytes;
150
151   g_return_val_if_fail (pad != NULL, NULL);
152   src = GST_AUDIOSRC(gst_pad_get_parent (pad));
153
154 //  g_print("attempting to read something from soundcard\n");
155
156   buf = gst_buffer_new ();
157   g_return_val_if_fail (buf, NULL);
158   
159   GST_BUFFER_DATA (buf) = (gpointer)g_malloc (src->bytes_per_read);
160
161   readbytes = read (src->fd,GST_BUFFER_DATA (buf),
162                     src->bytes_per_read);
163
164   if (readbytes == 0) {
165     gst_element_signal_eos (GST_ELEMENT (src));
166     return NULL;
167   }
168
169   GST_BUFFER_SIZE (buf) = readbytes;
170   GST_BUFFER_OFFSET (buf) = src->curoffset;
171   
172   src->curoffset += readbytes;
173
174 //  gst_buffer_add_meta(buf,GST_META(newmeta));
175
176 //  g_print("pushed buffer from soundcard of %d bytes\n",readbytes);
177   return buf;
178 }
179
180 static void 
181 gst_audiosrc_set_arg (GtkObject *object, GtkArg *arg, guint id) 
182 {
183   GstAudioSrc *src;
184
185   /* it's not null if we got it, but it might not be ours */
186   g_return_if_fail (GST_IS_AUDIOSRC (object));
187   
188   src = GST_AUDIOSRC (object);
189
190   switch (id) {
191     case ARG_BYTESPERREAD:
192       src->bytes_per_read = GTK_VALUE_INT (*arg);
193       break;
194     case ARG_FORMAT:
195       src->format = GTK_VALUE_INT (*arg);
196       break;
197     case ARG_CHANNELS:
198       src->channels = GTK_VALUE_INT (*arg);
199       break;
200     case ARG_FREQUENCY:
201       src->frequency = GTK_VALUE_INT (*arg);
202       break;
203     default:
204       break;
205   }
206 }
207
208 static void 
209 gst_audiosrc_get_arg (GtkObject *object, GtkArg *arg, guint id) 
210 {
211   GstAudioSrc *src;
212
213   /* it's not null if we got it, but it might not be ours */
214   g_return_if_fail (GST_IS_AUDIOSRC (object));
215   
216   src = GST_AUDIOSRC (object);
217
218   switch (id) {
219     case ARG_BYTESPERREAD:
220       GTK_VALUE_INT (*arg) = src->bytes_per_read;
221       break;
222     case ARG_FORMAT:
223       GTK_VALUE_INT (*arg) = src->format;
224       break;
225     case ARG_CHANNELS:
226       GTK_VALUE_INT (*arg) = src->channels;
227       break;
228     case ARG_FREQUENCY:
229       GTK_VALUE_INT (*arg) = src->frequency;
230       break;
231     default:
232       arg->type = GTK_TYPE_INVALID;
233       break;
234   }
235 }
236
237 static GstElementStateReturn 
238 gst_audiosrc_change_state (GstElement *element) 
239 {
240   g_return_val_if_fail (GST_IS_AUDIOSRC (element), FALSE);
241
242   /* if going down into NULL state, close the file if it's open */
243   if (GST_STATE_PENDING (element) == GST_STATE_NULL) {
244     if (GST_FLAG_IS_SET (element, GST_AUDIOSRC_OPEN))
245       gst_audiosrc_close_audio (GST_AUDIOSRC (element));
246   /* otherwise (READY or higher) we need to open the sound card */
247   } else {
248     if (!GST_FLAG_IS_SET (element, GST_AUDIOSRC_OPEN)) { 
249       if (!gst_audiosrc_open_audio (GST_AUDIOSRC (element)))
250         return GST_STATE_FAILURE;
251     }
252   }
253
254   if (GST_ELEMENT_CLASS (parent_class)->change_state)
255     return GST_ELEMENT_CLASS (parent_class)->change_state (element);
256   
257   return GST_STATE_SUCCESS;
258 }
259
260 static gboolean 
261 gst_audiosrc_open_audio (GstAudioSrc *src) 
262 {
263   g_return_val_if_fail (!GST_FLAG_IS_SET (src, GST_AUDIOSRC_OPEN), FALSE);
264
265   /* first try to open the sound card */
266   src->fd = open("/dev/dsp", O_RDONLY);
267
268   /* if we have it, set the default parameters and go have fun */ 
269   if (src->fd > 0) {
270     int arg = 0x7fff0006;
271
272     if (ioctl (src->fd, SNDCTL_DSP_SETFRAGMENT, &arg)) perror("uh");
273
274     /* set card state */
275     gst_audiosrc_sync_parms (src);
276     GST_DEBUG (0,"opened audio\n");
277     
278     GST_FLAG_SET (src, GST_AUDIOSRC_OPEN);
279     return TRUE;
280   }
281
282   return FALSE;
283 }
284
285 static void 
286 gst_audiosrc_close_audio (GstAudioSrc *src) 
287 {
288   g_return_if_fail (GST_FLAG_IS_SET (src, GST_AUDIOSRC_OPEN));
289
290   close(src->fd);
291   src->fd = -1;
292
293   GST_FLAG_UNSET (src, GST_AUDIOSRC_OPEN);
294 }
295
296 static void 
297 gst_audiosrc_sync_parms (GstAudioSrc *audiosrc) 
298 {
299   audio_buf_info ospace;
300   
301   g_return_if_fail (audiosrc != NULL);
302   g_return_if_fail (GST_IS_AUDIOSRC (audiosrc));
303   g_return_if_fail (audiosrc->fd > 0);
304  
305   ioctl(audiosrc->fd, SNDCTL_DSP_RESET, 0);
306  
307   ioctl(audiosrc->fd, SNDCTL_DSP_SETFMT, &audiosrc->format);
308   ioctl(audiosrc->fd, SNDCTL_DSP_CHANNELS, &audiosrc->channels);
309   ioctl(audiosrc->fd, SNDCTL_DSP_SPEED, &audiosrc->frequency);
310   
311   ioctl(audiosrc->fd, SNDCTL_DSP_GETOSPACE, &ospace);
312  
313   g_print("setting sound card to %dKHz %d bit %s (%d bytes buffer)\n",
314           audiosrc->frequency,audiosrc->format,
315           (audiosrc->channels == 2) ? "stereo" : "mono",ospace.bytes);
316
317 //  audiosrc->meta.format = audiosrc->format;
318 //  audiosrc->meta.channels = audiosrc->channels;
319 //  audiosrc->meta.frequency = audiosrc->frequency;
320 //  audiosrc->sentmeta = FALSE;
321 }