* buffer of the stdin task, it adds \p STDIN_FILENO to the read fd set
* of \a s.
*/
-void stdin_pre_select(struct sched *s, struct task *t)
+static void stdin_pre_select(struct sched *s, struct task *t)
{
struct stdin_task *sit = t->private_data;
t->ret = 1;
static void stdin_default_event_handler(struct task *t)
{
- PARA_NOTICE_LOG("%p: %s\n", t, PARA_STRERROR(-t->ret));
+ PARA_NOTICE_LOG("%p: %s\n", t, para_strerror(-t->ret));
unregister_task(t);
}
* appeears to be readable, data is read from stdin into the buffer of the
* stdin task.
*/
-void stdin_post_select(struct sched *s, struct task *t)
+static void stdin_post_select(struct sched *s, struct task *t)
{
struct stdin_task *sit = t->private_data;
ssize_t ret;
} else
t->ret = -E_STDIN_EOF;
if (t->ret < 0)
- sit->eof = 1;
+ sit->error = t->ret;
}
/**
{
sit->bufsize = 16 * 1024,
sit->loaded = 0,
- sit->eof = 0,
+ sit->error = 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.private_data = sit;
- mark_fd_nonblock(STDIN_FILENO);
+ mark_fd_nonblocking(STDIN_FILENO);
sprintf(sit->task.status, "stdin reader");
}