Lines Matching refs:msg
88 vhost_user_read(int fd, struct vhost_user_msg *msg) in vhost_user_read() argument
93 ret = recv(fd, (void *)msg, sz_hdr, 0); in vhost_user_read()
101 if (msg->flags != (valid_flags)) { in vhost_user_read()
103 msg->flags, valid_flags); in vhost_user_read()
107 sz_payload = msg->size; in vhost_user_read()
109 if ((size_t)sz_payload > sizeof(msg->payload)) in vhost_user_read()
113 ret = recv(fd, (void *)((char *)msg + sz_hdr), sz_payload, 0); in vhost_user_read()
117 ret, msg->size); in vhost_user_read()
209 prepare_vhost_memory_user(struct vhost_user_msg *msg, int fds[]) in prepare_vhost_memory_user() argument
214 wa.vm = &msg->payload.memory; in prepare_vhost_memory_user()
224 msg->payload.memory.nregions = wa.region_nr; in prepare_vhost_memory_user()
225 msg->payload.memory.padding = 0; in prepare_vhost_memory_user()
256 struct vhost_user_msg msg; in vhost_user_sock() local
275 msg.request = req; in vhost_user_sock()
276 msg.flags = VHOST_USER_VERSION; in vhost_user_sock()
277 msg.size = 0; in vhost_user_sock()
298 msg.flags |= VHOST_USER_NEED_REPLY_MASK; in vhost_user_sock()
303 msg.payload.u64 = *((__u64 *)arg); in vhost_user_sock()
304 msg.size = sizeof(m.payload.u64); in vhost_user_sock()
312 if (prepare_vhost_memory_user(&msg, fds) < 0) in vhost_user_sock()
314 fd_num = msg.payload.memory.nregions; in vhost_user_sock()
315 msg.size = sizeof(m.payload.memory.nregions); in vhost_user_sock()
316 msg.size += sizeof(m.payload.memory.padding); in vhost_user_sock()
317 msg.size += fd_num * sizeof(struct vhost_memory_region); in vhost_user_sock()
320 msg.flags |= VHOST_USER_NEED_REPLY_MASK; in vhost_user_sock()
330 memcpy(&msg.payload.state, arg, sizeof(msg.payload.state)); in vhost_user_sock()
331 msg.size = sizeof(m.payload.state); in vhost_user_sock()
335 memcpy(&msg.payload.state, arg, sizeof(msg.payload.state)); in vhost_user_sock()
336 msg.size = sizeof(m.payload.state); in vhost_user_sock()
341 memcpy(&msg.payload.addr, arg, sizeof(msg.payload.addr)); in vhost_user_sock()
342 msg.size = sizeof(m.payload.addr); in vhost_user_sock()
349 msg.payload.u64 = file->index & VHOST_USER_VRING_IDX_MASK; in vhost_user_sock()
350 msg.size = sizeof(m.payload.u64); in vhost_user_sock()
354 msg.payload.u64 |= VHOST_USER_VRING_NOFD_MASK; in vhost_user_sock()
362 len = VHOST_USER_HDR_SIZE + msg.size; in vhost_user_sock()
363 if (vhost_user_write(vhostfd, &msg, len, fds, fd_num) < 0) { in vhost_user_sock()
369 if (need_reply || msg.flags & VHOST_USER_NEED_REPLY_MASK) { in vhost_user_sock()
370 if (vhost_user_read(vhostfd, &msg) < 0) { in vhost_user_sock()
376 if (req != msg.request) { in vhost_user_sock()
385 if (msg.size != sizeof(m.payload.u64)) { in vhost_user_sock()
389 *((__u64 *)arg) = msg.payload.u64; in vhost_user_sock()
392 if (msg.size != sizeof(m.payload.state)) { in vhost_user_sock()
396 memcpy(arg, &msg.payload.state, in vhost_user_sock()
401 if (msg.size != sizeof(m.payload.u64)) { in vhost_user_sock()
406 if (msg.payload.u64 != 0) { in vhost_user_sock()