Index: DG/DialysateGenerator.py
===================================================================
diff -u -r0a66cef524a41670eed7b9204163bb9634a2f919 -r082ea4c8b0c6a3c804453308990d0bb98a0a2156
--- DG/DialysateGenerator.py	(.../DialysateGenerator.py)	(revision 0a66cef524a41670eed7b9204163bb9634a2f919)
+++ DG/DialysateGenerator.py	(.../DialysateGenerator.py)	(revision 082ea4c8b0c6a3c804453308990d0bb98a0a2156)
@@ -13,6 +13,7 @@
 #  @brief This class allows sending to and receiving from the DG device.
 #
 ############################################################################
+# TODO: Needs to be restructured and existing TODO items need to be addressed.
 
 from DialIn.CoreCANProtocol import (DenaliCanMessenger,
                                     DenaliMessage,
Index: HD/Alarms.py
===================================================================
diff -u
--- HD/Alarms.py	(revision 0)
+++ HD/Alarms.py	(revision 082ea4c8b0c6a3c804453308990d0bb98a0a2156)
@@ -0,0 +1,263 @@
+from DialIn.CoreCANProtocol import (DenaliMessage,
+                                    DenaliChannels)
+import struct
+from .utils import integer2ByteArray
+from .HemodialysisDevice import HD
+
+
+class HDAlarms:
+    """
+        \class HD_Alarms
+
+        \brief Hemodialysis Device (HD) Dialin API sub-class for alarm related commands.
+    """
+
+    # Alarms message IDs
+    MSG_ID_HD_ALARMS_PUBLISHED_STATUS = 0x0002
+    MSG_ID_HD_ALARM_ACTIVATE = 0x0003
+    MSG_ID_HD_ALARM_CLEAR = 0x0004
+    MSG_ID_HD_ALARM_LAMP_OVERRIDE = 0x8004
+    MSG_ID_HD_ALARM_STATE_OVERRIDE = 0x8006
+    MSG_ID_HD_ALARM_TIME_OVERRIDE = 0x8007
+
+    # Alarm lamp patterns
+    HD_ALARM_LAMP_PATTERN_OFF = 0
+    HD_ALARM_LAMP_PATTERN_OK = 1
+    HD_ALARM_LAMP_PATTERN_FAULT = 2
+    HD_ALARM_LAMP_PATTERN_HIGH = 3
+    HD_ALARM_LAMP_PATTERN_MEDIUM = 4
+    HD_ALARM_LAMP_PATTERN_LOW = 5
+    HD_ALARM_LAMP_PATTERN_MANUAL = 6
+
+    # Alarm status message field positions
+    START_POS_ALARM_STATE = DenaliMessage.PAYLOAD_START_INDEX
+    END_POS_ALARM_STATE = START_POS_ALARM_STATE + 4
+    START_POS_ALARM_TOP = END_POS_ALARM_STATE
+    END_POS_ALARM_TOP = START_POS_ALARM_TOP + 4
+    START_POS_ALARM_SILENCE_EXPIRES_IN = END_POS_ALARM_TOP
+    END_POS_ALARM_SILENCE_EXPIRES_IN = START_POS_ALARM_SILENCE_EXPIRES_IN + 4
+    START_POS_ALARM_ESCALATES_IN = END_POS_ALARM_SILENCE_EXPIRES_IN
+    END_POS_ALARM_ESCALATES_IN = START_POS_ALARM_ESCALATES_IN + 4
+    START_POS_ALARMS_FLAGS = END_POS_ALARM_ESCALATES_IN
+    END_POS_ALARMS_FLAGS = START_POS_ALARMS_FLAGS + 2
+
+    START_POS_ALARM_ID = DenaliMessage.PAYLOAD_START_INDEX
+    END_POS_ALARM_ID = START_POS_ALARM_ID + 2
+
+    def __init__(self, can_interface):
+        """
+            HD_Alarms constructor
+
+            \param outer_instance: reference to the HD (outer) class.
+
+            \returns HD_Alarms object.
+        """
+        self.can_interface = can_interface
+
+        if self.can_interface is not None:
+            channel_id = DenaliChannels.hd_alarm_broadcast_ch_id
+            msg_id = self.MSG_ID_HD_ALARMS_PUBLISHED_STATUS
+            self.can_interface.register_receiving_publication_function(channel_id, msg_id,
+                                                                       self.handler_alarms_status_sync)
+
+            channel_id = DenaliChannels.hd_alarm_broadcast_ch_id
+            msg_id = self.MSG_ID_HD_ALARM_ACTIVATE
+            self.can_interface.register_receiving_publication_function(channel_id, msg_id,
+                                                                       self.handler_alarm_activate)
+            channel_id = DenaliChannels.hd_alarm_broadcast_ch_id
+            msg_id = self.MSG_ID_HD_ALARM_CLEAR
+            self.can_interface.register_receiving_publication_function(channel_id, msg_id,
+                                                                       self.handler_alarm_clear)
+
+        # composite alarm status based on latest HD alarm status broadcast message
+        self.alarmsState = 0
+        self.alarmTop = 0
+        self.alarmsSilenceExpiresIn = 0
+        self.alarmsEscalatesIn = 0
+        self.alarmsFlags = 0
+
+        # alarm states based on received HD alarm activation and alarm clear messages
+        self.alarmStates = [False] * 50
+
+
+    def handler_alarms_status_sync(self, message):
+        """
+            Handles published alarms status messages.  Alarms status data are captured
+            for reference.
+
+            \param message:  published blood flow data message
+            \returns none
+        """
+
+        self.alarmsState = int.from_bytes(bytearray(
+            message['message'][self.START_POS_ALARM_STATE:self.END_POS_ALARM_STATE]),
+            byteorder=DenaliMessage.BYTE_ORDER)
+        self.alarmTop = int.from_bytes(bytearray(
+            message['message'][self.START_POS_ALARM_TOP:self.END_POS_ALARM_TOP]),
+            byteorder=DenaliMessage.BYTE_ORDER)
+        self.alarmsSilenceExpiresIn = int.from_bytes(bytearray(
+            message['message'][self.START_POS_ALARM_SILENCE_EXPIRES_IN:self.END_POS_ALARM_SILENCE_EXPIRES_IN]),
+            byteorder=DenaliMessage.BYTE_ORDER)
+        self.alarmsEscalatesIn = int.from_bytes(bytearray(
+            message['message'][self.START_POS_ALARM_ESCALATES_IN:self.END_POS_ALARM_ESCALATES_IN]),
+            byteorder=DenaliMessage.BYTE_ORDER)
+        self.alarmsFlags = int.from_bytes(bytearray(
+            message['message'][self.START_POS_ALARMS_FLAGS:self.END_POS_ALARMS_FLAGS]),
+            byteorder=DenaliMessage.BYTE_ORDER)
+
+    def handler_alarm_activate(self, message):
+        """
+            Handles published HD alarm activation messages.
+
+            \param message:  published HD alarm activation message
+            \returns none
+        """
+
+        alarmID = struct.unpack('<H', bytearray(message['message'][self.START_POS_ALARM_ID:self.END_POS_ALARM_ID]))
+        self.alarmStates[alarmID[0]] = True
+
+    def handler_alarm_clear(self, message):
+        """
+            Handles published HD alarm clear messages.
+
+            \param message:  published HD alarm clear message
+            \returns none
+        """
+
+        alarmID = struct.unpack('<H', bytearray(message['message'][self.START_POS_ALARM_ID:self.END_POS_ALARM_ID]))
+        self.alarmStates[alarmID[0]] = False
+
+    def cmd_alarm_state_override(self, reset, state, alarm):
+        """
+            Constructs and sends the alarm state override command
+
+            \param reset:  integer - 1 to reset a previous override, 0 to override
+            \param state:  integer - 1 for alarm active, 0 for alarm inactive
+            \param alarm:  integer - ID of alarm to override
+            \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        sta = integer2ByteArray(state)
+        alm = integer2ByteArray(alarm)
+        payload = rst + sta + alm
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_ALARM_STATE_OVERRIDE,
+                                              payload=payload)
+
+        print("override alarm state")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            # print(received_message)
+            if reset == HD.RESET:
+                str_res = "reset back to normal"
+            else:
+                str_res = ("active" if state != 0 else "inactive")
+            print("Alarm state overridden to " + str_res + ":" +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
+
+    def cmd_alarm_time_override(self, reset, time_ms, alarm):
+        """
+            Constructs and sends the alarm time override command
+
+            \param reset:  integer - 1 to reset a previous override, 0 to override
+            \param time_ms:  integer - time (in ms) since alarm was activated
+            \param alarm:  integer - ID of alarm to override
+            \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        ms = integer2ByteArray(time_ms)
+        alm = integer2ByteArray(alarm)
+        payload = rst + ms + alm
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_ALARM_TIME_OVERRIDE,
+                                              payload=payload)
+
+        print("override alarm time since activated")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            # print(received_message)
+            if reset == HD.RESET:
+                str_res = "reset back to normal"
+            else:
+                str_res = str(time_ms)
+            print("Alarm time since activated overridden to " + str_res + " ms: " + str(
+                received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
+
+    def cmd_alarm_lamp_pattern_override(self, reset, pattern):
+        """
+            Constructs and sends the alarm lamp pattern override command.
+
+            \param reset:  integer - 1 to reset a previous override, 0 to override
+            \param pattern:  integer - ID of alarm lamp pattern to override with
+            \returns 1 if successful, zero otherwise
+
+            \details Patterns: \n
+                0 = off \n
+                1 = ok \n
+                2 = fault \n
+                3 = high \n
+                4 = medium \n
+                5 = low \n
+                6 = manual
+        """
+        rst = integer2ByteArray(reset)
+        pat = integer2ByteArray(pattern)
+        payload = rst + pat
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_ALARM_LAMP_OVERRIDE,
+                                              payload=payload)
+
+        print("override alarm lamp pattern")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            print(received_message)
+            if reset == HD.RESET:
+                str_pat = "reset back to normal"
+            elif pattern == self.HD_ALARM_LAMP_PATTERN_OFF:
+                str_pat = "off"
+            elif pattern == self.HD_ALARM_LAMP_PATTERN_OK:
+                str_pat = "ok"
+            elif pattern == self.HD_ALARM_LAMP_PATTERN_FAULT:
+                str_pat = "fault"
+            elif pattern == self.HD_ALARM_LAMP_PATTERN_HIGH:
+                str_pat = "high"
+            elif pattern == self.HD_ALARM_LAMP_PATTERN_MEDIUM:
+                str_pat = "medium"
+            elif pattern == self.HD_ALARM_LAMP_PATTERN_LOW:
+                str_pat = "low"
+            else:
+                str_pat = "manual"
+            print("Alarm lamp pattern overridden to " + str_pat + ":" +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
Index: HD/Basics.py
===================================================================
diff -u
--- HD/Basics.py	(revision 0)
+++ HD/Basics.py	(revision 082ea4c8b0c6a3c804453308990d0bb98a0a2156)
@@ -0,0 +1,81 @@
+from DialIn.CoreCANProtocol import (DenaliMessage,
+                                    DenaliChannels)
+
+
+class HDBasics:
+    """
+    \class HDBasics
+
+    \brief Hemodialysis Device (HD) Dialin API sub-class for basic HD commands.
+    """
+
+    # Basic message IDs
+    MSG_ID_LOGIN_TO_HD = 0x8000
+    MSG_ID_HD_MSG = 0x8001
+
+    # HD login password
+    HD_LOGIN_PASSWORD = '123'
+
+    def __init__(self, can_interface):
+        """
+        HDBasics constructor
+
+        \param can_interface: the denali can interface object
+        """
+
+        self.can_interface = can_interface
+
+    def cmd_log_in_to_hd(self):
+        """
+        Constructs and sends a login command via CAN bus.  Login required before \n
+        other commands can be sent to the HD.
+
+        \returns 1 if logged in, 0 if log in failed
+        """
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_LOGIN_TO_HD,
+                                              payload=list(map(int, map(ord, self.HD_LOGIN_PASSWORD))))
+
+        print("login")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        if received_message is not None:
+            if received_message['message'][DenaliMessage.PAYLOAD_START_INDEX] == 1:
+                print("Logged In")
+            else:
+                print("Log In Failed.")
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
+
+    def cmd_hd_message_insert(self, msg):
+        """
+        Constructs and sends the insert HD message command.  Given message will \n
+        be inserted into the HD's received message queue for processing.
+
+        \param msg:  byte array - properly formatted HD message to insert
+
+        \returns 1 if successful, zero otherwise
+        """
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_MSG,
+                                              payload=msg)
+
+        print("insert HD message")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            print("Inserted message: " + str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
Index: HD/BloodFlow.py
===================================================================
diff -u
--- HD/BloodFlow.py	(revision 0)
+++ HD/BloodFlow.py	(revision 082ea4c8b0c6a3c804453308990d0bb98a0a2156)
@@ -0,0 +1,362 @@
+from DialIn.CoreCANProtocol import (DenaliMessage,
+                                    DenaliChannels)
+from .utils import integer2ByteArray, float2ByteArray
+from .HemodialysisDevice import HD
+import struct
+
+class HDBloodFlow:
+    """
+        \class HD_BloodFlow
+
+        \brief Hemodialysis Device (HD) Dialin API sub-class for blood-flow related commands.
+
+    """
+
+    # BloodFlow message IDs
+    MSG_ID_HD_BLOOD_FLOW_PUBLISHED_DATA = 0x0005
+    MSG_ID_HD_BLOOD_FLOW_SET_RATE_OVERRIDE = 0x8008
+    MSG_ID_HD_BLOOD_FLOW_MEAS_RATE_OVERRIDE = 0x8009
+    MSG_ID_HD_BLOOD_PUMP_MC_MEAS_SPEED_OVERRIDE = 0x800A
+    MSG_ID_HD_BLOOD_PUMP_MC_MEAS_CURRENT_OVERRIDE = 0x800B
+    MSG_ID_HD_BLOOD_FLOW_PUBLISH_INTERVAL_OVERRIDE = 0x800C
+    MSG_ID_HD_BLOOD_PUMP_MEAS_SPEED_OVERRIDE = 0x800E
+    MSG_ID_HD_BLOOD_PUMP_ROTOR_MEAS_SPEED_OVERRIDE = 0x800F
+
+    # BloodFlow broadcast message field positions
+    START_POS_SET_PT = DenaliMessage.PAYLOAD_START_INDEX
+    END_POS_SET_PT = START_POS_SET_PT + 4
+    START_POS_MEAS_FLOW = END_POS_SET_PT
+    END_POS_MEAS_FLOW = START_POS_MEAS_FLOW + 4
+    START_POS_MEAS_ROT_SPEED = END_POS_MEAS_FLOW
+    END_POS_MEAS_ROT_SPEED = START_POS_MEAS_ROT_SPEED + 4
+    START_POS_MEAS_SPEED = END_POS_MEAS_ROT_SPEED
+    END_POS_MEAS_SPEED = START_POS_MEAS_SPEED + 4
+    START_POS_MEAS_MC_SPEED = END_POS_MEAS_SPEED
+    END_POS_MEAS_MC_SPEED = START_POS_MEAS_MC_SPEED + 4
+    START_POS_MEAS_MC_CURR = END_POS_MEAS_MC_SPEED
+    END_POS_MEAS_MC_CURR = START_POS_MEAS_MC_CURR + 4
+    START_POS_PWM_DC = END_POS_MEAS_MC_CURR
+    END_POS_PWM_DC = START_POS_PWM_DC + 4
+
+    def __init__(self, can_interface=None):
+        """
+            HD_BloodFlow constructor
+
+            \param outer_instance: reference to the HD (outer) class.
+
+            \returns HD_BloodFlow object.
+        """
+        self.can_interface = can_interface
+
+        if self.can_interface is not None:
+            channel_id = DenaliChannels.hd_sync_broadcast_ch_id
+            msg_id = self.MSG_ID_HD_BLOOD_FLOW_PUBLISHED_DATA
+            self.can_interface.register_receiving_publication_function(channel_id, msg_id,
+                                                                  self.handlerBloodFlowSyncFunction)
+
+        self.TargetBloodFlowRate = 0
+        self.MeasuredBloodFlowRate = 0.0
+        self.MeasuredBloodPumpRotorSpeed = 0.0
+        self.MeasuredBloodPumpSpeed = 0.0
+        self.MeasuredBloodPumpMCSpeed = 0.0
+        self.MeasuredBloodPumpMCCurrent = 0.0
+        self.PWMDutyCyclePct = 0.0
+
+    def handlerBloodFlowSyncFunction(self, message):
+        """
+            Handles published blood flow data messages.  Blood flow data are captured
+            for reference.
+
+            \param message:  published blood flow data message
+            \returns none
+        """
+
+        # self.TargetBloodFlowRate = int.from_bytes(bytearray(
+        #    message['message'][self.START_POS_SET_PT:self.END_POS_SET_PT]),
+        #    byteorder=DenaliMessage.BYTE_ORDER)
+        tgt = struct.unpack('i', bytearray(
+            message['message'][self.START_POS_SET_PT:self.END_POS_SET_PT]))
+
+        flow = struct.unpack('f', bytearray(
+            message['message'][self.START_POS_MEAS_FLOW:self.END_POS_MEAS_FLOW]))
+        rotor = struct.unpack('f', bytearray(
+            message['message'][self.START_POS_MEAS_ROT_SPEED:self.END_POS_MEAS_ROT_SPEED]))
+        speed = struct.unpack('f', bytearray(
+            message['message'][self.START_POS_MEAS_SPEED:self.END_POS_MEAS_SPEED]))
+        mcspeed = struct.unpack('f', bytearray(
+            message['message'][self.START_POS_MEAS_MC_SPEED:self.END_POS_MEAS_MC_SPEED]))
+        mccurr = struct.unpack('f', bytearray(
+            message['message'][self.START_POS_MEAS_MC_CURR:self.END_POS_MEAS_MC_CURR]))
+        pwm = struct.unpack('f', bytearray(
+            message['message'][self.START_POS_PWM_DC:self.END_POS_PWM_DC]))
+
+        self.TargetBloodFlowRate = tgt[0]
+        self.MeasuredBloodFlowRate = flow[0]
+        self.MeasuredBloodPumpRotorSpeed = rotor[0]
+        self.MeasuredBloodPumpSpeed = speed[0]
+        self.MeasuredBloodPumpMCSpeed = mcspeed[0]
+        self.MeasuredBloodPumpMCCurrent = mccurr[0]
+        self.PWMDutyCyclePct = pwm[0]
+
+    def CmdBloodFlowSetPointOverride(self, reset, flow):
+        """
+            Constructs and sends the blood flow set point override command
+
+            \param reset:  integer - 1 to reset a previous override, 0 to override
+            \param flow:  integer - flow set point (in mL/min) to override with (negative for reverse direction)
+            \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        flo = integer2ByteArray(flow)
+        payload = rst + flo
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_BLOOD_FLOW_SET_RATE_OVERRIDE,
+                                              payload=payload)
+
+        print("override blood flow set point")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            # print(received_message)
+            if reset == HD.RESET:
+                str_res = "reset back to normal"
+            else:
+                str_res = str(flow)
+            print(
+                "Blood flow set point overridden to " + str_res + " mL/min: " +
+                str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
+
+    def CmdBloodFlowMeasuredOverride(self, reset, flow):
+        """
+            Constructs and sends the measured blood flow override command
+
+            \param reset:  integer - 1 to reset a previous override, 0 to override
+            \param flow:  integer - measured flow (in mL/min) to override with
+            \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        flo = float2ByteArray(flow)
+        payload = rst + flo
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_BLOOD_FLOW_MEAS_RATE_OVERRIDE,
+                                              payload=payload)
+
+        print("override measured blood flow")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            # print(received_message)
+            if reset == HD.RESET:
+                str_res = "reset back to normal"
+            else:
+                str_res = str(flow)
+            print("Blood flow (measured)) overridden to " + str_res + " mL/min: " +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
+
+    def CmdBloodPumpMCMeasuredSpeedOverride(self, reset, speed):
+        """
+            Constructs and sends the measured blood pump motor controller speed \n
+            override command.
+
+            \param reset:  integer - 1 to reset a previous override, 0 to override
+            \param speed:  integer - speed (in RPM) to override with
+            \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        spd = float2ByteArray(speed)
+        payload = rst + spd
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_BLOOD_PUMP_MC_MEAS_SPEED_OVERRIDE,
+                                              payload=payload)
+
+        print("override measured blood pump motor controller speed")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            # print(received_message)
+            if reset == HD.RESET:
+                str_res = "reset back to normal"
+            else:
+                str_res = str(speed)
+            print("Blood pump MC speed (measured) overridden to " + str_res + " RPM: " +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
+
+    def CmdBloodPumpMeasuredCurrentOverride(self, reset, curr):
+        """
+            Constructs and sends the measured blood pump motor current override command
+
+            \param reset:  integer - 1 to reset a previous override, 0 to override
+            \param curr:  float - current (in mA) to override with
+            \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        cur = float2ByteArray(curr)
+        payload = rst + cur
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_BLOOD_PUMP_MC_MEAS_CURRENT_OVERRIDE,
+                                              payload=payload)
+
+        print("override measured blood pump motor controller current")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            # print(received_message)
+            if reset == HD.RESET:
+                str_res = "reset back to normal"
+            else:
+                str_res = str(curr)
+            print("Blood pump MC current (measured) overridden to " + str_res + " mA: " +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
+
+    def CmdBloodPumpMeasuredSpeedOverride(self, reset, speed):
+        """
+            Constructs and sends the measured blood pump motor  speed override \n
+            command.
+
+            \param reset:  integer - 1 to reset a previous override, 0 to override
+            \param speed:  integer - speed (in RPM) to override with
+            \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        spd = float2ByteArray(speed)
+        payload = rst + spd
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_BLOOD_PUMP_MEAS_SPEED_OVERRIDE,
+                                              payload=payload)
+
+        print("override measured blood pump speed")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            # print(received_message)
+            if reset == HD.RESET:
+                str_res = "reset back to normal"
+            else:
+                str_res = str(speed)
+            print("Blood pump speed (measured) overridden to " + str_res + " RPM: " +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
+
+    def CmdBloodPumpRotorMeasuredSpeedOverride(self, reset, speed):
+        """
+            Constructs and sends the measured blood pump rotor speed override \n
+            command.
+
+            \param reset:  integer - 1 to reset a previous override, 0 to override
+            \param speed:  integer - speed (in RPM) to override with
+            \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        spd = float2ByteArray(speed)
+        payload = rst + spd
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_BLOOD_PUMP_ROTOR_MEAS_SPEED_OVERRIDE,
+                                              payload=payload)
+
+        print("override measured blood pump rotor speed")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            # print(received_message)
+            if reset == HD.RESET:
+                str_res = "reset back to normal"
+            else:
+                str_res = str(speed)
+            print("Blood pump rotor speed (measured) overridden to " + str_res + " RPM: " +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
+
+    def CmdBloodFlowBroadcastIntervalOverride(self, reset, ms):
+        """
+            Constructs and sends the measured blood flow broadcast interval override command
+
+            \param reset:  integer - 1 to reset a previous override, 0 to override
+            \param ms:  integer - interval (in ms) to override with
+            \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        mis = integer2ByteArray(ms)
+        payload = rst + mis
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_BLOOD_FLOW_PUBLISH_INTERVAL_OVERRIDE,
+                                              payload=payload)
+
+        print("override blood flow broadcast interval")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            # print(received_message)
+            if reset == HD.RESET:
+                str_res = "reset back to normal: "
+            else:
+                str_res = str(ms) + " ms: "
+            print("Blood flow broadcast interval overridden to " + str_res +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
Index: HD/Buttons.py
===================================================================
diff -u
--- HD/Buttons.py	(revision 0)
+++ HD/Buttons.py	(revision 082ea4c8b0c6a3c804453308990d0bb98a0a2156)
@@ -0,0 +1,99 @@
+from DialIn.CoreCANProtocol import (DenaliMessage,
+                                    DenaliChannels)
+
+from .utils import integer2ByteArray
+from .HemodialysisDevice import HD
+
+
+class HDButtons:
+    """
+    \class HD_Buttons
+
+    \brief Hemodialysis Device (HD) Dialin API sub-class for button related commands.
+    """
+
+    # Buttons message IDs
+    MSG_ID_HD_OFF_BUTTON_OVERRIDE = 0x8002
+    MSG_ID_HD_STOP_BUTTON_OVERRIDE = 0x8003
+
+    def __init__(self, can_interface):
+        """
+        HD_Buttons constructor
+
+        \param can_interface: the denali can interface object
+        """
+        self.can_interface = can_interface
+
+    def cmd_off_button_override(self, reset, state):
+        """
+        Constructs and sends the Off button override command
+
+        \param reset:  integer - 1 to reset a previous override, 0 to override
+        \param state:  integer - 1 to override off button to "pressed", 0 to "released"
+        \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        sta = integer2ByteArray(state)
+        payload = rst + sta
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_OFF_BUTTON_OVERRIDE,
+                                              payload=payload)
+
+        print("override off button")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            if reset == HD.RESET:
+                str_res = "reset back to normal"
+            else:
+                str_res = ("pressed" if state != 0 else "released")
+
+            print("Off button overridden to " + str_res + ":" +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
+
+    def cmd_stop_button_override(self, reset, state):
+        """
+        Constructs and sends the Stop button override command
+
+        \param reset:  integer - 1 to reset a previous override, 0 to override
+        \param state:  integer - 1 to override stop button to "pressed", 0 to "released"
+        \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        sta = integer2ByteArray(state)
+        payload = rst + sta
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_STOP_BUTTON_OVERRIDE,
+                                              payload=payload)
+
+        print("override stop button")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            if reset == HD.RESET:
+                str_res = "reset back to normal"
+            else:
+                str_res = ("pressed" if state != 0 else "released")
+            print("Stop button overridden to " + str_res + ":" +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+
+            # response payload is OK or not OK
+            return received_message["message"][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
Index: HD/DialysateInletFlow.py
===================================================================
diff -u
--- HD/DialysateInletFlow.py	(revision 0)
+++ HD/DialysateInletFlow.py	(revision 082ea4c8b0c6a3c804453308990d0bb98a0a2156)
@@ -0,0 +1,355 @@
+from DialIn.CoreCANProtocol import (DenaliMessage,
+                                    DenaliChannels)
+from .utils import integer2ByteArray, float2ByteArray
+from .HemodialysisDevice import HD
+import struct
+
+
+class HDDialysateInletFlow:
+    """
+        \class HD_DialysateInletFlow
+
+        \brief Hemodialysis Device (HD) Dialin API sub-class for dialysate inlet pump related commands.
+
+    """
+
+    # DialysateFlow message IDs
+    MSG_ID_HD_DIAL_IN_FLOW_PUBLISHED_DATA = 0x0008
+    MSG_ID_HD_DIAL_IN_FLOW_SET_RATE_OVERRIDE = 0x8010
+    MSG_ID_HD_DIAL_IN_FLOW_MEAS_RATE_OVERRIDE = 0x8011
+    MSG_ID_HD_DIAL_IN_PUMP_MC_MEAS_SPEED_OVERRIDE = 0x8012
+    MSG_ID_HD_DIAL_IN_PUMP_MC_MEAS_CURRENT_OVERRIDE = 0x8013
+    MSG_ID_HD_DIAL_IN_FLOW_PUBLISH_INTERVAL_OVERRIDE = 0x8014
+    MSG_ID_HD_DIAL_IN_PUMP_MEAS_SPEED_OVERRIDE = 0x8015
+    MSG_ID_HD_DIAL_IN_PUMP_ROTOR_MEAS_SPEED_OVERRIDE = 0x8016
+
+    # BloodFlow broadcast message field positions
+    START_POS_SET_PT = DenaliMessage.PAYLOAD_START_INDEX
+    END_POS_SET_PT = START_POS_SET_PT + 4
+    START_POS_MEAS_FLOW = END_POS_SET_PT
+    END_POS_MEAS_FLOW = START_POS_MEAS_FLOW + 4
+    START_POS_MEAS_ROT_SPEED = END_POS_MEAS_FLOW
+    END_POS_MEAS_ROT_SPEED = START_POS_MEAS_ROT_SPEED + 4
+    START_POS_MEAS_SPEED = END_POS_MEAS_ROT_SPEED
+    END_POS_MEAS_SPEED = START_POS_MEAS_SPEED + 4
+    START_POS_MEAS_MC_SPEED = END_POS_MEAS_SPEED
+    END_POS_MEAS_MC_SPEED = START_POS_MEAS_MC_SPEED + 4
+    START_POS_MEAS_MC_CURR = END_POS_MEAS_MC_SPEED
+    END_POS_MEAS_MC_CURR = START_POS_MEAS_MC_CURR + 4
+    START_POS_PWM_DC = END_POS_MEAS_MC_CURR
+    END_POS_PWM_DC = START_POS_PWM_DC + 4
+
+    def __init__(self, can_interface=None):
+        """
+        HD_DialysateFlow constructor
+
+        """
+        self.can_interface = can_interface
+
+        if self.can_interface is not None:
+            channel_id = DenaliChannels.hd_sync_broadcast_ch_id
+            msg_id = self.MSG_ID_HD_DIAL_IN_FLOW_PUBLISHED_DATA
+            self.can_interface.register_receiving_publication_function(channel_id, msg_id,
+                                                                       self.handlerDialysateInletFlowSyncFunction)
+
+        self.TargetDialysateInletFlowRate = 0
+        self.MeasuredDialysateInletFlowRate = 0.0
+        self.MeasuredDialysateInletPumpRotorSpeed = 0.0
+        self.MeasuredDialysateInletPumpSpeed = 0.0
+        self.MeasuredDialysateInletPumpMCSpeed = 0.0
+        self.MeasuredDialysateInletPumpMCCurrent = 0.0
+        self.PWMDutyCyclePct = 0.0
+
+    def handlerDialysateInletFlowSyncFunction(self, message):
+        """
+            Handles published dialysate inlet flow data messages.  Dialysate flow data are captured
+            for reference.
+
+            \param message:  published dialysate flow data message
+            \returns none
+        """
+
+        self.TargetDialysateInletFlowRate = int.from_bytes(bytearray(
+            message['message'][self.START_POS_SET_PT:self.END_POS_SET_PT]),
+            byteorder=DenaliMessage.BYTE_ORDER)
+        flow = struct.unpack('f', bytearray(
+            message['message'][self.START_POS_MEAS_FLOW:self.END_POS_MEAS_FLOW]))
+        rotor = struct.unpack('f', bytearray(
+            message['message'][self.START_POS_MEAS_ROT_SPEED:self.END_POS_MEAS_ROT_SPEED]))
+        speed = struct.unpack('f', bytearray(
+            message['message'][self.START_POS_MEAS_SPEED:self.END_POS_MEAS_SPEED]))
+        mcspeed = struct.unpack('f', bytearray(
+            message['message'][self.START_POS_MEAS_MC_SPEED:self.END_POS_MEAS_MC_SPEED]))
+        mccurr = struct.unpack('f', bytearray(
+            message['message'][self.START_POS_MEAS_MC_CURR:self.END_POS_MEAS_MC_CURR]))
+        pwm = struct.unpack('f', bytearray(
+            message['message'][self.START_POS_PWM_DC:self.END_POS_PWM_DC]))
+
+        self.MeasuredDialysateInletFlowRate = flow[0]
+        self.MeasuredDialysateInletPumpRotorSpeed = rotor[0]
+        self.MeasuredDialysateInletPumpSpeed = speed[0]
+        self.MeasuredDialysateInletPumpMCSpeed = mcspeed[0]
+        self.MeasuredDialysateInletPumpMCCurrent = mccurr[0]
+        self.PWMDutyCyclePct = pwm[0]
+
+    def CmdDialysateInletFlowSetPointOverride(self, reset, flow):
+        """
+            Constructs and sends the dialysate flow set point override command
+
+            \param reset:  integer - 1 to reset a previous override, 0 to override
+            \param flow:  integer - flow set point (in mL/min) to override with
+            \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        flo = integer2ByteArray(flow)
+        payload = rst + flo
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_DIAL_IN_FLOW_SET_RATE_OVERRIDE,
+                                              payload=payload)
+
+        print("override dialysate flow set point")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            # print(received_message)
+            if reset == HD.RESET:
+                str_res = "reset back to normal"
+            else:
+                str_res = str(flow)
+            print(
+                "Dialysate flow set point overridden to " + str_res + " mL/min: " +
+                str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
+
+    def CmdDialysateInletFlowMeasuredOverride(self, reset, flow):
+        """
+            Constructs and sends the measured dialysate flow override command
+
+            \param reset:  integer - 1 to reset a previous override, 0 to override
+            \param flow:  integer - measured flow (in mL/min) to override with
+            \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        flo = float2ByteArray(flow)
+        payload = rst + flo
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_DIAL_IN_FLOW_MEAS_RATE_OVERRIDE,
+                                              payload=payload)
+
+        print("override measured dialysate flow")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            # print(received_message)
+            if reset == HD.RESET:
+                str_res = "reset back to normal"
+            else:
+                str_res = str(flow)
+            print("Dialysate flow (measured)) overridden to " + str_res + " mL/min: " +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
+
+    def CmdDialysateInletPumpMCMeasuredSpeedOverride(self, reset, speed):
+        """
+            Constructs and sends the measured dialysate inlet pump motor controller speed \n
+            override command.
+
+            \param reset:  integer - 1 to reset a previous override, 0 to override
+            \param speed:  integer - speed (in RPM) to override with
+            \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        spd = float2ByteArray(speed)
+        payload = rst + spd
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_DIAL_IN_PUMP_MC_MEAS_SPEED_OVERRIDE,
+                                              payload=payload)
+
+        print("override measured dialysate inlet pump motor controller speed")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            # print(received_message)
+            if reset == HD.RESET:
+                str_res = "reset back to normal"
+            else:
+                str_res = str(speed)
+            print("Dialysate pump MC speed (measured) overridden to " + str_res + " RPM: " +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
+
+    def CmdDialysateInletPumpMeasuredCurrentOverride(self, reset, curr):
+        """
+            Constructs and sends the measured dialysate inlet pump motor current override command
+
+            \param reset:  integer - 1 to reset a previous override, 0 to override
+            \param curr:  integer - current (in mA) to override with
+            \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        cur = float2ByteArray(curr)
+        payload = rst + cur
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_DIAL_IN_PUMP_MC_MEAS_CURRENT_OVERRIDE,
+                                              payload=payload)
+
+        print("override measured dialysate inlet pump motor controller current")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            # print(received_message)
+            if reset == HD.RESET:
+                str_res = "reset back to normal"
+            else:
+                str_res = str(curr)
+            print("Dialysate inlet pump MC current (measured) overridden to " + str_res + " mA: " +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
+
+    def CmdDialysateInletPumpMeasuredSpeedOverride(self, reset, speed):
+        """
+            Constructs and sends the measured dialysate inlet pump motor speed override \n
+            command.
+
+            \param reset:  integer - 1 to reset a previous override, 0 to override
+            \param speed:  integer - speed (in RPM) to override with
+            \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        spd = float2ByteArray(speed)
+        payload = rst + spd
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_DIAL_IN_PUMP_MEAS_SPEED_OVERRIDE,
+                                              payload=payload)
+
+        print("override measured dialysate inlet pump speed")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            # print(received_message)
+            if reset == HD.RESET:
+                str_res = "reset back to normal"
+            else:
+                str_res = str(speed)
+            print("Dialysate inlet pump speed (measured) overridden to " + str_res + " RPM: " +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
+
+    def CmdDialysateInletPumpRotorMeasuredSpeedOverride(self, reset, speed):
+        """
+            Constructs and sends the measured dialysate inlet pump rotor speed override \n
+            command.
+
+            \param reset:  integer - 1 to reset a previous override, 0 to override
+            \param speed:  integer - speed (in RPM) to override with
+            \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        spd = float2ByteArray(speed)
+        payload = rst + spd
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_DIAL_IN_PUMP_ROTOR_MEAS_SPEED_OVERRIDE,
+                                              payload=payload)
+
+        print("override measured dialysate inlet pump rotor speed")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            # print(received_message)
+            if reset == HD.RESET:
+                str_res = "reset back to normal"
+            else:
+                str_res = str(speed)
+            print("Dialysate inlet pump rotor speed (measured) overridden to " + str_res + " RPM: " +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
+
+    def CmdDialysateInletFlowBroadcastIntervalOverride(self, reset, ms):
+        """
+            Constructs and sends the measured dialysate inlet flow broadcast interval override command
+
+            \param reset:  integer - 1 to reset a previous override, 0 to override
+            \param ms:  integer - interval (in ms) to override with
+            \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        mis = integer2ByteArray(ms)
+        payload = rst + mis
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_DIAL_IN_FLOW_PUBLISH_INTERVAL_OVERRIDE,
+                                              payload=payload)
+
+        print("override dialysate inlet flow broadcast interval")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            if reset == HD.RESET:
+                str_res = "reset back to normal: "
+            else:
+                str_res = str(ms) + " ms: "
+            print("Dialysate inlet flow broadcast interval overridden to " + str_res +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
Index: HD/DialysateOutletFlow.py
===================================================================
diff -u
--- HD/DialysateOutletFlow.py	(revision 0)
+++ HD/DialysateOutletFlow.py	(revision 082ea4c8b0c6a3c804453308990d0bb98a0a2156)
@@ -0,0 +1,429 @@
+from DialIn.CoreCANProtocol import (DenaliMessage,
+                                    DenaliChannels)
+from .utils import integer2ByteArray, float2ByteArray
+from .HemodialysisDevice import HD
+import struct
+
+class HDDialysateOutletFlow:
+    """
+    \class HD_DialysateOutletFlow
+
+    \brief Hemodialysis Device (HD) Dialin API sub-class for dialysate outlet pump related commands.
+
+    """
+
+    # DialysateFlow message IDs
+    MSG_ID_HD_DIAL_OUT_FLOW_PUBLISHED_DATA = 0x000B
+    MSG_ID_HD_LOAD_CELL_READINGS = 0x000C
+    MSG_ID_HD_DIAL_OUT_FLOW_PUBLISH_INTERVAL_OVERRIDE = 0x801E
+    MSG_ID_HD_DIAL_OUT_UF_REF_VOLUME_OVERRIDE = 0x801F
+    MSG_ID_HD_DIAL_OUT_UF_MEAS_VOLUME_OVERRIDE = 0x8020
+    MSG_ID_HD_DIAL_OUT_PUMP_MC_MEAS_SPEED_OVERRIDE = 0x8021
+    MSG_ID_HD_DIAL_OUT_PUMP_MC_MEAS_CURRENT_OVERRIDE = 0x8022
+    MSG_ID_HD_DIAL_OUT_PUMP_MEAS_SPEED_OVERRIDE = 0x8023
+    MSG_ID_HD_DIAL_OUT_PUMP_ROTOR_MEAS_SPEED_OVERRIDE = 0x8024
+    MSG_ID_HD_DIAL_OUT_LOAD_CELL_WEIGHT_OVERRIDE = 0x8025
+
+    # BloodFlow broadcast message field positions
+    START_POS_REF_VOL = DenaliMessage.PAYLOAD_START_INDEX
+    END_POS_REF_VOL = START_POS_REF_VOL + 4
+    START_POS_MEAS_VOL = END_POS_REF_VOL
+    END_POS_MEAS_VOL = START_POS_MEAS_VOL + 4
+    START_POS_MEAS_ROT_SPEED = END_POS_MEAS_VOL
+    END_POS_MEAS_ROT_SPEED = START_POS_MEAS_ROT_SPEED + 4
+    START_POS_MEAS_SPEED = END_POS_MEAS_ROT_SPEED
+    END_POS_MEAS_SPEED = START_POS_MEAS_SPEED + 4
+    START_POS_MEAS_MC_SPEED = END_POS_MEAS_SPEED
+    END_POS_MEAS_MC_SPEED = START_POS_MEAS_MC_SPEED + 4
+    START_POS_MEAS_MC_CURR = END_POS_MEAS_MC_SPEED
+    END_POS_MEAS_MC_CURR = START_POS_MEAS_MC_CURR + 4
+    START_POS_PWM_DC = END_POS_MEAS_MC_CURR
+    END_POS_PWM_DC = START_POS_PWM_DC + 4
+
+    def __init__(self, can_interface=None):
+        """
+        HDDialysateFlow constructor
+        """
+        self.can_interface = can_interface
+
+        if self.can_interface is not None:
+            channel_id = DenaliChannels.hd_sync_broadcast_ch_id
+            msg_id = self.MSG_ID_HD_DIAL_OUT_FLOW_PUBLISHED_DATA
+            self.can_interface.register_receiving_publication_function(channel_id, msg_id,
+                                                                  self.handlerDialysateOutletFlowSyncFunction)
+
+        self.ReferenceDialysateOutletUFVolume = 0.0
+        self.MeasuredDialysateOutletUFVolume = 0.0
+        self.MeasuredDialysateOutletPumpRotorSpeed = 0.0
+        self.MeasuredDialysateOutletPumpSpeed = 0.0
+        self.MeasuredDialysateOutletPumpMCSpeed = 0.0
+        self.MeasuredDialysateOutletPumpMCCurrent = 0.0
+        self.PWMDutyCyclePct = 0.0
+
+    def handlerDialysateOutletFlowSyncFunction(self, message):
+        """
+            Handles published dialysate outlet flow data messages.  Dialysate flow data are captured
+            for reference.
+
+            \param message:  published dialysate outlet flow data message
+            \returns none
+        """
+
+        refVol = struct.unpack('f', bytearray(
+            message['message'][self.START_POS_REF_VOL:self.END_POS_REF_VOL]))
+        measVol = struct.unpack('f', bytearray(
+            message['message'][self.START_POS_MEAS_VOL:self.END_POS_MEAS_VOL]))
+        rotor = struct.unpack('f', bytearray(
+            message['message'][self.START_POS_MEAS_ROT_SPEED:self.END_POS_MEAS_ROT_SPEED]))
+        speed = struct.unpack('f', bytearray(
+            message['message'][self.START_POS_MEAS_SPEED:self.END_POS_MEAS_SPEED]))
+        mcspeed = struct.unpack('f', bytearray(
+            message['message'][self.START_POS_MEAS_MC_SPEED:self.END_POS_MEAS_MC_SPEED]))
+        mccurr = struct.unpack('f', bytearray(
+            message['message'][self.START_POS_MEAS_MC_CURR:self.END_POS_MEAS_MC_CURR]))
+        pwm = struct.unpack('f', bytearray(
+            message['message'][self.START_POS_PWM_DC:self.END_POS_PWM_DC]))
+
+        self.ReferenceDialysateOutletUFVolume = refVol[0]
+        self.MeasuredDialysateOutletUFVolume = measVol[0]
+        self.MeasuredDialysateOutletPumpRotorSpeed = rotor[0]
+        self.MeasuredDialysateOutletPumpSpeed = speed[0]
+        self.MeasuredDialysateOutletPumpMCSpeed = mcspeed[0]
+        self.MeasuredDialysateOutletPumpMCCurrent = mccurr[0]
+        self.PWMDutyCyclePct = pwm[0]
+
+    def CmdDialysateOutletReferenceUFVolumeOverride(self, reset, refVol):
+        """
+        Constructs and sends the UF reference volume override command
+
+        \param reset:  integer - 1 to reset a previous override, 0 to override
+        \param refVol:  float - reference UF volume (in mL) to override with
+        \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        vol = float2ByteArray(refVol)
+        payload = rst + vol
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_DIAL_OUT_UF_REF_VOLUME_OVERRIDE,
+                                              payload=payload)
+
+        print("override UF reference volume with " + str(refVol) + "mL.")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            # print(received_message)
+            if reset == HD.RESET:
+                str_res = "reset back to normal.  "
+            else:
+                str_res = "overridden to " + str(refVol) + " mL.  "
+            print(
+                "UF reference volume " + str_res +
+                str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
+
+    def CmdDialysateOutletMeasuredUFVolumeOverride(self, reset, measVol):
+        """
+        Constructs and sends the measured UF volume override command
+
+        \param reset:  integer - 1 to reset a previous override, 0 to override
+        \param measVol:  float - measured UF volume (in mL) to override with
+        \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        vol = float2ByteArray(measVol)
+        payload = rst + vol
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_DIAL_OUT_UF_MEAS_VOLUME_OVERRIDE,
+                                              payload=payload)
+
+        print("override measured UF volume with " + str(measVol) + " mL.")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            # print(received_message)
+            if reset == HD.RESET:
+                str_res = "reset back to normal.  "
+            else:
+                str_res = "overridden to " + str(measVol) + " mL.  "
+            print("UF measured volume " + str_res +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
+
+    def CmdDialysateOutletPumpMCMeasuredSpeedOverride(self, reset, speed):
+        """
+            Constructs and sends the measured dialysate outlet pump motor controller speed \n
+            override command.
+
+            \param reset:  integer - 1 to reset a previous override, 0 to override
+            \param speed:  float - speed (in RPM) to override with
+            \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        spd = float2ByteArray(speed)
+        payload = rst + spd
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MeasuredDialysateOutletPumpMCSpeed,
+                                              payload=payload)
+
+        print("override measured dialysate outlet pump motor controller speed to " + str(spd) + " RPM.")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            # print(received_message)
+            if reset == HD.RESET:
+                str_res = "reset back to normal.  "
+            else:
+                str_res = "overridden to " + str(speed) + " RPM.  "
+            print("Dialysate outlet pump MC speed (measured) " + str_res +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
+
+    def CmdDialysateOutletPumpMeasuredCurrentOverride(self, reset, curr):
+        """
+        Constructs and sends the measured dialysate outlet pump motor current override command
+
+        \param reset:  integer - 1 to reset a previous override, 0 to override
+        \param curr:  float - current (in mA) to override with
+        \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        cur = float2ByteArray(curr)
+        payload = rst + cur
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_DIAL_OUT_PUMP_MC_MEAS_CURRENT_OVERRIDE,
+                                              payload=payload)
+
+        print("override measured dialysate outlet pump motor controller current")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            # print(received_message)
+            if reset == HD.RESET:
+                str_res = "reset back to normal.  "
+            else:
+                str_res = "overridden to " + str(curr) + " mA.  "
+            print("Dialysate outlet pump MC current (measured) " + str_res +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
+
+    def CmdDialysateOutletPumpMeasuredSpeedOverride(self, reset, speed):
+        """
+        Constructs and sends the measured dialysate outlet pump motor speed override \n
+        command.
+
+        \param reset:  integer - 1 to reset a previous override, 0 to override
+        \param speed:  float - speed (in RPM) to override with
+        \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        spd = float2ByteArray(speed)
+        payload = rst + spd
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_DIAL_OUT_PUMP_MEAS_SPEED_OVERRIDE,
+                                              payload=payload)
+
+        print("override measured dialysate outlet pump speed to " + str(speed) + " RPM.")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            # print(received_message)
+            if reset == HD.RESET:
+                str_res = "reset back to normal.  "
+            else:
+                str_res = "overridden to " + str(speed) + " RPM.  "
+            print("Dialysate outlet pump speed (measured) " + str_res +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
+
+    def CmdDialysateOutletPumpRotorMeasuredSpeedOverride(self, reset, speed):
+        """
+        Constructs and sends the measured dialysate outlet pump rotor speed override \n
+        command.
+
+        \param reset:  integer - 1 to reset a previous override, 0 to override
+        \param speed:  float - speed (in RPM) to override with
+        \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        spd = float2ByteArray(speed)
+        payload = rst + spd
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_DIAL_OUT_PUMP_ROTOR_MEAS_SPEED_OVERRIDE,
+                                              payload=payload)
+
+        print("override measured dialysate outlet pump rotor speed to " + str(speed) + " RPM.")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            # print(received_message)
+            if reset == HD.RESET:
+                str_res = "reset back to normal.  "
+            else:
+                str_res = "overridden to " + str(speed) + " RPM.  "
+            print("Dialysate outlet pump rotor speed (measured) " + str_res +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
+
+    def CmdDialysateOutletFlowBroadcastIntervalOverride(self, reset, ms):
+        """
+        Constructs and sends the measured dialysate outlet flow broadcast interval override command
+
+        \param reset:  integer - 1 to reset a previous override, 0 to override
+        \param ms:  integer - interval (in ms) to override with
+        \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        mis = integer2ByteArray(ms)
+        payload = rst + mis
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_DIAL_OUT_FLOW_PUBLISH_INTERVAL_OVERRIDE,
+                                              payload=payload)
+
+        print("override dialysate outlet flow broadcast interval to " + str(ms) + " ms.")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            # print(received_message)
+            if reset == HD.RESET:
+                str_res = "reset back to normal. "
+            else:
+                str_res = "overridden to " + str(ms) + " ms.  "
+            print("Dialysate outlet flow broadcast interval " + str_res +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
+
+    def CmdDialysateOutletPumpLoadCellWeightOverride(self, reset, weight, sensor):
+        """
+        Constructs and sends the measured load cell weight override command.
+
+        \param reset:  integer - 1 to reset a previous override, 0 to override
+        \param weight:  float - weight (in g) to override with
+        \param sensor:  integer - ID of load cell to override
+        \returns 1 if successful, zero otherwise
+
+        \details Load Cells: \n
+            0 = reservoir 1 primary \n
+            1 = reservoir 1 backup \n
+            2 = reservoir 2 primary \n
+            3 = reservoir 2 backup \n
+        """
+
+        rst = integer2ByteArray(reset)
+        spd = float2ByteArray(weight)
+        sen = integer2ByteArray(sensor)
+        payload = rst + spd + sen
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_DIAL_OUT_LOAD_CELL_WEIGHT_OVERRIDE,
+                                              payload=payload)
+
+        print("override measured load cell weight to " + str(weight) + " grams for load cell # " + str(sensor))
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            # print(received_message)
+            if reset == HD.RESET:
+                str_res = "reset back to normal.  "
+            else:
+                str_res = "overridden to " + str(weight) + " grams.  "
+            print("Load cell # " + str(sensor) + " " + str_res +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
+
+    def CmdSetLoadCellWeights(self, r1p, r1b, r2p, r2b):
+        """
+        Constructs and sends the set load cell weights command.
+
+        \param r1p:  float - weight (in g) for reservoir 1 primary load cell
+        \param r1b:  float - weight (in g) for reservoir 1 backup load cell
+        \param r2p:  float - weight (in g) for reservoir 2 primary load cell
+        \param r2b:  float - weight (in g) for reservoir 2 backup load cell
+        \returns 0 - no response will come from HD for this message
+        """
+
+        r1pb = float2ByteArray(r1p)
+        r1bb = float2ByteArray(r1b)
+        r2pb = float2ByteArray(r2p)
+        r2bb = float2ByteArray(r2b)
+        payload = r1pb + r1bb + r2pb + r2bb
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_LOAD_CELL_READINGS,
+                                              payload=payload)
+
+        print("measured load cell weights set.")
+
+        # Send message
+        received_message = self.can_interface.send(message, 0)
+
+        return 0
Index: HD/HD_DialOutFlow.py
===================================================================
diff -u -r68137f3ef7ad8dac0e1209b50272ba613543e2d9 -r082ea4c8b0c6a3c804453308990d0bb98a0a2156
--- HD/HD_DialOutFlow.py	(.../HD_DialOutFlow.py)	(revision 68137f3ef7ad8dac0e1209b50272ba613543e2d9)
+++ HD/HD_DialOutFlow.py	(.../HD_DialOutFlow.py)	(revision 082ea4c8b0c6a3c804453308990d0bb98a0a2156)
@@ -4,6 +4,7 @@
 import matplotlib.pyplot as plt
 import sys
 import numpy as np
+# TODO: Commented code needs to be removed
 
 
 class DialOutStates(Enum):
Index: HD/HD_TestScript.py
===================================================================
diff -u -r1e42fa562ee87c4f7e4e0f7e6e6a65aa6ac5fa8e -r082ea4c8b0c6a3c804453308990d0bb98a0a2156
--- HD/HD_TestScript.py	(.../HD_TestScript.py)	(revision 1e42fa562ee87c4f7e4e0f7e6e6a65aa6ac5fa8e)
+++ HD/HD_TestScript.py	(.../HD_TestScript.py)	(revision 082ea4c8b0c6a3c804453308990d0bb98a0a2156)
@@ -16,14 +16,14 @@
 # TODO: Use .format or f" {varname}" instead of casting to string.
 # TODO: Break while loops on some condition, shouldn't rely on Ctrl-C.
 
-from HemodialysisDevice import HD
+from .HemodialysisDevice import HD
 from time import sleep
 
 if __name__ == "__main__":
     hd = HD()
     sleep(2)
 
-    if hd.Basics.CmdLogInToHD() == 0:
+    if hd.Basics.cmd_log_in_to_hd() == 0:
         exit(1)
 
     hd.BloodFlow.CmdBloodFlowBroadcastIntervalOverride(hd.RESET, 0)
Index: HD/HemodialysisDevice.py
===================================================================
diff -u -r68137f3ef7ad8dac0e1209b50272ba613543e2d9 -r082ea4c8b0c6a3c804453308990d0bb98a0a2156
--- HD/HemodialysisDevice.py	(.../HemodialysisDevice.py)	(revision 68137f3ef7ad8dac0e1209b50272ba613543e2d9)
+++ HD/HemodialysisDevice.py	(.../HemodialysisDevice.py)	(revision 082ea4c8b0c6a3c804453308990d0bb98a0a2156)
@@ -1,2643 +1,68 @@
 ###########################################################################
 #
-#  Copyright (c) 2019-2019 Diality Inc. - All Rights Reserved.
+#  Copyright (c) 2019-2020 Diality Inc. - All Rights Reserved.
 #
 #  THIS CODE MAY NOT BE COPIED OR REPRODUCED IN ANY FORM, IN PART OR IN
 #  WHOLE, WITHOUT THE EXPLICIT PERMISSION OF THE COPYRIGHT OWNER.
 #
 #  @file HemodialysisDevice.py
 #
-#  @date 16-Oct-2019
-#  @author S. Nash
+#  @date 31-Mar-2020
+#  @author P. Lucia
 #
 #  @brief This class provides the basic interface to communicate with
 #         the HD board.
 #
 ############################################################################
-
-from DialIn.CoreCANProtocol import DenaliCanMessenger
-from DialIn.CoreCANProtocol import DenaliMessage
-from DialIn.CoreCANProtocol import DenaliChannels
+from DialIn.CoreCANProtocol import (DenaliCanMessenger)
 from time import sleep
-from binascii import unhexlify
-#from HD_DialOutFlow import HD_DialOut
-#from HD_DialOutFlow import DialOutStates
-import struct
-import ctypes
+from .Alarms import HDAlarms
+from .Buttons import HDButtons
+from .UI import HDUI
+from .Watchdog import HDWatchdog
+from .RTC import HDRTC
+from .BloodFlow import HDBloodFlow
+from .DialysateInletFlow import HDDialysateInletFlow
+from .DialysateOutletFlow import HDDialysateOutletFlow
+from .Treatment import HDTreatment
+from .Basics import HDBasics
+from .PressureOcclusion import HDPressureOcclusion
 
 
 class HD:
     # for reset param in override commands
     NO_RESET = 0
     RESET = 1
 
-    def __init__(self, can__interface="can0"):
+    def __init__(self, can_interface_name="can0"):
         """
-            HD constructor using can bus
+        HD constructor using can bus
 
-            \param bus:  can bus, e.g. "can0"
+        \param bus:  can bus, e.g. "can0"
+        \returns HD object provides test/service commands for the HD sub-system.
+        \details For example:
 
-            \returns HD object provides test/service commands for the HD sub-system.
-
-            \details For example:
-
-                hd_object = HD(can_interface='can0') or
-                hd_object = HD('can0')
+            hd_object = HD(can_interface='can0') or
+            hd_object = HD('can0')
         """
         # Create listener
-        self.can_interface = DenaliCanMessenger(can_interface=can__interface)
+        self.can_interface = DenaliCanMessenger(can_interface=can_interface_name)
         self.can_interface.start()
+
         # Create command groups
-        self.Basics = HD.HD__Basics(self)
-        self.Alarms = HD.HD_Alarms(self, self.can_interface)
-        self.BloodFlow = HD.HD_BloodFlow(self, self.can_interface)
-        self.Buttons = HD.HD_Buttons(self)
-        self.DialysateInletFlow = HD.HD_DialysateInletFlow(self, self.can_interface)
-        self.DialysateOutletFlow = HD.HD_DialysateOutletFlow(self, self.can_interface)
-        self.Pressure_Occlusion = HD.HD_Pressure_Occlusion(self, self.can_interface)
-        self.RTC = HD.HD_RTC(self, self.can_interface)
-        self.Treatment = HD.HD_Treatment(self, self.can_interface)
-        self.UI = HD.HD_UI(self)
-        self.Watchdog = HD.HD_Watchdog(self)
-        ## DialOut is an HD_DialOutFlow object
-       # self.DialOut = HD_DialOut(self.can_interface)
+        self.Basics = HDBasics(self.can_interface)
+        self.Alarms = HDAlarms(self.can_interface)
+        self.Buttons = HDButtons(self.can_interface)
+        self.UI = HDUI(self.can_interface)
+        self.RTC = HDRTC(self.can_interface)
+        self.Watchdog = HDWatchdog(self.can_interface)
+        self.BloodFlow = HDBloodFlow(self.can_interface)
+        self.DialysateInletFlow = HDDialysateInletFlow(self.can_interface)
+        self.DialysateOutletFlow = HDDialysateOutletFlow(self.can_interface)
+        self.Treatment = HDTreatment(self.can_interface)
+        self.Pressure_Occlusion = HDPressureOcclusion(self.can_interface)
 
-    class HD__Basics:
-        """
-            \class HD__Basics
 
-            \brief Hemodialysis Device (HD) Dialin API sub-class for basic HD commands.
-        """
-
-        # Basic message IDs
-        MSG_ID_LOGIN_TO_HD = 0x8000
-        MSG_ID_HD_MSG = 0x8001
-
-        # HD login password
-        HD_LOGIN_PASSWORD = '123'
-
-        def __init__(self, outer_instance):
-            self.outer_instance = outer_instance
-
-        """
-            HD__Basics constructor 
-
-            \param outer_instance: reference to the HD (outer) class.
-
-            \returns HD__Basics object.
-        """
-
-        def CmdLogInToHD(self):
-            """
-           Constructs and sends a login command via CAN bus.  Login required before \n
-           other commands can be sent to the HD.
-
-           \returns 1 if logged in, 0 if log in failed
-            """
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_LOGIN_TO_HD,
-                                                  payload=list(map(int, map(ord, self.HD_LOGIN_PASSWORD))))
-
-            print("login")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            if received_message is not None:
-                #print(received_message)
-                if received_message['message'][DenaliMessage.PAYLOAD_START_INDEX] == 1:
-                    print("Logged In")
-                else:
-                    print("Log In Failed.")
-                #print("Logged In: " + str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-        def CmdHDMessageInsert(self, msg):
-            """
-                Constructs and sends the insert HD message command.  Given message will \n
-                be inserted into the HD's received message queue for processing.
-
-                \param msg:  byte array - properly formatted HD message to insert
-
-                \returns 1 if successful, zero otherwise
-            """
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_MSG,
-                                                  payload=msg)
-
-            print("insert HD message")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                #print(received_message)
-                print("Inserted message: " + str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-    class HD_Buttons:
-        """
-            \class HD_Buttons
-
-            \brief Hemodialysis Device (HD) Dialin API sub-class for button related commands.
-        """
-
-        # Buttons message IDs
-        MSG_ID_HD_OFF_BUTTON_OVERRIDE = 0x8002
-        MSG_ID_HD_STOP_BUTTON_OVERRIDE = 0x8003
-
-        def __init__(self, outer_instance):
-            self.outer_instance = outer_instance
-
-        """
-            HD_Buttons constructor 
-            
-            \param outer_instance: reference to the HD (outer) class.
-
-            \returns HD_Buttons object.
-        """
-
-        def CmdOffButtonOverride(self, reset, state):
-            """
-                Constructs and sends the Off button override command
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param state:  integer - 1 to override off button to "pressed", 0 to "released"
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            sta = self.outer_instance.integer2ByteArray(state)
-            payload = rst + sta
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_OFF_BUTTON_OVERRIDE,
-                                                  payload=payload)
-
-            print("override off button")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                #print(received_message)
-                if reset == HD.RESET:
-                    str_res = "reset back to normal"
-                else:
-                    str_res = ("pressed" if state != 0 else "released")
-
-                print("Off button overridden to " + str_res + ":" +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-        def CmdStopButtonOverride(self, reset, state):
-            """
-                Constructs and sends the Stop button override command
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param state:  integer - 1 to override stop button to "pressed", 0 to "released"
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            sta = self.outer_instance.integer2ByteArray(state)
-            payload = rst + sta
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_STOP_BUTTON_OVERRIDE,
-                                                  payload=payload)
-
-            print("override stop button")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                #print(received_message)
-                if reset == HD.RESET:
-                    str_res = "reset back to normal"
-                else:
-                    str_res = ("pressed" if state != 0 else "released")
-                print("Stop button overridden to " + str_res + ":" +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message["message"][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-    class HD_UI:
-        """
-            \class HD_UI
-
-            \brief Hemodialysis Device (HD) Dialin API sub-class for UI commands.
-        """
-
-        # UI message IDs
-        MSG_ID_UI_CHECKIN_WITH_HD = 0x0007
-        MSG_ID_HD_UF_PAUSE_RESUME_REQUEST = 0x0010
-        MSG_ID_HD_TREATMENT_PARAMS_RANGES = 0x001A
-        MSG_ID_UF_SETTINGS_CHANGE_REQUEST_BY_USER = 0x0011
-        MSG_ID_UF_SETTINGS_CHANGE_RESPONSE_FROM_HD = 0x0013
-        MSG_ID_UF_SETTINGS_CHANGE_CONFIRMED_BY_USER = 0x0015
-        MSG_ID_TREATMENT_DURATION_SETTING_CHANGE_REQUEST = 0x0016
-        MSG_ID_TREATMENT_DURATION_SETTING_CHANGE_RESPONSE_FROM_HD = 0x001B
-        MSG_ID_BLOOD_DIALYSATE_FLOW_SETTING_CHANGE_REQUEST_BY_USER = 0x0017
-        MSG_ID_BLOOD_DIALYSATE_FLOW_SETTING_CHANGE_RESPONSE_FROM_HD = 0x0018
-
-        LITER_TO_ML_CONVERSION_FACTOR = 1000.0
-        UF_CMD_PAUSE = 0
-        UF_CMD_RESUME = 1
-        UF_CMD_CHANGE_TIME_TO_ADJUST = 0
-        UF_CMD_CHANGE_RATE_TO_ADJUST = 1
-        RESPONSE_REJECTED = 0
-        RESPONSE_ACCEPTED = 1
-
-        # HD update on valid treatment parameter ranges message field positions
-        START_POS_MIN_TREAT_TIME = DenaliMessage.PAYLOAD_START_INDEX
-        END_POS_MIN_TREAT_TIME = START_POS_MIN_TREAT_TIME + 4
-        START_POS_MAX_TREAT_TIME = END_POS_MIN_TREAT_TIME
-        END_POS_MAX_TREAT_TIME = START_POS_MAX_TREAT_TIME + 4
-        START_POS_MIN_UF_VOL = END_POS_MAX_TREAT_TIME
-        END_POS_MIN_UF_VOL = START_POS_MIN_UF_VOL + 4
-        START_POS_MAX_UF_VOL = END_POS_MIN_UF_VOL
-        END_POS_MAX_UF_VOL = START_POS_MAX_UF_VOL + 4
-        START_POS_MIN_DIAL_RATE = END_POS_MAX_UF_VOL
-        END_POS_MIN_DIAL_RATE = START_POS_MIN_DIAL_RATE + 4
-        START_POS_MAX_DIAL_RATE = END_POS_MIN_DIAL_RATE
-        END_POS_MAX_DIAL_RATE = START_POS_MAX_DIAL_RATE + 4
-
-        # HD response to treatment duration change request message field positions
-        START_POS_TIME_CHG_RSP_ACCEPTED = DenaliMessage.PAYLOAD_START_INDEX
-        END_POS_TIME_CHG_RSP_ACCEPTED = START_POS_TIME_CHG_RSP_ACCEPTED + 4
-        START_POS_TIME_CHG_RSP_REASON = END_POS_TIME_CHG_RSP_ACCEPTED
-        END_POS_TIME_CHG_RSP_REASON = START_POS_TIME_CHG_RSP_REASON + 4
-        START_POS_TIME_CHG_RSP_TIME = END_POS_TIME_CHG_RSP_REASON
-        END_POS_TIME_CHG_RSP_TIME = START_POS_TIME_CHG_RSP_TIME + 4
-        START_POS_TIME_CHG_RSP_UF_VOL = END_POS_TIME_CHG_RSP_TIME
-        END_POS_TIME_CHG_RSP_UF_VOL = START_POS_TIME_CHG_RSP_UF_VOL + 4
-
-        # HD response to UF volume change request message field positions
-        START_POS_UF_CHG_RSP_RESP = DenaliMessage.PAYLOAD_START_INDEX
-        END_POS_UF_CHG_RSP_RESP = START_POS_UF_CHG_RSP_RESP + 4
-        START_POS_UF_CHG_RSP_REJECT_REASON = END_POS_UF_CHG_RSP_RESP
-        END_POS_UF_CHG_RSP_REJECT_REASON = START_POS_UF_CHG_RSP_REJECT_REASON + 4
-        START_POS_UF_CHG_RSP_VOL = END_POS_UF_CHG_RSP_RESP
-        END_POS_UF_CHG_RSP_VOL = START_POS_UF_CHG_RSP_VOL + 4
-        START_POS_UF_CHG_RSP_TIME = END_POS_UF_CHG_RSP_VOL
-        END_POS_UF_CHG_RSP_TIME = START_POS_UF_CHG_RSP_TIME + 4
-        START_POS_UF_CHG_RSP_TIME_DIFF = END_POS_UF_CHG_RSP_TIME
-        END_POS_UF_CHG_RSP_TIME_DIFF = START_POS_UF_CHG_RSP_TIME_DIFF + 4
-        START_POS_UF_CHG_RSP_RATE = END_POS_UF_CHG_RSP_TIME_DIFF
-        END_POS_UF_CHG_RSP_RATE = START_POS_UF_CHG_RSP_RATE + 4
-        START_POS_UF_CHG_RSP_RATE_DIFF = END_POS_UF_CHG_RSP_RATE
-        END_POS_UF_CHG_RSP_RATE_DIFF = START_POS_UF_CHG_RSP_RATE_DIFF + 4
-
-        # HD response to blood/dialysate flow change request message field positions
-        START_POS_BLD_DIAL_CHG_RSP_ACCEPTED = DenaliMessage.PAYLOAD_START_INDEX
-        END_POS_BLD_DIAL_CHG_RSP_ACCEPTED = START_POS_BLD_DIAL_CHG_RSP_ACCEPTED + 4
-        START_POS_BLD_DIAL_CHG_RSP_REASON = END_POS_BLD_DIAL_CHG_RSP_ACCEPTED
-        END_POS_BLD_DIAL_CHG_RSP_REASON = START_POS_BLD_DIAL_CHG_RSP_REASON + 4
-        START_POS_BLD_DIAL_CHG_RSP_BLD_RATE = END_POS_BLD_DIAL_CHG_RSP_REASON
-        END_POS_BLD_DIAL_CHG_RSP_BLD_RATE = START_POS_BLD_DIAL_CHG_RSP_BLD_RATE + 4
-        START_POS_BLD_DIAL_CHG_RSP_DIAL_RATE = END_POS_BLD_DIAL_CHG_RSP_BLD_RATE
-        END_POS_BLD_DIAL_CHG_RSP_DIAL_RATE = START_POS_BLD_DIAL_CHG_RSP_DIAL_RATE + 4
-
-        def __init__(self, outer_instance, can_interface=None):
-            self.outer_instance = outer_instance
-            """
-                HD_UI constructor 
-    
-                \param outer_instance: reference to the HD (outer) class.
-                \can_interface: interface to can device.
-    
-                \returns HD_UI object.
-            """
-
-            # register function to handle HD response to UF change requests
-            if can_interface is not None:
-                channel_id = DenaliChannels.hd_to_ui_ch_id
-                can_interface.register_receiving_publication_function(channel_id, self.MSG_ID_UF_SETTINGS_CHANGE_RESPONSE_FROM_HD,
-                                                                      self.handlerUFChangeResponseFunction)
-                can_interface.register_receiving_publication_function(channel_id, self.MSG_ID_TREATMENT_DURATION_SETTING_CHANGE_RESPONSE_FROM_HD,
-                                                                      self.handlerTreatmentDurationChangeResponseFunction)
-                can_interface.register_receiving_publication_function(channel_id, self.MSG_ID_BLOOD_DIALYSATE_FLOW_SETTING_CHANGE_RESPONSE_FROM_HD,
-                                                                      self.handlerBloodAndDialysateChangeResponseFunction)
-                can_interface.register_receiving_publication_function(channel_id, self.MSG_ID_HD_TREATMENT_PARAMS_RANGES,
-                                                                      self.handlerTreatmentParamRangesFunction)
-
-            # initialize variables that will be populated by treatment parameter ranges message
-            self.MinTreatmentDurationMin = 0
-            self.MaxTreatmentDurationMin = 0
-            self.MinUFVolumeMl = 0
-            self.MaxUFVolumeMl = 0
-            self.MinDialysateFlowRateMlMin = 0
-            self.MaxDialysateFlowRateMlMin = 0
-            # initialize variables that will be populated by response from HD to treatment duration change request
-            self.DurationChangeSucceeded = False
-            self.DurationChangeRejectReason = 0
-            self.DurationChangeTimeMin = 0
-            self.DurationChangeUFVolMl = 0
-            # initialize variables that will be populated by response from HD to UF change request
-            self.UFChangeSucceeded = False
-            self.UFChangeRejectReason = 0
-            self.UFChangeVolumeMl = 0
-            self.UFChangeTimeMin = 0
-            self.UFChangeRateMlMin = 0.0
-            self.UFChangeTimeDiff = 0
-            self.UFChangeRateDiff = 0.0
-            # initialize variables that will be populated by response from HD to blood & dialysate flow rate change request
-            self.BloodAndDialysateFlowRateChangeSucceeded = False
-            self.BloodAndDialysateFlowRateChangeRejectReason = 0
-            self.TargetBloodFlowRate = 0
-            self.TargetDialysateFlowRate = 0
-
-        def handlerTreatmentParamRangesFunction(self, message):
-            """
-                Handler for response from HD regarding valid treatment parameter ranges.
-
-                \param message:  response message from HD regarding valid treatment parameter ranges.\n
-                    U32  Minimum treatment duration setting (in min.). \n
-                    U32  Maximum treatment duration setting (in min.). \n
-                    U32  Minimum ultrafiltration volume (in mL). \n
-                    U32  Maximum ultrafiltration volume (in mL). \n
-                    U32  Minimum dialysate flow rate (in mL/min). \n
-                    U32  Maximum dialysate flow rate (in mL/min).
-
-                \returns none
-            """
-            minTime = struct.unpack('i',bytearray(
-                message['message'][self.START_POS_MIN_TREAT_TIME:self.END_POS_MIN_TREAT_TIME]))
-            maxTime = struct.unpack('i',bytearray(
-                message['message'][self.START_POS_MAX_TREAT_TIME:self.END_POS_MAX_TREAT_TIME]))
-            minUFVol = struct.unpack('i',bytearray(
-                message['message'][self.START_POS_MIN_UF_VOL:self.END_POS_MIN_UF_VOL]))
-            maxUFVol = struct.unpack('i',bytearray(
-                message['message'][self.START_POS_MAX_UF_VOL:self.END_POS_MAX_UF_VOL]))
-            minDialRt = struct.unpack('i',bytearray(
-                message['message'][self.START_POS_MIN_DIAL_RATE:self.END_POS_MIN_DIAL_RATE]))
-            maxDialRt = struct.unpack('i',bytearray(
-                message['message'][self.START_POS_MAX_DIAL_RATE:self.END_POS_MAX_DIAL_RATE]))
-
-            self.MinTreatmentDurationMin = minTime[0]
-            self.MaxTreatmentDurationMin = maxTime[0]
-            self.MinUFVolumeMl = minUFVol[0]
-            self.MaxUFVolumeMl = maxUFVol[0]
-            self.MinDialysateFlowRateMlMin = minDialRt[0]
-            self.MaxDialysateFlowRateMlMin = maxDialRt[0]
-
-        def handlerTreatmentDurationChangeResponseFunction(self, message):
-            """
-                Handler for response from HD regarding treatment duration change request.
-
-                \param message:  response message from HD regarding treatment duration change.\n
-                    BOOL Accepted \n
-                    U32  Reject reason (if not accepted) \n
-                    U32  Treatment duration (min) \n
-                    U32  UF volue (mL) \n
-
-                \returns none
-            """
-            rsp = struct.unpack('i',bytearray(
-                message['message'][self.START_POS_TIME_CHG_RSP_ACCEPTED:self.END_POS_TIME_CHG_RSP_ACCEPTED]))
-            rea = struct.unpack('i',bytearray(
-                message['message'][self.START_POS_TIME_CHG_RSP_REASON:self.END_POS_TIME_CHG_RSP_REASON]))
-            tim = struct.unpack('i',bytearray(
-                message['message'][self.START_POS_TIME_CHG_RSP_TIME:self.END_POS_TIME_CHG_RSP_TIME]))
-            vol = struct.unpack('i',bytearray(
-                message['message'][self.START_POS_TIME_CHG_RSP_UF_VOL:self.END_POS_TIME_CHG_RSP_UF_VOL]))
-
-            self.DurationChangeSucceeded = rsp[0]
-            self.DurationChangeRejectReason = rea[0]
-            self.DurationChangeTimeMin = tim[0]
-            self.DurationChangeUFVolMl = vol[0]
-
-        def handlerBloodAndDialysateChangeResponseFunction(self, message):
-            """
-                Handler for response from HD regarding blood & dialysate flow rate change request.
-
-                \param message:  response message from HD regarding requested blood & dialysate flow rate settings change.\n
-                    BOOL Accepted \n
-                    U32  Reject reason (if not accepted) \n
-                    U32  Blood flow rate (mL/min) \n
-                    U32  Dialysate flow rate (mL/min) \n
-
-                \returns none
-            """
-            rsp = struct.unpack('i',bytearray(
-                message['message'][self.START_POS_BLD_DIAL_CHG_RSP_ACCEPTED:self.END_POS_BLD_DIAL_CHG_RSP_ACCEPTED]))
-            rea = struct.unpack('i',bytearray(
-                message['message'][self.START_POS_BLD_DIAL_CHG_RSP_REASON:self.END_POS_BLD_DIAL_CHG_RSP_REASON]))
-            bld = struct.unpack('i',bytearray(
-                message['message'][self.START_POS_BLD_DIAL_CHG_RSP_BLD_RATE:self.END_POS_BLD_DIAL_CHG_RSP_BLD_RATE]))
-            dil = struct.unpack('i',bytearray(
-                message['message'][self.START_POS_BLD_DIAL_CHG_RSP_DIAL_RATE:self.END_POS_BLD_DIAL_CHG_RSP_DIAL_RATE]))
-
-            if rsp[0] == self.RESPONSE_REJECTED:
-                resp = False
-            else:
-                resp = True
-            self.BloodAndDialysateFlowRateChangeSucceeded = resp
-            self.BloodAndDialysateFlowRateChangeRejectReason = rea[0]
-            self.TargetBloodFlowRate = bld[0]
-            self.TargetDialysateFlowRate = dil[0]
-
-        def handlerUFChangeResponseFunction(self, message):
-            """
-                Handler for response from HD regarding UF change request.
-
-                \param message:  response message from HD regarding requested ultrafiltration settings change.\n
-                    BOOL Accepted \n
-                    U32  RejectReason (if not accepted)
-                    F32  UF Volume (mL) - converted to Liters \n
-                    U32  Treatment Time (min) \n
-                    S32  Treatment Time Change (min) \n
-                    F32  UF Rate (mL/min) \n
-                    F32  UF Rate Change (mL/min)
-
-                \returns none
-            """
-            rsp = struct.unpack('i',bytearray(
-                message['message'][self.START_POS_UF_CHG_RSP_RESP:self.END_POS_UF_CHG_RSP_RESP]))
-            rea = struct.unpack('i',bytearray(
-                message['message'][self.START_POS_UF_CHG_RSP_REJECT_REASON:self.END_POS_UF_CHG_RSP_REJECT_REASON]))
-            vol = struct.unpack('f',bytearray(
-                message['message'][self.START_POS_UF_CHG_RSP_VOL:self.END_POS_UF_CHG_RSP_VOL]))
-            tim = struct.unpack('i',bytearray(
-                message['message'][self.START_POS_UF_CHG_RSP_TIME:self.END_POS_UF_CHG_RSP_TIME]))
-            tmd = struct.unpack('i',bytearray(
-                message['message'][self.START_POS_UF_CHG_RSP_TIME_DIFF:self.END_POS_UF_CHG_RSP_TIME_DIFF]))
-            rat = struct.unpack('f', bytearray(
-                message['message'][self.START_POS_UF_CHG_RSP_RATE:self.END_POS_UF_CHG_RSP_RATE]))
-            rtd = struct.unpack('f', bytearray(
-                message['message'][self.START_POS_UF_CHG_RSP_RATE_DIFF:self.END_POS_UF_CHG_RSP_RATE_DIFF]))
-
-            if rsp[0] == self.RESPONSE_REJECTED:
-                resp = False
-            else:
-                resp = True
-            self.UFChangeSucceeded = resp
-            self.UFChangeRejectReason = rea[0]
-            self.UFChangeVolumeL = vol[0] / self.LITER_TO_ML_CONVERSION_FACTOR
-            self.UFChangeTimeMin = tim[0]
-            self.UFChangeTimeDiff = tmd[0]
-            self.UFChangeRateMlMin = rat[0]
-            self.UFChangeRateDifff = rtd[0]
-
-        def CmdUICheckinWithHD(self):
-            """
-                Constructs and sends the UI check-in message
-
-                \returns none
-            """
-
-            payload = None
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_UI_CHECKIN_WITH_HD)
-
-            print("Sending UI checkin w/ HD")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message, 0)
-
-            return 0
-
-        def CmdUIUFPauseResume(self, cmd=UF_CMD_PAUSE):
-            """
-                Constructs and sends a UI UF command message
-
-                \param cmd: 0 for pause, 1 for resume
-
-                \returns none
-            """
-
-            payload = self.outer_instance.integer2ByteArray(cmd)
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_UF_PAUSE_RESUME_REQUEST,
-                                                  payload=payload)
-
-            if cmd == self.UF_CMD_PAUSE:
-                str_cmd = "pause"
-            else:
-                str_cmd = "resume"
-            print("Sending UF " + str_cmd + " command.")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message, 0)
-
-            return 0
-
-        def CmdUIUFSettingsChangeRequest(self, vol=0.0):
-            """
-                Constructs and sends a UI UF change settings command message
-
-                \param vol (float): new ultrafiltration volume setting (in L)
-
-                \returns none
-            """
-
-            # reset response to this command so we can tell when response is received
-            self.UFChangeResponse = None
-            # build command message
-            volume = self.outer_instance.float2ByteArray(vol * self.LITER_TO_ML_CONVERSION_FACTOR)
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_UF_SETTINGS_CHANGE_REQUEST_BY_USER,
-                                                  payload=volume)
-
-            print("Sending UF settings change request.")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message, 0)
-
-            return 0
-
-        def CmdUIUFSettingsChangeConfirm(self, vol=0.0, adj=UF_CMD_CHANGE_TIME_TO_ADJUST):
-            """
-                Constructs and sends a UI UF change settings command message
-
-                \param vol (float): new ultrafiltration volume setting (in L)
-                \param adj (int): 0 for adjust time, 1 for adjust rate
-
-                \returns none
-            """
-
-            # reset response to this command so we can tell when response is received
-            self.UFChangeResponse = None
-            # build command message
-            volume = self.outer_instance.float2ByteArray(vol * self.LITER_TO_ML_CONVERSION_FACTOR)
-            adjust = self.outer_instance.integer2ByteArray(adj)
-            payload = volume + adjust
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_UF_SETTINGS_CHANGE_REQUEST_BY_USER,
-                                                  payload=payload)
-
-            print("Sending UF settings change request.")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message, 0)
-
-            return 0
-
-        def CmdUIUFChangeSettingsConfirmedByUser(self, response=RESPONSE_REJECTED, vol=0.0, tm=0, rate=0.0):
-            """
-                Constructs and sends a UI UF change settings confirmed by user message
-
-                \param response (int): 0 for rejected, 1 for confirmed
-                \param vol (float): volume (in L) that was confirmed
-                \param tm (int): treatment time (in min) that was confirmed
-                \param rate (float): ultrafiltration rate (in mL/min) that was confirmed
-
-                \returns none
-            """
-
-            resp = self.outer_instance.integer2ByteArray(response)
-            volume = self.outer_instance.float2ByteArray(vol * self.LITER_TO_ML_CONVERSION_FACTOR)
-            min = self.outer_instance.integer2ByteArray(tm)
-            ufRate = self.outer_instance.float2ByteArray(rate)
-            payload = resp + volume + min + ufRate
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_UF_SETTINGS_CHANGE_CONFIRMED_BY_USER,
-                                                  payload=payload)
-
-            print("Sending UF settings change confirmation.")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message, 0)
-
-            return 0
-
-        def CmdUITreatmentDurationSettingChangeRequest(self, timeMin=0):
-            """
-                Constructs and sends a UI UF change settings confirmed by user message
-
-                \param timeMin (int): treatment time (in min).
-
-                \returns none
-            """
-
-            payload = self.outer_instance.integer2ByteArray(timeMin)
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_TREATMENT_DURATION_SETTING_CHANGE_REQUEST,
-                                                  payload=payload)
-
-            print("Sending treatment duration setting change request.")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message, 0)
-
-            return 0
-
-        def CmdUIBloodAndDialysateFlowSettingsChangeRequest(self, bloodFlow, dialFlow):
-            """
-                Constructs and sends a UI blood & dialysate flow settings change request by user message
-
-                \param bloodFlow (int): blood flow rate set point (in mL/min).
-                \param dialFlow (int): dialysate flow rate set point (in mL/min).
-
-                \returns none
-            """
-
-            bld = self.outer_instance.integer2ByteArray(bloodFlow)
-            dial = self.outer_instance.integer2ByteArray(dialFlow)
-            payload = bld + dial
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_BLOOD_DIALYSATE_FLOW_SETTING_CHANGE_REQUEST_BY_USER,
-                                                  payload=payload)
-
-            print("Sending blood & dialysate flow rate settings change request.")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message, 0)
-
-            return 0
-
-    class HD_Watchdog:
-        """
-            \class HD_Watchdog
-
-            \brief Hemodialysis Device (HD) Dialin API sub-class for watchdog related commands.
-        """
-
-        # Watchdog message IDs
-        MSG_ID_HD_WD_CHECKIN_OVERRIDE = 0x8005
-
-        def __init__(self, outer_instance):
-            self.outer_instance = outer_instance
-
-        """
-            HD_Watchdog constructor 
-
-            \param outer_instance: reference to the HD (outer) class.
-
-            \returns HD_Watchdog object.
-        """
-
-        def CmdWatchdogTaskCheckinOverride(self, reset, state, task):
-            """
-                Constructs and sends the watchdog task check-in override command
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param state:  integer - 1 for task checked in, 0 for task not checked in
-                \param task:  integer - ID of task to override
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            sta = self.outer_instance.integer2ByteArray(state)
-            tsk = self.outer_instance.integer2ByteArray(task)
-            payload = rst + sta + tsk
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_WD_CHECKIN_OVERRIDE,
-                                                  payload=payload)
-
-            print("override watchdog task check-in state")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                #print(received_message)
-                if reset == HD.RESET:
-                    str_res = "reset back to normal"
-                else:
-                    str_res = ("checked in" if state != 0 else "not checked in")
-                print("Watchdog task check-in overridden to " + str_res + ":" +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-    class HD_Alarms:
-        """
-            \class HD_Alarms
-
-            \brief Hemodialysis Device (HD) Dialin API sub-class for alarm related commands.
-        """
-
-        # Alarms message IDs
-        MSG_ID_HD_ALARMS_PUBLISHED_STATUS = 0x0002
-        MSG_ID_HD_ALARM_ACTIVATE = 0x0003
-        MSG_ID_HD_ALARM_CLEAR = 0x0004
-        MSG_ID_HD_ALARM_LAMP_OVERRIDE = 0x8004
-        MSG_ID_HD_ALARM_STATE_OVERRIDE = 0x8006
-        MSG_ID_HD_ALARM_TIME_OVERRIDE = 0x8007
-
-        # Alarm lamp patterns
-        HD_ALARM_LAMP_PATTERN_OFF = 0
-        HD_ALARM_LAMP_PATTERN_OK = 1
-        HD_ALARM_LAMP_PATTERN_FAULT = 2
-        HD_ALARM_LAMP_PATTERN_HIGH = 3
-        HD_ALARM_LAMP_PATTERN_MEDIUM = 4
-        HD_ALARM_LAMP_PATTERN_LOW = 5
-        HD_ALARM_LAMP_PATTERN_MANUAL = 6
-
-        # Alarm status message field positions
-        START_POS_ALARM_STATE = DenaliMessage.PAYLOAD_START_INDEX
-        END_POS_ALARM_STATE = START_POS_ALARM_STATE + 4
-        START_POS_ALARM_TOP = END_POS_ALARM_STATE
-        END_POS_ALARM_TOP = START_POS_ALARM_TOP + 4
-        START_POS_ALARM_SILENCE_EXPIRES_IN = END_POS_ALARM_TOP
-        END_POS_ALARM_SILENCE_EXPIRES_IN = START_POS_ALARM_SILENCE_EXPIRES_IN + 4
-        START_POS_ALARM_ESCALATES_IN = END_POS_ALARM_SILENCE_EXPIRES_IN
-        END_POS_ALARM_ESCALATES_IN = START_POS_ALARM_ESCALATES_IN + 4
-        START_POS_ALARMS_FLAGS = END_POS_ALARM_ESCALATES_IN
-        END_POS_ALARMS_FLAGS = START_POS_ALARMS_FLAGS + 2
-
-        START_POS_ALARM_ID = DenaliMessage.PAYLOAD_START_INDEX
-        END_POS_ALARM_ID = START_POS_ALARM_ID + 2
-
-        def __init__(self, outer_instance, can_interface=None):
-            """
-                HD_Alarms constructor
-
-                \param outer_instance: reference to the HD (outer) class.
-
-                \returns HD_Alarms object.
-            """
-            self.outer_instance = outer_instance
-
-            if can_interface is not None:
-                channel_id = DenaliChannels.hd_alarm_broadcast_ch_id
-                msg_id = self.MSG_ID_HD_ALARMS_PUBLISHED_STATUS
-                can_interface.register_receiving_publication_function(channel_id, msg_id,
-                                                                      self.handlerAlarmsStatusSyncFunction)
-
-                channel_id = DenaliChannels.hd_alarm_broadcast_ch_id
-                msg_id = self.MSG_ID_HD_ALARM_ACTIVATE
-                can_interface.register_receiving_publication_function(channel_id, msg_id,
-                                                                      self.handlerAlarmActivateFunction)
-                channel_id = DenaliChannels.hd_alarm_broadcast_ch_id
-                msg_id = self.MSG_ID_HD_ALARM_CLEAR
-                can_interface.register_receiving_publication_function(channel_id, msg_id,
-                                                                      self.handlerAlarmClearFunction)
-
-            # composite alarm status based on latest HD alarm status broadcast message
-            self.alarmsState = 0
-            self.alarmTop = 0
-            self.alarmsSilenceExpiresIn = 0
-            self.alarmsEscalatesIn = 0
-            self.alarmsFlags = 0
-
-            # alarm states based on received HD alarm activation and alarm clear messages
-            self.alarmStates = [False] * 50
-#            for x in range(0,511):
-#                self.alarmStates.append(False)
-
-        def handlerAlarmsStatusSyncFunction(self, message):
-            """
-                Handles published alarms status messages.  Alarms status data are captured
-                for reference.
-
-                \param message:  published blood flow data message
-                \returns none
-            """
-
-            self.alarmsState = int.from_bytes(bytearray(
-                message['message'][self.START_POS_ALARM_STATE:self.END_POS_ALARM_STATE]),
-                byteorder=DenaliMessage.BYTE_ORDER)
-            self.alarmTop = int.from_bytes(bytearray(
-                message['message'][self.START_POS_ALARM_TOP:self.END_POS_ALARM_TOP]),
-                byteorder=DenaliMessage.BYTE_ORDER)
-            self.alarmsSilenceExpiresIn = int.from_bytes(bytearray(
-                message['message'][self.START_POS_ALARM_SILENCE_EXPIRES_IN:self.END_POS_ALARM_SILENCE_EXPIRES_IN]),
-                byteorder=DenaliMessage.BYTE_ORDER)
-            self.alarmsEscalatesIn = int.from_bytes(bytearray(
-                message['message'][self.START_POS_ALARM_ESCALATES_IN:self.END_POS_ALARM_ESCALATES_IN]),
-                byteorder=DenaliMessage.BYTE_ORDER)
-            self.alarmsFlags = int.from_bytes(bytearray(
-                message['message'][self.START_POS_ALARMS_FLAGS:self.END_POS_ALARMS_FLAGS]),
-                byteorder=DenaliMessage.BYTE_ORDER)
-
-        def handlerAlarmActivateFunction(self, message):
-            """
-                Handles published HD alarm activation messages.
-
-                \param message:  published HD alarm activation message
-                \returns none
-            """
-
-            alarmID = struct.unpack('<H', bytearray(message['message'][self.START_POS_ALARM_ID:self.END_POS_ALARM_ID]))
-            self.alarmStates[alarmID[0]] = True
-
-        def handlerAlarmClearFunction(self, message):
-            """
-                Handles published HD alarm clear messages.
-
-                \param message:  published HD alarm clear message
-                \returns none
-            """
-
-            alarmID = struct.unpack('<H', bytearray(message['message'][self.START_POS_ALARM_ID:self.END_POS_ALARM_ID]))
-            self.alarmStates[alarmID[0]] = False
-
-        def CmdAlarmStateOverride(self, reset, state, alarm):
-            """
-                Constructs and sends the alarm state override command
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param state:  integer - 1 for alarm active, 0 for alarm inactive
-                \param alarm:  integer - ID of alarm to override
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            sta = self.outer_instance.integer2ByteArray(state)
-            alm = self.outer_instance.integer2ByteArray(alarm)
-            payload = rst + sta + alm
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_ALARM_STATE_OVERRIDE,
-                                                  payload=payload)
-
-            print("override alarm state")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                #print(received_message)
-                if reset == HD.RESET:
-                    str_res = "reset back to normal"
-                else:
-                    str_res = ("active" if state != 0 else "inactive")
-                print("Alarm state overridden to " + str_res + ":" +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-        def CmdAlarmTimeOverride(self, reset, time_ms, alarm):
-            """
-                Constructs and sends the alarm time override command
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param time_ms:  integer - time (in ms) since alarm was activated
-                \param alarm:  integer - ID of alarm to override
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            ms = self.outer_instance.integer2ByteArray(time_ms)
-            alm = self.outer_instance.integer2ByteArray(alarm)
-            payload = rst + ms + alm
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_ALARM_TIME_OVERRIDE,
-                                                  payload=payload)
-
-            print("override alarm time since activated")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                #print(received_message)
-                if reset == HD.RESET:
-                    str_res = "reset back to normal"
-                else:
-                    str_res = str(time_ms)
-                print("Alarm time since activated overridden to " + str_res + " ms: " + str(
-                    received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-        def CmdAlarmLampPatternOverride(self, reset, pattern):
-            """
-                Constructs and sends the alarm lamp pattern override command.
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param pattern:  integer - ID of alarm lamp pattern to override with
-                \returns 1 if successful, zero otherwise
-
-                \details Patterns: \n
-                    0 = off \n
-                    1 = ok \n
-                    2 = fault \n
-                    3 = high \n
-                    4 = medium \n
-                    5 = low \n
-                    6 = manual
-            """
-            rst = self.outer_instance.integer2ByteArray(reset)
-            pat = self.outer_instance.integer2ByteArray(pattern)
-            payload = rst + pat
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_ALARM_LAMP_OVERRIDE,
-                                                  payload=payload)
-
-            print("override alarm lamp pattern")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                print(received_message)
-                if reset == HD.RESET:
-                    str_pat = "reset back to normal"
-                elif pattern == self.HD_ALARM_LAMP_PATTERN_OFF:
-                    str_pat = "off"
-                elif pattern == self.HD_ALARM_LAMP_PATTERN_OK:
-                    str_pat = "ok"
-                elif pattern == self.HD_ALARM_LAMP_PATTERN_FAULT:
-                    str_pat = "fault"
-                elif pattern == self.HD_ALARM_LAMP_PATTERN_HIGH:
-                    str_pat = "high"
-                elif pattern == self.HD_ALARM_LAMP_PATTERN_MEDIUM:
-                    str_pat = "medium"
-                elif pattern == self.HD_ALARM_LAMP_PATTERN_LOW:
-                    str_pat = "low"
-                else:
-                    str_pat = "manual"
-                print("Alarm lamp pattern overridden to " + str_pat + ":" +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-    class HD_RTC:
-        """
-            \class HD_RTC
-
-            \brief Hemodialysis Device (HD) Dialin API sub-class for RTC commands.
-        """
-
-        MSG_ID_SET_RTC_DATE_TIME = 0x801D
-        MSG_ID_RTC_EPOCH = 0x000A
-
-        START_POS_SET_PT = DenaliMessage.PAYLOAD_START_INDEX
-        END_POS_SET_PT = START_POS_SET_PT + 4
-
-        def __init__(self, outer_instance, can_interface=None):
-            """
-                HD_BloodFlow constructor
-
-                \param outer_instance: reference to the HD (outer) class.
-
-                \returns HD_BloodFlow object.
-            """
-            self.outer_instance = outer_instance
-
-            if can_interface is not None:
-                channel_id = DenaliChannels.hd_sync_broadcast_ch_id
-                msg_id = self.MSG_ID_RTC_EPOCH
-                can_interface.register_receiving_publication_function(channel_id, msg_id,
-                                                                      self.handlerRTCEpoch)
-            self.RTCEpoch = 0
-
-        def handlerRTCEpoch(self, message):
-            """
-                Publishes the RTC time in epoch
-
-                \param message:  published RTC epoch message
-                \returns none
-            """
-            epoch = int.from_bytes(bytearray(
-                message['message'][self.START_POS_SET_PT:self.END_POS_SET_PT]),
-                byteorder=DenaliMessage.BYTE_ORDER)
-            self.RTCEpoch = ctypes.c_uint32(epoch)
-
-        def CmdSetRTCTimeAndDate(self, secs, mins, hours, days, months, years):
-            """
-                Constructs and sends the time and date to be written to RTC
-
-                \returns 1 if successful, zero otherwise
-            """
-            sec   = bytes([secs])
-            min   = bytes([mins])
-            hour  = bytes([hours])
-            day   = bytes([days])
-            month = bytes([months])
-            year  = self.outer_instance.integer2ByteArray(years)
-            payload = sec + min + hour + day + month + year
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_SET_RTC_DATE_TIME,
-                                                  payload=payload)
-
-            print("Setting time and date to RTC")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                print(received_message)
-                #str_res = str(flow)
-                print("Time and Date in RTC set to seconds: " + str(sec) + " minutes: " + str(min) + " hours: " +
-                      str(hour) + " days: " + str(day) + " months: " + str(month) + " years: " + str(year) +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-    class HD_BloodFlow:
-        """
-            \class HD_BloodFlow
-
-            \brief Hemodialysis Device (HD) Dialin API sub-class for blood-flow related commands.
-
-        """
-
-        # BloodFlow message IDs
-        MSG_ID_HD_BLOOD_FLOW_PUBLISHED_DATA = 0x0005
-        MSG_ID_HD_BLOOD_FLOW_SET_RATE_OVERRIDE = 0x8008
-        MSG_ID_HD_BLOOD_FLOW_MEAS_RATE_OVERRIDE = 0x8009
-        MSG_ID_HD_BLOOD_PUMP_MC_MEAS_SPEED_OVERRIDE = 0x800A
-        MSG_ID_HD_BLOOD_PUMP_MC_MEAS_CURRENT_OVERRIDE = 0x800B
-        MSG_ID_HD_BLOOD_FLOW_PUBLISH_INTERVAL_OVERRIDE = 0x800C
-        MSG_ID_HD_BLOOD_PUMP_MEAS_SPEED_OVERRIDE = 0x800E
-        MSG_ID_HD_BLOOD_PUMP_ROTOR_MEAS_SPEED_OVERRIDE = 0x800F
-
-        # BloodFlow broadcast message field positions
-        START_POS_SET_PT = DenaliMessage.PAYLOAD_START_INDEX
-        END_POS_SET_PT = START_POS_SET_PT + 4
-        START_POS_MEAS_FLOW = END_POS_SET_PT
-        END_POS_MEAS_FLOW = START_POS_MEAS_FLOW + 4
-        START_POS_MEAS_ROT_SPEED = END_POS_MEAS_FLOW
-        END_POS_MEAS_ROT_SPEED = START_POS_MEAS_ROT_SPEED + 4
-        START_POS_MEAS_SPEED = END_POS_MEAS_ROT_SPEED
-        END_POS_MEAS_SPEED = START_POS_MEAS_SPEED + 4
-        START_POS_MEAS_MC_SPEED = END_POS_MEAS_SPEED
-        END_POS_MEAS_MC_SPEED = START_POS_MEAS_MC_SPEED + 4
-        START_POS_MEAS_MC_CURR = END_POS_MEAS_MC_SPEED
-        END_POS_MEAS_MC_CURR = START_POS_MEAS_MC_CURR + 4
-        START_POS_PWM_DC = END_POS_MEAS_MC_CURR
-        END_POS_PWM_DC = START_POS_PWM_DC + 4
-
-        def __init__(self, outer_instance, can_interface=None):
-            """
-                HD_BloodFlow constructor
-
-                \param outer_instance: reference to the HD (outer) class.
-
-                \returns HD_BloodFlow object.
-            """
-            self.outer_instance = outer_instance
-
-            if can_interface is not None:
-                channel_id = DenaliChannels.hd_sync_broadcast_ch_id
-                msg_id = self.MSG_ID_HD_BLOOD_FLOW_PUBLISHED_DATA
-                can_interface.register_receiving_publication_function(channel_id, msg_id,
-                                                                      self.handlerBloodFlowSyncFunction)
-
-            self.TargetBloodFlowRate = 0
-            self.MeasuredBloodFlowRate = 0.0
-            self.MeasuredBloodPumpRotorSpeed = 0.0
-            self.MeasuredBloodPumpSpeed = 0.0
-            self.MeasuredBloodPumpMCSpeed = 0.0
-            self.MeasuredBloodPumpMCCurrent = 0.0
-            self.PWMDutyCyclePct = 0.0
-
-        def handlerBloodFlowSyncFunction(self, message):
-            """
-                Handles published blood flow data messages.  Blood flow data are captured
-                for reference.
-
-                \param message:  published blood flow data message
-                \returns none
-            """
-
-            #self.TargetBloodFlowRate = int.from_bytes(bytearray(
-            #    message['message'][self.START_POS_SET_PT:self.END_POS_SET_PT]),
-            #    byteorder=DenaliMessage.BYTE_ORDER)
-            tgt = struct.unpack('i',bytearray(
-                message['message'][self.START_POS_SET_PT:self.END_POS_SET_PT]))
-
-            flow = struct.unpack('f', bytearray(
-                message['message'][self.START_POS_MEAS_FLOW:self.END_POS_MEAS_FLOW]))
-            rotor = struct.unpack('f', bytearray(
-                message['message'][self.START_POS_MEAS_ROT_SPEED:self.END_POS_MEAS_ROT_SPEED]))
-            speed = struct.unpack('f', bytearray(
-                message['message'][self.START_POS_MEAS_SPEED:self.END_POS_MEAS_SPEED]))
-            mcspeed = struct.unpack('f', bytearray(
-                message['message'][self.START_POS_MEAS_MC_SPEED:self.END_POS_MEAS_MC_SPEED]))
-            mccurr = struct.unpack('f', bytearray(
-                message['message'][self.START_POS_MEAS_MC_CURR:self.END_POS_MEAS_MC_CURR]))
-            pwm = struct.unpack('f', bytearray(
-                message['message'][self.START_POS_PWM_DC:self.END_POS_PWM_DC]))
-
-            self.TargetBloodFlowRate = tgt[0]
-            self.MeasuredBloodFlowRate = flow[0]
-            self.MeasuredBloodPumpRotorSpeed = rotor[0]
-            self.MeasuredBloodPumpSpeed = speed[0]
-            self.MeasuredBloodPumpMCSpeed = mcspeed[0]
-            self.MeasuredBloodPumpMCCurrent = mccurr[0]
-            self.PWMDutyCyclePct = pwm[0]
-
-        def CmdBloodFlowSetPointOverride(self, reset, flow):
-            """
-                Constructs and sends the blood flow set point override command
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param flow:  integer - flow set point (in mL/min) to override with (negative for reverse direction)
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            flo = self.outer_instance.integer2ByteArray(flow)
-            payload = rst + flo
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_BLOOD_FLOW_SET_RATE_OVERRIDE,
-                                                  payload=payload)
-
-            print("override blood flow set point")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                #print(received_message)
-                if reset == HD.RESET:
-                    str_res = "reset back to normal"
-                else:
-                    str_res = str(flow)
-                print(
-                    "Blood flow set point overridden to " + str_res + " mL/min: " +
-                    str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-        def CmdBloodFlowMeasuredOverride(self, reset, flow):
-            """
-                Constructs and sends the measured blood flow override command
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param flow:  integer - measured flow (in mL/min) to override with
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            flo = self.outer_instance.float2ByteArray(flow)
-            payload = rst + flo
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_BLOOD_FLOW_MEAS_RATE_OVERRIDE,
-                                                  payload=payload)
-
-            print("override measured blood flow")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                #print(received_message)
-                if reset == HD.RESET:
-                    str_res = "reset back to normal"
-                else:
-                    str_res = str(flow)
-                print("Blood flow (measured)) overridden to " + str_res + " mL/min: " +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-        def CmdBloodPumpMCMeasuredSpeedOverride(self, reset, speed):
-            """
-                Constructs and sends the measured blood pump motor controller speed \n
-                override command.
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param speed:  integer - speed (in RPM) to override with
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            spd = self.outer_instance.float2ByteArray(speed)
-            payload = rst + spd
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_BLOOD_PUMP_MC_MEAS_SPEED_OVERRIDE,
-                                                  payload=payload)
-
-            print("override measured blood pump motor controller speed")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                #print(received_message)
-                if reset == HD.RESET:
-                    str_res = "reset back to normal"
-                else:
-                    str_res = str(speed)
-                print("Blood pump MC speed (measured) overridden to " + str_res + " RPM: " +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-        def CmdBloodPumpMeasuredCurrentOverride(self, reset, curr):
-            """
-                Constructs and sends the measured blood pump motor current override command
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param curr:  float - current (in mA) to override with
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            cur = self.outer_instance.float2ByteArray(curr)
-            payload = rst + cur
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_BLOOD_PUMP_MC_MEAS_CURRENT_OVERRIDE,
-                                                  payload=payload)
-
-            print("override measured blood pump motor controller current")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                #print(received_message)
-                if reset == HD.RESET:
-                    str_res = "reset back to normal"
-                else:
-                    str_res = str(curr)
-                print("Blood pump MC current (measured) overridden to " + str_res + " mA: " +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-        def CmdBloodPumpMeasuredSpeedOverride(self, reset, speed):
-            """
-                Constructs and sends the measured blood pump motor  speed override \n
-                command.
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param speed:  integer - speed (in RPM) to override with
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            spd = self.outer_instance.float2ByteArray(speed)
-            payload = rst + spd
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_BLOOD_PUMP_MEAS_SPEED_OVERRIDE,
-                                                  payload=payload)
-
-            print("override measured blood pump speed")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                #print(received_message)
-                if reset == HD.RESET:
-                    str_res = "reset back to normal"
-                else:
-                    str_res = str(speed)
-                print("Blood pump speed (measured) overridden to " + str_res + " RPM: " +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-        def CmdBloodPumpRotorMeasuredSpeedOverride(self, reset, speed):
-            """
-                Constructs and sends the measured blood pump rotor speed override \n
-                command.
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param speed:  integer - speed (in RPM) to override with
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            spd = self.outer_instance.float2ByteArray(speed)
-            payload = rst + spd
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_BLOOD_PUMP_ROTOR_MEAS_SPEED_OVERRIDE,
-                                                  payload=payload)
-
-            print("override measured blood pump rotor speed")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                #print(received_message)
-                if reset == HD.RESET:
-                    str_res = "reset back to normal"
-                else:
-                    str_res = str(speed)
-                print("Blood pump rotor speed (measured) overridden to " + str_res + " RPM: " +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-        def CmdBloodFlowBroadcastIntervalOverride(self, reset, ms):
-            """
-                Constructs and sends the measured blood flow broadcast interval override command
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param ms:  integer - interval (in ms) to override with
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            mis = self.outer_instance.integer2ByteArray(ms)
-            payload = rst + mis
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_BLOOD_FLOW_PUBLISH_INTERVAL_OVERRIDE,
-                                                  payload=payload)
-
-            print("override blood flow broadcast interval")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                #print(received_message)
-                if reset == HD.RESET:
-                    str_res = "reset back to normal: "
-                else:
-                    str_res = str(ms) + " ms: "
-                print("Blood flow broadcast interval overridden to " + str_res +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-    class HD_DialysateInletFlow:
-        """
-            \class HD_DialysateInletFlow
-
-            \brief Hemodialysis Device (HD) Dialin API sub-class for dialysate inlet pump related commands.
-
-        """
-
-        # DialysateFlow message IDs
-        MSG_ID_HD_DIAL_IN_FLOW_PUBLISHED_DATA = 0x0008
-        MSG_ID_HD_DIAL_IN_FLOW_SET_RATE_OVERRIDE = 0x8010
-        MSG_ID_HD_DIAL_IN_FLOW_MEAS_RATE_OVERRIDE = 0x8011
-        MSG_ID_HD_DIAL_IN_PUMP_MC_MEAS_SPEED_OVERRIDE = 0x8012
-        MSG_ID_HD_DIAL_IN_PUMP_MC_MEAS_CURRENT_OVERRIDE = 0x8013
-        MSG_ID_HD_DIAL_IN_FLOW_PUBLISH_INTERVAL_OVERRIDE = 0x8014
-        MSG_ID_HD_DIAL_IN_PUMP_MEAS_SPEED_OVERRIDE = 0x8015
-        MSG_ID_HD_DIAL_IN_PUMP_ROTOR_MEAS_SPEED_OVERRIDE = 0x8016
-
-        # BloodFlow broadcast message field positions
-        START_POS_SET_PT = DenaliMessage.PAYLOAD_START_INDEX
-        END_POS_SET_PT = START_POS_SET_PT + 4
-        START_POS_MEAS_FLOW = END_POS_SET_PT
-        END_POS_MEAS_FLOW = START_POS_MEAS_FLOW + 4
-        START_POS_MEAS_ROT_SPEED = END_POS_MEAS_FLOW
-        END_POS_MEAS_ROT_SPEED = START_POS_MEAS_ROT_SPEED + 4
-        START_POS_MEAS_SPEED = END_POS_MEAS_ROT_SPEED
-        END_POS_MEAS_SPEED = START_POS_MEAS_SPEED + 4
-        START_POS_MEAS_MC_SPEED = END_POS_MEAS_SPEED
-        END_POS_MEAS_MC_SPEED = START_POS_MEAS_MC_SPEED + 4
-        START_POS_MEAS_MC_CURR = END_POS_MEAS_MC_SPEED
-        END_POS_MEAS_MC_CURR = START_POS_MEAS_MC_CURR + 4
-        START_POS_PWM_DC = END_POS_MEAS_MC_CURR
-        END_POS_PWM_DC = START_POS_PWM_DC + 4
-
-        def __init__(self, outer_instance, can_interface=None):
-            """
-                HD_DialysateFlow constructor
-
-                \param outer_instance: reference to the HD (outer) class.
-
-                \returns HD_DialysateFlow object.
-            """
-            self.outer_instance = outer_instance
-
-            if can_interface is not None:
-                channel_id = DenaliChannels.hd_sync_broadcast_ch_id
-                msg_id = self.MSG_ID_HD_DIAL_IN_FLOW_PUBLISHED_DATA
-                can_interface.register_receiving_publication_function(channel_id, msg_id,
-                                                                      self.handlerDialysateInletFlowSyncFunction)
-
-            self.TargetDialysateInletFlowRate = 0
-            self.MeasuredDialysateInletFlowRate = 0.0
-            self.MeasuredDialysateInletPumpRotorSpeed = 0.0
-            self.MeasuredDialysateInletPumpSpeed = 0.0
-            self.MeasuredDialysateInletPumpMCSpeed = 0.0
-            self.MeasuredDialysateInletPumpMCCurrent = 0.0
-            self.PWMDutyCyclePct = 0.0
-
-        def handlerDialysateInletFlowSyncFunction(self, message):
-            """
-                Handles published dialysate inlet flow data messages.  Dialysate flow data are captured
-                for reference.
-
-                \param message:  published dialysate flow data message
-                \returns none
-            """
-
-            self.TargetDialysateInletFlowRate = int.from_bytes(bytearray(
-                message['message'][self.START_POS_SET_PT:self.END_POS_SET_PT]),
-                byteorder=DenaliMessage.BYTE_ORDER)
-            flow = struct.unpack('f', bytearray(
-                message['message'][self.START_POS_MEAS_FLOW:self.END_POS_MEAS_FLOW]))
-            rotor = struct.unpack('f', bytearray(
-                message['message'][self.START_POS_MEAS_ROT_SPEED:self.END_POS_MEAS_ROT_SPEED]))
-            speed = struct.unpack('f', bytearray(
-                message['message'][self.START_POS_MEAS_SPEED:self.END_POS_MEAS_SPEED]))
-            mcspeed = struct.unpack('f', bytearray(
-                message['message'][self.START_POS_MEAS_MC_SPEED:self.END_POS_MEAS_MC_SPEED]))
-            mccurr = struct.unpack('f', bytearray(
-                message['message'][self.START_POS_MEAS_MC_CURR:self.END_POS_MEAS_MC_CURR]))
-            pwm = struct.unpack('f', bytearray(
-                message['message'][self.START_POS_PWM_DC:self.END_POS_PWM_DC]))
-
-            self.MeasuredDialysateInletFlowRate = flow[0]
-            self.MeasuredDialysateInletPumpRotorSpeed = rotor[0]
-            self.MeasuredDialysateInletPumpSpeed = speed[0]
-            self.MeasuredDialysateInletPumpMCSpeed = mcspeed[0]
-            self.MeasuredDialysateInletPumpMCCurrent = mccurr[0]
-            self.PWMDutyCyclePct = pwm[0]
-
-        def CmdDialysateInletFlowSetPointOverride(self, reset, flow):
-            """
-                Constructs and sends the dialysate flow set point override command
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param flow:  integer - flow set point (in mL/min) to override with
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            flo = self.outer_instance.integer2ByteArray(flow)
-            payload = rst + flo
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_DIAL_IN_FLOW_SET_RATE_OVERRIDE,
-                                                  payload=payload)
-
-            print("override dialysate flow set point")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                #print(received_message)
-                if reset == HD.RESET:
-                    str_res = "reset back to normal"
-                else:
-                    str_res = str(flow)
-                print(
-                    "Dialysate flow set point overridden to " + str_res + " mL/min: " +
-                    str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-        def CmdDialysateInletFlowMeasuredOverride(self, reset, flow):
-            """
-                Constructs and sends the measured dialysate flow override command
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param flow:  integer - measured flow (in mL/min) to override with
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            flo = self.outer_instance.float2ByteArray(flow)
-            payload = rst + flo
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_DIAL_IN_FLOW_MEAS_RATE_OVERRIDE,
-                                                  payload=payload)
-
-            print("override measured dialysate flow")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                #print(received_message)
-                if reset == HD.RESET:
-                    str_res = "reset back to normal"
-                else:
-                    str_res = str(flow)
-                print("Dialysate flow (measured)) overridden to " + str_res + " mL/min: " +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-        def CmdDialysateInletPumpMCMeasuredSpeedOverride(self, reset, speed):
-            """
-                Constructs and sends the measured dialysate inlet pump motor controller speed \n
-                override command.
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param speed:  integer - speed (in RPM) to override with
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            spd = self.outer_instance.float2ByteArray(speed)
-            payload = rst + spd
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_DIAL_IN_PUMP_MC_MEAS_SPEED_OVERRIDE,
-                                                  payload=payload)
-
-            print("override measured dialysate inlet pump motor controller speed")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                #print(received_message)
-                if reset == HD.RESET:
-                    str_res = "reset back to normal"
-                else:
-                    str_res = str(speed)
-                print("Dialysate pump MC speed (measured) overridden to " + str_res + " RPM: " +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-        def CmdDialysateInletPumpMeasuredCurrentOverride(self, reset, curr):
-            """
-                Constructs and sends the measured dialysate inlet pump motor current override command
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param curr:  integer - current (in mA) to override with
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            cur = self.outer_instance.float2ByteArray(curr)
-            payload = rst + cur
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_DIAL_IN_PUMP_MC_MEAS_CURRENT_OVERRIDE,
-                                                  payload=payload)
-
-            print("override measured dialysate inlet pump motor controller current")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                #print(received_message)
-                if reset == HD.RESET:
-                    str_res = "reset back to normal"
-                else:
-                    str_res = str(curr)
-                print("Dialysate inlet pump MC current (measured) overridden to " + str_res + " mA: " +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-        def CmdDialysateInletPumpMeasuredSpeedOverride(self, reset, speed):
-            """
-                Constructs and sends the measured dialysate inlet pump motor speed override \n
-                command.
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param speed:  integer - speed (in RPM) to override with
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            spd = self.outer_instance.float2ByteArray(speed)
-            payload = rst + spd
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_DIAL_IN_PUMP_MEAS_SPEED_OVERRIDE,
-                                                  payload=payload)
-
-            print("override measured dialysate inlet pump speed")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                #print(received_message)
-                if reset == HD.RESET:
-                    str_res = "reset back to normal"
-                else:
-                    str_res = str(speed)
-                print("Dialysate inlet pump speed (measured) overridden to " + str_res + " RPM: " +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-        def CmdDialysateInletPumpRotorMeasuredSpeedOverride(self, reset, speed):
-            """
-                Constructs and sends the measured dialysate inlet pump rotor speed override \n
-                command.
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param speed:  integer - speed (in RPM) to override with
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            spd = self.outer_instance.float2ByteArray(speed)
-            payload = rst + spd
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_DIAL_IN_PUMP_ROTOR_MEAS_SPEED_OVERRIDE,
-                                                  payload=payload)
-
-            print("override measured dialysate inlet pump rotor speed")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                #print(received_message)
-                if reset == HD.RESET:
-                    str_res = "reset back to normal"
-                else:
-                    str_res = str(speed)
-                print("Dialysate inlet pump rotor speed (measured) overridden to " + str_res + " RPM: " +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-        def CmdDialysateInletFlowBroadcastIntervalOverride(self, reset, ms):
-            """
-                Constructs and sends the measured dialysate inlet flow broadcast interval override command
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param ms:  integer - interval (in ms) to override with
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            mis = self.outer_instance.integer2ByteArray(ms)
-            payload = rst + mis
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_DIAL_IN_FLOW_PUBLISH_INTERVAL_OVERRIDE,
-                                                  payload=payload)
-
-            print("override dialysate inlet flow broadcast interval")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                #print(received_message)
-                if reset == HD.RESET:
-                    str_res = "reset back to normal: "
-                else:
-                    str_res = str(ms) + " ms: "
-                print("Dialysate inlet flow broadcast interval overridden to " + str_res +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-    class HD_DialysateOutletFlow:
-        """
-            \class HD_DialysateOutletFlow
-
-            \brief Hemodialysis Device (HD) Dialin API sub-class for dialysate outlet pump related commands.
-
-        """
-
-        # DialysateFlow message IDs
-        MSG_ID_HD_DIAL_OUT_FLOW_PUBLISHED_DATA = 0x000B
-        MSG_ID_HD_LOAD_CELL_READINGS = 0x000C
-        MSG_ID_HD_DIAL_OUT_FLOW_PUBLISH_INTERVAL_OVERRIDE = 0x801E
-        MSG_ID_HD_DIAL_OUT_UF_REF_VOLUME_OVERRIDE = 0x801F
-        MSG_ID_HD_DIAL_OUT_UF_MEAS_VOLUME_OVERRIDE = 0x8020
-        MSG_ID_HD_DIAL_OUT_PUMP_MC_MEAS_SPEED_OVERRIDE = 0x8021
-        MSG_ID_HD_DIAL_OUT_PUMP_MC_MEAS_CURRENT_OVERRIDE = 0x8022
-        MSG_ID_HD_DIAL_OUT_PUMP_MEAS_SPEED_OVERRIDE = 0x8023
-        MSG_ID_HD_DIAL_OUT_PUMP_ROTOR_MEAS_SPEED_OVERRIDE = 0x8024
-        MSG_ID_HD_DIAL_OUT_LOAD_CELL_WEIGHT_OVERRIDE = 0x8025
-
-        # BloodFlow broadcast message field positions
-        START_POS_REF_VOL = DenaliMessage.PAYLOAD_START_INDEX
-        END_POS_REF_VOL = START_POS_REF_VOL + 4
-        START_POS_MEAS_VOL = END_POS_REF_VOL
-        END_POS_MEAS_VOL = START_POS_MEAS_VOL + 4
-        START_POS_MEAS_ROT_SPEED = END_POS_MEAS_VOL
-        END_POS_MEAS_ROT_SPEED = START_POS_MEAS_ROT_SPEED + 4
-        START_POS_MEAS_SPEED = END_POS_MEAS_ROT_SPEED
-        END_POS_MEAS_SPEED = START_POS_MEAS_SPEED + 4
-        START_POS_MEAS_MC_SPEED = END_POS_MEAS_SPEED
-        END_POS_MEAS_MC_SPEED = START_POS_MEAS_MC_SPEED + 4
-        START_POS_MEAS_MC_CURR = END_POS_MEAS_MC_SPEED
-        END_POS_MEAS_MC_CURR = START_POS_MEAS_MC_CURR + 4
-        START_POS_PWM_DC = END_POS_MEAS_MC_CURR
-        END_POS_PWM_DC = START_POS_PWM_DC + 4
-
-        def __init__(self, outer_instance, can_interface=None):
-            """
-                HD_DialysateFlow constructor
-
-                \param outer_instance: reference to the HD (outer) class.
-
-                \returns HD_DialysateFlow object.
-            """
-            self.outer_instance = outer_instance
-
-            if can_interface is not None:
-                channel_id = DenaliChannels.hd_sync_broadcast_ch_id
-                msg_id = self.MSG_ID_HD_DIAL_OUT_FLOW_PUBLISHED_DATA
-                can_interface.register_receiving_publication_function(channel_id, msg_id,
-                                                                      self.handlerDialysateOutletFlowSyncFunction)
-
-            self.ReferenceDialysateOutletUFVolume = 0.0
-            self.MeasuredDialysateOutletUFVolume = 0.0
-            self.MeasuredDialysateOutletPumpRotorSpeed = 0.0
-            self.MeasuredDialysateOutletPumpSpeed = 0.0
-            self.MeasuredDialysateOutletPumpMCSpeed = 0.0
-            self.MeasuredDialysateOutletPumpMCCurrent = 0.0
-            self.PWMDutyCyclePct = 0.0
-
-        def handlerDialysateOutletFlowSyncFunction(self, message):
-            """
-                Handles published dialysate outlet flow data messages.  Dialysate flow data are captured
-                for reference.
-
-                \param message:  published dialysate outlet flow data message
-                \returns none
-            """
-
-            refVol = struct.unpack('f', bytearray(
-                message['message'][self.START_POS_REF_VOL:self.END_POS_REF_VOL]))
-            measVol = struct.unpack('f', bytearray(
-                message['message'][self.START_POS_MEAS_VOL:self.END_POS_MEAS_VOL]))
-            rotor = struct.unpack('f', bytearray(
-                message['message'][self.START_POS_MEAS_ROT_SPEED:self.END_POS_MEAS_ROT_SPEED]))
-            speed = struct.unpack('f', bytearray(
-                message['message'][self.START_POS_MEAS_SPEED:self.END_POS_MEAS_SPEED]))
-            mcspeed = struct.unpack('f', bytearray(
-                message['message'][self.START_POS_MEAS_MC_SPEED:self.END_POS_MEAS_MC_SPEED]))
-            mccurr = struct.unpack('f', bytearray(
-                message['message'][self.START_POS_MEAS_MC_CURR:self.END_POS_MEAS_MC_CURR]))
-            pwm = struct.unpack('f', bytearray(
-                message['message'][self.START_POS_PWM_DC:self.END_POS_PWM_DC]))
-
-            self.ReferenceDialysateOutletUFVolume = refVol[0]
-            self.MeasuredDialysateOutletUFVolume = measVol[0]
-            self.MeasuredDialysateOutletPumpRotorSpeed = rotor[0]
-            self.MeasuredDialysateOutletPumpSpeed = speed[0]
-            self.MeasuredDialysateOutletPumpMCSpeed = mcspeed[0]
-            self.MeasuredDialysateOutletPumpMCCurrent = mccurr[0]
-            self.PWMDutyCyclePct = pwm[0]
-
-        def CmdDialysateOutletReferenceUFVolumeOverride(self, reset, refVol):
-            """
-                Constructs and sends the UF reference volume override command
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param refVol:  float - reference UF volume (in mL) to override with
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            vol = self.outer_instance.float2ByteArray(refVol)
-            payload = rst + vol
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_DIAL_OUT_UF_REF_VOLUME_OVERRIDE,
-                                                  payload=payload)
-
-            print("override UF reference volume with " + str(refVol) + "mL.")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                #print(received_message)
-                if reset == HD.RESET:
-                    str_res = "reset back to normal.  "
-                else:
-                    str_res = "overridden to " + str(refVol) + " mL.  "
-                print(
-                    "UF reference volume " + str_res +
-                    str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-        def CmdDialysateOutletMeasuredUFVolumeOverride(self, reset, measVol):
-            """
-                Constructs and sends the measured UF volume override command
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param measVol:  float - measured UF volume (in mL) to override with
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            vol = self.outer_instance.float2ByteArray(measVol)
-            payload = rst + vol
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_DIAL_OUT_UF_MEAS_VOLUME_OVERRIDE,
-                                                  payload=payload)
-
-            print("override measured UF volume with " + str(measVol) + " mL.")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                #print(received_message)
-                if reset == HD.RESET:
-                    str_res = "reset back to normal.  "
-                else:
-                    str_res = "overridden to " + str(measVol) + " mL.  "
-                print("UF measured volume " + str_res +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-        def CmdDialysateOutletPumpMCMeasuredSpeedOverride(self, reset, speed):
-            """
-                Constructs and sends the measured dialysate outlet pump motor controller speed \n
-                override command.
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param speed:  float - speed (in RPM) to override with
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            spd = self.outer_instance.float2ByteArray(speed)
-            payload = rst + spd
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MeasuredDialysateOutletPumpMCSpeed,
-                                                  payload=payload)
-
-            print("override measured dialysate outlet pump motor controller speed to " + str(spd) + " RPM.")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                #print(received_message)
-                if reset == HD.RESET:
-                    str_res = "reset back to normal.  "
-                else:
-                    str_res = "overridden to " + str(speed) + " RPM.  "
-                print("Dialysate outlet pump MC speed (measured) " + str_res +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-        def CmdDialysateOutletPumpMeasuredCurrentOverride(self, reset, curr):
-            """
-                Constructs and sends the measured dialysate outlet pump motor current override command
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param curr:  float - current (in mA) to override with
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            cur = self.outer_instance.float2ByteArray(curr)
-            payload = rst + cur
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_DIAL_OUT_PUMP_MC_MEAS_CURRENT_OVERRIDE,
-                                                  payload=payload)
-
-            print("override measured dialysate outlet pump motor controller current")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                #print(received_message)
-                if reset == HD.RESET:
-                    str_res = "reset back to normal.  "
-                else:
-                    str_res = "overridden to " + str(curr) + " mA.  "
-                print("Dialysate outlet pump MC current (measured) " + str_res +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-        def CmdDialysateOutletPumpMeasuredSpeedOverride(self, reset, speed):
-            """
-                Constructs and sends the measured dialysate outlet pump motor speed override \n
-                command.
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param speed:  float - speed (in RPM) to override with
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            spd = self.outer_instance.float2ByteArray(speed)
-            payload = rst + spd
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_DIAL_OUT_PUMP_MEAS_SPEED_OVERRIDE,
-                                                  payload=payload)
-
-            print("override measured dialysate outlet pump speed to " + str(speed) + " RPM.")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                #print(received_message)
-                if reset == HD.RESET:
-                    str_res = "reset back to normal.  "
-                else:
-                    str_res = "overridden to " + str(speed) + " RPM.  "
-                print("Dialysate outlet pump speed (measured) " + str_res +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-        def CmdDialysateOutletPumpRotorMeasuredSpeedOverride(self, reset, speed):
-            """
-                Constructs and sends the measured dialysate outlet pump rotor speed override \n
-                command.
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param speed:  float - speed (in RPM) to override with
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            spd = self.outer_instance.float2ByteArray(speed)
-            payload = rst + spd
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_DIAL_OUT_PUMP_ROTOR_MEAS_SPEED_OVERRIDE,
-                                                  payload=payload)
-
-            print("override measured dialysate outlet pump rotor speed to " + str(speed) + " RPM.")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                #print(received_message)
-                if reset == HD.RESET:
-                    str_res = "reset back to normal.  "
-                else:
-                    str_res = "overridden to " + str(speed) + " RPM.  "
-                print("Dialysate outlet pump rotor speed (measured) " + str_res +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-        def CmdDialysateOutletFlowBroadcastIntervalOverride(self, reset, ms):
-            """
-                Constructs and sends the measured dialysate outlet flow broadcast interval override command
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param ms:  integer - interval (in ms) to override with
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            mis = self.outer_instance.integer2ByteArray(ms)
-            payload = rst + mis
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_DIAL_OUT_FLOW_PUBLISH_INTERVAL_OVERRIDE,
-                                                  payload=payload)
-
-            print("override dialysate outlet flow broadcast interval to " + str(ms) + " ms.")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                #print(received_message)
-                if reset == HD.RESET:
-                    str_res = "reset back to normal. "
-                else:
-                    str_res = "overridden to " + str(ms) + " ms.  "
-                print("Dialysate outlet flow broadcast interval " + str_res +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-        def CmdDialysateOutletPumpLoadCellWeightOverride(self, reset, weight, sensor):
-            """
-                Constructs and sends the measured load cell weight override command.
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param weight:  float - weight (in g) to override with
-                \param sensor:  integer - ID of load cell to override
-                \returns 1 if successful, zero otherwise
-
-                \details Load Cells: \n
-                    0 = reservoir 1 primary \n
-                    1 = reservoir 1 backup \n
-                    2 = reservoir 2 primary \n
-                    3 = reservoir 2 backup \n
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            spd = self.outer_instance.float2ByteArray(weight)
-            sen = self.outer_instance.integer2ByteArray(sensor)
-            payload = rst + spd + sen
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_DIAL_OUT_LOAD_CELL_WEIGHT_OVERRIDE,
-                                                  payload=payload)
-
-            print("override measured load cell weight to " + str(weight) + " grams for load cell # " + str(sensor))
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                # print(received_message)
-                if reset == HD.RESET:
-                    str_res = "reset back to normal.  "
-                else:
-                    str_res = "overridden to " + str(weight) + " grams.  "
-                print("Load cell # " + str(sensor) + " " + str_res +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-        def CmdSetLoadCellWeights(self, r1p, r1b, r2p, r2b):
-            """
-                Constructs and sends the set load cell weights command.
-
-                \param r1p:  float - weight (in g) for reservoir 1 primary load cell
-                \param r1b:  float - weight (in g) for reservoir 1 backup load cell
-                \param r2p:  float - weight (in g) for reservoir 2 primary load cell
-                \param r2b:  float - weight (in g) for reservoir 2 backup load cell
-                \returns 0 - no response will come from HD for this message
-            """
-
-            r1pb = self.outer_instance.float2ByteArray(r1p)
-            r1bb = self.outer_instance.float2ByteArray(r1b)
-            r2pb = self.outer_instance.float2ByteArray(r2p)
-            r2bb = self.outer_instance.float2ByteArray(r2b)
-            payload = r1pb + r1bb + r2pb + r2bb
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_LOAD_CELL_READINGS,
-                                                  payload=payload)
-
-            print("measured load cell weights set.")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message, 0)
-
-            return 0
-
-    class HD_Treatment:
-        """
-            \class HD_Treatment
-
-            \brief Hemodialysis Device (HD) Dialin API sub-class for treatment related commands.
-
-        """
-
-        # Treatment message IDs
-        MSG_ID_HD_TREATMENT_TIME_PUBLISHED_DATA = 0x000D
-        MSG_ID_HD_TREATMENT_STATE_PUBLISHED_DATA = 0X000F
-
-        # Treatment time broadcast message field positions
-        START_POS_TIME_PRES = DenaliMessage.PAYLOAD_START_INDEX
-        END_POS_TIME_PRES = START_POS_TIME_PRES + 4
-        START_POS_TIME_ELAPSED = END_POS_TIME_PRES
-        END_POS_TIME_ELAPSED = START_POS_TIME_ELAPSED + 4
-        START_POS_TIME_REMAINING = END_POS_TIME_ELAPSED
-        END_POS_TIME_REMAINING = START_POS_TIME_REMAINING + 4
-
-        # Treatment state broadcast message field positions
-        START_POS_TREATMENT_STATE = DenaliMessage.PAYLOAD_START_INDEX
-        END_POS_TREATMENT_STATE = START_POS_TREATMENT_STATE + 4
-        START_POS_UF_STATE = END_POS_TREATMENT_STATE
-        END_POS_UF_STATE = START_POS_UF_STATE + 4
-        START_POS_SALINE_BOLUS_IN_PROGRESS = END_POS_UF_STATE
-        END_POS_SALINE_BOLUS_IN_PROGRESS = START_POS_SALINE_BOLUS_IN_PROGRESS + 4
-
-        def __init__(self, outer_instance, can_interface=None):
-            """
-                HD_Treatment constructor
-
-                \param outer_instance: reference to the HD (outer) class.
-
-                \returns HD_Treatment object.
-            """
-            self.outer_instance = outer_instance
-
-            if can_interface is not None:
-                channel_id = DenaliChannels.hd_sync_broadcast_ch_id
-                msg_id = self.MSG_ID_HD_TREATMENT_TIME_PUBLISHED_DATA
-                can_interface.register_receiving_publication_function(channel_id, msg_id,
-                                                                      self.handlerTreatmentTimeSyncFunction)
-                msg_id = self.MSG_ID_HD_TREATMENT_STATE_PUBLISHED_DATA
-                can_interface.register_receiving_publication_function(channel_id, msg_id,
-                                                                      self.handlerTreatmentStateSyncFunction)
-
-            self.TreatmentTimePrescribed = 0
-            self.TreatmentTimeElapsed = 0
-            self.TreatmentTimeRemaining = 0
-            self.TreatmentState = 0
-            self.TreatmentUFState = 0
-            self.SalineBolusInProgress = False
-
-        def handlerTreatmentTimeSyncFunction(self, message):
-            """
-                Handles published treatment time data messages.  Treatment time data are captured
-                for reference.
-
-                \param message:  published treatment time data message
-                \returns none
-            """
-
-            tot = struct.unpack('i', bytearray(
-                message['message'][self.START_POS_TIME_PRES:self.END_POS_TIME_PRES]))
-            ela = struct.unpack('i', bytearray(
-                message['message'][self.START_POS_TIME_ELAPSED:self.END_POS_TIME_ELAPSED]))
-            rem = struct.unpack('i', bytearray(
-                message['message'][self.START_POS_TIME_REMAINING:self.END_POS_TIME_REMAINING]))
-
-            self.TreatmentTimePrescribed = tot[0]
-            self.TreatmentTimeElapsed = ela[0]
-            self.TreatmentTimeRemaining = rem[0]
-
-        def handlerTreatmentStateSyncFunction(self, message):
-            """
-                Handles published treatment state data messages.  Treatment state data are captured
-                for reference.
-
-                \param message:  published treatment state data message
-                \returns none
-            """
-
-            tst = struct.unpack('i',bytearray(
-                message['message'][self.START_POS_TREATMENT_STATE:self.END_POS_TREATMENT_STATE]))
-            ufs = struct.unpack('i',bytearray(
-                message['message'][self.START_POS_UF_STATE:self.END_POS_UF_STATE]))
-            bol = struct.unpack('i',bytearray(
-                message['message'][self.START_POS_SALINE_BOLUS_IN_PROGRESS:self.END_POS_SALINE_BOLUS_IN_PROGRESS]))
-
-            self.TreatmentState = tst[0]
-            self.TreatmentUFState = ufs[0]
-            if bol[0] == 1:
-                self.SalineBolusInProgress = True
-            else:
-                self.SalineBolusInProgress = False
-
-    class HD_Pressure_Occlusion:
-        """
-            \class HD_Pressure_Occlusion
-
-            \brief Hemodialysis Device (HD) Dialin API sub-class for pressure related commands.
-
-        """
-
-        # Pressure/Occlusion message IDs
-        MSG_ID_HD_PRESSURE_OCCLUSION_DATA = 0x0009
-        MSG_ID_HD_PRESSURE_ARTERIAL_OVERRIDE = 0x8017
-        MSG_ID_HD_PRESSURE_VENOUS_OVERRIDE = 0x8018
-        MSG_ID_HD_OCCLUSION_BLOOD_PUMP_OVERRIDE = 0x8019
-        MSG_ID_HD_OCCLUSION_DIAL_IN_PUMP_OVERRIDE = 0x801A
-        MSG_ID_HD_OCCLUSION_DIAL_OUT_PUMP_OVERRIDE = 0x801B
-        MSG_ID_HD_PRES_OCCL_SEND_INTERVAL_OVERRIDE = 0x801C
-
-        # Pressure/Occlusion broadcast message field positions
-        START_POS_ART_PRES = DenaliMessage.PAYLOAD_START_INDEX
-        END_POS_ART_PRES = START_POS_ART_PRES + 4
-        START_POS_VEN_PRES = END_POS_ART_PRES
-        END_POS_VEN_PRES = START_POS_VEN_PRES + 4
-        START_POS_BP_OCCL = END_POS_VEN_PRES
-        END_POS_BP_OCCL = START_POS_BP_OCCL + 4
-        START_POS_DIP_OCCL = END_POS_BP_OCCL
-        END_POS_DIP_OCCL = START_POS_DIP_OCCL + 4
-        START_POS_DOP_OCCL = END_POS_DIP_OCCL
-        END_POS_DOP_OCCL = START_POS_DOP_OCCL + 4
-
-        def __init__(self, outer_instance, can_interface=None):
-            """
-                HD_Pressure_Occlusion constructor
-
-                \param outer_instance: reference to the HD (outer) class.
-
-                \returns HD_Pressure_Occlusion object.
-            """
-            self.outer_instance = outer_instance
-
-            if can_interface is not None:
-                channel_id = DenaliChannels.hd_sync_broadcast_ch_id
-                msg_id = self.MSG_ID_HD_PRESSURE_OCCLUSION_DATA
-                can_interface.register_receiving_publication_function(channel_id, msg_id,
-                                                                      self.handlerPresOcclSyncFunction)
-
-            self.arterialPressure = 0
-            self.venousPressure = 0.0
-            self.bloodPumpOcclusion = 0.0
-            self.dialysateInletPumpOcclusion = 0.0
-            self.dialysateOutletPumpOcclusion = 0.0
-
-
-        def handlerPresOcclSyncFunction(self, message):
-            """
-                Handles published pressure & occlusion data messages.  Pressure data are captured
-                for reference.
-
-                \param message:  published pressure & occlusion data message
-                \returns none
-            """
-
-            art = struct.unpack('f', bytearray(
-                message['message'][self.START_POS_ART_PRES:self.END_POS_ART_PRES]))
-            ven = struct.unpack('f', bytearray(
-                message['message'][self.START_POS_VEN_PRES:self.END_POS_VEN_PRES]))
-            bp = struct.unpack('f', bytearray(
-                message['message'][self.START_POS_BP_OCCL:self.END_POS_BP_OCCL]))
-            dpi = struct.unpack('f', bytearray(
-                message['message'][self.START_POS_DIP_OCCL:self.END_POS_DIP_OCCL]))
-            dpo = struct.unpack('f', bytearray(
-                message['message'][self.START_POS_DOP_OCCL:self.END_POS_DOP_OCCL]))
-
-            self.arterialPressure = art[0]
-            self.venousPressure = ven[0]
-            self.bloodPumpOcclusion = bp[0]
-            self.dialysateInletPumpOcclusion = dpi[0]
-            self.dialysateOutletPumpOcclusion = dpo[0]
-
-        def CmdArterialPressureMeasuredOverride(self, reset, pres):
-            """
-                Constructs and sends the measured arterial pressure override command
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param pres:  float - measured arterial pressure (in mmHg) to override with
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            prs = self.outer_instance.float2ByteArray(pres)
-            payload = rst + prs
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_PRESSURE_ARTERIAL_OVERRIDE,
-                                                  payload=payload)
-
-            print("override measured arterial pressure")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                if reset == HD.RESET:
-                    str_res = "reset back to normal.  "
-                else:
-                    str_res = str(pres) + " mmHg.  "
-                print("Arterial pressure (measured)) overridden to " + str_res +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-        # TEST CODE ***************************************
-        # def TestCANMessage(self, seq):
-        #     zero = self.outer_instance.integer2ByteArray(0)
-        #     seq1 = self.outer_instance.integer2ByteArray(seq)
-        #     seq2 = self.outer_instance.integer2ByteArray(seq+1)
-        #     seq3 = self.outer_instance.integer2ByteArray(seq+2)
-        #     seq4 = self.outer_instance.integer2ByteArray(seq+3)
-        #     seq5 = self.outer_instance.integer2ByteArray(seq+4)
-        #
-        #     payload = seq1 + zero + seq2 + zero + seq3 + zero + seq4 + zero + seq5
-        #
-        #     message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-        #                                          message_id=6,
-        #                                          payload=payload)
-        #
-        #     received_message = self.outer_instance.can_interface.send(message, 0)
-        #
-        #     return True
-
-        def CmdVenousPressureMeasuredOverride(self, reset, pres):
-            """
-                Constructs and sends the measured venous pressure \n
-                override command.
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param pres:  float - venous pressure (in mmHg) to override with
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            prs = self.outer_instance.float2ByteArray(pres)
-            payload = rst + prs
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_PRESSURE_VENOUS_OVERRIDE,
-                                                  payload=payload)
-
-            print("override measured venous pressure")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                if reset == HD.RESET:
-                    str_res = "reset back to normal.  "
-                else:
-                    str_res = str(pres) + " mmHg.  "
-                print("Venous pressure (measured) overridden to " + str_res +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-        def CmdBloodPumpMeasuredOcclusionOverride(self, reset, occl):
-            """
-                Constructs and sends the measured blood pump occlusion pressure override command
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param occl:  float - pressure (in mmHg) to override with
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            occ = self.outer_instance.float2ByteArray(occl)
-            payload = rst + occ
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_OCCLUSION_BLOOD_PUMP_OVERRIDE,
-                                                  payload=payload)
-
-            print("override measured blood pump occlusion pressure")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                if reset == HD.RESET:
-                    str_res = "reset back to normal.  "
-                else:
-                    str_res = str(occl) + " mmHg.  "
-                print("Blood pump occlusion pressure (measured) overridden to " + str_res +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-        def CmdDialysateInletPumpMeasuredOcclusionOverride(self, reset, occl):
-            """
-                Constructs and sends the measured dialysate inlet pump occlusion pressure override \n
-                command.
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param occl:  float - pressure (in mmHg) to override with
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            occ = self.outer_instance.float2ByteArray(occl)
-            payload = rst + occ
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_OCCLUSION_DIAL_IN_PUMP_OVERRIDE,
-                                                  payload=payload)
-
-            print("override measured dialysate inlet pump occlusion pressure")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                if reset == HD.RESET:
-                    str_res = "reset back to normal.  "
-                else:
-                    str_res = str(occl) + " mmHg.  "
-                print("Dialysate inlet pump occlusion pressure (measured) overridden to " + str_res +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-        def CmdDialysateOutletPumpMeasuredOcclusionOverride(self, reset, occl):
-            """
-                Constructs and sends the measured dialysate outlet pump occlusion pressure override \n
-                command.
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param occl:  float - pressure (in mmHg) to override with
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            occ = self.outer_instance.float2ByteArray(occl)
-            payload = rst + occ
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_OCCLUSION_DIAL_OUT_PUMP_OVERRIDE,
-                                                  payload=payload)
-
-            print("override measured dialysate outlet pump occlusion pressure")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                if reset == HD.RESET:
-                    str_res = "reset back to normal.  "
-                else:
-                    str_res = str(occl) + " mmHg.  "
-                print("Dialysate outlet pump occlusion pressure (measured) overridden to " + str_res +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-        def CmdPressureOcclusionBroadcastIntervalOverride(self, reset, ms):
-            """
-                Constructs and sends the pressure/occlusion broadcast interval override command
-
-                \param reset:  integer - 1 to reset a previous override, 0 to override
-                \param ms:  integer - interval (in ms) to override with
-                \returns 1 if successful, zero otherwise
-            """
-
-            rst = self.outer_instance.integer2ByteArray(reset)
-            mis = self.outer_instance.integer2ByteArray(ms)
-            payload = rst + mis
-
-            message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
-                                                  message_id=self.MSG_ID_HD_PRES_OCCL_SEND_INTERVAL_OVERRIDE,
-                                                  payload=payload)
-
-            print("override pressure/occlusion broadcast interval")
-
-            # Send message
-            received_message = self.outer_instance.can_interface.send(message)
-
-            # If there is content...
-            if received_message is not None:
-                if reset == HD.RESET:
-                    str_res = "reset back to normal: "
-                else:
-                    str_res = str(ms) + " ms: "
-                print("Pressure/occlusion broadcast interval overridden to " + str_res +
-                      str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
-                # response payload is OK or not OK
-                return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
-            else:
-                print("Timeout!!!!")
-                return False
-
-    def integer2ByteArray(self, val):
-        """
-            Converts an integer value into a byte array (little endian)
-
-            \param val:  integer to convert to byte array
-            \returns byte array
-        """
-        fmt = '%08x'  # integer to hex string formatter
-        b = unhexlify(fmt % val)  # convert int to byte array
-        b = b[::-1]  # little endian byte order
-        return b
-
-    def float2ByteArray(self, val):
-        """
-            Converts a float value into a byte array (little endian)
-
-            \param val:  float to convert to byte array
-            \returns byte array
-        """
-        b = struct.pack('<f', val)
-        return b
-
-
 if __name__ == "__main__":
     # create an HD object called hd
     hd = HD()
@@ -2648,13 +73,17 @@
 
     # wait 2 seconds and then login to HD as a tester
     sleep(2)
-    hd.Basics.CmdLogInToHD()
+    hd.Basics.cmd_log_in_to_hd()
 
-    #hd.RTC.CmdSetRTCTimeAndDate(0, 2, 1, 5, 1, 2020)
+    # FIXME: Delete commented code:
+    # hd.RTC.CmdSetRTCTimeAndDate(0, 2, 1, 5, 1, 2020)
 
     while True:
         print(hd.RTC.RTCEpoch)
         sleep(1)
+
+
+# FIXME: This should either be deleted or moved to a file:
 """"
     hd.BloodFlow.CmdBloodPumpMeasuredCurrentOverride(hd.NO_RESET,149)
     totalVolumeInMl = 2400
Index: HD/PressureOcclusion.py
===================================================================
diff -u
--- HD/PressureOcclusion.py	(revision 0)
+++ HD/PressureOcclusion.py	(revision 082ea4c8b0c6a3c804453308990d0bb98a0a2156)
@@ -0,0 +1,319 @@
+from DialIn.CoreCANProtocol import (DenaliMessage,
+                                    DenaliChannels)
+from .utils import integer2ByteArray, float2ByteArray
+from .HemodialysisDevice import HD
+import struct
+
+
+class HDPressureOcclusion:
+    """
+    \class HDPressureOcclusion
+
+    \brief Hemodialysis Device (HD) Dialin API sub-class for pressure related commands.
+    """
+
+    # Pressure/Occlusion message IDs
+    MSG_ID_HD_PRESSURE_OCCLUSION_DATA = 0x0009
+    MSG_ID_HD_PRESSURE_ARTERIAL_OVERRIDE = 0x8017
+    MSG_ID_HD_PRESSURE_VENOUS_OVERRIDE = 0x8018
+    MSG_ID_HD_OCCLUSION_BLOOD_PUMP_OVERRIDE = 0x8019
+    MSG_ID_HD_OCCLUSION_DIAL_IN_PUMP_OVERRIDE = 0x801A
+    MSG_ID_HD_OCCLUSION_DIAL_OUT_PUMP_OVERRIDE = 0x801B
+    MSG_ID_HD_PRES_OCCL_SEND_INTERVAL_OVERRIDE = 0x801C
+
+    # Pressure/Occlusion broadcast message field positions
+    START_POS_ART_PRES = DenaliMessage.PAYLOAD_START_INDEX
+    END_POS_ART_PRES = START_POS_ART_PRES + 4
+    START_POS_VEN_PRES = END_POS_ART_PRES
+    END_POS_VEN_PRES = START_POS_VEN_PRES + 4
+    START_POS_BP_OCCL = END_POS_VEN_PRES
+    END_POS_BP_OCCL = START_POS_BP_OCCL + 4
+    START_POS_DIP_OCCL = END_POS_BP_OCCL
+    END_POS_DIP_OCCL = START_POS_DIP_OCCL + 4
+    START_POS_DOP_OCCL = END_POS_DIP_OCCL
+    END_POS_DOP_OCCL = START_POS_DOP_OCCL + 4
+
+    def __init__(self, can_interface=None):
+        """
+        HDPressureOcclusion constructor
+
+        \param outer_instance: reference to the HD (outer) class.
+
+        \returns HDPressureOcclusion object.
+        """
+        self.can_interface = can_interface
+
+        if self.can_interface is not None:
+            channel_id = DenaliChannels.hd_sync_broadcast_ch_id
+            msg_id = self.MSG_ID_HD_PRESSURE_OCCLUSION_DATA
+            self.can_interface.register_receiving_publication_function(channel_id, msg_id,
+                                                                  self.handlerPresOcclSyncFunction)
+
+        self.arterialPressure = 0
+        self.venousPressure = 0.0
+        self.bloodPumpOcclusion = 0.0
+        self.dialysateInletPumpOcclusion = 0.0
+        self.dialysateOutletPumpOcclusion = 0.0
+
+    def test_can_message(self, seq):
+        zero = integer2ByteArray(0)
+        seq1 = integer2ByteArray(seq)
+        seq2 = integer2ByteArray(seq+1)
+        seq3 = integer2ByteArray(seq+2)
+        seq4 = integer2ByteArray(seq+3)
+        seq5 = integer2ByteArray(seq+4)
+
+        payload = seq1 + zero + seq2 + zero + seq3 + zero + seq4 + zero + seq5
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=6,
+                                              payload=payload)
+
+        self.can_interface.send(message, 0)
+
+    def handlerPresOcclSyncFunction(self, message):
+        """
+            Handles published pressure & occlusion data messages.  Pressure data are captured
+            for reference.
+
+            \param message:  published pressure & occlusion data message
+            \returns none
+        """
+
+        art = struct.unpack('f', bytearray(
+            message['message'][self.START_POS_ART_PRES:self.END_POS_ART_PRES]))
+        ven = struct.unpack('f', bytearray(
+            message['message'][self.START_POS_VEN_PRES:self.END_POS_VEN_PRES]))
+        bp = struct.unpack('f', bytearray(
+            message['message'][self.START_POS_BP_OCCL:self.END_POS_BP_OCCL]))
+        dpi = struct.unpack('f', bytearray(
+            message['message'][self.START_POS_DIP_OCCL:self.END_POS_DIP_OCCL]))
+        dpo = struct.unpack('f', bytearray(
+            message['message'][self.START_POS_DOP_OCCL:self.END_POS_DOP_OCCL]))
+
+        self.arterialPressure = art[0]
+        self.venousPressure = ven[0]
+        self.bloodPumpOcclusion = bp[0]
+        self.dialysateInletPumpOcclusion = dpi[0]
+        self.dialysateOutletPumpOcclusion = dpo[0]
+
+    def CmdArterialPressureMeasuredOverride(self, reset, pres):
+        """
+        Constructs and sends the measured arterial pressure override command
+
+        \param reset:  integer - 1 to reset a previous override, 0 to override
+        \param pres:  float - measured arterial pressure (in mmHg) to override with
+        \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        prs = float2ByteArray(pres)
+        payload = rst + prs
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_PRESSURE_ARTERIAL_OVERRIDE,
+                                              payload=payload)
+
+        print("override measured arterial pressure")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            if reset == HD.RESET:
+                str_res = "reset back to normal.  "
+            else:
+                str_res = str(pres) + " mmHg.  "
+            print("Arterial pressure (measured)) overridden to " + str_res +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
+
+
+
+    def CmdVenousPressureMeasuredOverride(self, reset, pres):
+        """
+        Constructs and sends the measured venous pressure \n
+        override command.
+
+        \param reset:  integer - 1 to reset a previous override, 0 to override
+        \param pres:  float - venous pressure (in mmHg) to override with
+        \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        prs = float2ByteArray(pres)
+        payload = rst + prs
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_PRESSURE_VENOUS_OVERRIDE,
+                                              payload=payload)
+
+        print("override measured venous pressure")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            if reset == HD.RESET:
+                str_res = "reset back to normal.  "
+            else:
+                str_res = str(pres) + " mmHg.  "
+            print("Venous pressure (measured) overridden to " + str_res +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
+
+    def CmdBloodPumpMeasuredOcclusionOverride(self, reset, occl):
+        """
+            Constructs and sends the measured blood pump occlusion pressure override command
+
+            \param reset:  integer - 1 to reset a previous override, 0 to override
+            \param occl:  float - pressure (in mmHg) to override with
+            \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        occ = float2ByteArray(occl)
+        payload = rst + occ
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_OCCLUSION_BLOOD_PUMP_OVERRIDE,
+                                              payload=payload)
+
+        print("override measured blood pump occlusion pressure")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            if reset == HD.RESET:
+                str_res = "reset back to normal.  "
+            else:
+                str_res = str(occl) + " mmHg.  "
+            print("Blood pump occlusion pressure (measured) overridden to " + str_res +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
+
+    def CmdDialysateInletPumpMeasuredOcclusionOverride(self, reset, occl):
+        """
+        Constructs and sends the measured dialysate inlet pump occlusion pressure override \n
+        command.
+
+        \param reset:  integer - 1 to reset a previous override, 0 to override
+        \param occl:  float - pressure (in mmHg) to override with
+        \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        occ = float2ByteArray(occl)
+        payload = rst + occ
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_OCCLUSION_DIAL_IN_PUMP_OVERRIDE,
+                                              payload=payload)
+
+        print("override measured dialysate inlet pump occlusion pressure")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            if reset == HD.RESET:
+                str_res = "reset back to normal.  "
+            else:
+                str_res = str(occl) + " mmHg.  "
+            print("Dialysate inlet pump occlusion pressure (measured) overridden to " + str_res +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
+
+    def CmdDialysateOutletPumpMeasuredOcclusionOverride(self, reset, occl):
+        """
+        Constructs and sends the measured dialysate outlet pump occlusion pressure override \n
+        command.
+
+        \param reset:  integer - 1 to reset a previous override, 0 to override
+        \param occl:  float - pressure (in mmHg) to override with
+        \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        occ = float2ByteArray(occl)
+        payload = rst + occ
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_OCCLUSION_DIAL_OUT_PUMP_OVERRIDE,
+                                              payload=payload)
+
+        print("override measured dialysate outlet pump occlusion pressure")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            if reset == HD.RESET:
+                str_res = "reset back to normal.  "
+            else:
+                str_res = str(occl) + " mmHg.  "
+            print("Dialysate outlet pump occlusion pressure (measured) overridden to " + str_res +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
+
+    def CmdPressureOcclusionBroadcastIntervalOverride(self, reset, ms):
+        """
+            Constructs and sends the pressure/occlusion broadcast interval override command
+
+            \param reset:  integer - 1 to reset a previous override, 0 to override
+            \param ms:  integer - interval (in ms) to override with
+            \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        mis = integer2ByteArray(ms)
+        payload = rst + mis
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_PRES_OCCL_SEND_INTERVAL_OVERRIDE,
+                                              payload=payload)
+
+        print("override pressure/occlusion broadcast interval")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            if reset == HD.RESET:
+                str_res = "reset back to normal: "
+            else:
+                str_res = str(ms) + " ms: "
+            print("Pressure/occlusion broadcast interval overridden to " + str_res +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
Index: HD/RTC.py
===================================================================
diff -u
--- HD/RTC.py	(revision 0)
+++ HD/RTC.py	(revision 082ea4c8b0c6a3c804453308990d0bb98a0a2156)
@@ -0,0 +1,82 @@
+from DialIn.CoreCANProtocol import (DenaliMessage,
+                                    DenaliChannels)
+from .utils import integer2ByteArray, float2ByteArray
+import ctypes
+
+class HDRTC:
+    """
+        \class HDRTC
+
+        \brief Hemodialysis Device (HD) Dialin API sub-class for RTC commands.
+    """
+
+    MSG_ID_SET_RTC_DATE_TIME = 0x801D
+    MSG_ID_RTC_EPOCH = 0x000A
+
+    START_POS_SET_PT = DenaliMessage.PAYLOAD_START_INDEX
+    END_POS_SET_PT = START_POS_SET_PT + 4
+
+    def __init__(self, outer_instance, can_interface=None):
+        """
+        HD_BloodFlow constructor
+
+        \param outer_instance: reference to the HD (outer) class.
+
+        \returns HD_BloodFlow object.
+        """
+        self.can_interface = can_interface
+
+        if self.can_interface is not None:
+            channel_id = DenaliChannels.hd_sync_broadcast_ch_id
+            msg_id = self.MSG_ID_RTC_EPOCH
+            self.can_interface.register_receiving_publication_function(channel_id, msg_id,
+                                                                  self.handlerRTCEpoch)
+        self.RTCEpoch = 0
+
+    def handlerRTCEpoch(self, message):
+        """
+            Publishes the RTC time in epoch
+
+            \param message:  published RTC epoch message
+            \returns none
+        """
+        epoch = int.from_bytes(bytearray(
+            message['message'][self.START_POS_SET_PT:self.END_POS_SET_PT]),
+            byteorder=DenaliMessage.BYTE_ORDER)
+        self.RTCEpoch = ctypes.c_uint32(epoch)
+
+    def CmdSetRTCTimeAndDate(self, secs, mins, hours, days, months, years):
+        """
+            Constructs and sends the time and date to be written to RTC
+
+            \returns 1 if successful, zero otherwise
+        """
+        sec = bytes([secs])
+        min = bytes([mins])
+        hour = bytes([hours])
+        day = bytes([days])
+        month = bytes([months])
+        year = integer2ByteArray(years)
+        payload = sec + min + hour + day + month + year
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_SET_RTC_DATE_TIME,
+                                              payload=payload)
+
+        print("Setting time and date to RTC")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            print(received_message)
+            # str_res = str(flow)
+            print("Time and Date in RTC set to seconds: " + str(sec) + " minutes: " + str(min) + " hours: " +
+                  str(hour) + " days: " + str(day) + " months: " + str(month) + " years: " + str(year) +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
Index: HD/Treatment.py
===================================================================
diff -u
--- HD/Treatment.py	(revision 0)
+++ HD/Treatment.py	(revision 082ea4c8b0c6a3c804453308990d0bb98a0a2156)
@@ -0,0 +1,97 @@
+from DialIn.CoreCANProtocol import (DenaliMessage,
+                                    DenaliChannels)
+import struct
+
+
+class HDTreatment:
+    """
+    \class HD_Treatment
+
+    \brief Hemodialysis Device (HD) Dialin API sub-class for treatment related commands.
+
+    """
+
+    # Treatment message IDs
+    MSG_ID_HD_TREATMENT_TIME_PUBLISHED_DATA = 0x000D
+    MSG_ID_HD_TREATMENT_STATE_PUBLISHED_DATA = 0X000F
+
+    # Treatment time broadcast message field positions
+    START_POS_TIME_PRES = DenaliMessage.PAYLOAD_START_INDEX
+    END_POS_TIME_PRES = START_POS_TIME_PRES + 4
+    START_POS_TIME_ELAPSED = END_POS_TIME_PRES
+    END_POS_TIME_ELAPSED = START_POS_TIME_ELAPSED + 4
+    START_POS_TIME_REMAINING = END_POS_TIME_ELAPSED
+    END_POS_TIME_REMAINING = START_POS_TIME_REMAINING + 4
+
+    # Treatment state broadcast message field positions
+    START_POS_TREATMENT_STATE = DenaliMessage.PAYLOAD_START_INDEX
+    END_POS_TREATMENT_STATE = START_POS_TREATMENT_STATE + 4
+    START_POS_UF_STATE = END_POS_TREATMENT_STATE
+    END_POS_UF_STATE = START_POS_UF_STATE + 4
+    START_POS_SALINE_BOLUS_IN_PROGRESS = END_POS_UF_STATE
+    END_POS_SALINE_BOLUS_IN_PROGRESS = START_POS_SALINE_BOLUS_IN_PROGRESS + 4
+
+    def __init__(self, can_interface=None):
+        """
+        HD_Treatment constructor
+        """
+        self.can_interface = can_interface
+
+        if self.can_interface is not None:
+            channel_id = DenaliChannels.hd_sync_broadcast_ch_id
+            msg_id = self.MSG_ID_HD_TREATMENT_TIME_PUBLISHED_DATA
+            self.can_interface.register_receiving_publication_function(channel_id, msg_id,
+                                                                  self.handlerTreatmentTimeSyncFunction)
+            msg_id = self.MSG_ID_HD_TREATMENT_STATE_PUBLISHED_DATA
+            self.can_interface.register_receiving_publication_function(channel_id, msg_id,
+                                                                  self.handlerTreatmentStateSyncFunction)
+
+        self.TreatmentTimePrescribed = 0
+        self.TreatmentTimeElapsed = 0
+        self.TreatmentTimeRemaining = 0
+        self.TreatmentState = 0
+        self.TreatmentUFState = 0
+        self.SalineBolusInProgress = False
+
+    def handlerTreatmentTimeSyncFunction(self, message):
+        """
+            Handles published treatment time data messages.  Treatment time data are captured
+            for reference.
+
+            \param message:  published treatment time data message
+            \returns none
+        """
+
+        tot = struct.unpack('i', bytearray(
+            message['message'][self.START_POS_TIME_PRES:self.END_POS_TIME_PRES]))
+        ela = struct.unpack('i', bytearray(
+            message['message'][self.START_POS_TIME_ELAPSED:self.END_POS_TIME_ELAPSED]))
+        rem = struct.unpack('i', bytearray(
+            message['message'][self.START_POS_TIME_REMAINING:self.END_POS_TIME_REMAINING]))
+
+        self.TreatmentTimePrescribed = tot[0]
+        self.TreatmentTimeElapsed = ela[0]
+        self.TreatmentTimeRemaining = rem[0]
+
+    def handlerTreatmentStateSyncFunction(self, message):
+        """
+            Handles published treatment state data messages.  Treatment state data are captured
+            for reference.
+
+            \param message:  published treatment state data message
+            \returns none
+        """
+
+        tst = struct.unpack('i', bytearray(
+            message['message'][self.START_POS_TREATMENT_STATE:self.END_POS_TREATMENT_STATE]))
+        ufs = struct.unpack('i', bytearray(
+            message['message'][self.START_POS_UF_STATE:self.END_POS_UF_STATE]))
+        bol = struct.unpack('i', bytearray(
+            message['message'][self.START_POS_SALINE_BOLUS_IN_PROGRESS:self.END_POS_SALINE_BOLUS_IN_PROGRESS]))
+
+        self.TreatmentState = tst[0]
+        self.TreatmentUFState = ufs[0]
+        if bol[0] == 1:
+            self.SalineBolusInProgress = True
+        else:
+            self.SalineBolusInProgress = False
Index: HD/UI.py
===================================================================
diff -u
--- HD/UI.py	(revision 0)
+++ HD/UI.py	(revision 082ea4c8b0c6a3c804453308990d0bb98a0a2156)
@@ -0,0 +1,424 @@
+from DialIn.CoreCANProtocol import (DenaliMessage,
+                                    DenaliChannels)
+from .utils import integer2ByteArray, float2ByteArray
+import struct
+
+
+class HDUI:
+    """
+    \class HD_UI
+
+    \brief Hemodialysis Device (HD) Dialin API sub-class for UI commands.
+    """
+
+    # UI message IDs
+    MSG_ID_UI_CHECKIN_WITH_HD = 0x0007
+    MSG_ID_HD_UF_PAUSE_RESUME_REQUEST = 0x0010
+    MSG_ID_HD_TREATMENT_PARAMS_RANGES = 0x001A
+    MSG_ID_UF_SETTINGS_CHANGE_REQUEST_BY_USER = 0x0011
+    MSG_ID_UF_SETTINGS_CHANGE_RESPONSE_FROM_HD = 0x0013
+    MSG_ID_UF_SETTINGS_CHANGE_CONFIRMED_BY_USER = 0x0015
+    MSG_ID_TREATMENT_DURATION_SETTING_CHANGE_REQUEST = 0x0016
+    MSG_ID_TREATMENT_DURATION_SETTING_CHANGE_RESPONSE_FROM_HD = 0x001B
+    MSG_ID_BLOOD_DIALYSATE_FLOW_SETTING_CHANGE_REQUEST_BY_USER = 0x0017
+    MSG_ID_BLOOD_DIALYSATE_FLOW_SETTING_CHANGE_RESPONSE_FROM_HD = 0x0018
+
+    LITER_TO_ML_CONVERSION_FACTOR = 1000.0
+    UF_CMD_PAUSE = 0
+    UF_CMD_RESUME = 1
+    UF_CMD_CHANGE_TIME_TO_ADJUST = 0
+    UF_CMD_CHANGE_RATE_TO_ADJUST = 1
+    RESPONSE_REJECTED = 0
+    RESPONSE_ACCEPTED = 1
+
+    # HD update on valid treatment parameter ranges message field positions
+    START_POS_MIN_TREAT_TIME = DenaliMessage.PAYLOAD_START_INDEX
+    END_POS_MIN_TREAT_TIME = START_POS_MIN_TREAT_TIME + 4
+    START_POS_MAX_TREAT_TIME = END_POS_MIN_TREAT_TIME
+    END_POS_MAX_TREAT_TIME = START_POS_MAX_TREAT_TIME + 4
+    START_POS_MIN_UF_VOL = END_POS_MAX_TREAT_TIME
+    END_POS_MIN_UF_VOL = START_POS_MIN_UF_VOL + 4
+    START_POS_MAX_UF_VOL = END_POS_MIN_UF_VOL
+    END_POS_MAX_UF_VOL = START_POS_MAX_UF_VOL + 4
+    START_POS_MIN_DIAL_RATE = END_POS_MAX_UF_VOL
+    END_POS_MIN_DIAL_RATE = START_POS_MIN_DIAL_RATE + 4
+    START_POS_MAX_DIAL_RATE = END_POS_MIN_DIAL_RATE
+    END_POS_MAX_DIAL_RATE = START_POS_MAX_DIAL_RATE + 4
+
+    # HD response to treatment duration change request message field positions
+    START_POS_TIME_CHG_RSP_ACCEPTED = DenaliMessage.PAYLOAD_START_INDEX
+    END_POS_TIME_CHG_RSP_ACCEPTED = START_POS_TIME_CHG_RSP_ACCEPTED + 4
+    START_POS_TIME_CHG_RSP_REASON = END_POS_TIME_CHG_RSP_ACCEPTED
+    END_POS_TIME_CHG_RSP_REASON = START_POS_TIME_CHG_RSP_REASON + 4
+    START_POS_TIME_CHG_RSP_TIME = END_POS_TIME_CHG_RSP_REASON
+    END_POS_TIME_CHG_RSP_TIME = START_POS_TIME_CHG_RSP_TIME + 4
+    START_POS_TIME_CHG_RSP_UF_VOL = END_POS_TIME_CHG_RSP_TIME
+    END_POS_TIME_CHG_RSP_UF_VOL = START_POS_TIME_CHG_RSP_UF_VOL + 4
+
+    # HD response to UF volume change request message field positions
+    START_POS_UF_CHG_RSP_RESP = DenaliMessage.PAYLOAD_START_INDEX
+    END_POS_UF_CHG_RSP_RESP = START_POS_UF_CHG_RSP_RESP + 4
+    START_POS_UF_CHG_RSP_REJECT_REASON = END_POS_UF_CHG_RSP_RESP
+    END_POS_UF_CHG_RSP_REJECT_REASON = START_POS_UF_CHG_RSP_REJECT_REASON + 4
+    START_POS_UF_CHG_RSP_VOL = END_POS_UF_CHG_RSP_RESP
+    END_POS_UF_CHG_RSP_VOL = START_POS_UF_CHG_RSP_VOL + 4
+    START_POS_UF_CHG_RSP_TIME = END_POS_UF_CHG_RSP_VOL
+    END_POS_UF_CHG_RSP_TIME = START_POS_UF_CHG_RSP_TIME + 4
+    START_POS_UF_CHG_RSP_TIME_DIFF = END_POS_UF_CHG_RSP_TIME
+    END_POS_UF_CHG_RSP_TIME_DIFF = START_POS_UF_CHG_RSP_TIME_DIFF + 4
+    START_POS_UF_CHG_RSP_RATE = END_POS_UF_CHG_RSP_TIME_DIFF
+    END_POS_UF_CHG_RSP_RATE = START_POS_UF_CHG_RSP_RATE + 4
+    START_POS_UF_CHG_RSP_RATE_DIFF = END_POS_UF_CHG_RSP_RATE
+    END_POS_UF_CHG_RSP_RATE_DIFF = START_POS_UF_CHG_RSP_RATE_DIFF + 4
+
+    # HD response to blood/dialysate flow change request message field positions
+    START_POS_BLD_DIAL_CHG_RSP_ACCEPTED = DenaliMessage.PAYLOAD_START_INDEX
+    END_POS_BLD_DIAL_CHG_RSP_ACCEPTED = START_POS_BLD_DIAL_CHG_RSP_ACCEPTED + 4
+    START_POS_BLD_DIAL_CHG_RSP_REASON = END_POS_BLD_DIAL_CHG_RSP_ACCEPTED
+    END_POS_BLD_DIAL_CHG_RSP_REASON = START_POS_BLD_DIAL_CHG_RSP_REASON + 4
+    START_POS_BLD_DIAL_CHG_RSP_BLD_RATE = END_POS_BLD_DIAL_CHG_RSP_REASON
+    END_POS_BLD_DIAL_CHG_RSP_BLD_RATE = START_POS_BLD_DIAL_CHG_RSP_BLD_RATE + 4
+    START_POS_BLD_DIAL_CHG_RSP_DIAL_RATE = END_POS_BLD_DIAL_CHG_RSP_BLD_RATE
+    END_POS_BLD_DIAL_CHG_RSP_DIAL_RATE = START_POS_BLD_DIAL_CHG_RSP_DIAL_RATE + 4
+
+    def __init__(self, can_interface):
+        """
+        HD_UI constructor
+
+        \param can_interface: the denali can interface object
+        """
+        self.can_interface = can_interface
+
+        # register function to handle HD response to UF change requests
+        if self.can_interface is not None:
+            channel_id = DenaliChannels.hd_to_ui_ch_id
+            self.can_interface.register_receiving_publication_function(channel_id,
+                                                                  self.MSG_ID_UF_SETTINGS_CHANGE_RESPONSE_FROM_HD,
+                                                                  self.handler_uf_change_response)
+            self.can_interface.register_receiving_publication_function(channel_id,
+                                                                  self.MSG_ID_TREATMENT_DURATION_SETTING_CHANGE_RESPONSE_FROM_HD,
+                                                                  self.handler_treatment_duration_change_response)
+            self.can_interface.register_receiving_publication_function(channel_id,
+                                                                  self.MSG_ID_BLOOD_DIALYSATE_FLOW_SETTING_CHANGE_RESPONSE_FROM_HD,
+                                                                  self.handler_blood_and_dialysate_change_response)
+            self.can_interface.register_receiving_publication_function(channel_id, self.MSG_ID_HD_TREATMENT_PARAMS_RANGES,
+                                                                  self.handler_treatment_param_ranges)
+
+        # initialize variables that will be populated by treatment parameter ranges message
+        self.MinTreatmentDurationMin = 0
+        self.MaxTreatmentDurationMin = 0
+        self.MinUFVolumeMl = 0
+        self.MaxUFVolumeMl = 0
+        self.MinDialysateFlowRateMlMin = 0
+        self.MaxDialysateFlowRateMlMin = 0
+        # initialize variables that will be populated by response from HD to treatment duration change request
+        self.DurationChangeSucceeded = False
+        self.DurationChangeRejectReason = 0
+        self.DurationChangeTimeMin = 0
+        self.DurationChangeUFVolMl = 0
+        # initialize variables that will be populated by response from HD to UF change request
+        self.UFChangeSucceeded = False
+        self.UFChangeRejectReason = 0
+        self.UFChangeVolumeMl = 0
+        self.UFChangeTimeMin = 0
+        self.UFChangeRateMlMin = 0.0
+        self.UFChangeTimeDiff = 0
+        self.UFChangeRateDiff = 0.0
+        # initialize variables that will be populated by response from HD to blood & dialysate flow rate change request
+        self.BloodAndDialysateFlowRateChangeSucceeded = False
+        self.BloodAndDialysateFlowRateChangeRejectReason = 0
+        self.TargetBloodFlowRate = 0
+        self.TargetDialysateFlowRate = 0
+
+    def handler_treatment_param_ranges(self, message):
+        """
+        Handler for response from HD regarding valid treatment parameter ranges.
+
+        \param message:  response message from HD regarding valid treatment parameter ranges.\n
+            U32  Minimum treatment duration setting (in min.). \n
+            U32  Maximum treatment duration setting (in min.). \n
+            U32  Minimum ultrafiltration volume (in mL). \n
+            U32  Maximum ultrafiltration volume (in mL). \n
+            U32  Minimum dialysate flow rate (in mL/min). \n
+            U32  Maximum dialysate flow rate (in mL/min).
+
+        \returns none
+        """
+        minTime = struct.unpack('i', bytearray(
+            message['message'][self.START_POS_MIN_TREAT_TIME:self.END_POS_MIN_TREAT_TIME]))
+        maxTime = struct.unpack('i', bytearray(
+            message['message'][self.START_POS_MAX_TREAT_TIME:self.END_POS_MAX_TREAT_TIME]))
+        minUFVol = struct.unpack('i', bytearray(
+            message['message'][self.START_POS_MIN_UF_VOL:self.END_POS_MIN_UF_VOL]))
+        maxUFVol = struct.unpack('i', bytearray(
+            message['message'][self.START_POS_MAX_UF_VOL:self.END_POS_MAX_UF_VOL]))
+        minDialRt = struct.unpack('i', bytearray(
+            message['message'][self.START_POS_MIN_DIAL_RATE:self.END_POS_MIN_DIAL_RATE]))
+        maxDialRt = struct.unpack('i', bytearray(
+            message['message'][self.START_POS_MAX_DIAL_RATE:self.END_POS_MAX_DIAL_RATE]))
+
+        self.MinTreatmentDurationMin = minTime[0]
+        self.MaxTreatmentDurationMin = maxTime[0]
+        self.MinUFVolumeMl = minUFVol[0]
+        self.MaxUFVolumeMl = maxUFVol[0]
+        self.MinDialysateFlowRateMlMin = minDialRt[0]
+        self.MaxDialysateFlowRateMlMin = maxDialRt[0]
+
+    def handler_treatment_duration_change_response(self, message):
+        """
+        Handler for response from HD regarding treatment duration change request.
+
+        \param message:  response message from HD regarding treatment duration change.\n
+            BOOL Accepted \n
+            U32  Reject reason (if not accepted) \n
+            U32  Treatment duration (min) \n
+            U32  UF volue (mL) \n
+
+        \returns none
+        """
+        rsp = struct.unpack('i', bytearray(
+            message['message'][self.START_POS_TIME_CHG_RSP_ACCEPTED:self.END_POS_TIME_CHG_RSP_ACCEPTED]))
+        rea = struct.unpack('i', bytearray(
+            message['message'][self.START_POS_TIME_CHG_RSP_REASON:self.END_POS_TIME_CHG_RSP_REASON]))
+        tim = struct.unpack('i', bytearray(
+            message['message'][self.START_POS_TIME_CHG_RSP_TIME:self.END_POS_TIME_CHG_RSP_TIME]))
+        vol = struct.unpack('i', bytearray(
+            message['message'][self.START_POS_TIME_CHG_RSP_UF_VOL:self.END_POS_TIME_CHG_RSP_UF_VOL]))
+
+        self.DurationChangeSucceeded = rsp[0]
+        self.DurationChangeRejectReason = rea[0]
+        self.DurationChangeTimeMin = tim[0]
+        self.DurationChangeUFVolMl = vol[0]
+
+    def handler_blood_and_dialysate_change_response(self, message):
+        """
+        Handler for response from HD regarding blood & dialysate flow rate change request.
+
+        \param message:  response message from HD regarding requested blood & dialysate flow rate settings change.\n
+            BOOL Accepted \n
+            U32  Reject reason (if not accepted) \n
+            U32  Blood flow rate (mL/min) \n
+            U32  Dialysate flow rate (mL/min) \n
+
+        \returns none
+        """
+        rsp = struct.unpack('i', bytearray(
+            message['message'][self.START_POS_BLD_DIAL_CHG_RSP_ACCEPTED:self.END_POS_BLD_DIAL_CHG_RSP_ACCEPTED]))
+        rea = struct.unpack('i', bytearray(
+            message['message'][self.START_POS_BLD_DIAL_CHG_RSP_REASON:self.END_POS_BLD_DIAL_CHG_RSP_REASON]))
+        bld = struct.unpack('i', bytearray(
+            message['message'][self.START_POS_BLD_DIAL_CHG_RSP_BLD_RATE:self.END_POS_BLD_DIAL_CHG_RSP_BLD_RATE]))
+        dil = struct.unpack('i', bytearray(
+            message['message'][self.START_POS_BLD_DIAL_CHG_RSP_DIAL_RATE:self.END_POS_BLD_DIAL_CHG_RSP_DIAL_RATE]))
+
+        if rsp[0] == self.RESPONSE_REJECTED:
+            resp = False
+        else:
+            resp = True
+        self.BloodAndDialysateFlowRateChangeSucceeded = resp
+        self.BloodAndDialysateFlowRateChangeRejectReason = rea[0]
+        self.TargetBloodFlowRate = bld[0]
+        self.TargetDialysateFlowRate = dil[0]
+
+    def handler_uf_change_response(self, message):
+        """
+        Handler for response from HD regarding UF change request.
+
+        \param message:  response message from HD regarding requested ultrafiltration settings change.\n
+            BOOL Accepted \n
+            U32  RejectReason (if not accepted)
+            F32  UF Volume (mL) - converted to Liters \n
+            U32  Treatment Time (min) \n
+            S32  Treatment Time Change (min) \n
+            F32  UF Rate (mL/min) \n
+            F32  UF Rate Change (mL/min)
+
+        \returns none
+        """
+        rsp = struct.unpack('i', bytearray(
+            message['message'][self.START_POS_UF_CHG_RSP_RESP:self.END_POS_UF_CHG_RSP_RESP]))
+        rea = struct.unpack('i', bytearray(
+            message['message'][self.START_POS_UF_CHG_RSP_REJECT_REASON:self.END_POS_UF_CHG_RSP_REJECT_REASON]))
+        vol = struct.unpack('f', bytearray(
+            message['message'][self.START_POS_UF_CHG_RSP_VOL:self.END_POS_UF_CHG_RSP_VOL]))
+        tim = struct.unpack('i', bytearray(
+            message['message'][self.START_POS_UF_CHG_RSP_TIME:self.END_POS_UF_CHG_RSP_TIME]))
+        tmd = struct.unpack('i', bytearray(
+            message['message'][self.START_POS_UF_CHG_RSP_TIME_DIFF:self.END_POS_UF_CHG_RSP_TIME_DIFF]))
+        rat = struct.unpack('f', bytearray(
+            message['message'][self.START_POS_UF_CHG_RSP_RATE:self.END_POS_UF_CHG_RSP_RATE]))
+        rtd = struct.unpack('f', bytearray(
+            message['message'][self.START_POS_UF_CHG_RSP_RATE_DIFF:self.END_POS_UF_CHG_RSP_RATE_DIFF]))
+
+        if rsp[0] == self.RESPONSE_REJECTED:
+            resp = False
+        else:
+            resp = True
+        self.UFChangeSucceeded = resp
+        self.UFChangeRejectReason = rea[0]
+        self.UFChangeVolumeL = vol[0] / self.LITER_TO_ML_CONVERSION_FACTOR
+        self.UFChangeTimeMin = tim[0]
+        self.UFChangeTimeDiff = tmd[0]
+        self.UFChangeRateMlMin = rat[0]
+        self.UFChangeRateDifff = rtd[0]
+
+    def cmd_ui_checkin_with_hd(self):
+        """
+        Constructs and sends the UI check-in message
+
+        \returns 0
+        """
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_UI_CHECKIN_WITH_HD)
+
+        print("Sending UI checkin w/ HD")
+
+        self.can_interface.send(message, 0)
+
+        return 0
+
+    def cmd_ui_uf_pause_resume(self, cmd=UF_CMD_PAUSE):
+        """
+        Constructs and sends a UI UF command message
+
+        \param cmd: 0 for pause, 1 for resume
+
+        \returns none
+        """
+
+        payload = integer2ByteArray(cmd)
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_UF_PAUSE_RESUME_REQUEST,
+                                              payload=payload)
+
+        if cmd == self.UF_CMD_PAUSE:
+            str_cmd = "pause"
+        else:
+            str_cmd = "resume"
+        print("Sending UF " + str_cmd + " command.")
+
+        self.can_interface.send(message, 0)
+
+        return 0
+
+    def cmd_ui_uf_settings_change_request(self, vol=0.0):
+        """
+        Constructs and sends a UI UF change settings command message
+
+        \param vol (float): new ultrafiltration volume setting (in L)
+
+        \returns none
+        """
+
+        # reset response to this command so we can tell when response is received
+        self.UFChangeResponse = None
+        # build command message
+        volume = float2ByteArray(vol * self.LITER_TO_ML_CONVERSION_FACTOR)
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_UF_SETTINGS_CHANGE_REQUEST_BY_USER,
+                                              payload=volume)
+
+        print("Sending UF settings change request.")
+
+        self.can_interface.send(message, 0)
+
+        return 0
+
+    def cmd_ui_uf_settings_change_confirm(self, vol=0.0, adj=UF_CMD_CHANGE_TIME_TO_ADJUST):
+        """
+        Constructs and sends a UI UF change settings command message
+
+        \param vol (float): new ultrafiltration volume setting (in L)
+        \param adj (int): 0 for adjust time, 1 for adjust rate
+
+        \returns none
+        """
+
+        # reset response to this command so we can tell when response is received
+        self.UFChangeResponse = None
+
+        # build command message
+        volume = float2ByteArray(vol * self.LITER_TO_ML_CONVERSION_FACTOR)
+        adjust = integer2ByteArray(adj)
+        payload = volume + adjust
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_UF_SETTINGS_CHANGE_REQUEST_BY_USER,
+                                              payload=payload)
+
+        print("Sending UF settings change request.")
+
+        self.can_interface.send(message, 0)
+
+        return 0
+
+    def cmd_ui_uf_change_settings_confirmed_by_user(self, response=RESPONSE_REJECTED, vol=0.0, tm=0, rate=0.0):
+        """
+        Constructs and sends a UI UF change settings confirmed by user message
+
+        \param response (int): 0 for rejected, 1 for confirmed
+        \param vol (float): volume (in L) that was confirmed
+        \param tm (int): treatment time (in min) that was confirmed
+        \param rate (float): ultrafiltration rate (in mL/min) that was confirmed
+
+        \returns none
+        """
+
+        resp = integer2ByteArray(response)
+        volume = float2ByteArray(vol * self.LITER_TO_ML_CONVERSION_FACTOR)
+        min = integer2ByteArray(tm)
+        ufRate = float2ByteArray(rate)
+        payload = resp + volume + min + ufRate
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_UF_SETTINGS_CHANGE_CONFIRMED_BY_USER,
+                                              payload=payload)
+
+        print("Sending UF settings change confirmation.")
+
+        self.can_interface.send(message, 0)
+
+        return 0
+
+    def cmd_ui_treatment_duration_setting_change_request(self, timeMin=0):
+        """
+            Constructs and sends a UI UF change settings confirmed by user message
+
+            \param timeMin (int): treatment time (in min).
+
+            \returns none
+        """
+
+        payload = integer2ByteArray(timeMin)
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_TREATMENT_DURATION_SETTING_CHANGE_REQUEST,
+                                              payload=payload)
+
+        print("Sending treatment duration setting change request.")
+
+        # Send message
+        self.can_interface.send(message, 0)
+
+        return 0
+
+    def cmd_ui_blood_and_dialysate_flow_settings_change_request(self, bloodFlow, dialFlow):
+        """
+        Constructs and sends a UI blood & dialysate flow settings change request by user message
+
+        \param bloodFlow (int): blood flow rate set point (in mL/min).
+        \param dialFlow (int): dialysate flow rate set point (in mL/min).
+
+        \returns none
+        """
+
+        bld = integer2ByteArray(bloodFlow)
+        dial = integer2ByteArray(dialFlow)
+        payload = bld + dial
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_BLOOD_DIALYSATE_FLOW_SETTING_CHANGE_REQUEST_BY_USER,
+                                              payload=payload)
+
+        print("Sending blood & dialysate flow rate settings change request.")
+
+        self.can_interface.send(message, 0)
+
+        return 0
Index: HD/Watchdog.py
===================================================================
diff -u
--- HD/Watchdog.py	(revision 0)
+++ HD/Watchdog.py	(revision 082ea4c8b0c6a3c804453308990d0bb98a0a2156)
@@ -0,0 +1,64 @@
+from DialIn.CoreCANProtocol import (DenaliMessage,
+                                    DenaliChannels)
+from .utils import integer2ByteArray, float2ByteArray
+from .HemodialysisDevice import HD
+
+class HDWatchdog:
+    """
+        \class HD_Watchdog
+
+        \brief Hemodialysis Device (HD) Dialin API sub-class for watchdog related commands.
+    """
+
+    # Watchdog message IDs
+    MSG_ID_HD_WD_CHECKIN_OVERRIDE = 0x8005
+
+    def __init__(self, can_interface):
+
+        """
+        HD_Watchdog constructor
+
+        \param outer_instance: reference to the HD (outer) class.
+
+        \returns HD_Watchdog object.
+        """
+        self.can_interface = can_interface
+
+    def CmdWatchdogTaskCheckinOverride(self, reset, state, task):
+        """
+        Constructs and sends the watchdog task check-in override command
+
+        \param reset:  integer - 1 to reset a previous override, 0 to override
+        \param state:  integer - 1 for task checked in, 0 for task not checked in
+        \param task:  integer - ID of task to override
+        \returns 1 if successful, zero otherwise
+        """
+
+        rst = integer2ByteArray(reset)
+        sta = integer2ByteArray(state)
+        tsk = integer2ByteArray(task)
+        payload = rst + sta + tsk
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id,
+                                              message_id=self.MSG_ID_HD_WD_CHECKIN_OVERRIDE,
+                                              payload=payload)
+
+        print("override watchdog task check-in state")
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            # print(received_message)
+            if reset == HD.RESET:
+                str_res = "reset back to normal"
+            else:
+                str_res = ("checked in" if state != 0 else "not checked in")
+            print("Watchdog task check-in overridden to " + str_res + ":" +
+                  str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]))
+            # response payload is OK or not OK
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            print("Timeout!!!!")
+            return False
Index: HD/utils.py
===================================================================
diff -u
--- HD/utils.py	(revision 0)
+++ HD/utils.py	(revision 082ea4c8b0c6a3c804453308990d0bb98a0a2156)
@@ -0,0 +1,25 @@
+import struct
+from binascii import unhexlify
+
+def integer2ByteArray(val):
+    """
+    Converts an integer value into a byte array (little endian)
+
+    \param val:  integer to convert to byte array
+    \returns byte array
+    """
+    fmt = '%08x'  # integer to hex string formatter
+    b = unhexlify(fmt % val)  # convert int to byte array
+    b = b[::-1]  # little endian byte order
+    return b
+
+
+def float2ByteArray(val):
+    """
+    Converts a float value into a byte array (little endian)
+
+    \param val:  float to convert to byte array
+    \returns byte array
+    """
+    b = struct.pack('<f', val)
+    return b