Home
last modified time | relevance | path

Searched refs:error_handler (Results 1 – 25 of 34) sorted by relevance

12

/unit/src/
H A Dnxt_port_rpc.h17 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 Dnxt_conn_connect.c26 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 Dnxt_conn_read.c29 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 Dnxt_port_rpc.c23 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 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()
231 nxt_work_queue_add(c->write_work_queue, c->write_state->error_handler, in nxt_event_conn_job_sendfile_return()
H A Dnxt_h1proto.c252 .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 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()
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 Dnxt_http_proxy.c198 .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 Dnxt_fd_event.h112 nxt_work_handler_t error_handler; member
H A Dnxt_conn_proxy.c135 .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 Dnxt_http_error.c73 .error_handler = nxt_http_request_error_handler,
H A Dnxt_conn_write.c41 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 Dnxt_h1proto_websocket.c205 .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 Dnxt_http_websocket.c24 .error_handler = nxt_http_websocket_error_handler,
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()
386 handler = c->read_state->error_handler; in nxt_cyassl_conn_io_read()
H A Dnxt_conn_close.c59 c->socket.error_handler = nxt_conn_close_error_ignore; in nxt_conn_close()
H A Dnxt_epoll_engine.c659 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 Dnxt_http_return.c233 .error_handler = nxt_http_request_error_handler,
H A Dnxt_openssl.c1215 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 Dnxt_poll_engine.c368 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 Dnxt_pollset_engine.c471 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 Dnxt_devpoll_engine.c486 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 Dnxt_kqueue_engine.c544 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 Dnxt_conn.h18 nxt_work_handler_t error_handler; member
H A Dnxt_select_engine.c191 ev->error_handler(task, ev, data); in nxt_select_error_handler()

12