openstack/neutron
Code Issues Proposed changes

Merge "Subcribe trunk & subport events to set subport id"

Browse Source
This commit is contained in:
Zuul 2020-03-30 19:21:24 +00:00 committed by Gerrit Code Review
commit 8a62683bea
2 changed files with 54 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
neutron/services/trunk/plugin.py
View File

@ -433,3 +433,23 @@ class TrunkPlugin(service_base.ServicePluginBase):
self.update_trunk(
context, trunk_id,
{'trunk': {'status': constants.TRUNK_DOWN_STATUS}})
@registry.receives(trunk_apidef.TRUNK,
[events.AFTER_CREATE, events.AFTER_DELETE])
@registry.receives(resources.SUBPORTS,
[events.AFTER_CREATE, events.AFTER_DELETE])
def _process_subport_device_id_event(self, resource, event,
trunk_plugin, payload):
context = payload.context
if resource == resources.SUBPORTS:
subports = payload.subports
trunk = payload.original_trunk
elif resource == trunk_apidef.TRUNK:
trunk = payload.current_trunk or payload.original_trunk
subports = trunk.sub_ports
if subports and trunk:
core_plugin = directory.get_plugin()
device_id = trunk.id if event == events.AFTER_CREATE else ''
for subport in subports:
core_plugin.update_port(context, subport.port_id,
{'port': {'device_id': device_id}})

34
neutron/tests/unit/services/trunk/test_plugin.py
View File

@ -345,6 +345,40 @@ class TrunkPluginTestCase(test_plugin.Ml2PluginV2TestCase):
self.assertEqual(final_trunk_status, current_trunk.status)
return trunk, current_trunk
def test__process_subport_device_id_event(self):
plugin = directory.get_plugin()
with self.port() as parent_port, self.port() as child_port1:
with self.port() as child_port2:
subport1 = create_subport_dict(child_port1['port']['id'])
trunk = self._create_test_trunk(parent_port,
subports=[subport1])
child_port1 = plugin.get_port(self.context,
child_port1['port']['id'])
self.assertEqual(trunk['id'], child_port1['device_id'])
subport2 = {
'segmentation_type': 'vlan',
'segmentation_id': 321,
'port_id': child_port2['port']['id']
}
self.trunk_plugin.add_subports(self.context, trunk['id'],
{'sub_ports': [subport2]})
child_port2 = plugin.get_port(self.context,
child_port2['port']['id'])
self.assertEqual(trunk['id'], child_port2['device_id'])
trunk = self.trunk_plugin.remove_subports(
self.context, trunk['id'],
{'sub_ports': [{'port_id': child_port2['id']}]})
child_port2 = plugin.get_port(self.context,
child_port2['id'])
self.assertEqual('', child_port2['device_id'])
self.trunk_plugin.delete_trunk(self.context, trunk['id'])
child_port1 = plugin.get_port(self.context,
child_port1['id'])
self.assertEqual('', child_port1['device_id'])
class TrunkPluginCompatDriversTestCase(test_plugin.Ml2PluginV2TestCase):