#!/usr/bin/env python3 import typing from socket import AF_INET6, inet_pton, inet_ntop import unittest from ipaddress import ip_address, IPv4Network, IPv6Network from scapy.packet import Raw from scapy.layers.l2 import Ether, ARP, Dot1Q from scapy.layers.inet import IP, UDP, ICMP from scapy.layers.inet6 import ( IPv6, ICMPv6ND_NS, ICMPv6NDOptSrcLLAddr, ICMPv6ND_NA, ICMPv6EchoRequest, ) from scapy.utils6 import in6_getnsma, in6_getnsmac from scapy.layers.vxlan import VXLAN from scapy.data import ETH_P_IP, ETH_P_IPV6 from framework import tag_fixme_vpp_workers from framework import VppTestCase, VppTestRunner from vpp_object import VppObject from vpp_interface import VppInterface from vpp_ip_route import ( VppIpRoute, VppRoutePath, VppIpTable, VppIpInterfaceAddress, VppIpInterfaceBind, find_route, FibPathProto, FibPathType, ) from vpp_l2 import ( VppBridgeDomain, VppBridgeDomainPort, VppBridgeDomainArpEntry, VppL2FibEntry, find_bridge_domain_port, VppL2Vtr, ) from vpp_sub_interface import L2_VTR_OP, VppDot1QSubint from vpp_ip import DpoProto, get_dpo_proto from vpp_papi import VppEnum, MACAddress from vpp_vxlan_gbp_tunnel import find_vxlan_gbp_tunnel, INDEX_INVALID, VppVxlanGbpTunnel from vpp_neighbor import VppNeighbor from vpp_acl import AclRule, VppAcl NUM_PKTS = 67 def find_gbp_endpoint( test, sw_if_index=None, ip=None, mac=None, tep=None, sclass=None, flags=None ): if ip: vip = ip if mac: vmac = MACAddress(mac) eps = test.vapi.gbp_endpoint_dump() for ep in eps: if tep: src = tep[0] dst = tep[1] if src != str(ep.endpoint.tun.src) or dst != str(ep.endpoint.tun.dst): continue if sw_if_index: if ep.endpoint.sw_if_index != sw_if_index: continue if sclass: if ep.endpoint.sclass != sclass: continue if flags: if flags != (flags & ep.endpoint.flags): continue if ip: for eip in ep.endpoint.ips: if vip == str(eip): return True if mac: if vmac == ep.endpoint.mac: return True return False def find_gbp_vxlan(test: VppTestCase, vni): ts = test.vapi.gbp_vxlan_tunnel_dump() for t in ts: if t.tunnel.vni == vni: return True return False class VppGbpEndpoint(VppObject): """ GBP Endpoint """ @property def mac(self): return str(self.vmac) @property def ip4(self): return self._ip4 @property def fip4(self): return self._fip4 @property def ip6(self): return self._ip6 @property def fip6(self): return self._fip6 @property def ips(self): return [self.ip4, self.ip6] @property def fips(self): return [self.fip4, self.fip6] def __init__( self, test, itf, epg, recirc, ip4, fip4, ip6, fip6, flags=0, tun_src="0.0.0.0", tun_dst="0.0.0.0", mac=True, ): self._test = test self.itf = itf self.handle = None self.epg = epg self.recirc = recirc self._ip4 = ip4 self._fip4 = fip4 self._ip6 = ip6 self._fip6 = fip6 if mac: self.vmac = MACAddress(self.itf.remote_mac) else: self.vmac = MACAddress("00:00:00:00:00:00") self.flags = flags self.tun_src = tun_src self.tun_dst = tun_dst def encode(self): ips = [self.ip4, self.ip6] return { "sw_if_index": self.itf.sw_if_index, "ips": ips, "n_ips": len(ips), "mac": self.vmac.packed, "sclass": self.epg.sclass, "flags": self.flags, "tun": { "src": self.tun_src, "dst": self.tun_dst, }, } def add_vpp_config(self): res = self._test.vapi.gbp_endpoint_add( endpoint=self.encode(), ) self.handle = res.handle self._test.registry.register(self, self._test.logger) def remove_vpp_config(self): self._test.vapi.gbp_endpoint_del(handle=self.handle) def object_id(self): return "gbp-endpoint:[%d==%d:%s:%d]" % ( self.handle, self.itf.sw_if_index, self.ip4, self.epg.sclass, ) def query_vpp_config(self): return find_gbp_endpoint(self._test, self.itf.sw_if_index, self.ip4) class VppGbpRecirc(VppObject): """ GBP Recirculation Interface """ def __init__(self, test, epg, recirc, is_ext=False): self._test = test self.recirc = recirc self.epg = epg self.is_ext = is_ext def encode(self): return { "is_ext": self.is_ext, "sw_if_index": self.recirc.sw_if_index, "sclass": self.epg.sclass, } def add_vpp_config(self): self._test.vapi.gbp_recirc_add_del( 1, recirc=self.encode(), ) self._test.registry.register(self, self._test.logger) def remove_vpp_config(self): self._test.vapi.gbp_recirc_add_del( 0, recirc=self.encode(), ) def object_id(self): return "gbp-recirc:[%d]" % (self.recirc.sw_if_index) def query_vpp_config(self): rs = self._test.vapi.gbp_recirc_dump() for r in rs: if r.recirc.sw_if_index == self.recirc.sw_if_index: return True return False class VppGbpExtItf(VppObject): """ GBP ExtItfulation Interface """ def __init__(self, test, itf, bd, rd, anon=False): self._test = test self.itf = itf self.bd = bd self.rd = rd self.flags = 1 if anon else 0 def encode(self): return { "sw_if_index": self.itf.sw_if_index, "bd_id": self.bd.bd_id, "rd_id": self.rd.rd_id, "flags": self.flags, } def add_vpp_config(self): self._test.vapi.gbp_ext_itf_add_del( 1, ext_itf=self.encode(), ) self._test.registry.register(self, self._test.logger) def remove_vpp_config(self): self._test.vapi.gbp_ext_itf_add_del( 0, ext_itf=self.encode(), ) def object_id(self): return "gbp-ext-itf:[%d]%s" % ( self.itf.sw_if_index, " [anon]" if self.flags else "", ) def query_vpp_config(self): rs = self._test.vapi.gbp_ext_itf_dump() for r in rs: if r.ext_itf.sw_if_index == self.itf.sw_if_index: return True return False class VppGbpSubnet(VppObject): """ GBP Subnet """ def __init__( self, test, rd, address, address_len, type, sw_if_index=0xFFFFFFFF, sclass=0xFFFF, ): # TODO: replace hardcoded defaults when vpp_papi supports # defaults in typedefs self._test = test self.rd_id = rd.rd_id a = ip_address(address) if 4 == a.version: self.prefix = IPv4Network("%s/%d" % (address, address_len), strict=False) else: self.prefix = IPv6Network("%s/%d" % (address, address_len), strict=False) self.type = type self.sw_if_index = sw_if_index self.sclass = sclass def encode(self): return { "type": self.type, "sw_if_index": self.sw_if_index, "sclass": self.sclass, "prefix": self.prefix, "rd_id": self.rd_id, } def add_vpp_config(self): self._test.vapi.gbp_subnet_add_del( is_add=1, subnet=self.encode(), ) self._test.registry.register(self, self._test.logger) def remove_vpp_config(self): self._test.vapi.gbp_subnet_add_del(is_add=0, subnet=self.encode()) def object_id(self): return "gbp-subnet:[%d-%s]" % (self.rd_id, self.prefix) def query_vpp_config(self): ss = self._test.vapi.gbp_subnet_dump() for s in ss: if ( s.subnet.rd_id == self.rd_id and s.subnet.type == self.type and s.subnet.prefix == self.prefix ): return True return False class VppGbpEndpointRetention(object): def __init__(self, remote_ep_timeout=0xFFFFFFFF): self.remote_ep_timeout = remote_ep_timeout def encode(self): return {"remote_ep_timeout": self.remote_ep_timeout} class VppGbpEndpointGroup(VppObject): """ GBP Endpoint Group """ def __init__( self, test, vnid, sclass, rd, bd, uplink, bvi, bvi_ip4, bvi_ip6=None, retention=VppGbpEndpointRetention(), ): self._test = test self.uplink = uplink self.bvi = bvi self.bvi_ip4 = bvi_ip4 self.bvi_ip6 = bvi_ip6 self.vnid = vnid self.bd = bd # VppGbpBridgeDomain self.rd = rd self.sclass = sclass if 0 == self.sclass: self.sclass = 0xFFFF self.retention = retention def encode(self) -> dict: return { "uplink_sw_if_index": self.uplink.sw_if_index if self.uplink else INDEX_INVALID, "bd_id": self.bd.bd.bd_id, "rd_id": self.rd.rd_id, "vnid": self.vnid, "sclass": self.sclass, "retention": self.retention.encode(), } def add_vpp_config(self): self._test.vapi.gbp_endpoint_group_add(epg=self.encode()) self._test.registry.register(self, self._test.logger) def remove_vpp_config(self): self._test.vapi.gbp_endpoint_group_del(sclass=self.sclass) def object_id(self) -> str: return "gbp-endpoint-group:[%d]" % (self.vnid) def query_vpp_config(self) -> bool: epgs = self._test.vapi.gbp_endpoint_group_dump() for epg in epgs: if epg.epg.vnid == self.vnid: return True return False class VppGbpBridgeDomain(VppObject): """ GBP Bridge Domain """ def __init__( self, test, bd, rd, bvi, uu_fwd: typing.Optional[VppVxlanGbpTunnel] = None, bm_flood=None, learn=True, uu_drop=False, bm_drop=False, ucast_arp=False, ): self._test = test self.bvi = bvi self.uu_fwd = uu_fwd self.bm_flood = bm_flood self.bd = bd self.rd = rd e = VppEnum.vl_api_gbp_bridge_domain_flags_t self.flags = e.GBP_BD_API_FLAG_NONE if not learn: self.flags |= e.GBP_BD_API_FLAG_DO_NOT_LEARN if uu_drop: self.flags |= e.GBP_BD_API_FLAG_UU_FWD_DROP if bm_drop: self.flags |= e.GBP_BD_API_FLAG_MCAST_DROP if ucast_arp: self.flags |= e.GBP_BD_API_FLAG_UCAST_ARP def encode(self) -> dict: return { "flags": self.flags, "bvi_sw_if_index": self.bvi.sw_if_index, "uu_fwd_sw_if_index": self.uu_fwd.sw_if_index if self.uu_fwd else INDEX_INVALID, "bm_flood_sw_if_index": self.bm_flood.sw_if_index if self.bm_flood else INDEX_INVALID, "bd_id": self.bd.bd_id, "rd_id": self.rd.rd_id, } def add_vpp_config(self): self._test.vapi.gbp_bridge_domain_add( bd=self.encode(), ) self._test.registry.register(self, self._test.logger) def remove_vpp_config(self): self._test.vapi.gbp_bridge_domain_del(bd_id=self.bd.bd_id) def object_id(self) -> str: return "gbp-bridge-domain:[%d]" % (self.bd.bd_id) def query_vpp_config(self) -> bool: bds = self._test.vapi.gbp_bridge_domain_dump() for bd in bds: if bd.bd.bd_id == self.bd.bd_id: return True return False class VppGbpRouteDomain(VppObject): """ GBP Route Domain """ def __init__(self, test, rd_id, scope, t4, t6, ip4_uu=None, ip6_uu=None): self._test = test self.rd_id = rd_id self.scope = scope self.t4 = t4 self.t6 = t6 self.ip4_uu = ip4_uu self.ip6_uu = ip6_uu def encode(self) -> dict: return { "rd_id": self.rd_id, "scope": self.scope, "ip4_table_id": self.t4.table_id, "ip6_table_id": self.t6.table_id, "ip4_uu_sw_if_index": self.ip4_uu.sw_if_index if self.ip4_uu else INDEX_INVALID, "ip6_uu_sw_if_index": self.ip6_uu.sw_if_index if self.ip6_uu else INDEX_INVALID, } def add_vpp_config(self): self._test.vapi.gbp_route_domain_add( rd=self.encode(), ) self._test.registry.register(self, self._test.logger) def remove_vpp_config(self): self._test.vapi.gbp_route_domain_del(rd_id=self.rd_id) def object_id(self): return "gbp-route-domain:[%d]" % (self.rd_id) def query_vpp_config(self): rds = self._test.vapi.gbp_route_domain_dump() for rd in rds: if rd.rd.rd_id == self.rd_id: return True return False class VppGbpContractNextHop: def __init__(self, mac, bd, ip, rd): self.mac = mac self.ip = ip self.bd = bd self.rd = rd def encode(self) -> dict: return { "ip": self.ip, "mac": self.mac.packed, "bd_id": self.bd.bd.bd_id, "rd_id": self.rd.rd_id, } class VppGbpContractRule: def __init__(self, action, hash_mode, nhs=None): self.action = action self.hash_mode = hash_mode self.nhs = [] if nhs is None else nhs def encode(self) -> dict: nhs = [] for nh in self.nhs: nhs.append(nh.encode()) while len(nhs) < 8: nhs.append({}) return { "action": self.action, "nh_set": {"hash_mode": self.hash_mode, "n_nhs": len(self.nhs), "nhs": nhs}, } def __repr__(self): return "" % ( self.action, self.hash_mode, ) class VppGbpContract(VppObject): """ GBP Contract """ def __init__( self, test, scope, sclass, dclass, acl_index, rules: list, allowed_ethertypes: list, ): self._test = test self.scope = scope self.acl_index = acl_index self.sclass = sclass self.dclass = dclass self.rules = rules self.allowed_ethertypes = allowed_ethertypes while len(self.allowed_ethertypes) < 16: self.allowed_ethertypes.append(0) def encode(self) -> dict: rules = [] for r in self.rules: rules.append(r.encode()) return { "acl_index": self.acl_index, "scope": self.scope, "sclass": self.sclass, "dclass": self.dclass, "n_rules": len(rules), "rules": rules, "n_ether_types": len(self.allowed_ethertypes), "allowed_ethertypes": self.allowed_ethertypes, } def add_vpp_config(self): r = self._test.vapi.gbp_contract_add_del(is_add=1, contract=self.encode()) self.stats_index = r.stats_index self._test.registry.register(self, self._test.logger) def remove_vpp_config(self): self._test.vapi.gbp_contract_add_del( is_add=0, contract=self.encode(), ) def object_id(self): return "gbp-contract:[%d:%d:%d:%d]" % ( self.scope, self.sclass, self.dclass, self.acl_index, ) def query_vpp_config(self): cs = self._test.vapi.gbp_contract_dump() for c in cs: if ( c.contract.scope == self.scope and c.contract.sclass == self.sclass and c.contract.dclass == self.dclass ): return True return False def get_drop_stats(self): c = self._test.statistics.get_counter("/net/gbp/contract/drop") return c[0][self.stats_index] def get_permit_stats(self): c = self._test.statistics.get_counter("/net/gbp/contract/permit") return c[0][self.stats_index] class VppGbpVxlanTunnel(VppInterface): """ GBP VXLAN tunnel """ def __init__(self, test, vni, bd_rd_id, mode, src): super(VppGbpVxlanTunnel, self).__init__(test) self._test = test self.vni = vni self.bd_rd_id = bd_rd_id self.mode = mode self.src = src def encode(self) -> dict: return { "vni": self.vni, "mode": self.mode, "bd_rd_id": self.bd_rd_id, "src": self.src, } def add_vpp_config(self): r = self._test.vapi.gbp_vxlan_tunnel_add( tunnel=self.encode(), ) self.set_sw_if_index(r.sw_if_index) self._test.registry.register(self, self._test.logger) def remove_vpp_config(self): self._test.vapi.gbp_vxlan_tunnel_del(vni=self.vni) def object_id(self): return "gbp-vxlan:%d" % (self.sw_if_index) def query_vpp_config(self): return find_gbp_vxlan(self._test, self.vni) @tag_fixme_vpp_workers class TestGBP(VppTestCase): """GBP Test Case""" @property def nat_config_flags(self): return VppEnum.vl_api_nat_config_flags_t @property def nat44_config_flags(self): return VppEnum.vl_api_nat44_config_flags_t @classmethod def setUpClass(cls): super(TestGBP, cls).setUpClass() @classmethod def tearDownClass(cls): super(TestGBP, cls).tearDownClass() def setUp(self): super(TestGBP, self).setUp() self.create_pg_interfaces(range(9)) self.create_loopback_interfaces(8) self.router_mac = MACAddress("00:11:22:33:44:55") for i in self.pg_interfaces: i.admin_up() for i in self.lo_interfaces: i.admin_up() self.vlan_100 = VppDot1QSubint(self, self.pg0, 100) self.vlan_100.admin_up() self.vlan_101 = VppDot1QSubint(self, self.pg0, 101) self.vlan_101.admin_up() self.vlan_102 = VppDot1QSubint(self, self.pg0, 102) self.vlan_102.admin_up() def tearDown(self): for i in self.pg_interfaces: i.admin_down() super(TestGBP, self).tearDown() for i in self.lo_interfaces: i.remove_vpp_config() self.lo_interfaces = [] self.vlan_102.remove_vpp_config() self.vlan_101.remove_vpp_config() self.vlan_100.remove_vpp_config() def send_and_expect_bridged(self, src, tx, dst): rx = self.send_and_expect(src, tx, dst) for r in rx: self.assertEqual(r[Ether].src, tx[0][Ether].src) self.assertEqual(r[Ether].dst, tx[0][Ether].dst) self.assertEqual(r[IP].src, tx[0][IP].src) self.assertEqual(r[IP].dst, tx[0][IP].dst) return rx def send_and_expect_bridged6(self, src, tx, dst): rx = self.send_and_expect(src, tx, dst) for r in rx: self.assertEqual(r[Ether].src, tx[0][Ether].src) self.assertEqual(r[Ether].dst, tx[0][Ether].dst) self.assertEqual(r[IPv6].src, tx[0][IPv6].src) self.assertEqual(r[IPv6].dst, tx[0][IPv6].dst) return rx def send_and_expect_routed(self, src, tx, dst, src_mac): rx = self.send_and_expect(src, tx, dst) for r in rx: self.assertEqual(r[Ether].src, src_mac) self.assertEqual(r[Ether].dst, dst.remote_mac) self.assertEqual(r[IP].src, tx[0][IP].src) self.assertEqual(r[IP].dst, tx[0][IP].dst) return rx def send_and_expect_routed6(self, src, tx, dst, src_mac): rx = self.send_and_expect(src, tx, dst) for r in rx: self.assertEqual(r[Ether].src, src_mac) self.assertEqual(r[Ether].dst, dst.remote_mac) self.assertEqual(r[IPv6].src, tx[0][IPv6].src) self.assertEqual(r[IPv6].dst, tx[0][IPv6].dst) return rx def send_and_expect_natted(self, src, tx, dst, src_ip): rx = self.send_and_expect(src, tx, dst) for r in rx: self.assertEqual(r[Ether].src, tx[0][Ether].src) self.assertEqual(r[Ether].dst, tx[0][Ether].dst) self.assertEqual(r[IP].src, src_ip) self.assertEqual(r[IP].dst, tx[0][IP].dst) return rx def send_and_expect_natted6(self, src, tx, dst, src_ip): rx = self.send_and_expect(src, tx, dst) for r in rx: self.assertEqual(r[Ether].src, tx[0][Ether].src) self.assertEqual(r[Ether].dst, tx[0][Ether].dst) self.assertEqual(r[IPv6].src, src_ip) self.assertEqual(r[IPv6].dst, tx[0][IPv6].dst) return rx def send_and_expect_unnatted(self, src, tx, dst, dst_ip): rx = self.send_and_expect(src, tx, dst) for r in rx: self.assertEqual(r[Ether].src, tx[0][Ether].src) self.assertEqual(r[Ether].dst, tx[0][Ether].dst) self.assertEqual(r[IP].dst, dst_ip) self.assertEqual(r[IP].src, tx[0][IP].src) return rx def send_and_expect_unnatted6(self, src, tx, dst, dst_ip): rx = self.send_and_expect(src, tx, dst) for r in rx: self.assertEqual(r[Ether].src, tx[0][Ether].src) self.assertEqual(r[Ether].dst, tx[0][Ether].dst) self.assertEqual(r[IPv6].dst, dst_ip) self.assertEqual(r[IPv6].src, tx[0][IPv6].src) return rx def send_and_expect_double_natted(self, src, tx, dst, src_ip, dst_ip): rx = self.send_and_expect(src, tx, dst) for r in rx: self.assertEqual(r[Ether].src, str(self.router_mac)) self.assertEqual(r[Ether].dst, dst.remote_mac) self.assertEqual(r[IP].dst, dst_ip) self.assertEqual(r[IP].src, src_ip) return rx def send_and_expect_double_natted6(self, src, tx, dst, src_ip, dst_ip): rx = self.send_and_expect(src, tx, dst) for r in rx: self.assertEqual(r[Ether].src, str(self.router_mac)) self.assertEqual(r[Ether].dst, dst.remote_mac) self.assertEqual(r[IPv6].dst, dst_ip) self.assertEqual(r[IPv6].src, src_ip) return rx def send_and_expect_no_arp(self, src, tx, dst): self.pg_send(src, tx) dst.get_capture(0, timeout=1) dst.assert_nothing_captured(remark="") def send_and_expect_arp(self, src, tx, dst): rx = self.send_and_expect(src, tx, dst) for r in rx: self.assertEqual(r[Ether].src, tx[0][Ether].src) self.assertEqual(r[Ether].dst, tx[0][Ether].dst) self.assertEqual(r[ARP].psrc, tx[0][ARP].psrc) self.assertEqual(r[ARP].pdst, tx[0][ARP].pdst) self.assertEqual(r[ARP].hwsrc, tx[0][ARP].hwsrc) self.assertEqual(r[ARP].hwdst, tx[0][ARP].hwdst) return rx def test_gbp(self): """Group Based Policy""" ep_flags = VppEnum.vl_api_gbp_endpoint_flags_t # # Route Domains # gt4 = VppIpTable(self, 0) gt4.add_vpp_config() gt6 = VppIpTable(self, 0, is_ip6=True) gt6.add_vpp_config() nt4 = VppIpTable(self, 20) nt4.add_vpp_config() nt6 = VppIpTable(self, 20, is_ip6=True) nt6.add_vpp_config() rd0 = VppGbpRouteDomain(self, 0, 400, gt4, gt6, None, None) rd20 = VppGbpRouteDomain(self, 20, 420, nt4, nt6, None, None) rd0.add_vpp_config() rd20.add_vpp_config() # # Bridge Domains # bd1 = VppBridgeDomain(self, 1) bd2 = VppBridgeDomain(self, 2) bd20 = VppBridgeDomain(self, 20) bd1.add_vpp_config() bd2.add_vpp_config() bd20.add_vpp_config() gbd1 = VppGbpBridgeDomain(self, bd1, rd0, self.loop0) gbd2 = VppGbpBridgeDomain(self, bd2, rd0, self.loop1) gbd20 = VppGbpBridgeDomain(self, bd20, rd20, self.loop2) gbd1.add_vpp_config() gbd2.add_vpp_config() gbd20.add_vpp_config() # # 3 EPGs, 2 of which share a BD. # 2 NAT EPGs, one for floating-IP subnets, the other for internet # epgs = [ VppGbpEndpointGroup( self, 220, 1220, rd0, gbd1, self.pg4, self.loop0, "10.0.0.128", "2001:10::128", ), VppGbpEndpointGroup( self, 221, 1221, rd0, gbd1, self.pg5, self.loop0, "10.0.1.128", "2001:10:1::128", ), VppGbpEndpointGroup( self, 222, 1222, rd0, gbd2, self.pg6, self.loop1, "10.0.2.128", "2001:10:2::128", ), VppGbpEndpointGroup( self, 333, 1333, rd20, gbd20, self.pg7, self.loop2, "11.0.0.128", "3001::128", ), VppGbpEndpointGroup( self, 444, 1444, rd20, gbd20, self.pg8, self.loop2, "11.0.0.129", "3001::129", ), ] recircs = [ VppGbpRecirc(self, epgs[0], self.loop3), VppGbpRecirc(self, epgs[1], self.loop4), VppGbpRecirc(self, epgs[2], self.loop5), VppGbpRecirc(self, epgs[3], self.loop6, is_ext=True), VppGbpRecirc(self, epgs[4], self.loop7, is_ext=True), ] epg_nat = epgs[3] recirc_nat = recircs[3] # # 4 end-points, 2 in the same subnet, 3 in the same BD # eps = [ VppGbpEndpoint( self, self.pg0, epgs[0], recircs[0], "10.0.0.1", "11.0.0.1", "2001:10::1", "3001::1", ), VppGbpEndpoint( self, self.pg1, epgs[0], recircs[0], "10.0.0.2", "11.0.0.2", "2001:10::2", "3001::2", ), VppGbpEndpoint( self, self.pg2, epgs[1], recircs[1], "10.0.1.1", "11.0.0.3", "2001:10:1::1", "3001::3", ), VppGbpEndpoint( self, self.pg3, epgs[2], recircs[2], "10.0.2.1", "11.0.0.4", "2001:10:2::1", "3001::4", ), ] self.vapi.nat44_ed_plugin_enable_disable(enable=1) self.vapi.nat66_plugin_enable_disable(enable=1) # # Config related to each of the EPGs # for epg in epgs: # IP config on the BVI interfaces if epg != epgs[1] and epg != epgs[4]: b4 = VppIpInterfaceBind(self, epg.bvi, epg.rd.t4).add_vpp_config() b6 = VppIpInterfaceBind(self, epg.bvi, epg.rd.t6).add_vpp_config() epg.bvi.set_mac(self.router_mac) # The BVIs are NAT inside interfaces flags = self.nat_config_flags.NAT_IS_INSIDE self.vapi.nat44_interface_add_del_feature( sw_if_index=epg.bvi.sw_if_index, flags=flags, is_add=1 ) self.vapi.nat66_add_del_interface( sw_if_index=epg.bvi.sw_if_index, flags=flags, is_add=1 ) if_ip4 = VppIpInterfaceAddress( self, epg.bvi, epg.bvi_ip4, 32, bind=b4 ).add_vpp_config() if_ip6 = VppIpInterfaceAddress( self, epg.bvi, epg.bvi_ip6, 128, bind=b6 ).add_vpp_config() # EPG uplink interfaces in the RD VppIpInterfaceBind(self, epg.uplink, epg.rd.t4).add_vpp_config() VppIpInterfaceBind(self, epg.uplink, epg.rd.t6).add_vpp_config() # add the BD ARP termination entry for BVI IP epg.bd_arp_ip4 = VppBridgeDomainArpEntry( self, epg.bd.bd, str(self.router_mac), epg.bvi_ip4 ) epg.bd_arp_ip6 = VppBridgeDomainArpEntry( self, epg.bd.bd, str(self.router_mac), epg.bvi_ip6 ) epg.bd_arp_ip4.add_vpp_config() epg.bd_arp_ip6.add_vpp_config() # EPG in VPP epg.add_vpp_config() for recirc in recircs: # EPG's ingress recirculation interface maps to its RD VppIpInterfaceBind(self, recirc.recirc, recirc.epg.rd.t4).add_vpp_config() VppIpInterfaceBind(self, recirc.recirc, recirc.epg.rd.t6).add_vpp_config() self.vapi.nat44_interface_add_del_feature( sw_if_index=recirc.recirc.sw_if_index, is_add=1 ) self.vapi.nat66_add_del_interface( sw_if_index=recirc.recirc.sw_if_index, is_add=1 ) recirc.add_vpp_config() for recirc in recircs: self.assertTrue( find_bridge_domain_port( self, recirc.epg.bd.bd.bd_id, recirc.recirc.sw_if_index ) ) for ep in eps: self.pg_enable_capture(self.pg_interfaces) self.pg_start() # # routes to the endpoints. We need these since there are no # adj-fibs due to the fact the the BVI address has /32 and # the subnet is not attached. # for ip, fip in zip(ep.ips, ep.fips): # Add static mappings for each EP from the 10/8 to 11/8 network if ip_address(ip).version == 4: flags = self.nat_config_flags.NAT_IS_ADDR_ONLY self.vapi.nat44_add_del_static_mapping( is_add=1, local_ip_address=ip, external_ip_address=fip, external_sw_if_index=0xFFFFFFFF, vrf_id=0, flags=flags, ) else: self.vapi.nat66_add_del_static_mapping( local_ip_address=ip, external_ip_address=fip, vrf_id=0, is_add=1 ) # VPP EP create ... ep.add_vpp_config() self.logger.info(self.vapi.cli("sh gbp endpoint")) # ... results in a Gratuitous ARP/ND on the EPG's uplink rx = ep.epg.uplink.get_capture(len(ep.ips) + 1, timeout=0.2) for ii, ip in enumerate(ep.ips): p = rx[ii] if ip_address(ip).version == 6: self.assertTrue(p.haslayer(ICMPv6ND_NA)) self.assertEqual(p[ICMPv6ND_NA].tgt, ip) else: self.assertTrue(p.haslayer(ARP)) self.assertEqual(p[ARP].psrc, ip) self.assertEqual(p[ARP].pdst, ip) # add the BD ARP termination entry for floating IP for fip in ep.fips: ba = VppBridgeDomainArpEntry(self, epg_nat.bd.bd, ep.mac, fip) ba.add_vpp_config() # floating IPs route via EPG recirc r = VppIpRoute( self, fip, ip_address(fip).max_prefixlen, [ VppRoutePath( fip, ep.recirc.recirc.sw_if_index, type=FibPathType.FIB_PATH_TYPE_DVR, proto=get_dpo_proto(fip), ) ], table_id=20, ) r.add_vpp_config() # L2 FIB entries in the NAT EPG BD to bridge the packets from # the outside direct to the internal EPG lf = VppL2FibEntry(self, epg_nat.bd.bd, ep.mac, ep.recirc.recirc, bvi_mac=0) lf.add_vpp_config() self.assert_equal( self.statistics["/net/arp/tx/gratuitous"][ :, epgs[0].uplink.sw_if_index ].sum(), 2, ) self.assert_equal( self.statistics["/net/arp/tx/gratuitous"][ :, epgs[1].uplink.sw_if_index ].sum(), 1, ) self.assert_equal( self.statistics["/net/ip6-nd/tx/gratuitous"][ :, epgs[0].uplink.sw_if_index ].sum(), 2, ) self.assert_equal( self.statistics["/net/ip6-nd/tx/gratuitous"][ :, epgs[1].uplink.sw_if_index ].sum(), 1, ) # # ARP packets for unknown IP are sent to the EPG uplink # pkt_arp = Ether(dst="ff:ff:ff:ff:ff:ff", src=self.pg0.remote_mac) / ARP( op="who-has", hwdst="ff:ff:ff:ff:ff:ff", hwsrc=self.pg0.remote_mac, pdst="10.0.0.88", psrc="10.0.0.99", ) self.vapi.cli("clear trace") self.pg0.add_stream(pkt_arp) self.pg_enable_capture(self.pg_interfaces) self.pg_start() rxd = epgs[0].uplink.get_capture(1) # # ARP/ND packets get a response # pkt_arp = Ether(dst="ff:ff:ff:ff:ff:ff", src=self.pg0.remote_mac) / ARP( op="who-has", hwdst="ff:ff:ff:ff:ff:ff", hwsrc=self.pg0.remote_mac, pdst=epgs[0].bvi_ip4, psrc=eps[0].ip4, ) self.send_and_expect(self.pg0, [pkt_arp], self.pg0) nsma = in6_getnsma(inet_pton(AF_INET6, eps[0].ip6)) d = inet_ntop(AF_INET6, nsma) pkt_nd = ( Ether(dst=in6_getnsmac(nsma), src=self.pg0.remote_mac) / IPv6(dst=d, src=eps[0].ip6) / ICMPv6ND_NS(tgt=epgs[0].bvi_ip6) / ICMPv6NDOptSrcLLAddr(lladdr=self.pg0.remote_mac) ) self.send_and_expect(self.pg0, [pkt_nd], self.pg0) # # broadcast packets are flooded # pkt_bcast = ( Ether(dst="ff:ff:ff:ff:ff:ff", src=self.pg0.remote_mac) / IP(src=eps[0].ip4, dst="232.1.1.1") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) self.vapi.cli("clear trace") self.pg0.add_stream(pkt_bcast) self.pg_enable_capture(self.pg_interfaces) self.pg_start() rxd = eps[1].itf.get_capture(1) self.assertEqual(rxd[0][Ether].dst, pkt_bcast[Ether].dst) rxd = epgs[0].uplink.get_capture(1) self.assertEqual(rxd[0][Ether].dst, pkt_bcast[Ether].dst) # # packets to non-local L3 destinations dropped # pkt_intra_epg_220_ip4 = ( Ether(src=self.pg0.remote_mac, dst=str(self.router_mac)) / IP(src=eps[0].ip4, dst="10.0.0.99") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) pkt_inter_epg_222_ip4 = ( Ether(src=self.pg0.remote_mac, dst=str(self.router_mac)) / IP(src=eps[0].ip4, dst="10.0.1.99") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) self.send_and_assert_no_replies(self.pg0, pkt_intra_epg_220_ip4 * NUM_PKTS) pkt_inter_epg_222_ip6 = ( Ether(src=self.pg0.remote_mac, dst=str(self.router_mac)) / IPv6(src=eps[0].ip6, dst="2001:10::99") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) self.send_and_assert_no_replies(self.pg0, pkt_inter_epg_222_ip6 * NUM_PKTS) # # Add the subnet routes # s41 = VppGbpSubnet( self, rd0, "10.0.0.0", 24, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_STITCHED_INTERNAL, ) s42 = VppGbpSubnet( self, rd0, "10.0.1.0", 24, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_STITCHED_INTERNAL, ) s43 = VppGbpSubnet( self, rd0, "10.0.2.0", 24, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_STITCHED_INTERNAL, ) s61 = VppGbpSubnet( self, rd0, "2001:10::1", 64, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_STITCHED_INTERNAL, ) s62 = VppGbpSubnet( self, rd0, "2001:10:1::1", 64, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_STITCHED_INTERNAL, ) s63 = VppGbpSubnet( self, rd0, "2001:10:2::1", 64, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_STITCHED_INTERNAL, ) s41.add_vpp_config() s42.add_vpp_config() s43.add_vpp_config() s61.add_vpp_config() s62.add_vpp_config() s63.add_vpp_config() self.send_and_expect_bridged( eps[0].itf, pkt_intra_epg_220_ip4 * NUM_PKTS, eps[0].epg.uplink ) self.send_and_expect_bridged( eps[0].itf, pkt_inter_epg_222_ip4 * NUM_PKTS, eps[0].epg.uplink ) self.send_and_expect_bridged6( eps[0].itf, pkt_inter_epg_222_ip6 * NUM_PKTS, eps[0].epg.uplink ) self.logger.info(self.vapi.cli("sh ip fib 11.0.0.2")) self.logger.info(self.vapi.cli("sh gbp endpoint-group")) self.logger.info(self.vapi.cli("sh gbp endpoint")) self.logger.info(self.vapi.cli("sh gbp recirc")) self.logger.info(self.vapi.cli("sh int")) self.logger.info(self.vapi.cli("sh int addr")) self.logger.info(self.vapi.cli("sh int feat loop6")) self.logger.info(self.vapi.cli("sh vlib graph ip4-gbp-src-classify")) self.logger.info(self.vapi.cli("sh int feat loop3")) self.logger.info(self.vapi.cli("sh int feat pg0")) # # Packet destined to unknown unicast is sent on the epg uplink ... # pkt_intra_epg_220_to_uplink = ( Ether(src=self.pg0.remote_mac, dst="00:00:00:33:44:55") / IP(src=eps[0].ip4, dst="10.0.0.99") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) self.send_and_expect_bridged( eps[0].itf, pkt_intra_epg_220_to_uplink * NUM_PKTS, eps[0].epg.uplink ) # ... and nowhere else self.pg1.get_capture(0, timeout=0.1) self.pg1.assert_nothing_captured(remark="Flood onto other VMS") pkt_intra_epg_221_to_uplink = ( Ether(src=self.pg2.remote_mac, dst="00:00:00:33:44:66") / IP(src=eps[0].ip4, dst="10.0.0.99") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) self.send_and_expect_bridged( eps[2].itf, pkt_intra_epg_221_to_uplink * NUM_PKTS, eps[2].epg.uplink ) # # Packets from the uplink are forwarded in the absence of a contract # pkt_intra_epg_220_from_uplink = ( Ether(src="00:00:00:33:44:55", dst=self.pg0.remote_mac) / IP(src=eps[0].ip4, dst="10.0.0.99") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) self.send_and_expect_bridged( self.pg4, pkt_intra_epg_220_from_uplink * NUM_PKTS, self.pg0 ) # # in the absence of policy, endpoints in the same EPG # can communicate # pkt_intra_epg = ( Ether(src=self.pg0.remote_mac, dst=self.pg1.remote_mac) / IP(src=eps[0].ip4, dst=eps[1].ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) self.send_and_expect_bridged(self.pg0, pkt_intra_epg * NUM_PKTS, self.pg1) # # in the absence of policy, endpoints in the different EPG # cannot communicate # pkt_inter_epg_220_to_221 = ( Ether(src=self.pg0.remote_mac, dst=self.pg2.remote_mac) / IP(src=eps[0].ip4, dst=eps[2].ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) pkt_inter_epg_221_to_220 = ( Ether(src=self.pg2.remote_mac, dst=self.pg0.remote_mac) / IP(src=eps[2].ip4, dst=eps[0].ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) pkt_inter_epg_220_to_222 = ( Ether(src=self.pg0.remote_mac, dst=str(self.router_mac)) / IP(src=eps[0].ip4, dst=eps[3].ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) self.send_and_assert_no_replies(eps[0].itf, pkt_inter_epg_220_to_221 * NUM_PKTS) self.send_and_assert_no_replies(eps[0].itf, pkt_inter_epg_220_to_222 * NUM_PKTS) # # A uni-directional contract from EPG 220 -> 221 # rule = AclRule(is_permit=1, proto=17) rule2 = AclRule( src_prefix=IPv6Network((0, 0)), dst_prefix=IPv6Network((0, 0)), is_permit=1, proto=17, ) acl = VppAcl(self, rules=[rule, rule2]) acl.add_vpp_config() c1 = VppGbpContract( self, 400, epgs[0].sclass, epgs[1].sclass, acl.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), ], [ETH_P_IP, ETH_P_IPV6], ) c1.add_vpp_config() self.send_and_expect_bridged( eps[0].itf, pkt_inter_epg_220_to_221 * NUM_PKTS, eps[2].itf ) self.send_and_assert_no_replies(eps[0].itf, pkt_inter_epg_220_to_222 * NUM_PKTS) # # contract for the return direction # c2 = VppGbpContract( self, 400, epgs[1].sclass, epgs[0].sclass, acl.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), ], [ETH_P_IP, ETH_P_IPV6], ) c2.add_vpp_config() self.send_and_expect_bridged( eps[0].itf, pkt_inter_epg_220_to_221 * NUM_PKTS, eps[2].itf ) self.send_and_expect_bridged( eps[2].itf, pkt_inter_epg_221_to_220 * NUM_PKTS, eps[0].itf ) ds = c2.get_drop_stats() self.assertEqual(ds["packets"], 0) ps = c2.get_permit_stats() self.assertEqual(ps["packets"], NUM_PKTS) # # the contract does not allow non-IP # pkt_non_ip_inter_epg_220_to_221 = ( Ether(src=self.pg0.remote_mac, dst=self.pg2.remote_mac) / ARP() ) self.send_and_assert_no_replies( eps[0].itf, pkt_non_ip_inter_epg_220_to_221 * 17 ) # # check that inter group is still disabled for the groups # not in the contract. # self.send_and_assert_no_replies(eps[0].itf, pkt_inter_epg_220_to_222 * NUM_PKTS) # # A uni-directional contract from EPG 220 -> 222 'L3 routed' # c3 = VppGbpContract( self, 400, epgs[0].sclass, epgs[2].sclass, acl.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), ], [ETH_P_IP, ETH_P_IPV6], ) c3.add_vpp_config() self.logger.info(self.vapi.cli("sh gbp contract")) self.send_and_expect_routed( eps[0].itf, pkt_inter_epg_220_to_222 * NUM_PKTS, eps[3].itf, str(self.router_mac), ) # # remove both contracts, traffic stops in both directions # c2.remove_vpp_config() c1.remove_vpp_config() c3.remove_vpp_config() acl.remove_vpp_config() self.send_and_assert_no_replies(eps[2].itf, pkt_inter_epg_221_to_220 * NUM_PKTS) self.send_and_assert_no_replies(eps[0].itf, pkt_inter_epg_220_to_221 * NUM_PKTS) self.send_and_expect_bridged(eps[0].itf, pkt_intra_epg * NUM_PKTS, eps[1].itf) # # EPs to the outside world # # in the EP's RD an external subnet via the NAT EPG's recirc se1 = VppGbpSubnet( self, rd0, "0.0.0.0", 0, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_STITCHED_EXTERNAL, sw_if_index=recirc_nat.recirc.sw_if_index, sclass=epg_nat.sclass, ) se2 = VppGbpSubnet( self, rd0, "11.0.0.0", 8, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_STITCHED_EXTERNAL, sw_if_index=recirc_nat.recirc.sw_if_index, sclass=epg_nat.sclass, ) se16 = VppGbpSubnet( self, rd0, "::", 0, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_STITCHED_EXTERNAL, sw_if_index=recirc_nat.recirc.sw_if_index, sclass=epg_nat.sclass, ) # in the NAT RD an external subnet via the NAT EPG's uplink se3 = VppGbpSubnet( self, rd20, "0.0.0.0", 0, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_STITCHED_EXTERNAL, sw_if_index=epg_nat.uplink.sw_if_index, sclass=epg_nat.sclass, ) se36 = VppGbpSubnet( self, rd20, "::", 0, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_STITCHED_EXTERNAL, sw_if_index=epg_nat.uplink.sw_if_index, sclass=epg_nat.sclass, ) se4 = VppGbpSubnet( self, rd20, "11.0.0.0", 8, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_STITCHED_EXTERNAL, sw_if_index=epg_nat.uplink.sw_if_index, sclass=epg_nat.sclass, ) se1.add_vpp_config() se2.add_vpp_config() se16.add_vpp_config() se3.add_vpp_config() se36.add_vpp_config() se4.add_vpp_config() self.logger.info(self.vapi.cli("sh ip fib 0.0.0.0/0")) self.logger.info(self.vapi.cli("sh ip fib 11.0.0.1")) self.logger.info(self.vapi.cli("sh ip6 fib ::/0")) self.logger.info(self.vapi.cli("sh ip6 fib %s" % eps[0].fip6)) # # From an EP to an outside address: IN2OUT # pkt_inter_epg_220_to_global = ( Ether(src=self.pg0.remote_mac, dst=str(self.router_mac)) / IP(src=eps[0].ip4, dst="1.1.1.1") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) # no policy yet self.send_and_assert_no_replies( eps[0].itf, pkt_inter_epg_220_to_global * NUM_PKTS ) rule = AclRule(is_permit=1, proto=17, ports=1234) rule2 = AclRule( is_permit=1, proto=17, ports=1234, src_prefix=IPv6Network((0, 0)), dst_prefix=IPv6Network((0, 0)), ) acl2 = VppAcl(self, rules=[rule, rule2]) acl2.add_vpp_config() c4 = VppGbpContract( self, 400, epgs[0].sclass, epgs[3].sclass, acl2.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), ], [ETH_P_IP, ETH_P_IPV6], ) c4.add_vpp_config() self.send_and_expect_natted( eps[0].itf, pkt_inter_epg_220_to_global * NUM_PKTS, self.pg7, eps[0].fip4 ) pkt_inter_epg_220_to_global = ( Ether(src=self.pg0.remote_mac, dst=str(self.router_mac)) / IPv6(src=eps[0].ip6, dst="6001::1") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) self.send_and_expect_natted6( self.pg0, pkt_inter_epg_220_to_global * NUM_PKTS, self.pg7, eps[0].fip6 ) # # From a global address to an EP: OUT2IN # pkt_inter_epg_220_from_global = ( Ether(src=str(self.router_mac), dst=self.pg0.remote_mac) / IP(dst=eps[0].fip4, src="1.1.1.1") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) self.send_and_assert_no_replies( self.pg7, pkt_inter_epg_220_from_global * NUM_PKTS ) c5 = VppGbpContract( self, 400, epgs[3].sclass, epgs[0].sclass, acl2.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), ], [ETH_P_IP, ETH_P_IPV6], ) c5.add_vpp_config() self.send_and_expect_unnatted( self.pg7, pkt_inter_epg_220_from_global * NUM_PKTS, eps[0].itf, eps[0].ip4 ) pkt_inter_epg_220_from_global = ( Ether(src=str(self.router_mac), dst=self.pg0.remote_mac) / IPv6(dst=eps[0].fip6, src="6001::1") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) self.send_and_expect_unnatted6( self.pg7, pkt_inter_epg_220_from_global * NUM_PKTS, eps[0].itf, eps[0].ip6 ) # # From a local VM to another local VM using resp. public addresses: # IN2OUT2IN # pkt_intra_epg_220_global = ( Ether(src=self.pg0.remote_mac, dst=str(self.router_mac)) / IP(src=eps[0].ip4, dst=eps[1].fip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) self.send_and_expect_double_natted( eps[0].itf, pkt_intra_epg_220_global * NUM_PKTS, eps[1].itf, eps[0].fip4, eps[1].ip4, ) pkt_intra_epg_220_global = ( Ether(src=self.pg0.remote_mac, dst=str(self.router_mac)) / IPv6(src=eps[0].ip6, dst=eps[1].fip6) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) self.send_and_expect_double_natted6( eps[0].itf, pkt_intra_epg_220_global * NUM_PKTS, eps[1].itf, eps[0].fip6, eps[1].ip6, ) # # cleanup # self.vapi.nat44_ed_plugin_enable_disable(enable=0) self.vapi.nat66_plugin_enable_disable(enable=0) def wait_for_ep_timeout( self, sw_if_index=None, ip=None, mac=None, tep=None, n_tries=100, s_time=1 ): # only learnt EP can timeout ep_flags = VppEnum.vl_api_gbp_endpoint_flags_t flags = ep_flags.GBP_API_ENDPOINT_FLAG_LEARNT while n_tries: if not find_gbp_endpoint(self, sw_if_index, ip, mac, tep=tep, flags=flags): return True n_tries = n_tries - 1 self.sleep(s_time) self.assertFalse( find_gbp_endpoint(self, sw_if_index, ip, mac, tep=tep, flags=flags) ) return False def test_gbp_learn_l2(self): """GBP L2 Endpoint Learning""" drop_no_contract = self.statistics.get_err_counter( "/err/gbp-policy-port/drop-no-contract" ) allow_intra_class = self.statistics.get_err_counter( "/err/gbp-policy-port/allow-intra-sclass" ) ep_flags = VppEnum.vl_api_gbp_endpoint_flags_t learnt = [ {"mac": "00:00:11:11:11:01", "ip": "10.0.0.1", "ip6": "2001:10::2"}, {"mac": "00:00:11:11:11:02", "ip": "10.0.0.2", "ip6": "2001:10::3"}, ] # # IP tables # gt4 = VppIpTable(self, 1) gt4.add_vpp_config() gt6 = VppIpTable(self, 1, is_ip6=True) gt6.add_vpp_config() rd1 = VppGbpRouteDomain(self, 1, 401, gt4, gt6) rd1.add_vpp_config() # # Pg2 hosts the vxlan tunnel, hosts on pg2 to act as TEPs # Pg3 hosts the IP4 UU-flood VXLAN tunnel # Pg4 hosts the IP6 UU-flood VXLAN tunnel # self.pg2.config_ip4() self.pg2.resolve_arp() self.pg2.generate_remote_hosts(4) self.pg2.configure_ipv4_neighbors() self.pg3.config_ip4() self.pg3.resolve_arp() self.pg4.config_ip4() self.pg4.resolve_arp() # # Add a mcast destination VXLAN-GBP tunnel for B&M traffic # tun_bm = VppVxlanGbpTunnel( self, self.pg4.local_ip4, "239.1.1.1", 88, mcast_itf=self.pg4 ) tun_bm.add_vpp_config() # # a GBP bridge domain with a BVI and a UU-flood interface # bd1 = VppBridgeDomain(self, 1) bd1.add_vpp_config() gbd1 = VppGbpBridgeDomain(self, bd1, rd1, self.loop0, self.pg3, tun_bm) gbd1.add_vpp_config() self.logger.info(self.vapi.cli("sh bridge 1 detail")) self.logger.info(self.vapi.cli("sh gbp bridge")) # ... and has a /32 applied ip_addr = VppIpInterfaceAddress(self, gbd1.bvi, "10.0.0.128", 32) ip_addr.add_vpp_config() # # The Endpoint-group in which we are learning endpoints # epg_220 = VppGbpEndpointGroup( self, 220, 112, rd1, gbd1, None, self.loop0, "10.0.0.128", "2001:10::128", VppGbpEndpointRetention(4), ) epg_220.add_vpp_config() epg_330 = VppGbpEndpointGroup( self, 330, 113, rd1, gbd1, None, self.loop1, "10.0.1.128", "2001:11::128", VppGbpEndpointRetention(4), ) epg_330.add_vpp_config() # # The VXLAN GBP tunnel is a bridge-port and has L2 endpoint # learning enabled # vx_tun_l2_1 = VppGbpVxlanTunnel( self, 99, bd1.bd_id, VppEnum.vl_api_gbp_vxlan_tunnel_mode_t.GBP_VXLAN_TUNNEL_MODE_L2, self.pg2.local_ip4, ) vx_tun_l2_1.add_vpp_config() # # A static endpoint that the learnt endpoints are trying to # talk to # ep = VppGbpEndpoint( self, self.pg0, epg_220, None, "10.0.0.127", "11.0.0.127", "2001:10::1", "3001::1", ) ep.add_vpp_config() self.assertTrue(find_route(self, ep.ip4, 32, table_id=1)) # a packet with an sclass from an unknown EPG p = ( Ether(src=self.pg2.remote_mac, dst=self.pg2.local_mac) / IP(src=self.pg2.remote_hosts[0].ip4, dst=self.pg2.local_ip4) / UDP(sport=1234, dport=48879) / VXLAN(vni=99, gpid=88, flags=0x88) / Ether(src=learnt[0]["mac"], dst=ep.mac) / IP(src=learnt[0]["ip"], dst=ep.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) self.send_and_assert_no_replies(self.pg2, p) self.logger.info(self.vapi.cli("sh error")) self.assert_error_counter_equal( "/err/gbp-policy-port/drop-no-contract", drop_no_contract + 1 ) # # we should not have learnt a new tunnel endpoint, since # the EPG was not learnt. # self.assertEqual( INDEX_INVALID, find_vxlan_gbp_tunnel( self, self.pg2.local_ip4, self.pg2.remote_hosts[0].ip4, 99 ), ) # ep is not learnt, because the EPG is unknown self.assertEqual(len(self.vapi.gbp_endpoint_dump()), 1) # # Learn new EPs from IP packets # for ii, l in enumerate(learnt): # a packet with an sclass from a known EPG # arriving on an unknown TEP p = ( Ether(src=self.pg2.remote_mac, dst=self.pg2.local_mac) / IP(src=self.pg2.remote_hosts[1].ip4, dst=self.pg2.local_ip4) / UDP(sport=1234, dport=48879) / VXLAN(vni=99, gpid=112, flags=0x88) / Ether(src=l["mac"], dst=ep.mac) / IP(src=l["ip"], dst=ep.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rx = self.send_and_expect(self.pg2, [p], self.pg0) # the new TEP tep1_sw_if_index = find_vxlan_gbp_tunnel( self, self.pg2.local_ip4, self.pg2.remote_hosts[1].ip4, 99 ) self.assertNotEqual(INDEX_INVALID, tep1_sw_if_index) # # the EP is learnt via the learnt TEP # both from its MAC and its IP # self.assertTrue( find_gbp_endpoint(self, vx_tun_l2_1.sw_if_index, mac=l["mac"]) ) self.assertTrue( find_gbp_endpoint(self, vx_tun_l2_1.sw_if_index, ip=l["ip"]) ) self.assert_error_counter_equal( "/err/gbp-policy-port/allow-intra-sclass", allow_intra_class + 2 ) self.logger.info(self.vapi.cli("show gbp endpoint")) self.logger.info(self.vapi.cli("show gbp vxlan")) self.logger.info(self.vapi.cli("show ip mfib")) # # If we sleep for the threshold time, the learnt endpoints should # age out # for l in learnt: self.wait_for_ep_timeout(vx_tun_l2_1.sw_if_index, mac=l["mac"]) # # Learn new EPs from GARP packets received on the BD's mcast tunnel # for ii, l in enumerate(learnt): # add some junk in the reserved field of the vxlan-header # next to the VNI. we should accept since reserved bits are # ignored on rx. p = ( Ether(src=self.pg2.remote_mac, dst=self.pg2.local_mac) / IP(src=self.pg2.remote_hosts[1].ip4, dst="239.1.1.1") / UDP(sport=1234, dport=48879) / VXLAN(vni=88, reserved2=0x80, gpid=112, flags=0x88) / Ether(src=l["mac"], dst="ff:ff:ff:ff:ff:ff") / ARP( op="who-has", psrc=l["ip"], pdst=l["ip"], hwsrc=l["mac"], hwdst="ff:ff:ff:ff:ff:ff", ) ) rx = self.send_and_expect(self.pg4, [p], self.pg0) # the new TEP tep1_sw_if_index = find_vxlan_gbp_tunnel( self, self.pg2.local_ip4, self.pg2.remote_hosts[1].ip4, 99 ) self.assertNotEqual(INDEX_INVALID, tep1_sw_if_index) # # the EP is learnt via the learnt TEP # both from its MAC and its IP # self.assertTrue( find_gbp_endpoint(self, vx_tun_l2_1.sw_if_index, mac=l["mac"]) ) self.assertTrue( find_gbp_endpoint(self, vx_tun_l2_1.sw_if_index, ip=l["ip"]) ) # # wait for the learnt endpoints to age out # for l in learnt: self.wait_for_ep_timeout(vx_tun_l2_1.sw_if_index, mac=l["mac"]) # # Learn new EPs from L2 packets # for ii, l in enumerate(learnt): # a packet with an sclass from a known EPG # arriving on an unknown TEP p = ( Ether(src=self.pg2.remote_mac, dst=self.pg2.local_mac) / IP(src=self.pg2.remote_hosts[1].ip4, dst=self.pg2.local_ip4) / UDP(sport=1234, dport=48879) / VXLAN(vni=99, gpid=112, flags=0x88) / Ether(src=l["mac"], dst=ep.mac) / Raw(b"\xa5" * 100) ) rx = self.send_and_expect(self.pg2, [p], self.pg0) # the new TEP tep1_sw_if_index = find_vxlan_gbp_tunnel( self, self.pg2.local_ip4, self.pg2.remote_hosts[1].ip4, 99 ) self.assertNotEqual(INDEX_INVALID, tep1_sw_if_index) # # the EP is learnt via the learnt TEP # both from its MAC and its IP # self.assertTrue( find_gbp_endpoint(self, vx_tun_l2_1.sw_if_index, mac=l["mac"]) ) self.logger.info(self.vapi.cli("show gbp endpoint")) self.logger.info(self.vapi.cli("show gbp vxlan")) self.logger.info(self.vapi.cli("show vxlan-gbp tunnel")) # # wait for the learnt endpoints to age out # for l in learnt: self.wait_for_ep_timeout(vx_tun_l2_1.sw_if_index, mac=l["mac"]) # # repeat. the do not learn bit is set so the EPs are not learnt # for l in learnt: # a packet with an sclass from a known EPG p = ( Ether(src=self.pg2.remote_mac, dst=self.pg2.local_mac) / IP(src=self.pg2.remote_hosts[1].ip4, dst=self.pg2.local_ip4) / UDP(sport=1234, dport=48879) / VXLAN(vni=99, gpid=112, flags=0x88, gpflags="D") / Ether(src=l["mac"], dst=ep.mac) / IP(src=l["ip"], dst=ep.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rx = self.send_and_expect(self.pg2, p * NUM_PKTS, self.pg0) for l in learnt: self.assertFalse( find_gbp_endpoint(self, vx_tun_l2_1.sw_if_index, mac=l["mac"]) ) # # repeat # for l in learnt: # a packet with an sclass from a known EPG # set a reserved bit in addition to the G and I # reserved bits should not be checked on rx. p = ( Ether(src=self.pg2.remote_mac, dst=self.pg2.local_mac) / IP(src=self.pg2.remote_hosts[1].ip4, dst=self.pg2.local_ip4) / UDP(sport=1234, dport=48879) / VXLAN(vni=99, gpid=112, flags=0xC8) / Ether(src=l["mac"], dst=ep.mac) / IP(src=l["ip"], dst=ep.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rx = self.send_and_expect(self.pg2, p * NUM_PKTS, self.pg0) self.assertTrue( find_gbp_endpoint(self, vx_tun_l2_1.sw_if_index, mac=l["mac"]) ) # # Static EP replies to dynamics # self.logger.info(self.vapi.cli("sh l2fib bd_id 1")) for l in learnt: p = ( Ether(src=ep.mac, dst=l["mac"]) / IP(dst=l["ip"], src=ep.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg0, p * 17, self.pg2) for rx in rxs: self.assertEqual(rx[IP].src, self.pg2.local_ip4) self.assertEqual(rx[IP].dst, self.pg2.remote_hosts[1].ip4) self.assertEqual(rx[UDP].dport, 48879) # the UDP source port is a random value for hashing self.assertEqual(rx[VXLAN].gpid, 112) self.assertEqual(rx[VXLAN].vni, 99) self.assertTrue(rx[VXLAN].flags.G) self.assertTrue(rx[VXLAN].flags.Instance) self.assertTrue(rx[VXLAN].gpflags.A) self.assertFalse(rx[VXLAN].gpflags.D) for l in learnt: self.wait_for_ep_timeout(vx_tun_l2_1.sw_if_index, mac=l["mac"]) # # repeat in the other EPG # there's no contract between 220 and 330, but the A-bit is set # so the packet is cleared for delivery # for l in learnt: # a packet with an sclass from a known EPG p = ( Ether(src=self.pg2.remote_mac, dst=self.pg2.local_mac) / IP(src=self.pg2.remote_hosts[1].ip4, dst=self.pg2.local_ip4) / UDP(sport=1234, dport=48879) / VXLAN(vni=99, gpid=113, flags=0x88, gpflags="A") / Ether(src=l["mac"], dst=ep.mac) / IP(src=l["ip"], dst=ep.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rx = self.send_and_expect(self.pg2, p * NUM_PKTS, self.pg0) self.assertTrue( find_gbp_endpoint(self, vx_tun_l2_1.sw_if_index, mac=l["mac"]) ) # # static EP cannot reach the learnt EPs since there is no contract # only test 1 EP as the others could timeout # p = ( Ether(src=ep.mac, dst=l["mac"]) / IP(dst=learnt[0]["ip"], src=ep.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) self.send_and_assert_no_replies(self.pg0, [p]) # # refresh the entries after the check for no replies above # for l in learnt: # a packet with an sclass from a known EPG p = ( Ether(src=self.pg2.remote_mac, dst=self.pg2.local_mac) / IP(src=self.pg2.remote_hosts[1].ip4, dst=self.pg2.local_ip4) / UDP(sport=1234, dport=48879) / VXLAN(vni=99, gpid=113, flags=0x88, gpflags="A") / Ether(src=l["mac"], dst=ep.mac) / IP(src=l["ip"], dst=ep.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rx = self.send_and_expect(self.pg2, p * NUM_PKTS, self.pg0) self.assertTrue( find_gbp_endpoint(self, vx_tun_l2_1.sw_if_index, mac=l["mac"]) ) # # Add the contract so they can talk # rule = AclRule(is_permit=1, proto=17) rule2 = AclRule( src_prefix=IPv6Network((0, 0)), dst_prefix=IPv6Network((0, 0)), is_permit=1, proto=17, ) acl = VppAcl(self, rules=[rule, rule2]) acl.add_vpp_config() c1 = VppGbpContract( self, 401, epg_220.sclass, epg_330.sclass, acl.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), ], [ETH_P_IP, ETH_P_IPV6], ) c1.add_vpp_config() for l in learnt: p = ( Ether(src=ep.mac, dst=l["mac"]) / IP(dst=l["ip"], src=ep.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) self.send_and_expect(self.pg0, [p], self.pg2) # # send UU packets from the local EP # self.logger.info(self.vapi.cli("sh gbp bridge")) self.logger.info(self.vapi.cli("sh bridge-domain 1 detail")) p_uu = ( Ether(src=ep.mac, dst="00:11:11:11:11:11") / IP(dst="10.0.0.133", src=ep.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(ep.itf, [p_uu], gbd1.uu_fwd) self.logger.info(self.vapi.cli("sh bridge 1 detail")) p_bm = ( Ether(src=ep.mac, dst="ff:ff:ff:ff:ff:ff") / IP(dst="10.0.0.133", src=ep.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect_only(ep.itf, [p_bm], tun_bm.mcast_itf) for rx in rxs: self.assertEqual(rx[IP].src, self.pg4.local_ip4) self.assertEqual(rx[IP].dst, "239.1.1.1") self.assertEqual(rx[UDP].dport, 48879) # the UDP source port is a random value for hashing self.assertEqual(rx[VXLAN].gpid, 112) self.assertEqual(rx[VXLAN].vni, 88) self.assertTrue(rx[VXLAN].flags.G) self.assertTrue(rx[VXLAN].flags.Instance) self.assertFalse(rx[VXLAN].gpflags.A) self.assertFalse(rx[VXLAN].gpflags.D) rule = AclRule(is_permit=1, proto=17) rule2 = AclRule( src_prefix=IPv6Network((0, 0)), dst_prefix=IPv6Network((0, 0)), is_permit=1, proto=17, ) acl = VppAcl(self, rules=[rule, rule2]) acl.add_vpp_config() c2 = VppGbpContract( self, 401, epg_330.sclass, epg_220.sclass, acl.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), ], [ETH_P_IP, ETH_P_IPV6], ) c2.add_vpp_config() for l in learnt: self.wait_for_ep_timeout(vx_tun_l2_1.sw_if_index, mac=l["mac"]) # # Check v6 Endpoints learning # for l in learnt: # a packet with an sclass from a known EPG p = ( Ether(src=self.pg2.remote_mac, dst=self.pg2.local_mac) / IP(src=self.pg2.remote_hosts[1].ip4, dst=self.pg2.local_ip4) / UDP(sport=1234, dport=48879) / VXLAN(vni=99, gpid=113, flags=0x88) / Ether(src=l["mac"], dst=ep.mac) / IPv6(src=l["ip6"], dst=ep.ip6) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rx = self.send_and_expect(self.pg2, p * NUM_PKTS, self.pg0) rx = self.send_and_expect(self.pg2, p * NUM_PKTS, self.pg0) self.assertTrue( find_gbp_endpoint( self, vx_tun_l2_1.sw_if_index, ip=l["ip6"], tep=[self.pg2.local_ip4, self.pg2.remote_hosts[1].ip4], ) ) self.logger.info(self.vapi.cli("sh int")) self.logger.info(self.vapi.cli("sh vxlan-gbp tunnel")) self.logger.info(self.vapi.cli("sh gbp vxlan")) self.logger.info(self.vapi.cli("sh gbp endpoint")) self.logger.info(self.vapi.cli("sh gbp interface")) # # EP moves to a different TEP # for l in learnt: # a packet with an sclass from a known EPG p = ( Ether(src=self.pg2.remote_mac, dst=self.pg2.local_mac) / IP(src=self.pg2.remote_hosts[2].ip4, dst=self.pg2.local_ip4) / UDP(sport=1234, dport=48879) / VXLAN(vni=99, gpid=113, flags=0x88) / Ether(src=l["mac"], dst=ep.mac) / IPv6(src=l["ip6"], dst=ep.ip6) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rx = self.send_and_expect(self.pg2, p * 1, self.pg0) rx = self.send_and_expect(self.pg2, p * NUM_PKTS, self.pg0) self.assertTrue( find_gbp_endpoint( self, vx_tun_l2_1.sw_if_index, sclass=113, mac=l["mac"], tep=[self.pg2.local_ip4, self.pg2.remote_hosts[2].ip4], ) ) # # v6 remote EP reachability # for l in learnt: p = ( Ether(src=ep.mac, dst=l["mac"]) / IPv6(dst=l["ip6"], src=ep.ip6) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg0, p * NUM_PKTS, self.pg2) for rx in rxs: self.assertEqual(rx[IP].src, self.pg2.local_ip4) self.assertEqual(rx[IP].dst, self.pg2.remote_hosts[2].ip4) self.assertEqual(rx[UDP].dport, 48879) # the UDP source port is a random value for hashing self.assertEqual(rx[VXLAN].gpid, 112) self.assertEqual(rx[VXLAN].vni, 99) self.assertTrue(rx[VXLAN].flags.G) self.assertTrue(rx[VXLAN].flags.Instance) self.assertTrue(rx[VXLAN].gpflags.A) self.assertFalse(rx[VXLAN].gpflags.D) self.assertEqual(rx[IPv6].dst, l["ip6"]) # # EP changes sclass # for l in learnt: # a packet with an sclass from a known EPG p = ( Ether(src=self.pg2.remote_mac, dst=self.pg2.local_mac) / IP(src=self.pg2.remote_hosts[2].ip4, dst=self.pg2.local_ip4) / UDP(sport=1234, dport=48879) / VXLAN(vni=99, gpid=112, flags=0x88) / Ether(src=l["mac"], dst=ep.mac) / IPv6(src=l["ip6"], dst=ep.ip6) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rx = self.send_and_expect(self.pg2, p * 1, self.pg0) rx = self.send_and_expect(self.pg2, p * NUM_PKTS, self.pg0) self.assertTrue( find_gbp_endpoint( self, vx_tun_l2_1.sw_if_index, mac=l["mac"], sclass=112, tep=[self.pg2.local_ip4, self.pg2.remote_hosts[2].ip4], ) ) # # check reachability and contract intra-epg # allow_intra_class = self.statistics.get_err_counter( "/err/gbp-policy-mac/allow-intra-sclass" ) for l in learnt: p = ( Ether(src=ep.mac, dst=l["mac"]) / IPv6(dst=l["ip6"], src=ep.ip6) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg0, p * NUM_PKTS, self.pg2) for rx in rxs: self.assertEqual(rx[IP].src, self.pg2.local_ip4) self.assertEqual(rx[IP].dst, self.pg2.remote_hosts[2].ip4) self.assertEqual(rx[UDP].dport, 48879) self.assertEqual(rx[VXLAN].gpid, 112) self.assertEqual(rx[VXLAN].vni, 99) self.assertTrue(rx[VXLAN].flags.G) self.assertTrue(rx[VXLAN].flags.Instance) self.assertTrue(rx[VXLAN].gpflags.A) self.assertFalse(rx[VXLAN].gpflags.D) self.assertEqual(rx[IPv6].dst, l["ip6"]) allow_intra_class += NUM_PKTS self.assert_error_counter_equal( "/err/gbp-policy-mac/allow-intra-sclass", allow_intra_class ) # # clean up # for l in learnt: self.wait_for_ep_timeout(vx_tun_l2_1.sw_if_index, mac=l["mac"]) self.pg2.unconfig_ip4() self.pg3.unconfig_ip4() self.pg4.unconfig_ip4() def test_gbp_contract(self): """GBP Contracts""" # # Route Domains # gt4 = VppIpTable(self, 0) gt4.add_vpp_config() gt6 = VppIpTable(self, 0, is_ip6=True) gt6.add_vpp_config() rd0 = VppGbpRouteDomain(self, 0, 400, gt4, gt6, None, None) rd0.add_vpp_config() # # Bridge Domains # bd1 = VppBridgeDomain(self, 1, arp_term=0) bd2 = VppBridgeDomain(self, 2, arp_term=0) bd1.add_vpp_config() bd2.add_vpp_config() gbd1 = VppGbpBridgeDomain(self, bd1, rd0, self.loop0) gbd2 = VppGbpBridgeDomain(self, bd2, rd0, self.loop1) gbd1.add_vpp_config() gbd2.add_vpp_config() # # 3 EPGs, 2 of which share a BD. # epgs = [ VppGbpEndpointGroup( self, 220, 1220, rd0, gbd1, None, self.loop0, "10.0.0.128", "2001:10::128", ), VppGbpEndpointGroup( self, 221, 1221, rd0, gbd1, None, self.loop0, "10.0.1.128", "2001:10:1::128", ), VppGbpEndpointGroup( self, 222, 1222, rd0, gbd2, None, self.loop1, "10.0.2.128", "2001:10:2::128", ), ] # # 4 end-points, 2 in the same subnet, 3 in the same BD # eps = [ VppGbpEndpoint( self, self.pg0, epgs[0], None, "10.0.0.1", "11.0.0.1", "2001:10::1", "3001::1", ), VppGbpEndpoint( self, self.pg1, epgs[0], None, "10.0.0.2", "11.0.0.2", "2001:10::2", "3001::2", ), VppGbpEndpoint( self, self.pg2, epgs[1], None, "10.0.1.1", "11.0.0.3", "2001:10:1::1", "3001::3", ), VppGbpEndpoint( self, self.pg3, epgs[2], None, "10.0.2.1", "11.0.0.4", "2001:10:2::1", "3001::4", ), ] # # Config related to each of the EPGs # for epg in epgs: # IP config on the BVI interfaces if epg != epgs[1]: b4 = VppIpInterfaceBind(self, epg.bvi, epg.rd.t4).add_vpp_config() b6 = VppIpInterfaceBind(self, epg.bvi, epg.rd.t6).add_vpp_config() epg.bvi.set_mac(self.router_mac) if_ip4 = VppIpInterfaceAddress( self, epg.bvi, epg.bvi_ip4, 32, bind=b4 ).add_vpp_config() if_ip6 = VppIpInterfaceAddress( self, epg.bvi, epg.bvi_ip6, 128, bind=b6 ).add_vpp_config() # add the BD ARP termination entry for BVI IP epg.bd_arp_ip4 = VppBridgeDomainArpEntry( self, epg.bd.bd, str(self.router_mac), epg.bvi_ip4 ) epg.bd_arp_ip4.add_vpp_config() # EPG in VPP epg.add_vpp_config() # # config ep # for ep in eps: ep.add_vpp_config() self.logger.info(self.vapi.cli("show gbp endpoint")) self.logger.info(self.vapi.cli("show interface")) self.logger.info(self.vapi.cli("show br")) # # Intra epg allowed without contract # pkt_intra_epg_220_to_220 = ( Ether(src=self.pg0.remote_mac, dst=self.pg1.remote_mac) / IP(src=eps[0].ip4, dst=eps[1].ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) self.send_and_expect_bridged(self.pg0, pkt_intra_epg_220_to_220 * 65, self.pg1) pkt_intra_epg_220_to_220 = ( Ether(src=self.pg0.remote_mac, dst=self.pg1.remote_mac) / IPv6(src=eps[0].ip6, dst=eps[1].ip6) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) self.send_and_expect_bridged6(self.pg0, pkt_intra_epg_220_to_220 * 65, self.pg1) # # Inter epg denied without contract # pkt_inter_epg_220_to_221 = ( Ether(src=self.pg0.remote_mac, dst=self.pg2.remote_mac) / IP(src=eps[0].ip4, dst=eps[2].ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) self.send_and_assert_no_replies(self.pg0, pkt_inter_epg_220_to_221) # # A uni-directional contract from EPG 220 -> 221 # rule = AclRule(is_permit=1, proto=17) rule2 = AclRule( src_prefix=IPv6Network((0, 0)), dst_prefix=IPv6Network((0, 0)), is_permit=1, proto=17, ) rule3 = AclRule(is_permit=1, proto=1) acl = VppAcl(self, rules=[rule, rule2, rule3]) acl.add_vpp_config() c1 = VppGbpContract( self, 400, epgs[0].sclass, epgs[1].sclass, acl.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), ], [ETH_P_IP, ETH_P_IPV6], ) c1.add_vpp_config() self.send_and_expect_bridged( eps[0].itf, pkt_inter_epg_220_to_221 * 65, eps[2].itf ) pkt_inter_epg_220_to_222 = ( Ether(src=self.pg0.remote_mac, dst=str(self.router_mac)) / IP(src=eps[0].ip4, dst=eps[3].ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) self.send_and_assert_no_replies(eps[0].itf, pkt_inter_epg_220_to_222 * 65) # # ping router IP in different BD # pkt_router_ping_220_to_221 = ( Ether(src=self.pg0.remote_mac, dst=str(self.router_mac)) / IP(src=eps[0].ip4, dst=epgs[1].bvi_ip4) / ICMP(type="echo-request") ) self.send_and_expect(self.pg0, [pkt_router_ping_220_to_221], self.pg0) pkt_router_ping_220_to_221 = ( Ether(src=self.pg0.remote_mac, dst=str(self.router_mac)) / IPv6(src=eps[0].ip6, dst=epgs[1].bvi_ip6) / ICMPv6EchoRequest() ) self.send_and_expect(self.pg0, [pkt_router_ping_220_to_221], self.pg0) # # contract for the return direction # c2 = VppGbpContract( self, 400, epgs[1].sclass, epgs[0].sclass, acl.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), ], [ETH_P_IP, ETH_P_IPV6], ) c2.add_vpp_config() self.send_and_expect_bridged( eps[0].itf, pkt_inter_epg_220_to_221 * 65, eps[2].itf ) pkt_inter_epg_221_to_220 = ( Ether(src=self.pg2.remote_mac, dst=self.pg0.remote_mac) / IP(src=eps[2].ip4, dst=eps[0].ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) self.send_and_expect_bridged( eps[2].itf, pkt_inter_epg_221_to_220 * 65, eps[0].itf ) pkt_inter_epg_221_to_220 = ( Ether(src=self.pg2.remote_mac, dst=str(self.router_mac)) / IP(src=eps[2].ip4, dst=eps[0].ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) self.send_and_expect_routed( eps[2].itf, pkt_inter_epg_221_to_220 * 65, eps[0].itf, str(self.router_mac) ) pkt_inter_epg_221_to_220 = ( Ether(src=self.pg2.remote_mac, dst=str(self.router_mac)) / IPv6(src=eps[2].ip6, dst=eps[0].ip6) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) self.send_and_expect_routed6( eps[2].itf, pkt_inter_epg_221_to_220 * 65, eps[0].itf, str(self.router_mac) ) # # contract between 220 and 222 uni-direction # c3 = VppGbpContract( self, 400, epgs[0].sclass, epgs[2].sclass, acl.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), ], [ETH_P_IP, ETH_P_IPV6], ) c3.add_vpp_config() self.send_and_expect(eps[0].itf, pkt_inter_epg_220_to_222 * 65, eps[3].itf) c3.remove_vpp_config() c1.remove_vpp_config() c2.remove_vpp_config() acl.remove_vpp_config() def test_gbp_bd_drop_flags(self): """GBP BD drop flags""" # # IP tables # gt4 = VppIpTable(self, 1) gt4.add_vpp_config() gt6 = VppIpTable(self, 1, is_ip6=True) gt6.add_vpp_config() rd1 = VppGbpRouteDomain(self, 1, 401, gt4, gt6) rd1.add_vpp_config() # # a GBP bridge domain with a BVI only # bd1 = VppBridgeDomain(self, 1) bd1.add_vpp_config() gbd1 = VppGbpBridgeDomain( self, bd1, rd1, self.loop0, None, None, uu_drop=True, bm_drop=True ) gbd1.add_vpp_config() self.logger.info(self.vapi.cli("sh bridge 1 detail")) self.logger.info(self.vapi.cli("sh gbp bridge")) # ... and has a /32 applied ip_addr = VppIpInterfaceAddress( self, gbd1.bvi, "10.0.0.128", 32 ).add_vpp_config() # # The Endpoint-group # epg_220 = VppGbpEndpointGroup( self, 220, 112, rd1, gbd1, None, self.loop0, "10.0.0.128", "2001:10::128", VppGbpEndpointRetention(3), ) epg_220.add_vpp_config() ep = VppGbpEndpoint( self, self.pg0, epg_220, None, "10.0.0.127", "11.0.0.127", "2001:10::1", "3001::1", ) ep.add_vpp_config() # # send UU/BM packet from the local EP with UU drop and BM drop enabled # in bd # self.logger.info(self.vapi.cli("sh bridge 1 detail")) self.logger.info(self.vapi.cli("sh gbp bridge")) p_uu = ( Ether(src=ep.mac, dst="00:11:11:11:11:11") / IP(dst="10.0.0.133", src=ep.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) self.send_and_assert_no_replies(ep.itf, [p_uu]) p_bm = ( Ether(src=ep.mac, dst="ff:ff:ff:ff:ff:ff") / IP(dst="10.0.0.133", src=ep.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) self.send_and_assert_no_replies(ep.itf, [p_bm]) self.pg3.unconfig_ip4() self.logger.info(self.vapi.cli("sh int")) def test_gbp_bd_arp_flags(self): """GBP BD arp flags""" # # IP tables # gt4 = VppIpTable(self, 1) gt4.add_vpp_config() gt6 = VppIpTable(self, 1, is_ip6=True) gt6.add_vpp_config() rd1 = VppGbpRouteDomain(self, 1, 401, gt4, gt6) rd1.add_vpp_config() # # Pg4 hosts the IP6 UU-flood VXLAN tunnel # self.pg4.config_ip4() self.pg4.resolve_arp() # # Add a mcast destination VXLAN-GBP tunnel for B&M traffic # tun_uu = VppVxlanGbpTunnel( self, self.pg4.local_ip4, "239.1.1.1", 88, mcast_itf=self.pg4 ) tun_uu.add_vpp_config() # # a GBP bridge domain with a BVI and a UU-flood interface # bd1 = VppBridgeDomain(self, 1) bd1.add_vpp_config() gbd1 = VppGbpBridgeDomain( self, bd1, rd1, self.loop0, tun_uu, None, ucast_arp=True ) gbd1.add_vpp_config() # ... and has a /32 applied ip_addr = VppIpInterfaceAddress( self, gbd1.bvi, "10.0.0.128", 32 ).add_vpp_config() # # The Endpoint-group # epg_220 = VppGbpEndpointGroup( self, 220, 112, rd1, gbd1, None, self.loop0, "10.0.0.128", "2001:10::128", VppGbpEndpointRetention(2), ) epg_220.add_vpp_config() ep = VppGbpEndpoint( self, self.pg0, epg_220, None, "10.0.0.127", "11.0.0.127", "2001:10::1", "3001::1", ) ep.add_vpp_config() # # send ARP packet from the local EP expect it on the uu interface # self.logger.info(self.vapi.cli("sh bridge 1 detail")) self.logger.info(self.vapi.cli("sh gbp bridge")) p_arp = Ether(src=ep.mac, dst="ff:ff:ff:ff:ff:ff") / ARP( op="who-has", psrc=ep.ip4, pdst="10.0.0.99", hwsrc=ep.mac, hwdst="ff:ff:ff:ff:ff:ff", ) self.send_and_expect(ep.itf, [p_arp], self.pg4) self.pg4.unconfig_ip4() def test_gbp_learn_vlan_l2(self): """GBP L2 Endpoint w/ VLANs""" ep_flags = VppEnum.vl_api_gbp_endpoint_flags_t learnt = [ {"mac": "00:00:11:11:11:01", "ip": "10.0.0.1", "ip6": "2001:10::2"}, {"mac": "00:00:11:11:11:02", "ip": "10.0.0.2", "ip6": "2001:10::3"}, ] # # IP tables # gt4 = VppIpTable(self, 1) gt4.add_vpp_config() gt6 = VppIpTable(self, 1, is_ip6=True) gt6.add_vpp_config() rd1 = VppGbpRouteDomain(self, 1, 401, gt4, gt6) rd1.add_vpp_config() # # Pg2 hosts the vxlan tunnel, hosts on pg2 to act as TEPs # self.pg2.config_ip4() self.pg2.resolve_arp() self.pg2.generate_remote_hosts(4) self.pg2.configure_ipv4_neighbors() self.pg3.config_ip4() self.pg3.resolve_arp() # # The EP will be on a vlan sub-interface # vlan_11 = VppDot1QSubint(self, self.pg0, 11) vlan_11.admin_up() self.vapi.l2_interface_vlan_tag_rewrite( sw_if_index=vlan_11.sw_if_index, vtr_op=L2_VTR_OP.L2_POP_1, push_dot1q=11 ) bd_uu_fwd = VppVxlanGbpTunnel( self, self.pg3.local_ip4, self.pg3.remote_ip4, 116 ) bd_uu_fwd.add_vpp_config() # # a GBP bridge domain with a BVI and a UU-flood interface # The BD is marked as do not learn, so no endpoints are ever # learnt in this BD. # bd1 = VppBridgeDomain(self, 1) bd1.add_vpp_config() gbd1 = VppGbpBridgeDomain(self, bd1, rd1, self.loop0, bd_uu_fwd, learn=False) gbd1.add_vpp_config() self.logger.info(self.vapi.cli("sh bridge 1 detail")) self.logger.info(self.vapi.cli("sh gbp bridge")) # ... and has a /32 applied ip_addr = VppIpInterfaceAddress( self, gbd1.bvi, "10.0.0.128", 32 ).add_vpp_config() # # The Endpoint-group in which we are learning endpoints # epg_220 = VppGbpEndpointGroup( self, 220, 441, rd1, gbd1, None, self.loop0, "10.0.0.128", "2001:10::128", VppGbpEndpointRetention(4), ) epg_220.add_vpp_config() # # The VXLAN GBP tunnel is a bridge-port and has L2 endpoint # learning enabled # vx_tun_l2_1 = VppGbpVxlanTunnel( self, 99, bd1.bd_id, VppEnum.vl_api_gbp_vxlan_tunnel_mode_t.GBP_VXLAN_TUNNEL_MODE_L2, self.pg2.local_ip4, ) vx_tun_l2_1.add_vpp_config() # # A static endpoint that the learnt endpoints are trying to # talk to # ep = VppGbpEndpoint( self, vlan_11, epg_220, None, "10.0.0.127", "11.0.0.127", "2001:10::1", "3001::1", ) ep.add_vpp_config() self.assertTrue(find_route(self, ep.ip4, 32, table_id=1)) # # Send to the static EP # for ii, l in enumerate(learnt): # a packet with an sclass from a known EPG # arriving on an unknown TEP p = ( Ether(src=self.pg2.remote_mac, dst=self.pg2.local_mac) / IP(src=self.pg2.remote_hosts[1].ip4, dst=self.pg2.local_ip4) / UDP(sport=1234, dport=48879) / VXLAN(vni=99, gpid=441, flags=0x88) / Ether(src=l["mac"], dst=ep.mac) / IP(src=l["ip"], dst=ep.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg2, [p], self.pg0) # # packet to EP has the EP's vlan tag # for rx in rxs: self.assertEqual(rx[Dot1Q].vlan, 11) # # the EP is not learnt since the BD setting prevents it # also no TEP too # self.assertFalse( find_gbp_endpoint(self, vx_tun_l2_1.sw_if_index, mac=l["mac"]) ) self.assertEqual( INDEX_INVALID, find_vxlan_gbp_tunnel( self, self.pg2.local_ip4, self.pg2.remote_hosts[1].ip4, 99 ), ) self.assertEqual(len(self.vapi.gbp_endpoint_dump()), 1) # # static to remotes # we didn't learn the remotes so they are sent to the UU-fwd # for l in learnt: p = ( Ether(src=ep.mac, dst=l["mac"]) / Dot1Q(vlan=11) / IP(dst=l["ip"], src=ep.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg0, p * 17, self.pg3) for rx in rxs: self.assertEqual(rx[IP].src, self.pg3.local_ip4) self.assertEqual(rx[IP].dst, self.pg3.remote_ip4) self.assertEqual(rx[UDP].dport, 48879) # the UDP source port is a random value for hashing self.assertEqual(rx[VXLAN].gpid, 441) self.assertEqual(rx[VXLAN].vni, 116) self.assertTrue(rx[VXLAN].flags.G) self.assertTrue(rx[VXLAN].flags.Instance) self.assertFalse(rx[VXLAN].gpflags.A) self.assertFalse(rx[VXLAN].gpflags.D) self.pg2.unconfig_ip4() self.pg3.unconfig_ip4() def test_gbp_learn_l3(self): """GBP L3 Endpoint Learning""" self.vapi.cli("set logging class gbp level debug") ep_flags = VppEnum.vl_api_gbp_endpoint_flags_t routed_dst_mac = "00:0c:0c:0c:0c:0c" routed_src_mac = "00:22:bd:f8:19:ff" learnt = [ {"mac": "00:00:11:11:11:02", "ip": "10.0.1.2", "ip6": "2001:10::2"}, {"mac": "00:00:11:11:11:03", "ip": "10.0.1.3", "ip6": "2001:10::3"}, ] # # IP tables # t4 = VppIpTable(self, 1) t4.add_vpp_config() t6 = VppIpTable(self, 1, True) t6.add_vpp_config() tun_ip4_uu = VppVxlanGbpTunnel( self, self.pg4.local_ip4, self.pg4.remote_ip4, 114 ) tun_ip6_uu = VppVxlanGbpTunnel( self, self.pg4.local_ip4, self.pg4.remote_ip4, 116 ) tun_ip4_uu.add_vpp_config() tun_ip6_uu.add_vpp_config() rd1 = VppGbpRouteDomain(self, 2, 401, t4, t6, tun_ip4_uu, tun_ip6_uu) rd1.add_vpp_config() self.loop0.set_mac(self.router_mac) # # Bind the BVI to the RD # b4 = VppIpInterfaceBind(self, self.loop0, t4).add_vpp_config() b6 = VppIpInterfaceBind(self, self.loop0, t6).add_vpp_config() # # Pg2 hosts the vxlan tunnel # hosts on pg2 to act as TEPs # pg3 is BD uu-fwd # pg4 is RD uu-fwd # self.pg2.config_ip4() self.pg2.resolve_arp() self.pg2.generate_remote_hosts(4) self.pg2.configure_ipv4_neighbors() self.pg3.config_ip4() self.pg3.resolve_arp() self.pg4.config_ip4() self.pg4.resolve_arp() # # a GBP bridge domain with a BVI and a UU-flood interface # bd1 = VppBridgeDomain(self, 1) bd1.add_vpp_config() gbd1 = VppGbpBridgeDomain(self, bd1, rd1, self.loop0, self.pg3) gbd1.add_vpp_config() self.logger.info(self.vapi.cli("sh bridge 1 detail")) self.logger.info(self.vapi.cli("sh gbp bridge")) self.logger.info(self.vapi.cli("sh gbp route")) # ... and has a /32 and /128 applied ip4_addr = VppIpInterfaceAddress( self, gbd1.bvi, "10.0.0.128", 32, bind=b4 ).add_vpp_config() ip6_addr = VppIpInterfaceAddress( self, gbd1.bvi, "2001:10::128", 128, bind=b6 ).add_vpp_config() # # The Endpoint-group in which we are learning endpoints # epg_220 = VppGbpEndpointGroup( self, 220, 441, rd1, gbd1, None, self.loop0, "10.0.0.128", "2001:10::128", VppGbpEndpointRetention(4), ) epg_220.add_vpp_config() # # The VXLAN GBP tunnel is in L3 mode with learning enabled # vx_tun_l3 = VppGbpVxlanTunnel( self, 101, rd1.rd_id, VppEnum.vl_api_gbp_vxlan_tunnel_mode_t.GBP_VXLAN_TUNNEL_MODE_L3, self.pg2.local_ip4, ) vx_tun_l3.add_vpp_config() # # A static endpoint that the learnt endpoints are trying to # talk to # ep = VppGbpEndpoint( self, self.pg0, epg_220, None, "10.0.0.127", "11.0.0.127", "2001:10::1", "3001::1", ) ep.add_vpp_config() # # learn some remote IPv4 EPs # for ii, l in enumerate(learnt): # a packet with an sclass from a known EPG # arriving on an unknown TEP p = ( Ether(src=self.pg2.remote_mac, dst=self.pg2.local_mac) / IP(src=self.pg2.remote_hosts[1].ip4, dst=self.pg2.local_ip4) / UDP(sport=1234, dport=48879) / VXLAN(vni=101, gpid=441, flags=0x88) / Ether(src=l["mac"], dst="00:00:00:11:11:11") / IP(src=l["ip"], dst=ep.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rx = self.send_and_expect(self.pg2, [p], self.pg0) # the new TEP tep1_sw_if_index = find_vxlan_gbp_tunnel( self, self.pg2.local_ip4, self.pg2.remote_hosts[1].ip4, vx_tun_l3.vni ) self.assertNotEqual(INDEX_INVALID, tep1_sw_if_index) # endpoint learnt via the parent GBP-vxlan interface self.assertTrue(find_gbp_endpoint(self, vx_tun_l3._sw_if_index, ip=l["ip"])) # # Static IPv4 EP replies to learnt # for l in learnt: p = ( Ether(src=ep.mac, dst=self.loop0.local_mac) / IP(dst=l["ip"], src=ep.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg0, p * 1, self.pg2) for rx in rxs: self.assertEqual(rx[IP].src, self.pg2.local_ip4) self.assertEqual(rx[IP].dst, self.pg2.remote_hosts[1].ip4) self.assertEqual(rx[UDP].dport, 48879) # the UDP source port is a random value for hashing self.assertEqual(rx[VXLAN].gpid, 441) self.assertEqual(rx[VXLAN].vni, 101) self.assertTrue(rx[VXLAN].flags.G) self.assertTrue(rx[VXLAN].flags.Instance) self.assertTrue(rx[VXLAN].gpflags.A) self.assertFalse(rx[VXLAN].gpflags.D) inner = rx[VXLAN].payload self.assertEqual(inner[Ether].src, routed_src_mac) self.assertEqual(inner[Ether].dst, routed_dst_mac) self.assertEqual(inner[IP].src, ep.ip4) self.assertEqual(inner[IP].dst, l["ip"]) for l in learnt: self.assertFalse(find_gbp_endpoint(self, tep1_sw_if_index, ip=l["ip"])) # # learn some remote IPv6 EPs # for ii, l in enumerate(learnt): # a packet with an sclass from a known EPG # arriving on an unknown TEP p = ( Ether(src=self.pg2.remote_mac, dst=self.pg2.local_mac) / IP(src=self.pg2.remote_hosts[1].ip4, dst=self.pg2.local_ip4) / UDP(sport=1234, dport=48879) / VXLAN(vni=101, gpid=441, flags=0x88) / Ether(src=l["mac"], dst="00:00:00:11:11:11") / IPv6(src=l["ip6"], dst=ep.ip6) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rx = self.send_and_expect(self.pg2, [p], self.pg0) # the new TEP tep1_sw_if_index = find_vxlan_gbp_tunnel( self, self.pg2.local_ip4, self.pg2.remote_hosts[1].ip4, vx_tun_l3.vni ) self.assertNotEqual(INDEX_INVALID, tep1_sw_if_index) self.logger.info(self.vapi.cli("show gbp bridge")) self.logger.info(self.vapi.cli("show vxlan-gbp tunnel")) self.logger.info(self.vapi.cli("show gbp vxlan")) self.logger.info(self.vapi.cli("show int addr")) # endpoint learnt via the TEP self.assertTrue(find_gbp_endpoint(self, ip=l["ip6"])) self.logger.info(self.vapi.cli("show gbp endpoint")) self.logger.info(self.vapi.cli("show ip fib index 1 %s" % l["ip"])) # # Static EP replies to learnt # for l in learnt: p = ( Ether(src=ep.mac, dst=self.loop0.local_mac) / IPv6(dst=l["ip6"], src=ep.ip6) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg0, p * NUM_PKTS, self.pg2) for rx in rxs: self.assertEqual(rx[IP].src, self.pg2.local_ip4) self.assertEqual(rx[IP].dst, self.pg2.remote_hosts[1].ip4) self.assertEqual(rx[UDP].dport, 48879) # the UDP source port is a random value for hashing self.assertEqual(rx[VXLAN].gpid, 441) self.assertEqual(rx[VXLAN].vni, 101) self.assertTrue(rx[VXLAN].flags.G) self.assertTrue(rx[VXLAN].flags.Instance) self.assertTrue(rx[VXLAN].gpflags.A) self.assertFalse(rx[VXLAN].gpflags.D) inner = rx[VXLAN].payload self.assertEqual(inner[Ether].src, routed_src_mac) self.assertEqual(inner[Ether].dst, routed_dst_mac) self.assertEqual(inner[IPv6].src, ep.ip6) self.assertEqual(inner[IPv6].dst, l["ip6"]) self.logger.info(self.vapi.cli("sh gbp endpoint")) for l in learnt: self.wait_for_ep_timeout(ip=l["ip"]) # # Static sends to unknown EP with no route # p = ( Ether(src=ep.mac, dst=self.loop0.local_mac) / IP(dst="10.0.0.99", src=ep.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) self.send_and_assert_no_replies(self.pg0, [p]) # # Add a route to static EP's v4 and v6 subnet # se_10_24 = VppGbpSubnet( self, rd1, "10.0.0.0", 24, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_TRANSPORT, ) se_10_24.add_vpp_config() # # static pings router # p = ( Ether(src=ep.mac, dst=self.loop0.local_mac) / IP(dst=epg_220.bvi_ip4, src=ep.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) self.send_and_expect(self.pg0, p * NUM_PKTS, self.pg0) p = ( Ether(src=ep.mac, dst=self.loop0.local_mac) / IPv6(dst=epg_220.bvi_ip6, src=ep.ip6) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) self.send_and_expect(self.pg0, p * NUM_PKTS, self.pg0) # # packets to address in the subnet are sent on the uu-fwd # p = ( Ether(src=ep.mac, dst=self.loop0.local_mac) / IP(dst="10.0.0.99", src=ep.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg0, [p], self.pg4) for rx in rxs: self.assertEqual(rx[IP].src, self.pg4.local_ip4) self.assertEqual(rx[IP].dst, self.pg4.remote_ip4) self.assertEqual(rx[UDP].dport, 48879) # the UDP source port is a random value for hashing self.assertEqual(rx[VXLAN].gpid, 441) self.assertEqual(rx[VXLAN].vni, 114) self.assertTrue(rx[VXLAN].flags.G) self.assertTrue(rx[VXLAN].flags.Instance) # policy is not applied to packets sent to the uu-fwd interfaces self.assertFalse(rx[VXLAN].gpflags.A) self.assertFalse(rx[VXLAN].gpflags.D) # # learn some remote IPv4 EPs # for ii, l in enumerate(learnt): # a packet with an sclass from a known EPG # arriving on an unknown TEP p = ( Ether(src=self.pg2.remote_mac, dst=self.pg2.local_mac) / IP(src=self.pg2.remote_hosts[2].ip4, dst=self.pg2.local_ip4) / UDP(sport=1234, dport=48879) / VXLAN(vni=101, gpid=441, flags=0x88) / Ether(src=l["mac"], dst="00:00:00:11:11:11") / IP(src=l["ip"], dst=ep.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rx = self.send_and_expect(self.pg2, [p], self.pg0) # the new TEP tep1_sw_if_index = find_vxlan_gbp_tunnel( self, self.pg2.local_ip4, self.pg2.remote_hosts[2].ip4, vx_tun_l3.vni ) self.assertNotEqual(INDEX_INVALID, tep1_sw_if_index) # endpoint learnt via the parent GBP-vxlan interface self.assertTrue(find_gbp_endpoint(self, vx_tun_l3._sw_if_index, ip=l["ip"])) # # Add a remote endpoint from the API # rep_88 = VppGbpEndpoint( self, vx_tun_l3, epg_220, None, "10.0.0.88", "11.0.0.88", "2001:10::88", "3001::88", ep_flags.GBP_API_ENDPOINT_FLAG_REMOTE, self.pg2.local_ip4, self.pg2.remote_hosts[2].ip4, mac=None, ) rep_88.add_vpp_config() # # Add a remote endpoint from the API that matches an existing one # this is a lower priority, hence the packet is sent to the DP leanrt # TEP # rep_2 = VppGbpEndpoint( self, vx_tun_l3, epg_220, None, learnt[0]["ip"], "11.0.0.101", learnt[0]["ip6"], "3001::101", ep_flags.GBP_API_ENDPOINT_FLAG_REMOTE, self.pg2.local_ip4, self.pg2.remote_hosts[1].ip4, mac=None, ) rep_2.add_vpp_config() # # Add a route to the learned EP's v4 subnet # packets should be send on the v4/v6 uu=fwd interface resp. # se_10_1_24 = VppGbpSubnet( self, rd1, "10.0.1.0", 24, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_TRANSPORT, ) se_10_1_24.add_vpp_config() self.logger.info(self.vapi.cli("show gbp endpoint")) ips = ["10.0.0.88", learnt[0]["ip"]] for ip in ips: p = ( Ether(src=ep.mac, dst=self.loop0.local_mac) / IP(dst=ip, src=ep.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg0, p * NUM_PKTS, self.pg2) for rx in rxs: self.assertEqual(rx[IP].src, self.pg2.local_ip4) self.assertEqual(rx[IP].dst, self.pg2.remote_hosts[2].ip4) self.assertEqual(rx[UDP].dport, 48879) # the UDP source port is a random value for hashing self.assertEqual(rx[VXLAN].gpid, 441) self.assertEqual(rx[VXLAN].vni, 101) self.assertTrue(rx[VXLAN].flags.G) self.assertTrue(rx[VXLAN].flags.Instance) self.assertTrue(rx[VXLAN].gpflags.A) self.assertFalse(rx[VXLAN].gpflags.D) inner = rx[VXLAN].payload self.assertEqual(inner[Ether].src, routed_src_mac) self.assertEqual(inner[Ether].dst, routed_dst_mac) self.assertEqual(inner[IP].src, ep.ip4) self.assertEqual(inner[IP].dst, ip) # # remove the API remote EPs, only API sourced is gone, the DP # learnt one remains # rep_88.remove_vpp_config() rep_2.remove_vpp_config() self.assertTrue(find_gbp_endpoint(self, ip=rep_2.ip4)) p = ( Ether(src=ep.mac, dst=self.loop0.local_mac) / IP(src=ep.ip4, dst=rep_2.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg0, [p], self.pg2) self.assertFalse(find_gbp_endpoint(self, ip=rep_88.ip4)) p = ( Ether(src=ep.mac, dst=self.loop0.local_mac) / IP(src=ep.ip4, dst=rep_88.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg0, [p], self.pg4) # # to appease the testcase we cannot have the registered EP still # present (because it's DP learnt) when the TC ends so wait until # it is removed # self.wait_for_ep_timeout(ip=rep_88.ip4) self.wait_for_ep_timeout(ip=rep_2.ip4) # # Same as above, learn a remote EP via CP and DP # this time remove the DP one first. expect the CP data to remain # rep_3 = VppGbpEndpoint( self, vx_tun_l3, epg_220, None, "10.0.1.4", "11.0.0.103", "2001::10:3", "3001::103", ep_flags.GBP_API_ENDPOINT_FLAG_REMOTE, self.pg2.local_ip4, self.pg2.remote_hosts[1].ip4, mac=None, ) rep_3.add_vpp_config() p = ( Ether(src=self.pg2.remote_mac, dst=self.pg2.local_mac) / IP(src=self.pg2.remote_hosts[2].ip4, dst=self.pg2.local_ip4) / UDP(sport=1234, dport=48879) / VXLAN(vni=101, gpid=441, flags=0x88) / Ether(src=l["mac"], dst="00:00:00:11:11:11") / IP(src="10.0.1.4", dst=ep.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg2, p * NUM_PKTS, self.pg0) self.assertTrue( find_gbp_endpoint( self, vx_tun_l3._sw_if_index, ip=rep_3.ip4, tep=[self.pg2.local_ip4, self.pg2.remote_hosts[2].ip4], ) ) p = ( Ether(src=ep.mac, dst=self.loop0.local_mac) / IP(dst="10.0.1.4", src=ep.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg0, p * NUM_PKTS, self.pg2) # host 2 is the DP learned TEP for rx in rxs: self.assertEqual(rx[IP].src, self.pg2.local_ip4) self.assertEqual(rx[IP].dst, self.pg2.remote_hosts[2].ip4) self.wait_for_ep_timeout( ip=rep_3.ip4, tep=[self.pg2.local_ip4, self.pg2.remote_hosts[2].ip4] ) rxs = self.send_and_expect(self.pg0, p * NUM_PKTS, self.pg2) # host 1 is the CP learned TEP for rx in rxs: self.assertEqual(rx[IP].src, self.pg2.local_ip4) self.assertEqual(rx[IP].dst, self.pg2.remote_hosts[1].ip4) # # shutdown with learnt endpoint present # p = ( Ether(src=self.pg2.remote_mac, dst=self.pg2.local_mac) / IP(src=self.pg2.remote_hosts[1].ip4, dst=self.pg2.local_ip4) / UDP(sport=1234, dport=48879) / VXLAN(vni=101, gpid=441, flags=0x88) / Ether(src=l["mac"], dst="00:00:00:11:11:11") / IP(src=learnt[1]["ip"], dst=ep.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rx = self.send_and_expect(self.pg2, [p], self.pg0) # endpoint learnt via the parent GBP-vxlan interface self.assertTrue(find_gbp_endpoint(self, vx_tun_l3._sw_if_index, ip=l["ip"])) # # TODO # remote endpoint becomes local # self.pg2.unconfig_ip4() self.pg3.unconfig_ip4() self.pg4.unconfig_ip4() def test_gbp_redirect(self): """GBP Endpoint Redirect""" self.vapi.cli("set logging class gbp level debug") ep_flags = VppEnum.vl_api_gbp_endpoint_flags_t routed_dst_mac = "00:0c:0c:0c:0c:0c" routed_src_mac = "00:22:bd:f8:19:ff" learnt = [ {"mac": "00:00:11:11:11:02", "ip": "10.0.1.2", "ip6": "2001:10::2"}, {"mac": "00:00:11:11:11:03", "ip": "10.0.1.3", "ip6": "2001:10::3"}, ] # # IP tables # t4 = VppIpTable(self, 1) t4.add_vpp_config() t6 = VppIpTable(self, 1, True) t6.add_vpp_config() rd1 = VppGbpRouteDomain(self, 2, 402, t4, t6) rd1.add_vpp_config() self.loop0.set_mac(self.router_mac) # # Bind the BVI to the RD # b_ip4 = VppIpInterfaceBind(self, self.loop0, t4).add_vpp_config() b_ip6 = VppIpInterfaceBind(self, self.loop0, t6).add_vpp_config() # # Pg7 hosts a BD's UU-fwd # self.pg7.config_ip4() self.pg7.resolve_arp() # # a GBP bridge domains for the EPs # bd1 = VppBridgeDomain(self, 1) bd1.add_vpp_config() gbd1 = VppGbpBridgeDomain(self, bd1, rd1, self.loop0) gbd1.add_vpp_config() bd2 = VppBridgeDomain(self, 2) bd2.add_vpp_config() gbd2 = VppGbpBridgeDomain(self, bd2, rd1, self.loop1) gbd2.add_vpp_config() # ... and has a /32 and /128 applied ip4_addr = VppIpInterfaceAddress( self, gbd1.bvi, "10.0.0.128", 32, bind=b_ip4 ).add_vpp_config() ip6_addr = VppIpInterfaceAddress( self, gbd1.bvi, "2001:10::128", 128, bind=b_ip6 ).add_vpp_config() ip4_addr = VppIpInterfaceAddress( self, gbd2.bvi, "10.0.1.128", 32 ).add_vpp_config() ip6_addr = VppIpInterfaceAddress( self, gbd2.bvi, "2001:11::128", 128 ).add_vpp_config() # # The Endpoint-groups in which we are learning endpoints # epg_220 = VppGbpEndpointGroup( self, 220, 440, rd1, gbd1, None, gbd1.bvi, "10.0.0.128", "2001:10::128", VppGbpEndpointRetention(60), ) epg_220.add_vpp_config() epg_221 = VppGbpEndpointGroup( self, 221, 441, rd1, gbd2, None, gbd2.bvi, "10.0.1.128", "2001:11::128", VppGbpEndpointRetention(60), ) epg_221.add_vpp_config() epg_222 = VppGbpEndpointGroup( self, 222, 442, rd1, gbd1, None, gbd1.bvi, "10.0.2.128", "2001:12::128", VppGbpEndpointRetention(60), ) epg_222.add_vpp_config() # # a GBP bridge domains for the SEPs # bd_uu1 = VppVxlanGbpTunnel(self, self.pg7.local_ip4, self.pg7.remote_ip4, 116) bd_uu1.add_vpp_config() bd_uu2 = VppVxlanGbpTunnel(self, self.pg7.local_ip4, self.pg7.remote_ip4, 117) bd_uu2.add_vpp_config() bd3 = VppBridgeDomain(self, 3) bd3.add_vpp_config() gbd3 = VppGbpBridgeDomain(self, bd3, rd1, self.loop2, bd_uu1, learn=False) gbd3.add_vpp_config() bd4 = VppBridgeDomain(self, 4) bd4.add_vpp_config() gbd4 = VppGbpBridgeDomain(self, bd4, rd1, self.loop3, bd_uu2, learn=False) gbd4.add_vpp_config() # # EPGs in which the service endpoints exist # epg_320 = VppGbpEndpointGroup( self, 320, 550, rd1, gbd3, None, gbd1.bvi, "12.0.0.128", "4001:10::128", VppGbpEndpointRetention(60), ) epg_320.add_vpp_config() epg_321 = VppGbpEndpointGroup( self, 321, 551, rd1, gbd4, None, gbd2.bvi, "12.0.1.128", "4001:11::128", VppGbpEndpointRetention(60), ) epg_321.add_vpp_config() # # three local endpoints # ep1 = VppGbpEndpoint( self, self.pg0, epg_220, None, "10.0.0.1", "11.0.0.1", "2001:10::1", "3001:10::1", ) ep1.add_vpp_config() ep2 = VppGbpEndpoint( self, self.pg1, epg_221, None, "10.0.1.1", "11.0.1.1", "2001:11::1", "3001:11::1", ) ep2.add_vpp_config() ep3 = VppGbpEndpoint( self, self.pg2, epg_222, None, "10.0.2.2", "11.0.2.2", "2001:12::1", "3001:12::1", ) ep3.add_vpp_config() # # service endpoints # sep1 = VppGbpEndpoint( self, self.pg3, epg_320, None, "12.0.0.1", "13.0.0.1", "4001:10::1", "5001:10::1", ) sep1.add_vpp_config() sep2 = VppGbpEndpoint( self, self.pg4, epg_320, None, "12.0.0.2", "13.0.0.2", "4001:10::2", "5001:10::2", ) sep2.add_vpp_config() sep3 = VppGbpEndpoint( self, self.pg5, epg_321, None, "12.0.1.1", "13.0.1.1", "4001:11::1", "5001:11::1", ) sep3.add_vpp_config() # this EP is not installed immediately sep4 = VppGbpEndpoint( self, self.pg6, epg_321, None, "12.0.1.2", "13.0.1.2", "4001:11::2", "5001:11::2", ) # # an L2 switch packet between local EPs in different EPGs # different dest ports on each so the are LB hashed differently # p4 = [ ( Ether(src=ep1.mac, dst=ep3.mac) / IP(src=ep1.ip4, dst=ep3.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ), ( Ether(src=ep3.mac, dst=ep1.mac) / IP(src=ep3.ip4, dst=ep1.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ), ] p6 = [ ( Ether(src=ep1.mac, dst=ep3.mac) / IPv6(src=ep1.ip6, dst=ep3.ip6) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ), ( Ether(src=ep3.mac, dst=ep1.mac) / IPv6(src=ep3.ip6, dst=ep1.ip6) / UDP(sport=1234, dport=1230) / Raw(b"\xa5" * 100) ), ] # should be dropped since no contract yet self.send_and_assert_no_replies(self.pg0, [p4[0]]) self.send_and_assert_no_replies(self.pg0, [p6[0]]) # # Add a contract with a rule to load-balance redirect via SEP1 and SEP2 # one of the next-hops is via an EP that is not known # rule4 = AclRule(is_permit=1, proto=17) rule6 = AclRule( src_prefix=IPv6Network((0, 0)), dst_prefix=IPv6Network((0, 0)), is_permit=1, proto=17, ) acl = VppAcl(self, rules=[rule4, rule6]) acl.add_vpp_config() # # test the src-ip hash mode # c1 = VppGbpContract( self, 402, epg_220.sclass, epg_222.sclass, acl.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_REDIRECT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [ VppGbpContractNextHop( sep1.vmac, sep1.epg.bd, sep1.ip4, sep1.epg.rd ), VppGbpContractNextHop( sep2.vmac, sep2.epg.bd, sep2.ip4, sep2.epg.rd ), ], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_REDIRECT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [ VppGbpContractNextHop( sep3.vmac, sep3.epg.bd, sep3.ip6, sep3.epg.rd ), VppGbpContractNextHop( sep4.vmac, sep4.epg.bd, sep4.ip6, sep4.epg.rd ), ], ), ], [ETH_P_IP, ETH_P_IPV6], ) c1.add_vpp_config() c2 = VppGbpContract( self, 402, epg_222.sclass, epg_220.sclass, acl.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_REDIRECT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [ VppGbpContractNextHop( sep1.vmac, sep1.epg.bd, sep1.ip4, sep1.epg.rd ), VppGbpContractNextHop( sep2.vmac, sep2.epg.bd, sep2.ip4, sep2.epg.rd ), ], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_REDIRECT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [ VppGbpContractNextHop( sep3.vmac, sep3.epg.bd, sep3.ip6, sep3.epg.rd ), VppGbpContractNextHop( sep4.vmac, sep4.epg.bd, sep4.ip6, sep4.epg.rd ), ], ), ], [ETH_P_IP, ETH_P_IPV6], ) c2.add_vpp_config() # # send again with the contract preset, now packets arrive # at SEP1 or SEP2 depending on the hashing # rxs = self.send_and_expect(self.pg0, p4[0] * 17, sep1.itf) for rx in rxs: self.assertEqual(rx[Ether].src, routed_src_mac) self.assertEqual(rx[Ether].dst, sep1.mac) self.assertEqual(rx[IP].src, ep1.ip4) self.assertEqual(rx[IP].dst, ep3.ip4) rxs = self.send_and_expect(self.pg2, p4[1] * 17, sep2.itf) for rx in rxs: self.assertEqual(rx[Ether].src, routed_src_mac) self.assertEqual(rx[Ether].dst, sep2.mac) self.assertEqual(rx[IP].src, ep3.ip4) self.assertEqual(rx[IP].dst, ep1.ip4) rxs = self.send_and_expect(self.pg0, p6[0] * 17, self.pg7) for rx in rxs: self.assertEqual(rx[Ether].src, self.pg7.local_mac) self.assertEqual(rx[Ether].dst, self.pg7.remote_mac) self.assertEqual(rx[IP].src, self.pg7.local_ip4) self.assertEqual(rx[IP].dst, self.pg7.remote_ip4) self.assertEqual(rx[VXLAN].vni, 117) self.assertTrue(rx[VXLAN].flags.G) self.assertTrue(rx[VXLAN].flags.Instance) # redirect policy has been applied self.assertTrue(rx[VXLAN].gpflags.A) self.assertFalse(rx[VXLAN].gpflags.D) inner = rx[VXLAN].payload self.assertEqual(inner[Ether].src, routed_src_mac) self.assertEqual(inner[Ether].dst, sep4.mac) self.assertEqual(inner[IPv6].src, ep1.ip6) self.assertEqual(inner[IPv6].dst, ep3.ip6) rxs = self.send_and_expect(self.pg2, p6[1] * 17, sep3.itf) for rx in rxs: self.assertEqual(rx[Ether].src, routed_src_mac) self.assertEqual(rx[Ether].dst, sep3.mac) self.assertEqual(rx[IPv6].src, ep3.ip6) self.assertEqual(rx[IPv6].dst, ep1.ip6) # # programme the unknown EP # sep4.add_vpp_config() rxs = self.send_and_expect(self.pg0, p6[0] * 17, sep4.itf) for rx in rxs: self.assertEqual(rx[Ether].src, routed_src_mac) self.assertEqual(rx[Ether].dst, sep4.mac) self.assertEqual(rx[IPv6].src, ep1.ip6) self.assertEqual(rx[IPv6].dst, ep3.ip6) # # and revert back to unprogrammed # sep4.remove_vpp_config() rxs = self.send_and_expect(self.pg0, p6[0] * 17, self.pg7) for rx in rxs: self.assertEqual(rx[Ether].src, self.pg7.local_mac) self.assertEqual(rx[Ether].dst, self.pg7.remote_mac) self.assertEqual(rx[IP].src, self.pg7.local_ip4) self.assertEqual(rx[IP].dst, self.pg7.remote_ip4) self.assertEqual(rx[VXLAN].vni, 117) self.assertTrue(rx[VXLAN].flags.G) self.assertTrue(rx[VXLAN].flags.Instance) # redirect policy has been applied self.assertTrue(rx[VXLAN].gpflags.A) self.assertFalse(rx[VXLAN].gpflags.D) inner = rx[VXLAN].payload self.assertEqual(inner[Ether].src, routed_src_mac) self.assertEqual(inner[Ether].dst, sep4.mac) self.assertEqual(inner[IPv6].src, ep1.ip6) self.assertEqual(inner[IPv6].dst, ep3.ip6) c1.remove_vpp_config() c2.remove_vpp_config() # # test the symmetric hash mode # c1 = VppGbpContract( self, 402, epg_220.sclass, epg_222.sclass, acl.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_REDIRECT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SYMMETRIC, [ VppGbpContractNextHop( sep1.vmac, sep1.epg.bd, sep1.ip4, sep1.epg.rd ), VppGbpContractNextHop( sep2.vmac, sep2.epg.bd, sep2.ip4, sep2.epg.rd ), ], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_REDIRECT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SYMMETRIC, [ VppGbpContractNextHop( sep3.vmac, sep3.epg.bd, sep3.ip6, sep3.epg.rd ), VppGbpContractNextHop( sep4.vmac, sep4.epg.bd, sep4.ip6, sep4.epg.rd ), ], ), ], [ETH_P_IP, ETH_P_IPV6], ) c1.add_vpp_config() c2 = VppGbpContract( self, 402, epg_222.sclass, epg_220.sclass, acl.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_REDIRECT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SYMMETRIC, [ VppGbpContractNextHop( sep1.vmac, sep1.epg.bd, sep1.ip4, sep1.epg.rd ), VppGbpContractNextHop( sep2.vmac, sep2.epg.bd, sep2.ip4, sep2.epg.rd ), ], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_REDIRECT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SYMMETRIC, [ VppGbpContractNextHop( sep3.vmac, sep3.epg.bd, sep3.ip6, sep3.epg.rd ), VppGbpContractNextHop( sep4.vmac, sep4.epg.bd, sep4.ip6, sep4.epg.rd ), ], ), ], [ETH_P_IP, ETH_P_IPV6], ) c2.add_vpp_config() # # send again with the contract preset, now packets arrive # at SEP1 for both directions # rxs = self.send_and_expect(self.pg0, p4[0] * 17, sep1.itf) for rx in rxs: self.assertEqual(rx[Ether].src, routed_src_mac) self.assertEqual(rx[Ether].dst, sep1.mac) self.assertEqual(rx[IP].src, ep1.ip4) self.assertEqual(rx[IP].dst, ep3.ip4) rxs = self.send_and_expect(self.pg2, p4[1] * 17, sep1.itf) for rx in rxs: self.assertEqual(rx[Ether].src, routed_src_mac) self.assertEqual(rx[Ether].dst, sep1.mac) self.assertEqual(rx[IP].src, ep3.ip4) self.assertEqual(rx[IP].dst, ep1.ip4) # # programme the unknown EP for the L3 tests # sep4.add_vpp_config() # # an L3 switch packet between local EPs in different EPGs # different dest ports on each so the are LB hashed differently # p4 = [ ( Ether(src=ep1.mac, dst=str(self.router_mac)) / IP(src=ep1.ip4, dst=ep2.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ), ( Ether(src=ep2.mac, dst=str(self.router_mac)) / IP(src=ep2.ip4, dst=ep1.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ), ] p6 = [ ( Ether(src=ep1.mac, dst=str(self.router_mac)) / IPv6(src=ep1.ip6, dst=ep2.ip6) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ), ( Ether(src=ep2.mac, dst=str(self.router_mac)) / IPv6(src=ep2.ip6, dst=ep1.ip6) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ), ] c3 = VppGbpContract( self, 402, epg_220.sclass, epg_221.sclass, acl.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_REDIRECT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SYMMETRIC, [ VppGbpContractNextHop( sep1.vmac, sep1.epg.bd, sep1.ip4, sep1.epg.rd ), VppGbpContractNextHop( sep2.vmac, sep2.epg.bd, sep2.ip4, sep2.epg.rd ), ], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_REDIRECT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SYMMETRIC, [ VppGbpContractNextHop( sep3.vmac, sep3.epg.bd, sep3.ip6, sep3.epg.rd ), VppGbpContractNextHop( sep4.vmac, sep4.epg.bd, sep4.ip6, sep4.epg.rd ), ], ), ], [ETH_P_IP, ETH_P_IPV6], ) c3.add_vpp_config() rxs = self.send_and_expect(self.pg0, p4[0] * 17, sep1.itf) for rx in rxs: self.assertEqual(rx[Ether].src, routed_src_mac) self.assertEqual(rx[Ether].dst, sep1.mac) self.assertEqual(rx[IP].src, ep1.ip4) self.assertEqual(rx[IP].dst, ep2.ip4) # # learn a remote EP in EPG 221 # packets coming from unknown remote EPs will be leant & redirected # vx_tun_l3 = VppGbpVxlanTunnel( self, 444, rd1.rd_id, VppEnum.vl_api_gbp_vxlan_tunnel_mode_t.GBP_VXLAN_TUNNEL_MODE_L3, self.pg2.local_ip4, ) vx_tun_l3.add_vpp_config() c4 = VppGbpContract( self, 402, epg_221.sclass, epg_220.sclass, acl.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_REDIRECT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [ VppGbpContractNextHop( sep1.vmac, sep1.epg.bd, sep1.ip4, sep1.epg.rd ), VppGbpContractNextHop( sep2.vmac, sep2.epg.bd, sep2.ip4, sep2.epg.rd ), ], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_REDIRECT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [ VppGbpContractNextHop( sep3.vmac, sep3.epg.bd, sep3.ip6, sep3.epg.rd ), VppGbpContractNextHop( sep4.vmac, sep4.epg.bd, sep4.ip6, sep4.epg.rd ), ], ), ], [ETH_P_IP, ETH_P_IPV6], ) c4.add_vpp_config() p = ( Ether(src=self.pg7.remote_mac, dst=self.pg7.local_mac) / IP(src=self.pg7.remote_ip4, dst=self.pg7.local_ip4) / UDP(sport=1234, dport=48879) / VXLAN(vni=444, gpid=441, flags=0x88) / Ether(src="00:22:22:22:22:33", dst=str(self.router_mac)) / IP(src="10.0.0.88", dst=ep1.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) # unknown remote EP to local EP redirected rxs = self.send_and_expect(self.pg7, [p], sep1.itf) for rx in rxs: self.assertEqual(rx[Ether].src, routed_src_mac) self.assertEqual(rx[Ether].dst, sep1.mac) self.assertEqual(rx[IP].src, "10.0.0.88") self.assertEqual(rx[IP].dst, ep1.ip4) # endpoint learnt via the parent GBP-vxlan interface self.assertTrue(find_gbp_endpoint(self, vx_tun_l3._sw_if_index, ip="10.0.0.88")) p = ( Ether(src=self.pg7.remote_mac, dst=self.pg7.local_mac) / IP(src=self.pg7.remote_ip4, dst=self.pg7.local_ip4) / UDP(sport=1234, dport=48879) / VXLAN(vni=444, gpid=441, flags=0x88) / Ether(src="00:22:22:22:22:33", dst=str(self.router_mac)) / IPv6(src="2001:10::88", dst=ep1.ip6) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) # unknown remote EP to local EP redirected (ipv6) rxs = self.send_and_expect(self.pg7, [p], sep3.itf) for rx in rxs: self.assertEqual(rx[Ether].src, routed_src_mac) self.assertEqual(rx[Ether].dst, sep3.mac) self.assertEqual(rx[IPv6].src, "2001:10::88") self.assertEqual(rx[IPv6].dst, ep1.ip6) # endpoint learnt via the parent GBP-vxlan interface self.assertTrue( find_gbp_endpoint(self, vx_tun_l3._sw_if_index, ip="2001:10::88") ) # # L3 switch from local to remote EP # p4 = [ ( Ether(src=ep1.mac, dst=str(self.router_mac)) / IP(src=ep1.ip4, dst="10.0.0.88") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) ] p6 = [ ( Ether(src=ep1.mac, dst=str(self.router_mac)) / IPv6(src=ep1.ip6, dst="2001:10::88") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) ] rxs = self.send_and_expect(self.pg0, p4[0] * 17, sep1.itf) for rx in rxs: self.assertEqual(rx[Ether].src, routed_src_mac) self.assertEqual(rx[Ether].dst, sep1.mac) self.assertEqual(rx[IP].src, ep1.ip4) self.assertEqual(rx[IP].dst, "10.0.0.88") rxs = self.send_and_expect(self.pg0, p6[0] * 17, sep4.itf) for rx in rxs: self.assertEqual(rx[Ether].src, routed_src_mac) self.assertEqual(rx[Ether].dst, sep4.mac) self.assertEqual(rx[IPv6].src, ep1.ip6) self.assertEqual(rx[IPv6].dst, "2001:10::88") # # test the dst-ip hash mode # c5 = VppGbpContract( self, 402, epg_220.sclass, epg_221.sclass, acl.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_REDIRECT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_DST_IP, [ VppGbpContractNextHop( sep1.vmac, sep1.epg.bd, sep1.ip4, sep1.epg.rd ), VppGbpContractNextHop( sep2.vmac, sep2.epg.bd, sep2.ip4, sep2.epg.rd ), ], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_REDIRECT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_DST_IP, [ VppGbpContractNextHop( sep3.vmac, sep3.epg.bd, sep3.ip6, sep3.epg.rd ), VppGbpContractNextHop( sep4.vmac, sep4.epg.bd, sep4.ip6, sep4.epg.rd ), ], ), ], [ETH_P_IP, ETH_P_IPV6], ) c5.add_vpp_config() rxs = self.send_and_expect(self.pg0, p4[0] * 17, sep1.itf) for rx in rxs: self.assertEqual(rx[Ether].src, routed_src_mac) self.assertEqual(rx[Ether].dst, sep1.mac) self.assertEqual(rx[IP].src, ep1.ip4) self.assertEqual(rx[IP].dst, "10.0.0.88") rxs = self.send_and_expect(self.pg0, p6[0] * 17, sep3.itf) for rx in rxs: self.assertEqual(rx[Ether].src, routed_src_mac) self.assertEqual(rx[Ether].dst, sep3.mac) self.assertEqual(rx[IPv6].src, ep1.ip6) self.assertEqual(rx[IPv6].dst, "2001:10::88") # # a programmed remote SEP in EPG 320 # # gbp vxlan tunnel for the remote SEP vx_tun_l3_sep = VppGbpVxlanTunnel( self, 555, rd1.rd_id, VppEnum.vl_api_gbp_vxlan_tunnel_mode_t.GBP_VXLAN_TUNNEL_MODE_L3, self.pg2.local_ip4, ) vx_tun_l3_sep.add_vpp_config() # remote SEP sep5 = VppGbpEndpoint( self, vx_tun_l3_sep, epg_320, None, "12.0.0.10", "13.0.0.10", "4001:10::10", "5001:10::10", ep_flags.GBP_API_ENDPOINT_FLAG_REMOTE, self.pg7.local_ip4, self.pg7.remote_ip4, mac=None, ) sep5.add_vpp_config() # # local l3out redirect tests # # add local l3out # the external bd self.loop4.set_mac(self.router_mac) b_lo4_ip4 = VppIpInterfaceBind(self, self.loop4, t4).add_vpp_config() b_lo4_ip6 = VppIpInterfaceBind(self, self.loop4, t6).add_vpp_config() ebd = VppBridgeDomain(self, 100) ebd.add_vpp_config() gebd = VppGbpBridgeDomain(self, ebd, rd1, self.loop4, None, None) gebd.add_vpp_config() # the external epg eepg = VppGbpEndpointGroup( self, 888, 765, rd1, gebd, None, gebd.bvi, "10.1.0.128", "2001:10:1::128", VppGbpEndpointRetention(60), ) eepg.add_vpp_config() # add subnets to BVI VppIpInterfaceAddress( self, gebd.bvi, "10.1.0.128", 24, bind=b_lo4_ip4 ).add_vpp_config() VppIpInterfaceAddress( self, gebd.bvi, "2001:10:1::128", 64, bind=b_lo4_ip6 ).add_vpp_config() # ... which are L3-out subnets VppGbpSubnet( self, rd1, "10.1.0.0", 24, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_L3_OUT, sclass=765, ).add_vpp_config() VppGbpSubnet( self, rd1, "2001:10:1::128", 64, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_L3_OUT, sclass=765, ).add_vpp_config() # external endpoints VppL2Vtr(self, self.vlan_100, L2_VTR_OP.L2_POP_1).add_vpp_config() eep1 = VppGbpEndpoint( self, self.vlan_100, eepg, None, "10.1.0.1", "11.1.0.1", "2001:10:1::1", "3001:10:1::1", ep_flags.GBP_API_ENDPOINT_FLAG_EXTERNAL, ) eep1.add_vpp_config() VppL2Vtr(self, self.vlan_101, L2_VTR_OP.L2_POP_1).add_vpp_config() eep2 = VppGbpEndpoint( self, self.vlan_101, eepg, None, "10.1.0.2", "11.1.0.2", "2001:10:1::2", "3001:10:1::2", ep_flags.GBP_API_ENDPOINT_FLAG_EXTERNAL, ) eep2.add_vpp_config() # external subnets reachable though eep1 and eep2 respectively VppIpRoute( self, "10.220.0.0", 24, [VppRoutePath(eep1.ip4, eep1.epg.bvi.sw_if_index)], table_id=t4.table_id, ).add_vpp_config() VppGbpSubnet( self, rd1, "10.220.0.0", 24, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_L3_OUT, sclass=4220, ).add_vpp_config() VppIpRoute( self, "10:220::", 64, [VppRoutePath(eep1.ip6, eep1.epg.bvi.sw_if_index)], table_id=t6.table_id, ).add_vpp_config() VppGbpSubnet( self, rd1, "10:220::", 64, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_L3_OUT, sclass=4220, ).add_vpp_config() VppIpRoute( self, "10.221.0.0", 24, [VppRoutePath(eep2.ip4, eep2.epg.bvi.sw_if_index)], table_id=t4.table_id, ).add_vpp_config() VppGbpSubnet( self, rd1, "10.221.0.0", 24, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_L3_OUT, sclass=4221, ).add_vpp_config() VppIpRoute( self, "10:221::", 64, [VppRoutePath(eep2.ip6, eep2.epg.bvi.sw_if_index)], table_id=t6.table_id, ).add_vpp_config() VppGbpSubnet( self, rd1, "10:221::", 64, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_L3_OUT, sclass=4221, ).add_vpp_config() # # l3out redirect to remote (known, then unknown) SEP # # packets from 1 external subnet to the other p = [ ( Ether(src=eep1.mac, dst=self.router_mac) / Dot1Q(vlan=100) / IP(src="10.220.0.17", dst="10.221.0.65") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ), ( Ether(src=eep1.mac, dst=self.router_mac) / Dot1Q(vlan=100) / IPv6(src="10:220::17", dst="10:221::65") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ), ] # packets should be dropped in absence of contract self.send_and_assert_no_replies(self.pg0, p) # contract redirecting to sep5 VppGbpContract( self, 402, 4220, 4221, acl.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_REDIRECT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_DST_IP, [ VppGbpContractNextHop( sep5.vmac, sep5.epg.bd, sep5.ip4, sep5.epg.rd ) ], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_REDIRECT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_DST_IP, [ VppGbpContractNextHop( sep5.vmac, sep5.epg.bd, sep5.ip6, sep5.epg.rd ) ], ), ], [ETH_P_IP, ETH_P_IPV6], ).add_vpp_config() rxs = self.send_and_expect(self.pg0, p, self.pg7) for rx, tx in zip(rxs, p): self.assertEqual(rx[Ether].src, self.pg7.local_mac) self.assertEqual(rx[Ether].dst, self.pg7.remote_mac) self.assertEqual(rx[IP].src, self.pg7.local_ip4) self.assertEqual(rx[IP].dst, self.pg7.remote_ip4) # this should use the programmed remote leaf TEP self.assertEqual(rx[VXLAN].vni, 555) self.assertEqual(rx[VXLAN].gpid, 4220) self.assertTrue(rx[VXLAN].flags.G) self.assertTrue(rx[VXLAN].flags.Instance) # redirect policy has been applied self.assertTrue(rx[VXLAN].gpflags.A) self.assertTrue(rx[VXLAN].gpflags.D) rxip = rx[VXLAN][Ether].payload txip = tx[Dot1Q].payload self.assertEqual(rxip.src, txip.src) self.assertEqual(rxip.dst, txip.dst) # remote SEP: it is now an unknown remote SEP and should go # to spine proxy sep5.remove_vpp_config() rxs = self.send_and_expect(self.pg0, p, self.pg7) for rx, tx in zip(rxs, p): self.assertEqual(rx[Ether].src, self.pg7.local_mac) self.assertEqual(rx[Ether].dst, self.pg7.remote_mac) self.assertEqual(rx[IP].src, self.pg7.local_ip4) self.assertEqual(rx[IP].dst, self.pg7.remote_ip4) # this should use the spine proxy TEP self.assertEqual(rx[VXLAN].vni, epg_320.bd.uu_fwd.vni) self.assertEqual(rx[VXLAN].gpid, 4220) self.assertTrue(rx[VXLAN].flags.G) self.assertTrue(rx[VXLAN].flags.Instance) # redirect policy has been applied self.assertTrue(rx[VXLAN].gpflags.A) self.assertTrue(rx[VXLAN].gpflags.D) rxip = rx[VXLAN][Ether].payload txip = tx[Dot1Q].payload self.assertEqual(rxip.src, txip.src) self.assertEqual(rxip.dst, txip.dst) # # l3out redirect to local SEP # # change the contract between l3out to redirect to local SEPs # instead of remote SEP VppGbpContract( self, 402, 4220, 4221, acl.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_REDIRECT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_DST_IP, [ VppGbpContractNextHop( sep1.vmac, sep1.epg.bd, sep1.ip4, sep1.epg.rd ) ], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_REDIRECT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_DST_IP, [ VppGbpContractNextHop( sep1.vmac, sep1.epg.bd, sep1.ip6, sep1.epg.rd ) ], ), ], [ETH_P_IP, ETH_P_IPV6], ).add_vpp_config() rxs = self.send_and_expect(self.pg0, p, sep1.itf) for rx, tx in zip(rxs, p): self.assertEqual(rx[Ether].src, routed_src_mac) self.assertEqual(rx[Ether].dst, sep1.mac) rxip = rx[Ether].payload txip = tx[Ether].payload self.assertEqual(rxip.src, txip.src) self.assertEqual(rxip.dst, txip.dst) # # redirect remote EP to remote (known then unknown) SEP # # remote SEP known again sep5.add_vpp_config() # contract to redirect to learnt SEP VppGbpContract( self, 402, epg_221.sclass, epg_222.sclass, acl.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_REDIRECT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_DST_IP, [ VppGbpContractNextHop( sep5.vmac, sep5.epg.bd, sep5.ip4, sep5.epg.rd ) ], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_REDIRECT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_DST_IP, [ VppGbpContractNextHop( sep5.vmac, sep5.epg.bd, sep5.ip6, sep5.epg.rd ) ], ), ], [ETH_P_IP, ETH_P_IPV6], ).add_vpp_config() # packets from unknown EP 221 to known EP in EPG 222 # should be redirected to known remote SEP base = ( Ether(src=self.pg7.remote_mac, dst=self.pg7.local_mac) / IP(src=self.pg7.remote_ip4, dst=self.pg7.local_ip4) / UDP(sport=1234, dport=48879) / VXLAN(vni=444, gpid=441, flags=0x88) / Ether(src="00:22:22:22:22:44", dst=str(self.router_mac)) ) p = [ ( base / IP(src="10.0.1.100", dst=ep3.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ), ( base / IPv6(src="2001:10::100", dst=ep3.ip6) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ), ] # unknown remote EP to local EP redirected to known remote SEP rxs = self.send_and_expect(self.pg7, p, self.pg7) for rx, tx in zip(rxs, p): self.assertEqual(rx[Ether].src, self.pg7.local_mac) self.assertEqual(rx[Ether].dst, self.pg7.remote_mac) self.assertEqual(rx[IP].src, self.pg7.local_ip4) self.assertEqual(rx[IP].dst, self.pg7.remote_ip4) # this should use the programmed remote leaf TEP self.assertEqual(rx[VXLAN].vni, 555) self.assertEqual(rx[VXLAN].gpid, epg_221.sclass) self.assertTrue(rx[VXLAN].flags.G) self.assertTrue(rx[VXLAN].flags.Instance) # redirect policy has been applied self.assertTrue(rx[VXLAN].gpflags.A) self.assertFalse(rx[VXLAN].gpflags.D) rxip = rx[VXLAN][Ether].payload txip = tx[VXLAN][Ether].payload self.assertEqual(rxip.src, txip.src) self.assertEqual(rxip.dst, txip.dst) # endpoint learnt via the parent GBP-vxlan interface self.assertTrue( find_gbp_endpoint(self, vx_tun_l3._sw_if_index, ip="10.0.1.100") ) self.assertTrue( find_gbp_endpoint(self, vx_tun_l3._sw_if_index, ip="2001:10::100") ) # remote SEP: it is now an unknown remote SEP and should go # to spine proxy sep5.remove_vpp_config() # remote EP (coming from spine proxy) to local EP redirected to # known remote SEP rxs = self.send_and_expect(self.pg7, p, self.pg7) for rx, tx in zip(rxs, p): self.assertEqual(rx[Ether].src, self.pg7.local_mac) self.assertEqual(rx[Ether].dst, self.pg7.remote_mac) self.assertEqual(rx[IP].src, self.pg7.local_ip4) self.assertEqual(rx[IP].dst, self.pg7.remote_ip4) # this should use the spine proxy TEP self.assertEqual(rx[VXLAN].vni, epg_320.bd.uu_fwd.vni) self.assertEqual(rx[VXLAN].gpid, epg_221.sclass) self.assertTrue(rx[VXLAN].flags.G) self.assertTrue(rx[VXLAN].flags.Instance) # redirect policy has been applied self.assertTrue(rx[VXLAN].gpflags.A) self.assertFalse(rx[VXLAN].gpflags.D) rxip = rx[VXLAN][Ether].payload txip = tx[VXLAN][Ether].payload self.assertEqual(rxip.src, txip.src) self.assertEqual(rxip.dst, txip.dst) # # cleanup # self.pg7.unconfig_ip4() def test_gbp_redirect_extended(self): """GBP Endpoint Redirect Extended""" self.vapi.cli("set logging class gbp level debug") ep_flags = VppEnum.vl_api_gbp_endpoint_flags_t routed_dst_mac = "00:0c:0c:0c:0c:0c" routed_src_mac = "00:22:bd:f8:19:ff" learnt = [ {"mac": "00:00:11:11:11:02", "ip": "10.0.1.2", "ip6": "2001:10::2"}, {"mac": "00:00:11:11:11:03", "ip": "10.0.1.3", "ip6": "2001:10::3"}, ] # # IP tables # t4 = VppIpTable(self, 1) t4.add_vpp_config() t6 = VppIpTable(self, 1, True) t6.add_vpp_config() # create IPv4 and IPv6 RD UU VxLAN-GBP TEP and bind them to the right # VRF rd_uu4 = VppVxlanGbpTunnel( self, self.pg7.local_ip4, self.pg7.remote_ip4, 114, mode=( VppEnum.vl_api_vxlan_gbp_api_tunnel_mode_t.VXLAN_GBP_API_TUNNEL_MODE_L3 ), ) rd_uu4.add_vpp_config() VppIpInterfaceBind(self, rd_uu4, t4).add_vpp_config() rd_uu6 = VppVxlanGbpTunnel( self, self.pg7.local_ip4, self.pg7.remote_ip4, 115, mode=( VppEnum.vl_api_vxlan_gbp_api_tunnel_mode_t.VXLAN_GBP_API_TUNNEL_MODE_L3 ), ) rd_uu6.add_vpp_config() VppIpInterfaceBind(self, rd_uu6, t4).add_vpp_config() rd1 = VppGbpRouteDomain(self, 2, 402, t4, t6, rd_uu4, rd_uu6) rd1.add_vpp_config() self.loop0.set_mac(self.router_mac) self.loop1.set_mac(self.router_mac) self.loop2.set_mac(self.router_mac) # # Bind the BVI to the RD # b_lo0_ip4 = VppIpInterfaceBind(self, self.loop0, t4).add_vpp_config() b_lo0_ip6 = VppIpInterfaceBind(self, self.loop0, t6).add_vpp_config() b_lo1_ip4 = VppIpInterfaceBind(self, self.loop1, t4).add_vpp_config() b_lo1_ip6 = VppIpInterfaceBind(self, self.loop1, t6).add_vpp_config() b_lo2_ip4 = VppIpInterfaceBind(self, self.loop2, t4).add_vpp_config() b_lo2_ip6 = VppIpInterfaceBind(self, self.loop2, t6).add_vpp_config() # # Pg7 hosts a BD's UU-fwd # self.pg7.config_ip4() self.pg7.resolve_arp() # # a GBP bridge domains for the EPs # bd1 = VppBridgeDomain(self, 1) bd1.add_vpp_config() gbd1 = VppGbpBridgeDomain(self, bd1, rd1, self.loop0) gbd1.add_vpp_config() bd2 = VppBridgeDomain(self, 2) bd2.add_vpp_config() gbd2 = VppGbpBridgeDomain(self, bd2, rd1, self.loop1) gbd2.add_vpp_config() # ... and has a /32 and /128 applied ip4_addr1 = VppIpInterfaceAddress( self, gbd1.bvi, "10.0.0.128", 32, bind=b_lo0_ip4 ).add_vpp_config() ip6_addr1 = VppIpInterfaceAddress( self, gbd1.bvi, "2001:10::128", 128, bind=b_lo0_ip6 ).add_vpp_config() ip4_addr2 = VppIpInterfaceAddress( self, gbd2.bvi, "10.0.1.128", 32, bind=b_lo1_ip4 ).add_vpp_config() ip6_addr2 = VppIpInterfaceAddress( self, gbd2.bvi, "2001:11::128", 128, bind=b_lo1_ip6 ).add_vpp_config() # # The Endpoint-groups # epg_220 = VppGbpEndpointGroup( self, 220, 440, rd1, gbd1, None, gbd1.bvi, "10.0.0.128", "2001:10::128", VppGbpEndpointRetention(60), ) epg_220.add_vpp_config() epg_221 = VppGbpEndpointGroup( self, 221, 441, rd1, gbd2, None, gbd2.bvi, "10.0.1.128", "2001:11::128", VppGbpEndpointRetention(60), ) epg_221.add_vpp_config() # # a GBP bridge domains for the SEPs # bd_uu3 = VppVxlanGbpTunnel(self, self.pg7.local_ip4, self.pg7.remote_ip4, 116) bd_uu3.add_vpp_config() bd3 = VppBridgeDomain(self, 3) bd3.add_vpp_config() gbd3 = VppGbpBridgeDomain(self, bd3, rd1, self.loop2, bd_uu3, learn=False) gbd3.add_vpp_config() ip4_addr3 = VppIpInterfaceAddress( self, gbd3.bvi, "12.0.0.128", 32, bind=b_lo2_ip4 ).add_vpp_config() ip6_addr3 = VppIpInterfaceAddress( self, gbd3.bvi, "4001:10::128", 128, bind=b_lo2_ip6 ).add_vpp_config() # # self.logger.info(self.vapi.cli("show gbp bridge")) # self.logger.info(self.vapi.cli("show vxlan-gbp tunnel")) # self.logger.info(self.vapi.cli("show gbp vxlan")) # self.logger.info(self.vapi.cli("show int addr")) # # # EPGs in which the service endpoints exist # epg_320 = VppGbpEndpointGroup( self, 320, 550, rd1, gbd3, None, gbd3.bvi, "12.0.0.128", "4001:10::128", VppGbpEndpointRetention(60), ) epg_320.add_vpp_config() # # endpoints # ep1 = VppGbpEndpoint( self, self.pg0, epg_220, None, "10.0.0.1", "11.0.0.1", "2001:10::1", "3001:10::1", ) ep1.add_vpp_config() ep2 = VppGbpEndpoint( self, self.pg1, epg_221, None, "10.0.1.1", "11.0.1.1", "2001:11::1", "3001:11::1", ) ep2.add_vpp_config() # # service endpoints # sep1 = VppGbpEndpoint( self, self.pg3, epg_320, None, "12.0.0.1", "13.0.0.1", "4001:10::1", "5001:10::1", ) sep2 = VppGbpEndpoint( self, self.pg4, epg_320, None, "12.0.0.2", "13.0.0.2", "4001:10::2", "5001:10::2", ) # sep1 and sep2 are not added to config yet # they are unknown for now # # add routes to EPG subnets # VppGbpSubnet( self, rd1, "10.0.0.0", 24, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_TRANSPORT, ).add_vpp_config() VppGbpSubnet( self, rd1, "10.0.1.0", 24, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_TRANSPORT, ).add_vpp_config() # # Local host to known local host in different BD # with SFC contract (source and destination are in # one node and service endpoint in another node) # p4 = [ ( Ether(src=ep1.mac, dst=str(self.router_mac)) / IP(src=ep1.ip4, dst=ep2.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ), ( Ether(src=ep2.mac, dst=str(self.router_mac)) / IP(src=ep2.ip4, dst=ep1.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ), ] p6 = [ ( Ether(src=ep1.mac, dst=str(self.router_mac)) / IPv6(src=ep1.ip6, dst=ep2.ip6) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ), ( Ether(src=ep2.mac, dst=str(self.router_mac)) / IPv6(src=ep2.ip6, dst=ep1.ip6) / UDP(sport=1234, dport=1230) / Raw(b"\xa5" * 100) ), ] # should be dropped since no contract yet self.send_and_assert_no_replies(self.pg0, [p4[0]]) self.send_and_assert_no_replies(self.pg0, [p6[0]]) # # Add a contract with a rule to load-balance redirect via SEP1 and SEP2 # one of the next-hops is via an EP that is not known # rule4 = AclRule(is_permit=1, proto=17) rule6 = AclRule( src_prefix=IPv6Network((0, 0)), dst_prefix=IPv6Network((0, 0)), is_permit=1, proto=17, ) acl = VppAcl(self, rules=[rule4, rule6]) acl.add_vpp_config() # # test the src-ip hash mode # c1 = VppGbpContract( self, 402, epg_220.sclass, epg_221.sclass, acl.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_REDIRECT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SYMMETRIC, [ VppGbpContractNextHop( sep1.vmac, sep1.epg.bd, sep1.ip4, sep1.epg.rd ) ], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_REDIRECT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SYMMETRIC, [ VppGbpContractNextHop( sep1.vmac, sep1.epg.bd, sep1.ip6, sep1.epg.rd ) ], ), ], [ETH_P_IP, ETH_P_IPV6], ) c1.add_vpp_config() c2 = VppGbpContract( self, 402, epg_221.sclass, epg_220.sclass, acl.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_REDIRECT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SYMMETRIC, [ VppGbpContractNextHop( sep1.vmac, sep1.epg.bd, sep1.ip4, sep1.epg.rd ) ], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_REDIRECT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SYMMETRIC, [ VppGbpContractNextHop( sep1.vmac, sep1.epg.bd, sep1.ip6, sep1.epg.rd ) ], ), ], [ETH_P_IP, ETH_P_IPV6], ) c2.add_vpp_config() # ep1 <--> ep2 redirected through sep1 # sep1 is unknown # packet is redirected to sep bd and then go through sep bd UU rxs = self.send_and_expect(self.pg0, p4[0] * 17, self.pg7) for rx in rxs: self.assertEqual(rx[Ether].src, self.pg7.local_mac) self.assertEqual(rx[Ether].dst, self.pg7.remote_mac) self.assertEqual(rx[IP].src, self.pg7.local_ip4) self.assertEqual(rx[IP].dst, self.pg7.remote_ip4) self.assertEqual(rx[VXLAN].vni, 116) self.assertTrue(rx[VXLAN].flags.G) self.assertTrue(rx[VXLAN].flags.Instance) # redirect policy has been applied self.assertTrue(rx[VXLAN].gpflags.A) self.assertFalse(rx[VXLAN].gpflags.D) inner = rx[VXLAN].payload self.assertEqual(inner[Ether].src, routed_src_mac) self.assertEqual(inner[Ether].dst, sep1.mac) self.assertEqual(inner[IP].src, ep1.ip4) self.assertEqual(inner[IP].dst, ep2.ip4) rxs = self.send_and_expect(self.pg1, p4[1] * 17, self.pg7) for rx in rxs: self.assertEqual(rx[Ether].src, self.pg7.local_mac) self.assertEqual(rx[Ether].dst, self.pg7.remote_mac) self.assertEqual(rx[IP].src, self.pg7.local_ip4) self.assertEqual(rx[IP].dst, self.pg7.remote_ip4) self.assertEqual(rx[VXLAN].vni, 116) self.assertTrue(rx[VXLAN].flags.G) self.assertTrue(rx[VXLAN].flags.Instance) # redirect policy has been applied self.assertTrue(rx[VXLAN].gpflags.A) self.assertFalse(rx[VXLAN].gpflags.D) inner = rx[VXLAN].payload self.assertEqual(inner[Ether].src, routed_src_mac) self.assertEqual(inner[Ether].dst, sep1.mac) self.assertEqual(inner[IP].src, ep2.ip4) self.assertEqual(inner[IP].dst, ep1.ip4) rxs = self.send_and_expect(self.pg0, p6[0] * 17, self.pg7) for rx in rxs: self.assertEqual(rx[Ether].src, self.pg7.local_mac) self.assertEqual(rx[Ether].dst, self.pg7.remote_mac) self.assertEqual(rx[IP].src, self.pg7.local_ip4) self.assertEqual(rx[IP].dst, self.pg7.remote_ip4) self.assertEqual(rx[VXLAN].vni, 116) self.assertTrue(rx[VXLAN].flags.G) self.assertTrue(rx[VXLAN].flags.Instance) # redirect policy has been applied inner = rx[VXLAN].payload self.assertEqual(inner[Ether].src, routed_src_mac) self.assertEqual(inner[Ether].dst, sep1.mac) self.assertEqual(inner[IPv6].src, ep1.ip6) self.assertEqual(inner[IPv6].dst, ep2.ip6) rxs = self.send_and_expect(self.pg1, p6[1] * 17, self.pg7) for rx in rxs: self.assertEqual(rx[Ether].src, self.pg7.local_mac) self.assertEqual(rx[Ether].dst, self.pg7.remote_mac) self.assertEqual(rx[IP].src, self.pg7.local_ip4) self.assertEqual(rx[IP].dst, self.pg7.remote_ip4) self.assertEqual(rx[VXLAN].vni, 116) self.assertTrue(rx[VXLAN].flags.G) self.assertTrue(rx[VXLAN].flags.Instance) # redirect policy has been applied self.assertTrue(rx[VXLAN].gpflags.A) self.assertFalse(rx[VXLAN].gpflags.D) inner = rx[VXLAN].payload self.assertEqual(inner[Ether].src, routed_src_mac) self.assertEqual(inner[Ether].dst, sep1.mac) self.assertEqual(inner[IPv6].src, ep2.ip6) self.assertEqual(inner[IPv6].dst, ep1.ip6) # configure sep1: it is now local # packets between ep1 and ep2 are redirected locally sep1.add_vpp_config() rxs = self.send_and_expect(self.pg0, p4[0] * 17, sep1.itf) for rx in rxs: self.assertEqual(rx[Ether].src, routed_src_mac) self.assertEqual(rx[Ether].dst, sep1.mac) self.assertEqual(rx[IP].src, ep1.ip4) self.assertEqual(rx[IP].dst, ep2.ip4) rxs = self.send_and_expect(self.pg1, p6[1] * 17, sep1.itf) for rx in rxs: self.assertEqual(rx[Ether].src, routed_src_mac) self.assertEqual(rx[Ether].dst, sep1.mac) self.assertEqual(rx[IPv6].src, ep2.ip6) self.assertEqual(rx[IPv6].dst, ep1.ip6) # packet coming from the l2 spine-proxy to sep1 p = ( Ether(src=self.pg7.remote_mac, dst=self.pg7.local_mac) / IP(src=self.pg7.remote_ip4, dst=self.pg7.local_ip4) / UDP(sport=1234, dport=48879) / VXLAN(vni=116, gpid=440, gpflags=0x08, flags=0x88) / Ether(src=str(self.router_mac), dst=sep1.mac) / IP(src=ep1.ip4, dst=ep2.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg7, [p] * 17, sep1.itf) for rx in rxs: self.assertEqual(rx[Ether].src, str(self.router_mac)) self.assertEqual(rx[Ether].dst, sep1.mac) self.assertEqual(rx[IP].src, ep1.ip4) self.assertEqual(rx[IP].dst, ep2.ip4) # contract for SEP to communicate with dst EP c3 = VppGbpContract( self, 402, epg_320.sclass, epg_221.sclass, acl.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SYMMETRIC, ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SYMMETRIC, ), ], [ETH_P_IP, ETH_P_IPV6], ) c3.add_vpp_config() # temporarily remove ep2, so that ep2 is remote & unknown ep2.remove_vpp_config() # packet going back from sep1 to its original dest (ep2) # as ep2 is now unknown (see above), it must go through # the rd UU (packet is routed) p1 = ( Ether(src=sep1.mac, dst=self.router_mac) / IP(src=ep1.ip4, dst=ep2.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg3, [p1] * 17, self.pg7) for rx in rxs: self.assertEqual(rx[Ether].src, self.pg7.local_mac) self.assertEqual(rx[Ether].dst, self.pg7.remote_mac) self.assertEqual(rx[IP].src, self.pg7.local_ip4) self.assertEqual(rx[IP].dst, self.pg7.remote_ip4) self.assertEqual(rx[VXLAN].vni, 114) self.assertTrue(rx[VXLAN].flags.G) self.assertTrue(rx[VXLAN].flags.Instance) # redirect policy has been applied inner = rx[VXLAN].payload self.assertEqual(inner[Ether].src, routed_src_mac) self.assertEqual(inner[Ether].dst, routed_dst_mac) self.assertEqual(inner[IP].src, ep1.ip4) self.assertEqual(inner[IP].dst, ep2.ip4) self.logger.info(self.vapi.cli("show bridge 3 detail")) sep1.remove_vpp_config() self.logger.info(self.vapi.cli("show bridge 1 detail")) self.logger.info(self.vapi.cli("show bridge 2 detail")) # re-add ep2: it is local again :) ep2.add_vpp_config() # packet coming back from the remote sep through rd UU p2 = ( Ether(src=self.pg7.remote_mac, dst=self.pg7.local_mac) / IP(src=self.pg7.remote_ip4, dst=self.pg7.local_ip4) / UDP(sport=1234, dport=48879) / VXLAN(vni=114, gpid=441, gpflags=0x09, flags=0x88) / Ether(src=str(self.router_mac), dst=self.router_mac) / IP(src=ep1.ip4, dst=ep2.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg7, [p2], self.pg1) for rx in rxs: self.assertEqual(rx[Ether].src, str(self.router_mac)) self.assertEqual(rx[Ether].dst, self.pg1.remote_mac) self.assertEqual(rx[IP].src, ep1.ip4) self.assertEqual(rx[IP].dst, ep2.ip4) # # bd_uu2.add_vpp_config() # # # cleanup # c1.remove_vpp_config() c2.remove_vpp_config() c3.remove_vpp_config() self.pg7.unconfig_ip4() def test_gbp_l3_out(self): """GBP L3 Out""" ep_flags = VppEnum.vl_api_gbp_endpoint_flags_t self.vapi.cli("set logging class gbp level debug") routed_dst_mac = "00:0c:0c:0c:0c:0c" routed_src_mac = "00:22:bd:f8:19:ff" # # IP tables # t4 = VppIpTable(self, 1) t4.add_vpp_config() t6 = VppIpTable(self, 1, True) t6.add_vpp_config() rd1 = VppGbpRouteDomain(self, 2, 55, t4, t6) rd1.add_vpp_config() self.loop0.set_mac(self.router_mac) # # Bind the BVI to the RD # b_ip4 = VppIpInterfaceBind(self, self.loop0, t4).add_vpp_config() b_ip6 = VppIpInterfaceBind(self, self.loop0, t6).add_vpp_config() # # Pg7 hosts a BD's BUM # Pg1 some other l3 interface # self.pg7.config_ip4() self.pg7.resolve_arp() # # a multicast vxlan-gbp tunnel for broadcast in the BD # tun_bm = VppVxlanGbpTunnel( self, self.pg7.local_ip4, "239.1.1.1", 88, mcast_itf=self.pg7 ) tun_bm.add_vpp_config() # # a GBP external bridge domains for the EPs # bd1 = VppBridgeDomain(self, 1) bd1.add_vpp_config() gbd1 = VppGbpBridgeDomain(self, bd1, rd1, self.loop0, None, tun_bm) gbd1.add_vpp_config() # # The Endpoint-groups in which the external endpoints exist # epg_220 = VppGbpEndpointGroup( self, 220, 113, rd1, gbd1, None, gbd1.bvi, "10.0.0.128", "2001:10::128", VppGbpEndpointRetention(4), ) epg_220.add_vpp_config() # the BVIs have the subnets applied ... ip4_addr = VppIpInterfaceAddress( self, gbd1.bvi, "10.0.0.128", 24, bind=b_ip4 ).add_vpp_config() ip6_addr = VppIpInterfaceAddress( self, gbd1.bvi, "2001:10::128", 64, bind=b_ip6 ).add_vpp_config() # ... which are L3-out subnets l3o_1 = VppGbpSubnet( self, rd1, "10.0.0.0", 24, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_L3_OUT, sclass=113, ) l3o_1.add_vpp_config() # # an external interface attached to the outside world and the # external BD # VppL2Vtr(self, self.vlan_100, L2_VTR_OP.L2_POP_1).add_vpp_config() VppL2Vtr(self, self.vlan_101, L2_VTR_OP.L2_POP_1).add_vpp_config() vlan_144 = VppDot1QSubint(self, self.pg0, 144) vlan_144.admin_up() # vlan_102 is not poped # # an unicast vxlan-gbp for inter-RD traffic # vx_tun_l3 = VppGbpVxlanTunnel( self, 444, rd1.rd_id, VppEnum.vl_api_gbp_vxlan_tunnel_mode_t.GBP_VXLAN_TUNNEL_MODE_L3, self.pg2.local_ip4, ) vx_tun_l3.add_vpp_config() # # External Endpoints # eep1 = VppGbpEndpoint( self, self.vlan_100, epg_220, None, "10.0.0.1", "11.0.0.1", "2001:10::1", "3001::1", ep_flags.GBP_API_ENDPOINT_FLAG_EXTERNAL, ) eep1.add_vpp_config() eep2 = VppGbpEndpoint( self, self.vlan_101, epg_220, None, "10.0.0.2", "11.0.0.2", "2001:10::2", "3001::2", ep_flags.GBP_API_ENDPOINT_FLAG_EXTERNAL, ) eep2.add_vpp_config() eep3 = VppGbpEndpoint( self, self.vlan_102, epg_220, None, "10.0.0.3", "11.0.0.3", "2001:10::3", "3001::3", ep_flags.GBP_API_ENDPOINT_FLAG_EXTERNAL, ) eep3.add_vpp_config() # # A remote external endpoint # rep = VppGbpEndpoint( self, vx_tun_l3, epg_220, None, "10.0.0.101", "11.0.0.101", "2001:10::101", "3001::101", ep_flags.GBP_API_ENDPOINT_FLAG_REMOTE, self.pg7.local_ip4, self.pg7.remote_ip4, mac=None, ) rep.add_vpp_config() # # EP1 impersonating EP3 is dropped # p = ( Ether(src=eep1.mac, dst="ff:ff:ff:ff:ff:ff") / Dot1Q(vlan=100) / ARP( op="who-has", psrc="10.0.0.3", pdst="10.0.0.128", hwsrc=eep1.mac, hwdst="ff:ff:ff:ff:ff:ff", ) ) self.send_and_assert_no_replies(self.pg0, p) # # ARP packet from External EPs are accepted and replied to # p_arp = ( Ether(src=eep1.mac, dst="ff:ff:ff:ff:ff:ff") / Dot1Q(vlan=100) / ARP( op="who-has", psrc=eep1.ip4, pdst="10.0.0.128", hwsrc=eep1.mac, hwdst="ff:ff:ff:ff:ff:ff", ) ) rxs = self.send_and_expect(self.pg0, p_arp * 1, self.pg0) # # ARP packet from host in remote subnet are accepted and replied to # p_arp = ( Ether(src=eep3.mac, dst="ff:ff:ff:ff:ff:ff") / Dot1Q(vlan=102) / ARP( op="who-has", psrc=eep3.ip4, pdst="10.0.0.128", hwsrc=eep3.mac, hwdst="ff:ff:ff:ff:ff:ff", ) ) rxs = self.send_and_expect(self.pg0, p_arp * 1, self.pg0) # # packets destined to unknown addresses in the BVI's subnet # are ARP'd for # p4 = ( Ether(src=eep1.mac, dst=str(self.router_mac)) / Dot1Q(vlan=100) / IP(src="10.0.0.1", dst="10.0.0.88") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) p6 = ( Ether(src=eep1.mac, dst=str(self.router_mac)) / Dot1Q(vlan=100) / IPv6(src="2001:10::1", dst="2001:10::88") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg0, p4 * 1, self.pg7) for rx in rxs: self.assertEqual(rx[Ether].src, self.pg7.local_mac) # self.assertEqual(rx[Ether].dst, self.pg7.remote_mac) self.assertEqual(rx[IP].src, self.pg7.local_ip4) self.assertEqual(rx[IP].dst, "239.1.1.1") self.assertEqual(rx[VXLAN].vni, 88) self.assertTrue(rx[VXLAN].flags.G) self.assertTrue(rx[VXLAN].flags.Instance) # policy was applied to the original IP packet self.assertEqual(rx[VXLAN].gpid, 113) self.assertTrue(rx[VXLAN].gpflags.A) self.assertFalse(rx[VXLAN].gpflags.D) inner = rx[VXLAN].payload self.assertTrue(inner.haslayer(ARP)) # # remote to external # p = ( Ether(src=self.pg7.remote_mac, dst=self.pg7.local_mac) / IP(src=self.pg7.remote_ip4, dst=self.pg7.local_ip4) / UDP(sport=1234, dport=48879) / VXLAN(vni=444, gpid=113, flags=0x88) / Ether(src=self.pg0.remote_mac, dst=str(self.router_mac)) / IP(src="10.0.0.101", dst="10.0.0.1") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg7, p * 1, self.pg0) # # local EP pings router # p = ( Ether(src=eep1.mac, dst=str(self.router_mac)) / Dot1Q(vlan=100) / IP(src=eep1.ip4, dst="10.0.0.128") / ICMP(type="echo-request") ) rxs = self.send_and_expect(self.pg0, p * 1, self.pg0) for rx in rxs: self.assertEqual(rx[Ether].src, str(self.router_mac)) self.assertEqual(rx[Ether].dst, eep1.mac) self.assertEqual(rx[Dot1Q].vlan, 100) # # local EP pings other local EP # p = ( Ether(src=eep1.mac, dst=eep2.mac) / Dot1Q(vlan=100) / IP(src=eep1.ip4, dst=eep2.ip4) / ICMP(type="echo-request") ) rxs = self.send_and_expect(self.pg0, p * 1, self.pg0) for rx in rxs: self.assertEqual(rx[Ether].src, eep1.mac) self.assertEqual(rx[Ether].dst, eep2.mac) self.assertEqual(rx[Dot1Q].vlan, 101) # # local EP pings router w/o vlan tag poped # p = ( Ether(src=eep3.mac, dst=str(self.router_mac)) / Dot1Q(vlan=102) / IP(src=eep3.ip4, dst="10.0.0.128") / ICMP(type="echo-request") ) rxs = self.send_and_expect(self.pg0, p * 1, self.pg0) for rx in rxs: self.assertEqual(rx[Ether].src, str(self.router_mac)) self.assertEqual(rx[Ether].dst, self.vlan_102.remote_mac) # # A ip4 subnet reachable through the external EP1 # ip_220 = VppIpRoute( self, "10.220.0.0", 24, [VppRoutePath(eep1.ip4, eep1.epg.bvi.sw_if_index)], table_id=t4.table_id, ) ip_220.add_vpp_config() l3o_220 = VppGbpSubnet( self, rd1, "10.220.0.0", 24, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_L3_OUT, sclass=4220, ) l3o_220.add_vpp_config() # # An ip6 subnet reachable through the external EP1 # ip6_220 = VppIpRoute( self, "10:220::", 64, [VppRoutePath(eep1.ip6, eep1.epg.bvi.sw_if_index)], table_id=t6.table_id, ) ip6_220.add_vpp_config() l3o6_220 = VppGbpSubnet( self, rd1, "10:220::", 64, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_L3_OUT, sclass=4220, ) l3o6_220.add_vpp_config() # # A subnet reachable through the external EP2 # ip_221 = VppIpRoute( self, "10.221.0.0", 24, [VppRoutePath(eep2.ip4, eep2.epg.bvi.sw_if_index)], table_id=t4.table_id, ) ip_221.add_vpp_config() l3o_221 = VppGbpSubnet( self, rd1, "10.221.0.0", 24, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_L3_OUT, sclass=4221, ) l3o_221.add_vpp_config() # # ping between hosts in remote subnets # dropped without a contract # p = ( Ether(src=eep1.mac, dst=str(self.router_mac)) / Dot1Q(vlan=100) / IP(src="10.220.0.1", dst="10.221.0.1") / ICMP(type="echo-request") ) self.send_and_assert_no_replies(self.pg0, p * 1) # # contract for the external nets to communicate # rule4 = AclRule(is_permit=1, proto=17) rule6 = AclRule( src_prefix=IPv6Network((0, 0)), dst_prefix=IPv6Network((0, 0)), is_permit=1, proto=17, ) acl = VppAcl(self, rules=[rule4, rule6]) acl.add_vpp_config() # # A contract with the wrong scope is not matched # c_44 = VppGbpContract( self, 44, 4220, 4221, acl.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), ], [ETH_P_IP, ETH_P_IPV6], ) c_44.add_vpp_config() self.send_and_assert_no_replies(self.pg0, p * 1) c1 = VppGbpContract( self, 55, 4220, 4221, acl.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), ], [ETH_P_IP, ETH_P_IPV6], ) c1.add_vpp_config() # # Contracts allowing ext-net 200 to talk with external EPs # c2 = VppGbpContract( self, 55, 4220, 113, acl.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), ], [ETH_P_IP, ETH_P_IPV6], ) c2.add_vpp_config() c3 = VppGbpContract( self, 55, 113, 4220, acl.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), ], [ETH_P_IP, ETH_P_IPV6], ) c3.add_vpp_config() # # ping between hosts in remote subnets # p = ( Ether(src=eep1.mac, dst=str(self.router_mac)) / Dot1Q(vlan=100) / IP(src="10.220.0.1", dst="10.221.0.1") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg0, p * 1, self.pg0) for rx in rxs: self.assertEqual(rx[Ether].src, str(self.router_mac)) self.assertEqual(rx[Ether].dst, eep2.mac) self.assertEqual(rx[Dot1Q].vlan, 101) # we did not learn these external hosts self.assertFalse(find_gbp_endpoint(self, ip="10.220.0.1")) self.assertFalse(find_gbp_endpoint(self, ip="10.221.0.1")) # # from remote external EP to local external EP # p = ( Ether(src=self.pg7.remote_mac, dst=self.pg7.local_mac) / IP(src=self.pg7.remote_ip4, dst=self.pg7.local_ip4) / UDP(sport=1234, dport=48879) / VXLAN(vni=444, gpid=113, flags=0x88) / Ether(src=self.pg0.remote_mac, dst=str(self.router_mac)) / IP(src="10.0.0.101", dst="10.220.0.1") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg7, p * 1, self.pg0) # # ping from an external host to the remote external EP # p = ( Ether(src=eep1.mac, dst=str(self.router_mac)) / Dot1Q(vlan=100) / IP(src="10.220.0.1", dst=rep.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg0, p * 1, self.pg7) for rx in rxs: self.assertEqual(rx[Ether].src, self.pg7.local_mac) # self.assertEqual(rx[Ether].dst, self.pg7.remote_mac) self.assertEqual(rx[IP].src, self.pg7.local_ip4) self.assertEqual(rx[IP].dst, self.pg7.remote_ip4) self.assertEqual(rx[VXLAN].vni, 444) self.assertTrue(rx[VXLAN].flags.G) self.assertTrue(rx[VXLAN].flags.Instance) # the sclass of the ext-net the packet came from self.assertEqual(rx[VXLAN].gpid, 4220) # policy was applied to the original IP packet self.assertTrue(rx[VXLAN].gpflags.A) # since it's an external host the reciever should not learn it self.assertTrue(rx[VXLAN].gpflags.D) inner = rx[VXLAN].payload self.assertEqual(inner[IP].src, "10.220.0.1") self.assertEqual(inner[IP].dst, rep.ip4) # # An external subnet reachable via the remote external EP # # # first the VXLAN-GBP tunnel over which it is reached # vx_tun_r1 = VppVxlanGbpTunnel( self, self.pg7.local_ip4, self.pg7.remote_ip4, 445, mode=( VppEnum.vl_api_vxlan_gbp_api_tunnel_mode_t.VXLAN_GBP_API_TUNNEL_MODE_L3 ), ) vx_tun_r1.add_vpp_config() VppIpInterfaceBind(self, vx_tun_r1, t4).add_vpp_config() self.logger.info(self.vapi.cli("sh vxlan-gbp tunnel")) # # then the special adj to resolve through on that tunnel # n1 = VppNeighbor( self, vx_tun_r1.sw_if_index, "00:0c:0c:0c:0c:0c", self.pg7.remote_ip4 ) n1.add_vpp_config() # # the route via the adj above # ip_222 = VppIpRoute( self, "10.222.0.0", 24, [VppRoutePath(self.pg7.remote_ip4, vx_tun_r1.sw_if_index)], table_id=t4.table_id, ) ip_222.add_vpp_config() l3o_222 = VppGbpSubnet( self, rd1, "10.222.0.0", 24, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_L3_OUT, sclass=4222, ) l3o_222.add_vpp_config() # # ping between hosts in local and remote external subnets # dropped without a contract # p = ( Ether(src=eep1.mac, dst=str(self.router_mac)) / Dot1Q(vlan=100) / IP(src="10.220.0.1", dst="10.222.0.1") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_assert_no_replies(self.pg0, p * 1) # # Add contracts ext-nets for 220 -> 222 # c4 = VppGbpContract( self, 55, 4220, 4222, acl.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), ], [ETH_P_IP, ETH_P_IPV6], ) c4.add_vpp_config() # # ping from host in local to remote external subnets # p = ( Ether(src=eep1.mac, dst=str(self.router_mac)) / Dot1Q(vlan=100) / IP(src="10.220.0.1", dst="10.222.0.1") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg0, p * 3, self.pg7) for rx in rxs: self.assertEqual(rx[Ether].src, self.pg7.local_mac) self.assertEqual(rx[Ether].dst, self.pg7.remote_mac) self.assertEqual(rx[IP].src, self.pg7.local_ip4) self.assertEqual(rx[IP].dst, self.pg7.remote_ip4) self.assertEqual(rx[VXLAN].vni, 445) self.assertTrue(rx[VXLAN].flags.G) self.assertTrue(rx[VXLAN].flags.Instance) # the sclass of the ext-net the packet came from self.assertEqual(rx[VXLAN].gpid, 4220) # policy was applied to the original IP packet self.assertTrue(rx[VXLAN].gpflags.A) # since it's an external host the reciever should not learn it self.assertTrue(rx[VXLAN].gpflags.D) inner = rx[VXLAN].payload self.assertEqual(inner[Ether].dst, "00:0c:0c:0c:0c:0c") self.assertEqual(inner[IP].src, "10.220.0.1") self.assertEqual(inner[IP].dst, "10.222.0.1") # # make the external subnet ECMP # vx_tun_r2 = VppVxlanGbpTunnel( self, self.pg7.local_ip4, self.pg7.remote_ip4, 446, mode=( VppEnum.vl_api_vxlan_gbp_api_tunnel_mode_t.VXLAN_GBP_API_TUNNEL_MODE_L3 ), ) vx_tun_r2.add_vpp_config() VppIpInterfaceBind(self, vx_tun_r2, t4).add_vpp_config() self.logger.info(self.vapi.cli("sh vxlan-gbp tunnel")) n2 = VppNeighbor( self, vx_tun_r2.sw_if_index, "00:0c:0c:0c:0c:0c", self.pg7.remote_ip4 ) n2.add_vpp_config() ip_222.modify( [ VppRoutePath(self.pg7.remote_ip4, vx_tun_r1.sw_if_index), VppRoutePath(self.pg7.remote_ip4, vx_tun_r2.sw_if_index), ] ) # # now expect load-balance # p = [ ( Ether(src=eep1.mac, dst=str(self.router_mac)) / Dot1Q(vlan=100) / IP(src="10.220.0.1", dst="10.222.0.1") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ), ( Ether(src=eep1.mac, dst=str(self.router_mac)) / Dot1Q(vlan=100) / IP(src="10.220.0.1", dst="10.222.0.1") / UDP(sport=1222, dport=1235) / Raw(b"\xa5" * 100) ), ] rxs = self.send_and_expect(self.pg0, p, self.pg7) self.assertEqual(rxs[0][VXLAN].vni, 445) self.assertEqual(rxs[1][VXLAN].vni, 446) # # Same LB test for v6 # n3 = VppNeighbor( self, vx_tun_r1.sw_if_index, "00:0c:0c:0c:0c:0c", self.pg7.remote_ip6 ) n3.add_vpp_config() n4 = VppNeighbor( self, vx_tun_r2.sw_if_index, "00:0c:0c:0c:0c:0c", self.pg7.remote_ip6 ) n4.add_vpp_config() ip_222_6 = VppIpRoute( self, "10:222::", 64, [ VppRoutePath(self.pg7.remote_ip6, vx_tun_r1.sw_if_index), VppRoutePath(self.pg7.remote_ip6, vx_tun_r2.sw_if_index), ], table_id=t6.table_id, ) ip_222_6.add_vpp_config() l3o_222_6 = VppGbpSubnet( self, rd1, "10:222::", 64, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_L3_OUT, sclass=4222, ) l3o_222_6.add_vpp_config() p = [ ( Ether(src=eep1.mac, dst=str(self.router_mac)) / Dot1Q(vlan=100) / IPv6(src="10:220::1", dst="10:222::1") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ), ( Ether(src=eep1.mac, dst=str(self.router_mac)) / Dot1Q(vlan=100) / IPv6(src="10:220::1", dst="10:222::1") / UDP(sport=7777, dport=8881) / Raw(b"\xa5" * 100) ), ] self.logger.info(self.vapi.cli("sh ip6 fib 10:222::1")) rxs = self.send_and_expect(self.pg0, p, self.pg7) self.assertEqual(rxs[0][VXLAN].vni, 445) self.assertEqual(rxs[1][VXLAN].vni, 446) # # ping from host in remote to local external subnets # there's no contract for this, but the A bit is set. # p = ( Ether(src=self.pg7.remote_mac, dst=self.pg7.local_mac) / IP(src=self.pg7.remote_ip4, dst=self.pg7.local_ip4) / UDP(sport=1234, dport=48879) / VXLAN(vni=445, gpid=4222, flags=0x88, gpflags="A") / Ether(src=self.pg0.remote_mac, dst=str(self.router_mac)) / IP(src="10.222.0.1", dst="10.220.0.1") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg7, p * 3, self.pg0) self.assertFalse(find_gbp_endpoint(self, ip="10.222.0.1")) # # ping from host in remote to remote external subnets # this is dropped by reflection check. # p = ( Ether(src=self.pg7.remote_mac, dst=self.pg7.local_mac) / IP(src=self.pg7.remote_ip4, dst=self.pg7.local_ip4) / UDP(sport=1234, dport=48879) / VXLAN(vni=445, gpid=4222, flags=0x88, gpflags="A") / Ether(src=self.pg0.remote_mac, dst=str(self.router_mac)) / IP(src="10.222.0.1", dst="10.222.0.2") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_assert_no_replies(self.pg7, p * 3) p = ( Ether(src=self.pg7.remote_mac, dst=self.pg7.local_mac) / IP(src=self.pg7.remote_ip4, dst=self.pg7.local_ip4) / UDP(sport=1234, dport=48879) / VXLAN(vni=445, gpid=4222, flags=0x88, gpflags="A") / Ether(src=self.pg0.remote_mac, dst=str(self.router_mac)) / IPv6(src="10:222::1", dst="10:222::2") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_assert_no_replies(self.pg7, p * 3) # # local EP # lep1 = VppGbpEndpoint( self, vlan_144, epg_220, None, "10.0.0.44", "11.0.0.44", "2001:10::44", "3001::44", ) lep1.add_vpp_config() # # local EP to local ip4 external subnet # p = ( Ether(src=lep1.mac, dst=str(self.router_mac)) / Dot1Q(vlan=144) / IP(src=lep1.ip4, dst="10.220.0.1") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg0, p * 1, self.pg0) for rx in rxs: self.assertEqual(rx[Ether].src, str(self.router_mac)) self.assertEqual(rx[Ether].dst, eep1.mac) self.assertEqual(rx[Dot1Q].vlan, 100) # # local EP to local ip6 external subnet # p = ( Ether(src=lep1.mac, dst=str(self.router_mac)) / Dot1Q(vlan=144) / IPv6(src=lep1.ip6, dst="10:220::1") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg0, p * 1, self.pg0) for rx in rxs: self.assertEqual(rx[Ether].src, str(self.router_mac)) self.assertEqual(rx[Ether].dst, eep1.mac) self.assertEqual(rx[Dot1Q].vlan, 100) # # ip4 and ip6 subnets that load-balance # ip_20 = VppIpRoute( self, "10.20.0.0", 24, [ VppRoutePath(eep1.ip4, eep1.epg.bvi.sw_if_index), VppRoutePath(eep2.ip4, eep2.epg.bvi.sw_if_index), ], table_id=t4.table_id, ) ip_20.add_vpp_config() l3o_20 = VppGbpSubnet( self, rd1, "10.20.0.0", 24, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_L3_OUT, sclass=4220, ) l3o_20.add_vpp_config() ip6_20 = VppIpRoute( self, "10:20::", 64, [ VppRoutePath(eep1.ip6, eep1.epg.bvi.sw_if_index), VppRoutePath(eep2.ip6, eep2.epg.bvi.sw_if_index), ], table_id=t6.table_id, ) ip6_20.add_vpp_config() l3o6_20 = VppGbpSubnet( self, rd1, "10:20::", 64, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_L3_OUT, sclass=4220, ) l3o6_20.add_vpp_config() self.logger.info(self.vapi.cli("sh ip fib 10.20.0.1")) self.logger.info(self.vapi.cli("sh ip6 fib 10:20::1")) # two ip6 packets whose port are chosen so they load-balance p = [ ( Ether(src=lep1.mac, dst=str(self.router_mac)) / Dot1Q(vlan=144) / IPv6(src=lep1.ip6, dst="10:20::1") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ), ( Ether(src=lep1.mac, dst=str(self.router_mac)) / Dot1Q(vlan=144) / IPv6(src=lep1.ip6, dst="10:20::1") / UDP(sport=124, dport=1230) / Raw(b"\xa5" * 100) ), ] rxs = self.send_and_expect(self.pg0, p, self.pg0, 2) self.assertEqual(rxs[0][Dot1Q].vlan, 101) self.assertEqual(rxs[1][Dot1Q].vlan, 100) # two ip4 packets whose port are chosen so they load-balance p = [ ( Ether(src=lep1.mac, dst=str(self.router_mac)) / Dot1Q(vlan=144) / IP(src=lep1.ip4, dst="10.20.0.1") / UDP(sport=1235, dport=1235) / Raw(b"\xa5" * 100) ), ( Ether(src=lep1.mac, dst=str(self.router_mac)) / Dot1Q(vlan=144) / IP(src=lep1.ip4, dst="10.20.0.1") / UDP(sport=124, dport=1230) / Raw(b"\xa5" * 100) ), ] rxs = self.send_and_expect(self.pg0, p, self.pg0, 2) self.assertEqual(rxs[0][Dot1Q].vlan, 101) self.assertEqual(rxs[1][Dot1Q].vlan, 100) # # cleanup # ip_222.remove_vpp_config() self.pg7.unconfig_ip4() self.vlan_101.set_vtr(L2_VTR_OP.L2_DISABLED) self.vlan_100.set_vtr(L2_VTR_OP.L2_DISABLED) def test_gbp_anon_l3_out(self): """GBP Anonymous L3 Out""" ep_flags = VppEnum.vl_api_gbp_endpoint_flags_t self.vapi.cli("set logging class gbp level debug") routed_dst_mac = "00:0c:0c:0c:0c:0c" routed_src_mac = "00:22:bd:f8:19:ff" # # IP tables # t4 = VppIpTable(self, 1) t4.add_vpp_config() t6 = VppIpTable(self, 1, True) t6.add_vpp_config() rd1 = VppGbpRouteDomain(self, 2, 55, t4, t6) rd1.add_vpp_config() self.loop0.set_mac(self.router_mac) # # Bind the BVI to the RD # bind_l0_ip4 = VppIpInterfaceBind(self, self.loop0, t4).add_vpp_config() bind_l0_ip6 = VppIpInterfaceBind(self, self.loop0, t6).add_vpp_config() # # Pg7 hosts a BD's BUM # Pg1 some other l3 interface # self.pg7.config_ip4() self.pg7.resolve_arp() # # a GBP external bridge domains for the EPs # bd1 = VppBridgeDomain(self, 1) bd1.add_vpp_config() gbd1 = VppGbpBridgeDomain(self, bd1, rd1, self.loop0, None, None) gbd1.add_vpp_config() # # The Endpoint-groups in which the external endpoints exist # epg_220 = VppGbpEndpointGroup( self, 220, 113, rd1, gbd1, None, gbd1.bvi, "10.0.0.128", "2001:10::128", VppGbpEndpointRetention(4), ) epg_220.add_vpp_config() # the BVIs have the subnet applied ... ip4_addr = VppIpInterfaceAddress( self, gbd1.bvi, "10.0.0.128", 24, bind=bind_l0_ip4 ).add_vpp_config() # ... which is an Anonymous L3-out subnets l3o_1 = VppGbpSubnet( self, rd1, "10.0.0.0", 24, VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_ANON_L3_OUT, sclass=113, ) l3o_1.add_vpp_config() # # an external interface attached to the outside world and the # external BD # VppL2Vtr(self, self.vlan_100, L2_VTR_OP.L2_POP_1).add_vpp_config() VppL2Vtr(self, self.vlan_101, L2_VTR_OP.L2_POP_1).add_vpp_config() # # vlan_100 and vlan_101 are anonymous l3-out interfaces # ext_itf = VppGbpExtItf(self, self.vlan_100, bd1, rd1, anon=True) ext_itf.add_vpp_config() ext_itf = VppGbpExtItf(self, self.vlan_101, bd1, rd1, anon=True) ext_itf.add_vpp_config() # # an unicast vxlan-gbp for inter-RD traffic # vx_tun_l3 = VppGbpVxlanTunnel( self, 444, rd1.rd_id, VppEnum.vl_api_gbp_vxlan_tunnel_mode_t.GBP_VXLAN_TUNNEL_MODE_L3, self.pg2.local_ip4, ) vx_tun_l3.add_vpp_config() # # A remote external endpoint # rep = VppGbpEndpoint( self, vx_tun_l3, epg_220, None, "10.0.0.201", "11.0.0.201", "2001:10::201", "3001::101", ep_flags.GBP_API_ENDPOINT_FLAG_REMOTE, self.pg7.local_ip4, self.pg7.remote_ip4, mac=None, ) rep.add_vpp_config() # # ARP packet from host in external subnet are accepted, flooded and # replied to. We expect 2 packets: # - APR request flooded over the other vlan subif # - ARP reply from BVI # p_arp = ( Ether(src=self.vlan_100.remote_mac, dst="ff:ff:ff:ff:ff:ff") / Dot1Q(vlan=100) / ARP( op="who-has", psrc="10.0.0.100", pdst="10.0.0.128", hwsrc=self.vlan_100.remote_mac, hwdst="ff:ff:ff:ff:ff:ff", ) ) rxs = self.send_and_expect(self.pg0, p_arp * 1, self.pg0, n_rx=2) p_arp = ( Ether(src=self.vlan_101.remote_mac, dst="ff:ff:ff:ff:ff:ff") / Dot1Q(vlan=101) / ARP( op="who-has", psrc="10.0.0.101", pdst="10.0.0.128", hwsrc=self.vlan_101.remote_mac, hwdst="ff:ff:ff:ff:ff:ff", ) ) rxs = self.send_and_expect(self.pg0, p_arp * 1, self.pg0, n_rx=2) # # remote to external # p = ( Ether(src=self.pg7.remote_mac, dst=self.pg7.local_mac) / IP(src=self.pg7.remote_ip4, dst=self.pg7.local_ip4) / UDP(sport=1234, dport=48879) / VXLAN(vni=vx_tun_l3.vni, gpid=epg_220.sclass, flags=0x88) / Ether(src=self.pg0.remote_mac, dst=str(self.router_mac)) / IP(src=str(rep.ip4), dst="10.0.0.100") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg7, p * 1, self.pg0) # # local EP pings router # p = ( Ether(src=self.vlan_100.remote_mac, dst=str(self.router_mac)) / Dot1Q(vlan=100) / IP(src="10.0.0.100", dst="10.0.0.128") / ICMP(type="echo-request") ) rxs = self.send_and_expect(self.pg0, p * 1, self.pg0) for rx in rxs: self.assertEqual(rx[Ether].src, str(self.router_mac)) self.assertEqual(rx[Ether].dst, self.vlan_100.remote_mac) self.assertEqual(rx[Dot1Q].vlan, 100) # # local EP pings other local EP # p = ( Ether(src=self.vlan_100.remote_mac, dst=self.vlan_101.remote_mac) / Dot1Q(vlan=100) / IP(src="10.0.0.100", dst="10.0.0.101") / ICMP(type="echo-request") ) rxs = self.send_and_expect(self.pg0, p * 1, self.pg0) for rx in rxs: self.assertEqual(rx[Ether].src, self.vlan_100.remote_mac) self.assertEqual(rx[Ether].dst, self.vlan_101.remote_mac) self.assertEqual(rx[Dot1Q].vlan, 101) # # A subnet reachable through an external router on vlan 100 # ip_220 = VppIpRoute( self, "10.220.0.0", 24, [VppRoutePath("10.0.0.100", epg_220.bvi.sw_if_index)], table_id=t4.table_id, ) ip_220.add_vpp_config() l3o_220 = VppGbpSubnet( self, rd1, "10.220.0.0", 24, # note: this a "regular" L3 out subnet (not connected) VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_L3_OUT, sclass=4220, ) l3o_220.add_vpp_config() # # A subnet reachable through an external router on vlan 101 # ip_221 = VppIpRoute( self, "10.221.0.0", 24, [VppRoutePath("10.0.0.101", epg_220.bvi.sw_if_index)], table_id=t4.table_id, ) ip_221.add_vpp_config() l3o_221 = VppGbpSubnet( self, rd1, "10.221.0.0", 24, # note: this a "regular" L3 out subnet (not connected) VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_L3_OUT, sclass=4221, ) l3o_221.add_vpp_config() # # ping between hosts in remote subnets # dropped without a contract # p = ( Ether(src=self.vlan_100.remote_mac, dst=str(self.router_mac)) / Dot1Q(vlan=100) / IP(src="10.220.0.1", dst="10.221.0.1") / ICMP(type="echo-request") ) rxs = self.send_and_assert_no_replies(self.pg0, p * 1) # # contract for the external nets to communicate # rule4 = AclRule(is_permit=1, proto=17) rule6 = AclRule( src_prefix=IPv6Network((0, 0)), dst_prefix=IPv6Network((0, 0)), is_permit=1, proto=17, ) acl = VppAcl(self, rules=[rule4, rule6]) acl.add_vpp_config() c1 = VppGbpContract( self, 55, 4220, 4221, acl.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), ], [ETH_P_IP, ETH_P_IPV6], ) c1.add_vpp_config() # # Contracts allowing ext-net 200 to talk with external EPs # c2 = VppGbpContract( self, 55, 4220, 113, acl.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), ], [ETH_P_IP, ETH_P_IPV6], ) c2.add_vpp_config() c3 = VppGbpContract( self, 55, 113, 4220, acl.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), ], [ETH_P_IP, ETH_P_IPV6], ) c3.add_vpp_config() # # ping between hosts in remote subnets # p = ( Ether(src=self.vlan_100.remote_mac, dst=str(self.router_mac)) / Dot1Q(vlan=100) / IP(src="10.220.0.1", dst="10.221.0.1") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg0, p * 1, self.pg0) for rx in rxs: self.assertEqual(rx[Ether].src, str(self.router_mac)) self.assertEqual(rx[Ether].dst, self.vlan_101.remote_mac) self.assertEqual(rx[Dot1Q].vlan, 101) # we did not learn these external hosts self.assertFalse(find_gbp_endpoint(self, ip="10.220.0.1")) self.assertFalse(find_gbp_endpoint(self, ip="10.221.0.1")) # # from remote external EP to local external EP # p = ( Ether(src=self.pg7.remote_mac, dst=self.pg7.local_mac) / IP(src=self.pg7.remote_ip4, dst=self.pg7.local_ip4) / UDP(sport=1234, dport=48879) / VXLAN(vni=444, gpid=113, flags=0x88) / Ether(src=self.pg0.remote_mac, dst=str(self.router_mac)) / IP(src=rep.ip4, dst="10.220.0.1") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg7, p * 1, self.pg0) # # ping from an external host to the remote external EP # p = ( Ether(src=self.vlan_100.remote_mac, dst=str(self.router_mac)) / Dot1Q(vlan=100) / IP(src="10.220.0.1", dst=rep.ip4) / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg0, p * 1, self.pg7) for rx in rxs: self.assertEqual(rx[Ether].src, self.pg7.local_mac) # self.assertEqual(rx[Ether].dst, self.pg7.remote_mac) self.assertEqual(rx[IP].src, self.pg7.local_ip4) self.assertEqual(rx[IP].dst, self.pg7.remote_ip4) self.assertEqual(rx[VXLAN].vni, 444) self.assertTrue(rx[VXLAN].flags.G) self.assertTrue(rx[VXLAN].flags.Instance) # the sclass of the ext-net the packet came from self.assertEqual(rx[VXLAN].gpid, 4220) # policy was applied to the original IP packet self.assertTrue(rx[VXLAN].gpflags.A) # since it's an external host the reciever should not learn it self.assertTrue(rx[VXLAN].gpflags.D) inner = rx[VXLAN].payload self.assertEqual(inner[IP].src, "10.220.0.1") self.assertEqual(inner[IP].dst, rep.ip4) # # An external subnet reachable via the remote external EP # # # first the VXLAN-GBP tunnel over which it is reached # vx_tun_r = VppVxlanGbpTunnel( self, self.pg7.local_ip4, self.pg7.remote_ip4, 445, mode=( VppEnum.vl_api_vxlan_gbp_api_tunnel_mode_t.VXLAN_GBP_API_TUNNEL_MODE_L3 ), ) vx_tun_r.add_vpp_config() VppIpInterfaceBind(self, vx_tun_r, t4).add_vpp_config() self.logger.info(self.vapi.cli("sh vxlan-gbp tunnel")) # # then the special adj to resolve through on that tunnel # n1 = VppNeighbor( self, vx_tun_r.sw_if_index, "00:0c:0c:0c:0c:0c", self.pg7.remote_ip4 ) n1.add_vpp_config() # # the route via the adj above # ip_222 = VppIpRoute( self, "10.222.0.0", 24, [VppRoutePath(self.pg7.remote_ip4, vx_tun_r.sw_if_index)], table_id=t4.table_id, ) ip_222.add_vpp_config() l3o_222 = VppGbpSubnet( self, rd1, "10.222.0.0", 24, # note: this a "regular" l3out subnet (not connected) VppEnum.vl_api_gbp_subnet_type_t.GBP_API_SUBNET_L3_OUT, sclass=4222, ) l3o_222.add_vpp_config() # # ping between hosts in local and remote external subnets # dropped without a contract # p = ( Ether(src=self.vlan_100.remote_mac, dst=str(self.router_mac)) / Dot1Q(vlan=100) / IP(src="10.220.0.1", dst="10.222.0.1") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_assert_no_replies(self.pg0, p * 1) # # Add contracts ext-nets for 220 -> 222 # c4 = VppGbpContract( self, 55, 4220, 4222, acl.acl_index, [ VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), VppGbpContractRule( VppEnum.vl_api_gbp_rule_action_t.GBP_API_RULE_PERMIT, VppEnum.vl_api_gbp_hash_mode_t.GBP_API_HASH_MODE_SRC_IP, [], ), ], [ETH_P_IP, ETH_P_IPV6], ) c4.add_vpp_config() # # ping from host in local to remote external subnets # p = ( Ether(src=self.vlan_100.remote_mac, dst=str(self.router_mac)) / Dot1Q(vlan=100) / IP(src="10.220.0.1", dst="10.222.0.1") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg0, p * 3, self.pg7) for rx in rxs: self.assertEqual(rx[Ether].src, self.pg7.local_mac) self.assertEqual(rx[Ether].dst, self.pg7.remote_mac) self.assertEqual(rx[IP].src, self.pg7.local_ip4) self.assertEqual(rx[IP].dst, self.pg7.remote_ip4) self.assertEqual(rx[VXLAN].vni, 445) self.assertTrue(rx[VXLAN].flags.G) self.assertTrue(rx[VXLAN].flags.Instance) # the sclass of the ext-net the packet came from self.assertEqual(rx[VXLAN].gpid, 4220) # policy was applied to the original IP packet self.assertTrue(rx[VXLAN].gpflags.A) # since it's an external host the reciever should not learn it self.assertTrue(rx[VXLAN].gpflags.D) inner = rx[VXLAN].payload self.assertEqual(inner[Ether].dst, "00:0c:0c:0c:0c:0c") self.assertEqual(inner[IP].src, "10.220.0.1") self.assertEqual(inner[IP].dst, "10.222.0.1") # # ping from host in remote to local external subnets # there's no contract for this, but the A bit is set. # p = ( Ether(src=self.pg7.remote_mac, dst=self.pg7.local_mac) / IP(src=self.pg7.remote_ip4, dst=self.pg7.local_ip4) / UDP(sport=1234, dport=48879) / VXLAN(vni=445, gpid=4222, flags=0x88, gpflags="A") / Ether(src=self.pg0.remote_mac, dst=str(self.router_mac)) / IP(src="10.222.0.1", dst="10.220.0.1") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_expect(self.pg7, p * 3, self.pg0) self.assertFalse(find_gbp_endpoint(self, ip="10.222.0.1")) # # ping from host in remote to remote external subnets # this is dropped by reflection check. # p = ( Ether(src=self.pg7.remote_mac, dst=self.pg7.local_mac) / IP(src=self.pg7.remote_ip4, dst=self.pg7.local_ip4) / UDP(sport=1234, dport=48879) / VXLAN(vni=445, gpid=4222, flags=0x88, gpflags="A") / Ether(src=self.pg0.remote_mac, dst=str(self.router_mac)) / IP(src="10.222.0.1", dst="10.222.0.2") / UDP(sport=1234, dport=1234) / Raw(b"\xa5" * 100) ) rxs = self.send_and_assert_no_replies(self.pg7, p * 3) # # cleanup # self.vlan_101.set_vtr(L2_VTR_OP.L2_DISABLED) self.vlan_100.set_vtr(L2_VTR_OP.L2_DISABLED) self.pg7.unconfig_ip4() # make sure the programmed EP is no longer learnt from DP self.wait_for_ep_timeout(sw_if_index=rep.itf.sw_if_index, ip=rep.ip4) if __name__ == "__main__": unittest.main(testRunner=VppTestRunner)