Index: leahi_dialin/fp/modules/permeate_tank.py =================================================================== diff -u -r1f2bf6d939eb4033dbedb7d7005494cc12fccbc6 -r8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d --- leahi_dialin/fp/modules/permeate_tank.py (.../permeate_tank.py) (revision 1f2bf6d939eb4033dbedb7d7005494cc12fccbc6) +++ leahi_dialin/fp/modules/permeate_tank.py (.../permeate_tank.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 @@ -50,8 +51,8 @@ self.permeate_tank_timestamp = 0.0 #: The timestamp of the last message self.permeate_tank_state = 0 #: The Permeate Tank's State value + self.handler_execution_times = [] - @publish(["msg_id_fp_permeate_tank_data", "permeate_tank_state", "permeate_tank_timestamp"]) def _handler_permeate_tank_sync(self, message, timestamp=0.0): """ @@ -60,12 +61,14 @@ @param message: published permeate tank data message @return: None """ + start = time.perf_counter() msg_list =[] msg_list.append(('self.permeate_tank_state', DataTypes.U32)) self.process_into_vars(decoder_list = msg_list, message = message) self.permeate_tank_timestamp = timestamp + self.handler_execution_times.append(time.perf_counter() - start) def cmd_permeate_tank_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int: