[Qemu-devel] [V3 PATCH 3/8] virtio-9p: Add client side interfaces for chroot environment

["M. Mohan Kumar" <mohan@in.ibm.com>]

Define QEMU side interfaces used for chroot environment.

Signed-off-by: M. Mohan Kumar <mohan@in.ibm.com>
---
 hw/9pfs/virtio-9p-chroot.c |   78 ++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 78 insertions(+), 0 deletions(-)

diff --git a/hw/9pfs/virtio-9p-chroot.c b/hw/9pfs/virtio-9p-chroot.c
index dcde2cc..25a7fab 100644
--- a/hw/9pfs/virtio-9p-chroot.c
+++ b/hw/9pfs/virtio-9p-chroot.c
@@ -91,6 +91,82 @@ static void chroot_read_request(int sockfd, V9fsFileObjectRequest *request)
     }
 }
 
+/* Receive file descriptor and error status from chroot process */
+static int v9fs_receivefd(int sockfd, int *error)
+{
+    struct msghdr msg = { };
+    struct iovec iov;
+    union MsgControl msg_control;
+    struct cmsghdr *cmsg;
+    int retval, fd;
+    FdInfo fd_info;
+
+    iov.iov_base = &fd_info;
+    iov.iov_len = sizeof(fd_info);
+
+    memset(&msg, 0, sizeof(msg));
+    msg.msg_iov = &iov;
+    msg.msg_iovlen = 1;
+    msg.msg_control = &msg_control;
+    msg.msg_controllen = sizeof(msg_control);
+
+    retval = recvmsg(sockfd, &msg, 0);
+    if (retval < 0) {
+        error_report("recvmsg: %s", strerror(errno));
+        exit(1);
+    }
+
+    /* If error is set, ancillary data is not present */
+    if (fd_info.fi_error) {
+        *error = fd_info.fi_error;
+        return -1;
+    }
+
+    for (cmsg = CMSG_FIRSTHDR(&msg); cmsg; cmsg = CMSG_NXTHDR(&msg, cmsg)) {
+        if (cmsg->cmsg_len != CMSG_LEN(sizeof(int)) ||
+                cmsg->cmsg_level != SOL_SOCKET ||
+                cmsg->cmsg_type != SCM_RIGHTS) {
+            continue;
+        }
+        fd = *((int *)CMSG_DATA(cmsg));
+        return fd;
+    }
+
+    *error = EAGAIN;
+    return -1;
+}
+
+/*
+ * V9fsFileObjectRequest is written into the socket by QEMU process.
+ * Then this request is read by chroot process using read_request function
+ */
+static void v9fs_write_request(int sockfd, V9fsFileObjectRequest *request)
+{
+    int retval;
+
+    retval = qemu_write_full(sockfd, &request->data,
+                    sizeof(request->data));
+    if (retval < 0) {
+        error_report("socket write failed: %s", strerror(errno));
+        exit(-1);
+    }
+
+    retval = qemu_write_full(sockfd, request->path.path,
+                    request->data.path_len);
+    if (retval < 0) {
+        error_report("socket write failed: %s", strerror(errno));
+        exit(-1);
+    }
+    if (request->data.oldpath_len > 0) {
+        retval = qemu_write_full(sockfd, request->path.old_path,
+                    request->data.oldpath_len);
+        if (retval < 0) {
+            error_report("socket write failed: %s", strerror(errno));
+            exit(-1);
+        }
+    }
+}
+
 static int chroot_daemonize(int chroot_sock)
 {
     sigset_t sigset;
@@ -122,6 +198,8 @@ static int chroot_daemonize(int chroot_sock)
 static void chroot_dummy(void)
 {
     (void)chroot_sendfd;
+    (void)v9fs_receivefd;
+    (void)v9fs_write_request;
 }
 
 /*
-- 
1.7.3.4