From 62ae1a1c364d2a35f0c6d9f10e485d03751053d6 Mon Sep 17 00:00:00 2001 From: Simon Lin Date: Tue, 13 Apr 2021 13:52:58 +0800 Subject: [PATCH] [thread-cert] specify MAX_JOBS via env (#6419) --- tests/scripts/thread-cert/run_cert_suite.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/tests/scripts/thread-cert/run_cert_suite.py b/tests/scripts/thread-cert/run_cert_suite.py index 7afa77473..c9af1f2f2 100644 --- a/tests/scripts/thread-cert/run_cert_suite.py +++ b/tests/scripts/thread-cert/run_cert_suite.py @@ -39,7 +39,7 @@ import config THREAD_VERSION = os.getenv('THREAD_VERSION') VIRTUAL_TIME = int(os.getenv('VIRTUAL_TIME', '1')) -MAX_JOBS = multiprocessing.cpu_count() * 2 if VIRTUAL_TIME else 10 +MAX_JOBS = int(os.getenv('MAX_JOBS', (multiprocessing.cpu_count() * 2 if VIRTUAL_TIME else 10))) _BACKBONE_TESTS_DIR = 'tests/scripts/thread-cert/backbone' @@ -131,14 +131,14 @@ class PortOffsetPool: def __init__(self, size: int): self._size = size self._pool = queue.Queue(maxsize=size) - for port_offset in range(1, size + 1): + for port_offset in range(0, size): self.release(port_offset) def allocate(self) -> int: return self._pool.get() def release(self, port_offset: int): - assert 1 <= port_offset <= self._size, port_offset + assert 0 <= port_offset < self._size, port_offset self._pool.put_nowait(port_offset)