commit 9107f2e1db6f544b5640f505dd214660ac3b40c7
author Peter Shafik <pshafik@ciena.com> Tue May 02 15:54:39 2017 -0400
committer Peter Shafik <pshafik@ciena.com> Fri May 05 10:38:46 2017 -0400
tree aa124e2d42eaa0a608b76d884e78efd32b2bf776
parent ba59b25753473375e6e40f5bb7b5bddab7a9175f

Adding infrastructure to allow sending messages between adapters
using the adapter-agent event bus.

Change-Id: Ia3654b8944745bc76f8ac4ea3c1439a082979dd4

voltha/adapters/broadcom_onu/broadcom_onu.py

diff --git a/voltha/adapters/broadcom_onu/broadcom_onu.py b/voltha/adapters/broadcom_onu/broadcom_onu.py
index 59fd987..b8f7d7f 100644
--- a/voltha/adapters/broadcom_onu/broadcom_onu.py
+++ b/voltha/adapters/broadcom_onu/broadcom_onu.py
@@ -68,6 +68,9 @@
         )
         self.devices_handlers = dict()  # device_id -> BroadcomOnuHandler()
 
+        # register for adapter messages
+        self.adapter_agent.register_for_inter_adapter_messages()
+
     def start(self):
         log.debug('starting')
         log.info('started')
@@ -138,6 +141,9 @@
         log.info('packet-out', logical_device_id=logical_device_id,
                  egress_port_no=egress_port_no, msg_len=len(msg))
 
+    def receive_inter_adapter_message(self, msg):
+        log.info('receive_inter_adapter_message', msg=msg)
+
 
 class BroadcomOnuHandler(object):
 
@@ -165,6 +171,7 @@
         self.proxy_address = device.proxy_address
         self.adapter_agent.register_for_proxied_messages(device.proxy_address)
 
+
         # populate device info
         device.root = True
         device.vendor = 'Broadcom'