File: //usr/local/lib/python3.10/dist-packages/aiohttp/__pycache__/web_server.cpython-310.pyc
o
���gH � @ s� d Z ddlZddlmZmZmZmZmZmZ ddl m
Z
ddl m Z ddl
mZ ddlmZmZmZ dd lmZ d
ZG d d � d �ZdS )
zLow level HTTP server.� N)�Any� Awaitable�Callable�Dict�List�Optional� )�AbstractStreamWriter)�RawRequestMessage)� StreamReader)�RequestHandler�_RequestFactory�_RequestHandler)� BaseRequest)�Serverc
@ s� e Zd Zdddd�dedee dedeej de d df d
d �Z
e d e e
fd d
��Zde
dejd dfdd�Z d#de
dee d dfdd�Zdedede
deddd ef dd�Zd$d d �Zd#d ee d dfd d �Zd e
fd!d"�ZdS )%r NF)�request_factory�handler_cancellation�loop�handlerr r r �kwargs�returnc K s< |pt �� | _i | _|| _d| _|| _|p| j| _|| _ d S )Nr )
�asyncio�get_running_loop�_loop� _connections�_kwargs�requests_count�request_handler�
_make_requestr r )�selfr r r r r � r �=/usr/local/lib/python3.10/dist-packages/aiohttp/web_server.py�__init__ s
zServer.__init__c C s t | j�� �S �N)�listr �keys)r r r r! � connections# s zServer.connections� transportc C s || j |< d S r# )r )r r r' r r r! �connection_made' s zServer.connection_made�excc s: � �j v r� jr� j�� �fdd�� d S �j � = d S d S )Nc s �j �� d �S r# )r �pop)�f�r r r r! �<lambda>2 s z(Server.connection_lost.<locals>.<lambda>)r �
_task_handler�add_done_callback)r r r) r r, r! �connection_lost, s
� �zServer.connection_lost�message�payload�protocol�writer�taskzasyncio.Task[None]c C s t |||||| j�S r# )r r )r r1 r2 r3 r4 r5 r r r! r 7 s zServer._make_requestc C s | j D ]}|�� qd S r# )r �close)r �connr r r! � pre_shutdownA s
�zServer.pre_shutdown�timeoutc � s4 �� fdd�| j D �}tj|� I d H | j �� d S )Nc 3 s � | ]}|� � �V qd S r# )�shutdown)�.0r7 �r9 r r! � <genexpr>F s � z"Server.shutdown.<locals>.<genexpr>)r r �gather�clear)r r9 �corosr r< r! r: E s �zServer.shutdownc C sX z
t | fd| ji| j��W S ty+ dd� | j�� D �}t | fd| ji|�� Y S w )Nr c S s i | ] \}}|d v r||�qS ))�debug�access_log_classr )r; �k�vr r r! �
<dictcomp>O s
�z#Server.__call__.<locals>.<dictcomp>)r r r � TypeError�items)r r r r r! �__call__J s ��zServer.__call__r# )r N) �__name__�
__module__� __qualname__r r r
�boolr �AbstractEventLoopr r" �propertyr r r& � Transportr( �
BaseExceptionr0 r
r r r r r8 �floatr: rH r r r r! r sd ������
���
����
� �����
�
r )�__doc__r �typingr r r r r r �abcr � http_parserr
�streamsr � web_protocolr r
r � web_requestr �__all__r r r r r! �<module> s