Home
last modified time | relevance | path

Searched refs:ready_handler (Results 1 – 25 of 29) 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_event_conn_job_sendfile.c15 nxt_work_handler_t ready_handler; member
81 jbs->ready_handler = nxt_event_conn_job_sendfile_return; in nxt_event_conn_job_sendfile_start()
150 nxt_job_return(task, &jbs->job, jbs->ready_handler); in nxt_event_conn_job_sendfile_handler()
222 nxt_work_queue_add(c->write_work_queue, c->write_state->ready_handler, in nxt_event_conn_job_sendfile_return()
H A Dnxt_port_rpc.c22 nxt_port_rpc_handler_t ready_handler; member
93 nxt_port_rpc_handler_t ready_handler, nxt_port_rpc_handler_t error_handler, in nxt_port_rpc_register_handler() argument
99 ex = nxt_port_rpc_register_handler_ex(task, port, ready_handler, 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
143 reg->ready_handler = ready_handler; in nxt_port_rpc_register_handler_ex()
347 reg->ready_handler(task, msg, reg->data); in nxt_port_rpc_handler()
H A Dnxt_conn_read.c23 nxt_work_queue_add(&engine->fast_work_queue, state->ready_handler, in nxt_conn_wait()
28 c->socket.read_handler = state->ready_handler; in nxt_conn_wait()
89 state->ready_handler, task, c, data); in nxt_conn_io_read()
H A Dnxt_conn_close.c128 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 Dnxt_conn_proxy.c133 .ready_handler = nxt_conn_proxy_client_buffer_alloc,
193 .ready_handler = nxt_conn_proxy_peer_connect,
231 .ready_handler = nxt_conn_proxy_connected,
282 .ready_handler = nxt_conn_proxy_peer_read,
331 .ready_handler = nxt_conn_proxy_client_read_ready,
355 .ready_handler = nxt_conn_proxy_peer_read_ready,
514 .ready_handler = nxt_conn_proxy_client_write_ready,
542 .ready_handler = nxt_conn_proxy_peer_write_ready,
936 .ready_handler = nxt_conn_proxy_completion,
H A Dnxt_conn_connect.c50 handler = state->ready_handler; in nxt_conn_io_connect()
140 nxt_work_queue_add(c->write_work_queue, c->write_state->ready_handler, in nxt_conn_connect_test()
H A Dnxt_http_proxy.c197 .ready_handler = nxt_http_proxy_header_send,
219 .ready_handler = nxt_http_proxy_header_sent,
241 .ready_handler = nxt_http_proxy_header_read,
287 .ready_handler = nxt_http_proxy_send_body,
H A Dnxt_h1proto.c250 .ready_handler = nxt_http_conn_test,
385 .ready_handler = nxt_h1p_conn_proto_init,
998 r->state->ready_handler(task, r, NULL); in nxt_h1p_request_body_read()
1454 .ready_handler = nxt_h1p_conn_sent,
1952 .ready_handler = nxt_h1p_conn_sent,
2084 .ready_handler = nxt_h1p_conn_closing,
2110 .ready_handler = nxt_h1p_conn_free,
2239 r->state->ready_handler(task, r, peer); in nxt_h1p_peer_connected()
2407 r->state->ready_handler(task, r, peer); in nxt_h1p_peer_header_sent()
2718 r->state->ready_handler(task, r, peer); in nxt_h1p_peer_body_process()
[all …]
H A Dnxt_http_websocket.c23 .ready_handler = nxt_http_websocket_client,
H A Dnxt_h1proto_websocket.c203 .ready_handler = nxt_h1p_conn_ws_frame_header_read,
437 r->state->ready_handler(task, r, NULL); in nxt_h1p_conn_ws_frame_process()
530 .ready_handler = nxt_h1p_conn_ws_frame_payload_read,
H A Dnxt_unit.h160 int (*ready_handler)(nxt_unit_ctx_t *); member
H A Dnxt_cyassl.c353 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()
H A Dnxt_gnutls.c482 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()
H A Dnxt_conn.h16 nxt_work_handler_t ready_handler; member
H A Dnxt_epoll_engine.c1073 handler = state->ready_handler; in nxt_epoll_edge_conn_io_connect()
1112 handler = state->ready_handler; in nxt_epoll_edge_conn_io_connect()
1145 nxt_work_queue_add(c->write_work_queue, c->write_state->ready_handler, in nxt_epoll_edge_conn_connected()
H A Dnxt_openssl.c1294 handler = state->ready_handler;
1448 handler = c->write_state->ready_handler;
1484 handler = c->write_state->ready_handler;
H A Dnxt_http.h71 nxt_work_handler_t ready_handler; member
H A Dnxt_conn_write.c128 nxt_work_queue_add(c->write_work_queue, c->write_state->ready_handler, in nxt_conn_io_write()
H A Dnxt_kqueue_engine.c867 handler = state->ready_handler; in nxt_kqueue_conn_io_connect()
908 nxt_work_queue_add(c->write_work_queue, c->write_state->ready_handler, in nxt_kqueue_conn_connected()
H A Dnxt_http_request.c300 .ready_handler = nxt_http_request_start,
536 .ready_handler = nxt_http_request_ready,
H A Dnxt_controller.c763 .ready_handler = nxt_controller_conn_read,
893 .ready_handler = nxt_controller_conn_body_read,
933 .ready_handler = nxt_controller_conn_write,
1000 .ready_handler = nxt_controller_conn_free,
H A Dnxt_java.c436 java_init.callbacks.ready_handler = nxt_java_ready_handler; in nxt_java_start()
/unit/src/test/
H A Dnxt_unit_app_test.c34 static int ready_handler(nxt_unit_ctx_t *ctx);
58 init.callbacks.ready_handler = ready_handler; in main()
94 ready_handler(nxt_unit_ctx_t *ctx) in ready_handler() function
/unit/go/
H A Dnxt_cgo_lib.c33 init.callbacks.ready_handler = nxt_go_ready; in nxt_cgo_run()

12