Lines Matching refs:wb
1099 chunkqueue_init(&hctx->wb); in handler_ctx_init()
1111 chunkqueue_reset(&hctx->wb); in handler_ctx_free()
1129 chunkqueue_reset(&hctx->wb); in handler_ctx_clear()
1861 if (!chunkqueue_is_empty(&hctx->wb))return; in gw_conditional_tcp_fin()
1879 if (chunkqueue_length(&hctx->wb) < 65536 - 16384) in gw_write_refill_wb()
1889 chunkqueue_steal(&hctx->wb, &r->reqbody_queue, in gw_write_refill_wb()
1891 else if (chunkqueue_is_empty(&hctx->wb)) in gw_write_refill_wb()
1892 chunkqueue_append_chunkqueue(&hctx->wb, &r->reqbody_queue); in gw_write_refill_wb()
1894 else if (qlen + chunkqueue_length(&hctx->wb) > 65536) { in gw_write_refill_wb()
1895 if (0 != chunkqueue_steal_with_tempfiles(&hctx->wb, in gw_write_refill_wb()
1900 chunkqueue_append_chunkqueue(&hctx->wb, &r->reqbody_queue); in gw_write_refill_wb()
2006 if (!chunkqueue_is_empty(&hctx->wb)) { in gw_write_request()
2012 hctx->fd, chunkqueue_length(&hctx->wb)); in gw_write_request()
2015 off_t bytes_out = hctx->wb.bytes_out; in gw_write_request()
2016 if (r->con->srv->network_backend_write(hctx->fd, &hctx->wb, in gw_write_request()
2030 (long long)hctx->wb.bytes_out, in gw_write_request()
2038 else if (hctx->wb.bytes_out > bytes_out) { in gw_write_request()
2045 if (hctx->wb.bytes_out == hctx->wb_reqlen) { in gw_write_request()
2049 off_t wblen = chunkqueue_length(&hctx->wb); in gw_write_request()
2050 if ((hctx->wb.bytes_in < hctx->wb_reqlen || hctx->wb_reqlen < 0) in gw_write_request()
2184 && (0 == hctx->wb.bytes_in in gw_handle_subrequest()
2186 : (hctx->wb.bytes_in < hctx->wb_reqlen || hctx->wb_reqlen < 0))) { in gw_handle_subrequest()
2191 if (chunkqueue_length(&hctx->wb) > 65536 - 4096 in gw_handle_subrequest()
2228 chunkqueue_append_chunkqueue(&hctx->wb, &r->reqbody_queue); in gw_handle_subrequest()
2231 if (0 != hctx->wb.bytes_in || -1 == hctx->wb_reqlen) { in gw_handle_subrequest()
2243 handler_t rc =((0==hctx->wb.bytes_in || !chunkqueue_is_empty(&hctx->wb)) in gw_handle_subrequest()
2379 if (hctx->wb.bytes_out == 0 && hctx->reconnects++ < 5) { in gw_recv_response_error()
2392 (long long)hctx->wb.bytes_out, proc->connection_name->ptr, in gw_recv_response_error()