*
* This function should perform any work necessary to write the incoming
* stream. If To this aim, it may allocate its private data structure and store
*
* This function should perform any work necessary to write the incoming
* stream. If To this aim, it may allocate its private data structure and store
int (*pre_select)(struct sched *s, struct writer_node *wn);
/**
* Called from the post_select function of the wng task. It must keep
int (*pre_select)(struct sched *s, struct writer_node *wn);
/**
* Called from the post_select function of the wng task. It must keep
* the wn->written variable (which may be modified by the wng handling
* functions). This function must return positive on success and
* negative on errors.
* the wn->written variable (which may be modified by the wng handling
* functions). This function must return positive on success and
* negative on errors.
struct writer_node *writer_nodes;
/** the maximum of the chunk_bytes values of the writer nodes in this group */
size_t max_chunk_bytes;
struct writer_node *writer_nodes;
/** the maximum of the chunk_bytes values of the writer nodes in this group */
size_t max_chunk_bytes;
- /** non-zero if end of file was encountered by the feeding task */
- int *input_eof;
- /** non-zero if end of file was encountered */
- int eof;
+ /** Non-zero if an error or end of file was encountered by the feeding task. */
+ int *input_error;
+ /** Non-zero if an error occurred or end of file was encountered. */
+ int error;