X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=stdout.c;h=178f3eebe5cab4e8f0df1d9fdf3e03b813a14f16;hp=fe188c9a0f45499af57585a2d04f147916e89072;hb=db0e72763ac5660b01c8c2db75901f4efa2c44cc;hpb=5c556c52f1196cea4536d36b683372de532943a9 diff --git a/stdout.c b/stdout.c index fe188c9a..178f3eeb 100644 --- a/stdout.c +++ b/stdout.c @@ -33,8 +33,8 @@ static void stdout_pre_select(struct sched *s, struct task *t) t->ret = 1; sot->check_fd = 0; if (!*sot->loaded) { - if (*sot->input_eof) { - t->ret = -E_STDOUT_EOF; + if (*sot->input_error) { + t->ret = *sot->input_error; s->timeout.tv_sec = 0; s->timeout.tv_usec = 1; } @@ -62,8 +62,8 @@ static void stdout_post_select(struct sched *s, struct task *t) t->ret = 1; if (!sot->check_fd) { - if (*sot->input_eof) - t->ret = -E_STDOUT_EOF; + if (*sot->input_error) + t->ret = *sot->input_error; return; } if (!FD_ISSET(STDOUT_FILENO, &s->wfds)) @@ -80,7 +80,7 @@ static void stdout_post_select(struct sched *s, struct task *t) static void stdout_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); } @@ -99,7 +99,7 @@ void stdout_set_defaults(struct stdout_task *sot) 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; + sot->error = 0; mark_fd_nonblocking(STDOUT_FILENO); sprintf(sot->task.status, "stdout writer"); }