Searched refs:mmap_msg (Results 1 – 2 of 2) sorted by last modified time
2633 nxt_port_mmap_msg_t mmap_msg; in nxt_unit_mmap_buf_send() member2651 m.mmap_msg.size = buf->free - buf->start; in nxt_unit_mmap_buf_send()2665 m.mmap_msg.mmap_id = hdr->id; in nxt_unit_mmap_buf_send()4224 nxt_port_mmap_msg_t *mmap_msg, *end; in nxt_unit_mmap_read() local4234 mmap_msg = recv_msg->start; in nxt_unit_mmap_read()4240 for (; mmap_msg < end; mmap_msg++) { in nxt_unit_mmap_read()4258 mmap_msg = recv_msg->start; in nxt_unit_mmap_read()4266 for (; mmap_msg < end; mmap_msg++) { in nxt_unit_mmap_read()4280 size = mmap_msg->size; in nxt_unit_mmap_read()4282 if (recv_msg->start == mmap_msg) { in nxt_unit_mmap_read()[all …]
696 b->mem.free = b->mem.start + mmap_msg->size; in nxt_port_mmap_get_incoming_buf()717 nxt_port_mmap_msg_t *mmap_msg; in nxt_port_mmap_write() local725 mmap_msg = mmsg_buf; in nxt_port_mmap_write()746 mmap_msg->mmap_id = hdr->id; 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() local778 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()792 msg->size += mmap_msg->size; in nxt_port_mmap_read()[all …]