/usr/lib/python2.6/site-packages/supervisor
Edit: /usr/lib/python2.6/site-packages/supervisor/xmlrpc.pyo (27542B)
FATc @ s 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 d k l Z d d k l Z d d k l Z d d k l Z d d k l Z d d
k l Z d d k l Z d d k l Z d
Z d f d YZ d Z d e f d YZ! d f d YZ" d Z# d f d YZ$ d f d YZ% d e& f d YZ' d f d YZ( d e f d YZ) d Z* d S(! iN( t
ProcessStates( t SupervisorStates( t getSupervisorStateDescription( t getProcessStateDescription( t xmlrpc_handler( t
get_header( t producers( t NOT_DONE_YET( t readFile( t tailFile( t gettagsg ?t Faultsc B sV 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 RS(
i i i i i i
i i i( i2 i< iF iP ( t __name__t
__module__t UNKNOWN_METHODt INCORRECT_PARAMETERSt
BAD_ARGUMENTSt SIGNATURE_UNSUPPORTEDt SHUTDOWN_STATEt BAD_NAMEt NO_FILEt FAILEDt ABNORMAL_TERMINATIONt SPAWN_ERRORt ALREADY_STARTEDt NOT_RUNNINGt SUCCESS( ( ( s5 /usr/lib/python2.6/site-packages/supervisor/xmlrpc.pyR s c C s3 x, t i D]! } t t | | j o | Sq
Wd S( Nt UNKNOWN( R t __dict__t getattr( t codet faultname( ( s5 /usr/lib/python2.6/site-packages/supervisor/xmlrpc.pyt getFaultDescription, s
t RPCErrorc B s e Z d d Z RS( c C sC | | _ t | | _ | d j o d | i | f | _ n d S( Ns %s: %s( R R t textt None( t selfR t extra( ( s5 /usr/lib/python2.6/site-packages/supervisor/xmlrpc.pyt __init__3 s
N( R R
R# R& ( ( ( s5 /usr/lib/python2.6/site-packages/supervisor/xmlrpc.pyR! 2 s t DeferredXMLRPCResponsec B s> e Z d Z e i d e i Z d Z d Z d Z RS( s A medusa producer that implements a deferred callback; requires
a subclass of asynchat.async_chat that handles NOT_DONE_YET sentinel s Connection: (.*)c C s1 | | _ | | _ t | _ t | i | _ d S( N( t callbackt requestt Falset finishedt floatt delay( R$ R) R( ( ( s5 /usr/lib/python2.6/site-packages/supervisor/xmlrpc.pyR& > s c C s | i o d Syx y" | i } | t j o t SWn- t j
o! } t i | i | i } n Xt | } t | _ | i
| SWn* t i t | _ | i
i d n Xd S( Nt i ( R+ R( R R! t xmlrpclibt FaultR R" t xmlrpc_marshalt Truet getresponset tracebackt print_excR) t error( R$ t valuet errt body( ( s5 /usr/lib/python2.6/site-packages/supervisor/xmlrpc.pyt moreD s
c C sb d | i d
t j
o2 } i h | d 6| i d 6| i d 6 t SX| t j o i | | f n& i h | d 6t
i d 6d d 6 o t S S( NR t statust descriptioni t OK( Rc R R R R R! R R" t popR R R ( R t eR R( R7 ( R R$ t resultst callbacksR R ( s5 /usr/lib/python2.6/site-packages/supervisor/xmlrpc.pyt startallj s:
g?( Rf Ra R t valuest sortR R R R R- R ( R$ R R ( ( R R$ R R R R s5 /usr/lib/python2.6/site-packages/supervisor/xmlrpc.pyR X s
/ c s | i d | i i i | d j o t t i | n g g t i t i
t i f f d } d | _ | | _
| S( s Stop a process named by name
@param string name The name of the process to stop
@return boolean result Always return True unless error
t stopProcessc s p7 i j o t t i n i d n pA i } | d j o t t i | n i d t S i t i
t i f j o t St Sd S( Ni (
Rc R! R R R t stopR# R R R t STOPPEDt EXITEDR2 ( t msg( R t stoppedR t called( s5 /usr/lib/python2.6/site-packages/supervisor/xmlrpc.pyt killit s
g?N( Rf Ra R R R# R! R R R R R R R- R ( R$ R R ( ( R R R R s5 /usr/lib/python2.6/site-packages/supervisor/xmlrpc.pyR s
c s i d i i i i i g g t i t i t i f f d } d | _
| _ | S( sq Stop all processes in the process list
@return boolean result Always return true unless error.
t stopAllProcessesc sj p x D] } | i j os y, i | i i i | i i f Wq t j
o4 } i h | d 6| i d 6| i d 6 q q Xq q Wn p S i d \ } } y
| } Wn> t j
o2 } i h | d 6| i d 6| i d 6 t SX| t j o i | | f n& i h | d 6t
i d 6d d 6 o t S S( NR R R i R ( Rc R R R R R! R R" R R R R ( R R R R( R7 ( R R$ R R R ( s5 /usr/lib/python2.6/site-packages/supervisor/xmlrpc.pyt killall s8
g?( Rf Ra R R R t reverseR R R R R- R ( R$ R ( ( R R$ R R R s5 /usr/lib/python2.6/site-packages/supervisor/xmlrpc.pyR s
9 c C s9 | d } | t i j on | d } | d } t i t i | d } t i t i | d } | | } d | d | f } n | t i t i f j o' | d } | p d | d } q5nn | t i t i f j oN | d o9 | d
} t i t i | d }
|
i
d } q5d
} n d } | S( NRe t startt nowi s pid %s, uptime %st pidR s unknown error (try "tail %s")R R i s %b %d %I:%M %ps Not startedR. ( R R t datetimeR t gmtimet FATALR R R t localtimet strftime( R$ R Re R R t start_dtt now_dtt uptimet descR t stop_dt( ( s5 /usr/lib/python2.6/site-packages/supervisor/xmlrpc.pyt _interpretProcessInfo s(
c C s | i d | i i i | } | d j o t t i | n t | i } t | i
} t t i } | i } | i
p d } | i p d } h
| d 6| d 6| d 6| d 6| d 6t | d 6| d
6| d 6| i i d 6| i d
6} | i | }
|
| d <| S( s Get info about a process named name
@param string name The name of the process
@return struct result A structure containing data about the process
t getProcessInfoR. i R R R R Re Rn R t
exitstatusRq R R N( Rf Ra R R R# R! R R t intt laststartt laststopR Rc R R R R Rq R R ( R$ R R R R R Re R R R R ( ( s5 /usr/lib/python2.6/site-packages/supervisor/xmlrpc.pyR 3 s0
c C sZ | i d | i i i } | i g } x$ | D] } | i | i | q6 W| S( sh Get info about all processes
@return array result An array of process status results
t getAllProcessInfo( Rf Ra R t keysR R R ( R$ t processnamest outputt processname( ( s5 /usr/lib/python2.6/site-packages/supervisor/xmlrpc.pyR X s
c C s | i d | i i i | } | d j o t t i | n | i i } | d j p t
i i | o t t i
| n y t | | | SWn7 t j
o+ } | i d } t t t | n Xd S( s0 Read length bytes from name's log starting at offset
@param string name the name of the process
@param int offset offset to start reading from.
@param int length number of bytes to read from the log.
@return string result Bytes of log
t readProcessLogi N( Rf Ra R R R# R! R R R Rq Rr Rs Rt R R Ru Rv R ( R$ R Rw Rx R Rq Ry Rz ( ( s5 /usr/lib/python2.6/site-packages/supervisor/xmlrpc.pyR f s
!
c C s | i d | i i i | } | d j o t t i | n | i i } | d j p t
i i | o d d t
g St | | | S( s{
Provides a more efficient way to tail logs than readProcessLog().
Use readProcessLog() to read chucks and tailProcessLog() to tail.
Requests (length) bytes from the (name)'s log, starting at
(offset). If the total log size is greater than (offset + length),
the overflow flag is set and the (offset) is automatically increased
to position the buffer at the end of the log. If less than (length)
bytes are available, the maximum number of available bytes will be
returned. (offset) returned is always the last offset in the log +1.
@param string name the name of the process
@param int offset offset to start reading from
@param int length maximum number of bytes to return
@return array result [string bytes, int offset, bool overflow]
t tailProcessLogR. i N( Rf Ra R R R# R! R R R Rq Rr Rs Rt R* R ( R$ R Rw Rx R Rq ( ( s5 /usr/lib/python2.6/site-packages/supervisor/xmlrpc.pyR s
!c C s | i d | i i i | } | d j o t t i | n y | i Wn. t t
i f j
o t t i | n Xt
S( s Clear the log for name and reopen it
@param string name The name of the process
@return boolean result Always True unless error
t clearProcessLogN( Rf Ra R R R# R! R R t
removelogsR~ Rr R6 R R2 ( R$ R R ( ( s5 /usr/lib/python2.6/site-packages/supervisor/xmlrpc.pyR s
c s | i d g g | i i i } | i x$ | D] } i | | i f q< W f d } d | _ | | _ | S( s] Clear all process log files
@return boolean result Always return true
t clearAllProcessLogsc s p S i d \ } } y | | Wn= t j
o1 } i h | d 6| i d 6| i d 6 n' X i h | d 6t i d 6d d 6 o t S S( Ni R R R R ( R R! R R R" R R R ( R R( R ( R R ( s5 /usr/lib/python2.6/site-packages/supervisor/xmlrpc.pyt clearall s g?( Rf Ra R R R R R R- R ( R$ R R R ( ( R R s5 /usr/lib/python2.6/site-packages/supervisor/xmlrpc.pyR s
( R R
R& Rf Rg Ri Rl Rp t readMainLogR{ R R R2 R R R R R R R R R R R ( ( ( s5 /usr/lib/python2.6/site-packages/supervisor/xmlrpc.pyR` s*
@ E + N % t SystemNamespaceRPCInterfacec B s> e Z d Z d Z d Z d Z d Z d Z RS( c C s> h | _ x! | D] \ } } | | i | t | } d | d R? t donet StringIOR4 R5 t getvaluet criticalR6 ( R$ Ro R) R R R R7 R8 t pushproducerR9 t iot val( ( s5 /usr/lib/python2.6/site-packages/supervisor/xmlrpc.pyt continue_requestr s6
c C s t | i | | S( N( R R ( R$ R R ( ( s5 /usr/lib/python2.6/site-packages/supervisor/xmlrpc.pyR s ( R R
R& R
R ( ( ( s5 /usr/lib/python2.6/site-packages/supervisor/xmlrpc.pyR m s 3c C s | i d } xc | D][ } | i d o t t i n t | | d } | d j o t t i q q Wy | | SWn" t j
o t t i n Xd S( Nt .R ( t splitR R! R R R R# t TypeErrorR ( t obR R Rs R ( ( s5 /usr/lib/python2.6/site-packages/supervisor/xmlrpc.pyR s
(+ R/ Rr R R R RX R4 R t tempfilet errnot signalR Ra R R R R t medusa.xmlrpc_handlerR t medusa.http_serverR t medusaR t httpR Rj R R R
Rh R R t ExceptionR! R' R1 R` R t dictR R R R ( ( ( s5 /usr/lib/python2.6/site-packages/supervisor/xmlrpc.pyt sH g
/;