Function run_aiohttp

benchmark/async.py:27–71

(host, port, barrier, profile)

def run_aiohttp(host, port, barrier, profile):

    from aiohttp import web

    @asyncio.coroutine
    def test(request):
        txt = 'Hello, ' + request.match_info['name']
        return web.Response(text=txt)

    @asyncio.coroutine
    def prepare(request):
        gc.collect()
        return web.Response(text='OK')

    @asyncio.coroutine
    def stop(request):
        loop.call_later(0.1, loop.stop)
        return web.Response(text='OK')

    @asyncio.coroutine
    def init(loop):
        app = web.Application(loop=loop)
        app.router.add_route('GET', '/prepare', prepare)
        app.router.add_route('GET', '/stop', stop)
        app.router.add_route('GET', '/test/{name}', test)

        handler = app.make_handler(keep_alive=15, timeout=None)
        srv = yield from loop.create_server(handler, host, port)
        return srv, app, handler

    loop = asyncio.get_event_loop()
    srv, app, handler = loop.run_until_complete(init(loop))
    barrier.wait()

    if profile:
        profiler.enable()

    loop.run_forever()
    srv.close()
    loop.run_until_complete(handler.finish_connections())
    loop.run_until_complete(srv.wait_closed())
    loop.close()

    if profile:
        profiler.disable()


def run_tornado(host, port, barrier, profile):