# Copyright (C) 2016 Nippon Telegraph and Telephone 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. from __future__ import absolute_import from itertools import combinations import sys import time import unittest from fabric.api import local import nose from lib.noseplugin import OptionParser, parser_option from lib import base from lib.base import BGP_FSM_ESTABLISHED from lib.gobgp import GoBGPContainer class GoBGPTestBase(unittest.TestCase): @classmethod def setUpClass(cls): # +----+ +----+ # | g1 |----(iBGP)----| g2 | # +----+ +----+ gobgp_ctn_image_name = parser_option.gobgp_image base.TEST_PREFIX = parser_option.test_prefix g1 = GoBGPContainer(name='g1', asn=65000, router_id='192.168.0.1', ctn_image_name=gobgp_ctn_image_name, log_level=parser_option.gobgp_log_level) g2 = GoBGPContainer(name='g2', asn=65000, router_id='192.168.0.2', ctn_image_name=gobgp_ctn_image_name, log_level=parser_option.gobgp_log_level) ctns = {ctn.name: ctn for ctn in [g1, g2]} initial_wait_time = max(ctn.run() for ctn in ctns.values()) time.sleep(initial_wait_time) g1.local("gobgp vrf add vrf1 rd 100:100 rt both 100:100") g1.local("gobgp vrf add vrf2 rd 200:200 rt both 200:200") g2.local("gobgp vrf add vrf1 rd 100:100 rt both 100:100") g2.local("gobgp vrf add vrf3 rd 300:300 rt both 300:300") g1.local("gobgp vrf vrf1 rib add 10.0.0.0/24") g1.local("gobgp vrf vrf2 rib add 10.0.0.0/24") g2.local("gobgp vrf vrf1 rib add 20.0.0.0/24") g2.local("gobgp vrf vrf3 rib add 20.0.0.0/24") for a, b in combinations(ctns.values(), 2): a.add_peer(b, vpn=True, passwd='rtc', graceful_restart=True) b.add_peer(a, vpn=True, passwd='rtc', graceful_restart=True) cls.g1 = g1 cls.g2 = g2 cls.ctns = ctns # test each neighbor state is turned establish def test_01_neighbor_established(self): self.g1.wait_for(expected_state=BGP_FSM_ESTABLISHED, peer=self.g2) def test_02_check_gobgp_adj_rib_out(self): time.sleep(2) self.assertEqual(1, len(self.g1.get_adj_rib_out(self.g2, rf='ipv4-l3vpn'))) self.assertEqual(1, len(self.g2.get_adj_rib_out(self.g1, rf='ipv4-l3vpn'))) def test_03_add_vrf(self): self.g1.local("gobgp vrf add vrf3 rd 300:300 rt both 300:300") time.sleep(2) self.assertEqual(3, len(self.g1.get_adj_rib_out(self.g2, rf='rtc'))) self.assertEqual(2, len(self.g1.get_adj_rib_in(self.g2, rf='ipv4-l3vpn'))) def test_04_del_vrf(self): self.g1.local("gobgp vrf del vrf1") time.sleep(2) self.assertEqual(2, len(self.g1.get_adj_rib_out(self.g2, rf='rtc'))) # TODO: # g2 should withdraw VPN routes when received a RTM withdrawal. # self.assertEqual(1, len(self.g1.get_adj_rib_in(self.g2, rf='ipv4-l3vpn'))) def test_05_rr_setup(self): # +------+ # | g3 | # +------| (RR) |------+ # | +------+ | # (iBGP) (iBGP) # | | # +-------------+ +-------------+ # | g4 | | g5 | # | (RR Client) | | (RR Client) | # +-------------+ +-------------+ gobgp_ctn_image_name = parser_option.gobgp_image g3 = GoBGPContainer(name='g3', asn=65000, router_id='192.168.0.3', ctn_image_name=gobgp_ctn_image_name, log_level=parser_option.gobgp_log_level) g4 = GoBGPContainer(name='g4', asn=65000, router_id='192.168.0.4', ctn_image_name=gobgp_ctn_image_name, log_level=parser_option.gobgp_log_level) g5 = GoBGPContainer(name='g5', asn=65000, router_id='192.168.0.5', ctn_image_name=gobgp_ctn_image_name, log_level=parser_option.gobgp_log_level) time.sleep(max(ctn.run() for ctn in [g3, g4, g5])) g3.add_peer(g4, vpn=True, is_rr_client=True) g4.add_peer(g3, vpn=True) g3.add_peer(g5, vpn=True, is_rr_client=True) g5.add_peer(g3, vpn=True) for v in [g3, g4, g5]: self.ctns[v.name] = v def test_06_neighbor_established(self): g3 = self.ctns['g3'] g4 = self.ctns['g4'] g5 = self.ctns['g5'] g3.wait_for(expected_state=BGP_FSM_ESTABLISHED, peer=g4) g3.wait_for(expected_state=BGP_FSM_ESTABLISHED, peer=g5) def test_07_rr_test(self): g3 = self.ctns['g3'] g4 = self.ctns['g4'] g5 = self.ctns['g5'] g4.local("gobgp vrf add vrf1 rd 100:100 rt both 100:100") time.sleep(1) g5.local("gobgp vrf add vrf1 rd 100:100 rt both 100:100") time.sleep(1) def check_rtc(client): rib = g3.get_adj_rib_out(client, rf='rtc') self.assertEqual(1, len(rib)) path = rib[0] self.assertEqual(g3.peers[client]['local_addr'].split('/')[0], path['nexthop']) ids = [attr['value'] for attr in path['attrs'] if attr['type'] == base.BGP_ATTR_TYPE_ORIGINATOR_ID] self.assertEqual(1, len(ids)) self.assertEqual(g3.router_id, ids[0]) check_rtc(g4) check_rtc(g5) g4.local("gobgp vrf vrf1 rib add 40.0.0.0/24") g5.local("gobgp vrf vrf1 rib add 50.0.0.0/24") time.sleep(1) def check_ipv4_l3vpn(client): rib = g3.get_adj_rib_out(client, rf='ipv4-l3vpn') self.assertEqual(1, len(rib)) path = rib[0] self.assertNotEqual(g3.peers[client]['local_addr'].split('/')[0], path['nexthop']) ids = [attr['value'] for attr in path['attrs'] if attr['type'] == base.BGP_ATTR_TYPE_ORIGINATOR_ID] self.assertEqual(1, len(ids)) self.assertNotEqual(client.router_id, ids[0]) check_ipv4_l3vpn(g4) check_ipv4_l3vpn(g5) def test_08_rr_setup2(self): # +----------+ +----------+ # | g1 |---(iBGP)---| g2 | # | (Non RR | | (Non RR | # | Client) | | Client) | # +----------+ +----------+ # | | # +--(iBGP)--+ +--(iBGP)--+ # | | # +------+ # | g3 | # +------| (RR) |------+ # | +------+ | # (iBGP) (iBGP) # | | # +-------------+ +-------------+ # | g4 | | g5 | # | (RR Client) | | (RR Client) | # +-------------+ +-------------+ g1 = self.ctns['g1'] g2 = self.ctns['g2'] g3 = self.ctns['g3'] g1.local("gobgp vrf del vrf2") g1.local("gobgp vrf del vrf3") g2.local("gobgp vrf del vrf1") g2.local("gobgp vrf del vrf3") g3.add_peer(g1, vpn=True) g1.add_peer(g3, vpn=True) g3.add_peer(g2, vpn=True) g2.add_peer(g3, vpn=True) g3.wait_for(expected_state=BGP_FSM_ESTABLISHED, peer=g1) g3.wait_for(expected_state=BGP_FSM_ESTABLISHED, peer=g2) def test_09_rr_test2(self): g1 = self.ctns['g1'] g2 = self.ctns['g2'] g3 = self.ctns['g3'] g4 = self.ctns['g4'] g5 = self.ctns['g5'] self.assertEqual(0, len(g1.get_adj_rib_in(g3, rf='ipv4-l3vpn'))) self.assertEqual(0, len(g2.get_adj_rib_in(g3, rf='ipv4-l3vpn'))) g1.local("gobgp vrf add vrf1 rd 100:100 rt both 100:100") g1.local("gobgp vrf vrf1 rib add 10.0.0.0/24") time.sleep(1) self.assertEqual(2, len(g1.get_adj_rib_in(g3, rf='ipv4-l3vpn'))) self.assertEqual(0, len(g2.get_adj_rib_in(g3, rf='ipv4-l3vpn'))) self.assertEqual(1, len(g3.get_adj_rib_in(g1, rf='ipv4-l3vpn'))) self.assertEqual(0, len(g3.get_adj_rib_in(g2, rf='ipv4-l3vpn'))) self.assertEqual(2, len(g4.get_adj_rib_in(g3, rf='ipv4-l3vpn'))) self.assertEqual(2, len(g5.get_adj_rib_in(g3, rf='ipv4-l3vpn'))) g2.local("gobgp vrf add vrf2 rd 200:200 rt both 200:200") g2.local("gobgp vrf vrf2 rib add 20.0.0.0/24") time.sleep(1) self.assertEqual(2, len(g1.get_adj_rib_in(g3, rf='ipv4-l3vpn'))) self.assertEqual(0, len(g2.get_adj_rib_in(g3, rf='ipv4-l3vpn'))) self.assertEqual(1, len(g3.get_adj_rib_in(g1, rf='ipv4-l3vpn'))) self.assertEqual(0, len(g3.get_adj_rib_in(g2, rf='ipv4-l3vpn'))) self.assertEqual(2, len(g4.get_adj_rib_in(g3, rf='ipv4-l3vpn'))) self.assertEqual(2, len(g5.get_adj_rib_in(g3, rf='ipv4-l3vpn'))) g4.local("gobgp vrf add vrf2 rd 200:200 rt both 200:200") time.sleep(1) self.assertEqual(2, len(g1.get_adj_rib_in(g3, rf='ipv4-l3vpn'))) self.assertEqual(0, len(g2.get_adj_rib_in(g3, rf='ipv4-l3vpn'))) self.assertEqual(1, len(g3.get_adj_rib_in(g1, rf='ipv4-l3vpn'))) self.assertEqual(1, len(g3.get_adj_rib_in(g2, rf='ipv4-l3vpn'))) self.assertEqual(3, len(g4.get_adj_rib_in(g3, rf='ipv4-l3vpn'))) self.assertEqual(2, len(g5.get_adj_rib_in(g3, rf='ipv4-l3vpn'))) if __name__ == '__main__': output = local("which docker 2>&1 > /dev/null ; echo $?", capture=True) if int(output) is not 0: print "docker not found" sys.exit(1) nose.main(argv=sys.argv, addplugins=[OptionParser()], defaultTest=sys.argv[0])