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

Handle client being suspended

Browse Source
This commit is contained in:
Steven Robertson 2012-01-13 20:55:44 -05:00
parent 4e23cd48f2
commit fbb807c0d4
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
worker.py
View File

@ -67,8 +67,6 @@ def work(server):
rev = git_rev() rev = git_rev()
r = redis.StrictRedis(server) r = redis.StrictRedis(server)
wid = uu('workers') wid = uu('workers')
# TODO: store information about this worker in a WID-named string with an
# expiration, and touch/update it every so often
r.sadd('renderpool:' + rev + ':workers', wid) r.sadd('renderpool:' + rev + ':workers', wid)
r.hmset(wid, { r.hmset(wid, {
'host': socket.gethostname(), 'host': socket.gethostname(),
@ -95,7 +93,7 @@ def work(server):
continue continue
sid, sidx, pid, gid, ftime, ftag = task[1].split(' ', 5) sid, sidx, pid, gid, ftime, ftag = task[1].split(' ', 5)
if pid != last_pid or gid != last_gid: if pid != last_pid or gid != last_gid or not riter:
if riter: if riter:
push_frame(r, riter.send(None)) push_frame(r, riter.send(None))
gnm = genome.Genome(json.loads(r.get(gid))) gnm = genome.Genome(json.loads(r.get(gid)))