Ë
|
¸^i× ã óJ d Z ddlZddlZddlZddlZddlZddlZddlmZ ddl m
|
Z
|
m Z m Z ddl mZ ddlmZ ddlmZ dd lmZ dd
|
lmZ dd lmZ e
|
rddlZej6 Zn ddlZej6 Zd Z G d dej> « Z G d de « Z!y# e $ r dZe ZY .w xY w)z%Async gunicorn worker for aiohttp.webé N)Ú FrameType)Ú TYPE_CHECKINGÚAnyÚOptional)ÚAccessLogFormat)Úbase)Úwebé )Ú
|
set_result)Ú Application)Ú AccessLogger)ÚGunicornWebWorkerÚGunicornUVLoopWebWorkerc ó e Zd Zej Zej Zde de ddf fd Z
|
d fd Z ddZ ddZ dd
|
Z dd ed ddfd Zdd Zdedee ddfdZdedee ddfdZede ddfd« ZdedefdZ xZS )r ÚargsÚkwÚreturnNc óN t | |i |¤ d | _ d| _ d | _ y ©Nr )ÚsuperÚ__init__Ú_taskÚ exit_codeÚ_notify_waiter)Úselfr r Ú __class__s õa H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\aiohttp/worker.pyr zGunicornWebWorker.__init__+ s+ ø Ü Ñ$Ð% "Ò%à37
|
ØØ>BÕó c óÖ t j « j « t j « | _ t j
|
| j « t | « y ©N)ÚasyncioÚget_event_loopÚcloseÚnew_event_loopÚloopÚset_event_loopr Ú init_process)r r s r r' z GunicornWebWorker.init_process2 sE ø ä× Ñ Ó ×&Ñ&Ô(ä×*Ñ*Ó, Ü× Ñ tyyÔ)ä Ñ Õ r c óØ | j j | j « « | _ | j j | j « | j j | j j « « | j j « t j | j « y # t
|
$ r | j j d« Y w xY w)Nz Exception in gunicorn worker) r% Ú create_taskÚ_runr Úrun_until_completeÚ ExceptionÚlogÚ exceptionÚshutdown_asyncgensr# ÚsysÚexitr ©r s r ÚrunzGunicornWebWorker.run; s ØYY×*Ñ*¨4¯9©9«;Ó7
|
ð ?Ø II× (Ñ (¨¯©Ô 4ð ×$Ñ$ T§Y¡Y×%AÑ%AÓ%CÔDØ Ôä Õ øô ò ?Ø HH× Ñ Ð =Ö >ð ?ús °%C Ã$C)Ã(C)c ó K d }t | j t « r | j }n¹t j | j « s2t
|
j dk rct j | j « rD| j « d { }t |t j « r|}|j }n'|}n$t dj | j « « |¤| j j r| j j nd }t j || j | j j" || j% | j j& « | j j( dz dz ¬« }|j+ « d { | j j, r| j/ | j « nd }|}|J |j0 }|J | j2 D ]2 }t j4 |||¬« }|j7 « d { 4 t9 j: « } | j< rÜ| j? « |j@ }
|
| jB r3|
|
| jB kD r$d| _ | j jE d| « nt| t9 j: « k( rE| jF t9 jH « k7 r$d| _ | j jE d | « n| jK « d { | j< rÜ|jO « d { y 7 ³7 ¨7 #7 3# tL $ r Y /w xY w7 w)
|
N)é é zUwsgi app should be either Application or async function returning Application, got {}éd é_ )ÚloggerÚkeepalive_timeoutÚ
|
access_logÚaccess_log_formatÚshutdown_timeout)Ú ssl_contextFz Max requests, shutting down: %sz!Parent changed, shutting down: %s)(Ú
|
isinstanceÚwsgir ÚinspectÚiscoroutinefunctionr0 Ú version_infor! r Ú AppRunnerÚappÚ RuntimeErrorÚformatÚcfgÚ accesslogr- r; Ú keepaliveÚ_get_valid_log_formatr< Úgraceful_timeoutÚsetupÚis_sslÚ_create_ssl_contextÚserverÚsocketsÚSockSiteÚstartÚosÚgetpidÚaliveÚnotifyÚrequests_countÚ max_requestsÚinfoÚppidÚgetppidÚ_wait_next_notifyÚ BaseExceptionÚcleanup) r ÚrunnerrE r@ r; ÚctxrP ÚsockÚsiteÚpidÚcnts r r* zGunicornWebWorker._runG s¦ è ø ØÜ dii¤Ô -Ø))CÜ × (Ñ (¨¯©Ô 3Ü × Ñ wÒ &¬7×+FÑ+FÀtÇyÁyÔ+Qà ×$DÜ$¤§ ¡ Ô.Ø Ø jjàä ð?ß?E¹vÀdÇiÁiÓ?Póð ð
|
>Ø04·±×0BÒ0B×,Ò,ÈJÜ]]ØØxxØ"&§(¡(×"4Ñ"4Ø%Ø"&×"<Ñ"<ØHH×.Ñ.ó#ð "&§¡×!:Ñ!:¸SÑ!@À2Ñ!Eô Fð lln× Ð à48·H±H·O²Od×&Ñ& t§x¡xÔ0ÈàØÐ!Ð!Ð!Ø ØÐ!Ð!Ð!ØLLò DÜ<<ØØØ ôDð
|
**,× Ñ ð ô iikð Ø**Ø à ×+Ñ+Ø×$Ò$¨¨t×/@Ñ/@Ò)@Ø!&DJØHHMMÐ"CÀTÕJàBIIKÒ'¨D¯I©I¼¿¹» Ò,EØ!&DJØHHMMÐ"EÀtÕLà ×0Ñ0Ó2×2Ð2ð **ð nnÓ × Ñ ðw %ùð0 ùð ùð" 3ùÜ ò Ù ð úð ús{ BM ÂMÂD M Æ MÆ BM È&M È'M ÉCM ÌM ÌM Ì*M Ì=M Ì>M ÍM Í M Í M Í MÍM ÍMÍM úasyncio.Future[bool]c ó | j « | j }|J |j « x| _ }| j j d| j |« |S )Ng ð?)Ú_notify_waiter_doner% Ú create_futurer Ú
|
call_later)r r% Úwaiters r r] z#GunicornWebWorker._wait_next_notify sZ Ø × Ñ Ô"àyyØÐ Ð Ð Ø'+×'9Ñ'9Ó';Ð;ÔfØ × Ñ S $×":Ñ":¸FÔCà r rk c óh | | j }| t |d« || j u rd | _ y y )NT)r r )r rk s r rh z%GunicornWebWorker._notify_waiter_done s? ð >Ø×(Ñ(FØ Ð Ü vtÔ $à T×(Ñ(Ñ (Ø"&DÕ ð )r c óÄ | j j t j | j t j d « | j j t j
|
| j t j
|
d « | j j t j | j t j d « | j j t j | j t j d « | j j t j | j t j d « | j j t j | j t j d « t j t j
|
d« t j t j d« y ©NF)r% Úadd_signal_handlerÚsignalÚSIGQUITÚ handle_quitÚSIGTERMÚ handle_exitÚSIGINTÚSIGWINCHÚ handle_winchÚSIGUSR1Ú handle_usr1ÚSIGABRTÚ handle_abortÚ siginterruptr2 s r Ú init_signalsz GunicornWebWorker.init_signals s. ð ×$Ñ$Ü NND× ,Ñ ,¬f¯n©n¸dô
|
ð ×$Ñ$Ü NND× ,Ñ ,¬f¯n©n¸dô
|
ð ×$Ñ$Ü MM4×+Ñ+¬V¯]©]¸Dô
|
ð ×$Ñ$Ü OOT× .Ñ .´·±Àô
|
ð ×$Ñ$Ü NND× ,Ñ ,¬f¯n©n¸dô
|
ð ×$Ñ$Ü NND× -Ñ -¬v¯~©~¸tô
|
ô ×ÑFNN¨EÔ2Ü×ÑFNN¨EÕ2r ÚsigÚframec óh d| _ | j j | « | j « y rn )rV rH Ú
|
worker_intrh ©r r~ r s r rr z GunicornWebWorker.handle_quit s+ Ø
|
ð ×ÑDÔ!ð × Ñ Õ"r c ó d| _ d| _ | j j | « t j
|
d« y )NFr
|
)rV r rH Ú worker_abortr0 r1 r s r r{ z GunicornWebWorker.handle_abortË s- Ø
|
ØØ × Ñ dÔ#Ü r rH Ú
|
SSLContextc óp t t d« t j | j « }|j | j
|
| j « | j |_ | j r|j | j « | j r|j | j « |S )z~Creates SSLContext instance for usage in asyncio.create_server.
|
|
See ssl.SSLSocket.__init__ for more details.
|
zSSL is not supported.) ÚsslrF r
Ú ssl_versionÚload_cert_chainÚcertfileÚkeyfileÚ cert_reqsÚ verify_modeÚca_certsÚload_verify_locationsÚciphersÚ set_ciphers)rH ra s r rO z%GunicornWebWorker._create_ssl_contextÑ s ô ;Ü Ð 6Ó7Ð 7ännS__Ó-Ø ×ÑCLL¨#¯+©+Ô6Ø --Ø <<Ø × %Ñ % c§l¡lÔ 3Ø ;;Ø OOCKKÔ (Ø
|
r Ú source_formatc ó~ || j k( r | j S t j d|« r t d« |S )Nz %\([^\)]+\)zêGunicorn's style options in form of `%(name)s` are not supported for the log formatting. Please use aiohttp's format specification to configure access log formatting: http://docs.aiohttp.org/en/stable/logging.html#format-specification)ÚDEFAULT_GUNICORN_LOG_FORMATÚDEFAULT_AIOHTTP_LOG_FORMATÚreÚsearchÚ
|
ValueError)r r s r rK z'GunicornWebWorker._get_valid_log_formatã sD Ø D× <Ñ <Ò <Ø×2Ñ2Ð 2Ü YY~ }Ô 5Ü ð(óð ð !Ð r ©r N)r rf r )Ú__name__Ú
|
__module__Ú __qualname__r Ú
|
LOG_FORMATr ÚGunicornAccessLogFormatÚdefaultr r r r' r3 r* r] r rh r} Úintr rr r{ Ú staticmethodrO ÚstrrK Ú __classcell__©r s @r r r & sè ø à!-×!8Ñ!8Ð Ø"9×"AÑ"AÐ ðCcð C¨ð C°õ Cõ ó
|
!óB óHð :>ñ 'Ø Ð 5Ñ6ð 'à ó 'ó 3ðD#sð #¨8°IÑ+>ð #À4ó #ð ð ¨H°YÑ,?ð ÀDó ð ð ð ¨ ò ó ðð" !°3ð !¸3÷ !r r c ó e Zd Zd fd Z xZS )r c ó´ dd l }t j « j « t j |j « « t | « y r )Úuvloopr! r" r# Úset_event_loop_policyÚEventLoopPolicyr r' )r r§ r s r r' z$GunicornUVLoopWebWorker.init_processó sA ø Ûô × Ñ Ó ×&Ñ&Ô(ô
|
×%Ñ% f×&<Ñ&<Ó&>Ô?ä Ñ Õ r r )r r r r' r£ r¤ s @r r r ò s ø ÷ ñ r r )"Ú__doc__r! rA rT r rp r0 Útypesr Útypingr r r Úgunicorn.configr r Úgunicorn.workersr Úaiohttpr Úhelpersr Úweb_appr Úweb_logr r r
Ú ImportErrorÚobjectÚ__all__ÚWorkerr r © r r ú<module>r¸ s ðÙ +ã Û Û Û Û Û
|
Ý ß /Ñ /å FÝ !å å Ý Ý !áÛà Jð Ûà^^
|
ð ;ôI! ô I!ôX Ð /õ øði ò ØØ
|
ð ús Á#B Â B"Â!B"
|
