+ jhRt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RIH t ^RI H t H t ^RI HtHtHtHt^RIHtHtHtHtHtHtHtHtHtHtHtHtHtH t H!t!^RI"H#t#!RR4t$R#) 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) DirtyWorkercla]tRt^1toRtRP 4Uu.uFp\ \RV,4NK upt^t R&Rlt Rt Rt Rt R tR tR tR tR tRtRtRtRtRtRtRtRtR'RltRtRtRtRtRt Rt!R(Rlt"Rt#Rt$R t%R!t&R"t'R)R#lt(R$t)R%t*Vt+R#uupi)* DirtyArbitera 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%sNc ZWnW nRVn\P!4VnW@n\P!RR7Vn T;'g+\PPVPR4Vn /Vn /Vn/Vn/Vn/Vn^Vn^VnRVnVPP*VnRVnRVn/Vn/Vn/Vn/Vn/Vn.Vn/VnVPA4R#)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.sockT)!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)selfrrr)r#s&&&&&K/var/www/idalgo/venv/lib/python3.14/site-packages/gunicorn/dirty/arbiter.py__init__DirtyArbiter.__init__BsIIK  &&.?@ &  "'',, KK+   "$ " ! 8811  !#  !!# c :VPPFLp\V4wr#Vf \V4pRVRVRV/VPV&\4VPV&KN R# \d'pTP P RY$4Rp?L^Rp?ii;i)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 Exceptionrwarningr7setr8)r>specrDrEes& r?r=DirtyArbiter._parse_app_specsysHH''D( min_requiredrKrEs& r?_get_minimum_workers!DirtyArbiter._get_minimum_workerssB NN))+D/L'"<> ,rBc .pVPP4Fkwr#VR,p\VPP V\ 444pVfVP V4KRWT8gKZVP V4Km V#)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 rE)r7itemslenr8getrJappend)r> app_pathsrDrKrEcurrent_workerss& r?_get_apps_for_new_worker%DirtyArbiter._get_apps_for_new_workers~ !%!5!5!7 K/L!$"5"5"9"9+su"MNO#  - /  -"8rBc \V4VPV&VFLpW0P9d\4VPV&VPV,P V4KN R#)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)listr9r8rJaddr> worker_pidrYapp_paths&&& r?_register_worker_apps"DirtyArbiter._register_worker_appssY+/y/J'!H22203##H-    ) - -j 9"rBc VPPV.4pVF7pW0P9gKVPV,PV4K9 R#)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)r9popr8discardr`s&& r?_unregister_workerDirtyArbiter._unregister_workersM''++J; "H...##H-55jA"rBc B\P!4VnVPP RVP4VP 'dM\ VP R4;_uu_4pVP\VP44RRR4VP\PR&VPPV4VP4\ P"!R4\$P&!VP)44VP-4R# +'giL;i \d'pTPPRT4Rp?LRp?ii;i \*dLfi;i TP-4i;i)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!rrinfor#openwritestrIOErrorrIr)environron_dirty_starting init_signalsr _setproctitleasynciorun _run_asyncKeyboardInterrupt _cleanup_sync)r>frLs& r?rwDirtyArbiter.runs&99;  8$((C <<< D$,,,,GGCM*- /3.>.> *+ ""4(  ?+ ! KK) *    --, D  !?CC D"!       sZE2%D4E>$E;4 E ?EE E8E33E8; F F F  F Fc fVPF(p\P!V\P4K* \P!\PVP4\P!\P VP4\P!\P VP4\P!\PVP4\P!\PVP4\P!\PVP4\P!\PVP4\P!\PVP4R#)zSet up signal handlers.N) SIGNALSsignalSIG_DFLSIGTERM_signal_handlerSIGQUITSIGINTSIGHUPSIGUSR1SIGCHLDSIGTTINSIGTTOU)r>sigs& r?rtDirtyArbiter.init_signals s<sr?.DirtyArbiter._signal_handler..sG//0D0D0FGrBNcL<\P!SP44#r)rvrreloadrsr?rr+sG// >rBz'SIGTTIN: Increasing dirty workers to %scL<\P!SP44#rrvrmanage_workersrsr?rr6G//0C0C0EFrBzASIGTTOU: Cannot decrease below %s workers (required by app specs)z'SIGTTOU: Decreasing dirty workers to %scL<\P!SP44#rrrsr?rrIrrBF)rrr5call_soon_threadsaferr reopen_filesrrr3rmrrRrIr1 _shutdown)r>rframe min_workerssf&& r?rDirtyArbiter._signal_handlers &.. zzz //G  &.. HH ! ! #  &-- zzz //>  &..    !  HHMMC** ,zzz //F  &.. 335K;.  .     !  HHMMC** ,zzz //F  ::: JJ + +DNN ; rBc bVP'dVPP4R#R#)zInitiate async shutdown.N)r4closers&r?rDirtyArbiter._shutdownRs <<< LL    rBc "\P!4Vn\PP VP 4'd!\P!VP 4\P!VPVP R7GRjxL Vn \P!VP R4VPPRVP 4VP4GRjxL \P!VP!44pVP;_uu_4GRjxL VPP#4GRjxL RRR4GRjxL TP)4TGRjxL TP+4GRjxL R#ELLLpLPLB +GRjxL 'giLY;i \P$\&3dLyi;iLf \P$dL{i;iLk TP)4TGRjxL M \P$dMi;iTP+4GRjxL i;i5i)z/Main async loop - start server, manage workers.)r'NizDirty arbiter listening on %s)rvget_running_loopr5r r'existsr)unlinkstart_unix_server handle_clientr4chmodrrmrr_worker_monitor serve_foreverCancelledError RuntimeErrorcancelstop)r> monitor_tasks& r?rxDirtyArbiter._run_asyncWs--/  77>>$** + + IId&& '%66   !!   !!5)  5t7G7GH!!###**4+?+?+AB  ||||ll00222$|    ! """))+  ;  $ $2$|||&& 5    #))       ! """))  ))+  s?BI*F-A#I*?F0(I*)GF2GF8#F4$F8( G3F64G8I* G7G5G7I*&H'I*0I*2G4F86G8G >G? G G GHGG2/H1G22H5G77H I*HI*I'&H2+H.,H21I'2I I' I  I' I#!I''I*c "VP'd\P!R4GRjxL \P!4VP 8wd5VP PR4RVnVP4R#VP4GRjxL VP4GRjxL KR#LL"L 5i)z1Periodically check worker health and manage pool.g?Nz+Parent changed, shutting down dirty arbiterF) r1rvsleepr getppidr"rrIrmurder_workersrrs&r?rDirtyArbiter._worker_monitorsjjj--$ $ $zz|tyy(  !NO"  %%' ' '%%' ' ' $ ( 's9CCB?A/CCC6C7 CCCc "VP4VP'dVP4GRjxL R#R#L5i)z#Handle SIGCHLD - reap dead workers.N) reap_workersr1rrs&r?rDirtyArbiter._handle_sigchlds4  :::%%' ' '  's6AA Ac "VPPR4VP'd\P!V4GRjxL pTPR4pT\P8XdTPY24GRjxL KrT\P8XdTPY24GRjxL KT\P8XdTPY24GRjxL KTPY24GRjxL KVP#4VP%4GRjxL R#L \ P dKEi;iLLLoLV \d'pTPP!RT4Rp?L}Rp?ii;iL` \dR#i;i TP#4TP%4GRjxL i \dii;i;i5i)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)rdebugr1r read_message_asyncrvIncompleteReadErrorrWMSG_TYPE_STASHhandle_stash_requestMSG_TYPE_STATUShandle_status_requestMSG_TYPE_MANAGEhandle_manage_request route_requestrHerrorr wait_closed)r>readerwritermessagemsg_typerLs&&& r?rDirtyArbiter.handle_clients ?@ ***$1$D$DV$LLG#;;v.};;;33GDDD!>!>>44WEEE!>!>>44WEEE,,W==='. LLN ((***/M22EFF> = HHNN8! < < = +   LLN ((***  s#G&ED: D8 D::E E /E:E;/E*E+EEE F& G&F1F2F6G&8D::EEF&EEEEE F)F F& FF&F F#G&"F##G&&G#8G G GG# G G#G  G##G&c F"VPRR4pVPR4pVPV4GRjxL pVf{VP'g \R4pM1V'dVP'd \ V4pM \R4p\ W64p\P!W'4GRjxL R#WPP9dVPV4GRjxL VPV,p\P!4P4p VPWV 34GRjxL V GRjxL R#EL LLgLL \dEp \ T\!RT 2TR74p\P!Y'4GRjxL Rp ? R#Rp ? ii;i5i)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 idunknownrbNzNo dirty workers availablezRequest failed:  worker_id)rW_get_available_workerr*rr7rr r write_message_asyncr-_start_worker_consumerrvr create_futureputrHr) r>request client_writer request_idrbrarresponsequeuefuturerLs &&& r?rDirtyArbiter.route_requestse[[y1 ;;z* 55h??  <<<"#?@dnnn4X>"#?@*:=H33ML L L  // /--j9 9 9"":.))+99;ii8999 MLL5@ M : :  M* #3A3!7:NH 33ML L L  Ms8F!EF!F!)F!;;F!6E7*F!!E "AF!2E 3F!8E=E >EF!F! F! F! E F3F FFF!FF!c aaa"\P!4oSSPS&VVV3Rlp\P!V!44pVSPS&R#5i)z3Start a consumer task for a worker's request queue.c<"SP'dqSP4GRjxL wrpSPSW4GRjxL VP4'gVP R4SP4KR#L]LA \ d2pTP4'gTP T4Rp?LORp?ii;i SP4i;i \PdR#i;i5ir) r1rW_execute_on_workerdone set_resultrH set_exception task_donervr)rrrrLrr>ras r?consumer5DirtyArbiter._start_worker_consumer..consumers***;@99;5F2GF *"55& &{{}}"--d3 )5F %4%{{}}"0034)--sC<C BC B B  B #B 4C C<C B C'C>C CC CC C95C<8C99C<N)rvQueuer-rr.)r>rartaskrsff @r?r#DirtyArbiter._start_worker_consumersJ ).:& $""8:.,0j)sAAc "VPRR4pVPV4GRjxL wrV\P!Wb4GRjxL \P !\P !V4VPPR7GRjxL pTPR4p T \P8Xd!\P!Y74GRjxL KT \P8Xd!\P!Y74GRjxL R#T \P\P39d!\P!Y74GRjxL R#TP P#RT 4EK)ELNEL1L \PdN\T\RTPP44p\P!Y84GRjxL R#i;iEL LL \$drp TP P'RY4TP)T4\T\+R T 2TR 74p\P!Y84GRjxL Rp ? R#Rp ? ii;i5i) 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)rW_get_worker_connectionr rrvwait_forrr dirty_timeout TimeoutErrorr rMSG_TYPE_CHUNK MSG_TYPE_ENDMSG_TYPE_RESPONSEMSG_TYPE_ERRORrrIrHr_close_worker_connectionr) r>rarrrrrrrrrLs &&&& r?rDirtyArbiter._execute_on_worker s [[y1 0 M#'#>#>z#JJNF33FD D D $+$4$4%88@ $ 6 6%G#;;v.};;;';;MSSS}999';;MSSS ? ? - < < >>';;MSSS  !GRKK D ++2")*:DHHF?G,G%4G, G(G,I+>G,G*G,I+ G,;G,>FAG"GG"G,I+!G""G,(G,*G,, I(7A I#II#I+#I((I+c 4"V'dBVP'd0WP9d\VPV,4pM%R#\VPP 44pV'gR#V'dVVP'dDVP P V^4pV^,\V4,VP V&M*VPpV^,\V4,VnW#\V4,,#5i)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. N) r7r8r^r*keysr:rWrVr/)r>rb eligible_pidsidxs&& r?r"DirtyArbiter._get_available_workerGs ... $T%8%8%B C !!2!2!45M &&**8Q7C.1Ag]9K-KD  *''C%(1WM0B$BD !3}#5566sDAD7 DDBDc "WP9dVPV,#VPPV4pV'g\RV 24h\ ^24FHp\ P PV4'dM0\P!R4GRjxL KJ \RV 24h\P!V4GRjxL wrEWE3VPV&WE3#LIL5i)z%Get or create connection to a worker.zNo socket for worker 皙?NzWorker socket not ready: ) r,r+rWrranger r'rrvropen_unix_connection)r>rar)_rrs&& r?r#DirtyArbiter._get_worker_connectionqs 00 0**:6 6))--j9 4ZLAB BrAww~~k**--$ $ $ 8 FG G&;;KHH/5.> +~ %Is+AC3 AC3%C/&/C3C1C31C3c WP9d0VPPV4wr#VP4R#R#)zClose connection to a worker.N)r,rfr)r>ra_readerrs&& r?r%DirtyArbiter._close_worker_connections4 00 0"5599*EOG LLN 1rBc "VPRR4p\P!4p.pVPP 4FmwrgVP P 4p\WH, ^4p VPRVRVPR\VR.4R\VRR 4R V /4Ko VPR R 7R VPRTR\!V4RVP"'d$\%VP"P'44M./p \)W:4p \*P,!W+4GRjxL R# \\\3dRp Li;iL$5i)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 rrNrageappsrYbootedFlast_heartbeatcVR,#)r)rks&r?r4DirtyArbiter.handle_status_request..s%rBkey arbiter_pidr*rE)rWtime monotonicr*rUtmp last_updateroundOSError ValueErrorAttributeErrorrXrgetattrsortrrVr7r^rr r r) r>rrrnow workers_inforworkerrr resultrs &&& r?r"DirtyArbiter.handle_status_requestsD[[y1 nn <<--/KC &$jj446 !&s'8!!<   svzz R8'&(E: . ! 0 01 488 | C - 4>>>D,,./r  !4// HHH+Z8 &!% &* Is7A E' ,E8CE'E%E'E"E'!E""E'c a"VPRR4pVPR4p\^\VPR^444pV\8Xd^p\ V4FWpSP 4pVe#S;P ^, unV^, p\P!R4GRjxL KY V^8Xd0RRR R R VR ^R RR\SP4RSP /pEMzRRR R R VR VR\SP4RSP /pEMMV\8XEd SP4p ^p \ V4FpSP V 8:dM\SP4^8:dMS;P ^,un\SPP4V3RlR7p SPV \ P"4V ^, p \P!R4GRjxL K RRR RR VRV R\SP4RSP /pM9\%RV 24p \'W<4p \(P*!W-4GRjxL R#SP,P/RV\8XdR MRVVPR VPR^444\1W84p \(P*!W-4GRjxL R#EL/LLL \2depSP,P5RT4\'T\%\7T444p \(P*!Y-4GRjxL Rp?R#Rp?ii;i5i)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 rropcountNrsuccessT operationr_ requestedspawnedreasonz)All apps have reached their worker limits total_workerstarget_workersc><SPV,P#rr*rpr>s&r?r4DirtyArbiter.handle_manage_request..s4<<?3F3FrBr removeremovedzUnknown manage operation: z6Worker management: %s %d workers (spawned/removed: %d)zManage operation error: %s)rWrPintrr spawn_workerr3rvrrVr*rrRminr kill_workerrrrr r rrrmr rHrrp)r>rrrr r!r%rrrr/ oldest_pidrrrLsf&& r?r"DirtyArbiter.handle_manage_requests[[y1 [[ As7;;w234N M]"uA!..0F)((A-(1 !--,,, &a<!4#U#U!1 "M'T\\):($*:*:F"4#U#U!7'T\\):($*:*: F''"779 uA'';64<<(A-$$)$"%T\\%6%6%8)F"HJ$$Z@qLG!--,,,& tw#S%6$d&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 M! A*K/7K&8E K/K)A&K/)K+*K/.M!0A/K/K- K/$M!&K/)K/+K/-K// M:AM MMM!MM!c T "VPRR4pVPR4pVPRR4pVPR4pVPR4pVPR4pR p V\8Xd9WPP9d/VPV&WpPV,V&R p EMV\8XdPWPP9dR R /p EMW`PV,9dR R /p EMxVPV,V,p EM\V\8XdDWPP9d0W`PV,9dVPV,VR p EMR p EMV\ 8XdWPP9d.p EM\ VPV,P44p V'd:V U u.uF-p \P!\V 4V4'gK+V NK/ p p T p EMV\8Xd6WPP9d"VPV,P4R p EM@V\8Xd8WPP9dR R/p EMR\VPV,4RV/p MV\8Xd#WPP9d/VPV&R p MV\8Xd$WPP9dVPVR p MR p MV\ 8Xd%\ VPP44p MtV\"8Xd1WPP9dR p MVVfR p MOW`PV,9p M9\%RV 24p \'W<4p \(P*!W-4GR jxL R #\-V \.4'dR V 9dV R ,pVR8Xd\%RV 24p M*VR 8Xd\%RV 24p M\%\V 44p RVP14P3RR4 R2V n\'W<4p M \7W94p \(P*!W-4GR jxL R #uup iLL \8depTP:P=RT4\'T\%\T444p \(P*!Y-4GR jxL R p?R #R p?ii;i5i)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_foundsizezUnknown stash operation: zTable not found: zKey not found: StashrErrorzStash operation error: %s)rWr r<r rrr^rfnmatchrprclearrrVrrrrrr r r isinstancedicttitlereplace error_typer rHrr)r>rrrr r7rr9r:rall_keyskrrrFrLs&&& r?r!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%&Ax$I%F~%---%%e,224}$ 1 11%'89FD$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)R(,EP6.(P-P-!E?P6 P2!P6%R('B?P6&P4'P6+R(-P64P66 R%AR RR R( R%%R(c a"SP'gR#SPpSP'dP\SP4V8d6SP 4pVfM \ P !R4GRjxL Ka\SP4V8dj\SPP4V3RlR7pSPV\P4\ P !R4GRjxL KR#LL 5i)z%Maintain the number of dirty workers.Nrc><SPV,P#rr*r+s&r?r-DirtyArbiter.manage_workers..s4<<?+>+>rBr ) r1r3rVr*r1rvrr2rr3rr)r>r3rr4sf r?rDirtyArbiter.manage_workersszzz && jjjS.<&&(F~--$ $ $$,,+-T\\..0!>@J   Z 8--$ $ $ . % %s*2DAD>D ?BDD  D Dc  VP'dVPP^4pMforce_all_appsrYr)rrrLs&& r?r1DirtyArbiter.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+=AH K 0I K !-K 6K K c \P!W4R# \dBpTP\P8XdTP T4Rp?R#Rp?R#Rp?ii;i)zKill a worker by PID.N)r killrerrnoESRCH_cleanup_worker)r>rrrLs&&& r?r3DirtyArbiter.kill_workersI * GGC  *ww%++%$$S))& *s A&0A!!A&c VPV4WP9d/VPV,P4VPVVPP VR4WP 9d@\ VP V,4pV'dVPPV4VPV4VPP VR4pV'dVPPW4VPP VR4pV'dA\PP!V4'd\P"!V4R#R#R# \$dR#i;i)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)rr.rr-rfr9r^r;rXrhr*rdirty_worker_exitr+r r'rrr)r>r dead_appsrr)s&& r?r_DirtyArbiter._cleanup_workers+ %%c* '' '  ! !# & - - /%%c* sD) %% %T0056I&&--i8 $!!#t,  HH & &t 4))--c48 277>>+66  +&7;  sE11 F?Fc b"VPP'gR#\VPP 44Fwr\ P !4VPP4, VPP8:dKUTP'gFTPPRT4RTn TPT\P 4KTPT\P"4K R# \\3dKi;i5i)z!Kill workers that have timed out.NzDIRTY WORKER TIMEOUT (pid:%s)T)rrr^r*rUrrrrrrabortedrcriticalr3rSIGABRTSIGKILL)r>rrs& r?rDirtyArbiter.murder_workerssxx%%%  2 2 45KC >>#fjj&<&<&>>$((BXBXXY >>>!!"A3G!%  fnn5  fnn56Z(  s2AD/ A DD/,A+D/D,(D/+D,,D/c \P!R\P4wrV'gR#Rp\P!V4'd\P!V4pMN\P !V4'd3\P !V4pVPPRW4W0P8XdVPPRV4VPV4VPPRV4EK \d,pTP\P8wdhRp?R#Rp?ii;i)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 WIFSIGNALEDWTERMSIGrrIrXrr_rmrr]ECHILD)r>wpidstatusexitcoderrLs& r?rDirtyArbiter.reap_workers*s !zz"bjj9 <<''!~~f5H^^F++++f-CHH$$%P%)0555HHNN#I4P$$T* r old_workersrs& r?rDirtyArbiter.reloadCs  /0txx--.A    --$ $ $/ 4<<,,./ xx5567C   S&.. 18 %sA'C)C*A-Cc "VPP4FpVP4K V'd\PM\P p\ P !4VPP,p\VPP44FpVPWS4K VP'dK\ P !4V8d1VP4\P!R4GRjxL K\\VPP44F#pVPV\P 4K% VP4R#Lb5i)zStop all workers.rN)r.rOrrrrrrdirty_graceful_timeoutr^r*rr3rrvrri)r>gracefulrrlimitrs&& r?rDirtyArbiter.stopQs))002D KKM3!)fnnfnn dhh=== ))+,C   S &-llltyy{U2    --$ $ $ ))+,C   S&.. 1-  %s9FBFAFE?A#Fc *VP'dQ\PPVP4'd"\P!VP4\PPVP 4'd"\P!VP 4\P!VP4FAp\P!\PPVPV44KC \P!VP4VPPRVP4R# \ dEL i;i \ dLi;i \ dLXi;i)zSynchronous cleanup on exit.zDirty arbiter exiting (pid: %s)N)r#r r'rrrr)listdirr&r(rmdirrrmr)r>r{s& r?rzDirtyArbiter._cleanup_synchs <<>$** + +  $**+  ZZ , "'',,t{{A67- HHT[[ !  7B%       s7 E! E34BF! E0/E03 FF FF)r:r5r6r;r4r/r1r7r8rrr3rr#r"r)r<r&r0r9r,r.r-r+r*)NNr)F)T),__name__ __module__ __qualname____firstlineno____doc__splitrrr~rXr@r=rRr[rcrhrwrtrrrxrrrrrrrrrrrrrr1r3r_rrrrrz__static_attributes____classdictcell__)x __classdict__s0@r?rr1s <AACEC12wvw{+CEG5 n 5D"6:$B"!@ <8rs]    @ " OCOCrB