Lines Matching refs:mmap_msg
665 nxt_pid_t spid, nxt_port_mmap_msg_t *mmap_msg) in nxt_port_mmap_get_incoming_buf() argument
673 mmap_msg->mmap_id); in nxt_port_mmap_get_incoming_buf()
687 nchunks = mmap_msg->size / PORT_MMAP_CHUNK_SIZE; in nxt_port_mmap_get_incoming_buf()
688 if ((mmap_msg->size % PORT_MMAP_CHUNK_SIZE) != 0) { in nxt_port_mmap_get_incoming_buf()
694 b->mem.start = nxt_port_mmap_chunk_start(hdr, mmap_msg->chunk_id); in nxt_port_mmap_get_incoming_buf()
696 b->mem.free = b->mem.start + mmap_msg->size; in nxt_port_mmap_get_incoming_buf()
704 hdr->src_pid, hdr->dst_pid, hdr->id, mmap_msg->chunk_id); in nxt_port_mmap_get_incoming_buf()
717 nxt_port_mmap_msg_t *mmap_msg; in nxt_port_mmap_write() local
725 mmap_msg = mmsg_buf; in nxt_port_mmap_write()
729 for (i = 0; i < sb->niov; i++, mmap_msg++) { in nxt_port_mmap_write()
746 mmap_msg->mmap_id = hdr->id; in nxt_port_mmap_write()
747 mmap_msg->chunk_id = nxt_port_mmap_chunk_id(hdr, bmem->mem.pos); in nxt_port_mmap_write()
748 mmap_msg->size = sb->iobuf[i].iov_len; in nxt_port_mmap_write()
751 mmap_msg->mmap_id, mmap_msg->chunk_id, mmap_msg->size, in nxt_port_mmap_write()
768 nxt_port_mmap_msg_t *end, *mmap_msg; in nxt_port_mmap_read() local
775 mmap_msg = (nxt_port_mmap_msg_t *) b->mem.pos; in nxt_port_mmap_read()
778 while (mmap_msg < end) { in nxt_port_mmap_read()
780 mmap_msg->mmap_id, mmap_msg->chunk_id, mmap_msg->size, in nxt_port_mmap_read()
784 msg->port_msg.pid, mmap_msg); in nxt_port_mmap_read()
792 msg->size += mmap_msg->size; in nxt_port_mmap_read()
794 mmap_msg++; in nxt_port_mmap_read()