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.pre_select = filter_pre_select;
s->fc->task.event_handler = filter_event_handler;
s->fc->task.private_data = s->fc;
s->fc->eof = 0;
s->receiver_node->output_eof = &s->fc->eof;
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.pre_select = a->receiver->pre_select;
rn->task.post_select = a->receiver->post_select;
rn->task.event_handler = rn_event_handler;
sprintf(rn->task.status, "%s receiver node", rn->receiver->name);
register_task(&rn->task);
}
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->post_select = audiod_post_select;
t->event_handler = NULL;
t->private_data = t;
sprintf(t->status, "audiod task");
}
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.pre_select = signal_pre_select;
st->task.post_select = signal_post_select;
st->task.private_data = st;
sprintf(st->task.status, "signal task");
}
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.post_select = command_post_select;
ct->task.event_handler = NULL;
ct->task.private_data = ct;
ct->fd = audiod_get_socket(); /* doesn't return on errors */
sprintf(ct->task.status, "command task");
}
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.pre_select = r->pre_select;
rn.task.post_select = r->post_select;
rn.task.event_handler = rn_event_handler;
sprintf(rn.task.status, "receiver node");
register_task(&rn.task);
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);
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->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);
struct task {
void *private_data;
struct task {
void *private_data;
int ret;
void (*pre_select)(struct sched *s, struct task *t);
void (*post_select)(struct sched *s, struct task *t);
int ret;
void (*pre_select)(struct sched *s, struct task *t);
void (*post_select)(struct sched *s, struct task *t);
-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);
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->bufsize = 16 * 1024,
sit->loaded = 0,
sit->eof = 0,
sit->task.pre_select = stdin_pre_select;
sit->task.post_select = stdin_post_select;
sit->task.event_handler = stdin_default_event_handler;
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.pre_select = stdout_pre_select;
sot->task.post_select = stdout_post_select;
sot->task.event_handler = stdout_default_event_handler;
sot->eof = 0;
sprintf(sot->task.status, "stdout writer");
}
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->written = para_calloc(num_writers * sizeof(size_t));
g->task.private_data = g;
g->task.post_select = wng_post_select;