File: //opt/alt/python37/lib64/python3.7/site-packages/aiohttp/__pycache__/web_runner.cpython-37.pyc
B
�k�a�+ � @ s4 d dl Z d dlZd dlZd dlmZmZ d dlmZmZm Z m
Z
d dl m Z ddl
mZ ddlmZ yd 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/python37/lib64/python3.7/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�_serverg 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 )Nr )r* r r r �name: s z
BaseSite.namec � s | j �| � d S )N)r � _reg_site)r* 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�hasattrr/ �shutdownr( �AssertionErrorr )r* r r r �stopC s
z
BaseSite.stop)r r r � __slots__�floatr r �intr+ �propertyr �strr, r. r6 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_portNg N@r# )r$ r% r& �
reuse_address�
reuse_portr ) r' �host�portr$ r% r& r@ rA r c sF t � j||||d� || _|d kr0| jr,dnd}|| _|| _|| _d S )N)r$ r% r& i� i� )�superr+ r< r r= r> r? ) r* r' rB rC r$ r% r& r@ rA )� __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)�schemerB rC )r r< r; r �buildr= )r* rH rB r r r r, 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& r@ rA )rD r. �asyncio�get_event_loopr r( r5 �
create_serverr< r= r r! r> r? r" )r* �loopr( )rE r r r. t s z
TCPSite.start)NN)r r r r7 r r; r9 r8 r �boolr+ r: r, r. �
__classcell__r r )rE 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 )�_pathg N@Nr# )r$ r% r& r )r' �pathr$ r% r& r c s t � j||||d� || _d S )N)r$ r% r& )rD r+ rQ )r* r' rR r$ r% r& )rE r r r+ � s zUnixSite.__init__)r c C s | j r
dnd}|� d| j� d�S )NrF rG z://unix:�:)r rQ )r* rH r r r r, � 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)rJ r& ) rD r. rK rL r r( r5 Zcreate_unix_serverrQ r r! r" )r* rN r( )rE r r r. � s zUnixSite.start)r r r r7 r; r8 r r r9 r+ r: r, r. rP r r )rE r r � s r c sV e Zd ZdZdd�deedd�� fdd�Zeed �d
d ��Zdd �� fd d
� Z � Z
S )r )rQ g N@)r$ r N)r' rR r$ r c s6 t �� }t|t j�s td��t� j||d� || _d S )Nz8Named Pipes only available in proactorloop under windows)r$ )rK rL �
isinstanceZProactorEventLoopr) rD r+ rQ )r* r' rR r$ rN )rE r r r+ � s
zNamedPipeSite.__init__)r c C s | j S )N)rQ )r* r r r r, � s zNamedPipeSite.namec � sN t � �� I d H t�� }| jj}|d k s,t�|�|| j�I d H }|d | _ d S )Nr )
rD r. rK rL r r( r5 Zstart_serving_piperQ r" )r* rN r( r" )rE r r r. � s zNamedPipeSite.start) r r r r7 r; r8 r+ r: r, r. rP r r )rE 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�_nameg N@Nr# )r$ r% 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 ) N)r$ r% r& rF rG �AF_UNIXz://unix:rS � )rH rB rC )
rD r+ rU r r3 �socket�familyrX � getsocknamer; r rI rV )
r* r' rW r$ r% r& rH r, rB rC )rE r r r+ � s zSockSite.__init__)r c C s | j S )N)rV )r* r r r r, � 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)rW rJ r& ) rD r. rK rL r r( r5 rM rU r r! r" )r* rN r( )rE r r r. � s zSockSite.start)r r r r7 rZ r8 r r r9 r+ r: r; r, r. rP r r )rE 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)r` �kwargsr c K s || _ || _d | _g | _d S )N)r] r^ r" r_ )r* r` ra r r r r+ � s zBaseRunner.__init__)r c C s | j S )N)r" )r* r r r r( � s zBaseRunner.serverc C sP g }xF| j D ]<}|j}|d k r |j}|d k r x|D ]}|�|�� � q2W q W |S )N)r_ r" �sockets�appendr\ )r* �ret�siter( rb rW r r r � addresses� s
zBaseRunner.addressesc C s
t | j�S )N)�setr_ )r* r r r �sites s zBaseRunner.sitesc � sX t �� }| jrDy |�tjt� |�tjt� W n tk
rB Y nX | � � I d H | _
d S )N) rK rL r] Zadd_signal_handler�signal�SIGINTr �SIGTERM�NotImplementedError� _make_serverr" )r* rN r r r �setup s zBaseRunner.setupc � s d S )Nr )r* r r r r4 s zBaseRunner.shutdownc � sz t �� }x t| j�D ]}|�� I d H qW | �� I d H d | _| jrvy |�t j
� |�t j � W n t k
rt Y nX d S )N)
rK rL �listr_ r6 �_cleanup_serverr" r] Zremove_signal_handlerri rj rk rl )r* rN re r r r �cleanup s zBaseRunner.cleanupc � s d S )Nr )r* r r r rm 0 s zBaseRunner._make_serverc � s d S )Nr )r* r r r rp 4 s zBaseRunner._cleanup_server)re r c C s. || j kr td|� d| � ���| j �|� d S )NzSite z! is already registered in runner )r_ r) rc )r* re r r r r- 8 s
zBaseRunner._reg_sitec C s" || j kr td|� d| � ���d S )NzSite z is not registered in runner )r_ r) )r* re r r r r0 = s
zBaseRunner._check_sitec C s. || j kr td|� d| � ���| j �|� d S )NzSite z is not registered in runner )r_ r) �remove)r* re r r r r1 A s
zBaseRunner._unreg_site)r r r r7 rO r r+ r: r r r( r rf r r
rh rn r r4 rq rm rp r- r0 r1 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_serverF)r` N)�
web_serverr` ra r c s t � jf d|i|�� || _d S )Nr` )rD r+ rs )r* rt r` ra )rE r r r+ L s zServerRunner.__init__)r c � s d S )Nr )r* r r r r4 R s zServerRunner.shutdownc � s | j S )N)rs )r* r r r rm U s zServerRunner._make_serverc � s d S )Nr )r* r r r rp X s z ServerRunner._cleanup_server)
r r r �__doc__r7 r rO r r+ r4 rm rp rP r r )rE 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)�_appF)r` N)�appr` ra r c s8 t � jf d|i|�� t|t�s.td�|���|| _d S )Nr` z?The first argument should be web.Application instance, got {!r})rD r+ rT r
� TypeError�formatrv )r* rw r` ra )rE r r r+ a s
zAppRunner.__init__)r c C s | j S )N)rv )r* r r r rw l s z
AppRunner.appc � s | j �� I d H d S )N)rv r4 )r* r r r r4 p s zAppRunner.shutdownc � sR t �� }| j�|� | jj�� | j�� I d H | j�� | jjf d|i| j��S )NrN ) rK rL rv Z _set_loopZ
on_startupZfreezeZstartupZ
_make_handlerr^ )r* rN r r r rm s s
zAppRunner._make_serverc � s | j �� I d H d S )N)rv rq )r* r r r rp | s zAppRunner._cleanup_server)r r r ru r7 r
rO r r+ r: rw r4 r rm rp rP r r )rE r r \ s r )!rK ri rZ �abcr r �typingr r r r Zyarlr Zweb_appr
rt r rJ r � ImportError�object�__all__�
SystemExitr r r
r r r r r r r r r r r �<module> s,
+2# )X