Index: leahi_dialin/fp/modules/ro_pump.py =================================================================== diff -u -r465679409a5fe6f6007ddffca1fd3e89ead9d9c4 -r8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d --- leahi_dialin/fp/modules/ro_pump.py (.../ro_pump.py) (revision 465679409a5fe6f6007ddffca1fd3e89ead9d9c4) +++ leahi_dialin/fp/modules/ro_pump.py (.../ro_pump.py) (revision 8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d) @@ -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: