Home
last modified time | relevance | path

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

/unit/src/
H A Dnxt_process.h102 nxt_queue_t ports; /* of nxt_port_t.link */ member
175 nxt_queue_link_data(nxt_queue_first(&process->ports), nxt_port_t, link)
181 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_process.c108 nxt_queue_init(&process->ports); in nxt_process_new()
373 nxt_assert(!nxt_queue_is_empty(&process->ports)); in nxt_process_create()
968 nxt_queue_insert_tail(&process->ports, &port->link); in nxt_process_port_add()
977 return nxt_queue_is_empty(&process->ports) ? 0 : in nxt_process_type()
H A Dnxt_router.h109 nxt_queue_t ports; /* of nxt_port_t.app_link */ member
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.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()
4476 nxt_queue_init(&process->ports); in nxt_unit_process_get()
5564 nxt_queue_insert_tail(&process->ports, &new_port->link); in nxt_unit_add_port()
5679 port = nxt_unit_port_hash_find(&lib->ports, port_id, 1); in nxt_unit_remove_port_unsafe()
5722 nxt_queue_t ports; in nxt_unit_remove_process() local
5725 nxt_queue_init(&ports); in nxt_unit_remove_process()
[all …]
H A Dnxt_runtime.c1413 nxt_assert(nxt_queue_is_empty(&process->ports)); in nxt_runtime_process_release()
1681 res = nxt_port_hash_add(&rt->ports, port); in nxt_runtime_port_add()
1701 res = nxt_port_hash_remove(&rt->ports, port); in nxt_runtime_port_remove()
1719 return nxt_port_hash_find(&rt->ports, pid, port_id); in nxt_runtime_port_find()
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_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_router.c711 main_app_port = nxt_port_hash_find(&rt->ports, port->pid, 0); in nxt_router_new_port_handler()
1770 nxt_queue_init(&app->ports); in nxt_router_conf_create()
2978 nxt_queue_insert_tail(&app->ports, &port->app_link); in nxt_router_app_prefork_ready()
3494 res = nxt_port_hash_add(&rt->ports, port); in nxt_router_rt_add_port()
4409 nxt_queue_each(port, &app->ports, nxt_port_t, app_link) { in nxt_router_app_get_port_for_quit()
4524 nxt_queue_insert_tail(&app->ports, &main_app_port->app_link); in nxt_router_app_port_release()
4859 nxt_assert(nxt_queue_is_empty(&app->ports)); in nxt_router_free_app()
/unit/
H A DCHANGES491 ports.