qgSddlZddlZddlZddlZddlZddlZddlZddlZddlm Z m Z ddl m Z ddl mZmZmZddl mZmZGddZy)N) HaltServerAppImportError)Pidfile)socksystemdutil) __version__SERVER_SOFTWAREc eZdZdZdZdZiZgZiZgZ gZ djDcgc]}ttd|zc}}}}Zedee DZdZdZd ZeeeZd Zd Zd Zd Z dZdZdZdZdZdZdZ dZ!dZ"dZ#dZ$dZ%dZ&d(dZ'dZ(d)dZ)dZ*d Z+d!Z,d"Z-d#Z.d$Z/d%Z0d&Z1d'Z2ycc}}}}w)*Arbiterz Arbiter maintain the workers processes alive. It launches or kills them if needed. It also manages application reloading via SIGHUP/USR2. z+HUP QUIT INT TERM TTIN TTOU USR1 USR2 WINCHzSIG%sc#K|]7}|dddk(r-|ddk7r%tt||ddjf9yw)Nr SIG_)getattrsignallower).0names N/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/gunicorn/arbiter.py zArbiter.-sI6: 8u aC  QR 01s=?cttjd<d|_d|_d|_|j |d|_d|_d|_ d|_ d|_ d|_ tj}tj dd}|j#dtj$||tj$d|_y)Nr FrMaster)argscwdr)r osenviron _num_workers _last_logged_active_worker_countlogsetuppidfiler worker_age reexec_pid master_pid master_namergetcwdsysargvinsert executable START_CTX)selfapprrs r__init__zArbiter.__init__2s(7 $% 04- 3  #kkmxx{ As~~&~~ c|jSN)rr.s r_get_num_workerszArbiter._get_num_workersNs   r1cd|j}||_|jj|||yr3)rcfgnworkers_changed)r.value old_values r_set_num_workerszArbiter._set_num_workersQs+%% ! !!$y9r1c ||_|j|_|j*|jj|j|_dtj vr|jj |jj|_|jj|_|jj|_ |jj|_ |jj|_ |jjdjdjdt!|jj"j%dD|jj&r?|jj&j%D]\}}|tj |<|jj(r|jj+yy)N GUNICORN_PIDzCurrent configuration: {0} c3ZK|]#\}}dj||j%yw)z {0}: {1}N)formatr9)rconfigr9s rrz Arbiter.setup..is-;!FE##FEKK8;s)+c |dSN)settings rzArbiter.setup..ms gajr1key)r/r7r! logger_classrr reopen_files worker_classaddressworkers num_workerstimeout proc_namedebugr@joinsortedsettingsitemsenv preload_appwsgi)r.r/kvs rr"z Arbiter.setupWsb77 88 xx,,SWW5DH RZZ ' HH ! ! # HH11xx'' 88++xx'' ++ 4;; II;$((++1138:; ;< = 88<< **, "1 ! 1  " 88   HHMMO r1c|jjdtdtjvrHt tjj d|_|jdz|_d|_ tj|_ |jj_|jj}|jdk7r|dz }t||_ |jj|j|jj!||j#|j$sd}t'j(}|r3d|_t+t&j,t&j,|z}n[|jrOg}tjj/dj1d D]}|j3t |t5j6|j|j||_d j9|j$Dcgc] }t;|c}}|jj=d |jjd ||j|jjd |jj>t'j@d |jtC|jDdr0|jDjG|j|j|jjI|ycc}w)zS Initialize the arbiter. Start listening and set pidfile if needed. zStarting gunicorn %sr=z.2zMaster.2NrT GUNICORN_FD,zArbiter bootedzListening at: %s (%s)zUsing worker: %sz&READY=1 STATUS=Gunicorn arbiter booted check_config)%r!infor rrintgetr&rQr'getpidpidr7r#rcreate on_starting init_signals LISTENERSr listen_fdsrangeSD_LISTEN_FDS_STARTpopsplitappendrcreate_socketsrSstrrRworker_class_str sd_notifyhasattrrLr_ when_ready)r.pidnamefdsrifdlnr listeners_strs rstartz Arbiter.startwsD  ,k: RZZ '!"**.."@ADO!^^d2DN)D 99; 88   'hh&&G!#4"7+DL LL   ) T" ~~C ++-J# G77#77*DF**..7==cB(BJJs2w'("00488SIDNdnn!Es#c(!EF  '(  -}dhhG  ($((*C*CDCTXXN 4$$n 5    * *488TXX > D!"Fs/L<c|jD]}tj|tjx|_}|D],}t j |t j |.|jj |jD]"}tj||j$tjtj|jy)z Initialize master signal handling. Most of the signals are queued. Child signals only wake up the master. N) PIPErclosepiperset_non_blocking close_on_execr!SIGNALSrSIGCHLD handle_chld)r.ppairss rrgzArbiter.init_signalss  A HHQK 779$ D "A  ! !! $   q ! "   *A MM!T[[ ) * fnnd&6&67r1ct|jdkr,|jj||jyy)N)len SIG_QUEUErnwakeupr.sigframes rrzArbiter.signals3 t~~  " NN ! !# & KKM #r1ch|jtjd|jz |j  |j |j r|j jdnd}|1|j|j|j m||jvr|jjd||jj|}t|d|zd}|s|jjd||jjd|||j!#t"t$f$r|j'Yyt($r1}|j'|j*|j, Yd}~yd}~wt.$rt0$rl|jjd d |j3d |j4|j4j7t9j:d YywxYw)zMain master loop. master [%s]TrNzIgnoring unknown signal: %sz handle_%szUnhandled signal: %szHandling signal: %s)reason exit_statusz Unhandled exception in main loopexc_infoF)rzr _setproctitlerQmanage_workersmaybe_promote_masterrrlsleepmurder_workers SIG_NAMESr!r`rbrerrorr StopIterationKeyboardInterrupthaltrrr SystemExit Exceptionstopr#unlinkr)exit)r.rsignamehandlerinsts rrunz Arbiter.runs  =4>>9:%     !))+/3~~dnn((+4;JJL'')'')dnn,HHMM"?E..,,S1!$ g(=tDHHNN#97C 3W=  +,01  IIK H IIT[[d6F6FI G G    HHNN=$(  * IIe ||' ##% HHRL  s%D'EH1<H1'F00A>H10H1cD|j|jy)zSIGCHLD handlingN) reap_workersrrs rrzArbiter.handle_chlds  r1cp|jjd|j|jy)z HUP handling. - Reload configuration - Start the new worker processes with a new configuration - Gracefully shutdown the old worker processes z Hang up: %sN)r!r`r'reloadr4s r handle_hupzArbiter.handle_hups%  mT%5%56 r1ct)zSIGTERM handling)rr4s r handle_termzArbiter.handle_termsr1c0|jdt)zSIGINT handlingFrrr4s r handle_intzArbiter.handle_int %r1c0|jdt)zSIGQUIT handlingFrr4s r handle_quitzArbiter.handle_quitrr1cN|xjdz c_|jy)zR SIGTTIN handling. Increases the number of workers by one. rDNrOrr4s r handle_ttinzArbiter.handle_ttin s! A r1cn|jdkry|xjdzc_|jy)zR SIGTTOU handling. Decreases the number of workers by one. rDNrr4s r handle_ttouzArbiter.handle_ttous2   q  A r1cv|jj|jtjy)zU SIGUSR1 handling. Kill all workers by sending them a SIGUSR1 N)r!rK kill_workersrSIGUSR1r4s r handle_usr1zArbiter.handle_usr1s&  &..)r1c$|jy)z SIGUSR2 handling. Creates a new arbiter/worker set as a fork of the current arbiter without affecting old workers. Use this to do live deployment with the ability to backout a change. N)reexecr4s r handle_usr2zArbiter.handle_usr2&s  r1c|jjrB|jjdd|_|j t jy|jjdy)zSIGWINCH handlingzgraceful stop of workersrz SIGWINCH ignored. Not daemonizedN) r7daemonr!r`rOrrSIGTERMrRr4s r handle_winchzArbiter.handle_winch/sI 88?? HHMM4 5 D    fnn - HHNN= >r1c|jdk(ry|jtjk7r|jj dd|_d|_|j j|_tjd=|j/|jj|j jtjd|jzyy)NrzMaster has been promoted.rr=r) r&rgetppidr!r`r'r7rQrr#renamerrr4s rrzArbiter.maybe_promote_master8s ??a   ??bjjl * HHMM5 6'D DO!XX//DN >*||' ##DHH$4$45   }t~~= > +r1c tj|jddy#t$r7}|jtj tj fvrYd}~yd}~wwxYw)z; Wake up the arbiter by writing to the PIPE rD.N)rwriter|OSErrorerrnoEAGAINEINTR)r.es rrzArbiter.wakeupIsN  HHTYYq\4 ( wwu||U[[99: s#& A&-A!!A&Ncn|j|dk(r|jjn|jj}|d|j| |d||j |j j |jj|tj|y)z halt arbiter rzShutting down: %sNz Reason: %s) rr!r`rr'r#rr7on_exitr)r)r.rrlog_funcs rrz Arbiter.haltSs $/1$4488==$((..$d&6&67   \6 * << # LL   !  r1c tj|jdgggd}|dsytj|jddr& tj|jddr%yy#t$rG}t |d|j d}|tjtjfvrYd}~yd}~wt$rtjYywxYw)zm Sleep until PIPE is readable or we timeout. A readable PIPE means a signal occurred. rg?NrDr) selectr|rreadrrrrrrrr)r)r.readyr error_numbers rrz Arbiter.sleepas MM499Q<."b#>E8''$))A,*''$))A,* "1gqvvay9LELL%++#>>?   HHJ s#+A8AA88 C&=C C&%C&c|j|jcxk(xrdk(ncxr&|j xr|jj }t j |j|g|_tj}|stj}tj|jjz}|j||jrPtj|kr9tjd|jrtj|kr9|jtj y)z Stop workers :attr graceful: boolean, If True (the default) workers will be killed gracefully (ie. trying to wait for the current connection) r皙?N)r%r&rr7 reuse_portr close_socketsrhrrSIGQUITtimegraceful_timeoutrWORKERSrSIGKILL)r.gracefulrrlimits rrz Arbiter.stopts OOt 3! 3 (LL  (HH'''  4>>62nn..C dhh777 #lltyy{U2 JJsOlltyy{U2 &..)r1cP|jdk7r|jjdy|jdk7r|jjdyt j }t j |_|jdk7ry|jj||jjj}t||d<|jrBtt j |d<tt|j|d<n%djd |jD|d <t j |j"d t j$|j"d|j"d |y) z1 Relaunch the master and workers. rz"USR2 signal ignored. Child exists.Nz#USR2 signal ignored. Parent exists.r= LISTEN_PID LISTEN_FDSr^c3NK|]}t|jywr3)rpfileno)rrxs rrz!Arbiter.reexec..s .=&)CJJL!.=s#%r]rr)r%r!warningr&rrcforkr7pre_execenv_origcopyrprrrhrSchdirr-execvpe)r.r&rs rrzArbiter.reexecs: ??a  HH  A B  ??a  HH  B C YY[ '') ??a   $((##((*"%j/ <<$' $4GL !$'DNN(;$>!$dnnV&>9:txx''( A      Q "&Js4JJ$ J! J!c|jsyt|jj}|D]\}} t j |j jz |jkrD |jsD|jjd|d|_ |j|tj|j|tj y#ttf$rYwxYw)z) Kill unused/idle workers NzWORKER TIMEOUT (pid:%s)T)rPlistrrVr monotonictmp last_updater ValueErrorabortedr!critical kill_workerrSIGABRTr)r.rNrdworkers rrzArbiter.murder_workerss|| t||))+,$ 6MS& >>#fjj&<&<&>>$,,NO >>!!";SA!%  fnn5  fnn5 6Z(  s *@'0'7'7'?H@ ww%,,&' sB*F?B5F?#FBF?F<9F?;F<<F?? G0G++G0c&t|j|jkr|j|jj }t |d}t||jkDrM|j d\}}|j|tjt||jkDrMt|}|j|k7r8||_ |jjdj|d|ddy y ) z[ Maintain the number of workers by spawning or killing as required. c |djSrC)age)ws rrGz(Arbiter.manage_workers..=s!r1rHrz {0} workerszgunicorn.workersgauge)metricr9mtype)extraN)rrrO spawn_workersrVrTrlrrrr r!rRr@)r.rNrdractive_worker_counts rrzArbiter.manage_workers4s t|| t// /    ,,$$&&89'lT---{{1~HS!   S&.. 1'lT---"'l  0 04G G4GD 1 HHNN=//0CD,>+>+2"4  5 Hr1c |xjdz c_|j|j|j|j|j|j dz |j |j}|j j||tj}|dk7r||_||j|<|S|jjD]}|jjtj|_ t!j"d|j$z|jj'd|j|j j)|||j+t-j.d|jj'd |j |jj|j jG||y#t0$rt2$r}|jj5ddt7d |zt,j8 t,j8j;t-j.|j<Yd}~d}~wt>$r_|jjAd |jBst-j.|jDt-j.d YWwxYw#t>$r1|jjIdtKjLYywxYw#|jj'd |j |jj|j jG||w#t>$r1|jjIdtKjLYwwxYwxYw)NrDg@rz worker [%s]zBooting worker with pid: %sz'Exception while loading the applicationTrz%s)filezException in worker processrzWorker exiting (pid: %s)z Exception during worker exit: %s)'r$rLrdrhr/rPr7r!pre_forkrrrvaluesrr}rcrrrQr` post_fork init_processr)rrrrRprintstderrflushrr exceptionbootedr worker_exitr traceback format_exc)r.rrdsiblingrs rrzArbiter.spawn_workerJs 1""4??DHHdnn#'88T\\C-?#'88TXX7 $'ggi !8FJ &DLL J||**, G KK    YY[  9   }t~~= > HHMM7 D HH  tV ,    ! HHQK HHMM4fjj A 9   "$$T62#   * HHNND$(  * $( , JJ    HHT(( ) )  HH  < ===//0 HHRL   9  !D!*!5!5!79 9 HHMM4fjj A 9   "$$T62 9  !D!*!5!5!79 9soB G=6K:=K7A8J L7 A'K73L76K77L7:7L43L47'O6NO7O OOOct|jt|jz D]<}|j t j dtjz>y)z Spawn new workers as needed. This is where a worker process leaves the main loop of the master process. rN)rjrOrrrrrrandom)r.rs rrzArbiter.spawn_workersxsOt''#dll*;;< .A     JJsV]]_, - .r1c|t|jj}|D]}|j||y)z^ Kill all workers with the signal `sig` :attr sig: `signal.SIG*` value N)rrkeysr)r.r worker_pidsrds rrzArbiter.kill_workerss: 4<<,,./  'C   S# & 'r1cp tj||y#t$r}|jtjk(rp |j j |}|jj|jj||Yd}~y#ttf$rYYd}~ywxYwd}~wwxYw)zj Kill a worker :attr pid: int, worker pid :attr sig: `signal.SIG*` value N) rkillrrESRCHrrlrr}r7r#r)r.rdrrrs rrzArbiter.kill_workers  GGC  ww%++%!\\--c2FJJ$$&HH((v6 '*  s3 B5B0ABB,%B0+B,,B00B5)Nr)T)3__name__ __module__ __qualname____doc__rrr-rhrr|rrmrrrdictdirrr0r5r;propertyrOr"rzrgrrrrrrrrrrrrrrrrrrrrrrrrr)rxrrs0000rr r s?NIIG DIEKKMOOvw{+OG>A&kI  8!:+-=>K@/"b8, *X   *??" &*6 GD5n6*5n5,,9\ .'EOsC r )rrr(rrr)rr$gunicorn.errorsrrgunicorn.pidfilergunicornrrrr r r rEr1rr:s: 6$((1K K r1