Index: leahi_dialin/dd/modules/conductivity_sensors.py =================================================================== diff -u -r8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d -r8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf --- leahi_dialin/dd/modules/conductivity_sensors.py (.../conductivity_sensors.py) (revision 8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d) +++ leahi_dialin/dd/modules/conductivity_sensors.py (.../conductivity_sensors.py) (revision 8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf) @@ -109,7 +109,8 @@ }, } - self.handler_execution_times = [] + 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): @@ -132,7 +133,7 @@ decoder_list = sensor_list, message = message) self.dd_conductivity_timestamp = timestamp - self.handler_execution_times.append(time.perf_counter() - start) + self.handler_cond_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): @@ -143,6 +144,7 @@ @param message: published DD conductivity sensor resistance data message @return: None """ + start = time.perf_counter() sensor_list =[] sensor_list.append((dd_enum_repository.DDConductivitySensorNames.D17_COND.name, dd_enum_repository.DDConductivityResistanceAttributes.RAW_RESISTANCE.name, DataTypes.F32)) sensor_list.append((dd_enum_repository.DDConductivitySensorNames.D27_COND.name, dd_enum_repository.DDConductivityResistanceAttributes.RAW_RESISTANCE.name, DataTypes.F32)) @@ -163,6 +165,7 @@ decoder_list = sensor_list, message = message) 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):