X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=recv.c;h=3b1c6917bda57f9a5a810b713bb41261dd1ae045;hp=8639ce2b63c654fa36595adcd79a2b68fbfa79e4;hb=60216e4058f4ecc24467df577e51cb2bd66508b0;hpb=704605b466aca3ae6ca6d1e03b6af55e3d245502 diff --git a/recv.c b/recv.c index 8639ce2b..3b1c6917 100644 --- a/recv.c +++ b/recv.c @@ -25,7 +25,7 @@ #include "error.h" #include "stdout.h" -struct gengetopt_args_info conf; +struct recv_args_info conf; INIT_RECV_ERRLISTS; @@ -45,7 +45,7 @@ static void *parse_config(int argc, char *argv[], int *receiver_num) { int i; - if (cmdline_parser(argc, argv, &conf)) + if (recv_cmdline_parser(argc, argv, &conf)) return NULL; if (conf.list_receivers_given) { printf("available receivers: "); @@ -60,7 +60,9 @@ static void *parse_config(int argc, char *argv[], int *receiver_num) void rn_event_handler(struct task *t) { + struct receiver_node *rn = t->private_data; PARA_NOTICE_LOG("%s\n", PARA_STRERROR(-t->ret)); + rn->eof = 1; unregister_task(t); } @@ -72,7 +74,6 @@ int main(int argc, char *argv[]) struct stdout_task sot; struct sched s; - init_sched(); s.default_timeout.tv_sec = 1; s.default_timeout.tv_usec = 0;