/** The alsa handle */
snd_pcm_t *handle;
/** Determined and set by alsa_open(). */
- int bytes_per_frame; /* TODO: Kill this after btr switch */
+ int bytes_per_frame;
/** The approximate maximum buffer duration in us. */
unsigned buffer_time;
/* Number of frames that fit into the buffer. */
* decoder of the writer node group.
*/
unsigned channels;
+ struct timeval drain_barrier;
};
/* Install PCM software and hardware configuration. */
snd_pcm_uframes_t period_size;
int err;
+ PARA_INFO_LOG("opening %s\n", conf->device_arg);
err = snd_pcm_open(&pad->handle, conf->device_arg,
SND_PCM_STREAM_PLAYBACK, SND_PCM_NONBLOCK);
if (err < 0)
}
/* Open an instance of the alsa writer. */
-static int alsa_open_nobtr(struct writer_node *wn)
-{
- struct alsa_write_args_info *conf = wn->conf;
- struct writer_node_group *wng = wn->wng;
- struct private_alsa_write_data *pad = para_calloc(sizeof(*pad));
-
- wn->private_data = pad;
- if (!conf->samplerate_given && wng->samplerate)
- pad->samplerate = *wng->samplerate;
- else
- pad->samplerate = conf->samplerate_arg;
- if (!conf->channels_given && wng->channels)
- pad->channels = *wng->channels;
- else
- pad->channels = conf->channels_arg;
- PARA_INFO_LOG("%d channel(s), %dHz\n", pad->channels, pad->samplerate);
- return 1;
-}
-
-static int alsa_open_btr(struct writer_node *wn)
-{
- struct private_alsa_write_data *pad = para_calloc(sizeof(*pad));
-
- sprintf(wn->task.status, "alsa writer");
- wn->private_data = pad;
- return 1;
-}
static int alsa_open(struct writer_node *wn)
{
- if (wn->btrn)
- return alsa_open_btr(wn);
- return alsa_open_nobtr(wn);
+ wn->private_data = para_calloc(sizeof(struct private_alsa_write_data));
+ return 1;
}
-static int alsa_write_pre_select(struct sched *s, struct writer_node *wn)
+static void alsa_write_pre_select(struct sched *s, struct task *t)
{
+ struct writer_node *wn = container_of(t, struct writer_node, task);
struct private_alsa_write_data *pad = wn->private_data;
- struct writer_node_group *wng = wn->wng;
struct timeval tv;
snd_pcm_sframes_t avail, underrun;
+ int ret;
if (!pad->handle)
- return 1;
- if (wn->btrn) {
- int ret = btr_node_status(wn->btrn, wn->min_iqs);
- if (ret == 0)
- return 1;
- if (ret < 0) {
- underrun = 10;
- goto timeout;
- }
- } else {
- if (*wng->loaded - wn->written < pad->bytes_per_frame)
- return 1;
- }
+ return;
+ ret = btr_node_status(wn->btrn, wn->min_iqs, BTR_NT_LEAF);
+ if (ret < 0)
+ sched_request_timeout_ms(20, s);
+ if (ret <= 0)
+ return;
/*
* Data is available to be written to the alsa handle. Compute number
* of milliseconds until next buffer underrun would occur.
if (underrun < 50)
underrun = 50;
underrun -= 50;
-timeout:
ms2tv(underrun, &tv);
if (tv_diff(&s->timeout, &tv, NULL) > 0)
s->timeout = tv;
- //PARA_CRIT_LOG("timout: %lu\n", tv2ms(&s->timeout));
- return 1;
-}
-
-static void alsa_write_pre_select_btr(struct sched *s, struct task *t)
-{
- struct writer_node *wn = container_of(t, struct writer_node, task);
- alsa_write_pre_select(s, wn);
-}
-
-static void xrun(snd_pcm_t *handle)
-{
- snd_pcm_status_t *status;
- int ret;
- struct timeval tv, diff;
-
- snd_pcm_status_alloca(&status);
- ret = snd_pcm_status(handle, status);
- if (ret < 0)
- return;
- if (snd_pcm_status_get_state(status) != SND_PCM_STATE_XRUN)
- return;
- snd_pcm_status_get_trigger_tstamp(status, &tv);
- tv_diff(now, &tv, &diff);
- PARA_WARNING_LOG("underrun: %lums\n", tv2ms(&diff));
-}
-
-static int alsa_write_post_select(__a_unused struct sched *s,
- struct writer_node *wn)
-{
- struct private_alsa_write_data *pad = wn->private_data;
- struct writer_node_group *wng = wn->wng;
- size_t bytes = *wng->loaded - wn->written;
- unsigned char *data = (unsigned char*)*wng->bufp + wn->written;
- snd_pcm_sframes_t ret, frames, avail;
-
- if (*wng->input_error < 0 && (!pad->handle || bytes < pad->bytes_per_frame)) {
- wn->written = *wng->loaded;
- return *wng->input_error;
- }
- if (!bytes) /* no data available */
- return 0;
- if (!pad->handle) {
- int err = alsa_init(pad, wn->conf);
- if (err < 0)
- return err;
- }
- frames = bytes / pad->bytes_per_frame;
- if (!frames) /* less than a single frame available */
- return 0;
- avail = snd_pcm_avail_update(pad->handle);
- if (avail <= 0)
- return 0;
- frames = PARA_MIN(frames, avail);
- ret = snd_pcm_writei(pad->handle, data, frames);
- if (ret >= 0) {
- wn->written += ret * pad->bytes_per_frame;
- return 1;
- }
- if (ret == -EPIPE) {
- xrun(pad->handle);
- snd_pcm_prepare(pad->handle);
- return 0;
- }
- PARA_WARNING_LOG("%s\n", snd_strerror(-ret));
- if (ret == -EAGAIN)
- return 0;
- return -E_ALSA_WRITE;
}
static void alsa_close(struct writer_node *wn)
snd_pcm_close(pad->handle);
snd_config_update_free_global();
}
- alsa_cmdline_parser_free(wn->conf);
free(pad);
}
-static void alsa_write_post_select_btr(__a_unused struct sched *s,
+static void alsa_write_post_select(__a_unused struct sched *s,
struct task *t)
{
struct writer_node *wn = container_of(t, struct writer_node, task);
struct btr_node *btrn = wn->btrn;
char *data;
size_t bytes;
- snd_pcm_sframes_t frames, avail;
+ snd_pcm_sframes_t frames;
int ret;
again:
t->error = 0;
- ret = btr_node_status(btrn, wn->min_iqs);
+ ret = btr_node_status(btrn, wn->min_iqs, BTR_NT_LEAF);
if (ret == 0)
return;
btr_merge(btrn, wn->min_iqs);
bytes = btr_next_buffer(btrn, &data);
- if (bytes < pad->bytes_per_frame) { /* eof */
+ if (ret < 0 || bytes < pad->bytes_per_frame) { /* eof */
assert(btr_no_parent(btrn));
ret = -E_ALSA_EOF;
if (!pad->handle)
goto err;
/* wait until pending frames are played */
- avail = snd_pcm_avail_update(pad->handle);
- if (avail + 1000 > pad->buffer_frames)
+ if (pad->drain_barrier.tv_sec == 0) {
+ PARA_DEBUG_LOG("waiting for device to drain\n");
+ tv_add(now, &(struct timeval)EMBRACE(0, 200 * 1000),
+ &pad->drain_barrier);
+ return;
+ }
+ if (tv_diff(now, &pad->drain_barrier, NULL) > 0)
goto err;
return;
}
if (!pad->handle) {
- char *buf;
struct alsa_write_args_info *conf = wn->conf;
if (bytes == 0) /* no data available */
return;
- PARA_CRIT_LOG("alsa init\n");
/* defaults */
pad->samplerate = conf->samplerate_arg;
pad->channels = conf->channels_arg;
if (!conf->samplerate_given) { /* config option trumps btr_exec */
- /* ask parent btr nodes */
- buf = NULL;
- ret = btr_exec_up(btrn, "samplerate", &buf);
- PARA_CRIT_LOG("ret: %d\n", ret);
- if (ret >= 0) {
- int32_t rate;
-
- ret = para_atoi32(buf, &rate);
- free(buf);
- if (ret < 0) /* should not happen */
- goto err;
+ int32_t rate;
+ if (get_btr_samplerate(btrn, &rate) >= 0)
pad->samplerate = rate;
- }
}
if (!conf->channels_given) {
- buf = NULL;
- ret = btr_exec_up(btrn, "channels", &buf);
- if (ret >= 0) {
- int32_t ch;
-
- ret = para_atoi32(buf, &ch);
- freep(&buf);
- if (ret < 0)
- goto err;
+ int32_t ch;
+ if (get_btr_channels(btrn, &ch) >= 0)
pad->channels = ch;
- }
}
PARA_INFO_LOG("%d channel(s), %dHz\n", pad->channels, pad->samplerate);
- ret = 1;
ret = alsa_init(pad, wn->conf);
if (ret < 0)
goto err;
wn->min_iqs = pad->bytes_per_frame;
}
frames = bytes / pad->bytes_per_frame;
- avail = snd_pcm_avail_update(pad->handle);
- if (avail <= 0)
- return;
- frames = PARA_MIN(frames, avail);
- //PARA_CRIT_LOG("writing %ld frames\n", frames);
frames = snd_pcm_writei(pad->handle, data, frames);
if (frames >= 0) {
btr_consume(btrn, frames * pad->bytes_per_frame);
goto again;
}
if (frames == -EPIPE) {
- xrun(pad->handle);
+ PARA_WARNING_LOG("underrun (tried to write %zu bytes)\n", bytes);
snd_pcm_prepare(pad->handle);
return;
}
- PARA_WARNING_LOG("%s\n", snd_strerror(-frames));
if (frames == -EAGAIN)
return;
+ PARA_WARNING_LOG("%s\n", snd_strerror(-frames));
ret = -E_ALSA_WRITE;
err:
assert(ret < 0);
+ btr_remove_node(btrn);
t->error = ret;
}
return NULL;
}
+static void alsa_free_config(void *conf)
+{
+ alsa_cmdline_parser_free(conf);
+}
+
/**
- * the init function of the alsa writer
+ * The init function of the alsa writer.
*
- * \param w pointer to the writer to initialize
+ * \param w Pointer to the writer to initialize.
*
- * \sa struct writer
+ * \sa struct \ref writer.
*/
void alsa_write_init(struct writer *w)
{
w->open = alsa_open;
w->close = alsa_close;
w->pre_select = alsa_write_pre_select;
- w->pre_select_btr = alsa_write_pre_select_btr;
w->post_select = alsa_write_post_select;
- w->post_select_btr = alsa_write_post_select_btr;
w->parse_config = alsa_parse_config;
w->shutdown = NULL; /* nothing to do */
+ w->free_config = alsa_free_config;
w->help = (struct ggo_help) {
.short_help = alsa_write_args_info_help,
.detailed_help = alsa_write_args_info_detailed_help