AҐiG<dZddlZddlZddlZddlZGddZy)zn Control Interface Command Handlers Provides handlers for all control commands with access to arbiter state. Nc eZdZdZdZdefdZdefdZdefdZdefdZ defdZ dd e defd Z dd e defd Z d e defd Zdd e defdZdd e defdZded e defdZdefdZdefdZddedefdZdefdZdefdZdefdZy)CommandHandlersz Command handlers with access to arbiter state. All handler methods return dictionaries that will be sent as the response data. c||_y)z Initialize handlers with arbiter reference. Args: arbiter: The Gunicorn arbiter instance N)arbiter)selfrs N/var/www/descvideos/venv/lib/python3.12/site-packages/gunicorn/ctl/handlers.py__init__zCommandHandlers.__init__s  returnc g}tj}|jjj D]d\}} |j j }t||z d}|j||j|j|j|df|jd|t|dS#ttf$rd}YkwxYw)a} 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 |dSNrws rz.CommandHandlers.show_workers..As 1U8r key)workerscount)time monotonicrWORKERSitemstmp last_updateroundOSError ValueErrorappendrrrsortlen)rrnowrworkerr"rs r show_workerszCommandHandlers.show_workers"snn<<//557 KC &$jj446 !&s['8!!< NNzz --!>>"0     + ,"S\::Z( &!% &s)CCCc 0|jjsddggdSt|jdd}g}g}|r%t|drt j }|j jD]f\}} |jj}t||z d}|j||jt|dgt|dd|d ht|d ru|j jD]X\} } t#|j$j'| g} |j| | j'd t)| | d Zd |jj||dS#tttf$rd}YwxYw)a% 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)rrr.rr app_specs worker_count) import_pathr2current_workers worker_pidsT)rdirty_arbiter_pidgetattrhasattrrrrr r!r"r#r$r%AttributeErrorr&rr1listapp_worker_mapgetr() rr/rr.r)rr*r"rpathspecr5s r show_dirtyzCommandHandlers.show_dirtyEs||--     otD  W]I>.."C,44::<  V*"(**"8"8":K%*3+&4    }k2"/"9"9"?"?"AJD$"&}'C'C'G'Gb'Q"RKKK'+(,(@+.{+;'2 !<<11   - ^<*%)N*s>)E<<FFc R|jj}i}gd}|D]v} t||}t|r t |}nKt |dr?t |tttttttdfs t |}|||<x|S#t$rYwxYw)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)rcfgr7callablestrr8 isinstanceintfloatboolr:dicttyper9)rrUconfig config_keysrvalues r show_configzCommandHandlers.show_configsll  C S)E?JEUK0S%tT4:N:PJE#s   "  sA3B B&%B&c t|jdi}|jd}d}|r!tt j|z d}||jj t |jj|jj|jdd|jdd|jdd|jjxsdd S) a 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_timeNr workers_spawnedrworkers_killedreloads)uptimerworkers_currentworkers_targetrerfrgr6) r7rr<r#rrr(r num_workersr6)rstatsrdrhs r show_statszCommandHandlers.show_statss h3YY|,  499;3Q7F<<##"4<<#7#78"ll66$yy):A>#ii(8!<yyA.!%!?!?!G4  r cg}|jjD]}t|}||jd} |j}|j t jk(rd|d<nE|j t jk(rd|d<n"|j t jk(rd|d<|j||t|dS#t$rd|d<Y1wxYw)zo Return bound socket information. Returns: Dictionary with listeners list )addressfdunixr]tcptcp6unknown) listenersr) r LISTENERSrWfilenosockfamilysocketAF_UNIXAF_INETAF_INET6 Exceptionr&r()rrulnraddr listener_inforxs rshow_listenerszCommandHandlers.show_listenerss <<)) ,Cs8DjjlM 2xx;;&..0,2M&)[[FNN2,1M&)[[FOO3,2M&)   ] +' ,*'Y@@  2(1 f% 2sA4CC! C!rctdt|}|jj}|jxj|z c_|jj |||jjdS)z Increase worker count. Args: count: Number of workers to add (default 1) Returns: Dictionary with added count and new total )addedprevioustotalmaxrYrrkwakeup)rr old_counts r worker_addzCommandHandlers.worker_addsiAs5z"LL,,    E)  !\\--  r ctdt|}|jj}td||z }||z }||j_|jj |||dS)z Decrease worker count. Args: count: Number of workers to remove (default 1) Returns: Dictionary with removed count and new total r)removedrrr)rrr new_countactual_removeds r worker_removezCommandHandlers.worker_removessAs5z"LL,, 9u,- "Y.#,   &!  r rct|}||jjvr dd|ddS tj|t j d|dS#t$r}dt|dcYd}~Sd}~wwxYw)z Gracefully terminate a specific worker. Args: pid: Worker process ID Returns: Dictionary with killed PID or error FzWorker z not foundsuccesserrorT)rkilledN) rYrroskillsignalSIGTERMr$rW)rres r worker_killzCommandHandlers.worker_kills#h dll** * "3%z2   GGC (   Q  s(A A8 A3-A83A8c|jjsdddStdt|}|j d|S)a 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 runningrraddrr6rrY_send_manage_messagerrs r dirty_addzCommandHandlers.dirty_add4sF||-- 4  As5z"((66r c|jjsdddStdt|}|j d|S)a 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_removezCommandHandlers.dirty_removeIsF||-- 4  As5z"((599r operationcd}t|jdr7|jjr!t|jjdd}|stj j d}|sdddS dd lm}m }m }|d k(r|n|}tjtjtj}|jd |j||j d ||d } |j#|| |j%|} |j'| j d|j(k(r| j dddiS| j d|j*k(r0| j di} d| j dt-| dSdd| j ddS#t.$r} dt-| dcYd} ~ Sd} ~ wwxYw)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_SOCKETFz%Cannot find dirty arbiter socket pathrr) DirtyProtocol MANAGE_OP_ADDMANAGE_OP_REMOVErg$@r)r]idoprr]resultrTrmessagezUnexpected response type: )r8rr/r7renvironr<gunicorn.dirty.protocolrrrrzr{ SOCK_STREAM settimeoutconnectMSG_TYPE_MANAGE write_message read_messagecloseMSG_TYPE_RESPONSEMSG_TYPE_ERRORrWr~) rrrdirty_socket_pathrrrrrxrequestresponserrs rrz$CommandHandlers._send_manage_message^s! 4<< 1dll6P6P ' **M4! ! " /F G   @  *   #,u"4:JB==1C1CDD OOD ! LL* +&55 G  ' 'g 6%11$7H JJL||F#}'F'FF||Hy$.?@@f%)E)EE Wb1$"YYy#e*= %9(,,v:N9OP   Q  s,9CF;A F;$F;; G GGGcztj|jjtj ddiS)zv Trigger graceful reload (equivalent to SIGHUP). Returns: Dictionary with status status reloading)rrrrrSIGHUPrs rrNzCommandHandlers.reloads+    &--0+&&r cztj|jjtj ddiS)zp Reopen log files (equivalent to SIGUSR1). Returns: Dictionary with status r reopening)rrrrrSIGUSR1rs rreopenzCommandHandlers.reopens+    &..1+&&r modec|dk(r9tj|jjtj n8tj|jjtj d|dS)z Initiate shutdown. Args: mode: "graceful" (SIGTERM) or "quick" (SIGINT) Returns: Dictionary with status quick shutting_down)rr)rrrrrSIGINTr)rrs rshutdownzCommandHandlers.shutdownsN 7? GGDLL$$fmm 4 GGDLL$$fnn 5)488r c vtj}|jjddd}g}|jjj D]Z\}} |j j}t||z d}|j|d|j|j|d\|jd d}g} |jjr*|jjd d d}|j!} ||t#||| t#| d S#ttf$rd}YwxYw) z Return overview of all processes (arbiter, web workers, dirty arbiter, dirty workers). Returns: Dictionary with complete process hierarchy rmaster)rr]roler Nweb)rr]rrrc |dSrrrs rrz*CommandHandlers.show_all..s qxr rr/z dirty master)r web_workersweb_worker_countr/rOdirty_worker_count)rrrrrr r!r"r#r$r%r&rrr'r6_query_dirty_workersr() rr) arbiter_inforrr*r"rdirty_arbiter_inforOs rshow_allzCommandHandlers.show_allsInn<<##  <<//557 KC &$jj446 !&s['8!!<   zz --"0     /0" << ) )||55'&" !557M$& #K 0/*"%m"4   9Z( &!% &s)D$$D87D8cd}t|jdr7|jjr!t|jjdd}|stj j d}|sgS ddlm}tjtjtj}|jd|j||jdd }|j|||j!|}|j#|j d |j$k(r$|j d i}|j d gS gS#t&$rYgSwxYw) 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/rrr)rg@z ctl-status-1)r]rr]rr)r8rr/r7rrr<rrrzr{rrrMSG_TYPE_STATUSrrrrr~)rrrrxrrrs rrz$CommandHandlers._query_dirty_workerss8! 4<< 1dll6P6P ' (B(BMSW X  " /F G  I  ===1C1CDD OOC LL* +&55$G  ' 'g 6%11$7H JJL||F#}'F'FF!h3zz)R00G     s6CE E$#E$c.ddddddddd d d d d ddd}d|iS)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]rNrzshutdown [graceful|quick]helpcommandsr)rrs rrzCommandHandlers.help1sFSA7A22;!?!G@ D-/)E, "H%%r N)r)graceful)__name__ __module__ __qualname____doc__r r\r+r?rarmrrYrrrrrrWrrNrrrr:rrrr rrrs!;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)rrrrzrrrr rrs$   x&x&r