VOL-1146
Addition of ONU discovery alarm in voltha/adapters/openolt/openolt_device.py
and post to kafka.
Change-Id: I5fd6374b39c5fcba1f58d538ba201110b5461921
diff --git a/voltha/adapters/openolt/openolt_device.py b/voltha/adapters/openolt/openolt_device.py
index f962513..3187975 100644
--- a/voltha/adapters/openolt/openolt_device.py
+++ b/voltha/adapters/openolt/openolt_device.py
@@ -45,6 +45,7 @@
DEFAULT_MGMT_VLAN
from voltha.adapters.openolt.openolt_alarms import OpenOltAlarmMgr
from voltha.adapters.openolt.openolt_bw import OpenOltBW
+from voltha.extensions.alarms.onu.onu_discovery_alarm import OnuDiscoveryAlarm
class OpenoltDevice(object):
@@ -352,6 +353,13 @@
self.log.debug("onu discovery indication", intf_id=intf_id,
serial_number=serial_number_str)
+ # Post ONU Discover alarm 20180809_0805
+ try:
+ OnuDiscoveryAlarm(self.alarm_mgr.alarms, pon_id=intf_id, serial_number=serial_number_str).raise_alarm()
+ except Exception as disc_alarm_error:
+ self.log.exception("onu-discovery-alarm-error", errmsg=disc_alarm_error.message)
+ # continue for now.
+
pir = self.bw_mgr.pir(serial_number_str)
self.log.debug("peak information rate", serial_number=serial_number,
pir=pir)