36 int rs_tube_is_idle(
rs_job_t const *);
Description of input and output buffers.
rs_result rs_scoop_read_rest(rs_job_t *job, size_t *len, void **ptr)
Read whatever data remains in the input stream.
size_t rs_scoop_total_avail(rs_job_t *job)
Return the total number of bytes available including the scoop and input buffer.
void rs_scoop_input(rs_job_t *job, size_t len)
Try to accept a from the input buffer to get LEN bytes in the scoop.
void rs_buffers_check_exit(rs_buffers_t const *stream)
Assert input is empty or output is full.
void rs_tube_copy(rs_job_t *job, int len)
Queue up a request to copy through len bytes from the input to the output of the stream.
rs_result
Return codes from nonblocking rsync operations.
int rs_tube_catchup(rs_job_t *job)
Put whatever will fit from the tube into the output of the stream.
rs_result rs_scoop_read(rs_job_t *job, size_t len, void **ptr)
Read LEN bytes if possible, and remove them from the input scoop.
int rs_buffers_copy(rs_buffers_t *stream, int max_len)
Copy up to max_len bytes from input of stream to its output.
rs_result rs_scoop_readahead(rs_job_t *job, size_t len, void **ptr)
Read from scoop without advancing.
void rs_tube_write(rs_job_t *job, const void *buf, size_t len)
Push some data into the tube for storage.
void rs_scoop_advance(rs_job_t *job, size_t len)
Advance the input cursor forward len bytes.
of this structure are private.