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