Index: leahi_dialin/fp/modules/ro_pump.py =================================================================== diff -u -r8ef0478470000c7e0de4dc05440521c955e18107 -r820c94585ab5d85c40395e828c4dfe2da164c105 --- leahi_dialin/fp/modules/ro_pump.py (.../ro_pump.py) (revision 8ef0478470000c7e0de4dc05440521c955e18107) +++ leahi_dialin/fp/modules/ro_pump.py (.../ro_pump.py) (revision 820c94585ab5d85c40395e828c4dfe2da164c105) @@ -16,6 +16,7 @@ # Module imports from logging import Logger +import time # Project imports from leahi_dialin.common.constants import NO_RESET @@ -63,6 +64,7 @@ fp_enum_repository.FPPumpAttributes.FB_DUTY_CYCLE_PCT.name: 0.0 } } + self.handler_execution_times = [] @publish(["msg_id_fp_ro_pump_data", "ro_pump", "ro_pump_timestamp" ]) @@ -74,6 +76,7 @@ @param message: published FP ro pump data message @return: none """ + start = time.perf_counter() sensor_list =[] sensor_list.append((fp_enum_repository.FPROPumpNames.P12_PUMP.name, fp_enum_repository.FPPumpAttributes.STATE.name, DataTypes.U32)) sensor_list.append((fp_enum_repository.FPROPumpNames.P12_PUMP.name, fp_enum_repository.FPPumpAttributes.DUTY_CYCLE.name, DataTypes.U32)) @@ -89,6 +92,7 @@ decoder_list = sensor_list, message = message) self.ro_pump_timestamp = timestamp + self.handler_execution_times.append(time.perf_counter() - start) def cmd_ro_pump_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int: