From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from mail-pf0-f171.google.com (mail-pf0-f171.google.com [209.85.192.171]) by dpdk.org (Postfix) with ESMTP id 40B8F379B for ; Thu, 2 Jun 2016 05:30:04 +0200 (CEST) Received: by mail-pf0-f171.google.com with SMTP id f144so25658246pfa.3 for ; Wed, 01 Jun 2016 20:30:04 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=igel-co-jp.20150623.gappssmtp.com; s=20150623; h=from:to:cc:subject:date:message-id:in-reply-to:references :in-reply-to:references; bh=inb3CNpUoI9jWxvZlM8Al8q94PPTYi/9nA1VU0sqhZQ=; b=hZqttioofIy0RFTcUyoyOp1/QdI6T3f26faalFRoVO3NYlLTC31hab3SvntBdJT+75 C9G14QRBCt3zE5xcZiGAcpbMrMvjh/cnTSDZn/8MYniRip6lJltzsb9/YeaHPTXs54OG RQzCMjUfHAHDt0IxXPkdVpOzA31VzRJnmoosyw2CDT/LW2ucOmgrA6lmtQttvVpmA4lz yU2d5VXldjgpAaDPD8XnkcYgzIbLl/0AtnJKKrPTmhca9gA/fBi7u/qwxbhEb3y5bUqK jI8dUBQMVNDAAqev+fkJdjaPAM8bAQlCQAsLsmK5V83TyJi+Pua3a3B09YmS/zJJWvEm h9fA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:from:to:cc:subject:date:message-id:in-reply-to :references:in-reply-to:references; bh=inb3CNpUoI9jWxvZlM8Al8q94PPTYi/9nA1VU0sqhZQ=; b=ZaYFUK3TpjyyxRNP4aHADgMZR/9pVRjHu/86o3nqSJcN725DVR/smpb/DAPadl0Xru KARUDGrQ0cRUKdeJJFHA1mVkzrC1Wnix8kkGohr0ZXLT15d3bIqw8Yhrb4MGq6f1nwMD 4xaQcQm6lhRqNdv1hkXmF+GjbQj+PmG5wvBtlZQycTAI9AqT+5oA4Z9A04U3o9RdgCly 7ZUQOJkrrt4vTJeK5QyyQxMcwTyO+stgZvGULz3kfvYsV48N1gsZcKL7O4l+B+jeM6t+ P8zaxgqcuc8mjUu3FzzYqdOMcApruLNHr+vv/AU7Skt0RfnqNorH+krRk6NntlCgJ2dY HrxA== X-Gm-Message-State: ALyK8tJ9bn0jzWt1p58CJ2oG0st3oLQr/UGw5/cIYssSxL0B8wXWCV5SCeQKt7/e/apvsw== X-Received: by 10.98.93.145 with SMTP id n17mr412829pfj.66.1464838203467; Wed, 01 Jun 2016 20:30:03 -0700 (PDT) Received: from localhost.localdomain (napt.igel.co.jp. [219.106.231.132]) by smtp.gmail.com with ESMTPSA id th5sm59830828pab.31.2016.06.01.20.30.01 (version=TLS1_2 cipher=ECDHE-RSA-AES128-SHA bits=128/128); Wed, 01 Jun 2016 20:30:02 -0700 (PDT) From: Tetsuya Mukawa To: dev@dpdk.org Cc: yuanhan.liu@linux.intel.com, jianfeng.tan@intel.com, huawei.xie@intel.com, Tetsuya Mukawa Date: Thu, 2 Jun 2016 12:29:42 +0900 Message-Id: <1464838185-21751-4-git-send-email-mukawa@igel.co.jp> X-Mailer: git-send-email 2.7.4 In-Reply-To: <1464838185-21751-1-git-send-email-mukawa@igel.co.jp> References: <1464838185-21751-1-git-send-email-mukawa@igel.co.jp> In-Reply-To: <1457512409-24403-12-git-send-email-mukawa@igel.co.jp> References: <1457512409-24403-12-git-send-email-mukawa@igel.co.jp> Subject: [dpdk-dev] [PATCH v5 3/6] virtio, qtest: Add functionality to share memory between QTest guest X-BeenThere: dev@dpdk.org X-Mailman-Version: 2.1.15 Precedence: list List-Id: patches and discussions about DPDK List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , X-List-Received-Date: Thu, 02 Jun 2016 03:30:04 -0000 The patch adds functionality to share memory between QTest guest and DPDK application using ivshmem device. The shared memory will be all EAL memory on hugepages. This memory will be accessed by QEMU vcpu and DPDK application using same address. Signed-off-by: Tetsuya Mukawa --- drivers/net/virtio/virtio_qtest/qtest_utils.c | 189 +++++++++++++++++++++++++- drivers/net/virtio/virtio_qtest/qtest_utils.h | 4 +- 2 files changed, 189 insertions(+), 4 deletions(-) diff --git a/drivers/net/virtio/virtio_qtest/qtest_utils.c b/drivers/net/virtio/virtio_qtest/qtest_utils.c index 2c088f0..9bc1fca 100644 --- a/drivers/net/virtio/virtio_qtest/qtest_utils.c +++ b/drivers/net/virtio/virtio_qtest/qtest_utils.c @@ -43,6 +43,9 @@ #include "../virtio_ethdev.h" #include "qtest_utils.h" +/* ivshmem configuration */ +#define IVSHMEM_PROTOCOL_VERSION 0 + #define PCI_CONFIG_ADDR(_bus, _device, _function, _offset) ( \ (1 << 31) | ((_bus) & 0xff) << 16 | ((_device) & 0x1f) << 11 | \ ((_function) & 0x7) << 8 | ((_offset) & 0xfc)) @@ -59,6 +62,7 @@ union qtest_pipefds { struct qtest_session { int qtest_socket; + int ivshmem_socket; pthread_mutex_t qtest_session_lock; struct qtest_pci_device_list head; @@ -411,6 +415,7 @@ qtest_close_sockets(struct qtest_session *s) qtest_close_one_socket(&s->qtest_socket); qtest_close_one_socket(&s->msgfds.readfd); qtest_close_one_socket(&s->msgfds.writefd); + qtest_close_one_socket(&s->ivshmem_socket); } static void @@ -716,6 +721,172 @@ qtest_register_target_devices(struct qtest_session *s, } static int +qtest_send_message_to_ivshmem(int sock_fd, uint64_t client_id, int shm_fd) +{ + struct iovec iov; + struct msghdr msgh; + size_t fdsize = sizeof(int); + char control[CMSG_SPACE(fdsize)]; + struct cmsghdr *cmsg; + int ret; + + memset(&msgh, 0, sizeof(msgh)); + iov.iov_base = &client_id; + iov.iov_len = sizeof(client_id); + + msgh.msg_iov = &iov; + msgh.msg_iovlen = 1; + + if (shm_fd >= 0) { + msgh.msg_control = &control; + msgh.msg_controllen = sizeof(control); + cmsg = CMSG_FIRSTHDR(&msgh); + cmsg->cmsg_len = CMSG_LEN(fdsize); + cmsg->cmsg_level = SOL_SOCKET; + cmsg->cmsg_type = SCM_RIGHTS; + memcpy(CMSG_DATA(cmsg), &shm_fd, fdsize); + } + + do { + ret = sendmsg(sock_fd, &msgh, 0); + } while (ret < 0 && errno == EINTR); + + if (ret < 0) { + PMD_DRV_LOG(ERR, "sendmsg error"); + return ret; + } + + return ret; +} + +/* This function is came from ../virtio_user/vhost_user.c + * + * Two possible options: + * 1. Match HUGEPAGE_INFO_FMT to find the file storing struct hugepage_file + * array. This is simple but cannot be used in secondary process because + * secondary process will close and munmap that file. + * 2. Match HUGEFILE_FMT to find hugepage files directly. + * + * We choose option 2. + */ +struct hugepage_file_info { + uint64_t addr; /**< virtual addr */ + size_t size; /**< the file size */ + char path[PATH_MAX]; /**< path to backing file */ +}; + +static int +get_hugepage_file_info(struct hugepage_file_info huges[], int max) +{ + int idx; + FILE *f; + char buf[BUFSIZ], *tmp, *tail; + char *str_underline, *str_start; + int huge_index; + uint64_t v_start, v_end; + + f = fopen("/proc/self/maps", "r"); + if (!f) { + PMD_DRV_LOG(ERR, "cannot open /proc/self/maps"); + return -1; + } + + idx = 0; + while (fgets(buf, sizeof(buf), f) != NULL) { + sscanf(buf, "%" PRIx64 "-%" PRIx64, &v_start, &v_end); + + tmp = strchr(buf, ' ') + 1; /** skip address */ + tmp = strchr(tmp, ' ') + 1; /** skip perm */ + tmp = strchr(tmp, ' ') + 1; /** skip offset */ + tmp = strchr(tmp, ' ') + 1; /** skip dev */ + tmp = strchr(tmp, ' ') + 1; /** skip inode */ + while (*tmp == ' ') /** skip spaces */ + tmp++; + tail = strrchr(tmp, '\n'); /** remove newline if exists */ + if (tail) + *tail = '\0'; + + /* Match HUGEFILE_FMT, aka "%s/%smap_%d", + * which is defined in eal_filesystem.h + */ + str_underline = strrchr(tmp, '_'); + if (!str_underline) + continue; + + str_start = str_underline - strlen("map"); + if (str_start < tmp) + continue; + + if (sscanf(str_start, "map_%d", &huge_index) != 1) + continue; + + if (idx >= max) { + PMD_DRV_LOG(ERR, "Exceed maximum of %d", max); + goto error; + } + huges[idx].addr = v_start; + huges[idx].size = v_end - v_start; + strcpy(huges[idx].path, tmp); + idx++; + } + + fclose(f); + return idx; + +error: + fclose(f); + return -1; +} + +static int +qtest_setup_shared_memory(struct qtest_session *s) +{ + int shm_fd, num, ret; + struct hugepage_file_info huges[1]; + + num = get_hugepage_file_info(huges, 1); + if (num != 1) { + PMD_DRV_LOG(ERR, + "Not supported memory configuration"); + return -1; + } + + shm_fd = open(huges[0].path, O_RDWR); + if (shm_fd < 0) { + PMD_DRV_LOG(ERR, + "Cannot open file: %s", huges[0].path); + return -1; + } + + /* send our protocol version first */ + ret = qtest_send_message_to_ivshmem(s->ivshmem_socket, + IVSHMEM_PROTOCOL_VERSION, -1); + if (ret < 0) { + PMD_DRV_LOG(ERR, + "Failed to send protocol version to ivshmem"); + return -1; + } + + /* send client id */ + ret = qtest_send_message_to_ivshmem(s->ivshmem_socket, 0, -1); + if (ret < 0) { + PMD_DRV_LOG(ERR, "Failed to send VMID to ivshmem"); + return -1; + } + + /* send message to ivshmem */ + ret = qtest_send_message_to_ivshmem(s->ivshmem_socket, -1, shm_fd); + if (ret < 0) { + PMD_DRV_LOG(ERR, "Failed to file descriptor to ivshmem"); + return -1; + } + + close(shm_fd); + + return 0; +} + +static int qtest_open_socket(char *path) { struct sockaddr_un sa = {0}; @@ -769,7 +940,7 @@ qtest_vdev_uninit(struct qtest_session *s) } struct qtest_session * -qtest_vdev_init(char *qtest_path, +qtest_vdev_init(char *qtest_path, char *ivshmem_path, struct qtest_pci_device *devices, int devnum) { struct qtest_session *s; @@ -796,7 +967,13 @@ qtest_vdev_init(char *qtest_path, ret = qtest_register_target_devices(s, devices, devnum); if (ret != 0) { - PMD_DRV_LOG(ERR, "Failed to initialize qtest session\n"); + PMD_DRV_LOG(ERR, "Failed to initialize qtest session"); + goto error; + } + + s->ivshmem_socket = qtest_open_socket(ivshmem_path); + if (s->ivshmem_socket < 0) { + PMD_DRV_LOG(ERR, "Failed to open %s", ivshmem_path); goto error; } @@ -813,9 +990,15 @@ qtest_vdev_init(char *qtest_path, } s->event_th_started = 1; + ret = qtest_setup_shared_memory(s); + if (ret != 0) { + PMD_DRV_LOG(ERR, "Failed to setup shared memory"); + goto error; + } + ret = qtest_init_pci_devices(s, devices, devnum); if (ret != 0) { - PMD_DRV_LOG(ERR, "Failed to initialize devices\n"); + PMD_DRV_LOG(ERR, "Failed to initialize devices"); goto error; } diff --git a/drivers/net/virtio/virtio_qtest/qtest_utils.h b/drivers/net/virtio/virtio_qtest/qtest_utils.h index a3d8176..6c70552 100644 --- a/drivers/net/virtio/virtio_qtest/qtest_utils.h +++ b/drivers/net/virtio/virtio_qtest/qtest_utils.h @@ -132,6 +132,8 @@ struct qtest_pci_device { * * @param qtest_path * Path of qtest socket. + * @param ivshmem_path + * Path of ivshmem socket. * @param devices * Array of device information. It should contain piix3, ivshmem and target * device(virtio-net device). @@ -140,7 +142,7 @@ struct qtest_pci_device { * @return * The pointer to qtest session structure. */ -struct qtest_session *qtest_vdev_init(char *qtest_path, +struct qtest_session *qtest_vdev_init(char *qtest_path, char *ivshmem_path, struct qtest_pci_device *devices, int devnum); /** -- 2.7.4