mirror-github-bspeice/cuburn
1
0
Fork 0
mirror of https://github.com/stevenrobertson/cuburn.git synced 2025-02-05 11:40:04 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

Queue -> Channel

Browse Source
This commit is contained in:
Steven Robertson 2014-12-20 18:27:27 -08:00
parent 10a45d4036
commit 0f8d2916d7
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
dist/client.py vendored
View File

@ -30,7 +30,7 @@ class RenderClient(object):
self.rsock.setsockopt(zmq.IDENTITY, self.cid) self.rsock.setsockopt(zmq.IDENTITY, self.cid)
self.rsock.connect(rsp_addr) self.rsock.connect(rsp_addr)
self.tq = queue.Queue(0) self.tq = queue.Channel()
self.taskmap = weakref.WeakValueDictionary() self.taskmap = weakref.WeakValueDictionary()
if start: self.start() if start: self.start()

2
dist/server.py vendored
View File

@ -93,7 +93,7 @@ def setup_responder(addrs, rq):
def main(addrs): def main(addrs):
# Channel holding (addr, task) pairs. # Channel holding (addr, task) pairs.
tq = queue.Queue(0) tq = queue.Channel()
# Queue holding response messages (as a list of raw zmq frames). # Queue holding response messages (as a list of raw zmq frames).
rq = queue.Queue() rq = queue.Queue()