From daa2f8596f513a24647836fcf5293d6e9be4d155 Mon Sep 17 00:00:00 2001 From: Antoine Poinsot Date: Wed, 11 May 2022 09:49:31 +0200 Subject: [PATCH] TMP: debug CI --- .cirrus.yml | 3 ++- tests/test_framework/coordinatord.py | 11 +++++++++-- 2 files changed, 11 insertions(+), 3 deletions(-) diff --git a/.cirrus.yml b/.cirrus.yml index 5ec66231..53b006c4 100644 --- a/.cirrus.yml +++ b/.cirrus.yml @@ -2,9 +2,10 @@ task: name: 'Functional tests' container: image: rust:latest + timeout_in: 90m # https://cirrus-ci.org/faq/#instance-timed-out env: - EXECUTOR_WORKERS: 1 + EXECUTOR_WORKERS: 10 VERBOSE: 1 LOG_LEVEL: debug TIMEOUT: 300 diff --git a/tests/test_framework/coordinatord.py b/tests/test_framework/coordinatord.py index 767e17fa..2dee065f 100644 --- a/tests/test_framework/coordinatord.py +++ b/tests/test_framework/coordinatord.py @@ -140,7 +140,7 @@ def __init__( self.s.bind(("localhost", self.port)) self.s.listen(1_000) # The server socket is set to nonblocking to stop immediately on shutdown - self.s.setblocking(False) + # self.s.setblocking(False) self.r_close_chann, self.w_close_chann = os.pipe() # A mapping from txid to pubkey to signature @@ -169,9 +169,16 @@ def run(self): if self.r_close_chann in r_fds: break if self.s.fileno() in r_fds: - t = threading.Thread(target=self.connection_handle, daemon=True) + t = threading.Thread(target=self.a, daemon=True) t.start() + def a(self): + try: + self.connection_handle() + except Exception as e: + logging.error(e) + raise e + def connection_handle(self): """Read and treat requests from this client. Blocking.""" client_fd, _ = self.s.accept()