Index: leahi_dialin/dd/modules/alarms.py
===================================================================
diff -u -r8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/dd/modules/alarms.py	(.../alarms.py)	(revision 8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf)
+++ leahi_dialin/dd/modules/alarms.py	(.../alarms.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -117,7 +117,7 @@
         self.last_alarm_data_1 = result['data_1']
         self.last_alarm_data_2 = result['data_2']
         self.dd_alarm_triggered_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     @publish(["msg_id_dd_alarm_info", "alarm_safety_shutdown_status",  "dd_alarm_info_timestamp"])
Index: leahi_dialin/dd/modules/balancing_chamber.py
===================================================================
diff -u -r8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/dd/modules/balancing_chamber.py	(.../balancing_chamber.py)	(revision 8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d)
+++ leahi_dialin/dd/modules/balancing_chamber.py	(.../balancing_chamber.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -91,7 +91,7 @@
                                message = message)
 
         self.dd_bal_chamber_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
     def cmd_balancing_chamber_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
         """
Index: leahi_dialin/dd/modules/blood_leak.py
===================================================================
diff -u -r8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/dd/modules/blood_leak.py	(.../blood_leak.py)	(revision 8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d)
+++ leahi_dialin/dd/modules/blood_leak.py	(.../blood_leak.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -159,7 +159,7 @@
         self.process_into_vars(decoder_list = msg_list,
                                message = message)
         self.dd_blood_leak_status_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     @publish(['msg_id_dd_send_blood_leak_emb_mode_response', 'blood_leak_emb_mode_cmd_response',
Index: leahi_dialin/dd/modules/concentrate_pump.py
===================================================================
diff -u -r9b516a55e9622aa62cce1a017153a03eb66fdcc7 -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/dd/modules/concentrate_pump.py	(.../concentrate_pump.py)	(revision 9b516a55e9622aa62cce1a017153a03eb66fdcc7)
+++ leahi_dialin/dd/modules/concentrate_pump.py	(.../concentrate_pump.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -132,7 +132,7 @@
                                decoder_list = sensor_list,
                                message = message)
         self.dd_concentrate_pump_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter()-start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
 
Index: leahi_dialin/dd/modules/conductivity_sensors.py
===================================================================
diff -u -rc4b92f4de01ac39942ccdc1a18d9dd85be31a2c0 -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/dd/modules/conductivity_sensors.py	(.../conductivity_sensors.py)	(revision c4b92f4de01ac39942ccdc1a18d9dd85be31a2c0)
+++ leahi_dialin/dd/modules/conductivity_sensors.py	(.../conductivity_sensors.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -137,7 +137,7 @@
                                decoder_list = sensor_list,
                                message = message)
         self.dd_conductivity_resistance_timestamp = timestamp
-        self.handler_resist_execution_times.append(time.perf_counter() - start)
+        self.handler_resist_execution_times.append((timestamp, message, 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):
Index: leahi_dialin/dd/modules/dialysate_pump.py
===================================================================
diff -u -r9b516a55e9622aa62cce1a017153a03eb66fdcc7 -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/dd/modules/dialysate_pump.py	(.../dialysate_pump.py)	(revision 9b516a55e9622aa62cce1a017153a03eb66fdcc7)
+++ leahi_dialin/dd/modules/dialysate_pump.py	(.../dialysate_pump.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -119,7 +119,7 @@
                                decoder_list = sensor_list,
                                message = message)
         self.dd_dialysate_pump_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter()-start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_dialysate_pump_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/dd/modules/drybicart.py
===================================================================
diff -u -r8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/dd/modules/drybicart.py	(.../drybicart.py)	(revision 8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d)
+++ leahi_dialin/dd/modules/drybicart.py	(.../drybicart.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -101,7 +101,7 @@
                                message = message)
 
         self.dd_dry_bicart_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_dry_bicart_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/dd/modules/events.py
===================================================================
diff -u -r8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/dd/modules/events.py	(.../events.py)	(revision 8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d)
+++ leahi_dialin/dd/modules/events.py	(.../events.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -292,7 +292,7 @@
         # Update event dictionary
         self._event_dictionary[event_enum.name].append(event_tuple)
         self.events_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
 
Index: leahi_dialin/dd/modules/gen_dialysate.py
===================================================================
diff -u -r8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/dd/modules/gen_dialysate.py	(.../gen_dialysate.py)	(revision 8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d)
+++ leahi_dialin/dd/modules/gen_dialysate.py	(.../gen_dialysate.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -80,7 +80,7 @@
         self.process_into_vars(decoder_list = msg_list,
                                message = message)
         self.dd_gen_dialysate_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_gen_dialysate_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/dd/modules/heaters.py
===================================================================
diff -u -r9b516a55e9622aa62cce1a017153a03eb66fdcc7 -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/dd/modules/heaters.py	(.../heaters.py)	(revision 9b516a55e9622aa62cce1a017153a03eb66fdcc7)
+++ leahi_dialin/dd/modules/heaters.py	(.../heaters.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -126,7 +126,7 @@
                                message = message,
                                start_from_byte = len(sensor_list) * DataTypes.U32.size())
         self.dd_heaters_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter()-start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_heaters_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/dd/modules/levels.py
===================================================================
diff -u -r8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/dd/modules/levels.py	(.../levels.py)	(revision 8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d)
+++ leahi_dialin/dd/modules/levels.py	(.../levels.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -86,7 +86,7 @@
                                message = message,
                                start_from_byte = len(sensor_list) * DataTypes.U32.size())
         self.dd_levels_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_levels_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/dd/modules/mixing_cntrl.py
===================================================================
diff -u -r9b516a55e9622aa62cce1a017153a03eb66fdcc7 -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/dd/modules/mixing_cntrl.py	(.../mixing_cntrl.py)	(revision 9b516a55e9622aa62cce1a017153a03eb66fdcc7)
+++ leahi_dialin/dd/modules/mixing_cntrl.py	(.../mixing_cntrl.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -158,7 +158,7 @@
                                message = message)
 
         self.dd_mixing_control_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter()-start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_dialysate_mixing_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/dd/modules/post_gen_dialysate.py
===================================================================
diff -u -r8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/dd/modules/post_gen_dialysate.py	(.../post_gen_dialysate.py)	(revision 8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d)
+++ leahi_dialin/dd/modules/post_gen_dialysate.py	(.../post_gen_dialysate.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -69,7 +69,7 @@
         self.process_into_vars(decoder_list = msg_list,
                                message = message)
         self.post_gen_state_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_post_gen_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/dd/modules/pre_gen_dialysate.py
===================================================================
diff -u -r8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/dd/modules/pre_gen_dialysate.py	(.../pre_gen_dialysate.py)	(revision 8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d)
+++ leahi_dialin/dd/modules/pre_gen_dialysate.py	(.../pre_gen_dialysate.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -81,7 +81,7 @@
                                message = message)
 
         self.pre_gen_state_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     @publish(["msg_id_dd_pre_gen_dialysate_request_data",
Index: leahi_dialin/dd/modules/pressure_sensors.py
===================================================================
diff -u -r8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/dd/modules/pressure_sensors.py	(.../pressure_sensors.py)	(revision 8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d)
+++ leahi_dialin/dd/modules/pressure_sensors.py	(.../pressure_sensors.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -84,7 +84,7 @@
                                decoder_list = sensor_list,
                                message = message)
         self.dd_pressures_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
     def cmd_pressure_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
         """
Index: leahi_dialin/dd/modules/rinse_pump.py
===================================================================
diff -u -r8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/dd/modules/rinse_pump.py	(.../rinse_pump.py)	(revision 8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d)
+++ leahi_dialin/dd/modules/rinse_pump.py	(.../rinse_pump.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -76,7 +76,7 @@
         self.process_into_vars(decoder_list = msg_list,
                                message = message)
         self.dd_rinse_pump_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_rinse_pump_data_publish_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/dd/modules/spent_chamber_fill.py
===================================================================
diff -u -r8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/dd/modules/spent_chamber_fill.py	(.../spent_chamber_fill.py)	(revision 8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d)
+++ leahi_dialin/dd/modules/spent_chamber_fill.py	(.../spent_chamber_fill.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -76,7 +76,7 @@
         self.process_into_vars(decoder_list = msg_list,
                                message = message)
         self.dd_spent_chamber_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_spent_chamber_fill_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/dd/modules/substitution_pump.py
===================================================================
diff -u -r8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/dd/modules/substitution_pump.py	(.../substitution_pump.py)	(revision 8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d)
+++ leahi_dialin/dd/modules/substitution_pump.py	(.../substitution_pump.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -85,7 +85,7 @@
                                message = message)
 
         self.dd_substitution_pump_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
     def cmd_substitution_pump_data_publish_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
         """
Index: leahi_dialin/dd/modules/temperature_sensors.py
===================================================================
diff -u -r9b516a55e9622aa62cce1a017153a03eb66fdcc7 -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/dd/modules/temperature_sensors.py	(.../temperature_sensors.py)	(revision 9b516a55e9622aa62cce1a017153a03eb66fdcc7)
+++ leahi_dialin/dd/modules/temperature_sensors.py	(.../temperature_sensors.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -115,7 +115,7 @@
                                decoder_list = sensor_list,
                                message = message)
         self.dd_temperatures_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter()-start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
         
 
 
Index: leahi_dialin/dd/modules/ultrafiltration.py
===================================================================
diff -u -r8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/dd/modules/ultrafiltration.py	(.../ultrafiltration.py)	(revision 8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d)
+++ leahi_dialin/dd/modules/ultrafiltration.py	(.../ultrafiltration.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -77,7 +77,7 @@
         self.process_into_vars(decoder_list = msg_list,
                                message = message)
         self.uf_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_uf_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/dd/modules/valves.py
===================================================================
diff -u -r8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/dd/modules/valves.py	(.../valves.py)	(revision 8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d)
+++ leahi_dialin/dd/modules/valves.py	(.../valves.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -288,7 +288,7 @@
             start = end
             end += 1
         self.dd_valves_states_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_valve_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/dd/modules/voltages.py
===================================================================
diff -u -r9b516a55e9622aa62cce1a017153a03eb66fdcc7 -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/dd/modules/voltages.py	(.../voltages.py)	(revision 9b516a55e9622aa62cce1a017153a03eb66fdcc7)
+++ leahi_dialin/dd/modules/voltages.py	(.../voltages.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -96,7 +96,7 @@
                                decoder_list = sensor_list,
                                message = message)
         self.dd_voltages_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter()-start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_monitored_voltages_broadcast_interval_override(self, ms: int = 1000, reset: int = NO_RESET) -> int:
Index: leahi_dialin/fp/modules/alarms.py
===================================================================
diff -u -r8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/fp/modules/alarms.py	(.../alarms.py)	(revision 8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d)
+++ leahi_dialin/fp/modules/alarms.py	(.../alarms.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -115,7 +115,7 @@
         self.last_alarm_data_1 = result['data_1']
         self.last_alarm_data_2 = result['data_2']
         self.fp_alarm_triggered_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_alarm_state_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/fp/modules/boost_pump.py
===================================================================
diff -u -r8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/fp/modules/boost_pump.py	(.../boost_pump.py)	(revision 8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d)
+++ leahi_dialin/fp/modules/boost_pump.py	(.../boost_pump.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -92,7 +92,7 @@
                                decoder_list = sensor_list,
                                message = message)
         self.boost_pump_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_boost_pump_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/fp/modules/conductivity_sensors.py
===================================================================
diff -u -rc4b92f4de01ac39942ccdc1a18d9dd85be31a2c0 -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/fp/modules/conductivity_sensors.py	(.../conductivity_sensors.py)	(revision c4b92f4de01ac39942ccdc1a18d9dd85be31a2c0)
+++ leahi_dialin/fp/modules/conductivity_sensors.py	(.../conductivity_sensors.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -110,7 +110,7 @@
                                decoder_list = sensor_list,
                                message = message)
         self.fp_conductivity_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     @publish(["msg_id_ro_rejection_ratio_data", "ro_rejection_ratio", "ro_rejection_ratio_timestamp"])
@@ -134,7 +134,7 @@
                                decoder_list = sensor_list,
                                message = message)
         self.ro_rejection_ratio_timestamp = timestamp
-        self.handler_ro_execution_times.append(time.perf_counter() - start)
+        self.handler_ro_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_conductivity_sensor_data_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/fp/modules/events.py
===================================================================
diff -u -r8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/fp/modules/events.py	(.../events.py)	(revision 8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf)
+++ leahi_dialin/fp/modules/events.py	(.../events.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -291,7 +291,7 @@
         # Update event dictionary
         self._event_dictionary[event_enum.name].append(event_tuple)
         self.events_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
     @publish(["msg_id_fp_op_mode_data", "event_op_mode_timestamp", "op_mode", "sub_mode"])
     def _handler_fp_op_mode_sync(self, message, timestamp=0.0):
Index: leahi_dialin/fp/modules/flow_sensors.py
===================================================================
diff -u -r8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/fp/modules/flow_sensors.py	(.../flow_sensors.py)	(revision 8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d)
+++ leahi_dialin/fp/modules/flow_sensors.py	(.../flow_sensors.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -76,7 +76,7 @@
                                decoder_list = sensor_list,
                                message = message)
         self.fp_flow_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_flow_sensor_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/fp/modules/levels.py
===================================================================
diff -u -r8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/fp/modules/levels.py	(.../levels.py)	(revision 8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d)
+++ leahi_dialin/fp/modules/levels.py	(.../levels.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -77,7 +77,7 @@
                                decoder_list = sensor_list,
                                message = message)
         self.fp_levels_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_levels_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/fp/modules/permeate_tank.py
===================================================================
diff -u -r8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/fp/modules/permeate_tank.py	(.../permeate_tank.py)	(revision 8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d)
+++ leahi_dialin/fp/modules/permeate_tank.py	(.../permeate_tank.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -68,7 +68,7 @@
         self.process_into_vars(decoder_list = msg_list,
                                message = message)
         self.permeate_tank_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_permeate_tank_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/fp/modules/pressure_sensors.py
===================================================================
diff -u -r8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/fp/modules/pressure_sensors.py	(.../pressure_sensors.py)	(revision 8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d)
+++ leahi_dialin/fp/modules/pressure_sensors.py	(.../pressure_sensors.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -83,7 +83,7 @@
                                decoder_list = sensor_list,
                                message = message)
         self.fp_pressure_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_pressure_sensors_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/fp/modules/ro_pump.py
===================================================================
diff -u -r8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/fp/modules/ro_pump.py	(.../ro_pump.py)	(revision 8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d)
+++ leahi_dialin/fp/modules/ro_pump.py	(.../ro_pump.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -92,7 +92,7 @@
                                decoder_list = sensor_list,
                                message = message)
         self.ro_pump_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_ro_pump_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/fp/modules/temperatures.py
===================================================================
diff -u -r8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/fp/modules/temperatures.py	(.../temperatures.py)	(revision 8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d)
+++ leahi_dialin/fp/modules/temperatures.py	(.../temperatures.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -89,7 +89,7 @@
                                decoder_list = sensor_list,
                                message = message)
         self.fp_temperature_sensors_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_temperatures_data_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/fp/modules/valves.py
===================================================================
diff -u -r8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/fp/modules/valves.py	(.../valves.py)	(revision 8ebb614a8c6e52b27d40ac5ef8b48aa22a4be73d)
+++ leahi_dialin/fp/modules/valves.py	(.../valves.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -164,7 +164,7 @@
             start = end
             end += 1
         self.fp_valves_states_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_valve_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/td/modules/air_pump.py
===================================================================
diff -u -r8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/td/modules/air_pump.py	(.../air_pump.py)	(revision 8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf)
+++ leahi_dialin/td/modules/air_pump.py	(.../air_pump.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -89,7 +89,7 @@
                                decoder_list = sensor_list,
                                message = message)
         self.td_air_pump_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_air_pump_data_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/td/modules/air_trap.py
===================================================================
diff -u -r8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/td/modules/air_trap.py	(.../air_trap.py)	(revision 8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf)
+++ leahi_dialin/td/modules/air_trap.py	(.../air_trap.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -120,7 +120,7 @@
                                message = message,
                                start_from_byte = (len(sensor_list_1) + len(sensor_list_2)) * DataTypes.U32.size())
         self.td_air_trap_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_air_trap_data_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/td/modules/alarms.py
===================================================================
diff -u -r8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/td/modules/alarms.py	(.../alarms.py)	(revision 8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf)
+++ leahi_dialin/td/modules/alarms.py	(.../alarms.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -389,7 +389,7 @@
                 self.alarm_table[result['Alarm_Id']][prop] = result[prop]
 
         self.alarm_table_timestamp = timestamp
-        self.handler_clr_execution_times.append(time.perf_counter() - start)
+        self.handler_clr_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_alarm_status_broadcast_interval_override(self, ms: int = 250, reset: int = NO_RESET):
Index: leahi_dialin/td/modules/blood_flow.py
===================================================================
diff -u -r8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/td/modules/blood_flow.py	(.../blood_flow.py)	(revision 8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf)
+++ leahi_dialin/td/modules/blood_flow.py	(.../blood_flow.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -91,7 +91,7 @@
                                decoder_list = sensor_list,
                                message = message)
         self.td_blood_flow_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_blood_flow_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/td/modules/blood_pressure.py
===================================================================
diff -u -r3e8c15745640db0568536912a36704a567bd73c2 -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/td/modules/blood_pressure.py	(.../blood_pressure.py)	(revision 3e8c15745640db0568536912a36704a567bd73c2)
+++ leahi_dialin/td/modules/blood_pressure.py	(.../blood_pressure.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -16,6 +16,7 @@
 
 # Module imports
 from logging import Logger
+import time
 
 # Project imports
 from leahi_dialin.common.generic_defs import DataTypes
@@ -56,6 +57,8 @@
         self.systolic = 0                                   #: The Patient's systolic blood pressure in mmHg
         self.diastolic = 0                                  #: The Patient's diastolic blood pressure in mmHg
         self.heart_rate = 0                                 #: The Patient's heart rate in PBM
+        self.handler_bp_time = []
+        self.handler_bp_rr_time = []
 
 
     @publish(["msg_id_td_blood_pressure_data", "systolic", "diastolic", "heart_rate", "blood_pressure_timestamp"])
@@ -66,6 +69,7 @@
         @param message:  published data message
         @return: none
         """
+        start = time.perf_counter()
         msg_list =[]
         msg_list.append(('self.systolic',    DataTypes.U32))
         msg_list.append(('self.diastolic',   DataTypes.U32))
@@ -74,8 +78,8 @@
         self.process_into_vars(decoder_list = msg_list,
                                message = message)
         self.blood_pressure_timestamp = timestamp
+        self.handler_bp_time.append((timestamp, message, time.perf_counter() - start))
 
-
     @publish(["msg_id_td_blood_pressure_response", "ack", "reject_reason", "rr_timestamp"])
     def _handler_bp_rr_sync(self, message, timestamp=0.0):
         """
@@ -84,13 +88,15 @@
         @param message: published data message
         @return: none
         """
+        start = time.perf_counter()
         msg_list =[]
         msg_list.append(('self.ack',            DataTypes.U32))
         msg_list.append(('self.reject_reason',  DataTypes.U32))
 
         self.process_into_vars(decoder_list = msg_list,
                                message = message)
         self.rr_timestamp = timestamp
+        self.handler_bp_rr_time.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_send_ui_blood_pressure_request(self) -> None:
Index: leahi_dialin/td/modules/bubble_detector.py
===================================================================
diff -u -r8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/td/modules/bubble_detector.py	(.../bubble_detector.py)	(revision 8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf)
+++ leahi_dialin/td/modules/bubble_detector.py	(.../bubble_detector.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -91,7 +91,7 @@
                                decoder_list = sensor_list,
                                message = message)
         self.td_air_bubbles_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_air_bubbles_data_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/td/modules/buttons.py
===================================================================
diff -u -r8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/td/modules/buttons.py	(.../buttons.py)	(revision 8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf)
+++ leahi_dialin/td/modules/buttons.py	(.../buttons.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -83,7 +83,7 @@
         if len(mode) > 0:
             self.poweroff_timeout_expired = bool(mode[0])
         self.td_power_off_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_off_button_override(self, state: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/td/modules/ejector.py
===================================================================
diff -u -r8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/td/modules/ejector.py	(.../ejector.py)	(revision 8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf)
+++ leahi_dialin/td/modules/ejector.py	(.../ejector.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -83,7 +83,7 @@
                                decoder_list = sensor_list,
                                message = message)
         self.td_ejector_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_ejector_data_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/td/modules/events.py
===================================================================
diff -u -r8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/td/modules/events.py	(.../events.py)	(revision 8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf)
+++ leahi_dialin/td/modules/events.py	(.../events.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -17,7 +17,7 @@
 import struct
 from logging import Logger
 from datetime import datetime
-from time import time
+import time
 # Module imports
 from logging import Logger
 
@@ -285,7 +285,7 @@
         # Update event dictionary
         self._event_dictionary[event_enum.name].append(event_tuple)
         self.events_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     @publish(["msg_id_td_op_mode_data", "event_op_mode_timestamp", "op_mode", "sub_mode"])
Index: leahi_dialin/td/modules/pressure_sensors.py
===================================================================
diff -u -r8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/td/modules/pressure_sensors.py	(.../pressure_sensors.py)	(revision 8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf)
+++ leahi_dialin/td/modules/pressure_sensors.py	(.../pressure_sensors.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -130,7 +130,7 @@
                                start_from_byte = (len(sensor_list_1) + len(msg_list_1)) * DataTypes.F32.size())
 
         self.td_pressure_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_pressure_sensors_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/td/modules/switches.py
===================================================================
diff -u -r8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/td/modules/switches.py	(.../switches.py)	(revision 8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf)
+++ leahi_dialin/td/modules/switches.py	(.../switches.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -72,7 +72,7 @@
                                decoder_list = sensor_list,
                                message = message)
         self.td_switches_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_switches_data_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/td/modules/syringe_pump.py
===================================================================
diff -u -r8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/td/modules/syringe_pump.py	(.../syringe_pump.py)	(revision 8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf)
+++ leahi_dialin/td/modules/syringe_pump.py	(.../syringe_pump.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -103,7 +103,7 @@
                                message = message)
 
         self.td_syringe_pump_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
     def cmd_syringe_pump_operation(self, operation: int = SyringePumpOperations.SYRINGE_PUMP_OP_STOP.value,
                                    rate: float = 0.0,
Index: leahi_dialin/td/modules/temperature_sensors.py
===================================================================
diff -u -r8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/td/modules/temperature_sensors.py	(.../temperature_sensors.py)	(revision 8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf)
+++ leahi_dialin/td/modules/temperature_sensors.py	(.../temperature_sensors.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -76,7 +76,7 @@
                                decoder_list = sensor_list,
                                message = message)
         self.td_temperature_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_temperature_sensors_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/td/modules/treatment.py
===================================================================
diff -u -r8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/td/modules/treatment.py	(.../treatment.py)	(revision 8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf)
+++ leahi_dialin/td/modules/treatment.py	(.../treatment.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -154,7 +154,7 @@
         self.process_into_vars(decoder_list = msg_list,
                                message = message)
         self.tx_params_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     @publish(["msg_id_td_saline_bolus_data", "tgt_saline_volume","cum_saline_volume","bol_saline_volume",
Index: leahi_dialin/td/modules/valves.py
===================================================================
diff -u -r8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/td/modules/valves.py	(.../valves.py)	(revision 8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf)
+++ leahi_dialin/td/modules/valves.py	(.../valves.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -93,7 +93,7 @@
             # Update the valves dictionary
             self.valves_status[result['Valve']] = result
         self.td_valves_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_valves_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
Index: leahi_dialin/td/modules/voltages.py
===================================================================
diff -u -r8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf -r034ef9887584984c3f261bfb748aa70994b9751b
--- leahi_dialin/td/modules/voltages.py	(.../voltages.py)	(revision 8ad61b1fa2e79b11b1c3db53a3242662e8eb9adf)
+++ leahi_dialin/td/modules/voltages.py	(.../voltages.py)	(revision 034ef9887584984c3f261bfb748aa70994b9751b)
@@ -82,7 +82,7 @@
                                decoder_list = sensor_list,
                                message = message)
         self.td_voltages_timestamp = timestamp
-        self.handler_execution_times.append(time.perf_counter() - start)
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_monitored_voltages_broadcast_interval_override(self, ms: int = 1000, reset: int = NO_RESET) -> int: