slapos.grid: do not ALWAYS sleep for promise_timeout.

Instead, poll often, and continue if promise finished.
parent ffb2abfb
...@@ -541,18 +541,27 @@ class Slapgrid(object): ...@@ -541,18 +541,27 @@ class Slapgrid(object):
process_handler.stdin.close() process_handler.stdin.close()
process_handler.stdin = None process_handler.stdin = None
time.sleep(self.promise_timeout) # Check if the promise finished every tenth of second,
# but timeout after promise_timeout.
sleep_time = 0.1
increment_limit = int(self.promise_timeout / sleep_time)
for current_increment in range(0, increment_limit):
if process_handler.poll() is None: if process_handler.poll() is None:
process_handler.terminate() time.sleep(sleep_time)
raise Slapgrid.PromiseError("The promise '%s' timed out" % promise) continue
elif process_handler.poll() != 0: if process_handler.poll() == 0:
# Success!
break
else:
stderr = process_handler.communicate()[1] stderr = process_handler.communicate()[1]
if stderr is None: if stderr is None:
stderr = "No error output from '%s'." % promise stderr = "No error output from '%s'." % promise
else: else:
stderr = "Promise '%s':" % promise + stderr stderr = "Promise '%s':" % promise + stderr
raise Slapgrid.PromiseError(stderr) raise Slapgrid.PromiseError(stderr)
else:
process_handler.terminate()
raise Slapgrid.PromiseError("The promise '%s' timed out" % promise)
if not promise_present: if not promise_present:
self.logger.info("No promise.") self.logger.info("No promise.")
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment