Index: leahi_dialin/dd/modules/conductivity_sensors.py =================================================================== diff -u -r6ce1aaaa1c5ce4ef44d51d7c805c81e34cdb2499 -rc4b92f4de01ac39942ccdc1a18d9dd85be31a2c0 --- leahi_dialin/dd/modules/conductivity_sensors.py (.../conductivity_sensors.py) (revision 6ce1aaaa1c5ce4ef44d51d7c805c81e34cdb2499) +++ leahi_dialin/dd/modules/conductivity_sensors.py (.../conductivity_sensors.py) (revision c4b92f4de01ac39942ccdc1a18d9dd85be31a2c0) @@ -16,6 +16,7 @@ # Module imports from logging import Logger +import time # Project imports from leahi_dialin.common.constants import NO_RESET @@ -97,6 +98,9 @@ }, } + self.handler_cond_execution_times = [] + self.handler_resist_execution_times = [] + @publish(["msg_id_dd_conductivity_data", "dd_conductivity", "dd_conductivity_timestamp"]) def _handler_conductivity_sensors_sync(self, message, timestamp=0.0): """ @@ -106,6 +110,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, dd_enum_repository.DDConductivityResistanceAttributes.CONDUCTIVITY.name, DataTypes.F32)) sensor_list.append((dd_enum_repository.DDConductivitySensorNames.D27_COND.name, dd_enum_repository.DDConductivityResistanceAttributes.CONDUCTIVITY.name, DataTypes.F32)) @@ -131,7 +136,8 @@ self.process_into_dict(dict_to_update = self.dd_conductivity, decoder_list = sensor_list, message = message) - self.dd_conductivity_timestamp = timestamp + self.dd_conductivity_resistance_timestamp = timestamp + self.handler_resist_execution_times.append(time.perf_counter() - start) @publish(["msg_id_dd_conductivity_version_data", "dd_conductivity_resistance", "dd_conductivity_version_timestamp"]) def _handler_conductivity_version_sync(self, message, timestamp=0.0):