min_written = PARA_MIN(min_written, t->ret);
}
*g->loaded -= min_written;
- if (!*g->loaded && *g->eof)
+ if (!*g->loaded && *g->input_eof)
t->ret = -E_WNG_EOF;
else
t->ret = 1;
wn->task.private_data = wn;
register_task(&wn->task);
}
+ sprintf(g->task.status, "%s", "writer node group");
+ g->eof = 0;
register_task(&g->task);
out:
return ret;