X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=write.c;h=a3cd4b5d640b5467ce762f8d4e2fb12450c0dc7a;hp=13b15a1d94034f95ae73fed94b3faba59fbf24eb;hb=899a19c03fc05f6fd98687e3eaa86841a4633a10;hpb=40cbbb95e256e63e1e6958e9034311d4904604af diff --git a/write.c b/write.c index 13b15a1d..a3cd4b5d 100644 --- a/write.c +++ b/write.c @@ -150,9 +150,8 @@ static struct writer_node_group *check_args(void) } ret = 1; out: - if (ret > 0) { + if (ret > 0) return wng; - } free(wng); return NULL; } @@ -165,8 +164,7 @@ static void idt_event_handler(struct task *t) unregister_task(t); wng->buf = sit.buf; wng->loaded = &sit.loaded; - wng->eof = &sit.eof; - sprintf(wng->task.status, "%s", "writer node group"); + wng->input_eof = &sit.eof; ret = wng_open(wng); if (ret < 0) { PARA_ERROR_LOG("%s\n", PARA_STRERROR(-ret));