summaryrefslogtreecommitdiff
path: root/modules/sndio
diff options
context:
space:
mode:
authorAlfred E. Heggestad <aeh@db.org>2014-04-09 21:26:16 +0200
committerAlfred E. Heggestad <aeh@db.org>2014-04-09 21:26:16 +0200
commitbca1461f503407fc9c8f7a692ec75c968a0acf27 (patch)
treefd92b283fe1145cef4f265069763c3fa52940568 /modules/sndio
parentc8f2d1852309be78cba0fd1cc570e65e5eaa3b8f (diff)
sndio: audio driver for OpenBSD
It was contributed by Dmitrij D. Czarkoff, thank you!
Diffstat (limited to 'modules/sndio')
-rw-r--r--modules/sndio/module.mk11
-rw-r--r--modules/sndio/sndio.c307
2 files changed, 318 insertions, 0 deletions
diff --git a/modules/sndio/module.mk b/modules/sndio/module.mk
new file mode 100644
index 0000000..79ace67
--- /dev/null
+++ b/modules/sndio/module.mk
@@ -0,0 +1,11 @@
+#
+# module.mk
+#
+# Copyright (C) 2014 Creytiv.com
+#
+
+MOD := sndio
+$(MOD)_SRCS += sndio.c
+$(MOD)_LFLAGS += -lsndio
+
+include mk/mod.mk
diff --git a/modules/sndio/sndio.c b/modules/sndio/sndio.c
new file mode 100644
index 0000000..ee0fd46
--- /dev/null
+++ b/modules/sndio/sndio.c
@@ -0,0 +1,307 @@
+/**
+ * @file sndio.c SndIO sound driver
+ *
+ * Copyright (C) 2014 Creytiv.com
+ */
+#include <stdlib.h>
+#include <string.h>
+#include <sndio.h>
+#include <pthread.h>
+#include <re.h>
+#include <rem.h>
+#include <baresip.h>
+
+
+struct ausrc_st {
+ struct ausrc *as;
+ struct sio_hdl *hdl;
+ pthread_t thread;
+ size_t nbytes;
+ void *buf;
+ int run;
+ ausrc_read_h *rh;
+ void *arg;
+};
+
+struct auplay_st {
+ struct auplay *ap;
+ struct sio_hdl *hdl;
+ pthread_t thread;
+ size_t nbytes;
+ void *buf;
+ int run;
+ auplay_write_h *wh;
+ void *arg;
+};
+
+static struct ausrc *ausrc;
+static struct auplay *auplay;
+
+
+static struct sio_par *sndio_initpar(void *arg)
+{
+ struct sio_par *par;
+ struct auplay_prm *prm = arg;
+
+ if ((par = malloc(sizeof(struct sio_par))) == NULL)
+ return NULL;
+
+ sio_initpar(par);
+
+ /* sndio doesn't support a-low and u-low */
+ prm->fmt = AUFMT_S16LE;
+ par->bits = 16;
+ par->bps = SIO_BPS(par->bits);
+ par->sig = 1;
+ par->le = 1;
+
+ par->rchan = prm->ch;
+ par->pchan = prm->ch;
+ par->rate = prm->srate;
+
+ return par;
+}
+
+
+static void *read_thread(void *arg)
+{
+ struct ausrc_st *st = arg;
+
+ if (!sio_start(st->hdl)) {
+ warning("sndio: could not start record\n");
+ goto out;
+ }
+
+ while (st->run) {
+ sio_read(st->hdl, st->buf, st->nbytes);
+ st->rh(st->buf, st->nbytes, st->arg);
+ }
+
+ out:
+ return NULL;
+}
+
+
+static void *write_thread(void *arg)
+{
+ struct auplay_st *st = arg;
+
+ if (!sio_start(st->hdl)) {
+ warning("sndio: could not start playback\n");
+ goto out;
+ }
+
+ while (st->run) {
+ st->wh(st->buf, st->nbytes, st->arg);
+ sio_write(st->hdl, st->buf, st->nbytes);
+ }
+
+ out:
+ return NULL;
+}
+
+
+static void ausrc_destructor(void *arg)
+{
+ struct ausrc_st *st = arg;
+
+ if (st->run) {
+ st->run = false;
+ (void)pthread_join(st->thread, NULL);
+ }
+
+ sio_close(st->hdl);
+
+ mem_deref(st->buf);
+ mem_deref(st->as);
+}
+
+
+static void auplay_destructor(void *arg)
+{
+ struct auplay_st *st = arg;
+
+ if (st->run) {
+ st->run = false;
+ (void)pthread_join(st->thread, NULL);
+ }
+
+ sio_close(st->hdl);
+
+ mem_deref(st->buf);
+ mem_deref(st->ap);
+}
+
+
+static int src_alloc(struct ausrc_st **stp, struct ausrc *as,
+ struct media_ctx **ctx,
+ struct ausrc_prm *prm, const char *device,
+ ausrc_read_h *rh, ausrc_error_h *errh, void *arg)
+{
+ struct ausrc_st *st;
+ struct sio_par *par;
+ int err;
+ const char *name;
+
+ (void)ctx;
+ (void)errh;
+
+ if (!stp || !as || !prm)
+ return EINVAL;
+
+ name = (str_isset(device)) ? device : SIO_DEVANY;
+
+ if ((st = mem_zalloc(sizeof(*st), ausrc_destructor)) == NULL)
+ return ENOMEM;
+
+ st->as = mem_ref(as);
+ st->rh = rh;
+ st->arg = arg;
+ st->hdl = sio_open(name, SIO_REC, 0);
+
+ if (!st->hdl) {
+ warning("sndio: could not open ausrc device '%s'\n", name);
+ err = EINVAL;
+ goto out;
+ }
+
+ par = sndio_initpar(prm);
+ if (!par) {
+ err = ENOMEM;
+ goto out;
+ }
+
+ if (!sio_setpar(st->hdl, par)) {
+ free(par);
+ err = EINVAL;
+ goto out;
+ }
+
+ if (!sio_getpar(st->hdl, par)) {
+ free(par);
+ err = EINVAL;
+ goto out;
+ }
+
+ st->nbytes = 2 * par->appbufsz;
+ st->buf = mem_alloc(st->nbytes, NULL);
+ if (!st->buf) {
+ free(par);
+ err = ENOMEM;
+ goto out;
+ }
+
+ free(par);
+
+ st->run = true;
+ err = pthread_create(&st->thread, NULL, read_thread, st);
+ if (err)
+ st->run = false;
+
+ out:
+ if (err)
+ mem_deref(st);
+ else
+ *stp = st;
+
+ return err;
+}
+
+
+static int play_alloc(struct auplay_st **stp, struct auplay *ap,
+ struct auplay_prm *prm, const char *device,
+ auplay_write_h *wh, void *arg)
+{
+ struct auplay_st *st;
+ struct sio_par *par;
+ int err;
+ const char *name;
+
+ if (!stp || !ap || !prm)
+ return EINVAL;
+
+ name = (str_isset(device)) ? device : SIO_DEVANY;
+
+ if ((st = mem_zalloc(sizeof(*st), auplay_destructor)) == NULL)
+ return ENOMEM;
+
+ st->ap = mem_ref(ap);
+ st->wh = wh;
+ st->arg = arg;
+ st->hdl = sio_open(name, SIO_PLAY, 0);
+
+ if (!st->hdl) {
+ warning("sndio: could not open auplay device '%s'\n", name);
+ err = EINVAL;
+ goto out;
+ }
+
+ par = sndio_initpar(prm);
+ if (!par) {
+ err = ENOMEM;
+ goto out;
+ }
+
+ if (!sio_setpar(st->hdl, par)) {
+ free(par);
+ err = EINVAL;
+ goto out;
+ }
+
+ if (!sio_getpar(st->hdl, par)) {
+ free(par);
+ err = EINVAL;
+ goto out;
+ }
+
+ st->nbytes = 2 * par->appbufsz;
+ st->buf = mem_alloc(st->nbytes, NULL);
+ if (!st->buf) {
+ free(par);
+ err = ENOMEM;
+ goto out;
+ }
+
+ free(par);
+
+ st->run = true;
+ err = pthread_create(&st->thread, NULL, write_thread, st);
+ if (err)
+ st->run = false;
+
+ out:
+ if (err)
+ mem_deref(st);
+ else
+ *stp = st;
+
+ return err;
+}
+
+
+static int sndio_init(void)
+{
+ int err = 0;
+
+ err |= ausrc_register(&ausrc, "sndio", src_alloc);
+ err |= auplay_register(&auplay, "sndio", play_alloc);
+
+ return err;
+}
+
+
+static int sndio_close(void)
+{
+ ausrc = mem_deref(ausrc);
+ auplay = mem_deref(auplay);
+
+ return 0;
+}
+
+
+EXPORT_SYM const struct mod_export DECL_EXPORTS(sndio) = {
+ "sndio",
+ "sound",
+ sndio_init,
+ sndio_close
+};