(- d dl Z d dlZd dlZd dlZd dlmZmZ d dlmZm Z m
Z
m Z m Z m
Z
d dlmZ ddlmZ ddlmZ ddlmZ d d lmZ n
# e$ r eZY nw xY wd
Z G d d e Z d dZ G d de Z G d de Z G d de Z G d de Z! G d de Z" G d de Z# G d d e# Z$ G d d e# Z%dS ) N)ABCabstractmethod)Any AwaitableCallableListOptionalSet)URL )PathLike) Application)Server)
SSLContext) BaseSiteTCPSiteUnixSite
NamedPipeSiteSockSite
BaseRunner AppRunner ServerRunner GracefulExitc e Zd ZdZdS )r r N)__name__
__module__ __qualname__code f/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib64/python3.11/site-packages/aiohttp/web_runner.pyr r ! s DDDr r returnc t N)r r r r! _raise_graceful_exitr% % s
..r c e Zd ZdZddddddded ee d
ed df
d Ze e
d e fd
Z e
dd Z
ddZdS )r )_runner _ssl_context_backlog_server N@N shutdown_timeout ssl_contextbacklogrunnerr r. r/ r0 r" c |j t d |dk r%d}t j |t d ||_ || _ || _ || _ d | _ d S )Nz(Call runner.setup() before making a siter+ z,shutdown_timeout should be set on BaseRunner )
stacklevel)
server RuntimeErrorwarningswarnDeprecationWarning_shutdown_timeoutr' r( r) r* )selfr1 r. r/ r0 msgs r! __init__zBaseSite.__init__, sl = IJJ J t # #@C M# 1a @ @ @ @'7F $ '
9= r c d S r$ r r; s r! namez
BaseSite.name? s
r c > K | j | d S r$ )r' _reg_siter? s r! startzBaseSite.startD s" t$$$$$r c K | j | | j | j | j | d S r$ )r' _check_siter* close _unreg_siter? s r! stopz
BaseSite.stopH sT &&& < # L &&&&&r r" N)r r r __slots__floatr r intr= propertyr strr@ rC rH r r r! r r ) s BI #',0
> > > > >
j) >
>
> > > >&
c
^ X
% % % ^%' ' ' ' ' 'r r c e Zd ZdZ ddddddddddee d ee d
ed ee d ed
ee dee ddf fdZ
e defd Z d fd Z
xZS )r )_host_port_reuse_address _reuse_portNr+ r, )r. r/ r0
reuse_address
reuse_portr1 r hostportr. r/ r0 rT rU r" c t |||| || _ | | j rdnd}|| _ || _ || _ d S )Nr- i i )superr= rP r( rQ rR rS )
r; r1 rV rW r. r/ r0 rT rU __class__s
r! r= zTCPSite.__init__S sn -#
< ,644$D
+%r c | j rdnd}| j dn| j }t t j ||| j S )Nhttpshttpz0.0.0.0schemerV rW )r( rP rN r buildrQ )r; r_ rV s r! r@ z TCPSite.namel sF -96 J .yyDJ39FDJGGGHHHr c ( K t d {V t j }| j j }|J | || j | j | j | j
| j | j d {V | _
d S )N)sslr0 rT rU )rY rC asyncioget_event_loopr' r5
create_serverrP rQ r( r) rR rS r* r; loopr5 rZ s r! rC z
TCPSite.startr s ggmmoo %'' $!!! ! / / J J!M -' 0
r )NNrI )r r r rJ r rN rL rK r boolr= rM r@ rC
__classcell__rZ s @r! r r P s! CI
# " & #',0(,%)& & & & sm& sm &
& j)& & ~& TN&
& & & & & &2 Ic I I I XI
r r c
z e Zd ZdZddddddded ed
ee d ed df fd
Z e
d e fd Z d fd Z
xZS )r _pathr+ Nr, r- r1 r pathr. r/ r0 r" c ` t |||| || _ d S )Nr- )rY r= rm )r; r1 rn r. r/ r0 rZ s r! r= zUnixSite.__init__ s? -#
r c 2 | j rdnd}| d| j dS )Nr\ r] ://unix::)r( rm )r; r_ s r! r@ z
UnixSite.name s, -96//$*////r c K t d {V t j }| j j }|J | || j | j | j d {V | _
d S )N)rb r0 ) rY rC rc rd r' r5 create_unix_serverrm r( r) r* rf s r! rC zUnixSite.start s ggmmoo %'' $!!! ! 4 4 J!M 5
r rI )r r r rJ r
rK r r rL r= rM rN r@ rC ri rj s @r! r r s I #',0
j)
" 0c 0 0 0 X0
r r c b e Zd ZdZdddddededd f fd
Zedefd Zd
fd Z xZ
S )r rl r+ r. r1 r rn r. r" Nc t j }t |t j st d t || || _ d S )Nz8Named Pipes only available in proactorloop under windowsrv )rc rd
isinstanceProactorEventLoopr6 rY r= rm )r; r1 rn r. rg rZ s r! r= zNamedPipeSite.__init__ so %'' '+
M
2BCCC
r c | j S r$ rl r? s r! r@ zNamedPipeSite.name
zr c K t d {V t j }| j j }|J | || j d {V }|d | _ d S )Nr ) rY rC rc rd r' r5 start_serving_piperm r* )r; rg r5 r* rZ s r! rC zNamedPipeSite.start s ggmmoo %'' $!!! // DJ
qz r rI ) r r r rJ rN rK r= rM r@ rC ri rj s @r! r r s I MQ " *- DI
c X" " " " " " " " " "r r c
e Zd ZdZdddddddej d ed
ee d ed df fd
Z e
d e fd Z d fd Z
xZS )r )_sock_namer+ Nr, r- r1 r sockr. r/ r0 r" c t |||| || _ | j rdnd}t t
d r0|j t
j k r| d| d}nC| d d \ }} t t j ||| }|| _ d S ) Nr- r\ r] AF_UNIXrq rr r3 r^ )
rY r= r r( hasattrsocketfamilyr getsocknamerN r r` r ) r; r1 r r. r/ r0 r_ r@ rV rW rZ s r! r= zSockSite.__init__ s -#
-96 69 % % G$+ *G*G ;;d&6&6&8&8;;;DD ))++BQB/JD$syTEEEFFD
r c | j S r$ )r r? s r! r@ z
SockSite.name r{ r c K t d {V t j }| j j }|J | || j | j | j d {V | _
d S )N)r rb r0 ) rY rC rc rd r' r5 re r r( r) r* rf s r! rC zSockSite.start s ggmmoo %'' $!!! ! / / ):DM 0
r rI )r r r rJ r rK r r rL r= rM rN r@ rC ri rj s @r! r r s "I #',0 m
j)
0 c X
r r c 6 e Zd ZdZddddedededd fd
Zede e
fd Z ede e fd Z
edee fd
ZddZedd ZddZede
fd Zedd Zdedd fdZdedd fdZdedd fdZd S )r shutdown_callback_handle_signals_kwargsr* _sitesr: Fr+ )handle_signalsr. r r. kwargsr" Nc Z d | _ || _ || _ d | _ g | _ || _ d S r$ r )r; r r. r s r! r= zBaseRunner.__init__ s9 KO - )- &( !1 r c | j S r$ )r* r? s r! r5 zBaseRunner.server s
|r c g }| j D ]@}|j }|5|j }|,|D ])}| | *A|S r$ )r r* socketsappendr )r; retsiter5 r r s r! addresseszBaseRunner.addresses sh K 7 7D\F! .& ' 7 7
4#3#3#5#56666
r c * t | j S r$ )setr r? s r! siteszBaseRunner.sites s 4; r c 4 K t j }| j r\ | t j t | t j t n# t $ r Y nw xY w| d {V | _
d S r$ ) rc rd r add_signal_handlersignalSIGINTr% SIGTERMNotImplementedError _make_serverr* r; rg s r! setupzBaseRunner.setup s %''
''
7KLLL''8LMMMM&
" . . 0 0000000 s A
A) )
A65A6c
K dS )z8Call any shutdown hooks to help server close gracefully.Nr r? s r! shutdownzBaseRunner.shutdown) s
r c K t | j D ] }| d {V | j ry| j | d {V | j r| d {V | j | j d {V | d {V d | _ | j ret j } | t j | t j d S # t $ r Y d S w xY wd S r$ )listr rH r* pre_shutdownr r r: _cleanup_serverr rc get_running_loopremove_signal_handlerr r r r )r; r rg s r! cleanupzBaseRunner.cleanup- s
%% D))++ < @ L % % ' ' '--// ! ! ! ! ! ! !%
/,,.........,''(>?? ? ? ? ? ? ? ?""$$$$$$$$$ +--D
**6=999**6>:::::&
s 0>D0 0
D>=D>c
K d S r$ r r? s r! r zBaseRunner._make_serverI r c
K d S r$ r r? s r! r zBaseRunner._cleanup_serverM r r r c v || j v rt d| d| | j | d S )NSite z! is already registered in runner )r r6 r r; r s r! rB zBaseRunner._reg_siteQ sJ 4; Tt T Td T TUU U 4 r c B || j vrt d| d| d S Nr z is not registered in runner )r r6 r s r! rE zBaseRunner._check_siteV s6 t{ " " Pt P P$ P PQQ Q # "r c v || j vrt d| d| | j | d S r )r r6 remover s r! rG zBaseRunner._unreg_siteZ sJ t{ " " Pt P P$ P PQQ Q 4 r rI )r r r rJ rh rK r r= rM r r r5 r r r
r r r r r r r r rB rE rG r r r! r r s I %"& 2 2 2 2 2
2
2 2 2 2 ( X 49 X s8} X 1 1 1 1 G G G ^G 8
F
^
^
!h !4 ! ! ! !
R RT R R R R! !T ! ! ! ! ! !r r c Z e Zd ZdZdZdddedededd f fd
Zdd Z defd Z
dd
Z xZ S )r zLow-level web server runner _web_serverFr
web_serverr r r" Nc L t j dd|i| || _ d S )Nr r )rY r= r )r; r r r rZ s r! r= zServerRunner.__init__e s5 AAA&AAA%r c
K d S r$ r r? s r! r zServerRunner.shutdownk r c K | j S r$ r r? s r! r zServerRunner._make_servern s r c
K d S r$ r r? s r! r z ServerRunner._cleanup_serverq r r rI )
r r r __doc__rJ r rh r r= r r r ri rj s @r! r r ` s %% I =B& & & &59&MP&
& & & & & &
F
r r c v e Zd ZdZdZdddedededd f fd
Ze defd Z
dd Z de fd
Z
ddZ xZS )r zWeb Application runner_appFr appr r r" Nc t j dd|i| t |t s"t d | || _ d S )Nr z?The first argument should be web.Application instance, got {!r}r )rY r= rx r TypeErrorformatr )r; r r r rZ s r! r= zAppRunner.__init__z sh AAA&AAA#{++ %%+VC[[
r c | j S r$ r r? s r! r z
AppRunner.app s
yr c H K | j d {V d S r$ )r r r? s r! r zAppRunner.shutdown s2 i """""""""""r c > K t j }| j | | j j | j d {V | j | j j dd|i| j S )Nrg r ) rc rd r _set_loop
on_startupfreezestartup
_make_handlerr r s r! r zAppRunner._make_server s %'' D!!! ##%%%i !!!!!!!!! &ty&AADADLAAAr c H K | j d {V d S r$ )r r r? s r! r zAppRunner._cleanup_server s2 i !!!!!!!!!!!r rI )r r r r rJ r rh r r= rM r r r r r ri rj s @r! r r u s I ;@ 37 KN
[ X# # # #BF B B B B" " " " " " " "r r rI )&rc r r r7 abcr r typingr r r r r r
yarlr typedefsr
web_appr r r rb r ImportErrorobject__all__
SystemExitr r% r r r r r r r r r r r! r s
# # # # # # # # @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ JJJ
:
$' $' $' $' $'s $' $' $'N/
/
/
/
/
h /
/
/
d#
#
#
#
#
x #
#
#
L " " " " "H " " ">&
&
&
&
&
x &
&
&
Rm! m! m! m! m! m! m! m!`
:
*!" !" !" !" !"
!" !" !" !" !"s A AA