ping all or specified VF

Author: azelezniak

drivers/net/ixgbe/ixgbe_ethdev.c

@@ -252,6 +252,7 @@ static int ixgbe_set_pool_vlan_anti_spoof(struct rte_eth_dev *dev,
 		uint32_t vf, uint8_t on);
 static int ixgbe_set_pool_mac_anti_spoof(struct rte_eth_dev *dev,
 		uint32_t vf, uint8_t on);
+static int ixgbe_ping_vfs(struct rte_eth_dev *dev, int32_t vf);
 static int ixgbe_mirror_rule_set(struct rte_eth_dev *dev,
 		struct rte_eth_mirror_conf *mirror_conf,
 		uint8_t rule_id, uint8_t on);
@@ -467,6 +468,7 @@ static const struct eth_dev_ops ixgbe_eth_dev_ops = {
 	.set_vf_vlan_filter   = ixgbe_set_pool_vlan_filter,
 	.set_vf_vlan_anti_spoof  = ixgbe_set_pool_vlan_anti_spoof,
 	.set_vf_mac_anti_spoof   = ixgbe_set_pool_mac_anti_spoof,
+	.ping_vfs             = ixgbe_ping_vfs,
 	.set_queue_rate_limit = ixgbe_set_queue_rate_limit,
 	.set_vf_rate_limit    = ixgbe_set_vf_rate_limit,
 	.reta_update          = ixgbe_dev_rss_reta_update,
@@ -4330,6 +4332,32 @@ ixgbe_set_pool_mac_anti_spoof(struct rte_eth_dev *dev,
 	return ret;
 }
 
+static int 
+ixgbe_ping_vfs(struct rte_eth_dev *dev, int32_t vf)
+{
+	int ret = 0;   
+	struct ixgbe_hw *hw =
+		IXGBE_DEV_PRIVATE_TO_HW(dev->data->dev_private);
+
+	struct ixgbe_vf_info *vfinfo =
+		*IXGBE_DEV_PRIVATE_TO_P_VFDATA(dev->data->dev_private);
+    
+	u32 ping;
+	int i;
+  
+	for (i = 0; i < dev->pci_dev->max_vfs; i++) {
+		ping = IXGBE_PF_CONTROL_MSG;
+		if (vfinfo[i].clear_to_send)
+			ping |= IXGBE_VT_MSGTYPE_CTS;
+    
+		/* ping every VF or only one specified */
+		if (vf < 0 || vf == i)
+			ixgbe_write_mbx(hw, &ping, 1, i);
+	}
+
+	return ret;
+}
+
 #define IXGBE_MRCTL_VPME  0x01 /* Virtual Pool Mirroring. */
 #define IXGBE_MRCTL_UPME  0x02 /* Uplink Port Mirroring. */
 #define IXGBE_MRCTL_DPME  0x04 /* Downlink Port Mirroring. */

lib/librte_ether/rte_ethdev.c

@@ -2338,6 +2338,22 @@ rte_eth_dev_set_vf_mac_anti_spoof(uint8_t port_id,
 						   vf, on);  
 }
 
+int
+rte_eth_dev_ping_vfs(uint8_t port_id, int32_t vf)
+{
+	struct rte_eth_dev *dev;
+	RTE_ETH_VALID_PORTID_OR_ERR_RET(port_id, -ENODEV);
+
+	dev = &rte_eth_devices[port_id];
+	if ( vf > 64) {
+		RTE_PMD_DEBUG_TRACE("VF ping: VM %d > 64\n", vf);
+		return -EINVAL;
+	}
+
+	RTE_FUNC_PTR_OR_ERR_RET(*dev->dev_ops->ping_vfs, -ENOTSUP);
+	return (*dev->dev_ops->ping_vfs)(dev, vf);  
+}
+
 int rte_eth_set_queue_rate_limit(uint8_t port_id, uint16_t queue_idx,
 					uint16_t tx_rate)
 {

lib/librte_ether/rte_ethdev.h

@@ -1193,6 +1193,10 @@ typedef int (*eth_set_vf_mac_anti_spoof_t)(struct rte_eth_dev *dev,
 				  uint8_t on);
 /**< @internal Set VF MAC anti spoof */
 
+typedef int (*eth_ping_vfs_t)(struct rte_eth_dev *dev,
+				int32_t vf);
+/**< @internal ping one or all vf's */
+
 typedef int (*eth_set_queue_rate_limit_t)(struct rte_eth_dev *dev,
 				uint16_t queue_idx,
 				uint16_t tx_rate);
@@ -1395,6 +1399,7 @@ struct eth_dev_ops {
 	eth_set_vf_vlan_filter_t   set_vf_vlan_filter;  /**< Set VF VLAN filter */
 	eth_set_vf_vlan_anti_spoof_t  set_vf_vlan_anti_spoof; /**< Set VF VLAN anti spoof */
 	eth_set_vf_mac_anti_spoof_t   set_vf_mac_anti_spoof;  /**< Set VF MAC anti spoof */
+	eth_ping_vfs_t             ping_vfs;                  /**< Ping one or all VF's */
 	eth_udp_tunnel_add_t       udp_tunnel_add;
 	eth_udp_tunnel_del_t       udp_tunnel_del;
 	eth_set_queue_rate_limit_t set_queue_rate_limit;   /**< Set queue rate limit */
@@ -3162,6 +3167,24 @@ rte_eth_dev_set_vf_mac_anti_spoof(uint8_t port,
 				uint32_t vf,
 				uint8_t on);      
 
+/**
+ * Ping all or specified VF 
+ *
+ * @param port_id
+ *   The port identifier of the Ethernet device.
+ * @param vf
+ * ID specifying VF ID to ping or all if -1.
+ *
+ * @return
+ *   - (0) if successful.
+ *   - (-ENOTSUP) if hardware doesn't support this feature.
+ *   - (-ENODEV) if *port_id* invalid.
+ *   - (-EINVAL) if bad parameter.
+ */
+int
+rte_eth_dev_ping_vfs(uint8_t port,
+				int32_t vf);    
+
 /**
  * Set a traffic mirroring rule on an Ethernet device
  *