Index: leahi_dialin/fp/modules/valves.py =================================================================== diff -u -r1f2bf6d939eb4033dbedb7d7005494cc12fccbc6 -r8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d --- leahi_dialin/fp/modules/valves.py (.../valves.py) (revision 1f2bf6d939eb4033dbedb7d7005494cc12fccbc6) +++ leahi_dialin/fp/modules/valves.py (.../valves.py) (revision 8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d) @@ -18,6 +18,7 @@ import struct from logging import Logger from collections import OrderedDict +import time # Project imports from leahi_dialin.common.constants import NO_RESET @@ -79,6 +80,7 @@ valve_name = fp_enum_repository.FPValveNames(i).name self.valve_states_enum[valve_name] = 0 self.valves_sensed_states[valve_name] = '' + self.handler_execution_times = [] @staticmethod @@ -132,6 +134,7 @@ @param message: published FP valves states message @return: none """ + start = time.perf_counter() # Extract each valve state from U08 valves states using bit-masking io_valves = struct.unpack(DataTypes.U08.unpack_attrib(), bytearray(message['message'][self.START_IO_VALVES_STATES:self.END_IO_VALVES_STATES])) self.m4_valv["state"] = self._binary_to_valve_state(io_valves[0] & 1) @@ -161,6 +164,7 @@ start = end end += 1 self.fp_valves_states_timestamp = timestamp + self.handler_execution_times.append(time.perf_counter() - start) def cmd_valve_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int: