Home
last modified time | relevance | path

Searched refs:rb (Results 1 – 4 of 4) sorted by relevance

/unit/src/
H A Dnxt_recvbuf.c11 nxt_recvbuf_mem_coalesce(nxt_recvbuf_coalesce_t *rb) in nxt_recvbuf_mem_coalesce() argument
22 for (b = rb->buf; b != NULL; b = b->next) { in nxt_recvbuf_mem_coalesce()
30 if (++n >= rb->nmax) { in nxt_recvbuf_mem_coalesce()
34 nxt_iobuf_set(&rb->iobuf[n], b->mem.free, size); in nxt_recvbuf_mem_coalesce()
37 nxt_iobuf_add(&rb->iobuf[n], size); in nxt_recvbuf_mem_coalesce()
41 nxt_iobuf_data(&rb->iobuf[n]), in nxt_recvbuf_mem_coalesce()
42 nxt_iobuf_size(&rb->iobuf[n])); in nxt_recvbuf_mem_coalesce()
52 rb->size = total; in nxt_recvbuf_mem_coalesce()
H A Dnxt_conn_proxy.c380 nxt_buf_t *rb, *wb; in nxt_conn_proxy_read_process() local
392 rb = source->read; in nxt_conn_proxy_read_process()
394 if (rb->mem.pos != rb->mem.free) { in nxt_conn_proxy_read_process()
405 wb->mem.pos = rb->mem.pos; in nxt_conn_proxy_read_process()
410 rb->mem.pos = rb->mem.free; in nxt_conn_proxy_read_process()
411 rb->mem.start = rb->mem.free; in nxt_conn_proxy_read_process()
416 if (rb->mem.start != rb->mem.end) { in nxt_conn_proxy_read_process()
422 source->read = rb->next; in nxt_conn_proxy_read_process()
571 nxt_buf_t *rb, *wb; in nxt_conn_proxy_write_process() local
592 if (rb == NULL) { in nxt_conn_proxy_write_process()
[all …]
H A Dnxt_conn_read.c138 nxt_recvbuf_coalesce_t rb; in nxt_conn_io_recvbuf() local
140 rb.buf = b; in nxt_conn_io_recvbuf()
141 rb.iobuf = iov; in nxt_conn_io_recvbuf()
142 rb.nmax = NXT_IOBUF_MAX; in nxt_conn_io_recvbuf()
143 rb.size = 0; in nxt_conn_io_recvbuf()
145 niov = nxt_recvbuf_mem_coalesce(&rb); in nxt_conn_io_recvbuf()
160 if ((size_t) n < rb.size) { in nxt_conn_io_recvbuf()
H A Dnxt_recvbuf.h20 nxt_uint_t nxt_recvbuf_mem_coalesce(nxt_recvbuf_coalesce_t *rb);