Index: leahi_dialin/dd/modules/conductivity_sensors.py =================================================================== diff -u -rb587077b5d61033e25b2aa372bc04e221bc77a6f -r8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d --- leahi_dialin/dd/modules/conductivity_sensors.py (.../conductivity_sensors.py) (revision b587077b5d61033e25b2aa372bc04e221bc77a6f) +++ leahi_dialin/dd/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 @@ -108,6 +109,7 @@ }, } + self.handler_execution_times = [] @publish(["msg_id_dd_conductivity_data", "dd_conductivity", "dd_conductivity_timestamp"]) def _handler_conductivity_sensors_sync(self, message, timestamp=0.0): @@ -118,6 +120,7 @@ @param message: published DD conductivity sensor data message @return: None """ + start = time.perf_counter() sensor_list =[] sensor_list.append((dd_enum_repository.DDConductivitySensorNames.D17_COND.name, DataTypes.F32)) sensor_list.append((dd_enum_repository.DDConductivitySensorNames.D27_COND.name, DataTypes.F32)) @@ -129,6 +132,7 @@ decoder_list = sensor_list, message = message) self.dd_conductivity_timestamp = timestamp + self.handler_execution_times.append(time.perf_counter() - start) @publish(["msg_id_dd_conductivity_resistance_data", "dd_conductivity_resistance", "dd_conductivity_resistance_timestamp"]) def _handler_conductivity_resistance_sync(self, message, timestamp=0.0):