proxmox-mirrors/mirror_frr
1
0
Fork 0
mirror of https://git.proxmox.com/git/mirror_frr synced 2025-06-05 23:49:42 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

tests: clarify bgp_vpnv4_asbr

Browse Source 
Clarify bgp_vpnv4_asbr. Cosmetic change.

Signed-off-by: Louis Scalbert <louis.scalbert@6wind.com>
This commit is contained in:
Louis Scalbert 2024-11-05 16:33:02 +01:00
parent 1df6c57e69
commit aceae79ae0
1 changed files with 150 additions and 113 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

263
tests/topotests/bgp_vpnv4_asbr/test_bgp_vpnv4_asbr.py
View File

@ -368,17 +368,17 @@ def test_protocols_convergence():
# check that r2 peerings are ok # check that r2 peerings are ok
logger.info("Checking BGP ipv4 vpn summary for r2") logger.info("Checking BGP ipv4 vpn summary for r2")
router = tgen.gears["r2"] r2 = tgen.gears["r2"]
json_file = "{}/{}/ipv4_vpn_summary.json".format(CWD, router.name) json_file = "{}/{}/ipv4_vpn_summary.json".format(CWD, r2.name)
expected = json.loads(open(json_file).read()) expected = json.loads(open(json_file).read())
test_func = partial( test_func = partial(
topotest.router_json_cmp, topotest.router_json_cmp,
router, r2,
"show bgp ipv4 vpn summary json", "show bgp ipv4 vpn summary json",
expected, expected,
) )
_, result = topotest.run_and_expect(test_func, None, count=20, wait=0.5) _, result = topotest.run_and_expect(test_func, None, count=20, wait=0.5)
assertmsg = '"{}" JSON output mismatches'.format(router.name) assertmsg = '"{}" JSON output mismatches'.format(r2.name)
assert result is None, assertmsg assert result is None, assertmsg
@ -400,11 +400,11 @@ def test_mpls_setup_ok():
tgen = get_topogen() tgen = get_topogen()
if tgen.routers_have_failure(): if tgen.routers_have_failure():
pytest.skip(tgen.errors) pytest.skip(tgen.errors)
router = tgen.gears["r2"] r2 = tgen.gears["r2"]
# diagnostic # diagnostic
logger.info("Dumping mplsvpn nexthop table") logger.info("Dumping mplsvpn nexthop table")
router.vtysh_cmd("show bgp mplsvpn-nh-label-bind detail", isjson=False) r2.vtysh_cmd("show bgp mplsvpn-nh-label-bind detail")
vpnv4_checks = { vpnv4_checks = {
"172.31.1.0/24": "r1", "172.31.1.0/24": "r1",
@ -414,10 +414,10 @@ def test_mpls_setup_ok():
} }
logger.info( logger.info(
"{}, check that 'show bgp ipv4 vpn' and 'show mpls table' are set accordingly on all devices".format( "{}, check that 'show bgp ipv4 vpn' and 'show mpls table' are set accordingly on all devices".format(
router.name r2.name
) )
) )
check_show_bgp_vpn_ok(router, vpnv4_checks) check_show_bgp_vpn_ok(r2, vpnv4_checks)
logger.info("h1, check that ping from h1 to (h2,h3) is ok") logger.info("h1, check that ping from h1 to (h2,h3) is ok")
check_ping("h1", "172.31.1.10", True, 20, 0.5) check_ping("h1", "172.31.1.10", True, 20, 0.5)
@ -436,71 +436,85 @@ def test_r3_prefixes_removed():
tgen = get_topogen() tgen = get_topogen()
if tgen.routers_have_failure(): if tgen.routers_have_failure():
pytest.skip(tgen.errors) pytest.skip(tgen.errors)
router = tgen.gears["r3"] r3 = tgen.gears["r3"]
logger.info("{}, keeping only 172.31.3.0/24 network".format(router.name)) logger.info("{}, keeping only 172.31.3.0/24 network".format(r3.name))
router.vtysh_cmd("configure terminal\ninterface r3-eth1 vrf vrf1\nshutdown\n") r3.vtysh_cmd(
router.vtysh_cmd("configure terminal\ninterface r3-eth2 vrf vrf1\nshutdown\n") """
configure terminal
interface r3-eth1 vrf vrf1
shutdown
!
interface r3-eth2 vrf vrf1
shutdown\n
"""
)
router = tgen.gears["r2"] r2 = tgen.gears["r2"]
logger.info( logger.info(
"{}, check that 'show bgp ipv4 vpn' has only 172.31.3.0/24 network from r3".format( "{}, check that 'show bgp ipv4 vpn' has only 172.31.3.0/24 network from r3".format(
router.name r2.name
) )
) )
for prefix in ("172.31.1.0/24", "172.31.2.0/24"): for prefix in ("172.31.1.0/24", "172.31.2.0/24"):
test_func = functools.partial( test_func = functools.partial(
check_show_bgp_vpn_prefix_not_found, check_show_bgp_vpn_prefix_not_found,
router, r2,
"ipv4", "ipv4",
prefix, prefix,
"444:3", "444:3",
) )
success, _ = topotest.run_and_expect(test_func, None, count=10, wait=0.5) success, _ = topotest.run_and_expect(test_func, None, count=10, wait=0.5)
assert success, "{}, vpnv4 update {} still present".format(router.name, prefix) assert success, "{}, vpnv4 update {} still present".format(r2.name, prefix)
# diagnostic # diagnostic
logger.info("Dumping mplsvpn nexthop table") logger.info("Dumping mplsvpn nexthop table")
router.vtysh_cmd("show bgp mplsvpn-nh-label-bind detail", isjson=False) r2.vtysh_cmd("show bgp mplsvpn-nh-label-bind detail")
prefix = "172.31.3.0/24" prefix = "172.31.3.0/24"
logger.info( logger.info(
"{}, check that 'show bgp ipv4 vpn' and 'show mpls table' are set accordingly on r2 and on r1".format( "{}, check that 'show bgp ipv4 vpn' and 'show mpls table' are set accordingly on r2 and on r1".format(
router.name r2.name
) )
) )
vpnv4_checks = { vpnv4_checks = {
prefix: "r1", prefix: "r1",
} }
label_ip_entries = check_show_bgp_vpn_ok(router, vpnv4_checks) label_ip_entries = check_show_bgp_vpn_ok(r2, vpnv4_checks)
router = tgen.gears["r3"] r3 = tgen.gears["r3"]
logger.info("{}, removing {} network".format(router.name, prefix)) logger.info("{}, removing {} network".format(r3.name, prefix))
router.vtysh_cmd("configure terminal\ninterface r3-eth3 vrf vrf1\nshutdown\n") r3.vtysh_cmd(
"""
configure terminal
interface r3-eth3 vrf vrf1
shutdown\n
"""
)
router = tgen.gears["r2"] r2 = tgen.gears["r2"]
logger.info( logger.info(
"{}, check that 'show bgp ipv4 vpn' has not {} network from r3".format( "{}, check that 'show bgp ipv4 vpn' has not {} network from r3".format(
router.name, prefix r2.name, prefix
) )
) )
test_func = functools.partial( test_func = functools.partial(
check_show_bgp_vpn_prefix_not_found, check_show_bgp_vpn_prefix_not_found,
router, r2,
"ipv4", "ipv4",
prefix, prefix,
"444:3", "444:3",
) )
success, _ = topotest.run_and_expect(test_func, None, count=10, wait=0.5) success, _ = topotest.run_and_expect(test_func, None, count=10, wait=0.5)
assert success, "{}, vpnv4 update {} still present".format(router.name, prefix) assert success, "{}, vpnv4 update {} still present".format(r2.name, prefix)
logger.info( logger.info(
"{}, check that 'show mpls table {}' is not present".format( "{}, check that 'show mpls table {}' is not present".format(
router.name, label_ip_entries[prefix] r2.name, label_ip_entries[prefix]
) )
) )
test_func = functools.partial( test_func = functools.partial(
check_show_mpls_table_entry_label_not_found, router, label_ip_entries[prefix] check_show_mpls_table_entry_label_not_found, r2, label_ip_entries[prefix]
) )
success, _ = topotest.run_and_expect(test_func, None, count=10, wait=0.5) success, _ = topotest.run_and_expect(test_func, None, count=10, wait=0.5)
assert success, "r1, mpls entry with in_label {} still present".format( assert success, "r1, mpls entry with in_label {} still present".format(
@ -517,59 +531,74 @@ def test_r3_prefixes_added_back():
tgen = get_topogen() tgen = get_topogen()
if tgen.routers_have_failure(): if tgen.routers_have_failure():
pytest.skip(tgen.errors) pytest.skip(tgen.errors)
router = tgen.gears["r3"] r3 = tgen.gears["r3"]
prefix = "172.31.3.0/24" prefix = "172.31.3.0/24"
logger.info("{}, restoring the {} network from r3".format(router.name, prefix)) logger.info("{}, restoring the {} network from r3".format(r3.name, prefix))
router.vtysh_cmd("configure terminal\ninterface r3-eth3 vrf vrf1\nno shutdown\n") r3.vtysh_cmd(
"""
configure terminal
interface r3-eth3 vrf vrf1
no shutdown
"""
)
router = tgen.gears["r2"] r2 = tgen.gears["r2"]
logger.info( logger.info(
"{}, check that 'show bgp ipv4 vpn' has {} network from r3".format( "{}, check that 'show bgp ipv4 vpn' has {} network from r3".format(
router.name, prefix r2.name, prefix
) )
) )
test_func = functools.partial( test_func = functools.partial(
check_show_bgp_vpn_prefix_found, check_show_bgp_vpn_prefix_found,
router, r2,
"ipv4", "ipv4",
prefix, prefix,
"444:3", "444:3",
) )
success, _ = topotest.run_and_expect(test_func, None, count=10, wait=0.5) success, _ = topotest.run_and_expect(test_func, None, count=10, wait=0.5)
assert success, "{}, vpnv4 update {} not present".format(router.name, prefix) assert success, "{}, vpnv4 update {} not present".format(r2.name, prefix)
logger.info( logger.info(
"{}, check that 'show bgp ipv4 vpn' and 'show mpls table' are set accordingly on r2 and on r1".format( "{}, check that 'show bgp ipv4 vpn' and 'show mpls table' are set accordingly on r2 and on r1".format(
router.name r2.name
) )
) )
vpnv4_checks = { vpnv4_checks = {
prefix: "r1", prefix: "r1",
} }
check_show_bgp_vpn_ok(router, vpnv4_checks) check_show_bgp_vpn_ok(r2, vpnv4_checks)
router = tgen.gears["r3"] r3 = tgen.gears["r3"]
logger.info( logger.info(
"{}, restoring the redistribute connected prefixes from r3".format(router.name) "{}, restoring the redistribute connected prefixes from r3".format(r3.name)
) )
router.vtysh_cmd("configure terminal\ninterface r3-eth1 vrf vrf1\nno shutdown\n") r3.vtysh_cmd(
router.vtysh_cmd("configure terminal\ninterface r3-eth2 vrf vrf1\nno shutdown\n") """
router = tgen.gears["r2"] configure terminal
interface r3-eth1 vrf vrf1
no shutdown
!
interface r3-eth2 vrf vrf1
no shutdown
"""
)
r2 = tgen.gears["r2"]
for prefix in ("172.31.1.0/24", "172.31.2.0/24"): for prefix in ("172.31.1.0/24", "172.31.2.0/24"):
test_func = functools.partial( test_func = functools.partial(
check_show_bgp_vpn_prefix_found, check_show_bgp_vpn_prefix_found,
router, r2,
"ipv4", "ipv4",
prefix, prefix,
"444:3", "444:3",
) )
success, _ = topotest.run_and_expect(test_func, None, count=10, wait=0.5) success, _ = topotest.run_and_expect(test_func, None, count=10, wait=0.5)
assert success, "{}, vpnv4 update {} not present".format(router.name, prefix) assert success, "{}, vpnv4 update {} not present".format(r2.name, prefix)
# diagnostic # diagnostic
logger.info("Dumping mplsvpn nexthop table") logger.info("Dumping mplsvpn nexthop table")
tgen.gears["r2"].vtysh_cmd("show bgp mplsvpn-nh-label-bind detail", isjson=False) r2.vtysh_cmd("show bgp mplsvpn-nh-label-bind detail")
def test_unconfigure_nexthop_change_nexthop_self(): def test_unconfigure_nexthop_change_nexthop_self():
@ -583,44 +612,47 @@ def test_unconfigure_nexthop_change_nexthop_self():
if tgen.routers_have_failure(): if tgen.routers_have_failure():
pytest.skip(tgen.errors) pytest.skip(tgen.errors)
router = tgen.gears["r2"] r2 = tgen.gears["r2"]
vpnv4_checks = { vpnv4_checks = {
"172.31.1.0/24": "r1", "172.31.1.0/24": "r1",
"172.31.2.0/24": "r1", "172.31.2.0/24": "r1",
"172.31.3.0/24": "r1", "172.31.3.0/24": "r1",
} }
logger.info( logger.info(
"{}, Get the list of labels allocated for prefixes from r3".format(router.name) "{}, Get the list of labels allocated for prefixes from r3".format(r2.name)
) )
label_ip_entries = check_show_bgp_vpn_ok(router, vpnv4_checks) label_ip_entries = check_show_bgp_vpn_ok(r2, vpnv4_checks)
logger.info( logger.info("{}, disable next-hop-self for 192.0.2.100 neighbor".format(r2.name))
"{}, disable next-hop-self for 192.0.2.100 neighbor".format(router.name)
) r2.vtysh_cmd(
router = tgen.gears["r2"] """
router.vtysh_cmd( configure terminal
"configure terminal\nrouter bgp 65500\naddress-family ipv4 vpn\nno neighbor 192.0.2.100 next-hop-self\n" router bgp 65500
address-family ipv4 vpn
no neighbor 192.0.2.100 next-hop-self
"""
) )
for prefix, label in label_ip_entries.items(): for prefix, label in label_ip_entries.items():
logger.info( logger.info(
"{}, check mpls entry for {} with in_label {} is not present'".format( "{}, check mpls entry for {} with in_label {} is not present'".format(
router.name, prefix, label r2.name, prefix, label
) )
) )
test_func = functools.partial( test_func = functools.partial(
check_show_mpls_table_entry_label_not_found, router, label check_show_mpls_table_entry_label_not_found, r2, label
) )
success, _ = topotest.run_and_expect(test_func, None, count=10, wait=0.5) success, _ = topotest.run_and_expect(test_func, None, count=10, wait=0.5)
assert success, "r1, mpls entry for {} with in_label {} still present".format( assert success, "r1, mpls entry for {} with in_label {} still present".format(
prefix, label prefix, label
) )
router = tgen.gears["r1"] r1 = tgen.gears["r1"]
for prefix, label in label_ip_entries.items(): for prefix, label in label_ip_entries.items():
test_func = functools.partial( test_func = functools.partial(
check_show_bgp_vpn_prefix_not_found, check_show_bgp_vpn_prefix_not_found,
router, r1,
"ipv4", "ipv4",
prefix, prefix,
"444:3", "444:3",
@ -628,12 +660,12 @@ def test_unconfigure_nexthop_change_nexthop_self():
) )
success, _ = topotest.run_and_expect(test_func, None, count=10, wait=0.5) success, _ = topotest.run_and_expect(test_func, None, count=10, wait=0.5)
assert success, "{}, mpls vpn update {} label {} is present".format( assert success, "{}, mpls vpn update {} label {} is present".format(
router.name, prefix, label r1.name, prefix, label
) )
for prefix, label in label_ip_entries.items(): for prefix, label in label_ip_entries.items():
test_func = functools.partial( test_func = functools.partial(
check_show_bgp_vpn_prefix_found, check_show_bgp_vpn_prefix_found,
router, r1,
"ipv4", "ipv4",
prefix, prefix,
"444:3", "444:3",
@ -641,12 +673,12 @@ def test_unconfigure_nexthop_change_nexthop_self():
) )
success, _ = topotest.run_and_expect(test_func, None, count=10, wait=0.5) success, _ = topotest.run_and_expect(test_func, None, count=10, wait=0.5)
assert success, "{}, mpls vpn update {} label {} is present".format( assert success, "{}, mpls vpn update {} label {} is present".format(
router.name, prefix, label r1.name, prefix, label
) )
# diagnostic # diagnostic
logger.info("Dumping mplsvpn nexthop table") logger.info("Dumping mplsvpn nexthop table")
tgen.gears["r2"].vtysh_cmd("show bgp mplsvpn-nh-label-bind detail", isjson=False) tgen.gears["r2"].vtysh_cmd("show bgp mplsvpn-nh-label-bind detail")
def test_reconfigure_nexthop_change_nexthop_self(): def test_reconfigure_nexthop_change_nexthop_self():
@ -660,10 +692,15 @@ def test_reconfigure_nexthop_change_nexthop_self():
if tgen.routers_have_failure(): if tgen.routers_have_failure():
pytest.skip(tgen.errors) pytest.skip(tgen.errors)
router = tgen.gears["r2"] r2 = tgen.gears["r2"]
logger.info("{}, enable next-hop-self for 192.0.2.100 neighbor".format(router.name)) logger.info("{}, enable next-hop-self for 192.0.2.100 neighbor".format(r2.name))
router.vtysh_cmd( r2.vtysh_cmd(
"configure terminal\nrouter bgp 65500\naddress-family ipv4 vpn\nneighbor 192.0.2.100 next-hop-self\n" """
configure terminal
router bgp 65500
address-family ipv4 vpn
neighbor 192.0.2.100 next-hop-self
"""
) )
vpnv4_checks = { vpnv4_checks = {
"172.31.1.0/24": "r1", "172.31.1.0/24": "r1",
@ -672,17 +709,17 @@ def test_reconfigure_nexthop_change_nexthop_self():
} }
logger.info( logger.info(
"{}, check that 'show bgp ipv4 vpn' and 'show mpls table' are set accordingly on r2 and on r1".format( "{}, check that 'show bgp ipv4 vpn' and 'show mpls table' are set accordingly on r2 and on r1".format(
router.name r2.name
) )
) )
check_show_bgp_vpn_ok(router, vpnv4_checks) check_show_bgp_vpn_ok(r2, vpnv4_checks)
logger.info("h1, check that ping from h1 to (h2,h3) is ok") logger.info("h1, check that ping from h1 to (h2,h3) is ok")
check_ping("h1", "172.31.1.10", True, 20, 0.5) check_ping("h1", "172.31.1.10", True, 20, 0.5)
check_ping("h1", "172.31.2.10", True, 20, 0.5) check_ping("h1", "172.31.2.10", True, 20, 0.5)
# diagnostic # diagnostic
logger.info("Dumping mplsvpn nexthop table") logger.info("Dumping mplsvpn nexthop table")
router.vtysh_cmd("show bgp mplsvpn-nh-label-bind detail", isjson=False) r2.vtysh_cmd("show bgp mplsvpn-nh-label-bind detail")
def test_declare_vpn_network_with_different_label(): def test_declare_vpn_network_with_different_label():
@ -696,20 +733,21 @@ def test_declare_vpn_network_with_different_label():
if tgen.routers_have_failure(): if tgen.routers_have_failure():
pytest.skip(tgen.errors) pytest.skip(tgen.errors)
router = tgen.gears["r3"] r3 = tgen.gears["r3"]
logger.info( logger.info(
"{}, declare static 33.33.33.33/32 network rd 33:33 label 33".format( "{}, declare static 33.33.33.33/32 network rd 33:33 label 33".format(r3.name)
router.name
)
) )
router.vtysh_cmd( r3.vtysh_cmd(
"configure terminal\nrouter bgp 65501\nno bgp network import-check\n" """
) configure terminal
router.vtysh_cmd( router bgp 65501
"configure terminal\nrouter bgp 65501\naddress-family ipv4 vpn\nnetwork 33.33.33.33/32 rd 444:3 label 33\n" no bgp network import-check\n"
address-family ipv4 vpn
network 33.33.33.33/32 rd 444:3 label 33
"""
) )
router = tgen.gears["r2"] r2 = tgen.gears["r2"]
vpnv4_entries = { vpnv4_entries = {
"172.31.1.0/24": None, "172.31.1.0/24": None,
"172.31.2.0/24": None, "172.31.2.0/24": None,
@ -720,7 +758,7 @@ def test_declare_vpn_network_with_different_label():
for prefix, label in vpnv4_entries.items(): for prefix, label in vpnv4_entries.items():
test_func = functools.partial( test_func = functools.partial(
check_show_bgp_vpn_prefix_found, check_show_bgp_vpn_prefix_found,
router, r2,
"ipv4", "ipv4",
prefix, prefix,
"444:3", "444:3",
@ -729,7 +767,7 @@ def test_declare_vpn_network_with_different_label():
) )
success, _ = topotest.run_and_expect(test_func, None, count=10, wait=0.5) success, _ = topotest.run_and_expect(test_func, None, count=10, wait=0.5)
assert success, "{}, vpnv4 update {}, label {} not present".format( assert success, "{}, vpnv4 update {}, label {} not present".format(
router.name, prefix, label r2.name, prefix, label
) )
vpnv4_checks = { vpnv4_checks = {
@ -740,10 +778,10 @@ def test_declare_vpn_network_with_different_label():
} }
logger.info( logger.info(
"{}, check that 'show bgp ipv4 vpn' and 'show mpls table' are set accordingly on r2 and on r1".format( "{}, check that 'show bgp ipv4 vpn' and 'show mpls table' are set accordingly on r2 and on r1".format(
router.name r2.name
) )
) )
check_show_bgp_vpn_ok(router, vpnv4_checks) check_show_bgp_vpn_ok(r2, vpnv4_checks)
def test_filter_vpn_network_from_r1(): def test_filter_vpn_network_from_r1():
@ -757,52 +795,51 @@ def test_filter_vpn_network_from_r1():
if tgen.routers_have_failure(): if tgen.routers_have_failure():
pytest.skip(tgen.errors) pytest.skip(tgen.errors)
router = tgen.gears["r2"] r2 = tgen.gears["r2"]
vpnv4_checks = { vpnv4_checks = {
"172.31.0.0/24": "r3", "172.31.0.0/24": "r3",
} }
logger.info( logger.info(
"{}, check that 'show bgp ipv4 vpn' and 'show mpls table' are set accordingly on r2 and on r3".format( "{}, check that 'show bgp ipv4 vpn' and 'show mpls table' are set accordingly on r2 and on r3".format(
router.name r2.name
) )
) )
label_ip_entries = check_show_bgp_vpn_ok(router, vpnv4_checks) label_ip_entries = check_show_bgp_vpn_ok(r2, vpnv4_checks)
for prefix, label in label_ip_entries.items(): for prefix, label in label_ip_entries.items():
logger.info("{}, filter prefix {} from r1".format(router.name, prefix)) logger.info("{}, filter prefix {} from r1".format(r2.name, prefix))
router.vtysh_cmd( r2.vtysh_cmd(
"configure terminal\nroute-map rmap deny 1\nmatch ip next-hop address 192.0.2.1\n" """
) configure terminal
router.vtysh_cmd( route-map rmap deny 1
"configure terminal\nrouter bgp 65500\naddress-family ipv4 vpn\nneighbor 192.0.2.100 route-map rmap in\n" match ip next-hop address 192.0.2.1
) !
logger.info( router bgp 65500
"{}, check that prefix {} is not present".format(router.name, prefix) address-family ipv4 vpn
neighbor 192.0.2.100 route-map rmap in
"""
) )
logger.info("{}, check that prefix {} is not present".format(r2.name, prefix))
test_func = functools.partial( test_func = functools.partial(
check_show_bgp_vpn_prefix_not_found, check_show_bgp_vpn_prefix_not_found,
router, r2,
"ipv4", "ipv4",
"172.31.0.0/24", "172.31.0.0/24",
"444:1", "444:1",
) )
success, _ = topotest.run_and_expect(test_func, None, count=10, wait=0.5) success, _ = topotest.run_and_expect(test_func, None, count=10, wait=0.5)
assert success, "{}, vpnv4 update {}, is still present".format( assert success, "{}, vpnv4 update {}, is still present".format(r2.name, prefix)
router.name, prefix
)
# diagnostic # diagnostic
logger.info("Dumping mplsvpn nexthop table") logger.info("Dumping mplsvpn nexthop table")
router.vtysh_cmd("show bgp mplsvpn-nh-label-bind detail", isjson=False) r2.vtysh_cmd("show bgp mplsvpn-nh-label-bind detail")
logger.info( logger.info(
"{}, check that show mpls table {} is not present".format( "{}, check that show mpls table {} is not present".format(r2.name, label)
router.name, label
)
) )
test_func = functools.partial( test_func = functools.partial(
check_show_mpls_table_entry_label_not_found, router, int(label) check_show_mpls_table_entry_label_not_found, r2, int(label)
) )
success, _ = topotest.run_and_expect(test_func, None, count=10, wait=0.5) success, _ = topotest.run_and_expect(test_func, None, count=10, wait=0.5)
assert success, "r1, mpls entry for {} with in_label {} still present".format( assert success, "r1, mpls entry for {} with in_label {} still present".format(
@ -821,34 +858,34 @@ def test_unfilter_vpn_network_from_r1():
if tgen.routers_have_failure(): if tgen.routers_have_failure():
pytest.skip(tgen.errors) pytest.skip(tgen.errors)
router = tgen.gears["r2"] r2 = tgen.gears["r2"]
prefix = "172.31.0.0/24" prefix = "172.31.0.0/24"
logger.info("{}, filter prefix {} from r1".format(router.name, prefix)) logger.info("{}, filter prefix {} from r1".format(r2.name, prefix))
router.vtysh_cmd( r2.vtysh_cmd(
"configure terminal\nrouter bgp 65500\naddress-family ipv4 vpn\nno neighbor 192.0.2.100 route-map rmap in\n" "configure terminal\nrouter bgp 65500\naddress-family ipv4 vpn\nno neighbor 192.0.2.100 route-map rmap in\n"
) )
logger.info("{}, check that prefix {} is present".format(router.name, prefix)) logger.info("{}, check that prefix {} is present".format(r2.name, prefix))
test_func = functools.partial( test_func = functools.partial(
check_show_bgp_vpn_prefix_found, router, "ipv4", prefix, "444:1" check_show_bgp_vpn_prefix_found, r2, "ipv4", prefix, "444:1"
) )
success, _ = topotest.run_and_expect(test_func, None, count=10, wait=0.5) success, _ = topotest.run_and_expect(test_func, None, count=10, wait=0.5)
assert success, "{}, vpnv4 update {}, is not present".format(router.name, prefix) assert success, "{}, vpnv4 update {}, is not present".format(r2.name, prefix)
vpnv4_checks = { vpnv4_checks = {
"172.31.0.0/24": "r3", "172.31.0.0/24": "r3",
} }
logger.info( logger.info(
"{}, check that 'show bgp ipv4 vpn' and 'show mpls table' are set accordingly on all devices".format( "{}, check that 'show bgp ipv4 vpn' and 'show mpls table' are set accordingly on all devices".format(
router.name r2.name
) )
) )
check_show_bgp_vpn_ok(router, vpnv4_checks) check_show_bgp_vpn_ok(r2, vpnv4_checks)
# diagnostic # diagnostic
logger.info("Dumping mplsvpn nexthop table") logger.info("Dumping mplsvpn nexthop table")
router.vtysh_cmd("show bgp mplsvpn-nh-label-bind detail", isjson=False) r2.vtysh_cmd("show bgp mplsvpn-nh-label-bind detail")
def test_memory_leak(): def test_memory_leak():