source: roaraudio/libroar/stream.c @ 5229:d7e314825b8a

//stream.c:

/*
 *      Copyright (C) Philipp 'ph3-der-loewe' Schafft - 2008-2011
 *
 *  This file is part of libroar a part of RoarAudio,
 *  a cross-platform sound system for both, home and professional use.
 *  See README for details.
 *
 *  This file is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License version 3
 *  as published by the Free Software Foundation.
 *
 *  libroar 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 General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with this software; see the file COPYING.  If not, write to
 *  the Free Software Foundation, 51 Franklin Street, Fifth Floor,
 *  Boston, MA 02110-1301, USA.
 *
 *  NOTE for everyone want's to change something and send patches:
 *  read README and HACKING! There a addition information on
 *  the license of this document you need to read before you send
 *  any patches.
 *
 *  NOTE for uses of non-GPL (LGPL,...) software using libesd, libartsc
 *  or libpulse*:
 *  The libs libroaresd, libroararts and libroarpulse link this lib
 *  and are therefore GPL. Because of this it may be illigal to use
 *  them with any software that uses libesd, libartsc or libpulse*.
 */

#include "libroar.h"

int roar_stream_connect  (struct roar_connection * con, struct roar_stream * s, int dir) {
 return roar_stream_connect2(con, s, dir, -1);
}

int roar_stream_connect2 (struct roar_connection * con, struct roar_stream * s, int dir, int mixer) {
 struct roar_libroar_config * config = roar_libroar_get_config();
 struct roar_stream  ms;
 struct roar_message m;

 s->dir = dir;

 memset(&m,  0, sizeof(m));
 memcpy(&ms, s, sizeof(ms));

 m.cmd     = ROAR_CMD_NEW_STREAM;
 m.stream  = mixer;
 m.pos     = 0;

 if ( config != NULL ) {
  if ( config->info.rate )
   ms.info.rate = config->info.rate;
  if ( config->info.bits )
   ms.info.bits = config->info.bits;
  if ( config->info.channels )
   ms.info.channels = config->info.channels;
  if ( config->info.codec )
   ms.info.codec = config->info.codec;
 }

 roar_stream_s2m(&ms, &m);

 if ( roar_req3(con, &m, NULL) != 0 )
  return -1;

 if ( m.cmd == ROAR_CMD_OK ) {
  s->id = m.stream;

  ROAR_DBG("roar_stream_connect(*) = 0");
  return 0;
 }

 ROAR_ERR("roar_stream_connect(*): Connecting new stream faild!");
 ROAR_DBG("roar_stream_connect(*) = -1");
 return -1;
}

int roar_stream_new (struct roar_stream * s, unsigned int rate,
                     unsigned int channels, unsigned int bits, unsigned int codec) {

 if ( s == NULL ) {
  roar_err_set(ROAR_ERROR_FAULT);
  return -1;
 }

 s->fh         = -1;
 s->id         = -1;
 s->pos        =  0;
 s->pos_rel_id = -1;

 s->dir        = ROAR_DIR_DEFAULT;

/*
 s->datalen    = 0;
 s->offset     = 0;

 s->database   = NULL;
 s->dataoff    = NULL;
*/

 s->info.rate     = rate;
 s->info.channels = channels;
 s->info.bits     = bits;
 s->info.codec    = codec;

 if ( bits > ROAR_BITS_MAX )
  return -1;

 return 0;
}

int roar_stream_set_rel_id(struct roar_stream * s, int id) {
 if ( s == NULL ) {
  roar_err_set(ROAR_ERROR_FAULT);
  return -1;
 }

 s->pos_rel_id = id;

 return 0;
}

int roar_stream_get_rel_id(struct roar_stream * s) {
 if ( s == NULL ) {
  roar_err_set(ROAR_ERROR_FAULT);
  return -1;
 }

 return s->pos_rel_id;
}

int roar_stream_new_by_id(struct roar_stream * s, int id) {
 if ( s == NULL ) {
  roar_err_set(ROAR_ERROR_FAULT);
  return -1;
 }

 if ( roar_stream_new_empty(s) == -1 )
  return -1;

 return roar_stream_set_id(s, id);
}

int roar_stream_new_empty(struct roar_stream * s) {
 if ( s == NULL ) {
  roar_err_set(ROAR_ERROR_FAULT);
  return -1;
 }

 return roar_stream_new(s, 0, 0, 0, 0);
}

int roar_stream_set_id (struct roar_stream * s, int id) {
 if ( s == NULL ) {
  roar_err_set(ROAR_ERROR_FAULT);
  return -1;
 }

 s->id = id;

 return 0;
}

int roar_stream_get_id (struct roar_stream * s) {
 if ( s == NULL ) {
  roar_err_set(ROAR_ERROR_FAULT);
  return -1;
 }

 return s->id;
}

int roar_stream_set_fh (struct roar_stream * s, int fh) {
 if ( s == NULL ) {
  roar_err_set(ROAR_ERROR_FAULT);
  return -1;
 }

 s->fh = fh;

 return 0;
}

int roar_stream_get_fh (struct roar_stream * s) {
 if ( s == NULL ) {
  roar_err_set(ROAR_ERROR_FAULT);
  return -1;
 }

 return s->fh;
}

int roar_stream_set_dir (struct roar_stream * s, int dir) {
 if ( s == NULL ) {
  roar_err_set(ROAR_ERROR_FAULT);
  return -1;
 }

 s->dir = dir;

 return 0;
}

int roar_stream_get_dir (struct roar_stream * s) {
 if ( s == NULL ) {
  roar_err_set(ROAR_ERROR_FAULT);
  return -1;
 }

 return s->dir;
}


