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

Fix little output glitch

Browse Source
This commit is contained in:
Steven Robertson 2012-06-10 09:14:25 -07:00
parent c424af5124
commit 54e2192dde
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dist/server.py vendored
View File

@ -72,12 +72,12 @@ def setup_worker_listener(addrs, tq, rq):
worker_addr = readyq.get() worker_addr = readyq.get()
wsock.send_multipart([worker_addr, '', pickle.dumps(ctask)]) wsock.send_multipart([worker_addr, '', pickle.dumps(ctask)])
@spawn @spawn
def read_rsps(): def read_rsps():
while True: while True:
rsp = wsock.recv_multipart(copy=False) rsp = wsock.recv_multipart(copy=False)
if rsp[2].bytes != '': if rsp[2].bytes != '':
print '< ', ' '.join([r.bytes for r in rsp[1:-1]]) print '< ', ' '.join([r.bytes for r in rsp[2:-1]])
rq.put(rsp[2:]) rq.put(rsp[2:])
readyq.put(rsp[0]) readyq.put(rsp[0])