Home
last modified time | relevance | path

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

/unit/src/
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);
250 nxt_router_access_log_ready(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_access_log_ready()
268 nxt_router_access_log_error(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_access_log_error()
329 nxt_router_access_log_reopen_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_router_access_log_reopen_handler()
413 nxt_router_access_log_reopen_ready(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_access_log_reopen_ready()
437 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_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.h357 void nxt_port_quit_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
358 void nxt_port_new_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
359 void nxt_port_process_ready_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
361 nxt_port_recv_msg_t *msg);
362 void nxt_port_mmap_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
363 void nxt_port_data_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
364 void nxt_port_remove_pid_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
365 void nxt_port_empty_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.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_script.h30 void nxt_script_store_get_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
32 nxt_port_recv_msg_t *msg);
H A Dnxt_main.h19 typedef struct nxt_port_recv_msg_s nxt_port_recv_msg_t; typedef
20 typedef void (*nxt_port_handler_t)(nxt_task_t *task, nxt_port_recv_msg_t *msg);
H A Dnxt_main_process.c53 nxt_port_recv_msg_t *msg);
55 nxt_port_recv_msg_t *msg);
59 nxt_port_recv_msg_t *msg);
62 nxt_port_recv_msg_t *msg);
64 nxt_port_recv_msg_t *msg);
68 nxt_port_recv_msg_t *msg);
337 nxt_main_data_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_data_handler()
345 nxt_main_new_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_new_port_handler()
371 nxt_main_start_process_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_start_process_handler()
1040 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_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_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_controller.c51 nxt_port_recv_msg_t *msg);
54 nxt_port_recv_msg_t *msg);
56 nxt_port_recv_msg_t *msg);
59 nxt_port_recv_msg_t *msg, void *data);
93 nxt_port_recv_msg_t *msg, void *data);
100 nxt_port_recv_msg_t *msg, void *data);
109 nxt_port_recv_msg_t *msg, void *data);
117 nxt_port_recv_msg_t *msg, void *data);
119 nxt_port_recv_msg_t *msg, void *data);
410 nxt_port_recv_msg_t *msg) in nxt_controller_process_new_port_handler()
[all …]
H A Dnxt_process.c51 static void nxt_process_whoami_ok(nxt_task_t *task, nxt_port_recv_msg_t *msg,
53 static void nxt_process_whoami_error(nxt_task_t *task, nxt_port_recv_msg_t *msg,
59 static void nxt_process_created_ok(nxt_task_t *task, nxt_port_recv_msg_t *msg,
62 nxt_port_recv_msg_t *msg, void *data);
812 nxt_process_whoami_ok(nxt_task_t *task, nxt_port_recv_msg_t *msg, void *data) in nxt_process_whoami_ok()
857 nxt_process_whoami_error(nxt_task_t *task, nxt_port_recv_msg_t *msg, void *data) in nxt_process_whoami_error()
907 nxt_process_created_ok(nxt_task_t *task, nxt_port_recv_msg_t *msg, void *data) in nxt_process_created_ok()
947 nxt_process_created_error(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_process_created_error()
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_router.c103 nxt_port_recv_msg_t *msg);
105 nxt_port_recv_msg_t *msg);
107 nxt_port_recv_msg_t *msg);
109 nxt_port_recv_msg_t *msg);
111 nxt_port_recv_msg_t *msg);
146 nxt_port_recv_msg_t *msg, void *data);
148 nxt_port_recv_msg_t *msg, void *data);
151 nxt_port_recv_msg_t *msg, void *data);
158 nxt_port_recv_msg_t *msg, void *data);
265 nxt_port_recv_msg_t *msg);
[all …]
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_router.h263 nxt_port_recv_msg_t *msg);
H A Dnxt_process.h201 void nxt_signal_quit_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
H A Dnxt_script.c541 nxt_script_store_get_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_script_store_get_handler()
630 nxt_script_store_delete_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_script_store_delete_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_port_memory.c765 nxt_port_mmap_read(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_port_mmap_read()