Home
last modified time | relevance | path

Searched refs:incoming (Results 1 – 6 of 6) sorted by relevance

/unit/src/
H A Dnxt_port_memory.c259 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()
H A Dnxt_process.h107 nxt_port_mmaps_t incoming; member
H A Dnxt_process.c110 nxt_thread_mutex_create(&process->incoming.mutex); in nxt_process_new()
295 nxt_port_mmaps_destroy(&p->incoming, 0); in nxt_process_child_fixup()
H A Dnxt_runtime.c1412 nxt_port_mmaps_destroy(&process->incoming, 1); in nxt_runtime_process_release()
1414 nxt_thread_mutex_destroy(&process->incoming.mutex); in nxt_runtime_process_release()
H A Dnxt_unit.c372 nxt_unit_mmaps_t incoming; member
642 nxt_unit_mmaps_init(&lib->incoming); in nxt_unit_create()
777 nxt_unit_mmaps_destroy(&lib->incoming); in nxt_unit_lib_release()
4031 pthread_mutex_lock(&lib->incoming.mutex); in nxt_unit_incoming_mmap()
4033 mm = nxt_unit_mmap_at(&lib->incoming, hdr->id); in nxt_unit_incoming_mmap()
4052 pthread_mutex_unlock(&lib->incoming.mutex); in nxt_unit_incoming_mmap()
4248 mmaps = &lib->incoming; in nxt_unit_mmap_read()
H A Dnxt_router.c5857 nxt_thread_mutex_lock(&process->incoming.mutex); in nxt_router_oosm_handler()
5859 for (i = 0; i < process->incoming.size; i++) { in nxt_router_oosm_handler()
5860 mmap_handler = process->incoming.elts[i].mmap_handler; in nxt_router_oosm_handler()
5880 nxt_thread_mutex_unlock(&process->incoming.mutex); in nxt_router_oosm_handler()