1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
|
"""Utilities for setting up quagga peering"""
import re
import time
import functest.utils.functest_logger as ft_logger
import functest.utils.functest_utils as ft_utils
import sdnvpn.lib.config as config
from sdnvpn.lib.utils import run_odl_cmd, exec_cmd
logger = ft_logger.Logger("sdnvpn-quagga").getLogger()
COMMON_CONFIG = config.CommonConfig()
def odl_add_neighbor(neighbor_ip, controller):
command = 'configure-bgp -op add-neighbor --as-num 200'
command += ' --ip %s --use-source-ip %s' % (neighbor_ip, controller.ip)
success = run_odl_cmd(controller, command)
return success
def bootstrap_quagga(fip_addr, controller_ip):
script = gen_quagga_setup_script(
controller_ip,
fip_addr)
cmd = "sshpass -popnfv ssh opnfv@%s << EOF %s EOF" % (fip_addr, script)
rc = ft_utils.execute_command(cmd)
return rc == 0
def gen_quagga_setup_script(controller_ip,
fake_floating_ip,
ext_net_mask):
with open(COMMON_CONFIG.quagga_setup_script_path) as f:
template = f.read()
script = template % (controller_ip,
fake_floating_ip,
ext_net_mask)
return script
def check_for_peering(controller):
cmd = 'show-bgp --cmd "ip bgp neighbors"'
tries = 20
neighbors = None
bgp_state_regex = re.compile("(BGP state =.*)")
opens_regex = re.compile("Opens:(.*)")
while tries > 0:
if neighbors and 'Established' in neighbors:
break
neighbors = run_odl_cmd(controller, cmd)
logger.info("Output of %s: %s", cmd, neighbors)
if neighbors:
opens = opens_regex.search(neighbors)
if opens:
logger.info("Opens sent/received: %s", opens.group(1))
state = bgp_state_regex.search(neighbors)
if state:
logger.info("Peering state: %s", state.group(1))
tries -= 1
time.sleep(1)
if not neighbors or 'Established' not in neighbors:
logger.error("Quagga failed to peer with OpenDaylight")
logger.error("OpenDaylight status: %s", neighbors)
return False
logger.info("Quagga peered with OpenDaylight")
return True
def check_for_route_exchange(ip):
"""Check that Quagga has learned the route to an IP"""
logger.debug("Checking that '%s' is in the Zebra routing table", ip)
routes, success = exec_cmd("vtysh -c 'show ip route'", verbose=True)
if not success:
return False
logger.debug("Zebra routing table: %s", routes)
return ip in routes
|