File: //opt/saltstack/salt/lib/python3.10/site-packages/aiohttp/__pycache__/web_server.cpython-310.pyc
o
;jb � @ 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�dededB dedejdB ded df d
d �Z e
d e e fd d
��Z
de dejd dfdd�Z d#de dedB d dfdd�Zdedede deddd ef dd�Zd$d d �Zd#d edB 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 )
�asyncioZget_running_loop�_loop� _connections�_kwargsZrequests_countZrequest_handler�
_make_requestr r )�selfr r r r r � r �F/opt/saltstack/salt/lib/python3.10/site-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 Z
_task_handlerZadd_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 r, r- r. r/ r0 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)�.0r2 �r4 r r � <genexpr>F s � z"Server.shutdown.<locals>.<genexpr>)r r Zgather�clear)r r4 Zcorosr r7 r r5 E s �zServer.shutdownc C sl z
t | fd| ji| j��W S ty5 dd� | j�� D �}t | fd| ji|��}|j�d| j� | Y S w )Nr c S s i | ] \}}|d v r||�qS ))�debugZaccess_log_classr )r6 �k�vr r r �
<dictcomp>O s
�z#Server.__call__.<locals>.<dictcomp>z~Failed to create request handler with custom kwargs %r, falling back to filtered kwargs. This may indicate a misconfiguration.)r r r � TypeError�items�logger�warning)r r r r r r �__call__J s ���zServer.__call__r )r N)�__name__�
__module__� __qualname__r r
�boolr ZAbstractEventLoopr r �propertyr! r r# Z Transportr% �
BaseExceptionr+ r
r r r r r3 �floatr5 rB r r r r r sd ������
���
����
� �����
�
r )�__doc__r �typingr r r r r r �abcr Z http_parserr
Zstreamsr Z web_protocolr r
r Z web_requestr �__all__r r r r r �<module> s