+/* write.c */
+static int read_stdin(char *buf, size_t bytes_to_load, size_t *loaded)
+{
+ ssize_t ret;
+
+ while (*loaded < bytes_to_load) {
+ ret = read(STDIN_FILENO, buf + *loaded, bytes_to_load - *loaded);
+ if (ret <= 0) {
+ if (ret < 0)
+ ret = -E_READ_STDIN;
+ return ret;
+ }
+ *loaded += ret;
+ }
+ return 1;
+}
+
+/* write_common.c */
+
+const char *writer_names[] ={WRITER_NAMES};
+static struct writer writers[NUM_SUPPORTED_WRITERS] = {WRITER_ARRAY};
+
+int wng_write(struct writer_node_group *g, char *buf, size_t *loaded)
+{
+ int ret, i, need_more_writes = 1;
+ size_t min_written = 0;
+
+ while (need_more_writes) {
+ need_more_writes = 0;
+ FOR_EACH_WRITER_NODE(i, g) {
+ size_t w = g->written[i];
+ unsigned char *p = buf + w;
+ int bytes_to_write;
+ struct writer_node *wn = &g->writer_nodes[i];
+ if (!i)
+ min_written = w;
+ else
+ min_written = PARA_MIN(min_written, w);
+ if (w == *loaded)
+ continue;
+ if (!g->eof && (*loaded < wn->chunk_bytes + w))
+ continue;
+ bytes_to_write = PARA_MIN(wn->chunk_bytes,
+ *loaded - w);
+ ret = wn->writer->write(p, bytes_to_write, wn);
+ if (ret < 0)
+ goto out;
+ if (ret != bytes_to_write)
+ PARA_WARNING_LOG("short write: %d/%d\n", ret,
+ bytes_to_write);
+ g->written[i] += ret;
+ need_more_writes = 1;
+ }
+ }
+ *loaded -= min_written;
+ ret = 0;
+ if (g->eof)
+ goto out;
+ if (*loaded)
+ memmove(buf, buf + min_written, *loaded);
+ FOR_EACH_WRITER_NODE(i, g)
+ g->written[i] -= min_written;
+ ret = 1;
+out:
+ return ret;
+}
+
+/* write_common.c */
+int wng_open(struct writer_node_group *g)
+{
+ int i, ret = 1;
+
+ FOR_EACH_WRITER_NODE(i, g) {
+ struct writer_node *wn = &g->writer_nodes[i];
+ ret = wn->writer->open(wn);
+ if (ret < 0)
+ goto out;
+ wn->chunk_bytes = ret;
+ g->max_chunk_bytes = PARA_MAX(g->max_chunk_bytes, ret);
+ }
+out:
+ return ret;
+}
+
+/* write_common.c */
+void wng_close(struct writer_node_group *g)
+{
+ int i;
+
+ FOR_EACH_WRITER_NODE(i, g) {
+ struct writer_node *wn = &g->writer_nodes[i];
+ wn->writer->close(wn);
+ }
+}
+
+/* write.c */