sVc@sddlmZddlZddlZddlZddlZddlZddlZddlZddl Z ddl m Z m Z ddl mZddlmZddlmZddlmZmZdefd YZdS( i(tprint_functionN(t HaltServertAppImportError(tPidfile(tcreate_sockets(tutil(t __version__tSERVER_SOFTWAREtArbitercBseZdZdZdZiZgZiZgZgZ gdj D]Z e e de ^qCZedee DZdZdZdZeeeZd Zd Zd Zd Z d ZdZdZdZdZdZdZ dZ!dZ"dZ#dZ$dZ%d&ddZ'dZ(e)dZ*dZ+dZ,dZ-d Z.d!Z/d"Z0d#Z1d$Z2d%Z3RS('s Arbiter maintain the workers processes alive. It launches or kills them if needed. It also manages application reloading via SIGHUP/USR2. iis+HUP QUIT INT TERM TTIN TTOU USR1 USR2 WINCHsSIG%sccsN|]D}|d dkr|ddkrtt||djfVqdS(itSIGt_N(tgetattrtsignaltlower(t.0tname((s`/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/arbiter.pys 2scCsttjdlstkeycSs|dS(Ni((tsetting((s`/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/arbiter.pytos(R%R(RRt logger_classRRt reopen_filest worker_classtaddresstworkerst num_workersttimeoutt proc_nametdebugR.tjointsortedtsettingstitemstenvt preload_apptwsgi(R$R%tktv((s`/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/arbiter.pyRYs*    cCsL|jjdttj|_|jjdk r_t |jj|_|jj |jn|jj ||j |j st|j|j|_ ndjg|j D]}t|^q}|jjd|jjd||j|jjd|jjt|jdr8|jj|j|jn|jj|dS(sS Initialize the arbiter. Start listening and set pidfile if needed. sStarting gunicorn %st,sArbiter bootedsListening at: %s (%s)sUsing worker: %st check_configN(RtinfoRRtgetpidtpidR(RRRtcreatet on_startingt init_signalst LISTENERSRR<tstrR;tworker_class_strthasattrR5RFt when_ready(R$tlt listeners_str((s`/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/arbiter.pytstartys   +cCs|jr/g|jD]}tj|^qntj|_}x(|D] }tj|tj|qIW|jjg|jD]}t j ||j ^qt j t j |j dS(s Initialize master signal handling. Most of the signals are queued. Child signals only wake up the master. N( tPIPERtclosetpipeRtset_non_blockingt close_on_execRtSIGNALSR tSIGCHLDt handle_chld(R$tptpairts((s`/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/arbiter.pyRLs &   )cCs6t|jdkr2|jj||jndS(Ni(tlent SIG_QUEUEtappendtwakeup(R$tsigtframe((s`/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/arbiter.pyR scCs|jtjd|jy|jxtr!t|jrU|jjdnd }|d kr|j |j |jq.n||j kr|j jd|q.n|j j|}t|d|d }|s|j jd|q.n|j jd|||jq.WWntk r@|jntk rZ|jntk r}|jd|jd|jnvtk rnctk r|j jd tj|jt|jd k r|jj nt!j"d nXd S( sMain master loop.s master [%s]isIgnoring unknown signal: %ss handle_%ssUnhandled signal: %ssHandling signal: %streasont exit_statuss$Unhandled exception in main loop: %siN(#RTRt _setproctitleR:tmanage_workerstTrueR`RatpopRtsleeptmurder_workerst SIG_NAMESRRGtgetR terrorRct StopIterationthalttKeyboardInterruptRRfRgt SystemExitt Exceptiont tracebackt format_exctstoptFalseRtunlinkRtexit(R$Rdtsignamethandlertinst((s`/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/arbiter.pytrunsJ   '             cCs|j|jdS(sSIGCHLD handlingN(t reap_workersRc(R$RdRe((s`/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/arbiter.pyR\s cCs$|jjd|j|jdS(s HUP handling. - Reload configuration - Start the new worker processes with a new configuration - Gracefully shutdown the old worker processes s Hang up: %sN(RRGRtreload(R$((s`/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/arbiter.pyt handle_hupscCs tdS(sSIGTERM handlingN(Rq(R$((s`/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/arbiter.pyt handle_termscCs|jttdS(sSIGINT handlingN(RxRyRq(R$((s`/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/arbiter.pyt handle_ints cCs|jttdS(sSIGQUIT handlingN(RxRyRq(R$((s`/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/arbiter.pyt handle_quits cCs|jd7_|jdS(sR SIGTTIN handling. Increases the number of workers by one. iN(R8Ri(R$((s`/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/arbiter.pyt handle_ttinscCs0|jdkrdS|jd8_|jdS(sR SIGTTOU handling. Decreases the number of workers by one. iN(R8Ri(R$((s`/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/arbiter.pyt handle_ttouscCs!|jj|jtjdS(sU SIGUSR1 handling. Kill all workers by sending them a SIGUSR1 N(RR4t kill_workersR tSIGUSR1(R$((s`/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/arbiter.pyt handle_usr1s cCs|jdS(s SIGUSR2 handling. Creates a new master/worker set as a slave of the current master without affecting old workers. Use this to do live deployment with the ability to backout a change. N(treexec(R$((s`/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/arbiter.pyt handle_usr2scCsL|jjr8|jjdd|_|jtjn|jjddS(sSIGWINCH handlingsgraceful stop of workersis SIGWINCH ignored. Not daemonizedN( R(tdaemonRRGR8RR tSIGTERMR;(R$((s`/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/arbiter.pyt handle_winchs   cCsVytj|jddWn4tk rQ}|jtjtjgkrRqRnXdS(s; Wake up the arbiter by writing to the PIPE it.N(RtwriteRUtIOErrorterrnotEAGAINtEINTR(R$te((s`/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/arbiter.pyRc"s icCs|j|jjd|j|dk rB|jjd|n|jdk ra|jjn|jj|t j |dS(s halt arbiter sShutting down: %ss Reason: %sN( RxRRGRRRRzR(ton_exitRR{(R$RfRg((s`/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/arbiter.pyRr,s  cCsyTtj|jdgggd}|ds3dSxtj|jddrRq6WWntjk r}|jdtjtjgkrqnNt k r}|jtjtjgkrqnt k rt j nXdS(sm Sleep until PIPE is readable or we timeout. A readable PIPE means a signal occurred. ig?Ni( tselectRURtreadRpRRRRtOSErrorRsRR{(R$treadyR((s`/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/arbiter.pyRl7s"    cCsg|_tj}|s$tj}ntj|jj}|j|x,|jrutj|krutj dqJW|jtj dS(s Stop workers :attr graceful: boolean, If True (the default) workers will be killed gracefully (ie. trying to wait for the current connection) g?N( RMR RtSIGQUITttimeR(tgraceful_timeoutRtWORKERSRltSIGKILL(R$tgracefulRdtlimit((s`/opt/seafile/seafile-server-5.1.3/seahub/thirdpart/gunicorn-19.4.5-py2.7.egg/gunicorn/arbiter.pyRxKs    cCs|jdk r,|jjd|jjntj|_|jdkrWd|_dS|jj j }g|j D]}|j ^qs}dj g|D]}t|^q|ds