import 15.2.0 Octopus source

[ceph.git] / ceph / src / spdk / dpdk / drivers / net / virtio / virtio_user / vhost_kernel_tap.c

diff --git a/ceph/src/spdk/dpdk/drivers/net/virtio/virtio_user/vhost_kernel_tap.c b/ceph/src/spdk/dpdk/drivers/net/virtio/virtio_user/vhost_kernel_tap.c
index 9ea7ade742756f9da9127d21ba0714b3ba49dcb1..fbd9e979d7a2ba9860e23e36f238f21099d3c6a4 100644 (file)
--- a/ceph/src/spdk/dpdk/drivers/net/virtio/virtio_user/vhost_kernel_tap.c
+++ b/ceph/src/spdk/dpdk/drivers/net/virtio/virtio_user/vhost_kernel_tap.c
@@ -16,21 +16,56 @@
 
 #include "vhost_kernel_tap.h"
 #include "../virtio_logs.h"
+#include "../virtio_pci.h"
+
+static int
+vhost_kernel_tap_set_offload(int fd, uint64_t features)
+{
+       unsigned int offload = 0;
+
+       if (features & (1ULL << VIRTIO_NET_F_GUEST_CSUM)) {
+               offload |= TUN_F_CSUM;
+               if (features & (1ULL << VIRTIO_NET_F_GUEST_TSO4))
+                       offload |= TUN_F_TSO4;
+               if (features & (1ULL << VIRTIO_NET_F_GUEST_TSO6))
+                       offload |= TUN_F_TSO6;
+               if (features & ((1ULL << VIRTIO_NET_F_GUEST_TSO4) |
+                       (1ULL << VIRTIO_NET_F_GUEST_TSO6)) &&
+                       (features & (1ULL << VIRTIO_NET_F_GUEST_ECN)))
+                       offload |= TUN_F_TSO_ECN;
+               if (features & (1ULL << VIRTIO_NET_F_GUEST_UFO))
+                       offload |= TUN_F_UFO;
+       }
+
+       if (offload != 0) {
+               /* Check if our kernel supports TUNSETOFFLOAD */
+               if (ioctl(fd, TUNSETOFFLOAD, 0) != 0 && errno == EINVAL) {
+                       PMD_DRV_LOG(ERR, "Kernel does't support TUNSETOFFLOAD\n");
+                       return -ENOTSUP;
+               }
+
+               if (ioctl(fd, TUNSETOFFLOAD, offload) != 0) {
+                       offload &= ~TUN_F_UFO;
+                       if (ioctl(fd, TUNSETOFFLOAD, offload) != 0) {
+                               PMD_DRV_LOG(ERR, "TUNSETOFFLOAD ioctl() failed: %s\n",
+                                       strerror(errno));
+                               return -1;
+                       }
+               }
+       }
+
+       return 0;
+}
 
 int
 vhost_kernel_open_tap(char **p_ifname, int hdr_size, int req_mq,
-                        const char *mac)
+                        const char *mac, uint64_t features)
 {
        unsigned int tap_features;
+       char *tap_name = NULL;
        int sndbuf = INT_MAX;
        struct ifreq ifr;
        int tapfd;
-       unsigned int offload =
-                       TUN_F_CSUM |
-                       TUN_F_TSO4 |
-                       TUN_F_TSO6 |
-                       TUN_F_TSO_ECN |
-                       TUN_F_UFO;
 
        /* TODO:
         * 1. verify we can get/set vnet_hdr_len, tap_probe_vnet_hdr_len
@@ -78,6 +113,12 @@ vhost_kernel_open_tap(char **p_ifname, int hdr_size, int req_mq,
                goto error;
        }
 
+       tap_name = strdup(ifr.ifr_name);
+       if (!tap_name) {
+               PMD_DRV_LOG(ERR, "strdup ifname failed: %s", strerror(errno));
+               goto error;
+       }
+
        fcntl(tapfd, F_SETFL, O_NONBLOCK);
 
        if (ioctl(tapfd, TUNSETVNETHDRSZ, &hdr_size) < 0) {
@@ -90,13 +131,7 @@ vhost_kernel_open_tap(char **p_ifname, int hdr_size, int req_mq,
                goto error;
        }
 
-       /* TODO: before set the offload capabilities, we'd better (1) check
-        * negotiated features to see if necessary to offload; (2) query tap
-        * to see if it supports the offload capabilities.
-        */
-       if (ioctl(tapfd, TUNSETOFFLOAD, offload) != 0)
-               PMD_DRV_LOG(ERR, "TUNSETOFFLOAD ioctl() failed: %s",
-                          strerror(errno));
+       vhost_kernel_tap_set_offload(tapfd, features);
 
        memset(&ifr, 0, sizeof(ifr));
        ifr.ifr_hwaddr.sa_family = ARPHRD_ETHER;
@@ -106,11 +141,12 @@ vhost_kernel_open_tap(char **p_ifname, int hdr_size, int req_mq,
                goto error;
        }
 
-       if (!(*p_ifname))
-               *p_ifname = strdup(ifr.ifr_name);
+       free(*p_ifname);
+       *p_ifname = tap_name;
 
        return tapfd;
 error:
+       free(tap_name);
        close(tapfd);
        return -1;
 }