ó [³XMc@sºdZddlZddlZddlZddlZddlZddlmZddlm Z ddl m Z m Z m Z mZde jfd„ƒYZde jfd „ƒYZdS( sD Test running processes with the APIs in L{twisted.internet.utils}. iÿÿÿÿN(tplatform(tunittest(terrortreactortutilst interfacestProcessUtilsTestscBsãeZdZejedƒdkr-dZndZdZ e j Z d„Z d„Zd„Zd„Zd„Zd„Zd„Zejƒr™d e_nd „Zd „Zd „Zd „Zd„Zd„Zd„Zd„ZRS(st Test running a process using L{getProcessOutput}, L{getProcessValue}, and L{getProcessOutputAndValue}. s)reactor doesn't implement IReactorProcesscCsU|jƒ}t|dƒ}|jtjj|ƒtjƒ|jƒtjj|ƒS(sj Write the given list of lines to a text file and return the absolute path to it. twt( tmktemptfiletwritetostlineseptjointclosetpathtabspath(tselft sourceLinestscriptt scriptFile((s</usr/lib/python2.7/dist-packages/twisted/test/test_iutils.pytmakeSourceFiles    cCsI|jddddgƒ}tj|jd|gƒ}|j|jdƒS(s™ L{getProcessOutput} returns a L{Deferred} which fires with the complete output of the process it runs after that process exits. s import syssfor s in 'hello world\n':s sys.stdout.write(s)s sys.stdout.flush()s-us hello world (RRtgetProcessOutputtexet addCallbackt assertEquals(RRtd((s</usr/lib/python2.7/dist-packages/twisted/test/test_iutils.pyt test_output(s csbˆjddgƒ}tjˆjd|gƒ}ˆj|tƒ}‡fd†}|j|ƒ|S(s— The L{Deferred} returned by L{getProcessOutput} is fired with an L{IOError} L{Failure} if the child process writes to stderr. s import syss!sys.stderr.write("hello world\n")s-ucsˆj|jtjƒS(N(t assertFailuret processEndedRt ProcessDone(terr(R(s</usr/lib/python2.7/dist-packages/twisted/test/test_iutils.pytcbFailedCs(RRRRRtIOErrorR(RRRR ((Rs</usr/lib/python2.7/dist-packages/twisted/test/test_iutils.pyttest_outputWithErrorIgnored6s  cCsR|jdddddgƒ}tj|jd|gdtƒ}|j|jdƒS( sÒ If a C{True} value is supplied for the C{errortoo} parameter to L{getProcessOutput}, the returned L{Deferred} fires with the child's stderr output as well as its stdout output. s import sysssys.stdout.write("foo")ssys.stdout.flush()ssys.stderr.write("foo")ssys.stderr.flush()s-uterrortootfoofoo(RRRRtTrueRt assertEqual(RRR((s</usr/lib/python2.7/dist-packages/twisted/test/test_iutils.pyttest_outputWithErrorCollectedIs !cCs@|jdgƒ}tj|jd|gƒ}|j|jdƒS(s| The L{Deferred} returned by L{getProcessValue} is fired with the exit status of the child process. sraise SystemExit(1)s-ui(RRtgetProcessValueRRR&(RRR((s</usr/lib/python2.7/dist-packages/twisted/test/test_iutils.pyt test_value\scs[tj}ˆjddddgƒ}‡fd†}tjˆjd|gƒ}|j|ƒS(s The L{Deferred} returned by L{getProcessOutputAndValue} fires with a three-tuple, the elements of which give the data written to the child's stdout, the data written to the child's stderr, and the exit status of the child. s import syss"sys.stdout.write('hello world!\n')s$sys.stderr.write('goodbye world!\n')s sys.exit(1)csJ|\}}}ˆj|dƒˆj|dtjƒˆj|dƒdS(Ns hello world! sgoodbye world!i(RR R (t.0toutRtcode(R(s</usr/lib/python2.7/dist-packages/twisted/test/test_iutils.pytgotOutputAndValuevs s-u(tsyst executableRRtgetProcessOutputAndValueRR(RRRR-R((Rs</usr/lib/python2.7/dist-packages/twisted/test/test_iutils.pyttest_outputAndValuegs  csjˆjddddddgƒ}‡fd†}tjˆjd|gƒ}ˆj|tƒ}|j|ƒS( s If the child process exits because of a signal, the L{Deferred} returned by L{getProcessOutputAndValue} fires a L{Failure} of a tuple containing the the child's stdout, stderr, and the signal which caused it to exit. simport sys, os, signals"sys.stdout.write('stdout bytes\n')s"sys.stderr.write('stderr bytes\n')ssys.stdout.flush()ssys.stderr.flush()s$os.kill(os.getpid(), signal.SIGKILL)csF|\}}}ˆj|dƒˆj|dƒˆj|tjƒdS(Ns stdout bytes s stderr bytes (RtsignaltSIGKILL(R*R+Rtsig(R(s</usr/lib/python2.7/dist-packages/twisted/test/test_iutils.pyR-s s-u(RRR0RRttupleR(RRR-R((Rs</usr/lib/python2.7/dist-packages/twisted/test/test_iutils.pyttest_outputSignal~s  s"Windows doesn't have real signals.cCsltjj|jƒƒ}tj|ƒ|jddgƒ}||jd|gd|ƒ}|j||ƒ|S(Nsimport os, sysssys.stdout.write(os.getcwd())s-uR(R RRRtmakedirsRRR(RtutilFunctchecktdirRR((s</usr/lib/python2.7/dist-packages/twisted/test/test_iutils.pyt _pathTests  cCs|jtj|jƒS(s L{getProcessOutput} runs the given command with the working directory given by the C{path} parameter. (R;RRR&(R((s</usr/lib/python2.7/dist-packages/twisted/test/test_iutils.pyttest_getProcessOutputPath¨scs"‡fd†}ˆjtj|ƒS(s~ L{getProcessValue} runs the given command with the working directory given by the C{path} parameter. csˆj|dƒdS(Ni(R&(tresulttignored(R(s</usr/lib/python2.7/dist-packages/twisted/test/test_iutils.pyR9µs(R;RR((RR9((Rs</usr/lib/python2.7/dist-packages/twisted/test/test_iutils.pyttest_getProcessValuePath°scs"‡fd†}ˆjtj|ƒS(s‡ L{getProcessOutputAndValue} runs the given command with the working directory given by the C{path} parameter. cs3|\}}}ˆj||ƒˆj|dƒdS(Ni(R&(R*R:R+Rtstatus(R(s</usr/lib/python2.7/dist-packages/twisted/test/test_iutils.pyR9¿s (R;RR0(RR9((Rs</usr/lib/python2.7/dist-packages/twisted/test/test_iutils.pyt!test_getProcessOutputAndValuePathºscCsÑtjj|jƒƒ}tj|ƒ|jdd|fdgƒ}|jtjtjƒƒtj|ƒ|jtj |t j tj dƒj ƒƒtj |dƒ||j d|gƒ}|j||ƒ|S(Nsimport os, sys, statsos.chmod(%r, stat.S_IXUSR)ssys.stdout.write(os.getcwd())t.is-u(R RRRR7Rt addCleanuptchdirtgetcwdtchmodtstattS_IMODEtst_modeRR(RR8R9R:RR((s</usr/lib/python2.7/dist-packages/twisted/test/test_iutils.pyt_defaultPathTestÅs    %cCs|jtj|jƒS(s If no value is supplied for the C{path} parameter, L{getProcessOutput} runs the given command in the same working directory as the parent process and succeeds even if the current working directory is not accessible. (RJRRR&(R((s</usr/lib/python2.7/dist-packages/twisted/test/test_iutils.pyt test_getProcessOutputDefaultPathâscs"‡fd†}ˆjtj|ƒS(s If no value is supplied for the C{path} parameter, L{getProcessValue} runs the given command in the same working directory as the parent process and succeeds even if the current working directory is not accessible. csˆj|dƒdS(Ni(R&(R=R>(R(s</usr/lib/python2.7/dist-packages/twisted/test/test_iutils.pyR9ós(RJRR((RR9((Rs</usr/lib/python2.7/dist-packages/twisted/test/test_iutils.pyttest_getProcessValueDefaultPathìscs"‡fd†}ˆjtj|ƒS(s  If no value is supplied for the C{path} parameter, L{getProcessOutputAndValue} runs the given command in the same working directory as the parent process and succeeds even if the current working directory is not accessible. cs3|\}}}ˆj||ƒˆj|dƒdS(Ni(R&(R*R:R+RR@(R(s</usr/lib/python2.7/dist-packages/twisted/test/test_iutils.pyR9ÿs (RJRR0(RR9((Rs</usr/lib/python2.7/dist-packages/twisted/test/test_iutils.pyt(test_getProcessOutputAndValueDefaultPathøsN(t__name__t __module__t__doc__RtIReactorProcessRtNonetskiptoutputtvalueR.R/RRRR"R'R)R1R6Rt isWindowsR;R<R?RARJRKRLRM(((s</usr/lib/python2.7/dist-packages/twisted/test/test_iutils.pyRs.            tWarningSuppressioncBs,eZd„Zd„Zd„Zd„ZRS(cCs%g|_tj|_|jt_dS(N(twarningst showwarningt originalshow(R((s</usr/lib/python2.7/dist-packages/twisted/test/test_iutils.pytsetUps  cCs|jt_dS(N(RZRXRY(R((s</usr/lib/python2.7/dist-packages/twisted/test/test_iutils.pyttearDownscOs|jj||fƒdS(N(RXtappend(Rtatkw((s</usr/lib/python2.7/dist-packages/twisted/test/test_iutils.pyRYscCs—d„}tj|d tddƒfƒ}|dƒ|jt|jƒdƒ|dƒ|jt|jƒdƒ|dƒ|jt|jƒdƒdS( NcSstj|ƒdS(N(RXtwarn(tmsg((s</usr/lib/python2.7/dist-packages/twisted/test/test_iutils.pytfstignoretmessagesThis is messagesSanity check messageisUnignored messagei(signore(RtsuppressWarningstdictRtlenRX(RRbtg((s</usr/lib/python2.7/dist-packages/twisted/test/test_iutils.pyttestSuppressWarningss !   (RNROR[R\RYRi(((s</usr/lib/python2.7/dist-packages/twisted/test/test_iutils.pyRWs   (RPRXR RGR.R2ttwisted.python.runtimeRt twisted.trialRttwisted.internetRRRRtTestCaseRRW(((s</usr/lib/python2.7/dist-packages/twisted/test/test_iutils.pyts <"ø