/unit/src/ |
H A D | nxt_port_rpc.h | 17 nxt_port_rpc_handler_t ready_handler, nxt_port_rpc_handler_t error_handler, 20 nxt_port_rpc_handler_t ready_handler, nxt_port_rpc_handler_t error_handler,
|
H A D | nxt_conn_connect.c | 26 handler = c->write_state->error_handler; in nxt_conn_sys_socket() 55 c->socket.error_handler = nxt_conn_connect_error; in nxt_conn_io_connect() 69 handler = state->error_handler; in nxt_conn_io_connect() 179 handler = state->error_handler; in nxt_conn_connect_error()
|
H A D | nxt_conn_read.c | 29 c->socket.error_handler = state->error_handler; in nxt_conn_wait() 64 c->socket.error_handler = state->error_handler; in nxt_conn_io_read() 95 handler = (n == 0) ? state->close_handler : state->error_handler; in nxt_conn_io_read()
|
H A D | nxt_port_rpc.c | 23 nxt_port_rpc_handler_t error_handler; member 93 nxt_port_rpc_handler_t ready_handler, nxt_port_rpc_handler_t error_handler, in nxt_port_rpc_register_handler() argument 100 error_handler, 0); in nxt_port_rpc_register_handler() 122 nxt_port_rpc_handler_t ready_handler, nxt_port_rpc_handler_t error_handler, in nxt_port_rpc_register_handler_ex() argument 144 reg->error_handler = error_handler; in nxt_port_rpc_register_handler_ex() 344 reg->error_handler(task, msg, reg->data); in nxt_port_rpc_handler() 433 reg->error_handler(task, &msg, reg->data); in nxt_port_rpc_remove_peer()
|
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() 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_h1proto.c | 252 .error_handler = nxt_h1p_conn_error, 387 .error_handler = nxt_h1p_conn_error, 1689 r->state->error_handler(task, r, h1p); in nxt_h1p_request_error() 1842 .error_handler = nxt_h1p_conn_error, 2086 .error_handler = nxt_h1p_conn_closing, 2220 .error_handler = nxt_h1p_peer_error, 2363 .error_handler = nxt_h1p_peer_error, 2375 .error_handler = nxt_h1p_peer_error, 2436 .error_handler = nxt_h1p_peer_error, 2447 .error_handler = nxt_h1p_peer_error, [all …]
|
H A D | nxt_gnutls.c | 332 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() 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() 621 handler = c->write_state->error_handler; in nxt_gnutls_conn_io_shutdown()
|
H A D | nxt_http_proxy.c | 198 .error_handler = nxt_http_proxy_error, 220 .error_handler = nxt_http_proxy_error, 242 .error_handler = nxt_http_proxy_error, 288 .error_handler = nxt_http_proxy_error,
|
H A D | nxt_fd_event.h | 112 nxt_work_handler_t error_handler; member
|
H A D | nxt_conn_proxy.c | 135 .error_handler = nxt_conn_proxy_error, 195 .error_handler = nxt_conn_proxy_error, 233 .error_handler = nxt_conn_proxy_error, 284 .error_handler = nxt_conn_proxy_error, 333 .error_handler = nxt_conn_proxy_read_error, 357 .error_handler = nxt_conn_proxy_read_error, 515 .error_handler = nxt_conn_proxy_write_error, 543 .error_handler = nxt_conn_proxy_write_error,
|
H A D | nxt_http_error.c | 73 .error_handler = nxt_http_request_error_handler,
|
H A D | nxt_conn_write.c | 41 c->socket.error_handler = c->write_state->error_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_h1proto_websocket.c | 205 .error_handler = nxt_h1p_conn_ws_error, 456 r->state->error_handler(task, r, h1p); in nxt_h1p_conn_ws_error() 532 .error_handler = nxt_h1p_conn_ws_error, 641 r->state->error_handler(task, r, r->proto.any); in nxt_h1p_conn_ws_error_sent()
|
H A D | nxt_http_websocket.c | 24 .error_handler = nxt_http_websocket_error_handler,
|
H A D | nxt_cyassl.c | 223 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() 386 handler = c->read_state->error_handler; in nxt_cyassl_conn_io_read()
|
H A D | nxt_conn_close.c | 59 c->socket.error_handler = nxt_conn_close_error_ignore; in nxt_conn_close()
|
H A D | nxt_epoll_engine.c | 659 ev->error_handler(ev->task, ev, data); in nxt_epoll_error_handler() 1078 c->socket.error_handler = nxt_conn_connect_error; in nxt_epoll_edge_conn_io_connect() 1107 c->socket.error_handler = state->error_handler; in nxt_epoll_edge_conn_io_connect() 1117 handler = state->error_handler; in nxt_epoll_edge_conn_io_connect()
|
H A D | nxt_http_return.c | 233 .error_handler = nxt_http_request_error_handler,
|
H A D | nxt_openssl.c | 1215 nxt_work_queue_add(c->read_work_queue, c->read_state->error_handler, 1320 handler = state->error_handler; 1513 c->socket.error_handler = c->write_state->error_handler; 1532 handler = c->write_state->error_handler;
|
H A D | nxt_poll_engine.c | 368 nxt_work_queue_add(&engine->fast_work_queue, ev->error_handler, in nxt_poll_commit_changes() 571 ev->error_handler, ev->task, ev, ev->data); in nxt_poll()
|
H A D | nxt_pollset_engine.c | 471 nxt_work_queue_add(&engine->fast_work_queue, ev->error_handler, in nxt_pollset_change_error() 610 nxt_work_queue_add(&engine->fast_work_queue, ev->error_handler, in nxt_pollset_poll()
|
H A D | nxt_devpoll_engine.c | 486 nxt_work_queue_add(&engine->fast_work_queue, ev->error_handler, in nxt_devpoll_change_error() 626 nxt_work_queue_add(&engine->fast_work_queue, ev->error_handler, in nxt_devpoll_poll()
|
H A D | nxt_kqueue_engine.c | 544 ev->error_handler(task, ev, data); in nxt_kqueue_fd_error_handler() 872 c->socket.error_handler = nxt_conn_connect_error; in nxt_kqueue_conn_io_connect() 885 handler = state->error_handler; in nxt_kqueue_conn_io_connect()
|
H A D | nxt_conn.h | 18 nxt_work_handler_t error_handler; member
|
H A D | nxt_select_engine.c | 191 ev->error_handler(task, ev, data); in nxt_select_error_handler()
|