[AN9W d Z ddlZddlZddlZddlZddlZddlmZ ddlm Z m
Z
m Z m Z m
Z
ddlmZ ddlmZ ddlmZ dd lmZ dd
lmZ dd lmZ ddlZej Z n# e $ r dZe Z Y nw xY wd Z G d
dej Z! G d de! Z"dS )z%Async gunicorn worker for aiohttp.web N) FrameType)Any AwaitableCallableOptionalUnion)AccessLogFormat)base)web )
set_result) Application) AccessLogger)GunicornWebWorkerGunicornUVLoopWebWorkerc 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 argskwreturnNc d t j |i | d | _ d| _ d | _ d S Nr )super__init___task exit_code_notify_waiter)selfr r __class__s b/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib64/python3.11/site-packages/aiohttp/worker.pyr zGunicornWebWorker.__init__% s; $%"%%%37
>B c t j t j | _ t j | j t
d S N)asyncioget_event_loopclosenew_event_looploopset_event_loopr init_process)r r s r r) z GunicornWebWorker.init_process, s] &&(((*,, ty)))
r c | j | | _ | j | j n*# t
$ r | j d Y nw xY w| j | j | j t j | j d S )Nz Exception in gunicorn worker)
r' create_task_runr run_until_complete Exceptionlog exceptionshutdown_asyncgensr% sysexitr r s r runzGunicornWebWorker.run5 s Y**499;;77
? I ( ( 4 4 4 4 ? ? ? H = > > > > > ? $$TY%A%A%C%CDDD s A $A:9A:c n K d }t | j t r| j }nt j | j rA| d {V }t |t
j r
|}|j }n*|}n't d | j |p| j
j r | j j
nd }t j || j | j
j || | j
j | j
j dz dz }| d {V | j
j r| | j
nd }|}|J |j }|J | j D ]3}t j ||| }| d {V 4t3 j } | j r| |j }
| j r.|
| j k r#d| _ | j d| np| t3 j k r?| j t3 j! k r#d| _ | j d| n| " d {V | j n# tF $ r Y nw xY w|$ d {V d S ) NzUwsgi app should be either Application or async function returning Application, got {}d _ )loggerkeepalive_timeout
access_logaccess_log_formatshutdown_timeout) ssl_contextFz Max requests, shutting down: %sz!Parent changed, shutting down: %s)%
isinstancewsgir r# iscoroutinefunctionr AppRunnerapp RuntimeErrorformatcfg accesslogr/ r; keepalive_get_valid_log_formatr< graceful_timeoutsetupis_ssl_create_ssl_contextserversocketsSockSitestartosgetpidalivenotifyrequests_count max_requestsinfoppidgetppid_wait_next_notify
BaseExceptioncleanup) r runnerrC r@ r; ctxrN socksitepidcnts r r, zGunicornWebWorker._runA s di - -
)CC
(
3
3 $$$$$$D$
..
j ??Evdi?P?P
>040BL,,J]x"&("4%"&"<"<H.# # "&!:S!@2!E F llnn 48HOMd&&tx000!!! !!!L D< D
**,, ikk *
3
+$ 3t/@)@)@!&DJHMM"CTJJJJBIKK''DI ,E,E!&DJHMM"EtLLLL 00222222222 *
3 D nn s (F vt $ $ $ T( ( ("&D ) (r c
| j t j | j t j d | j t j | j t j d | j t j | j t j d | j t j | j t j d | j t j
| j t j
d | j t j | j
t j d t j t j d t j t j
d d S NF)r' add_signal_handlersignalSIGQUIT handle_quitSIGTERM handle_exitSIGINTSIGWINCH handle_winchSIGUSR1 handle_usr1SIGABRT handle_abort siginterruptr4 s r init_signalsz GunicornWebWorker.init_signals s<
$$ ND ,fnd
$$ ND ,fnd
$$ M4+V]D
$$ OT .
$$ ND ,fnd
$$ ND -v~t
FNE222FNE22222r sigframec p d| _ | j | | d S rl )rT rF
worker_intrf r r| r} s r rp z GunicornWebWorker.handle_quit s;
D!!!
"""""r c ~ d| _ d| _ | j | t j d d S )NFr )rT r rF worker_abortr2 r3 r s r ry z GunicornWebWorker.handle_abort s7
d### r rF
SSLContextc @ t t d t j | j }| | j | j | j |_ | j r|
| j | j r| | j |S )z~Creates SSLContext instance for usage in asyncio.create_server.
See ssl.SSLSocket.__init__ for more details.
NzSSL is not supported.)
sslrD r ssl_versionload_cert_chaincertfilekeyfile cert_reqs verify_modeca_certsload_verify_locationsciphers set_ciphers)rF r_ s r rM z%GunicornWebWorker._create_ssl_context s ; 677 7nS_-- CL#+666 - < 4 % %cl 3 3 3 ; ) OOCK ( ( (
r
source_formatc r || j k r| j S t j d| rt d |S )Nz %\([^\)]+\)zGunicorn'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_FORMATDEFAULT_AIOHTTP_LOG_FORMATresearch
ValueError)r r s r rI z'GunicornWebWorker._get_valid_log_format sL D < < <2 2
Y~}
5
5 ! (
! r r N)r rd r" )__name__
__module__ __qualname__r
LOG_FORMATr GunicornAccessLogFormatdefaultr r r r) r5 r, r[ r rf r{ intr rp ry staticmethodrM strrI
__classcell__r s @r r r s !-!8 "9"A Cc C C C C C C C C
!
!
!
!@ @ @ @ D :> ' ' 56 '
' ' ' ' 3 3 3 3D#s #8I+> #4 # # # # HY,? D \" !3 !3 ! ! ! ! ! ! ! !r r c e Zd Zd fd Z xZS )r r Nc dd l }t j t j | t
d S r )uvloopr# r$ r% set_event_loop_policyEventLoopPolicyr r) )r r r s r r) z$GunicornUVLoopWebWorker.init_process sd
&&(((
%f&<&<&>&>???
r r )r r r r) r r s @r r r s= r r )#__doc__r# rR r rn r2 typesr typingr r r r r gunicorn.configr r gunicorn.workersr
aiohttpr helpersr
web_appr web_logr r r ImportErrorobject__all__Workerr r r r r s + +
< < < < < < < < < < < < < < F F F F F F ! ! ! ! ! ! ! ! ! ! ! !JJJ JJ
CJJJ
;G! G! G! G! G! G! G! G!T
/
s A A('A(