Lines Matching refs:subbufs_consumed
245 return (buf->subbufs_produced - buf->subbufs_consumed) ? 0 : 1; in relay_buf_empty()
256 size_t ready = buf->subbufs_produced - buf->subbufs_consumed; in relay_buf_full()
360 buf->subbufs_consumed = 0; in __relay_reset()
784 size_t subbufs_consumed) in relay_subbufs_consumed() argument
792 subbufs_consumed > chan->n_subbufs) in relay_subbufs_consumed()
796 if (subbufs_consumed > buf->subbufs_produced - buf->subbufs_consumed) in relay_subbufs_consumed()
797 buf->subbufs_consumed = buf->subbufs_produced; in relay_subbufs_consumed()
799 buf->subbufs_consumed += subbufs_consumed; in relay_subbufs_consumed()
941 if (buf->subbufs_produced == buf->subbufs_consumed && in relay_file_read_consume()
952 read_subbuf = buf->subbufs_consumed % n_subbufs; in relay_file_read_consume()
972 size_t consumed = buf->subbufs_consumed; in relay_file_read_avail()
976 consumed = buf->subbufs_consumed; in relay_file_read_avail()
986 buf->subbufs_consumed = consumed; in relay_file_read_avail()
998 buf->subbufs_produced > buf->subbufs_consumed) in relay_file_read_avail()
1048 size_t consumed = buf->subbufs_consumed % n_subbufs; in relay_file_read_start_pos()
1239 if (rbuf->subbufs_produced == rbuf->subbufs_consumed) in subbuf_splice_actor()