};
struct play_task {
- struct task task;
+ struct task *task;
/* A bit array of invalid files (those will be skipped). */
bool *invalid;
/* The file which is currently open. */
/* returns: 0 not eof, 1: eof, < 0: fatal error. */
static int get_playback_error(struct play_task *pt)
{
- int err = pt->wn.task.error;
+ int err;
+ if (!pt->wn.task)
+ return 0;
+ err = pt->wn.task->error;
if (err >= 0)
return 0;
if (pt->fn.task->error >= 0)
if (ret == 0)
return ret;
PARA_NOTICE_LOG("cleaning up wn/fn nodes\n");
+ task_reap(&pt->wn.task);
w->close(&pt->wn);
btr_remove_node(&pt->wn.btrn);
w->free_config(pt->wn.conf);
/* setup default writer */
pt->wn.conf = check_writer_arg_or_die(NULL, &pt->wn.writer_num);
- pt->wn.task.error = 0;
/* success, register tasks */
pt->rn.task = task_register(
static void kill_stream(struct play_task *pt)
{
- task_notify(&pt->wn.task, E_EOF);
+ if (pt->wn.task)
+ task_notify(pt->wn.task, E_EOF);
}
#ifdef HAVE_READLINE
*/
static int session_post_select(__a_unused struct sched *s, struct task *t)
{
- struct play_task *pt = container_of(t, struct play_task, task);
+ struct play_task *pt = task_context(t);
int ret;
if (pt->background)
static int session_post_select(struct sched *s, struct task *t)
{
- struct play_task *pt = container_of(t, struct play_task, task);
+ struct play_task *pt = task_context(t);
char c;
if (!FD_ISSET(STDIN_FILENO, &s->rfds))
static void play_pre_select(struct sched *s, struct task *t)
{
- struct play_task *pt = container_of(t, struct play_task, task);
+ struct play_task *pt = task_context(t);
char state;
para_fd_set(STDIN_FILENO, &s->rfds, &s->max_fileno);
static int play_post_select(struct sched *s, struct task *t)
{
- struct play_task *pt = container_of(t, struct play_task, task);
+ struct play_task *pt = task_context(t);
int ret;
ret = eof_cleanup(pt);
pt->rq = CRT_FILE_CHANGE;
pt->current_file = conf.inputs_num - 1;
pt->playing = true;
- pt->task.pre_select = play_pre_select;
- pt->task.post_select = play_post_select;
- sprintf(pt->task.status, "play task");
- register_task(&sched, &pt->task);
+ pt->task = task_register(&(struct task_info){
+ .name = "play",
+ .pre_select = play_pre_select,
+ .post_select = play_post_select,
+ .context = pt,
+ }, &sched);
ret = schedule(&sched);
sched_shutdown(&sched);
if (ret < 0)