Searched refs:read_queue (Results 1 – 10 of 10) sorted by relevance
87 chunkqueue_reset(con->read_queue); in connection_close()140 chunkqueue_reset(con->read_queue); in connection_read_for_eos_ssl()208 r->bytes_read_ckpt = r->read_queue.bytes_in; in connection_handle_response_end_state()510 con->read_queue = &r->read_queue; in connection_init()525 if (con->read_queue != &r->read_queue) in connection_free()526 chunkqueue_free(con->read_queue); in connection_free()641 chunkqueue * const cq = con->read_queue; in connection_handle_read_state()1193 chunkqueue * const cq = con->read_queue; in connection_state_machine_h2()1561 && chunkqueue_is_empty(con->read_queue)) { in connection_graceful_shutdown_maint()1839 || !chunkqueue_is_empty(&r->read_queue) in connection_check_expect_100()[all …]
49 chunkqueue_init(&r->read_queue); in request_init_data()209 chunkqueue_reset(&r->read_queue); in request_free_data()277 chunkqueue_reset(&r->read_queue); in request_release()
197 struct chunkqueue read_queue; /* HTTP request queue [ mem ] */ member253 ((r)->read_queue.bytes_out - (r)->bytes_read_ckpt)
37 chunkqueue *read_queue; /* a small queue for low-level read ( HTTP request ) [ mem ] */ member
1029 chunkqueue * const cq = con->read_queue; in h2_recv_data()1100 chunkqueue * const rq = &r->read_queue; in h2_recv_data()1487 chunkqueue * const rq = &r->read_queue; in h2_parse_headers_frame()1711 chunkqueue * const cq = con->read_queue; in h2_parse_frames()1855 chunkqueue * const cq = con->read_queue; in h2_want_read()1896 chunkqueue * const cq = con->read_queue; in h2_recv_client_connection_preface()2833 con->read_queue->bytes_in -= r->read_queue.bytes_in; in h2_release_stream()
188 size_t rsz = (size_t)(r->read_queue.bytes_out - hctx->wb.bytes_in); in scgi_create_env()
245 size_t rsz = (size_t)(r->read_queue.bytes_out - hctx->wb.bytes_in); in fcgi_create_env()
839 size_t rsz = (size_t)(r->read_queue.bytes_out - hctx->gw.wb.bytes_in); in proxy_create_env()
353 chunkqueue_append_chunkqueue(&r->reqbody_queue, &r->read_queue); in wstunnel_create_env()
524 if (chunkqueue_is_empty(con->read_queue)) r->keep_alive = 0; in server_oneshot_handle_fdevent()