Index: HemodialysisDevice.py =================================================================== diff -u -rf2b88894a458d9e03a9cb005af02ef16fd5e6f32 -r02d0551b15b9bd9824b83041d2d8ce11367872c8 --- HemodialysisDevice.py (.../HemodialysisDevice.py) (revision f2b88894a458d9e03a9cb005af02ef16fd5e6f32) +++ HemodialysisDevice.py (.../HemodialysisDevice.py) (revision 02d0551b15b9bd9824b83041d2d8ce11367872c8) @@ -14,8 +14,8 @@ # ############################################################################ -from DialityCoreCanProtocol import DialinCanMessenger -from DialityCoreCanProtocol import DialinMessage +from DialityCoreCanProtocol import DenaliCanMessenger +from DialityCoreCanProtocol import DenaliMessage from time import sleep from binascii import unhexlify import struct @@ -43,7 +43,7 @@ hd_object = HD('can0') """ # Create listener - self.can_interface = DialinCanMessenger(can_interface=can__interface) + self.can_interface = DenaliCanMessenger(can_interface=can__interface) self.can_interface.start() # Create command groups self._Basics = HD.HD__Basics(self) @@ -86,7 +86,7 @@ request_id = 0x8000 cargo = b'123' - message = DialinMessage.buildMessage(message_id=request_id, payload=cargo) + message = DenaliMessage.buildMessage(message_id=request_id, payload=cargo) print("login") @@ -117,7 +117,7 @@ request_id = 0x8001 cargo = msg - message = DialinMessage.buildMessage(message_id=request_id, payload=cargo) + message = DenaliMessage.buildMessage(message_id=request_id, payload=cargo) print("insert HD message") @@ -172,7 +172,7 @@ sta = self.outer_instance.integer2ByteArray(state) cargo = rst + sta - message = DialinMessage.buildMessage(message_id=request_id, payload=cargo) + message = DenaliMessage.buildMessage(message_id=request_id, payload=cargo) print("override off button") @@ -211,7 +211,7 @@ sta = self.outer_instance.integer2ByteArray(state) cargo = rst + sta - message = DialinMessage.buildMessage(message_id=request_id, payload=cargo) + message = DenaliMessage.buildMessage(message_id=request_id, payload=cargo) print("override stop button") @@ -270,7 +270,7 @@ tsk = self.outer_instance.integer2ByteArray(task) cargo = rst + sta + tsk - message = DialinMessage.buildMessage(message_id=request_id, payload=cargo) + message = DenaliMessage.buildMessage(message_id=request_id, payload=cargo) print("override watchdog task check-in state") @@ -327,7 +327,7 @@ alm = self.outer_instance.integer2ByteArray(alarm) cargo = rst + sta + alm - message = DialinMessage.buildMessage(message_id=request_id, payload=cargo) + message = DenaliMessage.buildMessage(message_id=request_id, payload=cargo) print("override alarm state") @@ -368,7 +368,7 @@ alm = self.outer_instance.integer2ByteArray(alarm) cargo = rst + ms + alm - message = DialinMessage.buildMessage(message_id=request_id, payload=cargo) + message = DenaliMessage.buildMessage(message_id=request_id, payload=cargo) print("override alarm time since activated") @@ -416,7 +416,7 @@ pat = self.__integer2ByteArray(pattern) cargo = rst + pat - message = DialinMessage.buildMessage(message_id=request_id, payload=cargo) + message = DenaliMessage.buildMessage(message_id=request_id, payload=cargo) print("override alarm lamp pattern") @@ -505,7 +505,7 @@ flo = self.outer_instance.integer2ByteArray(flow) cargo = rst + flo - message = DialinMessage.buildMessage(message_id=request_id, payload=cargo) + message = DenaliMessage.buildMessage(message_id=request_id, payload=cargo) print("override blood flow set point") @@ -544,7 +544,7 @@ flo = self.outer_instance.integer2ByteArray(flow) cargo = rst + flo - message = DialinMessage.buildMessage(message_id=request_id, payload=cargo) + message = DenaliMessage.buildMessage(message_id=request_id, payload=cargo) print("override measured blood flow") @@ -587,7 +587,7 @@ spd = self.outer_instance.integer2ByteArray(speed) cargo = rst + spd - message = DialinMessage.buildMessage(message_id=request_id, payload=cargo) + message = DenaliMessage.buildMessage(message_id=request_id, payload=cargo) print("override measured blood pump speed") @@ -626,7 +626,7 @@ cur = self.outer_instance.integer2ByteArray(curr) cargo = rst + cur - message = DialinMessage.buildMessage(message_id=request_id, payload=cargo) + message = DenaliMessage.buildMessage(message_id=request_id, payload=cargo) print("override measured blood pump motor current") @@ -665,7 +665,7 @@ mis = self.outer_instance.integer2ByteArray(ms) cargo = rst + mis - message = DialinMessage.buildMessage(message_id=request_id, payload=cargo) + message = DenaliMessage.buildMessage(message_id=request_id, payload=cargo) print("override blood flow broadcast interval") @@ -712,3 +712,18 @@ # wait 2 seconds and then login to HD as a tester sleep(2) hd._Basics.CmdLogInToHD() + + tgtRate = 0 + hd.BloodFlow.CmdBloodFlowBroadcastIntervalOverride(hd.NO_RESET, 2000) + + while True: + if hd.BloodFlow.TargetBloodFlowRate == 0: + if tgtRate != 0: + hd.BloodFlow.CmdBloodFlowBroadcastIntervalOverride(hd.NO_RESET, 2000) + tgtRate = 0 + else: + if tgtRate == 0: + hd.BloodFlow.CmdBloodFlowBroadcastIntervalOverride(hd.NO_RESET, 200) + tgtRate = hd.BloodFlow.TargetBloodFlowRate + +# hd.BloodFlow.CmdBloodFlowBroadcastIntervalOverride(hd.RESET,0) \ No newline at end of file