}
ret = 1;
out:
- if (ret > 0) {
+ if (ret > 0)
return wng;
- }
free(wng);
return NULL;
}
unregister_task(t);
wng->buf = sit.buf;
wng->loaded = &sit.loaded;
- wng->eof = &sit.eof;
- sprintf(wng->task.status, "%s", "writer node group");
+ wng->input_eof = &sit.eof;
ret = wng_open(wng);
if (ret < 0) {
PARA_ERROR_LOG("%s\n", PARA_STRERROR(-ret));
register_task(&idt.task);
}
-static void stdin_event_handler(struct task *t)
-{
- unregister_task(t);
- if (t->ret != -E_STDIN_EOF)
- PARA_ERROR_LOG("%s\n", PARA_STRERROR(-t->ret));
- else
- PARA_INFO_LOG("%s\n", PARA_STRERROR(-t->ret));
-}
-
int main(int argc, char *argv[])
{
int ret = -E_WRITE_SYNTAX;
init_supported_writers();
init_sched();
- sit.bufsize = 16 * 1024,
- sit.buf = para_malloc(16 * 1024),
- sit.loaded = 0,
- sit.task.pre_select = stdin_pre_select;
- sit.task.post_select = stdin_post_select;
- sit.task.event_handler = stdin_event_handler;
- sit.task.private_data = &sit;
- sprintf(sit.task.status, "stdin reader");
+ stdin_set_defaults(&sit);
+ sit.buf = para_malloc(sit.bufsize),
register_task(&sit.task);
cwt.task.pre_select = check_wav_pre_select;