/usr/lib/python3/dist-packages/aiohttp/web_server.py is in python3-aiohttp 3.0.1-1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 | """Low level HTTP server."""
import asyncio
from .web_protocol import RequestHandler
from .web_request import BaseRequest
__all__ = ('Server',)
class Server:
def __init__(self, handler, *, request_factory=None, loop=None, **kwargs):
if loop is None:
loop = asyncio.get_event_loop()
self._loop = loop
self._connections = {}
self._kwargs = kwargs
self.requests_count = 0
self.request_handler = handler
self.request_factory = request_factory or self._make_request
@property
def connections(self):
return list(self._connections.keys())
def connection_made(self, handler, transport):
self._connections[handler] = transport
def connection_lost(self, handler, exc=None):
if handler in self._connections:
del self._connections[handler]
def _make_request(self, message, payload, protocol, writer, task):
return BaseRequest(
message, payload, protocol, writer, task, self._loop)
async def shutdown(self, timeout=None):
coros = [conn.shutdown(timeout) for conn in self._connections]
await asyncio.gather(*coros, loop=self._loop)
self._connections.clear()
def __call__(self):
return RequestHandler(self, loop=self._loop, **self._kwargs)
|