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 j�| j �I d H | j �| � d S )N� wait_closed)
r � _check_siter$ � _unreg_site�close�hasattrr4 �shutdownr, r! 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* rD rE r c sF t � j||||d� || _|d kr0| jr,dnd}|| _|| _|| _d S )Nr' i� i� )�superr/ r@ r" rA rB rC ) r. r+ rF rG r( r) r* rD rE �� __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��schemerF rG )r" r@ r? r �buildrA )r. rN rF r r r r1 n s z TCPSite.namec � sP t � �� I d H t�� }| jj}|j|| j| j| j | j
| j | j d�I d H | _
d S )N)�sslr* rD rE )rH r3 �asyncio�get_event_loopr r, �
create_serverr@ rA r" r# rB rC r$ �r. �loopr, rI 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 rI 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' )rH r/ rY )r. r+ rZ r( r) r* rI r r r/ � s �zUnixSite.__init__r c C s | j r
dnd}|� d| j� d�S )NrK rL �://unix:�:)r" rY )r. rN r r r r1 � s z
UnixSite.namec � sD t � �� I d H t�� }| jj}|j|| j| j| j d�I d H | _
d S )N)rP r* ) rH r3 rQ rR r r, Zcreate_unix_serverrY r" r# r$ rT rI r r r3 � s �zUnixSite.start)r r r r; r? r< r r r= r/ r> r1 r3 rW r r rI r r � s ��r c sV e Zd ZdZdd�deedd�� fdd�Zeed �d
d ��Zdd �� fd d
� Z � Z
S )r rX r% �r( r N)r+ rZ r( r c s6 t �� }t|t j�s td��t� j||d� || _d S )Nz8Named Pipes only available in proactorloop under windowsr] )rQ rR �
isinstanceZProactorEventLoopr- rH r/ rY )r. r+ rZ r( rU rI r r r/ � s �zNamedPipeSite.__init__r c C s | j S r rX r0 r r r r1 � s zNamedPipeSite.namec � sB t � �� I d H t�� }| jj}|�|| j�I d H }|d | _d S )Nr ) rH r3 rQ rR r r, Zstart_serving_piperY r$ )r. rU r, r$ rI r r r3 � s
zNamedPipeSite.start) r r r r; r? r< r/ r> r1 r3 rW r r rI 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' rK rL �AF_UNIXr[ r\ � rM )
rH r/ r_ r" r8 �socketZfamilyrb � getsocknamer? r rO r` )
r. r+ ra r( r) r* rN r1 rF rG rI r r r/ � s �zSockSite.__init__r c C s | j S r )r` r0 r r r r1 � s z
SockSite.namec � sD t � �� I d H t�� }| jj}|j|| j| j| j d�I d H | _
d S )N)ra rP r* ) rH r3 rQ rR r r, rS r_ r" r# r$ rT rI r r r3 � s �zSockSite.start)r r r r; rd r< r r r= r/ r> r? r1 r3 rW r r rI 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)rk �kwargsr c K s || _ || _d | _g | _d S r rf )r. rk rl 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 )ri r$ �sockets�appendre )r. Zret�siter, rm ra r r r � addresses� s
zBaseRunner.addressesc C s
t | j�S r )�setri 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 ) rQ rR rg Zadd_signal_handler�signal�SIGINTr �SIGTERM�NotImplementedError� _make_serverr$ �r. rU 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 )
rQ rR r$ �listri r: �_cleanup_serverrg Zremove_signal_handlerrs rt ru rv )r. rU ro r r r �cleanup s
zBaseRunner.cleanupc � s d S r r r0 r r r rw 0 s zBaseRunner._make_serverc � s d S r r r0 r r r r{ 4 s zBaseRunner._cleanup_server)ro r c C s. || j kr td|� d| � ���| j �|� d S )N�Site z! is already registered in runner )ri r- rn �r. ro r r r r2 8 s
zBaseRunner._reg_sitec C s" || j kr td|� d| � ���d S �Nr} z is not registered in runner )ri r- r~ r r r r5 = s
zBaseRunner._check_sitec C s. || j kr td|� d| � ���| j �|� d S r )ri r- �remover~ r r r r6 A s
zBaseRunner._unreg_site)r r r r; rV r r/ r> r r r, r rp r r
rr ry r r9 r| rw 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_serverFrj N)�
web_serverrk rl r c s t � jf d|i|�� || _d S )Nrk )rH r/ r� )r. r� rk rl rI 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 rw 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 rV r r/ r9 rw r{ rW r r rI 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��_appFrj N)�apprk rl r c s8 t � jf d|i|�� t|t�s.td�|���|| _d S )Nrk z?The first argument should be web.Application instance, got {!r})rH r/ r^ r
� TypeError�formatr� )r. r� rk rl rI 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 )NrU ) rQ rR r� Z _set_loopZ
on_startupZfreezeZstartupZ
_make_handlerrh rx r r r rw 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
rV r r/ r> r� r9 r rw r{ rW r r rI r r \ s � � r )!rQ rs rd �abcr r �typingr r r r Zyarlr Zweb_appr
r� r rP r � ImportError�object�__all__�
SystemExitr r r
r r r r r r r r r r r �<module> s,
+2#)\