* [dts] [PATCH V1 2/2] tests/rte_flow_common: add function for cvl_advanced_iavf_rss
@ 2020-06-02 11:42 Zeng Xiaoxiao
2020-06-02 3:26 ` He, Zhiwei
0 siblings, 1 reply; 2+ messages in thread
From: Zeng Xiaoxiao @ 2020-06-02 11:42 UTC (permalink / raw)
To: dts; +Cc: Zeng Xiaoxiao
Signed-off-by: Zeng Xiaoxiao <xiaoxiaox.zeng@intel.com>
---
tests/rte_flow_common.py | 66 ++++++++++++++++++++++++++++++++++++++++
1 file changed, 66 insertions(+)
diff --git a/tests/rte_flow_common.py b/tests/rte_flow_common.py
index be0e434..0c4a13a 100644
--- a/tests/rte_flow_common.py
+++ b/tests/rte_flow_common.py
@@ -473,3 +473,69 @@ def find_queueid_rxpackets_list(id, q_rx_list):
if (int(item[0]) == id):
return int(item[1])
return 0
+
+def check_iavf_packets_rss_queue(out, count, rss_match=True):
+ """
+ check each queue has receive packets
+ """
+ out = out.split("Forward statistics for port 0")[0]
+ lines = out.split("\r\n")
+ queue_flag = 0
+ packet_sumnum = 0
+
+ for line in lines:
+ line = line.strip()
+ if "Forward Stats" in line.strip():
+ result_scanner = r"RX Port= \d+/Queue=\s?([0-9]+)"
+ scanner = re.compile(result_scanner, re.DOTALL)
+ m = scanner.search(line)
+ queue_num = m.group(1)
+ if queue_num is not None:
+ queue_flag = queue_flag + 1
+
+ elif line.strip().startswith("RX-packets"):
+ result_scanner = r"RX-packets:\s?([0-9]+)"
+ scanner = re.compile(result_scanner, re.DOTALL)
+ m = scanner.search(line)
+ packet_num = m.group(1)
+ if len(packet_num) != 0:
+ packet_sumnum = packet_sumnum + int(packet_num)
+
+ if rss_match:
+ if queue_flag >= 10 and packet_sumnum == count:
+ log_msg = "Packets has send to %s queues" % queue_flag
+ return True, log_msg
+ else:
+ log_msg = "Packets not send to different queues"
+ return False, log_msg
+ else:
+ if queue_flag == 1 and packet_sumnum == count:
+ log_msg = "Packets not match rule"
+ return True, log_msg
+ else:
+ log_msg = "Packets send to different queues"
+ return False, log_msg
+
+
+def check_pf_rss_queue(out, count):
+ """
+ check each queue has receive packets
+ """
+ lines = out.split("\r\n")
+ queue_num = []
+ packet_sumnum = 0
+
+ for line in lines:
+ line = line.strip()
+ if "_packets" in line.strip():
+ result_scanner = r"rx_queue_\d+_packets:\s?(\d+)"
+ scanner = re.compile(result_scanner, re.DOTALL)
+ m = scanner.search(line)
+ queue_pkg = m.group(1)
+ queue_num.append(queue_pkg)
+ packet_sumnum = packet_sumnum + int(queue_pkg)
+
+ if packet_sumnum == count and len(queue_num) == 10:
+ return True
+ else:
+ return False
\ No newline at end of file
--
2.17.1
^ permalink raw reply [flat|nested] 2+ messages in thread* Re: [dts] [PATCH V1 2/2] tests/rte_flow_common: add function for cvl_advanced_iavf_rss
2020-06-02 11:42 [dts] [PATCH V1 2/2] tests/rte_flow_common: add function for cvl_advanced_iavf_rss Zeng Xiaoxiao
@ 2020-06-02 3:26 ` He, Zhiwei
0 siblings, 0 replies; 2+ messages in thread
From: He, Zhiwei @ 2020-06-02 3:26 UTC (permalink / raw)
To: Zeng, XiaoxiaoX, dts; +Cc: Zeng, XiaoxiaoX
Acked-by Zhiwei.he <zhiwei.he@intel.com>
-----Original Message-----
From: dts <dts-bounces@dpdk.org> On Behalf Of Zeng Xiaoxiao
Sent: Tuesday, June 2, 2020 7:42 PM
To: dts@dpdk.org
Cc: Zeng, XiaoxiaoX <xiaoxiaox.zeng@intel.com>
Subject: [dts] [PATCH V1 2/2] tests/rte_flow_common: add function for cvl_advanced_iavf_rss
Signed-off-by: Zeng Xiaoxiao <xiaoxiaox.zeng@intel.com>
---
tests/rte_flow_common.py | 66 ++++++++++++++++++++++++++++++++++++++++
1 file changed, 66 insertions(+)
diff --git a/tests/rte_flow_common.py b/tests/rte_flow_common.py index be0e434..0c4a13a 100644
--- a/tests/rte_flow_common.py
+++ b/tests/rte_flow_common.py
@@ -473,3 +473,69 @@ def find_queueid_rxpackets_list(id, q_rx_list):
if (int(item[0]) == id):
return int(item[1])
return 0
+
+def check_iavf_packets_rss_queue(out, count, rss_match=True):
+ """
+ check each queue has receive packets
+ """
+ out = out.split("Forward statistics for port 0")[0]
+ lines = out.split("\r\n")
+ queue_flag = 0
+ packet_sumnum = 0
+
+ for line in lines:
+ line = line.strip()
+ if "Forward Stats" in line.strip():
+ result_scanner = r"RX Port= \d+/Queue=\s?([0-9]+)"
+ scanner = re.compile(result_scanner, re.DOTALL)
+ m = scanner.search(line)
+ queue_num = m.group(1)
+ if queue_num is not None:
+ queue_flag = queue_flag + 1
+
+ elif line.strip().startswith("RX-packets"):
+ result_scanner = r"RX-packets:\s?([0-9]+)"
+ scanner = re.compile(result_scanner, re.DOTALL)
+ m = scanner.search(line)
+ packet_num = m.group(1)
+ if len(packet_num) != 0:
+ packet_sumnum = packet_sumnum + int(packet_num)
+
+ if rss_match:
+ if queue_flag >= 10 and packet_sumnum == count:
+ log_msg = "Packets has send to %s queues" % queue_flag
+ return True, log_msg
+ else:
+ log_msg = "Packets not send to different queues"
+ return False, log_msg
+ else:
+ if queue_flag == 1 and packet_sumnum == count:
+ log_msg = "Packets not match rule"
+ return True, log_msg
+ else:
+ log_msg = "Packets send to different queues"
+ return False, log_msg
+
+
+def check_pf_rss_queue(out, count):
+ """
+ check each queue has receive packets
+ """
+ lines = out.split("\r\n")
+ queue_num = []
+ packet_sumnum = 0
+
+ for line in lines:
+ line = line.strip()
+ if "_packets" in line.strip():
+ result_scanner = r"rx_queue_\d+_packets:\s?(\d+)"
+ scanner = re.compile(result_scanner, re.DOTALL)
+ m = scanner.search(line)
+ queue_pkg = m.group(1)
+ queue_num.append(queue_pkg)
+ packet_sumnum = packet_sumnum + int(queue_pkg)
+
+ if packet_sumnum == count and len(queue_num) == 10:
+ return True
+ else:
+ return False
\ No newline at end of file
--
2.17.1
^ permalink raw reply [flat|nested] 2+ messages in thread
end of thread, other threads:[~2020-06-02 3:26 UTC | newest]
Thread overview: 2+ messages (download: mbox.gz / follow: Atom feed)
-- links below jump to the message on this page --
2020-06-02 11:42 [dts] [PATCH V1 2/2] tests/rte_flow_common: add function for cvl_advanced_iavf_rss Zeng Xiaoxiao
2020-06-02 3:26 ` He, Zhiwei
This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox;
as well as URLs for NNTP newsgroup(s).