File: //opt/saltstack/salt/lib/python3.10/site-packages/aiohttp/__pycache__/web_runner.cpython-310.pyc
o
;j�1 � @ sd d dl Z d dlZd dlZd dlZd dlmZmZ d dlmZm Z d dl
m Z ddlm Z ddl
mZ ddlmZ dd lmZ dd
lmZ erMd d lmZ nzd d lmZ W n ey` eZY nw d ZG d
d� de�Zd"dd�Z G dd� de�Z G dd� de �Z G dd� de �Z G dd� de �Z G dd� de �Z!G d d � d e�Z"G d d � d e"�Z#G d d!� d!e"�Z$dS )#� N)�ABC�abstractmethod)�
TYPE_CHECKING�Any)�URL� )�AbstractAccessLogger)�PathLike)� Application)� AccessLogger)�Server)�
SSLContext) �BaseSite�TCPSite�UnixSite�
NamedPipeSite�SockSite�
BaseRunner� AppRunner� ServerRunner� GracefulExitc @ s e Zd ZdZdS )r r N)�__name__�
__module__� __qualname__�code� r r �F/opt/saltstack/salt/lib/python3.10/site-packages/aiohttp/web_runner.pyr % s r �returnc C s t � ��N)r r r r r �_raise_graceful_exit) s r c @ sj e Zd ZdZdddd�ddded edB d
ed df
d d
�Zee d e
fdd���Z e ddd��Z ddd�Z
dS )r )�_runner� _ssl_context�_backlog�_server� N@N� ��shutdown_timeout� ssl_context�backlog�runnerr r' r( r) r c C sP |j d u r td��|dkrd}tj|tdd� ||_|| _|| _|| _d | _ d S )Nz(Call runner.setup() before making a siter$ z,shutdown_timeout should be set on BaseRunner� )�
stacklevel)
�server� RuntimeError�warnings�warn�DeprecationWarning�_shutdown_timeoutr r! r" r# )�selfr* r' r( r) �msgr r r �__init__0 s
zBaseSite.__init__c C s d S r r �r3 r r r �nameC s z
BaseSite.namec � s �| j �| � d S r )r � _reg_siter6 r r r �startH s �zBaseSite.startc � s2 �| j �| � | jd ur| j�� | j �| � d S r )r � _check_siter# �close� _unreg_siter6 r r r �stopL s
�
z
BaseSite.stop�r N)r r r � __slots__�floatr
�intr5 �propertyr �strr7 r9 r= r r r r r - s, �����
� r c s� e Zd ZdZ ddddddd�dddedB d edB d
ed edB d ed
edB dedB ddf� fdd�Z e
defdd��Z e
defdd��Z d� fdd� Z
� ZS )r )�_host�_port� _bound_port�_reuse_address� _reuse_portNr$ r% )r' r( r) �
reuse_address�
reuse_portr* r �host�portr' r( r) rI rJ r c sL t � j||||d� || _|d u r| jrdnd}|| _d | _|| _|| _d S )Nr& i� i� )�superr5 rD r! rE rF rG rH ) r3 r* rK rL r' r( r) rI rJ �� __class__r r r5 W s �
zTCPSite.__init__c C s | j dur| j S | jS )a� The port the server is listening on.
If the server hasn't been started yet, this returns the requested port
(which might be 0 for a dynamic port).
After the server starts, it returns the actual bound port. This is
especially useful when port=0 was requested, as it allows retrieving the
dynamically assigned port after the site has started.
N)rF rE r6 r r r rL q s
z TCPSite.portc C s4 | j rdnd}| js dn| j}ttj||| jd��S )N�https�httpz0.0.0.0��schemerK rL )r! rD rC r �buildrL )r3 rS rK r r r r7 s z TCPSite.namec � s� �t � �� I d H t�� }| jj}|d usJ �|j|| j| j| j | j
| j | j d�I d H | _
| j
jr>| j
jd �� d | _d S | j| _d S )N)�sslr) rI rJ r r )rM r9 �asyncio�get_event_loopr r- �
create_serverrD rE r! r" rG rH r# �sockets� getsocknamerF �r3 �loopr- rN r r r9 � s" � � z
TCPSite.start)NNr> )r r r r? rC rA r@ r
�boolr5 rB rL r7 r9 �
__classcell__r r rN r r T sD �������� �
� �
r c
sh e Zd ZdZdddd�ddded ed
edB d ed df � fd
d�Ze d e
fdd��Z d� fdd� Z � Z
S )r ��_pathr$ Nr% r& r* r �pathr' r( r) r c s t � j||||d� || _d S )Nr& )rM r5 r` )r3 r* ra r' r( r) rN r r r5 � s �
zUnixSite.__init__c C s | j rdnd}|� d| j� d�S )NrP rQ �://unix:�:)r! r` )r3 rS r r r r7 � s z
UnixSite.namec � �R �t � �� I d H t�� }| jj}|d usJ �|j|| j| j| j d�I d H | _
d S )N)rU r) ) rM r9 rV rW r r- Zcreate_unix_serverr` r! r" r# r[ rN r r r9 � s � �zUnixSite.startr> )r r r r? r r@ r
rA r5 rB rC r7 r9 r^ r r rN r r � s* �������r c sX e Zd ZdZdd�dddededd f� fd
d �Zedefd d
��Zd� fdd� Z � Z
S )r r_ r$ �r' r* r ra r' r Nc s6 t �� }t|t j�std��t� j||d� || _d S )Nz9Named Pipes only available in proactor loop under windowsre )rV rW �
isinstanceZProactorEventLoopr. rM r5 r` )r3 r* ra r' r\ rN r r r5 � s ��
zNamedPipeSite.__init__c C � | j S r r_ r6 r r r r7 � � zNamedPipeSite.namec � sP �t � �� I d H t�� }| jj}|d usJ �|�|| j�I d H }|d | _d S �Nr ) rM r9 rV rW r r- Zstart_serving_piper` r# )r3 r\ r- r# rN r r r9 � s �
�zNamedPipeSite.startr> ) r r r r? rC r@ r5 rB r7 r9 r^ r r rN r r � s �����
r c
sj e Zd ZdZdddd�dddejd ed
edB d ed df � fd
d�Ze d e
fdd��Z d� fdd� Z � Z
S )r )�_sock�_namer$ Nr% r& r* r �sockr' r( r) r c
s� t � j||||d� || _| jrdnd}ttd�r*|jtjkr*|� d|�� � d�}n|�� d d� \}} t t
j ||| d��}|| _ d S ) Nr& rP rQ �AF_UNIXrb rc r+ rR )
rM r5 rj r! �hasattr�socket�familyrm rZ rC r rT rk )
r3 r* rl r' r( r) rS r7 rK rL rN r r r5 � s �
zSockSite.__init__c C rg r )rk r6 r r r r7 � rh z
SockSite.namec � rd )N)rl rU r) ) rM r9 rV rW r r- rX rj r! r" r# r[ rN r r r9 � s � �zSockSite.startr> )r r r r? ro r@ r
rA r5 rB rC r7 r9 r^ r r rN r r � s* �������r c @ s� e Zd ZdZddd�dedededd fd
d �Zede d B fd d
��Z
ede e fdd��Z ede
e fdd��Zd#dd�Zed#dd��Zd#dd�Zede fdd��Zed#dd��Zd edd fd d �Zd edd fd d �Zd edd fd!d"�Zd S )$r ��_handle_signals�_kwargsr# �_sitesr2 Fr$ )�handle_signalsr' ru r' �kwargsr Nc K s" || _ || _d | _g | _|| _d S r rq )r3 ru r' rv r r r r5
s
zBaseRunner.__init__c C rg r )r# r6 r r r r- rh zBaseRunner.serverc C sH g }| j D ] }|j}|d ur!|j}|d ur!|D ] }|�|�� � qq|S r )rt r# rY �appendrZ )r3 �ret�siter- rY rl r r r � addresses s
�zBaseRunner.addressesc C s
t | j�S r )�setrt r6 r r r �sites' s
zBaseRunner.sitesc � sX �t �� }| jr"z|�tjt� |�tjt� W n ty! Y nw | � � I d H | _
d S r ) rV rW rr Zadd_signal_handler�signal�SIGINTr �SIGTERM�NotImplementedError� _make_serverr# �r3 r\ r r r �setup+ s � �zBaseRunner.setupc � s �dS )z8Call any shutdown hooks to help server close gracefully.Nr r6 r r r �shutdown8 s zBaseRunner.shutdownc � s� �t | j�D ] }|�� I d H q| jr1t�d�I d H | j�� | �� I d H | j�| j�I d H | � � I d H d | _| j
r\t� � }z|� t
j� |� t
j� W d S ty[ Y d S w d S ri )�listrt r= r# rV �sleepZ pre_shutdownr� r2 �_cleanup_serverrr Zget_running_loopZremove_signal_handlerr} r~ r r� )r3 ry r\ r r r �cleanup< s& �
��zBaseRunner.cleanupc � � �d S r r r6 r r r r� W � �zBaseRunner._make_serverc � r� r r r6 r r r r� [ r� zBaseRunner._cleanup_serverry c C s. || j v rtd|� d| � ���| j �|� d S )N�Site z! is already registered in runner )rt r. rw �r3 ry r r r r8 _ �
zBaseRunner._reg_sitec C s" || j vrtd|� d| � ���d S �Nr� z is not registered in runner )rt r. r� r r r r: d s
�zBaseRunner._check_sitec C s. || j vrtd|� d| � ���| j �|� d S r� )rt r. �remover� r r r r< h r� zBaseRunner._unreg_siter> )r r r r? r] r@ r r5 rB r r- r� rz r{ r r| r� r r� r� r� r� r8 r: r< r r r r r s< ����
�
r c s^ e Zd ZdZdZdd�dedededd f� fd
d �Zdd d
�Z defdd�Z
ddd�Z � Z S )r zLow-level web server runner�� _web_serverF)ru �
web_serverru rv r Nc s t � jdd|i|�� || _d S )Nru r )rM r5 r� )r3 r� ru rv rN r r r5 s s
zServerRunner.__init__c � r� r r r6 r r r r� y � �zServerRunner.shutdownc � s �| j S r r� r6 r r r r� | s �zServerRunner._make_serverc � r� r r r6 r r r r� r� z ServerRunner._cleanup_serverr> )
r r r �__doc__r? r r] r r5 r� r� r� r^ r r rN r r n s �����
r c sz e Zd ZdZdZded�dededee de
d d
f
� fd d �Z e d efd
d��Z
ddd�Zd efdd�Zddd�Z� ZS )r zWeb Application runner��_appF)ru �access_log_class�appru r� rv r Nc sB t � jdd|i|�� t|t�std|����|| jd< || _d S )Nru z;The first argument should be web.Application instance, got r� r )rM r5 rf r
� TypeErrorrs r� )r3 r� ru r� rv rN r r r5 � s
�
zAppRunner.__init__c C rg r r� r6 r r r r� � rh z
AppRunner.appc � � �| j �� I d H d S r )r� r� r6 r r r r� � � �zAppRunner.shutdownc � sT �t �� }| j�|� | jj�� | j�� I d H | j�� | jjdd|i| j��S )Nr\ r ) rV rW r� Z _set_loopZ
on_startupZfreezeZstartupZ
_make_handlerrs r� r r r r� � s �
zAppRunner._make_serverc � r� r )r� r� r6 r r r r� � r� zAppRunner._cleanup_serverr> )r r r r� r? r r
r] �typer r r5 rB r� r� r r� r� r^ r r rN r r � s* ������
r r> )%rV r} ro r/ �abcr r �typingr r Zyarlr r Ztypedefsr Zweb_appr
Zweb_logr r� r rU r
� ImportError�object�__all__�
SystemExitr r r r r r r r r r r r r r �<module> s< �
'E& )g