Add a Consts file to Common that holds classes that have only constants values and no methods. Add there a class for L2 multicast-router port related consts. Signed-off-by: Nogah Frankel <nogahf(a)mellanox.com&gt; Reviewed-by: Yotam Gigi <yotamg(a)mellanox.com&gt; --- lnst/Common/Consts.py | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) create mode 100644 lnst/Common/Consts.py diff --git a/lnst/Common/Consts.py b/lnst/Common/Consts.py new file mode 100644 index 0000000..bdcff0b --- /dev/null +++ b/lnst/Common/Consts.py @@ -0,0 +1,16 @@ +""" +General perpuses constants file + +Copyright 2016-2017 Mellanox Technologies. All rights reserved. +Licensed under the GNU General Public License, version 2 as +published by the Free Software Foundation; see COPYING for details. +""" + +__autor__ = """ +nogahf(a)mellanox.com (Nogah Frankel) +""" + +class MCAST_ROUTER_PORT: + FIXED_OFF = 0 + LEARNING = 1 + FIXED_ON = 2 -- 2.4.3

Hi Jan This file should contain a lot of consts classes, for multiple purposes. This first class is recipe only, but other classes might not be. (Actually, we have a code in writing right now that have a consts class that is in use in some BridgeTool function). I agree that this file is quite general, and in the future it should probably become a package with several files under it , but I think that we should wait until we have some more classes in there before deciding how to break it apart. Thanks Nogah

Add functions to set mcast flood on\off on an interface that is a bridge slave. Add a similar support to set mrouter port state. Mcast flood flag decides whether multicast packets should be flooded to a port when multicast snooping is disabled. Default is on. Mrouter port state can be fixed on, fixed off or learning, where the later indicates that the mrouter state should be learned according to IGMP queries. If a port is set to be mrouter port, all multicast packets will be flooded to it, when multicast snooping is enabled. Signed-off-by: Nogah Frankel <nogahf(a)mellanox.com&gt; Reviewed-by: Yotam Gigi <yotamg(a)mellanox.com&gt; --- lnst/Controller/Machine.py | 7 +++++++ lnst/Controller/Task.py | 6 ++++++ lnst/Slave/InterfaceManager.py | 13 +++++++++++++ lnst/Slave/NetTestSlave.py | 18 ++++++++++++++++++ 4 files changed, 44 insertions(+) diff --git a/lnst/Controller/Machine.py b/lnst/Controller/Machine.py index fe196ad..7077018 100644 --- a/lnst/Controller/Machine.py +++ b/lnst/Controller/Machine.py @@ -966,6 +966,13 @@ class Interface(object): self._machine._rpc_call_x(self._netns, "set_br_state", self._id, br_state_info) + def set_mcast_flood(self, on): + self._machine._rpc_call_x(self._netns, "set_mcast_flood", self._id, on) + + def set_mcast_router(self, state): + self._machine._rpc_call_x(self._netns, "set_mcast_router", self._id, + state) + def set_speed(self, speed): self._machine._rpc_call_x(self._netns, "set_speed", self._id, speed) diff --git a/lnst/Controller/Task.py b/lnst/Controller/Task.py index b5080d2..daf52ab 100644 --- a/lnst/Controller/Task.py +++ b/lnst/Controller/Task.py @@ -700,6 +700,12 @@ class InterfaceAPI(object): def set_br_state(_self, state, self=False, master=False): _self._if.set_br_state({"state": state, "self": self, "master": master}) + def set_mcast_flood(self, on): + return self._if.set_mcast_flood(on) + + def set_mcast_router(self, state): + return self._if.set_mcast_router(state) + def set_speed(self, speed): return self._if.set_speed(speed) diff --git a/lnst/Slave/InterfaceManager.py b/lnst/Slave/InterfaceManager.py index b21c962..e6399b3 100644 --- a/lnst/Slave/InterfaceManager.py +++ b/lnst/Slave/InterfaceManager.py @@ -797,3 +797,16 @@ class Device(object): def set_pause_off(self): exec_cmd("ethtool -A %s rx off tx off autoneg off" % self._name, die_on_err=False) + + def set_mcast_flood(self, on = True): + cmd = "ip link set dev %s type bridge_slave mcast_flood " % self._name + if on: + cmd += "on" + else: + cmd += "off" + exec_cmd(cmd) + + def set_mcast_router(self, state): + cmd = "ip link set dev %s type bridge_slave mcast_router %d" % \ + (self._name, state) + exec_cmd(cmd) diff --git a/lnst/Slave/NetTestSlave.py b/lnst/Slave/NetTestSlave.py index ddbfe72..8a39f90 100644 --- a/lnst/Slave/NetTestSlave.py +++ b/lnst/Slave/NetTestSlave.py @@ -1031,6 +1031,24 @@ class SlaveMethods: return False return True + def set_mcast_flood(self, if_id, on): + dev = self._if_manager.get_mapped_device(if_id) + if dev is not None: + dev.set_mcast_flood(on) + else: + logging.error("Device with id '%s' not found." % if_id) + return False + return True + + def set_mcast_router(self, if_id, state): + dev = self._if_manager.get_mapped_device(if_id) + if dev is not None: + dev.set_mcast_router(state) + else: + logging.error("Device with id '%s' not found." % if_id) + return False + return True + class ServerHandler(ConnectionHandler): def __init__(self, addr): super(ServerHandler, self).__init__() -- 2.4.3

