9+lA d dl Z d dlZd dlZd dlmZmZ d dlmZmZm Z m
Z
d dl m Z ddl
mZ ddlmZ d dlmZ n
# e$ r eZY nw xY wd Z G d
d e Zd d
Z 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 de Z G d d e Z dS ) N)ABCabstractmethod)AnyListOptionalSet)URL ) Application)Server)
SSLContext) BaseSiteTCPSiteUnixSite
NamedPipeSiteSockSite
BaseRunner AppRunner ServerRunner GracefulExitc e Zd ZdZdS )r r
N)__name__
__module__ __qualname__code t/builddir/build/BUILD/imunify360-venv-2.6.2/opt/imunify360/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_shutdown_timeout _ssl_context_backlog_server N@N shutdown_timeout ssl_contextbacklogrunnerr r, r- r. r c x |j t d || _ || _ || _ || _ d | _ d S )Nz(Call runner.setup() before making a site)server RuntimeErrorr$ r% r& r' r( )selfr/ r, r- r. s r __init__zBaseSite.__init__* sD = IJJ J !1 '
9= r c d S r! r r3 s r namez
BaseSite.name: s
r c > K | j | d S r! )r$ _reg_siter6 s r startzBaseSite.start? s" t$$$$$r c K | j | | j | j | d S | j t | j d r | j d {V | j d {V | j j sJ | j j | j d {V | j | d S )N wait_closed)
r$ _check_siter( _unreg_siteclosehasattrr< shutdownr1 r% r6 s r stopz
BaseSite.stopC s &&& < L $ $T * * * F 4< / / -,**,, , , , , , , ,l##%%%%%%%%%|""""l!**4+ABBBBBBBBB &&&&&r r N)r r r __slots__floatr r
intr4 propertyr strr7 r: rB r r r r r ' s WI #',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- r.
reuse_address
reuse_portr/ r hostportr, r- r. rN rO r c t |||| || _ | | j rdnd}|| _ || _ || _ d S )Nr+ i i )superr4 rJ r& rK rL rM )
r3 r/ rP rQ r, r- r. rN rO __class__s
r r4 zTCPSite.__init__U sn -#
< ,644$D
+%r c | j rdnd}| j dn| j }t t j ||| j S )Nhttpshttpz0.0.0.0schemerP rQ )r& rJ rH r buildrK )r3 rY rP s r r7 z TCPSite.namen 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)sslr. rN rO )rS r: asyncioget_event_loopr$ r1
create_serverrJ rK r& r' rL rM r( r3 loopr1 rT s r r: z
TCPSite.startt s ggmmoo %'' $!!! ! / / J J!M -' 0
r )NNrC )r r r rD r rH rF rE r
boolr4 rG r7 r:
__classcell__rT s @r r r R 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 efd Z d fd Z xZ
S )r _pathr) Nr* r+ r/ r pathr, r- r. r c ` t |||| || _ d S )Nr+ )rS r4 rg )r3 r/ rh r, r- r. rT s r r4 zUnixSite.__init__ s? -#
r c 2 | j rdnd}| d| j dS )NrV rW ://unix::)r& rg )r3 rY s r r7 z
UnixSite.name s, -96//$*////r c K t d {V t j }| j j }|J | || j | j | j d {V | _
d S )N)r\ r. ) rS r: r] r^ r$ r1 create_unix_serverrg r& r' r( r` s r r: zUnixSite.start s ggmmoo %'' $!!! ! 4 4 DJD$5t} 5
r rC )r r r rD rH rE r r
rF r4 rG r7 r: rc rd 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 rf r) r, r/ r rh r, r Nc t j }t |t j st d t || || _ d S )Nz8Named Pipes only available in proactorloop under windowsrp )r] r^
isinstanceProactorEventLoopr2 rS r4 rg )r3 r/ rh r, ra rT s r r4 zNamedPipeSite.__init__ so %'' '+
M
2BCCC
r c | j S r! rf r6 s r r7 zNamedPipeSite.name
zr c K t d {V t j }| j j }|J | || j d {V }|d | _ d S )Nr ) rS r: r] r^ r$ r1 start_serving_piperg r( )r3 ra r1 r( rT s r r: zNamedPipeSite.start s ggmmoo %'' $!!! // DJ
qz r rC ) r r r rD rH rE r4 rG r7 r: rc rd 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+ r/ r sockr, r- r. 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+ rV rW AF_UNIXrk rl rX )
rS r4 ry r& r@ socketfamilyr} getsocknamerH r rZ rz ) r3 r/ r{ r, r- r. rY r7 rP rQ rT s r r4 zSockSite.__init__ s -#
-96 69 % % G$+ *G*G ;;d&6&6&8&8;;;DD ))++BQB/JD$syTEEEFFD
r c | j S r! )rz r6 s r r7 z
SockSite.name ru r c K t d {V t j }| j j }|J | || j | j | j d {V | _
d S )N)r{ r\ r. ) rS r: r] r^ r$ r1 r_ ry r& r' r( r` s r r: zSockSite.start s ggmmoo %'' $!!! ! / / ):DM 0
r rC )r r r rD r rE r r
rF r4 rG rH r7 r: rc rd s @r r r s "I #',0 m
j)
0 c X
r r c 0 e Zd ZdZdddededdfdZedee fd Z
ede e fd
Z ede
e fd Zdd Zedd
ZddZede fd Zedd ZdeddfdZdeddfdZdeddfdZdS )r _handle_signals_kwargsr( _sitesFhandle_signalsr kwargsr Nc > || _ || _ d | _ g | _ d S r! r )r3 r r s r r4 zBaseRunner.__init__ s# - )- &( r c | j S r! )r( r6 s r r1 zBaseRunner.server s
|r c g }| j D ]@}|j }|5|j }|,|D ])}| | *A|S r! )r r( socketsappendr )r3 retsiter1 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 r6 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! ) r] r^ r add_signal_handlersignalSIGINTr" SIGTERMNotImplementedError _make_serverr( r3 ra s r setupzBaseRunner.setup s %''
''
7KLLL''8LMMMM&
" . . 0 0000000 s A
A) )
A65A6c
K d S r! r r6 s r rA zBaseRunner.shutdown r c K t j }t | j D ] }| d {V | d {V d | _ | j rR | t j
| t j d S # t $ r Y d S w xY wd S r! )
r] r^ listr rB _cleanup_serverr( r remove_signal_handlerr r r r )r3 ra r s r cleanupzBaseRunner.cleanup s %'' %% D))++ ""$$$$$$$$$
**6=999**6>:::::&
s 0>B0 0
B>=B>c
K d S r! r r6 s r r zBaseRunner._make_server0 r r c
K d S r! r r6 s r r zBaseRunner._cleanup_server4 r r r c v || j v rt d| d| | j | d S )NSite z! is already registered in runner )r r2 r r3 r s r r9 zBaseRunner._reg_site8 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 r2 r s r r= zBaseRunner._check_site= s6 t{ " " Pt P P$ P PQQ Q # "r c v || j vrt d| d| | j | d S r )r r2 remover s r r> zBaseRunner._unreg_siteA sJ t{ " " Pt P P$ P PQQ Q 4 r rC )r r r rD rb r r4 rG r r r1 r r r r r r r rA r r r r9 r= r> r r r r r s CI16 ) ) )$ )# )$ ) ) ) ) ( X 49 X s8} X 1 1 1 1
^
&
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 )rS r4 r )r3 r r r rT s r r4 zServerRunner.__init__L s5 AAA&AAA%r c
K d S r! r r6 s r rA zServerRunner.shutdownR r c K | j S r! r r6 s r r zServerRunner._make_serverU s r c
K d S r! r r6 s r r z ServerRunner._cleanup_serverX r r rC )
r r r __doc__rD r rb r r4 rA r r rc rd s @r r r G 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 )rS r4 rr r TypeErrorformatr )r3 r r r rT s r r4 zAppRunner.__init__a sh AAA&AAA#{++ %%+VC[[
r c | j S r! r r6 s r r z
AppRunner.appl s
yr c H K | j d {V d S r! )r rA r6 s r rA zAppRunner.shutdownp s2 i """""""""""r c > K t j }| j | | j j | j d {V | j | j j dd|i| j S )Nra r ) r] r^ r _set_loop
on_startupfreezestartup
_make_handlerr r s r r zAppRunner._make_servers s %'' D!!! ##%%%i !!!!!!!!! &ty&AADADLAAAr c H K | j d {V d S r! )r r r6 s r r zAppRunner._cleanup_server| s2 i !!!!!!!!!!!r rC )r r r r rD r rb r r4 rG r rA r r r rc rd s @r r r \ s I ;@ 37 KN
[ X# # # #BF B B B B" " " " " " " "r r rC )!r] r r abcr r typingr r r r yarlr web_appr r r r\ r
ImportErrorobject__all__
SystemExitr r" r r r r r r r r r r r r s|
# # # # # # # # + + + + + + + + + + + + JJJ
:
(' (' (' (' ('s (' (' ('V/
/
/
/
/
h /
/
/
d
x
F " " " " "H " " ">&
&
&
&
&
x &
&
&
RU! U! U! U! U! U! U! U!p
:
*!" !" !" !" !"
!" !" !" !" !"s ; AA