FM / aiohttp

/opt/alt/python37/lib64/python3.7/site-packages/aiohttp/

/opt/alt/python37/lib64/python3.7/site-packages/aiohttp

Name	Size	Mode	Actions
.hash/	-	0755	rm
__pycache__/	-	0755	rm
abc.py	5513	0644	edit dl rm
base_protocol.py	2700	0644	edit dl rm
client.py	44926	0644	edit dl rm
client_exceptions.py	9277	0644	edit dl rm
client_proto.py	8196	0644	edit dl rm
client_reqrep.py	36886	0644	edit dl rm
client_ws.py	10540	0644	edit dl rm
connector.py	50854	0644	edit dl rm
cookiejar.py	13570	0644	edit dl rm
formdata.py	6122	0644	edit dl rm
hdrs.py	4724	0644	edit dl rm
helpers.py	26243	0644	edit dl rm
http.py	1824	0644	edit dl rm
http_exceptions.py	2586	0644	edit dl rm
http_parser.py	32590	0644	edit dl rm
http_websocket.py	25359	0644	edit dl rm
http_writer.py	5976	0644	edit dl rm
locks.py	1152	0644	edit dl rm
log.py	325	0644	edit dl rm
multipart.py	32437	0644	edit dl rm
payload.py	13700	0644	edit dl rm
payload_streamer.py	2112	0644	edit dl rm
py.typed	7	0644	edit dl rm
pytest_plugin.py	11772	0644	edit dl rm
resolver.py	5092	0644	edit dl rm
streams.py	20840	0644	edit dl rm
tcp_helpers.py	962	0644	edit dl rm
test_utils.py	21219	0644	edit dl rm
tracing.py	15305	0644	edit dl rm
typedefs.py	1766	0644	edit dl rm
web.py	17929	0644	edit dl rm
web_app.py	17268	0644	edit dl rm
web_exceptions.py	10106	0644	edit dl rm
web_fileresponse.py	10784	0644	edit dl rm
web_log.py	7565	0644	edit dl rm
web_middlewares.py	4137	0644	edit dl rm
web_protocol.py	22548	0644	edit dl rm
web_request.py	27888	0644	edit dl rm
web_response.py	27567	0644	edit dl rm
web_routedef.py	6040	0644	edit dl rm
web_runner.py	11189	0644	edit dl rm
web_server.py	2058	0644	edit dl rm
web_urldispatcher.py	39547	0644	edit dl rm
web_ws.py	17259	0644	edit dl rm
worker.py	8779	0644	edit dl rm
_cparser.pxd	4998	0644	edit dl rm
_find_header.c	187570	0644	edit dl rm
_find_header.h	170	0644	edit dl rm
_find_header.pxd	68	0644	edit dl rm
_headers.pxi	2007	0644	edit dl rm
_helpers.c	212982	0644	edit dl rm
_helpers.cpython-37m-x86_64-linux-gnu.so	194883	0755	edit dl rm
_helpers.pyi	202	0644	edit dl rm
_helpers.pyx	1049	0644	edit dl rm
_http_parser.c	978187	0644	edit dl rm
_http_parser.cpython-37m-x86_64-linux-gnu.so	1446340	0755	edit dl rm
_http_parser.pyx	26571	0644	edit dl rm
_http_writer.c	221270	0644	edit dl rm
_http_writer.cpython-37m-x86_64-linux-gnu.so	207227	0755	edit dl rm
_http_writer.pyx	4575	0644	edit dl rm
_websocket.c	138420	0644	edit dl rm
_websocket.cpython-37m-x86_64-linux-gnu.so	93369	0755	edit dl rm
_websocket.pyx	1561	0644	edit dl rm
__init__.py	6870	0644	edit dl rm

Edit: /opt/alt/python37/lib64/python3.7/site-packages/aiohttp/worker.py (8779B)

"""Async gunicorn worker for aiohttp.web"""

import asyncio
import os
import re
import signal
import sys
from types import FrameType
from typing import Any, Awaitable, Callable, Optional, Union  # noqa

