From patchwork Mon Jan 17 15:41:03 2022 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: "Xu, HailinX" X-Patchwork-Id: 105910 Return-Path: X-Original-To: patchwork@inbox.dpdk.org Delivered-To: patchwork@inbox.dpdk.org Received: from mails.dpdk.org (mails.dpdk.org [217.70.189.124]) by inbox.dpdk.org (Postfix) with ESMTP id B1703A0353; Mon, 17 Jan 2022 09:12:40 +0100 (CET) Received: from [217.70.189.124] (localhost [127.0.0.1]) by mails.dpdk.org (Postfix) with ESMTP id A8C8341168; Mon, 17 Jan 2022 09:12:40 +0100 (CET) Received: from mga11.intel.com (mga11.intel.com [192.55.52.93]) by mails.dpdk.org (Postfix) with ESMTP id 2B8314067B for ; Mon, 17 Jan 2022 09:12:39 +0100 (CET) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/simple; d=intel.com; i=@intel.com; q=dns/txt; s=Intel; t=1642407159; x=1673943159; h=from:to:cc:subject:date:message-id:in-reply-to: references; bh=gemAShK7h0avCQIzKLe1rffXbiwhVVATkRH1dmZYgsI=; b=NA59IUHbgLRBZElLXc0IdOoCAq0NuRU8D9+r7niKa01sbfnHnNUGp9Tl bBn0MD0nElvkfZz8+KF/p4Jfw0qhkk63pYme04sQsS3WQQSXpq/SK8DTV Nd7Fam1HdZsa5HKTlE3pd3OjpYu+1ywinwLBV8KtunVZv8xX5YqOZEA40 Wr//KN0zgqDlubIQZ+Ip57Mi06vb4zohqPcJ38WB1dCytcoDfM4d4taEn 1As99WOIXGYsffxm+RolWS207ADI0Z7q/yBcMRYW3FKudxcXFvOehov/6 u52DKDdAgUSG5A0zDVID21A+0GDD3no5qIOVGOG+6dQnmUcbh8iuqYK3i w==; X-IronPort-AV: E=McAfee;i="6200,9189,10229"; a="242135323" X-IronPort-AV: E=Sophos;i="5.88,295,1635231600"; d="scan'208";a="242135323" Received: from fmsmga001.fm.intel.com ([10.253.24.23]) by fmsmga102.fm.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384; 17 Jan 2022 00:12:38 -0800 X-IronPort-AV: E=Sophos;i="5.88,295,1635231600"; d="scan'208";a="671486930" Received: from unknown (HELO localhost.localdomain) ([10.239.251.69]) by fmsmga001-auth.fm.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384; 17 Jan 2022 00:12:37 -0800 From: Hailin Xu To: qi.fu@intel.com, dts@dpdk.org Cc: Hailin Xu Subject: [dts][PATCH v2 1/2] tests/rte_flow_common: add priority common interface Date: Mon, 17 Jan 2022 23:41:03 +0800 Message-Id: <20220117154104.25824-2-hailinx.xu@intel.com> X-Mailer: git-send-email 2.17.1 In-Reply-To: <20220117154104.25824-1-hailinx.xu@intel.com> References: <20220117154104.25824-1-hailinx.xu@intel.com> X-BeenThere: dts@dpdk.org X-Mailman-Version: 2.1.29 Precedence: list List-Id: test suite reviews and discussions List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Errors-To: dts-bounces@dpdk.org add flow priority common interface Signed-off-by: Hailin Xu --- tests/rte_flow_common.py | 61 ++++++++++++++++++++++++++++++++++++++++ 1 file changed, 61 insertions(+) diff --git a/tests/rte_flow_common.py b/tests/rte_flow_common.py index 969d3222..1fca08ad 100644 --- a/tests/rte_flow_common.py +++ b/tests/rte_flow_common.py @@ -1297,3 +1297,64 @@ class FdirProcessing(object): if not v: failed_cases.append(k) self.verify(all(test_results.values()), "{} failed".format(failed_cases)) + + def send_pkt_get_out(self, pkts, port_id=0, count=1, interval=0): + tx_port = self.tester_ifaces[0] if port_id == 0 else self.tester_ifaces[1] + self.logger.info('----------send packet-------------') + self.logger.info('{}'.format(pkts)) + self.pmd_output.execute_cmd("start") + self.pmd_output.execute_cmd("clear port stats all") + self.pkt.update_pkt(pkts) + self.pkt.send_pkt(crb=self.test_case.tester, tx_port=tx_port, count=count, interval=interval) + + out1 = self.pmd_output.get_output(timeout=1) + out2 = self.pmd_output.execute_cmd("stop") + return out1 + out2 + + def check_rx_packets(self, out, check_param, expect_pkt, stats=True): + queue = check_param['queue'] + p = 'Forward\s+statistics\s+for\s+port\s+0.*\n.*?RX-packets:\s(\d+)\s+' + if queue == 'null': + pkt_num = re.search(p, out).group(1) + if stats: + self.verify(int(pkt_num) == 0, "receive %s packets, expect receive 0 packets" % pkt_num) + else: + self.verify(int(pkt_num) == expect_pkt, "receive {} packets, expect receive {} packets".format(pkt_num, expect_pkt)) + else: + check_queue(out, check_param, stats=stats) + + def handle_priority_cases(self, vectors): + rule = vectors['rule'] + packets = vectors['packet'] + check_param = vectors['check_param'] + self.validate_rule(rule) + rule_list = self.create_rule(rule) + self.check_rule(rule_list=rule_list) + out = self.send_pkt_get_out(packets['matched']) + self.check_rx_packets(out, check_param['check_0'], len(packets['matched'])) + out = self.send_pkt_get_out(packets['mismatched']) + self.check_rx_packets(out, check_param['check_0'], len(packets['mismatched']), stats=False) + + # destroy rule with priority 0 + self.destroy_rule(rule_id=rule_list[0]) + self.check_rule(rule_list=rule_list[1:]) + out = self.send_pkt_get_out(packets['matched']) + self.check_rx_packets(out, check_param['check_1'], len(packets['matched'])) + out = self.send_pkt_get_out(packets['mismatched']) + self.check_rx_packets(out, check_param['check_0'], len(packets['mismatched']), stats=False) + self.check_rx_packets(out, check_param['check_1'], len(packets['mismatched']), stats=False) + + # destroy rule with priority 1 + rule_id = self.create_rule(rule[0]) + self.destroy_rule(rule_id=rule_list[1]) + self.check_rule(rule_list=rule_id) + out = self.send_pkt_get_out(packets['matched']) + self.check_rx_packets(out, check_param['check_0'], len(packets['matched'])) + out = self.send_pkt_get_out(packets['mismatched']) + self.check_rx_packets(out, check_param['check_0'], len(packets['mismatched']), stats=False) + + # destroy all rule + self.destroy_rule(rule_id=rule_id) + out = self.send_pkt_get_out(packets['matched']) + self.check_rx_packets(out, check_param['check_0'], len(packets['matched']), stats=False) + self.check_rx_packets(out, check_param['check_1'], len(packets['matched']), stats=False) From patchwork Mon Jan 17 15:41:04 2022 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: "Xu, HailinX" X-Patchwork-Id: 105911 Return-Path: X-Original-To: patchwork@inbox.dpdk.org Delivered-To: patchwork@inbox.dpdk.org Received: from mails.dpdk.org (mails.dpdk.org [217.70.189.124]) by inbox.dpdk.org (Postfix) with ESMTP id 33D30A034F; Mon, 17 Jan 2022 09:12:44 +0100 (CET) Received: from [217.70.189.124] (localhost [127.0.0.1]) by mails.dpdk.org (Postfix) with ESMTP id 27FD841190; Mon, 17 Jan 2022 09:12:44 +0100 (CET) Received: from mga11.intel.com (mga11.intel.com [192.55.52.93]) by mails.dpdk.org (Postfix) with ESMTP id 4D1EF4067B for ; Mon, 17 Jan 2022 09:12:41 +0100 (CET) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/simple; d=intel.com; i=@intel.com; q=dns/txt; s=Intel; t=1642407161; x=1673943161; h=from:to:cc:subject:date:message-id:in-reply-to: references; bh=sZtGZ+lnWNy8ZeRy/J0wF2T7VqNTGFv/DebjZzfXGFY=; b=ZfeoWikj8YKT8lpX8PjOG1Zbj71EpAZbKGRbvG1nT9r447DXVuPE5B9q 6d+3P5nRTKY99x8mN9Iu2FrOJOpmXD8rd9q/UVeRSdV3JQ4yAg5w8OdzW LH+pj8HvuP3MJQQ6xTGvau1zJDXCEV2rv30MjBzyK2gFMmn6qH5cPFjUE Btgu/gFjjPo8ivywRTSMbX3XZ3RkZk9mygky9FkHOadsoDP0HygowXouD SaJgob21k1cHPtYXa0puMKaj6Fm3RTLQKmcPik2jhwBw9tSGNMH8avQDK tWEobbYpJ4OG/XLcaWTBwaJTIUR8nhZRtSkHAcCPf9MmE6Uj/J2EQgH5/ A==; X-IronPort-AV: E=McAfee;i="6200,9189,10229"; a="242135331" X-IronPort-AV: E=Sophos;i="5.88,295,1635231600"; d="scan'208";a="242135331" Received: from fmsmga001.fm.intel.com ([10.253.24.23]) by fmsmga102.fm.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384; 17 Jan 2022 00:12:40 -0800 X-IronPort-AV: E=Sophos;i="5.88,295,1635231600"; d="scan'208";a="671486950" Received: from unknown (HELO localhost.localdomain) ([10.239.251.69]) by fmsmga001-auth.fm.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384; 17 Jan 2022 00:12:39 -0800 From: Hailin Xu To: qi.fu@intel.com, dts@dpdk.org Cc: Hailin Xu Subject: [dts][PATCH v2 2/2] tests/cvl_flow_priority: add pf flow priority cases Date: Mon, 17 Jan 2022 23:41:04 +0800 Message-Id: <20220117154104.25824-3-hailinx.xu@intel.com> X-Mailer: git-send-email 2.17.1 In-Reply-To: <20220117154104.25824-1-hailinx.xu@intel.com> References: <20220117154104.25824-1-hailinx.xu@intel.com> X-BeenThere: dts@dpdk.org X-Mailman-Version: 2.1.29 Precedence: list List-Id: test suite reviews and discussions List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Errors-To: dts-bounces@dpdk.org add cvl pf flow priority cases Signed-off-by: Hailin Xu Tested-by: Xu Hailin Acked-by: Qi Fu Tested-by: Zhimin Huang --- tests/TestSuite_cvl_flow_priority.py | 555 ++++++++++++++++++++++++ 1 file changed, 555 insertions(+) create mode 100644 tests/TestSuite_cvl_flow_priority.py diff --git a/tests/TestSuite_cvl_flow_priority.py b/tests/TestSuite_cvl_flow_priority.py new file mode 100644 index 00000000..1abc9f1c --- /dev/null +++ b/tests/TestSuite_cvl_flow_priority.py @@ -0,0 +1,555 @@ +# BSD LICENSE +# +# Copyright(c) 2021 Intel Corporation. All rights reserved. +# All rights reserved. +# +# Redistribution and use in source and binary forms, with or without +# modification, are permitted provided that the following conditions +# are met: +# +# * Redistributions of source code must retain the above copyright +# notice, this list of conditions and the following disclaimer. +# * Redistributions in binary form must reproduce the above copyright +# notice, this list of conditions and the following disclaimer in +# the documentation and/or other materials provided with the +# distribution. +# * Neither the name of Intel Corporation nor the names of its +# contributors may be used to endorse or promote products derived +# from this software without specific prior written permission. +# +# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS +# "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT +# LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR +# A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT +# OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, +# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT +# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, +# DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY +# THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT +# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE +# OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + +import json +import time +import re +import copy + +from framework.test_case import TestCase, skip_unsupported_pkg, check_supported_nic +from framework.pmd_output import PmdOutput +from framework.packet import Packet +from .rte_flow_common import FdirProcessing, check_drop + +tv_mac_ipv4_pay = { + 'name': 'tv_mac_ipv4_pay', + 'rule': ['flow create 0 priority 0 ingress pattern eth dst is 68:05:ca:8d:ed:a8 / ipv4 src is 192.168.0.1 dst is 192.168.0.2 tos is 4 ttl is 2 / end actions queue index 1 / end', + 'flow create 0 priority 1 ingress pattern eth dst is 68:05:ca:8d:ed:a8 / ipv4 src is 192.168.0.1 dst is 192.168.0.2 tos is 4 ttl is 2 / end actions queue index 4 / end'], + 'packet': { + 'matched': ['Ether(dst="68:05:ca:8d:ed:a8")/IP(src="192.168.0.1",dst="192.168.0.2",tos=4,ttl=2)/("X"*480)'], + 'mismatched': ['Ether(dst="68:05:ca:8d:ed:a1")/IP(src="192.168.0.1",dst="192.168.0.2",tos=4,ttl=2)/("X"*480)', + 'Ether(dst="68:05:ca:8d:ed:a8")/IP(src="192.168.0.3",dst="192.168.0.2",tos=4,ttl=2)/("X"*480)', + 'Ether(dst="68:05:ca:8d:ed:a8")/IP(src="192.168.0.1",dst="192.168.0.7",tos=4,ttl=2)/("X"*480)', + 'Ether(dst="68:05:ca:8d:ed:a8")/IP(src="192.168.0.1",dst="192.168.0.2",tos=5,ttl=2)/("X"*480)', + 'Ether(dst="68:05:ca:8d:ed:a8")/IP(src="192.168.0.1",dst="192.168.0.2",tos=4,ttl=9)/("X"*480)']}, + 'check_param': { + 'check_0': {'queue': 1}, + 'check_1': {'queue': 4},} +} + +tv_mac_ipv4_udp_pay = { + 'name': 'tv_mac_ipv4_udp_pay', + 'rule': ['flow create 0 priority 0 ingress pattern eth / ipv4 src is 192.168.0.2 dst is 192.168.0.3 tos is 4 / udp src is 50 dst is 23 / end actions rss queues 4 5 end / end', + 'flow create 0 priority 1 ingress pattern eth / ipv4 src is 192.168.0.2 dst is 192.168.0.3 tos is 4 / udp src is 50 dst is 23 / end actions queue index 2 / end'], + 'packet': { + 'matched': ['Ether()/IP(src="192.168.0.2",dst="192.168.0.3",tos=4)/UDP(sport=50,dport=23)/Raw("x"*80)'], + 'mismatched': ['Ether()/IP(src="192.168.0.5",dst="192.168.0.3",tos=4)/UDP(sport=50,dport=23)/Raw("x"*80)', + 'Ether()/IP(src="192.168.0.2",dst="192.168.0.7",tos=4)/UDP(sport=50,dport=23)/Raw("x"*80)', + 'Ether()/IP(src="192.168.0.2",dst="192.168.0.3",tos=5)/UDP(sport=50,dport=23)/Raw("x"*80)', + 'Ether()/IP(src="192.168.0.2",dst="192.168.0.3",tos=4)/UDP(sport=2,dport=23)/Raw("x"*80)', + 'Ether()/IP(src="192.168.0.2",dst="192.168.0.3",tos=4)/UDP(sport=50,dport=3)/Raw("x"*80)']}, + 'check_param': { + 'check_0': {'queue': [4, 5]}, + 'check_1': {'queue': 2}} +} + +tv_mac_ipv6 = { + 'name': 'tv_mac_ipv6', + 'rule': ['flow create 0 priority 0 ingress pattern eth / ipv6 src is CDCD:910A:2222:5498:8475:1111:3900:1536 dst is CDCD:910A:2222:5498:8475:1111:3900:2020 / end actions rss queues 4 5 end / end', + 'flow create 0 priority 1 ingress pattern eth / ipv6 src is CDCD:910A:2222:5498:8475:1111:3900:1536 dst is CDCD:910A:2222:5498:8475:1111:3900:2020 / end actions queue index 8 / end'], + 'packet': { + 'matched': ['Ether()/IPv6(src="CDCD:910A:2222:5498:8475:1111:3900:1536", dst="CDCD:910A:2222:5498:8475:1111:3900:2020")/("X"*480)', + ], + 'mismatched': ['Ether()/IPv6(src="CDCD:910A:2222:5498:8475:1111:3900:1537", dst="CDCD:910A:2222:5498:8475:1111:3900:2020")/("X"*480)', + 'Ether()/IPv6(src="CDCD:910A:2222:5498:8475:1111:3900:1536", dst="CDCD:910A:2222:5498:8475:1111:3900:2023")/("X"*480)', + 'Ether()/IPv6(src="CDCD:910A:2222:5498:8475:1111:3900:1537", dst="CDCD:910A:2222:5498:8475:1111:3900:2020")/IPv6ExtHdrFragment()/("X"*480)', + 'Ether()/IPv6(src="CDCD:910A:2222:5498:8475:1111:3900:1536", dst="CDCD:910A:2222:5498:8475:1111:3900:2023")/IPv6ExtHdrFragment()/("X"*480)']}, + 'check_param': { + 'check_0': {'queue': [4, 5]}, + 'check_1': {'queue': 8}} +} + +tv_mac_ipv6_tcp = { + 'name': 'tv_mac_ipv6_tcp', + 'rule': ['flow create 0 priority 0 ingress pattern eth / ipv6 dst is CDCD:910A:2222:5498:8475:1111:3900:2020 tc is 3 / tcp src is 25 dst is 23 / end actions rss queues 4 5 end / end', + 'flow create 0 priority 1 ingress pattern eth / ipv6 dst is CDCD:910A:2222:5498:8475:1111:3900:2020 tc is 3 / tcp src is 25 dst is 23 / end actions queue index 3 / end'], + 'packet': { + 'matched': ['Ether()/IPv6(src="CDCD:910A:2222:5498:8475:1111:3900:1515",dst="CDCD:910A:2222:5498:8475:1111:3900:2020",tc=3)/TCP(sport=25,dport=23)/Raw("x"*80)'], + 'mismatched': ['Ether()/IPv6(src="CDCD:910A:2222:5498:8475:1111:3900:1515",dst="CDCD:910A:2222:5498:8475:1111:3900:2023",tc=3)/TCP(sport=25,dport=23)/Raw("x"*80)', + 'Ether()/IPv6(src="CDCD:910A:2222:5498:8475:1111:3900:1515",dst="CDCD:910A:2222:5498:8475:1111:3900:2020",tc=7)/TCP(sport=25,dport=23)/Raw("x"*80)', + 'Ether()/IPv6(src="CDCD:910A:2222:5498:8475:1111:3900:1515",dst="CDCD:910A:2222:5498:8475:1111:3900:2020",tc=3)/TCP(sport=1,dport=23)/Raw("x"*80)', + 'Ether()/IPv6(src="CDCD:910A:2222:5498:8475:1111:3900:1515",dst="CDCD:910A:2222:5498:8475:1111:3900:2020",tc=3)/TCP(sport=25,dport=20)/Raw("x"*80)'] + }, + 'check_param': { + 'check_0': {'queue': [4, 5]}, + 'check_1': {'queue': 3}}, +} + +tv_mac_ipv4_vxlan_ipv4_frag = { + 'name': 'tv_mac_ipv4_vxlan_ipv4_frag', + 'rule': ['flow create 0 priority 0 ingress pattern eth / ipv4 / udp / vxlan / eth / ipv4 src is 192.168.0.2 dst is 192.168.0.3 / end actions rss queues 2 3 end / end', + 'flow create 0 priority 1 ingress pattern eth / ipv4 / udp / vxlan / eth / ipv4 src is 192.168.0.2 dst is 192.168.0.3 / end actions queue index 5 / end'], + 'packet': { + 'matched': ['Ether()/IP()/UDP()/VXLAN()/Ether()/IP(src="192.168.0.2", dst="192.168.0.3",frag=5)/Raw("x"*80)'], + 'mismatched': ['Ether()/IP()/UDP()/VXLAN()/Ether()/IP(src="192.168.0.4", dst="192.168.0.3",frag=5)/Raw("x"*80)', + 'Ether()/IP()/UDP()/VXLAN()/Ether()/IP(src="192.168.0.2", dst="192.168.0.5",frag=5)/Raw("x"*80)', + ]}, + 'check_param': { + 'check_0': {'queue': [2, 3]}, + 'check_1': {'queue': 5}} +} + +tv_mac_ipv4_vxlan_ipv4_pay = { + 'name': 'tv_mac_ipv4_vxlan_ipv4_pay', + 'rule': ['flow create 0 priority 0 ingress pattern eth / ipv4 / udp / vxlan / eth / ipv4 src is 192.168.0.2 dst is 192.168.0.3 / end actions queue index 5 / end', + 'flow create 0 priority 1 ingress pattern eth / ipv4 / udp / vxlan / eth / ipv4 src is 192.168.0.2 dst is 192.168.0.3 / end actions rss queues 2 3 end / end'], + 'packet': { + 'matched': ['Ether()/IP()/UDP()/VXLAN()/Ether()/IP(src="192.168.0.2", dst="192.168.0.3")/Raw("x"*80)', + 'Ether()/IP()/UDP()/VXLAN()/Ether()/IP(src="192.168.0.2", dst="192.168.0.3")/TCP()/Raw("x"*80)'], + 'mismatched': ['Ether()/IP()/UDP()/VXLAN()/Ether()/IP(src="192.168.0.5", dst="192.168.0.3")/Raw("x"*80)', + 'Ether()/IP()/UDP()/VXLAN()/Ether()/IP(src="192.168.0.2", dst="192.168.0.7")/Raw("x"*80)', + 'Ether()/IP()/UDP()/VXLAN()/Ether()/IP(src="192.168.0.5", dst="192.168.0.3")/TCP()/Raw("x"*80)', + 'Ether()/IP()/UDP()/VXLAN()/Ether()/IP(src="192.168.0.2", dst="192.168.0.7")/TCP()/Raw("x"*80)', + ]}, + 'check_param': { + 'check_0': {'queue': 5}, + 'check_1': {'queue': [2, 3]}} +} + +tv_mac_ipv4_nvgre_ipv4_udp_pay = { + 'name': 'tv_mac_ipv4_nvgre_ipv4_udp_pay', + 'rule': ['flow create 0 priority 0 ingress pattern eth / ipv4 dst is 192.168.0.1 / nvgre tni is 0x8 / eth dst is 68:05:ca:8d:ed:a8 / ipv4 src is 192.168.1.2 dst is 192.168.1.3 / udp src is 25 dst is 23 / end actions rss queues 2 3 end / end', + 'flow create 0 priority 1 ingress pattern eth / ipv4 dst is 192.168.0.1 / nvgre tni is 0x8 / eth dst is 68:05:ca:8d:ed:a8 / ipv4 src is 192.168.1.2 dst is 192.168.1.3 / udp src is 25 dst is 23 / end actions queue index 4 / end'], + 'packet': { + 'matched': ['Ether()/IP(dst="192.168.0.1")/NVGRE(TNI=0x8)/Ether(dst="68:05:ca:8d:ed:a8")/IP(src="192.168.1.2", dst="192.168.1.3")/UDP(sport=25,dport=23)/Raw("x"*80)'], + 'mismatched': ['Ether()/IP(dst="192.168.0.2")/NVGRE(TNI=0x8)/Ether(dst="68:05:ca:8d:ed:a8")/IP(src="192.168.1.2", dst="192.168.1.3")/UDP(sport=25,dport=23)/Raw("x"*80)', + 'Ether()/IP(dst="192.168.0.1")/NVGRE(TNI=0x1)/Ether(dst="68:05:ca:8d:ed:a8")/IP(src="192.168.1.2", dst="192.168.1.3")/UDP(sport=25,dport=23)/Raw("x"*80)', + 'Ether()/IP(dst="192.168.0.1")/NVGRE(TNI=0x8)/Ether(dst="68:05:ca:8d:ed:a3")/IP(src="192.168.1.2", dst="192.168.1.3")/UDP(sport=25,dport=23)/Raw("x"*80)', + 'Ether()/IP(dst="192.168.0.1")/NVGRE(TNI=0x8)/Ether(dst="68:05:ca:8d:ed:a8")/IP(src="192.168.1.5", dst="192.168.1.3")/UDP(sport=25,dport=23)/Raw("x"*80)', + 'Ether()/IP(dst="192.168.0.1")/NVGRE(TNI=0x8)/Ether(dst="68:05:ca:8d:ed:a8")/IP(src="192.168.1.2", dst="192.168.1.7")/UDP(sport=25,dport=23)/Raw("x"*80)', + 'Ether()/IP(dst="192.168.0.1")/NVGRE(TNI=0x8)/Ether(dst="68:05:ca:8d:ed:a8")/IP(src="192.168.1.2", dst="192.168.1.3")/UDP(sport=2,dport=23)/Raw("x"*80)', + 'Ether()/IP(dst="192.168.0.1")/NVGRE(TNI=0x8)/Ether(dst="68:05:ca:8d:ed:a8")/IP(src="192.168.1.2", dst="192.168.1.3")/UDP(sport=25,dport=20)/Raw("x"*80)']}, + 'check_param': { + 'check_0': {'queue': [2, 3]}, + 'check_1': {'queue': 4}} +} + +tv_mac_ipv4_nvgre_ipv4_tcp = { + 'name': 'tv_mac_ipv4_nvgre_ipv4_tcp', + 'rule': ['flow create 0 priority 0 ingress pattern eth / ipv4 dst is 192.168.0.1 / nvgre tni is 2 / eth dst is 68:05:ca:8d:ed:a8 / ipv4 src is 192.168.1.2 dst is 192.168.1.3 / tcp src is 25 dst is 23 / end actions queue index 5 / end', + 'flow create 0 priority 1 ingress pattern eth / ipv4 dst is 192.168.0.1 / nvgre tni is 2 / eth dst is 68:05:ca:8d:ed:a8 / ipv4 src is 192.168.1.2 dst is 192.168.1.3 / tcp src is 25 dst is 23 / end actions rss queues 2 3 end / end'], + 'packet': { + 'matched': ['Ether()/IP(dst="192.168.0.1")/NVGRE(TNI=2)/Ether(dst="68:05:ca:8d:ed:a8")/IP(src="192.168.1.2", dst="192.168.1.3")/TCP(sport=25,dport=23)/Raw("x"*80)'], + 'mismatched': ['Ether()/IP(dst="192.168.0.2")/NVGRE(TNI=2)/Ether(dst="68:05:ca:8d:ed:a8")/IP(src="192.168.1.2", dst="192.168.1.3")/TCP(sport=25,dport=23)/Raw("x"*80)', + 'Ether()/IP(dst="192.168.0.1")/NVGRE(TNI=3)/Ether(dst="68:05:ca:8d:ed:a8")/IP(src="192.168.1.2", dst="192.168.1.3")/TCP(sport=25,dport=23)/Raw("x"*80)', + 'Ether()/IP(dst="192.168.0.1")/NVGRE(TNI=2)/Ether(dst="68:05:ca:8d:ed:a3")/IP(src="192.168.1.2", dst="192.168.1.3")/TCP(sport=25,dport=23)/Raw("x"*80)', + 'Ether()/IP(dst="192.168.0.1")/NVGRE(TNI=2)/Ether(dst="68:05:ca:8d:ed:a8")/IP(src="192.168.1.5", dst="192.168.1.3")/TCP(sport=25,dport=23)/Raw("x"*80)', + 'Ether()/IP(dst="192.168.0.1")/NVGRE(TNI=2)/Ether(dst="68:05:ca:8d:ed:a8")/IP(src="192.168.1.2", dst="192.168.1.7")/TCP(sport=25,dport=23)/Raw("x"*80)', + 'Ether()/IP(dst="192.168.0.1")/NVGRE(TNI=2)/Ether(dst="68:05:ca:8d:ed:a8")/IP(src="192.168.1.2", dst="192.168.1.3")/TCP(sport=1,dport=23)/Raw("x"*80)', + 'Ether()/IP(dst="192.168.0.1")/NVGRE(TNI=2)/Ether(dst="68:05:ca:8d:ed:a8")/IP(src="192.168.1.2", dst="192.168.1.3")/TCP(sport=25,dport=20)/Raw("x"*80)']}, + 'check_param': { + 'check_0': {'queue': 5}, + 'check_1': {'queue': [2, 3]}} +} + +tv_ethertype_filter_pppoed = { + 'name': 'tv_ethertype_filter_pppoed', + 'rule': ['flow create 0 priority 0 ingress pattern eth type is 0x8863 / end actions queue index 4 / end', + 'flow create 0 priority 1 ingress pattern eth type is 0x8863 / end actions queue index 2 / end'], + 'packet': { + 'matched': ['Ether(type=0x8863)/Raw("x" *80)', + 'Ether()/PPPoED()/Raw("x" *80)'], + 'mismatched': ['Ether(type=0x8864)/Raw("x" *80)', + 'Ether()/PPPoE()/Raw("x" *80)']}, + 'check_param': { + 'check_0': {'queue': 4}, + 'check_1': {'queue': 2}} +} + +tv_mac_vlan_pppoe_ipv4_pay_session_id_proto_id = { + 'name': 'tv_mac_vlan_pppoe_ipv4_pay_session_id_proto_id', + 'rule': ['flow create 0 priority 0 ingress pattern eth dst is 00:11:22:33:44:55 / vlan tci is 1 / pppoes seid is 3 / pppoe_proto_id is 0x0021 / end actions queue index 1 / end', + 'flow create 0 priority 1 ingress pattern eth dst is 00:11:22:33:44:55 / vlan tci is 1 / pppoes seid is 3 / pppoe_proto_id is 0x0021 / end actions queue index 2 / end'], + 'packet': { + 'matched': ['Ether(dst="00:11:22:33:44:55",type=0x8100)/Dot1Q(vlan=1,type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x00\\x21\')/IP()/Raw("x"*80)'], + 'mismatched': ['Ether(dst="00:11:22:33:44:54",type=0x8100)/Dot1Q(vlan=1,type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x00\\x21\')/IP()/Raw("x" * 80)', + 'Ether(dst="00:11:22:33:44:55",type=0x8100)/Dot1Q(vlan=2,type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x00\\x21\')/IP()/Raw("x" * 80)', + 'Ether(dst="00:11:22:33:44:55",type=0x8100)/Dot1Q(vlan=1,type=0x8864)/PPPoE(sessionid=4)/PPP(b\'\\x00\\x21\')/IP()/Raw("x" * 80)', + 'Ether(dst="00:11:22:33:44:55",type=0x8100)/Dot1Q(vlan=1,type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x00\\x21\')/IPv6()/Raw("x" * 80)']}, + 'check_param': { + 'check_0': {'queue': 1}, + 'check_1': {'queue': 2}} +} + +tv_mac_vlan_pppoe_ipv6_pay_session_id_proto_id = { + 'name': 'tv_mac_vlan_pppoe_ipv6_pay_session_id_proto_id', + 'rule': ['flow create 0 priority 0 ingress pattern eth dst is 00:11:22:33:44:55 / vlan tci is 1 / pppoes seid is 3 / pppoe_proto_id is 0x0057 / end actions queue index 1 / end', + 'flow create 0 priority 1 ingress pattern eth dst is 00:11:22:33:44:55 / vlan tci is 1 / pppoes seid is 3 / pppoe_proto_id is 0x0057 / end actions queue index 2 / end'], + 'packet': { + 'matched': ['Ether(dst="00:11:22:33:44:55",type=0x8100)/Dot1Q(vlan=1,type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x00\\x57\')/IPv6()/Raw("x" * 80)'], + 'mismatched': ['Ether(dst="00:11:22:33:44:54",type=0x8100)/Dot1Q(vlan=1,type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x00\\x57\')/IPv6()/Raw("x" * 80)', + 'Ether(dst="00:11:22:33:44:55",type=0x8100)/Dot1Q(vlan=2,type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x00\\x57\')/IPv6()/Raw("x" * 80)', + 'Ether(dst="00:11:22:33:44:55",type=0x8100)/Dot1Q(vlan=1,type=0x8864)/PPPoE(sessionid=4)/PPP(b\'\\x00\\x57\')/IPv6()/Raw("x" * 80)', + 'Ether(dst="00:11:22:33:44:55",type=0x8100)/Dot1Q(vlan=1,type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x00\\x57\')/IP()/Raw("x" * 80)']}, + 'check_param': { + 'check_0': {'queue': 1}, + 'check_1': {'queue': 2}} +} + +tv_mac_pppoe_ipv4_pay_ip_address = { + 'name': 'tv_mac_pppoe_ipv4_pay_ip_address', + 'rule': ['flow create 0 priority 0 ingress pattern eth / pppoes / ipv4 src is 192.168.1.1 dst is 192.168.1.2 / end actions queue index 1 / end', + 'flow create 0 priority 1 ingress pattern eth / pppoes / ipv4 src is 192.168.1.1 dst is 192.168.1.2 / end actions queue index 2 / end'], + 'packet': { + 'matched': ['Ether(dst="00:11:22:33:44:55",type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x00\\x21\')/IP(src="192.168.1.1", dst="192.168.1.2")/Raw("x"*80)'], + 'mismatched': ['Ether(dst="00:11:22:33:44:55",type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x00\\x21\')/IP(src="192.168.1.3", dst="192.168.1.2")/Raw("x"*80)', + 'Ether(dst="00:11:22:33:44:55",type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x00\\x21\')/IP(src="192.168.1.1", dst="192.168.1.4")/Raw("x"*80)']}, + 'check_param': { + 'check_0': {'queue': 1}, + 'check_1': {'queue': 2}} +} + +tv_mac_pppoe_ipv6_udp_pay = { + 'name': 'tv_mac_pppoe_ipv6_udp_pay', + 'rule': ['flow create 0 priority 0 ingress pattern eth / pppoes / ipv6 dst is CDCD:910A:2222:5498:8475:1111:3900:2022 / udp src is 25 dst is 23 / end actions queue index 1 / end', + 'flow create 0 priority 1 ingress pattern eth / pppoes / ipv6 dst is CDCD:910A:2222:5498:8475:1111:3900:2022 / udp src is 25 dst is 23 / end actions queue index 2 / end'], + 'packet': { + 'matched': ['Ether(src="11:22:33:44:55:99",dst="00:11:22:33:44:55",type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x00\\x57\')/IPv6(src="CDCD:910A:2222:5498:8475:1111:3900:1536", dst="CDCD:910A:2222:5498:8475:1111:3900:2022")/UDP(sport=25,dport=23)/Raw("x" * 80)'], + 'mismatched': ['Ether(src="11:22:33:44:55:99",dst="00:11:22:33:44:55",type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x00\\x57\')/IPv6(src="CDCD:910A:2222:5498:8475:1111:3900:1536", dst="CDCD:910A:2222:5498:8475:1111:3900:2023")/UDP(sport=25,dport=23)/Raw("x" * 80)', + 'Ether(src="11:22:33:44:55:99",dst="00:11:22:33:44:55",type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x00\\x57\')/IPv6(src="CDCD:910A:2222:5498:8475:1111:3900:1536", dst="CDCD:910A:2222:5498:8475:1111:3900:2022")/UDP(sport=27,dport=23)/Raw("x" * 80)', + 'Ether(src="11:22:33:44:55:99",dst="00:11:22:33:44:55",type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x00\\x57\')/IPv6(src="CDCD:910A:2222:5498:8475:1111:3900:1536", dst="CDCD:910A:2222:5498:8475:1111:3900:2022")/UDP(sport=25,dport=19)/Raw("x" * 80)']}, + 'check_param': { + 'check_0': {'queue': 1}, + 'check_1': {'queue': 2}} +} + +tv_mac_vlan_pppoe_ipv4_tcp_pay_non_src_dst_port = { + 'name': 'tv_mac_vlan_pppoe_ipv4_tcp_pay_non_src_dst_port', + 'rule': ['flow create 0 priority 0 ingress pattern eth / vlan tci is 1 / pppoes / ipv4 src is 192.168.1.1 dst is 192.168.1.2 / tcp / end actions queue index 1 / end', + 'flow create 0 priority 1 ingress pattern eth / vlan tci is 1 / pppoes / ipv4 src is 192.168.1.1 dst is 192.168.1.2 / tcp / end actions queue index 2 / end'], + 'packet': { + 'matched': ['Ether(dst="00:11:22:33:44:55",type=0x8100)/Dot1Q(vlan=1,type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x00\\x21\')/IP(src="192.168.1.1", dst="192.168.1.2")/TCP(sport=25,dport=23)/Raw("x" * 80)'], + 'mismatched': ['Ether(dst="00:11:22:33:44:55",type=0x8100)/Dot1Q(vlan=2,type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x00\\x21\')/IP(src="192.168.1.1", dst="192.168.1.2")/TCP(sport=25,dport=23)/Raw("x" * 80)', + 'Ether(dst="00:11:22:33:44:55",type=0x8100)/Dot1Q(vlan=1,type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x00\\x21\')/IP(src="192.168.1.3", dst="192.168.1.2")/TCP(sport=25,dport=23)/Raw("x" * 80)', + 'Ether(dst="00:11:22:33:44:55",type=0x8100)/Dot1Q(vlan=1,type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x00\\x21\')/IP(src="192.168.1.1", dst="192.168.1.4")/TCP(sport=25,dport=23)/Raw("x" * 80)', + 'Ether(dst="00:11:22:33:44:55",type=0x8100)/Dot1Q(vlan=1,type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x00\\x21\')/IP(src="192.168.1.1", dst="192.168.1.2")/UDP(sport=25,dport=23)/Raw("x" * 80)', + 'Ether(dst="00:11:22:33:44:55",type=0x8100)/Dot1Q(vlan=1,type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x00\\x21\')/IP(src="192.168.1.1", dst="192.168.1.2")/Raw("x" * 80)']}, + 'check_param': { + 'check_0': {'queue': 1}, + 'check_1': {'queue': 2}} +} + +tv_mac_vlan_pppoe_ipv6_pay_ip_address = { + 'name': 'tv_mac_vlan_pppoe_ipv6_pay_ip_address', + 'rule': ['flow create 0 priority 0 ingress pattern eth / vlan tci is 1 / pppoes / ipv6 src is CDCD:910A:2222:5498:8475:1111:3900:1536 / end actions queue index 1 / end', + 'flow create 0 priority 1 ingress pattern eth / vlan tci is 1 / pppoes / ipv6 src is CDCD:910A:2222:5498:8475:1111:3900:1536 / end actions queue index 2 / end'], + 'packet': { + 'matched': ['Ether(src="11:22:33:44:55:99",dst="00:11:22:33:44:55",type=0x8100)/Dot1Q(vlan=1,type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x00\\x57\')/IPv6(src="CDCD:910A:2222:5498:8475:1111:3900:1536", dst="CDCD:910A:2222:5498:8475:1111:3900:2022")/Raw("x"*80)'], + 'mismatched': ['Ether(src="11:22:33:44:55:99",dst="00:11:22:33:44:55",type=0x8100)/Dot1Q(vlan=2,type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x00\\x57\')/IPv6(src="CDCD:910A:2222:5498:8475:1111:3900:1536", dst="CDCD:910A:2222:5498:8475:1111:3900:2022")/Raw("x"*80)', + 'Ether(src="11:22:33:44:55:99",dst="00:11:22:33:44:55",type=0x8100)/Dot1Q(vlan=1,type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x00\\x57\')/IPv6(src="CDCD:910A:2222:5498:8475:1111:3900:1537", dst="CDCD:910A:2222:5498:8475:1111:3900:2022")/Raw("x"*80)']}, + 'check_param': { + 'check_0': {'queue': 1}, + 'check_1': {'queue': 2}} +} + +tv_mac_pppoe_lcp_pay = { + 'name': 'tv_mac_pppoe_lcp_pay', + 'rule': ['flow create 0 priority 0 ingress pattern eth dst is 00:11:22:33:44:55 / pppoes seid is 3 / pppoe_proto_id is 0xc021 / end actions queue index 1 / end', + 'flow create 0 priority 1 ingress pattern eth dst is 00:11:22:33:44:55 / pppoes seid is 3 / pppoe_proto_id is 0xc021 / end actions queue index 2 / end'], + 'packet': { + 'matched': ['Ether(src="11:22:33:44:55:99",dst="00:11:22:33:44:55",type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\xc0\\x21\')/PPP_LCP()/Raw("x" * 80)'], + 'mismatched': ['Ether(src="11:22:33:44:55:99",dst="00:11:22:33:44:53",type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\xc0\\x21\')/PPP_LCP()/Raw("x" * 80)', + 'Ether(src="11:22:33:44:55:99",dst="00:11:22:33:44:55",type=0x8864)/PPPoE(sessionid=4)/PPP(b\'\\xc0\\x21\')/PPP_LCP()/Raw("x" * 80)', + 'Ether(src="11:22:33:44:55:99",dst="00:11:22:33:44:55",type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x00\\x21\')/IP()/Raw("x" * 80)']}, + 'check_param': { + 'check_0': {'queue': 1}, + 'check_1': {'queue': 2}} +} + +tv_mac_pppoe_ipcp_pay = { + 'name': 'tv_mac_pppoe_ipcp_pay', + 'rule': ['flow create 0 priority 0 ingress pattern eth dst is 00:11:22:33:44:55 / pppoes seid is 3 / pppoe_proto_id is 0x8021 / end actions queue index 1 / end', + 'flow create 0 priority 1 ingress pattern eth dst is 00:11:22:33:44:55 / pppoes seid is 3 / pppoe_proto_id is 0x8021 / end actions queue index 2 / end'], + 'packet': { + 'matched': ['Ether(src="11:22:33:44:55:99",dst="00:11:22:33:44:55",type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x80\\x21\')/PPP_IPCP()/Raw("x" * 80)'], + 'mismatched': ['Ether(src="11:22:33:44:55:99",dst="00:11:22:33:44:53",type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x80\\x21\')/PPP_IPCP()/Raw("x" * 80)', + 'Ether(src="11:22:33:44:55:99",dst="00:11:22:33:44:55",type=0x8864)/PPPoE(sessionid=4)/PPP(b\'\\x80\\x21\')/PPP_IPCP()/Raw("x" * 80)', + 'Ether(src="11:22:33:44:55:99",dst="00:11:22:33:44:55",type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x00\\x21\')/IP()/Raw("x" * 80)']}, + 'check_param': { + 'check_0': {'queue': 1}, + 'check_1': {'queue': 2}} +} + +tv_mac_vlan_pppoe_lcp_pay = { + 'name': 'tv_mac_vlan_pppoe_lcp_pay', + 'rule': ['flow create 0 priority 0 ingress pattern eth dst is 00:11:22:33:44:55 / vlan tci is 1 / pppoes seid is 3 / pppoe_proto_id is 0xc021 / end actions queue index 1 / end', + 'flow create 0 priority 1 ingress pattern eth dst is 00:11:22:33:44:55 / vlan tci is 1 / pppoes seid is 3 / pppoe_proto_id is 0xc021 / end actions queue index 2 / end'], + 'packet': { + 'matched': ['Ether(src="11:22:33:44:55:99",dst="00:11:22:33:44:55",type=0x8100)/Dot1Q(vlan=1,type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\xc0\\x21\')/PPP_LCP()/Raw("x" * 80)'], + 'mismatched': ['Ether(src="11:22:33:44:55:99",dst="00:11:22:33:44:53",type=0x8100)/Dot1Q(vlan=1,type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\xc0\\x21\')/PPP_LCP()/Raw("x" * 80)', + 'Ether(src="11:22:33:44:55:99",dst="00:11:22:33:44:55",type=0x8100)/Dot1Q(vlan=2,type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\xc0\\x21\')/PPP_LCP()/Raw("x" * 80)', + 'Ether(src="11:22:33:44:55:99",dst="00:11:22:33:44:55",type=0x8100)/Dot1Q(vlan=1,type=0x8864)/PPPoE(sessionid=4)/PPP(b\'\\xc0\\x21\')/PPP_LCP()/Raw("x" * 80)', + 'Ether(src="11:22:33:44:55:99",dst="00:11:22:33:44:55",type=0x8100)/Dot1Q(vlan=1,type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x00\\x21\')/IP()/Raw("x" * 80)']}, + 'check_param': { + 'check_0': {'queue': 1}, + 'check_1': {'queue': 2}} +} + +tv_mac_vlan_pppoe_ipcp_pay = { + 'name': 'tv_mac_vlan_pppoe_ipcp_pay', + 'rule': ['flow create 0 priority 0 ingress pattern eth dst is 00:11:22:33:44:55 / vlan tci is 1 / pppoes seid is 3 / pppoe_proto_id is 0x8021 / end actions queue index 1 / end', + 'flow create 0 priority 1 ingress pattern eth dst is 00:11:22:33:44:55 / vlan tci is 1 / pppoes seid is 3 / pppoe_proto_id is 0x8021 / end actions queue index 2 / end'], + 'packet': { + 'matched': ['Ether(src="11:22:33:44:55:99",dst="00:11:22:33:44:55",type=0x8100)/Dot1Q(vlan=1,type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x80\\x21\')/PPP_IPCP()/Raw("x" * 80)'], + 'mismatched': ['Ether(src="11:22:33:44:55:99",dst="00:11:22:33:44:53",type=0x8100)/Dot1Q(vlan=1,type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x80\\x21\')/PPP_IPCP()/Raw("x" * 80)', + 'Ether(src="11:22:33:44:55:99",dst="00:11:22:33:44:55",type=0x8100)/Dot1Q(vlan=2,type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x80\\x21\')/PPP_IPCP()/Raw("x" * 80)', + 'Ether(src="11:22:33:44:55:99",dst="00:11:22:33:44:55",type=0x8100)/Dot1Q(vlan=1,type=0x8864)/PPPoE(sessionid=4)/PPP(b\'\\x80\\x21\')/PPP_IPCP()/Raw("x" * 80)', + 'Ether(src="11:22:33:44:55:99",dst="00:11:22:33:44:55",type=0x8100)/Dot1Q(vlan=1,type=0x8864)/PPPoE(sessionid=3)/PPP(b\'\\x00\\x21\')/IP()/Raw("x" * 80)' + ]}, + 'check_param': { + 'check_0': {'queue': 1}, + 'check_1': {'queue': 2}} +} + +class CVLPFFlowPriorityTest(TestCase): + supported_nic = ['columbiaville_100g', 'columbiaville_25g', 'columbiaville_25gx2'] + + @check_supported_nic(supported_nic) + def set_up_all(self): + """ + Run at the start of each test suite. + """ + self.dut_ports = self.dut.get_ports(self.nic) + # Verify that enough ports are available + self.verify(len(self.dut_ports) >= 1, "Insufficient ports") + self.tester_port0 = self.tester.get_local_port(self.dut_ports[0]) + self.tester_iface0 = self.tester.get_interface(self.tester_port0) + self.tester_port1 = self.tester.get_local_port(self.dut_ports[0]) + self.tester_iface1 = self.tester.get_interface(self.tester_port0) + self.pf_pci=self.dut.ports_info[self.dut_ports[0]]['pci'] + self.pkt = Packet() + self.pmdout = PmdOutput(self.dut) + self.rxq = 16 + self.process = FdirProcessing(self, self.pmdout, [self.tester_iface0, self.tester_iface1], self.rxq) + + def set_up(self): + """ + Run before each test case. + """ + self.reload_ice() + self.launch_testpmd() + + def reload_ice(self): + self.dut.bind_interfaces_linux('ice') + self.dut.send_expect('rmmod ice', '#', 120) + self.dut.send_expect('modprobe ice', '#', 120) + self.dut.bind_interfaces_linux('vfio-pci') + + def launch_testpmd(self, eal_param=False): + """ + launch testpmd with the command + """ + #if eal_param: + if self._suite_result.test_case == 'test_flow_priority_filter': + self.pmdout.start_testpmd(cores='1S/4C/1T', ports=[self.pf_pci], eal_param='--log-level=ice,8', param="--rxq=16 --txq=16") + else: + self.pmdout.start_testpmd(cores='1S/4C/1T', ports=[self.pf_pci], param="--rxq=16 --txq=16") + self.pmdout.execute_cmd('set fwd rxonly') + self.pmdout.execute_cmd('set verbose 1') + self.pmdout.execute_cmd('rx_vxlan_port add 4789 0') + self.pmdout.execute_cmd('start') + + def test_mac_ipv4_pay(self): + self.process.handle_priority_cases(tv_mac_ipv4_pay) + + def test_mac_ipv4_udp_pay(self): + self.process.handle_priority_cases(tv_mac_ipv4_udp_pay) + + def test_mac_ipv6(self): + self.process.handle_priority_cases(tv_mac_ipv6) + + def test_mac_ipv6_tcp(self): + self.process.handle_priority_cases(tv_mac_ipv6_tcp) + + def test_mac_ipv4_vxlan_ipv4_frag(self): + self.process.handle_priority_cases(tv_mac_ipv4_vxlan_ipv4_frag) + + def test_mac_ipv4_vxlan_ipv4_pay(self): + self.process.handle_priority_cases(tv_mac_ipv4_vxlan_ipv4_pay) + + def test_mac_ipv4_nvgre_ipv4_udp_pay(self): + self.process.handle_priority_cases(tv_mac_ipv4_nvgre_ipv4_udp_pay) + + def test_mac_ipv4_nvgre_ipv4_tcp(self): + self.process.handle_priority_cases(tv_mac_ipv4_nvgre_ipv4_tcp) + + def test_ethertype_filter_pppoed(self): + self.process.handle_priority_cases(tv_ethertype_filter_pppoed) + + def test_mac_vlan_pppoe_ipv4_pay_session_id_proto_id(self): + self.process.handle_priority_cases(tv_mac_vlan_pppoe_ipv4_pay_session_id_proto_id) + + def test_mac_vlan_pppoe_ipv6_pay_session_id_proto_id(self): + self.process.handle_priority_cases(tv_mac_vlan_pppoe_ipv6_pay_session_id_proto_id) + + def test_mac_pppoe_ipv4_pay_ip_address(self): + self.process.handle_priority_cases(tv_mac_pppoe_ipv4_pay_ip_address) + + def test_mac_pppoe_ipv6_udp_pay(self): + self.process.handle_priority_cases(tv_mac_pppoe_ipv6_udp_pay) + + def test_mac_vlan_pppoe_ipv4_tcp_pay_non_src_dst_port(self): + self.process.handle_priority_cases(tv_mac_vlan_pppoe_ipv4_tcp_pay_non_src_dst_port) + + def test_mac_vlan_pppoe_ipv6_pay_ip_address(self): + self.process.handle_priority_cases(tv_mac_vlan_pppoe_ipv6_pay_ip_address) + + def test_mac_pppoe_lcp_pay(self): + self.process.handle_priority_cases(tv_mac_pppoe_lcp_pay) + + def test_mac_pppoe_ipcp_pay(self): + self.process.handle_priority_cases(tv_mac_pppoe_ipcp_pay) + + def test_mac_vlan_pppoe_lcp_pay(self): + self.process.handle_priority_cases(tv_mac_vlan_pppoe_lcp_pay) + + def test_mac_vlan_pppoe_ipcp_pay(self): + self.process.handle_priority_cases(tv_mac_vlan_pppoe_ipcp_pay) + + def create_rule_and_check(self, rule_list, check_param): + for rule in rule_list: + out = self.pmdout.execute_cmd(rule) + if isinstance(check_param, list): + self.verify(check_param[0] in out or check_param[1] in out, "create rule result not meet expected") + else: + self.verify(check_param in out, "create rule result not meet expected") + + self.pmdout.execute_cmd('flow flush 0') + + def test_flow_priority_filter(self): + rule_list1 = ['flow create 0 priority 0 ingress pattern eth / ipv4 dst is 192.168.0.1 / nvgre tni is 2 / eth / ipv4 src is 192.168.1.2 dst is 192.168.1.3 / end actions queue index 3 / end', + 'flow create 0 priority 0 ingress pattern eth / ipv4 / udp / vxlan / eth / ipv4 src is 192.168.0.2 dst is 192.168.0.3 / tcp src is 50 dst is 23 / end actions rss queues 4 5 end / end', + 'flow create 0 priority 0 ingress pattern eth dst is 00:11:22:33:44:55 / vlan tci is 1 / pppoes seid is 3 / pppoe_proto_id is 0x0057 / end actions drop / end'] + + rule_list2 = [ + 'flow create 0 priority 0 ingress pattern eth / ipv4 / udp / vxlan / eth / ipv4 src is 192.168.0.2 dst is 192.168.0.3 / tcp src is 50 dst is 23 / end actions rss queues 4 5 end / mark id 3 / end', + ] + + rule_list3 = ['flow create 0 priority 1 ingress pattern eth / ipv4 dst is 192.168.0.1 / nvgre tni is 2 / eth / ipv4 src is 192.168.1.2 dst is 192.168.1.3 / end actions queue index 3 / end', + 'flow create 0 priority 1 ingress pattern eth / ipv4 / udp / vxlan / eth / ipv4 src is 192.168.0.2 dst is 192.168.0.3 / tcp src is 50 dst is 23 / end actions rss queues 4 5 end / end', + 'flow create 0 priority 1 ingress pattern eth dst is 00:11:22:33:44:55 / vlan tci is 1 / pppoes seid is 3 / pppoe_proto_id is 0x0057 / end actions drop / end'] + + rule_list4 = ['flow create 0 priority 1 ingress pattern eth / ipv4 dst is 192.168.0.1 / nvgre tni is 2 / eth / ipv4 src is 192.168.1.2 dst is 192.168.1.3 / end actions queue index 3 / mark id 3 / end', + 'flow create 0 priority 1 ingress pattern eth / ipv4 / udp / vxlan / eth / ipv4 src is 192.168.0.2 dst is 192.168.0.3 / tcp src is 50 dst is 23 / end actions rss queues 4 5 end / mark id 3 / end', + 'flow create 0 priority 1 ingress pattern eth dst is 00:11:22:33:44:55 / vlan tci is 1 / pppoes seid is 3 / pppoe_proto_id is 0x0057 / end actions drop / mark id 3 / end'] + + self.create_rule_and_check(rule_list1, 'Succeeded to create (2) flow') + self.create_rule_and_check(rule_list2, 'Succeeded to create (1) flow') + self.create_rule_and_check(rule_list3, 'Succeeded to create (2) flow') + self.create_rule_and_check(rule_list4, 'Failed to create flow') + + def test_negative(self): + rules = ['flow create 0 priority 2 ingress pattern eth / ipv4 src is 192.168.0.1 dst is 192.168.0.2 / end actions queue index 3 / end', + 'flow create 0 priority a ingress pattern eth / ipv4 src is 192.168.0.1 dst is 192.168.0.2 / end actions queue index 3 / end', + 'flow create 0 priority 1 ingress pattern eth / ipv4 src is 192.168.0.1 dst is 192.168.0.2 / end actions mark / rss / end'] + + self.create_rule_and_check(rules, ['Failed to create flow', 'Bad arguments']) + + def test_exclusive(self): + p = 'port\s+\d+/queue(.+?):\s+received\s+\d+\s+packets' + p1 = 'Forward\s+statistics\s+for\s+port\s+0.*?\n.*?RX-packets:\s+(\d+)' + + rule_list1 = ['flow create 0 priority 1 ingress pattern eth / ipv4 src is 192.168.0.1 dst is 192.168.0.2 / end actions queue index 3 / end', + 'flow create 0 priority 0 ingress pattern eth / ipv4 src is 192.168.0.1 dst is 192.168.0.2 / end actions queue index 3 / end'] + pkts1 = 'Ether(dst="68:05:ca:8d:ed:a8")/IP(src="192.168.0.1",dst="192.168.0.2",tos=4,ttl=2)/TCP()/("X"*480)' + + rule_list2 = ['flow create 0 priority 1 ingress pattern eth / ipv4 src is 192.168.0.1 dst is 192.168.0.2 / end actions queue index 3 / end', + 'flow create 0 priority 1 ingress pattern eth / ipv4 src is 192.168.0.1 dst is 192.168.0.2 / end actions rss queues 4 5 end / end'] + + rule_list3 = ['flow create 0 priority 0 ingress pattern eth / vlan / vlan / pppoes / pppoe_proto_id is 0x21 / end actions queue index 3 / end', + 'flow create 0 priority 1 ingress pattern eth / vlan / vlan / pppoes seid is 1 / ipv4 / end actions queue index 2 / end', + 'flow create 0 priority 1 ingress pattern eth / vlan / vlan tci is 12 / ipv4 src is 196.222.232.221 / end actions queue index 4 / end', + 'flow create 0 priority 0 ingress pattern eth / vlan / vlan tci is 12 / ipv4 src is 196.222.232.221 / end actions rss queues 7 8 end / end', + 'flow create 0 priority 0 ingress pattern eth / vlan tci is 1 / vlan tci is 2 / end actions drop / end', + 'flow create 0 priority 1 ingress pattern eth / vlan tci is 1 / vlan tci is 2 / end actions queue index 5 / end'] + pkts3 = ['Ether(dst="00:11:22:33:44:55",type=0x8100)/Dot1Q(vlan=1,type=0x8100)/Dot1Q(vlan=0x2,type=0x8864)/PPPoE(sessionid=0x1)/PPP(b\'\\x00\\x21\')/IP()/UDP(dport=23)/("X"*480)', + 'Ether()/Dot1Q(vlan=1)/Dot1Q(vlan=12)/IP(src="196.222.232.221")/Raw("x"*480)', + 'Ether()/Dot1Q(vlan=1)/Dot1Q(vlan=2)/Raw("x"*480)'] + # subcase1: same pattern/input set/action different priority + rule_id = self.process.create_rule(rule_list1) + self.process.check_rule(rule_list=rule_id) + out = self.process.send_pkt_get_out(pkts1) + self.pmdout.execute_cmd('flow flush 0') + queue = re.search(p, out).group(1) + self.verify(int(queue) == 3, "queue {} receive pkt, expect queue 3".format(queue)) + + # subcase2: same pattern/input set/priority different action + for rule in rule_list2: + out = self.pmdout.execute_cmd(rule) + rule_index = rule_list2.index(rule) + check_param = 'Flow rule #0 created' if rule_index == 0 else 'Failed to create flow' + self.verify(check_param in out, 'create rule result not meet expected') + self.pmdout.execute_cmd('flow flush 0') + + # subcase3: some rules overlap + rule_id = self.process.create_rule(rule_list3) + self.process.check_rule(rule_list=rule_id) + + out = self.process.send_pkt_get_out(pkts3[0]) + queue = re.search(p, out).group(1) + self.verify(int(queue) == 3, "queue {} receive pkt, expect queue 3".format(queue)) + + out = self.process.send_pkt_get_out(pkts3[1]) + queue = re.search(p, out).group(1) + self.verify(int(queue) in [7, 8], "queue {} receive pkt, expect queue 7/8".format(queue)) + + out = self.process.send_pkt_get_out(pkts3[2]) + pkt_num = re.search(p1, out).group(1) + self.verify(int(pkt_num) == 0, 'drop pkt failed') + + # destroy rule + self.process.destroy_rule(rule_id=0) + self.process.destroy_rule(rule_id=3) + self.process.destroy_rule(rule_id=4) + out = self.process.send_pkt_get_out(pkts3[0]) + queue = re.findall(p, out) + self.verify(len(queue) == 1 and int(queue[0]) == 2, 'queue 3 not receive this pkt') + + out = self.process.send_pkt_get_out(pkts3[1]) + queue = re.findall(p, out) + self.verify(len(queue) == 1 and int(queue[0]) == 4, 'queue 1/2 not receive this pkt') + + out = self.process.send_pkt_get_out(pkts3[2]) + queue = re.findall(p, out) + self.verify(len(queue) == 1 and int(queue[0]) == 5, 'drop pkt failed') + + def tear_down(self): + """ + Run after each test case. + """ + self.pmdout.execute_cmd('quit', '# ') + + def tear_down_all(self): + """ + Run after each test suite. + """ + self.dut.kill_all() +