[Newport] Thermal manager (#23)

* Signed-off-by: Vadym Yashchenko <[email protected]>

Author: VadymYashchenko

device/barefoot/x86_64-accton_as9516_32d-r0/platform.json

@@ -133,52 +133,61 @@
         ],
         "thermals": [
             {
-                "name": "tmp75-i2c-3-4b:switch-temp"
+                "name": "com_e_driver-i2c-4-33:cpu-temp"
             },
             {
                 "name": "com_e_driver-i2c-4-33:memory-temp"
             },
             {
-                "name": "com_e_driver-i2c-4-33:cpu-temp"
+                "name": "psu_driver-i2c-7-59:psu2-temp1"
             },
             {
-                "name": "coretemp-isa-0000:core-0"
+                "name": "psu_driver-i2c-7-59:psu2-temp2"
             },
             {
-                "name": "coretemp-isa-0000:core-1"
+                "name": "psu_driver-i2c-7-59:psu2-temp3"
             },
             {
-                "name": "coretemp-isa-0000:core-2"
+                "name": "psu_driver-i2c-7-5a:psu1-temp1"
             },
             {
-                "name": "coretemp-isa-0000:core-3"
+                "name": "psu_driver-i2c-7-5a:psu1-temp2"
             },
             {
-                "name": "coretemp-isa-0000:package-id-0"
+                "name": "psu_driver-i2c-7-5a:psu1-temp3"
             },
             {
-                "name": "psu_driver-i2c-7-5a:psu1-temp1"
+                "name": "tmp75-i2c-3-48:chip-temp"
             },
             {
-                "name": "psu_driver-i2c-7-5a:psu1-temp2"
+                "name": "tmp75-i2c-3-49:exhaust2-temp"
             },
             {
-                "name": "psu_driver-i2c-7-5a:psu1-temp3"
+                "name": "tmp75-i2c-3-4a:exhaust-temp"
+            },
+            {
+                "name": "tmp75-i2c-3-4b:intake-temp"
+            },
+            {
+                "name": "tmp75-i2c-3-4c:tofino-temp"
+            },
+            {
+                "name": "tmp75-i2c-3-4d:intake2-temp"
             },
             {
-                "name": "tmp75-i2c-3-4a:inlet-left-temp"
+                "name": "coretemp-isa-0000:package-id-0"
             },
             {
-                "name": "tmp75-i2c-3-4c:inlet-right-temp"
+                "name": "coretemp-isa-0000:core-0"
             },
             {
-                "name": "tmp75-i2c-3-4d:temp1"
+                "name": "coretemp-isa-0000:core-1"
             },
             {
-                "name": "tmp75-i2c-3-48:outlet-middle-temp"
+                "name": "coretemp-isa-0000:core-2"
             },
             {
-                "name": "tmp75-i2c-3-49:inlet-middle-temp"
+                "name": "coretemp-isa-0000:core-3"
             }
         ],
         "sfps": [

platform/barefoot/sonic-platform-modules-bfn-montara/sonic_platform/chassis.py

@@ -8,6 +8,7 @@
     from sonic_platform.fan_drawer import fan_drawer_list_get
     from sonic_platform.thermal import thermal_list_get
     from eeprom import Eeprom
+    from sonic_platform.thermal_manager import ThermalManager
 except ImportError as e:
     raise ImportError(str(e) + "- required module not found")
 
@@ -24,6 +25,8 @@ def __init__(self):
         self.__thermals = None
         self.__psu_list = None
         self.__sfp_list = None
+        self.__thermal_mngr = None
+        self.__polling_thermal_time = 30
 
     @property
     def _eeprom(self):
@@ -87,6 +90,16 @@ def _sfp_list(self):
     def _sfp_list(self, value):
         pass
 
+    @property
+    def _thermal_mngr(self):
+        if self.__thermal_mngr is None:
+            self.__thermal_mngr = ThermalManager(self.__polling_thermal_time)
+        return self.__thermal_mngr
+
+    @_thermal_mngr.setter
+    def _thermal_mngr(self, value):
+        self.__thermal_mngr = ThermalManager(value)
+
     def get_name(self):
         """
         Retrieves the name of the chassis
@@ -240,3 +253,10 @@ def get_status_led(self):
             specified.
         """
         return self.system_led
+
+    def get_thermal_manager(self):
+        return self._thermal_mngr
+
+    def __del__(self):
+        if self.__thermal_mngr is not None:
+            self.__thermal_mngr.stop()

platform/barefoot/sonic-platform-modules-bfn-montara/sonic_platform/thermal_manager.py

@@ -0,0 +1,69 @@
+try:
+    from threading import Timer
+except ImportError as e:
+    raise ImportError (str(e) + "- required module not found")
+    
+class ThermalManager():
+    def __init__(self, polling_time = 30.0):
+        self.__polling_thermal_time = polling_time
+        self.__thermals = None
+        self.__timer = None
+        self.__chassis = None
+        
+    def start(self):
+        self.work()
+        self.__timer = Timer(self.__polling_thermal_time, self.start)
+        self.__timer.start()
+
+    def work(self):
+        if self.__chassis is not None:
+            self.__thermals = self.__chassis._thermal_list
+            for term in self.__thermals:
+                self.check(term)
+
+    def check(self, sensor):
+        temperature = sensor.get_temperature()
+        if temperature is not None:
+            temp_high = sensor.get_high_threshold()
+            temp_low = sensor.get_low_threshold()
+            if temp_high > -999.0:
+                if temperature > temp_high:
+                    print('Sensor ', sensor.get_name(), ' temperature more then', temp_high, '!!!')
+            else:
+                print('Sensor ', sensor.get_name(), ' has no high temperature threshold')
+
+            if temp_low > -999.0:
+                if temperature < temp_low:
+                    print('Sensor ', sensor.get_name(), ' temperature less then', temp_low, '!!!')
+            else:
+                print('Sensor ', sensor.get_name(), ' has no low temperature threshold')
+            
+    def stop(self):
+        if self.__timer is not None:
+            self.__timer.cancel()
+
+    def __del__(self):
+        if self.__timer is not None:
+            self.__timer.cancel()
+
+    # for compatibility with old version
+    def run_policy(self, chassis_def):
+        self.__chassis = chassis_def
+
+    def get_interval(self):
+        return self.__polling_thermal_time
+
+    def initialize(self):
+        pass
+
+    def load(self, json_file):
+        pass
+
+    def init_thermal_algorithm(self, chassis_def):
+        self.__chassis = chassis_def
+        self.start()
+
+    def deinitialize(self):
+        self.stop()
+        del self
+