U
'�7`�+ � @ s4 d dl Z d dlZd dlZd dlmZmZ d dlmZmZm Z m
Z
d dl m Z ddl
mZ ddlmZ zd dlmZ W n ek
r� eZY nX d ZG d
d � d e�Zdd �d
d�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�Z G dd� de�Z G dd� de�Z G dd � d e �Z G d d � d e �Z dS ) � N)�ABC�abstractmethod)�Any�List�Optional�Set)�URL� )� Application)�Server)�
SSLContext) �BaseSite�TCPSite�UnixSite�
NamedPipeSite�SockSite�
BaseRunner� AppRunner� ServerRunner� GracefulExitc @ s e Zd ZdZdS )r r N)�__name__�
__module__� __qualname__�code� r r �E/opt/alt/python38/lib64/python3.8/site-packages/aiohttp/web_runner.pyr s r ��returnc C s
t � �d S �N)r r r r r �_raise_graceful_exit# s r c @ sj e Zd ZdZdddd�deee edd�dd �Ze e
e d
�d d ���Z e
dd
�d
d��Z
dd
�dd�ZdS )r
)�_runner�_shutdown_timeout� _ssl_context�_backlog�_server� N@N� ��shutdown_timeout� ssl_context�backlogr )�runnerr( r) r* r c C s4 |j d krtd��|| _|| _|| _|| _d | _d S )Nz(Call runner.setup() before making a site)�server� RuntimeErrorr r! r" r# r$ )�selfr+ r( r) r* r r r �__init__* s
zBaseSite.__init__r c C s d S r r �r. r r r �name: s z
BaseSite.namec � s | j �| � d S r )r � _reg_siter0 r r r �start? s zBaseSite.startc � s� | j �| � | jd kr&| j �| � d S | j�� t| jd�rL| j�� I d H | j �� I d H | j jsht �| j j�| j
�I d H | j �| � d S )N� wait_closed) r � _check_siter$ � _unreg_site�close�hasattrr4 �shutdownr, �AssertionErrorr! r0 r r r �stopC s
z
BaseSite.stop)r r r � __slots__�floatr r �intr/ �propertyr �strr1 r3 r; r r r r r
' s" �� r
c s~ e Zd ZdZddddddd�dee ee eee eee ee dd� � fdd �Z
e ed
�d d ��Z dd
�� fd
d� Z
� ZS )r )�_host�_port�_reuse_address� _reuse_portNr% r& )r( r) r* �
reuse_address�
reuse_portr ) r+ �host�portr( r) r* rE rF r c sF t � j||||d� || _|d kr0| jr,dnd}|| _|| _|| _d S )Nr' i� i� )�superr/ rA r" rB rC rD ) r. r+ rG rH r( r) r* rE rF �� __class__r r r/ U s �zTCPSite.__init__r c C s8 | j r
dnd}| jd kr dn| j}ttj||| jd��S )N�https�httpz0.0.0.0��schemerG rH )r" rA r@ r �buildrB )r. rO rG r r r r1 n s z TCPSite.namec � s\ t � �� I d H t�� }| jj}|d k s,t�|j|| j| j | j
| j | j | j
d�I d H | _d S )N)�sslr* rE rF )rI r3 �asyncio�get_event_loopr r, r: �
create_serverrA rB r" r# rC rD r$ �r. �loopr, rJ r r r3 t s �z
TCPSite.start)NN)r r r r< r r@ r> r= r �boolr/ r? r1 r3 �
__classcell__r r rJ r r R s. ���r c sb e Zd ZdZdddd�deeee edd�� fdd �Z e
ed
�d d ��Z dd
�� fd
d� Z � Z
S )r ��_pathr% Nr& r' r )r+ �pathr( r) r* r c s t � j||||d� || _d S )Nr' )rI r/ rZ )r. r+ r[ r( r) r* rJ r r r/ � s �zUnixSite.__init__r c C s | j r
dnd}|� d| j� d�S )NrL rM �://unix:�:)r" rZ )r. rO r r r r1 � s z
UnixSite.namec � sP t � �� I d H t�� }| jj}|d k s,t�|j|| j| j | j
d�I d H | _ d S )N)rQ r* ) rI r3 rR rS r r, r: Zcreate_unix_serverrZ r" r# r$ rU rJ r r r3 � s �zUnixSite.start)r r r r< r@ r= r r r> r/ r? r1 r3 rX r r rJ r r � s ��r c sV e Zd ZdZdd�deedd�� fdd�Zeed �d
d ��Zdd �� fd d
� Z � Z
S )r rY r% �r( r N)r+ r[ r( r c s6 t �� }t|t j�s td��t� j||d� || _d S )Nz8Named Pipes only available in proactorloop under windowsr^ )rR rS �
isinstanceZProactorEventLoopr- rI r/ rZ )r. r+ r[ r( rV rJ r r r/ � s �zNamedPipeSite.__init__r c C s | j S r rY r0 r r r r1 � s zNamedPipeSite.namec � sN t � �� I d H t�� }| jj}|d k s,t�|�|| j�I d H }|d | _ d S )Nr )
rI r3 rR rS r r, r: Zstart_serving_piperZ r$ )r. rV r, r$ rJ r r r3 � s zNamedPipeSite.start) r r r r< r@ r= r/ r? r1 r3 rX r r rJ r r � s � � r c sd e Zd ZdZdddd�dejeee edd�� fdd �Z e
e d
�d d ��Z dd
�� fd
d� Z
� ZS )r )�_sock�_namer% Nr& r' r )r+ �sockr( r) r* r c
s� t � j||||d� || _| jr$dnd}ttd�rT|jtjkrT|� d|�� � d�}n(|�� d d� \}} t t
j ||| d��}|| _ d S ) Nr' rL rM �AF_UNIXr\ r] � rN )
rI r/ r` r" r8 �socketZfamilyrc � getsocknamer@ r rP ra )
r. r+ rb r( r) r* rO r1 rG rH rJ r r r/ � s �zSockSite.__init__r c C s | j S r )ra r0 r r r r1 � s z
SockSite.namec � sP t � �� I d H t�� }| jj}|d k s,t�|j|| j| j | j
d�I d H | _ d S )N)rb rQ r* ) rI r3 rR rS r r, r: rT r` r" r# r$ rU rJ r r r3 � s �zSockSite.start)r r r r< re r= r r r> r/ r? r@ r1 r3 rX r r rJ r r � s ��r c @ s� e Zd ZdZdd�eedd�dd�Zeee d�d d
��Z
ee e d�d d ��Z ee
e d�d
d��Zdd�dd�Zedd�dd��Zdd�dd�Zee d�dd��Zedd�dd��Zedd�dd�Zedd�d d �Zedd�d d �ZdS ) r ��_handle_signals�_kwargsr$ �_sitesF��handle_signalsN)rl �kwargsr c K s || _ || _d | _g | _d S r rg )r. rl rm r r r r/ � s zBaseRunner.__init__r c C s | j S r )r$ r0 r r r r, � s zBaseRunner.serverc C sH g }| j D ]8}|j}|d k r
|j}|d k r
|D ]}|�|�� � q.q
|S r )rj r$ �sockets�appendrf )r. Zret�siter, rn rb r r r � addresses� s
zBaseRunner.addressesc C s
t | j�S r )�setrj r0 r r r �sites s zBaseRunner.sitesc � sX t �� }| jrDz |�tjt� |�tjt� W n tk
rB Y nX | � � I d H | _
d S r ) rR rS rh Zadd_signal_handler�signal�SIGINTr �SIGTERM�NotImplementedError� _make_serverr$ �r. rV r r r �setup s zBaseRunner.setupc � s d S r r r0 r r r r9 s zBaseRunner.shutdownc � s� t �� }| jd krd S t| j�D ]}|�� I d H q | �� I d H d | _| jr�z |�t j
� |�t j � W n t k
r~ Y nX d S r )
rR rS r$ �listrj r; �_cleanup_serverrh Zremove_signal_handlerrt ru rv rw )r. rV rp r r r �cleanup s
zBaseRunner.cleanupc � s d S r r r0 r r r rx 0 s zBaseRunner._make_serverc � s d S r r r0 r r r r| 4 s zBaseRunner._cleanup_server)rp r c C s. || j kr td|� d| � ���| j �|� d S )N�Site z! is already registered in runner )rj r- ro �r. rp r r r r2 8 s
zBaseRunner._reg_sitec C s" || j kr td|� d| � ���d S �Nr~ z is not registered in runner )rj r- r r r r r5 = s
zBaseRunner._check_sitec C s. || j kr td|� d| � ���| j �|� d S r� )rj r- �remover r r r r6 A s
zBaseRunner._unreg_site)r r r r< rW r r/ r? r r r, r rq r r
rs rz r r9 r} rx r| r2 r5 r6 r r r r r � s&
r c s` e Zd ZdZdZdd�eeedd�� fdd�Zdd �d
d �Z ed �d d
�Z
dd �dd�Z � Z S )r zLow-level web server runner�� _web_serverFrk N)�
web_serverrl rm r c s t � jf d|i|�� || _d S )Nrl )rI r/ r� )r. r� rl rm rJ r r r/ L s zServerRunner.__init__r c � s d S r r r0 r r r r9 R s zServerRunner.shutdownc � s | j S r r� r0 r r r rx U s zServerRunner._make_serverc � s d S r r r0 r r r r| X s z ServerRunner._cleanup_server)
r r r �__doc__r< r rW r r/ r9 rx r| rX r r rJ r r G s � �r c sr e Zd ZdZdZdd�eeedd�� fdd�Ze ed �d
d ��Z
dd �d d
�Z e d �dd�Z
dd �dd�Z� ZS )r zWeb Application runner��_appFrk N)�apprl rm r c s8 t � jf d|i|�� t|t�s.td�|���|| _d S )Nrl z?The first argument should be web.Application instance, got {!r})rI r/ r_ r
� TypeError�formatr� )r. r� rl rm rJ r r r/ a s
��zAppRunner.__init__r c C s | j S r r� r0 r r r r� l s z
AppRunner.appc � s | j �� I d H d S r )r� r9 r0 r r r r9 p s zAppRunner.shutdownc � sR t �� }| j�|� | jj�� | j�� I d H | j�� | jjf d|i| j��S )NrV ) rR rS r� Z _set_loopZ
on_startupZfreezeZstartupZ
_make_handlerri ry r r r rx s s
zAppRunner._make_serverc � s | j �� I d H d S r )r� r} r0 r r r r| | s zAppRunner._cleanup_server)r r r r� r< r
rW r r/ r? r� r9 r rx r| rX r r rJ r r \ s � � r )!rR rt re �abcr r �typingr r r r Zyarlr Zweb_appr
r� r rQ r � ImportError�object�__all__�
SystemExitr r r
r r r r r r r r r r r �<module> s,
+2#)\