int roar_stream_exec    (struct roar_connection * con, struct roar_stream * s) {
 struct roar_message m;

 memset(&m,  0, sizeof(m));

 m.cmd     = ROAR_CMD_EXEC_STREAM;
 m.stream  = s->id;
 m.datalen = 0;
 m.pos     = 0;

 if ( roar_req(con, &m, NULL) == -1 )
  return -1;

 if ( m.cmd == ROAR_CMD_OK )
  return 0;
 return -1;
}

int roar_stream_connect_to (struct roar_connection * con, struct roar_stream * s, int type, char * host, int port) {
 struct roar_message m;

 if ( roar_stream_connect_to_ask(con, s, type, host, port) == -1 )
  return -1;

 if ( roar_recv_message(con, &m, NULL) == -1 )
  return -1;

 if ( m.cmd == ROAR_CMD_OK )
  return 0;
 return -1;
}

int roar_stream_connect_to_ask (struct roar_connection * con, struct roar_stream * s, int type, char * host, int port) {
 struct roar_message m;
 int len = 0;

 if ( host == NULL ) {
  roar_err_set(ROAR_ERROR_FAULT);
  return -1;
 }

 ROAR_DBG("roar_stream_connect_to_ask(*): Ask the server to connect to: %s:%i", host, port);

 memset(&m,  0, sizeof(m));

 m.cmd     = ROAR_CMD_CON_STREAM;
 m.stream  = s->id;
 m.pos     = 0;

 m.data[0] = 0;
 m.data[1] = type;
 ((uint16_t*)&(m.data))[1] = ROAR_HOST2NET16(port);

 len = strlen(host);

 if ( len > 76 ) {
  roar_err_set(ROAR_ERROR_NAMETOOLONG);
  return -1;
 }

 strncpy(&(m.data[4]), host, len);

 m.datalen = len + 4;

 if ( roar_send_message(con, &m, NULL) == -1 )
  return -1;

 return 0;
}

int roar_stream_passfh  (struct roar_connection * con, struct roar_stream * s, int fh) {
 struct roar_message m;
 int confh;

 if ( con == NULL || s == NULL ) {
  roar_err_set(ROAR_ERROR_FAULT);
  return -1;
 }

 if ( fh < 0 ) {
  roar_err_set(ROAR_ERROR_INVAL);
  return -1;
 }

 memset(&m,  0, sizeof(m));

 m.cmd     = ROAR_CMD_PASSFH;
 m.stream  = s->id;
 m.pos     = 0;
 m.datalen = 0;

 ROAR_DBG("roar_stream_passfh(con=%p{...}, s={.id=%i,...}, fh=%i) = ?", con, s->id, fh);

 roar_libroar_nowarn();
 if ( (confh = roar_get_connection_fh(con)) == -1 ) {
  roar_libroar_warn();
  return -1;
 }
 roar_libroar_warn();

 if ( roar_send_message(con, &m, NULL) == -1 ) {
  ROAR_DBG("roar_stream_passfh(con=%p{...}, s={.id=%i,...}, fh=%i) = -1 // can not send message", con, s->id, fh);
  return -1;
 }

 ROAR_DBG("roar_stream_passfh(*): msg send");

 if ( roar_socket_send_fh(confh, fh, NULL, 0) == -1 )
  return -1;

 ROAR_DBG("roar_stream_passfh(*): fh send");

 if ( roar_recv_message(con, &m, NULL) == -1 )
  return -1;

 ROAR_DBG("roar_stream_passfh(*): mes recved");

 if ( m.cmd == ROAR_CMD_OK )
  return 0;

 return -1;
}

int roar_stream_attach_simple (struct roar_connection * con, struct roar_stream * s, int client) {
 struct roar_message m;
 uint16_t * info = (uint16_t *) m.data;
 int i;

 if ( con == NULL || s == NULL ) {
  roar_err_set(ROAR_ERROR_FAULT);
  return -1;
 }

 if ( client < 0 ) {
  roar_err_set(ROAR_ERROR_INVAL);
  return -1;
 }

 memset(&m,  0, sizeof(m));

 m.cmd     = ROAR_CMD_ATTACH;
 m.stream  = s->id;
 m.pos     = 0;
 m.datalen = 6;

 info[0] = 0;
 info[1] = ROAR_ATTACH_SIMPLE;
 info[2] = client;

 for (i = 0; i < m.datalen/2; i++) {
  info[i] = ROAR_HOST2NET16(info[i]);
 }

 if ( roar_req(con, &m, NULL) == -1 )
  return -1;

 if ( m.cmd != ROAR_CMD_OK )
  return -1;

 return 0;
}

int roar_stream_add_data (struct roar_connection * con, struct roar_stream * s, char * data, size_t len) {
 struct roar_message m;

 if ( con == NULL || s == NULL || data == NULL ) {
  roar_err_set(ROAR_ERROR_FAULT);
  return -1;
 }

 memset(&m,  0, sizeof(m));

 m.cmd     = ROAR_CMD_ADD_DATA;
 m.stream  = s->id;
 m.pos     = 0;
 m.datalen = len;

// if ( roar_req(con, &m, (void**)&data) == -1 )
//  return -1;
 if ( roar_send_message(con, &m, data) != 0 )
  return -1;

 if ( roar_recv_message(con, &m, NULL) == -1 )
  return -1;

 if ( m.cmd == ROAR_CMD_OK )
  return 0;
 return -1;
}

