Searched refs:ports (Results 1 – 11 of 11) sorted by last modified time
/unit/ |
H A D | CHANGES | 680 ports.
|
/unit/src/ |
H A D | nxt_router.c | 733 main_app_port = nxt_port_hash_find(&rt->ports, port->pid, 0); in nxt_router_new_port_handler() 1840 nxt_queue_init(&app->ports); in nxt_router_conf_create() 3141 nxt_queue_insert_tail(&app->ports, &port->app_link); in nxt_router_app_prefork_ready() 3657 res = nxt_port_hash_add(&rt->ports, port); in nxt_router_rt_add_port() 4609 nxt_queue_each(port, &app->ports, nxt_port_t, app_link) { in nxt_router_app_get_port_for_quit() 4724 nxt_queue_insert_tail(&app->ports, &main_app_port->app_link); in nxt_router_app_port_release() 5059 nxt_assert(nxt_queue_is_empty(&app->ports)); in nxt_router_free_app()
|
H A D | nxt_application.c | 730 nxt_assert(!nxt_queue_is_empty(&process->ports)); in nxt_proto_process_created_handler() 840 nxt_assert(!nxt_queue_is_empty(&process->ports)); in nxt_proto_sigchld_handler()
|
H A D | nxt_runtime.c | 1534 nxt_assert(nxt_queue_is_empty(&process->ports)); in nxt_runtime_process_release() 1802 res = nxt_port_hash_add(&rt->ports, port); in nxt_runtime_port_add() 1822 res = nxt_port_hash_remove(&rt->ports, port); in nxt_runtime_port_remove() 1840 return nxt_port_hash_find(&rt->ports, pid, port_id); in nxt_runtime_port_find()
|
H A D | nxt_runtime.h | 44 nxt_lvlhsh_t ports; /* of nxt_port_t */ member
|
H A D | nxt_router.h | 115 nxt_queue_t ports; /* of nxt_port_t.app_link */ member
|
H A D | nxt_unit.c | 621 lib->ports.slot = NULL; in nxt_unit_create() 1485 port = nxt_unit_port_hash_find(&lib->ports, port_id, 0); in nxt_unit_request_check_response_port() 1533 res = nxt_unit_port_hash_add(&lib->ports, port); in nxt_unit_request_check_response_port() 1550 nxt_unit_port_hash_find(&lib->ports, port_id, 1); in nxt_unit_request_check_response_port() 1559 nxt_queue_insert_tail(&process->ports, &port_impl->link); in nxt_unit_request_check_response_port() 4477 nxt_queue_init(&process->ports); in nxt_unit_process_get() 5565 nxt_queue_insert_tail(&process->ports, &new_port->link); in nxt_unit_add_port() 5680 port = nxt_unit_port_hash_find(&lib->ports, port_id, 1); in nxt_unit_remove_port_unsafe() 5723 nxt_queue_t ports; in nxt_unit_remove_process() local 5726 nxt_queue_init(&ports); in nxt_unit_remove_process() [all …]
|
H A D | nxt_process.h | 106 nxt_queue_t ports; /* of nxt_port_t.link */ member 179 nxt_queue_link_data(nxt_queue_first(&process->ports), nxt_port_t, link) 185 nxt_queue_each(port, &process->ports, nxt_port_t, link)
|
H A D | nxt_process.c | 124 nxt_queue_init(&process->ports); in nxt_process_new() 614 nxt_assert(!nxt_queue_is_empty(&process->ports)); in nxt_process_create() 1224 nxt_queue_insert_tail(&process->ports, &port->link); in nxt_process_port_add() 1233 return nxt_queue_is_empty(&process->ports) ? 0 : in nxt_process_type()
|
H A D | nxt_port.c | 327 nxt_assert(!nxt_queue_is_empty(&process->ports)); in nxt_port_process_ready_handler() 474 || nxt_queue_is_empty(&p->ports)) in nxt_port_remove_notify_others()
|
H A D | nxt_port_memory.c | 858 if (nxt_slow_path(process == NULL || nxt_queue_is_empty(&process->ports))) in nxt_process_broadcast_shm_ack() 878 nxt_queue_each(port, &process->ports, nxt_port_t, link) { in nxt_port_broadcast_shm_ack()
|