commit f37726bea503edf86a0971b27cc6efe0927d2e10
author Daniel Velasco <dvelben@gmail.com> Tue Mar 14 17:36:55 2017 +0100
committer Ali Al-Shabibi <ali@onlab.us> Thu Mar 16 02:12:20 2017 -0700
tree 205d8b516c393a77cc0c8cdccbde454f0fccaa29
parent 98eff41b7ed9c70adad54919478d9879f69c33b5

pmcs message sequence completed

Change-Id: Iacf4a6f1371ec0f237e36d54e0630ac46b4f59be

voltha/adapters/microsemi_olt/microsemi_olt.py

diff --git a/voltha/adapters/microsemi_olt/microsemi_olt.py b/voltha/adapters/microsemi_olt/microsemi_olt.py
index 532915d..098140c 100644
--- a/voltha/adapters/microsemi_olt/microsemi_olt.py
+++ b/voltha/adapters/microsemi_olt/microsemi_olt.py
@@ -132,12 +132,19 @@
                   flows=flows, groups=groups)
 
     def send_proxied_message(self, proxy_address, msg):
-        log.info('send-proxied-message', proxy_address=proxy_address, msg=msg)
-        # TODO make this more efficient
-        omci_proxy = OMCIProxy(proxy_address=proxy_address,
-                               msg=msg)
-        omci_proxy.run()
-        del omci_proxy
+        if msg.opcode == "0x302a":
+            log.info('send-omci-proxied-message', proxy_address=proxy_address, msg=msg)
+            # TODO make this more efficient
+            omci_proxy = OMCIProxy(proxy_address=proxy_address,
+                                   msg=msg)
+            omci_proxy.run()
+            del omci_proxy
+
+        else:
+            log.info('send-proxied-message', proxy_address=proxy_address, msg=msg)
+            api_proxy = APIProxy(device.proxy_address,msg)
+            api_proxy.run()
+            del api_proxy 
 
     def receive_proxied_message(self, proxy_address, msg):
         raise NotImplementedError()