kу% < 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" G d de! Z#dS )z%Async gunicorn worker for aiohttp.web N) FrameType)Any AwaitableCallableOptionalUnion)AccessLogFormat)base)web )
set_result) Application) AccessLogger)GunicornWebWorkerGunicornUVLoopWebWorkerGunicornTokioWebWorkerc e Zd Zej Zej Zde de ddf fd Z
d fd Z ddZ ddZ
dd
Z dd ed ddfd Zdd
ZdededdfdZdededdfdZede 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 p/builddir/build/BUILD/imunify360-venv-2.6.2/opt/imunify360/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 K d }t | j t r| j }nt j | j rA| d {V }t |t
j r
|}|j }n*|}n't d | j |_| j
j r | j j
nd }t j || j | j
j || | j
j }| d {V | j
j r| | j
nd }|}|J |j }|J | j D ]D}t j |||| j
j dz dz }| d {V Et3 j } | j r| |j }
| j
j r3|
| j
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 {})loggerkeepalive_timeout
access_logaccess_log_formatd _ ) ssl_contextshutdown_timeoutFz Max requests, shutting down: %sz!Parent changed, shutting down: %s)%
isinstancewsgir r$ iscoroutinefunctionr AppRunnerapp RuntimeErrorformatcfg accesslogr0 r: keepalive_get_valid_log_formatr; setupis_ssl_create_ssl_contextserversocketsSockSitegraceful_timeoutstartosgetpidalivenotifyrequests_count max_requestsinfoppidgetppid_wait_next_notify
BaseExceptioncleanup) r runnerrD rA r: ctxrN socksitepidcnts r r- zGunicornWebWorker._runA s di - -
)CC
(
3
3 $$$$$$D$
..
j ??Evdi?P?P
>040BL,,J]x"&("4%"&"<"<H.# # F llnn 48HOMd&&tx000!!! !!!L D< !%!:S!@2!E D **,, ikk *
3
+8( 3S483H-H-H!&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 t j dk r+t j t j t j d S d S )NF) )r( add_signal_handlersignalSIGQUIT handle_quitSIGTERM handle_exitSIGINTSIGWINCH handle_winchSIGUSR1 handle_usr1SIGABRT handle_abort siginterruptr3 version_infoSIGCHLDSIG_DFLr5 s r init_signalsz GunicornWebWorker.init_signals sl
$$ ND ,fnd
$$ ND ,fnd
$$ M4+V]D
$$ OT .
$$ ND ,fnd
$$ ND -v~t
FNE222FNE222 f $ $
M&.&. 9 9 9 9 9 % $r! sigframec p d| _ | j | | d S )NF)rU rG
worker_intrg r r r s r rr z GunicornWebWorker.handle_quit s;
D!!!
"""""r! c ~ d| _ d| _ | j | t j d d S )NFr )rU r rG worker_abortr3 r4 r s r r{ z GunicornWebWorker.handle_abort s7
d### r! rG
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.)
sslrE r ssl_versionload_cert_chaincertfilekeyfile cert_reqs verify_modeca_certsload_verify_locationsciphers set_ciphers)rG 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 rJ z'GunicornWebWorker._get_valid_log_format sL D < < <2 2
Y~}
5
5 ! (
! r! r N)r re r# )__name__
__module__ __qualname__r
LOG_FORMATr GunicornAccessLogFormatdefaultr r r r* r6 r- r\ r rg r intr rr r{ staticmethodrM strrJ
__classcell__r s @r r r s !-!8 "9"A Cc C C C C C C C C
!
!
!
!@ @ @ @ D :> ' ' 56 '
' ' ' '&: &: &: &:P#s #9 # # # # # I $ \" !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 = r! r c e Zd Zd fd Z xZS )r r Nc dd l }t j t j | t
d S r )tokior$ r% r& r r r r* )r r r s r r* z#GunicornTokioWebWorker.init_process sd &&(((
%e&;&;&=&=>>>
r! r r r s @r r r r r! r )$__doc__r$ rS r rp r3 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 r s + +
< < < < < < < < < < < < < < F F F F F F ! ! ! ! ! ! ! ! ! ! ! !JJJ JJ
CJJJ
UM! M! M! M! M! M! M! M!`
/
.
s A A('A(