Add a function that returns the ifstat (relative statistic, being set to 0 on every read) for cpu hits (packets that went on slow path). Can be used only on devices that support this ifstat extension. Signed-off-by: Nogah Frankel <nogahf(a)mellanox.com&gt; Reviewed-by: Yotam Gigi <yotamg(a)mellanox.com&gt; --- lnst/Controller/Machine.py | 5 +++++ lnst/Controller/Task.py | 3 +++ lnst/Slave/InterfaceManager.py | 29 +++++++++++++++++++++++++++++ lnst/Slave/NetTestSlave.py | 7 +++++++ 4 files changed, 44 insertions(+) diff --git a/lnst/Controller/Machine.py b/lnst/Controller/Machine.py index a6a3165..1836f71 100644 --- a/lnst/Controller/Machine.py +++ b/lnst/Controller/Machine.py @@ -783,6 +783,11 @@ class Interface(object): self._id) return stats + def link_cpu_ifstat(self): + stats = self._machine._rpc_call_x(self._netns, "link_cpu_ifstat", + self._id) + return stats + def set_addresses(self, ips): self._addresses = ips self._machine._rpc_call_x(self._netns, "set_addresses", diff --git a/lnst/Controller/Task.py b/lnst/Controller/Task.py index 10b937d..70293a5 100644 --- a/lnst/Controller/Task.py +++ b/lnst/Controller/Task.py @@ -610,6 +610,9 @@ class InterfaceAPI(object): def link_stats(self): return self._if.link_stats() + def link_cpu_ifstat(self): + return self._if.link_cpu_ifstat() + def set_link_up(self): return self._if.set_link_up() diff --git a/lnst/Slave/InterfaceManager.py b/lnst/Slave/InterfaceManager.py index e6399b3..e28682f 100644 --- a/lnst/Slave/InterfaceManager.py +++ b/lnst/Slave/InterfaceManager.py @@ -705,6 +705,35 @@ class Device(object): "tx_collsns": tx_stats[5]}) return stats + def link_cpu_ifstat(self): + stats = {"devname": self._name, + "hwaddr": self._hwaddr} + try: + out, _ = exec_cmd("ifstat -x c %s" % self._name) + except: + return {} + lines = iter(out.split("\n")) + line_first = "" + line_decond = "" + for line in lines: + if (len(line.split()) == 0): + continue + if (line.split()[0] == self._name): + break + else: + return {} + stats_data = line.split()[1:] + for i in range(len(stats_data)): + stats_data[i] = stats_data[i].replace("K", "000") + stats_data[i] = stats_data[i].replace("M", "000000") + + stats_data = map(int, stats_data) + stats["rx_packets"] = stats_data[0] + stats["tx_packets"] = stats_data[2] + stats["rx_bytes"] = stats_data[4] + stats["tx_bytes"] = stats_data[6] + return stats + def set_addresses(self, ips): self._conf.set_addresses(ips) exec_cmd("ip addr flush %s" % self._name) diff --git a/lnst/Slave/NetTestSlave.py b/lnst/Slave/NetTestSlave.py index af80f55..cdcf951 100644 --- a/lnst/Slave/NetTestSlave.py +++ b/lnst/Slave/NetTestSlave.py @@ -194,6 +194,13 @@ class SlaveMethods: return {} return dev.get_if_data() + def link_cpu_ifstat(self, if_id): + dev = self._if_manager.get_mapped_device(if_id) + if dev is None: + logging.error("Device with id '%s' not found." % if_id) + return {} + return dev.link_cpu_ifstat() + def link_stats(self, if_id): dev = self._if_manager.get_mapped_device(if_id) if dev is None: -- 2.4.3

