Home
last modified time | relevance | path

Searched refs:nxt_port_recv_msg_t (Results 1 – 19 of 19) sorted by path

/unit/src/
H A Dnxt_application.c48 static void nxt_discovery_quit(nxt_task_t *task, nxt_port_recv_msg_t *msg,
57 nxt_port_recv_msg_t *msg);
58 static void nxt_proto_quit_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
60 nxt_port_recv_msg_t *msg);
499 nxt_discovery_quit(nxt_task_t *task, nxt_port_recv_msg_t *msg, void *data) in nxt_discovery_quit()
595 nxt_proto_start_process_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_proto_start_process_handler()
672 nxt_proto_quit_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_proto_quit_handler()
703 nxt_proto_process_created_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_proto_process_created_handler()
H A Dnxt_cert.c952 nxt_cert_store_discovery_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg)
1124 nxt_cert_store_get_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_cert_store_get_handler()
1214 nxt_cert_store_delete_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_cert_store_delete_handler()
H A Dnxt_cert.h29 void nxt_cert_store_get_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
30 void nxt_cert_store_delete_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
H A Dnxt_controller.c49 nxt_port_recv_msg_t *msg);
52 nxt_port_recv_msg_t *msg);
54 nxt_port_recv_msg_t *msg);
57 nxt_port_recv_msg_t *msg, void *data);
92 nxt_port_recv_msg_t *msg, void *data);
100 nxt_port_recv_msg_t *msg, void *data);
102 nxt_port_recv_msg_t *msg, void *data);
378 nxt_port_recv_msg_t *msg) in nxt_controller_process_new_port_handler()
436 nxt_port_recv_msg_t *msg) in nxt_controller_router_ready_handler()
504 nxt_controller_conf_init_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_controller_conf_init_handler()
[all …]
H A Dnxt_main.h18 typedef struct nxt_port_recv_msg_s nxt_port_recv_msg_t; typedef
19 typedef void (*nxt_port_handler_t)(nxt_task_t *task, nxt_port_recv_msg_t *msg);
H A Dnxt_main_process.c50 nxt_port_recv_msg_t *msg);
54 nxt_port_recv_msg_t *msg);
57 nxt_port_recv_msg_t *msg);
59 nxt_port_recv_msg_t *msg);
63 nxt_port_recv_msg_t *msg);
332 nxt_main_data_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_data_handler()
340 nxt_main_new_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_new_port_handler()
366 nxt_main_start_process_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_start_process_handler()
615 nxt_main_process_whoami_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_process_whoami_handler()
1026 nxt_main_port_socket_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_port_socket_handler()
[all …]
H A Dnxt_port.c15 static void nxt_port_remove_pid(nxt_task_t *task, nxt_port_recv_msg_t *msg,
17 static void nxt_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
173 nxt_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_port_handler()
195 nxt_port_quit_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_port_quit_handler()
260 nxt_port_new_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_port_new_port_handler()
310 nxt_port_process_ready_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_port_process_ready_handler()
345 nxt_port_mmap_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_port_mmap_handler()
438 nxt_port_data_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_port_data_handler()
502 nxt_port_remove_pid_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_port_remove_pid_handler()
518 nxt_port_remove_pid(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_port_remove_pid()
[all …]
H A Dnxt_port.h343 void nxt_port_quit_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
344 void nxt_port_new_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
345 void nxt_port_process_ready_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
347 nxt_port_recv_msg_t *msg);
348 void nxt_port_mmap_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
349 void nxt_port_data_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
350 void nxt_port_remove_pid_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
351 void nxt_port_empty_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
H A Dnxt_port_memory.c765 nxt_port_mmap_read(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_port_mmap_read()
H A Dnxt_port_memory.h38 nxt_port_mmap_read(nxt_task_t *task, nxt_port_recv_msg_t *msg);
H A Dnxt_port_rpc.c307 nxt_port_rpc_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_port_rpc_handler()
376 nxt_port_recv_msg_t msg; in nxt_port_rpc_remove_peer()
496 nxt_port_recv_msg_t msg; in nxt_port_rpc_close()
H A Dnxt_port_rpc.h12 nxt_port_recv_msg_t *msg, void *data);
27 void nxt_port_rpc_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
H A Dnxt_port_socket.c35 nxt_port_recv_msg_t *msg);
738 nxt_port_recv_msg_t msg; in nxt_port_read_handler()
821 nxt_port_recv_msg_t msg, *smsg; in nxt_port_queue_read_handler()
1036 nxt_port_recv_msg_t *fmsg; in nxt_port_lvlhsh_frag_test()
1075 static nxt_port_recv_msg_t *
1077 nxt_port_recv_msg_t *msg) in nxt_port_frag_start()
1081 nxt_port_recv_msg_t *fmsg; in nxt_port_frag_start()
1086 fmsg = nxt_mp_alloc(port->mem_pool, sizeof(nxt_port_recv_msg_t)); in nxt_port_frag_start()
1131 static nxt_port_recv_msg_t *
1172 nxt_port_recv_msg_t *msg) in nxt_port_read_msg_process()
[all …]
H A Dnxt_process.c35 static void nxt_process_whoami_ok(nxt_task_t *task, nxt_port_recv_msg_t *msg,
37 static void nxt_process_whoami_error(nxt_task_t *task, nxt_port_recv_msg_t *msg,
43 static void nxt_process_created_ok(nxt_task_t *task, nxt_port_recv_msg_t *msg,
46 nxt_port_recv_msg_t *msg, void *data);
556 nxt_process_whoami_ok(nxt_task_t *task, nxt_port_recv_msg_t *msg, void *data) in nxt_process_whoami_ok()
601 nxt_process_whoami_error(nxt_task_t *task, nxt_port_recv_msg_t *msg, void *data) in nxt_process_whoami_error()
651 nxt_process_created_ok(nxt_task_t *task, nxt_port_recv_msg_t *msg, void *data) in nxt_process_created_ok()
691 nxt_process_created_error(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_process_created_error()
H A Dnxt_process.h197 void nxt_signal_quit_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
H A Dnxt_router.c88 nxt_port_recv_msg_t *msg);
90 nxt_port_recv_msg_t *msg);
92 nxt_port_recv_msg_t *msg);
94 nxt_port_recv_msg_t *msg);
129 nxt_port_recv_msg_t *msg, void *data);
131 nxt_port_recv_msg_t *msg, void *data);
134 nxt_port_recv_msg_t *msg, void *data);
142 nxt_port_recv_msg_t *msg, void *data);
144 nxt_port_recv_msg_t *msg, void *data);
242 nxt_port_recv_msg_t *msg);
[all …]
H A Dnxt_router.h255 nxt_port_recv_msg_t *msg);
H A Dnxt_router_access_log.c33 nxt_port_recv_msg_t *msg, void *data);
35 nxt_port_recv_msg_t *msg, void *data);
39 nxt_port_recv_msg_t *msg, void *data);
41 nxt_port_recv_msg_t *msg, void *data);
247 nxt_router_access_log_ready(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_access_log_ready()
265 nxt_router_access_log_error(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_access_log_error()
326 nxt_router_access_log_reopen_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_router_access_log_reopen_handler()
410 nxt_router_access_log_reopen_ready(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_access_log_reopen_ready()
434 nxt_router_access_log_reopen_error(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_access_log_reopen_error()
H A Dnxt_signal_handlers.c40 nxt_signal_quit_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_signal_quit_handler()