Home
last modified time | relevance | path

Searched refs:nxt_port_recv_msg_t (Results 1 – 17 of 17) sorted by relevance

/unit/src/
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_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_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.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_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_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_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_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);
532 nxt_process_whoami_ok(nxt_task_t *task, nxt_port_recv_msg_t *msg, void *data) in nxt_process_whoami_ok()
577 nxt_process_whoami_error(nxt_task_t *task, nxt_port_recv_msg_t *msg, void *data) in nxt_process_whoami_error()
627 nxt_process_created_ok(nxt_task_t *task, nxt_port_recv_msg_t *msg, void *data) in nxt_process_created_ok()
667 nxt_process_created_error(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_process_created_error()
H A Dnxt_port_memory.h38 nxt_port_mmap_read(nxt_task_t *task, nxt_port_recv_msg_t *msg);
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()
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);
96 nxt_port_recv_msg_t *msg);
134 nxt_port_recv_msg_t *msg, void *data);
136 nxt_port_recv_msg_t *msg, void *data);
139 nxt_port_recv_msg_t *msg, void *data);
147 nxt_port_recv_msg_t *msg, void *data);
268 nxt_port_recv_msg_t *msg);
[all …]
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_application.c41 static void nxt_discovery_quit(nxt_task_t *task, nxt_port_recv_msg_t *msg,
50 nxt_port_recv_msg_t *msg);
51 static void nxt_proto_quit_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
53 nxt_port_recv_msg_t *msg);
492 nxt_discovery_quit(nxt_task_t *task, nxt_port_recv_msg_t *msg, void *data) in nxt_discovery_quit()
588 nxt_proto_start_process_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_proto_start_process_handler()
663 nxt_proto_quit_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_proto_quit_handler()
694 nxt_proto_process_created_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_proto_process_created_handler()
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_process.h195 void nxt_signal_quit_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
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_port_memory.c765 nxt_port_mmap_read(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_port_mmap_read()