247 	return (buf->subbufs_produced - buf->subbufs_consumed) ? 0 : 1;  in relay_buf_empty()
258 	size_t ready = buf->subbufs_produced - buf->subbufs_consumed;  in relay_buf_full()
365 	buf->subbufs_consumed = 0;  in __relay_reset()
816 			    size_t subbufs_consumed)  in relay_subbufs_consumed()  argument
824 	if (!buf || subbufs_consumed > chan->n_subbufs)  in relay_subbufs_consumed()
827 	if (subbufs_consumed > buf->subbufs_produced - buf->subbufs_consumed)  in relay_subbufs_consumed()
828 		buf->subbufs_consumed = buf->subbufs_produced;  in relay_subbufs_consumed()
830 		buf->subbufs_consumed += subbufs_consumed;  in relay_subbufs_consumed()
974 	if (buf->subbufs_produced == buf->subbufs_consumed &&  in relay_file_read_consume()
985 		read_subbuf = buf->subbufs_consumed % n_subbufs;  in relay_file_read_consume()
1009 	consumed = buf->subbufs_consumed;  in relay_file_read_avail()
1019 		buf->subbufs_consumed = consumed;  in relay_file_read_avail()
1031 		    buf->subbufs_produced > buf->subbufs_consumed)  in relay_file_read_avail()
1079 	size_t consumed = buf->subbufs_consumed % n_subbufs;  in relay_file_read_start_pos()
1224 	if (rbuf->subbufs_produced == rbuf->subbufs_consumed)  in subbuf_splice_actor()