+ jG>Rt^RIt^RIt^RIt^RIt!RR4tR#)zn Control Interface Command Handlers Provides handlers for all control commands with access to arbiter state. Ncpa]tRt^toRtRtV3RlRltV3RlRltV3RlRltV3R lR lt V3R lR lt R'V3R lRllt R'V3RlRllt V3RlRlt R'V3RlRlltR'V3RlRlltV3RlRltV3RlRltV3RlRltR(V3RlRlltV3RlR ltV3R!lR"ltV3R#lR$ltR%tVtR&#))CommandHandlersz Command handlers with access to arbiter state. All handler methods return dictionaries that will be sent as the response data. c WnR#)z_ Initialize handlers with arbiter reference. Args: arbiter: The Gunicorn arbiter instance Narbiter)selfrs&&J/var/www/idalgo/venv/lib/python3.14/site-packages/gunicorn/ctl/handlers.py__init__CommandHandlers.__init__s  c <V^8dQhRS[/#returndict)format __classdict__s"r __annotate__CommandHandlers.__annotate__"s!;!;d!;r c  .p\P!4pVPPP 4Fkwr4VP P 4p\W%, ^4pVPRVRVPRVPRVPRV/4Km VPRR7R VR \V4/# \\3dRpLti;i) a5 Return list of HTTP workers. Returns: Dictionary with workers list containing: - pid: Worker process ID - age: Worker age (spawn order) - requests: Number of requests handled (if available) - booted: Whether worker has finished booting - last_heartbeat: Seconds since last heartbeat Npidagebootedabortedlast_heartbeatcVR,#rws&r.CommandHandlers.show_workers..As1U8r keyworkerscount)time monotonicrWORKERSitemstmp last_updateroundOSError ValueErrorappendrrrsortlen)rr%nowrworkerr,rs& r show_workersCommandHandlers.show_workers"snn<<//557KC &$jj446 !&s'8!!< NNsvzz&--6>> .  8  + ,7GS\::Z( &!% &s,C  C#"C#c <V^8dQhRS[/#r r)rrs"rrrEs: : D: r c VPP'g RRRRR.R./#\VPRR4p.p.pV'Ed?\VR4'Ed,\P !4pVP P4FmwrVVPP4p\WG, ^4pVPRVRVPR\VR .4R \VR R4R V/4Ko \VR 4'dzVP P4F[wr\#VP$P'V .44p VPR V RV P'R4R\)V 4RV /4K] RRRVPPRVRV/# \\\3dRpELi;i)z Return dirty workers and apps information. Returns: Dictionary with: - enabled: Whether dirty arbiter is running - pid: Dirty arbiter PID - workers: List of dirty worker info - apps: List of dirty app specs enabledFrNr%apps dirty_arbiterr app_pathsrr app_specs import_path worker_countcurrent_workers worker_pidsT)rdirty_arbiter_pidgetattrhasattrr'r(r%r*r+r,r-r.r/AttributeErrorr0rr=listapp_worker_mapgetr2) rr;r%r:r3rr4r,rpathspecrAs & r show_dirtyCommandHandlers.show_dirtyEs||---5t2    otD  =W]I>>.."C,44::< *"(**"8"8":K%*3+$n   = }k22"/"9"9"?"?"AJD"&}'C'C'G'Gb'Q"RKKK%t&(@)3{+;%{ !#B t 4<<11 w D   - ^<*%)N*s,F''GGc <V^8dQhRS[/#r r)rrs"rrrs!!T!r c  |VPPp/p.ROpVFp\W4p\V4'd \ V4pMW\ VR4'dF\ V\\\\\\\R434'g \ V4pWRV&K V# \dKi;i)zZ Return current effective configuration. Returns: Dictionary of configuration values __class__N)bindr% worker_classthreadstimeoutgraceful_timeout keepalive max_requestsmax_requests_jitterworker_connections preload_appdaemonpidfile proc_namereload dirty_workers dirty_apps dirty_timeoutcontrol_socketcontrol_socket_disable)rcfgrCcallablestrrD isinstanceintfloatboolrFrtyperE)rrcconfig config_keysr$values& r show_configCommandHandlers.show_configsll C )E??JEUK00S%tT4:N:P:PJE#s  "  sBB,, B;:B;c <V^8dQhRS[/#r r)rrs"rrrs  D r c \VPR/4pVPR4pRpV'd'\\P!4V, ^4pRTRVPP R\ VPP4RVPPRVPR^4R VPR ^4R VPR ^4R VPP;'gR/#) aA Return server statistics. Returns: Dictionary with: - uptime: Seconds since arbiter started - pid: Arbiter PID - workers_current: Current number of workers - workers_spawned: Total workers spawned - workers_killed: Total workers killed (if tracked) - reloads: Number of reloads (if tracked) _stats start_timeNuptimerworkers_currentworkers_targetworkers_spawnedworkers_killedreloadsrB) rCrrHr-r'rr2r) num_workersrB)rstatsrsrts& r show_statsCommandHandlers.show_statss h3YY|,  499;3Q7F f 4<<## s4<<#7#78 dll66 uyy):A> eii(8!< uyyA. !?!?!G!G4  r c <V^8dQhRS[/#r r)rrs"rrrsAAAr c .pVPPFp\V4pRVRVP4/pVPpVP \ P8XdRVR&MIVP \ P8XdRVR&M$VP \ P8XdRVR&VPV4K RVR \V4/# \d RTR&L6i;i) zO Return bound socket information. Returns: Dictionary with listeners list addressfdunixrjtcptcp6unknown listenersr&) r LISTENERSrefilenosockfamilysocketAF_UNIXAF_INETAF_INET6 Exceptionr0r2)rrlnraddr listener_infors& rshow_listenersCommandHandlers.show_listenerss <<))Cs8D4cjjlM 2xx;;&..0,2M&)[[FNN2,1M&)[[FOO3,2M&)   ] +'**YY@@  2(1 f% 2s0C-$C$CC-,C-c&<V^8dQhRS[RS[/#rr&rrgr)rrs"rrrs   D r c \^\V44pVPPpVP;PV, unVPP 4RVRVRVPP/#)z Increase worker count. Args: count: Number of workers to add (default 1) Returns: Dictionary with added count and new total addedprevioustotalmaxrgrrzwakeup)rr& old_counts&& r worker_addCommandHandlers.worker_addsoAs5z"LL,,    E)   U  T\\--  r c&<V^8dQhRS[RS[/#rr)rrs"rrrs  3 t r c \^\V44pVPPp\^W!, 4pW#, pW0PnVPP 4RVRVRV/#)z Decrease worker count. Args: count: Number of workers to remove (default 1) Returns: Dictionary with removed count and new total removedrrr)rr&r new_countactual_removeds&& r worker_removeCommandHandlers.worker_removessAs5z"LL,, 9,- ".#,    ~  Y  r c&<V^8dQhRS[RS[/#)rrrr)rrs"rrrsstr c \V4pWPP9d RRRRV R2/#\P!V\ P 4RRRV/# \dpRRR\T4/uRp?#Rp?ii;i) z} Gracefully terminate a specific worker. Args: pid: Worker process ID Returns: Dictionary with killed PID or error successFerrorzWorker z not foundTkilledN) rgrr)oskillsignalSIGTERMr.re)rres&& r worker_killCommandHandlers.worker_kills#h ll** *573%z2   GGC (4#  5Q  s*A B'A;5B;Bc&<V^8dQhRS[RS[/#rr)rrs"rrr4s77s747r c VPP'gRRRR/#\^\V44pVP RV4#)z Spawn additional dirty workers. Sends a MANAGE message to the dirty arbiter to spawn workers. Args: count: Number of dirty workers to add (default 1) Returns: Dictionary with added count or error rFrDirty arbiter not runningaddrrBrrg_send_manage_messagerr&s&&r dirty_addCommandHandlers.dirty_add4sN||---54  As5z"((66r c&<V^8dQhRS[RS[/#rr)rrs"rrrIs::#:d:r c VPP'gRRRR/#\^\V44pVP RV4#)z Remove dirty workers. Sends a MANAGE message to the dirty arbiter to remove workers. Args: count: Number of dirty workers to remove (default 1) Returns: Dictionary with removed count or error rFrrremoverrs&&r dirty_removeCommandHandlers.dirty_removeIsN||---54  As5z"((599r c,<V^8dQhRS[RS[RS[/#)r operationr&r)rergr)rrs"rrr^s'CCcC#C$Cr c  Rp\VPR4'd>VPP'd"\VPPRR4pV'g \P P R4pV'gRRRR/#^R IHpH pH pVR 8XdTMTp\P!\P\P4pVPR 4VPV4R VP R ^RVRV/p VP#W4VP%V4p VP'4V P R 4VP(8XdV P RRR/4#V P R 4VP*8Xd2V P R/4p RRRV P R\-V 44/#RRRRV P R 4 2/# \.dp RRR\-T 4/uRp ? #Rp ? ii;i)z Send a worker management message to the dirty arbiter. Args: operation: "add" or "remove" count: Number of workers to add/remove Returns: Dictionary with result or error Nr; socket_pathGUNICORN_DIRTY_SOCKETrFrz%Cannot find dirty arbiter socket path) DirtyProtocol MANAGE_OP_ADDMANAGE_OP_REMOVErg$@rjidopr&resultTmessagezUnexpected response type: )rDrr;rCrenvironrHgunicorn.dirty.protocolrrrrr SOCK_STREAM settimeoutconnectMSG_TYPE_MANAGE write_message read_messagecloseMSG_TYPE_RESPONSEMSG_TYPE_ERRORrer) rrr&dirty_socket_pathrrrrrrequestresponserrs &&& rr$CommandHandlers._send_manage_message^s! 4<< 1 1dll6P6P6P ' **M4! ! " /F G  5@  *   #,u"4:JB==1C1CDD OOD ! LL* + 55ab G  ' ' 6%11$7H JJL||F#}'F'FF||Hy$.?@@f%)E)EE Wb1uUYYy#e*= u9(,,v:N9OP  5Q  s,C#G6AGG H*G>8H>Hc <V^8dQhRS[/#r r)rrs"rrrs ' ' 'r c |\P!VPP\P 4RR/#)zV Trigger graceful reload (equivalent to SIGHUP). Returns: Dictionary with status status reloading)rrrrrSIGHUPrs&rr]CommandHandlers.reloads+    &--0+&&r c <V^8dQhRS[/#r r)rrs"rrrs'''r c |\P!VPP\P 4RR/#)zP Reopen log files (equivalent to SIGUSR1). Returns: Dictionary with status r reopening)rrrrrSIGUSR1rs&rreopenCommandHandlers.reopens+    &..1+&&r c&<V^8dQhRS[RS[/#)rmoder)rer)rrs"rrrs99S9$9r c VR8Xd;\P!VPP\P 4M9\P!VPP\P 4RRRV/#)zs Initiate shutdown. Args: mode: "graceful" (SIGTERM) or "quick" (SIGINT) Returns: Dictionary with status quickr shutting_downr)rrrrrSIGINTr)rrs&&rshutdownCommandHandlers.shutdownsR 7? GGDLL$$fmm 4 GGDLL$$fnn 5/6488r c <V^8dQhRS[/#r r)rrs"rrrs9 9 $9 r c \P!4pRVPPRRRR/p.pVPPP 4FawrEVP P4p\W, ^4pVPRVRRRVPR VPR V/4Kc VPR R 7Rp.p VPP'd-RVPPRR RR/pVP!4p RVRVR\#V4R VRV R\#V 4/# \\3dRpLi;i)z Return overview of all processes (arbiter, web workers, dirty arbiter, dirty workers). Returns: Dictionary with complete process hierarchy rrjrrolemasterNwebrrrcVR,#rrrs&rr!*CommandHandlers.show_all..sqxr r#r;z dirty master web_workersweb_worker_countr^dirty_worker_count)r'r(rrr)r*r+r,r-r.r/r0rrr1rB_query_dirty_workersr2) rr3 arbiter_inforrr4r,rdirty_arbiter_infor^s & rshow_allCommandHandlers.show_allsfnn 4<<## I H  <<//557KC &$jj446 !&s'8!!<   svzz&-- .   8 /0" << ) ) )t||55" !557M | ; K 0 / ] #m"4   9Z( &!% &s,D<<EEc <V^8dQhRS[/#r )rF)rrs"rrrs++d+r c Rp\VPR4'd>VPP'd"\VPPRR4pV'g \P P R4pV'g.#^RIHp\P!\P\P4pVPR4VPV4RVPRR /pVPW44VP!V4pVP#4VP R4VP$8Xd%VP R /4pVP R .4#.# \&d.#i;i) z Query the dirty arbiter for worker information. Connects to the dirty arbiter socket and sends a status request. Returns: List of dirty worker info dicts, or empty list on error Nr;rr)rg@rjrz ctl-status-1rr%)rDrr;rCrrrHrrrrrrrMSG_TYPE_STATUSrrrrr)rrrrrrrs& rr$CommandHandlers._query_dirty_workerss@! 4<< 1 1dll6P6P6P ' (B(BMSW X  " /F G  I  ===1C1CDD OOC LL* + 55nG  ' ' 6%11$7H JJL||F#}'F'FF!h3zz)R00G     sC E22 FFc <V^8dQhRS[/#r r)rrs"rrr1s&&d&r c JRRRRRRRRR R R R R RRRRRRRRRRRRRRRRR/pRV/#) z\ Return list of available commands. Returns: Dictionary with commands and descriptions zshow allz8Show all processes (arbiter, web workers, dirty workers)z show workersz#List HTTP workers with their statusz show dirtyzList dirty workers and appsz show configz$Show current effective configurationz show statszShow server statisticszshow listenerszShow bound socketszworker add [N]zSpawn N workers (default 1)zworker remove [N]zRemove N workers (default 1)zworker kill z$Gracefully terminate specific workerz dirty add [N]z!Spawn N dirty workers (default 1)zdirty remove [N]z"Remove N dirty workers (default 1)r]zGraceful reload (HUP)rzReopen log files (USR1)zshutdown [graceful|quick]zShutdown server (TERM/INT)helpzShow this help messagecommandsr)rr s& rrCommandHandlers.help1sr R A 7 A 2 2 ; !? !G @  D - / ')E , "H%%r rN))graceful)__name__ __module__ __qualname____firstlineno____doc__r r5rKrnr|rrrrrrrr]rrrrr__static_attributes____classdictcell__)rs@rrrs!;!;F: : x!!F  >AA@  .  8<77*::*CCJ ' '''99"9 9 v++Z&&r r)rrrrr'rrr rrs$   x&x&r