from gunicorn.config import AccessLogFormat as GunicornAccessLogFormat
from gunicorn.workers import base

from aiohttp import web

from .helpers import set_result
from .web_app import Application
from .web_log import AccessLogger

try:
    import ssl

SSLContext = ssl.SSLContext
except ImportError:  # pragma: no cover
    ssl = None  # type: ignore[assignment]
    SSLContext = object  # type: ignore[misc,assignment]

__all__ = ("GunicornWebWorker", "GunicornUVLoopWebWorker", "GunicornTokioWebWorker")

class GunicornWebWorker(base.Worker):  # type: ignore[misc,no-any-unimported]

DEFAULT_AIOHTTP_LOG_FORMAT = AccessLogger.LOG_FORMAT
    DEFAULT_GUNICORN_LOG_FORMAT = GunicornAccessLogFormat.default

def __init__(self, *args: Any, **kw: Any) -> None:  # pragma: no cover
        super().__init__(*args, **kw)

self._task = None  # type: Optional[asyncio.Task[None]]
        self.exit_code = 0
        self._notify_waiter = None  # type: Optional[asyncio.Future[bool]]

def init_process(self) -> None:
        # create new event_loop after fork
        asyncio.get_event_loop().close()

self.loop = asyncio.new_event_loop()
        asyncio.set_event_loop(self.loop)

super().init_process()

def run(self) -> None:
        self._task = self.loop.create_task(self._run())

try:  # ignore all finalization problems
            self.loop.run_until_complete(self._task)
        except Exception:
            self.log.exception("Exception in gunicorn worker")
        self.loop.run_until_complete(self.loop.shutdown_asyncgens())
        self.loop.close()

sys.exit(self.exit_code)

async def _run(self) -> None:
        runner = None
        if isinstance(self.wsgi, Application):
            app = self.wsgi
        elif asyncio.iscoroutinefunction(self.wsgi):
            wsgi = await self.wsgi()
            if isinstance(wsgi, web.AppRunner):
                runner = wsgi
                app = runner.app
            else:
                app = wsgi
        else:
            raise RuntimeError(
                "wsgi app should be either Application or "
                "async function returning Application, got {}".format(self.wsgi)
            )

if runner is None:
            access_log = self.log.access_log if self.cfg.accesslog else None
            runner = web.AppRunner(
                app,
                logger=self.log,
                keepalive_timeout=self.cfg.keepalive,
                access_log=access_log,
                access_log_format=self._get_valid_log_format(
                    self.cfg.access_log_format
                ),
            )
        await runner.setup()

ctx = self._create_ssl_context(self.cfg) if self.cfg.is_ssl else None

runner = runner
        assert runner is not None
        server = runner.server
        assert server is not None
        for sock in self.sockets:
            site = web.SockSite(
                runner,
                sock,
                ssl_context=ctx,
                shutdown_timeout=self.cfg.graceful_timeout / 100 * 95,
            )
            await site.start()

# If our parent changed then we shut down.
        pid = os.getpid()
        try:
            while self.alive:  # type: ignore[has-type]
                self.notify()

cnt = server.requests_count
                if self.cfg.max_requests and cnt > self.cfg.max_requests:
                    self.alive = False
                    self.log.info("Max requests, shutting down: %s", self)

elif pid == os.getpid() and self.ppid != os.getppid():
                    self.alive = False
                    self.log.info("Parent changed, shutting down: %s", self)
                else:
                    await self._wait_next_notify()
        except BaseException:
            pass

await runner.cleanup()

def _wait_next_notify(self) -> "asyncio.Future[bool]":
        self._notify_waiter_done()

loop = self.loop
        assert loop is not None
        self._notify_waiter = waiter = loop.create_future()
        self.loop.call_later(1.0, self._notify_waiter_done, waiter)

return waiter

def _notify_waiter_done(
        self, waiter: Optional["asyncio.Future[bool]"] = None
    ) -> None:
        if waiter is None:
            waiter = self._notify_waiter
        if waiter is not None:
            set_result(waiter, True)

