| 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/twisted/internet/test/ |
Upload File : |
ó
ƇNc @ s¸ d Z e Z d d l Z d d l Z d d l Z d d l Z d d l m Z m Z d d l
m Z d d l m
Z
d d l m Z m Z d d l m Z d d l m Z d d l m Z d d
l m Z m Z 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 e f d „ ƒ YZ# d e f d „ ƒ YZ$ d e$ f d „ ƒ YZ% e& ƒ j' e% j( ƒ ƒ d e$ f d „ ƒ YZ) e& ƒ j' e) j( ƒ ƒ d e f d „ ƒ YZ* d S( s2
Tests for implementations of L{IReactorProcess}.
iÿÿÿÿN( t TestCaset SkipTest( t ReactorBuilder( t set( t msgt err( t platform( t FilePath( t utils( t IReactorProcesst IProcessTransport( t Deferredt succeed( t ProcessProtocol( t ProcessDonet ProcessTerminated( t _signalst _ShutdownCallbackProcessProtocolc B s) e Z d Z d „ Z d „ Z d „ Z RS( sõ
An L{IProcessProtocol} which fires a Deferred when the process it is
associated with ends.
@ivar received: A C{dict} mapping file descriptors to lists of bytes
received from the child process on those file descriptors.
c C s | | _ i | _ d S( N( t whenFinishedt received( t selfR ( ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt __init__# s c C s | j j | g ƒ j | ƒ d S( N( R t
setdefaultt append( R t fdt bytes( ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt childDataReceived( s c C s | j j d ƒ d S( N( R t callbackt None( R t reason( ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt processEnded, s ( t __name__t
__module__t __doc__R R R ( ( ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyR s t ProcessTestsBuilderBasec B s• e Z d Z e g Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z
d „ Z e e
d d
ƒ d
k rx d e _ n d
„ Z d „ Z d „ Z RS( sæ
Base class for L{IReactorProcess} tests which defines some tests which
can be applied to PTY or non-PTY uses of C{spawnProcess}.
Subclasses are expected to set the C{usePTY} attribute to C{True} or
C{False}.
c s‹ t ƒ } t | ƒ } | j ƒ ‰ ˆ j | t j t j d d g d | j ƒ} | j t j | ƒ ƒ | j
‡ f d † ƒ | j ˆ ƒ d S( s
L{IReactorProcess.spawnProcess} connects the protocol passed to it
to a transport which provides L{IProcessTransport}.
s -ct t usePTYc s
ˆ j ƒ S( N( t stop( t ignored( t reactor( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt <lambda>S s N( R R t buildReactort spawnProcesst syst
executableR$ t
assertTrueR
t
providedByt addCallbackt
runReactor( R t endedt protocolt transport( ( R' sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt test_processTransportInterface< s c s£ | j ƒ ‰ t ƒ } t | ƒ ‰ d t j ‰ d ‰ ‡ ‡ ‡ ‡ ‡ f d † } ˆ j | ƒ | j ‡ f d † ƒ | j ˆ ƒ | j ˆ d j ˆ j
d ƒ ƒ d S( s¸
Helper for testing L{IProcessTransport} write functionality. This
method spawns a child process and gives C{write} a chance to write some
bytes to it. It then verifies that the bytes were actually written to
it (by relying on the child process to echo them back).
@param write: A two-argument callable. This is invoked with a process
transport and some bytes to write to it.
s hello, worlds2 import sys
sys.stdout.write(sys.stdin.readline())
c s] ˆ j ˆ t j t j d ˆ g ƒ } y ˆ | ˆ ƒ Wn! t d d ƒ | j d ƒ n Xd S( Ns -cs! Unhandled exception while writingt KILL( R* R+ R, R R t
signalProcess( R3 ( t writeR2 R' R t program( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt startupl s
c s
ˆ j ƒ S( N( R% ( R& ( R' ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyR( v s R# i N( R) R R t ost linesept callWhenRunningR/ R0 t assertEqualt joinR ( R R7 R1 R9 ( ( R2 R' R R7 R8 sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt
_writeTestW s
c C s d „ } | j | ƒ d S( s|
L{IProcessTransport.write} writes the specified C{str} to the standard
input of the child process.
c S s | j | ƒ d S( N( R7 ( R3 R ( ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyR7 s N( R? ( R R7 ( ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt
test_write| s c C s d „ } | j | ƒ d S( s
L{IProcessTransport.writeSequence} writes the specified C{list} of
C{str} to the standard input of the child process.
c S s | j t | ƒ ƒ d S( N( t
writeSequencet list( R3 R ( ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyR7 ‹ s N( R? ( R R7 ( ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt test_writeSequence† s c C s d „ } | j | ƒ d S( sŽ
L{IProcessTransport.writeToChild} writes the specified C{str} to the
specified file descriptor of the child process.
c S s | j d | ƒ d S( Ni ( t writeToChild( R3 R ( ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyR7 • s N( R? ( R R7 ( ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt test_writeToChild s c s ‡ f d † } ˆ j | ƒ d S( s¦
L{IProcessTransport.writeToChild} raises L{KeyError} if passed a file
descriptor which is was not set up by L{IReactorProcess.spawnProcess}.
c s2 z ˆ j t | j d | ƒ Wd | j | ƒ Xd S( Ni
( t assertRaisest KeyErrorRD R7 ( R3 R ( R ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyR7 Ÿ s N( R? ( R R7 ( ( R sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt" test_writeToChildBadFileDescriptorš s c s | j ƒ ‰ | j r d } n i } t j ƒ ‰ ‡ f d † } t j t j | ƒ t ƒ } ˆ j t | ƒ t
j t
j d d g d | j d | ƒˆ j d ƒ ˆ j
ƒ s» | j d ƒ n g } | j | j ƒ | rÛ d S| j ‡ f d † ƒ | j ˆ ƒ | j | ƒ d S(
sÚ
If, before the reactor is started with L{IReactorCore.run}, a
process is started with L{IReactorProcess.spawnProcess} and
terminates, the process is reaped once the reactor is started.
c s ˆ j ƒ d S( N( R ( t args( t signaled( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt handler» s s -cR# R$ t childFDsix s, Timed out waiting for child process to exit.Nc s
ˆ j ƒ S( N( R% ( R& ( R' ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyR( Ø s ( R) R$ R t threadingt Eventt signalt SIGCHLDR R* R R+ R, t waitt isSett failR/ R R0 R- ( R RL RK R1 t result( ( R' RJ sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt test_spawnProcessEarlyIsReaped¨ s* "
RP s; Platform lacks SIGCHLD, early-spawnProcess test can't work.c sÚ d ‰ t t d ˆ ƒ ‰ t ƒ ‰ d } d t f ‡ ‡ f d † ƒ Y} ˆ j ƒ ‰ ˆ j ˆ j | ƒ t j t j d | g d ˆ j ƒ‡ ‡ f d † } ˆ j
| ƒ ˆ j t ƒ ˆ j
‡ f d † ƒ ˆ j
ˆ ƒ d
S( s©
The C{reason} argument passed to L{IProcessProtocol.processExited} is a
L{ProcessTerminated} instance if the child process exits with a signal.
t TERMt SIGsE import sys
sys.stdout.write('x')
sys.stdout.flush()
sys.stdin.read()
t Exiterc s8 e Z ‡ f d † Z d „ Z ‡ f d † Z d „ Z RS( c s( t d | | f ƒ | j j ˆ ƒ d S( Ns childDataReceived(%d, %r)( R R3 R6 ( R R t data( t sigName( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyR ÷ s c S s t d | f ƒ d S( Ns childConnectionLost(%d)( R ( R R ( ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt childConnectionLostû s c s% t d | f ƒ ˆ j | g ƒ d S( Ns processExited(%r)( R R ( R R ( t exited( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt
processExitedþ s c S s t d | f ƒ d S( Ns processEnded(%r)( R ( R R ( ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyR s ( R R R R[ R] R ( ( RZ R\ ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyRX ö s s -cR$ c s~ | \ } | j t ƒ | j } t j ƒ rT ˆ j | j d ƒ ˆ j | j d ƒ n& ˆ j | j ˆ ƒ ˆ j | j d ƒ d S( Ni (
t trapR t valueR t isWindowst assertIdenticalRO R R= t exitCode( t .0t failureR ( R t sigNum( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt cbExited s
c s
ˆ j ƒ S( N( R% ( t ign( R' ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyR( # s N( t getattrRO R R
R) R< R* R+ R, R$ R/ t
addErrbackR R0 ( R t sourceRX Rf ( ( RZ R\ Re R R' sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt test_processExitedWithSignalã s
c sÏ | j ƒ ‰ d d d g } t t d d
ƒ d
k } ˆ j j } | | k re | re t d | ƒ ‚ n t j j d k r† t d ƒ ‚ n g ‰ ‡ ‡ f d † } ˆ j | ƒ | j
ˆ ƒ | j ˆ d g ƒ d
S( sÎ
If a child process exits while a system call is in progress, the system
call should not be interfered with. In particular, it should not fail
with EINTR.
Older versions of Twisted installed a SIGCHLD handler on POSIX without
using the feature exposed by the SA_RESTART flag to sigaction(2). The
most noticable problem this caused was for blocking reads and writes to
sometimes fail with EINTR.
t Glib2Reactort Gtk2Reactort PortableGtkReactort siginterrupts( %s is not supported without siginterruptt _installHandlerUsingSignals@ _signals._installHandlerUsingSignal doesn't support this featurec s[ zI t j d t j f ƒ } t j d t j f ƒ } ˆ j | j ƒ ƒ Wd ˆ j ƒ Xd S( Ns$ %s -c "import time; time.sleep(0.1)"s1 %s -c "import time; time.sleep(0.5); print 'Foo'"( R: t popenR+ R, R t readR% ( t f1t f2( R' RT ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt fD s s Foo
N( R) Rh RO R t __class__R R R t installHandlerR< R0 R= ( R t skippedReactorst hasSigInterruptt reactorClassNameRu ( ( R' RT sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt' test_systemCallUninterruptedByChildExit( s
c s d d l m } | d k r+ t d ƒ ‚ n t t ƒ } | j ƒ j ƒ j ƒ j ƒ } d d | j f d d d f } ‡ f d
† ‰ ˆ j ƒ ‰ d t f ‡ ‡ f d † ƒ Y} | ƒ } ˆ j ˆ j
| t j t j d
d d j
| ƒ g d ˆ j ƒˆ j ˆ ƒ d S( s¯
A spawned process has only stdin, stdout and stderr open
(file descriptor 3 is also reported as open, because of the call to
'os.listdir()').
iÿÿÿÿ( t platformTypet posixs$ Test only applies to POSIX platformss
import syss sys.path.insert(0, '%s')s$ from twisted.internet import processs- sys.stdout.write(str(process._listOpenFDs()))s sys.stdout.flush()c s ˆ j d | ƒ d S( Ns [0, 1, 2, 3]( R= ( t output( R ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt checkOutputi s t Protocolc s, e Z d „ Z d „ Z ‡ ‡ f d † Z RS( c S s
g | _ d S( N( R~ ( R ( ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyR o s c S s | j j | ƒ d S( N( R~ R ( R RY ( ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt outReceivedr s c s, z ˆ d j | j ƒ ƒ Wd ˆ j ƒ Xd S( NR# ( R> R~ R% ( R R ( R R' ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyR u s ( R R R R R ( ( R' R ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyR€ n s s -Wignores -cs
R$ N( t twisted.python.runtimeR| R R t __file__t parentt pathR) R
R< R* R+ R, R> R$ R0 ( R R| t heret topRj R€ t proto( ( R' R R sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt test_openFileDescriptorsV s&
N( R R R! R t requiredInterfacesR4 R? R@ RC RE RH RU Rh RO R t skipRk R{ R‰ ( ( ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyR" 1 s %
6 E .t ProcessTestsBuilderc B s} e Z d Z e Z e e ƒ j d ƒ j Z e
j ƒ r? d Z n d Z d „ Z
d „ Z d „ Z d „ Z d „ Z d „ Z RS(
sp
Builder defining tests relating to L{IReactorProcess} for child processes
which do not have a PTY.
s process_helper.pyt windowsR# c s t ƒ ‰ i t ƒ d 6t ƒ d 6t ƒ d 6‰ d t f ‡ ‡ f d † ƒ Y} d } | j ƒ ‰ ˆ j ˆ j | ƒ t j t j d | g d | j ƒ‡ f d † } ˆ j | ƒ ‡ f d
† } ˆ j | ƒ d „ } ˆ j | ƒ ˆ j t
ƒ ‡ f d † } ˆ j | ƒ | j ˆ ƒ d
S( s’
L{IProcessProtocol.childConnectionLost} is called each time a file
descriptor associated with a child process is closed.
i i i t Closerc s& e Z ‡ f d † Z ‡ f d † Z RS( c s ˆ j | ƒ d S( N( R ( R R3 ( t connected( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt makeConnectionœ s c s ˆ | j d ƒ d S( N( R R ( R t childFD( t lost( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyR[ Ÿ s ( R R R R[ ( ( R R’ ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyRŽ › s sw import os, sys
while 1:
line = sys.stdin.readline().strip()
if not line:
break
os.close(int(line))
s -cR$ c s' ˆ j d ƒ ˆ d j ‡ f d † ƒ S( Ns 2
i c s ˆ S( N( ( Rg ( R3 ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyR( ± s ( R7 R/ ( R3 ( R’ ( R3 sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt cbConnected¯ s
c s' ˆ j d ƒ ˆ d j ‡ f d † ƒ S( Ns 1
i c s ˆ S( N( ( Rg ( R3 ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyR( ¶ s ( R7 R/ ( R3 ( R’ ( R3 sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt
lostSecond´ s
c S s | j d ƒ d S( Ns
( R7 ( R3 ( ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt lostFirst¹ s c s ˆ j ƒ d S( N( R% ( R& ( R' ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt cbEnded¾ s N( R R
R) R< R* R+ R, R$ R/ Ri R R0 ( R RŽ Rj R“ R” R• R– ( ( R' R’ R sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt test_childConnectionLost“ s$ $
c sÊ t ƒ ‰ g ‰ d t f ‡ ‡ f d † ƒ Y} ˆ j ƒ ‰ ˆ j ˆ j | ƒ t j t j ˆ j d ˆ j g d ˆ j ƒ‡ ‡ f d † } ˆ j
| ƒ ˆ j t ƒ ˆ j
‡ f d † ƒ ˆ j
ˆ ƒ d S( sÂ
L{IProcessProtocol.processEnded} is called after the child process
exits and L{IProcessProtocol.childConnectionLost} is called for each of
its file descriptors.
t Enderc s8 e Z d „ Z ‡ f d † Z d „ Z ‡ f d † Z RS( c S s% t d | | f ƒ | j j ƒ d S( Ns childDataReceived(%d, %r)( R R3 t loseConnection( R R RY ( ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyR Ð s c s" t d | f ƒ ˆ j | ƒ d S( Ns childConnectionLost(%d)( R R ( R R‘ ( R’ ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyR[ Ô s c S s t d | f ƒ d S( Ns processExited(%r)( R ( R R ( ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyR] Ø s c s% t d | f ƒ ˆ j | g ƒ d S( Ns processEnded(%r)( R R ( R R ( R1 ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyR Û s ( R R R R[ R] R ( ( R’ R1 ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyR˜ Ï s t childR$ c s? | \ } | j t ƒ ˆ j t ˆ ƒ t d d d g ƒ ƒ d S( Ni i i ( R^ R R= R ( Rc Rd ( R’ R ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyR– æ s
c s
ˆ j ƒ S( N( R% ( Rg ( R' ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyR( ì s N( R R
R) R< R* R+ R, t keepStdioOpenProgramt keepStdioOpenArgR$ R/ Ri R R0 ( R R˜ R– ( ( R' R’ R R1 sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt test_processEndedÆ s
c sø t ƒ ‰ t ƒ ‰ g ‰ d t f ‡ ‡ ‡ f d † ƒ Y} ˆ j ƒ ‰ ˆ j ˆ j | ƒ t j t j ˆ j d ˆ j g d ˆ j ƒ‡ ‡ ‡ f d † } ˆ j
| ƒ ‡ ‡ f d † } ˆ j
| ƒ ˆ j t ƒ ˆ j
‡ f d † ƒ ˆ j
ˆ ƒ d S( s®
L{IProcessProtocol.processExited} is called when the child process
exits, even if file descriptors associated with the child are still
open.
t Waiterc s2 e Z d „ Z ‡ ‡ f d † Z ‡ f d † Z RS( c S s t d | | f ƒ d S( Ns childDataReceived(%d, %r)( R ( R R RY ( ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyR ÿ s c sD t d | f ƒ ˆ j | ƒ t ˆ ƒ d k r@ ˆ j d ƒ n d S( Ns childConnectionLost(%d)i ( R R t lenR R ( R R‘ ( R’ t allLost( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyR[ s
c s2 t d | f ƒ ˆ j | g ƒ | j j ƒ d S( Ns processExited(%r)( R R R3 R™ ( R R ( R\ ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyR] s ( R R R R[ R] ( ( R’ R R\ ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyRž þ s Rš R$ c s; | \ } | j t ƒ t d ˆ f ƒ ˆ j ˆ g ƒ ˆ S( Ns cbExited; lost = %s( R^ R R R= ( Rc Rd ( R’ R R ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyRf s
c s) ˆ j t ˆ ƒ t d d d g ƒ ƒ d S( Ni i i ( R= R ( R& ( R R’ ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt cbAllLost s c s
ˆ j ƒ S( N( R% ( Rg ( R' ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyR( ! s N( R R
R) R< R* R+ R, R› Rœ R$ R/ Ri R R0 ( R Rž Rf R¡ ( ( R' R’ R R R\ sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt test_processExitedô s" "
c C sU | j ƒ } t | d ƒ } | j t j j | ƒ t j ƒ | j ƒ t j j | ƒ S( sj
Write the given list of lines to a text file and return the absolute
path to it.
t wt( t mktempt fileR7 R: R; R> t closeR… t abspath( R t sourceLinest scriptt
scriptFile( ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt makeSourceFile& s
c s¥ d ‰ ˆ j d t j f d d ˆ f d g ƒ ‰ t j ˆ d ƒ ˆ j ƒ ‰ ‡ ‡ f d † ‰ ‡ f d † ‰ ‡ ‡ ‡ ‡ f d † } ˆ j | ƒ ˆ j ˆ ƒ d
S( s¹
Spawning a process with an executable which is a script starting
with an interpreter definition line (#!) uses that interpreter to
evaluate the script.
s this is the shebang outputs #!%ss
import syss sys.stdout.write('%s')s sys.stdout.flush()iÀ c sZ | \ } } } t d | | | f ƒ ˆ j | ˆ ƒ ˆ j | d ƒ ˆ j | d ƒ d S( Ns cbProcessExited((%r, %r, %d))R# i ( R R= ( Rc t outR t code( R t SHEBANG_OUTPUT( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt cbProcessExitedC s
c s ˆ j ƒ | S( N( R% ( t passthrough( R' ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt shutdownI s
c s@ t j ˆ d ˆ ƒ} | j ˆ ƒ | j ˆ ƒ | j t ƒ d S( NR' ( R t getProcessOutputAndValuet addBothR/ Ri R ( t d( R' R¯ Rª R± ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt startM s
N( R« R+ R, R: t chmodR) R< R0 ( R Rµ ( ( R' R R¯ Rª R± R® sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt test_shebang2 s
c s© d ‰ d d d d d g ‰ ˆ j d j t t t d d ƒ ƒ ƒ ƒ ˆ j ƒ ‰ ‡ ‡ f d
† ‰ ‡ f d † ‰ ‡ ‡ ‡ ‡ ‡ f d † } ˆ j | ƒ ˆ j ˆ ƒ d
S( sq
Arguments given to spawnProcess are passed to the child process as
originally intended.
sÀ import sys, os
try:
import msvcrt
msvcrt.setmode(sys.stdout.fileno(), os.O_BINARY)
except ImportError:
pass
for arg in sys.argv[1:]:
sys.stdout.write(arg + chr(0))
sys.stdout.flush()t hellot "s |<>^&s "\\"hello\\"s "foo\ bar baz\""R# i i c s- | j d ƒ } | j ƒ ˆ j ˆ | ƒ d S( Nt ( t splitt popR= ( R~ ( R RI ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt processFinishedp s
c s ˆ j ƒ | S( N( R% ( RT ( R' ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyR± v s
c sF t d ƒ } | j ‡ ‡ ‡ f d † ƒ | j ˆ ƒ | j ˆ ƒ d S( Nc s# t j t j d ˆ g ˆ d ˆ ƒS( Ns -cR' ( R t getProcessOutputR+ R, ( t dummy( R' RI Rj ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyR( | s ( R R R/ R³ ( R´ ( RI R½ Rj R± R' ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt
spawnChildz s
N( R R> t mapt chrt xrangeR) R< R0 ( R RÀ ( ( R± R' R RI Rj R½ sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt test_processCommandLineArgumentsW s
(
( R R R! t FalseR$ R Rƒ t siblingR… R› R R` Rœ R— R R¢ R« R· RÄ ( ( ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyRŒ ƒ s 3 . 2 %t PTYProcessTestsBuilderc B sE e Z d Z e Z e j ƒ r' d Z n e j ƒ rC i d d 6Z n RS( si
Builder defining tests relating to L{IReactorProcess} for child processes
which have a PTY.
s" PTYs are not supported on Windows.s# OS X's poll() does not support PTYss( twisted.internet.pollreactor.PollReactor(
R R R! t TrueR$ R R` R‹ t isMacOSXRx ( ( ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyRÇ ‡ s t PotentialZombieWarningTestsc B s e Z d Z d „ Z RS( sE
Tests for L{twisted.internet.error.PotentialZombieWarning}.
c C sv d d l m } | j | j | j g ƒ } | j | d d t ƒ | j | d d d ƒ | j t | ƒ d ƒ d S( s¾
Accessing L{PotentialZombieWarning} via the
I{PotentialZombieWarning} attribute of L{twisted.internet.error}
results in a deprecation warning being emitted.
iÿÿÿÿ( t errori t categoryt messages„ twisted.internet.error.PotentialZombieWarning was deprecated in Twisted 10.0.0: There is no longer any potential for zombie process.i N( t twisted.internetRË t PotentialZombieWarningt
flushWarningst test_deprecatedR= t DeprecationWarningRŸ ( R RË t warnings( ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyRÑ œ s ( R R R! RÑ ( ( ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyRÊ ˜ s (+ R! t typet
__metaclass__R: R+ RO RM t twisted.trial.unittestR R t# twisted.internet.test.reactormixinsR t twisted.python.compatR t twisted.python.logR R R‚ R t twisted.python.filepathR RÎ R t twisted.internet.interfacesR R
t twisted.internet.deferR R t twisted.internet.protocolR
t twisted.internet.errorR R R R R" RŒ t globalst updatet makeTestCaseClassesRÇ RÊ ( ( ( sF /usr/lib/python2.7/dist-packages/twisted/internet/test/test_process.pyt <module> s. 0ÿ Sÿ