Searched refs:ports (Results 1 – 10 of 10) sorted by relevance
/unit/src/ |
H A D | nxt_process.h | 102 nxt_queue_t ports; /* of nxt_port_t.link */ member 173 nxt_queue_link_data(nxt_queue_first(&process->ports), nxt_port_t, link) 179 nxt_queue_each(port, &process->ports, nxt_port_t, link)
|
H A D | nxt_runtime.h | 44 nxt_lvlhsh_t ports; /* of nxt_port_t */ member
|
H A D | nxt_router.h | 107 nxt_queue_t ports; /* of nxt_port_t.app_link */ member
|
H A D | nxt_process.c | 108 nxt_queue_init(&process->ports); in nxt_process_new() 992 nxt_queue_insert_tail(&process->ports, &port->link); in nxt_process_port_add() 1001 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_unit.c | 616 lib->ports.slot = NULL; in nxt_unit_create() 1471 port = nxt_unit_port_hash_find(&lib->ports, port_id, 0); in nxt_unit_request_check_response_port() 1519 res = nxt_unit_port_hash_add(&lib->ports, port); in nxt_unit_request_check_response_port() 1536 nxt_unit_port_hash_find(&lib->ports, port_id, 1); in nxt_unit_request_check_response_port() 1545 nxt_queue_insert_tail(&process->ports, &port_impl->link); in nxt_unit_request_check_response_port() 4462 nxt_queue_init(&process->ports); in nxt_unit_process_get() 5550 nxt_queue_insert_tail(&process->ports, &new_port->link); in nxt_unit_add_port() 5665 port = nxt_unit_port_hash_find(&lib->ports, port_id, 1); in nxt_unit_remove_port_unsafe() 5708 nxt_queue_t ports; in nxt_unit_remove_process() local 5711 nxt_queue_init(&ports); in nxt_unit_remove_process() [all …]
|
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()
|
H A D | nxt_runtime.c | 1676 res = nxt_port_hash_add(&rt->ports, port); in nxt_runtime_port_add() 1696 res = nxt_port_hash_remove(&rt->ports, port); in nxt_runtime_port_remove() 1714 return nxt_port_hash_find(&rt->ports, pid, port_id); in nxt_runtime_port_find()
|
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() 1706 nxt_queue_init(&app->ports); in nxt_router_conf_create() 2931 nxt_queue_insert_tail(&app->ports, &port->app_link); in nxt_router_app_prefork_ready() 3447 res = nxt_port_hash_add(&rt->ports, port); in nxt_router_rt_add_port() 4740 nxt_queue_each(port, &app->ports, nxt_port_t, app_link) { in nxt_router_app_get_port_for_quit() 4855 nxt_queue_insert_tail(&app->ports, &main_app_port->app_link); in nxt_router_app_port_release() 5190 nxt_assert(nxt_queue_is_empty(&app->ports)); in nxt_router_free_app()
|
/unit/ |
H A D | CHANGES | 452 ports.
|