commands.process: return immediately when terminating process, without having to deal with the queue.

otherwise, we have to block for $smalldelay between putting and getting the item, since queue putting is not instantaneous
and sometimes we would get 'nothing returned' instead of the timeout message.
This commit is contained in:
Daniel Folkinshteyn 2010-08-05 14:48:12 -04:00
parent e779b70609
commit 27be9ceb74
1 changed files with 1 additions and 1 deletions

View File

@ -90,7 +90,7 @@ def process(f, *args, **kwargs):
p.join(timeout)
if p.is_alive():
p.terminate()
q.put("%s aborted due to timeout." % (p.name,))
return "%s aborted due to timeout." % (p.name,)
try:
v = q.get(block=False)
except Queue.Empty: