}
ret = 1;
out:
- if (ret > 0) {
+ if (ret > 0)
return wng;
- }
free(wng);
return NULL;
}
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));