246 	return (buf->subbufs_produced - buf->subbufs_consumed) ? 0 : 1;  in relay_buf_empty()
257 	size_t ready = buf->subbufs_produced - buf->subbufs_consumed;  in relay_buf_full()
364 	buf->subbufs_consumed = 0;  in __relay_reset()
810 			    size_t subbufs_consumed)  in relay_subbufs_consumed()  argument
818 	if (!buf || subbufs_consumed > chan->n_subbufs)  in relay_subbufs_consumed()
821 	if (subbufs_consumed > buf->subbufs_produced - buf->subbufs_consumed)  in relay_subbufs_consumed()
822 		buf->subbufs_consumed = buf->subbufs_produced;  in relay_subbufs_consumed()
824 		buf->subbufs_consumed += subbufs_consumed;  in relay_subbufs_consumed()
968 	if (buf->subbufs_produced == buf->subbufs_consumed &&  in relay_file_read_consume()
979 		read_subbuf = buf->subbufs_consumed % n_subbufs;  in relay_file_read_consume()
999 	size_t consumed = buf->subbufs_consumed;  in relay_file_read_avail()
1003 	consumed = buf->subbufs_consumed;  in relay_file_read_avail()
1013 		buf->subbufs_consumed = consumed;  in relay_file_read_avail()
1025 		    buf->subbufs_produced > buf->subbufs_consumed)  in relay_file_read_avail()
1075 	size_t consumed = buf->subbufs_consumed % n_subbufs;  in relay_file_read_start_pos()
1221 	if (rbuf->subbufs_produced == rbuf->subbufs_consumed)  in subbuf_splice_actor()