NoRecordFound,
NoExternalPortFound
)
-from .sdnconn import SdnConnectorError
+from osm_ro_plugin.sdnconn import SdnConnectorError
INSTANCE_NET_STATUS_ERROR = ('DOWN', 'ERROR', 'VIM_ERROR',
'DELETED', 'SCHEDULED_DELETION')
return merge_dicts(wan_port_mapping, service_mapping_info=mapping)
def _get_port_sdn(self, ovim, instance_net):
- criteria = {'net_id': instance_net['sdn_net_id']}
try:
- local_port_mapping = ovim.get_ports(filter=criteria)
+ local_port_mapping = ovim.get_ports(instance_net['sdn_net_id'])
if local_port_mapping:
return (local_port_mapping[0]['switch_dpid'],
except: # noqa
self.logger.exception('Problems when calling OpenVIM')
- self.logger.debug('No ports found using criteria:\n%r\n.', criteria)
+ self.logger.debug("No ports found for sdn_net_id='{}'", instance_net['sdn_net_id'])
return None
def _evaluate_rules(self, rules, vim_info):
if details.get('encapsulation_type') == 'vlan':
point['service_endpoint_encapsulation_type'] = 'dot1q'
point['service_endpoint_encapsulation_info'] = {
- 'vlan': details['encapsulation_id']
+ 'vlan': details['encapsulation_id'],
+ 'switch_dpid': wan_info['switch_dpid'],
+ 'switch_port': wan_info['switch_port']
}
else:
point['service_endpoint_encapsulation_type'] = 'none'
if len(connection_points) == 2:
return 'ELINE'
else:
- raise NotImplementedError('Multipoint connectivity is not '
- 'supported yet.')
+ # added to support DPB WIM connector
+ return 'ELAN'
def _update_persistent_data(self, persistence, service_uuid, conn_info):
"""Store plugin/connector specific information in the database"""