commit 1e66e2a8314762526f9272f2e14871b246b8c472
author Shad Ansari <shad@opennetworking.org> Thu Apr 18 21:48:58 2019 -0700
committer Shad Ansari <shad@opennetworking.org> Fri May 17 06:01:33 2019 +0000
tree dab9b65784fe20485a9e12f8d713d981bdd6f1d7
parent 748fbf935552e1cd46669ecfb93874932c406db5

Add missing __delete_port() in openolt datamodel

Change-Id: I282ce4ce0c654b8dcd6b051970fc8e6459c65dd6

voltha/adapters/openolt/openolt_data_model.py

diff --git a/voltha/adapters/openolt/openolt_data_model.py b/voltha/adapters/openolt/openolt_data_model.py
index 58d2f75..de43677 100644
--- a/voltha/adapters/openolt/openolt_data_model.py
+++ b/voltha/adapters/openolt/openolt_data_model.py
@@ -222,7 +222,7 @@
         except Exception as e:
             self.log.error('logical_port delete error', error=e)
         try:
-            self.delete_port(onu_device.serial_number)
+            self.__delete_port(onu_device.serial_number)
         except Exception as e:
             self.log.error('port delete error', error=e)
 
@@ -507,6 +507,17 @@
                     self.logical_device_id, logical_port)
                 return
 
+    def __delete_port(self, serial_number):
+        ports = self.proxy.get('/devices/{}/ports'.format(
+            self.device_id))
+        for port in ports:
+            if port.label == serial_number:
+                self.log.debug('delete-port',
+                               onu_serial_number=serial_number,
+                               port=port)
+                self.adapter_agent.delete_port(self.device_id, port)
+                return
+
     def __onu_ports_down(self, onu_device):
         onu_ports = self.proxy.get('devices/{}/ports'.format(onu_device.id))
         for onu_port in onu_ports: