Index: leahi_dialin/fp/modules/conductivity_sensors.py =================================================================== diff -u -r1f2bf6d939eb4033dbedb7d7005494cc12fccbc6 -r8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d --- leahi_dialin/fp/modules/conductivity_sensors.py (.../conductivity_sensors.py) (revision 1f2bf6d939eb4033dbedb7d7005494cc12fccbc6) +++ leahi_dialin/fp/modules/conductivity_sensors.py (.../conductivity_sensors.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 @@ -71,6 +72,7 @@ fp_enum_repository.FPRORejectionRatioNames.GEN_PERMEATE_STATE.name: 0 } + self.handler_execution_times = [] @publish(["msg_id_fp_conductivity_data", "fp_conductivity", "fp_conductivity_timestamp"]) def _handler_conductivity_sensors_sync(self, message, timestamp=0.0): @@ -81,6 +83,7 @@ @param message: published conductivity sensor data message @return: None """ + start = time.perf_counter() sensor_list =[] sensor_list.append((fp_enum_repository.FPConductivitySensorNames.P9_COND.name, DataTypes.F32)) sensor_list.append((fp_enum_repository.FPConductivitySensorNames.P18_COND.name, DataTypes.F32)) @@ -100,6 +103,7 @@ @param message: Published RO Rejection Ratio data message @return: None """ + start = time.perf_counter() sensor_list =[] sensor_list.append((fp_enum_repository.FPRORejectionRatioNames.RAW_RO_REJECTION_RATIO.name, DataTypes.F32)) sensor_list.append((fp_enum_repository.FPRORejectionRatioNames.RAW_RO_REJECTION_RATIO_TANK_FILL.name, DataTypes.F32)) @@ -111,6 +115,7 @@ decoder_list = sensor_list, message = message) self.ro_rejection_ratio_timestamp = timestamp + self.handler_execution_times.append(time.perf_counter() - start) def cmd_conductivity_sensor_data_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int: