TMP: debug CI

.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

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()