if waiter is self._notify_waiter:
            self._notify_waiter = None

def init_signals(self) -> None:
        # Set up signals through the event loop API.

self.loop.add_signal_handler(
            signal.SIGQUIT, self.handle_quit, signal.SIGQUIT, None
        )

self.loop.add_signal_handler(
            signal.SIGTERM, self.handle_exit, signal.SIGTERM, None
        )

self.loop.add_signal_handler(
            signal.SIGINT, self.handle_quit, signal.SIGINT, None
        )

self.loop.add_signal_handler(
            signal.SIGWINCH, self.handle_winch, signal.SIGWINCH, None
        )

self.loop.add_signal_handler(
            signal.SIGUSR1, self.handle_usr1, signal.SIGUSR1, None
        )

self.loop.add_signal_handler(
            signal.SIGABRT, self.handle_abort, signal.SIGABRT, None
        )

# Don't let SIGTERM and SIGUSR1 disturb active requests
        # by interrupting system calls
        signal.siginterrupt(signal.SIGTERM, False)
        signal.siginterrupt(signal.SIGUSR1, False)
        # Reset signals so Gunicorn doesn't swallow subprocess return codes
        # See: https://github.com/aio-libs/aiohttp/issues/6130
        if sys.version_info < (3, 8):
            # Starting from Python 3.8,
            # the default child watcher is ThreadedChildWatcher.
            # The watcher doesn't depend on SIGCHLD signal,
            # there is no need to reset it.
            signal.signal(signal.SIGCHLD, signal.SIG_DFL)

def handle_quit(self, sig: int, frame: FrameType) -> None:
        self.alive = False

# worker_int callback
        self.cfg.worker_int(self)

# wakeup closing process
        self._notify_waiter_done()

def handle_abort(self, sig: int, frame: FrameType) -> None:
        self.alive = False
        self.exit_code = 1
        self.cfg.worker_abort(self)
        sys.exit(1)

@staticmethod
    def _create_ssl_context(cfg: Any) -> "SSLContext":
        """Creates SSLContext instance for usage in asyncio.create_server.

See ssl.SSLSocket.__init__ for more details.
        """
        if ssl is None:  # pragma: no cover
            raise RuntimeError("SSL is not supported.")

ctx = ssl.SSLContext(cfg.ssl_version)
        ctx.load_cert_chain(cfg.certfile, cfg.keyfile)
        ctx.verify_mode = cfg.cert_reqs
        if cfg.ca_certs:
            ctx.load_verify_locations(cfg.ca_certs)
        if cfg.ciphers:
            ctx.set_ciphers(cfg.ciphers)
        return ctx

def _get_valid_log_format(self, source_format: str) -> str:
        if source_format == self.DEFAULT_GUNICORN_LOG_FORMAT:
            return self.DEFAULT_AIOHTTP_LOG_FORMAT
        elif re.search(r"%\([^\)]+\)", source_format):
            raise ValueError(
                "Gunicorn's style options in form of `%(name)s` are not "
                "supported for the log formatting. Please use aiohttp's "
                "format specification to configure access log formatting: "
                "http://docs.aiohttp.org/en/stable/logging.html"
                "#format-specification"
            )
        else:
            return source_format

class GunicornUVLoopWebWorker(GunicornWebWorker):
    def init_process(self) -> None:
        import uvloop

# Close any existing event loop before setting a
        # new policy.
        asyncio.get_event_loop().close()

# Setup uvloop policy, so that every
        # asyncio.get_event_loop() will create an instance
        # of uvloop event loop.
        asyncio.set_event_loop_policy(uvloop.EventLoopPolicy())

super().init_process()

class GunicornTokioWebWorker(GunicornWebWorker):
    def init_process(self) -> None:  # pragma: no cover
        import tokio

# Close any existing event loop before setting a
        # new policy.
        asyncio.get_event_loop().close()

# Setup tokio policy, so that every
        # asyncio.get_event_loop() will create an instance
        # of tokio event loop.
        asyncio.set_event_loop_policy(tokio.EventLoopPolicy())

super().init_process()

cmd: