uvloop#197 reproduced crash

leak.py

import asyncio
import ssl
import threading
import socket
import gc

import uvloop

asyncio.set_event_loop_policy(uvloop.EventLoopPolicy())


def server():
    s = socket.socket()
    s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
    s.bind(('0.0.0.0', 8088))
    s.listen(2000)
    while True:
        ss, addr = s.accept()
        while ss.recv(1024):
            pass


threading.Thread(target=server, daemon=True).start()


async def sub():
    try:
        ctx = ssl.SSLContext()
        ctx.verify_mode = ssl.CERT_NONE

        await asyncio.wait_for(
            asyncio.open_connection('127.0.0.1', 8088, ssl=ctx), 0.1)
    except asyncio.TimeoutError:
        pass


async def main():
    fs = []
    for i in range(1000):
        fs.append(asyncio.ensure_future(sub()))

    await asyncio.wait(fs)

    gc.collect()


def test():
    asyncio.get_event_loop().run_until_complete(main())


if __name__ == '__main__':
    test()