248 	return (buf->subbufs_produced - buf->subbufs_consumed) ? 0 : 1;  in relay_buf_empty()
259 	size_t ready = buf->subbufs_produced - buf->subbufs_consumed;  in relay_buf_full()
363 	buf->subbufs_consumed = 0;  in __relay_reset()
790 			    size_t subbufs_consumed)  in relay_subbufs_consumed()  argument
798 					subbufs_consumed > chan->n_subbufs)  in relay_subbufs_consumed()
802 	if (subbufs_consumed > buf->subbufs_produced - buf->subbufs_consumed)  in relay_subbufs_consumed()
803 		buf->subbufs_consumed = buf->subbufs_produced;  in relay_subbufs_consumed()
805 		buf->subbufs_consumed += subbufs_consumed;  in relay_subbufs_consumed()
947 	if (buf->subbufs_produced == buf->subbufs_consumed &&  in relay_file_read_consume()
958 		read_subbuf = buf->subbufs_consumed % n_subbufs;  in relay_file_read_consume()
978 	size_t consumed = buf->subbufs_consumed;  in relay_file_read_avail()
982 	consumed = buf->subbufs_consumed;  in relay_file_read_avail()
992 		buf->subbufs_consumed = consumed;  in relay_file_read_avail()
1004 		    buf->subbufs_produced > buf->subbufs_consumed)  in relay_file_read_avail()
1054 	size_t consumed = buf->subbufs_consumed % n_subbufs;  in relay_file_read_start_pos()
1240 	if (rbuf->subbufs_produced == rbuf->subbufs_consumed)  in subbuf_splice_actor()