source: roaraudio/roard/sources.c @ 5381:430b1d26e12d

Last change on this file since 5381:430b1d26e12d was 5381:430b1d26e12d, checked in by phi, 12 years ago

updated copyright years

File size: 12.2 KB
Line 
1//sources.c:
2
3/*
4 *      Copyright (C) Philipp 'ph3-der-loewe' Schafft - 2008-2012
5 *
6 *  This file is part of roard a part of RoarAudio,
7 *  a cross-platform sound system for both, home and professional use.
8 *  See README for details.
9 *
10 *  This file is free software; you can redistribute it and/or modify
11 *  it under the terms of the GNU General Public License version 3
12 *  as published by the Free Software Foundation.
13 *
14 *  RoarAudio is distributed in the hope that it will be useful,
15 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
16 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
17 *  GNU General Public License for more details.
18 *
19 *  You should have received a copy of the GNU General Public License
20 *  along with this software; see the file COPYING.  If not, write to
21 *  the Free Software Foundation, 51 Franklin Street, Fifth Floor,
22 *  Boston, MA 02110-1301, USA.
23 *
24 */
25
26#include "roard.h"
27
28#ifndef ROAR_WITHOUT_DCOMP_SOURCES
29
30static int g_source_client = -1;
31
32#define ROAR_SOURCE_DEFAULT "cf"
33
34struct roar_source g_source[] = {
35 {"raw",  "DSTR source",                 "/some/file",     SRC_FLAG_FHSEC, ROAR_SUBSYS_WAVEFORM, NULL,  sources_add_dstr},
36 {"cf",   "Old CF source",               "/some/file.ext", SRC_FLAG_NONE,  ROAR_SUBSYS_WAVEFORM, sources_add_cf,   NULL},
37 {"roar", "New simple RoarAudio source", "some.host",      SRC_FLAG_NONE,  ROAR_SUBSYS_WAVEFORM, NULL, sources_add_roar},
38#ifndef ROAR_WITHOUT_DCOMP_CDRIVER
39 {"oss",  "OSS CDriver",                 "/dev/audio",     SRC_FLAG_NONE,  ROAR_SUBSYS_WAVEFORM, NULL, sources_add_cdriver},
40#endif
41 {"radionoise", "Noise source at -102dB", NULL,            SRC_FLAG_NONE, ROAR_SUBSYS_WAVEFORM, NULL, sources_add_radionoise},
42 {NULL, NULL, NULL, SRC_FLAG_NONE, 0, NULL, NULL} // EOL
43};
44
45int sources_init (void) {
46 return 0;
47}
48
49void print_sourcelist (void) {
50 int i;
51 char subsys[7] = "      ";
52
53 printf("  Source    Flag Subsys - Description (devices)\n");
54 printf("-------------------------------------------------------\n");
55
56 for (i = 0; g_source[i].name != NULL; i++) {
57  strncpy(subsys, "      ", 6);
58
59  if ( g_source[i].subsystems & ROAR_SUBSYS_WAVEFORM )
60   subsys[0] = 'W';
61  if ( g_source[i].subsystems & ROAR_SUBSYS_MIDI )
62   subsys[1] = 'M';
63  if ( g_source[i].subsystems & ROAR_SUBSYS_CB )
64   subsys[2] = 'C';
65  if ( g_source[i].subsystems & ROAR_SUBSYS_LIGHT )
66   subsys[3] = 'L';
67  if ( g_source[i].subsystems & ROAR_SUBSYS_RAW )
68   subsys[4] = 'R';
69  if ( g_source[i].subsystems & ROAR_SUBSYS_COMPLEX )
70   subsys[5] = 'X';
71
72  if ( g_source[i].devices != NULL ) {
73   printf("  %-10s %c%c%c %6s - %s (devices: %s)\n", g_source[i].name,
74                 g_source[i].flags & SRC_FLAG_FHSEC      ? 's' : ' ',
75                 g_source[i].old_open != NULL            ? 'S' : ' ',
76                 g_source[i].new_open != NULL            ? 'N' : ' ',
77                 subsys,
78                 g_source[i].desc, g_source[i].devices);
79  } else {
80   printf("  %-9s %c%c%c %6s - %s\n", g_source[i].name,
81                 g_source[i].flags & SRC_FLAG_FHSEC      ? 's' : ' ',
82                 g_source[i].old_open != NULL            ? 'S' : ' ',
83                 g_source[i].new_open != NULL            ? 'N' : ' ',
84                 subsys,
85                 g_source[i].desc);
86  }
87 }
88}
89
90
91int sources_set_client (int client) {
92 if ( client >= 0 ) {
93  g_source_client = client;
94  return 0;
95 } else {
96  return -1;
97 }
98}
99
100int sources_free (void) {
101 return 0;
102}
103
104int sources_add (char * driver, char * device, char * container, char * options, int primary) {
105 int i;
106
107 if ( driver == NULL )
108  driver = ROAR_SOURCE_DEFAULT;
109
110 for (i = 0; g_source[i].name != NULL; i++) {
111  if ( !strcmp(g_source[i].name, driver) ) {
112   if ( g_source[i].new_open != NULL ) {
113    return sources_add_new(&(g_source[i]), driver, device, container, options, primary);
114   } else if ( g_source[i].old_open != NULL ) {
115    return g_source[i].old_open(driver, device, container, options, primary);
116   } else {
117    ROAR_ERR("sources_add(driver='%s', ...): Found source but did not find any open rutine", driver);
118    return -1;
119   }
120  }
121 }
122
123 ROAR_ERR("sources_add(driver='%s', ...): Source not found", driver);
124 return -1;
125}
126
127int sources_add_new (struct roar_source * source,
128                     char * driver, char * device,
129                     char * container,
130                     char * options, int primary) {
131 int  stream;
132 int  fh = -1;
133 struct roar_stream        *  s;
134 struct roar_stream_server * ss;
135 char * k, * v;
136 int error = 0;
137 int f_sync = 0, f_mmap = 0;
138 int codec;
139 char * strtok_store;
140
141 if ( source == NULL )
142  return -1;
143
144 if ( (stream = streams_new()) == -1 ) {
145  return -1;
146 }
147
148 if ( streams_get(stream, &ss) == -1 ) {
149  streams_delete(stream);
150  return -1;
151 }
152
153 s = ROAR_STREAM(ss);
154
155 memcpy(&(s->info), g_sa, sizeof(struct roar_audio_info));
156
157 codec = s->info.codec;
158
159 if ( streams_set_dir(stream, ROAR_DIR_PLAY, 1) == -1 ) {
160  streams_delete(stream);
161  return -1;
162 }
163
164 s->pos_rel_id = -1;
165
166 if ( options == NULL ) {
167  k = NULL;
168 } else {
169  k = roar_mm_strtok_r(options, ",", &strtok_store);
170 }
171 while (k != NULL) {
172  if ( (v = strstr(k, "=")) != NULL ) {
173   *v++ = 0;
174  }
175
176  if ( strcmp(k, "rate") == 0 ) {
177   s->info.rate = roar_str2rate(v);
178  } else if ( strcmp(k, "channels") == 0 ) {
179   s->info.channels = roar_str2channels(v);
180  } else if ( strcmp(k, "bits") == 0 ) {
181   s->info.bits = roar_str2bits(v);
182  } else if ( strcmp(k, "codec") == 0 ) {
183   if ( (codec = roar_str2codec(v)) == -1 ) {
184    ROAR_ERR("sources_add_new(*): unknown codec '%s'", v);
185    error++;
186   }
187
188  } else if ( strcmp(k, "name") == 0 ) {
189   if ( streams_set_name(stream, v) == -1 ) {
190    ROAR_ERR("add_output(*): Can not set Stream name");
191    error++;
192   }
193
194  } else if ( strcmp(k, "mmap") == 0 ) {
195   f_mmap = 1;
196  } else if ( strcmp(k, "sync") == 0 ) {
197   f_sync = 1;
198  } else if ( strcmp(k, "primary") == 0 ) {
199   primary = 1;
200  } else if ( strcmp(k, "meta") == 0 ) {
201   streams_set_flag(stream, ROAR_FLAG_META);
202  } else if ( strcmp(k, "cleanmeta") == 0 ) {
203   streams_set_flag(stream, ROAR_FLAG_CLEANMETA);
204  } else if ( strcmp(k, "autoconf") == 0 ) {
205   streams_set_flag(stream, ROAR_FLAG_AUTOCONF);
206
207  } else {
208   ROAR_ERR("sources_add_new(*): unknown option '%s'", k);
209   error++;
210  }
211
212  if ( error ) {
213   streams_delete(stream);
214   if ( primary ) alive = 0;
215   return -1;
216  }
217
218  k = roar_mm_strtok_r(NULL, ",", &strtok_store);
219 }
220
221 if ( primary )
222  streams_mark_primary(stream);
223
224 streams_set_flag(stream, ROAR_FLAG_SOURCE);
225 client_stream_add(g_source_client, stream);
226
227 if ( codec == ROAR_CODEC_ALAW || codec == ROAR_CODEC_MULAW )
228  s->info.bits = 8; // needed to open OSS driver, will be overriden by codecfilter
229
230 s->info.codec = codec;
231 ROAR_STREAM_SERVER(s)->codec_orgi = codec;
232
233 if ( source->new_open(stream, device, fh, driver) == -1 ) {
234  streams_delete(stream);
235  return -1;
236 }
237
238 _LIBROAR_IGNORE_RET(roar_vio_ctl(&(ss->vio), ROAR_VIO_CTL_SET_SSTREAMID, &stream)); // ignore errors here
239 _LIBROAR_IGNORE_RET(roar_vio_ctl(&(ss->vio), ROAR_VIO_CTL_SET_SSTREAM,   s)); // ignore errors here
240
241 if ( f_sync ) {
242  streams_set_flag(stream, ROAR_FLAG_SYNC);
243 } else {
244  streams_reset_flag(stream, ROAR_FLAG_SYNC);
245 }
246
247 if ( f_mmap )
248  streams_set_flag(stream, ROAR_FLAG_MMAP);
249
250 return 0;
251}
252
253int sources_add_dstr  (int stream   , const char * device, int fh, const char * driver) {
254 struct roar_stream_server * ss;
255 struct roar_vio_defaults def;
256
257 if ( roar_vio_dstr_init_defaults(&def, ROAR_VIO_DEF_TYPE_NONE, O_RDONLY, 0644) == -1 )
258  return -1;
259
260 streams_get(stream, &ss);
261
262 if ( fh > -1 ) {
263  if ( roar_vio_open_fh(&(ss->vio), fh) == -1 )
264   return -1;
265 } else {
266  if ( roar_vio_open_dstr(&(ss->vio), device, &def, 1) == -1 )
267   return -1;
268 }
269
270 return streams_set_fh(stream, -2);
271}
272
273#define _ret(x) streams_delete(stream); return (x)
274
275int sources_add_cf (const char * driver, const char * device, const char * container, const char * options, int primary) {
276 int  stream;
277 int  codec;
278 int  len;
279 char buf[64];
280 struct roar_stream    * s;
281 struct roar_vio_calls * vio;
282 struct roar_vio_defaults def;
283
284 if ( roar_vio_dstr_init_defaults(&def, ROAR_VIO_DEF_TYPE_NONE, O_RDONLY, 0644) == -1 )
285  return -1;
286
287 if ( (stream = streams_new()) == -1 ) {
288  return -1;
289 }
290
291 streams_get_clientobj(stream, &s);
292
293 memcpy(&(s->info), g_sa, sizeof(struct roar_audio_info));
294
295 if ( streams_set_dir(stream, ROAR_DIR_PLAY, 1) == -1 ) {
296  streams_delete(stream);
297  return -1;
298 }
299
300 s->pos_rel_id = -1;
301
302/*
303 if ( (fh = open(device, O_RDONLY, 0644)) == -1 ) {
304  return -1;
305 }
306*/
307
308 vio = &(ROAR_STREAM_SERVER(s)->vio);
309
310 if ( roar_vio_open_dstr(vio, device, &def, 1) == -1 ) {
311  roar_vio_clear_calls(vio); // clear the VIO object again
312                            // from things roar_vio_open_dstr() left.
313  _ret(-1);
314 }
315
316 ROAR_DBG("sources_add_cf(*) = ?");
317
318 // TODO: find out a better way of doing auto detetion without need for seek!
319 if ( options == NULL ) {
320  if ( (len = roar_vio_read(vio, buf, 64)) < 1 ) {
321   _ret(-1);
322  }
323
324  if ( roar_vio_lseek(vio, -len, SEEK_CUR) == (roar_off_t)-1 ) {
325   _ret(-1);
326  }
327
328  if ( (codec = roar_file_codecdetect(buf, len)) == -1 ) {
329   _ret(-1);
330  }
331 } else {
332  if ( !strncmp(options, "codec=", 6) )
333   options += 6;
334
335  if ( (codec = roar_str2codec(options)) == -1 ) {
336   _ret(-1);
337  }
338 }
339
340 s->info.codec = codec;
341
342 ROAR_STREAM_SERVER(s)->codec_orgi = codec;
343
344 ROAR_DBG("sources_add_cf(*) = ?");
345 streams_set_fh(stream, -2);
346 ROAR_DBG("sources_add_cf(*) = ?");
347 streams_set_socktype(stream, ROAR_SOCKET_TYPE_FILE);
348
349 if ( primary )
350  streams_mark_primary(stream);
351
352 streams_set_flag(stream, ROAR_FLAG_SOURCE);
353 client_stream_add(g_source_client, stream);
354
355 return 0;
356}
357
358#undef _ret
359
360#ifndef ROAR_WITHOUT_DCOMP_CDRIVER
361int sources_add_cdriver (int stream   , const char * device, int fh, const char * driver) {
362 struct roar_stream_server * ss;
363
364 if ( fh > -1 )
365  return -1;
366
367 if ( streams_get(stream, &ss) == -1 )
368  return -1;
369
370 if ( !strncmp(driver, "cdriver:", 8) )
371  driver += 8;
372
373 ROAR_DBG("sources_add_cdriver(stream=%i, device='%s', fh=%i, driver='%s') = ?", stream, device, fh, driver);
374
375 if ( roar_cdriver_open(&(ss->vio), driver, device, &(ROAR_STREAM(ss)->info), ROAR_DIR_RECORD) == -1 )
376  return -1;
377
378 return streams_set_fh(stream, -2);
379}
380#endif
381
382static ssize_t sources_radionoise_read (struct roar_vio_calls * vio, void *buf, size_t count) {
383 int32_t * pcm = buf;
384 int16_t noise;
385 size_t len, i;
386
387 ROAR_DBG("sources_radionoise_read(vio=%p, buf=%p, count=%llu) = 0", vio, buf, (long long unsigned int)count);
388
389 // ensure size is a multiple of 4.
390 count -= count & 0x03LLU;
391
392 if ( count == 0 )
393  return 0;
394
395 if ( buf == NULL )
396  return -1;
397
398 roar_random_gen_nonce(buf, count);
399
400 len = count / 4;
401
402 for (i = 0; i < len; i++) {
403  noise  = pcm[i] & 0xFFFF;
404  pcm[i] = ((int32_t)noise << 16) >> 17;
405 }
406
407 ROAR_DBG("sources_radionoise_read(vio=%p, buf=%p, count=?) = %llu", vio, buf, (long long unsigned int)count);
408 return count;
409}
410
411static int     sources_radionoise_return_zero (struct roar_vio_calls * vio) {
412 (void)vio;
413
414 ROAR_DBG("sources_radionoise_return_zero(vio=%p) = 0", vio);
415
416 return 0;
417}
418
419static int  sources_radionoise_ctl(struct roar_vio_calls * vio, roar_vio_ctl_t cmd, void * data) {
420 if ( cmd == ROAR_VIO_CTL_NONBLOCK )
421  return 0;
422
423 roar_err_set(ROAR_ERROR_BADRQC);
424 return -1;
425}
426
427int sources_add_radionoise (int stream, const char * device, int fh, const char * driver) {
428 struct roar_stream_server * ss;
429 struct roar_audio_info    * info;
430
431 if ( fh > -1 )
432  return -1;
433
434 if ( streams_get(stream, &ss) == -1 )
435  return -1;
436
437 info = &(ROAR_STREAM(ss)->info);
438
439 info->codec = ROAR_CODEC_DEFAULT;
440 info->bits  = 32;
441
442 memset(&(ss->vio), 0, sizeof(struct roar_vio_calls));
443 ss->vio.read     = sources_radionoise_read;
444 ss->vio.close    = sources_radionoise_return_zero;
445 ss->vio.sync     = sources_radionoise_return_zero;
446 ss->vio.ctl      = sources_radionoise_ctl;
447
448 return streams_set_fh(stream, -2);
449}
450
451int sources_add_roar (int stream, const char * device, int fh, const char * driver) {
452 struct roar_stream_server * ss;
453 struct roar_stream        * s;
454
455 if ( fh > -1 )
456  return -1;
457
458 if ( streams_get(stream, &ss) == -1 )
459  return -1;
460
461 s = ROAR_STREAM(ss);
462
463 if ( roar_vio_simple_stream(&(ss->vio), s->info.rate, s->info.channels, s->info.bits, s->info.codec,
464                             device, ROAR_DIR_MONITOR, "roard", -1) == -1 )
465  return -1;
466
467 return streams_set_fh(stream, -2);
468}
469
470#endif
471
472//ll
Note: See TracBrowser for help on using the repository browser.