int roar_stream_send_data (struct roar_connection * con, struct roar_stream * s, char * data, size_t len) {

 roar_debug_warn_obsolete("roar_stream_send_data", "roar_vio_write", NULL);

 if ( s == NULL ) {
  roar_err_set(ROAR_ERROR_FAULT);
  return -1;
 }

 if ( s->fh == -1 ) {
  if ( con == NULL ) {
   roar_err_set(ROAR_ERROR_NOTSUP);
   return -1;
  }

  if ( roar_stream_add_data(con, s, data, len) == -1 )
   return -1;

  return len;
 }

#ifdef ROAR_HAVE_IO_POSIX
 return ROAR_NETWORK_WRITE(s->fh, data, len);
#endif

 roar_err_set(ROAR_ERROR_NOTSUP);
 return -1;
}

int roar_stream_get_info (struct roar_connection * con, struct roar_stream * s, struct roar_stream_info * info) {
 struct roar_message m;
 uint16_t * data = (uint16_t *) m.data;
 int i;

 if ( con == NULL || s == NULL || info == NULL ) {
  roar_err_set(ROAR_ERROR_FAULT);
  return -1;
 }

 memset(&m,  0, sizeof(m));

 m.cmd     = ROAR_CMD_GET_STREAM_PARA;
 m.stream  = s->id;
 m.datalen = 4;
 m.pos     = 0;

 data[0] = 0; // Version and reserved
 data[1] = ROAR_STREAM_PARA_INFO; // stream

 for (i = 0; i < m.datalen/2; i++) {
  data[i] = ROAR_HOST2NET16(data[i]);
 }

 if ( roar_req(con, &m, NULL) == -1 )
  return -1;

 if ( m.cmd != ROAR_CMD_OK )
  return -1;

 for (i = 0; i < m.datalen/2; i++) {
  data[i] = ROAR_NET2HOST16(data[i]);
 }

 if ( m.datalen < 7*2 ) {
  roar_err_set(ROAR_ERROR_MSGSIZE);
  return -1;
 }

 if ( data[0] != 0 || data[1] != 1 ) {
  roar_err_set(ROAR_ERROR_NSVERSION);
  return -1;
 }

 memset(info, 0, sizeof(struct roar_stream_info));
 info->mixer = -1;
 info->role  = ROAR_ROLE_UNKNOWN;

 info->block_size     = data[2];
 info->pre_underruns  = data[3];
 info->post_underruns = data[4];
 info->codec          = data[5];
 info->flags          = data[6];
 info->delay          = data[7]*1000;

 if ( m.datalen < 9*2 ) {
  info->state         = ROAR_STREAMSTATE_UNKNOWN;
  return 0;
 } else {
  info->state         = data[8];
 }

 if ( m.datalen < 10*2 ) {
  return 0;
 } else {
  info->flags        |= ((uint32_t)data[9]) << 16;
 }

 if ( m.datalen < 11*2 ) {
  return 0;
 } else {
  info->mixer         = data[10];
 }

 if ( m.datalen < 12*2 ) {
  return 0;
 } else {
  info->role          = data[11];
 }

 return 0;
}

int roar_stream_get_name (struct roar_connection * con, struct roar_stream * s, char * name, size_t len) {
 struct roar_message m;
 uint16_t * data = (uint16_t *) m.data;

 if ( con == NULL || s == NULL || name == NULL || len == 0 ) {
  roar_err_set(ROAR_ERROR_FAULT);
  return -1;
 }

 name[0] = 0; // just in case...

 memset(&m,  0, sizeof(m));

 m.cmd     = ROAR_CMD_GET_STREAM_PARA;
 m.stream  = s->id;
 m.datalen = 4;
 m.pos     = 0;

 data[0] = 0; // Version and reserved
 data[1] = ROAR_STREAM_PARA_NAME; // stream

 data[0] = ROAR_HOST2NET16(data[0]);
 data[1] = ROAR_HOST2NET16(data[1]);

 ROAR_DBG("roar_stream_get_name(*) = ?");

 if ( roar_req(con, &m, NULL) == -1 )
  return -1;

 ROAR_DBG("roar_stream_get_name(*) = ?");

 if ( m.cmd != ROAR_CMD_OK )
  return -1;

 ROAR_DBG("roar_stream_get_name(*) = ?");

 if ( m.datalen < 4 ) {
  roar_err_set(ROAR_ERROR_MSGSIZE);
  return -1;
 }

 data[0] = ROAR_NET2HOST16(data[0]);
 data[1] = ROAR_NET2HOST16(data[1]);

 ROAR_DBG("roar_stream_get_name(*) = ?");

 if ( data[0] != 0 ) {
  roar_err_set(ROAR_ERROR_NSVERSION);
  return -1;
 }

 if ( data[1] != ROAR_STREAM_PARA_NAME ) {
  roar_err_set(ROAR_ERROR_TYPEMM);
  return -1;
 }

 m.datalen -= 4;

 len--;

 if ( len > m.datalen )
  len = m.datalen;

 strncpy(name, ((char*)m.data)+4, len);
 name[len] = 0;

 ROAR_DBG("roar_stream_get_name(*) = 0");

 return 0;
}

