ihSrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKJ r SSK J r J r SSK JrJrJrJr SSKJrJrJrJrJrJrJrJrJrJrJrJrJrJ r J!r! SSK"J#r# "S S 5r$g) z Dirty Arbiter Process Asyncio-based arbiter that manages the dirty worker pool and routes requests from HTTP workers to available dirty workers. N)util)get_app_workers_attributeparse_dirty_app_spec) DirtyErrorDirtyNoWorkersAvailableErrorDirtyTimeoutErrorDirtyWorkerError) DirtyProtocolmake_error_response make_response STASH_OP_PUT STASH_OP_GETSTASH_OP_DELETE STASH_OP_KEYSSTASH_OP_CLEAR STASH_OP_INFOSTASH_OP_ENSURESTASH_OP_DELETE_TABLESTASH_OP_TABLESSTASH_OP_EXISTS MANAGE_OP_ADDMANAGE_OP_REMOVE) DirtyWorkerc l\rSrSrSrSR 5VVVVs/sHn[ [SU-5PM snnnnrSr S(Sjr Sr S r S r S rS rS rSrSrSrSrSrSrSrSrSrSrS)SjrSrSrSrSrSr Sr!S*Sjr"S r#S!r$S"r%S#r&S$r'S+S%jr(S&r)S'r*gs snnnnf), DirtyArbiter1a Dirty arbiter that manages the dirty worker pool. The arbiter runs an asyncio event loop and handles: - Spawning and managing dirty worker processes - Accepting connections from HTTP workers - Routing requests to available dirty workers - Monitoring worker health via heartbeat z*HUP QUIT INT TERM TTIN TTOU USR1 USR2 CHLDzSIG%sNcPXlX lSUl[R"5UlX@l[R"SS9Ul U=(d* [RRURS5Ul 0Ul 0Ul0Ul0Ul0UlSUlSUlSUlURR*UlSUlSUl0Ul0Ul0Ul0Ul0Ul/Ul0UlURA5 g)z Initialize the dirty arbiter. Args: cfg: Gunicorn config log: Logger socket_path: Path to the arbiter's Unix socket pidfile: Well-known PID file location for orphan detection Nzgunicorn-dirty-)prefixz arbiter.sockrT)!cfglogpidosgetpidppidpidfiletempfilemkdtemptmpdirpathjoin socket_pathworkersworker_socketsworker_connections worker_queuesworker_consumers_worker_rr_index worker_agealive dirty_workers num_workers_server_loop_pending_requests app_specsapp_worker_mapworker_app_map_app_rr_indices_pending_respawns stash_tables_parse_app_specs)selfr!r"r-r's H/var/www/ias/venv/lib/python3.13/site-packages/gunicorn/dirty/arbiter.py__init__DirtyArbiter.__init__Bs IIK  &&.?@ & "'',, KK+   "$ " ! 8811  !#  !!# c0URRHIn[U5up#Uc [U5nUUUS.URU'[5URU'MK g![a&nUR R SX$5 SnANZSnAff=f)aK Parse all app specifications from config. Populates self.app_specs with parsed information about each app, including the import path and worker count limits. Worker count priority: 1. Config override (e.g., "module:Class:2") - highest priority 2. Class attribute (e.g., workers = 2 on the class) 3. None (all workers) - default Nz,Could not read workers attribute from %s: %s) import_path worker_count original_spec) r! dirty_appsrr Exceptionr"warningr;setr<)rBspecrHrIes rCrADirtyArbiter._parse_app_specsysHH''D( ,rFc/nURR5Heup#USn[URR U[ 555nUcUR U5 MMXT:dMTUR U5 Mg U$)aP Determine which apps a new worker should load. Returns a list of import paths for apps that need more workers. Apps with workers=None (all workers) are always included. Apps with worker limits are included only if they haven't reached their limit yet. Returns: List of import paths to load, or empty list if no apps need workers rI)r;itemslenr<getrNappend)rB app_pathsrHrOrIcurrent_workerss rC_get_apps_for_new_worker%DirtyArbiter._get_apps_for_new_workers~ !%!5!5!7 K/L!$"5"5"9"9+su"MNO#  - /  -"8rFc[U5URU'UHGnX0R;a[5URU'URUR U5 MI g)a Register which apps a worker has loaded. Updates both app_worker_map and worker_app_map to track the bidirectional relationship between workers and apps. Args: worker_pid: The PID of the worker app_paths: List of app import paths loaded by this worker N)listr=r<rNaddrB worker_pidr]app_paths rC_register_worker_apps"DirtyArbiter._register_worker_appssY+/y/J'!H22203##H-    ) - -j 9"rFcURRU/5nUH2nX0R;dMURURU5 M4 g)z Unregister a worker's apps when it exits. Removes the worker from all tracking maps. Args: worker_pid: The PID of the worker to unregister N)r=popr<discardrds rC_unregister_workerDirtyArbiter._unregister_workersM''++J; "H...##H-55jA"rFc&[R"5UlURR SUR5 UR (aD[ UR S5nUR[UR55 SSS5 UR[RS'URRU5 UR5 [ R""S5 [$R&"UR)55 UR-5 g!,(df  N=f![a&nURRSU5 SnANSnAff=f![*a Naf=f!UR-5 f=f)z&Run the dirty arbiter (blocking call).z Dirty arbiter starting (pid: %s)wNzFailed to write PID file: %sGUNICORN_DIRTY_SOCKETz dirty-arbiter)r$r%r#r"infor'openwritestrIOErrorrMr-environr!on_dirty_starting init_signalsr _setproctitleasynciorun _run_asyncKeyboardInterrupt _cleanup_sync)rBfrPs rCr{DirtyArbiter.runs!99;  8$((C << D$,,,GGCM*- /3.>.> *+ ""4(  ?+ ! KK) *    --, D  !?CC D"!       sZD;)%D*D;5$E.* D84D;8D;; E+E&&E+. E;8E>:E;;E>>FcdURH(n[R"U[R5 M* [R"[RUR5 [R"[R UR5 [R"[R UR5 [R"[RUR5 [R"[RUR5 [R"[RUR5 [R"[RUR5 [R"[RUR5 g)zSet up signal handlers.N) SIGNALSsignalSIG_DFLSIGTERM_signal_handlerSIGQUITSIGINTSIGHUPSIGUSR1SIGCHLDSIGTTINSIGTTOU)rBsigs rCrxDirtyArbiter.init_signals s<[R"TR55$N)rz create_task_handle_sigchldrBsrC.DirtyArbiter._signal_handler..sG//0D0D0FGrFNcL>[R"TR55$r)rzrreloadrsrCrr+sG// >rFrz'SIGTTIN: Increasing dirty workers to %scL>[R"TR55$rrzrmanage_workersrsrCrr6G//0C0C0EFrFzASIGTTOU: Cannot decrease below %s workers (required by app specs)z'SIGTTOU: Decreasing dirty workers to %scL>[R"TR55$rrrsrCrrIrrFF)rrr9call_soon_threadsaferr" reopen_filesrrr7rqrrVrMr5 _shutdown)rBrframe min_workerss` rCrDirtyArbiter._signal_handlers &.. zz //G  &.. HH ! ! #  &-- zz //>  &..    !  HHMMC** ,zz //F  &.. 335K;.  .     !  HHMMC** ,zz //F  :: JJ + +DNN ; rFc\UR(aURR5 gg)zInitiate async shutdown.N)r8closers rCrDirtyArbiter._shutdownRs << LL    rFc# [R"5Ul[RR UR 5(a [R"UR 5 [R"URUR S9IShvN Ul [R"UR S5 URRSUR 5 UR5IShvN [R"UR!55nURIShvN URR#5IShvN SSS5IShvN UR)5 UIShvN UR+5IShvN gGN NNoNONA!,IShvN (df  NV=f![R$[&4a Nuf=fNb![R$a Nvf=fNf!UR)5 UIShvN O![R$a Of=fUR+5IShvN f=f7f)z/Main async loop - start server, manage workers.)r+NizDirty arbiter listening on %s)rzget_running_loopr9r$r+existsr-unlinkstart_unix_server handle_clientr8chmodr"rqrr_worker_monitor serve_foreverCancelledError RuntimeErrorcancelstop)rB monitor_tasks rCr|DirtyArbiter._run_asyncWs--/  77>>$** + + IId&& '%66   !!   !!5)  5t7G7GH!!###**4+?+?+AB  |||ll00222$|    ! """))+  ;  $ $2$|||&& 5    #))       ! """))  ))+  s9BIF A#I;F#<(I%G5F%6G9F+F'F+ G'F)(G,I=G'G%G'IHI#I%G'F+)G+G1F4 2 G>GHGG"H!G""H%G''G>;I=G>>IIH!HH! I!H85I7H88IIIIc# UR(a[R"S5IShvN [R"5UR :wa3UR RS5 SUlUR5 gUR5IShvN UR5IShvN UR(aMggNN3N7f)z1Periodically check worker health and manage pool.g?Nz+Parent changed, shutting down dirty arbiterF) r5rzsleepr$getppidr&r"rMrmurder_workersrrs rCrDirtyArbiter._worker_monitorsjj--$ $ $zz|tyy(  !NO"  %%' ' '%%' ' 'jjj $ ( 's:+CC A-CCC3C4C CCCc# UR5 UR(aUR5IShvN ggN7f)z#Handle SIGCHLD - reap dead workers.N) reap_workersr5rrs rCrDirtyArbiter._handle_sigchlds2  ::%%' ' '  's5A>Ac# URRS5 UR(a[R"U5IShvN nURS5nU[R:XaURX25IShvN OuU[R:XaURX25IShvN OGU[R:XaURX25IShvN OURX25IShvN UR(aMUR#5 UR%5IShvN gN![ R a MCf=fNNN|Nd![a&nURR!SU5 SnANzSnAff=fN]![a gf=f!UR#5 UR%5IShvN f![a ff=f=f7f)z Handle a connection from an HTTP worker. Routes requests to available dirty workers and returns responses. Supports both regular responses and streaming (chunk-based) responses. Also handles stash (shared state) operations. z&New client connection from HTTP workerNtypezClient connection error: %s)r"debugr5r read_message_asyncrzIncompleteReadErrorr[MSG_TYPE_STASHhandle_stash_requestMSG_TYPE_STATUShandle_status_requestMSG_TYPE_MANAGEhandle_manage_request route_requestrLerrorr wait_closed)rBreaderwritermessagemsg_typerPs rCrDirtyArbiter.handle_clients ?@ **$1$D$DV$LLG#;;v.};;;33GDDD!>!>>44WEEE!>!>>44WEEE,,W==='***. LLN ((***/M22EFF> = HHNN8! < < = +   LLN ((***  sG)E%E E E9E%E -E%6E7-E%$E!%E%>E#?E%G)'F:F;F?G)EEE%F*EE%E%!E%#E%% F/F F*FF*F F'$G)&F''G)*G&<GGGG& G# G&"G##G&&G)c $# URSS5nURS5nURU5IShvN nUcvUR(d [S5nO/U(aUR(a [ U5nO [S5n[ X65n[R"X'5IShvN gXPR;aURU5IShvN URUn[R"5R5n URXU 45IShvN U IShvN gNNNaNN ![a@n [ U[!SU 3US95n[R"X'5IShvN Sn A gSn A ff=f7f)a Route a request to an available dirty worker via queue. Each worker has a dedicated queue and consumer task. Requests are submitted to the queue and processed sequentially by the consumer. For streaming responses, messages (chunks) are forwarded directly to the client_writer as they arrive from the worker. Args: request: Request message dict client_writer: StreamWriter to send responses to client idunknownrfNzNo dirty workers availablezRequest failed:  worker_id)r[_get_available_workerr.rr;rr r write_message_asyncr1_start_worker_consumerrzr create_futureputrLr ) rBrequest client_writer request_idrfrerresponsequeuefuturerPs rCrDirtyArbiter.route_requestsa[[y1 ;;z* 55h??  <<"#?@dnn4X>"#?@*:=H33ML L L  // /--j9 9 9"":.))+99;ii8999 MLL5@ M : :  M* #3A3!7:NH 33ML L L  Ms8FD9A7F2D;3(FD=A F(D?)F.E3E4E8F;F=F?FE F  0F=F>FFF  Fc^^^# [R"5mTTRT'UUU4Sjn[R"U"55nUTRT'g7f)z3Start a consumer task for a worker's request queue.c># TR(aTR5IShvN upnTRTX5IShvN UR5(dUR S5 TR5 TR(aMggNmNQ![ a0nUR5(dUR U5 SnAN^SnAff=f!TR5 f=f![Ra gf=f7fr) r5r[_execute_on_workerdone set_resultrL set_exception task_donerzr)rrrrPrrBres rCconsumer5DirtyArbiter._start_worker_consumer..consumers**;@99;5F2GF *"55& &{{}}"--d3 )***5F %4%{{}}"0034)--sDC-BC-BB*B2C-DDC-B C%&C CCCC**C--DDDDN)rzQueuer1rr2)rBrertaskrs`` @rCr#DirtyArbiter._start_worker_consumersJ ).:& $""8:.,0j)sAAc # URSS5nURU5IShvN upV[R"Xb5IShvN [R "[R "U5URRS9IShvN nURS5n U [R:Xa [R"X75IShvN MU [R:Xa[R"X75IShvN gU [R[R4;a[R"X75IShvN gUR R#SU 5 GM GNFGN)N![RaL [U[SURR55n[R"X85IShvN gf=fGNNN![$amn UR R'SX5 UR)U5 [U[+S U 3US 95n[R"X85IShvN Sn A gSn A ff=f7f) z Execute request on a specific worker (called by consumer). Handles both regular responses and streaming (chunk-based) responses. For streaming, chunk and end messages are forwarded directly to the client_writer as they arrive from the worker. rrN)timeoutzWorker timeoutrz$Unknown message type from worker: %sz Error executing on worker %s: %szWorker communication failed: r)r[_get_worker_connectionr rrzwait_forrr! dirty_timeout TimeoutErrorr r MSG_TYPE_CHUNK MSG_TYPE_ENDMSG_TYPE_RESPONSEMSG_TYPE_ERRORr"rMrLr_close_worker_connectionr ) rBrerrrrrrrrrPs rCrDirtyArbiter._execute_on_worker s[[y1 0 M#'#>#>z#JJNF33FD D D $+$4$4%88@ $ 6 6%G#;;v.};;;';;MSSS}999';;MSSS ? ? - < < >>';;MSSS  !GRC K D ++2")*:DHHG"G3G"G G" I=G" G  G"I G"3G"6E88AGGGG"IGG"G" G"" I,AI I  IIIIc# U(a:UR(a)XR;a[URU5nO$g[URR 55nU(dgU(aLUR(a;UR R US5nUS-[U5-UR U'O"URnUS-[U5-UlX#[U5-$7f)a Get an available worker PID using round-robin selection. If app_path is provided, only returns workers that have loaded that specific app. Uses per-app round-robin to ensure fair distribution among eligible workers. Args: app_path: Optional import path of the target app. If None, returns any worker using global round-robin. Returns: Worker PID or None if no eligible workers are available. Nrr) r;r<rbr.keysr>r[rZr3)rBrf eligible_pidsidxs rCr"DirtyArbiter._get_available_workerGs ... $T%8%8%B C !!2!2!45M &&**8Q7C.1Ag]9K-KD  *''C%(1WM0B$BD !3}#5566sC2C4c# XR;aURU$URRU5nU(d[SU35e[ S5HGn[ R RU5(a O0[R"S5IShvN MI [SU35e[R"U5IShvN upEXE4URU'XE4$NIN7f)z%Get or create connection to a worker.zNo socket for worker 2皙?NzWorker socket not ready: ) r0r/r[rranger$r+rrzropen_unix_connection)rBrer-_rrs rCr#DirtyArbiter._get_worker_connectionqs 00 0**:6 6))--j9 4ZLAB BrAww~~k**--$ $ $ 8 FG G&;;KHH/5.> +~ %Is$BC,C(/C,C*C,*C,c~XR;a.URRU5up#UR5 gg)zClose connection to a worker.N)r0rjr)rBre_readerrs rCr%DirtyArbiter._close_worker_connections4 00 0"5599*EOG LLN 1rFc # URSS5n[R"5n/nURR 5HeupgUR R 5n[XH- S5n URUUR[US/5[USS5U S.5 Mg URS S 9 URU[!U5UR"(a#[%UR"R'55O/S .n [)X:5n [*R,"X+5IShvN g![[[4a Sn Nf=fN"7f) z Handle a status query request. Returns information about the dirty arbiter and its workers. Args: message: Status request message client_writer: StreamWriter to send response to client rrNr]bootedF)r#ageappsr last_heartbeatc US$)Nr )ros rCr4DirtyArbiter.handle_status_request..s%rFkey) arbiter_pidr.rIr)r[time monotonicr.rYtmp last_updateroundOSError ValueErrorAttributeErrorr\r getattrsortr#rZr;rbrr r r) rBrrrnow workers_infor#workerrrresultrs rCr"DirtyArbiter.handle_status_requests0[[y1 nn <<--/KC &$jj446 !&s'8!!<   zz R8!&(E:"0 ! 0 01 88# -37>>D,,./r  !4// HHH+Z8 &!% &* Is7A E (D74B=E1E2E7EEEEc h^# URSS5nURS5n[S[URSS555nU[:XaSn[ U5HNnTR 5nUbT=R S- slUS- n[R"S5IShvN MP US:Xa)S S USS [TR5TR S .nGO`S S UU[TR5TR S .nGO8U[:XaTR5n Sn [ U5HnTR U ::a O[TR5S::a OT=R S-sl[TRR5U4SjS9n TRU [ R"5 U S- n [R"S5IShvN M S SUU [TR5TR S.nO8[%SU35n ['X<5n [(R*"X-5IShvN gTR,R/SU[:XaS OSUURSURSS555 [1X85n [(R*"X-5IShvN gGN NN~N ![2acnTR,R5SU5 ['U[%[7U555n [(R*"X-5IShvN SnAgSnAff=f7f)z Handle a worker management request. Supports adding or removing dirty workers via protocol messages. Args: message: Manage request message client_writer: StreamWriter to send response to client rroprcountrNrTrcz)All apps have reached their worker limits)success operation requestedspawnedreason total_workerstarget_workers)r(r)r*r+r-r.c6>TRUR$rr.r prBs rCr4DirtyArbiter.handle_manage_request..s4<<?3F3FrFrremove)r(r)r*removedr-r.zUnknown manage operation: z6Worker management: %s %d workers (spawned/removed: %d)r+r5zManage operation error: %s)r[rTintrr spawn_workerr7rzrrZr.rrVminr kill_workerrrrr r rr"rqr rLrrt)rBrrrr&r'r+rr#rr5 oldest_pidrrrPs` rCr"DirtyArbiter.handle_manage_requests[[y1 [[ As7;;w234N M]"uA!..0F)((A-(1 !--,,, &a<#'%*%*#$"M),T\\):*.*:*:F$(%*%*#*),T\\):*.*:*: F''"779 uA'';64<<(A-$$)$"%T\\%6%6%8)F"HJ$$Z@qLG!--,,,& $!)!&&%(%6&*&6&6 #%?t#DE.zA#77 PPP HHMMR#%#6%H **Y 9a0HI K %Z8H33ML L LA-R-Q M M HHNN7 ;*:z#a&7IJH33ML L L MsA L2 A K-J9.D/KJ<A!K?J>KL2A.K3K4K8L29K<K>KK L/ AL*L" L*%L2*L//L2c # URSS5nURS5nURSS5nURS5nURS5nURS5nS n U[:Xa3XPR;a0URU'XpRUU'S n GO{U[:XaAXPR;aS S 0n GO\X`RU;aS S 0n GODURUUn GO0U[:Xa9XPR;a&X`RU;aURUU S n GOS n GOU[ :Xa}XPR;a/n GO[ URUR55n U(a9U V s/sH,n [R"[U 5U5(dM*U PM. n n U n GOfU[:Xa0XPR;aURUR5 S n GO,U[:Xa1XPR;aS S0n GO [URU5US.n OU[:Xa!XPR;a0URU'S n OU[:Xa"XPR;aURU S n OS n OU[ :Xa$[ URR55n OlU[":Xa*XPR;aS n OPUcS n OJX`RU;n O8[%SU35n ['X<5n [(R*"X-5IS hvN g [-U [.5(a~S U ;axU S nUS:Xa[%SU35n O)US :Xa[%SU35n O[%[U 55n SUR15R3SS5S3U l['X<5n O [7X95n [(R*"X-5IS hvN g s sn fNN ![8acnUR:R=SU5 ['U[%[U555n [(R*"X-5IS hvN S nAg S nAff=f7f)z Handle a stash operation directly in the arbiter. All stash tables are stored in arbiter memory for simplicity and fast access. Args: message: Stash operation message client_writer: StreamWriter to send response to client rrr&tablervaluepatternNTr key_not_foundFtable_not_found)sizer=zUnknown stash operation: zTable not found: zKey not found: StashrErrorzStash operation error: %s)r[rr@rrrrbrfnmatchrtrclearrrZrrrrrr r r isinstancedicttitlereplace error_typer rLr"r)rBrrrr&r=rr?r@r#all_keyskrrrLrPs rCr!DirtyArbiter.handle_stash_requests[[y1 [[  GR(kk%  G$++i(a MF\! 1 11/1D%%e,05!!%(-|# 1 11%7F 1 1% 88%7F!..u5c:F&---#9J9J59Q2Q))%05!F"F}$ 1 11F#D$5$5e$<$A$A$CDH/7$Ix!'.s1vw'G%&x$I%F~%---%%e,224}$ 1 11%'89F!$D$5$5e$< =!&F & 1 11/1D%%e,,,---))%0!F"F&d//4467& 1 11"F[!F $5$5e$<rd#CD.zA#77 PPP&$''Gv,=#G_ !22&):5''BCE?2&'>?E&s6{3E%*:+;+;+=+E+Ec2+N*Ou#U .zA(<33ML L L{$IXQ" M M HHNN6 :*:z#a&7IJH33ML L L MsA)Q,DO,)O#4O#:E&O, O(!O,%Q&B7O,O*O,"Q#O,*O,, Q6AQ Q  QQQQc^# TR(dgTRnTR(aw[TR5U:a^TR 5nUcOJ[ R "S5IShvN TR(a[TR5U:aM^[TR5U:a[TRR5U4SjS9nTRU[R5 [ R "S5IShvN [TR5U:aMggNN#7f)z%Maintain the number of dirty workers.Nrc6>TRUR$rr0r1s rCr-DirtyArbiter.manage_workers..s4<<?+>+>rFr) r5r7rZr.r7rzrr8rr9rr)rBr7r#r:s` rCrDirtyArbiter.manage_workersszz && jjS.<&&(F~--$ $ $ jjS.<$,,+-T\\..0!>@J   Z 8--$ $ $ $,,+- % %s1A6E9E:.E*A8E"E#EEEc rUR(aURRS5nO;U(a$[URR 55nOUR 5nU(dUR RS5 gU=RS- sl[RRURSURS35n[URURUURUR US9n[R "5nUS:walXTlX@R"U'X0R$U'UR'XR5 URR)X5 UR R+SXR5 U$[R,"5Ul[.R0"S URR2S 35 UR55 [R6"S5 g![8a9n[R6"UR:b UR:OS5 SnAgSnAf[<ae UR R?S 5 UR@(d [R6"URB5 [R6"S5 gf=f) a Spawn a new dirty worker. Worker app assignment follows these priorities: 1. If there are pending respawns (from dead workers), use those apps 2. Otherwise, determine apps for a new worker based on allocation 3. If force_all_apps=True, spawn with all apps regardless of limits Args: force_all_apps: If True, spawn worker with all apps ignoring limits Returns: Worker PID in parent process, or None if no apps need workers rz)No apps need more workers, skipping spawnNrzworker-z.sock)r r&r]r!r"r-z,Spawned dirty worker (pid: %s) with apps: %szdirty-worker []z!Exception in dirty worker process)"r?rjrbr;rr_r"rr4r$r+r,r*rr#r!forkr.r/rgdirty_post_forkrqr%rry proc_name init_process_exit SystemExitcoderL exceptionr WORKER_BOOT_ERROR)rBforce_all_appsr]r-r"r#rPs rCr7DirtyArbiter.spawn_workers  ! !..2215I T^^0023I557I HHNNF G 1ggll KK74??"359 #  ggi !8J &LL '2   $  & &s 6 HH $ $T 2 HHMMH *JYY[     0B0B/C1E F    ! HHQK : HHqvv1QVVq 9 9  HH  B C==//0 HHQK  s 1AH J6/IA/J65J6c[R"X5 g![a>nUR[R:XaUR U5 SnAgSnAgSnAff=f)zKill a worker by PID.N)r$killrerrnoESRCH_cleanup_worker)rBr#rrPs rCr9DirtyArbiter.kill_workersI * GGC  *ww%++%$$S))& *s A!/AA!cURU5 XR;a*URUR5 URU URR US5 XR ;a:[ UR U5nU(aURRU5 URU5 URR US5nU(aURRX5 URR US5nU(a=[RR!U5(a[R""U5 ggg![$a gf=f)z Clean up after a worker exits. Saves the dead worker's app list to pending respawns so the replacement worker gets the same apps. N)rr2rr1rjr=rbr?r\rlr.r!dirty_worker_exitr/r$r+rrr)rBr# dead_appsr"r-s rCreDirtyArbiter._cleanup_workers+ %%c* '' '  ! !# & - - /%%c* sD) %% %T0056I&&--i8 $!!#t,  HH & &t 4))--c48 277>>+66  +&7;  sE E-,E-cN# URR(dg[URR 55Hup[ R "5URR5- URR::aMPUR(dEURRSU5 SUl URU[R 5 MURU[R"5 M g![[4a Mf=f7f)z!Kill workers that have timed out.NzDIRTY WORKER TIMEOUT (pid:%s)T)r!rrbr.rYrrrrrrabortedr"criticalr9rSIGABRTSIGKILL)rBr#r"s rCrDirtyArbiter.murder_workerssxx%%  2 2 45KC >>#fjj&<&<&>>$((BXBXXY >>!!"A3G!%  fnn5  fnn56Z(  s,AD%ADA>D%D"D%!D""D%c[R"S[R5upU(dgSn[R"U5(a[R"U5nOM[R "U5(a2[R "U5nURRSX5 X0R:XaURRSU5 URU5 URRSU5 GM ![a)nUR[R:waeSnAgSnAff=f)zReap dead worker processes.Nz)Dirty worker (pid:%s) killed by signal %sz$Dirty worker failed to boot (pid:%s)zDirty worker exited (pid:%s))r$waitpidWNOHANG WIFEXITED WEXITSTATUS WIFSIGNALEDWTERMSIGr"rMr^rrerqrrcECHILD)rBwpidstatusexitcoderrPs rCrDirtyArbiter.reap_workers*s !zz"bjj9 <<''!~~f5H^^F++++f-CHH$$%P%)0555HHNN#I4P$$T* >$** + +  $**+  ZZ , "'',,t{{A67- HHT[[ !  7B%       s7 E E.1BE> E+*E+. E;:E;> F  F )r>r9r:r?r8r3r5r;r<r!r"r7r#r'r&r-r@r*r4r=r0r2r1r/r.)NNr)F)T)+__name__ __module__ __qualname____firstlineno____doc__splitrrrr^rDrArVr_rgrlr{rxrrr|rrrrrrrrrrrrrr7r9rerrrrr~__static_attributes__).0xrrs0000rCrr1s<AACEC12wvw{+CEG5 n 5D"6:$B"!@ <8rs]    @ " OCOCrF