Index: leahi_dialin/td/modules/treatment.py =================================================================== diff -u -r489ce5ef49041b863501b7fecd6e4716e7dcaa9f -r0762e3a03157e5f3428387a6914a13ed38d3ddca --- leahi_dialin/td/modules/treatment.py (.../treatment.py) (revision 489ce5ef49041b863501b7fecd6e4716e7dcaa9f) +++ leahi_dialin/td/modules/treatment.py (.../treatment.py) (revision 0762e3a03157e5f3428387a6914a13ed38d3ddca) @@ -16,11 +16,13 @@ # Module imports from logging import Logger +import time # Project imports from leahi_dialin.common.constants import NO_RESET from leahi_dialin.common.generic_defs import DataTypes from leahi_dialin.common.msg_ids import MsgIds +from leahi_dialin.common.msg_ids import MsgIds from leahi_dialin.common.override_templates import cmd_generic_override from leahi_dialin.common import td_enum_repository from leahi_dialin.protocols.CAN import CanMessenger, CanChannels @@ -119,6 +121,7 @@ # Treatment Parameters Data. Most recent response. self.tx_param_req_timestamp = 0 #: The timestamp of the latest Treatment Parameters Request message + self.handler_execution_times = [] self.treatment_paramters = { 'blood_flow_rate': 0, # The Blood flow rate 'dialysate_flow_rate': 0, # The Dialysate flow rate @@ -228,6 +231,7 @@ @param message: published treatment parameter range data message @return: none """ + start = time.perf_counter() msg_list = [] msg_list.append((self.treatment_param_ranges, 'min_tx_time', DataTypes.U32)) msg_list.append((self.treatment_param_ranges, 'max_tx_time', DataTypes.U32)) @@ -238,6 +242,7 @@ self.process_into_vars(decoder_list = msg_list, message = message) self.tx_params_timestamp = timestamp + self.handler_execution_times.append((timestamp, message, time.perf_counter() - start)) @publish(["MSG_ID_TD_FLUID_BOLUS_DATA", "tgt_saline_volume","cum_saline_volume","bol_saline_volume",