/unit/test/ |
H A D | test_asgi_application.py | 242 read_timeout=1, 270 read_timeout=1, 288 read_timeout=1, 317 read_timeout=1,
|
H A D | test_procman.py | 185 read_timeout=1,
|
H A D | test_reconfigure_tls.py | 61 read_timeout=1,
|
H A D | test_node_application.py | 143 read_timeout=1,
|
H A D | test_access_log.py | 47 read_timeout=1, 187 _ = client.http(b"""GE""", raw=True, read_timeout=1) 213 _ = client.http(b"""GET / HTTP/1.1""", raw=True, read_timeout=1) 227 _ = client.http(b"""GET / HTTP/1.1\n""", raw=True, read_timeout=1) 309 client.post(url='/bbs', body=body, read_timeout=1)
|
H A D | test_ruby_application.py | 403 read_timeout=1,
|
H A D | test_tls.py | 521 read_timeout=1, 574 read_timeout=1, 621 read_timeout=1,
|
H A D | test_settings.py | 113 read_timeout=1, 170 read_timeout=1, 204 read_timeout=1, 238 read_timeout=1, 245 b"""012""", start=True, sock=sock, read_timeout=1, raw=True 251 b"""345""", start=True, sock=sock, read_timeout=1, raw=True 319 read_timeout=1,
|
H A D | test_static_fallback.py | 145 client.get(read_timeout=1)
|
H A D | test_php_application.py | 318 read_timeout=1,
|
H A D | test_perl_application.py | 229 read_timeout=1,
|
H A D | test_python_application.py | 213 read_timeout=1, 241 read_timeout=1, 259 read_timeout=1, 288 read_timeout=1,
|
H A D | test_proxy.py | 508 get_http10(read_timeout=1)
|
H A D | test_java_application.py | 810 read_timeout=1,
|
H A D | test_node_websockets.py | 25 assert client.recvall(sock, read_timeout=0.1) == b'', 'empty soc' 468 assert client.recvall(sock, read_timeout=0.1) == b'', '2_7' 473 assert client.recvall(sock, read_timeout=0.1) == b'', '2_8' 541 assert client.recvall(sock, read_timeout=0.1) == b'', 'empty 3_2' 557 assert client.recvall(sock, read_timeout=0.1) == b'', 'empty 3_3' 757 assert client.recvall(sock, read_timeout=0.1) == b'', '5_4' 790 assert client.recvall(sock, read_timeout=0.1) == b'', '5_7' 965 assert client.recvall(sock, read_timeout=0.1) == b'', '5_20' 1138 client.recvall(sock, read_timeout=1) 1295 frame = ws.frame_read(sock, read_timeout=5) [all …]
|
H A D | test_java_websockets.py | 25 assert client.recvall(sock, read_timeout=0.1) == b'', 'empty soc' 448 assert client.recvall(sock, read_timeout=0.1) == b'', '2_7' 453 assert client.recvall(sock, read_timeout=0.1) == b'', '2_8' 521 assert client.recvall(sock, read_timeout=0.1) == b'', 'empty 3_2' 737 assert client.recvall(sock, read_timeout=0.1) == b'', '5_4' 770 assert client.recvall(sock, read_timeout=0.1) == b'', '5_7' 945 assert client.recvall(sock, read_timeout=0.1) == b'', '5_20' 966 frame = ws.frame_read(sock, read_timeout=3) 975 frame = ws.frame_read(sock, read_timeout=3) 1118 client.recvall(sock, read_timeout=1) [all …]
|
H A D | test_asgi_websockets.py | 28 assert client.recvall(sock, read_timeout=0.1) == b'', 'empty soc' 520 assert client.recvall(sock, read_timeout=0.1) == b'', '2_7' 525 assert client.recvall(sock, read_timeout=0.1) == b'', '2_8' 593 assert client.recvall(sock, read_timeout=0.1) == b'', 'empty 3_2' 609 assert client.recvall(sock, read_timeout=0.1) == b'', 'empty 3_3' 809 assert client.recvall(sock, read_timeout=0.1) == b'', '5_4' 842 assert client.recvall(sock, read_timeout=0.1) == b'', '5_7' 1017 assert client.recvall(sock, read_timeout=0.1) == b'', '5_20' 1190 client.recvall(sock, read_timeout=1) 1347 frame = ws.frame_read(sock, read_timeout=5) [all …]
|
H A D | test_go_application.py | 97 read_timeout=1,
|
H A D | test_status.py | 123 read_timeout=1, 141 read_timeout=1, 187 read_timeout=1, 213 client.get(read_timeout=1)
|
/unit/src/ |
H A D | nxt_router.c | 1589 offsetof(nxt_websocket_conf_t, read_timeout), 1993 skcf->websocket_conf.read_timeout = 60 * 1000; in nxt_router_conf_create()
|
H A D | nxt_router.h | 164 nxt_msec_t read_timeout; member
|
H A D | nxt_h1proto_websocket.c | 211 .timer_data = offsetof(nxt_socket_conf_t, websocket_conf.read_timeout), 536 .timer_data = offsetof(nxt_socket_conf_t, websocket_conf.read_timeout),
|
/unit/test/unit/applications/ |
H A D | websockets.py | 72 def frame_read(self, sock, read_timeout=60): argument 76 rlist = select.select([sock], [], [], read_timeout)[0] 80 if read_timeout == 60: 229 def message_read(self, sock, read_timeout=60): argument 230 frame = self.frame_read(sock, read_timeout=read_timeout) 233 temp = self.frame_read(sock, read_timeout=read_timeout)
|