The key is used to create the EGRE tunnel.
"""
def setup_virtual_link(slice, key, rate, myid, nodeid, ipaddr, virtip, vnet):
- logger.log("%s: Set up virtual link to node %d" % (slice, nodeid))
+ logger.log("%s: Set up virtual link to node %s" % (slice, nodeid))
run(setup_link_cmd + " %s %s %s %s %s %s %s" % (slice, nodeid, ipaddr,
key, rate, virtip, vnet))
return
for iface in old_ifaces:
m = re.match(pattern1, iface)
if m:
- key = int(m.group(1))
- node = int(m.group(2))
+ key = m.group(1)
+ node = m.group(2)
teardown_virtual_link(key, node)
m = re.match(pattern2, iface)
if m:
- key = int(m.group(1))
+ key = m.group(1)
teardown_nat(key)
return
logger.log("%s: virtual link to node %s exists" % (slice, nodeid))
refresh_virtual_link(nodeid, key)
+
+"""
+Update NAT interface for the slice
+"""
+def update_nat(slice, myid, key, netns):
if not nat_exists(key):
if netns:
setup_nat(slice, myid, key)
f = open(filename, 'w')
password = "zebra"
write_header(f, myname, password)
+ name = None
for name in ifaces:
f.write ("""!
ip ospf network non-broadcast
""" % name)
- f.write ("""!
+ if name:
+ f.write ("""!
router ospf
ospf router-id %s
""" % ifaces[name]['local-ip'])
f.close()
return
+"""
+Write /etc/vini/egre-keys.txt, used by vsys topo scripts
+"""
+def write_egre_keys(slicekeys):
+ vini_dir = "/etc/vini"
+ if not os.path.exists(vini_dir):
+ try:
+ os.mkdir(vini_dir)
+ except os.error:
+ logger.log("topo: could not create %s\n" % vini_dir)
+ return
+ keys_file = "%s/egre-keys.txt" % vini_dir
+ f = open(keys_file, 'w')
+ for slice in slicekeys:
+ f.write("%s %s\n" % (slice, slicekeys[slice]))
+ f.close()
+ return
+
+"""
+Executed on NM startup
+"""
def start(options, config):
run ("echo 1 > /proc/sys/net/ipv4/ip_forward")
pass
global ifaces, old_ifaces
ifaces = old_ifaces = sioc.gifconf()
+ slicekeys = {}
for sliver in data['slivers']:
attrs = {}
- for attribute in sliver['attributes']:
- attrs[attribute['tagname']] = attribute['value']
+ for tag in sliver['attributes']:
+ attrs[tag['tagname']] = tag['value']
+ if tag['tagname'] == 'egre_key':
+ slicekeys[sliver['name']] = tag['value']
+
if 'netns' in attrs:
netns = int(attrs['netns'])
write_conf_and_restart(sliver['name'], netns)
if vserver.VServer(sliver['name']).is_running():
- if 'egre_key' in attrs and 'topo_rspec' in attrs:
- logger.log("topo: Update topology for slice %s" % \
- sliver['name'])
- update_links(sliver['name'], data['node_id'],
- attrs['topo_rspec'], attrs['egre_key'], netns)
- update_quagga_configs(sliver['name'], data['hostname'],
- data['node_id'], attrs['topo_rspec'],
- attrs['egre_key'], netns)
+ if 'egre_key' in attrs:
+ logger.log("topo: Update slice %s" % sliver['name'])
+ update_nat(sliver['name'], data['node_id'], attrs['egre_key'],
+ netns)
+ if 'topo_rspec' in attrs:
+ update_links(sliver['name'], data['node_id'],
+ attrs['topo_rspec'], attrs['egre_key'], netns)
+ update_quagga_configs(sliver['name'], data['hostname'],
+ data['node_id'], attrs['topo_rspec'],
+ attrs['egre_key'], netns)
if 'hosts' in attrs:
update_hosts(sliver['name'], attrs['hosts'])
else:
sliver['name'])
clean_up_old_virtual_links()
+ write_egre_keys(slicekeys)
return