int roar_stream_get_chanmap (struct roar_connection * con, struct roar_stream * s, char * map, size_t * len) {
 struct roar_message m;
 uint16_t * data = (uint16_t *) m.data;

 ROAR_DBG("roar_stream_get_chanmap(con=%p, s=%p, map=%p, len=%p) = ?", con, s, map, len);

 if ( con == NULL || s == NULL || map == NULL || len == NULL ) {
  roar_err_set(ROAR_ERROR_FAULT);
  return -1;
 }

 if ( *len == 0 ) {
  roar_err_set(ROAR_ERROR_INVAL);
  return -1;
 }

 memset(&m, 0, sizeof(m));

 m.cmd     = ROAR_CMD_GET_STREAM_PARA;
 m.stream  = s->id;
 m.datalen = 2*2;

 data[0] = 0; // Version and reserved
 data[1] = ROAR_STREAM_PARA_CHANMAP;

 data[0] = ROAR_HOST2NET16(data[0]);
 data[1] = ROAR_HOST2NET16(data[1]);

 if ( roar_req(con, &m, NULL) == -1 )
  return -1;

 ROAR_DBG("roar_stream_get_chanmap(con=%p, s=%p{.id=%i}, map=%p, len=%p) = ?", con, s, s->id, map, len);

 if ( m.cmd != ROAR_CMD_OK )
  return -1;

 ROAR_DBG("roar_stream_get_chanmap(con=%p, s=%p{.id=%i}, map=%p, len=%p) = ?", con, s, s->id, map, len);

 if ( m.datalen < 4 ) {
  roar_err_set(ROAR_ERROR_MSGSIZE);
  return -1;
 }

 data[0] = ROAR_NET2HOST16(data[0]);
 data[1] = ROAR_NET2HOST16(data[1]);

 ROAR_DBG("roar_stream_get_chanmap(con=%p, s=%p{.id=%i}, map=%p, len=%p) = ?", con, s, s->id, map, len);

 if ( data[0] != 0 ) {
  roar_err_set(ROAR_ERROR_NSVERSION);
  return -1;
 }

 if ( data[1] != ROAR_STREAM_PARA_CHANMAP ) {
  roar_err_set(ROAR_ERROR_TYPEMM);
  return -1;
 }

 ROAR_DBG("roar_stream_get_chanmap(con=%p, s=%p{.id=%i}, map=%p, len=%p) = ?", con, s, s->id, map, len);

 m.datalen -= 4;

 if ( m.datalen > *len ) {
  roar_err_set(ROAR_ERROR_NOMEM);
  return -1;
 }

 ROAR_DBG("roar_stream_get_chanmap(con=%p, s=%p{.id=%i}, map=%p, len=%p) = ?", con, s, s->id, map, len);

 memcpy(map, &(m.data[4]), m.datalen);

 *len = m.datalen;

 ROAR_DBG("roar_stream_get_chanmap(con=%p, s=%p{.id=%i}, map=%p, len=%p) = 0", con, s, s->id, map, len);
 return 0;
}

int roar_stream_set_chanmap (struct roar_connection * con, struct roar_stream * s, char * map, size_t   len) {
 struct roar_message m;
 uint16_t * data = (uint16_t *) m.data;

 if ( con == NULL || s == NULL || map == NULL ) {
  roar_err_set(ROAR_ERROR_FAULT);
  return -1;
 }

 if ( len == 0 ) {
  roar_err_set(ROAR_ERROR_INVAL);
  return 0;
 }

 memset(&m, 0, sizeof(m));

 m.cmd     = ROAR_CMD_SET_STREAM_PARA;
 m.stream  = s->id;
 m.datalen = 2*2 + len;

 if ( m.datalen > sizeof(m.data) )
  return -1;

 data[0] = 0; // Version and reserved
 data[1] = ROAR_STREAM_PARA_CHANMAP;

 data[0] = ROAR_HOST2NET16(data[0]);
 data[1] = ROAR_HOST2NET16(data[1]);

 memcpy(&(m.data[4]), map, len);

 if ( roar_req(con, &m, NULL) == -1 )
  return -1;

 if ( m.cmd != ROAR_CMD_OK )
  return -1;

 return 0;
}


int roar_stream_set_flags (struct roar_connection * con, struct roar_stream * s, int flags, int reset) {
 return roar_stream_set_flags2(con, s, flags, reset == ROAR_RESET_FLAG ? ROAR_RESET_FLAG : ROAR_SET_FLAG);
}

int roar_stream_set_flags2 (struct roar_connection * con, struct roar_stream * s, uint32_t flags, int action) {
 struct roar_message m;
 uint16_t * data = (uint16_t *) m.data;
 int i;

 if ( con == NULL || s == NULL ) {
  roar_err_set(ROAR_ERROR_FAULT);
  return -1;
 }

 memset(&m,  0, sizeof(m));

 m.cmd     = ROAR_CMD_SET_STREAM_PARA;
 m.stream  = s->id;
 m.pos     = 0;

 if ( flags & 0xFFFF0000 ) {
  m.datalen = 2*5;
 } else {
  m.datalen = 2*4;
 }

 data[0] = 0; // Version and reserved
 data[1] = ROAR_STREAM_PARA_FLAGS; // flags
 data[2] = action;
 data[3] = flags & 0x0000FFFF;

 if ( flags & 0xFFFF0000 ) {
  data[4] = (flags & 0xFFFF0000) >> 16;
 }

 for (i = 0; i < m.datalen/2; i++) {
  data[i] = ROAR_HOST2NET16(data[i]);
 }

 if ( roar_req(con, &m, NULL) == -1 )
  return -1;

 if ( m.cmd != ROAR_CMD_OK )
  return -1;

 return 0;
}

int roar_stream_set_role  (struct roar_connection * con, struct roar_stream * s, int role) {
 struct roar_message m;
 uint16_t * data = (uint16_t *) m.data;
 int i;

 if ( con == NULL || s == NULL ) {
  roar_err_set(ROAR_ERROR_FAULT);
  return -1;
 }

 memset(&m,  0, sizeof(m));

 m.cmd     = ROAR_CMD_SET_STREAM_PARA;
 m.stream  = s->id;
 m.datalen = 6;
 m.pos     = 0;

 data[0] = 0; // Version and reserved
 data[1] = ROAR_STREAM_PARA_ROLE; // flags
 data[2] = role;

 for (i = 0; i < m.datalen/2; i++) {
  data[i] = ROAR_HOST2NET16(data[i]);
 }

 if ( roar_req(con, &m, NULL) == -1 )
  return -1;

 if ( m.cmd != ROAR_CMD_OK )
  return -1;

 return 0;
}

