summaryrefslogtreecommitdiffhomepage
path: root/test
diff options
context:
space:
mode:
authorAndrei Zeliankou <zelenkov@nginx.com>2020-03-23 19:18:26 +0000
committerAndrei Zeliankou <zelenkov@nginx.com>2020-03-23 19:18:26 +0000
commit48ad88ee7209fd949f3ed1075f62ca78c2220224 (patch)
treeecf9442c82b4f94054116c76102011a9298b10d6 /test
parentac9ca6d75cf8987b6650923aa126c0d3ab06f41e (diff)
downloadunit-48ad88ee7209fd949f3ed1075f62ca78c2220224.tar.gz
unit-48ad88ee7209fd949f3ed1075f62ca78c2220224.tar.bz2
Tests: increase default "read_timeout" value to 60s.
This change is necessary to avoid errors on slow hosts. Also slightly reworked argument passing to the recvall() function.
Diffstat (limited to '')
-rw-r--r--test/unit/applications/websockets.py4
-rw-r--r--test/unit/http.py27
2 files changed, 16 insertions, 15 deletions
diff --git a/test/unit/applications/websockets.py b/test/unit/applications/websockets.py
index ef16f433..eaed2ee7 100644
--- a/test/unit/applications/websockets.py
+++ b/test/unit/applications/websockets.py
@@ -52,7 +52,7 @@ class TestApplicationWebsocket(TestApplicationProto):
)
resp = ''
- while select.select([sock], [], [], 30)[0]:
+ while select.select([sock], [], [], 60)[0]:
resp += sock.recv(4096).decode()
if (
@@ -70,7 +70,7 @@ class TestApplicationWebsocket(TestApplicationProto):
def serialize_close(self, code=1000, reason=''):
return struct.pack('!H', code) + reason.encode('utf-8')
- def frame_read(self, sock, read_timeout=30):
+ def frame_read(self, sock, read_timeout=60):
def recv_bytes(sock, bytes):
data = b''
while select.select([sock], [], [], read_timeout)[0]:
diff --git a/test/unit/http.py b/test/unit/http.py
index 281b27d6..8c71825a 100644
--- a/test/unit/http.py
+++ b/test/unit/http.py
@@ -17,11 +17,6 @@ class TestHTTP(TestUnit):
port = 7080 if 'port' not in kwargs else kwargs['port']
url = '/' if 'url' not in kwargs else kwargs['url']
http = 'HTTP/1.0' if 'http_10' in kwargs else 'HTTP/1.1'
- read_buffer_size = (
- 4096
- if 'read_buffer_size' not in kwargs
- else kwargs['read_buffer_size']
- )
headers = (
{'Host': 'localhost', 'Connection': 'close'}
@@ -101,12 +96,15 @@ class TestHTTP(TestUnit):
resp = ''
if 'no_recv' not in kwargs:
- read_timeout = (
- 30 if 'read_timeout' not in kwargs else kwargs['read_timeout']
- )
- resp = self.recvall(
- sock, read_timeout=read_timeout, buff_size=read_buffer_size
- ).decode(encoding)
+ recvall_kwargs = {}
+
+ if 'read_timeout' in kwargs:
+ recvall_kwargs['read_timeout'] = kwargs['read_timeout']
+
+ if 'read_buffer_size' in kwargs:
+ recvall_kwargs['buff_size'] = kwargs['read_buffer_size']
+
+ resp = self.recvall(sock, **recvall_kwargs).decode(encoding)
self.log_in(resp)
@@ -174,9 +172,12 @@ class TestHTTP(TestUnit):
def put(self, **kwargs):
return self.http('PUT', **kwargs)
- def recvall(self, sock, read_timeout=30, buff_size=4096):
+ def recvall(self, sock, **kwargs):
+ timeout = 60 if 'read_timeout' not in kwargs else kwargs['read_timeout']
+ buff_size = 4096 if 'buff_size' not in kwargs else kwargs['buff_size']
+
data = b''
- while select.select([sock], [], [], read_timeout)[0]:
+ while select.select([sock], [], [], timeout)[0]:
try:
part = sock.recv(buff_size)
except: