May 6, 2025 · May 7, 2025 · May 7, 2025 · May 7, 2025 · May 7, 2025 · May 7, 2025
diff --git a/testgres/impl/port_manager__generic.py b/testgres/impl/port_manager__generic.py
        assert isinstance(os_ops, OsOperations)
        self._os_ops = os_ops
        self._guard = threading.Lock()
        self._available_ports = set(range(1024,65535))
        self._available_ports = set(range(1024,65536))
        self._reserved_ports = set()
        self._lock_dir = None

            t = None

            for port in sampled_ports:
                assert type(port) == int  # noqa: E721
                assert not (port in self._reserved_ports)
                assert port in self._available_ports

                assert port >= 0
                assert port <= 65535

                if not self._os_ops.is_port_free(port):
                    continue


    def release_port(self, number: int) -> None:
        assert type(number) == int  # noqa: E721
        assert number >= 0
        assert number <= 65535

        assert self._guard is not None
        assert type(self._reserved_ports) == set  # noqa: E721
Original file line number	Diff line number	Diff line change
Expand Up		@@ -24,7 +24,7 @@ def __init__(self, os_ops: OsOperations):
		assert isinstance(os_ops, OsOperations)
		self._os_ops = os_ops
		self._guard = threading.Lock()
		self._available_ports = set(range(1024,65535))
		self._available_ports = set(range(1024,65536))
		self._reserved_ports = set()
		self._lock_dir = None

Expand DownExpand Up		@@ -52,9 +52,13 @@ def reserve_port(self) -> int:
		t = None

		for port in sampled_ports:
		assert type(port) == int # noqa: E721
		assert not (port in self._reserved_ports)
		assert port in self._available_ports

		assert port >= 0
		assert port <= 65535

		if not self._os_ops.is_port_free(port):
		continue

Expand DownExpand Up		@@ -82,6 +86,8 @@ def reserve_port(self) -> int:

		def release_port(self, number: int) -> None:
		assert type(number) == int # noqa: E721
		assert number >= 0
		assert number <= 65535

		assert self._guard is not None
		assert type(self._reserved_ports) == set # noqa: E721
Expand Down