Home
last modified time | relevance | path

Searched refs:nxt_port_t (Results 1 – 24 of 24) sorted by path

/unit/src/
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()
1059 nxt_port_t *my_port, *proto_port, *router_port; in nxt_unit_default_init()
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_controller.c438 nxt_port_t *router_port; in nxt_controller_router_ready_handler()
565 nxt_port_t *router_port, *controller_port; in nxt_controller_conf_send()
1436 nxt_port_t *router_port; in nxt_controller_check_postpone_request()
1760 nxt_port_t *router_port, *controller_port; in nxt_controller_process_control()
1910 nxt_port_t *main_port; in nxt_controller_conf_store()
H A Dnxt_event_engine.h479 nxt_port_t *port;
H A Dnxt_external.c70 nxt_port_t *my_port, *proto_port, *router_port; in nxt_external_start()
H A Dnxt_main.h16 typedef struct nxt_port_s nxt_port_t; typedef
H A Dnxt_main_process.c343 nxt_port_t *port; in nxt_main_new_port_handler()
372 nxt_port_t *port; in nxt_main_start_process_handler()
554 nxt_port_t *port; in nxt_main_process_created_handler()
619 nxt_port_t *port; in nxt_main_process_whoami_handler()
700 nxt_port_t *port; in nxt_main_process_port_create()
789 nxt_port_t *port; in nxt_main_process_sigusr1_handler()
888 nxt_port_t *port; in nxt_main_process_sigchld_handler()
1031 nxt_port_t *port; in nxt_main_port_socket_handler()
1281 nxt_port_t *port; in nxt_main_port_modules_handler()
1456 nxt_port_t *ctl_port; in nxt_main_port_conf_store_handler()
[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.h197 nxt_port_t *port;
205 nxt_port_t *new_port;
230 nxt_port_t *main_app_port;
316 void nxt_port_destroy(nxt_port_t *port);
317 void nxt_port_close(nxt_task_t *task, nxt_port_t *port);
319 void nxt_port_write_close(nxt_port_t *port);
321 void nxt_port_read_close(nxt_port_t *port);
327 nxt_port_socket_write(nxt_task_t *task, nxt_port_t *port, in nxt_port_socket_write()
335 void nxt_port_enable(nxt_task_t *task, nxt_port_t *port,
338 nxt_port_t *new_port, uint32_t stream);
[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_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_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_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_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_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_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_process.c169 nxt_port_t *port; in nxt_process_start()
456 nxt_port_t *port; in nxt_process_do_start()
509 nxt_port_t *my_port, *main_port; in nxt_process_whoami()
560 nxt_port_t *port; in nxt_process_whoami_ok()
614 nxt_port_t *my_port, *main_port; in nxt_process_send_created()
963 nxt_process_port_add(nxt_task_t *task, nxt_process_t *process, nxt_port_t *port) in nxt_process_port_add()
985 nxt_port_t *port; in nxt_process_close_ports()
H A Dnxt_process.h112 nxt_port_t *parent_port;
175 nxt_queue_link_data(nxt_queue_first(&process->ports), nxt_port_t, link)
178 nxt_port_t *port);
181 nxt_queue_each(port, &process->ports, nxt_port_t, link)
H A Dnxt_router.c83 nxt_port_t *controller_port);
121 nxt_port_t *port);
123 nxt_port_t *port);
376 nxt_port_t *dport; in nxt_router_start_app_process_handler()
484 nxt_port_t *router_port; in nxt_router_start_app_process()
518 nxt_port_t *app_port; in nxt_router_msg_cancel()
2850 nxt_port_t *port; in nxt_router_app_prefork_ready()
3322 nxt_port_t *port; in nxt_router_thread_start()
3395 nxt_port_t *port; in nxt_router_rt_add_port()
4309 nxt_inline nxt_port_t *
[all …]
H A Dnxt_router.h85 nxt_port_t *port;
149 nxt_port_t *shared_port;
150 nxt_port_t *proto_port;
237 void nxt_router_app_port_close(nxt_task_t *task, nxt_port_t *port);
H A Dnxt_router_access_log.c202 nxt_port_t *main_port, *router_port; in nxt_router_access_log_open()
332 nxt_port_t *main_port, *router_port; in nxt_router_access_log_reopen_handler()
H A Dnxt_router_request.h30 nxt_port_t *app_port;
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()
1548 nxt_port_t *port; in nxt_runtime_process_add()
1641 nxt_port_t *
1645 nxt_port_t *port; in nxt_runtime_process_port_create()
1672 nxt_runtime_port_add(nxt_task_t *task, nxt_port_t *port) in nxt_runtime_port_add()
1692 nxt_runtime_port_remove(nxt_task_t *task, nxt_port_t *port) in nxt_runtime_port_remove()
1713 nxt_port_t *
H A Dnxt_runtime.h43 nxt_port_t *port_by_type[NXT_PROCESS_MAX];
111 nxt_port_t *nxt_runtime_process_port_create(nxt_task_t *task, nxt_runtime_t *rt,
114 void nxt_runtime_port_remove(nxt_task_t *task, nxt_port_t *port);
117 NXT_EXPORT nxt_port_t *nxt_runtime_port_find(nxt_runtime_t *rt, nxt_pid_t pid,