Lines Matching refs:read_queue
87 chunkqueue_reset(con->read_queue); in connection_close()
138 if (con->network_read(con, con->read_queue, MAX_READ_LIMIT) < 0) in connection_read_for_eos_ssl()
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()
1072 if (chunkqueue_is_empty(con->read_queue)) r->keep_alive = 0; in connection_revents_err()
1191 && (chunkqueue_is_empty(con->read_queue) || h2_parse_frames(con)) in connection_state_machine_h2()
1193 chunkqueue * const cq = con->read_queue; in connection_state_machine_h2()
1273 && !chunkqueue_is_empty(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()
1858 chunkqueue * const cq = &r->read_queue; in connection_handle_read_post_state()