232 	return (buf->subbufs_produced - buf->subbufs_consumed) ? 0 : 1;  in relay_buf_empty()
243 	size_t ready = buf->subbufs_produced - buf->subbufs_consumed;  in relay_buf_full()
296 	buf->subbufs_consumed = 0;  in __relay_reset()
728 			    size_t subbufs_consumed)  in relay_subbufs_consumed()  argument
736 	if (!buf || subbufs_consumed > chan->n_subbufs)  in relay_subbufs_consumed()
739 	if (subbufs_consumed > buf->subbufs_produced - buf->subbufs_consumed)  in relay_subbufs_consumed()
740 		buf->subbufs_consumed = buf->subbufs_produced;  in relay_subbufs_consumed()
742 		buf->subbufs_consumed += subbufs_consumed;  in relay_subbufs_consumed()
886 	if (buf->subbufs_produced == buf->subbufs_consumed &&  in relay_file_read_consume()
897 		read_subbuf = buf->subbufs_consumed % n_subbufs;  in relay_file_read_consume()
921 	consumed = buf->subbufs_consumed;  in relay_file_read_avail()
931 		buf->subbufs_consumed = consumed;  in relay_file_read_avail()
943 		    buf->subbufs_produced > buf->subbufs_consumed)  in relay_file_read_avail()
991 	size_t consumed = buf->subbufs_consumed % n_subbufs;  in relay_file_read_start_pos()