Home
last modified time | relevance | path

Searched refs:nxt_port_t (Results 1 – 25 of 25) sorted by relevance

/unit/src/
H A Dnxt_port_rpc.h16 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 Dnxt_port_hash.h14 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 Dnxt_port.h211 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 Dnxt_port.c26 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 Dnxt_port_hash.c20 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 Dnxt_port_socket.c36 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 Dnxt_port_memory.h34 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 Dnxt_runtime.h43 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 Dnxt_port_rpc.c29 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 Dnxt_process.h116 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 Dnxt_router.h91 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 Dnxt_router_request.h30 nxt_port_t *app_port;
H A Dnxt_main.h17 typedef struct nxt_port_s nxt_port_t; typedef
H A Dnxt_router.c98 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 Dnxt_port_memory.c20 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 Dnxt_main_process.c418 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 Dnxt_process.c185 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 Dnxt_script.c485 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 Dnxt_runtime.c43 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 Dnxt_cert.c958 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 Dnxt_router_access_log.c230 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 Dnxt_application.c169 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 Dnxt_external.c70 nxt_port_t *my_port, *proto_port, *router_port; in nxt_external_start()
H A Dnxt_event_engine.h479 nxt_port_t *port;
H A Dnxt_controller.c470 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()