aboutsummaryrefslogtreecommitdiff
path: root/cryptech_muxd
diff options
context:
space:
mode:
authorRob Austein <sra@hactrn.net>2017-04-11 01:16:29 -0400
committerRob Austein <sra@hactrn.net>2017-04-11 01:16:29 -0400
commit9798cf231fe7506135f0cb2361896a1abe3d9ecb (patch)
tree1183945d37b3341a14fef7c866c0032b39d65f96 /cryptech_muxd
parentcc46a697de71e66e90653e3ac7fffe413acfd8c8 (diff)
parent482cc1a5f135e5c6f66f124ec134e6423fbae115 (diff)
Merge branch 'pymux' into pkcs8
Diffstat (limited to 'cryptech_muxd')
-rwxr-xr-xcryptech_muxd5
1 files changed, 3 insertions, 2 deletions
diff --git a/cryptech_muxd b/cryptech_muxd
index 269ac15..dacf889 100755
--- a/cryptech_muxd
+++ b/cryptech_muxd
@@ -166,11 +166,12 @@ class RPCIOStream(SerialIOStream):
logger.debug("RPC recv: %s", ":".join("{:02x}".format(ord(c)) for c in reply))
try:
handle = client_handle_get(slip_decode(reply))
+ queue = self.queues[handle]
except:
continue
logger.debug("RPC queue put: handle 0x%x, qsize %s, maxsize %s",
- handle, self.queues[handle].qsize(), self.queues[handle].maxsize)
- self.queues[handle].put_nowait(reply)
+ handle, queue.qsize(), queue.maxsize)
+ queue.put_nowait(reply)
class QueuedStreamClosedError(tornado.iostream.StreamClosedError):