Ë
|
¸^i/ ã ó d dl Z d dlZd dlZd dlZd dlmZmZ d dlmZm Z m
|
Z
|
m Z m Z d dl mZ ddlmZ ddlmZ ddlmZ erd d lmZ n d d lmZ d
|
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$y# e$ r eZY sw xY w) é N)ÚABCÚabstractmethod)Ú TYPE_CHECKINGÚAnyÚListÚOptionalÚSet)ÚURLé )ÚPathLike)Ú Application)ÚServer)Ú
|
SSLContext) ÚBaseSiteÚTCPSiteÚUnixSiteÚ NamedPipeSiteÚSockSiteÚ
|
BaseRunnerÚ AppRunnerÚ ServerRunnerÚ GracefulExitc ó e Zd ZdZy)r r N)Ú__name__Ú
|
__module__Ú __qualname__Úcode© ó õe H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\aiohttp/web_runner.pyr r # s Ø Dr r c ó t « ©N)r r r r Ú_raise_graceful_exitr# ' s
|
Ü
|
.Ðr c óv e Zd ZdZddddddded ee d
|
ed df
|
d Ze e
|
d e fd « « Z e
|
dd« Z ddZy)r )Ú_runnerÚ _ssl_contextÚ_backlogÚ_serverç N@Né ©Úshutdown_timeoutÚ ssl_contextÚbacklogÚrunnerr r, r- r. Úreturnc ó¾ |j t d« |dk7 r%d}t j |t d¬« ||_ || _ || _ || _ d | _ y )Nz(Call runner.setup() before making a siter) z,shutdown_timeout should be set on BaseRunneré )Ú
|
stacklevel)
|
ÚserverÚ RuntimeErrorÚwarningsÚwarnÚDeprecationWarningÚ_shutdown_timeoutr% r& r' r( )Úselfr/ r, r- r. Úmsgs r Ú__init__zBaseSite.__init__. s] ð ==Ð Ü Ð IÓJÐ JØ tÒ #Ø@CÜ MM#Ô 1¸aÕ @Ø'7FÔ $Ø Ø 'ÔØ Ø9= r c ó y r" r ©r: s r Únamez BaseSite.nameA s ð r c óB K | j j | « y wr" )r% Ú _reg_siter> s r ÚstartzBaseSite.startF s è ø à × Ñ tÕ$ùs c óÄ K | j j | « | j | j j « | j j | « y wr" )r% Ú _check_siter( ÚcloseÚ _unreg_siter> s r Ústopz BaseSite.stopJ sD è ø Ø × Ñ Ô&Ø <<Ð #Ø LL× Ñ Ô à × Ñ Õ&ùs A A ©r0 N)r r r Ú __slots__Úfloatr r Úintr< Úpropertyr Ústrr? rB rG r r r r r + s ØBIð #'Ø,0Øò >à ð>ð ð >ð
|
jÑ)ð >ð ð >ð
|
ó>ð& Øð cò ó ó ð ð ò%ó ð%ô'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 ÚhostÚportr, r- r. rS rT r0 c ó t | ||||¬« || _ || j rdnd}|| _ || _ || _ y )Nr+ iû i )Úsuperr< rO r& rP rQ rR )
|
r: r/ rU rV r, r- r. rS rT Ú __class__s
|
r r< zTCPSite.__init__U sW ø ô ÑØ Ø -Ø#Øð ô
|
ð
|
Ø <Ø ×,Ò,4°$DØ
|
Ø +ÔØ%Õr c ó¬ | j rdnd}| j sdn | j }t t j ||| j
|
¬« « S )NÚhttpsÚhttpz0.0.0.0©ÚschemerU rV )r& rO rM r
|
ÚbuildrP )r: r^ rU s r r? z TCPSite.namen s> à × -Ò -°6Ø $§
|
¢
|
y°·
|
±
|
Ü399 F°¸D¿J¹JÔGÓHÐHr c ó` K t | « d { t j « }| j j
|
}|J |j || j | j | j | j | j | j ¬« d { | _ y 7 7 w)N)Ússlr. rS rT )rX rB ÚasyncioÚget_event_loopr% r4 Ú create_serverrO rP r& r' rQ rR r( ©r: Úloopr4 rY s r rB z TCPSite.startt s øè ø Ügmo× Ð Ü×%Ñ%Ó'Ø ×$Ñ$ØÐ!Ð!Ð!Ø !× /Ñ /Ø Ø JJØ JJØ×!Ñ!ØMMØ ×-Ñ-Ø×'Ñ'ð 0ó
|
÷
|
ð øð
|
ús" B.B*B B. B, B.Â,B.)NNrH )r r r rI r rM rK rJ r Úboolr< rL r? rB Ú __classcell__©rY s @r r r R sÀ ø ØCIð
|
#Ø "ð &ð #'Ø,0ØØ(,Ø%)ò&à ð&ð smð&ð smð &ð ð &ð jÑ)ð&ð ð&ð ~ð&ð TNð&ð
|
õ&ð2 ðIcò Ió ðI÷
|
|
ñ
|
r r c ón e Zd ZdZddddddded ed
|
ee d ed df fd Z e
|
d e fd« Z d fd Z xZS )r ©Ú_pathr) Nr* r+ r/ r Úpathr, r- r. r0 c ó: t | ||||¬« || _ y )Nr+ )rX r< rl )r: r/ rm r, r- r. rY s r r< zUnixSite.__init__ s, ø ô ÑØ Ø -Ø#Øð ô
|
ð
|
r c óF | j rdnd}| d| j dS )Nr[ r\ ú://unix:ú:)r& rl )r: r^ s r r? z UnixSite.name s( à × -Ò -°6Ø $§*¡* ¨QÐ/Ð/r c ó K t | « d { t j « }| j j
|
}|J |j || j | j | j ¬« d { | _
|
y 7 s7 w)N)ra r. ) rX rB rb rc r% r4 Úcreate_unix_serverrl r& r' r( re s r rB zUnixSite.start s øè ø Ügmo× Ð Ü×%Ñ%Ó'Ø ×$Ñ$ØÐ!Ð!Ð!Ø !× 4Ñ 4Ø Ø JJØ×!Ñ!ØMMð 5ó
|
÷
|
ð øð
|
úó" B B A(B Á>B Á? B Â B rH )r r r rI r rJ r r rK r< rL rM r? rB rh ri s @r r r s| ø ØIð #'Ø,0Øòà ðð ðð
|
ð ð jÑ)ð ð ðð
|
õð" ð0cò 0ó ð0÷
|
|
ñ
|
|
r r c ó\ e Zd ZdZdddddededd f fd
|
Zedefd « Zd fd Z xZ
|
S )r rk r) ©r, r/ r rm r, r0 Nc ó¨ t j « }t |t j « s t d« t
|
| ||¬« || _ y )Nz9Named Pipes only available in proactor loop under windowsrv )rb rc Ú
|
isinstanceÚProactorEventLoopr5 rX r< rl )r: r/ rm r, rf rY s r r< zNamedPipeSite.__init__ sT ø ô ×%Ñ%Ó'ÜØ '×+Ñ+ô
|
ô ØKóð ô ÑÐ2BÐÔCØ
|
r c ó | j S r" rk r> s r r? zNamedPipeSite.nameº ó àzzÐr c óú K t | « d { t j « }| j j
|
}|J |j || j « d { }|d | _ y 7 a7 w©Nr ) rX rB rb rc r% r4 Ústart_serving_piperl r( )r: rf r4 r( rY s r rB zNamedPipeSite.start¾ su øè ø Ügmo× Ð Ü×%Ñ%Ó'Ø ×$Ñ$ØÐ!Ð!Ð!Ø ×/Ñ/Ø DJJó
|
÷
|
ð qz ð øð
|
ús" A;A7AA;Á'A9Á(A;Á9A;rH ) r r r rI rM rJ r< rL r? rB rh ri s @r r r ª sY ø ØIð MQò Ø"ð Ø*-ð ØDIð à õ ð ðcò ó ð÷"ñ "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. r0 c ól t
|
| ||||¬« || _ | j rdnd}t t
|
d« r;|j t
|
j k( r | d|j « d}|| _ y |j « d d \ }} t t j ||| ¬« « }|| _ y ) Nr+ r[ r\ ÚAF_UNIXrp rq r2 r] ) rX r< r r& ÚhasattrÚsocketÚfamilyr Ú getsocknamerM r
|
r_ r ) r: r/ r r, r- r. r^ r? rU rV rY s r r< zSockSite.__init__Ì s² ø ô ÑØ Ø -Ø#Øð ô
|
ð
|
Ø × -Ò -°6Ü 69Ô %¨$¯+©+¼¿ ¹ Ò*GØ XX d×&6Ñ&6Ó&8Ð%9¸Ð;Dð
|
ð ×)Ñ)Ó+¨B¨QÐ/JD$Üsyy¨°TÀÔEÓFDØ
|
r c ó | j S r" )r r> s r r? z SockSite.nameä r{ r c ó K t | « d { t j « }| j j
|
}|J |j || j | j | j ¬« d { | _
|
y 7 s7 w)N)r ra r. ) rX rB rb rc r% r4 rd r r& r' r( re s r rB zSockSite.startè s} øè ø Ügmo× Ð Ü×%Ñ%Ó'Ø ×$Ñ$ØÐ!Ð!Ð!Ø !× /Ñ /Ø ¨×):Ñ):ÀDÇMÁMð 0ó
|
÷
|
ð øð
|
úrt rH )r r r rI r rJ r r rK r< rL rM r? rB rh ri s @r r r É s ø Ø"Ið #'Ø,0Øòà ðð mmðð
|
ð ð jÑ)ð ð ðð
|
õð0 ðcò ó ð÷
|
ñ
|
r r c óþ e Zd ZdZddddedededd fd
|
Zede e
|
fd « Z ede e fd « Z edee fd « ZddZedd« ZddZede
|
fd« Zedd« Zdedd fdZdedd fdZdedd fdZy )r ©Ú_handle_signalsÚ_kwargsr( Ú_sitesr9 Fr) )Úhandle_signalsr, r r, Úkwargsr0 Nc óJ || _ || _ d | _ g | _ || _ y r" r )r: r r, r s r r< zBaseRunner.__init__õ s) ð .Ô Ø Ø)- Ø&( Ø!1Õ r c ó | j S r" )r( r> s r r4 zBaseRunner.server s à||Ðr c ó´ g }| j D ]F }|j }||j }|!|D ]! }|j |j « « # H |S r" )r r( ÚsocketsÚappendr )r: ÚretÚsiter4 r r s r Ú addresseszBaseRunner.addresses sc àØKKò 7DØ\\FØÑ!Ø ..ØÑ&Ø 'ò 7Ø
|
|
4×#3Ñ#3Ó#5Õ6ñ7ð 7ð
|
r c ó, t | j « S r" )Úsetr r> s r ÚsiteszBaseRunner.sites s ä4;;Ó Ð r c ó: K t j « }| j rI |j t j
|
t « |j t j t « | j « d { | _
|
y # t $ r Y )w xY w7 wr" ) rb rc r Úadd_signal_handlerÚsignalÚSIGINTr# ÚSIGTERMÚNotImplementedErrorÚ _make_serverr( ©r: rf s r ÚsetupzBaseRunner.setup sz è ø Ü×%Ñ%Ó'à × Ò ð Ø×'Ñ'¬¯ © Ô7KÔLØ×'Ñ'¬¯©Ô8LÔMð
|
"× .Ñ .Ó 0×0 øô 'ò áð úð 1ús5 !B¤AB
|
Á,BÁ?BÂ
|
BÂ
|
BÂBÂBÂBc ó K yw)z8Call any shutdown hooks to help server close gracefully.Nr r> s r ÚshutdownzBaseRunner.shutdown# s è ø ùó c ó² K t | j « D ] }|j « d { | j r|t j
|
d« d { | j j « | j « d { | j j | j « d { | j « d { d | _ | j rTt j « } |j t j « |j t j « y y 7 7 æ7 ¶7 7 u# t $ r Y y w xY wwr} )Úlistr rG r( rb ÚsleepÚ pre_shutdownr§ r9 Ú_cleanup_serverr Úget_running_loopÚremove_signal_handlerr r r¡ r¢ )r: r rf s r ÚcleanupzBaseRunner.cleanup' s è ø ô
|
Ó%ò DØ))+× Ñ ð ð <<ô -- Ó"× "Ð "Ø LL× %Ñ %Ô 'Ø--/× !Ð !Ø,,×'Ñ'¨×(>Ñ(>Ó?× ?Ð ?Ø×"Ñ"Ó$×$Ð$à Ø × Ò Ü×+Ñ+Ó-Dð Ø×*Ñ*¬6¯=©=Ô9Ø×*Ñ*¬6¯>©>Õ:ð ð ùð
|
#øà !øØ ?øØ$ùô 'ò áð üs{ ,E®D=¯*EÁE Á1E E ,EÂ8EÂ9EÃEÃ+EÃ=>E Ä;EÅ EÅEÅEÅEÅ EÅEÅEÅEc ó K y wr" r r> s r r£ zBaseRunner._make_serverB ó è ø à ùr¨ c ó K y wr" r r> s r r zBaseRunner._cleanup_serverF r² r¨ r c óx || j v rt d| d| « | j j |« y )NúSite z! is already registered in runner )r r5 r ©r: r s r rA zBaseRunner._reg_siteJ s9 Ø 4;;Ñ Ü t fÐ,MÈdÈVÐ TÓUÐ UØ ×Ñ4Õ r c óB || j vrt d| d| « y ©Nrµ z is not registered in runner )r r5 r¶ s r rD zBaseRunner._check_siteO s, Ø t{{Ñ "Ü t fÐ,IÈ$ÈÐ PÓQÐ Qð #r c óx || j vrt d| d| « | j j |« y r¸ )r r5 Úremover¶ s r rF zBaseRunner._unreg_siteS s9 Ø t{{Ñ "Ü t fÐ,IÈ$ÈÐ PÓQÐ QØ ×Ñ4Õ r rH )r r r rI rg rJ r r< rL r r r4 r r r r r r¥ r r§ r° r£ r rA rD rF r r r r r ò s% ØXIð
|
%Ø"&ò 2ð ð 2ð ð 2ð
|
ð 2ð
|
ó 2ð ð Ñ(ò ó ð ð ð 4 9ò ó ð ð ð s8}ò ó ð ó 1ð òGó ðGóð6 ð Fò ó ð ð ò ó ð ð!hð !¨4ó !ð
|
R ð R¨Tó 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_serverF©r Ú
|
web_serverr r r0 Nc ó6 t | dd|i|¤ || _ y )Nr r )rX r< r½ )r: r¿ r r rY s r r< zServerRunner.__init__^ s" ø ô ÑÑA¨ÐA¸&ÒAØ%Õr c ó K y wr" r r> s r r§ zServerRunner.shutdownd ó è ø Ø ùr¨ c ó" K | j S wr" r¼ r> s r r£ zServerRunner._make_serverg s è ø Ø× Ñ Ð ùs c ó K y wr" r r> s r r z ServerRunner._cleanup_serverj r r¨ rH ) r r r Ú__doc__rI r rg r r< r§ r£ r rh ri s @r r r Y sL ø Ù%à Ið =Bò&Ø ð&Ø59ð&ØMPð&à õ&ó ð Fó ÷ r r c óp e Zd ZdZdZdddedededd f fd
|
Ze defd « Z
|
dd Z de fd Z ddZ xZS )r zWeb Application runner©Ú_appFr¾ Úappr r r0 Nc ó t | dd|i|¤ t |t « st dj |« « || _ y )Nr z?The first argument should be web.Application instance, got {!r}r )rX r< rx r Ú TypeErrorÚformatrÈ )r: rÉ r r rY s r r< zAppRunner.__init__s sH ø ô ÑÑA¨ÐA¸&ÒAÜ#{Ô+Üð%ß%+¡V¨C£[óð ð r c ó | j S r" rÇ r> s r rÉ z AppRunner.app~ s àyyÐr c óT K | j j « d { y 7 wr" )rÈ r§ r> s r r§ zAppRunner.shutdown s è ø Øii× Ñ Ó"×"Ò"úó ( &¡(c ó| K t j « }| j j |« | j j j « | j j « d { | j j « | j j dd|i| j ¤S 7 Fw)Nrf r ) rb rc rÈ Ú _set_loopÚ
|
on_startupÚfreezeÚstartupÚ _make_handlerr r¤ s r r£ zAppRunner._make_server
s è ø Ü×%Ñ%Ó'Ø ×ÑDÔ!Ø × Ñ ×#Ñ#Ô%Øii× Ñ Ó!×!Ð!Ø ×ÑÔà&tyy×&Ñ&ÑA¨DÐA°D·L±LÑAÐAð "ús A1B<Á3B:Á4AB<c óT K | j j « d { y 7 wr" )rÈ r° r> s r r zAppRunner._cleanup_server s è ø Øii× Ñ Ó!×!Ò!úrÏ rH )r r r rÅ rI r rg r r< rL rÉ r§ r r£ r rh ri s @r r r n si ø Ù àIð ;@ò Ø ð Ø37ð ØKNð à õ ð ð[ò ó ðó#ðB Fó B÷"r r rH )%rb r r r6 Úabcr r Útypingr r r r r Úyarlr
|
Útypedefsr Úweb_appr r¿ r ra r Ú ImportErrorÚobjectÚ__all__Ú
|
SystemExitr r# r r r r r r r r r r r ú<module>rà sÊ ðÛ Û Û Û ß #ß :Õ :å å Ý Ý áÞ ð Ý"ð
|
ô :ô óô$'sô $'ôN/
|
hô /
|
ôd#
|
xô #
|
ôL "Hô "ô>&
|
xô &
|
ôRd!ô d!ôN :ô ô*!"
|
õ !"øðw
|
ò Ø
|
ð ús Á B9 Â9CÃC
|
