x/vmware-nsx
Code Issues Proposed changes

Merge "NSX|P: Fix listener create & update"

Browse Source
This commit is contained in:
Zuul 2020-07-02 07:50:23 +00:00 committed by Gerrit Code Review
commit d366383af6
2 changed files with 31 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
vmware_nsx/services/lbaas/nsx_p/implementation/listener_mgr.py
View File

@ -91,11 +91,14 @@ class EdgeListenerManagerFromDict(base_mgr.NsxpLoadbalancerBaseManager):
lb_vip_address = floating_ips[0]['floating_ip_address'] lb_vip_address = floating_ips[0]['floating_ip_address']
else: else:
lb_vip_address = listener['loadbalancer']['vip_address'] lb_vip_address = listener['loadbalancer']['vip_address']
lb_service = lb_utils.get_lb_nsx_lb_service(
self.core_plugin.nsxpolicy, listener['loadbalancer_id'])
kwargs = {'virtual_server_id': listener['id'], kwargs = {'virtual_server_id': listener['id'],
'ip_address': lb_vip_address, 'ip_address': lb_vip_address,
'ports': [listener['protocol_port']], 'ports': [listener['protocol_port']],
'application_profile_id': listener['id'], 'application_profile_id': listener['id'],
'lb_service_id': listener['loadbalancer_id'], 'lb_service_id': lb_service['id'],
'description': listener.get('description')} 'description': listener.get('description')}
if vs_name: if vs_name:
kwargs['name'] = vs_name kwargs['name'] = vs_name

27
vmware_nsx/tests/unit/services/lbaas/test_nsxp_driver.py
View File

