Home
last modified time | relevance | path

Searched refs:ready_handler (Results 1 – 25 of 42) 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_job_resolve.h21 nxt_work_handler_t ready_handler; member
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_job_file_cache.c27 nxt_job_return(&jbf->job, jbf->ready_handler); in nxt_job_file_cache_read()
H A Dnxt_job_file.h54 nxt_work_handler_t ready_handler; member
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.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_h1proto.c250 .ready_handler = nxt_http_conn_test,
385 .ready_handler = nxt_h1p_conn_proto_init,
988 r->state->ready_handler(task, r, NULL); in nxt_h1p_request_body_read()
1444 .ready_handler = nxt_h1p_conn_sent,
1941 .ready_handler = nxt_h1p_conn_sent,
2073 .ready_handler = nxt_h1p_conn_closing,
2099 .ready_handler = nxt_h1p_conn_free,
2228 r->state->ready_handler(task, r, peer); in nxt_h1p_peer_connected()
2396 r->state->ready_handler(task, r, peer); in nxt_h1p_peer_header_sent()
2707 r->state->ready_handler(task, r, peer); in nxt_h1p_peer_body_process()
[all …]
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_cache.h80 nxt_work_handler_t ready_handler; member
H A Dnxt_stream_module.c44 up->ready_handler = nxt_stream_connection_peer; in nxt_stream_connection_init()
H A Dnxt_job_file.c87 handler = jbf->ready_handler; in nxt_job_file_open_and_read()
137 nxt_job_return(task, &jbf->job, jbf->ready_handler); in nxt_job_file_open_and_read()
H A Dnxt_job_resolve.c119 handler = jbr->ready_handler; in nxt_job_resolve()
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_cache.c191 return state->ready_handler; in nxt_cache_query_locked()
299 return state->ready_handler; in nxt_cache_node_test()
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
/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