Searched refs:incoming (Results 1 – 7 of 7) sorted by relevance
259 nxt_thread_mutex_lock(&process->incoming.mutex); in nxt_port_incoming_port_mmap()261 port_mmap = nxt_port_mmap_at(&process->incoming, hdr->id); in nxt_port_incoming_port_mmap()280 nxt_thread_mutex_unlock(&process->incoming.mutex); in nxt_port_incoming_port_mmap()525 nxt_thread_mutex_lock(&process->incoming.mutex); in nxt_port_get_port_incoming_mmap()527 if (nxt_fast_path(process->incoming.size > id)) { in nxt_port_get_port_incoming_mmap()528 mmap_handler = process->incoming.elts[id].mmap_handler; in nxt_port_get_port_incoming_mmap()536 nxt_thread_mutex_unlock(&process->incoming.mutex); in nxt_port_get_port_incoming_mmap()
111 nxt_port_mmaps_t incoming; member
126 nxt_thread_mutex_create(&process->incoming.mutex); in nxt_process_new()311 nxt_port_mmaps_destroy(&p->incoming, 0); in nxt_process_child_fixup()
1481 nxt_port_mmaps_destroy(&process->incoming, 1); in nxt_runtime_process_release()1483 nxt_thread_mutex_destroy(&process->incoming.mutex); in nxt_runtime_process_release()
372 nxt_unit_mmaps_t incoming; member637 rc = nxt_unit_mmaps_init(&lib->incoming); in nxt_unit_create()654 nxt_unit_mmaps_destroy(&lib->incoming); in nxt_unit_create()791 nxt_unit_mmaps_destroy(&lib->incoming); in nxt_unit_lib_release()4046 pthread_mutex_lock(&lib->incoming.mutex); in nxt_unit_incoming_mmap()4048 mm = nxt_unit_mmap_at(&lib->incoming, hdr->id); in nxt_unit_incoming_mmap()4067 pthread_mutex_unlock(&lib->incoming.mutex); in nxt_unit_incoming_mmap()4263 mmaps = &lib->incoming; in nxt_unit_mmap_read()
5737 nxt_thread_mutex_lock(&process->incoming.mutex); in nxt_router_oosm_handler()5739 for (i = 0; i < process->incoming.size; i++) { in nxt_router_oosm_handler()5740 mmap_handler = process->incoming.elts[i].mmap_handler; in nxt_router_oosm_handler()5760 nxt_thread_mutex_unlock(&process->incoming.mutex); in nxt_router_oosm_handler()
5904 incoming requests."5986 incoming requests."