Lines Matching refs:read_subbuf

964 	size_t read_subbuf;  in relay_file_read_consume()  local
977 read_subbuf = buf->subbufs_consumed % n_subbufs; in relay_file_read_consume()
979 read_subbuf = read_pos / buf->chan->subbuf_size; in relay_file_read_consume()
980 if (buf->bytes_consumed + buf->padding[read_subbuf] == subbuf_size) { in relay_file_read_consume()
981 if ((read_subbuf == buf->subbufs_produced % n_subbufs) && in relay_file_read_consume()
1040 size_t read_subbuf, read_offset, write_subbuf, write_offset; in relay_file_read_subbuf_avail() local
1045 read_subbuf = read_pos / subbuf_size; in relay_file_read_subbuf_avail()
1047 padding = buf->padding[read_subbuf]; in relay_file_read_subbuf_avail()
1049 if (read_subbuf == write_subbuf) { in relay_file_read_subbuf_avail()
1070 size_t read_subbuf, padding, padding_start, padding_end; in relay_file_read_start_pos() local
1077 read_subbuf = read_pos / subbuf_size; in relay_file_read_start_pos()
1078 padding = buf->padding[read_subbuf]; in relay_file_read_start_pos()
1079 padding_start = (read_subbuf + 1) * subbuf_size - padding; in relay_file_read_start_pos()
1080 padding_end = (read_subbuf + 1) * subbuf_size; in relay_file_read_start_pos()
1082 read_subbuf = (read_subbuf + 1) % n_subbufs; in relay_file_read_start_pos()
1083 read_pos = read_subbuf * subbuf_size; in relay_file_read_start_pos()
1099 size_t read_subbuf, padding, end_pos; in relay_file_read_end_pos() local
1103 read_subbuf = read_pos / subbuf_size; in relay_file_read_end_pos()
1104 padding = buf->padding[read_subbuf]; in relay_file_read_end_pos()
1106 end_pos = (read_subbuf + 1) * subbuf_size; in relay_file_read_end_pos()
1205 size_t read_subbuf = read_start / subbuf_size; in subbuf_splice_actor() local
1206 size_t padding = rbuf->padding[read_subbuf]; in subbuf_splice_actor()
1207 size_t nonpad_end = read_subbuf * subbuf_size + subbuf_size - padding; in subbuf_splice_actor()