openstack/neutron
Code Issues Proposed changes

Merge "Handle all portbinding attrs in case of bulk port creation"

Browse Source
This commit is contained in:
Zuul 2021-08-31 07:28:31 +00:00 committed by Gerrit Code Review
commit a2ffbfa552
2 changed files with 24 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
neutron/plugins/ml2/plugin.py
View File

@ -1592,6 +1592,10 @@ class Ml2Plugin(db_base_plugin_v2.NeutronDbPluginV2,
process_extensions=False) process_extensions=False)
port_dict[portbindings.HOST_ID] = pdata.get( port_dict[portbindings.HOST_ID] = pdata.get(
portbindings.HOST_ID) portbindings.HOST_ID)
port_dict[portbindings.VNIC_TYPE] = pdata.get(
portbindings.VNIC_TYPE)
port_dict[portbindings.PROFILE] = pdata.get(
portbindings.PROFILE)
# Activities immediately post-port-creation # Activities immediately post-port-creation
self.extension_manager.process_create_port(context, pdata, self.extension_manager.process_create_port(context, pdata,

20
neutron/tests/unit/plugins/ml2/test_plugin.py
View File

@ -1388,6 +1388,26 @@ class TestMl2PortsV2(test_plugin.TestPortsV2, Ml2PluginV2TestCase):
else: else:
self.assertTrue('ports' in ports) self.assertTrue('ports' in ports)
def test_create_ports_bulk_with_portbinding_attrs(self):
ctx = context.get_admin_context()
with self.network() as net:
overrides = {0: {portbindings.HOST_ID: 'host1',
portbindings.VNIC_TYPE: 'direct',
portbindings.PROFILE: {'foo': 'foo'}},
1: {portbindings.HOST_ID: 'host2',
portbindings.VNIC_TYPE: 'macvtap',
portbindings.PROFILE: {'bar': 'bar'}}}
res = self._create_port_bulk(self.fmt, 2, net['network']['id'],
'test', True, context=ctx,
override=overrides)
ports = self.deserialize(self.fmt, res)['ports']
self.assertCountEqual(['direct', 'macvtap'],
[p[portbindings.VNIC_TYPE] for p in ports])
self.assertCountEqual([{'foo': 'foo'}, {'bar': 'bar'}],
[p[portbindings.PROFILE] for p in ports])
self.assertCountEqual(['host1', 'host2'],
[p[portbindings.HOST_ID] for p in ports])
def test_create_ports_bulk_with_sec_grp_member_provider_update(self): def test_create_ports_bulk_with_sec_grp_member_provider_update(self):
ctx = context.get_admin_context() ctx = context.get_admin_context()
plugin = directory.get_plugin() plugin = directory.get_plugin()