#define _ROAR_STREAM_MESSAGE_LEN ((5+1)*4)

int roar_stream_s2m     (struct roar_stream * s, struct roar_message * m) {
 uint32_t * data;
 int i;

 if ( s == NULL || m == NULL ) {
  roar_err_set(ROAR_ERROR_FAULT);
  return -1;
 }

 m->datalen = _ROAR_STREAM_MESSAGE_LEN;
 data = (uint32_t*) m->data;

 data[0] = s->dir;
 data[1] = s->pos_rel_id;
 data[2] = s->info.rate;
 data[3] = s->info.bits;
 data[4] = s->info.channels;
 data[5] = s->info.codec;

 for (i = 0; i < _ROAR_STREAM_MESSAGE_LEN/4; i++)
  data[i] = ROAR_HOST2NET32(data[i]);

 ROAR_DBG("roar_stream_s2m(*): s->info:");
 roar_debug_audio_info_print(&(s->info));

 m->pos = s->pos;

 return 0;
}
int roar_stream_m2s     (struct roar_stream * s, struct roar_message * m) {
 uint32_t * data;
 int i;

 if ( s == NULL || m == NULL ) {
  roar_err_set(ROAR_ERROR_FAULT);
  return -1;
 }

 if ( m->datalen != _ROAR_STREAM_MESSAGE_LEN ) {
  roar_err_set(ROAR_ERROR_MSGSIZE);
  return -1;
 }

 s->pos = m->pos;

 data = (uint32_t*) m->data;

 for (i = 0; i < _ROAR_STREAM_MESSAGE_LEN/4; i++)
  data[i] = ROAR_NET2HOST32(data[i]);

 s->id            = m->stream;
 s->dir           = data[0];
 s->pos_rel_id    = data[1];
 s->info.rate     = data[2];
 s->info.bits     = data[3];
 s->info.channels = data[4];
 s->info.codec    = data[5];

 ROAR_DBG("roar_stream_m2s(*): s->info:");
 roar_debug_audio_info_print(&(s->info));

 return 0;
}

// stream direction funcs:
/*
#define roar_dir2str(x)   ((x) == ROAR_DIR_PLAY   ? "play"   : (x) == ROAR_DIR_MONITOR ? "monitor" : \
                           (x) == ROAR_DIR_FILTER ? "filter" : (x) == ROAR_DIR_RECORD  ? "record"  : \
                           (x) == ROAR_DIR_OUTPUT ? "output" : (x) == ROAR_DIR_BIDIR   ? "bidir"   : \
                           (x) == ROAR_DIR_MIXING ? "mixing" : \
                           "unknown")
*/

static struct {
 int    dir;
 const char * name;
} _libroar_dir[] = {
 {ROAR_DIR_PLAY,        "play"       },
 {ROAR_DIR_RECORD,      "record"     },
 {ROAR_DIR_MONITOR,     "monitor"    },
 {ROAR_DIR_FILTER,      "filter"     },
 {ROAR_DIR_OUTPUT,      "output"     },
 {ROAR_DIR_MIXING,      "mixing"     },
 {ROAR_DIR_META,        "meta"       },
 {ROAR_DIR_BIDIR,       "bidir"      },
 {ROAR_DIR_THRU,        "thru"       },
 {ROAR_DIR_BRIDGE,      "bridge"     },
 {ROAR_DIR_MIDI_IN,     "midi_in"    },
 {ROAR_DIR_MIDI_OUT,    "midi_out"   },
 {ROAR_DIR_LIGHT_IN,    "light_in"   },
 {ROAR_DIR_LIGHT_OUT,   "light_out"  },
 {ROAR_DIR_RAW_IN,      "raw_in"     },
 {ROAR_DIR_RAW_OUT,     "raw_out"    },
 {ROAR_DIR_COMPLEX_IN,  "complex_in" },
 {ROAR_DIR_COMPLEX_OUT, "complex_out"},
 {ROAR_DIR_RDTCS_IN,    "rdtcs_in"   },
 {ROAR_DIR_RDTCS_OUT,   "rdtcs_out"  },
 {-1,                   "unknown"    }
};

const char * roar_dir2str (const int dir) {
 int i;

 for (i = 0; _libroar_dir[i].dir != -1; i++)
  if ( _libroar_dir[i].dir == dir )
   return _libroar_dir[i].name;

 return _libroar_dir[i].name;
}

int roar_str2dir (const char * name) {
 int i;

 for (i = 0; _libroar_dir[i].dir != -1; i++)
  if ( !strcmp(_libroar_dir[i].name, name) )
   return _libroar_dir[i].dir;

 return _libroar_dir[i].dir;
}

// codec funcs:

/*
#define roar_codec2str(x) ((x) == ROAR_CODEC_PCM_S_LE  ? "pcm_s_le"  : (x) == ROAR_CODEC_PCM_S_BE  ? "pcm_s_be"  : \
                           (x) == ROAR_CODEC_PCM_S_PDP ? "pcm_s_pdp" : (x) == ROAR_CODEC_MIDI_FILE ? "midi_file" : \
                           "unknown" )
*/

