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;
}
}
-static void wng_error_handler(struct task *t)
+static void wng_event_handler(struct task *t)
{
struct writer_node_group *g = t->private_data;
g->written = para_calloc(num_writers * sizeof(size_t));
g->task.private_data = g;
g->task.post_select = wng_post_select;
- g->task.error_handler = wng_error_handler;
+ g->task.event_handler = wng_event_handler;
g->task.flags = POST_ADD_TAIL;
return g;
}