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 j| j I d H | j | d S )N wait_closed)
r _check_siter$ _unreg_siteclosehasattrr4 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 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* 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||| jdS )Nhttpshttpz0.0.0.0schemerF 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 dI d H | _
d S )N)sslr* rD rE )rH r3 asyncioget_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 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' )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 dS )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 dI 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 ZdZdddeedd fddZeed d
d Zdd fd d
Z Z
S )r rX r% r( r N)r+ rZ r( r c s6 t }t|t js tdt 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}||| jI 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 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' 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 dI 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 ZdZddeeddddZeee dd d
Z
ee e dd d Z ee
e dd
dZddddZeddddZddddZee dddZeddddZeddddZeddd d Zeddd d ZdS ) r _handle_signals_kwargsr$ _sitesFhandle_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$ socketsappendre )r. Zretsiter, rm ra r r r addresses s
zBaseRunner.addressesc C s
t | jS 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_handlersignalSIGINTr SIGTERMNotImplementedError _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| jD ]}| I d H q | I d H d | _| jrz |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 )NSite 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 ZdZdZddeeedd fddZdd d
d Z ed d d
Z
dd ddZ 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 ZdZdZddeeedd fddZe ed d
d Z
dd d d
Z e d ddZ
dd ddZ ZS )r zWeb Application runner_appFrj N)apprk rl r c s8 t jf d|i| t|ts.td||| _d S )Nrk z?The first argument should be web.Application instance, got {!r})rH r/ r^ r
TypeErrorformatr )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| jS )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 ImportErrorobject__all__
SystemExitr r r
r r r r r r r r r r r <module> s,
+2#)\