Searched refs:write_state (Results 1 – 13 of 13) sorted by relevance
/unit/src/ |
H A D | nxt_conn_connect.c | 26 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 D | nxt_event_conn_job_sendfile.c | 54 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 D | nxt_conn_write.c | 41 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 D | nxt_conn_close.c | 128 c->write_state->ready_handler, in nxt_conn_close_handler() 165 nxt_work_queue_add(&engine->fast_work_queue, c->write_state->ready_handler, in nxt_conn_close_timer_handler()
|
H A D | nxt_conn_proxy.c | 115 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 D | nxt_gnutls.c | 584 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 D | nxt_openssl.c | 1275 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 D | nxt_h1proto.c | 1380 c->write_state = &nxt_h1p_request_send_state; in nxt_h1p_request_header_send() 1485 c->write_state = &nxt_h1p_request_send_state; in nxt_h1p_request_send() 1938 c->write_state = &nxt_h1p_timeout_response_state; in nxt_h1p_idle_response() 2067 c->write_state = &nxt_h1p_shutdown_state; in nxt_h1p_closing() 2101 c->write_state = &nxt_h1p_close_state; in nxt_h1p_conn_closing() 2184 c->write_state = &nxt_h1p_peer_connect_state; in nxt_h1p_peer_connect() 2320 c->write_state = &nxt_h1p_peer_header_send_state; in nxt_h1p_peer_header_send() 2352 c->write_state = &nxt_h1p_peer_header_body_send_state; in nxt_h1p_peer_header_send() 2841 c->write_state = &nxt_h1p_peer_close_state; in nxt_h1p_peer_close()
|
H A D | nxt_cyassl.c | 471 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 D | nxt_kqueue_engine.c | 861 state = c->write_state; in nxt_kqueue_conn_io_connect() 904 if (c->write_state->timer_autoreset) { in nxt_kqueue_conn_connected() 908 nxt_work_queue_add(c->write_work_queue, c->write_state->ready_handler, in nxt_kqueue_conn_connected()
|
H A D | nxt_epoll_engine.c | 1067 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 D | nxt_conn.h | 131 const nxt_conn_state_t *write_state; member
|
H A D | nxt_controller.c | 1015 c->write_state = &nxt_controller_conn_close_state; in nxt_controller_conn_close() 2645 c->write_state = &nxt_controller_conn_write_state; in nxt_controller_response()
|