1cddlZddlZddlZddlZddlZddlZddlZddlmZddlm Z ddlm Z ddlm Z ddl m ZddlmZddlmZdd lmZdd lmZdd lmZdd lmZdd lmZmZddlmZddlmZddlmZddlm Z ejBGdde"Z#Gdde#Z$ejBGdde"Z%Gdde%Z&Gdde&Z'Gdde%Z(Gdde"Z)e)Z)d Z*y)!N)maxint)as_bytes) as_string)PY2) asyncore_25) ProcessStates)SupervisorStates)getProcessStateDescription)STOPPED_STATES)decode_wait_status)signame)ProcessException BadCommand)EventListenerStates)events)RestartUnconditionally) SocketManagercZeZdZdZdZdZdZdZdZdZ dZ dZ dZ dZ dZdZdZdZdZdZdZdZdZdZdZdZd Zd Zej:ej>ej@ejBejDejFejHejJejLejNejPejRejTejVejXejZiZ.dd Z/d Z0d Z1dZ2dZ3dZ4dZ5dZ6dZ7dZ8dZ9dZ:dZ;dZdZ?dZ@dZAdZBy) SubprocesszA class to manage a subprocess.rNFcX||_i|_i|_tj|_y)zDConstructor. Argument is a ProcessConfig instance. N)config dispatcherspipesrSTOPPEDstateselfrs 4/usr/lib/python3/dist-packages/supervisor/process.py__init__zSubprocess.__init__;s'   "** c||jjD]}t|ds|j!y)N removelogs)rvalueshasattrr"r dispatchers rr"zSubprocess.removelogsE6**113 (Jz<0%%' (r c||jjD]}t|ds|j!y)N reopenlogs)rr#r$r)r%s rr)zSubprocess.reopenlogsJr'r c|jjD]C}|jr|j|j s4|j EyN)rr#readablehandle_read_eventwritablehandle_write_eventr%s rdrainzSubprocess.drainOsR**113 0J ""$,,.""$--/ 0r cr|jr |jrttjd|j d}|ttjd|j |}|jrttjd|xj|z c_|jy)NzProcess already closedstdinzProcess has no stdin channelz Process' stdin channel is closed) pidkillingOSErrorerrnoEPIPErrclosed input_bufferflush)rcharsstdin_fdr&s rwritezSubprocess.writeZsxx4<<%++'?@ @::g&  %++'EF F%%h/   %++'IJ J5(r c  tj|jj}|r|d}n t dd|vr)|} |jjj|}ns|jj}d}d}|D]I}tjj||} |jjj|}n||}n|}|jjj|||||fS#t$r3}t d|jjdt |d}~wwxYw#t$rd}YwwxYw#t$rYwxYw)zInternal: turn a program name into a file name, using $PATH, make sure it exists / is executable, raising a ProcessException if not zcan't parse command : Nrzcommand is empty/)shlexsplitrcommand ValueErrorrstroptionsstatr5get_pathospathjoincheck_execv_args) r commandargseprogramfilenamestrJfounddirs rget_execv_argszSubprocess.get_execv_argsisc /++dkk&9&9:K !!nG/0 0 '>H [[((--h7 ;;'')DEB  S'2,,11%8B z"  ,,X{BG$$M /$$c!f./ / /  s;)D %E/%E E.EE EE E%$E%cN|j}||ury||_|tjk(r=tj}|xjdz c_||jz|_|j j|}| ||||}tj|yy)NF) rrBACKOFFtimebackoffdelay event_mapgetrnotify)r new_stateexpected old_statenow event_classevents r change_statezSubprocess.change_statesJJ  !  -- -))+C LLA Lt||+DJnn((3  "i:E MM%  #r c|j|vrgt|j}djtt|}t |j j }td|d|d|y)N zAssertion failed for r?z not in )rr rKmaprrnameAssertionError)rstates current_stateallowable_states processnames r_assertInStatezSubprocess._assertInStatesf ::V #6tzzBM"xx,F(OP #DKK$4$45K ],<">? ? $r cv||_|jjjj d|zy)Nz spawnerr: %s)spawnerrrrFloggerinformsgs rrecord_spawnerrzSubprocess.record_spawnerrs,  ""''(<=r c(|jj}t|jj}|jr!d|z}|j j |yd|_d|_d|_ d|_ d|_ tj|_ |jtj tj"tj$tj&|j)tj* |j-\}} |jj5|\|_|_ |jG} | dk7r|jO| S|jQ||S#t.$rf}|j1|j2d|jtj*|j)tj$Yd}~yd}~wwxYw#t:t<f$r}|j2d}|t>j@k(rd|z}n&d|dt>jBjE||}|j1||jtj*|j)tj$Yd}~yd}~wwxYw#t:$r}|j2d}|t>jHk(rd|z}n&d |dt>jBjE||}|j1||jtj*|j)tj$|jK|j8|jM|j8Yd}~yd}~wwxYw) zStart the subprocess. It must not be running already. Return the process id. If the fork() call fails, return None. zprocess '%s' already runningNFrz!too many open files to spawn '%s'z&unknown error making dispatchers for 'z': z1Too many processes in process table to spawn '%s'zunknown error during fork for '))rrFrrhr3rqwarnr4rp exitstatus system_stopadministrative_stoprX laststartrnrEXITEDFATALrWrrdSTARTINGrTrruargsmake_dispatchersrrr5IOErrorr6EMFILE errorcoder\forkEAGAINclose_parent_pipesclose_child_pipes_spawn_as_parent_spawn_as_child) rrFrmrtrPargvwhatwhycoder3s rspawnzSubprocess.spawns ++%% 0 01 882[@C NN   $    #(  M00-2E2E)11=3H3H J -001 !002NHd +/;;+G+G+M (D dj ,,.C" !8((- -''$7 7W    1 .    6 6 7   m33 4   ! 88A;Du||#;kI$ "5??#6#6tT#BD   %    6 6 7   m33 4   88A;Du||#M#$$ "5??#6#6tT#BD   %    6 6 7   m33 4  & &tzz 2  % %djj 1  sK F(G2J+ G/ AG**G/2J(BJ##J(+ N4CN  Nc~||_|jj}|j|j|j j dt|jjd|d|_ tj|jjz|_ ||j|<|S)Nz spawned: 'z ' with pid )r3rrFrrrqrrrrhrprX startsecsrZ pidhistory)rr3rFs rrzSubprocess._spawn_as_parents++%%!!$**-Yt{{GWGW=XZ]^_ YY[4;;#8#88 "&3 r c|jj}|j|jdd|j|jdd|jjr |j|jddn|j|jddt d|j D]}|j|y)N child_stdinr child_stdoutrV child_stderr)rrFdup2rredirect_stderrrangeminfdsclose_fd)rrFis r_prepare_child_fdszSubprocess._prepare_child_fdss++%% TZZ .2 TZZ/3 ;; & & LLN3Q 7 LLN3Q 7q'..) A   Q  r c6|jj} |j|j|j }|rY|jj }d|d|d}|j dd|z |j dd|jdytjj}d|d <|jj}| |jjj}|r||d <|jj|d <|jr#|jjj|d <|jj%|j|jj|jj } | |j#|  |jj.%|j1|jj.|j3||||j dd|jdy#t$$r} t&j(j+| j,d | j,d } d| d| d}|j dd|zYd} ~ |j dd|jdyd} ~ wwxYw#t$$rf} t&j(j+| j,d | j,d } d|d d| d}|j dd|zYd} ~ d} ~ wt5j6\\} } }}}}|d|d| d|}d|d|d}|j dd|zYoxYw#|j dd|jdwxYw)Nzcouldn't setuid to r? rz supervisor: z*supervisor: child process was not spawned 1SUPERVISOR_ENABLEDSUPERVISOR_SERVER_URLSUPERVISOR_PROCESS_NAMESUPERVISOR_GROUP_NAMErzcouldn't chdir to zcouldn't exec z, z: file: z line: )rrFsetpgrprset_uiduidr=_exitrIenvironcopy serverurlrhgroup environmentupdate directorychdirr5r6rr\rumasksetumaskexecveasyncorecompact_traceback)rrPrrF setuid_msgrrtenvrcwdrrfilefunlinetvtbinfoerrors rrzSubprocess._spawn_as_childs++%%C  OO   # # %Jkkoo7:JG a#!56\ MM!J K MM# Y**//#C(+C$ % --I  KK//99 /8+,-1[[-=-=C) *zz/3zz/@/@/E/E+,{{&&2 4;;223++''C ?MM#& 7;;$$0$$T[[%6%67xs3 MM!J K MM# 5 **388A; D694@ a#!56* MM!J K MM# 5  7**388A; D26q'4@ a#!566 7080J0J0L-!sD1Qv78!T4H2:EB a#!56 MM!J K MM# s_A&M3#C;M3H%3AJ6% J3.AJ.M3.J33M36 M0?AL M3 A M0-M33%Nc|jtjk(rl||jkr||_|jdkDrF||j|j j z kr||j j z|_yyy|jtjk(rV||jkDrF||j|j j zkr||j j z |_yyy|jtjk(rl||jkr||_ |jdkDrF||j|j jz kr||j jz|_yyy|jtjk(rB|jdkDr2||j|jz kr||jz|_yyyy)z Check if system clock has rolled backward beyond test_time. If so, set affected timestamps to test_time. rN) rrr~r{rZrrRUNNINGSTOPPINGlaststopreport stopwaitsecsrWrY)r test_times r+_check_and_adjust_for_system_clock_rollbackz6Subprocess._check_and_adjust_for_system_clock_rollbackes| ::// /4>>)!*zzA~)tzzDKK)>> #S~ ZZ=00 04>>)i4>>DKKLaLa;a.b!*T[[-B-B!B/c) ZZ=11 14...&/#zzA~)tzzDKKd |d |jdt7| }|jj|Yd} ~ yd} ~ wwxYw#t9j:} d|d|jd| }|jj=||jt j>d|_d|_|cYSxYw)aSend a signal to the subprocess with the intention to kill it (to make it exit). This may or may not actually kill it. Return None if the signal was sent, or an error message string if an error occurred or if the subprocess is not running. z0Attempted to kill %s, which is in BACKOFF state.Nzattempted to kill z with sig  but it wasn't runningzprocess group zkilling  (pid z) z with signal Tunable to signal z'), it probably just exited on its own: zunknown problem killing  ():Fr) rXrrFrrhrrrWrqdebugrdrr3r r killasgroup stopasgroupr4rrZrnrr~rr5r6ESRCHrE traceback format_exccriticalUNKNOWN) rsigrarFrmrtras_groupr3exctbs rrzSubprocess.kills[iik++%% 0 01 ::.. .EC NN  %   m33 4xx/C NN  %J ::// /++11K++11K 'H + $ ( ' .  4;;333  M11)22)22 4 -001hh 88)C   S#&(' 99 +/:DHHc#hPCNN((-   %%'B:E:>((BHC NN # #C (   m33 4 DLDJJs2 H J&AJ<J JJJ A5Lc |jj}t|jj}|js/d|dt |d}|j j||S|j jd|d|jdt ||jtjtjtj |j|j|y #t$ra}|jtj k(r>d|d|jdt#|}|j j|Yd }~y d }~wwxYw#t%j&}d |d |jd |}|j j)||j+tj,|cYSxYw) zSend a signal to the subprocess, without intending to kill it. Return None if the signal was sent, or an error message string if an error occurred or if the subprocess is not running. zattempted to send z sig rzsending rz) sig rz+), it probably just now exited on its own: Nzunknown problem sending sig rr)rrFrrhr3r rqrrnrrr~rrr5r6rrErrrrdr)rrrFrmrtrrs rsignalzSubprocess.signalsn ++%% 0 01 xx/C NN  %J + $ ' .  M11)22)22 4   TXXs+&% 99 +/:DHHs8%CNN((-   %%'B +TXXr;C NN # #C (   m33 4Js2'D E. AE)#E1(E))E..E11A'Gc$|jt|\}}tj}|j|||_t |j j}||jkDr'||jz |j jk}nBd}|j jjjd|d|jd||j jv}|jrd|_d|_||_d|d|d}|j%t&j(|j+t&j,|r1|j jjj/|n|j jjj|n|rd |_d |_d |d|d zd}|j%t&j2|j+t&j4|j jjj|n5d|_d|_||_|j8t&j2k(r|j+t&j:|j%t&j:|r]d |d|d zd}|j+t&j<d|j jjj/|nfd|z|_d |d|d zd}|j+t&j<d|j jjj|d|_ |j jj?|j@i|_ i|_!|jD;tGjHtGjJ||jDd |_"y y )zK The process was reaped and we need to report and manage its state Fz process '' (zr) laststart time is in the future, don't know how long process was running so assuming it did not exit too quicklyrz stopped: r)Nz1Exited too quickly (process log may have details)zexited: z; not expectedz ; expectedT)r_zBad exit code %s)&r0r rXrlaststoprrrhr{rrFrqrwr3 exitcodesr4rZrxrnrrrdrrrrpr~rWrYrrr|rrrrcrr]EventRejectedEvent) rr3stsesrtrarm too_quickly exit_expecteds rfinishzSubprocess.finishs $S)Ciik 88=  0 01  .1F1FFKK KK   & & + ++6txxA B dkk333 <<!DLDJ DO(3S9C    6 6 7   m33 4 ##**//4 ##**//4#DOODM'2C:J4JKC    6 6 7   m33 4 KK   & & + +C 0 DJDL DO zz]333!!-"7"78    5 5 6+6l8JK!!-"6"6!F ##**//4!3R 7 +6>N8NO!!-"6"6!G ##**//4 ..tzz:  :: ! MM&33D$**E FDJ "r c|jjy|jjj|jj}|Sr+)rrrFdrop_privilegesrss rrzSubprocess.set_uidus: ;;?? " kk!!11$++//B r c\|jj|jjkSr+rpriorityrothers r__lt__zSubprocess.__lt__{!{{##ell&;&;;;r c\|jj|jjk(Sr+rrs r__eq__zSubprocess.__eq__~s!{{##u||'<'<<)rrhrrencodeidr get_staterrhs r__repr__zSubprocess.__repr__sO{{ T?))*:;D tH  &t~~'7 8: :r c|jSr+)rrs rrzSubprocess.get_states zzr ctj}|j}|j||jjj }|jjj tjkDr$|tjk(rv|jjr|jjtur|jn|j|jjvr|jn|tj k(r3|j"s'|jj$rf|jnU|tj&k(rB|j(|jj*kr||j,kDr|jt/|jj0}|tj2k(r||j"z |jj4kDr|d|_d|_|j7tj2|j9tj:d|jj4z}|j=d|d||tj&k(rN|j(|jj*kDr*|j?d}|j=d|d|yy|tj@k(ru|j,|z }|dkr`|jjj jCd|d|jDd |jGtHjJyyy) NrzNentered RUNNING state, process has stayed up for > than %s seconds (startsecs)z success: rfz7entered FATAL state, too many start retries too quicklyz gave up: z killing 'rz) with SIGKILL)&rXrrrrFrqmoodr RESTARTINGrr| autorestartrrrxrrr{ autostartrWrY startretriesrZrrhr~rrnrdrrrrrrwr3rrSIGKILL)rrarrqrmrt time_lefts r transitionzSubprocess.transitionstiik  88=$$++ ;;   # #&6&A&A A ,,,;;**{{..2HH ??$++2G2GG JJL-///;;((JJL-///<<4;;#;#;;TZZ'  0 01 M** *T^^#dkk&;&;;   ##M$:$:;!!-"7"7846:kk6K6KL SAB M)) )||dkk666 ! SAB 7m,, , S(IA~ ##**//:E:>((DE &..)-r )T)C__name__ __module__ __qualname____doc__r3rrlistener_statercr{rrrZrzryr4rYrrrxrprrr"r)r0r=rTrrWrProcessStateBackoffEventr}ProcessStateFatalEventrProcessStateUnknownEventrProcessStateStoppedEventr|ProcessStateExitedEventrProcessStateRunningEventr~ProcessStateStartingEventrProcessStateStoppingEventr[rdrnrurrrrrrrrrrrrrrrrrr rrr!s* C F EN EIHN EKGGK EJH E+( ( 0 ,%^ v>>v<<v>>v>>v==v>> @ @ @ @  I!"?>G8R   EN6,1 */Sj-^[z <= :>*r rc4eZdZdZdZdZdZdZdZdZ y) FastCGISubprocessz7Extends Subprocess class to handle FastCGI subprocessesc>tj||d|_yr+)rr fcgi_sockrs rrzFastCGISubprocess.__init__sD&)r c |j tdt|jds.td|jdt|j|jjj |_y)zU The FastCGI socket needs to be created by the parent before we fork Nz"No group set for FastCGISubprocesssocket_managerzNo SocketManager set for :)rNotImplementedErrorr$rSr" get_socketr rs r before_spawnzFastCGISubprocess.before_spawnsi :: %&JK Ktzz#34%15S_'NO O22==?r cb|jtj|}|d|_|S)zR Overrides Subprocess.spawn() so we can hook in before it happens N)r&rrr )rr3s rrzFastCGISubprocess.spawns1 t$ ;!DN r cd|_y)zM Releases reference to FastCGI socket when process is reaped N)r rs r after_finishzFastCGISubprocess.after_finishs r cTtj|||}|j|S)zR Overrides Subprocess.finish() so we can hook in after it happens )rrr))rr3rretvals rrzFastCGISubprocess.finishs)""4c2  r c|jj}|jj}|j |d|j |j dd|jj r |j |j ddn|j |j ddtd|jD]}|j|y)z Overrides Subprocess._prepare_child_fds() The FastCGI socket needs to be set to file descriptor 0 in the child rrrVrrrN) r filenorrFrrrrrr)rsock_fdrFrs rrz$FastCGISubprocess._prepare_child_fdss ..'')++%% Wa  TZZ/3 ;; & & LLN3Q 7 LLN3Q 7q'..) A   Q  r N) rrrrrr&rr)rrrr rrrs$A @  r rcHeZdZdZdZdZdZdZdZdZ dZ d Z d Z y ) ProcessGroupBasec||_i|_|jjD]*}|j||j|j<,yr+)r processesprocess_configs make_processrh)rrpconfigs rrzProcessGroupBase.__init__sH {{22 FG+2+?+?+EDNN7<< ( Fr c\|jj|jjkSr+rrs rrzProcessGroupBase.__lt__rr c\|jj|jjk(Sr+rrs rrzProcessGroupBase.__eq__s!{{##u||'<'<<r ct|jj}|j|j |D]~}|j }|t jk(r|j7|t jk(r|j[|t jk(so|jyr+) listr2r#sortreverserrrrr~rWr)rr2procrs rstop_allzProcessGroupBase.stop_all-s..01  DNN$E --- -000 -///  r c|jjDcgc]}|jtvs|c}Scc}w)z@ Processes which aren't in a state that is considered 'stopped' )r2r#rr )rxs rget_unstopped_processesz(ProcessGroupBase.get_unstopped_processes>s; NN113"qq{{}8 " ""s AAc~i}|jjD]}|j|j|Sr+)r2r#rr)rrr=s rget_dispatchersz ProcessGroupBase.get_dispatchersCs= ~~,,. 4G   w22 3 4r cyr+rrs r before_removezProcessGroupBase.before_removeIs r N) rrrrrrrr"r)rErHrJrLrr rr0r0 s5F<=7!!""   r r0ceZdZdZy) ProcessGroupcb|jjD]}|jyr+)r2r#r)rrDs rrzProcessGroup.transitionMs(NN))+ D OO  r N)rrrrrr rrNrNLsr rNceZdZdZy)FastCGIProcessGroupc `tj|||jdt}||j|j j |_ |jjy#t$r.}td|jjd|d}~wwxYw)N socketManager)rqz Could not create FastCGI socket r?) rNrr\r socket_configrFrqr"r% ExceptionrDr)rrkwargssockManagerKlassrNs rrzFastCGIProcessGroup.__init__SsdF+!::o}E.v/C/C6 IHMM(8"45*=)A)A& %  ##**00LL+/07 :#xx{ekk1KK''..44 k34s.AE GA!GGc tj|}t|}d|jjj ||jj ||||d}d|zS)Nz3.0)versidr^ pool_namer event_namervr|zver:%(ver)s server:%(sid)s serial:%(serial)s pool:%(pool_name)s poolserial:%(pool_serial)s eventname:%(event_name)s len:%(len)s %(payload)s)rgetEventNameByTypervrrF identifierrh)rrr^rr|r payload_lenDs rr}z EventListenerPool._eventEnvelopesi..z: 'l ++%%00 ((%# DFGH Ir c|jjD]"}tj||j$tjtj |j yr+)r pool_eventsr subscribererrgrrs rrazEventListenerPool._subscribesM++11 J   z4+<+< = >644d6J6JKr N)F) rrrrrgrrLrjrerpr}rarmrr rrZrZbs86. ),: DI"J Lr rZceZdZdZy)rucd|_y)Nr\)r^rs rrzGlobalSerial.__init__s  r NrXrr rrurusr rucx|jtk(rd|_|xjdz c_|jS)Nr\rV)r^r)insts rrtrts- {{f KK1K ;;r )+r6 functoolsrIrrArXrsupervisor.compatrrrrsupervisor.medusarrsupervisor.statesrr r r supervisor.optionsr r rrsupervisor.dispatchersr supervisorrsupervisor.datatypesrsupervisor.socket_managerrtotal_orderingobjectrrr0rNrQrZrurtrr rrs  $&'!5+.8,1&;673 l *l *l *\; ; z < v< < |# ,"NL(NLb6~ r