Lines Matching refs:mm

3497     nxt_unit_mmap_t         *mm, *mm_end;  in nxt_unit_mmap_get()  local
3511 for (mm = lib->outgoing.elts; mm < mm_end; mm++) { in nxt_unit_mmap_get()
3512 hdr = mm->hdr; in nxt_unit_mmap_get()
3516 || mm->src_thread != pthread_self())) in nxt_unit_mmap_get()
3749 nxt_unit_mmap_t *mm; in nxt_unit_new_mmap() local
3755 mm = nxt_unit_mmap_at(&lib->outgoing, lib->outgoing.size); in nxt_unit_new_mmap()
3756 if (nxt_slow_path(mm == NULL)) { in nxt_unit_new_mmap()
3777 mm->hdr = mem; in nxt_unit_new_mmap()
3787 mm->src_thread = pthread_self(); in nxt_unit_new_mmap()
4005 nxt_unit_mmap_t *mm; in nxt_unit_incoming_mmap() local
4048 mm = nxt_unit_mmap_at(&lib->incoming, hdr->id); in nxt_unit_incoming_mmap()
4049 if (nxt_slow_path(mm == NULL)) { in nxt_unit_incoming_mmap()
4057 mm->hdr = hdr; in nxt_unit_incoming_mmap()
4061 nxt_queue_add(&awaiting_rbuf, &mm->awaiting_rbuf); in nxt_unit_incoming_mmap()
4062 nxt_queue_init(&mm->awaiting_rbuf); in nxt_unit_incoming_mmap()
4152 nxt_unit_mmap_t *mm, *end; in nxt_unit_mmaps_destroy() local
4157 for (mm = mmaps->elts; mm < end; mm++) { in nxt_unit_mmaps_destroy()
4158 munmap(mm->hdr, PORT_MMAP_SIZE); in nxt_unit_mmaps_destroy()
4174 nxt_unit_mmap_t *mm; in nxt_unit_check_rbuf_mmap() local
4177 mm = nxt_unit_mmap_at(mmaps, id); in nxt_unit_check_rbuf_mmap()
4178 if (nxt_slow_path(mm == NULL)) { in nxt_unit_check_rbuf_mmap()
4188 *hdr = mm->hdr; in nxt_unit_check_rbuf_mmap()
4194 need_rbuf = nxt_queue_is_empty(&mm->awaiting_rbuf); in nxt_unit_check_rbuf_mmap()
4196 nxt_queue_insert_tail(&mm->awaiting_rbuf, &rbuf->link); in nxt_unit_check_rbuf_mmap()