Add a function that validates that the amount of packets went via slowpath is below a threshold. It counts the traffic with ifstat, meaning that it returns the traffic count since the last call to it. So one should call it and ignore the results before starting the traffic. Add this check to test 20 to check that data is not going via slowpath. Signed-off-by: Nogah Frankel <nogahf(a)mellanox.com&gt; Reviewed-by: Yotam Gigi <yotamg(a)mellanox.com&gt; --- recipes/switchdev/TestLib.py | 17 +++++++++++++++++ recipes/switchdev/l2-020-bridge_mdb.py | 7 +++++-- 2 files changed, 22 insertions(+), 2 deletions(-) diff --git a/recipes/switchdev/TestLib.py b/recipes/switchdev/TestLib.py index 62db24e..e6ba505 100644 --- a/recipes/switchdev/TestLib.py +++ b/recipes/switchdev/TestLib.py @@ -260,6 +260,23 @@ class TestLib: ["shouldn't", "should"][expect]) self.custom(iface.get_host(), "iperf_mc", err_str) + def check_cpu_traffic(self, ifaces, thershold = 100, test = True): + err = False + for iface in ifaces: + stats = iface.link_cpu_ifstat() + if not test: + continue + + # Check tx only, since in rx case it is hard to distinguish between + # offloading error and "legal" cpu traps. + if stats["tx_packets"] > thershold: + err = True + self.custom(iface.get_host(), "cpu traffic", + "%s sent too much data (%d packets)" % \ + (stats["devname"], stats["tx_packets"])) + if not err: + self.custom(iface.get_host(), "cpu traffic", "") + def pktgen(self, if1, if2, pkt_size, desc=None, thread_option=[], **kwargs): if1.set_mtu(self._mtu) m1 = if1.get_host() diff --git a/recipes/switchdev/l2-020-bridge_mdb.py b/recipes/switchdev/l2-020-bridge_mdb.py index f48d11e..7f89104 100644 --- a/recipes/switchdev/l2-020-bridge_mdb.py +++ b/recipes/switchdev/l2-020-bridge_mdb.py @@ -33,8 +33,9 @@ def do_task(ctl, hosts, ifaces, aliases): m1_if, m2_if, m3_if, m4_if, sw_if1, sw_if2, sw_if3, sw_if4 = ifaces # Create a bridge - sw_br = sw.create_bridge(slaves=[sw_if1, sw_if2, sw_if3, sw_if4], - options={"vlan_filtering": 1}) + sw_ports = [sw_if1, sw_if2, sw_if3, sw_if4] + sw_br = sw.create_bridge(slaves=sw_ports, options={"vlan_filtering": 1, + "multicast_querier": 1}) m1_if.set_addresses(test_ip(1,1)) m2_if.set_addresses(test_ip(1, 2)) @@ -44,6 +45,7 @@ def do_task(ctl, hosts, ifaces, aliases): tl = TestLib(ctl, aliases) + tl.check_cpu_traffic(sw_ports, test=False) for iface in [m1_if, m2_if, m3_if, m4_if]: iface.enable_multicast() @@ -52,6 +54,7 @@ def do_task(ctl, hosts, ifaces, aliases): test_standard_mutlicast(tl, m2_if, [m3_if, m4_if, m1_if], [], mcgrp(5)) for iface in [m1_if, m2_if, m3_if, m4_if]: iface.disable_multicast() + tl.check_cpu_traffic(sw_ports) do_task(ctl, [ctl.get_host("machine1"), ctl.get_host("machine2"), -- 2.4.3

