114 lines
3.8 KiB
Python
114 lines
3.8 KiB
Python
from charmhelpers.core.hookenv import (
|
|
relation_ids,
|
|
related_units,
|
|
relation_get,
|
|
config,
|
|
unit_get,
|
|
)
|
|
from charmhelpers.core.host import list_nics, get_nic_hwaddr
|
|
from charmhelpers.contrib.openstack import context
|
|
from charmhelpers.core.host import service_running, service_start
|
|
from charmhelpers.contrib.network.ovs import add_bridge, add_bridge_port
|
|
from charmhelpers.contrib.openstack.utils import get_host_ip
|
|
from charmhelpers.contrib.network.ip import get_address_in_network
|
|
|
|
import re
|
|
|
|
OVS_BRIDGE = 'br-int'
|
|
DATA_BRIDGE = 'br-data'
|
|
|
|
|
|
def _neutron_api_settings():
|
|
'''
|
|
Inspects current neutron-plugin relation
|
|
'''
|
|
neutron_settings = {
|
|
'neutron_security_groups': False,
|
|
'l2_population': True,
|
|
'overlay_network_type': 'gre',
|
|
}
|
|
for rid in relation_ids('neutron-plugin-api'):
|
|
for unit in related_units(rid):
|
|
rdata = relation_get(rid=rid, unit=unit)
|
|
if 'l2-population' not in rdata:
|
|
continue
|
|
neutron_settings = {
|
|
'l2_population': rdata['l2-population'],
|
|
'neutron_security_groups': rdata['neutron-security-groups'],
|
|
'overlay_network_type': rdata['overlay-network-type'],
|
|
}
|
|
# Override with configuration if set to true
|
|
if config('disable-security-groups'):
|
|
neutron_settings['neutron_security_groups'] = False
|
|
return neutron_settings
|
|
return neutron_settings
|
|
|
|
|
|
class OVSPluginContext(context.NeutronContext):
|
|
interfaces = []
|
|
|
|
@property
|
|
def plugin(self):
|
|
return 'ovs'
|
|
|
|
@property
|
|
def network_manager(self):
|
|
return 'neutron'
|
|
|
|
@property
|
|
def neutron_security_groups(self):
|
|
neutron_api_settings = _neutron_api_settings()
|
|
return neutron_api_settings['neutron_security_groups']
|
|
|
|
def get_data_port(self):
|
|
data_ports = config('data-port')
|
|
if not data_ports:
|
|
return None
|
|
hwaddrs = {}
|
|
for nic in list_nics(['eth', 'bond']):
|
|
hwaddrs[get_nic_hwaddr(nic).lower()] = nic
|
|
mac_regex = re.compile(r'([0-9A-F]{2}[:-]){5}([0-9A-F]{2})', re.I)
|
|
for entry in data_ports.split():
|
|
entry = entry.strip().lower()
|
|
if re.match(mac_regex, entry):
|
|
if entry in hwaddrs:
|
|
return hwaddrs[entry]
|
|
else:
|
|
return entry
|
|
return None
|
|
|
|
def _ensure_bridge(self):
|
|
if not service_running('openvswitch-switch'):
|
|
service_start('openvswitch-switch')
|
|
add_bridge(OVS_BRIDGE)
|
|
add_bridge(DATA_BRIDGE)
|
|
data_port = self.get_data_port()
|
|
if data_port:
|
|
add_bridge_port(DATA_BRIDGE, data_port, promisc=True)
|
|
|
|
def ovs_ctxt(self):
|
|
# In addition to generating config context, ensure the OVS service
|
|
# is running and the OVS bridge exists. Also need to ensure
|
|
# local_ip points to actual IP, not hostname.
|
|
ovs_ctxt = super(OVSPluginContext, self).ovs_ctxt()
|
|
if not ovs_ctxt:
|
|
return {}
|
|
|
|
self._ensure_bridge()
|
|
|
|
conf = config()
|
|
ovs_ctxt['local_ip'] = \
|
|
get_address_in_network(config('os-data-network'),
|
|
get_host_ip(unit_get('private-address')))
|
|
neutron_api_settings = _neutron_api_settings()
|
|
ovs_ctxt['neutron_security_groups'] = self.neutron_security_groups
|
|
ovs_ctxt['l2_population'] = neutron_api_settings['l2_population']
|
|
ovs_ctxt['overlay_network_type'] = \
|
|
neutron_api_settings['overlay_network_type']
|
|
# TODO: We need to sort out the syslog and debug/verbose options as a
|
|
# general context helper
|
|
ovs_ctxt['use_syslog'] = conf['use-syslog']
|
|
ovs_ctxt['verbose'] = conf['verbose']
|
|
ovs_ctxt['debug'] = conf['debug']
|
|
return ovs_ctxt
|