aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorKevin O'Connor <kevin@koconnor.net>2019-06-26 10:31:15 -0400
committerKevinOConnor <kevin@koconnor.net>2019-07-10 10:43:20 -0400
commita116fa9054d952b910c696d9c8f0a0b632b90b26 (patch)
tree9a83c543057a9da497b1c5033a24160f621848c5
parentb2c778b93122aacd93b983775c10b97d392e92b4 (diff)
downloadkutter-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.py10
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: