void *private_data;
/** send that many bytes in one go */
int chunk_bytes;
+ struct task task;
+ struct writer_node_group *wng;
};
/** describes one supported writer */
*
*/
int (*write)(char *data, size_t nbytes, struct writer_node *);
+void (*pre_select)(struct sched *s, struct task *t);
+void (*post_select)(struct sched *s, struct task *t);
/**
* close one instance of the writer
*
size_t max_chunk_bytes;
/** non-zero if end of file was encountered */
int eof;
+char *buf;
+size_t *loaded;
+struct task task;
};
/** loop over each writer node in a writer group */