Index: leahi_dialin/fp/modules/boost_pump.py =================================================================== diff -u -r0f08c28544b557b2bbd8c04b10cff284f41e4fb9 -r80f84ad5638667894e9df2161b9c5d9b8f27ed9b --- leahi_dialin/fp/modules/boost_pump.py (.../boost_pump.py) (revision 0f08c28544b557b2bbd8c04b10cff284f41e4fb9) +++ leahi_dialin/fp/modules/boost_pump.py (.../boost_pump.py) (revision 80f84ad5638667894e9df2161b9c5d9b8f27ed9b) @@ -49,19 +49,19 @@ self.can_interface.register_receiving_publication_function(channel_id, msg_id, self._handler_boost_pump_sync) self.ro_pump_timestamp = 0.0 - self.p12_ro_pump_state = 0 - self.p12_ro_pump_duty_cycle = 0.0 - self.p12_ro_pump_fb_duty_cycle = 0.0 - self.p12_ro_pump_speed = 0.0 - self.p40_boost_pump_state = 0 - self.p40_boost_pump_duty_cycle = 0.0 - self.p40_boost_pump_fb_duty_cycle = 0.0 - self.p40_boost_pump_speed = 0.0 + self.p12_pump_state = 0 + self.p12_pump_duty_cycle = 0.0 + self.p12_pump_fb_duty_cycle = 0.0 + self.p12_pump_speed = 0.0 + self.p40_pump_state = 0 + self.p40_pump_duty_cycle = 0.0 + self.p40_pump_fb_duty_cycle = 0.0 + self.p40_pump_speed = 0.0 - @publish(["ro_pump_timestamp", "p12_ro_pump_state", "p12_ro_pump_duty_cycle", "p12_ro_pump_fb_duty_cycle", - "p12_ro_pump_speed", "p40_boost_pump_state", "p40_boost_pump_duty_cycle", - "p40_boost_pump_fb_duty_cycle", "p40_boost_pump_speed"]) + @publish(["ro_pump_timestamp", "p12_pump_state", "p12_pump_duty_cycle", "p12_pump_fb_duty_cycle", + "p12_pump_speed", "p40_pump_state", "p40_pump_duty_cycle", + "p40_pump_fb_duty_cycle", "p40_pump_speed"]) def _handler_boost_pump_sync(self, message, timestamp=0.0): """ Handles published RO pump data messages. RO pump data is captured @@ -71,35 +71,25 @@ @return: none """ - rps = struct.unpack('i', bytearray( + self.p12_pump_state = struct.unpack('i', bytearray( message['message'][MsgFieldPositions.START_POS_FIELD_1:MsgFieldPositions.END_POS_FIELD_1])) - rpdc = struct.unpack('i', bytearray( + self.p12_pump_duty_cycle = struct.unpack('i', bytearray( message['message'][MsgFieldPositions.START_POS_FIELD_2:MsgFieldPositions.END_POS_FIELD_2])) - rpfbdc = struct.unpack('i', bytearray( + self.p12_pump_fb_duty_cycle = struct.unpack('i', bytearray( message['message'][MsgFieldPositions.START_POS_FIELD_3:MsgFieldPositions.END_POS_FIELD_3])) - rprpm = struct.unpack('f', bytearray( + self.p12_pump_speed = struct.unpack('f', bytearray( message['message'][MsgFieldPositions.START_POS_FIELD_4:MsgFieldPositions.END_POS_FIELD_4])) - bps = struct.unpack('i', bytearray( + self.p40_pump_state = struct.unpack('i', bytearray( message['message'][MsgFieldPositions.START_POS_FIELD_5:MsgFieldPositions.END_POS_FIELD_5])) - bpdc = struct.unpack('i', bytearray( + self.p40_pump_duty_cycle = struct.unpack('i', bytearray( message['message'][MsgFieldPositions.START_POS_FIELD_6:MsgFieldPositions.END_POS_FIELD_6])) - bpfbdc = struct.unpack('i', bytearray( + self.p40_pump_fb_duty_cycle = struct.unpack('i', bytearray( message['message'][MsgFieldPositions.START_POS_FIELD_7:MsgFieldPositions.END_POS_FIELD_7])) - bprpm = struct.unpack('f', bytearray( + self.p40_pump_speed = struct.unpack('f', bytearray( message['message'][MsgFieldPositions.START_POS_FIELD_8:MsgFieldPositions.END_POS_FIELD_8])) self.ro_pump_timestamp = timestamp - self.p12_ro_pump_state = rps[0] - self.p12_ro_pump_duty_cycle = rpdc[0] - self.p12_ro_pump_fb_duty_cycle = rpfbdc[0] - self.p12_ro_pump_speed = rprpm[0] - self.p40_boost_pump_state = bps[0] - self.p40_boost_pump_duty_cycle = bpdc[0] - self.p40_boost_pump_fb_duty_cycle = bpfbdc[0] - self.p40_boost_pump_speed = bprpm[0] - - def cmd_boost_pump_set_speed_rate_override(self, pump: int, rpm: int, reset: int = NO_RESET) -> int: """ Constructs and sends the boost pump set point command @@ -144,8 +134,8 @@ Constraints: Must be logged into FP. + @param pump: integer - the pump id to set pwm @param pwm: integer - counts to override the pwm ( 0 - 500 ) - @param reset: integer - 1 to reset a previous override, 0 to override @return: 1 if successful, zero otherwise """