diff options
author | Evgueni Petrov <evgueni.s.petrov@gmail.com> | 2022-02-10 16:47:00 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:47:00 +0300 |
commit | 6bde7c5def28273dc3eb4b26959d640ce52e5d2f (patch) | |
tree | b83306b6e37edeea782e9eed673d89286c4fef35 /library/python/testing | |
parent | 19d7d7947f95423df4b50d3a6e858cd689db06ed (diff) | |
download | ydb-6bde7c5def28273dc3eb4b26959d640ce52e5d2f.tar.gz |
Restoring authorship annotation for Evgueni Petrov <evgueni.s.petrov@gmail.com>. Commit 2 of 2.
Diffstat (limited to 'library/python/testing')
-rw-r--r-- | library/python/testing/yatest_common/yatest/common/network.py | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/library/python/testing/yatest_common/yatest/common/network.py b/library/python/testing/yatest_common/yatest/common/network.py index ce3074dcb2..37bcb1b8e0 100644 --- a/library/python/testing/yatest_common/yatest/common/network.py +++ b/library/python/testing/yatest_common/yatest/common/network.py @@ -71,7 +71,7 @@ class PortManager(object): retries -= 1 result_port = self.get_tcp_port() - if not self.is_port_free(result_port, socket.SOCK_DGRAM): + if not self.is_port_free(result_port, socket.SOCK_DGRAM): self.release_port(result_port) # Don't try to _capture_port(), it's already captured in the get_tcp_port() return result_port @@ -163,7 +163,7 @@ class PortManager(object): with self._lock: return self._capture_port_no_lock(port, sock_type) - def is_port_free(self, port, sock_type=socket.SOCK_STREAM): + def is_port_free(self, port, sock_type=socket.SOCK_STREAM): sock = socket.socket(socket.AF_INET6, sock_type) try: sock.bind(('::', port)) @@ -189,14 +189,14 @@ class PortManager(object): filelock = library.python.filelock.FileLock(os.path.join(self._sync_dir, str(port))) if not filelock.acquire(blocking=False): return False - if self.is_port_free(port, sock_type): + if self.is_port_free(port, sock_type): self._filelocks[port] = filelock return True else: filelock.release() return False - if self.is_port_free(port, sock_type): + if self.is_port_free(port, sock_type): self._filelocks[port] = filelock return True if filelock: |