OXIESEC PANEL
- Current Dir:
/
/
opt
/
cloudlinux
/
venv
/
lib
/
python3.11
/
site-packages
/
aiohttp
Server IP: 2a02:4780:11:1084:0:327f:3464:10
Upload:
Create Dir:
Name
Size
Modified
Perms
📁
..
-
09/05/2025 09:34:06 AM
rwxr-xr-x
📁
.hash
-
02/07/2025 10:01:29 PM
rwxr-xr-x
📄
__init__.py
7.58 KB
12/18/2024 10:23:16 AM
rw-r--r--
📁
__pycache__
-
02/07/2025 11:11:02 PM
rwxr-xr-x
📄
_cparser.pxd
4.22 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
_find_header.pxd
68 bytes
12/18/2024 10:23:16 AM
rw-r--r--
📄
_headers.pxi
1.96 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
_helpers.cpython-311-x86_64-linux-gnu.so
86.01 KB
12/18/2024 10:23:52 AM
rwxr-xr-x
📄
_helpers.pyi
202 bytes
12/18/2024 10:23:16 AM
rw-r--r--
📄
_helpers.pyx
1.02 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
_http_parser.cpython-311-x86_64-linux-gnu.so
569.59 KB
12/18/2024 10:23:52 AM
rwxr-xr-x
📄
_http_parser.pyx
27.4 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
_http_writer.cpython-311-x86_64-linux-gnu.so
75.01 KB
12/18/2024 10:23:52 AM
rwxr-xr-x
📄
_http_writer.pyx
4.47 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
_websocket.cpython-311-x86_64-linux-gnu.so
53.37 KB
12/18/2024 10:23:52 AM
rwxr-xr-x
📄
_websocket.pyx
1.52 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
abc.py
5.37 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
base_protocol.py
2.68 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
client.py
46.17 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
client_exceptions.py
9.19 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
client_proto.py
8.45 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
client_reqrep.py
38.75 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
client_ws.py
10.75 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
compression_utils.py
4.9 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
connector.py
51.56 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
cookiejar.py
13.69 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
formdata.py
5.96 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
hdrs.py
4.5 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
helpers.py
29.55 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
http.py
1.8 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
http_exceptions.py
2.65 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
http_parser.py
34.66 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
http_websocket.py
26.09 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
http_writer.py
5.79 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
locks.py
1.11 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
log.py
325 bytes
12/18/2024 10:23:16 AM
rw-r--r--
📄
multipart.py
31.71 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
payload.py
13.22 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
payload_streamer.py
2.04 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
py.typed
7 bytes
12/18/2024 10:23:16 AM
rw-r--r--
📄
pytest_plugin.py
11.33 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
resolver.py
4.95 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
streams.py
20.35 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
tcp_helpers.py
961 bytes
12/18/2024 10:23:16 AM
rw-r--r--
📄
test_utils.py
19.71 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
tracing.py
14.78 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
typedefs.py
1.44 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
web.py
18.81 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
web_app.py
17.88 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
web_exceptions.py
10.12 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
web_fileresponse.py
11.15 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
web_log.py
7.62 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
web_middlewares.py
3.94 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
web_protocol.py
22.5 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
web_request.py
28.08 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
web_response.py
27.08 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
web_routedef.py
5.99 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
web_runner.py
11.46 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
web_server.py
2.53 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
web_urldispatcher.py
39.12 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
web_ws.py
18.21 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
worker.py
7.78 KB
12/18/2024 10:23:16 AM
rw-r--r--
Editing: web_server.py
Close
"""Low level HTTP server.""" import asyncio from typing import Any, Awaitable, Callable, Dict, List, Optional # noqa from .abc import AbstractStreamWriter from .helpers import get_running_loop from .http_parser import RawRequestMessage from .streams import StreamReader from .web_protocol import RequestHandler, _RequestFactory, _RequestHandler from .web_request import BaseRequest __all__ = ("Server",) class Server: def __init__( self, handler: _RequestHandler, *, request_factory: Optional[_RequestFactory] = None, handler_cancellation: bool = False, loop: Optional[asyncio.AbstractEventLoop] = None, **kwargs: Any ) -> None: self._loop = get_running_loop(loop) self._connections: Dict[RequestHandler, asyncio.Transport] = {} self._kwargs = kwargs self.requests_count = 0 self.request_handler = handler self.request_factory = request_factory or self._make_request self.handler_cancellation = handler_cancellation @property def connections(self) -> List[RequestHandler]: return list(self._connections.keys()) def connection_made( self, handler: RequestHandler, transport: asyncio.Transport ) -> None: self._connections[handler] = transport def connection_lost( self, handler: RequestHandler, exc: Optional[BaseException] = None ) -> None: if handler in self._connections: del self._connections[handler] def _make_request( self, message: RawRequestMessage, payload: StreamReader, protocol: RequestHandler, writer: AbstractStreamWriter, task: "asyncio.Task[None]", ) -> BaseRequest: return BaseRequest(message, payload, protocol, writer, task, self._loop) def pre_shutdown(self) -> None: for conn in self._connections: conn.close() async def shutdown(self, timeout: Optional[float] = None) -> None: coros = (conn.shutdown(timeout) for conn in self._connections) await asyncio.gather(*coros) self._connections.clear() def __call__(self) -> RequestHandler: try: return RequestHandler(self, loop=self._loop, **self._kwargs) except TypeError: # Failsafe creation: remove all custom handler_args kwargs = { k: v for k, v in self._kwargs.items() if k in ["debug", "access_log_class"] } return RequestHandler(self, loop=self._loop, **kwargs)