diff options
author | Kevin O'Connor <kevin@koconnor.net> | 2019-06-21 20:46:44 -0400 |
---|---|---|
committer | Kevin O'Connor <kevin@koconnor.net> | 2019-06-21 21:42:20 -0400 |
commit | 9feb05ce418a57127ac1f95f5f07e8ef4beae7f4 (patch) | |
tree | 2dfab2f92e5b8be8600973793b2c388dcd20ce34 /klippy/mcu.py | |
parent | e202a8802b31495622a47178459481540f314b7c (diff) | |
download | kutter-9feb05ce418a57127ac1f95f5f07e8ef4beae7f4.tar.gz kutter-9feb05ce418a57127ac1f95f5f07e8ef4beae7f4.tar.xz kutter-9feb05ce418a57127ac1f95f5f07e8ef4beae7f4.zip |
mcu: Support minclock in send_with_response() requests
Enhance send_with_response() so that it supports queries with a
minclock.
Signed-off-by: Kevin O'Connor <kevin@koconnor.net>
Diffstat (limited to 'klippy/mcu.py')
-rw-r--r-- | klippy/mcu.py | 16 |
1 files changed, 11 insertions, 5 deletions
diff --git a/klippy/mcu.py b/klippy/mcu.py index b10a9c99..15148a86 100644 --- a/klippy/mcu.py +++ b/klippy/mcu.py @@ -426,19 +426,25 @@ class MCU_adc: # Wrapper around command sending class CommandWrapper: - def __init__(self, mcu, serial, cmd, cmd_queue): + def __init__(self, mcu, serial, clocksync, cmd, cmd_queue): self._mcu = mcu self._serial = serial + self._clocksync = clocksync self._cmd = cmd self._cmd_queue = cmd_queue def send(self, data=(), minclock=0, reqclock=0): cmd = self._cmd.encode(data) self._serial.raw_send(cmd, minclock, reqclock, self._cmd_queue) - def send_with_response(self, data=(), response=None, response_oid=None): + def send_with_response(self, data=(), response=None, response_oid=None, + minclock=0): + minsystime = 0. + if minclock: + minsystime = self._clocksync.estimate_clock_systime(minclock) cmd = self._cmd.encode(data) try: - src = serialhdl.SerialRetryCommand(self._serial, cmd, - response, response_oid) + src = serialhdl.SerialRetryCommand( + self._serial, [cmd], self._cmd_queue, response, response_oid, + minclock=minclock, minsystime=minsystime) return src.get_response() except serialhdl.error as e: raise error(str(e)) @@ -710,7 +716,7 @@ class MCU: if cq is None: cq = self._serial.get_default_command_queue() cmd = self._serial.get_msgparser().lookup_command(msgformat) - return CommandWrapper(self, self._serial, cmd, cq) + return CommandWrapper(self, self._serial, self._clocksync, cmd, cq) def try_lookup_command(self, msgformat): try: return self.lookup_command(msgformat) |