commit aae997158f2676b145e5647bb0e87f40c246f815
author onkarkundargi <onkar.kundargi@gmail.com> Mon Sep 23 15:02:52 2019 +0530
committer onkarkundargi <onkar.kundargi@gmail.com> Wed Sep 25 18:19:30 2019 +0530
tree 1051de284d0f66723d455517ecaa09830540c403
parent fe6ac434dd620a60c84ea860a5e27fc0ae510fa3

SEBA-596 #comments Implemented periodic test action for ONT

Change-Id: I0ba789d4e0066f01b36b502cbb1462913a0112a5

python/adapters/brcm_openomci_onu/brcm_openomci_onu_handler.py

diff --git a/python/adapters/brcm_openomci_onu/brcm_openomci_onu_handler.py b/python/adapters/brcm_openomci_onu/brcm_openomci_onu_handler.py
index 4a7521b..6038af4 100644
--- a/python/adapters/brcm_openomci_onu/brcm_openomci_onu_handler.py
+++ b/python/adapters/brcm_openomci_onu/brcm_openomci_onu_handler.py
@@ -55,6 +55,8 @@
 from uni_port import *
 from onu_traffic_descriptor import *
 from pyvoltha.common.tech_profile.tech_profile import TechProfile
+from pyvoltha.adapters.extensions.omci.tasks.omci_test_request import OmciTestRequest
+from pyvoltha.adapters.extensions.omci.omci_entities import AniG
 
 OP = EntityOperations
 RC = ReasonCodes
@@ -267,6 +269,19 @@
             #Start collecting stats from the device after a brief pause
             reactor.callLater(10, self.pm_metrics.start_collector)
 
+            # Code to Run OMCI Test Action
+            kwargs_omci_test_action = {
+                OmciTestRequest.DEFAULT_FREQUENCY_KEY:
+                    OmciTestRequest.DEFAULT_COLLECTION_FREQUENCY
+            }
+            serial_number = device.serial_number
+            test_request = OmciTestRequest(self.core_proxy,
+                                           self.omci_agent, self.device_id,
+                                           AniG, serial_number,
+                                           self.logical_device_id,
+                                           exclusive=False,
+                                           **kwargs_omci_test_action)
+            reactor.callLater(60, test_request.start_collector)
             self.enabled = True
         else:
             self.log.info('onu-already-activated')