Lines Matching refs:mmap_msg

2619         nxt_port_mmap_msg_t  mmap_msg;  in nxt_unit_mmap_buf_send()  member
2637 m.mmap_msg.size = buf->free - buf->start; in nxt_unit_mmap_buf_send()
2644 m.msg.mmap = hdr != NULL && m.mmap_msg.size > 0; in nxt_unit_mmap_buf_send()
2651 m.mmap_msg.mmap_id = hdr->id; in nxt_unit_mmap_buf_send()
2652 m.mmap_msg.chunk_id = nxt_port_mmap_chunk_id(hdr, in nxt_unit_mmap_buf_send()
2657 (int) m.mmap_msg.mmap_id, in nxt_unit_mmap_buf_send()
2658 (int) m.mmap_msg.chunk_id, in nxt_unit_mmap_buf_send()
2659 (int) m.mmap_msg.size); in nxt_unit_mmap_buf_send()
2689 (int) m.mmap_msg.chunk_id - (int) first_free_chunk); in nxt_unit_mmap_buf_send()
2710 (int) (sizeof(m.msg) + m.mmap_msg.size)); in nxt_unit_mmap_buf_send()
2714 m.mmap_msg.size + sizeof(m.msg), NULL); in nxt_unit_mmap_buf_send()
2716 if (nxt_slow_path(res != (ssize_t) (m.mmap_msg.size + sizeof(m.msg)))) { in nxt_unit_mmap_buf_send()
4210 nxt_port_mmap_msg_t *mmap_msg, *end; in nxt_unit_mmap_read() local
4220 mmap_msg = recv_msg->start; in nxt_unit_mmap_read()
4226 for (; mmap_msg < end; mmap_msg++) { in nxt_unit_mmap_read()
4244 mmap_msg = recv_msg->start; in nxt_unit_mmap_read()
4252 for (; mmap_msg < end; mmap_msg++) { in nxt_unit_mmap_read()
4254 recv_msg->pid, mmap_msg->mmap_id, in nxt_unit_mmap_read()
4265 start = nxt_port_mmap_chunk_start(hdr, mmap_msg->chunk_id); in nxt_unit_mmap_read()
4266 size = mmap_msg->size; in nxt_unit_mmap_read()
4268 if (recv_msg->start == mmap_msg) { in nxt_unit_mmap_read()
4284 (int) hdr->id, (int) mmap_msg->chunk_id, in nxt_unit_mmap_read()
4285 (int) mmap_msg->size); in nxt_unit_mmap_read()