• Home
  • Raw
  • Download

Lines Matching refs:subbuf_size

566 			 size_t subbuf_size,  in relay_open()  argument
575 if (!(subbuf_size && n_subbufs)) in relay_open()
577 if (subbuf_size > UINT_MAX / n_subbufs) in relay_open()
592 chan->subbuf_size = subbuf_size; in relay_open()
593 chan->alloc_size = PAGE_ALIGN(subbuf_size * n_subbufs); in relay_open()
752 if (unlikely(length > buf->chan->subbuf_size)) in relay_switch_subbuf()
755 if (buf->offset != buf->chan->subbuf_size + 1) { in relay_switch_subbuf()
756 buf->prev_padding = buf->chan->subbuf_size - buf->offset; in relay_switch_subbuf()
762 buf->chan->subbuf_size - in relay_switch_subbuf()
765 buf->early_bytes += buf->chan->subbuf_size - in relay_switch_subbuf()
781 new = buf->start + new_subbuf * buf->chan->subbuf_size; in relay_switch_subbuf()
784 buf->offset = buf->chan->subbuf_size + 1; in relay_switch_subbuf()
790 if (unlikely(length + buf->offset > buf->chan->subbuf_size)) in relay_switch_subbuf()
859 chan->last_toobig, chan->subbuf_size); in relay_close()
970 size_t subbuf_size = buf->chan->subbuf_size; in relay_file_read_consume() local
978 if (buf->bytes_consumed + bytes_consumed > subbuf_size) { in relay_file_read_consume()
987 read_subbuf = read_pos / buf->chan->subbuf_size; in relay_file_read_consume()
988 if (buf->bytes_consumed + buf->padding[read_subbuf] == subbuf_size) { in relay_file_read_consume()
990 (buf->offset == subbuf_size)) in relay_file_read_consume()
1002 size_t subbuf_size = buf->chan->subbuf_size; in relay_file_read_avail() local
1011 if (unlikely(buf->offset > subbuf_size)) { in relay_file_read_avail()
1023 produced = (produced % n_subbufs) * subbuf_size + buf->offset; in relay_file_read_avail()
1024 consumed = (consumed % n_subbufs) * subbuf_size + buf->bytes_consumed; in relay_file_read_avail()
1027 produced += n_subbufs * subbuf_size; in relay_file_read_avail()
1030 if (buf->offset == subbuf_size && in relay_file_read_avail()
1049 size_t subbuf_size = buf->chan->subbuf_size; in relay_file_read_subbuf_avail() local
1051 write_subbuf = (buf->data - buf->start) / subbuf_size; in relay_file_read_subbuf_avail()
1052 write_offset = buf->offset > subbuf_size ? subbuf_size : buf->offset; in relay_file_read_subbuf_avail()
1053 read_subbuf = read_pos / subbuf_size; in relay_file_read_subbuf_avail()
1054 read_offset = read_pos % subbuf_size; in relay_file_read_subbuf_avail()
1061 avail = (subbuf_size - padding) - read_offset; in relay_file_read_subbuf_avail()
1077 size_t subbuf_size = buf->chan->subbuf_size; in relay_file_read_start_pos() local
1080 size_t read_pos = (consumed * subbuf_size + buf->bytes_consumed) in relay_file_read_start_pos()
1081 % (n_subbufs * subbuf_size); in relay_file_read_start_pos()
1083 read_subbuf = read_pos / subbuf_size; in relay_file_read_start_pos()
1085 padding_start = (read_subbuf + 1) * subbuf_size - padding; in relay_file_read_start_pos()
1086 padding_end = (read_subbuf + 1) * subbuf_size; in relay_file_read_start_pos()
1089 read_pos = read_subbuf * subbuf_size; in relay_file_read_start_pos()
1106 size_t subbuf_size = buf->chan->subbuf_size; in relay_file_read_end_pos() local
1109 read_subbuf = read_pos / subbuf_size; in relay_file_read_end_pos()
1111 if (read_pos % subbuf_size + count + padding == subbuf_size) in relay_file_read_end_pos()
1112 end_pos = (read_subbuf + 1) * subbuf_size; in relay_file_read_end_pos()
1115 if (end_pos >= subbuf_size * n_subbufs) in relay_file_read_end_pos()
1168 if (rbuf->bytes_consumed >= rbuf->chan->subbuf_size) { in relay_consume_bytes()
1170 rbuf->bytes_consumed %= rbuf->chan->subbuf_size; in relay_consume_bytes()
1205 unsigned int subbuf_size = rbuf->chan->subbuf_size; in subbuf_splice_actor() local
1209 size_t read_subbuf = read_start / subbuf_size; in subbuf_splice_actor()
1211 size_t nonpad_end = read_subbuf * subbuf_size + subbuf_size - padding; in subbuf_splice_actor()
1232 if (len > (subbuf_size - read_start % subbuf_size)) in subbuf_splice_actor()
1233 len = subbuf_size - read_start % subbuf_size; in subbuf_splice_actor()