static struct {
 int    codec;
 const char * name;
 const char * mime;
} _libroar_codec[] = {
 // PCM:
 {ROAR_CODEC_PCM_S_LE,    "pcm_s_le",    NULL},
 {ROAR_CODEC_PCM_S_BE,    "pcm_s_be",    NULL},
 {ROAR_CODEC_PCM_S_PDP,   "pcm_s_pdp",   NULL},
 {ROAR_CODEC_PCM_U_LE,    "pcm_u_le",    NULL},
 {ROAR_CODEC_PCM_U_BE,    "pcm_u_be",    NULL},
 {ROAR_CODEC_PCM_U_PDP,   "pcm_u_pdp",   NULL},
 {ROAR_CODEC_DEFAULT,     "default",     NULL}, // alias
 {ROAR_CODEC_DEFAULT,     "pcm",         NULL}, // alias
 {ROAR_CODEC_DEFAULT,     "raw",         NULL}, // alias
 {ROAR_CODEC_PCM_S,       "pcm_s",       NULL}, // alias
 {ROAR_CODEC_PCM_U,       "pcm_u",       NULL}, // alias

 // MIDI:
 {ROAR_CODEC_MIDI_FILE,   "midi_file",   NULL},
 {ROAR_CODEC_MIDI,        "midi",        NULL},
 {ROAR_CODEC_ROARMIDI,    "roarmidi",    NULL},

 // XIPH:
 {ROAR_CODEC_OGG_VORBIS,  "ogg_vorbis",  "application/ogg"},
 {ROAR_CODEC_OGG_VORBIS,  "vorbis",      "application/ogg"}, // alias
 {ROAR_CODEC_FLAC,        "flac",        "audio/x-flac"},
 {ROAR_CODEC_OGG_SPEEX,   "ogg_speex",   "audio/ogg; codecs=speex"},
 {ROAR_CODEC_OGG_SPEEX,   "speex",       "audio/ogg; codecs=speex"}, // alias
 {ROAR_CODEC_OGG_FLAC,    "ogg_flac",    "audio/ogg; codecs=flac"},
 {ROAR_CODEC_OGG_GENERAL, "ogg_general", "application/ogg"},
 {ROAR_CODEC_OGG_CELT,    "ogg_celt",    "audio/ogg; codecs=celt"},
 {ROAR_CODEC_OGG,         "ogg",         "application/ogg"},
 {ROAR_CODEC_OGG_OPUS,    "ogg_opus",    NULL},
 {ROAR_CODEC_ROAR_OPUS,   "roar_opus",   NULL},
 {ROAR_CODEC_ROAR_CELT,   "roar_celt",   NULL},
 {ROAR_CODEC_ROAR_SPEEX,  "roar_speex",  NULL},

 // RAUM:
 {ROAR_CODEC_RAUM,        "raum",        NULL},
 {ROAR_CODEC_RAUM_VORBIS, "raum_vorbis", NULL},
 {ROAR_CODEC_RAUM_FLAC,   "raum_flac",   NULL},

 // RIFF/WAVE like:
 {ROAR_CODEC_RIFF_WAVE,   "riff_wave",   "audio/x-wav"},
 {ROAR_CODEC_RIFF_WAVE,   "wave",        "audio/x-wav"}, // alias
 {ROAR_CODEC_RIFF_WAVE,   "wav",         "audio/x-wav"}, // alias
 {ROAR_CODEC_RIFX,        "rifx",        NULL},
 {ROAR_CODEC_AU,          "au",          "audio/basic"},
 {ROAR_CODEC_AIFF,        "aiff",        "audio/aiff"},

 //Log codecs:
 {ROAR_CODEC_ALAW,        "alaw",        NULL},
 {ROAR_CODEC_AUTLAW_LE,   "autlaw_le",   NULL},
 {ROAR_CODEC_AUTLAW_BE,   "autlaw_be",   NULL},
 {ROAR_CODEC_AUTLAW,      "autlaw",      NULL}, // alias
 {ROAR_CODEC_MULAW,       "mulaw",       NULL},
 {ROAR_CODEC_MULAW,       "ulaw",        NULL}, // alias
 {ROAR_CODEC_MUUTLAW_LE,  "muutlaw_le",  NULL},
 {ROAR_CODEC_MUUTLAW_BE,  "muutlaw_be",  NULL},
 {ROAR_CODEC_MUUTLAW,     "muutlaw",     NULL}, // alias

 //GSM:
 {ROAR_CODEC_GSM,         "gsm",         NULL},
 {ROAR_CODEC_GSM49,       "gsm49",       NULL},

 //SPC-700 Bit Rate Reduction of
 //Super Nintendo Entertainment System (SNES)
 {ROAR_CODEC_BRR,         "brr",         NULL},

 // Meta Codecs:
 {ROAR_CODEC_META_VCLT,     "meta_vclt",     NULL},
 {ROAR_CODEC_META_RALT,     "meta_ralt",     NULL},
 {ROAR_CODEC_META_RALB,     "meta_ralb",     NULL},
 {ROAR_CODEC_META_RALB_LE,  "meta_ralb_le",  NULL},
 {ROAR_CODEC_META_RALB_BE,  "meta_ralb_be",  NULL},
 {ROAR_CODEC_META_RALB_PDP, "meta_ralb_pdp", NULL},

 // light control:
 {ROAR_CODEC_DMX512,      "dmx512",      NULL},
 {ROAR_CODEC_ROARDMX,     "roardmx",     NULL},

 // Radio Data and Transmitter Control System:
 {ROAR_CODEC_RDS,         "rds",         NULL},

 // User specific:
 {ROAR_CODEC_USER0,       "user0",       NULL},
 {ROAR_CODEC_USER1,       "user1",       NULL},
 {ROAR_CODEC_USER2,       "user2",       NULL},
 {ROAR_CODEC_USER3,       "user3",       NULL},
 {ROAR_CODEC_USER4,       "user4",       NULL},
 {ROAR_CODEC_USER5,       "user5",       NULL},
 {ROAR_CODEC_USER6,       "user6",       NULL},
 {ROAR_CODEC_USER7,       "user7",       NULL},
 {ROAR_CODEC_USER8,       "user8",       NULL},
 {ROAR_CODEC_USER9,       "user9",       NULL},
 {ROAR_CODEC_USER10,      "user10",      NULL},
 {ROAR_CODEC_USER11,      "user11",      NULL},
 {ROAR_CODEC_USER12,      "user12",      NULL},
 {ROAR_CODEC_USER13,      "user13",      NULL},
 {ROAR_CODEC_USER14,      "user14",      NULL},
 {ROAR_CODEC_USER15,      "user15",      NULL},
 {-1, NULL, NULL}
};

