It is unused. Kill PRE_ADD_TAIL and POST_ADD_TAIL too.
s->fc->task.pre_select = filter_pre_select;
s->fc->task.event_handler = filter_event_handler;
s->fc->task.private_data = s->fc;
- s->fc->task.flags = 0;
s->fc->eof = 0;
s->receiver_node->output_eof = &s->fc->eof;
rn->task.pre_select = a->receiver->pre_select;
rn->task.post_select = a->receiver->post_select;
rn->task.event_handler = rn_event_handler;
- rn->task.flags = 0;
sprintf(rn->task.status, "%s receiver node", rn->receiver->name);
register_task(&rn->task);
}
t->post_select = audiod_post_select;
t->event_handler = NULL;
t->private_data = t;
- t->flags = 0;
sprintf(t->status, "audiod task");
}
st->task.pre_select = signal_pre_select;
st->task.post_select = signal_post_select;
st->task.private_data = st;
- st->task.flags = 0;
sprintf(st->task.status, "signal task");
}
ct->task.post_select = command_post_select;
ct->task.event_handler = NULL;
ct->task.private_data = ct;
- ct->task.flags = 0;
ct->fd = audiod_get_socket(); /* doesn't return on errors */
sprintf(ct->task.status, "command task");
}
rn.task.pre_select = r->pre_select;
rn.task.post_select = r->post_select;
rn.task.event_handler = rn_event_handler;
- rn.task.flags = 0;
sprintf(rn.task.status, "receiver node");
register_task(&rn.task);
PARA_INFO_LOG("registering %s (%p)\n", t->status, t);
if (t->pre_select) {
PARA_DEBUG_LOG("pre_select: %p\n", &t->pre_select);
- if (t->flags & PRE_ADD_TAIL)
- list_add_tail(&t->pre_select_node, &pre_select_list);
- else
- list_add(&t->pre_select_node, &pre_select_list);
+ list_add(&t->pre_select_node, &pre_select_list);
}
if (t->post_select) {
PARA_DEBUG_LOG("post_select: %p\n", &t->pre_select);
- if (t->flags & POST_ADD_TAIL)
- list_add_tail(&t->post_select_node, &post_select_list);
- else
- list_add(&t->post_select_node, &post_select_list);
+ list_add(&t->post_select_node, &post_select_list);
}
return t;
}
struct task {
void *private_data;
- unsigned flags;
int ret;
void (*pre_select)(struct sched *s, struct task *t);
void (*post_select)(struct sched *s, struct task *t);
char status[MAXLINE];
};
-enum task_flags {
- PRE_ADD_TAIL = 1,
- POST_ADD_TAIL = 2,
-};
-
void *register_task(struct task *t);
void unregister_task(struct task *t);
int sched(struct sched *s);
sit->bufsize = 16 * 1024,
sit->loaded = 0,
sit->eof = 0,
- sit->task.flags = 0,
sit->task.pre_select = stdin_pre_select;
sit->task.post_select = stdin_post_select;
sit->task.event_handler = stdin_default_event_handler;
sot->task.pre_select = stdout_pre_select;
sot->task.post_select = stdout_post_select;
sot->task.event_handler = stdout_default_event_handler;
- sot->task.flags = 0;
sot->eof = 0;
sprintf(sot->task.status, "stdout writer");
}
g->written = para_calloc(num_writers * sizeof(size_t));
g->task.private_data = g;
g->task.post_select = wng_post_select;
- g->task.flags = 0;
return g;
}