- PARA_INFO_LOG("wav filter node: %p, output buffer: %p, loaded: %zd\n",
- fn, fn->buf, fn->loaded);
+}
+
+static void wav_pre_select(struct sched *s, struct task *t)
+{
+ struct filter_node *fn = container_of(t, struct filter_node, task);
+ size_t iqs = btr_get_input_queue_size(fn->btrn);
+
+ t->error = 0;
+ if (iqs == 0)
+ return;
+ s->timeout.tv_sec = 0;
+ s->timeout.tv_usec = 1;
+}
+
+static void wav_post_select(__a_unused struct sched *s, struct task *t)
+{
+ struct filter_node *fn = container_of(t, struct filter_node, task);
+ struct btr_node *btrn = fn->btrn;
+ size_t iqs = btr_get_input_queue_size(btrn);
+ int ret;
+ char *header, *buf;
+ int32_t rate, ch;
+
+ t->error = 0;
+ if (iqs == 0) {
+ ret = -E_WAV_EOF;
+ if (btr_no_parent(btrn))
+ goto err;
+ return;
+ }
+ ret = btr_exec_up(btrn, "samplerate", &buf);
+ if (ret < 0) {
+ ret = -E_WAV_BAD_FC;
+ goto err;
+ }
+ ret = para_atoi32(buf, &rate);
+ free(buf);
+ if (ret < 0)
+ goto err;
+ ret = btr_exec_up(btrn, "channels", &buf);
+ if (ret < 0) {
+ ret = -E_WAV_BAD_FC;
+ goto err;
+ }
+ ret = para_atoi32(buf, &ch);
+ free(buf);
+ if (ret < 0)
+ goto err;
+ header = para_malloc(WAV_HEADER_LEN);
+ make_wav_header(ch, rate, header);
+ btr_add_output(header, WAV_HEADER_LEN, btrn);
+ ret = -E_WAV_SUCCESS;
+err:
+ t->error = ret;
+ if (ret == -E_WAV_SUCCESS)
+ btr_splice_out_node(btrn);
+ else {
+ btr_remove_node(btrn);
+ PARA_ERROR_LOG("%s\n", para_strerror(-ret));
+ }