int roar_str2codec(const char * codec) {
 int i;
 int guess;

 if ( codec == NULL || *codec == 0 )
  return ROAR_CODEC_DEFAULT;

 if ( (guess = atoi(codec)) > 0 )
  return guess;

 for (i = 0; _libroar_codec[i].codec != -1; i++)
  if ( strcasecmp(_libroar_codec[i].name, codec) == 0 )
   return _libroar_codec[i].codec;

 roar_err_set(ROAR_ERROR_NOENT);
 return -1;
}


const char * roar_codec2str (const int codec) {
 int i;

 for (i = 0; _libroar_codec[i].codec != -1; i++)
  if ( _libroar_codec[i].codec == codec )
   return _libroar_codec[i].name;

 return "unknown";
}

int    roar_mime2codec (const char * mime) {
 int i;

 if ( mime == NULL ) {
  roar_err_set(ROAR_ERROR_FAULT);
  return -1;
 }

 if ( *mime == 0 ) {
  roar_err_set(ROAR_ERROR_INVAL);
  return -1;
 }

 for (i = 0; _libroar_codec[i].codec != -1; i++)
  if ( _libroar_codec[i].mime != NULL )
   if ( strcasecmp(_libroar_codec[i].mime, mime) == 0 )
    return _libroar_codec[i].codec;

 roar_err_set(ROAR_ERROR_NOENT);
 return -1;
}

const char * roar_codec2mime (const int    codec) {
 int i;

 for (i = 0; _libroar_codec[i].codec != -1; i++)
  if ( _libroar_codec[i].codec == codec )
   return _libroar_codec[i].mime;

 roar_err_set(ROAR_ERROR_NOENT);
 return NULL;
}

int32_t roar_str2rate(const char * rate) {
 struct roar_audio_info info;
 int ret;

 if ( roar_profile2info(&info, rate) != -1 ) {
  return info.rate;
 }

 ret = atoi(rate);

 if ( ret == 0 && rate[0] != '0' ) {
  roar_err_set(ROAR_ERROR_NOENT);
  return -1;
 }

 return ret;
}

int32_t roar_str2bits(const char * bits) {
 struct roar_audio_info info;
 int ret;

 if ( roar_profile2info(&info, bits) != -1 ) {
  return info.bits;
 }

 ret = atoi(bits);

 if ( ret == 0 && bits[0] != '0' ) {
  roar_err_set(ROAR_ERROR_NOENT);
  return -1;
 }

 return ret;
}

int32_t roar_str2channels(const char * channels) {
 struct roar_audio_info info;
 int ret;

 if ( !strcasecmp(channels, "mono") ) {
  return 1;
 } else if ( !strcasecmp(channels, "stereo") ) {
  return 2;
 }

 if ( roar_profile2info(&info, channels) != -1 ) {
  return info.channels;
 }

 ret = atoi(channels);

 if ( ret == 0 && channels[0] != '0' ) {
  roar_err_set(ROAR_ERROR_NOENT);
  return -1;
 }

 return ret;
}


const char * roar_streamstate2str(int streamstate) {
 switch (streamstate) {
  case ROAR_STREAMSTATE_UNUSED:  return "unused";  break;
  case ROAR_STREAMSTATE_INITING: return "initing"; break;
  case ROAR_STREAMSTATE_NEW:     return "new";     break;
  case ROAR_STREAMSTATE_OLD:     return "old";     break;
  case ROAR_STREAMSTATE_CLOSING: return "closing"; break;
 }

 return "unknown";
}

static struct {
 int    role;
 const char * name;
} _libroar_role[] = {
 {ROAR_ROLE_UNKNOWN,          "unknown"         },
 {ROAR_ROLE_NONE,             "none"            },
 {ROAR_ROLE_MUSIC,            "music"           },
 {ROAR_ROLE_VIDEO,            "video"           },
 {ROAR_ROLE_GAME,             "game"            },
 {ROAR_ROLE_EVENT,            "event"           },
 {ROAR_ROLE_BEEP,             "beep"            },
 {ROAR_ROLE_PHONE,            "phone"           },
 {ROAR_ROLE_BACKGROUND_MUSIC, "background music"},
 {ROAR_ROLE_BACKGROUND_MUSIC, "background_music"}, // alias
 {ROAR_ROLE_VOICE,            "voice"           },
 {ROAR_ROLE_INSTRUMENT,       "instrument"      },
 {ROAR_ROLE_RHYTHM,           "rhythm"          },
 {ROAR_ROLE_CLICK,            "click",          },
 {ROAR_ROLE_MIXED,            "mixed",          },
 {-1, NULL}
};

int    roar_str2role  (const char * role) {
 int i;

 roar_err_clear();

 for (i = 0; _libroar_role[i].name != NULL; i++)
  if ( !strcasecmp(_libroar_role[i].name, role) )
   return _libroar_role[i].role;

 roar_err_set(ROAR_ERROR_NOENT);
 return ROAR_ROLE_UNKNOWN;
}

const char * roar_role2str  (const int    role) {
 int i;

 for (i = 0; _libroar_role[i].name != NULL; i++)
  if ( _libroar_role[i].role == role )
   return _libroar_role[i].name;

 return "unknown";
}

