diff options
author | Kevin O'Connor <kevin@koconnor.net> | 2019-06-26 10:31:15 -0400 |
---|---|---|
committer | KevinOConnor <kevin@koconnor.net> | 2019-07-10 10:43:20 -0400 |
commit | a116fa9054d952b910c696d9c8f0a0b632b90b26 (patch) | |
tree | 9a83c543057a9da497b1c5033a24160f621848c5 | |
parent | b2c778b93122aacd93b983775c10b97d392e92b4 (diff) | |
download | kutter-a116fa9054d952b910c696d9c8f0a0b632b90b26.tar.gz kutter-a116fa9054d952b910c696d9c8f0a0b632b90b26.tar.xz kutter-a116fa9054d952b910c696d9c8f0a0b632b90b26.zip |
serialhdl: Use register_response() for both registering and unregistering
Signed-off-by: Kevin O'Connor <kevin@koconnor.net>
-rw-r--r-- | klippy/serialhdl.py | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/klippy/serialhdl.py b/klippy/serialhdl.py index 1b4f1e13..33f16f51 100644 --- a/klippy/serialhdl.py +++ b/klippy/serialhdl.py @@ -139,10 +139,10 @@ class SerialReader: # Serial response callbacks def register_response(self, callback, name, oid=None): with self.lock: - self.handlers[name, oid] = callback - def unregister_response(self, name, oid=None): - with self.lock: - del self.handlers[name, oid] + if callback is None: + del self.handlers[name, oid] + else: + self.handlers[name, oid] = callback # Command sending def raw_send(self, cmd, minclock, reqclock, cmd_queue): self.ffi_lib.serialqueue_send( @@ -217,7 +217,7 @@ class SerialRetryCommand: retry_time = self.first_query_time + self.RETRY_TIME self.send_timer = reactor.register_timer(self.send_event, retry_time) def unregister(self): - self.serial.unregister_response(self.name, self.oid) + self.serial.register_response(None, self.name, self.oid) self.serial.reactor.unregister_timer(self.send_timer) def send_event(self, eventtime): if self.response is not None: |