x/vmware-nsxlib
Code Issues Proposed changes

Update policy segment & port admin state using passthrough api

Browse Source 
Change-Id: I3a63ef10a16697f7fd6f0d1fb8b08c65baa8e0d1
This commit is contained in:
Adit Sarfaty 2018-12-30 14:16:45 +02:00
parent e600658c8a
commit b8edf1f428
1 changed files with 45 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
vmware_nsxlib/v3/policy/core_resources.py
View File

@ -1386,6 +1386,27 @@ class NsxPolicySegmentApi(NsxPolicyResourceBase):
return self._get_realization_info(segment_def, return self._get_realization_info(segment_def,
entity_type=entity_type) entity_type=entity_type)
def wait_until_realized(self, segment_id, entity_type=None,
tenant=constants.POLICY_INFRA_TENANT,
sleep=None, max_attempts=None):
segment_def = self.entry_def(segment_id=segment_id, tenant=tenant)
return self._wait_until_realized(segment_def, entity_type=entity_type,
sleep=sleep,
max_attempts=max_attempts)
@check_allowed_passthrough
def set_admin_state(self, segment_id, admin_state,
tenant=constants.POLICY_INFRA_TENANT):
"""Set the segment admin state using the passthrough api"""
realization_info = self.wait_until_realized(
segment_id, entity_type='RealizedLogicalSwitch', tenant=tenant)
nsx_ls_uuid = self.get_realized_id(
segment_id, tenant=tenant, realization_info=realization_info)
self.nsx_api.logical_switch.update(
nsx_ls_uuid,
admin_state=admin_state)
def get_transport_zone_id(self, segment_id, def get_transport_zone_id(self, segment_id,
tenant=constants.POLICY_INFRA_TENANT): tenant=constants.POLICY_INFRA_TENANT):
segment = self.get(segment_id, tenant=tenant) segment = self.get(segment_id, tenant=tenant)
@ -1523,6 +1544,30 @@ class NsxPolicySegmentPortApi(NsxPolicyResourceBase):
tenant=tenant) tenant=tenant)
return self._get_realization_info(port_def, entity_type=entity_type) return self._get_realization_info(port_def, entity_type=entity_type)
def wait_until_realized(self, segment_id, port_id, entity_type=None,
tenant=constants.POLICY_INFRA_TENANT,
sleep=None, max_attempts=None):
port_def = self.entry_def(segment_id=segment_id, port_id=port_id,
tenant=tenant)
return self._wait_until_realized(port_def, entity_type=entity_type,
sleep=sleep,
max_attempts=max_attempts)
@check_allowed_passthrough
def set_admin_state(self, segment_id, port_id, admin_state,
tenant=constants.POLICY_INFRA_TENANT):
"""Set the segment port admin state using the passthrough api"""
realization_info = self.wait_until_realized(
segment_id, port_id, entity_type='RealizedLogicalPort',
tenant=tenant)
nsx_lp_uuid = self.get_realized_id(
segment_id, port_id, tenant=tenant,
realization_info=realization_info)
self.nsx_api.logical_port.update(
nsx_lp_uuid, False,
admin_state=admin_state)
class SegmentPortProfilesBindingMapBaseApi(NsxPolicyResourceBase): class SegmentPortProfilesBindingMapBaseApi(NsxPolicyResourceBase):