ssize_t roar_info2samplesize (struct roar_audio_info * info) {
 if ( info == NULL ) {
  roar_err_set(ROAR_ERROR_FAULT);
  return -1;
 }

 switch (info->codec) {
  case ROAR_CODEC_PCM_S_LE:
  case ROAR_CODEC_PCM_S_BE:
  case ROAR_CODEC_PCM_S_PDP:
  case ROAR_CODEC_PCM_U_LE:
  case ROAR_CODEC_PCM_U_BE:
  case ROAR_CODEC_PCM_U_PDP:
    return info->bits;
   break;
  case ROAR_CODEC_ALAW:
  case ROAR_CODEC_MULAW:
    return 8;
   break;
  case ROAR_CODEC_DMX512:
    return 8;
   break;
  case ROAR_CODEC_RDS:
    return 26;
   break;
  default:
    roar_err_set(ROAR_ERROR_INVAL);
    return -1;
   break;
 }
}

ssize_t roar_info2framesize  (struct roar_audio_info * info) {
 ssize_t ret = roar_info2samplesize(info);

 if ( ret == -1 )
  return -1;

 ret *= info->channels;

 return ret;
}

ssize_t roar_info2bitspersec(struct roar_audio_info * info) {
 ssize_t ret = roar_info2samplesize(info);

 if ( ret == -1 )
  return -1;

 ret *= info->channels * info->rate;

 return ret;
}

static struct {
 const char * name;
 struct roar_audio_info info;
} _libroar_aiprofiles[] = {
 {"default",   {.rate     = ROAR_RATE_DEFAULT,
                .bits     = ROAR_BITS_DEFAULT,
                .channels = ROAR_CHANNELS_DEFAULT,
                .codec    = ROAR_CODEC_DEFAULT}},
 {"default-server",
               {.rate     = ROAR_RATE_DEFAULT,
                .bits     = ROAR_ROARD_BITS,
                .channels = ROAR_CHANNELS_DEFAULT,
                .codec    = ROAR_CODEC_DEFAULT}},
 {"wav",       {.rate     = ROAR_RATE_DEFAULT,
                .bits     = ROAR_BITS_DEFAULT,
                .channels = ROAR_CHANNELS_DEFAULT,
                .codec    = ROAR_CODEC_RIFF_WAVE}},
 {"au",        {.rate     = ROAR_RATE_DEFAULT,
                .bits     = ROAR_BITS_DEFAULT,
                .channels = ROAR_CHANNELS_DEFAULT,
                .codec    = ROAR_CODEC_AU}},
 {"cd",        {.rate =  44100, .bits = 16, .channels =  2, .codec = ROAR_CODEC_DEFAULT}},
 {"cdr",       {.rate =  44100, .bits = 16, .channels =  2, .codec = ROAR_CODEC_PCM_S_BE}},
 {"dat",       {.rate =  48000, .bits = 16, .channels =  2, .codec = ROAR_CODEC_PCM_S_LE}},
 {"isdn-eu",   {.rate =   8000, .bits =  8, .channels =  1, .codec = ROAR_CODEC_ALAW}},
 {"isdn-na",   {.rate =   8000, .bits =  8, .channels =  1, .codec = ROAR_CODEC_MULAW}},
 {"speex-nb",  {.rate =   8000, .bits = 16, .channels =  2, .codec = ROAR_CODEC_ROAR_SPEEX}},
 {"speex-wb",  {.rate =  16000, .bits = 16, .channels =  2, .codec = ROAR_CODEC_ROAR_SPEEX}},
 {"speex-uwb", {.rate =  32000, .bits = 16, .channels =  2, .codec = ROAR_CODEC_ROAR_SPEEX}},
 {"opus",      {.rate =  48000, .bits = 16, .channels =  2, .codec = ROAR_CODEC_ROAR_OPUS}},
 {"gsm",       {.rate =   8000, .bits = 16, .channels =  1, .codec = ROAR_CODEC_GSM}},
 {"brr",       {.rate =   8000, .bits = 32, .channels =  1, .codec = ROAR_CODEC_BRR}},
 {"brr6k",     {.rate =   6000, .bits = 32, .channels =  1, .codec = ROAR_CODEC_BRR}},
 {"rds",       {.rate =      0, .bits =  0, .channels =  0, .codec = ROAR_CODEC_RDS}},
 {"midi",      {.rate =      0, .bits =  8, .channels = 16, .codec = ROAR_CODEC_MIDI}},
 {"dmx512",    {.rate =      0, .bits =  8, .channels =  0, .codec = ROAR_CODEC_DMX512}},
 {NULL,        {.rate =      0, .bits =  0, .channels =  0, .codec = 0}}
};

int     roar_profile2info    (struct roar_audio_info * info, const char * profile) {
 int i;

 if ( info == NULL || profile == NULL ) {
  roar_err_set(ROAR_ERROR_FAULT);
  return -1;
 }

 for (i = 0; _libroar_aiprofiles[i].name != NULL; i++) {
  if ( !strcasecmp(_libroar_aiprofiles[i].name, profile) ) {
   memcpy(info, &(_libroar_aiprofiles[i].info), sizeof(struct roar_audio_info));
   return 0;
  }
 }

 roar_err_set(ROAR_ERROR_NOENT);
 return -1;
}

ssize_t   roar_profiles_list   (const char ** list, size_t len, size_t offset) {
 size_t i;
 int idx = 0;

 if ( list == NULL ) {
  roar_err_set(ROAR_ERROR_FAULT);
  return -1;
 }

 if ( len == 0 )
  return 0;

 if ( offset >= (sizeof(_libroar_aiprofiles)/sizeof(*_libroar_aiprofiles)) )
  return 0;

 for (i = offset; _libroar_aiprofiles[i].name != NULL; i++) {
  list[idx++] = _libroar_aiprofiles[i].name;
 }

 return idx;
}

//ll