# Copyright 2021-present Intel Corporation. # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. """ Thrift SAI interface MPLS tests """ import random from sai_thrift.sai_headers import * from sai_base_test import * @group("draft") class MplsCpuTrapTest(SaiHelper): ''' Basic MPLS trap test class ''' def setUp(self): super(MplsCpuTrapTest, self).setUp() status = clear_counter( self, sai_thrift_clear_port_stats, self.port10) self.assertEqual(status, SAI_STATUS_SUCCESS) status = clear_counter( self, sai_thrift_clear_router_interface_stats, self.port10_rif) self.assertEqual(status, SAI_STATUS_SUCCESS) stats = query_counter( self, sai_thrift_get_port_stats, self.port10) self.port10_disc_stats = stats['SAI_PORT_STAT_IF_IN_DISCARDS'] self.assertEqual(self.port10_disc_stats, 0) stats = query_counter( self, sai_thrift_get_router_interface_stats, self.port10_rif) self.port10_rif_in_stats = \ stats['SAI_ROUTER_INTERFACE_STAT_IN_PACKETS'] self.assertEqual(self.port10_rif_in_stats, 0) self.port10_rif_out_stats = \ stats['SAI_ROUTER_INTERFACE_STAT_OUT_PACKETS'] self.assertEqual(self.port10_rif_out_stats, 0) self.inseg_entry = sai_thrift_inseg_entry_t(label=3) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry, packet_action=SAI_PACKET_ACTION_TRAP) self.assertEqual(status, SAI_STATUS_SUCCESS) def runTest(self): self.mplsImplicitNullLabelTrapDropTest() self.mplsLabelLookupMissTest() def tearDown(self): sai_thrift_remove_inseg_entry(self.client, self.inseg_entry) super(MplsCpuTrapTest, self).tearDown() def _verifyStats(self): ''' Additional helper function for statistics verification Return: bool: True if statistics are correct, otherwise False ''' rif_stats = query_counter( self, sai_thrift_get_router_interface_stats, self.port10_rif) port_stats = query_counter( self, sai_thrift_get_port_stats, self.port10) if self.port10_rif_in_stats != \ rif_stats['SAI_ROUTER_INTERFACE_STAT_IN_PACKETS'] or \ self.port10_rif_out_stats != \ rif_stats['SAI_ROUTER_INTERFACE_STAT_OUT_PACKETS'] or \ self.port10_disc_stats != \ port_stats['SAI_PORT_STAT_IF_IN_DISCARDS']: return False print("\tStatistics correct") return True def mplsImplicitNullLabelTrapDropTest(self): ''' Verify if MPLS packet with implicit null label (3) is trapped or dropped as defined. ''' print("\nmplsImplicitNullLabelTrapDropTest()") send_pkt = simple_tcp_packet( eth_dst=ROUTER_MAC, ip_dst='40.40.40.1', ip_ttl=64) mpls_tag = {'label': 3, 'ttl': 63, 'tc': 0, 's': 1} mpls_tag_list = [mpls_tag] mpls_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list, inner_frame=send_pkt['IP']) try: pre_stats = query_counter( self, sai_thrift_get_queue_stats, self.cpu_queue0) print("Implicit null label action trap") send_packet(self, self.dev_port10, mpls_pkt) time.sleep(4) post_stats = query_counter( self, sai_thrift_get_queue_stats, self.cpu_queue0) self.assertEqual( post_stats["SAI_QUEUE_STAT_PACKETS"], pre_stats["SAI_QUEUE_STAT_PACKETS"] + 1) self.port10_rif_in_stats += 1 self.port10_rif_out_stats += 1 self.assertTrue(self._verifyStats()) print("Set implicit null label to drop action") sai_thrift_set_inseg_entry_attribute( self.client, self.inseg_entry, packet_action=SAI_PACKET_ACTION_DROP) send_packet(self, self.dev_port10, mpls_pkt) verify_no_other_packets(self) self.port10_rif_in_stats += 1 self.port10_disc_stats += 1 self.assertTrue(self._verifyStats()) print("Add second inseg_entry for label stack") inseg_entry_4 = sai_thrift_inseg_entry_t(label=4) status = sai_thrift_create_inseg_entry( self.client, inseg_entry_4, packet_action=SAI_PACKET_ACTION_TRAP) self.assertEqual(status, SAI_STATUS_SUCCESS) mpls_tag = {'label': 3, 'ttl': 63, 'tc': 0, 's': 0} mpls_tag_2 = {'label': 4, 'ttl': 63, 'tc': 0, 's': 1} mpls_tag_list = [mpls_tag, mpls_tag_2] mpls_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list, inner_frame=send_pkt['IP']) send_packet(self, self.dev_port10, mpls_pkt) verify_no_other_packets(self) self.port10_rif_in_stats += 1 self.port10_disc_stats += 1 self.assertTrue(self._verifyStats()) finally: sai_thrift_set_inseg_entry_attribute( self.client, self.inseg_entry, packet_action=SAI_PACKET_ACTION_TRAP) sai_thrift_remove_inseg_entry(self.client, inseg_entry_4) def mplsLabelLookupMissTest(self): ''' Verify if MPLS packet with unknown label is dropped and checks that associated debug counter is hit. ''' print("\nmplsLabelLookupMissTest()") send_pkt = simple_tcp_packet( eth_dst=ROUTER_MAC, ip_dst='40.40.40.1', ip_ttl=64) mpls_tag = {'label': 4, 'ttl': 63, 'tc': 0, 's': 1} mpls_tag_list = [mpls_tag] mpls_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list, inner_frame=send_pkt['IP']) try: drop_reason = sai_thrift_s32_list_t( count=1, int32list=[SAI_IN_DROP_REASON_MPLS_MISS]) debug_cnt = sai_thrift_create_debug_counter( self.client, type=SAI_DEBUG_COUNTER_TYPE_PORT_IN_DROP_REASONS, in_drop_reason_list = drop_reason) self.assertNotEqual(debug_cnt, 0) print("Sending packet with unknown label - should be dropped") send_packet(self, self.dev_port10, mpls_pkt) verify_no_other_packets(self) self.port10_rif_in_stats += 1 self.port10_disc_stats += 1 self.assertTrue(self._verifyStats()) print("Add second inseg_entry for bottom label") inseg_entry_4 = sai_thrift_inseg_entry_t(label=4) status = sai_thrift_create_inseg_entry( self.client, inseg_entry_4, packet_action=SAI_PACKET_ACTION_TRAP) self.assertEqual(status, SAI_STATUS_SUCCESS) mpls_tag = {'label': 5, 'ttl': 63, 'tc': 0, 's': 0} mpls_tag_2 = {'label': 4, 'ttl': 63, 'tc': 0, 's': 1} mpls_tag_list = [mpls_tag, mpls_tag_2] mpls_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list, inner_frame=send_pkt['IP']) print("Sending packet with unknown top label - should be dropped") send_packet(self, self.dev_port10, mpls_pkt) verify_no_other_packets(self) self.port10_rif_in_stats += 1 self.port10_disc_stats += 1 self.assertTrue(self._verifyStats()) dc_attr = sai_thrift_get_debug_counter_attribute( self.client, debug_cnt, index=True) dc_index = dc_attr['index'] dc_stats = sai_thrift_get_debug_counter_port_stat( self.client, self.port10, [dc_index]) finally: sai_thrift_remove_inseg_entry(self.client, inseg_entry_4) sai_thrift_remove_debug_counter(self.client, debug_cnt) @group("draft") class MplsIpv6Test(SaiHelper): ''' Basic IPv6 MPLS test class ''' def setUp(self): super(MplsIpv6Test, self).setUp() ttl_value = 63 exp_value = 5 ipv6_1 = '100::1' ipv6_2 = '100::2' ipv6_3 = '100::3' ipv6_4 = '220::1' ipv6_5 = '330::1' ipv6_6 = '550::1' ipv6_7 = '700::1' ipv6_8 = '710::1' ipv6_9 = '720::1' ipv6_10 = '800::1' ipv6_subnet_1 = '110::1/128' ipv6_subnet_2 = '120::1/128' ipv6_subnet_3 = '130::1/128' ipv6_subnet_4 = '200::1/128' dmac = '00:11:22:33:44:55' # Ingress LER config self.ingress_rif = self.port10_rif self.egress_rif_1 = self.port11_rif label_list = [1000] label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_1 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv6_1), router_interface_id=self.egress_rif_1, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_ttl_mode=SAI_OUTSEG_TTL_MODE_PIPE, outseg_ttl_value=ttl_value, outseg_exp_value=exp_value, outseg_type=SAI_OUTSEG_TYPE_PUSH) label_list.append(2000) label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_2 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv6_2), router_interface_id=self.egress_rif_1, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_ttl_mode=SAI_OUTSEG_TTL_MODE_PIPE, outseg_ttl_value=ttl_value, outseg_exp_value=exp_value, outseg_type=SAI_OUTSEG_TYPE_PUSH) label_list.append(3000) label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_3 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv6_3), router_interface_id=self.egress_rif_1, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_ttl_mode=SAI_OUTSEG_TTL_MODE_PIPE, outseg_ttl_value=ttl_value, outseg_exp_value=exp_value, outseg_type=SAI_OUTSEG_TYPE_PUSH) # note: neighbor with the same dst_ip as MPLS nexthop has to be created # after MPLS nexthop is created, # if not it will create second nexthop of type IP with this dst_ip # and neither of them will be functioning correctly - packets # will be gleaned to CPU self.mpls_neighbor_entry_1 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_1, ip_address=sai_ipaddress(ipv6_1)) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_1, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.mpls_neighbor_entry_2 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_1, ip_address=sai_ipaddress(ipv6_2)) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_2, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.mpls_neighbor_entry_3 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_1, ip_address=sai_ipaddress(ipv6_3)) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_3, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.mpls_encap_route_1 = sai_thrift_route_entry_t( vr_id=self.default_vrf, destination=sai_ipprefix(ipv6_subnet_1)) sai_thrift_create_route_entry( self.client, self.mpls_encap_route_1, next_hop_id=self.nhop_label_1) self.mpls_encap_route_2 = sai_thrift_route_entry_t( vr_id=self.default_vrf, destination=sai_ipprefix(ipv6_subnet_2)) sai_thrift_create_route_entry( self.client, self.mpls_encap_route_2, next_hop_id=self.nhop_label_2) self.mpls_encap_route_3 = sai_thrift_route_entry_t( vr_id=self.default_vrf, destination=sai_ipprefix(ipv6_subnet_3)) sai_thrift_create_route_entry( self.client, self.mpls_encap_route_3, next_hop_id=self.nhop_label_3) # MPLS egress LER term config self.egress_rif_2 = self.port12_rif self.mpls_rif = sai_thrift_create_router_interface( self.client, type=SAI_ROUTER_INTERFACE_TYPE_MPLS_ROUTER, virtual_router_id=self.default_vrf) self.nhop_1 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv6_4), router_interface_id=self.egress_rif_2, type=SAI_NEXT_HOP_TYPE_IP) self.neighbor_entry_1 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_2, ip_address=sai_ipaddress(ipv6_4)) sai_thrift_create_neighbor_entry( self.client, self.neighbor_entry_1, dst_mac_address=dmac, no_host_route=True) self.route_entry_1 = sai_thrift_route_entry_t( vr_id=self.default_vrf, destination=sai_ipprefix(ipv6_subnet_4)) sai_thrift_create_route_entry( self.client, self.route_entry_1, next_hop_id=self.nhop_1) self.inseg_entry_1000 = sai_thrift_inseg_entry_t(label=1000) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_1000, num_of_pop=1, pop_ttl_mode=SAI_INSEG_ENTRY_POP_TTL_MODE_PIPE, next_hop_id=self.mpls_rif) self.assertEqual(status, SAI_STATUS_SUCCESS) # MPLS Egress LER Null Term configs self.inseg_entry_0 = sai_thrift_inseg_entry_t(label=0) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_0, num_of_pop=1, pop_ttl_mode=SAI_INSEG_ENTRY_POP_TTL_MODE_PIPE, next_hop_id=self.mpls_rif) self.assertEqual(status, SAI_STATUS_SUCCESS) # MPLS Egress PHP configs self.egress_rif_3 = self.port13_rif self.nhop_2 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv6_4), router_interface_id=self.egress_rif_3, type=SAI_NEXT_HOP_TYPE_IP) self.neighbor_entry_2 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_3, ip_address=sai_ipaddress(ipv6_4)) status = sai_thrift_create_neighbor_entry( self.client, self.neighbor_entry_2, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.inseg_entry_2000 = sai_thrift_inseg_entry_t(label=2000) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_2000, num_of_pop=1, pop_ttl_mode=SAI_INSEG_ENTRY_POP_TTL_MODE_UNIFORM, next_hop_id=self.nhop_2) self.assertEqual(status, SAI_STATUS_SUCCESS) self.inseg_entry_2111 = sai_thrift_inseg_entry_t(label=2111) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_2111, num_of_pop=2, pop_ttl_mode=SAI_INSEG_ENTRY_POP_TTL_MODE_UNIFORM, next_hop_id=self.nhop_2) self.assertEqual(status, SAI_STATUS_SUCCESS) self.inseg_entry_2222 = sai_thrift_inseg_entry_t(label=2222) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_2222, num_of_pop=3, pop_ttl_mode=SAI_INSEG_ENTRY_POP_TTL_MODE_UNIFORM, next_hop_id=self.nhop_2) self.assertEqual(status, SAI_STATUS_SUCCESS) # MPLS Egress PHP Swap Null configs self.egress_rif_4 = sai_thrift_create_router_interface( self.client, type=SAI_ROUTER_INTERFACE_TYPE_PORT, port_id=self.port25, virtual_router_id=self.default_vrf) label_list = [0] label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_4 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv6_5), router_interface_id=self.egress_rif_4, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_ttl_mode=SAI_OUTSEG_TTL_MODE_PIPE, outseg_ttl_value=ttl_value, outseg_type=SAI_OUTSEG_TYPE_SWAP) self.mpls_neighbor_entry_4 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_4, ip_address=sai_ipaddress(ipv6_5)) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_4, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.inseg_entry_3000 = sai_thrift_inseg_entry_t(label=3000) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_3000, next_hop_id=self.nhop_label_4) self.assertEqual(status, SAI_STATUS_SUCCESS) # MPLS Transit Swap configs self.egress_rif_5 = sai_thrift_create_router_interface( self.client, type=SAI_ROUTER_INTERFACE_TYPE_PORT, port_id=self.port26, virtual_router_id=self.default_vrf) label_list = [0] label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_5 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv6_6), router_interface_id=self.egress_rif_5, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_type=SAI_OUTSEG_TYPE_SWAP) self.mpls_neighbor_entry_5 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_5, ip_address=sai_ipaddress(ipv6_6)) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_5, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.inseg_entry_5000 = sai_thrift_inseg_entry_t(label=5000) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_5000, next_hop_id=self.nhop_label_5) self.assertEqual(status, SAI_STATUS_SUCCESS) # MLPS ECMP Swap configs self.egress_rif_6 = sai_thrift_create_router_interface( self.client, type=SAI_ROUTER_INTERFACE_TYPE_PORT, port_id=self.port27, virtual_router_id=self.default_vrf) self.egress_rif_7 = sai_thrift_create_router_interface( self.client, type=SAI_ROUTER_INTERFACE_TYPE_PORT, port_id=self.port28, virtual_router_id=self.default_vrf) self.egress_rif_8 = sai_thrift_create_router_interface( self.client, type=SAI_ROUTER_INTERFACE_TYPE_PORT, port_id=self.port29, virtual_router_id=self.default_vrf) label_list = [7070] label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_6 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv6_7), router_interface_id=self.egress_rif_6, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_type=SAI_OUTSEG_TYPE_SWAP) label_list = [7171] label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_7 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv6_8), router_interface_id=self.egress_rif_7, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_type=SAI_OUTSEG_TYPE_SWAP) label_list = [7272] label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_8 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv6_9), router_interface_id=self.egress_rif_8, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_type=SAI_OUTSEG_TYPE_SWAP) self.ecmp_group = sai_thrift_create_next_hop_group( self.client, type=SAI_NEXT_HOP_GROUP_TYPE_ECMP) self.ecmp_mbr1 = sai_thrift_create_next_hop_group_member( self.client, next_hop_group_id=self.ecmp_group, next_hop_id=self.nhop_label_6) self.ecmp_mbr2 = sai_thrift_create_next_hop_group_member( self.client, next_hop_group_id=self.ecmp_group, next_hop_id=self.nhop_label_7) self.ecmp_mbr3 = sai_thrift_create_next_hop_group_member( self.client, next_hop_group_id=self.ecmp_group, next_hop_id=self.nhop_label_8) self.mpls_neighbor_entry_6 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_6, ip_address=sai_ipaddress(ipv6_7)) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_6, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.mpls_neighbor_entry_7 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_7, ip_address=sai_ipaddress(ipv6_8)) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_7, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.mpls_neighbor_entry_8 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_8, ip_address=sai_ipaddress(ipv6_9)) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_8, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.inseg_entry_7000 = sai_thrift_inseg_entry_t(label=7000) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_7000, next_hop_id=self.ecmp_group) self.assertEqual(status, SAI_STATUS_SUCCESS) # MPLS Transit Push configs self.egress_rif_9 = sai_thrift_create_router_interface( self.client, type=SAI_ROUTER_INTERFACE_TYPE_PORT, port_id=self.port30, virtual_router_id=self.default_vrf) label_list = [9000] label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_9 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv6_10), router_interface_id=self.egress_rif_9, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_ttl_mode=SAI_OUTSEG_TTL_MODE_PIPE, outseg_ttl_value=ttl_value, outseg_exp_value=exp_value, outseg_type=SAI_OUTSEG_TYPE_PUSH) self.mpls_neighbor_entry_9 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_9, ip_address=sai_ipaddress(ipv6_10)) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_9, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.inseg_entry_8000 = sai_thrift_inseg_entry_t(label=8000) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_8000, next_hop_id=self.nhop_label_9) self.assertEqual(status, SAI_STATUS_SUCCESS) # packet counters settings for rif in [self.ingress_rif, self.egress_rif_1, self.egress_rif_2, self.egress_rif_3, self.egress_rif_4, self.egress_rif_5, self.egress_rif_6, self.egress_rif_7, self.egress_rif_8, self.egress_rif_9, self.mpls_rif]: status = clear_counter( self, sai_thrift_clear_router_interface_stats, rif) self.assertEqual(status, SAI_STATUS_SUCCESS) self.ingress_rif_in_stats = 0 # port 10 self.ingress_rif_out_stats = 0 self.egress_rif_1_in_stats = 0 # port 11 self.egress_rif_1_out_stats = 0 self.egress_rif_2_in_stats = 0 # port 12 self.egress_rif_2_out_stats = 0 self.egress_rif_3_in_stats = 0 # port 13 self.egress_rif_3_out_stats = 0 self.egress_rif_4_in_stats = 0 # port 25 self.egress_rif_4_out_stats = 0 self.egress_rif_5_in_stats = 0 # port 26 self.egress_rif_5_out_stats = 0 self.egress_rif_9_in_stats = 0 # port 30 self.egress_rif_9_out_stats = 0 self.mpls_rif_in_stats = 0 self.mpls_rif_out_stats = 0 def runTest(self): self.mplsIngressLERTest() self.mplsEgressLERTermTest() self.mplsEgressLERNullTermTest() self.mplsEgressPhpTest() self.mplsEgressPhpSwapNullTest() self.mplsTransitSwapTest() self.mplsTransitSwapEcmpHashTest() self.mplsTransitPushTest() def tearDown(self): sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_8000) sai_thrift_remove_neighbor_entry( self.client, self.mpls_neighbor_entry_9) sai_thrift_remove_next_hop(self.client, self.nhop_label_9) sai_thrift_remove_router_interface(self.client, self.egress_rif_9) sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_7000) sai_thrift_remove_neighbor_entry(self.client, self.mpls_neighbor_entry_8) sai_thrift_remove_neighbor_entry(self.client, self.mpls_neighbor_entry_7) sai_thrift_remove_neighbor_entry(self.client, self.mpls_neighbor_entry_6) sai_thrift_remove_next_hop_group_member(self.client, self.ecmp_mbr3) sai_thrift_remove_next_hop_group_member(self.client, self.ecmp_mbr2) sai_thrift_remove_next_hop_group_member(self.client, self.ecmp_mbr1) sai_thrift_remove_next_hop_group(self.client, self.ecmp_group) sai_thrift_remove_next_hop(self.client, self.nhop_label_8) sai_thrift_remove_next_hop(self.client, self.nhop_label_7) sai_thrift_remove_next_hop(self.client, self.nhop_label_6) sai_thrift_remove_router_interface(self.client, self.egress_rif_8) sai_thrift_remove_router_interface(self.client, self.egress_rif_7) sai_thrift_remove_router_interface(self.client, self.egress_rif_6) sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_5000) sai_thrift_remove_neighbor_entry(self.client, self.mpls_neighbor_entry_5) sai_thrift_remove_next_hop(self.client, self.nhop_label_5) sai_thrift_remove_router_interface(self.client, self.egress_rif_5) sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_3000) sai_thrift_remove_neighbor_entry(self.client, self.mpls_neighbor_entry_4) sai_thrift_remove_next_hop(self.client, self.nhop_label_4) sai_thrift_remove_router_interface(self.client, self.egress_rif_4) sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_2222) sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_2111) sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_2000) sai_thrift_remove_neighbor_entry(self.client, self.neighbor_entry_2) sai_thrift_remove_next_hop(self.client, self.nhop_2) sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_0) sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_1000) sai_thrift_remove_route_entry(self.client, self.route_entry_1) sai_thrift_remove_neighbor_entry(self.client, self.neighbor_entry_1) sai_thrift_remove_next_hop(self.client, self.nhop_1) sai_thrift_remove_router_interface(self.client, self.mpls_rif) sai_thrift_remove_route_entry(self.client, self.mpls_encap_route_1) sai_thrift_remove_route_entry(self.client, self.mpls_encap_route_2) sai_thrift_remove_route_entry(self.client, self.mpls_encap_route_3) sai_thrift_remove_neighbor_entry(self.client, self.mpls_neighbor_entry_1) sai_thrift_remove_neighbor_entry(self.client, self.mpls_neighbor_entry_2) sai_thrift_remove_neighbor_entry(self.client, self.mpls_neighbor_entry_3) sai_thrift_remove_next_hop(self.client, self.nhop_label_1) sai_thrift_remove_next_hop(self.client, self.nhop_label_2) sai_thrift_remove_next_hop(self.client, self.nhop_label_3) super(MplsIpv6Test, self).tearDown() def _verifyStats(self): ''' Additional helper function for statistics verification Return: bool: True if statistics are correct, otherwise False ''' for rif, in_cnt, out_cnt in zip( [self.ingress_rif, self.egress_rif_1, self.egress_rif_2, self.egress_rif_3, self.egress_rif_4, self.egress_rif_5, self.egress_rif_9, self.mpls_rif], [self.ingress_rif_in_stats, self.egress_rif_1_in_stats, self.egress_rif_2_in_stats, self.egress_rif_3_in_stats, self.egress_rif_4_in_stats, self.egress_rif_5_in_stats, self.egress_rif_9_in_stats, self.mpls_rif_in_stats], [self.ingress_rif_out_stats, self.egress_rif_1_out_stats, self.egress_rif_2_out_stats, self.egress_rif_3_out_stats, self.egress_rif_4_out_stats, self.egress_rif_5_out_stats, self.egress_rif_9_out_stats, self.mpls_rif_out_stats]): stats = query_counter( self, sai_thrift_get_router_interface_stats, rif) if in_cnt != stats['SAI_ROUTER_INTERFACE_STAT_IN_PACKETS'] or \ out_cnt != stats['SAI_ROUTER_INTERFACE_STAT_OUT_PACKETS']: print("Counters doesn't match!") return False print("\tStatistics correct") return True def mplsIngressLERTest(self): ''' Verify if MPLS labels are added to packet in ingress LER. ''' print("\nmplsIngressLERTest()") send_pkt_1 = simple_tcpv6_packet( eth_dst=ROUTER_MAC, ipv6_dst='110::1', ipv6_hlim=64) send_pkt_2 = simple_tcpv6_packet( eth_dst=ROUTER_MAC, ipv6_dst='120::1', ipv6_hlim=64) send_pkt_3 = simple_tcpv6_packet( eth_dst=ROUTER_MAC, ipv6_dst='130::1', ipv6_hlim=64) exp_pkt_1 = simple_tcpv6_packet( eth_dst='00:11:22:33:44:55', eth_src=ROUTER_MAC, ipv6_dst='110::1', ipv6_hlim=63) exp_pkt_2 = simple_tcpv6_packet( eth_dst='00:11:22:33:44:55', eth_src=ROUTER_MAC, ipv6_dst='120::1', ipv6_hlim=63) exp_pkt_3 = simple_tcpv6_packet( eth_dst='00:11:22:33:44:55', eth_src=ROUTER_MAC, ipv6_dst='130::1', ipv6_hlim=63) mpls_tag_list = [] mpls_tag_1 = {'label': 1000, 'ttl': 63, 'tc': 5, 's': 0} mpls_tag_2 = {'label': 2000, 'ttl': 63, 'tc': 5, 's': 0} mpls_tag_3 = {'label': 3000, 'ttl': 63, 'tc': 5, 's': 0} mpls_tag_1['s'] = 1 mpls_tag_list.append(mpls_tag_1) mpls_pkt_label_1 = simple_mpls_packet( eth_src=ROUTER_MAC, eth_dst='00:11:22:33:44:55', mpls_tags=mpls_tag_list, inner_frame=exp_pkt_1['IPv6']) mpls_tag_1['s'] = 0 mpls_tag_2['s'] = 1 del mpls_tag_list[:] mpls_tag_list.append(mpls_tag_1) mpls_tag_list.append(mpls_tag_2) mpls_pkt_label_2 = simple_mpls_packet( eth_src=ROUTER_MAC, eth_dst='00:11:22:33:44:55', mpls_tags=mpls_tag_list, inner_frame=exp_pkt_2['IPv6']) mpls_tag_1['s'] = 0 mpls_tag_2['s'] = 0 mpls_tag_3['s'] = 1 del mpls_tag_list[:] mpls_tag_list.append(mpls_tag_1) mpls_tag_list.append(mpls_tag_2) mpls_tag_list.append(mpls_tag_3) mpls_pkt_label_3 = simple_mpls_packet( eth_src=ROUTER_MAC, eth_dst='00:11:22:33:44:55', mpls_tags=mpls_tag_list, inner_frame=exp_pkt_3['IPv6']) print("Send ip packet to add one MPLS label 1000") send_packet(self, self.dev_port10, send_pkt_1) verify_packet(self, mpls_pkt_label_1, self.dev_port11) self.ingress_rif_in_stats += 1 self.egress_rif_1_out_stats += 1 print("Send ip packet to add two MPLS label stack - 1000, 2000") send_packet(self, self.dev_port10, send_pkt_2) verify_packet(self, mpls_pkt_label_2, self.dev_port11) self.ingress_rif_in_stats += 1 self.egress_rif_1_out_stats += 1 print("Send ip packet to add three MPLS label stack - " "1000, 2000, 3000") send_packet(self, self.dev_port10, send_pkt_3) verify_packet(self, mpls_pkt_label_3, self.dev_port11) self.ingress_rif_in_stats += 1 self.egress_rif_1_out_stats += 1 self.assertTrue(self._verifyStats()) def mplsEgressLERTermTest(self): ''' Verify if MPLS label is popped in Egress LER and packet is forwarded based on IP lookup. ''' print("\nmplsIngressLERTermTest()") send_pkt = simple_tcpv6_packet( eth_dst=ROUTER_MAC, ipv6_dst='200::1', ipv6_hlim=64) mpls_tag = {'label': 1000, 'ttl': 63, 'tc': 0, 's': 1} mpls_tag_list = [mpls_tag] mpls_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list, inner_frame=send_pkt['IPv6']) recv_pkt = simple_tcpv6_packet( eth_dst='00:11:22:33:44:55', eth_src=ROUTER_MAC, ipv6_dst='200::1', ipv6_hlim=63) print("Send MPLS tag packet with label 1000 - term and IP lookup") send_packet(self, self.dev_port10, mpls_pkt) verify_packet(self, recv_pkt, self.dev_port12) self.mpls_rif_in_stats += 1 self.egress_rif_2_out_stats += 1 self.assertTrue(self._verifyStats()) def mplsEgressLERNullTermTest(self): ''' Verify if MPLS null label is popped in Egress LER and packet is forwarded based on IP lookup. ''' print("\nmplsIngressLERNullTermTest()") send_pkt = simple_tcpv6_packet( eth_dst=ROUTER_MAC, ipv6_dst='200::1', ipv6_hlim=64) mpls_tag = {'label': 0, 'ttl': 63, 'tc': 0, 's': 1} mpls_tag_list = [mpls_tag] mpls_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list, inner_frame=send_pkt['IPv6']) recv_pkt = simple_tcpv6_packet( eth_dst='00:11:22:33:44:55', eth_src=ROUTER_MAC, ipv6_dst='200::1', ipv6_hlim=63) print("Send MPLS tag packet with label 0 - term and IP lookup") send_packet(self, self.dev_port10, mpls_pkt) verify_packet(self, recv_pkt, self.dev_port12) self.mpls_rif_in_stats += 1 self.egress_rif_2_out_stats += 1 self.assertTrue(self._verifyStats()) def mplsEgressPhpTest(self): ''' Verify PHP pops label and forwards packet. ''' print("\nmplsEgressPhpTest()") send_pkt = simple_tcpv6_packet( eth_dst=ROUTER_MAC, ipv6_dst='300::1', ipv6_hlim=64) mpls_tag = {'label': 2000, 'ttl': 63, 'tc': 0, 's': 1} mpls_tag_list = [mpls_tag] mpls_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list, inner_frame=send_pkt['IPv6']) mpls_tag_2 = {'label': 2111, 'ttl': 63, 'tc': 0, 's': 0} mpls_tag_list_2 = [mpls_tag_2, mpls_tag] mpls_tag_2_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list_2, inner_frame=send_pkt['IPv6']) mpls_tag_3 = {'label': 2222, 'ttl': 63, 'tc': 0, 's': 0} mpls_tag_list_3 = [mpls_tag_3, mpls_tag_2, mpls_tag] mpls_tag_3_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list_3, inner_frame=send_pkt['IPv6']) recv_pkt = simple_tcpv6_packet( eth_dst='00:11:22:33:44:55', eth_src=ROUTER_MAC, ipv6_dst='300::1', ipv6_hlim=62) recv_mpls_tag_list = [mpls_tag] recv_mpls_pkt = simple_mpls_packet( eth_dst='00:11:22:33:44:55', eth_src=ROUTER_MAC, mpls_tags=recv_mpls_tag_list, inner_frame=send_pkt['IPv6']) try: print("Send MPLS tag pakcet with label 2000 - " "PHP and forward IP packet") send_packet(self, self.dev_port10, mpls_pkt) verify_packet(self, recv_pkt, self.dev_port13) self.ingress_rif_in_stats += 1 self.egress_rif_3_out_stats += 1 print("Send MPLS tag pakcet with labels - 2111, 2000 - " "PHP and forward IP packet") send_packet(self, self.dev_port10, mpls_tag_2_pkt) verify_packet(self, recv_pkt, self.dev_port13) self.ingress_rif_in_stats += 1 self.egress_rif_3_out_stats += 1 print("Send MPLS tag pakcet with labels - 2222, 2111, 2000 - " "PHP and forward IP packet") send_packet(self, self.dev_port10, mpls_tag_3_pkt) verify_packet(self, recv_pkt, self.dev_port13) self.ingress_rif_in_stats += 1 self.egress_rif_3_out_stats += 1 print("Set MPLS object label 2222 to pop only 2 labels") sai_thrift_set_inseg_entry_attribute( self.client, self.inseg_entry_2222, num_of_pop=2) print("Send MPLS tag pakcet with labels - 2222, 2111, 2000 - " "Pop 2 labels and forward MPLS with 2000") send_packet(self, self.dev_port10, mpls_tag_3_pkt) verify_packet(self, recv_mpls_pkt, self.dev_port13) self.ingress_rif_in_stats += 1 self.egress_rif_3_out_stats += 1 self.assertTrue(self._verifyStats()) finally: sai_thrift_set_inseg_entry_attribute( self.client, self.inseg_entry_2222, num_of_pop=3) def mplsEgressPhpSwapNullTest(self): ''' Verify PHP swaps label with explicit null and forwards packet. ''' print("\nmplsEgressPhpSwapNullTest()") send_pkt = simple_tcpv6_packet( eth_dst=ROUTER_MAC, ipv6_dst='400::1', ipv6_hlim=64) mpls_tag = {'label': 3000, 'ttl': 64, 'tc': 0, 's': 1} mpls_tag_list = [mpls_tag] mpls_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list, inner_frame=send_pkt['IPv6']) null_tag = {'label': 0, 'ttl': 63, 'tc': 0, 's': 1} null_mpls_tag_list = [null_tag] recv_mpls_pkt = simple_mpls_packet( eth_dst='00:11:22:33:44:55', eth_src=ROUTER_MAC, mpls_tags=null_mpls_tag_list, inner_frame=send_pkt['IPv6']) print("Send MPLS tag pakcet with label 3000 - " "PHP and forward packet with explicit NULL label") send_packet(self, self.dev_port10, mpls_pkt) verify_packet(self, recv_mpls_pkt, self.dev_port25) self.ingress_rif_in_stats += 1 self.egress_rif_4_out_stats += 1 self.assertTrue(self._verifyStats()) def mplsTransitSwapTest(self): ''' Verify MPLS label is swapped with another label or explicit null label and if only top label is swapped in Transit LSR. ''' print("\nmplsTransitSwapTest()") send_pkt = simple_tcpv6_packet( eth_dst=ROUTER_MAC, ipv6_dst='660::1', ipv6_hlim=64) mpls_tag = {'label': 5000, 'ttl': 64, 'tc': 3, 's': 1} mpls_tag_list = [mpls_tag] mpls_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list, inner_frame=send_pkt['IPv6']) mpls_tag = {'label': 0, 'ttl': 63, 'tc': 3, 's': 1} mpls_tag_list = [mpls_tag] recv_mpls_pkt = simple_mpls_packet( eth_src=ROUTER_MAC, eth_dst='00:11:22:33:44:55', mpls_tags=mpls_tag_list, inner_frame=send_pkt['IPv6']) mpls_tag = {'label': 6000, 'ttl': 63, 'tc': 3, 's': 1} new_mpls_tag_list = [mpls_tag] recv_mpls_pkt_6000 = simple_mpls_packet( eth_src=ROUTER_MAC, eth_dst='00:11:22:33:44:55', mpls_tags=new_mpls_tag_list, inner_frame=send_pkt['IPv6']) mpls_tag_1 = {'label': 5000, 'ttl': 64, 'tc': 5, 's': 0} mpls_tag_2 = {'label': 4000, 'ttl': 63, 'tc': 5, 's': 0} mpls_tag_3 = {'label': 3000, 'ttl': 63, 'tc': 5, 's': 1} mpls_3_tag_list = [mpls_tag_1, mpls_tag_2, mpls_tag_3] mpls_3_tag_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_3_tag_list, inner_frame=send_pkt['IPv6']) mpls_swap_tag = {'label': 6000, 'ttl': 63, 'tc': 5, 's': 0} recv_mpls_3_tag_list = [mpls_swap_tag, mpls_tag_2, mpls_tag_3] recv_mpls_3_tag_pkt = simple_mpls_packet( eth_src=ROUTER_MAC, eth_dst='00:11:22:33:44:55', mpls_tags=recv_mpls_3_tag_list, inner_frame=send_pkt['IPv6']) try: print("Send MPLS tag 5000 packet and swap with explicit NULL") send_packet(self, self.dev_port10, mpls_pkt) verify_packet(self, recv_mpls_pkt, self.dev_port26) self.ingress_rif_in_stats += 1 self.egress_rif_5_out_stats += 1 print("Set MPLS nexthop to swap with label 6000") sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_5000) sai_thrift_remove_neighbor_entry(self.client, self.mpls_neighbor_entry_5) sai_thrift_remove_next_hop(self.client, self.nhop_label_5) label_list = [6000] label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_5 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress('550::1'), router_interface_id=self.egress_rif_5, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_type=SAI_OUTSEG_TYPE_SWAP) self.mpls_neighbor_entry_5 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_5, ip_address=sai_ipaddress('550::1')) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_5, dst_mac_address='00:11:22:33:44:55', no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.inseg_entry_5000 = sai_thrift_inseg_entry_t(label=5000) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_5000, next_hop_id=self.nhop_label_5) self.assertEqual(status, SAI_STATUS_SUCCESS) print("Send MPLS tag 5000 packet and swap with 6000") send_packet(self, self.dev_port10, mpls_pkt) verify_packet(self, recv_mpls_pkt_6000, self.dev_port26) self.ingress_rif_in_stats += 1 self.egress_rif_5_out_stats += 1 print("Send 3-tagged packet and swap top label 5000 with 6000") send_packet(self, self.dev_port10, mpls_3_tag_pkt) verify_packet(self, recv_mpls_3_tag_pkt, self.dev_port26) self.ingress_rif_in_stats += 1 self.egress_rif_5_out_stats += 1 self.assertTrue(self._verifyStats()) finally: sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_5000) sai_thrift_remove_neighbor_entry(self.client, self.mpls_neighbor_entry_5) sai_thrift_remove_next_hop(self.client, self.nhop_label_5) label_list = [0] label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_5 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress('550::1'), router_interface_id=self.egress_rif_5, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_type=SAI_OUTSEG_TYPE_SWAP) self.mpls_neighbor_entry_5 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_5, ip_address=sai_ipaddress('550::1')) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_5, dst_mac_address='00:11:22:33:44:55', no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.inseg_entry_5000 = sai_thrift_inseg_entry_t(label=5000) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_5000, next_hop_id=self.nhop_label_5) self.assertEqual(status, SAI_STATUS_SUCCESS) def mplsTransitSwapEcmpHashTest(self): ''' Verify ECMP forwarding with MPLS Transit nhops. ''' print("\nmplsTransitSwapEcmpHashTest()") send_pkt = simple_tcpv6_packet( eth_dst=ROUTER_MAC, ipv6_dst='660::1', ipv6_hlim=64) mpls_tag = {'label': 7000, 'ttl': 64, 'tc': 3, 's': 1} mpls_tag_list = [mpls_tag] mpls_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list, inner_frame=send_pkt['IPv6']) mpls_swap_tag_7070 = {'label': 7070, 'ttl': 63, 'tc': 3, 's': 1} mpls_tag_7070 = [mpls_swap_tag_7070] mpls_swap_tag_7171 = {'label': 7171, 'ttl': 63, 'tc': 3, 's': 1} mpls_tag_7171 = [mpls_swap_tag_7171] mpls_swap_tag_7272 = {'label': 7272, 'ttl': 63, 'tc': 3, 's': 1} mpls_tag_7272 = [mpls_swap_tag_7272] recv_mpls_7070 = simple_mpls_packet( eth_src=ROUTER_MAC, eth_dst='00:11:22:33:44:55', mpls_tags=mpls_tag_7070, inner_frame=send_pkt['IPv6']) recv_mpls_7171 = simple_mpls_packet( eth_src=ROUTER_MAC, eth_dst='00:11:22:33:44:55', mpls_tags=mpls_tag_7171, inner_frame=send_pkt['IPv6']) recv_mpls_7272 = simple_mpls_packet( eth_src=ROUTER_MAC, eth_dst='00:11:22:33:44:55', mpls_tags=mpls_tag_7272, inner_frame=send_pkt['IPv6']) rif_cntr_id = 'SAI_ROUTER_INTERFACE_STAT_OUT_PACKETS' rif6_stats_start = query_counter( self, sai_thrift_get_router_interface_stats, self.egress_rif_6) rif7_stats_start = query_counter( self, sai_thrift_get_router_interface_stats, self.egress_rif_7) rif8_stats_start = query_counter( self, sai_thrift_get_router_interface_stats, self.egress_rif_8) print("ECMP - Send MPLS tag packet 7000") send_packet(self, self.dev_port10, mpls_pkt) self.ingress_rif_in_stats += 1 verify_any_packet_any_port( self, [recv_mpls_7070, recv_mpls_7171, recv_mpls_7272], [self.dev_port27, self.dev_port28, self.dev_port29]) rif6_stats_end = query_counter( self, sai_thrift_get_router_interface_stats, self.egress_rif_6) rif7_stats_end = query_counter( self, sai_thrift_get_router_interface_stats, self.egress_rif_7) rif8_stats_end = query_counter( self, sai_thrift_get_router_interface_stats, self.egress_rif_8) if (rif6_stats_end[rif_cntr_id] - rif6_stats_start[rif_cntr_id] == 1): final_egress_rif = self.egress_rif_6 if (rif7_stats_end[rif_cntr_id] - rif7_stats_start[rif_cntr_id] == 1): final_egress_rif = self.egress_rif_7 if (rif8_stats_end[rif_cntr_id] - rif8_stats_start[rif_cntr_id] == 1): final_egress_rif = self.egress_rif_8 else: final_egress_rif = 0 iter_count = 10 rif_lb_start_count = query_counter( self, sai_thrift_get_router_interface_stats, final_egress_rif) for _ in range(0, iter_count): l4_sport = random.randint(5000, 65535) l4_dport = random.randint(5000, 65535) mpls_pkt['TCP'].sport = l4_sport mpls_pkt['TCP'].dport = l4_dport send_packet(self, self.dev_port10, mpls_pkt) self.ingress_rif_in_stats += 1 time.sleep(2) rif_lb_end_count = query_counter( self, sai_thrift_get_router_interface_stats, final_egress_rif) diff = (rif_lb_end_count[rif_cntr_id] - rif_lb_start_count[rif_cntr_id]) self.assertEqual(diff, iter_count) self.assertTrue(self._verifyStats()) def mplsTransitPushTest(self): ''' Verify MPLS label is pushed on stack in transit LSR. ''' print("\nmplsTransitPushTest()") send_pkt = simple_tcpv6_packet( eth_dst=ROUTER_MAC, ipv6_dst='660::1', ipv6_hlim=64) mpls_tag = {'label': 8000, 'ttl': 64, 'tc': 3, 's': 1} mpls_tag_list = [mpls_tag] mpls_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list, inner_frame=send_pkt['IPv6']) mpls_push_tag = {'label': 9000, 'ttl': 63, 'tc': 5, 's': 0} mpls_tag_list = [mpls_push_tag, mpls_tag] recv_mpls_pkt = simple_mpls_packet( eth_dst="00:11:22:33:44:55", eth_src=ROUTER_MAC, mpls_tags=mpls_tag_list, inner_frame=send_pkt['IPv6']) send_packet(self, self.dev_port10, mpls_pkt) verify_packet(self, recv_mpls_pkt, self.dev_port30) self.ingress_rif_in_stats += 1 self.egress_rif_9_out_stats += 1 self.assertTrue(self._verifyStats()) @group("draft") class MplsIpv4Test(SaiHelper): ''' Basic IPv4 MPLS test class ''' def setUp(self): super(MplsIpv4Test, self).setUp() ttl_value = 63 exp_value = 5 ipv4_1 = '10.10.10.1' ipv4_2 = '10.10.10.2' ipv4_3 = '10.10.10.3' ipv4_4 = '20.20.20.1' ipv4_5 = '30.30.30.1' ipv4_6 = '50.50.50.1' ipv4_7 = '70.70.70.1' ipv4_8 = '71.71.71.1' ipv4_9 = '72.72.72.1' ipv4_10 = '80.80.80.1' ipv4_subnet_1 = '10.10.10.1/32' ipv4_subnet_2 = '10.10.10.2/32' ipv4_subnet_3 = '10.10.10.3/32' ipv4_subnet_4 = '20.20.20.1/24' dmac = '00:11:22:33:44:55' # Ingress LER config self.ingress_rif = self.port10_rif self.egress_rif_1 = self.port11_rif label_list = [1000] label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_1 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv4_1), router_interface_id=self.egress_rif_1, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_ttl_mode=SAI_OUTSEG_TTL_MODE_PIPE, outseg_ttl_value=ttl_value, outseg_exp_value=exp_value, outseg_type=SAI_OUTSEG_TYPE_PUSH) label_list.append(2000) label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_2 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv4_2), router_interface_id=self.egress_rif_1, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_ttl_mode=SAI_OUTSEG_TTL_MODE_PIPE, outseg_ttl_value=ttl_value, outseg_exp_value=exp_value, outseg_type=SAI_OUTSEG_TYPE_PUSH) label_list.append(3000) label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_3 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv4_3), router_interface_id=self.egress_rif_1, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_ttl_mode=SAI_OUTSEG_TTL_MODE_PIPE, outseg_ttl_value=ttl_value, outseg_exp_value=exp_value, outseg_type=SAI_OUTSEG_TYPE_PUSH) # note: neighbor with the same dst_ip as MPLS nexthop has to be created # after MPLS nexthop is created, # if not it will create second nexthop of type IP with this dst_ip # and neither of them will be functioning correctly - packets # will be gleaned to CPU self.mpls_neighbor_entry_1 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_1, ip_address=sai_ipaddress(ipv4_1)) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_1, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.mpls_neighbor_entry_2 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_1, ip_address=sai_ipaddress(ipv4_2)) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_2, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.mpls_neighbor_entry_3 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_1, ip_address=sai_ipaddress(ipv4_3)) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_3, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.mpls_encap_route_1 = sai_thrift_route_entry_t( vr_id=self.default_vrf, destination=sai_ipprefix(ipv4_subnet_1)) sai_thrift_create_route_entry( self.client, self.mpls_encap_route_1, next_hop_id=self.nhop_label_1) self.mpls_encap_route_2 = sai_thrift_route_entry_t( vr_id=self.default_vrf, destination=sai_ipprefix(ipv4_subnet_2)) sai_thrift_create_route_entry( self.client, self.mpls_encap_route_2, next_hop_id=self.nhop_label_2) self.mpls_encap_route_3 = sai_thrift_route_entry_t( vr_id=self.default_vrf, destination=sai_ipprefix(ipv4_subnet_3)) sai_thrift_create_route_entry( self.client, self.mpls_encap_route_3, next_hop_id=self.nhop_label_3) # MPLS egress LER term config self.egress_rif_2 = self.port12_rif self.vrf = sai_thrift_create_virtual_router(self.client) self.egress_rif_vrf = sai_thrift_create_router_interface( self.client, type=SAI_ROUTER_INTERFACE_TYPE_PORT, port_id=self.port24, virtual_router_id=self.default_vrf) self.mpls_rif = sai_thrift_create_router_interface( self.client, type=SAI_ROUTER_INTERFACE_TYPE_MPLS_ROUTER, virtual_router_id=self.default_vrf) self.nhop_vrf = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv4_4), router_interface_id=self.egress_rif_vrf, type=SAI_NEXT_HOP_TYPE_IP) self.neighbor_entry_vrf = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_vrf, ip_address=sai_ipaddress(ipv4_4)) sai_thrift_create_neighbor_entry( self.client, self.neighbor_entry_vrf, dst_mac_address=dmac, no_host_route=True) self.route_entry_vrf = sai_thrift_route_entry_t( vr_id=self.vrf, destination=sai_ipprefix(ipv4_subnet_4)) sai_thrift_create_route_entry( self.client, self.route_entry_vrf, next_hop_id=self.nhop_vrf) self.nhop_1 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv4_4), router_interface_id=self.egress_rif_2, type=SAI_NEXT_HOP_TYPE_IP) self.neighbor_entry_1 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_2, ip_address=sai_ipaddress(ipv4_4)) sai_thrift_create_neighbor_entry( self.client, self.neighbor_entry_1, dst_mac_address=dmac, no_host_route=True) self.route_entry_1 = sai_thrift_route_entry_t( vr_id=self.default_vrf, destination=sai_ipprefix(ipv4_subnet_4)) sai_thrift_create_route_entry( self.client, self.route_entry_1, next_hop_id=self.nhop_1) self.inseg_entry_1000 = sai_thrift_inseg_entry_t(label=1000) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_1000, num_of_pop=1, pop_ttl_mode=SAI_INSEG_ENTRY_POP_TTL_MODE_PIPE, next_hop_id=self.mpls_rif) self.assertEqual(status, SAI_STATUS_SUCCESS) # MPLS Egress LER Null Term configs self.inseg_entry_0 = sai_thrift_inseg_entry_t(label=0) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_0, num_of_pop=1, pop_ttl_mode=SAI_INSEG_ENTRY_POP_TTL_MODE_PIPE, next_hop_id=self.mpls_rif) self.assertEqual(status, SAI_STATUS_SUCCESS) # MPLS Egress PHP configs self.egress_rif_3 = self.port13_rif self.nhop_2 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv4_4), router_interface_id=self.egress_rif_3, type=SAI_NEXT_HOP_TYPE_IP) self.neighbor_entry_2 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_3, ip_address=sai_ipaddress(ipv4_4)) status = sai_thrift_create_neighbor_entry( self.client, self.neighbor_entry_2, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.inseg_entry_2000 = sai_thrift_inseg_entry_t(label=2000) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_2000, num_of_pop=1, pop_ttl_mode=SAI_INSEG_ENTRY_POP_TTL_MODE_UNIFORM, next_hop_id=self.nhop_2) self.assertEqual(status, SAI_STATUS_SUCCESS) self.inseg_entry_2111 = sai_thrift_inseg_entry_t(label=2111) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_2111, num_of_pop=2, pop_ttl_mode=SAI_INSEG_ENTRY_POP_TTL_MODE_UNIFORM, next_hop_id=self.nhop_2) self.assertEqual(status, SAI_STATUS_SUCCESS) self.inseg_entry_2222 = sai_thrift_inseg_entry_t(label=2222) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_2222, num_of_pop=3, pop_ttl_mode=SAI_INSEG_ENTRY_POP_TTL_MODE_UNIFORM, next_hop_id=self.nhop_2) self.assertEqual(status, SAI_STATUS_SUCCESS) # MPLS Egress PHP Swap Null configs self.egress_rif_4 = sai_thrift_create_router_interface( self.client, type=SAI_ROUTER_INTERFACE_TYPE_PORT, port_id=self.port25, virtual_router_id=self.default_vrf) label_list = [0] label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_4 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv4_5), router_interface_id=self.egress_rif_4, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_ttl_mode=SAI_OUTSEG_TTL_MODE_PIPE, outseg_ttl_value=ttl_value, outseg_type=SAI_OUTSEG_TYPE_SWAP) self.mpls_neighbor_entry_4 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_4, ip_address=sai_ipaddress(ipv4_5)) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_4, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.inseg_entry_3000 = sai_thrift_inseg_entry_t(label=3000) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_3000, next_hop_id=self.nhop_label_4) self.assertEqual(status, SAI_STATUS_SUCCESS) # MPLS Transit Swap configs self.egress_rif_5 = sai_thrift_create_router_interface( self.client, type=SAI_ROUTER_INTERFACE_TYPE_PORT, port_id=self.port26, virtual_router_id=self.default_vrf) label_list = [0] label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_5 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv4_6), router_interface_id=self.egress_rif_5, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_type=SAI_OUTSEG_TYPE_SWAP) self.mpls_neighbor_entry_5 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_5, ip_address=sai_ipaddress(ipv4_6)) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_5, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.inseg_entry_5000 = sai_thrift_inseg_entry_t(label=5000) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_5000, next_hop_id=self.nhop_label_5) self.assertEqual(status, SAI_STATUS_SUCCESS) # MLPS ECMP Swap configs self.egress_rif_6 = sai_thrift_create_router_interface( self.client, type=SAI_ROUTER_INTERFACE_TYPE_PORT, port_id=self.port27, virtual_router_id=self.default_vrf) self.egress_rif_7 = sai_thrift_create_router_interface( self.client, type=SAI_ROUTER_INTERFACE_TYPE_PORT, port_id=self.port28, virtual_router_id=self.default_vrf) self.egress_rif_8 = sai_thrift_create_router_interface( self.client, type=SAI_ROUTER_INTERFACE_TYPE_PORT, port_id=self.port29, virtual_router_id=self.default_vrf) label_list = [7070] label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_6 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv4_7), router_interface_id=self.egress_rif_6, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_type=SAI_OUTSEG_TYPE_SWAP) label_list = [7171] label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_7 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv4_8), router_interface_id=self.egress_rif_7, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_type=SAI_OUTSEG_TYPE_SWAP) label_list = [7272] label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_8 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv4_9), router_interface_id=self.egress_rif_8, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_type=SAI_OUTSEG_TYPE_SWAP) self.ecmp_group = sai_thrift_create_next_hop_group( self.client, type=SAI_NEXT_HOP_GROUP_TYPE_ECMP) self.ecmp_mbr1 = sai_thrift_create_next_hop_group_member( self.client, next_hop_group_id=self.ecmp_group, next_hop_id=self.nhop_label_6) self.ecmp_mbr2 = sai_thrift_create_next_hop_group_member( self.client, next_hop_group_id=self.ecmp_group, next_hop_id=self.nhop_label_7) self.ecmp_mbr3 = sai_thrift_create_next_hop_group_member( self.client, next_hop_group_id=self.ecmp_group, next_hop_id=self.nhop_label_8) self.mpls_neighbor_entry_6 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_6, ip_address=sai_ipaddress(ipv4_7)) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_6, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.mpls_neighbor_entry_7 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_7, ip_address=sai_ipaddress(ipv4_8)) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_7, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.mpls_neighbor_entry_8 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_8, ip_address=sai_ipaddress(ipv4_9)) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_8, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.inseg_entry_7000 = sai_thrift_inseg_entry_t(label=7000) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_7000, next_hop_id=self.ecmp_group) self.assertEqual(status, SAI_STATUS_SUCCESS) # MPLS Transit Push configs self.egress_rif_9 = sai_thrift_create_router_interface( self.client, type=SAI_ROUTER_INTERFACE_TYPE_PORT, port_id=self.port30, virtual_router_id=self.default_vrf) label_list = [9000] label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_9 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv4_10), router_interface_id=self.egress_rif_9, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_ttl_mode=SAI_OUTSEG_TTL_MODE_PIPE, outseg_ttl_value=ttl_value, outseg_exp_value=exp_value, outseg_type=SAI_OUTSEG_TYPE_PUSH) self.mpls_neighbor_entry_9 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_9, ip_address=sai_ipaddress(ipv4_10)) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_9, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.inseg_entry_8000 = sai_thrift_inseg_entry_t(label=8000) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_8000, next_hop_id=self.nhop_label_9) self.assertEqual(status, SAI_STATUS_SUCCESS) # packet counters settings for rif in [self.ingress_rif, self.egress_rif_1, self.egress_rif_2, self.egress_rif_3, self.egress_rif_4, self.egress_rif_5, self.egress_rif_9, self.egress_rif_vrf, self.mpls_rif]: status = clear_counter( self, sai_thrift_clear_router_interface_stats, rif) self.assertEqual(status, SAI_STATUS_SUCCESS) self.ingress_rif_in_stats = 0 # port 10 self.ingress_rif_out_stats = 0 self.egress_rif_1_in_stats = 0 # port 11 self.egress_rif_1_out_stats = 0 self.egress_rif_2_in_stats = 0 # port 12 self.egress_rif_2_out_stats = 0 self.egress_rif_3_in_stats = 0 # port 13 self.egress_rif_3_out_stats = 0 self.egress_rif_4_in_stats = 0 # port 25 self.egress_rif_4_out_stats = 0 self.egress_rif_5_in_stats = 0 # port 26 self.egress_rif_5_out_stats = 0 self.egress_rif_vrf_in_stats = 0 # port 24 self.egress_rif_vrf_out_stats = 0 self.egress_rif_9_in_stats = 0 # port 30 self.egress_rif_9_out_stats = 0 self.mpls_rif_in_stats = 0 self.mpls_rif_out_stats = 0 def runTest(self): self.mplsIngressLERTest() self.mplsEgressLERTermTest() self.mplsEgressLERTermUpdateMplsRifVrfTest() self.mplsEgressLERNullTermTest() self.mplsEgressPhpTest() self.mplsEgressPhpSwapNullTest() self.mplsTransitSwapTest() self.mplsTransitSwapEcmpHashTest() self.mplsTransitPushTest() def tearDown(self): sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_8000) sai_thrift_remove_neighbor_entry( self.client, self.mpls_neighbor_entry_9) sai_thrift_remove_next_hop(self.client, self.nhop_label_9) sai_thrift_remove_router_interface(self.client, self.egress_rif_9) sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_7000) sai_thrift_remove_neighbor_entry(self.client, self.mpls_neighbor_entry_8) sai_thrift_remove_neighbor_entry(self.client, self.mpls_neighbor_entry_7) sai_thrift_remove_neighbor_entry(self.client, self.mpls_neighbor_entry_6) sai_thrift_remove_next_hop_group_member(self.client, self.ecmp_mbr3) sai_thrift_remove_next_hop_group_member(self.client, self.ecmp_mbr2) sai_thrift_remove_next_hop_group_member(self.client, self.ecmp_mbr1) sai_thrift_remove_next_hop_group(self.client, self.ecmp_group) sai_thrift_remove_next_hop(self.client, self.nhop_label_8) sai_thrift_remove_next_hop(self.client, self.nhop_label_7) sai_thrift_remove_next_hop(self.client, self.nhop_label_6) sai_thrift_remove_router_interface(self.client, self.egress_rif_8) sai_thrift_remove_router_interface(self.client, self.egress_rif_7) sai_thrift_remove_router_interface(self.client, self.egress_rif_6) sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_5000) sai_thrift_remove_neighbor_entry(self.client, self.mpls_neighbor_entry_5) sai_thrift_remove_next_hop(self.client, self.nhop_label_5) sai_thrift_remove_router_interface(self.client, self.egress_rif_5) sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_3000) sai_thrift_remove_neighbor_entry(self.client, self.mpls_neighbor_entry_4) sai_thrift_remove_next_hop(self.client, self.nhop_label_4) sai_thrift_remove_router_interface(self.client, self.egress_rif_4) sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_2222) sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_2111) sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_2000) sai_thrift_remove_neighbor_entry(self.client, self.neighbor_entry_2) sai_thrift_remove_next_hop(self.client, self.nhop_2) sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_0) sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_1000) sai_thrift_remove_route_entry(self.client, self.route_entry_vrf) sai_thrift_remove_neighbor_entry(self.client, self.neighbor_entry_vrf) sai_thrift_remove_next_hop(self.client, self.nhop_vrf) sai_thrift_remove_router_interface(self.client, self.egress_rif_vrf) sai_thrift_remove_virtual_router(self.client, self.vrf) sai_thrift_remove_route_entry(self.client, self.route_entry_1) sai_thrift_remove_neighbor_entry(self.client, self.neighbor_entry_1) sai_thrift_remove_next_hop(self.client, self.nhop_1) sai_thrift_remove_router_interface(self.client, self.mpls_rif) sai_thrift_remove_route_entry(self.client, self.mpls_encap_route_1) sai_thrift_remove_route_entry(self.client, self.mpls_encap_route_2) sai_thrift_remove_route_entry(self.client, self.mpls_encap_route_3) sai_thrift_remove_neighbor_entry(self.client, self.mpls_neighbor_entry_1) sai_thrift_remove_neighbor_entry(self.client, self.mpls_neighbor_entry_2) sai_thrift_remove_neighbor_entry(self.client, self.mpls_neighbor_entry_3) sai_thrift_remove_next_hop(self.client, self.nhop_label_1) sai_thrift_remove_next_hop(self.client, self.nhop_label_2) sai_thrift_remove_next_hop(self.client, self.nhop_label_3) super(MplsIpv4Test, self).tearDown() def _verifyStats(self): ''' Additional helper function for statistics verification Return: bool: True if statistics are correct, otherwise False ''' for rif, in_cnt, out_cnt in zip( [self.ingress_rif, self.egress_rif_1, self.egress_rif_2, self.egress_rif_3, self.egress_rif_4, self.egress_rif_5, self.egress_rif_9, self.egress_rif_vrf, self.mpls_rif], [self.ingress_rif_in_stats, self.egress_rif_1_in_stats, self.egress_rif_2_in_stats, self.egress_rif_3_in_stats, self.egress_rif_4_in_stats, self.egress_rif_5_in_stats, self.egress_rif_9_in_stats, self.egress_rif_vrf_in_stats, self.mpls_rif_in_stats], [self.ingress_rif_out_stats, self.egress_rif_1_out_stats, self.egress_rif_2_out_stats, self.egress_rif_3_out_stats, self.egress_rif_4_out_stats, self.egress_rif_5_out_stats, self.egress_rif_9_out_stats, self.egress_rif_vrf_out_stats, self.mpls_rif_out_stats]): stats = query_counter( self, sai_thrift_get_router_interface_stats, rif) if in_cnt != stats['SAI_ROUTER_INTERFACE_STAT_IN_PACKETS'] or \ out_cnt != stats['SAI_ROUTER_INTERFACE_STAT_OUT_PACKETS']: print("Counters doesn't match!") return False print("\tStatistics correct") return True def mplsIngressLERTest(self): ''' Verify if MPLS labels are added to packet in ingress LER. ''' print("\nmplsIngressLERTest()") send_pkt_1 = simple_tcp_packet( eth_dst=ROUTER_MAC, ip_dst='10.10.10.1', ip_ttl=64) send_pkt_2 = simple_tcp_packet( eth_dst=ROUTER_MAC, ip_dst='10.10.10.2', ip_ttl=64) send_pkt_3 = simple_tcp_packet( eth_dst=ROUTER_MAC, ip_dst='10.10.10.3', ip_ttl=64) exp_pkt_1 = simple_tcp_packet( eth_dst='00:11:22:33:44:55', eth_src=ROUTER_MAC, ip_dst='10.10.10.1', ip_ttl=63) exp_pkt_2 = simple_tcp_packet( eth_dst='00:11:22:33:44:55', eth_src=ROUTER_MAC, ip_dst='10.10.10.2', ip_ttl=63) exp_pkt_3 = simple_tcp_packet( eth_dst='00:11:22:33:44:55', eth_src=ROUTER_MAC, ip_dst='10.10.10.3', ip_ttl=63) mpls_tag_list = [] mpls_tag_1 = {'label': 1000, 'ttl': 63, 'tc': 5, 's': 0} mpls_tag_2 = {'label': 2000, 'ttl': 63, 'tc': 5, 's': 0} mpls_tag_3 = {'label': 3000, 'ttl': 63, 'tc': 5, 's': 0} mpls_tag_1['s'] = 1 mpls_tag_list.append(mpls_tag_1) mpls_pkt_label_1 = simple_mpls_packet( eth_src=ROUTER_MAC, eth_dst='00:11:22:33:44:55', mpls_tags=mpls_tag_list, inner_frame=exp_pkt_1['IP']) mpls_tag_1['s'] = 0 mpls_tag_2['s'] = 1 del mpls_tag_list[:] mpls_tag_list.append(mpls_tag_1) mpls_tag_list.append(mpls_tag_2) mpls_pkt_label_2 = simple_mpls_packet( eth_src=ROUTER_MAC, eth_dst='00:11:22:33:44:55', mpls_tags=mpls_tag_list, inner_frame=exp_pkt_2['IP']) mpls_tag_1['s'] = 0 mpls_tag_2['s'] = 0 mpls_tag_3['s'] = 1 del mpls_tag_list[:] mpls_tag_list.append(mpls_tag_1) mpls_tag_list.append(mpls_tag_2) mpls_tag_list.append(mpls_tag_3) mpls_pkt_label_3 = simple_mpls_packet( eth_src=ROUTER_MAC, eth_dst='00:11:22:33:44:55', mpls_tags=mpls_tag_list, inner_frame=exp_pkt_3['IP']) print("Send ip packet to add one MPLS label 1000") send_packet(self, self.dev_port10, send_pkt_1) verify_packet(self, mpls_pkt_label_1, self.dev_port11) self.ingress_rif_in_stats += 1 self.egress_rif_1_out_stats += 1 print("Send ip packet to add two MPLS label stack - 1000, 2000") send_packet(self, self.dev_port10, send_pkt_2) verify_packet(self, mpls_pkt_label_2, self.dev_port11) self.ingress_rif_in_stats += 1 self.egress_rif_1_out_stats += 1 print("Send ip packet to add three MPLS label stack - " "1000, 2000, 3000") send_packet(self, self.dev_port10, send_pkt_3) verify_packet(self, mpls_pkt_label_3, self.dev_port11) self.ingress_rif_in_stats += 1 self.egress_rif_1_out_stats += 1 self.assertTrue(self._verifyStats()) def mplsEgressLERTermTest(self): ''' Verify if MPLS label is popped in Egress LER and packet is forwarded based on IP lookup. ''' print("\nmplsIngressLERTermTest()") send_pkt = simple_tcp_packet( eth_dst=ROUTER_MAC, ip_dst='20.20.20.1', ip_ttl=64) mpls_tag = {'label': 1000, 'ttl': 63, 'tc': 0, 's': 1} mpls_tag_list = [mpls_tag] mpls_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list, inner_frame=send_pkt['IP']) recv_pkt = simple_tcp_packet( eth_dst='00:11:22:33:44:55', eth_src=ROUTER_MAC, ip_dst='20.20.20.1', ip_ttl=63) print("Send MPLS tag packet with label 1000 - term and IP lookup") send_packet(self, self.dev_port10, mpls_pkt) verify_packet(self, recv_pkt, self.dev_port12) self.mpls_rif_in_stats += 1 self.egress_rif_2_out_stats += 1 self.assertTrue(self._verifyStats()) def mplsEgressLERTermUpdateMplsRifVrfTest(self): ''' Verify if MPLS label is popped in Egress LER and packet is forwarded based on IP lookup afert changing VRF on MPLS RIF. ''' print("\nmplsIngressLERTermUpdateMplsRifVrfTest()") send_pkt = simple_tcp_packet( eth_dst=ROUTER_MAC, ip_dst='20.20.20.1', ip_ttl=64) mpls_tag = {'label': 1000, 'ttl': 63, 'tc': 0, 's': 1} mpls_tag_list = [mpls_tag] mpls_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list, inner_frame=send_pkt['IP']) recv_pkt = simple_tcp_packet( eth_dst='00:11:22:33:44:55', eth_src=ROUTER_MAC, ip_dst='20.20.20.1', ip_ttl=63) try: print("Send MPLS tag packet with label 1000 - term and IP lookup" "forwarded to port", self.dev_port12) send_packet(self, self.dev_port10, mpls_pkt) verify_packet(self, recv_pkt, self.dev_port12) self.egress_rif_2_out_stats += 1 print("Remove existing MPLS RIF and create new with different VRF") sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_0) sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_1000) sai_thrift_remove_router_interface(self.client, self.mpls_rif) self.mpls_rif = sai_thrift_create_router_interface( self.client, type=SAI_ROUTER_INTERFACE_TYPE_MPLS_ROUTER, virtual_router_id=self.vrf) self.inseg_entry_1000 = sai_thrift_inseg_entry_t(label=1000) sai_thrift_create_inseg_entry( self.client, self.inseg_entry_1000, num_of_pop=1, pop_ttl_mode=SAI_INSEG_ENTRY_POP_TTL_MODE_PIPE, next_hop_id=self.mpls_rif) self.inseg_entry_0 = sai_thrift_inseg_entry_t(label=0) sai_thrift_create_inseg_entry( self.client, self.inseg_entry_0, num_of_pop=1, pop_ttl_mode=SAI_INSEG_ENTRY_POP_TTL_MODE_PIPE, next_hop_id=self.mpls_rif) print("Send MPLS tag packet with label 1000 - term and IP lookup" "forwarded to port", self.dev_port24) send_packet(self, self.dev_port10, mpls_pkt) verify_packet(self, recv_pkt, self.dev_port24) self.mpls_rif_in_stats = 1 self.egress_rif_vrf_out_stats += 1 self.assertTrue(self._verifyStats()) finally: sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_0) sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_1000) sai_thrift_remove_router_interface(self.client, self.mpls_rif) self.mpls_rif = sai_thrift_create_router_interface( self.client, type=SAI_ROUTER_INTERFACE_TYPE_MPLS_ROUTER, virtual_router_id=self.default_vrf) self.inseg_entry_1000 = sai_thrift_inseg_entry_t(label=1000) sai_thrift_create_inseg_entry( self.client, self.inseg_entry_1000, num_of_pop=1, pop_ttl_mode=SAI_INSEG_ENTRY_POP_TTL_MODE_PIPE, next_hop_id=self.mpls_rif) self.inseg_entry_0 = sai_thrift_inseg_entry_t(label=0) sai_thrift_create_inseg_entry( self.client, self.inseg_entry_0, num_of_pop=1, pop_ttl_mode=SAI_INSEG_ENTRY_POP_TTL_MODE_PIPE, next_hop_id=self.mpls_rif) def mplsEgressLERNullTermTest(self): ''' Verify if MPLS null label is popped in Egress LER and packet is forwarded based on IP lookup. ''' print("\nmplsIngressLERNullTermTest()") send_pkt = simple_tcp_packet( eth_dst=ROUTER_MAC, ip_dst='20.20.20.1', ip_ttl=64) mpls_tag = {'label': 0, 'ttl': 63, 'tc': 0, 's': 1} mpls_tag_list = [mpls_tag] mpls_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list, inner_frame=send_pkt['IP']) recv_pkt = simple_tcp_packet( eth_dst='00:11:22:33:44:55', eth_src=ROUTER_MAC, ip_dst='20.20.20.1', ip_ttl=63) print("Send MPLS tag packet with label 0 - term and IP lookup") send_packet(self, self.dev_port10, mpls_pkt) verify_packet(self, recv_pkt, self.dev_port12) self.mpls_rif_in_stats = 1 self.egress_rif_2_out_stats += 1 self.assertTrue(self._verifyStats()) def mplsEgressPhpTest(self): ''' Verify PHP pops label and forwards packet. ''' print("\nmplsEgressPhpTest()") send_pkt = simple_tcp_packet( eth_dst=ROUTER_MAC, ip_dst='30.30.30.1', ip_ttl=64) mpls_tag = {'label': 2000, 'ttl': 63, 'tc': 0, 's': 1} mpls_tag_list = [mpls_tag] mpls_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list, inner_frame=send_pkt['IP']) mpls_tag_2 = {'label': 2111, 'ttl': 63, 'tc': 0, 's': 0} mpls_tag_list_2 = [mpls_tag_2, mpls_tag] mpls_tag_2_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list_2, inner_frame=send_pkt['IP']) mpls_tag_3 = {'label': 2222, 'ttl': 63, 'tc': 0, 's': 0} mpls_tag_list_3 = [mpls_tag_3, mpls_tag_2, mpls_tag] mpls_tag_3_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list_3, inner_frame=send_pkt['IP']) recv_pkt = simple_tcp_packet( eth_dst='00:11:22:33:44:55', eth_src=ROUTER_MAC, ip_dst='30.30.30.1', ip_ttl=62) recv_mpls_tag_list = [mpls_tag] recv_mpls_pkt = simple_mpls_packet( eth_dst='00:11:22:33:44:55', eth_src=ROUTER_MAC, mpls_tags=recv_mpls_tag_list, inner_frame=send_pkt['IP']) try: print("Send MPLS tag pakcet with label 2000 - " "PHP and forward IP packet") send_packet(self, self.dev_port10, mpls_pkt) verify_packet(self, recv_pkt, self.dev_port13) self.ingress_rif_in_stats += 1 self.egress_rif_3_out_stats += 1 print("Send MPLS tag pakcet with labels - 2111, 2000 - " "PHP and forward IP packet") send_packet(self, self.dev_port10, mpls_tag_2_pkt) verify_packet(self, recv_pkt, self.dev_port13) self.ingress_rif_in_stats += 1 self.egress_rif_3_out_stats += 1 print("Send MPLS tag pakcet with labels - 2222, 2111, 2000 - " "PHP and forward IP packet") send_packet(self, self.dev_port10, mpls_tag_3_pkt) verify_packet(self, recv_pkt, self.dev_port13) self.ingress_rif_in_stats += 1 self.egress_rif_3_out_stats += 1 print("Set MPLS object label 2222 to pop only 2 labels") sai_thrift_set_inseg_entry_attribute( self.client, self.inseg_entry_2222, num_of_pop=2) print("Send MPLS tag pakcet with labels - 2222, 2111, 2000 - " "Pop 2 labels and forward MPLS with 2000") send_packet(self, self.dev_port10, mpls_tag_3_pkt) verify_packet(self, recv_mpls_pkt, self.dev_port13) self.ingress_rif_in_stats += 1 self.egress_rif_3_out_stats += 1 self.assertTrue(self._verifyStats()) finally: sai_thrift_set_inseg_entry_attribute( self.client, self.inseg_entry_2222, num_of_pop=3) def mplsEgressPhpSwapNullTest(self): ''' Verify PHP swaps label with explicit null and forwards packet. ''' print("\nmplsEgressPhpSwapNullTest()") send_pkt = simple_tcp_packet( eth_dst=ROUTER_MAC, ip_dst='40.40.40.1', ip_ttl=64) mpls_tag = {'label': 3000, 'ttl': 64, 'tc': 0, 's': 1} mpls_tag_list = [mpls_tag] mpls_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list, inner_frame=send_pkt['IP']) null_tag = {'label': 0, 'ttl': 63, 'tc': 0, 's': 1} null_mpls_tag_list = [null_tag] recv_mpls_pkt = simple_mpls_packet( eth_dst='00:11:22:33:44:55', eth_src=ROUTER_MAC, mpls_tags=null_mpls_tag_list, inner_frame=send_pkt['IP']) print("Send MPLS tag pakcet with label 3000 - " "PHP and forward packet with explicit NULL label") send_packet(self, self.dev_port10, mpls_pkt) verify_packet(self, recv_mpls_pkt, self.dev_port25) self.ingress_rif_in_stats += 1 self.egress_rif_4_out_stats += 1 self.assertTrue(self._verifyStats()) def mplsTransitSwapTest(self): ''' Verify MPLS label is swapped with another label or explicit null label and if only top label is swapped in Transit LSR. ''' print("\nmplsTransitSwapTest()") send_pkt = simple_tcp_packet( eth_dst=ROUTER_MAC, ip_dst='60.60.60.1', ip_ttl=64) mpls_tag = {'label': 5000, 'ttl': 64, 'tc': 3, 's': 1} mpls_tag_list = [mpls_tag] mpls_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list, inner_frame=send_pkt['IP']) mpls_tag = {'label': 0, 'ttl': 63, 'tc': 3, 's': 1} mpls_tag_list = [mpls_tag] recv_mpls_pkt = simple_mpls_packet( eth_src=ROUTER_MAC, eth_dst='00:11:22:33:44:55', mpls_tags=mpls_tag_list, inner_frame=send_pkt['IP']) mpls_tag = {'label': 6000, 'ttl': 63, 'tc': 3, 's': 1} new_mpls_tag_list = [mpls_tag] recv_mpls_pkt_6000 = simple_mpls_packet( eth_src=ROUTER_MAC, eth_dst='00:11:22:33:44:55', mpls_tags=new_mpls_tag_list, inner_frame=send_pkt['IP']) mpls_tag_1 = {'label': 5000, 'ttl': 64, 'tc': 5, 's': 0} mpls_tag_2 = {'label': 4000, 'ttl': 63, 'tc': 5, 's': 0} mpls_tag_3 = {'label': 3000, 'ttl': 63, 'tc': 5, 's': 1} mpls_3_tag_list = [mpls_tag_1, mpls_tag_2, mpls_tag_3] mpls_3_tag_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_3_tag_list, inner_frame=send_pkt['IP']) mpls_swap_tag = {'label': 6000, 'ttl': 63, 'tc': 5, 's': 0} recv_mpls_3_tag_list = [mpls_swap_tag, mpls_tag_2, mpls_tag_3] recv_mpls_3_tag_pkt = simple_mpls_packet( eth_src=ROUTER_MAC, eth_dst='00:11:22:33:44:55', mpls_tags=recv_mpls_3_tag_list, inner_frame=send_pkt['IP']) try: print("Send MPLS tag 5000 packet and swap with explicit NULL") send_packet(self, self.dev_port10, mpls_pkt) verify_packet(self, recv_mpls_pkt, self.dev_port26) self.ingress_rif_in_stats += 1 self.egress_rif_5_out_stats += 1 print("Set MPLS nexthop to swap with label 6000") sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_5000) sai_thrift_remove_neighbor_entry(self.client, self.mpls_neighbor_entry_5) sai_thrift_remove_next_hop(self.client, self.nhop_label_5) label_list = [6000] label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_5 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress('50.50.50.1'), router_interface_id=self.egress_rif_5, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_type=SAI_OUTSEG_TYPE_SWAP) self.mpls_neighbor_entry_5 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_5, ip_address=sai_ipaddress('50.50.50.1')) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_5, dst_mac_address='00:11:22:33:44:55', no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.inseg_entry_5000 = sai_thrift_inseg_entry_t(label=5000) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_5000, next_hop_id=self.nhop_label_5) self.assertEqual(status, SAI_STATUS_SUCCESS) print("Send MPLS tag 5000 packet and swap with 6000") send_packet(self, self.dev_port10, mpls_pkt) verify_packet(self, recv_mpls_pkt_6000, self.dev_port26) self.ingress_rif_in_stats += 1 self.egress_rif_5_out_stats += 1 print("Send 3-tagged packet and swap top label 5000 with 6000") send_packet(self, self.dev_port10, mpls_3_tag_pkt) verify_packet(self, recv_mpls_3_tag_pkt, self.dev_port26) self.ingress_rif_in_stats += 1 self.egress_rif_5_out_stats += 1 self.assertTrue(self._verifyStats()) finally: sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_5000) sai_thrift_remove_neighbor_entry(self.client, self.mpls_neighbor_entry_5) sai_thrift_remove_next_hop(self.client, self.nhop_label_5) label_list = [0] label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_5 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress('50.50.50.1'), router_interface_id=self.egress_rif_5, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_type=SAI_OUTSEG_TYPE_SWAP) self.mpls_neighbor_entry_5 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_5, ip_address=sai_ipaddress('50.50.50.1')) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_5, dst_mac_address='00:11:22:33:44:55', no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.inseg_entry_5000 = sai_thrift_inseg_entry_t(label=5000) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_5000, next_hop_id=self.nhop_label_5) self.assertEqual(status, SAI_STATUS_SUCCESS) def mplsTransitSwapEcmpHashTest(self): ''' Verify ECMP group with MPLS Transit nhops. ''' print("\nmplsTransitSwapEcmpHashTest()") send_pkt = simple_tcp_packet( eth_dst=ROUTER_MAC, ip_dst='60.60.60.1', ip_ttl=64) mpls_tag = {'label': 7000, 'ttl': 64, 'tc': 3, 's': 1} mpls_tag_list = [mpls_tag] mpls_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list, inner_frame=send_pkt['IP']) mpls_swap_tag_7070 = {'label': 7070, 'ttl': 63, 'tc': 3, 's': 1} mpls_tag_7070 = [mpls_swap_tag_7070] mpls_swap_tag_7171 = {'label': 7171, 'ttl': 63, 'tc': 3, 's': 1} mpls_tag_7171 = [mpls_swap_tag_7171] mpls_swap_tag_7272 = {'label': 7272, 'ttl': 63, 'tc': 3, 's': 1} mpls_tag_7272 = [mpls_swap_tag_7272] recv_mpls_7070 = simple_mpls_packet( eth_src=ROUTER_MAC, eth_dst='00:11:22:33:44:55', mpls_tags=mpls_tag_7070, inner_frame=send_pkt['IP']) recv_mpls_7171 = simple_mpls_packet( eth_src=ROUTER_MAC, eth_dst='00:11:22:33:44:55', mpls_tags=mpls_tag_7171, inner_frame=send_pkt['IP']) recv_mpls_7272 = simple_mpls_packet( eth_src=ROUTER_MAC, eth_dst='00:11:22:33:44:55', mpls_tags=mpls_tag_7272, inner_frame=send_pkt['IP']) rif_cntr_id = 'SAI_ROUTER_INTERFACE_STAT_OUT_PACKETS' rif6_stats_start = query_counter( self, sai_thrift_get_router_interface_stats, self.egress_rif_6) rif7_stats_start = query_counter( self, sai_thrift_get_router_interface_stats, self.egress_rif_7) rif8_stats_start = query_counter( self, sai_thrift_get_router_interface_stats, self.egress_rif_8) print("ECMP - Send MPLS tag packet 7000") send_packet(self, self.dev_port10, mpls_pkt) self.ingress_rif_in_stats += 1 verify_any_packet_any_port( self, [recv_mpls_7070, recv_mpls_7171, recv_mpls_7272], [self.dev_port27, self.dev_port28, self.dev_port29]) rif6_stats_end = query_counter( self, sai_thrift_get_router_interface_stats, self.egress_rif_6) rif7_stats_end = query_counter( self, sai_thrift_get_router_interface_stats, self.egress_rif_7) rif8_stats_end = query_counter( self, sai_thrift_get_router_interface_stats, self.egress_rif_8) if (rif6_stats_end[rif_cntr_id] - rif6_stats_start[rif_cntr_id] == 1): final_egress_rif = self.egress_rif_6 if (rif7_stats_end[rif_cntr_id] - rif7_stats_start[rif_cntr_id] == 1): final_egress_rif = self.egress_rif_7 if (rif8_stats_end[rif_cntr_id] - rif8_stats_start[rif_cntr_id] == 1): final_egress_rif = self.egress_rif_8 else: final_egress_rif = 0 iter_count = 10 rif_lb_start_count = query_counter( self, sai_thrift_get_router_interface_stats, final_egress_rif) for _ in range(0, iter_count): l4_sport = random.randint(5000, 65535) l4_dport = random.randint(5000, 65535) mpls_pkt['TCP'].sport = l4_sport mpls_pkt['TCP'].dport = l4_dport send_packet(self, self.dev_port10, mpls_pkt) self.ingress_rif_in_stats += 1 time.sleep(2) rif_lb_end_count = query_counter( self, sai_thrift_get_router_interface_stats, final_egress_rif) diff = (rif_lb_end_count[rif_cntr_id] - rif_lb_start_count[rif_cntr_id]) self.assertEqual(diff, iter_count) self._verifyStats() def mplsTransitPushTest(self): ''' Verify MPLS label is pushed on stack in transit LSR. ''' print("\nmplsTransitPushTest()") send_pkt = simple_tcp_packet( eth_dst=ROUTER_MAC, ip_dst='60.60.60.10', ip_ttl=64) mpls_tag = {'label': 8000, 'ttl': 64, 'tc': 3, 's': 1} mpls_tag_list = [mpls_tag] mpls_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list, inner_frame=send_pkt['IP']) mpls_push_tag = {'label': 9000, 'ttl': 63, 'tc': 5, 's': 0} mpls_tag_list = [mpls_push_tag, mpls_tag] recv_mpls_pkt = simple_mpls_packet( eth_dst="00:11:22:33:44:55", eth_src=ROUTER_MAC, mpls_tags=mpls_tag_list, inner_frame=send_pkt['IP']) send_packet(self, self.dev_port10, mpls_pkt) verify_packet(self, recv_mpls_pkt, self.dev_port30) self.ingress_rif_in_stats += 1 self.egress_rif_9_out_stats += 1 self.assertTrue(self._verifyStats()) @group("draft") class MplsCreationTest(SaiHelper): ''' Basic MPLS creation test class ''' def runTest(self): self.mplsCreateAndRemoveTest() self.mplsAttributesTest() self.mplsCreateTheSameEntryTest() def mplsCreateAndRemoveTest(self): ''' Test creates and removes several MPLS entries in loop. ''' print("\nmplsCreateAndRemoveTest()") for _ in range(0, 5): inseg_entry = sai_thrift_inseg_entry_t(label=200) status = sai_thrift_create_inseg_entry(self.client, inseg_entry) self.assertEqual(status, SAI_STATUS_SUCCESS) status = sai_thrift_remove_inseg_entry(self.client, inseg_entry) self.assertEqual(status, SAI_STATUS_SUCCESS) def mplsAttributesTest(self): ''' Verify set and get operations on MPLS attributes. ''' print("\nmplsAttributesTest()") num_of_pop = 2 packet_action = SAI_PACKET_ACTION_DROP next_hop_id = self.port10_rif inseg_entry = sai_thrift_inseg_entry_t(label=200) status = sai_thrift_create_inseg_entry( self.client, inseg_entry, num_of_pop=num_of_pop, pop_ttl_mode=SAI_INSEG_ENTRY_POP_TTL_MODE_PIPE, packet_action=packet_action, next_hop_id=next_hop_id) self.assertEqual(status, SAI_STATUS_SUCCESS) try: attr = sai_thrift_get_inseg_entry_attribute( self.client, inseg_entry, packet_action=True) self.assertEqual(attr['packet_action'], packet_action) print(attr) attr = sai_thrift_get_inseg_entry_attribute( self.client, inseg_entry, num_of_pop=True) self.assertEqual(attr['num_of_pop'], num_of_pop) print(attr) attr = sai_thrift_get_inseg_entry_attribute( self.client, inseg_entry, next_hop_id=True) self.assertEqual(attr['next_hop_id'], next_hop_id) print(attr) status = sai_thrift_remove_inseg_entry(self.client, inseg_entry) self.assertEqual(status, SAI_STATUS_SUCCESS) inseg_entry = sai_thrift_inseg_entry_t(label=200) status = sai_thrift_create_inseg_entry(self.client, inseg_entry) sai_thrift_set_inseg_entry_attribute( self.client, inseg_entry, packet_action=packet_action) attr = sai_thrift_get_inseg_entry_attribute( self.client, inseg_entry, packet_action=True) self.assertEqual(attr['packet_action'], packet_action) print(attr) sai_thrift_set_inseg_entry_attribute( self.client, inseg_entry, num_of_pop=num_of_pop) attr = sai_thrift_get_inseg_entry_attribute( self.client, inseg_entry, num_of_pop=True) self.assertEqual(attr['num_of_pop'], num_of_pop) print(attr) sai_thrift_set_inseg_entry_attribute( self.client, inseg_entry, next_hop_id=next_hop_id) attr = sai_thrift_get_inseg_entry_attribute( self.client, inseg_entry, next_hop_id=True) self.assertEqual(attr['next_hop_id'], next_hop_id) print(attr) finally: status = sai_thrift_remove_inseg_entry(self.client, inseg_entry) self.assertEqual(status, SAI_STATUS_SUCCESS) def mplsCreateTheSameEntryTest(self): ''' Verify it is not possible to create duplicated MPLS entry. ''' print("\nmplsCreateTheSameEntryTest()") try: inseg_entry = sai_thrift_inseg_entry_t(label=200) status = sai_thrift_create_inseg_entry(self.client, inseg_entry) self.assertEqual(status, SAI_STATUS_SUCCESS) inseg_entry = sai_thrift_inseg_entry_t(label=200) status = sai_thrift_create_inseg_entry(self.client, inseg_entry) self.assertNotEqual(status, SAI_STATUS_SUCCESS) finally: status = sai_thrift_remove_inseg_entry(self.client, inseg_entry) self.assertEqual(status, SAI_STATUS_SUCCESS) @group("draft") class MplsObjectsAvailabilityTest(SaiHelperBase): ''' CRM objects availability verification class ''' def runTest(self): print("\nMplsObjectsAvailabilityTest()") no_of_objects = random.randint(10, 100) label = 100 inseg_entry_list = [] try: mpls_rif = sai_thrift_create_router_interface( self.client, type=SAI_ROUTER_INTERFACE_TYPE_MPLS_ROUTER, virtual_router_id=self.default_vrf) obj_avail_before = sai_thrift_object_type_get_availability( self.client, obj_type=SAI_OBJECT_TYPE_INSEG_ENTRY) print("%d Inseg entries available\n" "Creating a random number of Inseg entries (%d)" % (obj_avail_before, no_of_objects)) for _ in range(no_of_objects): inseg_entry = sai_thrift_inseg_entry_t(label=label) status = sai_thrift_create_inseg_entry( self.client, inseg_entry, next_hop_id=mpls_rif) self.assertEqual(status, SAI_STATUS_SUCCESS) inseg_entry_list.append(inseg_entry) label += 1 obj_avail_after = sai_thrift_object_type_get_availability( self.client, obj_type=SAI_OBJECT_TYPE_INSEG_ENTRY) self.assertEqual(obj_avail_before, obj_avail_after + no_of_objects) print("%d objects available after creation of %d Inseg entries" % (obj_avail_after, no_of_objects)) finally: for inseg_entry in inseg_entry_list: sai_thrift_remove_inseg_entry(self.client, inseg_entry) sai_thrift_remove_router_interface(self.client, mpls_rif) @group("draft") class MplsIpv6TtlModeTest(SaiHelper): ''' This class contains tests of the ttl_mode for IPv6 MPLS packets, focusing mostly on the uniform mode. Note that the pipe mode is covered in more detail in MplsIpv6Test. ''' def setUp(self): super(MplsIpv6TtlModeTest, self).setUp() ttl_value = 63 exp_value = 5 ipv6_1 = '100::1' ipv6_2 = '100::2' ipv6_3 = '100::3' ipv6_4 = '220::1' ipv6_5 = '330::1' ipv6_10 = '800::1' ipv6_subnet_1 = '110::1/128' ipv6_subnet_2 = '120::1/128' ipv6_subnet_3 = '130::1/128' ipv6_subnet_4 = '200::1/128' dmac = '00:11:22:33:44:55' # Ingress LER config self.ingress_rif = self.port10_rif self.egress_rif_1 = self.port11_rif label_list = [1000] label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_1 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv6_1), router_interface_id=self.egress_rif_1, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_ttl_mode=SAI_OUTSEG_TTL_MODE_UNIFORM, outseg_ttl_value=ttl_value, outseg_exp_value=exp_value, outseg_type=SAI_OUTSEG_TYPE_PUSH) label_list.append(2000) label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_2 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv6_2), router_interface_id=self.egress_rif_1, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_ttl_mode=SAI_OUTSEG_TTL_MODE_UNIFORM, outseg_ttl_value=ttl_value, outseg_exp_value=exp_value, outseg_type=SAI_OUTSEG_TYPE_PUSH) label_list.append(3000) label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_3 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv6_3), router_interface_id=self.egress_rif_1, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_ttl_mode=SAI_OUTSEG_TTL_MODE_UNIFORM, outseg_ttl_value=ttl_value, outseg_exp_value=exp_value, outseg_type=SAI_OUTSEG_TYPE_PUSH) # note: neighbor with the same dst_ip as MPLS nexthop has to be created # after MPLS nexthop is created, # if not it will create second nexthop of type IP with this dst_ip # and neither of them will be functioning correctly - packets # will be gleaned to CPU self.mpls_neighbor_entry_1 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_1, ip_address=sai_ipaddress(ipv6_1)) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_1, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.mpls_neighbor_entry_2 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_1, ip_address=sai_ipaddress(ipv6_2)) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_2, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.mpls_neighbor_entry_3 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_1, ip_address=sai_ipaddress(ipv6_3)) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_3, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.mpls_encap_route_1 = sai_thrift_route_entry_t( vr_id=self.default_vrf, destination=sai_ipprefix(ipv6_subnet_1)) sai_thrift_create_route_entry( self.client, self.mpls_encap_route_1, next_hop_id=self.nhop_label_1) self.mpls_encap_route_2 = sai_thrift_route_entry_t( vr_id=self.default_vrf, destination=sai_ipprefix(ipv6_subnet_2)) sai_thrift_create_route_entry( self.client, self.mpls_encap_route_2, next_hop_id=self.nhop_label_2) self.mpls_encap_route_3 = sai_thrift_route_entry_t( vr_id=self.default_vrf, destination=sai_ipprefix(ipv6_subnet_3)) sai_thrift_create_route_entry( self.client, self.mpls_encap_route_3, next_hop_id=self.nhop_label_3) # MPLS egress LER term config self.egress_rif_2 = self.port12_rif self.mpls_rif = sai_thrift_create_router_interface( self.client, type=SAI_ROUTER_INTERFACE_TYPE_MPLS_ROUTER, virtual_router_id=self.default_vrf) self.nhop_1 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv6_4), router_interface_id=self.egress_rif_2, type=SAI_NEXT_HOP_TYPE_IP) self.neighbor_entry_1 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_2, ip_address=sai_ipaddress(ipv6_4)) sai_thrift_create_neighbor_entry( self.client, self.neighbor_entry_1, dst_mac_address=dmac, no_host_route=True) self.route_entry_1 = sai_thrift_route_entry_t( vr_id=self.default_vrf, destination=sai_ipprefix(ipv6_subnet_4)) sai_thrift_create_route_entry( self.client, self.route_entry_1, next_hop_id=self.nhop_1) self.inseg_entry_1000 = sai_thrift_inseg_entry_t(label=1000) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_1000, num_of_pop=1, pop_ttl_mode=SAI_INSEG_ENTRY_POP_TTL_MODE_UNIFORM, next_hop_id=self.mpls_rif) self.assertEqual(status, SAI_STATUS_SUCCESS) # MPLS Egress LER Null Term configs self.inseg_entry_0 = sai_thrift_inseg_entry_t(label=0) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_0, num_of_pop=1, pop_ttl_mode=SAI_INSEG_ENTRY_POP_TTL_MODE_UNIFORM, next_hop_id=self.mpls_rif) self.assertEqual(status, SAI_STATUS_SUCCESS) # MPLS Egress PHP configs self.egress_rif_3 = self.port13_rif self.nhop_2 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv6_4), router_interface_id=self.egress_rif_3, type=SAI_NEXT_HOP_TYPE_IP) self.neighbor_entry_2 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_3, ip_address=sai_ipaddress(ipv6_4)) status = sai_thrift_create_neighbor_entry( self.client, self.neighbor_entry_2, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.inseg_entry_2000 = sai_thrift_inseg_entry_t(label=2000) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_2000, num_of_pop=1, pop_ttl_mode=SAI_INSEG_ENTRY_POP_TTL_MODE_UNIFORM, next_hop_id=self.nhop_2) self.assertEqual(status, SAI_STATUS_SUCCESS) self.inseg_entry_2111 = sai_thrift_inseg_entry_t(label=2111) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_2111, num_of_pop=2, pop_ttl_mode=SAI_INSEG_ENTRY_POP_TTL_MODE_UNIFORM, next_hop_id=self.nhop_2) self.assertEqual(status, SAI_STATUS_SUCCESS) self.inseg_entry_2222 = sai_thrift_inseg_entry_t(label=2222) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_2222, num_of_pop=3, pop_ttl_mode=SAI_INSEG_ENTRY_POP_TTL_MODE_UNIFORM, next_hop_id=self.nhop_2) self.assertEqual(status, SAI_STATUS_SUCCESS) # MPLS Egress PHP Swap Null configs self.egress_rif_4 = sai_thrift_create_router_interface( self.client, type=SAI_ROUTER_INTERFACE_TYPE_PORT, port_id=self.port25, virtual_router_id=self.default_vrf) label_list = [0] label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_4 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv6_5), router_interface_id=self.egress_rif_4, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_ttl_mode=SAI_OUTSEG_TTL_MODE_UNIFORM, outseg_ttl_value=ttl_value, outseg_type=SAI_OUTSEG_TYPE_SWAP) self.mpls_neighbor_entry_4 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_4, ip_address=sai_ipaddress(ipv6_5)) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_4, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.inseg_entry_3000 = sai_thrift_inseg_entry_t(label=3000) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_3000, next_hop_id=self.nhop_label_4) self.assertEqual(status, SAI_STATUS_SUCCESS) # MPLS Transit Push configs self.egress_rif_9 = sai_thrift_create_router_interface( self.client, type=SAI_ROUTER_INTERFACE_TYPE_PORT, port_id=self.port30, virtual_router_id=self.default_vrf) label_list = [9000] label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_9 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv6_10), router_interface_id=self.egress_rif_9, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_ttl_mode=SAI_OUTSEG_TTL_MODE_UNIFORM, outseg_ttl_value=ttl_value, outseg_exp_value=exp_value, outseg_type=SAI_OUTSEG_TYPE_PUSH) self.mpls_neighbor_entry_9 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_9, ip_address=sai_ipaddress(ipv6_10)) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_9, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.inseg_entry_8000 = sai_thrift_inseg_entry_t(label=8000) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_8000, next_hop_id=self.nhop_label_9) self.assertEqual(status, SAI_STATUS_SUCCESS) def runTest(self): self.mplsIngressLERTtlModeTest() self.mplsEgressLERTermTtlModeTest() self.mplsEgressLERNullTermTtlModeTest() self.mplsEgressPhpTtlModeTest() def tearDown(self): sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_8000) sai_thrift_remove_neighbor_entry( self.client, self.mpls_neighbor_entry_9) sai_thrift_remove_next_hop(self.client, self.nhop_label_9) sai_thrift_remove_router_interface(self.client, self.egress_rif_9) sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_3000) sai_thrift_remove_neighbor_entry(self.client, self.mpls_neighbor_entry_4) sai_thrift_remove_next_hop(self.client, self.nhop_label_4) sai_thrift_remove_router_interface(self.client, self.egress_rif_4) sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_2222) sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_2111) sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_2000) sai_thrift_remove_neighbor_entry(self.client, self.neighbor_entry_2) sai_thrift_remove_next_hop(self.client, self.nhop_2) sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_0) sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_1000) sai_thrift_remove_route_entry(self.client, self.route_entry_1) sai_thrift_remove_neighbor_entry(self.client, self.neighbor_entry_1) sai_thrift_remove_next_hop(self.client, self.nhop_1) sai_thrift_remove_router_interface(self.client, self.mpls_rif) sai_thrift_remove_route_entry(self.client, self.mpls_encap_route_1) sai_thrift_remove_route_entry(self.client, self.mpls_encap_route_2) sai_thrift_remove_route_entry(self.client, self.mpls_encap_route_3) sai_thrift_remove_neighbor_entry(self.client, self.mpls_neighbor_entry_1) sai_thrift_remove_neighbor_entry(self.client, self.mpls_neighbor_entry_2) sai_thrift_remove_neighbor_entry(self.client, self.mpls_neighbor_entry_3) sai_thrift_remove_next_hop(self.client, self.nhop_label_1) sai_thrift_remove_next_hop(self.client, self.nhop_label_2) sai_thrift_remove_next_hop(self.client, self.nhop_label_3) super(MplsIpv6TtlModeTest, self).tearDown() def mplsIngressLERTtlModeTest(self): ''' Verify if MPLS labels are added to packet in ingress LER using TTL values from the incoming IPv6 packets. ''' print("\nmplsIngressLERTtlModeTest()") send_pkt_1 = simple_tcpv6_packet( eth_dst=ROUTER_MAC, ipv6_dst='110::1', ipv6_hlim=58) send_pkt_2 = simple_tcpv6_packet( eth_dst=ROUTER_MAC, ipv6_dst='120::1', ipv6_hlim=60) send_pkt_3 = simple_tcpv6_packet( eth_dst=ROUTER_MAC, ipv6_dst='130::1', ipv6_hlim=62) exp_pkt_1 = simple_tcpv6_packet( eth_dst='00:11:22:33:44:55', eth_src=ROUTER_MAC, ipv6_dst='110::1', ipv6_hlim=57) exp_pkt_2 = simple_tcpv6_packet( eth_dst='00:11:22:33:44:55', eth_src=ROUTER_MAC, ipv6_dst='120::1', ipv6_hlim=59) exp_pkt_3 = simple_tcpv6_packet( eth_dst='00:11:22:33:44:55', eth_src=ROUTER_MAC, ipv6_dst='130::1', ipv6_hlim=61) mpls_tag_list = [] mpls_tag_1 = {'label': 1000, 'ttl': 63, 'tc': 5, 's': 0} mpls_tag_2 = {'label': 2000, 'ttl': 63, 'tc': 5, 's': 0} mpls_tag_3 = {'label': 3000, 'ttl': 63, 'tc': 5, 's': 0} mpls_tag_1['s'] = 1 mpls_tag_1['ttl'] = 57 mpls_tag_list.append(mpls_tag_1) mpls_pkt_label_1 = simple_mpls_packet( eth_src=ROUTER_MAC, eth_dst='00:11:22:33:44:55', mpls_tags=mpls_tag_list, inner_frame=exp_pkt_1['IPv6']) mpls_tag_1['s'] = 0 mpls_tag_2['s'] = 1 mpls_tag_1['ttl'] = 59 mpls_tag_2['ttl'] = 59 del mpls_tag_list[:] mpls_tag_list.append(mpls_tag_1) mpls_tag_list.append(mpls_tag_2) mpls_pkt_label_2 = simple_mpls_packet( eth_src=ROUTER_MAC, eth_dst='00:11:22:33:44:55', mpls_tags=mpls_tag_list, inner_frame=exp_pkt_2['IPv6']) mpls_tag_1['s'] = 0 mpls_tag_2['s'] = 0 mpls_tag_3['s'] = 1 mpls_tag_1['ttl'] = 61 mpls_tag_2['ttl'] = 61 mpls_tag_3['ttl'] = 61 del mpls_tag_list[:] mpls_tag_list.append(mpls_tag_1) mpls_tag_list.append(mpls_tag_2) mpls_tag_list.append(mpls_tag_3) mpls_pkt_label_3 = simple_mpls_packet( eth_src=ROUTER_MAC, eth_dst='00:11:22:33:44:55', mpls_tags=mpls_tag_list, inner_frame=exp_pkt_3['IPv6']) mpls_tag_1['ttl'] = 63 mpls_tag_2['ttl'] = 63 mpls_tag_3['ttl'] = 63 del mpls_tag_list[:] mpls_tag_list.append(mpls_tag_1) mpls_tag_list.append(mpls_tag_2) mpls_tag_list.append(mpls_tag_3) mpls_pkt_label_4 = simple_mpls_packet( eth_src=ROUTER_MAC, eth_dst='00:11:22:33:44:55', mpls_tags=mpls_tag_list, inner_frame=exp_pkt_3['IPv6']) mpls_tag_1['ttl'] = 32 mpls_tag_2['ttl'] = 32 mpls_tag_3['ttl'] = 32 del mpls_tag_list[:] mpls_tag_list.append(mpls_tag_1) mpls_tag_list.append(mpls_tag_2) mpls_tag_list.append(mpls_tag_3) mpls_pkt_label_5 = simple_mpls_packet( eth_src=ROUTER_MAC, eth_dst='00:11:22:33:44:55', mpls_tags=mpls_tag_list, inner_frame=exp_pkt_3['IPv6']) print("Send ip packet to add one MPLS label 1000") send_packet(self, self.dev_port10, send_pkt_1) verify_packet(self, mpls_pkt_label_1, self.dev_port11) print("Send ip packet to add two MPLS label stack - 1000, 2000") send_packet(self, self.dev_port10, send_pkt_2) verify_packet(self, mpls_pkt_label_2, self.dev_port11) print("Send ip packet to add three MPLS label stack - " "1000, 2000, 3000") send_packet(self, self.dev_port10, send_pkt_3) verify_packet(self, mpls_pkt_label_3, self.dev_port11) sai_thrift_set_next_hop_attribute( self.client, self.nhop_label_3, outseg_ttl_mode=SAI_OUTSEG_TTL_MODE_PIPE) print("Change nexthop to pipe mode and send 3 label ip packet - " "1000, 2000, 3000") send_packet(self, self.dev_port10, send_pkt_3) verify_packet(self, mpls_pkt_label_4, self.dev_port11) sai_thrift_set_next_hop_attribute( self.client, self.nhop_label_3, outseg_ttl_value=32) print("Change nexthop ttl value to 32 and send 3 label ip packet " "- 1000, 2000, 3000") send_packet(self, self.dev_port10, send_pkt_3) verify_packet(self, mpls_pkt_label_5, self.dev_port11) sai_thrift_set_next_hop_attribute( self.client, self.nhop_label_3, outseg_ttl_mode=SAI_OUTSEG_TTL_MODE_UNIFORM) print("Change nexthop to uniform mode and send 3 label ip packet " "- 1000, 2000, 3000") send_packet(self, self.dev_port10, send_pkt_3) verify_packet(self, mpls_pkt_label_3, self.dev_port11) def mplsEgressLERTermTtlModeTest(self): ''' Verify if MPLS label is popped in Egress LER and packet is forwarded based on IP lookup using the TTL value from the popped MPLS label. ''' print("\nmplsEgressLERTermTtlModeTest()") send_pkt = simple_tcpv6_packet( eth_dst=ROUTER_MAC, ipv6_dst='200::1', ipv6_hlim=64) mpls_tag = {'label': 1000, 'ttl': 55, 'tc': 0, 's': 1} mpls_tag_list = [mpls_tag] mpls_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list, inner_frame=send_pkt['IPv6']) recv_pkt = simple_tcpv6_packet( eth_dst='00:11:22:33:44:55', eth_src=ROUTER_MAC, ipv6_dst='200::1', ipv6_hlim=54) print("Send MPLS tag packet with label 1000 - term and IP lookup") send_packet(self, self.dev_port10, mpls_pkt) verify_packet(self, recv_pkt, self.dev_port12) sai_thrift_set_inseg_entry_attribute( self.client, self.inseg_entry_1000, pop_ttl_mode=SAI_INSEG_ENTRY_POP_TTL_MODE_PIPE) recv_pkt['IPv6'].hlim = 63 print("Send MPLS tag packet after changing ttl mode to pipe") send_packet(self, self.dev_port10, mpls_pkt) verify_packet(self, recv_pkt, self.dev_port12) sai_thrift_set_inseg_entry_attribute( self.client, self.inseg_entry_1000, pop_ttl_mode=SAI_INSEG_ENTRY_POP_TTL_MODE_UNIFORM) recv_pkt['IPv6'].hlim = 54 print("Send MPLS tag packet after changing ttl mode to uniform") send_packet(self, self.dev_port10, mpls_pkt) verify_packet(self, recv_pkt, self.dev_port12) def mplsEgressLERNullTermTtlModeTest(self): ''' Verify if MPLS null label is popped in Egress LER and packet is forwarded based on IP lookup using the TTL value from the popped MPLS label. ''' print("\nmplsEgressLERNullTermTtlModeTest()") send_pkt = simple_tcpv6_packet( eth_dst=ROUTER_MAC, ipv6_dst='200::1', ipv6_hlim=64) mpls_tag = {'label': 0, 'ttl': 60, 'tc': 0, 's': 1} mpls_tag_list = [mpls_tag] mpls_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list, inner_frame=send_pkt['IPv6']) recv_pkt = simple_tcpv6_packet( eth_dst='00:11:22:33:44:55', eth_src=ROUTER_MAC, ipv6_dst='200::1', ipv6_hlim=59) print("Send MPLS tag packet with label 0 - term and IP lookup") send_packet(self, self.dev_port10, mpls_pkt) verify_packet(self, recv_pkt, self.dev_port12) def mplsEgressPhpTtlModeTest(self): ''' Verify PHP pops label and forwards packet using TTL value from the top label in the stack. ''' print("\nmplsEgressPhpTtlModeTest()") send_pkt = simple_tcpv6_packet( eth_dst=ROUTER_MAC, ipv6_dst='300::1', ipv6_hlim=64) mpls_tag = {'label': 2000, 'ttl': 60, 'tc': 0, 's': 1} mpls_tag_list = [mpls_tag] mpls_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list, inner_frame=send_pkt['IPv6']) mpls_tag_2 = {'label': 2111, 'ttl': 58, 'tc': 0, 's': 0} mpls_tag_list_2 = [mpls_tag_2, mpls_tag] mpls_tag_2_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list_2, inner_frame=send_pkt['IPv6']) mpls_tag_3 = {'label': 2222, 'ttl': 56, 'tc': 0, 's': 0} mpls_tag_list_3 = [mpls_tag_3, mpls_tag_2, mpls_tag] mpls_tag_3_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list_3, inner_frame=send_pkt['IPv6']) recv_pkt = simple_tcpv6_packet( eth_dst='00:11:22:33:44:55', eth_src=ROUTER_MAC, ipv6_dst='300::1', ipv6_hlim=63) mpls_tag['ttl'] = 60 recv_mpls_tag_list = [mpls_tag] recv_mpls_pkt_2 = simple_mpls_packet( eth_dst='00:11:22:33:44:55', eth_src=ROUTER_MAC, mpls_tags=recv_mpls_tag_list, inner_frame=send_pkt['IPv6']) try: print("Send MPLS tag packet with label 2000 - " "PHP and forward IP packet") recv_pkt['IPv6'].hlim = 59 send_packet(self, self.dev_port10, mpls_pkt) verify_packet(self, recv_pkt, self.dev_port13) print("Send MPLS tag packet with labels - 2111, 2000 - " "PHP and forward IP packet") recv_pkt['IPv6'].hlim = 57 send_packet(self, self.dev_port10, mpls_tag_2_pkt) verify_packet(self, recv_pkt, self.dev_port13) print("Send MPLS tag packet with labels - 2222, 2111, 2000 - " "PHP and forward IP packet") recv_pkt['IPv6'].hlim = 55 send_packet(self, self.dev_port10, mpls_tag_3_pkt) verify_packet(self, recv_pkt, self.dev_port13) sai_thrift_set_inseg_entry_attribute( self.client, self.inseg_entry_2222, pop_ttl_mode=SAI_INSEG_ENTRY_POP_TTL_MODE_PIPE) print("Set MPLS object label 2222 to pop only 2 labels") sai_thrift_set_inseg_entry_attribute( self.client, self.inseg_entry_2222, num_of_pop=2) print("Send MPLS tag packet with labels - 2222, 2111, 2000 - " "Pop 2 labels and forward MPLS with 2000") send_packet(self, self.dev_port10, mpls_tag_3_pkt) verify_packet(self, recv_mpls_pkt_2, self.dev_port13) finally: sai_thrift_set_inseg_entry_attribute( self.client, self.inseg_entry_2222, num_of_pop=3) @group("draft") class MplsIpv4TtlModeTest(SaiHelper): ''' This class contains tests of the ttl_mode for IPv4 MPLS packets, focusing mostly on the uniform mode. Note that the pipe mode is covered in more detail in MplsIpv4Test. ''' def setUp(self): super(MplsIpv4TtlModeTest, self).setUp() ttl_value = 63 exp_value = 5 ipv4_1 = '10.10.10.1' ipv4_2 = '10.10.10.2' ipv4_3 = '10.10.10.3' ipv4_4 = '20.20.20.1' ipv4_5 = '30.30.30.1' ipv4_10 = '80.80.80.1' ipv4_subnet_1 = '10.10.10.1/32' ipv4_subnet_2 = '10.10.10.2/32' ipv4_subnet_3 = '10.10.10.3/32' ipv4_subnet_4 = '20.20.20.1/24' dmac = '00:11:22:33:44:55' # Ingress LER config self.ingress_rif = self.port10_rif self.egress_rif_1 = self.port11_rif label_list = [1000] label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_1 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv4_1), router_interface_id=self.egress_rif_1, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_ttl_mode=SAI_OUTSEG_TTL_MODE_UNIFORM, outseg_ttl_value=ttl_value, outseg_exp_value=exp_value, outseg_type=SAI_OUTSEG_TYPE_PUSH) label_list.append(2000) label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_2 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv4_2), router_interface_id=self.egress_rif_1, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_ttl_mode=SAI_OUTSEG_TTL_MODE_UNIFORM, outseg_ttl_value=ttl_value, outseg_exp_value=exp_value, outseg_type=SAI_OUTSEG_TYPE_PUSH) label_list.append(3000) label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_3 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv4_3), router_interface_id=self.egress_rif_1, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_ttl_mode=SAI_OUTSEG_TTL_MODE_UNIFORM, outseg_ttl_value=ttl_value, outseg_exp_value=exp_value, outseg_type=SAI_OUTSEG_TYPE_PUSH) # note: neighbor with the same dst_ip as MPLS nexthop has to be created # after MPLS nexthop is created, # if not it will create second nexthop of type IP with this dst_ip # and neither of them will be functioning correctly - packets # will be gleaned to CPU self.mpls_neighbor_entry_1 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_1, ip_address=sai_ipaddress(ipv4_1)) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_1, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.mpls_neighbor_entry_2 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_1, ip_address=sai_ipaddress(ipv4_2)) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_2, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.mpls_neighbor_entry_3 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_1, ip_address=sai_ipaddress(ipv4_3)) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_3, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.mpls_encap_route_1 = sai_thrift_route_entry_t( vr_id=self.default_vrf, destination=sai_ipprefix(ipv4_subnet_1)) sai_thrift_create_route_entry( self.client, self.mpls_encap_route_1, next_hop_id=self.nhop_label_1) self.mpls_encap_route_2 = sai_thrift_route_entry_t( vr_id=self.default_vrf, destination=sai_ipprefix(ipv4_subnet_2)) sai_thrift_create_route_entry( self.client, self.mpls_encap_route_2, next_hop_id=self.nhop_label_2) self.mpls_encap_route_3 = sai_thrift_route_entry_t( vr_id=self.default_vrf, destination=sai_ipprefix(ipv4_subnet_3)) sai_thrift_create_route_entry( self.client, self.mpls_encap_route_3, next_hop_id=self.nhop_label_3) # MPLS egress LER term config self.egress_rif_2 = self.port12_rif self.mpls_rif = sai_thrift_create_router_interface( self.client, type=SAI_ROUTER_INTERFACE_TYPE_MPLS_ROUTER, virtual_router_id=self.default_vrf) self.nhop_1 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv4_4), router_interface_id=self.egress_rif_2, type=SAI_NEXT_HOP_TYPE_IP) self.neighbor_entry_1 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_2, ip_address=sai_ipaddress(ipv4_4)) sai_thrift_create_neighbor_entry( self.client, self.neighbor_entry_1, dst_mac_address=dmac, no_host_route=True) self.route_entry_1 = sai_thrift_route_entry_t( vr_id=self.default_vrf, destination=sai_ipprefix(ipv4_subnet_4)) sai_thrift_create_route_entry( self.client, self.route_entry_1, next_hop_id=self.nhop_1) self.inseg_entry_1000 = sai_thrift_inseg_entry_t(label=1000) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_1000, num_of_pop=1, pop_ttl_mode=SAI_INSEG_ENTRY_POP_TTL_MODE_UNIFORM, next_hop_id=self.mpls_rif) self.assertEqual(status, SAI_STATUS_SUCCESS) # MPLS Egress LER Null Term configs self.inseg_entry_0 = sai_thrift_inseg_entry_t(label=0) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_0, num_of_pop=1, pop_ttl_mode=SAI_INSEG_ENTRY_POP_TTL_MODE_UNIFORM, next_hop_id=self.mpls_rif) self.assertEqual(status, SAI_STATUS_SUCCESS) # MPLS Egress PHP configs self.egress_rif_3 = self.port13_rif self.nhop_2 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv4_4), router_interface_id=self.egress_rif_3, type=SAI_NEXT_HOP_TYPE_IP) self.neighbor_entry_2 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_3, ip_address=sai_ipaddress(ipv4_4)) status = sai_thrift_create_neighbor_entry( self.client, self.neighbor_entry_2, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.inseg_entry_2000 = sai_thrift_inseg_entry_t(label=2000) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_2000, num_of_pop=1, pop_ttl_mode=SAI_INSEG_ENTRY_POP_TTL_MODE_UNIFORM, next_hop_id=self.nhop_2) self.assertEqual(status, SAI_STATUS_SUCCESS) self.inseg_entry_2111 = sai_thrift_inseg_entry_t(label=2111) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_2111, num_of_pop=2, pop_ttl_mode=SAI_INSEG_ENTRY_POP_TTL_MODE_UNIFORM, next_hop_id=self.nhop_2) self.assertEqual(status, SAI_STATUS_SUCCESS) self.inseg_entry_2222 = sai_thrift_inseg_entry_t(label=2222) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_2222, num_of_pop=3, pop_ttl_mode=SAI_INSEG_ENTRY_POP_TTL_MODE_UNIFORM, next_hop_id=self.nhop_2) self.assertEqual(status, SAI_STATUS_SUCCESS) # MPLS Egress PHP Swap Null configs self.egress_rif_4 = sai_thrift_create_router_interface( self.client, type=SAI_ROUTER_INTERFACE_TYPE_PORT, port_id=self.port25, virtual_router_id=self.default_vrf) label_list = [0] label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_4 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv4_5), router_interface_id=self.egress_rif_4, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_ttl_mode=SAI_OUTSEG_TTL_MODE_UNIFORM, outseg_ttl_value=ttl_value, outseg_type=SAI_OUTSEG_TYPE_SWAP) self.mpls_neighbor_entry_4 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_4, ip_address=sai_ipaddress(ipv4_5)) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_4, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.inseg_entry_3000 = sai_thrift_inseg_entry_t(label=3000) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_3000, next_hop_id=self.nhop_label_4) self.assertEqual(status, SAI_STATUS_SUCCESS) # MPLS Transit Push configs self.egress_rif_9 = sai_thrift_create_router_interface( self.client, type=SAI_ROUTER_INTERFACE_TYPE_PORT, port_id=self.port30, virtual_router_id=self.default_vrf) label_list = [9000] label_list_t = sai_thrift_u32_list_t( count=len(label_list), uint32list=label_list) self.nhop_label_9 = sai_thrift_create_next_hop( self.client, ip=sai_ipaddress(ipv4_10), router_interface_id=self.egress_rif_9, type=SAI_NEXT_HOP_TYPE_MPLS, labelstack=label_list_t, outseg_ttl_mode=SAI_OUTSEG_TTL_MODE_UNIFORM, outseg_ttl_value=ttl_value, outseg_exp_value=exp_value, outseg_type=SAI_OUTSEG_TYPE_PUSH) self.mpls_neighbor_entry_9 = sai_thrift_neighbor_entry_t( rif_id=self.egress_rif_9, ip_address=sai_ipaddress(ipv4_10)) status = sai_thrift_create_neighbor_entry( self.client, self.mpls_neighbor_entry_9, dst_mac_address=dmac, no_host_route=True) self.assertEqual(status, SAI_STATUS_SUCCESS) self.inseg_entry_8000 = sai_thrift_inseg_entry_t(label=8000) status = sai_thrift_create_inseg_entry( self.client, self.inseg_entry_8000, next_hop_id=self.nhop_label_9) self.assertEqual(status, SAI_STATUS_SUCCESS) def runTest(self): self.mplsIngressLERTtlModeTest() self.mplsEgressLERTermTtlModeTest() self.mplsEgressLERNullTermTtlModeTest() self.mplsEgressPhpTtlModeTest() def tearDown(self): sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_8000) sai_thrift_remove_neighbor_entry( self.client, self.mpls_neighbor_entry_9) sai_thrift_remove_next_hop(self.client, self.nhop_label_9) sai_thrift_remove_router_interface(self.client, self.egress_rif_9) sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_3000) sai_thrift_remove_neighbor_entry(self.client, self.mpls_neighbor_entry_4) sai_thrift_remove_next_hop(self.client, self.nhop_label_4) sai_thrift_remove_router_interface(self.client, self.egress_rif_4) sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_2222) sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_2111) sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_2000) sai_thrift_remove_neighbor_entry(self.client, self.neighbor_entry_2) sai_thrift_remove_next_hop(self.client, self.nhop_2) sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_0) sai_thrift_remove_inseg_entry(self.client, self.inseg_entry_1000) sai_thrift_remove_route_entry(self.client, self.route_entry_1) sai_thrift_remove_neighbor_entry(self.client, self.neighbor_entry_1) sai_thrift_remove_next_hop(self.client, self.nhop_1) sai_thrift_remove_router_interface(self.client, self.mpls_rif) sai_thrift_remove_route_entry(self.client, self.mpls_encap_route_1) sai_thrift_remove_route_entry(self.client, self.mpls_encap_route_2) sai_thrift_remove_route_entry(self.client, self.mpls_encap_route_3) sai_thrift_remove_neighbor_entry(self.client, self.mpls_neighbor_entry_1) sai_thrift_remove_neighbor_entry(self.client, self.mpls_neighbor_entry_2) sai_thrift_remove_neighbor_entry(self.client, self.mpls_neighbor_entry_3) sai_thrift_remove_next_hop(self.client, self.nhop_label_1) sai_thrift_remove_next_hop(self.client, self.nhop_label_2) sai_thrift_remove_next_hop(self.client, self.nhop_label_3) super(MplsIpv4TtlModeTest, self).tearDown() def mplsIngressLERTtlModeTest(self): ''' Verify if MPLS labels are added to packet in ingress LER using TTL values from the incoming IPv4 packets. ''' print("\nmplsIngressLERTtlModeTest()") send_pkt_1 = simple_tcp_packet( eth_dst=ROUTER_MAC, ip_dst='10.10.10.1', ip_ttl=58) send_pkt_2 = simple_tcp_packet( eth_dst=ROUTER_MAC, ip_dst='10.10.10.2', ip_ttl=60) send_pkt_3 = simple_tcp_packet( eth_dst=ROUTER_MAC, ip_dst='10.10.10.3', ip_ttl=62) exp_pkt_1 = simple_tcp_packet( eth_dst='00:11:22:33:44:55', eth_src=ROUTER_MAC, ip_dst='10.10.10.1', ip_ttl=57) exp_pkt_2 = simple_tcp_packet( eth_dst='00:11:22:33:44:55', eth_src=ROUTER_MAC, ip_dst='10.10.10.2', ip_ttl=59) exp_pkt_3 = simple_tcp_packet( eth_dst='00:11:22:33:44:55', eth_src=ROUTER_MAC, ip_dst='10.10.10.3', ip_ttl=61) mpls_tag_list = [] mpls_tag_1 = {'label': 1000, 'ttl': 63, 'tc': 5, 's': 0} mpls_tag_2 = {'label': 2000, 'ttl': 63, 'tc': 5, 's': 0} mpls_tag_3 = {'label': 3000, 'ttl': 63, 'tc': 5, 's': 0} mpls_tag_1['s'] = 1 mpls_tag_1['ttl'] = 57 mpls_tag_list.append(mpls_tag_1) mpls_pkt_label_1 = simple_mpls_packet( eth_src=ROUTER_MAC, eth_dst='00:11:22:33:44:55', mpls_tags=mpls_tag_list, inner_frame=exp_pkt_1['IP']) mpls_tag_1['s'] = 0 mpls_tag_2['s'] = 1 mpls_tag_1['ttl'] = 59 mpls_tag_2['ttl'] = 59 del mpls_tag_list[:] mpls_tag_list.append(mpls_tag_1) mpls_tag_list.append(mpls_tag_2) mpls_pkt_label_2 = simple_mpls_packet( eth_src=ROUTER_MAC, eth_dst='00:11:22:33:44:55', mpls_tags=mpls_tag_list, inner_frame=exp_pkt_2['IP']) mpls_tag_1['s'] = 0 mpls_tag_2['s'] = 0 mpls_tag_3['s'] = 1 mpls_tag_1['ttl'] = 61 mpls_tag_2['ttl'] = 61 mpls_tag_3['ttl'] = 61 del mpls_tag_list[:] mpls_tag_list.append(mpls_tag_1) mpls_tag_list.append(mpls_tag_2) mpls_tag_list.append(mpls_tag_3) mpls_pkt_label_3 = simple_mpls_packet( eth_src=ROUTER_MAC, eth_dst='00:11:22:33:44:55', mpls_tags=mpls_tag_list, inner_frame=exp_pkt_3['IP']) print("Send ip packet to add one MPLS label 1000") send_packet(self, self.dev_port10, send_pkt_1) verify_packet(self, mpls_pkt_label_1, self.dev_port11) print("Send ip packet to add two MPLS label stack - 1000, 2000") send_packet(self, self.dev_port10, send_pkt_2) verify_packet(self, mpls_pkt_label_2, self.dev_port11) print("Send ip packet to add three MPLS label stack - " "1000, 2000, 3000") send_packet(self, self.dev_port10, send_pkt_3) verify_packet(self, mpls_pkt_label_3, self.dev_port11) def mplsEgressLERTermTtlModeTest(self): ''' Verify if MPLS label is popped in Egress LER and packet is forwarded based on IP lookup using the TTL value from the popped MPLS label. ''' print("\nmplsIngressLERTermTtlModeTest()") send_pkt = simple_tcp_packet( eth_dst=ROUTER_MAC, ip_dst='20.20.20.1', ip_ttl=64) mpls_tag = {'label': 1000, 'ttl': 55, 'tc': 0, 's': 1} mpls_tag_list = [mpls_tag] mpls_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list, inner_frame=send_pkt['IP']) recv_pkt = simple_tcp_packet( eth_dst='00:11:22:33:44:55', eth_src=ROUTER_MAC, ip_dst='20.20.20.1', ip_ttl=54) print("Send MPLS tag packet with label 1000 - term and IP lookup") send_packet(self, self.dev_port10, mpls_pkt) verify_packet(self, recv_pkt, self.dev_port12) def mplsEgressLERNullTermTtlModeTest(self): ''' Verify if MPLS null label is popped in Egress LER and packet is forwarded based on IP lookup using the TTL value from the popped MPLS label. ''' print("\nmplsIngressLERNullTermTtlModeTest()") send_pkt = simple_tcp_packet( eth_dst=ROUTER_MAC, ip_dst='20.20.20.1', ip_ttl=64) mpls_tag = {'label': 0, 'ttl': 60, 'tc': 0, 's': 1} mpls_tag_list = [mpls_tag] mpls_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list, inner_frame=send_pkt['IP']) recv_pkt = simple_tcp_packet( eth_dst='00:11:22:33:44:55', eth_src=ROUTER_MAC, ip_dst='20.20.20.1', ip_ttl=59) print("Send MPLS tag packet with label 0 - term and IP lookup") send_packet(self, self.dev_port10, mpls_pkt) verify_packet(self, recv_pkt, self.dev_port12) def mplsEgressPhpTtlModeTest(self): ''' Verify PHP pops label and forwards packet using TTL value from the top label in the stack. ''' print("\nmplsEgressPhpTtlModeTest()") send_pkt = simple_tcp_packet( eth_dst=ROUTER_MAC, ip_dst='30.30.30.1', ip_ttl=64) mpls_tag = {'label': 2000, 'ttl': 60, 'tc': 0, 's': 1} mpls_tag_list = [mpls_tag] mpls_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list, inner_frame=send_pkt['IP']) mpls_tag_2 = {'label': 2111, 'ttl': 58, 'tc': 0, 's': 0} mpls_tag_list_2 = [mpls_tag_2, mpls_tag] mpls_tag_2_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list_2, inner_frame=send_pkt['IP']) mpls_tag_3 = {'label': 2222, 'ttl': 56, 'tc': 0, 's': 0} mpls_tag_list_3 = [mpls_tag_3, mpls_tag_2, mpls_tag] mpls_tag_3_pkt = simple_mpls_packet( eth_dst=ROUTER_MAC, mpls_tags=mpls_tag_list_3, inner_frame=send_pkt['IP']) recv_pkt = simple_tcp_packet( eth_dst='00:11:22:33:44:55', eth_src=ROUTER_MAC, ip_dst='30.30.30.1', ip_ttl=63) try: print("Send MPLS tag pakcet with label 2000 - " "PHP and forward IP packet") recv_pkt['IP'].ttl = 59 send_packet(self, self.dev_port10, mpls_pkt) verify_packet(self, recv_pkt, self.dev_port13) print("Send MPLS tag pakcet with labels - 2111, 2000 - " "PHP and forward IP packet") recv_pkt['IP'].ttl = 57 send_packet(self, self.dev_port10, mpls_tag_2_pkt) verify_packet(self, recv_pkt, self.dev_port13) print("Send MPLS tag pakcet with labels - 2222, 2111, 2000 - " "PHP and forward IP packet") recv_pkt['IP'].ttl = 55 send_packet(self, self.dev_port10, mpls_tag_3_pkt) verify_packet(self, recv_pkt, self.dev_port13) finally: sai_thrift_set_inseg_entry_attribute( self.client, self.inseg_entry_2222, num_of_pop=3)