dpdk: add rss argument to set user specific rss offload

Author: Pavel Siska

src/plugins/input/dpdk/src/dpdk.cpp

@@ -86,12 +86,13 @@ void DpdkCore::configure(const char* params)
 	uint16_t rxQueueCount = parser.rx_queues();
 	m_mBufsCount = parser.pkt_buffer_size();
 	uint16_t mtuSize = parser.mtu_size();
+	uint64_t rssOffload = parser.rss_offload();
 
 	configureEal(parser.eal_params());
 
 	m_dpdkDevices.reserve(parser.port_numbers().size());
 	for (auto portID : parser.port_numbers()) {
-		m_dpdkDevices.emplace_back(portID, rxQueueCount, mempoolSize, m_mBufsCount, mtuSize);
+		m_dpdkDevices.emplace_back(portID, rxQueueCount, mempoolSize, m_mBufsCount, mtuSize, rssOffload);
 	}
 
 	isConfigured = true;

src/plugins/input/dpdk/src/dpdk.hpp

@@ -34,6 +34,7 @@ class DpdkOptParser : public OptionsParser {
 	uint16_t rx_queues_ = 1;
 	std::string eal_;
 	uint16_t mtu_;
+	uint64_t rss_offload_ = 0;
 
 	std::vector<uint16_t> parsePortNumbers(std::string arg)
 	{
@@ -123,6 +124,20 @@ class DpdkOptParser : public OptionsParser {
 				return true;
 			},
 			RequiredArgument);
+		register_option(
+			"r",
+			"rss",
+			"VALUE",
+			"RSS offload value. Default: 0",
+			[this](const char* arg) {
+				try {
+					rss_offload_ = str2num<decltype(rss_offload_)>(arg);
+				} catch (std::invalid_argument&) {
+					return false;
+				}
+				return true;
+			},
+			RequiredArgument);
 		register_option(
 			"e",
 			"eal",
@@ -160,6 +175,8 @@ class DpdkOptParser : public OptionsParser {
 	uint16_t rx_queues() const { return rx_queues_; }
 
 	uint16_t mtu_size() const { return mtu_; }
+
+	uint64_t rss_offload() const { return rss_offload_; }
 };
 
 class DpdkCore {

src/plugins/input/dpdk/src/dpdkDevice.cpp

@@ -42,7 +42,9 @@ DpdkDevice::DpdkDevice(
 	uint16_t rxQueueCount,
 	uint16_t memPoolSize,
 	uint16_t mbufsCount,
-	uint16_t mtuSize)
+	uint16_t mtuSize,
+	uint64_t rssOffload
+	)
 	: m_portID(portID)
 	, m_rxQueueCount(rxQueueCount)
 	, m_txQueueCount(0)
@@ -51,6 +53,7 @@ DpdkDevice::DpdkDevice(
 	, m_supportedRSS(false)
 	, m_supportedHWTimestamp(false)
 	, m_mtuSize(mtuSize)
+	, m_rssOffload(rssOffload)
 {
 	validatePort();
 	recognizeDriver();
@@ -94,9 +97,13 @@ void DpdkDevice::recognizeDriver()
 	std::cerr << "\tflow type RSS offloads: " << rteDevInfo.flow_type_rss_offloads << std::endl;
 
 	/* Check if RSS hashing is supported in NIC */
-	m_supportedRSS = (rteDevInfo.flow_type_rss_offloads & RTE_ETH_RSS_IP) != 0;
-	std::cerr << "\tDetected RSS offload capability: " << (m_supportedRSS ? "yes" : "no")
-			  << std::endl;
+	if (m_rxQueueCount > 1) {
+		m_supportedRSS = (rteDevInfo.flow_type_rss_offloads & RTE_ETH_RSS_IP) != 0;
+		std::cerr << "\tDetected RSS offload capability: " << (m_supportedRSS ? "yes" : "no")
+					  << std::endl;
+	} else {
+		m_supportedRSS = false;
+	}
 
 	/* Check if HW timestamps are supported, we support NFB cards only */
 	if (m_isNfbDpdkDriver) {
@@ -241,12 +248,19 @@ rte_eth_rss_conf DpdkDevice::createRSSConfig()
 			return hashKey[idx++ % sizeof(hashKey)];
 		});
 
-	const uint64_t rssOffloads = rteDevInfo.flow_type_rss_offloads & RTE_ETH_RSS_IP;
-	if (rssOffloads != RTE_ETH_RSS_IP) {
-		std::cerr << "RTE_ETH_RSS_IP is not supported by the card. Used subset: " << rssOffloads
-				  << std::endl;
+	uint64_t rssOffloads = 0;
+	if (m_rssOffload) {
+		rssOffloads = m_rssOffload;
+	} else {
+		rssOffloads = rteDevInfo.flow_type_rss_offloads & RTE_ETH_RSS_IP;
+		if (rssOffloads != RTE_ETH_RSS_IP) {
+			std::cerr << "RTE_ETH_RSS_IP is not supported by the card. Used subset: " << rssOffloads
+					  << std::endl;
+		}
 	}
 
+	std::cerr << "RSS offloads: " << rssOffloads << std::endl;
+
 	rssConfig.rss_key = m_hashKey.data();
 	rssConfig.rss_key_len = rssHashKeySize;
 	rssConfig.rss_hf = rssOffloads;

src/plugins/input/dpdk/src/dpdkDevice.hpp

@@ -48,13 +48,15 @@ class DpdkDevice {
 	 * @param memPoolSize The size of the memory pool for packet buffers.
 	 * @param mbufsCount The number of mbufs (packet buffers) to be allocated.
 	 * @param mtuSize Maximum transmission unit of input interface.
+	 * @param rssOffload RSS offload value. 0 for subset of RTE_ETH_RSS_IP.
 	 */
 	DpdkDevice(
 		uint16_t portID,
 		uint16_t rxQueueCount,
 		uint16_t memPoolSize,
 		uint16_t mbufsCount,
-		uint16_t mtuSize);
+		uint16_t mtuSize,
+		uint64_t rssOffload);
 
 	/**
 	 * @brief Receives packets from the specified receive queue of the DPDK device.
@@ -102,6 +104,7 @@ class DpdkDevice {
 	int m_rxTimestampOffset;
 	int m_rxTimestampDynflag;
 	uint16_t m_mtuSize;
+	uint64_t m_rssOffload = 0;
 };
 
 } // namespace ipxp