Index: dialin/common/msg_ids.py =================================================================== diff -u -rc8f72e093dcecb791c8209911773630a822c7e03 -rfe1972cd6dd94cb89c66bfb238dac50cb710224e --- dialin/common/msg_ids.py (.../msg_ids.py) (revision c8f72e093dcecb791c8209911773630a822c7e03) +++ dialin/common/msg_ids.py (.../msg_ids.py) (revision fe1972cd6dd94cb89c66bfb238dac50cb710224e) @@ -239,8 +239,8 @@ MSG_ID_HD_AIR_TRAP_SEND_INTERVAL_OVERRIDE = 0X8032 MSG_ID_HD_AIR_TRAP_LEVEL_SENSOR_OVERRIDE = 0X8033 MSG_ID_HD_SOFTWARE_RESET_REQUEST = 0X8034 - MSG_ID_BLOOD_FLOW_SIG_STRENGTH_OVERRIDE = 0X8035 - MSG_ID_DIAL_IN_FLOW_SIG_STRENGTH_OVERRIDE = 0X8036 + MSG_ID___AVAILABLE_3 = 0X8035 + MSG_ID___AVAILABLE_4 = 0X8036 MSG_ID_BLOOD_PUMP_HOME_CMD = 0X8037 MSG_ID_DIAL_IN_PUMP_HOME_CMD = 0X8038 MSG_ID_DIAL_OUT_PUMP_HOME_CMD = 0X8039 @@ -282,7 +282,7 @@ MSG_ID_HD_BUBBLE_STATUS_OVERRIDE = 0X805E MSG_ID_HD_BLOOD_PRIME_VOLUME_OVERRIDE = 0X805F MSG_ID_HD_BUBBLE_SELF_TEST_REQUEST = 0X8060 - MSG_ID_HD_BLOOD_PRIME_SAFETY_VOLUME_OVERRIDE = 0X8061 + MSG_ID_HD___AVAILABLE_1 = 0X8061 MSG_ID_HD_SWITCHES_STATUS_OVERRIDE = 0x8062 MSG_ID_HD_SWITCHES_PUBLISH_INTERVAL_OVERRIDE = 0x8063 MSG_ID_HD_BATTERY_REMAINING_PERCENT_OVERRIDE = 0x8064 @@ -291,7 +291,7 @@ MSG_ID_HD_FANS_PUBLISH_INTERVAL_OVERRIDE = 0x8067 MSG_ID_HD_FANS_RPM_OVERRIDE = 0x8068 MSG_ID_HD_RINSEBACK_VOLUME_OVERRIDE = 0x8069 - MSG_ID_HD_RINSEBACK_SAFETY_VOLUME_OVERRIDE = 0x806A + MSG_ID_HD___AVAILABLE_2 = 0x806A MSG_ID_HD_ALARM_STATUS_PUBLISH_INTERVAL_OVERRIDE = 0x806B MSG_ID_HD_TREATMENT_TIME_DATA_PUBLISH_INTERVAL_OVERRIDE = 0x806C MSG_ID_HD_TREATMENT_RANGES_PUBLISH_INTERVAL_OVERRIDE = 0x806D Index: dialin/dg/load_cells.py =================================================================== diff -u -rf06c062512981820509a86a07a54b7070adbf3d1 -rfe1972cd6dd94cb89c66bfb238dac50cb710224e --- dialin/dg/load_cells.py (.../load_cells.py) (revision f06c062512981820509a86a07a54b7070adbf3d1) +++ dialin/dg/load_cells.py (.../load_cells.py) (revision fe1972cd6dd94cb89c66bfb238dac50cb710224e) @@ -149,7 +149,7 @@ payload = rst + mis message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_dg_ch_id, - message_id=MsgIds.MSG_ID_LOAD_CELLL_SEND_INTERVAL_OVERRIDE.value, + message_id=MsgIds.MSG_ID_LOAD_CELL_SEND_INTERVAL_OVERRIDE.value, payload=payload) self.logger.debug("override DG load cell broadcast interval") Index: dialin/hd/blood_flow.py =================================================================== diff -u -r46ae582aedfc3ba78748f99bbbd6c5659582a758 -rfe1972cd6dd94cb89c66bfb238dac50cb710224e --- dialin/hd/blood_flow.py (.../blood_flow.py) (revision 46ae582aedfc3ba78748f99bbbd6c5659582a758) +++ dialin/hd/blood_flow.py (.../blood_flow.py) (revision fe1972cd6dd94cb89c66bfb238dac50cb710224e) @@ -403,46 +403,6 @@ self.logger.debug("Timeout!!!!") return False - def cmd_blood_flow_signal_strength_override(self, signal_strength: float, reset: int = NO_RESET) -> int: - """ - Constructs and sends the measured blood flow signal strength % override \n - command. - Constraints: - Must be logged into HD. - - @param signal_strength: float - pct (0..100) to override with - @param reset: integer - 1 to reset a previous override, 0 to override - @return: 1 if successful, zero otherwise - """ - - rst = integer_to_bytearray(reset) - sig = float_to_bytearray(signal_strength) - payload = rst + sig - - message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id, - message_id=MsgIds.MSG_ID_BLOOD_FLOW_SIG_STRENGTH_OVERRIDE.value, - payload=payload) - - self.logger.debug("override measured blood flow signal strength") - - # Send message - received_message = self.can_interface.send(message) - - # If there is content... - if received_message is not None: - # self.logger.debug(received_message) - if reset == RESET: - str_sig = "reset back to normal" - else: - str_sig = str(signal_strength) - self.logger.debug("Blood pump flow signal strength overridden to " + str_sig + " %: " + - str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX])) - # response payload is OK or not OK - return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX] - else: - self.logger.debug("Timeout!!!!") - return False - def cmd_blood_flow_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int: """ Constructs and sends the measured blood flow broadcast interval override command Index: dialin/hd/dialysate_inlet_flow.py =================================================================== diff -u -rebf0a72a1a1a52f3cfe20975de4857201275888c -rfe1972cd6dd94cb89c66bfb238dac50cb710224e --- dialin/hd/dialysate_inlet_flow.py (.../dialysate_inlet_flow.py) (revision ebf0a72a1a1a52f3cfe20975de4857201275888c) +++ dialin/hd/dialysate_inlet_flow.py (.../dialysate_inlet_flow.py) (revision fe1972cd6dd94cb89c66bfb238dac50cb710224e) @@ -53,7 +53,6 @@ self.measured_dialysate_inlet_pump_mc_speed = 0.0 self.measured_dialysate_inlet_pump_mc_current = 0.0 self.pwm_duty_cycle_pct = 0.0 - self.flow_signal_strength = 0.0 def get_target_dialysate_inlet_flow_rate(self): """ @@ -111,23 +110,14 @@ """ return self.pwm_duty_cycle_pct - def get_flow_signal_strength(self): - """ - Gets the dialysate flow signal strength pct - - @return: the dialysate flow signal strength pct (0..100) - """ - return self.flow_signal_strength - @publish([ "target_dialysate_inlet_flow_rate", "measured_dialysate_inlet_flow_rate", "measured_dialysate_inlet_pump_rotor_speed", "measured_dialysate_inlet_pump_speed", "measured_dialysate_inlet_pump_mc_speed", "measured_dialysate_inlet_pump_mc_current", - "pwm_duty_cycle_pct", - "flow_signal_strength" + "pwm_duty_cycle_pct" ]) def _handler_dialysate_inlet_flow_sync(self, message): """ @@ -152,8 +142,6 @@ message['message'][MsgFieldPositions.START_POS_FIELD_6:MsgFieldPositions.END_POS_FIELD_6])) pwm = struct.unpack('f', bytearray( message['message'][MsgFieldPositions.START_POS_FIELD_7:MsgFieldPositions.END_POS_FIELD_7])) - sig = struct.unpack('f', bytearray( - message['message'][MsgFieldPositions.START_POS_FIELD_8:MsgFieldPositions.END_POS_FIELD_8])) self.target_dialysate_inlet_flow_rate = tgt[0] self.measured_dialysate_inlet_flow_rate = flow[0] @@ -162,7 +150,6 @@ self.measured_dialysate_inlet_pump_mc_speed = mcspeed[0] self.measured_dialysate_inlet_pump_mc_current = mccurr[0] self.pwm_duty_cycle_pct = pwm[0] - self.flow_signal_strength = sig[0] def cmd_dialysate_inlet_flow_set_point_override(self, flow: int, @@ -416,46 +403,6 @@ self.logger.debug("Timeout!!!!") return False - def cmd_dialysate_flow_signal_strength_override(self, signal_strength: float, reset: int = NO_RESET) -> int: - """ - Constructs and sends the measured dialysate flow signal strength % override \n - command. - Constraints: - Must be logged into HD. - - @param signal_strength: float - pct (0..100) to override with - @param reset: integer - 1 to reset a previous override, 0 to override - @return: 1 if successful, zero otherwise - """ - - rst = integer_to_bytearray(reset) - sig = float_to_bytearray(signal_strength) - payload = rst + sig - - message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id, - message_id=MsgIds.MSG_ID_DIAL_IN_FLOW_SIG_STRENGTH_OVERRIDE.value, - payload=payload) - - self.logger.debug("override measured dialysate flow signal strength") - - # Send message - received_message = self.can_interface.send(message) - - # If there is content... - if received_message is not None: - # self.logger.debug(received_message) - if reset == RESET: - str_sig = "reset back to normal" - else: - str_sig = str(signal_strength) - self.logger.debug("Dialysate pump flow signal strength overridden to " + str_sig + " %: " + - str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX])) - # response payload is OK or not OK - return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX] - else: - self.logger.debug("Timeout!!!!") - return False - def cmd_dialysate_inlet_flow_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int: """ Constructs and sends the measured dialysate inlet flow broadcast interval override command Index: dialin/hd/treatment.py =================================================================== diff -u -recfaee3ad071edb368488eb750692f16a91ddbad -rfe1972cd6dd94cb89c66bfb238dac50cb710224e --- dialin/hd/treatment.py (.../treatment.py) (revision ecfaee3ad071edb368488eb750692f16a91ddbad) +++ dialin/hd/treatment.py (.../treatment.py) (revision fe1972cd6dd94cb89c66bfb238dac50cb710224e) @@ -178,7 +178,6 @@ self.rinseback_cur_rate = 0 self.rinseback_timeout_secs = 0 self.rinseback_countdown_secs = 0 - self.rinseback_safety_cum_vol = 0.0 # re-circulation status self.recirc_timeout_secs = 0 self.recirc_countdown_secs = 0 @@ -327,14 +326,6 @@ """ return self.blood_prime_cum_vol - def get_blood_prime_safety_volume_delivered(self) -> float: - """ - Returns blood prime safety volume (in mL) delivered - - @return: The blood prime safety volume delivered - """ - return self.blood_prime_ind_cum_vol - def get_rinseback_target_volume(self) -> float: """ Returns rinseback target volume (in mL) @@ -351,14 +342,6 @@ """ return self.rinseback_cum_vol - def get_rinseback_safety_volume_delivered(self) -> float: - """ - Returns rinseback safety volume (in mL) delivered - - @return: The rinseback safety volume delivered - """ - return self.rinseback_safety_cum_vol - def get_rinseback_current_rate(self) -> int: """ Returns rinseback current rate (in mL/min) @@ -528,15 +511,12 @@ message['message'][MsgFieldPositions.START_POS_FIELD_4:MsgFieldPositions.END_POS_FIELD_4])) cdn = struct.unpack('i', bytearray( message['message'][MsgFieldPositions.START_POS_FIELD_5:MsgFieldPositions.END_POS_FIELD_5])) - rsv = struct.unpack('f', bytearray( - message['message'][MsgFieldPositions.START_POS_FIELD_6:MsgFieldPositions.END_POS_FIELD_6])) self.rinseback_tgt_vol = tgt[0] self.rinseback_cum_vol = cum[0] self.rinseback_cur_rate = rat[0] self.rinseback_timeout_secs = tmo[0] self.rinseback_countdown_secs = cdn[0] - self.rinseback_safety_cum_vol = rsv[0] @publish([ "blood_prime_tgt_vol", @@ -1325,40 +1305,6 @@ self.logger.debug("Timeout!!!!") return False - def cmd_blood_prime_safety_volume_delivered_override(self, volume: float, reset: int = NO_RESET) -> int: - """ - Constructs and sends the blood prime safety volume delivered override command - Constraints: - Must be logged into HD. - - @param volume: float - safety volume (in mL) of blood delivered during blood prime (must be positive) - @param reset: integer - 1 to reset a previous override, 0 to override - @return: 1 if successful, zero otherwise - """ - - rst = integer_to_bytearray(reset) - vol = float_to_bytearray(volume) - payload = rst + vol - - message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id, - message_id=MsgIds.MSG_ID_HD_BLOOD_PRIME_SAFETY_VOLUME_OVERRIDE.value, - payload=payload) - - self.logger.debug("override HD blood prime safety volume delivered (in mL).") - - # Send message - received_message = self.can_interface.send(message) - - # If there is content... - if received_message is not None: - self.logger.debug("Blood prime safety volume delivered overridden to " + str(volume) + " mL. " + - str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX])) - # response payload is OK or not OK - return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX] - else: - self.logger.debug("Timeout!!!!") - return False - def cmd_rinseback_volume_delivered_override(self, volume: float, reset: int = NO_RESET) -> int: """ Constructs and sends the rinseback volume delivered override command @@ -1393,40 +1339,6 @@ self.logger.debug("Timeout!!!!") return False - def cmd_rinseback_safety_volume_delivered_override(self, volume: float, reset: int = NO_RESET) -> int: - """ - Constructs and sends the rinseback safety volume delivered override command - Constraints: - Must be logged into HD. - - @param volume: float - safety volume (in mL) of blood returned during rinseback (must be positive) - @param reset: integer - 1 to reset a previous override, 0 to override - @return: 1 if successful, zero otherwise - """ - - rst = integer_to_bytearray(reset) - vol = float_to_bytearray(volume) - payload = rst + vol - - message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_hd_ch_id, - message_id=MsgIds.MSG_ID_HD_RINSEBACK_SAFETY_VOLUME_OVERRIDE.value, - payload=payload) - - self.logger.debug("override HD rinseback safety volume delivered (in mL).") - - # Send message - received_message = self.can_interface.send(message) - - # If there is content... - if received_message is not None: - self.logger.debug("Rinseback safety volume delivered overridden to " + str(volume) + " mL. " + - str(received_message['message'][DenaliMessage.PAYLOAD_START_INDEX])) - # response payload is OK or not OK - return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX] - else: - self.logger.debug("Timeout!!!!") - return False - def cmd_blood_prime_submode_broadcast_interval_override(self, ms: int = 250, reset: int = NO_RESET): """ Constructs and sends the treatment blood prime sub-mode broadcast interval override command