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 eZdd d
dZG dd deZG dd deZG dd deZG dd deZ G dd deZ G dd deZ G dd d e Z G d d d e Z dS ) N)ABCabstractmethod)AnyListOptionalSet)URL ) Application)Server)
SSLContext) BaseSiteTCPSiteUnixSite
NamedPipeSiteSockSite
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 ZdZdddddeee edddd Ze e
e d
d d Z e
dd
d
dZ
dd
ddZdS )r
)_runner_shutdown_timeout _ssl_context_backlog_server N@N shutdown_timeout ssl_contextbacklogr )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| jdrL| 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_siteclosehasattrr4 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 ZdZddddddddee 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+ hostportr( 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||| jdS )Nhttpshttpz0.0.0.0schemerG 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
dI d H | _d S )N)sslr* rE rF )rI r3 asyncioget_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 ZdZdddddeeee 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 dS )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
dI 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 ZdZdddeedd fddZeed d
d Zdd fd d
Z Z
S )r rY r% r( r N)r+ r[ r( r c s6 t }t|t js tdt 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||| jI 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 ZdZdddddejeee 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}ttdrT|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
dI 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 ZdZddeeddddZeee dd d
Z
ee e dd d Z ee
e dd
dZddddZeddddZddddZee dddZeddddZeddddZeddd d Zeddd d ZdS ) r _handle_signals_kwargsr$ _sitesFhandle_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$ socketsappendrf )r. Zretsiter, rn rb r r r addresses s
zBaseRunner.addressesc C s
t | jS 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_handlersignalSIGINTr SIGTERMNotImplementedError _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| jD ]}| I d H q | I d H d | _| jrz |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 )NSite 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 ZdZdZddeeedd fddZdd d
d Z ed d d
Z
dd ddZ 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 ZdZdZddeeedd fddZe ed d
d Z
dd d d
Z e d ddZ
dd ddZ ZS )r zWeb Application runner_appFrk N)apprl rm r c s8 t jf d|i| t|ts.td||| _d S )Nrl z?The first argument should be web.Application instance, got {!r})rI r/ r_ r
TypeErrorformatr )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| jS )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 ImportErrorobject__all__
SystemExitr r r
r r r r r r r r r r r <module> s,
+2#)\