Lines Matching refs:ring_buf
20 struct ring_buf ring_buf; member
68 ring_buf_init(&qss->ring_buf); in ossl_quic_sstream_new()
69 if (!ring_buf_resize(&qss->ring_buf, init_buf_size, 0)) { in ossl_quic_sstream_new()
70 ring_buf_destroy(&qss->ring_buf, 0); in ossl_quic_sstream_new()
87 ring_buf_destroy(&qss->ring_buf, qss->cleanse); in ossl_quic_sstream_free()
117 hdr->offset = qss->ring_buf.head_offset; in ossl_quic_sstream_get_stream_frame()
137 if (!ring_buf_get_buf_at(&qss->ring_buf, in ossl_quic_sstream_get_stream_frame()
160 && hdr->offset + hdr->len == qss->ring_buf.head_offset; in ossl_quic_sstream_get_stream_frame()
177 return qss->ring_buf.head_offset; in ossl_quic_sstream_get_cur_size()
202 if (!qss->have_final_size || final_size != qss->ring_buf.head_offset) in ossl_quic_sstream_mark_transmitted_fin()
277 *final_size = qss->ring_buf.head_offset; in ossl_quic_sstream_get_final_size()
289 struct ring_buf old_ring_buf = qss->ring_buf; in ossl_quic_sstream_append()
308 l = ring_buf_push(&qss->ring_buf, buf, buf_len); in ossl_quic_sstream_append()
320 assert(r.end + 1 == qss->ring_buf.head_offset); in ossl_quic_sstream_append()
322 qss->ring_buf = old_ring_buf; in ossl_quic_sstream_append()
353 ring_buf_cpop_range(&qss->ring_buf, h->range.start, h->range.end, in qss_cull()
359 return ring_buf_resize(&qss->ring_buf, num_bytes, qss->cleanse); in ossl_quic_sstream_set_buffer_size()
364 return qss->ring_buf.alloc; in ossl_quic_sstream_get_buffer_size()
369 return ring_buf_used(&qss->ring_buf); in ossl_quic_sstream_get_buffer_used()
374 return ring_buf_avail(&qss->ring_buf); in ossl_quic_sstream_get_buffer_avail()
392 cur_size = qss->ring_buf.head_offset; in ossl_quic_sstream_is_totally_acked()
