* [dts] [PATCH V2][pmd_bonded_8023ad]: upload automation script
@ 2019-02-28 5:36 yufengmx
2019-02-28 5:36 ` [dts] [PATCH V2]pmd_bonded_8023ad: " yufengmx
0 siblings, 1 reply; 5+ messages in thread
From: yufengmx @ 2019-02-28 5:36 UTC (permalink / raw)
To: dts; +Cc: yufengmx
pmd_bonded_8023ad automation script
v2:
- unify the same methods with pmd_stacked_bonded suite and put them in bonding.py.
- remove testing content using switch equipment
- remove debug methods.
- remove un-used parameters.
- fix typo issue.
yufengmx (1):
pmd_bonded_8023ad: upload automation script
tests/TestSuite_pmd_bonded_8023ad.py | 599 +++++++++++++++++++++++++++++++++++
1 file changed, 599 insertions(+)
create mode 100644 tests/TestSuite_pmd_bonded_8023ad.py
--
1.9.3
^ permalink raw reply [flat|nested] 5+ messages in thread
* [dts] [PATCH V2]pmd_bonded_8023ad: upload automation script
2019-02-28 5:36 [dts] [PATCH V2][pmd_bonded_8023ad]: upload automation script yufengmx
@ 2019-02-28 5:36 ` yufengmx
2019-02-28 6:04 ` Mo, YufengX
2019-02-28 10:58 ` Tu, Lijuan
0 siblings, 2 replies; 5+ messages in thread
From: yufengmx @ 2019-02-28 5:36 UTC (permalink / raw)
To: dts; +Cc: yufengmx
This automation script is for pmd bonded 8023ad feature.
IEEE 802.3ad Dynamic link aggregation. Creates aggregation groups that share
the same speed and duplex settings. Utilizes all slaves in the active
aggregator according to the 802.3ad specification. Slave selection for outgoing
traffic is done according to the transmit hash policy.
Signed-off-by: yufengmx <yufengx.mo@intel.com>
---
tests/TestSuite_pmd_bonded_8023ad.py | 599 +++++++++++++++++++++++++++++++++++
1 file changed, 599 insertions(+)
create mode 100644 tests/TestSuite_pmd_bonded_8023ad.py
diff --git a/tests/TestSuite_pmd_bonded_8023ad.py b/tests/TestSuite_pmd_bonded_8023ad.py
new file mode 100644
index 0000000..cad573e
--- /dev/null
+++ b/tests/TestSuite_pmd_bonded_8023ad.py
@@ -0,0 +1,599 @@
+# BSD LICENSE
+#
+# Copyright(c) 2010-2019 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 time
+import re
+import traceback
+
+# import dts/framework libs
+from test_case import TestCase
+from exception import VerifyFailure
+
+# import bonding lib(common methods for pmd bonding command)
+import bonding
+from bonding import MODE_LACP, FRAME_SIZE_64
+
+######################
+# bonding 802.3ad mode
+######################
+class TestBonding8023AD(TestCase):
+ AGG_MODES = ["bandwidth", "stable", "count"]
+ DEDICATED_QUEUES = ['disable', 'enable']
+
+ #
+ # On dut, dpdk bonding
+ #
+
+ def set_8023ad_agg_mode(self, bond_port, mode="bandwidth"):
+ """
+ set bonding agg_mode <port_id> <agg_name>
+
+ Set 802.11AD Aggregator Mode
+ """
+ cmd = "set bonding agg_mode %d %s" % (bond_port, mode)
+ self.bond_inst.d_console(cmd)
+ cur_mode = self.bond_inst.get_bonding_info(bond_port, 'agg_mode')
+ if mode == cur_mode:
+ fmt = "set bonding agg_mode <{0}> successfully"
+ self.logger.info(fmt.format(mode))
+ else:
+ msg = "failed to set bonding agg_mode <{0}>".format(mode)
+ self.logger.error(msg)
+ raise VerifyFailure(msg)
+
+ def get_8023ad_agg_mode(self, bond_port):
+ """
+ get 802.3ad mode aggregator Mode
+ """
+ cur_mode = self.bond_inst.get_bonding_info(bond_port, 'agg_mode')
+ return cur_mode
+
+ def set_8023ad_dedicated_queues(self, bond_port, status='disable'):
+ """
+ set 802.11AD dedicated_queues mode(enable|disable)
+ """
+ cmds =[
+ ["set bonding lacp dedicated_queues %s %s" % (bond_port, status),
+ ['', 'port %s failed'%bond_port, False], 2],]
+ out = self.bond_inst.d_console(cmds)
+ # when set 'hw'
+ if status == 'enable':
+ expected_msg = 'queues for LACP control packets enabled'
+ err_fmt = "link bonding mode 4 (802.3ad) set {0} failed"
+ self.verify(expected_msg in out, err_fmt.format(status))
+ elif status == 'disable':
+ expected_msg = 'queues for LACP control packets disabled'
+ err_fmt = "link bonding mode 4 (802.3ad) set {0} failed"
+ self.verify(expected_msg in out, err_fmt.format(status))
+
+ def set_8023ad_bonded(self, slaves, bond_mode, ignore=True):
+ ''' set 802.3ad bonded mode for the specified bonding mode '''
+ specified_socket = self.dut.get_numa_id(slaves[0])
+ # create bonded device, add slaves in it
+ bond_port = self.bond_inst.create_bonded_device(bond_mode, specified_socket)
+ if not ignore:
+ # when no slave attached, mac should be 00:00:00:00:00:00
+ self.bonding_8023ad_check_macs_without_slaves(bond_port)
+ # add slave
+ self.bond_inst.add_slave(bond_port, False, '', *slaves)
+ return bond_port
+
+ def get_pci_link(self, slaves):
+ ''' get slaves ports pci address '''
+ slaves_pci = []
+ for port_id in slaves:
+ slaves_pci.append(self.dut.ports_info[port_id]['pci'])
+ if not slaves_pci:
+ msg = "can't find tx_port pci"
+ self.logger.error(msg)
+ raise VerifyFailure(msg)
+ return slaves_pci
+
+ def set_bond_port_ready(self, tx_port, bond_port):
+ cmd= "set portlist {0},{1}".format(tx_port, bond_port)
+ self.bond_inst.d_console(cmd)
+ # for port link up is slow and unstable,
+ # every port should start one by one
+ cmds = []
+ port_num = len(self.dut_ports)
+ start_fmt = "port start {0}".format
+ for cnt in range(port_num):
+ cmds.append([start_fmt(cnt), '', 5])
+ self.bond_inst.d_console(cmds)
+ time.sleep(10)
+ self.bond_inst.d_console([start_fmt(self.bond_port), '', 15])
+ time.sleep(5)
+ self.bond_inst.d_console(["start", '', 10])
+ self.logger.info("set bond port ready done !!!")
+
+ def run_8023ad_pre(self, slaves, bond_mode):
+ bond_port = self.set_8023ad_bonded(slaves, bond_mode)
+ # should set port to stop and make sure port re-sync with parter when
+ # testpmd linking with switch equipment
+ cmds = ["port stop all", '', 15]
+ self.bond_inst.d_console(cmds)
+ time.sleep(2)
+ cmds = ["port start all", '', 10]
+ self.bond_inst.d_console(cmds)
+ time.sleep(2)
+ return bond_port
+
+ def bonding_8023ad_check_macs_without_slaves(self, bond_port):
+ query_type = 'mac'
+ bond_port_mac = self.bond_inst.get_port_mac(bond_port, query_type)
+ default_mac = '00:00:00:00:00:00'
+ if bond_port_mac == default_mac:
+ msg = "bond port default mac is [{0}]".format(default_mac)
+ self.logger.info(msg)
+ else:
+ fmt = "bond port default mac is [{0}], not expected mac"
+ msg = fmt.format(bond_port_mac)
+ self.logger.warning(msg)
+
+ def bonding_8023ad_check_macs(self, slaves, bond_port):
+ ''' check if bonded device's mac is one of its slaves mac '''
+ query_type = 'mac'
+ bond_port_mac = self.bond_inst.get_port_mac(bond_port, query_type)
+ if bond_port_mac == '00:00:00:00:00:00':
+ msg = "bond port hasn't set mac address"
+ self.logger.info(msg)
+ return
+
+ for port_id in slaves:
+ slave_mac = self.bond_inst.get_port_info(port_id, query_type)
+ if bond_port_mac == slave_mac:
+ fmt = "bonded device's mac is slave [{0}]'s mac [{1}]"
+ msg = fmt.format(port_id, slave_mac)
+ self.logger.info(msg)
+ return port_id
+ else:
+ fmt = "bonded device's current mac [{0}] " + \
+ "is not one of its slaves mac"
+ msg = fmt.format(bond_port_mac)
+ # it is not supported by dpdk, but supported by linux normal
+ # bonding/802.3ad tool
+ self.logger.warning('bonding_8023ad_check_macs: ' + msg)
+
+ def check_bonded_device_mac_change(self, slaves, bond_port):
+ remove_slave = 0
+ cur_slaves = slaves[1:]
+ self.bond_inst.remove_slaves(bond_port, False, *[remove_slave])
+ self.bonding_8023ad_check_macs(cur_slaves, bond_port)
+
+ def check_bonded_device_start(self, bond_port):
+ cmds = [["port stop all", '', 15],
+ ["port start %s"%bond_port, '', 10],
+ ["start", [' ', 'core dump', False]]]
+ self.bond_inst.d_console(cmds)
+ time.sleep(2)
+
+ def stop_bonded_device(self, bond_port):
+ cmds =[["stop", '', 10],
+ ["port stop %s"%bond_port, '', 10],]
+ self.bond_inst.d_console(cmds)
+ time.sleep(2)
+
+ def check_bonded_device_up_down(self, bond_port):
+ # stop bonded device
+ cmd = "port stop {0}".format(bond_port)
+ self.bond_inst.d_console(cmd)
+ status = self.bond_inst.get_port_info(bond_port, 'link_status')
+ if status != 'down':
+ msg = "bond port {0} fail to set down".format(bond_port)
+ self.logger.error(msg)
+ raise VerifyFailure(msg)
+ else:
+ msg = "bond port {0} set down successful !".format(bond_port)
+ self.logger.info(msg)
+ # start bonded device
+ cmds = ["port start {0}".format(bond_port), '', 10]
+ self.bond_inst.d_console(cmds)
+ status = self.bond_inst.get_port_info(bond_port, 'link_status')
+ if status != 'up':
+ msg = "bond port {0} fail to set up".format(bond_port)
+ self.logger.error(msg)
+ raise VerifyFailure(msg)
+ else:
+ msg = "bond port {0} set up successful !".format(bond_port)
+ self.logger.info(msg)
+
+ def check_bonded_device_promisc_mode(self, slaves, bond_port):
+ # disable bonded device promiscuous mode
+ cmd = "set promisc {0} off".format(bond_port)
+ self.bond_inst.d_console(cmd)
+ time.sleep(2)
+ status = self.bond_inst.get_port_info(bond_port, 'promiscuous_mode')
+ if status != 'disabled':
+ fmt = "bond port {0} fail to set promiscuous mode disabled"
+ msg = fmt.format(bond_port)
+ self.logger.warning(msg)
+ else:
+ fmt = "bond port {0} set promiscuous mode disabled successful !"
+ msg = fmt.format(bond_port)
+ self.logger.info(msg)
+ self.bond_inst.d_console("start")
+ time.sleep(2)
+ # check slave promiscuous mode
+ for port_id in slaves:
+ status = self.bond_inst.get_port_info(port_id, 'promiscuous_mode')
+ if status != 'disabled':
+ fmt = ("slave port {0} promiscuous mode "
+ "isn't the same as bond port 'disabled', ")
+ msg = fmt.format(port_id)
+ self.logger.warning(msg)
+ # dpdk developer hasn't completed this function as linux
+ # document description about `Promiscuous mode`, ignore it here
+ # temporarily
+ #raise VerifyFailure(msg)
+ else:
+ fmt = "slave port {0} promiscuous mode is 'disabled' too"
+ msg = fmt.format(port_id)
+ self.logger.info(msg)
+ # enable bonded device promiscuous mode
+ cmd = "set promisc {0} on".format(bond_port)
+ self.bond_inst.d_console(cmd)
+ time.sleep(3)
+ status = self.bond_inst.get_port_info(bond_port, 'promiscuous_mode')
+ if status != 'enabled':
+ fmt = "bond port {0} fail to set promiscuous mode enabled"
+ msg = fmt.format(bond_port)
+ self.logger.error(msg)
+ raise VerifyFailure(msg)
+ else:
+ fmt = "bond port {0} set promiscuous mode enabled successful !"
+ msg = fmt.format(bond_port)
+ self.logger.info(msg)
+ # check slave promiscuous mode
+ for port_id in slaves:
+ status = self.bond_inst.get_port_info(port_id, 'promiscuous_mode')
+ if status != 'enabled':
+ fmt = "slave port {0} promiscuous mode " + \
+ "isn't the same as bond port 'enabled'"
+ msg = fmt.format(port_id)
+ self.logger.warning(msg)
+ # dpdk developer hasn't completed this function as linux
+ # document description about `Promiscuous mode`, ignore it here
+ # temporarily
+ #raise VerifyFailure(msg)
+ else:
+ fmt = "slave port {0} promiscuous mode is 'enabled' too"
+ msg = fmt.format(port_id)
+ self.logger.info(msg)
+
+ def check_8023ad_agg_modes(self, slaves, bond_mode):
+ ''' check aggregator mode '''
+ check_results = []
+ default_agg_mode = 'stable'
+ for mode in self.AGG_MODES:
+ try:
+ self.bond_inst.start_testpmd()
+ bond_port = self.set_8023ad_bonded(slaves, bond_mode)
+ cur_agg_mode = self.get_8023ad_agg_mode(bond_port)
+ if cur_agg_mode != default_agg_mode:
+ fmt = ("link bonding mode 4 (802.3ad) default agg mode "
+ "isn't {0}")
+ msg = fmt.format(default_agg_mode)
+ self.logger.warning(msg)
+ # ignore default mode
+ if mode == default_agg_mode:
+ fmt = ("link bonding mode 4 (802.3ad) "
+ "current agg mode is {0}")
+ msg = fmt.format(mode)
+ self.logger.info(msg)
+ continue
+ cmds = [
+ ["port stop all", '', 15],
+ ["port start all", '', 15]]
+ self.bond_inst.d_console(cmds)
+ self.set_8023ad_agg_mode(bond_port, mode)
+ except Exception as e:
+ check_results.append(e); print traceback.format_exc()
+ finally:
+ self.bond_inst.close_testpmd()
+ time.sleep(2)
+
+ if check_results:
+ for result in check_results:
+ self.logger.error(result)
+ raise VerifyFailure('check_8023ad_agg_modes is failed')
+
+ def check_8023ad_dedicated_queues(self, slaves, bond_mode):
+ ''' check 802.3ad dedicated queues '''
+ check_results = []
+ default_slow_queue = 'unknown'
+ for mode in self.DEDICATED_QUEUES:
+ try:
+ self.bond_inst.start_testpmd()
+ bond_port = self.set_8023ad_bonded(slaves, bond_mode)
+ self.set_8023ad_dedicated_queues(bond_port, mode)
+ except Exception as e:
+ check_results.append(e); print traceback.format_exc()
+ finally:
+ self.bond_inst.close_testpmd()
+ time.sleep(2)
+
+ if check_results:
+ for result in check_results:
+ self.logger.error(result)
+ raise VerifyFailure('check_8023ad_dedicated_queues is failed')
+
+ def get_commandline_options(self, agg_mode):
+ slaves = self.dut_ports
+ # get bonding port configuration
+ slave_pcis = self.get_pci_link(slaves)
+ # create commandline option format
+ bonding_name = 'net_bonding0'
+ slaves_pci = ["slave=" + pci for pci in slave_pcis]
+ bonding_mode = 'mode={0}'.format(str(MODE_LACP))
+ agg_config = 'agg_mode={0}'
+ vdev_format = ",".join([bonding_name] + slaves_pci + \
+ [bonding_mode, agg_config])
+ # command line option
+ mode = str(MODE_LACP)
+ option = vdev_format.format(agg_mode)
+ vdev_option = " --vdev '{0}'".format(option)
+ # 802.3ad bond port only create one, it must be the max port number
+ bond_port = len(self.dut_ports)
+ return bond_port, vdev_option
+
+ def run_test_pre(self, agg_mode):
+ # get bonding port configuration
+ bond_port, vdev_option = self.get_commandline_options(agg_mode)
+ self.bond_port = bond_port
+ # boot up testpmd
+ self.bond_inst.start_testpmd(eal_option=vdev_option)
+ cur_slaves, cur_agg_mode = self.bond_inst.get_bonding_info(bond_port,
+ ['slaves', 'agg_mode'])
+ if agg_mode != cur_agg_mode:
+ fmt = 'expected agg mode is [{0}], current agg mode is [{1}]'
+ msg = fmt.format(agg_mode, cur_agg_mode)
+ self.logger.warning(msg)
+ # get forwarding port
+ for port_id in range(len(self.dut_ports)):
+ # select a non-slave port as forwarding port to do transmitting
+ if str(port_id) not in cur_slaves:
+ tx_port_id = port_id
+ break
+ else:
+ tx_port_id = bond_port
+ # enable dedicated queue
+ self.set_8023ad_dedicated_queues(bond_port, 'enable')
+ self.set_bond_port_ready(tx_port_id, bond_port)
+ slaves = [int(slave) for slave in cur_slaves]
+
+ return bond_port, slaves, tx_port_id
+
+ def run_dpdk_functional_pre(self):
+ mode = MODE_LACP
+ slaves = self.dut_ports[:]
+ self.bond_inst.start_testpmd()
+ bond_port = self.run_8023ad_pre(slaves, mode)
+ return slaves, bond_port
+
+ def run_dpdk_functional_post(self):
+ self.bond_inst.close_testpmd()
+
+ def check_cmd_line_option_status(self, agg_mode, bond_port, slaves):
+ mode = str(MODE_LACP)
+ msgs = []
+ cur_mode, cur_slaves, cur_active_slaves, cur_agg_mode =\
+ self.bond_inst.get_bonding_info(bond_port,
+ ['mode', 'slaves', 'active_slaves', 'agg_mode'])
+ # check bonding mode
+ if mode != cur_mode:
+ fmt = 'expected mode is [{0}], current mode is [{1}]'
+ msg = fmt.format(mode, cur_mode)
+ msgs.append(msg)
+ # check bonding 802.3ad agg mode
+ if agg_mode != cur_agg_mode:
+ fmt ='expected agg mode is [{0}], current agg mode is [{1}]'
+ msg = fmt.format(agg_mode, cur_agg_mode)
+ msgs.append(msg)
+ # check bonded slaves
+ _cur_slaves = [int(id) for id in cur_slaves]
+ if not _cur_slaves or cmp(sorted(slaves), sorted(_cur_slaves)) != 0:
+ slaves_str = ' '.join([str(id) for id in slaves])
+ cur_slaves_str = ' '.join([str(id) for id in _cur_slaves]) \
+ if _cur_slaves else ''
+ msg_format = 'expected slaves is [{0}], current slaves is [{1}]'
+ msg = msg_format.format(slaves_str, cur_slaves_str)
+ msgs.append(msg)
+ # check active slaves status before ports start
+ if self.kdriver is 'i40e':
+ if cur_active_slaves:
+ check_active_slaves = [int(id) for id in cur_active_slaves]
+ if cmp(sorted(slaves), sorted(check_active_slaves)) != 0:
+ slaves_str = ' '.join([str(id) for id in slaves])
+ msg_fmt = ('expected active slaves is [{0}], '
+ 'current active slaves is [{1}]')
+ msg = msg_fmt.format(slaves_str, cur_active_slaves)
+ msgs.append(msg)
+ else:
+ msg = 'active slaves should not be empty'
+ #self.logger.warning(msg)
+ #msgs.append(msg)
+ else:
+ if cur_active_slaves:
+ msg = 'active slaves should be empty'
+ #self.logger.warning(msg)
+ #msgs.append(msg)
+ # check status after ports start
+ self.bond_inst.start_ports()
+ # set bonded device to active status
+ if self.kdriver is not 'i40e':
+ cur_active_slaves = [
+ int(id) for id in self.bond_inst.get_bonding_info(
+ bond_port, 'active_slaves')]
+ if not cur_active_slaves or cmp(sorted(slaves),
+ sorted(cur_active_slaves)) != 0:
+ slaves_str = ' '.join([str(id) for id in slaves])
+ active_str = ' '.join([str(id) for id in cur_active_slaves]) \
+ if cur_active_slaves else ''
+ msg_fmt = (
+ 'expected active slaves is [{0}], '
+ 'current active slaves is [{1}]')
+ msg = msg_fmt.format(slaves_str, active_str)
+ msgs.append(msg)
+ return msgs
+ #
+ # Test cases.
+ #
+ def set_up_all(self):
+ """
+ Run before each test suite
+ """
+ self.verify('bsdapp' not in self.target, "Bonding not support freebsd")
+ #------------------------------------------------------------
+ # link peer resource
+ self.dut_ports = self.dut.get_ports()
+ required_link = 2
+ self.verify(len(self.dut_ports) >= required_link, "Insufficient ports")
+ #------------------------------------------------------------
+ # 802.3ad related
+ self.bond_port = None
+ self.bond_slave = self.dut_ports[0]
+ #----------------------------------------------------------------
+ # initialize bonding common methods name
+ config = {
+ 'parent': self,
+ 'pkt_name': 'udp',
+ 'pkt_size': FRAME_SIZE_64,
+ 'src_mac': '52:00:00:00:00:03',
+ 'src_ip': '10.239.129.65',
+ 'src_port': 61,
+ 'dst_ip': '10.239.129.88',
+ 'dst_port': 53,}
+ self.bond_inst = bonding.PmdBonding(**config)
+
+ def set_up(self):
+ """
+ Run before each test case.
+ """
+ pass
+
+ def tear_down(self):
+ """
+ Run after each test case.
+ """
+ try:
+ self.bond_inst.close_testpmd()
+ except Exception:
+ pass
+
+ def tear_down_all(self):
+ """
+ Run after each test suite.
+ """
+ pass
+
+ def test_basic_behav_startStop(self):
+ '''
+ test 802.3ad basic behavior(bond port start/stop)
+ '''
+ msg = ''
+ slaves, bond_port = self.run_dpdk_functional_pre()
+ try:
+ for _ in range(10):
+ self.check_bonded_device_start(bond_port)
+ self.stop_bonded_device(bond_port)
+ except Exception as e:
+ print traceback.format_exc()
+ msg = "bonding 8023ad check start/stop failed"
+ self.run_dpdk_functional_post()
+ if msg:
+ raise VerifyFailure(msg)
+
+ def test_basic_behav_mac(self):
+ '''
+ test 802.3ad basic behavior(bond port mac address)
+ '''
+ msg = ''
+ slaves, bond_port = self.run_dpdk_functional_pre()
+ try:
+ self.bonding_8023ad_check_macs(slaves, bond_port)
+ self.check_bonded_device_mac_change(slaves, bond_port)
+ except Exception as e:
+ msg = "bonding 8023ad check mac failed"
+ self.run_dpdk_functional_post()
+ if msg:
+ raise VerifyFailure(msg)
+
+ def test_basic_behav_upDown(self):
+ '''
+ test 802.3ad basic behavior(bond port link up/down)
+ '''
+ msg = ''
+ slaves, bond_port = self.run_dpdk_functional_pre()
+ try:
+ self.check_bonded_device_up_down(bond_port)
+ except Exception as e:
+ msg = "bonding 8023ad check link up/down failed"
+ self.run_dpdk_functional_post()
+ if msg:
+ raise VerifyFailure(msg)
+
+ def test_basic_behav_promisc_mode(self):
+ '''
+ test 802.3ad basic behavior(bond port promisc mode)
+ '''
+ msg = ''
+ slaves, bond_port = self.run_dpdk_functional_pre()
+ try:
+ self.check_bonded_device_promisc_mode(slaves, bond_port)
+ except Exception as e:
+ msg = "bonding 8023ad check promisc mode failed"
+ self.run_dpdk_functional_post()
+ if msg:
+ raise VerifyFailure(msg)
+
+ def test_command_line_option(self):
+ ''' test 802.3ad bonding configs with commandline option '''
+ msgs = []
+ for agg_mode in self.AGG_MODES:
+ bond_port, cur_slaves, tx_port_id = self.run_test_pre(agg_mode)
+ msgs += self.check_cmd_line_option_status(
+ agg_mode, bond_port, cur_slaves)
+ self.bond_inst.close_testpmd()
+ if msgs:
+ for msg in msgs:
+ self.logger.warning(msg)
+ msg = 'fail to config from command line at {0}'.format(agg_mode)
+ raise VerifyFailure(msg)
+
+ def test_basic_behav_agg_mode(self):
+ ''' test 802.3ad aggregator mode setting '''
+ mode = MODE_LACP
+ self.check_8023ad_agg_modes(self.dut_ports, mode)
+
+ def test_basic_dedicated_queues(self):
+ ''' test 802.3ad dedicated queues setting '''
+ mode = MODE_LACP
+ self.check_8023ad_dedicated_queues(self.dut_ports, mode)
\ No newline at end of file
--
1.9.3
^ permalink raw reply [flat|nested] 5+ messages in thread
* Re: [dts] [PATCH V2]pmd_bonded_8023ad: upload automation script
2019-02-28 5:36 ` [dts] [PATCH V2]pmd_bonded_8023ad: " yufengmx
@ 2019-02-28 6:04 ` Mo, YufengX
2019-02-28 8:40 ` Chen, Zhaoyan
2019-02-28 10:58 ` Tu, Lijuan
1 sibling, 1 reply; 5+ messages in thread
From: Mo, YufengX @ 2019-02-28 6:04 UTC (permalink / raw)
To: dts; +Cc: Mo, YufengX
Tested-by: Mo, YufengX <yufengx.mo@intel.com>
> -----Original Message-----
> From: Mo, YufengX
> Sent: Thursday, February 28, 2019 1:36 PM
> To: dts@dpdk.org
> Cc: Mo, YufengX <yufengx.mo@intel.com>
> Subject: [dts][PATCH V2]pmd_bonded_8023ad: upload automation script
>
>
> This automation script is for pmd bonded 8023ad feature.
>
> IEEE 802.3ad Dynamic link aggregation. Creates aggregation groups that share
> the same speed and duplex settings. Utilizes all slaves in the active
> aggregator according to the 802.3ad specification. Slave selection for outgoing
> traffic is done according to the transmit hash policy.
>
> Signed-off-by: yufengmx <yufengx.mo@intel.com>
> ---
> tests/TestSuite_pmd_bonded_8023ad.py | 599 +++++++++++++++++++++++++++++++++++
> 1 file changed, 599 insertions(+)
> create mode 100644 tests/TestSuite_pmd_bonded_8023ad.py
>
> diff --git a/tests/TestSuite_pmd_bonded_8023ad.py b/tests/TestSuite_pmd_bonded_8023ad.py
> new file mode 100644
> index 0000000..cad573e
> --- /dev/null
> +++ b/tests/TestSuite_pmd_bonded_8023ad.py
> @@ -0,0 +1,599 @@
> +# BSD LICENSE
> +#
> +# Copyright(c) 2010-2019 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 time
> +import re
> +import traceback
> +
> +# import dts/framework libs
> +from test_case import TestCase
> +from exception import VerifyFailure
> +
> +# import bonding lib(common methods for pmd bonding command)
> +import bonding
> +from bonding import MODE_LACP, FRAME_SIZE_64
> +
> +######################
> +# bonding 802.3ad mode
> +######################
> +class TestBonding8023AD(TestCase):
> + AGG_MODES = ["bandwidth", "stable", "count"]
> + DEDICATED_QUEUES = ['disable', 'enable']
> +
> + #
> + # On dut, dpdk bonding
> + #
> +
> + def set_8023ad_agg_mode(self, bond_port, mode="bandwidth"):
> + """
> + set bonding agg_mode <port_id> <agg_name>
> +
> + Set 802.11AD Aggregator Mode
> + """
> + cmd = "set bonding agg_mode %d %s" % (bond_port, mode)
> + self.bond_inst.d_console(cmd)
> + cur_mode = self.bond_inst.get_bonding_info(bond_port, 'agg_mode')
> + if mode == cur_mode:
> + fmt = "set bonding agg_mode <{0}> successfully"
> + self.logger.info(fmt.format(mode))
> + else:
> + msg = "failed to set bonding agg_mode <{0}>".format(mode)
> + self.logger.error(msg)
> + raise VerifyFailure(msg)
> +
> + def get_8023ad_agg_mode(self, bond_port):
> + """
> + get 802.3ad mode aggregator Mode
> + """
> + cur_mode = self.bond_inst.get_bonding_info(bond_port, 'agg_mode')
> + return cur_mode
> +
> + def set_8023ad_dedicated_queues(self, bond_port, status='disable'):
> + """
> + set 802.11AD dedicated_queues mode(enable|disable)
> + """
> + cmds =[
> + ["set bonding lacp dedicated_queues %s %s" % (bond_port, status),
> + ['', 'port %s failed'%bond_port, False], 2],]
> + out = self.bond_inst.d_console(cmds)
> + # when set 'hw'
> + if status == 'enable':
> + expected_msg = 'queues for LACP control packets enabled'
> + err_fmt = "link bonding mode 4 (802.3ad) set {0} failed"
> + self.verify(expected_msg in out, err_fmt.format(status))
> + elif status == 'disable':
> + expected_msg = 'queues for LACP control packets disabled'
> + err_fmt = "link bonding mode 4 (802.3ad) set {0} failed"
> + self.verify(expected_msg in out, err_fmt.format(status))
> +
> + def set_8023ad_bonded(self, slaves, bond_mode, ignore=True):
> + ''' set 802.3ad bonded mode for the specified bonding mode '''
> + specified_socket = self.dut.get_numa_id(slaves[0])
> + # create bonded device, add slaves in it
> + bond_port = self.bond_inst.create_bonded_device(bond_mode, specified_socket)
> + if not ignore:
> + # when no slave attached, mac should be 00:00:00:00:00:00
> + self.bonding_8023ad_check_macs_without_slaves(bond_port)
> + # add slave
> + self.bond_inst.add_slave(bond_port, False, '', *slaves)
> + return bond_port
> +
> + def get_pci_link(self, slaves):
> + ''' get slaves ports pci address '''
> + slaves_pci = []
> + for port_id in slaves:
> + slaves_pci.append(self.dut.ports_info[port_id]['pci'])
> + if not slaves_pci:
> + msg = "can't find tx_port pci"
> + self.logger.error(msg)
> + raise VerifyFailure(msg)
> + return slaves_pci
> +
> + def set_bond_port_ready(self, tx_port, bond_port):
> + cmd= "set portlist {0},{1}".format(tx_port, bond_port)
> + self.bond_inst.d_console(cmd)
> + # for port link up is slow and unstable,
> + # every port should start one by one
> + cmds = []
> + port_num = len(self.dut_ports)
> + start_fmt = "port start {0}".format
> + for cnt in range(port_num):
> + cmds.append([start_fmt(cnt), '', 5])
> + self.bond_inst.d_console(cmds)
> + time.sleep(10)
> + self.bond_inst.d_console([start_fmt(self.bond_port), '', 15])
> + time.sleep(5)
> + self.bond_inst.d_console(["start", '', 10])
> + self.logger.info("set bond port ready done !!!")
> +
> + def run_8023ad_pre(self, slaves, bond_mode):
> + bond_port = self.set_8023ad_bonded(slaves, bond_mode)
> + # should set port to stop and make sure port re-sync with parter when
> + # testpmd linking with switch equipment
> + cmds = ["port stop all", '', 15]
> + self.bond_inst.d_console(cmds)
> + time.sleep(2)
> + cmds = ["port start all", '', 10]
> + self.bond_inst.d_console(cmds)
> + time.sleep(2)
> + return bond_port
> +
> + def bonding_8023ad_check_macs_without_slaves(self, bond_port):
> + query_type = 'mac'
> + bond_port_mac = self.bond_inst.get_port_mac(bond_port, query_type)
> + default_mac = '00:00:00:00:00:00'
> + if bond_port_mac == default_mac:
> + msg = "bond port default mac is [{0}]".format(default_mac)
> + self.logger.info(msg)
> + else:
> + fmt = "bond port default mac is [{0}], not expected mac"
> + msg = fmt.format(bond_port_mac)
> + self.logger.warning(msg)
> +
> + def bonding_8023ad_check_macs(self, slaves, bond_port):
> + ''' check if bonded device's mac is one of its slaves mac '''
> + query_type = 'mac'
> + bond_port_mac = self.bond_inst.get_port_mac(bond_port, query_type)
> + if bond_port_mac == '00:00:00:00:00:00':
> + msg = "bond port hasn't set mac address"
> + self.logger.info(msg)
> + return
> +
> + for port_id in slaves:
> + slave_mac = self.bond_inst.get_port_info(port_id, query_type)
> + if bond_port_mac == slave_mac:
> + fmt = "bonded device's mac is slave [{0}]'s mac [{1}]"
> + msg = fmt.format(port_id, slave_mac)
> + self.logger.info(msg)
> + return port_id
> + else:
> + fmt = "bonded device's current mac [{0}] " + \
> + "is not one of its slaves mac"
> + msg = fmt.format(bond_port_mac)
> + # it is not supported by dpdk, but supported by linux normal
> + # bonding/802.3ad tool
> + self.logger.warning('bonding_8023ad_check_macs: ' + msg)
> +
> + def check_bonded_device_mac_change(self, slaves, bond_port):
> + remove_slave = 0
> + cur_slaves = slaves[1:]
> + self.bond_inst.remove_slaves(bond_port, False, *[remove_slave])
> + self.bonding_8023ad_check_macs(cur_slaves, bond_port)
> +
> + def check_bonded_device_start(self, bond_port):
> + cmds = [["port stop all", '', 15],
> + ["port start %s"%bond_port, '', 10],
> + ["start", [' ', 'core dump', False]]]
> + self.bond_inst.d_console(cmds)
> + time.sleep(2)
> +
> + def stop_bonded_device(self, bond_port):
> + cmds =[["stop", '', 10],
> + ["port stop %s"%bond_port, '', 10],]
> + self.bond_inst.d_console(cmds)
> + time.sleep(2)
> +
> + def check_bonded_device_up_down(self, bond_port):
> + # stop bonded device
> + cmd = "port stop {0}".format(bond_port)
> + self.bond_inst.d_console(cmd)
> + status = self.bond_inst.get_port_info(bond_port, 'link_status')
> + if status != 'down':
> + msg = "bond port {0} fail to set down".format(bond_port)
> + self.logger.error(msg)
> + raise VerifyFailure(msg)
> + else:
> + msg = "bond port {0} set down successful !".format(bond_port)
> + self.logger.info(msg)
> + # start bonded device
> + cmds = ["port start {0}".format(bond_port), '', 10]
> + self.bond_inst.d_console(cmds)
> + status = self.bond_inst.get_port_info(bond_port, 'link_status')
> + if status != 'up':
> + msg = "bond port {0} fail to set up".format(bond_port)
> + self.logger.error(msg)
> + raise VerifyFailure(msg)
> + else:
> + msg = "bond port {0} set up successful !".format(bond_port)
> + self.logger.info(msg)
> +
> + def check_bonded_device_promisc_mode(self, slaves, bond_port):
> + # disable bonded device promiscuous mode
> + cmd = "set promisc {0} off".format(bond_port)
> + self.bond_inst.d_console(cmd)
> + time.sleep(2)
> + status = self.bond_inst.get_port_info(bond_port, 'promiscuous_mode')
> + if status != 'disabled':
> + fmt = "bond port {0} fail to set promiscuous mode disabled"
> + msg = fmt.format(bond_port)
> + self.logger.warning(msg)
> + else:
> + fmt = "bond port {0} set promiscuous mode disabled successful !"
> + msg = fmt.format(bond_port)
> + self.logger.info(msg)
> + self.bond_inst.d_console("start")
> + time.sleep(2)
> + # check slave promiscuous mode
> + for port_id in slaves:
> + status = self.bond_inst.get_port_info(port_id, 'promiscuous_mode')
> + if status != 'disabled':
> + fmt = ("slave port {0} promiscuous mode "
> + "isn't the same as bond port 'disabled', ")
> + msg = fmt.format(port_id)
> + self.logger.warning(msg)
> + # dpdk developer hasn't completed this function as linux
> + # document description about `Promiscuous mode`, ignore it here
> + # temporarily
> + #raise VerifyFailure(msg)
> + else:
> + fmt = "slave port {0} promiscuous mode is 'disabled' too"
> + msg = fmt.format(port_id)
> + self.logger.info(msg)
> + # enable bonded device promiscuous mode
> + cmd = "set promisc {0} on".format(bond_port)
> + self.bond_inst.d_console(cmd)
> + time.sleep(3)
> + status = self.bond_inst.get_port_info(bond_port, 'promiscuous_mode')
> + if status != 'enabled':
> + fmt = "bond port {0} fail to set promiscuous mode enabled"
> + msg = fmt.format(bond_port)
> + self.logger.error(msg)
> + raise VerifyFailure(msg)
> + else:
> + fmt = "bond port {0} set promiscuous mode enabled successful !"
> + msg = fmt.format(bond_port)
> + self.logger.info(msg)
> + # check slave promiscuous mode
> + for port_id in slaves:
> + status = self.bond_inst.get_port_info(port_id, 'promiscuous_mode')
> + if status != 'enabled':
> + fmt = "slave port {0} promiscuous mode " + \
> + "isn't the same as bond port 'enabled'"
> + msg = fmt.format(port_id)
> + self.logger.warning(msg)
> + # dpdk developer hasn't completed this function as linux
> + # document description about `Promiscuous mode`, ignore it here
> + # temporarily
> + #raise VerifyFailure(msg)
> + else:
> + fmt = "slave port {0} promiscuous mode is 'enabled' too"
> + msg = fmt.format(port_id)
> + self.logger.info(msg)
> +
> + def check_8023ad_agg_modes(self, slaves, bond_mode):
> + ''' check aggregator mode '''
> + check_results = []
> + default_agg_mode = 'stable'
> + for mode in self.AGG_MODES:
> + try:
> + self.bond_inst.start_testpmd()
> + bond_port = self.set_8023ad_bonded(slaves, bond_mode)
> + cur_agg_mode = self.get_8023ad_agg_mode(bond_port)
> + if cur_agg_mode != default_agg_mode:
> + fmt = ("link bonding mode 4 (802.3ad) default agg mode "
> + "isn't {0}")
> + msg = fmt.format(default_agg_mode)
> + self.logger.warning(msg)
> + # ignore default mode
> + if mode == default_agg_mode:
> + fmt = ("link bonding mode 4 (802.3ad) "
> + "current agg mode is {0}")
> + msg = fmt.format(mode)
> + self.logger.info(msg)
> + continue
> + cmds = [
> + ["port stop all", '', 15],
> + ["port start all", '', 15]]
> + self.bond_inst.d_console(cmds)
> + self.set_8023ad_agg_mode(bond_port, mode)
> + except Exception as e:
> + check_results.append(e); print traceback.format_exc()
> + finally:
> + self.bond_inst.close_testpmd()
> + time.sleep(2)
> +
> + if check_results:
> + for result in check_results:
> + self.logger.error(result)
> + raise VerifyFailure('check_8023ad_agg_modes is failed')
> +
> + def check_8023ad_dedicated_queues(self, slaves, bond_mode):
> + ''' check 802.3ad dedicated queues '''
> + check_results = []
> + default_slow_queue = 'unknown'
> + for mode in self.DEDICATED_QUEUES:
> + try:
> + self.bond_inst.start_testpmd()
> + bond_port = self.set_8023ad_bonded(slaves, bond_mode)
> + self.set_8023ad_dedicated_queues(bond_port, mode)
> + except Exception as e:
> + check_results.append(e); print traceback.format_exc()
> + finally:
> + self.bond_inst.close_testpmd()
> + time.sleep(2)
> +
> + if check_results:
> + for result in check_results:
> + self.logger.error(result)
> + raise VerifyFailure('check_8023ad_dedicated_queues is failed')
> +
> + def get_commandline_options(self, agg_mode):
> + slaves = self.dut_ports
> + # get bonding port configuration
> + slave_pcis = self.get_pci_link(slaves)
> + # create commandline option format
> + bonding_name = 'net_bonding0'
> + slaves_pci = ["slave=" + pci for pci in slave_pcis]
> + bonding_mode = 'mode={0}'.format(str(MODE_LACP))
> + agg_config = 'agg_mode={0}'
> + vdev_format = ",".join([bonding_name] + slaves_pci + \
> + [bonding_mode, agg_config])
> + # command line option
> + mode = str(MODE_LACP)
> + option = vdev_format.format(agg_mode)
> + vdev_option = " --vdev '{0}'".format(option)
> + # 802.3ad bond port only create one, it must be the max port number
> + bond_port = len(self.dut_ports)
> + return bond_port, vdev_option
> +
> + def run_test_pre(self, agg_mode):
> + # get bonding port configuration
> + bond_port, vdev_option = self.get_commandline_options(agg_mode)
> + self.bond_port = bond_port
> + # boot up testpmd
> + self.bond_inst.start_testpmd(eal_option=vdev_option)
> + cur_slaves, cur_agg_mode = self.bond_inst.get_bonding_info(bond_port,
> + ['slaves', 'agg_mode'])
> + if agg_mode != cur_agg_mode:
> + fmt = 'expected agg mode is [{0}], current agg mode is [{1}]'
> + msg = fmt.format(agg_mode, cur_agg_mode)
> + self.logger.warning(msg)
> + # get forwarding port
> + for port_id in range(len(self.dut_ports)):
> + # select a non-slave port as forwarding port to do transmitting
> + if str(port_id) not in cur_slaves:
> + tx_port_id = port_id
> + break
> + else:
> + tx_port_id = bond_port
> + # enable dedicated queue
> + self.set_8023ad_dedicated_queues(bond_port, 'enable')
> + self.set_bond_port_ready(tx_port_id, bond_port)
> + slaves = [int(slave) for slave in cur_slaves]
> +
> + return bond_port, slaves, tx_port_id
> +
> + def run_dpdk_functional_pre(self):
> + mode = MODE_LACP
> + slaves = self.dut_ports[:]
> + self.bond_inst.start_testpmd()
> + bond_port = self.run_8023ad_pre(slaves, mode)
> + return slaves, bond_port
> +
> + def run_dpdk_functional_post(self):
> + self.bond_inst.close_testpmd()
> +
> + def check_cmd_line_option_status(self, agg_mode, bond_port, slaves):
> + mode = str(MODE_LACP)
> + msgs = []
> + cur_mode, cur_slaves, cur_active_slaves, cur_agg_mode =\
> + self.bond_inst.get_bonding_info(bond_port,
> + ['mode', 'slaves', 'active_slaves', 'agg_mode'])
> + # check bonding mode
> + if mode != cur_mode:
> + fmt = 'expected mode is [{0}], current mode is [{1}]'
> + msg = fmt.format(mode, cur_mode)
> + msgs.append(msg)
> + # check bonding 802.3ad agg mode
> + if agg_mode != cur_agg_mode:
> + fmt ='expected agg mode is [{0}], current agg mode is [{1}]'
> + msg = fmt.format(agg_mode, cur_agg_mode)
> + msgs.append(msg)
> + # check bonded slaves
> + _cur_slaves = [int(id) for id in cur_slaves]
> + if not _cur_slaves or cmp(sorted(slaves), sorted(_cur_slaves)) != 0:
> + slaves_str = ' '.join([str(id) for id in slaves])
> + cur_slaves_str = ' '.join([str(id) for id in _cur_slaves]) \
> + if _cur_slaves else ''
> + msg_format = 'expected slaves is [{0}], current slaves is [{1}]'
> + msg = msg_format.format(slaves_str, cur_slaves_str)
> + msgs.append(msg)
> + # check active slaves status before ports start
> + if self.kdriver is 'i40e':
> + if cur_active_slaves:
> + check_active_slaves = [int(id) for id in cur_active_slaves]
> + if cmp(sorted(slaves), sorted(check_active_slaves)) != 0:
> + slaves_str = ' '.join([str(id) for id in slaves])
> + msg_fmt = ('expected active slaves is [{0}], '
> + 'current active slaves is [{1}]')
> + msg = msg_fmt.format(slaves_str, cur_active_slaves)
> + msgs.append(msg)
> + else:
> + msg = 'active slaves should not be empty'
> + #self.logger.warning(msg)
> + #msgs.append(msg)
> + else:
> + if cur_active_slaves:
> + msg = 'active slaves should be empty'
> + #self.logger.warning(msg)
> + #msgs.append(msg)
> + # check status after ports start
> + self.bond_inst.start_ports()
> + # set bonded device to active status
> + if self.kdriver is not 'i40e':
> + cur_active_slaves = [
> + int(id) for id in self.bond_inst.get_bonding_info(
> + bond_port, 'active_slaves')]
> + if not cur_active_slaves or cmp(sorted(slaves),
> + sorted(cur_active_slaves)) != 0:
> + slaves_str = ' '.join([str(id) for id in slaves])
> + active_str = ' '.join([str(id) for id in cur_active_slaves]) \
> + if cur_active_slaves else ''
> + msg_fmt = (
> + 'expected active slaves is [{0}], '
> + 'current active slaves is [{1}]')
> + msg = msg_fmt.format(slaves_str, active_str)
> + msgs.append(msg)
> + return msgs
> + #
> + # Test cases.
> + #
> + def set_up_all(self):
> + """
> + Run before each test suite
> + """
> + self.verify('bsdapp' not in self.target, "Bonding not support freebsd")
> + #------------------------------------------------------------
> + # link peer resource
> + self.dut_ports = self.dut.get_ports()
> + required_link = 2
> + self.verify(len(self.dut_ports) >= required_link, "Insufficient ports")
> + #------------------------------------------------------------
> + # 802.3ad related
> + self.bond_port = None
> + self.bond_slave = self.dut_ports[0]
> + #----------------------------------------------------------------
> + # initialize bonding common methods name
> + config = {
> + 'parent': self,
> + 'pkt_name': 'udp',
> + 'pkt_size': FRAME_SIZE_64,
> + 'src_mac': '52:00:00:00:00:03',
> + 'src_ip': '10.239.129.65',
> + 'src_port': 61,
> + 'dst_ip': '10.239.129.88',
> + 'dst_port': 53,}
> + self.bond_inst = bonding.PmdBonding(**config)
> +
> + def set_up(self):
> + """
> + Run before each test case.
> + """
> + pass
> +
> + def tear_down(self):
> + """
> + Run after each test case.
> + """
> + try:
> + self.bond_inst.close_testpmd()
> + except Exception:
> + pass
> +
> + def tear_down_all(self):
> + """
> + Run after each test suite.
> + """
> + pass
> +
> + def test_basic_behav_startStop(self):
> + '''
> + test 802.3ad basic behavior(bond port start/stop)
> + '''
> + msg = ''
> + slaves, bond_port = self.run_dpdk_functional_pre()
> + try:
> + for _ in range(10):
> + self.check_bonded_device_start(bond_port)
> + self.stop_bonded_device(bond_port)
> + except Exception as e:
> + print traceback.format_exc()
> + msg = "bonding 8023ad check start/stop failed"
> + self.run_dpdk_functional_post()
> + if msg:
> + raise VerifyFailure(msg)
> +
> + def test_basic_behav_mac(self):
> + '''
> + test 802.3ad basic behavior(bond port mac address)
> + '''
> + msg = ''
> + slaves, bond_port = self.run_dpdk_functional_pre()
> + try:
> + self.bonding_8023ad_check_macs(slaves, bond_port)
> + self.check_bonded_device_mac_change(slaves, bond_port)
> + except Exception as e:
> + msg = "bonding 8023ad check mac failed"
> + self.run_dpdk_functional_post()
> + if msg:
> + raise VerifyFailure(msg)
> +
> + def test_basic_behav_upDown(self):
> + '''
> + test 802.3ad basic behavior(bond port link up/down)
> + '''
> + msg = ''
> + slaves, bond_port = self.run_dpdk_functional_pre()
> + try:
> + self.check_bonded_device_up_down(bond_port)
> + except Exception as e:
> + msg = "bonding 8023ad check link up/down failed"
> + self.run_dpdk_functional_post()
> + if msg:
> + raise VerifyFailure(msg)
> +
> + def test_basic_behav_promisc_mode(self):
> + '''
> + test 802.3ad basic behavior(bond port promisc mode)
> + '''
> + msg = ''
> + slaves, bond_port = self.run_dpdk_functional_pre()
> + try:
> + self.check_bonded_device_promisc_mode(slaves, bond_port)
> + except Exception as e:
> + msg = "bonding 8023ad check promisc mode failed"
> + self.run_dpdk_functional_post()
> + if msg:
> + raise VerifyFailure(msg)
> +
> + def test_command_line_option(self):
> + ''' test 802.3ad bonding configs with commandline option '''
> + msgs = []
> + for agg_mode in self.AGG_MODES:
> + bond_port, cur_slaves, tx_port_id = self.run_test_pre(agg_mode)
> + msgs += self.check_cmd_line_option_status(
> + agg_mode, bond_port, cur_slaves)
> + self.bond_inst.close_testpmd()
> + if msgs:
> + for msg in msgs:
> + self.logger.warning(msg)
> + msg = 'fail to config from command line at {0}'.format(agg_mode)
> + raise VerifyFailure(msg)
> +
> + def test_basic_behav_agg_mode(self):
> + ''' test 802.3ad aggregator mode setting '''
> + mode = MODE_LACP
> + self.check_8023ad_agg_modes(self.dut_ports, mode)
> +
> + def test_basic_dedicated_queues(self):
> + ''' test 802.3ad dedicated queues setting '''
> + mode = MODE_LACP
> + self.check_8023ad_dedicated_queues(self.dut_ports, mode)
> \ No newline at end of file
> --
> 1.9.3
^ permalink raw reply [flat|nested] 5+ messages in thread
* Re: [dts] [PATCH V2]pmd_bonded_8023ad: upload automation script
2019-02-28 6:04 ` Mo, YufengX
@ 2019-02-28 8:40 ` Chen, Zhaoyan
0 siblings, 0 replies; 5+ messages in thread
From: Chen, Zhaoyan @ 2019-02-28 8:40 UTC (permalink / raw)
To: Mo, YufengX, dts; +Cc: Mo, YufengX, Chen, Zhaoyan
Acked-by: Chen, Zhaoyan <zhaoyan.chen@intel.com>
Regards,
Zhaoyan Chen
> -----Original Message-----
> From: dts [mailto:dts-bounces@dpdk.org] On Behalf Of Mo, YufengX
> Sent: Thursday, February 28, 2019 2:04 PM
> To: dts@dpdk.org
> Cc: Mo, YufengX <yufengx.mo@intel.com>
> Subject: Re: [dts] [PATCH V2]pmd_bonded_8023ad: upload automation script
>
> Tested-by: Mo, YufengX <yufengx.mo@intel.com>
>
> > -----Original Message-----
> > From: Mo, YufengX
> > Sent: Thursday, February 28, 2019 1:36 PM
> > To: dts@dpdk.org
> > Cc: Mo, YufengX <yufengx.mo@intel.com>
> > Subject: [dts][PATCH V2]pmd_bonded_8023ad: upload automation script
> >
> >
> > This automation script is for pmd bonded 8023ad feature.
> >
> > IEEE 802.3ad Dynamic link aggregation. Creates aggregation groups
> > that share the same speed and duplex settings. Utilizes all slaves in
> > the active aggregator according to the 802.3ad specification. Slave
> > selection for outgoing traffic is done according to the transmit hash policy.
> >
> > Signed-off-by: yufengmx <yufengx.mo@intel.com>
> > ---
> > tests/TestSuite_pmd_bonded_8023ad.py | 599
> > +++++++++++++++++++++++++++++++++++
> > 1 file changed, 599 insertions(+)
> > create mode 100644 tests/TestSuite_pmd_bonded_8023ad.py
> >
> > diff --git a/tests/TestSuite_pmd_bonded_8023ad.py
> > b/tests/TestSuite_pmd_bonded_8023ad.py
> > new file mode 100644
> > index 0000000..cad573e
> > --- /dev/null
> > +++ b/tests/TestSuite_pmd_bonded_8023ad.py
> > @@ -0,0 +1,599 @@
> > +# BSD LICENSE
> > +#
> > +# Copyright(c) 2010-2019 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 time
> > +import re
> > +import traceback
> > +
> > +# import dts/framework libs
> > +from test_case import TestCase
> > +from exception import VerifyFailure
> > +
> > +# import bonding lib(common methods for pmd bonding command) import
> > +bonding from bonding import MODE_LACP, FRAME_SIZE_64
> > +
> > +######################
> > +# bonding 802.3ad mode
> > +######################
> > +class TestBonding8023AD(TestCase):
> > + AGG_MODES = ["bandwidth", "stable", "count"]
> > + DEDICATED_QUEUES = ['disable', 'enable']
> > +
> > + #
> > + # On dut, dpdk bonding
> > + #
> > +
> > + def set_8023ad_agg_mode(self, bond_port, mode="bandwidth"):
> > + """
> > + set bonding agg_mode <port_id> <agg_name>
> > +
> > + Set 802.11AD Aggregator Mode
> > + """
> > + cmd = "set bonding agg_mode %d %s" % (bond_port, mode)
> > + self.bond_inst.d_console(cmd)
> > + cur_mode = self.bond_inst.get_bonding_info(bond_port, 'agg_mode')
> > + if mode == cur_mode:
> > + fmt = "set bonding agg_mode <{0}> successfully"
> > + self.logger.info(fmt.format(mode))
> > + else:
> > + msg = "failed to set bonding agg_mode <{0}>".format(mode)
> > + self.logger.error(msg)
> > + raise VerifyFailure(msg)
> > +
> > + def get_8023ad_agg_mode(self, bond_port):
> > + """
> > + get 802.3ad mode aggregator Mode
> > + """
> > + cur_mode = self.bond_inst.get_bonding_info(bond_port, 'agg_mode')
> > + return cur_mode
> > +
> > + def set_8023ad_dedicated_queues(self, bond_port, status='disable'):
> > + """
> > + set 802.11AD dedicated_queues mode(enable|disable)
> > + """
> > + cmds =[
> > + ["set bonding lacp dedicated_queues %s %s" % (bond_port, status),
> > + ['', 'port %s failed'%bond_port, False], 2],]
> > + out = self.bond_inst.d_console(cmds)
> > + # when set 'hw'
> > + if status == 'enable':
> > + expected_msg = 'queues for LACP control packets enabled'
> > + err_fmt = "link bonding mode 4 (802.3ad) set {0} failed"
> > + self.verify(expected_msg in out, err_fmt.format(status))
> > + elif status == 'disable':
> > + expected_msg = 'queues for LACP control packets disabled'
> > + err_fmt = "link bonding mode 4 (802.3ad) set {0} failed"
> > + self.verify(expected_msg in out, err_fmt.format(status))
> > +
> > + def set_8023ad_bonded(self, slaves, bond_mode, ignore=True):
> > + ''' set 802.3ad bonded mode for the specified bonding mode '''
> > + specified_socket = self.dut.get_numa_id(slaves[0])
> > + # create bonded device, add slaves in it
> > + bond_port = self.bond_inst.create_bonded_device(bond_mode,
> specified_socket)
> > + if not ignore:
> > + # when no slave attached, mac should be 00:00:00:00:00:00
> > + self.bonding_8023ad_check_macs_without_slaves(bond_port)
> > + # add slave
> > + self.bond_inst.add_slave(bond_port, False, '', *slaves)
> > + return bond_port
> > +
> > + def get_pci_link(self, slaves):
> > + ''' get slaves ports pci address '''
> > + slaves_pci = []
> > + for port_id in slaves:
> > + slaves_pci.append(self.dut.ports_info[port_id]['pci'])
> > + if not slaves_pci:
> > + msg = "can't find tx_port pci"
> > + self.logger.error(msg)
> > + raise VerifyFailure(msg)
> > + return slaves_pci
> > +
> > + def set_bond_port_ready(self, tx_port, bond_port):
> > + cmd= "set portlist {0},{1}".format(tx_port, bond_port)
> > + self.bond_inst.d_console(cmd)
> > + # for port link up is slow and unstable,
> > + # every port should start one by one
> > + cmds = []
> > + port_num = len(self.dut_ports)
> > + start_fmt = "port start {0}".format
> > + for cnt in range(port_num):
> > + cmds.append([start_fmt(cnt), '', 5])
> > + self.bond_inst.d_console(cmds)
> > + time.sleep(10)
> > + self.bond_inst.d_console([start_fmt(self.bond_port), '', 15])
> > + time.sleep(5)
> > + self.bond_inst.d_console(["start", '', 10])
> > + self.logger.info("set bond port ready done !!!")
> > +
> > + def run_8023ad_pre(self, slaves, bond_mode):
> > + bond_port = self.set_8023ad_bonded(slaves, bond_mode)
> > + # should set port to stop and make sure port re-sync with parter when
> > + # testpmd linking with switch equipment
> > + cmds = ["port stop all", '', 15]
> > + self.bond_inst.d_console(cmds)
> > + time.sleep(2)
> > + cmds = ["port start all", '', 10]
> > + self.bond_inst.d_console(cmds)
> > + time.sleep(2)
> > + return bond_port
> > +
> > + def bonding_8023ad_check_macs_without_slaves(self, bond_port):
> > + query_type = 'mac'
> > + bond_port_mac = self.bond_inst.get_port_mac(bond_port, query_type)
> > + default_mac = '00:00:00:00:00:00'
> > + if bond_port_mac == default_mac:
> > + msg = "bond port default mac is [{0}]".format(default_mac)
> > + self.logger.info(msg)
> > + else:
> > + fmt = "bond port default mac is [{0}], not expected mac"
> > + msg = fmt.format(bond_port_mac)
> > + self.logger.warning(msg)
> > +
> > + def bonding_8023ad_check_macs(self, slaves, bond_port):
> > + ''' check if bonded device's mac is one of its slaves mac '''
> > + query_type = 'mac'
> > + bond_port_mac = self.bond_inst.get_port_mac(bond_port, query_type)
> > + if bond_port_mac == '00:00:00:00:00:00':
> > + msg = "bond port hasn't set mac address"
> > + self.logger.info(msg)
> > + return
> > +
> > + for port_id in slaves:
> > + slave_mac = self.bond_inst.get_port_info(port_id, query_type)
> > + if bond_port_mac == slave_mac:
> > + fmt = "bonded device's mac is slave [{0}]'s mac [{1}]"
> > + msg = fmt.format(port_id, slave_mac)
> > + self.logger.info(msg)
> > + return port_id
> > + else:
> > + fmt = "bonded device's current mac [{0}] " + \
> > + "is not one of its slaves mac"
> > + msg = fmt.format(bond_port_mac)
> > + # it is not supported by dpdk, but supported by linux normal
> > + # bonding/802.3ad tool
> > + self.logger.warning('bonding_8023ad_check_macs: ' + msg)
> > +
> > + def check_bonded_device_mac_change(self, slaves, bond_port):
> > + remove_slave = 0
> > + cur_slaves = slaves[1:]
> > + self.bond_inst.remove_slaves(bond_port, False, *[remove_slave])
> > + self.bonding_8023ad_check_macs(cur_slaves, bond_port)
> > +
> > + def check_bonded_device_start(self, bond_port):
> > + cmds = [["port stop all", '', 15],
> > + ["port start %s"%bond_port, '', 10],
> > + ["start", [' ', 'core dump', False]]]
> > + self.bond_inst.d_console(cmds)
> > + time.sleep(2)
> > +
> > + def stop_bonded_device(self, bond_port):
> > + cmds =[["stop", '', 10],
> > + ["port stop %s"%bond_port, '', 10],]
> > + self.bond_inst.d_console(cmds)
> > + time.sleep(2)
> > +
> > + def check_bonded_device_up_down(self, bond_port):
> > + # stop bonded device
> > + cmd = "port stop {0}".format(bond_port)
> > + self.bond_inst.d_console(cmd)
> > + status = self.bond_inst.get_port_info(bond_port, 'link_status')
> > + if status != 'down':
> > + msg = "bond port {0} fail to set down".format(bond_port)
> > + self.logger.error(msg)
> > + raise VerifyFailure(msg)
> > + else:
> > + msg = "bond port {0} set down successful !".format(bond_port)
> > + self.logger.info(msg)
> > + # start bonded device
> > + cmds = ["port start {0}".format(bond_port), '', 10]
> > + self.bond_inst.d_console(cmds)
> > + status = self.bond_inst.get_port_info(bond_port, 'link_status')
> > + if status != 'up':
> > + msg = "bond port {0} fail to set up".format(bond_port)
> > + self.logger.error(msg)
> > + raise VerifyFailure(msg)
> > + else:
> > + msg = "bond port {0} set up successful !".format(bond_port)
> > + self.logger.info(msg)
> > +
> > + def check_bonded_device_promisc_mode(self, slaves, bond_port):
> > + # disable bonded device promiscuous mode
> > + cmd = "set promisc {0} off".format(bond_port)
> > + self.bond_inst.d_console(cmd)
> > + time.sleep(2)
> > + status = self.bond_inst.get_port_info(bond_port, 'promiscuous_mode')
> > + if status != 'disabled':
> > + fmt = "bond port {0} fail to set promiscuous mode disabled"
> > + msg = fmt.format(bond_port)
> > + self.logger.warning(msg)
> > + else:
> > + fmt = "bond port {0} set promiscuous mode disabled successful !"
> > + msg = fmt.format(bond_port)
> > + self.logger.info(msg)
> > + self.bond_inst.d_console("start")
> > + time.sleep(2)
> > + # check slave promiscuous mode
> > + for port_id in slaves:
> > + status = self.bond_inst.get_port_info(port_id, 'promiscuous_mode')
> > + if status != 'disabled':
> > + fmt = ("slave port {0} promiscuous mode "
> > + "isn't the same as bond port 'disabled', ")
> > + msg = fmt.format(port_id)
> > + self.logger.warning(msg)
> > + # dpdk developer hasn't completed this function as linux
> > + # document description about `Promiscuous mode`, ignore it here
> > + # temporarily
> > + #raise VerifyFailure(msg)
> > + else:
> > + fmt = "slave port {0} promiscuous mode is 'disabled' too"
> > + msg = fmt.format(port_id)
> > + self.logger.info(msg)
> > + # enable bonded device promiscuous mode
> > + cmd = "set promisc {0} on".format(bond_port)
> > + self.bond_inst.d_console(cmd)
> > + time.sleep(3)
> > + status = self.bond_inst.get_port_info(bond_port, 'promiscuous_mode')
> > + if status != 'enabled':
> > + fmt = "bond port {0} fail to set promiscuous mode enabled"
> > + msg = fmt.format(bond_port)
> > + self.logger.error(msg)
> > + raise VerifyFailure(msg)
> > + else:
> > + fmt = "bond port {0} set promiscuous mode enabled successful !"
> > + msg = fmt.format(bond_port)
> > + self.logger.info(msg)
> > + # check slave promiscuous mode
> > + for port_id in slaves:
> > + status = self.bond_inst.get_port_info(port_id, 'promiscuous_mode')
> > + if status != 'enabled':
> > + fmt = "slave port {0} promiscuous mode " + \
> > + "isn't the same as bond port 'enabled'"
> > + msg = fmt.format(port_id)
> > + self.logger.warning(msg)
> > + # dpdk developer hasn't completed this function as linux
> > + # document description about `Promiscuous mode`, ignore it here
> > + # temporarily
> > + #raise VerifyFailure(msg)
> > + else:
> > + fmt = "slave port {0} promiscuous mode is 'enabled' too"
> > + msg = fmt.format(port_id)
> > + self.logger.info(msg)
> > +
> > + def check_8023ad_agg_modes(self, slaves, bond_mode):
> > + ''' check aggregator mode '''
> > + check_results = []
> > + default_agg_mode = 'stable'
> > + for mode in self.AGG_MODES:
> > + try:
> > + self.bond_inst.start_testpmd()
> > + bond_port = self.set_8023ad_bonded(slaves, bond_mode)
> > + cur_agg_mode = self.get_8023ad_agg_mode(bond_port)
> > + if cur_agg_mode != default_agg_mode:
> > + fmt = ("link bonding mode 4 (802.3ad) default agg mode "
> > + "isn't {0}")
> > + msg = fmt.format(default_agg_mode)
> > + self.logger.warning(msg)
> > + # ignore default mode
> > + if mode == default_agg_mode:
> > + fmt = ("link bonding mode 4 (802.3ad) "
> > + "current agg mode is {0}")
> > + msg = fmt.format(mode)
> > + self.logger.info(msg)
> > + continue
> > + cmds = [
> > + ["port stop all", '', 15],
> > + ["port start all", '', 15]]
> > + self.bond_inst.d_console(cmds)
> > + self.set_8023ad_agg_mode(bond_port, mode)
> > + except Exception as e:
> > + check_results.append(e); print traceback.format_exc()
> > + finally:
> > + self.bond_inst.close_testpmd()
> > + time.sleep(2)
> > +
> > + if check_results:
> > + for result in check_results:
> > + self.logger.error(result)
> > + raise VerifyFailure('check_8023ad_agg_modes is failed')
> > +
> > + def check_8023ad_dedicated_queues(self, slaves, bond_mode):
> > + ''' check 802.3ad dedicated queues '''
> > + check_results = []
> > + default_slow_queue = 'unknown'
> > + for mode in self.DEDICATED_QUEUES:
> > + try:
> > + self.bond_inst.start_testpmd()
> > + bond_port = self.set_8023ad_bonded(slaves, bond_mode)
> > + self.set_8023ad_dedicated_queues(bond_port, mode)
> > + except Exception as e:
> > + check_results.append(e); print traceback.format_exc()
> > + finally:
> > + self.bond_inst.close_testpmd()
> > + time.sleep(2)
> > +
> > + if check_results:
> > + for result in check_results:
> > + self.logger.error(result)
> > + raise VerifyFailure('check_8023ad_dedicated_queues is
> > + failed')
> > +
> > + def get_commandline_options(self, agg_mode):
> > + slaves = self.dut_ports
> > + # get bonding port configuration
> > + slave_pcis = self.get_pci_link(slaves)
> > + # create commandline option format
> > + bonding_name = 'net_bonding0'
> > + slaves_pci = ["slave=" + pci for pci in slave_pcis]
> > + bonding_mode = 'mode={0}'.format(str(MODE_LACP))
> > + agg_config = 'agg_mode={0}'
> > + vdev_format = ",".join([bonding_name] + slaves_pci + \
> > + [bonding_mode, agg_config])
> > + # command line option
> > + mode = str(MODE_LACP)
> > + option = vdev_format.format(agg_mode)
> > + vdev_option = " --vdev '{0}'".format(option)
> > + # 802.3ad bond port only create one, it must be the max port number
> > + bond_port = len(self.dut_ports)
> > + return bond_port, vdev_option
> > +
> > + def run_test_pre(self, agg_mode):
> > + # get bonding port configuration
> > + bond_port, vdev_option = self.get_commandline_options(agg_mode)
> > + self.bond_port = bond_port
> > + # boot up testpmd
> > + self.bond_inst.start_testpmd(eal_option=vdev_option)
> > + cur_slaves, cur_agg_mode = self.bond_inst.get_bonding_info(bond_port,
> > + ['slaves', 'agg_mode'])
> > + if agg_mode != cur_agg_mode:
> > + fmt = 'expected agg mode is [{0}], current agg mode is [{1}]'
> > + msg = fmt.format(agg_mode, cur_agg_mode)
> > + self.logger.warning(msg)
> > + # get forwarding port
> > + for port_id in range(len(self.dut_ports)):
> > + # select a non-slave port as forwarding port to do transmitting
> > + if str(port_id) not in cur_slaves:
> > + tx_port_id = port_id
> > + break
> > + else:
> > + tx_port_id = bond_port
> > + # enable dedicated queue
> > + self.set_8023ad_dedicated_queues(bond_port, 'enable')
> > + self.set_bond_port_ready(tx_port_id, bond_port)
> > + slaves = [int(slave) for slave in cur_slaves]
> > +
> > + return bond_port, slaves, tx_port_id
> > +
> > + def run_dpdk_functional_pre(self):
> > + mode = MODE_LACP
> > + slaves = self.dut_ports[:]
> > + self.bond_inst.start_testpmd()
> > + bond_port = self.run_8023ad_pre(slaves, mode)
> > + return slaves, bond_port
> > +
> > + def run_dpdk_functional_post(self):
> > + self.bond_inst.close_testpmd()
> > +
> > + def check_cmd_line_option_status(self, agg_mode, bond_port, slaves):
> > + mode = str(MODE_LACP)
> > + msgs = []
> > + cur_mode, cur_slaves, cur_active_slaves, cur_agg_mode =\
> > + self.bond_inst.get_bonding_info(bond_port,
> > + ['mode', 'slaves', 'active_slaves', 'agg_mode'])
> > + # check bonding mode
> > + if mode != cur_mode:
> > + fmt = 'expected mode is [{0}], current mode is [{1}]'
> > + msg = fmt.format(mode, cur_mode)
> > + msgs.append(msg)
> > + # check bonding 802.3ad agg mode
> > + if agg_mode != cur_agg_mode:
> > + fmt ='expected agg mode is [{0}], current agg mode is [{1}]'
> > + msg = fmt.format(agg_mode, cur_agg_mode)
> > + msgs.append(msg)
> > + # check bonded slaves
> > + _cur_slaves = [int(id) for id in cur_slaves]
> > + if not _cur_slaves or cmp(sorted(slaves), sorted(_cur_slaves)) != 0:
> > + slaves_str = ' '.join([str(id) for id in slaves])
> > + cur_slaves_str = ' '.join([str(id) for id in _cur_slaves]) \
> > + if _cur_slaves else ''
> > + msg_format = 'expected slaves is [{0}], current slaves is [{1}]'
> > + msg = msg_format.format(slaves_str, cur_slaves_str)
> > + msgs.append(msg)
> > + # check active slaves status before ports start
> > + if self.kdriver is 'i40e':
> > + if cur_active_slaves:
> > + check_active_slaves = [int(id) for id in cur_active_slaves]
> > + if cmp(sorted(slaves), sorted(check_active_slaves)) != 0:
> > + slaves_str = ' '.join([str(id) for id in slaves])
> > + msg_fmt = ('expected active slaves is [{0}], '
> > + 'current active slaves is [{1}]')
> > + msg = msg_fmt.format(slaves_str, cur_active_slaves)
> > + msgs.append(msg)
> > + else:
> > + msg = 'active slaves should not be empty'
> > + #self.logger.warning(msg)
> > + #msgs.append(msg)
> > + else:
> > + if cur_active_slaves:
> > + msg = 'active slaves should be empty'
> > + #self.logger.warning(msg)
> > + #msgs.append(msg)
> > + # check status after ports start
> > + self.bond_inst.start_ports()
> > + # set bonded device to active status
> > + if self.kdriver is not 'i40e':
> > + cur_active_slaves = [
> > + int(id) for id in self.bond_inst.get_bonding_info(
> > + bond_port, 'active_slaves')]
> > + if not cur_active_slaves or cmp(sorted(slaves),
> > + sorted(cur_active_slaves)) != 0:
> > + slaves_str = ' '.join([str(id) for id in slaves])
> > + active_str = ' '.join([str(id) for id in cur_active_slaves]) \
> > + if cur_active_slaves else ''
> > + msg_fmt = (
> > + 'expected active slaves is [{0}], '
> > + 'current active slaves is [{1}]')
> > + msg = msg_fmt.format(slaves_str, active_str)
> > + msgs.append(msg)
> > + return msgs
> > + #
> > + # Test cases.
> > + #
> > + def set_up_all(self):
> > + """
> > + Run before each test suite
> > + """
> > + self.verify('bsdapp' not in self.target, "Bonding not support freebsd")
> > + #------------------------------------------------------------
> > + # link peer resource
> > + self.dut_ports = self.dut.get_ports()
> > + required_link = 2
> > + self.verify(len(self.dut_ports) >= required_link, "Insufficient ports")
> > + #------------------------------------------------------------
> > + # 802.3ad related
> > + self.bond_port = None
> > + self.bond_slave = self.dut_ports[0]
> > + #----------------------------------------------------------------
> > + # initialize bonding common methods name
> > + config = {
> > + 'parent': self,
> > + 'pkt_name': 'udp',
> > + 'pkt_size': FRAME_SIZE_64,
> > + 'src_mac': '52:00:00:00:00:03',
> > + 'src_ip': '10.239.129.65',
> > + 'src_port': 61,
> > + 'dst_ip': '10.239.129.88',
> > + 'dst_port': 53,}
> > + self.bond_inst = bonding.PmdBonding(**config)
> > +
> > + def set_up(self):
> > + """
> > + Run before each test case.
> > + """
> > + pass
> > +
> > + def tear_down(self):
> > + """
> > + Run after each test case.
> > + """
> > + try:
> > + self.bond_inst.close_testpmd()
> > + except Exception:
> > + pass
> > +
> > + def tear_down_all(self):
> > + """
> > + Run after each test suite.
> > + """
> > + pass
> > +
> > + def test_basic_behav_startStop(self):
> > + '''
> > + test 802.3ad basic behavior(bond port start/stop)
> > + '''
> > + msg = ''
> > + slaves, bond_port = self.run_dpdk_functional_pre()
> > + try:
> > + for _ in range(10):
> > + self.check_bonded_device_start(bond_port)
> > + self.stop_bonded_device(bond_port)
> > + except Exception as e:
> > + print traceback.format_exc()
> > + msg = "bonding 8023ad check start/stop failed"
> > + self.run_dpdk_functional_post()
> > + if msg:
> > + raise VerifyFailure(msg)
> > +
> > + def test_basic_behav_mac(self):
> > + '''
> > + test 802.3ad basic behavior(bond port mac address)
> > + '''
> > + msg = ''
> > + slaves, bond_port = self.run_dpdk_functional_pre()
> > + try:
> > + self.bonding_8023ad_check_macs(slaves, bond_port)
> > + self.check_bonded_device_mac_change(slaves, bond_port)
> > + except Exception as e:
> > + msg = "bonding 8023ad check mac failed"
> > + self.run_dpdk_functional_post()
> > + if msg:
> > + raise VerifyFailure(msg)
> > +
> > + def test_basic_behav_upDown(self):
> > + '''
> > + test 802.3ad basic behavior(bond port link up/down)
> > + '''
> > + msg = ''
> > + slaves, bond_port = self.run_dpdk_functional_pre()
> > + try:
> > + self.check_bonded_device_up_down(bond_port)
> > + except Exception as e:
> > + msg = "bonding 8023ad check link up/down failed"
> > + self.run_dpdk_functional_post()
> > + if msg:
> > + raise VerifyFailure(msg)
> > +
> > + def test_basic_behav_promisc_mode(self):
> > + '''
> > + test 802.3ad basic behavior(bond port promisc mode)
> > + '''
> > + msg = ''
> > + slaves, bond_port = self.run_dpdk_functional_pre()
> > + try:
> > + self.check_bonded_device_promisc_mode(slaves, bond_port)
> > + except Exception as e:
> > + msg = "bonding 8023ad check promisc mode failed"
> > + self.run_dpdk_functional_post()
> > + if msg:
> > + raise VerifyFailure(msg)
> > +
> > + def test_command_line_option(self):
> > + ''' test 802.3ad bonding configs with commandline option '''
> > + msgs = []
> > + for agg_mode in self.AGG_MODES:
> > + bond_port, cur_slaves, tx_port_id = self.run_test_pre(agg_mode)
> > + msgs += self.check_cmd_line_option_status(
> > + agg_mode, bond_port, cur_slaves)
> > + self.bond_inst.close_testpmd()
> > + if msgs:
> > + for msg in msgs:
> > + self.logger.warning(msg)
> > + msg = 'fail to config from command line at {0}'.format(agg_mode)
> > + raise VerifyFailure(msg)
> > +
> > + def test_basic_behav_agg_mode(self):
> > + ''' test 802.3ad aggregator mode setting '''
> > + mode = MODE_LACP
> > + self.check_8023ad_agg_modes(self.dut_ports, mode)
> > +
> > + def test_basic_dedicated_queues(self):
> > + ''' test 802.3ad dedicated queues setting '''
> > + mode = MODE_LACP
> > + self.check_8023ad_dedicated_queues(self.dut_ports, mode)
> > \ No newline at end of file
> > --
> > 1.9.3
^ permalink raw reply [flat|nested] 5+ messages in thread
* Re: [dts] [PATCH V2]pmd_bonded_8023ad: upload automation script
2019-02-28 5:36 ` [dts] [PATCH V2]pmd_bonded_8023ad: " yufengmx
2019-02-28 6:04 ` Mo, YufengX
@ 2019-02-28 10:58 ` Tu, Lijuan
1 sibling, 0 replies; 5+ messages in thread
From: Tu, Lijuan @ 2019-02-28 10:58 UTC (permalink / raw)
To: Mo, YufengX, dts; +Cc: Mo, YufengX
Applying: pmd_bonded_8023ad: upload automation script
.git/rebase-apply/patch:69: trailing whitespace.
.git/rebase-apply/patch:94: trailing whitespace.
cmds =[
.git/rebase-apply/patch:180: trailing whitespace.
.git/rebase-apply/patch:419: trailing whitespace.
self.bond_inst.get_bonding_info(bond_port,
.git/rebase-apply/patch:466: trailing whitespace.
if not cur_active_slaves or cmp(sorted(slaves),
warning: 5 lines add whitespace errors.
> -----Original Message-----
> From: dts [mailto:dts-bounces@dpdk.org] On Behalf Of yufengmx
> Sent: Thursday, February 28, 2019 1:36 PM
> To: dts@dpdk.org
> Cc: Mo, YufengX <yufengx.mo@intel.com>
> Subject: [dts] [PATCH V2]pmd_bonded_8023ad: upload automation script
>
>
> This automation script is for pmd bonded 8023ad feature.
>
> IEEE 802.3ad Dynamic link aggregation. Creates aggregation groups that share
> the same speed and duplex settings. Utilizes all slaves in the active aggregator
> according to the 802.3ad specification. Slave selection for outgoing traffic is
> done according to the transmit hash policy.
>
> Signed-off-by: yufengmx <yufengx.mo@intel.com>
> ---
> tests/TestSuite_pmd_bonded_8023ad.py | 599
> +++++++++++++++++++++++++++++++++++
> 1 file changed, 599 insertions(+)
> create mode 100644 tests/TestSuite_pmd_bonded_8023ad.py
>
> diff --git a/tests/TestSuite_pmd_bonded_8023ad.py
> b/tests/TestSuite_pmd_bonded_8023ad.py
> new file mode 100644
> index 0000000..cad573e
> --- /dev/null
> +++ b/tests/TestSuite_pmd_bonded_8023ad.py
> @@ -0,0 +1,599 @@
> +# BSD LICENSE
> +#
> +# Copyright(c) 2010-2019 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 time
> +import re
> +import traceback
> +
> +# import dts/framework libs
> +from test_case import TestCase
> +from exception import VerifyFailure
> +
> +# import bonding lib(common methods for pmd bonding command) import
> +bonding from bonding import MODE_LACP, FRAME_SIZE_64
> +
> +######################
> +# bonding 802.3ad mode
> +######################
> +class TestBonding8023AD(TestCase):
> + AGG_MODES = ["bandwidth", "stable", "count"]
> + DEDICATED_QUEUES = ['disable', 'enable']
> +
> + #
> + # On dut, dpdk bonding
> + #
> +
> + def set_8023ad_agg_mode(self, bond_port, mode="bandwidth"):
> + """
> + set bonding agg_mode <port_id> <agg_name>
> +
> + Set 802.11AD Aggregator Mode
> + """
> + cmd = "set bonding agg_mode %d %s" % (bond_port, mode)
> + self.bond_inst.d_console(cmd)
> + cur_mode = self.bond_inst.get_bonding_info(bond_port, 'agg_mode')
> + if mode == cur_mode:
> + fmt = "set bonding agg_mode <{0}> successfully"
> + self.logger.info(fmt.format(mode))
> + else:
> + msg = "failed to set bonding agg_mode <{0}>".format(mode)
> + self.logger.error(msg)
> + raise VerifyFailure(msg)
> +
> + def get_8023ad_agg_mode(self, bond_port):
> + """
> + get 802.3ad mode aggregator Mode
> + """
> + cur_mode = self.bond_inst.get_bonding_info(bond_port, 'agg_mode')
> + return cur_mode
> +
> + def set_8023ad_dedicated_queues(self, bond_port, status='disable'):
> + """
> + set 802.11AD dedicated_queues mode(enable|disable)
> + """
> + cmds =[
> + ["set bonding lacp dedicated_queues %s %s" % (bond_port, status),
> + ['', 'port %s failed'%bond_port, False], 2],]
> + out = self.bond_inst.d_console(cmds)
> + # when set 'hw'
> + if status == 'enable':
> + expected_msg = 'queues for LACP control packets enabled'
> + err_fmt = "link bonding mode 4 (802.3ad) set {0} failed"
> + self.verify(expected_msg in out, err_fmt.format(status))
> + elif status == 'disable':
> + expected_msg = 'queues for LACP control packets disabled'
> + err_fmt = "link bonding mode 4 (802.3ad) set {0} failed"
> + self.verify(expected_msg in out, err_fmt.format(status))
> +
> + def set_8023ad_bonded(self, slaves, bond_mode, ignore=True):
> + ''' set 802.3ad bonded mode for the specified bonding mode '''
> + specified_socket = self.dut.get_numa_id(slaves[0])
> + # create bonded device, add slaves in it
> + bond_port = self.bond_inst.create_bonded_device(bond_mode,
> specified_socket)
> + if not ignore:
> + # when no slave attached, mac should be 00:00:00:00:00:00
> + self.bonding_8023ad_check_macs_without_slaves(bond_port)
> + # add slave
> + self.bond_inst.add_slave(bond_port, False, '', *slaves)
> + return bond_port
> +
> + def get_pci_link(self, slaves):
> + ''' get slaves ports pci address '''
> + slaves_pci = []
> + for port_id in slaves:
> + slaves_pci.append(self.dut.ports_info[port_id]['pci'])
> + if not slaves_pci:
> + msg = "can't find tx_port pci"
> + self.logger.error(msg)
> + raise VerifyFailure(msg)
> + return slaves_pci
> +
> + def set_bond_port_ready(self, tx_port, bond_port):
> + cmd= "set portlist {0},{1}".format(tx_port, bond_port)
> + self.bond_inst.d_console(cmd)
> + # for port link up is slow and unstable,
> + # every port should start one by one
> + cmds = []
> + port_num = len(self.dut_ports)
> + start_fmt = "port start {0}".format
> + for cnt in range(port_num):
> + cmds.append([start_fmt(cnt), '', 5])
> + self.bond_inst.d_console(cmds)
> + time.sleep(10)
> + self.bond_inst.d_console([start_fmt(self.bond_port), '', 15])
> + time.sleep(5)
> + self.bond_inst.d_console(["start", '', 10])
> + self.logger.info("set bond port ready done !!!")
> +
> + def run_8023ad_pre(self, slaves, bond_mode):
> + bond_port = self.set_8023ad_bonded(slaves, bond_mode)
> + # should set port to stop and make sure port re-sync with parter when
> + # testpmd linking with switch equipment
> + cmds = ["port stop all", '', 15]
> + self.bond_inst.d_console(cmds)
> + time.sleep(2)
> + cmds = ["port start all", '', 10]
> + self.bond_inst.d_console(cmds)
> + time.sleep(2)
> + return bond_port
> +
> + def bonding_8023ad_check_macs_without_slaves(self, bond_port):
> + query_type = 'mac'
> + bond_port_mac = self.bond_inst.get_port_mac(bond_port, query_type)
> + default_mac = '00:00:00:00:00:00'
> + if bond_port_mac == default_mac:
> + msg = "bond port default mac is [{0}]".format(default_mac)
> + self.logger.info(msg)
> + else:
> + fmt = "bond port default mac is [{0}], not expected mac"
> + msg = fmt.format(bond_port_mac)
> + self.logger.warning(msg)
> +
> + def bonding_8023ad_check_macs(self, slaves, bond_port):
> + ''' check if bonded device's mac is one of its slaves mac '''
> + query_type = 'mac'
> + bond_port_mac = self.bond_inst.get_port_mac(bond_port, query_type)
> + if bond_port_mac == '00:00:00:00:00:00':
> + msg = "bond port hasn't set mac address"
> + self.logger.info(msg)
> + return
> +
> + for port_id in slaves:
> + slave_mac = self.bond_inst.get_port_info(port_id, query_type)
> + if bond_port_mac == slave_mac:
> + fmt = "bonded device's mac is slave [{0}]'s mac [{1}]"
> + msg = fmt.format(port_id, slave_mac)
> + self.logger.info(msg)
> + return port_id
> + else:
> + fmt = "bonded device's current mac [{0}] " + \
> + "is not one of its slaves mac"
> + msg = fmt.format(bond_port_mac)
> + # it is not supported by dpdk, but supported by linux normal
> + # bonding/802.3ad tool
> + self.logger.warning('bonding_8023ad_check_macs: ' + msg)
> +
> + def check_bonded_device_mac_change(self, slaves, bond_port):
> + remove_slave = 0
> + cur_slaves = slaves[1:]
> + self.bond_inst.remove_slaves(bond_port, False, *[remove_slave])
> + self.bonding_8023ad_check_macs(cur_slaves, bond_port)
> +
> + def check_bonded_device_start(self, bond_port):
> + cmds = [["port stop all", '', 15],
> + ["port start %s"%bond_port, '', 10],
> + ["start", [' ', 'core dump', False]]]
> + self.bond_inst.d_console(cmds)
> + time.sleep(2)
> +
> + def stop_bonded_device(self, bond_port):
> + cmds =[["stop", '', 10],
> + ["port stop %s"%bond_port, '', 10],]
> + self.bond_inst.d_console(cmds)
> + time.sleep(2)
> +
> + def check_bonded_device_up_down(self, bond_port):
> + # stop bonded device
> + cmd = "port stop {0}".format(bond_port)
> + self.bond_inst.d_console(cmd)
> + status = self.bond_inst.get_port_info(bond_port, 'link_status')
> + if status != 'down':
> + msg = "bond port {0} fail to set down".format(bond_port)
> + self.logger.error(msg)
> + raise VerifyFailure(msg)
> + else:
> + msg = "bond port {0} set down successful !".format(bond_port)
> + self.logger.info(msg)
> + # start bonded device
> + cmds = ["port start {0}".format(bond_port), '', 10]
> + self.bond_inst.d_console(cmds)
> + status = self.bond_inst.get_port_info(bond_port, 'link_status')
> + if status != 'up':
> + msg = "bond port {0} fail to set up".format(bond_port)
> + self.logger.error(msg)
> + raise VerifyFailure(msg)
> + else:
> + msg = "bond port {0} set up successful !".format(bond_port)
> + self.logger.info(msg)
> +
> + def check_bonded_device_promisc_mode(self, slaves, bond_port):
> + # disable bonded device promiscuous mode
> + cmd = "set promisc {0} off".format(bond_port)
> + self.bond_inst.d_console(cmd)
> + time.sleep(2)
> + status = self.bond_inst.get_port_info(bond_port, 'promiscuous_mode')
> + if status != 'disabled':
> + fmt = "bond port {0} fail to set promiscuous mode disabled"
> + msg = fmt.format(bond_port)
> + self.logger.warning(msg)
> + else:
> + fmt = "bond port {0} set promiscuous mode disabled successful !"
> + msg = fmt.format(bond_port)
> + self.logger.info(msg)
> + self.bond_inst.d_console("start")
> + time.sleep(2)
> + # check slave promiscuous mode
> + for port_id in slaves:
> + status = self.bond_inst.get_port_info(port_id, 'promiscuous_mode')
> + if status != 'disabled':
> + fmt = ("slave port {0} promiscuous mode "
> + "isn't the same as bond port 'disabled', ")
> + msg = fmt.format(port_id)
> + self.logger.warning(msg)
> + # dpdk developer hasn't completed this function as linux
> + # document description about `Promiscuous mode`, ignore it here
> + # temporarily
> + #raise VerifyFailure(msg)
> + else:
> + fmt = "slave port {0} promiscuous mode is 'disabled' too"
> + msg = fmt.format(port_id)
> + self.logger.info(msg)
> + # enable bonded device promiscuous mode
> + cmd = "set promisc {0} on".format(bond_port)
> + self.bond_inst.d_console(cmd)
> + time.sleep(3)
> + status = self.bond_inst.get_port_info(bond_port, 'promiscuous_mode')
> + if status != 'enabled':
> + fmt = "bond port {0} fail to set promiscuous mode enabled"
> + msg = fmt.format(bond_port)
> + self.logger.error(msg)
> + raise VerifyFailure(msg)
> + else:
> + fmt = "bond port {0} set promiscuous mode enabled successful !"
> + msg = fmt.format(bond_port)
> + self.logger.info(msg)
> + # check slave promiscuous mode
> + for port_id in slaves:
> + status = self.bond_inst.get_port_info(port_id, 'promiscuous_mode')
> + if status != 'enabled':
> + fmt = "slave port {0} promiscuous mode " + \
> + "isn't the same as bond port 'enabled'"
> + msg = fmt.format(port_id)
> + self.logger.warning(msg)
> + # dpdk developer hasn't completed this function as linux
> + # document description about `Promiscuous mode`, ignore it here
> + # temporarily
> + #raise VerifyFailure(msg)
> + else:
> + fmt = "slave port {0} promiscuous mode is 'enabled' too"
> + msg = fmt.format(port_id)
> + self.logger.info(msg)
> +
> + def check_8023ad_agg_modes(self, slaves, bond_mode):
> + ''' check aggregator mode '''
> + check_results = []
> + default_agg_mode = 'stable'
> + for mode in self.AGG_MODES:
> + try:
> + self.bond_inst.start_testpmd()
> + bond_port = self.set_8023ad_bonded(slaves, bond_mode)
> + cur_agg_mode = self.get_8023ad_agg_mode(bond_port)
> + if cur_agg_mode != default_agg_mode:
> + fmt = ("link bonding mode 4 (802.3ad) default agg mode "
> + "isn't {0}")
> + msg = fmt.format(default_agg_mode)
> + self.logger.warning(msg)
> + # ignore default mode
> + if mode == default_agg_mode:
> + fmt = ("link bonding mode 4 (802.3ad) "
> + "current agg mode is {0}")
> + msg = fmt.format(mode)
> + self.logger.info(msg)
> + continue
> + cmds = [
> + ["port stop all", '', 15],
> + ["port start all", '', 15]]
> + self.bond_inst.d_console(cmds)
> + self.set_8023ad_agg_mode(bond_port, mode)
> + except Exception as e:
> + check_results.append(e); print traceback.format_exc()
> + finally:
> + self.bond_inst.close_testpmd()
> + time.sleep(2)
> +
> + if check_results:
> + for result in check_results:
> + self.logger.error(result)
> + raise VerifyFailure('check_8023ad_agg_modes is failed')
> +
> + def check_8023ad_dedicated_queues(self, slaves, bond_mode):
> + ''' check 802.3ad dedicated queues '''
> + check_results = []
> + default_slow_queue = 'unknown'
> + for mode in self.DEDICATED_QUEUES:
> + try:
> + self.bond_inst.start_testpmd()
> + bond_port = self.set_8023ad_bonded(slaves, bond_mode)
> + self.set_8023ad_dedicated_queues(bond_port, mode)
> + except Exception as e:
> + check_results.append(e); print traceback.format_exc()
> + finally:
> + self.bond_inst.close_testpmd()
> + time.sleep(2)
> +
> + if check_results:
> + for result in check_results:
> + self.logger.error(result)
> + raise VerifyFailure('check_8023ad_dedicated_queues is
> + failed')
> +
> + def get_commandline_options(self, agg_mode):
> + slaves = self.dut_ports
> + # get bonding port configuration
> + slave_pcis = self.get_pci_link(slaves)
> + # create commandline option format
> + bonding_name = 'net_bonding0'
> + slaves_pci = ["slave=" + pci for pci in slave_pcis]
> + bonding_mode = 'mode={0}'.format(str(MODE_LACP))
> + agg_config = 'agg_mode={0}'
> + vdev_format = ",".join([bonding_name] + slaves_pci + \
> + [bonding_mode, agg_config])
> + # command line option
> + mode = str(MODE_LACP)
> + option = vdev_format.format(agg_mode)
> + vdev_option = " --vdev '{0}'".format(option)
> + # 802.3ad bond port only create one, it must be the max port number
> + bond_port = len(self.dut_ports)
> + return bond_port, vdev_option
> +
> + def run_test_pre(self, agg_mode):
> + # get bonding port configuration
> + bond_port, vdev_option = self.get_commandline_options(agg_mode)
> + self.bond_port = bond_port
> + # boot up testpmd
> + self.bond_inst.start_testpmd(eal_option=vdev_option)
> + cur_slaves, cur_agg_mode = self.bond_inst.get_bonding_info(bond_port,
> + ['slaves', 'agg_mode'])
> + if agg_mode != cur_agg_mode:
> + fmt = 'expected agg mode is [{0}], current agg mode is [{1}]'
> + msg = fmt.format(agg_mode, cur_agg_mode)
> + self.logger.warning(msg)
> + # get forwarding port
> + for port_id in range(len(self.dut_ports)):
> + # select a non-slave port as forwarding port to do transmitting
> + if str(port_id) not in cur_slaves:
> + tx_port_id = port_id
> + break
> + else:
> + tx_port_id = bond_port
> + # enable dedicated queue
> + self.set_8023ad_dedicated_queues(bond_port, 'enable')
> + self.set_bond_port_ready(tx_port_id, bond_port)
> + slaves = [int(slave) for slave in cur_slaves]
> +
> + return bond_port, slaves, tx_port_id
> +
> + def run_dpdk_functional_pre(self):
> + mode = MODE_LACP
> + slaves = self.dut_ports[:]
> + self.bond_inst.start_testpmd()
> + bond_port = self.run_8023ad_pre(slaves, mode)
> + return slaves, bond_port
> +
> + def run_dpdk_functional_post(self):
> + self.bond_inst.close_testpmd()
> +
> + def check_cmd_line_option_status(self, agg_mode, bond_port, slaves):
> + mode = str(MODE_LACP)
> + msgs = []
> + cur_mode, cur_slaves, cur_active_slaves, cur_agg_mode =\
> + self.bond_inst.get_bonding_info(bond_port,
> + ['mode', 'slaves', 'active_slaves', 'agg_mode'])
> + # check bonding mode
> + if mode != cur_mode:
> + fmt = 'expected mode is [{0}], current mode is [{1}]'
> + msg = fmt.format(mode, cur_mode)
> + msgs.append(msg)
> + # check bonding 802.3ad agg mode
> + if agg_mode != cur_agg_mode:
> + fmt ='expected agg mode is [{0}], current agg mode is [{1}]'
> + msg = fmt.format(agg_mode, cur_agg_mode)
> + msgs.append(msg)
> + # check bonded slaves
> + _cur_slaves = [int(id) for id in cur_slaves]
> + if not _cur_slaves or cmp(sorted(slaves), sorted(_cur_slaves)) != 0:
> + slaves_str = ' '.join([str(id) for id in slaves])
> + cur_slaves_str = ' '.join([str(id) for id in _cur_slaves]) \
> + if _cur_slaves else ''
> + msg_format = 'expected slaves is [{0}], current slaves is [{1}]'
> + msg = msg_format.format(slaves_str, cur_slaves_str)
> + msgs.append(msg)
> + # check active slaves status before ports start
> + if self.kdriver is 'i40e':
> + if cur_active_slaves:
> + check_active_slaves = [int(id) for id in cur_active_slaves]
> + if cmp(sorted(slaves), sorted(check_active_slaves)) != 0:
> + slaves_str = ' '.join([str(id) for id in slaves])
> + msg_fmt = ('expected active slaves is [{0}], '
> + 'current active slaves is [{1}]')
> + msg = msg_fmt.format(slaves_str, cur_active_slaves)
> + msgs.append(msg)
> + else:
> + msg = 'active slaves should not be empty'
> + #self.logger.warning(msg)
> + #msgs.append(msg)
> + else:
> + if cur_active_slaves:
> + msg = 'active slaves should be empty'
> + #self.logger.warning(msg)
> + #msgs.append(msg)
> + # check status after ports start
> + self.bond_inst.start_ports()
> + # set bonded device to active status
> + if self.kdriver is not 'i40e':
> + cur_active_slaves = [
> + int(id) for id in self.bond_inst.get_bonding_info(
> + bond_port, 'active_slaves')]
> + if not cur_active_slaves or cmp(sorted(slaves),
> + sorted(cur_active_slaves)) != 0:
> + slaves_str = ' '.join([str(id) for id in slaves])
> + active_str = ' '.join([str(id) for id in cur_active_slaves]) \
> + if cur_active_slaves else ''
> + msg_fmt = (
> + 'expected active slaves is [{0}], '
> + 'current active slaves is [{1}]')
> + msg = msg_fmt.format(slaves_str, active_str)
> + msgs.append(msg)
> + return msgs
> + #
> + # Test cases.
> + #
> + def set_up_all(self):
> + """
> + Run before each test suite
> + """
> + self.verify('bsdapp' not in self.target, "Bonding not support freebsd")
> + #------------------------------------------------------------
> + # link peer resource
> + self.dut_ports = self.dut.get_ports()
> + required_link = 2
> + self.verify(len(self.dut_ports) >= required_link, "Insufficient ports")
> + #------------------------------------------------------------
> + # 802.3ad related
> + self.bond_port = None
> + self.bond_slave = self.dut_ports[0]
> + #----------------------------------------------------------------
> + # initialize bonding common methods name
> + config = {
> + 'parent': self,
> + 'pkt_name': 'udp',
> + 'pkt_size': FRAME_SIZE_64,
> + 'src_mac': '52:00:00:00:00:03',
> + 'src_ip': '10.239.129.65',
> + 'src_port': 61,
> + 'dst_ip': '10.239.129.88',
> + 'dst_port': 53,}
> + self.bond_inst = bonding.PmdBonding(**config)
> +
> + def set_up(self):
> + """
> + Run before each test case.
> + """
> + pass
> +
> + def tear_down(self):
> + """
> + Run after each test case.
> + """
> + try:
> + self.bond_inst.close_testpmd()
> + except Exception:
> + pass
> +
> + def tear_down_all(self):
> + """
> + Run after each test suite.
> + """
> + pass
> +
> + def test_basic_behav_startStop(self):
> + '''
> + test 802.3ad basic behavior(bond port start/stop)
> + '''
> + msg = ''
> + slaves, bond_port = self.run_dpdk_functional_pre()
> + try:
> + for _ in range(10):
> + self.check_bonded_device_start(bond_port)
> + self.stop_bonded_device(bond_port)
> + except Exception as e:
> + print traceback.format_exc()
> + msg = "bonding 8023ad check start/stop failed"
> + self.run_dpdk_functional_post()
> + if msg:
> + raise VerifyFailure(msg)
> +
> + def test_basic_behav_mac(self):
> + '''
> + test 802.3ad basic behavior(bond port mac address)
> + '''
> + msg = ''
> + slaves, bond_port = self.run_dpdk_functional_pre()
> + try:
> + self.bonding_8023ad_check_macs(slaves, bond_port)
> + self.check_bonded_device_mac_change(slaves, bond_port)
> + except Exception as e:
> + msg = "bonding 8023ad check mac failed"
> + self.run_dpdk_functional_post()
> + if msg:
> + raise VerifyFailure(msg)
> +
> + def test_basic_behav_upDown(self):
> + '''
> + test 802.3ad basic behavior(bond port link up/down)
> + '''
> + msg = ''
> + slaves, bond_port = self.run_dpdk_functional_pre()
> + try:
> + self.check_bonded_device_up_down(bond_port)
> + except Exception as e:
> + msg = "bonding 8023ad check link up/down failed"
> + self.run_dpdk_functional_post()
> + if msg:
> + raise VerifyFailure(msg)
> +
> + def test_basic_behav_promisc_mode(self):
> + '''
> + test 802.3ad basic behavior(bond port promisc mode)
> + '''
> + msg = ''
> + slaves, bond_port = self.run_dpdk_functional_pre()
> + try:
> + self.check_bonded_device_promisc_mode(slaves, bond_port)
> + except Exception as e:
> + msg = "bonding 8023ad check promisc mode failed"
> + self.run_dpdk_functional_post()
> + if msg:
> + raise VerifyFailure(msg)
> +
> + def test_command_line_option(self):
> + ''' test 802.3ad bonding configs with commandline option '''
> + msgs = []
> + for agg_mode in self.AGG_MODES:
> + bond_port, cur_slaves, tx_port_id = self.run_test_pre(agg_mode)
> + msgs += self.check_cmd_line_option_status(
> + agg_mode, bond_port, cur_slaves)
> + self.bond_inst.close_testpmd()
> + if msgs:
> + for msg in msgs:
> + self.logger.warning(msg)
> + msg = 'fail to config from command line at {0}'.format(agg_mode)
> + raise VerifyFailure(msg)
> +
> + def test_basic_behav_agg_mode(self):
> + ''' test 802.3ad aggregator mode setting '''
> + mode = MODE_LACP
> + self.check_8023ad_agg_modes(self.dut_ports, mode)
> +
> + def test_basic_dedicated_queues(self):
> + ''' test 802.3ad dedicated queues setting '''
> + mode = MODE_LACP
> + self.check_8023ad_dedicated_queues(self.dut_ports, mode)
> \ No newline at end of file
> --
> 1.9.3
^ permalink raw reply [flat|nested] 5+ messages in thread
end of thread, other threads:[~2019-02-28 10:59 UTC | newest]
Thread overview: 5+ messages (download: mbox.gz / follow: Atom feed)
-- links below jump to the message on this page --
2019-02-28 5:36 [dts] [PATCH V2][pmd_bonded_8023ad]: upload automation script yufengmx
2019-02-28 5:36 ` [dts] [PATCH V2]pmd_bonded_8023ad: " yufengmx
2019-02-28 6:04 ` Mo, YufengX
2019-02-28 8:40 ` Chen, Zhaoyan
2019-02-28 10:58 ` Tu, Lijuan
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).