/usr/lib/python2.6/site-packages/supervisor
Edit: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyc (22117B)
FATc @ sL d Z d d k Z d d k Z d d k Z d d k Z d d k Z d d k Z d d k Z d d k Z d d k Z d d k
Z
d d k Z d d k Z d d k
l Z d d k
l Z d d k
l Z d f d YZ d Z d f d
YZ d Z d f d
YZ d f d YZ e d Z e d j o e n d S( s supervisord -- run a set of applications as daemons.
Usage: %s [options]
Options:
-c/--configuration URL -- configuration file or URL
-n/--nodaemon -- run in the foreground (same as 'nodaemon true' in config file)
-h/--help -- print this usage message and exit
-u/--user USER -- run supervisord as this user (or numeric uid)
-m/--umask UMASK -- use this umask for daemon subprocess (default is 022)
-d/--directory DIRECTORY -- directory to chdir to when daemonized
-l/--logfile FILENAME -- use FILENAME as logfile path
-y/--logfile_maxbytes BYTES -- use BYTES to limit the max size of logfile
-z/--logfile_backups NUM -- number of backups to keep when max bytes reached
-e/--loglevel LEVEL -- use LEVEL as log level (debug,info,warn,error,critical)
-j/--pidfile FILENAME -- write a pid file for the daemon process to FILENAME
-i/--identifier STR -- identifier used for this instance of supervisord
-q/--childlogdir DIRECTORY -- the log directory for child process logs
-k/--nocleanup -- prevent the process from performing cleanup (removal of
orphaned child log files, etc.) at startup.
-w/--http_port SOCKET -- the host/port that the HTTP server should listen on
-g/--http_username STR -- the username for HTTP auth
-r/--http_password STR -- the password for HTTP auth
-a/--minfds NUM -- the minimum number of file descriptors for start success
--minprocs NUM -- the minimum number of processes available for start success
iN( t
ServerOptions( t decode_wait_status( t signamet
ProcessStatesc B s8 e Z d Z d Z d Z d Z d Z d Z d Z d Z RS( i i
i i i( id i i (
t __name__t
__module__t STOPPEDt STARTINGt RUNNINGt BACKOFFt STOPPINGt EXITEDt FATALt UNKNOWN( ( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyR ; s c C s3 x, t i D]! } t t | | j o | Sq
Wd S( N( R t __dict__t getattr( t codet statename( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyt getProcessStateDescriptionE s
t SupervisorStatesc B s e Z d Z d Z RS( i i ( R R t ACTIVEt SHUTDOWN( ( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyR J s c C s3 x, t i D]! } t t | | j o | Sq
Wd S( N( R R R ( R R ( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyt getSupervisorStateDescriptionN s
t
Subprocessc B s e Z d Z d Z d Z d Z d Z d Z d Z d Z d Z
d Z d Z
d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d
Z d Z d Z d
Z d Z d Z d Z d Z d Z d Z! d Z" RS( s A class to manage a subprocess.i t c
C sq | | _ | | _ h | _ | i oH | i } | i } | i | i t i d d | d | d | | _ n d S( sc Constructor.
Arguments are a ServerOptions instance and a ProcessConfig instance.
s %(message)st rotatingt maxbytest backupsN(
t optionst configt pipest logfilet logfile_backupst logfile_maxbytest getLoggert loggingt INFOt childlog( t selfR R R R ( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyt __init__g s
c C s= | i o/ x, | i i D] } | i | i q Wn d S( N( R% t handlerst removet reopen( R& t handler( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyt
removelogs{ s
c C s3 | i o% x" | i i D] } | i q Wn d S( N( R% R( R* ( R& R+ ( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyt
reopenlogs s
c C su | i og | i d } | _ | i o | i i | n d | i i | f } | i i i | i i | n d S( NR s
%s output:
%s( t logbufferR% t infoR t nameR t loggert logt TRACE( R& t datat msg( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyt
log_output s
c G so | i i | i d } | d j o% | i i | i d | i d =n | i i o | i | 7_ n d S( Nt stdoutR ( R t readfdR t close_fdR t
log_stdoutR. ( R& t ignoredt output( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyt drain_stdout s
c G so | i i | i d } | d j o% | i i | i d | i d =n | i i o | i | 7_ n d S( Nt stderrR ( R R8 R R9 R t
log_stderrR. ( R& R; R< ( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyt drain_stderr s
c C sF | i i d o | i n | i i d o | i n d S( NR7 R> ( R t has_keyR= R@ ( R& ( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyt drain s c C s | i p g Sg } | i i d o! | i | i d | i g n | i i d o! | i | i d | i g n | S( NR7 R> ( R RA t appendR= R@ ( R& t drains( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyt get_pipe_drains s
!!c C s t i | i i } | d } d | j oM | } y# | i i | } | | | f SWqt j
o | | d f SXn | i i } d } d } x_ | D]W } t i
i | | } y# | i i | } | | | f SWq t j
o
q q Xq Wd | d f Sd S( sY Internal: turn a program name into a file name, using $PATH,
make sure it exists i t /N( t shlext splitR t commandR t statt OSErrort Nonet get_patht ost patht join( R& t commandargst programt filenamet stRO t dir( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyt get_execv_args s*
c C sP t i } | | _ | i i i d | | i d | _ | | i | _ d S( Ns spawnerr: %si ( t timet spawnerrR R1 t criticalt backofft delay( R& R5 t now( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyt record_spawnerr s
c C s | i i } | i o" d | } | i i i | d Sd | _ d | _ d | _ d | _
d | _ t i | _
| i \ } } } | i i | | | } | d j o | i | d Sy | i i | _ Wnd t j
oX } | d } | t i j o d | } n d t i i | | } | i | d SXy | i i } Wn t j
o~ } | d } | t i j o d | } n d t i i | | } | i | | i i | i | i i | i d SX| d j op | | _ | i i | i | i i i d | | f d | _ t i | i i | _ | | i i | <| Sz| i i | i i! | i d d | i i! | i d d
| i i! | i d d x- t" d
| i i# D] }
| i i$ |
qW| i% } | oD | i i& d
d | | i i' f | i i& d
d | | f n y | i i( | | Wn t j
oC } | d } | i i& d
d | d t i i | | f n\ t) i* \ \ } } }
} } } d | | | |
f } | i i& d
d | | f n XWd | i i+ d Xd S( s Start the subprocess. It must not be running already.
Return the process id. If the fork() call fails, return 0.
s process %r already runningNi s too many open files to spawn %rs unknown error: %ss/ Too many processes in process table to spawn %rs spawned: %r with pid %st child_stdint child_stdouti t child_stderri i s" %s: error trying to setuid to %s!
s %s: %s
s couldn't exec %s: %s
s %s, %s: file: %s line: %si (, R R0 t pidR R1 RY t killingRL RX t
exitstatust system_stopt administrative_stopRW t laststartRV t check_execv_argsR] t
make_pipesR RK t errnot EMFILEt errorcodet gett forkt EAGAINt close_parent_pipest close_child_pipesR/ t startsecsR[ t
pidhistoryt setpgrpt dup2t ranget minfdsR9 t set_uidt writet uidt execvt asyncoret compact_tracebackt _exit( R& t pnameR5 RS t argvRT t fail_msgt whyR Ra t it filet funt linet tt vt tbinfot error( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyt spawn s
!
%!c C s d | _ | i | i i S( s Administrative stop i ( Re t killR t
stopsignal( R& ( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyt stop; s c C s0 t i } | i p4 d | i i t | f } | i i i | | Sye | i i i d | i i | i t | f d | _ | | i i | _
| i i | i | Wnz t i } t
i d | | i } d | i i | i | f } | i i i | d | _ d | _ d | _
| SXd S( s Send a signal to the subprocess. This may or may not 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.
s6 attempted to kill %s with sig %s but it wasn't runnings" killing %s (pid %s) with signal %si R s" unknown problem killing %s (%s):%si N( RW Ra R R0 R R R1 t debugRb t stopwaitsecsR[ R t StringIOt tracebackt print_exct getvalueRY RL ( R& t sigR\ R5 t iot tb( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyR @ s4
c
C s | i | i t | \ } } t i } | | _ | i i } | | i | i i j } | | i i j } | p | } | i
o/ d | _
d | _ | | _ d | | f } n | o3 d | _ d | _
| | _ d | | d f } nj d | _ | i
d | _
| | i
| _ | o
d | _ n | o d | | _ n d | | d f } | i i i | d | _ | i i | i h | _ d S(
sK The process was reaped and we need to report and manage its state
i s stopped: %s (%s)s exited: %s (%s)s
; expectedi s1 Exited too quickly (process log may have details)s Bad exit code %ss ; not expectedN( RB R6 R RW t laststopR R0 Rf Rq t exitcodesRb R[ Rc RZ RL RX R R1 R/ Ra Ro R (
R& Ra t stst esR5 R\ t processnamet
tooquicklyt badexitt expected( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyt finishc s>
c C s4 | i i d j o d S| i i | i i } | S( N( R Ry RL R t dropPrivileges( R& R5 ( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyRw s c C s t | i i | i i S( N( t cmpR t priority( R& t other( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyt __cmp__ s c C s) d t | | i i t | i f S( Ns+
( t idR R0 R t get_state( R& ( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyt __repr__ s c C s | i p t i S| i o t i S| i o t i S| i d j o | i o t i St i
Sn: | i o | i o t i
St i Sn | i o t i St i S( N( Rf R R Rb R
Rd R Rc RL Re R R[ Ra R R R R
( R& ( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyR s"
N(# R R t __doc__Ra Rf R R[ Re Rd Rb RZ RL R R% R. Rc RX R' R, R- R6 R= R@ RB RE RV R] R R R R Rw R R R ( ( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyR S s@ h # 2 t
Supervisorc B s e Z d Z e Z d Z d Z d e e d Z e d Z e d Z
d Z d Z d Z
d Z d
Z d Z e d Z d
Z d Z RS( i i c C s
| | _ d S( N( R ( R& R ( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyR' s c C s | i i | | i i g } g } | i i } | o | i | n | o | i i } | i | n | i i | | | i i p | i i n | i i
| i | d S( N( R t realizet cleanup_fdsRw RC t set_rlimitst extendt make_loggert nocleanupt clear_autochildlogdirt create_autochildlogst run( R& t argst testt firstt
info_messagest critical_messagest
setuid_msgt rlimit_messages( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyt main s
c C s h | _ x6 | i i D]( } | i } | i i | | i | than %s seconds (startsecs)s success: %s %s( RW R R R R R R1 R R RZ t startretriesR[ Rd R/ R0 R Rf Rq ( R& R\ R R R R R1 R5 ( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyR o s* "
c C s6 g } | i i D] } | i o | | q q ~ S( s* Processes which are starting or stopping ( R R R[ ( R& R R ( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyR s c C s{ t i } | i i } g } xS | D]K } | i t i j o/ | i | } | d j o | i | qs q( q( W| S( s Processes which we've attempted to stop but which haven't responded
to a kill request within a given amount of time (stopwaitsecs) i ( RW R R R R R
R[ RC ( R& R\ R t undeadR t time_left( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyt
get_undead s
c C sQ xJ | i D]< } | i i i d | i i | i f | i t i q
Wd S( Ns killing %r (%s) with SIGKILL(
R R R1 RY R R0 Ra R t signalt SIGKILL( R& R ( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyR s
c C s | i i \ } } | ou | i i i | d } | d j o | i i i d | n | i i } | i | | | p | i
q n d S( Ns reaped unknown pid %s)( R t waitpidRr Rl RL R1 RY R R0 R R ( R& t onceRa R t processR0 ( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyR s
c C sa | i i oP| i i d } | i _ | t i t i t i f j o* | i i i d t | d | _ q]| t i
j o* | i i i d t | d | _ q]| t i j o! | i i i d t | q]| t i
j oR | i i i d t | | i i xB | i i D] } | i q$Wq]| i i i d t | n d S( Ns# received %s indicating exit requestis& received %s indicating restart requesti s# received %s indicating a child quits) received %s indicating log reopen requests received %s indicating nothing( R R RL t SIGTERMt SIGINTt SIGQUITR1 RY R R t SIGHUPt SIGCHLDR/ t SIGUSR2R- R R R ( R& R R ( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyR s,
c C s | i d j o t i St i S( Ni ( R R R R ( R& ( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyR s N( R R R t FalseR R R' RL R R R R R R R R R R R R ( ( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyR s Y "
c C s t i d j p
t d t } x t } t | } | i d | | t } | o | S| i d j o t
i d n x! | i i
D] } | i q W| i i o | i i i q# q# d S( Nt posixs) This code makes Unix-specific assumptionsi ( RN R0 t AssertionErrorR R R R RL R R t syst exitR R R, R t
httpservert close( R R R t dR ( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyR s
t __main__( R RN R RW Ri t socketR R R{ R R RG R# R R R R R R R R R R R R R ( ( ( s: /usr/lib/python2.6/site-packages/supervisor/supervisord.pyt ( s4
h