Index: leahi_dialin/td/modules/air_pump.py =================================================================== diff -u -r1f2bf6d939eb4033dbedb7d7005494cc12fccbc6 -r8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf --- leahi_dialin/td/modules/air_pump.py (.../air_pump.py) (revision 1f2bf6d939eb4033dbedb7d7005494cc12fccbc6) +++ leahi_dialin/td/modules/air_pump.py (.../air_pump.py) (revision 8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf) @@ -16,7 +16,7 @@ # Module imports from logging import Logger - +import time # Project imports from leahi_dialin.common.constants import NO_RESET from leahi_dialin.common.generic_defs import DataTypes @@ -64,6 +64,7 @@ td_enum_repository.TDAirPumpAttributes.SCALAR_POWER.name: 0 } } + self.handler_execution_times = [] @publish(["msg_id_td_air_pump_data", "td_air_pump", "td_air_pump_timestamp"]) @@ -74,6 +75,7 @@ @param message: published air pump data message as: air pump state @return: None """ + start = time.perf_counter() sensor_list =[] sensor_list.append((td_enum_repository.TDAirPumpNames.H12_AIR_PUMP.name, td_enum_repository.TDAirPumpAttributes.STATE.name, DataTypes.U32)) sensor_list.append((td_enum_repository.TDAirPumpNames.H12_AIR_PUMP.name, td_enum_repository.TDAirPumpAttributes.DUTY_CYCLE.name, DataTypes.F32)) @@ -87,6 +89,7 @@ decoder_list = sensor_list, message = message) self.td_air_pump_timestamp = timestamp + self.handler_execution_times.append(time.perf_counter() - start) def cmd_air_pump_data_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int: