X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=stdin.c;h=4e567008dd1f2f7a3d98cf691a6ce04c2e5a7de1;hp=25eca2ef224f312a1249493d2bc9b192ce066d76;hb=94fa6ad6ec3068227d322cb83186ff8780100107;hpb=19d9318abf42debb15d833d4e56ab636893285c3 diff --git a/stdin.c b/stdin.c index 25eca2ef..4e567008 100644 --- a/stdin.c +++ b/stdin.c @@ -1,10 +1,10 @@ /* - * Copyright (C) 2006 Andre Noll + * Copyright (C) 2006-2008 Andre Noll * * Licensed under the GPL v2. For licencing details see COPYING. */ -/** \file stdin.c functions that deal with reading from stdin */ +/** \file stdin.c Functions that deal with reading from stdin. */ #include /* readdir() */ #include @@ -19,10 +19,10 @@ #include "stdin.h" /** - * the pre_select function of the stdin task + * The pre_select function of the stdin task. * - * \param s the scheduler this task was registered to - * \param t the task structure of the stdin task + * \param s The scheduler this task was registered to. + * \param t The task structure of the stdin task. * * This function is always successful. If there is space left in the * buffer of the stdin task, it adds \p STDIN_FILENO to the read fd set @@ -41,15 +41,15 @@ static void stdin_pre_select(struct sched *s, struct task *t) 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); } /** - * the post select function of the stdin task + * The post select function of the stdin task. * - * \param s the scheduler this task was registered to - * \param t the task structure of the stdin task + * \param s The scheduler this task was registered to. + * \param t The task structure of the stdin task. * * This function checks if \p STDIN_FILENO was included by in the read fd set * of \a s during the previous pre_select call. If yes, and \p STDIN_FILENO @@ -90,6 +90,8 @@ static void stdin_post_select(struct sched *s, struct task *t) */ void stdin_set_defaults(struct stdin_task *sit) { + int ret; + sit->bufsize = 16 * 1024, sit->loaded = 0, sit->error = 0, @@ -97,6 +99,10 @@ void stdin_set_defaults(struct stdin_task *sit) sit->task.post_select = stdin_post_select; sit->task.event_handler = stdin_default_event_handler; sit->task.private_data = sit; - mark_fd_nonblocking(STDIN_FILENO); sprintf(sit->task.status, "stdin reader"); + ret = mark_fd_nonblocking(STDIN_FILENO); + if (ret >= 0) + return; + PARA_EMERG_LOG("%s\n", para_strerror(-ret)); + exit(EXIT_FAILURE); }