X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=recv.c;h=0875d17d0dd0ebba5141f7db53be474f89597924;hp=0fe46411df8348cb92b65d2f22902f36f03d133f;hb=c73d23911d78ed10179c12ef8f79a3fcf3bbcdaf;hpb=5c556c52f1196cea4536d36b683372de532943a9 diff --git a/recv.c b/recv.c index 0fe46411..0875d17d 100644 --- a/recv.c +++ b/recv.c @@ -48,8 +48,8 @@ static void *parse_config(int argc, char *argv[], int *receiver_num) static 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; + PARA_NOTICE_LOG("%s\n", para_strerror(-t->ret)); + rn->error = t->ret; unregister_task(t); } @@ -94,7 +94,7 @@ int main(int argc, char *argv[]) stdout_set_defaults(&sot); sot.buf = rn.buf; sot.loaded = &rn.loaded; - sot.input_eof = &rn.eof; + sot.input_error = &rn.error; register_task(&sot.task); rn.task.private_data = &rn; @@ -111,6 +111,6 @@ out: if (r) r->shutdown(); if (ret < 0) - PARA_ERROR_LOG("%s\n", PARA_STRERROR(-ret)); + PARA_ERROR_LOG("%s\n", para_strerror(-ret)); return ret < 0? EXIT_FAILURE : EXIT_SUCCESS; }