Commit 8dfdc86c authored by Michael Achenbach's avatar Michael Achenbach Committed by Commit Bot

[testrunner] Fix sigterm handler

Bug: v8:8292
Change-Id: Icbfb8cb0c4ba9cdb5a6c1cbec5e4c6e61c9d0d4b
Reviewed-on: https://chromium-review.googlesource.com/c/v8/v8/+/2019163Reviewed-by: 's avatarLiviu Rau <liviurau@chromium.org>
Commit-Queue: Michael Achenbach <machenbach@chromium.org>
Cr-Commit-Position: refs/heads/master@{#65974}
parent d49a1842
......@@ -41,21 +41,27 @@ class AbortException(Exception):
@contextmanager
def handle_sigterm(process, handle_sigterm):
"""Handle sigterm for `process` and restore previous handler to prevent
def handle_sigterm(process, abort_fun, enabled):
"""Call`abort_fun` on sigterm and restore previous handler to prevent
erroneous termination of an already terminated process.
Args:
process: The process to terminate.
abort_fun: Function taking two parameters: the process to terminate and
an array with a boolean for storing if an abort occured.
enabled: If False, this wrapper will be a no-op.
"""
# Variable to communicate with the signal handler.
abort_occured = [False]
def handler(signum, frame):
self._abort(process, abort_occured)
abort_fun(process, abort_occured)
if handle_sigterm:
if enabled:
previous = signal.signal(signal.SIGTERM, handler)
try:
yield
finally:
if handle_sigterm:
if enabled:
signal.signal(signal.SIGTERM, previous)
if abort_occured[0]:
......@@ -95,7 +101,7 @@ class BaseCommand(object):
process = self._start_process()
with handle_sigterm(process, self.handle_sigterm):
with handle_sigterm(process, self._abort, self.handle_sigterm):
# Variable to communicate with the timer.
timeout_occured = [False]
timer = threading.Timer(
......
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