90 lines
3.0 KiB
Python
90 lines
3.0 KiB
Python
|
from charmhelpers.core.hookenv import (
|
||
|
|
relation_ids,
|
||
|
|
related_units,
|
||
|
|
relation_get,
|
||
|
|
is_relation_made,
|
||
|
|
config,
|
||
|
|
unit_get,
|
||
|
|
log,
|
||
|
|
)
|
||
|
|
|
||
|
|
from charmhelpers.contrib.openstack import context
|
||
|
|
from charmhelpers.core.host import service_running, service_start
|
||
|
|
from charmhelpers.contrib.network.ovs import add_bridge
|
||
|
|
from charmhelpers.contrib.openstack.utils import get_host_ip
|
||
|
|
OVS_BRIDGE = 'br-int'
|
||
|
|
|
||
|
|
class OSContextError(Exception):
|
||
|
|
pass
|
||
|
|
class NovaComputeAMQPContext(context.OSContextGenerator):
|
||
|
|
def __call__(self):
|
||
|
|
conf = config()
|
||
|
|
try:
|
||
|
|
username = conf['rabbit-user']
|
||
|
|
vhost = conf['rabbit-vhost']
|
||
|
|
except KeyError as e:
|
||
|
|
log('Could not generate shared_db context. '
|
||
|
|
'Missing required charm config options: %s.' % e)
|
||
|
|
raise OSContextError
|
||
|
|
ctxt = {}
|
||
|
|
for rid in relation_ids('neutron-plugin'):
|
||
|
|
for unit in related_units(rid):
|
||
|
|
if relation_get('clustered', rid=rid, unit=unit):
|
||
|
|
ctxt['clustered'] = True
|
||
|
|
ctxt['rabbitmq_host'] = relation_get('vip', rid=rid,
|
||
|
|
unit=unit)
|
||
|
|
else:
|
||
|
|
ctxt['rabbitmq_host'] = relation_get('private-address',
|
||
|
|
rid=rid, unit=unit)
|
||
|
|
ctxt.update({
|
||
|
|
'rabbitmq_user': username,
|
||
|
|
'rabbitmq_password': relation_get('rabbitmq_password', rid=rid,
|
||
|
|
unit=unit),
|
||
|
|
'rabbitmq_virtual_host': vhost,
|
||
|
|
})
|
||
|
|
return ctxt
|
||
|
|
|
||
|
|
def _neutron_security_groups():
|
||
|
|
'''
|
||
|
|
Inspects current neutron-plugin relation and determine if nova-c-c has
|
||
|
|
instructed us to use neutron security groups.
|
||
|
|
'''
|
||
|
|
for rid in relation_ids('neutron-plugin'):
|
||
|
|
for unit in related_units(rid):
|
||
|
|
return relation_get('neutron_security_groups',rid=rid, unit=unit)
|
||
|
|
return False
|
||
|
|
|
||
|
|
class OVSPluginContext(context.NeutronContext):
|
||
|
|
interfaces = []
|
||
|
|
|
||
|
|
@property
|
||
|
|
def plugin(self):
|
||
|
|
return 'ovs'
|
||
|
|
|
||
|
|
@property
|
||
|
|
def network_manager(self):
|
||
|
|
return 'neutron'
|
||
|
|
|
||
|
|
@property
|
||
|
|
def neutron_security_groups(self):
|
||
|
|
return _neutron_security_groups()
|
||
|
|
|
||
|
|
def _ensure_bridge(self):
|
||
|
|
if not service_running('openvswitch-switch'):
|
||
|
|
service_start('openvswitch-switch')
|
||
|
|
add_bridge(OVS_BRIDGE)
|
||
|
|
|
||
|
|
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()
|
||
|
|
|
||
|
|
ovs_ctxt['local_ip'] = get_host_ip(unit_get('private-address'))
|
||
|
|
ovs_ctxt['neutron_security_groups'] = self.neutron_security_groups
|
||
|
|
return ovs_ctxt
|