Lines Matching refs:wb
380 nxt_buf_t *rb, *wb; in nxt_conn_proxy_read_process() local
398 wb = nxt_buf_mem_alloc(source->mem_pool, 0, 0); in nxt_conn_proxy_read_process()
399 if (wb == NULL) { in nxt_conn_proxy_read_process()
405 wb->mem.pos = rb->mem.pos; in nxt_conn_proxy_read_process()
406 wb->mem.free = rb->mem.free; in nxt_conn_proxy_read_process()
407 wb->mem.start = rb->mem.pos; in nxt_conn_proxy_read_process()
408 wb->mem.end = rb->mem.free; in nxt_conn_proxy_read_process()
413 nxt_conn_proxy_write_add(sink, wb); in nxt_conn_proxy_read_process()
571 nxt_buf_t *rb, *wb; in nxt_conn_proxy_write_process() local
575 wb = sink->write; in nxt_conn_proxy_write_process()
577 if (nxt_buf_is_sync(wb)) { in nxt_conn_proxy_write_process()
582 nxt_buf_free(sink->mem_pool, wb); in nxt_conn_proxy_write_process()
587 if (wb->mem.start != wb->mem.pos) { in nxt_conn_proxy_write_process()
598 rb->mem.pos = wb->mem.start; in nxt_conn_proxy_write_process()
599 rb->mem.free = wb->mem.start; in nxt_conn_proxy_write_process()
600 rb->mem.start = wb->mem.start; in nxt_conn_proxy_write_process()
601 rb->mem.end = wb->mem.pos; in nxt_conn_proxy_write_process()
603 wb->mem.start = wb->mem.pos; in nxt_conn_proxy_write_process()
608 if (wb->mem.pos != wb->mem.free) { in nxt_conn_proxy_write_process()
614 sink->write = wb->next; in nxt_conn_proxy_write_process()
615 nxt_buf_free(sink->mem_pool, wb); in nxt_conn_proxy_write_process()