| Server IP : 61.19.30.66 / Your IP : 216.73.216.15 Web Server : Apache/2.2.22 (Ubuntu) System : Linux klw 3.11.0-15-generic #25~precise1-Ubuntu SMP Thu Jan 30 17:39:31 UTC 2014 x86_64 User : www-data ( 33) PHP Version : 5.3.10-1ubuntu3.48 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority, MySQL : ON | cURL : OFF | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : OFF Directory : /usr/lib/python2.7/dist-packages/landscape/lib/ |
Upload File : |
ó
}9Rc
@ s¢ d d l m Z m Z d d l m Z d d l m Z m Z d d l m Z d d l
Z
e d Z d e f d YZ
d
i d d d e e d d d Z d S( i’’’’( t DeferredListt Deferred( t ProcessProtocol( t Processt
ProcessReader( t reactorNc C s< t | d d d | } | j d | j d | S( Nt fireOnOneErrbacki t
consumeErrorsc S s g | D] } | d ^ q S( Ni ( ( t rt x( ( s> /usr/lib/python2.7/dist-packages/landscape/lib/twisted_util.pyt <lambda> s c S s
| j j S( N( t valuet
subFailure( t f( ( s> /usr/lib/python2.7/dist-packages/landscape/lib/twisted_util.pyR
s ( R t addCallbackt
addErrback( t deferredst consume_errorst d( ( s> /usr/lib/python2.7/dist-packages/landscape/lib/twisted_util.pyt gather_results s
t AllOutputProcessProtocolc B s8 e Z d Z d d d Z d Z d Z d Z RS( s< A process protocol for getting stdout, stderr and exit code.c C sU | | _ t j | _ t j | _ | j j | _ | | _ | | _ d | _ d S( Nt (
t deferredt cStringIOt StringIOt outBuft errBuft writet errReceivedt stdint
line_receivedt
_partial_line( t selfR R R ( ( s> /usr/lib/python2.7/dist-packages/landscape/lib/twisted_util.pyt __init__ s c C s6 | j d k r2 | j j | j | j j n d S( N( R t Nonet transportR t
closeStdin( R ( ( s> /usr/lib/python2.7/dist-packages/landscape/lib/twisted_util.pyt connectionMade s c C sx | j j | | j d k r# d S| j d } | j | d | d <| j | _ x | D] } | j | q] Wd S( Ns
i ( R R R R" t splitR t pop( R t datat linest line( ( s> /usr/lib/python2.7/dist-packages/landscape/lib/twisted_util.pyt outReceived" s
c C s | j r% | j | j d | _ n | j j } | j j } | j } | j } | j r} | j j | | | j f n | j j
| | | f d S( NR ( R R R t getvalueR R t exitCodet signalR t errbackt callback( R t reasont outt errt et code( ( s> /usr/lib/python2.7/dist-packages/landscape/lib/twisted_util.pyt processEnded2 s N( t __name__t
__module__t __doc__R" R! R% R+ R6 ( ( ( s> /usr/lib/python2.7/dist-packages/landscape/lib/twisted_util.pyR s
c
s | g }
|
j | t } t | d | d | } t j | | d |
d | d | d | d | d | | s f d }
|
_ n | S(
sļ
Spawn a process using Twisted reactor.
Return a deferred which will be called with process stdout, stderr and exit
code.
@param wait_pipes: if set to False, don't wait for stdin/stdout pipes to
close when process ends.
@param line_received: an optional callback called with every line of
output from the process as parameter.
@note: compared to reactor.spawnProcess, this version does NOT require the
executable name as first element of args.
R R t argst envt patht uidt gidt usePTYc sp j r_ j r_ x= j j D], } t | t rE | j n | j q# Wi _ n t j d S( sė A less strict version of Process.maybeCallProcessEnded.
This behaves exactly like the original method, but in case the
process has ended already and sent us a SIGCHLD, it doesn't wait
for the stdin/stdout pipes to close, because the child process
itself might have passed them to its own child processes.
@note: Twisted 8.2 now has a processExited hook that could
be used in place of this workaround.
N( t pipest pidt
itervaluest
isinstanceR t doReadt stopReadingR t maybeCallProcessEnded( t pipe( t process( s> /usr/lib/python2.7/dist-packages/landscape/lib/twisted_util.pyRF ^ s
( t extendR R R t spawnProcessRF ( t
executableR: R; R< R= R> R? t
wait_pipesR R t list_argst resultt protocolRF ( ( RH s> /usr/lib/python2.7/dist-packages/landscape/lib/twisted_util.pyt
spawn_process@ s
( ( t twisted.internet.deferR R t twisted.internet.protocolR t twisted.internet.processR R t twisted.internetR R t FalseR R R" t TrueRP ( ( ( s> /usr/lib/python2.7/dist-packages/landscape/lib/twisted_util.pyt <module> s /