Lines Matching refs:sock
111 sock = socket.socket(family, socket.SOCK_STREAM)
117 sock.settimeout(timeout)
120 sock.bind(addr)
121 sock.listen(backlog)
123 sock.close()
127 self, sock, server_prog, timeout, max_clients)
133 sock = socket.socket(family, socket.SOCK_STREAM)
139 sock.settimeout(timeout)
142 self, sock, client_prog, timeout)
228 def prog(sock):
230 sock.starttls(client_sslctx)
231 sock.connect(addr)
232 sock.send(A_DATA)
234 data = sock.recv_all(2)
237 sock.send(B_DATA)
238 data = sock.recv_all(4)
241 sock.close()
304 def server(sock):
305 sock.starttls(
309 data = sock.recv_all(len(A_DATA))
311 sock.send(b'OK')
313 data = sock.recv_all(len(B_DATA))
315 sock.send(b'SPAM')
317 sock.close()
342 sock = socket.socket()
343 sock.connect(addr)
345 sock=sock,
360 sock.close()
393 def server(sock):
395 sock.recv_all(1024 * 1024)
399 sock.close()
430 def server(sock):
432 sock.starttls(
435 sock.connect()
439 sock.close()
468 def server(sock):
471 sock.recv_all(1024 * 1024)
475 sock.close()
512 def server(sock):
513 sock.recv(1024)
515 sock.close()
638 def server(sock):
639 orig_sock = sock.dup()
641 sock.starttls(
644 sock.sendall(b'A\n')
645 sock.recv_all(1)
650 sock.close()
684 def serve(sock):
685 sock.settimeout(self.TIMEOUT)
687 data = sock.recv_all(len(HELLO_MSG))
690 sock.starttls(server_context, server_side=True)
692 sock.sendall(b'O')
693 data = sock.recv_all(len(HELLO_MSG))
696 sock.unwrap()
697 sock.close()
746 def serve(sock):
747 sock.settimeout(self.TIMEOUT)
749 sock.starttls(server_context, server_side=True)
751 sock.sendall(b'O')
752 data = sock.recv_all(len(HELLO_MSG))
755 sock.unwrap()
756 sock.close()
811 def serve(sock):
812 sock.settimeout(self.TIMEOUT)
814 data = sock.recv_all(len(HELLO_MSG))
817 sock.starttls(server_context, server_side=True)
819 sock.sendall(b'O')
820 data = sock.recv_all(len(HELLO_MSG))
823 sock.sendall(b'2')
824 data = sock.recv_all(len(HELLO_MSG))
827 sock.unwrap()
828 sock.close()
904 def serve(sock):
905 sock.settimeout(self.TIMEOUT)
907 data = sock.recv_all(len(HELLO_MSG))
913 data = sock.recv_all(1024 * 1024)
917 sock.close()
965 def client(sock, addr):
966 sock.settimeout(self.TIMEOUT)
968 sock.connect(addr)
969 data = sock.recv_all(len(HELLO_MSG))
972 sock.starttls(client_context)
973 sock.sendall(HELLO_MSG)
975 sock.unwrap()
976 sock.close()
1026 with self.tcp_client(lambda sock: client(sock, addr),
1094 def prog(sock):
1096 sock.connect(addr)
1097 sock.starttls(client_sslctx_1)
1112 sock.send(outgoing.read())
1113 incoming.write(sock.recv(65536))
1115 sock.send(outgoing.read())
1134 sock.close()
1138 sock.close()
1192 def server(sock):
1193 sock.starttls(
1197 data = sock.recv_all(len(A_DATA))
1199 sock.send(b'OK')
1201 sock.unwrap()
1203 sock.close()
1258 def server(sock):
1259 sock.starttls(sslctx, server_side=True)
1260 self.assertEqual(sock.recv_all(4), b'ping')
1261 sock.send(b'pong')
1263 data = sock.recv_all(CHUNK * SIZE)
1265 sock.close()
1268 def wrapper(sock):
1270 meth(sock)
1318 def server(sock):
1328 sock.send(outgoing.read())
1329 incoming.write(sock.recv(16384))
1332 sock.send(outgoing.read())
1339 incoming.write(sock.recv(16384))
1345 sock.send(outgoing.read())
1352 sock.send(outgoing.read())
1361 incoming.write(sock.recv(16384))
1370 sock.close()
1372 def eof_server(sock):
1373 sock.starttls(sslctx, server_side=True)
1374 self.assertEqual(sock.recv_all(4), b'ping')
1375 sock.send(b'pong')
1380 sock.shutdown(socket.SHUT_WR)
1383 data = sock.recv_all(CHUNK * SIZE)
1386 sock.close()
1416 def wrapper(sock):
1418 meth(sock)
1487 def server(sock):
1492 sock = sslctx.wrap_socket(sock, server_side=True)
1493 sock.recv(32)
1494 sock.close()
1528 def server(sock):
1533 sock = sslctx.wrap_socket(sock, server_side=True)
1534 sock.send(b'hello')
1535 assert sock.recv(1024) == b'world'
1536 sock.send(b'extra bytes')
1538 sock.shutdown(socket.SHUT_WR)
1541 assert sock.recv(1024) == b''
1542 sock.close()
1587 def __init__(self, sock):
1588 self.__sock = sock
1640 def __init__(self, test, sock, prog, timeout):
1645 self._sock = sock
1661 def __init__(self, test, sock, prog, timeout, max_clients):
1669 self._sock = sock
1734 def _handle_client(self, sock):
1735 self._prog(TestSocketWrapper(sock))