This test tests MC flood to ports that is configured statically to be mrouter, meaning that it should get all the MC traffic, regardless of join requests. The test uses 4 ports: one that sends the data, one that send no join request and shouldn't get any traffic, one that sends some join requests and should get some of the traffic and a PUT (port under tests). The test use 3 MC groups: - Unregistered one (no port sent join request to it). - A MC group that was registered to only by a port that is not the PUT. - A MC group that is registered to by the previous port and the PUT. The test's algorithm is as follows: - Send the needed join requests. - Set the PUT to be mrouter (statically on) - send traffic from all of the MC groups. - Check that all of them were sent to the PUT. - Check that the other ports got the traffic according to the join requests - Set the PUT to not be mrouter (statically off) - Send traffic from all of the MC groups. - Check that all the ports (including the PUT) got the traffic according to the join requests - Check that all the traffic hadn't gone via slowpath Signed-off-by: Nogah Frankel <nogahf(a)mellanox.com&gt; Reviewed-by: Yotam Gigi <yotamg(a)mellanox.com&gt; --- .../l2-023-bridge_mdb_mc_router_port_basic.py | 108 +++++++++++++++++++++ .../l2-023-bridge_mdb_mc_router_port_basic.xml | 70 +++++++++++++ 2 files changed, 178 insertions(+) create mode 100644 recipes/switchdev/l2-023-bridge_mdb_mc_router_port_basic.py create mode 100644 recipes/switchdev/l2-023-bridge_mdb_mc_router_port_basic.xml diff --git a/recipes/switchdev/l2-023-bridge_mdb_mc_router_port_basic.py b/recipes/switchdev/l2-023-bridge_mdb_mc_router_port_basic.py new file mode 100644 index 0000000..562454e --- /dev/null +++ b/recipes/switchdev/l2-023-bridge_mdb_mc_router_port_basic.py @@ -0,0 +1,108 @@ +""" +Copyright 2016 Mellanox Technologies. All rights reserved. +Licensed under the GNU General Public License, version 2 as +published by the Free Software Foundation; see COPYING for details. +""" + +__author__ = """ +nogahf(a)mellanox.com (Nogah Frankel) +""" + +from lnst.Controller.Task import ctl +from TestLib import TestLib +from time import sleep +import logging +from lnst.Common.Consts import MCAST_ROUTER_PORT + +def test_ip(major, minor): + return ["192.168.10%d.%d/24" % (major, minor), + "2002:%d::%d/64" % (major, minor)] + +def mcgrp(i): + return "239.255.1.%d" % i + +def do_task(ctl, hosts, ifaces, aliases): + m1, m2, sw = hosts + m1_if, m2_if, m3_if, m4_if, sw_if1, sw_if2, sw_if3, sw_if4 = ifaces + + # Create a bridge + sw_ports = [sw_if1, sw_if2, sw_if3, sw_if4] + sw_br = sw.create_bridge(slaves=sw_ports, options={"vlan_filtering": 1}) + + m1_if.set_addresses(test_ip(1, 1)) + m2_if.set_addresses(test_ip(1, 2)) + m3_if.set_addresses(test_ip(1, 3)) + m4_if.set_addresses(test_ip(1, 4)) + sleep(15) + + tl = TestLib(ctl, aliases) + for iface in [m1_if, m2_if, m3_if, m4_if]: + iface.enable_multicast() + + logging.info("%s join %s" % (m3_if.get_devname(), mcgrp(1))) + s_procs_1 = [tl.iperf_mc_listen(m3_if, mcgrp(1))] + logging.info("%s and %s join %s" % (m2_if.get_devname(), + m3_if.get_devname(), mcgrp(2))) + s_procs_2 = [tl.iperf_mc_listen(listener, mcgrp(2)) + for listener in [m2_if, m3_if]] + tl._ctl.wait(2) + + logging.info("set mrouter on") + mcast_iface = [m2_if, m3_if, m4_if] + sw_if2.set_mcast_router(MCAST_ROUTER_PORT.FIXED_ON) + + logging.info("check registered mid flood") + tl.check_cpu_traffic(sw_ports, test=False) + result = tl.iperf_mc(m1_if, mcast_iface, mcgrp(1)) + tl.mc_ipref_compare_result(mcast_iface, result, [True, True, False]) + tl.check_cpu_traffic(sw_ports) + + logging.info("check registered mid with mrouter flood") + result = tl.iperf_mc(m1_if, mcast_iface, mcgrp(2)) + tl.mc_ipref_compare_result(mcast_iface, result, [True, True, False]) + tl.check_cpu_traffic(sw_ports) + + logging.info("check unregistered mc flood") + result = tl.iperf_mc(m1_if, mcast_iface, mcgrp(3)) + tl.mc_ipref_compare_result(mcast_iface, result, [True, False, False]) + tl.check_cpu_traffic(sw_ports) + + logging.info("set mrouter off") + sw_if2.set_mcast_router(MCAST_ROUTER_PORT.FIXED_OFF) + tl._ctl.wait(2) + + logging.info("check registered mid flood") + result = tl.iperf_mc(m1_if, mcast_iface, mcgrp(1)) + tl.mc_ipref_compare_result(mcast_iface, result, [False, True, False]) + tl.check_cpu_traffic(sw_ports) + + logging.info("check registered mid with mrouter flood") + result = tl.iperf_mc(m1_if, mcast_iface, mcgrp(2)) + tl.mc_ipref_compare_result(mcast_iface, result, [True, True, False]) + tl.check_cpu_traffic(sw_ports) + + logging.info("check unregistered mc flood") + result = tl.iperf_mc(m1_if, mcast_iface, mcgrp(3)) + tl.mc_ipref_compare_result(mcast_iface, result, [False, False, False]) + tl.check_cpu_traffic(sw_ports) + + sw_if2.set_mcast_router(MCAST_ROUTER_PORT.LEARNING) + + for proc in s_procs_1 + s_procs_2: + proc.intr() + + for iface in mcast_iface: + iface.disable_multicast() + +do_task(ctl, [ctl.get_host("machine1"), + ctl.get_host("machine2"), + ctl.get_host("switch")], + [ctl.get_host("machine1").get_interface("veth1"), + ctl.get_host("machine1").get_interface("veth3"), + ctl.get_host("machine2").get_interface("veth1"), + ctl.get_host("machine2").get_interface("veth3"), + ctl.get_host("switch").get_interface("if1"), + ctl.get_host("switch").get_interface("if2"), + ctl.get_host("switch").get_interface("if3"), + ctl.get_host("switch").get_interface("if4")], + ctl.get_aliases()) diff --git a/recipes/switchdev/l2-023-bridge_mdb_mc_router_port_basic.xml b/recipes/switchdev/l2-023-bridge_mdb_mc_router_port_basic.xml new file mode 100644 index 0000000..f672eb7 --- /dev/null +++ b/recipes/switchdev/l2-023-bridge_mdb_mc_router_port_basic.xml @@ -0,0 +1,70 @@ +<lnstrecipe xmlns:xi="http://www.w3.org/2003/XInclude"> + <xi:include href="default_aliases.xml" /> + <network> + <host id="machine1"> + <interfaces> + <eth id="if1" label="A" /> + <veth_pair> + <veth id="veth0"/> + <veth id="veth1" netns="nsif1"> + </veth> + </veth_pair> + <bridge id="brif1"> + <slaves> + <slave id="if1"/> + <slave id="veth0"/> + </slaves> + </bridge> + <eth id="if2" label="B" /> + <veth_pair> + <veth id="veth2"/> + <veth id="veth3" netns="nsif2"> + </veth> + </veth_pair> + <bridge id="brif2"> + <slaves> + <slave id="if2"/> + <slave id="veth2"/> + </slaves> + </bridge> + </interfaces> + </host> + <host id="machine2"> + <interfaces> + <eth id="if1" label="C" /> + <veth_pair> + <veth id="veth0"/> + <veth id="veth1" netns="nsif1"> + </veth> + </veth_pair> + <bridge id="brif1"> + <slaves> + <slave id="if1"/> + <slave id="veth0"/> + </slaves> + </bridge> + <eth id="if2" label="D" /> + <veth_pair> + <veth id="veth2"/> + <veth id="veth3" netns="nsif2"> + </veth> + </veth_pair> + <bridge id="brif2"> + <slaves> + <slave id="if2"/> + <slave id="veth2"/> + </slaves> + </bridge> + </interfaces> + </host> + <host id="switch"> + <interfaces> + <eth id="if1" label="A" /> + <eth id="if2" label="B" /> + <eth id="if3" label="C" /> + <eth id="if4" label="D" /> + </interfaces> + </host> + </network> + <task python="l2-023-bridge_mdb_mc_router_port_basic.py" /> +</lnstrecipe> -- 2.4.3

