XMAN Replicator

Path: /opt/cloudlinux/venv/lib/python3.11/site-packages/aiohttp/

Name	Size	Rights	Date	Actions
[.]	<DIR>	drwxr-xr-x	2026-02-11 06:01	🔄 🗑️ 🗑️📁 ⬇️ 🔒
[..]	<DIR>	drwxr-xr-x	2026-06-17 05:00	🔄 🗑️ 🗑️📁 ⬇️ 🔒
[.hash]	<DIR>	drwxr-xr-x	2026-02-11 06:01	🔄 🗑️ 🗑️📁 ⬇️ 🔒
__init__.py	7,762 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
[__pycache__]	<DIR>	drwxr-xr-x	2026-02-11 06:08	🔄 🗑️ 🗑️📁 ⬇️ 🔒
_cparser.pxd	4,318 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
_find_header.pxd	68 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
_headers.pxi	2,007 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
_helpers.cpython-311-x86_64-linux-gnu.so	88,072 B	-rwxr-xr-x	2026-01-20 13:18	✏️ 🔄 🗑️ ⬇️ 🔒
_helpers.pyi	202 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
_helpers.pyx	1,049 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
_http_parser.cpython-311-x86_64-linux-gnu.so	583,264 B	-rwxr-xr-x	2026-01-20 13:18	✏️ 🔄 🗑️ ⬇️ 🔒
_http_parser.pyx	28,058 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
_http_writer.cpython-311-x86_64-linux-gnu.so	76,808 B	-rwxr-xr-x	2026-01-20 13:18	✏️ 🔄 🗑️ ⬇️ 🔒
_http_writer.pyx	4,575 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
_websocket.cpython-311-x86_64-linux-gnu.so	54,648 B	-rwxr-xr-x	2026-01-20 13:18	✏️ 🔄 🗑️ ⬇️ 🔒
_websocket.pyx	1,561 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
abc.py	5,500 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
base_protocol.py	2,741 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
client.py	47,276 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
client_exceptions.py	9,411 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
client_proto.py	8,651 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
client_reqrep.py	39,680 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
client_ws.py	11,010 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
compression_utils.py	5,015 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
connector.py	52,798 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
cookiejar.py	14,015 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
formdata.py	6,106 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
hdrs.py	4,613 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
helpers.py	30,255 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
http.py	1,842 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
http_exceptions.py	2,716 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
http_parser.py	35,496 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
http_websocket.py	26,716 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
http_writer.py	5,933 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
locks.py	1,136 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
log.py	325 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
multipart.py	32,472 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
payload.py	13,542 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
payload_streamer.py	2,087 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
py.typed	7 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
pytest_plugin.py	11,605 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
resolver.py	5,070 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
streams.py	20,836 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
tcp_helpers.py	961 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
test_utils.py	20,185 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
tracing.py	15,132 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
typedefs.py	1,471 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
web.py	19,263 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
web_app.py	18,311 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
web_exceptions.py	10,360 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
web_fileresponse.py	11,416 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
web_log.py	7,801 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
web_middlewares.py	4,032 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
web_protocol.py	23,044 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
web_request.py	28,756 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
web_response.py	27,729 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
web_routedef.py	6,132 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
web_runner.py	11,736 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
web_server.py	2,587 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
web_urldispatcher.py	40,057 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
web_ws.py	18,647 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
worker.py	7,965 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒

Edit: worker.py

"""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")

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: Optional[asyncio.Task[None]] = None
        self.exit_code = 0
        self._notify_waiter: Optional[asyncio.Future[bool]] = None

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
                ),
                shutdown_timeout=self.cfg.graceful_timeout / 100 * 95,
            )
        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,
            )
            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.max_requests and cnt > self.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

def handle_quit(self, sig: int, frame: Optional[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: Optional[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()

🛸 XMAN Replicator

Edit: worker.py

PHP Console

SQL Console