vpp - Vector Packet Processing

Age	Commit message (Expand)	Author	Files	Lines
2018-03-09	MPLS Unifom mode	Neale Ranns	1	-368/+473
2018-01-09	test: consolidate the multiple versions of send_and_*	Neale Ranns	1	-16/+7
2017-11-11	MPLS disposition actions at the tail of unicast LSPs	Neale Ranns	1	-2/+112
2017-10-31	Refactor IP input checks for re-use at MPLS disposition	Neale Ranns	1	-2/+21
2017-09-11	FIB table add/delete API	Neale Ranns	1	-6/+42
2017-08-08	L2 over MPLS	Neale Ranns	1	-56/+262
2017-05-26	MPLS lookup DPO does not pop the label (nor does it handle replicate)	Neale Ranns	1	-0/+20
2017-05-24	Missing VLIB node for IPv6 disposition from mcast MPLS LSP	Neale Ranns	1	-4/+73
2017-05-23	Labelled attached paths via an MPLS tunnel	Neale Ranns	1	-2/+25
2017-04-24	Improve Load-Balance MAPs	Neale Ranns	1	-0/+359
2017-04-07	MPLS Mcast	Neale Ranns	1	-22/+255
2017-03-17	Fix IP feature ordering.	Neale Ranns	1	-0/+83
2017-03-03	Changing the IP table for an interface is an error if the interface already h...	Neale Ranns	1	-4/+5
2017-02-20	Python test IP and MPLS objects conform to infra.	Neale Ranns	1	-75/+66
2016-12-23	make test: improve handling of packet captures	Klement Sekera	1	-17/+24
2016-12-16	make test: improve robustness and performance	Klement Sekera	1	-23/+6
2016-12-14	Ping response in a VRF context uses correct FIB for response	Neale Ranns	1	-10/+73
2016-12-13	make test: Use VXLAN built in scapy 2.3.3	Matej Klotton	1	-28/+33
2016-12-06	add missing import to mpls test	Gabriel Ganne	1	-0/+1
2016-12-05	make test: fix missing log/packet messages	Klement Sekera	1	-6/+6
2016-12-02	MPLS infrastructure improvments	Neale Ranns	1	-20/+502
2016-11-01	MPLS Exp-null Tests	Neale Ranns	1	-0/+209

