Lines Matching refs:bytes_consumed
300 buf->bytes_consumed = 0; in __relay_reset()
883 size_t bytes_consumed) in relay_file_read_consume() argument
890 buf->offset == buf->bytes_consumed) in relay_file_read_consume()
893 if (buf->bytes_consumed + bytes_consumed > subbuf_size) { in relay_file_read_consume()
895 buf->bytes_consumed = 0; in relay_file_read_consume()
898 buf->bytes_consumed += bytes_consumed; in relay_file_read_consume()
903 if (buf->bytes_consumed + buf->padding[read_subbuf] == subbuf_size) { in relay_file_read_consume()
908 buf->bytes_consumed = 0; in relay_file_read_consume()
935 buf->bytes_consumed = 0; in relay_file_read_avail()
939 consumed = (consumed % n_subbufs) * subbuf_size + buf->bytes_consumed; in relay_file_read_avail()
995 size_t read_pos = consumed * subbuf_size + buf->bytes_consumed; in relay_file_read_start_pos()
1078 static void relay_consume_bytes(struct rchan_buf *rbuf, int bytes_consumed) in relay_consume_bytes() argument
1080 rbuf->bytes_consumed += bytes_consumed; in relay_consume_bytes()
1082 if (rbuf->bytes_consumed >= rbuf->chan->subbuf_size) { in relay_consume_bytes()
1084 rbuf->bytes_consumed %= rbuf->chan->subbuf_size; in relay_consume_bytes()