@ -734,6 +734,9 @@ class TestEdgeLbaasV2Listener(BaseTestEdgeLbaasV2):
mock.patch.object(self.core_plugin, mock.patch.object(self.core_plugin,
'get_waf_profile_path_and_mode', 'get_waf_profile_path_and_mode',
return_value=(None, None)), \ return_value=(None, None)), \
mock.patch.object(self.core_plugin.nsxpolicy, 'search_by_tags',
return_value={'results': [
{'id': LB_SERVICE_ID}]}),\
mock.patch.object(self.vs_client, 'create_or_overwrite' mock.patch.object(self.vs_client, 'create_or_overwrite'
) as mock_add_virtual_server: ) as mock_add_virtual_server:
mock_get_floatingips.return_value = [] mock_get_floatingips.return_value = []
@ -775,6 +778,9 @@ class TestEdgeLbaasV2Listener(BaseTestEdgeLbaasV2):
mock.patch.object(self.core_plugin, mock.patch.object(self.core_plugin,
'get_waf_profile_path_and_mode', 'get_waf_profile_path_and_mode',
return_value=(None, None)), \ return_value=(None, None)), \
mock.patch.object(self.core_plugin.nsxpolicy, 'search_by_tags',
return_value={'results': [
{'id': LB_SERVICE_ID}]}),\
mock.patch.object(self.vs_client, 'create_or_overwrite' mock.patch.object(self.vs_client, 'create_or_overwrite'
) as mock_add_virtual_server: ) as mock_add_virtual_server:
mock_get_floatingips.return_value = [] mock_get_floatingips.return_value = []
@ -811,6 +817,9 @@ class TestEdgeLbaasV2Listener(BaseTestEdgeLbaasV2):
mock.patch.object(self.core_plugin, mock.patch.object(self.core_plugin,
'get_waf_profile_path_and_mode', 'get_waf_profile_path_and_mode',
return_value=(None, None)), \ return_value=(None, None)), \
mock.patch.object(self.core_plugin.nsxpolicy, 'search_by_tags',
return_value={'results': [
{'id': LB_SERVICE_ID}]}),\
mock.patch.object(self.vs_client, 'create_or_overwrite' mock.patch.object(self.vs_client, 'create_or_overwrite'
) as mock_add_virtual_server: ) as mock_add_virtual_server:
mock_get_floatingips.return_value = [] mock_get_floatingips.return_value = []
@ -872,6 +881,9 @@ class TestEdgeLbaasV2Listener(BaseTestEdgeLbaasV2):
return_value=(None, None)), \ return_value=(None, None)), \
mock.patch.object(self.vs_client, 'create_or_overwrite' mock.patch.object(self.vs_client, 'create_or_overwrite'
) as mock_add_virtual_server,\ ) as mock_add_virtual_server,\
mock.patch.object(self.core_plugin.nsxpolicy, 'search_by_tags',
return_value={'results': [
{'id': LB_SERVICE_ID}]}),\
mock.patch.object(self.vs_client, 'get', return_value={}),\ mock.patch.object(self.vs_client, 'get', return_value={}),\
mock.patch.object(self.edge_driver.listener, '_get_pool_tags'),\ mock.patch.object(self.edge_driver.listener, '_get_pool_tags'),\
mock.patch.object(self.pp_cookie_client, 'create_or_overwrite' mock.patch.object(self.pp_cookie_client, 'create_or_overwrite'
@ -925,6 +937,9 @@ class TestEdgeLbaasV2Listener(BaseTestEdgeLbaasV2):
mock.patch.object(self.core_plugin, mock.patch.object(self.core_plugin,
'get_waf_profile_path_and_mode', 'get_waf_profile_path_and_mode',
return_value=(None, None)), \ return_value=(None, None)), \
mock.patch.object(self.core_plugin.nsxpolicy, 'search_by_tags',
return_value={'results': [
{'id': LB_SERVICE_ID}]}),\
mock.patch.object(self.vs_client, 'create_or_overwrite' mock.patch.object(self.vs_client, 'create_or_overwrite'
) as mock_add_virtual_server: ) as mock_add_virtual_server:
mock_get_floatingips.return_value = [] mock_get_floatingips.return_value = []
@ -961,6 +976,9 @@ class TestEdgeLbaasV2Listener(BaseTestEdgeLbaasV2):
with mock.patch.object(self.core_plugin, with mock.patch.object(self.core_plugin,
'get_waf_profile_path_and_mode', 'get_waf_profile_path_and_mode',
return_value=(None, None)), \ return_value=(None, None)), \
mock.patch.object(self.core_plugin.nsxpolicy, 'search_by_tags',
return_value={'results': [
{'id': LB_SERVICE_ID}]}),\
mock.patch.object(self.core_plugin, 'get_floatingips' mock.patch.object(self.core_plugin, 'get_floatingips'
) as mock_get_floatingips: ) as mock_get_floatingips:
mock_get_floatingips.return_value = [] mock_get_floatingips.return_value = []
@ -983,6 +1001,9 @@ class TestEdgeLbaasV2Listener(BaseTestEdgeLbaasV2):
with mock.patch.object(self.core_plugin, with mock.patch.object(self.core_plugin,
'get_waf_profile_path_and_mode', 'get_waf_profile_path_and_mode',
return_value=(None, None)), \ return_value=(None, None)), \
mock.patch.object(self.core_plugin.nsxpolicy, 'search_by_tags',
return_value={'results': [
{'id': LB_SERVICE_ID}]}),\
mock.patch.object(self.core_plugin, 'get_floatingips' mock.patch.object(self.core_plugin, 'get_floatingips'
) as mock_get_floatingips: ) as mock_get_floatingips:
mock_get_floatingips.return_value = [] mock_get_floatingips.return_value = []
@ -1008,6 +1029,9 @@ class TestEdgeLbaasV2Listener(BaseTestEdgeLbaasV2):
mock.patch.object(self.core_plugin, mock.patch.object(self.core_plugin,
'get_waf_profile_path_and_mode', 'get_waf_profile_path_and_mode',
return_value=(None, None)), \ return_value=(None, None)), \
mock.patch.object(self.core_plugin.nsxpolicy, 'search_by_tags',
return_value={'results': [
{'id': LB_SERVICE_ID}]}),\
mock.patch.object(self.edge_driver.listener, '_get_pool_tags'),\ mock.patch.object(self.edge_driver.listener, '_get_pool_tags'),\
mock.patch.object(self.vs_client, 'get', return_value={}),\ mock.patch.object(self.vs_client, 'get', return_value={}),\
mock.patch.object(self.vs_client, 'update', mock.patch.object(self.vs_client, 'update',
@ -1058,6 +1082,9 @@ class TestEdgeLbaasV2Listener(BaseTestEdgeLbaasV2):
) as mock_create_pp, \ ) as mock_create_pp, \
mock.patch.object(self.pp_generic_client, 'delete' mock.patch.object(self.pp_generic_client, 'delete'
) as mock_delete_pp, \ ) as mock_delete_pp, \
mock.patch.object(self.core_plugin.nsxpolicy, 'search_by_tags',
return_value={'results': [
{'id': LB_SERVICE_ID}]}),\
mock.patch.object(self.core_plugin, 'get_floatingips' mock.patch.object(self.core_plugin, 'get_floatingips'
) as mock_get_floatingips, \ ) as mock_get_floatingips, \
mock.patch.object(self.edge_driver.listener, mock.patch.object(self.edge_driver.listener,