Home
last modified time | relevance | path

Searched refs:sock (Results 1 – 25 of 73) sorted by relevance

123

/unit/test/
H A Dtest_node_websockets.py39 sock.close()
55 sock.close()
81 sock.close()
97 sock.close()
116 sock.close()
141 sock.close()
160 sock.close()
214 sock.close()
564 sock,
832 sock,
[all …]
H A Dtest_java_websockets.py39 sock.close()
55 sock.close()
81 sock.close()
97 sock.close()
116 sock.close()
141 sock.close()
195 sock.close()
326 sock.close()
545 sock,
813 sock,
[all …]
H A Dtest_asgi_websockets.py61 sock.close()
77 sock.close()
102 sock.close()
123 sock.close()
139 sock.close()
158 sock.close()
195 sock.close()
214 sock.close()
618 sock,
886 sock,
[all …]
H A Dtest_settings.py32 sock=sock,
65 sock=sock,
76 sock=sock,
82 sock.close()
91 sock=sock,
116 return self.http(b"""0123456789""", sock=sock, raw=True)
150 b"""012""", start=True, sock=sock, read_timeout=1, raw=True
156 b"""345""", start=True, sock=sock, read_timeout=1, raw=True
161 resp = self.http(b"""6789""", sock=sock, raw=True)
232 return self.get(sock=sock)
[all …]
H A Dtest_proxy.py23 sock.bind(server_address)
24 sock.listen(5)
26 def recvall(sock): argument
193 socks.append(sock)
263 sock.close()
272 sock.close()
296 sock.close()
314 sock.close()
392 sock = self.post_http10(
404 sock.close()
[all …]
H A Dtest_tls_conf_command.py38 (resp, sock) = self.get_ssl(start=True)
40 shared_ciphers = sock.shared_ciphers()
42 protocol = sock.cipher()[1]
55 sock.close()
58 (resp, sock) = self.get_ssl(start=True)
60 cipher = sock.cipher()
63 shared_ciphers = sock.shared_ciphers()
66 sock.close()
85 (resp, sock) = self.get_ssl(start=True)
87 cipher_new = sock.cipher()
[all …]
H A Dtest_asgi_application.py186 resp = self.post(sock=sock, body=body)
214 socks.append(sock)
223 sock=socks[i],
262 (resp, sock) = self.post(start=True, sock=sock, body=body)
271 resp = self.get(sock=sock)
280 sock = self.http(
298 sock=sock,
360 sock = self.get(
369 socks.append(sock)
375 for sock in socks:
[all …]
H A Dtest_reconfigure.py24 sock = self.http(
38 sock=sock,
44 sock = self.http(b'', raw=True, no_recv=True)
52 assert self.get(sock=sock)['status'] == 408, 'request timeout'
H A Dtest_node_es_modules.py36 _, sock, _ = self.ws.upgrade()
38 self.ws.frame_write(sock, self.ws.OP_TEXT, message)
39 frame = self.ws.frame_read(sock)
43 self.ws.frame_write(sock, self.ws.OP_TEXT, message)
44 frame = self.ws.frame_read(sock)
48 sock.close()
H A Dtest_status.py84 sock = self.get(port=7081, no_recv=True)
90 sock.close()
115 sock = self.http(b'', raw=True, no_recv=True)
118 self.get(sock=sock)
123 (_, sock) = self.get(
135 self.get(sock=sock)
169 (_, sock) = self.get(
179 sock.close()
H A Dtest_python_application.py171 resp = self.post(sock=sock, body=body)
199 socks.append(sock)
208 sock=socks[i],
247 (resp, sock) = self.post(start=True, sock=sock, body=body)
256 resp = self.get(sock=sock)
553 _, sock = self.get(
568 assert self.get(sock=sock) == {}, 'closed connection'
588 _, sock = self.get(
603 assert self.get(sock=sock) == {}, 'closed connection 2'
781 for sock in socks:
[all …]
H A Dtest_proxy_chunked.py19 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
20 sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
21 sock.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1)
24 sock.bind(server_address)
25 sock.listen(10)
27 def recvall(sock): argument
31 rlist = select.select([sock], [], [], 0.1)
36 part = sock.recv(buff_size)
45 connection, client_address = sock.accept()
H A Dtest_perl_application.py195 (resp, sock) = self.post(
215 sock=sock,
262 sock = self.get(
271 socks.append(sock)
275 for sock in socks:
276 resp = self.recvall(sock).decode('utf-8')
288 sock.close()
H A Dtest_reconfigure_tls.py52 (_, sock) = self.get(
63 assert self.get(sock=sock)['status'] == 200, 'reconfigure'
105 assert self.get(sock=ssl_sock)['status'] == 408, 'request timeout'
H A Dtest_tls_sni.py138 resp, sock = self.get_ssl(
148 assert sock.getpeercert()['subject'][0][0][1] == expect
180 resp, sock = self.get_ssl(
186 sock.getpeercert()['subject'][0][0][1]
266 resp, sock = self.get_ssl(
276 assert sock.getpeercert()['subjectAltName'][0][1] == 'alt.localhost.com'
H A Dtest_ruby_application.py346 (resp, sock) = self.post(
359 resp = self.post(sock=sock, body=body)
391 sock = self.get(
400 socks.append(sock)
404 for sock in socks:
405 resp = self.recvall(sock).decode('utf-8')
417 sock.close()
H A Dtest_static.py188 sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
189 sock.bind(temp_dir + '/assets/unix_socket')
193 sock.close()
219 sock = self.get(no_recv=True)
222 assert sock.recv(1) == b'H', 'client 1'
224 assert sock.recv(1) == b'T', 'client 1 again'
227 sock.close()
H A Dtest_tls.py504 (resp, sock) = self.post_ssl(
521 sock=sock,
543 (resp, sock) = self.get_ssl(start=True)
547 sock.close()
559 (resp, sock) = self.get_ssl(
571 resp = self.get_ssl(sock=sock)
600 (_, sock) = self.post_ssl(
620 resp = self.post_ssl(sock=sock, body='0123456789')
H A Dtest_routing.py1490 return (sock, port)
1492 sock, port = sock_port()
1496 assert self.get(sock=sock)['status'] == 200, 'exact'
1499 sock, port = sock_port()
1503 assert self.get(sock=sock)['status'] == 404, 'negative'
1506 sock, port = sock_port()
1510 assert self.get(sock=sock)['status'] == 404, 'negative 3'
1513 sock, port = sock_port()
1517 assert self.get(sock=sock)['status'] == 200, 'range single'
1527 socks.sort(key=lambda sock: sock[1])
[all …]
H A Dtest_go_application.py94 (resp, sock) = self.post(
107 resp = self.post(sock=sock, body=body)
H A Dtest_variables.py53 sock = self.http(b'', raw=True, no_recv=True)
57 assert self.get(url='/r_time_1', sock=sock)['status'] == 200
60 sock = self.http(
74 sock=sock,
/unit/test/unit/applications/
H A Dwebsockets.py46 sock = self.get(
57 resp += sock.recv(4096).decode()
63 return (resp, sock, key)
71 def frame_read(self, sock, read_timeout=60): argument
72 def recv_bytes(sock, bytes): argument
104 data = recv_bytes(sock, 2)
107 data = recv_bytes(sock, 8)
111 mask_bits = recv_bytes(sock, 4)
116 data = recv_bytes(sock, length)
194 sock.sendall(frame)
[all …]
/unit/test/unit/
H A Dhttp.py49 sock = kwargs['wrapper'](sock, server_hostname=server_hostname)
53 sock.connect(connect_args)
55 sock.close()
59 sock = kwargs['sock']
88 sock.sendall(req)
110 return sock
127 sock.close()
130 return (resp, sock)
178 def recvall(self, sock, **kwargs): argument
186 rlist = select.select([sock], [], [], timeout)[0]
[all …]
H A Dutils.py54 with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock:
56 sock.settimeout(5)
57 sock.connect(('127.0.0.1', port))
/unit/pkg/docker/
H A Ddocker-entrypoint.sh7 …{http_code}' -X PUT --data-binary @$1 --unix-socket /var/run/control.unit.sock http://localhost/$2)
27 /usr/sbin/$1 --control unix:/var/run/control.unit.sock
29 …while [ ! -S /var/run/control.unit.sock ]; do echo "$0: Waiting for control socket to be created..…
32 /usr/bin/curl -s -X GET --unix-socket /var/run/control.unit.sock http://localhost/
60 …while [ -S /var/run/control.unit.sock ]; do echo "$0: Waiting for control socket to be removed..."…

123