X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=stdin.c;h=fd803ae5441acf01446dadab89c35d3bec14cecd;hp=14dd9d40f4d56e2cb5845fa95546db7a7baa8581;hb=f652ce6afe7f6fd0e42814505234cbf4321a736e;hpb=32e646780461f96682d1191d31e08e4602ab125e diff --git a/stdin.c b/stdin.c index 14dd9d40..fd803ae5 100644 --- a/stdin.c +++ b/stdin.c @@ -1,5 +1,5 @@ /* - * Copyright (C) 2006-2011 Andre Noll + * Copyright (C) 2006-2013 Andre Noll * * Licensed under the GPL v2. For licencing details see COPYING. */ @@ -7,7 +7,6 @@ /** \file stdin.c Functions that deal with reading from stdin. */ #include -#include #include #include "para.h" @@ -84,7 +83,7 @@ static void stdin_post_select(struct sched *s, struct task *t) if (ret >= 0) return; err: - btr_remove_node(sit->btrn); + btr_remove_node(&sit->btrn); //btr_pool_free(sit->btrp); t->error = ret; } @@ -104,7 +103,7 @@ void stdin_set_defaults(struct stdin_task *sit) sit->task.pre_select = stdin_pre_select; sit->task.post_select = stdin_post_select; - sit->btrp = btr_pool_new("stdin", 64 * 1024); + sit->btrp = btr_pool_new("stdin", 128 * 1024); sprintf(sit->task.status, "stdin reader"); ret = mark_fd_nonblocking(STDIN_FILENO); if (ret >= 0)