This recipe tests mrouter with many flood configurations. Its algorithm is as follows: - Configure a bridge multicast setup - Configure some mc_router ports - Make several ports join a mc group and send traffic to it - Validate that traffic is received by both joined ports and mc_router ports - Remove the mc_router_ports and send traffic to that group - Validate that traffic is received by only by the joined ports - Add some mc_router ports again and send traffic to the group - Validate that traffic is received by both joined ports and mc_router ports - Check that all the traffic hadn't gone via slowpath Signed-off-by: Yotam Gigi <yotamg(a)mellanox.com&gt; Signed-off-by: Nogah Frankel <nogahf(a)mellanox.com&gt; --- .../l2-025-bridge_mdb_flood_with_mc_router.py | 142 +++++++++++++++++++++ .../l2-025-bridge_mdb_flood_with_mc_router.xml | 70 ++++++++++ 2 files changed, 212 insertions(+) create mode 100644 recipes/switchdev/l2-025-bridge_mdb_flood_with_mc_router.py create mode 100644 recipes/switchdev/l2-025-bridge_mdb_flood_with_mc_router.xml diff --git a/recipes/switchdev/l2-025-bridge_mdb_flood_with_mc_router.py b/recipes/switchdev/l2-025-bridge_mdb_flood_with_mc_router.py new file mode 100644 index 0000000..698705d --- /dev/null +++ b/recipes/switchdev/l2-025-bridge_mdb_flood_with_mc_router.py @@ -0,0 +1,142 @@ +""" +Copyright 2016 Mellanox Technologies. All rights reserved. +Licensed under the GNU General Public License, version 2 as +published by the Free Software Foundation; see COPYING for details. +""" + +__author__ = """ +yotamg(a)mellanox.com (Yotam Gigi) +""" + +from lnst.Controller.Task import ctl +from TestLib import TestLib +from time import sleep +from lnst.Common.Consts import MCAST_ROUTER_PORT + +def test_ip(major, minor): + return ["192.168.10%d.%d/24" % (major, minor), + "2002:%d::%d/64" % (major, minor)] + +def mcgrp(i): + return "239.255.1.%d" % i + +def set_peer_mc_router(dev_map, dev, value): + sw_dev = dev_map[dev] + sw_dev.set_mcast_router(value) + sw = sw_dev.get_host() + +def test_mrouter(tl, dev_map, sender, listeners, bridged, mc_routers, group): + mcast_ifaces = listeners + bridged + + expected_no_mcr = [True for l in listeners] + [False for l in bridged] + expected = [True for l in listeners] + [l in mc_routers for l in bridged] + + s_procs = [tl.iperf_mc_listen(listener, group) for listener in listeners] + tl._ctl.wait(2) + + result = tl.iperf_mc(sender, mcast_ifaces, group) + tl.mc_ipref_compare_result(mcast_ifaces, result, expected_no_mcr) + + for mcr in mc_routers: + set_peer_mc_router(dev_map, mcr, MCAST_ROUTER_PORT.FIXED_ON) + + result = tl.iperf_mc(sender, mcast_ifaces, group) + tl.mc_ipref_compare_result(mcast_ifaces, result, expected) + + for mcr in mc_routers: + set_peer_mc_router(dev_map, mcr, MCAST_ROUTER_PORT.LEARNING) + + result = tl.iperf_mc(sender, mcast_ifaces, group) + tl.mc_ipref_compare_result(mcast_ifaces, result, expected_no_mcr) + + for mcr in mc_routers: + set_peer_mc_router(dev_map, mcr, MCAST_ROUTER_PORT.FIXED_ON) + + result = tl.iperf_mc(sender, mcast_ifaces, group) + tl.mc_ipref_compare_result(mcast_ifaces, result, expected) + + for proc in s_procs: + proc.intr() + + for mcr in mc_routers: + set_peer_mc_router(dev_map, mcr, MCAST_ROUTER_PORT.LEARNING) + +def do_task(ctl, hosts, ifaces, aliases): + m1, m2, sw = hosts + m1_if, m2_if, m3_if, m4_if, sw_if1, sw_if2, sw_if3, sw_if4 = ifaces + dev_map = { m1_if : sw_if1, m2_if : sw_if2, m3_if : sw_if3, m4_if : sw_if4 } + + # Create a bridge + sw_ifaces = [sw_if1, sw_if2, sw_if3, sw_if4] + sw_br = sw.create_bridge(slaves=sw_ifaces, options={"vlan_filtering": 1}) + + m1_if.set_addresses(test_ip(1, 1)) + m2_if.set_addresses(test_ip(1, 2)) + m3_if.set_addresses(test_ip(1, 3)) + m4_if.set_addresses(test_ip(1, 4)) + sleep(15) + + tl = TestLib(ctl, aliases) + + for iface in [m1_if, m2_if, m3_if, m4_if]: + iface.enable_multicast() + + tl.check_cpu_traffic(sw_ifaces, test=False) + test_mrouter(tl, dev_map, \ + sender = m1_if, \ + listeners = [], \ + bridged = [m3_if, m2_if, m4_if], \ + mc_routers = [m4_if], \ + group = mcgrp(1)) + + test_mrouter(tl, dev_map, \ + sender = m1_if, \ + listeners = [m2_if], \ + bridged = [m4_if, m3_if], \ + mc_routers = [m3_if], \ + group = mcgrp(2)) + + test_mrouter(tl, dev_map, \ + sender = m1_if, \ + listeners = [m2_if, m4_if], \ + bridged = [m3_if], \ + mc_routers = [m3_if], \ + group = mcgrp(3)) + + test_mrouter(tl, dev_map, \ + sender = m1_if, \ + listeners = [m2_if], \ + bridged = [m3_if, m4_if], \ + mc_routers = [m3_if, m4_if], \ + group = mcgrp(4)) + + test_mrouter(tl, dev_map, \ + sender = m1_if, \ + listeners = [m2_if, m4_if], \ + bridged = [m3_if], \ + mc_routers = [m2_if], \ + group = mcgrp(5)) + + test_mrouter(tl, dev_map, \ + sender = m1_if, \ + listeners = [m2_if, m4_if], \ + bridged = [m3_if], \ + mc_routers = [m2_if, m3_if], \ + group = mcgrp(6)) + + tl.check_cpu_traffic(sw_ifaces) + for iface in [m1_if, m2_if, m3_if, m4_if]: + iface.disable_multicast() + +do_task(ctl, [ctl.get_host("machine1"), + ctl.get_host("machine2"), + ctl.get_host("switch")], + [ctl.get_host("machine1").get_interface("veth1"), + ctl.get_host("machine1").get_interface("veth3"), + ctl.get_host("machine2").get_interface("veth1"), + ctl.get_host("machine2").get_interface("veth3"), + ctl.get_host("switch").get_interface("if1"), + ctl.get_host("switch").get_interface("if2"), + ctl.get_host("switch").get_interface("if3"), + ctl.get_host("switch").get_interface("if4")], + ctl.get_aliases()) diff --git a/recipes/switchdev/l2-025-bridge_mdb_flood_with_mc_router.xml b/recipes/switchdev/l2-025-bridge_mdb_flood_with_mc_router.xml new file mode 100644 index 0000000..22aa966 --- /dev/null +++ b/recipes/switchdev/l2-025-bridge_mdb_flood_with_mc_router.xml @@ -0,0 +1,70 @@ +<lnstrecipe xmlns:xi="http://www.w3.org/2003/XInclude"> + <xi:include href="default_aliases.xml" /> + <network> + <host id="machine1"> + <interfaces> + <eth id="if1" label="A" /> + <veth_pair> + <veth id="veth0"/> + <veth id="veth1" netns="nsif1"> + </veth> + </veth_pair> + <bridge id="brif1"> + <slaves> + <slave id="if1"/> + <slave id="veth0"/> + </slaves> + </bridge> + <eth id="if2" label="B" /> + <veth_pair> + <veth id="veth2"/> + <veth id="veth3" netns="nsif2"> + </veth> + </veth_pair> + <bridge id="brif2"> + <slaves> + <slave id="if2"/> + <slave id="veth2"/> + </slaves> + </bridge> + </interfaces> + </host> + <host id="machine2"> + <interfaces> + <eth id="if1" label="C" /> + <veth_pair> + <veth id="veth0"/> + <veth id="veth1" netns="nsif1"> + </veth> + </veth_pair> + <bridge id="brif1"> + <slaves> + <slave id="if1"/> + <slave id="veth0"/> + </slaves> + </bridge> + <eth id="if2" label="D" /> + <veth_pair> + <veth id="veth2"/> + <veth id="veth3" netns="nsif2"> + </veth> + </veth_pair> + <bridge id="brif2"> + <slaves> + <slave id="if2"/> + <slave id="veth2"/> + </slaves> + </bridge> + </interfaces> + </host> + <host id="switch"> + <interfaces> + <eth id="if1" label="A" /> + <eth id="if2" label="B" /> + <eth id="if3" label="C" /> + <eth id="if4" label="D" /> + </interfaces> + </host> + </network> + <task python="l2-025-bridge_mdb_flood_with_mc_router.py" /> +</lnstrecipe> -- 2.4.3