Initial commit

.dockerignore

+.cache

Dockerfile

+FROM ubuntu:16.04
+MAINTAINER elvis@magic.io
+
+RUN DEBIAN_FRONTEND=noninteractive \
+        apt-get update && apt-get install -y \
+            language-pack-en
+
+ENV LANG en_US.UTF-8
+ENV WORKON_HOME /usr/local/python-venvs
+
+RUN mkdir -p /usr/local/python-venvs
+
+RUN DEBIAN_FRONTEND=noninteractive \
+        apt-get install -y \
+            autoconf automake libtool build-essential \
+            python3 python3-pip git
+
+RUN pip3 install vex
+RUN vex --python=python3.5 -m bench pip install -U pip
+RUN mkdir -p /var/lib/cache/pip
+
+ADD http_server.py /tmp/http_server.py
+ADD requirements.txt /tmp/requirements.txt
+
+EXPOSE 25000
+
+VOLUME /var/lib/cache
+
+ENTRYPOINT ["/entrypoint"]
+
+ADD entrypoint /entrypoint

entrypoint

+#!/bin/bash
+
+
+echo 'Installing packages...'
+vex bench pip --cache-dir=/var/lib/cache/pip install -r /tmp/requirements.txt
+
+mkdir -p /usr/local/repos
+cd /usr/local/repos
+git clone https://github.com/dabeaz/curio.git
+git clone https://github.com/MagicStack/uvloop.git
+cp /tmp/http_server.py uvloop/examples/bench/
+
+echo "Running server on port 25000..."
+vex bench python "$@"

http_server.py

+import argparse
+import asyncio
+import aiohttp
+import aiohttp.server
+from aiohttp import web
+import gc
+import sys
+
+import uvloop
+
+from socket import *
+
+
+PRINT = 0
+
+
+def abort(msg):
+    print(msg, file=sys.stderr)
+    sys.exit(1)
+
+
+def aiohttp_server(loop, addr):
+    PAYLOAD = b'<h1>Hello, World!</h1>'
+
+    async def handle(request):
+        return web.Response(body=PAYLOAD)
+
+    app = web.Application(loop=loop)
+    app.router.add_route('GET', '/', handle)
+    handler = app.make_handler()
+    server = loop.create_server(handler, *addr)
+
+    return server
+
+
+if __name__ == '__main__':
+    parser = argparse.ArgumentParser()
+    parser.add_argument('--type', default='asyncio+aiohttp', action='store')
+    parser.add_argument('--addr', default='127.0.0.1:25000', type=str)
+    args = parser.parse_args()
+
+    if args.type:
+        parts = args.type.split('+')
+        if len(parts) > 1:
+            loop_type = parts[0]
+            server_type = parts[1]
+        else:
+            server_type = args.type
+
+        if server_type == 'aiohttp':
+            if not loop_type:
+                loop_type = 'asyncio'
+        else:
+            loop_type = None
+
+        if loop_type not in {'asyncio', 'uvloop'}:
+            abort('unrecognized loop type: {}'.format(loop_type))
+
+        if server_type not in {'aiohttp'}:
+            abort('unrecognized server type: {}'.format(server_type))
+
+        if loop_type:
+            loop = globals()[loop_type].new_event_loop()
+        else:
+            loop = None
+
+        print('using {} loop: {!r}'.format(loop_type, loop))
+        print('using {} HTTP server'.format(server_type))
+
+    if loop:
+        asyncio.set_event_loop(loop)
+        loop.set_debug(False)
+
+    unix = False
+    if args.addr.startswith('file:'):
+        unix = True
+        addr = args.addr[5:]
+    else:
+        addr = args.addr.split(':')
+        addr[1] = int(addr[1])
+        addr = tuple(addr)
+
+    server_factory = globals()['{}_server'.format(server_type)]
+
+    print('serving on: {}'.format(addr))
+
+    if loop:
+        server = loop.run_until_complete(server_factory(loop, addr))
+        try:
+            loop.run_forever()
+        finally:
+            server.close()
+            loop.close()

requirements.txt

+uvloop
+curio
+aiohttp