struct writer_node *wn = &g->writer_nodes[i];
t->ret = wn->writer->pre_select(s, wn);
if (t->ret < 0) {
struct writer_node *wn = &g->writer_nodes[i];
t->ret = wn->writer->pre_select(s, wn);
if (t->ret < 0) {
struct writer_node *wn = &g->writer_nodes[i];
t->ret = wn->writer->post_select(s, wn);
if (t->ret < 0) {
struct writer_node *wn = &g->writer_nodes[i];
t->ret = wn->writer->post_select(s, wn);
if (t->ret < 0) {
FOR_EACH_WRITER_NODE(i, g)
g->writer_nodes[i].written -= min_written;
}
FOR_EACH_WRITER_NODE(i, g)
g->writer_nodes[i].written -= min_written;
}
g->max_chunk_bytes = PARA_MAX(g->max_chunk_bytes, ret);
}
sprintf(g->task.status, "%s", "writer node group");
g->max_chunk_bytes = PARA_MAX(g->max_chunk_bytes, ret);
}
sprintf(g->task.status, "%s", "writer node group");