Home
last modified time | relevance | path

Searched refs:read_state (Results 1 – 11 of 11) sorted by last modified time

/unit/src/
H A Dnxt_h1proto.c233 c->read_state = &nxt_h1p_idle_state; in nxt_http_conn_init()
237 c->read_state = &nxt_http_idle_state; in nxt_http_conn_init()
277 c->read_state = &nxt_h1p_idle_close_state; in nxt_http_idle_io_read_handler()
326 c->read_state = &nxt_h1p_idle_state; in nxt_http_conn_test()
413 c->read_state = &nxt_h1p_idle_close_state; in nxt_h1p_idle_io_read_handler()
611 c->read_state = &nxt_h1p_header_parse_state; in nxt_h1p_conn_request_header_parse()
983 c->read_state = &nxt_h1p_read_body_state; in nxt_h1p_request_body_read()
1818 c->read_state = &nxt_h1p_keepalive_state; in nxt_h1p_keepalive()
2421 c->read_state = &nxt_h1p_peer_header_read_state; in nxt_h1p_peer_header_read()
2424 c->read_state = &nxt_h1p_peer_header_read_timer_state; in nxt_h1p_peer_header_read()
[all …]
H A Dnxt_controller.c749 c->read_state = &nxt_controller_conn_read_state; in nxt_controller_conn_init()
845 c->read_state = &nxt_controller_conn_body_read_state; in nxt_controller_conn_read()
H A Dnxt_kqueue_engine.c986 nxt_work_queue_add(c->read_work_queue, c->read_state->close_handler, in nxt_kqueue_conn_io_read()
H A Dnxt_openssl.c1215 nxt_work_queue_add(c->read_work_queue, c->read_state->error_handler,
1275 state = (c->read_state != NULL) ? c->read_state : c->write_state;
1281 if (c->read_state != NULL) {
1325 wq = (c->read_state != NULL) ? c->read_work_queue : c->write_work_queue;
1438 c->read_state = NULL;
H A Dnxt_conn.h126 const nxt_conn_state_t *read_state; member
H A Dnxt_conn_accept.c304 c->read_state->close_handler(c->socket.task, c, c->socket.data); in nxt_conn_accept_close_idle_handler()
H A Dnxt_gnutls.c332 c->read_state->error_handler, c, c->socket.data); in nxt_gnutls_conn_init()
457 c->read_state->error_handler, c, data); in nxt_gnutls_conn_handshake()
482 handler = c->read_state->ready_handler; in nxt_gnutls_conn_io_read()
499 handler = c->read_state->ready_handler; in nxt_gnutls_conn_io_read()
502 handler = c->read_state->close_handler; in nxt_gnutls_conn_io_read()
517 handler = c->read_state->error_handler; in nxt_gnutls_conn_io_read()
613 c->socket.error_handler = c->read_state->error_handler; in nxt_gnutls_conn_io_shutdown()
H A Dnxt_h1proto_websocket.c139 c->read_state = &nxt_h1p_read_ws_frame_header_state; in nxt_h1p_websocket_frame_start()
330 c->read_state = &nxt_h1p_read_ws_frame_payload_state; in nxt_h1p_conn_ws_frame_header_read()
H A Dnxt_conn_proxy.c124 p->client->read_state = &nxt_conn_proxy_client_wait_state; in nxt_conn_proxy()
173 client->read_state = &nxt_conn_proxy_client_read_state; in nxt_conn_proxy_client_buffer_alloc()
183 client->read_state = &nxt_conn_proxy_client_first_read_state; in nxt_conn_proxy_client_buffer_alloc()
220 client->read_state = &nxt_conn_proxy_client_read_state; in nxt_conn_proxy_peer_connect()
260 peer->read_state = &nxt_conn_proxy_peer_wait_state; in nxt_conn_proxy_connected()
268 client->read_state = &nxt_conn_proxy_client_read_state; in nxt_conn_proxy_connected()
315 peer->read_state = &nxt_conn_proxy_peer_read_state; in nxt_conn_proxy_peer_read()
H A Dnxt_conn_read.c20 state = c->read_state; in nxt_conn_wait()
63 state = c->read_state; in nxt_conn_io_read()
74 state = c->read_state; in nxt_conn_io_read()
H A Dnxt_cyassl.c223 c->read_state->error_handler, c, c->socket.data); in nxt_cyassl_conn_init()
330 c->read_state->error_handler, c, data); in nxt_cyassl_conn_handshake()
353 handler = c->read_state->ready_handler; in nxt_cyassl_conn_io_read()
372 handler = c->read_state->ready_handler; in nxt_cyassl_conn_io_read()
386 handler = c->read_state->error_handler; in nxt_cyassl_conn_io_read()
516 if (c->read_state != NULL) { in nxt_cyassl_conn_test_error()
518 handler = c->read_state->close_handler; in nxt_cyassl_conn_test_error()