Lines Matching refs:m

2620     } m;  in nxt_unit_mmap_buf_send()  local
2637 m.mmap_msg.size = buf->free - buf->start; in nxt_unit_mmap_buf_send()
2639 m.msg.stream = req_impl->stream; in nxt_unit_mmap_buf_send()
2640 m.msg.pid = lib->pid; in nxt_unit_mmap_buf_send()
2641 m.msg.reply_port = 0; in nxt_unit_mmap_buf_send()
2642 m.msg.type = _NXT_PORT_MSG_DATA; in nxt_unit_mmap_buf_send()
2643 m.msg.last = last != 0; in nxt_unit_mmap_buf_send()
2644 m.msg.mmap = hdr != NULL && m.mmap_msg.size > 0; in nxt_unit_mmap_buf_send()
2645 m.msg.nf = 0; in nxt_unit_mmap_buf_send()
2646 m.msg.mf = 0; in nxt_unit_mmap_buf_send()
2650 if (m.msg.mmap) { 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()
2661 res = nxt_unit_port_send(req->ctx, req->response_port, &m, sizeof(m), in nxt_unit_mmap_buf_send()
2663 if (nxt_slow_path(res != sizeof(m))) { in nxt_unit_mmap_buf_send()
2689 (int) m.mmap_msg.chunk_id - (int) first_free_chunk); in nxt_unit_mmap_buf_send()
2696 || mmap_buf->plain_ptr > buf->start - sizeof(m.msg))) in nxt_unit_mmap_buf_send()
2706 memcpy(buf->start - sizeof(m.msg), &m.msg, sizeof(m.msg)); in nxt_unit_mmap_buf_send()
2710 (int) (sizeof(m.msg) + m.mmap_msg.size)); in nxt_unit_mmap_buf_send()
2713 buf->start - sizeof(m.msg), 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()
4304 } m; in nxt_unit_get_mmap() local
4309 memset(&m.msg, 0, sizeof(nxt_port_msg_t)); in nxt_unit_get_mmap()
4311 m.msg.pid = lib->pid; in nxt_unit_get_mmap()
4312 m.msg.reply_port = ctx_impl->read_port->id.id; in nxt_unit_get_mmap()
4313 m.msg.type = _NXT_PORT_MSG_GET_MMAP; in nxt_unit_get_mmap()
4315 m.get_mmap.id = id; in nxt_unit_get_mmap()
4319 res = nxt_unit_port_send(ctx, lib->router_port, &m, sizeof(m), NULL); in nxt_unit_get_mmap()
4320 if (nxt_slow_path(res != sizeof(m))) { in nxt_unit_get_mmap()
5340 } m; in nxt_unit_send_port() local
5344 m.msg.stream = 0; in nxt_unit_send_port()
5345 m.msg.pid = lib->pid; in nxt_unit_send_port()
5346 m.msg.reply_port = 0; in nxt_unit_send_port()
5347 m.msg.type = _NXT_PORT_MSG_NEW_PORT; in nxt_unit_send_port()
5348 m.msg.last = 0; in nxt_unit_send_port()
5349 m.msg.mmap = 0; in nxt_unit_send_port()
5350 m.msg.nf = 0; in nxt_unit_send_port()
5351 m.msg.mf = 0; in nxt_unit_send_port()
5353 m.new_port.id = port->id.id; in nxt_unit_send_port()
5354 m.new_port.pid = port->id.pid; in nxt_unit_send_port()
5355 m.new_port.type = NXT_PROCESS_APP; in nxt_unit_send_port()
5356 m.new_port.max_size = 16 * 1024; in nxt_unit_send_port()
5357 m.new_port.max_share = 64 * 1024; in nxt_unit_send_port()
5361 res = nxt_unit_port_send(ctx, dst, &m, sizeof(m), &oob); in nxt_unit_send_port()
5363 return (res == sizeof(m)) ? NXT_UNIT_OK : NXT_UNIT_ERROR; in nxt_unit_send_port()
5752 } nxt_packed m; in nxt_unit_quit() local
5825 memset(&m.msg, 0, sizeof(nxt_port_msg_t)); in nxt_unit_quit()
5827 m.msg.pid = lib->pid; in nxt_unit_quit()
5828 m.msg.type = _NXT_PORT_MSG_QUIT; in nxt_unit_quit()
5829 m.quit_param = quit_param; in nxt_unit_quit()
5843 &m, sizeof(m), NULL); in nxt_unit_quit()
5861 } m; in nxt_unit_get_port() local
5866 memset(&m.msg, 0, sizeof(nxt_port_msg_t)); in nxt_unit_get_port()
5868 m.msg.pid = lib->pid; in nxt_unit_get_port()
5869 m.msg.reply_port = ctx_impl->read_port->id.id; in nxt_unit_get_port()
5870 m.msg.type = _NXT_PORT_MSG_GET_PORT; in nxt_unit_get_port()
5872 m.get_port.id = port_id->id; in nxt_unit_get_port()
5873 m.get_port.pid = port_id->pid; in nxt_unit_get_port()
5878 res = nxt_unit_port_send(ctx, lib->router_port, &m, sizeof(m), NULL); in nxt_unit_get_port()
5879 if (nxt_slow_path(res != sizeof(m))) { in nxt_unit_get_port()
6265 } nxt_packed m; in nxt_unit_app_queue_recv() local
6288 memset(&m.msg, 0, sizeof(nxt_port_msg_t)); in nxt_unit_app_queue_recv()
6290 m.msg.pid = lib->pid; in nxt_unit_app_queue_recv()
6291 m.msg.type = _NXT_PORT_MSG_QUIT; in nxt_unit_app_queue_recv()
6292 m.quit_param = NXT_QUIT_GRACEFUL; in nxt_unit_app_queue_recv()
6295 &m, sizeof(m), NULL); in nxt_unit_app_queue_recv()