import socket import scapy.compat from scapy.layers.inet import IP, UDP from scapy.layers.inet6 import IPv6 from scapy.layers.l2 import Ether, GRE from scapy.packet import Raw from scapy.data import IP_PROTOS from framework import VppTestCase from util import ppp """ TestLB is a subclass of VPPTestCase classes. TestLB class defines Load Balancer test cases for: - IP4 to GRE4 encap on per-port vip case - IP4 to GRE6 encap on per-port vip case - IP6 to GRE4 encap on per-port vip case - IP6 to GRE6 encap on per-port vip case - IP4 to L3DSR encap on vip case - IP4 to L3DSR encap on per-port vip case - IP4 to NAT4 encap on per-port vip case - IP6 to NAT6 encap on per-port vip case As stated in comments below, GRE has issues with IPv6. All test cases involving IPv6 are executed, but received packets are not parsed and checked. """ class TestLB(VppTestCase): """ Load Balancer Test Case """ @classmethod def setUpClass(cls): super(TestLB, cls).setUpClass() cls.ass = range(5) cls.packets = range(1) try: cls.create_pg_interfaces(range(2)) cls.interfaces = list(cls.pg_interfaces) for i in cls.interfaces: i.admin_up() i.config_ip4() i.config_ip6() i.disable_ipv6_ra() i.resolve_arp() i.resolve_ndp() dst4 = socket.inet_pton(socket.AF_INET, "10.0.0.0") dst6 = socket.inet_pton(socket.AF_INET6, "2002::") cls.vapi.ip_add_del_route(dst_address=dst4, dst_address_length=24, next_hop_address=cls.pg1.remote_ip4n) cls.vapi.ip_add_del_route(dst_address=dst6, dst_address_length=16, next_hop_address=cls.pg1.remote_ip6n, is_ipv6=1) cls.vapi.lb_conf(ip4_src_address="39.40.41.42", ip6_src_address="2004::1") except Exception: super(TestLB, cls).tearDownClass() raise @classmethod def tearDownClass(cls): super(TestLB, cls).tearDownClass() def tearDown(self): super(TestLB, self).tearDown() def show_commands_at_teardown(self): self.logger.info(self.vapi.cli("show lb vip verbose")) def getIPv4Flow(self, id): return (IP(dst="90.0.%u.%u" % (id / 255, id % 255), src="40.0.%u.%u" % (id / 255, id % 255)) / UDP(sport=10000 + id, dport=20000)) def getIPv6Flow(self, id): return (IPv6(dst="2001::%u" % (id), src="fd00:f00d:ffff::%u" % (id)) / UDP(sport=10000 + id, dport=20000)) def generatePackets(self, src_if, isv4): self.reset_packet_infos() pkts = [] for pktid in self.packets: info = self.create_packet_info(src_if, self.pg1) payload = self.info_to_payload(info) ip = self.getIPv4Flow(pktid) if isv4 else self.getIPv6Flow(pktid) packet = (Ether(dst=src_if.local_mac, src=src_if.remote_mac) / ip / Raw(payload)) self.extend_packet(packet, 128) info.data = packet.copy() pkts.append(packet) return pkts def checkInner(self, gre, isv4): IPver = IP if isv4 else IPv6 self.assertEqual(gre.proto, 0x0800 if isv4 else 0x86DD) self.assertEqual(gre.flags, 0) self.assertEqual(gre.version, 0) inner = IPver(scapy.compat.raw(gre.payload)) payload_info = self.payload_to_info(inner[Raw]) self.info = self.packet_infos[payload_info.index] self.assertEqual(payload_info.src, self.pg0.sw_if_index) self.assertEqual(scapy.compat.raw(inner), scapy.compat.raw(self.info.data[IPver])) def checkCapture(self, encap, isv4): self.pg0.assert_nothing_captured() out = self.pg1.get_capture(len(self.packets)) load = [0] * len(self.ass) self.info = None for p in out: try: asid = 0 gre = None if (encap == 'gre4'): ip = p[IP] asid = int(ip.dst.split(".")[3]) self.assertEqual(ip.version, 4) self.assertEqual(ip.flags, 0) self.assertEqual(ip.src, "39.40.41.42") self.assertEqual(ip.dst, "10.0.0.%u" % asid) self.assertEqual(ip.proto, 47) self.assertEqual(len(ip.options), 0) gre = p[GRE] self.checkInner(gre, isv4) elif (encap == 'gre6'): ip = p[IPv6] asid = ip.dst.split(":") asid = asid[len(asid) - 1] asid = 0 if asid == "" else int(asid) self.assertEqual(ip.version, 6) self.assertEqual(ip.tc, 0) self.assertEqual(ip.fl, 0) self.assertEqual(ip.src, "2004::1") self.assertEqual( socket.inet_pton(socket.AF_INET6, ip.dst), socket.inet_pton(socket.AF_INET6, "2002::%u" % asid) ) self.assertEqual(ip.nh, 47) # self.assertEqual(len(ip.options), 0) gre = GRE(scapy.compat.raw(p[IPv6].payload)) self.checkInner(gre, isv4) elif (encap == 'l3dsr'): ip = p[IP] asid = int(ip.dst.split(".")[3]) self.assertEqual(ip.version, 4) self.assertEqual(ip.flags, 0) self.assertEqual(ip.dst, "10.0.0.%u" % asid) self.assertEqual(ip.tos, 0x1c) self.assertEqual(len(ip.options), 0) self.assert_ip_checksum_valid(p) if ip.proto == IP_PROTOS.tcp: self.assert_tcp_checksum_valid(p) elif ip.proto == IP_PROTOS.udp: self.assert_udp_checksum_valid(p) elif (encap == 'nat4'): ip = p[IP] asid = int(ip.dst.split(".")[3]) self.assertEqual(ip.version, 4) self.assertEqual(ip.flags, 0) self.assertEqual(ip.dst, "10.0.0.%u" % asid) self.assertEqual(ip.proto, 17) self.assertEqual(len(ip.options), 0) udp = p[UDP] self.assertEqual(udp.dport, 3307) elif (encap == 'nat6'): ip = p[IPv6] asid = ip.dst.split(":") asid = asid[len(asid) - 1] asid = 0 if asid == "" else int(asid) self.assertEqual(ip.version, 6) self.assertEqual(ip.tc, 0) self.assertEqual(ip.fl, 0) self.assertEqual( socket.inet_pton(socket.AF_INET6, ip.dst), socket.inet_pton(socket.AF_INET6, "2002::%u" % asid) ) self.assertEqual(ip.nh, 17) self.assertGreaterEqual(ip.hlim, 63) udp = UDP(scapy.compat.raw(p[IPv6].payload)) self.assertEqual(udp.dport, 3307) load[asid] += 1 except: self.logger.error(ppp("Unexpected or invalid packet:", p)) raise # This is just to roughly check that the balancing algorithm # is not completely biased. for asid in self.ass: if load[asid] < len(self.packets) / (len(self.ass) * 2): self.logger.error( "ASS is not balanced: load[%d] = %d" % (asid, load[asid])) raise Exception("Load Balancer algorithm is biased") def test_lb_ip4_gre4(self): """ Load Balancer IP4 GRE4 on vip case """ try: self.vapi.cli( "lb vip 90.0.0.0/8 encap gre4") for asid in self.ass: self.vapi.cli( "lb as 90.0.0.0/8 10.0.0.%u" % (asid)) self.pg0.add_stream(self.generatePackets(self.pg0, isv4=True)) self.pg_enable_capture(self.pg_interfaces) self.pg_start() self.checkCapture(encap='gre4', isv4=True) finally: for asid in self.ass: self.vapi.cli( "lb as 90.0.0.0/8 10.0.0.%u del" % (asid)) self.vapi.cli( "lb vip 90.0.0.0/8 encap gre4 del") self.vapi.cli("test lb flowtable flush") def test_lb_ip6_gre4(self): """ Load Balancer IP6 GRE4 on vip case """ try: self.vapi.cli( "lb vip 2001::/16 encap gre4") for asid in self.ass: self.vapi.cli( "lb as 2001::/16 10.0.0.%u" % (asid)) self.pg0.add_stream(self.generatePackets(self.pg0, isv4=False)) self.pg_enable_capture(self.pg_interfaces) self.pg_start() self.checkCapture(encap='gre4', isv4=False) finally: for asid in self.ass: self.vapi.cli( "lb as 2001::/16 10.0.0.%u del" % (asid)) self.vapi.cli( "lb vip 2001::/16 encap gre4 del") self.vapi.cli("test lb flowtable flush") def test_lb_ip4_gre6(self): """ Load Balancer IP4 GRE6 on vip case """ try: self.vapi.cli( "lb vip 90.0.0.0/8 encap gre6") for asid in self.ass: self.vapi.cli( "lb as 90.0.0.0/8 2002::%u" % (asid)) self.pg0.add_stream(self.generatePackets(self.pg0, isv4=True)) self.pg_enable_capture(self.pg_interfaces) self.pg_start() self.checkCapture(encap='gre6', isv4=True) finally: for asid in self.ass: self.vapi.cli( "lb as 90.0.0.0/8 2002::%u del" % (asid)) self.vapi.cli( "lb vip 90.0.0.0/8 encap gre6 del") self.vapi.cli("test lb flowtable flush") def test_lb_ip6_gre6(self): """ Load Balancer IP6 GRE6 on vip case """ try: self.vapi.cli( "lb vip 2001::/16 encap gre6") for asid in self.ass: self.vapi.cli( "lb as 2001::/16 2002::%u" % (asid)) self.pg0.add_stream(self.generatePackets(self.pg0, isv4=False)) self.pg_enable_capture(self.pg_interfaces) self.pg_start() self.checkCapture(encap='gre6', isv4=False) finally: for asid in self.ass: self.vapi.cli( "lb as 2001::/16 2002::%u del" % (asid)) self.vapi.cli( "lb vip 2001::/16 encap gre6 del") self.vapi.cli("test lb flowtable flush") def test_lb_ip4_gre4_port(self): """ Load Balancer IP4 GRE4 on per-port-vip case """ try: self.vapi.cli( "lb vip 90.0.0.0/8 protocol udp port 20000 encap gre4") for asid in self.ass: self.vapi.cli( "lb as 90.0.0.0/8 protocol udp port 20000 10.0.0.%u" % (asid)) self.pg0.add_stream(self.generatePackets(self.pg0, isv4=True)) self.pg_enable_capture(self.pg_interfaces) self.pg_start() self.checkCapture(encap='gre4', isv4=True) finally: for asid in self.ass: self.vapi.cli( "lb as 90.0.0.0/8 protocol udp port 20000 10.0.0.%u del" % (asid)) self.vapi.cli( "lb vip 90.0.0.0/8 protocol udp port 20000 encap gre4 del") self.vapi.cli("test lb flowtable flush") def test_lb_ip6_gre4_port(self): """ Load Balancer IP6 GRE4 on per-port-vip case """ try: self.vapi.cli( "lb vip 2001::/16 protocol udp port 20000 encap gre4") for asid in self.ass: self.vapi.cli( "lb as 2001::/16 protocol udp port 20000 10.0.0.%u" % (asid)) self.pg0.add_stream(self.generatePackets(self.pg0, isv4=False)) self.pg_enable_capture(self.pg_interfaces) self.pg_start() self.checkCapture(encap='gre4', isv4=False) finally: for asid in self.ass: self.vapi.cli( "lb as 2001::/16 protocol udp port 20000 10.0.0.%u del" % (asid)) self.vapi.cli( "lb vip 2001::/16 protocol udp port 20000 encap gre4 del") self.vapi.cli("test lb flowtable flush") def test_lb_ip4_gre6_port(self): """ Load Balancer IP4 GRE6 on per-port-vip case """ try: self.vapi.cli( "lb vip 90.0.0.0/8 protocol udp port 20000 encap gre6") for asid in self.ass: self.vapi.cli( "lb as 90.0.0.0/8 protocol udp port 20000 2002::%u" % (asid)) self.pg0.add_stream(self.generatePackets(self.pg0, isv4=True)) self.pg_enable_capture(self.pg_interfaces) self.pg_start() self.checkCapture(encap='gre6', isv4=True) finally: for asid in self.ass: self.vapi.cli( "lb as 90.0.0.0/8 protocol udp port 20000 2002::%u del" % (asid)) self.vapi.cli( "lb vip 90.0.0.0/8 protocol udp port 20000 encap gre6 del") self.vapi.cli("test lb flowtable flush") def test_lb_ip6_gre6_port(self): """ Load Balancer IP6 GRE6 on per-port-vip case """ try: self.vapi.cli( "lb vip 2001::/16 protocol udp port 20000 encap gre6") for asid in self.ass: self.vapi.cli( "lb as 2001::/16 protocol udp port 20000 2002::%u" % (asid)) self.pg0.add_stream(self.generatePackets(self.pg0, isv4=False)) self.pg_enable_capture(self.pg_interfaces) self.pg_start() self.checkCapture(encap='gre6', isv4=False) finally: for asid in self.ass: self.vapi.cli( "lb as 2001::/16 protocol udp port 20000 2002::%u del" % (asid)) self.vapi.cli( "lb vip 2001::/16 protocol udp port 20000 encap gre6 del") self.vapi.cli("test lb flowtable flush") def test_lb_ip4_l3dsr(self): """ Load Balancer IP4 L3DSR on vip case """ try: self.vapi.cli( "lb vip 90.0.0.0/8 encap l3dsr dscp 7") for asid in self.ass: self.vapi.cli( "lb as 90.0.0.0/8 10.0.0.%u" % (asid)) self.pg0.add_stream(self.generatePackets(self.pg0, isv4=True)) self.pg_enable_capture(self.pg_interfaces) self.pg_start() self.checkCapture(encap='l3dsr', isv4=True) finally: for asid in self.ass: self.vapi.cli( "lb as 90.0.0.0/8 10.0.0.%u del" % (asid)) self.vapi.cli( "lb vip 90.0.0.0/8 encap l3dsr" " dscp 7 del") self.vapi.cli("test lb flowtable flush") def test_lb_ip4_l3dsr_port(self): """ Load Balancer IP4 L3DSR on per-port-vip case """ try: self.vapi.cli( "lb vip 90.0.0.0/8 protocol udp port 20000 encap l3dsr dscp 7") for asid in self.ass: self.vapi.cli( "lb as 90.0.0.0/8 protocol udp port 20000 10.0.0.%u" % (asid)) self.pg0.add_stream(self.generatePackets(self.pg0, isv4=True)) self.pg_enable_capture(self.pg_interfaces) self.pg_start() self.checkCapture(encap='l3dsr', isv4=True) finally: for asid in self.ass: self.vapi.cli( "lb as 90.0.0.0/8 protocol udp port 20000 10.0.0.%u del" % (asid)) self.vapi.cli( "lb vip 90.0.0.0/8 protocol udp port 20000 encap l3dsr" " dscp 7 del") self.vapi.cli("test lb flowtable flush") def test_lb_ip4_nat4_port(self): """ Load Balancer IP4 NAT4 on per-port-vip case """ try: self.vapi.cli( "lb vip 90.0.0.0/8 protocol udp port 20000 encap nat4" " type clusterip target_port 3307") for asid in self.ass: self.vapi.cli( "lb as 90.0.0.0/8 protocol udp port 20000 10.0.0.%u" % (asid)) self.pg0.add_stream(self.generatePackets(self.pg0, isv4=True)) self.pg_enable_capture(self.pg_interfaces) self.pg_start() self.checkCapture(encap='nat4', isv4=True) finally: for asid in self.ass: self.vapi.cli( "lb as 90.0.0.0/8 protocol udp port 20000 10.0.0.%u del" % (asid)) self.vapi.cli( "lb vip 90.0.0.0/8 protocol udp port 20000 encap nat4" " type clusterip target_port 3307 del") self.vapi.cli("test lb flowtable flush") def test_lb_ip6_nat6_port(self): """ Load Balancer IP6 NAT6 on per-port-vip case """ try: self.vapi.cli( "lb vip 2001::/16 protocol udp port 20000 encap nat6" " type clusterip target_port 3307") for asid in self.ass: self.vapi.cli( "lb as 2001::/16 protocol udp port 20000 2002::%u" % (asid)) self.pg0.add_stream(self.generatePackets(self.pg0, isv4=False)) self.pg_enable_capture(self.pg_interfaces) self.pg_start() self.checkCapture(encap='nat6', isv4=False) finally: for asid in self.ass: self.vapi.cli( "lb as 2001::/16 protocol udp port 20000 2002::%u del" % (asid)) self.vapi.cli( "lb vip 2001::/16 protocol udp port 20000 encap nat6" " type clusterip target_port 3307 del") self.vapi.cli("test lb flowtable flush")