Home
last modified time | relevance | path

Searched refs:ports (Results 1 – 10 of 10) sorted by relevance

/unit/src/
H A Dnxt_process.h102 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 Dnxt_runtime.h44 nxt_lvlhsh_t ports; /* of nxt_port_t */ member
H A Dnxt_router.h107 nxt_queue_t ports; /* of nxt_port_t.app_link */ member
H A Dnxt_process.c108 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 Dnxt_port.c327 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 Dnxt_unit.c616 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 Dnxt_port_memory.c858 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 Dnxt_runtime.c1676 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 Dnxt_router.c733 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 DCHANGES452 ports.