X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=write.h;h=aece23133c14e9934c363fc7aeb5c83287080ba0;hp=5f8ab3ab142eff3cbd89189ede339fd4ef413b40;hb=2290d9be0703d3f83f38c2f100b1b41ec0790bb3;hpb=3e4e5c000805b8bebf431d6e0431940fa17886ad diff --git a/write.h b/write.h index 5f8ab3ab..aece2313 100644 --- a/write.h +++ b/write.h @@ -31,6 +31,8 @@ struct writer_node { 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 */ @@ -62,6 +64,8 @@ int (*open)(struct writer_node *); * */ 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 * @@ -91,6 +95,9 @@ int *written; 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 */