MACOS = (sys.platform == 'darwin')
BUF_MULTIPLIER = 1024 if not MACOS else 64
+HANDSHAKE_TIMEOUT = support.LONG_TIMEOUT
def tearDownModule():
await fut
async def start_server():
- extras = {}
- extras = dict(ssl_handshake_timeout=support.SHORT_TIMEOUT)
-
srv = await asyncio.start_server(
handle_client,
'127.0.0.1', 0,
family=socket.AF_INET,
ssl=sslctx,
- **extras)
+ ssl_handshake_timeout=HANDSHAKE_TIMEOUT)
try:
srv_socks = srv.sockets
sock.close()
async def client(addr):
- extras = {}
- extras = dict(ssl_handshake_timeout=support.SHORT_TIMEOUT)
-
reader, writer = await asyncio.open_connection(
*addr,
ssl=client_sslctx,
server_hostname='',
- **extras)
+ ssl_handshake_timeout=HANDSHAKE_TIMEOUT)
writer.write(A_DATA)
self.assertEqual(await reader.readexactly(2), b'OK')
reader, writer = await asyncio.open_connection(
sock=sock,
ssl=client_sslctx,
- server_hostname='')
+ server_hostname='',
+ ssl_handshake_timeout=HANDSHAKE_TIMEOUT)
writer.write(A_DATA)
self.assertEqual(await reader.readexactly(2), b'OK')
*addr,
ssl=client_sslctx,
server_hostname='',
- ssl_handshake_timeout=support.SHORT_TIMEOUT)
+ ssl_handshake_timeout=HANDSHAKE_TIMEOUT)
writer.close()
await self.wait_closed(writer)
extras = {}
if server_ssl:
- extras = dict(ssl_handshake_timeout=support.SHORT_TIMEOUT)
+ extras = dict(ssl_handshake_timeout=HANDSHAKE_TIMEOUT)
f = loop.create_task(
loop.connect_accepted_socket(
reader, writer = await asyncio.open_connection(
*addr,
ssl=client_sslctx,
- server_hostname='')
+ server_hostname='',
+ ssl_handshake_timeout=HANDSHAKE_TIMEOUT)
self.assertEqual(await reader.readline(), b'A\n')
writer.write(b'B')
await fut
async def start_server():
- extras = {}
-
srv = await self.loop.create_server(
server_protocol_factory,
'127.0.0.1', 0,
family=socket.AF_INET,
- ssl=sslctx_1,
- **extras)
+ ssl=sslctx_1)
try:
srv_socks = srv.sockets
sock.close()
async def client(addr):
- extras = {}
- extras = dict(ssl_handshake_timeout=support.SHORT_TIMEOUT)
-
reader, writer = await asyncio.open_connection(
*addr,
ssl=client_sslctx,
server_hostname='',
- **extras)
+ ssl_handshake_timeout=HANDSHAKE_TIMEOUT)
writer.write(A_DATA)
self.assertEqual(await reader.readexactly(2), b'OK')
reader, writer = await asyncio.open_connection(
*addr,
ssl=client_sslctx,
- server_hostname='')
+ server_hostname='',
+ ssl_handshake_timeout=HANDSHAKE_TIMEOUT)
sslprotocol = writer.transport._ssl_protocol
writer.write(b'ping')
data = await reader.readexactly(4)
reader, writer = await asyncio.open_connection(
*addr,
ssl=client_sslctx,
- server_hostname='')
+ server_hostname='',
+ ssl_handshake_timeout=HANDSHAKE_TIMEOUT)
writer.write(b'ping')
data = await reader.readexactly(4)
self.assertEqual(data, b'pong')
reader, writer = await asyncio.open_connection(
*addr,
ssl=client_sslctx,
- server_hostname='')
+ server_hostname='',
+ ssl_handshake_timeout=HANDSHAKE_TIMEOUT)
writer.write(b'ping')
data = await reader.readexactly(4)
self.assertEqual(data, b'pong')