/unit/src/ |
H A D | nxt_port_rpc.h | 16 uint32_t nxt_port_rpc_register_handler(nxt_task_t *task, nxt_port_t *port, 19 void *nxt_port_rpc_register_handler_ex(nxt_task_t *task, nxt_port_t *port, 24 void nxt_port_rpc_ex_set_peer(nxt_task_t *task, nxt_port_t *port, 28 void nxt_port_rpc_remove_peer(nxt_task_t *task, nxt_port_t *port, 30 void nxt_port_rpc_cancel(nxt_task_t *task, nxt_port_t *port, uint32_t stream); 31 void nxt_port_rpc_close(nxt_task_t *task, nxt_port_t *port);
|
H A D | nxt_port_hash.h | 14 nxt_int_t nxt_port_hash_add(nxt_lvlhsh_t *port_hash, nxt_port_t *port); 16 nxt_int_t nxt_port_hash_remove(nxt_lvlhsh_t *port_hash, nxt_port_t *port); 18 nxt_port_t *nxt_port_hash_find(nxt_lvlhsh_t *port_hash, nxt_pid_t pid, 21 nxt_port_t *nxt_port_hash_retrieve(nxt_lvlhsh_t *port_hash);
|
H A D | nxt_port.h | 211 nxt_port_t *port; 219 nxt_port_t *new_port; 244 nxt_port_t *main_app_port; 330 void nxt_port_destroy(nxt_port_t *port); 331 void nxt_port_close(nxt_task_t *task, nxt_port_t *port); 333 void nxt_port_write_close(nxt_port_t *port); 335 void nxt_port_read_close(nxt_port_t *port); 341 nxt_port_socket_write(nxt_task_t *task, nxt_port_t *port, in nxt_port_socket_write() 349 void nxt_port_enable(nxt_task_t *task, nxt_port_t *port, 352 nxt_port_t *new_port, uint32_t stream); [all …]
|
H A D | nxt_port.c | 26 nxt_port_t *port; in nxt_port_mp_cleanup() 48 nxt_port_t * 53 nxt_port_t *port; in nxt_port_new() 206 nxt_port_t *port; in nxt_port_send_new_port() 229 nxt_port_send_port(nxt_task_t *task, nxt_port_t *port, nxt_port_t *new_port, in nxt_port_send_port() 262 nxt_port_t *port; in nxt_port_new_port_handler() 312 nxt_port_t *port; in nxt_port_process_ready_handler() 379 nxt_port_t *port; in nxt_port_change_log_file() 459 nxt_port_t *port; in nxt_port_remove_notify_others() 549 nxt_port_t *port; [all …]
|
H A D | nxt_port_hash.c | 20 nxt_port_t *port; in nxt_port_hash_test() 44 nxt_port_t * 63 nxt_port_hash_add(nxt_lvlhsh_t *port_hash, nxt_port_t *port) in nxt_port_hash_add() 94 nxt_port_hash_remove(nxt_lvlhsh_t *port_hash, nxt_port_t *port) in nxt_port_hash_remove() 122 nxt_port_t *
|
H A D | nxt_port_socket.c | 36 static nxt_buf_t *nxt_port_buf_alloc(nxt_port_t *port); 120 nxt_port_destroy(nxt_port_t *port) in nxt_port_destroy() 143 nxt_port_write_close(nxt_port_t *port) in nxt_port_write_close() 374 nxt_port_t *port; in nxt_port_write_handler() 569 nxt_port_msg_first(nxt_port_t *port) in nxt_port_msg_first() 721 nxt_port_read_close(nxt_port_t *port) in nxt_port_read_close() 736 nxt_port_t *port; in nxt_port_read_handler() 817 nxt_port_t *port; in nxt_port_queue_read_handler() 1305 nxt_port_buf_alloc(nxt_port_t *port) in nxt_port_buf_alloc() 1328 nxt_port_buf_free(nxt_port_t *port, nxt_buf_t *b) in nxt_port_buf_free() [all …]
|
H A D | nxt_port_memory.h | 34 nxt_port_mmap_write(nxt_task_t *task, nxt_port_t *port, 49 nxt_port_mmap_get_method(nxt_task_t *task, nxt_port_t *port, nxt_buf_t *b);
|
H A D | nxt_runtime.h | 43 nxt_port_t *port_by_type[NXT_PROCESS_MAX]; 116 nxt_port_t *nxt_runtime_process_port_create(nxt_task_t *task, nxt_runtime_t *rt, 119 void nxt_runtime_port_remove(nxt_task_t *task, nxt_port_t *port); 122 NXT_EXPORT nxt_port_t *nxt_runtime_port_find(nxt_runtime_t *rt, nxt_pid_t pid,
|
H A D | nxt_port_rpc.c | 29 nxt_port_rpc_remove_from_peers(nxt_task_t *task, nxt_port_t *port, 92 nxt_port_rpc_register_handler(nxt_task_t *task, nxt_port_t *port, in nxt_port_rpc_register_handler() 121 nxt_port_rpc_register_handler_ex(nxt_task_t *task, nxt_port_t *port, in nxt_port_rpc_register_handler_ex() 188 nxt_port_rpc_ex_set_peer(nxt_task_t *task, nxt_port_t *port, in nxt_port_rpc_ex_set_peer() 254 nxt_port_rpc_remove_from_peers(nxt_task_t *task, nxt_port_t *port, in nxt_port_rpc_remove_from_peers() 312 nxt_port_t *port; in nxt_port_rpc_handler() 367 nxt_port_rpc_remove_peer(nxt_task_t *task, nxt_port_t *port, nxt_pid_t peer) in nxt_port_rpc_remove_peer() 460 nxt_port_rpc_cancel(nxt_task_t *task, nxt_port_t *port, uint32_t stream) in nxt_port_rpc_cancel() 493 nxt_port_rpc_close(nxt_task_t *task, nxt_port_t *port) in nxt_port_rpc_close()
|
H A D | nxt_process.h | 116 nxt_port_t *parent_port; 179 nxt_queue_link_data(nxt_queue_first(&process->ports), nxt_port_t, link) 182 nxt_port_t *port); 185 nxt_queue_each(port, &process->ports, nxt_port_t, link)
|
H A D | nxt_router.h | 91 nxt_port_t *port; 155 nxt_port_t *shared_port; 156 nxt_port_t *proto_port; 247 void nxt_router_app_port_close(nxt_task_t *task, nxt_port_t *port);
|
H A D | nxt_router_request.h | 30 nxt_port_t *app_port;
|
H A D | nxt_main.h | 17 typedef struct nxt_port_s nxt_port_t; typedef
|
H A D | nxt_router.c | 98 nxt_port_t *controller_port); 138 nxt_port_t *port); 140 nxt_port_t *port); 402 nxt_port_t *dport; in nxt_router_start_app_process_handler() 510 nxt_port_t *router_port; in nxt_router_start_app_process() 544 nxt_port_t *app_port; in nxt_router_msg_cancel() 955 nxt_port_t *port; in nxt_router_status_handler() 3104 nxt_port_t *port; in nxt_router_app_prefork_ready() 3649 nxt_port_t *port; in nxt_router_rt_add_port() 4600 nxt_inline nxt_port_t * [all …]
|
H A D | nxt_port_memory.c | 20 static void nxt_port_broadcast_shm_ack(nxt_task_t *task, nxt_port_t *port, 664 nxt_port_mmap_get_incoming_buf(nxt_task_t *task, nxt_port_t *port, in nxt_port_mmap_get_incoming_buf() 711 nxt_port_mmap_write(nxt_task_t *task, nxt_port_t *port, in nxt_port_mmap_write() 804 nxt_port_mmap_get_method(nxt_task_t *task, nxt_port_t *port, nxt_buf_t *b) in nxt_port_mmap_get_method() 856 nxt_port_t *port; in nxt_process_broadcast_shm_ack() 872 nxt_port_broadcast_shm_ack(nxt_task_t *task, nxt_port_t *port, void *data) in nxt_port_broadcast_shm_ack() 878 nxt_queue_each(port, &process->ports, nxt_port_t, link) { in nxt_port_broadcast_shm_ack()
|
H A D | nxt_main_process.c | 418 nxt_port_t *port; in nxt_main_new_port_handler() 447 nxt_port_t *port; in nxt_main_start_process_handler() 629 nxt_port_t *port; in nxt_main_process_created_handler() 699 nxt_port_t *port; in nxt_main_process_whoami_handler() 780 nxt_port_t *port; in nxt_main_process_port_create() 869 nxt_port_t *port; in nxt_main_process_sigusr1_handler() 968 nxt_port_t *port; in nxt_main_process_sigchld_handler() 1115 nxt_port_t *port; in nxt_main_port_socket_handler() 1414 nxt_port_t *port; in nxt_main_port_modules_handler() 1589 nxt_port_t *ctl_port; in nxt_main_port_conf_store_handler() [all …]
|
H A D | nxt_process.c | 185 nxt_port_t *port; in nxt_process_start() 712 nxt_port_t *port; in nxt_process_do_start() 765 nxt_port_t *my_port, *main_port; in nxt_process_whoami() 816 nxt_port_t *port; in nxt_process_whoami_ok() 870 nxt_port_t *my_port, *main_port; in nxt_process_send_created() 1219 nxt_process_port_add(nxt_task_t *task, nxt_process_t *process, nxt_port_t *port) in nxt_process_port_add() 1241 nxt_port_t *port; in nxt_process_close_ports()
|
H A D | nxt_script.c | 485 nxt_port_t *main_port, *recv_port; in nxt_script_store_get() 547 nxt_port_t *port; in nxt_script_store_get_handler() 611 nxt_port_t *main_port; in nxt_script_store_delete() 634 nxt_port_t *ctl_port; in nxt_script_store_delete_handler()
|
H A D | nxt_runtime.c | 43 static void nxt_runtime_port_add(nxt_task_t *task, nxt_port_t *port); 497 nxt_port_t *port; in nxt_runtime_stop_app_processes() 524 nxt_port_t *port; in nxt_runtime_stop_all_processes() 1671 nxt_port_t *port; in nxt_runtime_process_add() 1764 nxt_port_t * 1768 nxt_port_t *port; in nxt_runtime_process_port_create() 1795 nxt_runtime_port_add(nxt_task_t *task, nxt_port_t *port) in nxt_runtime_port_add() 1815 nxt_runtime_port_remove(nxt_task_t *task, nxt_port_t *port) in nxt_runtime_port_remove() 1836 nxt_port_t *
|
H A D | nxt_cert.c | 958 nxt_port_t *port; 1068 nxt_port_t *main_port, *recv_port; in nxt_cert_store_get() 1130 nxt_port_t *port; in nxt_cert_store_get_handler() 1195 nxt_port_t *main_port; in nxt_cert_store_delete() 1218 nxt_port_t *ctl_port; in nxt_cert_store_delete_handler()
|
H A D | nxt_router_access_log.c | 230 nxt_port_t *main_port, *router_port; in nxt_router_access_log_open() 360 nxt_port_t *main_port, *router_port; in nxt_router_access_log_reopen_handler()
|
H A D | nxt_application.c | 169 nxt_port_t *main_port, *discovery_port; in nxt_discovery_start() 599 nxt_port_t *port; in nxt_proto_start_process_handler() 689 nxt_port_t *port; in nxt_proto_quit_children() 769 nxt_port_t *port; in nxt_proto_sigchld_handler() 1118 nxt_port_t *my_port, *proto_port, *router_port; in nxt_unit_default_init()
|
H A D | nxt_external.c | 70 nxt_port_t *my_port, *proto_port, *router_port; in nxt_external_start()
|
H A D | nxt_event_engine.h | 479 nxt_port_t *port;
|
H A D | nxt_controller.c | 470 nxt_port_t *router_port; in nxt_controller_router_ready_handler() 598 nxt_port_t *router_port, *controller_port; in nxt_controller_conf_send() 1549 nxt_port_t *router_port; in nxt_controller_check_postpone_request() 1572 nxt_port_t *router_port, *controller_port; in nxt_controller_process_status() 2283 nxt_port_t *router_port, *controller_port; in nxt_controller_process_control() 2433 nxt_port_t *main_port; in nxt_controller_conf_store()
|