Home
last modified time | relevance | path

Searched refs:write_state (Results 1 – 14 of 14) sorted by relevance

/unit/src/
H A Dnxt_conn_connect.c26 handler = c->write_state->error_handler; in nxt_conn_sys_socket()
44 state = c->write_state; in nxt_conn_io_connect()
133 if (c->write_state->timer_autoreset) { in nxt_conn_connect_test()
140 nxt_work_queue_add(c->write_work_queue, c->write_state->ready_handler, in nxt_conn_connect_test()
163 state = c->write_state; in nxt_conn_connect_error()
H A Dnxt_event_conn_job_sendfile.c54 c->write_state->error_handler(task, c, NULL); in nxt_event_conn_job_sendfile_start()
59 c->socket.error_handler = c->write_state->error_handler; in nxt_event_conn_job_sendfile_start()
208 if (sent != 0 && c->write_state->timer_autoreset) { in nxt_event_conn_job_sendfile_return()
215 nxt_conn_timer(task->thread->engine, c, c->write_state, in nxt_event_conn_job_sendfile_return()
222 nxt_work_queue_add(c->write_work_queue, c->write_state->ready_handler, in nxt_event_conn_job_sendfile_return()
231 nxt_work_queue_add(c->write_work_queue, c->write_state->error_handler, in nxt_event_conn_job_sendfile_return()
H A Dnxt_conn_close.c124 c->write_state->ready_handler, in nxt_conn_close_handler()
155 c->write_state->ready_handler, in nxt_conn_close_timer_handler()
H A Dnxt_conn_write.c41 c->socket.error_handler = c->write_state->error_handler; in nxt_conn_io_write()
90 if (c->write_state->timer_autoreset) { in nxt_conn_io_write()
113 nxt_conn_timer(engine, c, c->write_state, &c->write_timer); in nxt_conn_io_write()
128 nxt_work_queue_add(c->write_work_queue, c->write_state->ready_handler, in nxt_conn_io_write()
141 nxt_work_queue_add(c->write_work_queue, c->write_state->error_handler, in nxt_conn_io_write()
H A Dnxt_conn_proxy.c115 peer->write_state = &nxt_conn_proxy_peer_connect_state; in nxt_conn_proxy()
222 p->peer->write_state = &nxt_conn_proxy_peer_connect_state; in nxt_conn_proxy_peer_connect()
261 peer->write_state = &nxt_conn_proxy_peer_write_state; in nxt_conn_proxy_connected()
269 client->write_state = &nxt_conn_proxy_client_write_state; in nxt_conn_proxy_connected()
314 p->client->write_state = &nxt_conn_proxy_client_write_state; in nxt_conn_proxy_peer_read()
316 peer->write_state = &nxt_conn_proxy_peer_write_state; in nxt_conn_proxy_peer_read()
841 peer->write_state = &nxt_conn_proxy_peer_connect_state; in nxt_conn_proxy_reconnect_handler()
957 p->client->write_state = &nxt_conn_proxy_close_state; in nxt_conn_proxy_complete()
963 p->peer->write_state = &nxt_conn_proxy_close_state; in nxt_conn_proxy_complete()
H A Dnxt_stream_source.c64 c->write_state = &nxt_stream_source_connect_state; in nxt_stream_source_connect()
104 c->write_state = &nxt_stream_source_request_write_state; in nxt_stream_source_connected()
H A Dnxt_gnutls.c584 handler = c->write_state->close_handler; in nxt_gnutls_conn_io_shutdown()
606 handler = c->write_state->close_handler; in nxt_gnutls_conn_io_shutdown()
621 handler = c->write_state->error_handler; in nxt_gnutls_conn_io_shutdown()
H A Dnxt_openssl.c1275 state = (c->read_state != NULL) ? c->read_state : c->write_state;
1448 handler = c->write_state->ready_handler;
1484 handler = c->write_state->ready_handler;
1513 c->socket.error_handler = c->write_state->error_handler;
1520 handler = c->write_state->close_handler;
1532 handler = c->write_state->error_handler;
H A Dnxt_h1proto.c1370 c->write_state = &nxt_h1p_request_send_state; in nxt_h1p_request_header_send()
1475 c->write_state = &nxt_h1p_request_send_state; in nxt_h1p_request_send()
1927 c->write_state = &nxt_h1p_timeout_response_state; in nxt_h1p_idle_response()
2056 c->write_state = &nxt_h1p_shutdown_state; in nxt_h1p_closing()
2090 c->write_state = &nxt_h1p_close_state; in nxt_h1p_conn_closing()
2173 c->write_state = &nxt_h1p_peer_connect_state; in nxt_h1p_peer_connect()
2309 c->write_state = &nxt_h1p_peer_header_send_state; in nxt_h1p_peer_header_send()
2341 c->write_state = &nxt_h1p_peer_header_body_send_state; in nxt_h1p_peer_header_send()
2830 c->write_state = &nxt_h1p_peer_close_state; in nxt_h1p_peer_close()
H A Dnxt_cyassl.c471 c->write_state->close_handler, c, data); in nxt_cyassl_conn_io_shutdown()
522 handler = c->write_state->close_handler; in nxt_cyassl_conn_test_error()
H A Dnxt_kqueue_engine.c860 state = c->write_state; in nxt_kqueue_conn_io_connect()
903 if (c->write_state->timer_autoreset) { in nxt_kqueue_conn_connected()
907 nxt_work_queue_add(c->write_work_queue, c->write_state->ready_handler, in nxt_kqueue_conn_connected()
H A Dnxt_conn.h131 const nxt_conn_state_t *write_state; member
H A Dnxt_epoll_engine.c1067 state = c->write_state; in nxt_epoll_edge_conn_io_connect()
1141 if (c->write_state->timer_autoreset) { in nxt_epoll_edge_conn_connected()
1145 nxt_work_queue_add(c->write_work_queue, c->write_state->ready_handler, in nxt_epoll_edge_conn_connected()
H A Dnxt_controller.c974 c->write_state = &nxt_controller_conn_close_state; in nxt_controller_conn_close()
2122 c->write_state = &nxt_controller_conn_write_state; in nxt_controller_response()