Home
last modified time | relevance | path

Searched refs:ports (Results 1 – 11 of 11) sorted by path

/unit/
H A DCHANGES680 ports.
/unit/src/
H A Dnxt_application.c730 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 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_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_process.c124 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 Dnxt_process.h106 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 Dnxt_router.c733 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 Dnxt_router.h115 nxt_queue_t ports; /* of nxt_port_t.app_link */ member
H A Dnxt_runtime.c1534 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 Dnxt_runtime.h44 nxt_lvlhsh_t ports; /* of nxt_port_t */ member
H A Dnxt_unit.c621 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 …]