iG<SrSSKrSSKrSSKrSSKr"SS5rg)zn Control Interface Command Handlers Provides handlers for all control commands with access to arbiter state. Nc@\rSrSrSrSrS\4SjrS\4SjrS\4Sjr S\4Sjr S\4S jr SS \ S\4S jjr SS \ S\4S jjrS \ S\4SjrSS \ S\4SjjrSS \ S\4SjjrS\S \ S\4SjrS\4SjrS\4SjrSS\S\4SjjrS\4SjrS\4SjrS\4SjrSrg)CommandHandlersz Command handlers with access to arbiter state. All handler methods return dictionaries that will be sent as the response data. cXlg)z_ Initialize handlers with arbiter reference. Args: arbiter: The Gunicorn arbiter instance Narbiter)selfrs G/var/www/ias/venv/lib/python3.13/site-packages/gunicorn/ctl/handlers.py__init__CommandHandlers.__init__s  returnc /n[R"5nURRR 5Hcup4UR R 5n[X%- S5nURUURURURUS.5 Me URSS9 U[U5S.$![[4a SnNkf=f)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 N)pidagebootedabortedlast_heartbeatc US$Nrws r .CommandHandlers.show_workers..As1U8r key)workerscount)time monotonicrWORKERSitemstmp last_updateroundOSError ValueErrorappendrrrsortlen)r rnowrworkerr&rs r show_workersCommandHandlers.show_workers"snn<<//557KC &$jj446 !&s'8!!< NNzz --!>>"0  8  + ,"S\::Z( &!% &s(CCCc ^URR(dSS//S.$[URSS5n/n/nU(Ga1[US5(Ga[R "5nUR R5HeupVURR5n[XG- S5nURUUR[US/5[USS5US .5 Mg [US 5(avUR R5HXup[#UR$R'U /55n URU U R'S 5[)U 5U S .5 MZ S URRUUS.$![[[4a SnNf=f)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 FN)enabledrrapps dirty_arbiterrr app_pathsr)rrr3rr app_specs worker_count) import_pathr7current_workers worker_pidsT)rdirty_arbiter_pidgetattrhasattrr!r"rr$r%r&r'r(r)AttributeErrorr*rr6listapp_worker_mapgetr,) r r4rr3r-rr.r&rpathspecr:s r show_dirtyCommandHandlers.show_dirtyEs||--     otD  W]I>>.."C,44::< *"(**"8"8":K%*3+&4   = }k22"/"9"9"?"?"AJD"&}'C'C'G'Gb'Q"RKKK'+(,(@+.{+;'2 !#B<<11   - ^<*%)N*s (FF,+F,c tURRn0n/SQnUHn[X5n[U5(a [ U5nOU[ US5(aD[ U[[[[[[[S545(d [ U5nXRU'M U$![a Mf=f)zZ Return current effective configuration. Returns: Dictionary of configuration values )bindr worker_classthreadstimeoutgraceful_timeout keepalive max_requestsmax_requests_jitterworker_connections preload_appdaemonpidfile proc_namereload dirty_workers dirty_apps dirty_timeoutcontrol_socketcontrol_socket_disable __class__N)rcfgr<callablestrr= isinstanceintfloatboolr?dicttyper>)r r[config config_keysrvalues r show_configCommandHandlers.show_configsll C )E??JEUK00S%tT4:N:P:PJE#s  "  sBB)) B76B7c [URS05nURS5nSnU(a"[[R"5U- S5nUURR [ URR5URRURSS5URSS5URSS5URR=(d SS .$) 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_timeNrworkers_spawnedrworkers_killedreloads)uptimerworkers_currentworkers_targetrlrmrnr;) r<rrAr'r!rr,r# num_workersr;)r statsrkros r show_statsCommandHandlers.show_statss h3YY|,  499;3Q7F<<##"4<<#7#78"ll66$yy):A>#ii(8!<yyA.!%!?!?!G4  r c/nURRHn[U5nUUR5S.nURnUR [ R:XaSUS'OGUR [ R:XaSUS'O#UR [ R:XaSUS'URU5 M U[U5S.$![a SUS'N4f=f)zO Return bound socket information. Returns: Dictionary with listeners list )addressfdunixrctcptcp6unknown) listenersr ) r LISTENERSr]filenosockfamilysocketAF_UNIXAF_INETAF_INET6 Exceptionr*r,)r r}lnraddr listener_infors r show_listenersCommandHandlers.show_listenerss <<))Cs8DjjlM 2xx;;&..0,2M&)[[FNN2,1M&)[[FOO3,2M&)   ] +'**'Y@@  2(1 f% 2s/C+#C#CC'&C'r c[S[U55nURRnUR=RU- slURR 5 UUURRS.$)z Increase worker count. Args: count: Number of workers to add (default 1) Returns: Dictionary with added count and new total )addedprevioustotalmaxr_rrrwakeup)r r old_counts r worker_addCommandHandlers.worker_addsiAs5z"LL,,    E)  !\\--  r c[S[U55nURRn[SX!- 5nX#- nX0RlURR 5 UUUS.$)z Decrease worker count. Args: count: Number of workers to remove (default 1) Returns: Dictionary with removed count and new total r)removedrrr)r r r new_countactual_removeds r worker_removeCommandHandlers.worker_removesmAs5z"LL,, 9,- ".#,   &!  r rc[U5nXRR;a SSUS3S.$[R"U[ R 5 SUS.$![anS[U5S.sSnA$SnAff=f)z} Gracefully terminate a specific worker. Args: pid: Worker process ID Returns: Dictionary with killed PID or error FzWorker z not foundsuccesserrorT)rkilledN) r_rr#oskillsignalSIGTERMr(r])r res r worker_killCommandHandlers.worker_kills#h ll** * "3%z2   GGC (   Q  s)A A;# A60A;6A;cURR(dSSS.$[S[U55nUR SU5$)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 FDirty arbiter not runningrraddrr;rr__send_manage_messager r s r dirty_addCommandHandlers.dirty_add4sF||-- 4  As5z"((66r cURR(dSSS.$[S[U55nUR SU5$)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 Frrrremoverrs r dirty_removeCommandHandlers.dirty_removeIsF||-- 4  As5z"((599r operationcSn[URS5(a<URR(a![URRSS5nU(d[R R S5nU(dSSS.$SS KJnJ nJ n US :XaUOUn[R"[R[R5nURS 5 URU5 UR S UUS .n UR#X5 UR%U5n UR'5 U R S5UR(:XaU R SSS05$U R S5UR*:Xa0U R S05n SU R S[-U 55S.$SSU R S53S.$![.an S[-U 5S.sSn A $Sn A ff=f)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 Nr4 socket_pathGUNICORN_DIRTY_SOCKETFz%Cannot find dirty arbiter socket pathrr) DirtyProtocol MANAGE_OP_ADDMANAGE_OP_REMOVErg$@r)rcidopr rcresultrTrmessagezUnexpected response type: )r=rr4r<renvironrAgunicorn.dirty.protocolrrrrr SOCK_STREAM settimeoutconnectMSG_TYPE_MANAGE write_message read_messagecloseMSG_TYPE_RESPONSEMSG_TYPE_ERRORr]r) r rr dirty_socket_pathrrrrrrequestresponserrs r r$CommandHandlers._send_manage_message^s! 4<< 1 1dll6P6P ' **M4! ! " /F G   @  *   #,u"4:JB==1C1CDD OOD ! LL* +&55 G  ' ' 6%11$7H JJL||F#}'F'FF||Hy$.?@@f%)E)EE Wb1$"YYy#e*= %9(,,v:N9OP   Q  s, CG,AG;G G4 G/)G4/G4c|[R"URR[R 5 SS0$)zV Trigger graceful reload (equivalent to SIGHUP). Returns: Dictionary with status status reloading)rrrrrSIGHUPr s r rTCommandHandlers.reloads+    &--0+&&r c|[R"URR[R 5 SS0$)zP Reopen log files (equivalent to SIGUSR1). Returns: Dictionary with status r reopening)rrrrrSIGUSR1rs r reopenCommandHandlers.reopens+    &..1+&&r modecUS:Xa:[R"URR[R 5 O9[R"URR[R 5 SUS.$)zs Initiate shutdown. Args: mode: "graceful" (SIGTERM) or "quick" (SIGINT) Returns: Dictionary with status quick shutting_down)rr)rrrrrSIGINTr)r rs r shutdownCommandHandlers.shutdownsN 7? GGDLL$$fmm 4 GGDLL$$fnn 5)488r c ~[R"5nURRSSS.n/nURRR 5HYupEUR R5n[X- S5nURUSURURUS.5 M[ URSS 9 Sn/n URR(a*URRS S S.nUR!5n UU[#U5UU [#U 5S .$![[4a SnNf=f) z Return overview of all processes (arbiter, web workers, dirty arbiter, dirty workers). Returns: Dictionary with complete process hierarchy rmaster)rrcrolerNweb)rrcrrrc US$rrrs r r*CommandHandlers.show_all..sqxr rr4z dirty master)r web_workersweb_worker_countr4rUdirty_worker_count)r!r"rrr#r$r%r&r'r(r)r*rrr+r;_query_dirty_workersr,) r r- arbiter_inforrr.r&rdirty_arbiter_inforUs r show_allCommandHandlers.show_alls@nn<<##  <<//557KC &$jj446 !&s'8!!<   zz --"0   8 /0" << ) )||55'&" !557M$& #K 0/*"%m"4   9Z( &!% &s(D''D<;D<cSn[URS5(a<URR(a![URRSS5nU(d[R R S5nU(d/$SSKJn [R"[R[R5nURS5 URU5 URSS .nURX45 UR!U5nUR#5 UR S 5UR$:Xa$UR S 05nUR S /5$/$![&a /$f=f) 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 Nr4rrr)rg@z ctl-status-1)rcrrcrr)r=rr4r<rrrArrrrrrrMSG_TYPE_STATUSrrrrr)r rrrrrrs r r$CommandHandlers._query_dirty_workerss9! 4<< 1 1dll6P6P ' (B(BMSW X  " /F G  I  ===1C1CDD OOC LL* +&55$G  ' ' 6%11$7H JJL||F#}'F'FF!h3zz)R00G     s CE,, E:9E:c.SSSSSSSSS S S S S SSS.nSU0$)z\ Return list of available commands. Returns: Dictionary with commands and descriptions z8Show all processes (arbiter, web workers, dirty workers)z#List HTTP workers with their statuszList dirty workers and appsz$Show current effective configurationzShow server statisticszShow bound socketszSpawn N workers (default 1)zRemove N workers (default 1)z$Gracefully terminate specific workerz!Spawn N dirty workers (default 1)z"Remove N dirty workers (default 1)zGraceful reload (HUP)zReopen log files (USR1)zShutdown server (TERM/INT)zShow this help message)zshow allz show workersz show dirtyz show configz show statszshow listenerszworker add [N]zworker remove [N]zworker kill z dirty add [N]zdirty remove [N]rTrzshutdown [graceful|quick]helpcommandsr)r rs r rCommandHandlers.help1sFSA7A22;!?!G@ D-/)E, "H%%r rN)r)graceful)__name__ __module__ __qualname____firstlineno____doc__r rbr/rDrgrtrr_rrrrrr]rrTrrrr?rr__static_attributes__rr r rrs!;d!;F: D: x!T!F D >AA@  D . 3 t 8st<7s747*:#:d:*CcC#C$CJ ' '''9S9$9"9 $9 v+d+Z&d&r r)rrrrr!rrr r rs$   x&x&r