#include <regex.h>
#include <sys/types.h>
#include <dirent.h>
+#include <stdbool.h>
#include "para.h"
#include "string.h"
#include "sched.h"
#include "ggo.h"
#include "stdin.h"
+#include "buffer_tree.h"
#include "write.h"
#include "write_common.h"
#include "fd.h"
struct task task;
};
+enum check_wav_state {
+ CWS_NEED_HEADER,
+ CWS_HAVE_HEADER,
+ CWS_NO_HEADER,
+};
+
+struct check_wav_task_btr {
+ int state;
+ /** Number of channels specified in wav header given by \a buf. */
+ unsigned channels;
+ /** Sample rate specified in wav header given by \a buf. */
+ unsigned samplerate;
+ /** The task structure used by the scheduler. */
+ struct task task;
+ struct btr_node *btrn;
+};
+
/** Delay writing until given time. */
struct initial_delay_task {
/** The time the first data should be written out. */
s->timeout.tv_usec = 1;
}
+static void check_wav_pre_select_btr(__a_unused struct sched *s, struct task *t)
+{
+ struct check_wav_task_btr *cwt = container_of(t, struct check_wav_task_btr, task);
+
+ if (btr_get_input_queue_size(cwt->btrn) < WAV_HEADER_LEN)
+ return;
+ s->timeout.tv_sec = 0;
+ s->timeout.tv_usec = 1;
+}
+
+static int check_wav_exec(struct btr_node *btrn, const char *cmd, char **result)
+{
+ struct check_wav_task_btr *cwt = btr_context(btrn);
+
+
+ if (!strcmp(cmd, "samplerate")) {
+ if (cwt->state != CWS_HAVE_HEADER)
+ return -ERRNO_TO_PARA_ERROR(ENAVAIL);
+ *result = make_message("%d", cwt->samplerate);
+ return 1;
+ }
+ if (!strcmp(cmd, "channels")) {
+ if (cwt->state != CWS_HAVE_HEADER)
+ return -ERRNO_TO_PARA_ERROR(ENAVAIL);
+ *result = make_message("%d", cwt->channels);
+ return 1;
+ }
+ return -ERRNO_TO_PARA_ERROR(ENOTSUP);
+}
+
+static void check_wav_post_select_btr(__a_unused struct sched *s, struct task *t)
+{
+ struct check_wav_task_btr *cwt = container_of(t, struct check_wav_task_btr, task);
+ unsigned char *a;
+ size_t sz = btr_get_input_queue_size(cwt->btrn);
+
+ t->error = 0;
+ if (cwt->state != CWS_NEED_HEADER)
+ goto out;
+ if (sz < WAV_HEADER_LEN) {
+ if (!btr_no_parent(cwt->btrn))
+ return;
+ if (sz != 0) {
+ cwt->state = CWS_NO_HEADER;
+ goto out;
+ }
+ t->error = -E_WRITE_EOF;
+ goto err;
+ }
+ cwt->channels = 2;
+ cwt->samplerate = 44100;
+ btr_next_buffer(cwt->btrn, (char **)&a);
+ if (a[0] != 'R' || a[1] != 'I' || a[2] != 'F' || a[3] != 'F') {
+ PARA_NOTICE_LOG("wav header not found\n");
+ cwt->state = CWS_NO_HEADER;
+ sprintf(t->status, "check wav: no header");
+ goto out;
+ }
+ PARA_INFO_LOG("found wav header\n");
+ cwt->state = CWS_HAVE_HEADER;
+ sprintf(t->status, "check wav: have header");
+ cwt->channels = (unsigned) a[22];
+ cwt->samplerate = a[24] + (a[25] << 8) + (a[26] << 16) + (a[27] << 24);
+ PARA_INFO_LOG("channels: %d, sample rate: %d\n", cwt->channels, cwt->samplerate);
+ btr_consume(cwt->btrn, WAV_HEADER_LEN);
+out:
+ if (sz)
+ btr_pushdown(cwt->btrn);
+ else {
+ if (btr_no_parent(cwt->btrn))
+ t->error = -E_WRITE_EOF;
+ }
+err:
+ if (t->error < 0)
+ btr_remove_node(cwt->btrn);
+}
+
static void initial_delay_pre_select(struct sched *s, struct task *t)
{
struct initial_delay_task *idt = container_of(t, struct initial_delay_task, task);
exit(0);
}
+/*
+ TODO: check wav, initial delay, multiple writers, non-default writers
+ */
+static int main_btr(struct sched *s)
+{
+ int i, ret;
+ struct check_wav_task_btr _cwt, *cwt = &_cwt;
+ struct writer_node *wns;
+
+ loglevel = get_loglevel_by_name(conf.loglevel_arg);
+ sit.btrn = btr_new_node("stdin", NULL /* stdin has no parent */, NULL, NULL);
+ stdin_set_defaults(&sit);
+ register_task(&sit.task);
+
+ cwt->state = CWS_NEED_HEADER;
+ cwt->btrn = btr_new_node("check wav", sit.btrn, check_wav_exec, cwt);
+ sprintf(cwt->task.status, "check wav");
+ cwt->task.pre_select = check_wav_pre_select_btr;
+ cwt->task.post_select = check_wav_post_select_btr;
+ cwt->task.error = 0;
+ register_task(&cwt->task);
+
+ ret = -E_WRITE_SYNTAX;
+ if (!conf.writer_given) {
+ i = 0;
+ wns = para_calloc(sizeof(*wns));
+ ret = setup_writer_node(NULL, cwt->btrn, wns);
+ if (ret < 0)
+ goto out;
+ i = 1;
+ } else {
+ wns = para_calloc(conf.writer_given * sizeof(*wns));
+ for (i = 0; i < conf.writer_given; i++) {
+ ret = setup_writer_node(conf.writer_arg[i],
+ cwt->btrn, wns + i);
+ if (ret < 0)
+ goto out;
+ }
+ }
+
+ s->default_timeout.tv_sec = 10;
+ s->default_timeout.tv_usec = 50000;
+ ret = schedule(s);
+out:
+ for (i--; i >= 0; i--) {
+ struct writer_node *wn = wns + i;
+ struct writer *w = writers + wn->writer_num;
+
+ w->close(wn);
+ btr_free_node(wn->btrn);
+ free(wn->conf);
+ free(wn);
+ }
+ free(wns);
+ btr_free_node(cwt->btrn);
+ return ret;
+}
+
/**
* Para_write's main function.
*
if (conf.help_given || conf.detailed_help_given)
print_help_and_die();
+ if (conf.buffer_tree_given) {
+ ret = main_btr(&s);
+ goto out;
+ }
wng = check_args();
if (!wng)
goto out;
projects / paraslash.git / blobdiff