tmp = NULL;
}
pt->rn.task.pre_select = afh_recv->pre_select;
- if (afh_recv->new_post_select) {
- pt->rn.task.new_post_select = afh_recv->new_post_select;
- pt->rn.task.post_select = NULL;
- } else {
- pt->rn.task.post_select = NULL;
- pt->rn.task.new_post_select = afh_recv->new_post_select;
- }
+ pt->rn.task.post_select = afh_recv->post_select;
sprintf(pt->rn.task.status, "%s receiver node", afh_recv->name);
return 1;
fail:
pt->fn.filter_num = ret;
decoder = filters + ret;
pt->fn.task.pre_select = decoder->pre_select;
- if (decoder->new_post_select) {
- pt->fn.task.new_post_select = decoder->new_post_select;
- pt->fn.task.post_select = NULL;
- } else {
- pt->fn.task.new_post_select = NULL;
- pt->fn.task.post_select = decoder->post_select;
- }
+ pt->fn.task.post_select = decoder->post_select;
sprintf(pt->fn.task.status, "%s decoder", af);
pt->fn.btrn = btr_new_node(&(struct btr_node_description)
EMBRACE(.name = decoder->name, .parent = pt->rn.btrn,
static int play_i9e_line_handler(char *line)
{
- struct play_task *pt = &play_task;
- int ret;
-
- if (line == NULL || !*line)
- return 0;
- ret = run_command(line, pt);
- if (ret < 0)
- return ret;
- return 0;
+ return run_command(line, &play_task);
}
static int play_i9e_key_handler(int key)
);
}
-static void play_post_select(struct sched *s, struct task *t)
+static int play_post_select(struct sched *s, struct task *t)
{
struct play_task *pt = container_of(t, struct play_task, task);
int ret;
ret = eof_cleanup(pt);
if (ret < 0) {
pt->rq = CRT_TERM_RQ;
- return;
+ return 0;
}
ret = session_post_select(s, t);
if (ret < 0)
}
ret = 1;
out:
- t->error = ret;
+ return ret;
}
/**