From patchwork Thu Dec 21 16:53:20 2017 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: "Varghese, Vipin" X-Patchwork-Id: 32559 X-Patchwork-Delegate: ferruh.yigit@amd.com Return-Path: X-Original-To: patchwork@dpdk.org Delivered-To: patchwork@dpdk.org Received: from [92.243.14.124] (localhost [127.0.0.1]) by dpdk.org (Postfix) with ESMTP id 1CE441B258; Thu, 21 Dec 2017 12:12:17 +0100 (CET) Received: from mga05.intel.com (mga05.intel.com [192.55.52.43]) by dpdk.org (Postfix) with ESMTP id 64E521B254 for ; Thu, 21 Dec 2017 12:12:15 +0100 (CET) X-Amp-Result: SKIPPED(no attachment in message) X-Amp-File-Uploaded: False Received: from fmsmga004.fm.intel.com ([10.253.24.48]) by fmsmga105.fm.intel.com with ESMTP/TLS/DHE-RSA-AES256-GCM-SHA384; 21 Dec 2017 03:12:14 -0800 X-ExtLoop1: 1 X-IronPort-AV: E=Sophos;i="5.45,435,1508828400"; d="scan'208";a="14512064" Received: from unknown (HELO localhost.localdomain) ([10.224.122.203]) by fmsmga004.fm.intel.com with ESMTP; 21 Dec 2017 03:12:12 -0800 From: Vipin Varghese To: dev@dpdk.org Cc: ferruh.yigit@intel.com, amol.patel@intel.com, david.hunt@intel.com, deepak.k.jain@intel.com, Vipin Varghese Date: Thu, 21 Dec 2017 22:23:20 +0530 Message-Id: <1513875200-5061-1-git-send-email-vipin.varghese@intel.com> X-Mailer: git-send-email 1.9.1 Subject: [dpdk-dev] [PATCH v1] [net/tap] add logic to assign speed from user X-BeenThere: dev@dpdk.org X-Mailman-Version: 2.1.15 Precedence: list List-Id: DPDK patches and discussions List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Errors-To: dev-bounces@dpdk.org Sender: "dev" TAP speed is passed as user argument, but never set to interface. New logic brings speed get and set to LOCAL and REMOTE interfaces. Updated the default PMD speeed to 10M as per Linux Kernel default value. Signed-off-by: Vipin Varghese --- drivers/net/tap/rte_eth_tap.c | 185 +++++++++++++++++++++++++++++++++++++++++- 1 file changed, 182 insertions(+), 3 deletions(-) diff --git a/drivers/net/tap/rte_eth_tap.c b/drivers/net/tap/rte_eth_tap.c index 6b27679..7238504 100644 --- a/drivers/net/tap/rte_eth_tap.c +++ b/drivers/net/tap/rte_eth_tap.c @@ -62,6 +62,8 @@ #include #include #include +#include +#include #include #include @@ -96,7 +98,7 @@ static volatile uint32_t tap_trigger; /* Rx trigger */ static struct rte_eth_link pmd_link = { - .link_speed = ETH_SPEED_NUM_10G, + .link_speed = ETH_SPEED_NUM_10M, .link_duplex = ETH_LINK_FULL_DUPLEX, .link_status = ETH_LINK_DOWN, .link_autoneg = ETH_LINK_SPEED_AUTONEG @@ -1229,6 +1231,178 @@ enum ioctl_mode { }; static int +tap_speed_set(struct pmd_internals *pmd, const char *iface_name, +enum ioctl_mode mode, uint32_t speed) +{ + int err; + struct ifreq ifr; + struct ethtool_cmd edataCmd = {0}; +#ifdef ETHTOOL_SLINKSETTINGS + struct ethtool_link_settings edataLink = {0}; +#endif + + if ((pmd == NULL) || (iface_name == NULL) || + (speed == ETH_SPEED_NUM_NONE)) + return -1; + + RTE_LOG(DEBUG, PMD, + "SET speed %u for %s iface_name %s\n", + speed, + (mode == REMOTE_ONLY)?"REMOTE":"LOCAL", + iface_name); + + switch (speed) { + case (ETH_SPEED_NUM_10M): + case (ETH_SPEED_NUM_100M): + case (ETH_SPEED_NUM_1G): + case (ETH_SPEED_NUM_2_5G): + case (ETH_SPEED_NUM_5G): + case (ETH_SPEED_NUM_10G): + case (ETH_SPEED_NUM_20G): + case (ETH_SPEED_NUM_25G): + case (ETH_SPEED_NUM_40G): + case (ETH_SPEED_NUM_50G): + case (ETH_SPEED_NUM_56G): + case (ETH_SPEED_NUM_100G): + break; + + default: + RTE_LOG(ERR, PMD, + "Unsupported SET speed %u for %s iface_name %s.\n", + speed, + (mode == REMOTE_ONLY)?"REMOTE":"LOCAL", + iface_name); + + return -2; + } + +#ifdef ETHTOOL_SLINKSETTINGS + edataLink.speed = speed; + edataLink.cmd = ETHTOOL_SLINKSETTINGS; + ifr.ifr_data = (caddr_t)&edataLink; + + err = tap_ioctl(pmd, SIOCETHTOOL, &ifr, 0, + (mode == REMOTE_ONLY)?REMOTE_ONLY:LOCAL_ONLY); + if (err == 0) + return speed; +#endif + + edataCmd.speed = speed; + edataCmd.cmd = ETHTOOL_SSET; + ifr.ifr_data = (caddr_t)&edataCmd; + + err = tap_ioctl(pmd, SIOCETHTOOL, &ifr, 0, + (mode == REMOTE_ONLY)?REMOTE_ONLY:LOCAL_ONLY); + + if (err == 0) + return speed; + + RTE_LOG(ERR, PMD, + "Failed to SET speed %u for %s iface_name %s.\n", + speed, (mode == REMOTE_ONLY)?"REMOTE":"LOCAL", iface_name); + + return -2; +} + +static int +tap_speed_get(struct pmd_internals *pmd, const char *iface_name, +enum ioctl_mode mode) +{ + int err; + struct ifreq ifr; + struct ethtool_cmd edataCmd = {0}; +#ifdef ETHTOOL_GLINKSETTINGS + struct ethtool_link_settings edataLink = {0}; +#endif + + if ((pmd == NULL) || (iface_name == NULL)) + return -1; + + RTE_LOG(DEBUG, PMD, + "Retrive speed for %s iface_name %s.\n", + (mode == REMOTE_ONLY)?"REMOTE":"LOCAL", iface_name); + +#ifdef ETHTOOL_GLINKSETTINGS + edataLink.speed = 0; + edataLink.cmd = ETHTOOL_GLINKSETTINGS; + ifr.ifr_data = (caddr_t)&edataLink; + + err = tap_ioctl(pmd, SIOCETHTOOL, &ifr, 0, + (mode == REMOTE_ONLY)?REMOTE_ONLY:LOCAL_ONLY); + + if ((err == 0) && (edataLink.speed)) + return edataLink.speed; +#endif + + edataCmd.speed = 0; + edataCmd.cmd = ETHTOOL_GSET; + ifr.ifr_data = (caddr_t)&edataCmd; + + err = tap_ioctl(pmd, SIOCETHTOOL, &ifr, 0, + (mode == REMOTE_ONLY)?REMOTE_ONLY:LOCAL_ONLY); + if ((err == 0) && (edataCmd.speed)) + return edataCmd.speed; + + RTE_LOG(ERR, PMD, + "Failed to retrive speed for %s iface_name %s.\n", + (mode == REMOTE_ONLY)?"REMOTE":"LOCAL", iface_name); + + return -2; +} + +static int +eth_dev_tap_config_speed(struct pmd_internals *pmd) +{ + int err = 0, remoteSpeed = 0, localSpeed = 0; + + err = tap_speed_get(pmd, + pmd->name, LOCAL_ONLY); + if (err <= ETH_SPEED_NUM_NONE) + return err; + localSpeed = err; + + RTE_LOG(DEBUG, PMD, + "Local interface %s speed got %d desired %u\n", + pmd->name, localSpeed, pmd_link.link_speed); + + if (localSpeed != (int) pmd_link.link_speed) { + err = tap_speed_set(pmd, pmd->name, LOCAL_ONLY, + pmd_link.link_speed); + if (err <= ETH_SPEED_NUM_NONE) + return 0; + localSpeed = err; + } + pmd_link.link_speed = (unsigned int) localSpeed; + + RTE_LOG(INFO, PMD, + "speed %u for ifindex for %s.\n", + pmd_link.link_speed, pmd->name); + + /*If remote interface is passed as argument, update speed*/ + if (strlen(pmd->remote_iface)) { + err = tap_speed_get(pmd, pmd->remote_iface, REMOTE_ONLY); + if (err <= ETH_SPEED_NUM_NONE) + return err; + remoteSpeed = (unsigned int) err; + + if ((unsigned int) remoteSpeed != pmd_link.link_speed) { + err = tap_speed_set(pmd, pmd->remote_iface, + REMOTE_ONLY, pmd_link.link_speed); + if (err <= ETH_SPEED_NUM_NONE) + return 0; + + remoteSpeed = (int) pmd_link.link_speed; + } + + RTE_LOG(INFO, PMD, + "Remote ifindex %s; speed %u matches to PMD\n", + pmd->remote_iface, remoteSpeed); + } + + return pmd_link.link_speed; +} + +static int eth_dev_tap_create(struct rte_vdev_device *vdev, char *tap_name, char *remote_iface, int fixed_mac_type) { @@ -1403,6 +1577,11 @@ enum ioctl_mode { } } + if (eth_dev_tap_config_speed(pmd) > 0) + data->dev_link = pmd_link; + else + goto error_exit; + return 0; disable_rte_flow: @@ -1448,7 +1627,7 @@ enum ioctl_mode { const char *value, void *extra_args) { - *(int *)extra_args = (value) ? atoi(value) : ETH_SPEED_NUM_10G; + *(int *)extra_args = (value) ? atoi(value) : ETH_SPEED_NUM_10M; return 0; } @@ -1493,7 +1672,7 @@ enum ioctl_mode { name = rte_vdev_device_name(dev); params = rte_vdev_device_args(dev); - speed = ETH_SPEED_NUM_10G; + speed = ETH_SPEED_NUM_10M; snprintf(tap_name, sizeof(tap_name), "%s%d", DEFAULT_TAP_NAME, tap_unit++); memset(remote_iface, 0, RTE_ETH_NAME_MAX_LEN);