Index: leahi_dialin/td/modules/air_pump.py =================================================================== diff -u -re45b20cdc5d4c5dcff8cef530b173ca94cb2e422 -r820c94585ab5d85c40395e828c4dfe2da164c105 --- leahi_dialin/td/modules/air_pump.py (.../air_pump.py) (revision e45b20cdc5d4c5dcff8cef530b173ca94cb2e422) +++ leahi_dialin/td/modules/air_pump.py (.../air_pump.py) (revision 820c94585ab5d85c40395e828c4dfe2da164c105) @@ -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: