VOL-2172: Deleting tech-profile at ONU
- Handle DELETE_GEM_PORT_REQUEST and DELETE_TCONT_REQ inter-adapter-message.
- Introduce a new OMCI task BrcmTpDeleteTask to delete GemPorts and TCONT
- When tech-profile download is already done, check if it is case
where new gem-ports are being added dynamically. If new gem-ports
are detected in TpInstance, add them.
- Rename BrcmTpServiceSpecificTask to BrcmTpSetupTask
- Move setting up of IEEE8021pMapper and ANI MacBridgePortConfigData
to BrcmTpSetupTask (when TCONT is being setup). There should be
unique IEEE8021pMapper and ANI MacBridgePortConfigData per TCONT.
- When TCONT is removed, remove IEEE8021pMapper and ANI MacBridgePortConfigData.
- Ensure IEEE8021pMapper and ANI MacBridgePortConfigData have element of
TP-Table ID in its entity ID.
- GemPort Entity ID set to be same as GemPort ID and not dynamically generated.
- Fix code indentations
- Bump voltha proto version to 2.1.1
- Bump pyvoltha version to 2.3.2
Change-Id: Ie4a90d6cd6916e27a6e32b3727b161252cb80ca3
diff --git a/python/adapters/brcm_openomci_onu/omci/brcm_uni_lock_task.py b/python/adapters/brcm_openomci_onu/omci/brcm_uni_lock_task.py
index aecefc1..8e9a2e1 100644
--- a/python/adapters/brcm_openomci_onu/omci/brcm_uni_lock_task.py
+++ b/python/adapters/brcm_openomci_onu/omci/brcm_uni_lock_task.py
@@ -47,10 +47,10 @@
:param priority: (int) OpenOMCI Task priority (0..255) 255 is the highest
"""
super(BrcmUniLockTask, self).__init__(BrcmUniLockTask.name,
- omci_agent,
- device_id,
- priority=priority,
- exclusive=True)
+ omci_agent,
+ device_id,
+ priority=priority,
+ exclusive=True)
self._device = omci_agent.get_device(device_id)
self._lock = lock
self._results = None
@@ -74,7 +74,6 @@
super(BrcmUniLockTask, self).start()
self._local_deferred = reactor.callLater(0, self.perform_lock)
-
@inlineCallbacks
def perform_lock(self):
"""
@@ -98,7 +97,7 @@
for entity_id in veip_list:
veip_value = self._config.veip_entities[entity_id]
msg = VeipUniFrame(entity_id,
- attributes=dict(administrative_state=state))
+ attributes=dict(administrative_state=state))
yield self._send_uni_lock_msg(entity_id, veip_value, msg)
msg = OntGFrame(attributes={'administrative_state': state})
@@ -122,7 +121,6 @@
self.log.exception('setting-uni-lock-state', e=e)
self.deferred.errback(failure.Failure(e))
-
@inlineCallbacks
def _send_uni_lock_msg(self, entity_id, value, me_message):
frame = me_message.set()