j3 DdZddlZddlZddlZddlZddlmZddlmZm Z m Z de de fdZ de de fdZde de fd Zde de fd Zde de fd Zde de fd Zde de fd Zde de de fdZdde de dedefdZdde dedefdZdZedkrejedSdS)zv gunicornc - Gunicorn control interface CLI Interactive and single-command modes for controlling Gunicorn instances. N)_get_default_control_socket) ControlClientControlClientError parse_commanddatareturnc |dg}|sdSg}|dddddddd dd |d |D]}|d d }|dd }|drdnd}|d}||dnd}||dd|dd|d d||d|d|dt|dd|S)z"Format workers output for display.workerszNo workers runningPID<10 AGE<6BOOTED<8 LAST_BEATz(----------------------------------------pid?agebootedyesnolast_heartbeatNs agon/aTotal: countz workers getappendlenjoin) rr lineswrrrhbhb_strs C/var/www/html/venv/lib/python3.11/site-packages/gunicorn/ctl/cli.pyformat_workersr*syhhy"%%G $## E LLEFFFFFF8FFFFFGGG LL AAeeE3eeE3%%//3t UU# $ $!#BU ???#???6???v??@@@@ LL LLD488GS\\::DDDEEE 99U  c |dsdSg}|d|d|d|dg}|r|d|dd d d d d d dd d|d|D]}|dd}|dd}d|dgdd}|d}||dnd}||d d |d d |dd ||d|dg}|r|d|ddd dd d d|d|D]}} | dddd} | d d!} | d"} | t| nd#} || dd | d d | ~d$|S)%z(Format dirty workers output for display.enabledzDirty arbiter not runningzDirty arbiter PID: rrr zDIRTY WORKERS:r r r rrAPPSz<30rz<------------------------------------------------------------rr, appsNrrrz DIRTY APPS:APPWORKERSLIMIT2-------------------------------------------------- import_pathcurrent_workersr worker_countnoner)r!r"r$str)rr%r r&rrr0r'r(apppathcurrentlimit limit_strs r) format_dirtyr@-s 88I  +** E LL8txx88999 LLhhy"%%G  %&&& IIIEIIIvIIIKIIJJJ X D DA%%s##C%%s##C99QUU62..//4D'((B%'^\\\\F LLCBBBcBBBtBBB&BB C C C C R 88FB  D B ]### ===I===G==>>> X B BC77=#..ss3Dgg/33GGGN++E&+&7E VI LLD@@@w@@@Y@@ A A A A 99U  r+cg}|d}|rXt|dz}t|dzdz}t|dz}|r |d|d|d}n|r |d|d}n|d}nd}|d||d |d d|d |d d |d|dd |d|dd |d|dd |d|dd |d}|r|d|d|S)z Format stats output for display.uptimei<zh zm sunknownzUptime: zPID: rzWorkers current: workers_currentrzWorkers target: workers_targetzWorkers spawned: workers_spawnedzWorkers killed: workers_killedzReloads: reloadsdirty_arbiter_pidzDirty arbiter: r)r!intr"r$)rr%rBhoursminutesseconds uptime_str dirty_pids r) format_statsrRWs E XXh  F FdN##v}+,,frk""  '!::W:::::JJ  '#11w111JJ#JJ  LL2j22333 LLBdhhui&@&@BBCCC LLFdhh/@!&D&DFFGGG LLEdhh/?&C&CEEFFF LLFdhh/@!&D&DFFGGG LLEdhh/?&C&CEEFFF LL>dhhy!&<&<>>???,--I7 5)55666 99U  r+c 6|dg}|sdSg}|ddddddd|d |D]c}|d d }|d d }|d d }||dd|dd|d|d|d|dt|dd|S)z$Format listeners output for display. listenerszNo listeners boundADDRESSz<40r TYPErFDz7-------------------------------------------------------addressrtypefdrrrz listenersrr )rrTr%lnraddrltyperZs r)format_listenersr^xs7b))I $## E LLI666F66666777 LL44wwy#&&$$ WWT3   2225222b223333 LL LLH488GS^^<<HHHIII 99U  r+c$g}t|D]X}||}t|trdd|D}||d|Yd|S)z!Format config output for display.r/c34K|]}t|VdSN)r:).0vs r) z format_config..s(44c!ff444444r+z: r)sortedkeys isinstancelistr$r")rr%keyvalues r) format_configrks Ediikk""((S  eT " " 5II44e44444E &&u&&'''' 99U  r+c|di}g}|d|d|r+td|Dnd}t |D]'\}}|d|d|dzd |(d |S) zFormat help output for display.commandszAvailable commands:rc34K|]}t|VdSra)r#)rbcmds r)rdzformat_help..s(66s#c((666666r+r <r r)r!r"maxrfreitemsr$)rrmr%max_lenrodescs r) format_helprwsxx B''H E LL&''' LL;CIc66hmmoo666666GHNN,,--77 T 5#5! 5555t556666 99U  r+c g}|di}|d|d|dd|d|dg}|d|d d d |r|d d ddddddddd|d d|D]}|dd}|dd}|drdnd}|d}||dnd} |d |dd|dd|dd| n|d|d|d} | r|d |d| dd|d|d!g} |d"|d#d d | r*|d d dddddd$|d d%| D]}|dd}|dd}|d&g} | r| d d'd(} |d |dd|dd| | d)dD]=}|d'd(}|d dddddd|>|d |dd|dd*n@|dn*|d |d+d,|S)-z#Format show all output for display.arbiterzARBITER (master)z PID: rrr web_workersz WEB WORKERS (web_worker_countr)rpr r r rrrrrz&--------------------------------------rrrrrNrrz (none) dirty_arbiterz DIRTY ARBITER dirty_workerszDIRTY WORKERS (dirty_worker_countr.r5r0:z (no apps)z (not running)r)r!r"splitr$)rr%ryrzr&rrrr'r(r}r~r0 first_appr;app_names r) format_allrsn Ehhy"%%G LL#$$$ LL47;;uc2244555 LL((="--K LLC*}00<<>>??? R"55  Ktxx0Da'H'HKKKLLL  % LL=e===%===V== > > > LLh ) ) )" D DeeE3''eeE3''uuVR((D $Q c 2 22 6ILL!Dc!D!D!D!D!D!D!D!DEEE#ABBxGG#&99S>>"#5 %E"%E%E%E2%E%E%E8%E%EFFFFGLL!Bc!B!B!B!B!B!B!BCCCC D LL $ $ $ $ _%%% &''' 99U  r+commandc|}|dkrt|S|dkrt|S|dkrt |S|dkrt |S|dkrt |S|dkrt|S|dkrt|S|rtj |d Sd S) z Format response data based on command. Args: command: Original command string data: Response data dictionary Returns: Formatted string for display zshow allz show workersz show dirtyz show statszshow listenersz show confighelprrindentOK) lowerstriprr*r@rRr^rkrwjsondumps)rr cmd_lowers r)format_responsers %%''IJ$ n $ $d### l " "D!!! l " "D!!! & & &%%% m # #T""" f  4     .:d1--- -tr+F socket_path json_outputc t|5}t|\}}|r,|dd|n|}||}|r$t t j|dnt||}t | ddddS#1swxYwYdS#t$r)} t d| tj Yd} ~ dSd} ~ wt$rYd SwxYw) z Execute single command and exit. Args: socket_path: Path to control socket command: Command to execute json_output: If True, output raw JSON Returns: Exit code (0 for success, 1 for error) r rrrNrError: filer) rrr$r send_commandprintrrrrsysstderrKeyboardInterrupt) rrrclientroargs full_commandresultoutputes r) run_commandr st ; ' ' 6%g..IC@DMc44CHHTNN44::<<<#L((66F dj2223333(f55f                     mmm#*----qqqqq sssAC BB</ C <CC CC DC77 DDc. ddl}d}n#t$rd}YnwxYw t|}|n6#t$r)}t d|t jYd}~dSd}~wwxYwt d|t d t tj d }|r' | |n#t$rYnwxYwd} td }n#t$rt YnEwxYw|sF|d vrn& t#|\} } | r,| d d | n| } || } |r$t t)j| dnt-| | } t | nx#t$rk}t d| ||n%#t$rt dd}YYd}~n!wxYwYd}~nd}~wwxYwt n #t0$rt d}YnwxYw||r' ||nS#t4$rYnGwxYwnB#||r' ||w#t4$rYwwxYwwxYw|S)z Run interactive CLI with readline support. Args: socket_path: Path to control socket json_output: If True, output raw JSON Returns: Exit code rNTFrrrz Connected to z3Type 'help' for available commands, 'quit' to exit.z~/.gunicornc_historyz gunicorn> )quitexitqr rrrzConnection lost. Exiting.r)readline ImportErrorrconnectrrrrosr< expanduserread_history_fileFileNotFoundErrorinputrEOFErrorrrr$rrrrcloserwrite_history_file Exception)rrr has_readlinerr history_file exit_codelinerorrrrs r)run_interactiver.s  {++  mmm#*----qqqqq '+ ' '((( ?@@@ GGG7%%&<==L   & &| 4 4 4 4     D I/#  \**0022     zz||444 )$// TDHQ#8888>>@@@c ,,\::"$*VA6667777,S&99F&MMM%   mmm$$$LLNNNNN$$$$)5666 !IEEEEE%$$$$  GGGG# J        ++L9999          ++L9999      s #A A3 A..A3C C*)C*0I52!DI5D0,I5/D00I5BG,+I5, I!6I (H21I2I II5III5I!!I54K5JKJK,K KKL+LL L L LLctjdtjd}|ddt d|dd d |d d dd|dddd|}|jrddlm}td|ddS|j }tj |s1tj tj|}|jrt#||j|jSt'||jS)z#Main entry point for gunicornc CLI.zGunicorn control interfacea? Examples: gunicornc # Interactive mode (default socket) gunicornc -s /tmp/myapp.ctl # Interactive mode with custom socket gunicornc -c "show workers" # Single command mode gunicornc -c "worker add 2" # Add 2 workers gunicornc -c "show stats" -j # Output stats as JSON ) descriptionformatter_classepilogz-sz--socketzUControl socket path (default: auto-detected based on XDG_RUNTIME_DIR or ~/.gunicorn/))defaultrz-cz --commandzExecute single command and exit)rz-jz--json store_truezOutput raw JSON (for scripting))actionrz-vz --versionzShow version and exitr) __version__zgunicornc (gunicorn r|)argparseArgumentParserRawDescriptionHelpFormatter add_argumentr parse_argsversiongunicornrrsocketrr<isabsr$getcwdrrrr)parserrrrs r)mainrs  $0 <    F  j+-- d   k .   h .   k $     D |(((((( 3[333444q+K 7== % %=gll29;; <<  |7; di@@@{DI666r+__main__)F)__doc__rrrrgunicorn.configrgunicorn.ctl.clientrrrdictr:r*r@rRr^rkrwrrboolrLrrr__name__rr+r)rs0   777777PPPPPPPPPP#2't'''''TtB4C,       d s     ;T;c;;;;| S      FS3TcBWWW4WCWWWWt676767r z CHTTVVr+