aboutsummaryrefslogtreecommitdiffstats
path: root/library/python/testing
diff options
context:
space:
mode:
authorEvgueni Petrov <evgueni.s.petrov@gmail.com>2022-02-10 16:47:00 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:47:00 +0300
commit6bde7c5def28273dc3eb4b26959d640ce52e5d2f (patch)
treeb83306b6e37edeea782e9eed673d89286c4fef35 /library/python/testing
parent19d7d7947f95423df4b50d3a6e858cd689db06ed (diff)
downloadydb-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.py8
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: