+ j8Rt^RIHt^RIt^RIt^RIt^RIHtHt^RI H t ^RI H t H t HtHtHt^RIHtHt^RIHt^RIHtHt^R IHt^R IHt^R IHt^R IH t ^R I!H"t"H#t#Rt$]%!]PL4t']PPPS]PT4]'R&!RR]P*4t+!RR]#4t,R#)z Tests for L{twisted.internet.stdio}. @var properEnv: A copy of L{os.environ} which has L{bytes} keys/values on POSIX platforms and native L{str} keys/values on Windows. ) annotationsN)AnyCallable)skipIf)defererrorprotocolreactorstdio)IProcessTransportIReactorProcess)ProcessProtocol)filepathlog)Failure) requireModule)platform)ConnectionLostNotifyingProtocol)SkipTestTestCasesxyz123abc Twisted is great! PYTHONPATHcR]tRt^'t$RtRtR]R&R]R&RRltR tR t R t R t R#) StandardIOTestProcessProtocola Test helper for collecting output from a child process and notifying something when it exits. @ivar onConnection: A L{defer.Deferred} which will be called back with L{None} when the connection to the child process is established. @ivar onCompletion: A L{defer.Deferred} which will be errbacked with the failure associated with the child process exiting when it exits. @ivar onDataReceived: A L{defer.Deferred} which will be called back with this instance whenever C{childDataReceived} is called, or L{None} to suppress these callbacks. @ivar data: A C{dict} mapping file descriptors to strings containing all bytes received from the child process on each file descriptor. Nzdefer.Deferred[None] | NoneonDataReceivedr transportcV^8dQhRR/#)returnNone)formats"9/usr/lib/python3/dist-packages/twisted/test/test_stdio.py __annotate__*StandardIOTestProcessProtocol.__annotate__=s))$)c |\P!4Vn\P!4Vn/VnR#N)rDeferred onConnection onCompletiondataselfs&r!__init__&StandardIOTestProcessProtocol.__init__=s'27..2B27..2B&( r$c <VPPR4R#r&)r(callbackr+s&r!connectionMade,StandardIOTestProcessProtocol.connectionMadeBs ""4(r$c VPPVR4V,VPV&VPe'VPRuq0nVPV4R#R#)z{ Record all bytes received from the child process in the C{data} dictionary. Fire C{onDataReceived} if it is not L{None}. r$N)r*getrr0)r,namebytesds&&& r!childDataReceived/StandardIOTestProcessProtocol.childDataReceivedEsU ))--c2U: $    *%)%8%8$ "A" JJt  +r$c <VPPV4R#r&)r)r0)r,reasons&&r! processEnded*StandardIOTestProcessProtocol.processEndedOs ""6*r$)r*r)r(r) __name__ __module__ __qualname____firstlineno____doc__r__annotations__r-r1r8r<__static_attributes__rr$r!rr's.$37N/6  ) )+r$rc]tRt^St]P !4'd ]!R4fRtRRltRRlt Rt RR R llt R R lt R Rlt RRltRtRtRtRtRtRtRt]!]P !4R4R4tRtR#)StandardInputOutputTests win32processNzIOn windows, spawnProcess is not available in the absence of win32process.c ,V^8dQhRRRRRRRRR R /#) rprotor siblingz str | bytesargsstrkwrrr r)r s"r!r"%StandardInputOutputTests.__annotate__Zs4  $ /: CF NQ  r$c @\V\4'dVP4p\PRRV,\ P P.\V4,p\\ 4P!V\PV3R\/VB#)a Launch a child Python process and communicate with it using the given ProcessProtocol. @param proto: A L{ProcessProtocol} instance which will be connected to the child process. @param sibling: The basename of a file containing the Python program to run in the child process. @param *args: strings which will be passed to the child process on the command line as C{argv[2:]}. @param **kw: additional arguments to pass to L{reactor.spawnProcess}. @return: The L{IProcessTransport} provider for the spawned process. z-mz twisted.test.env) isinstancer6decodesys executabler __class__r?listr spawnProcess properEnv)r,rIrJrKrMprocargss&&&*, r! _spawnProcess&StandardInputOutputTests._spawnProcessZs( gu % %nn&G NN  g %    ( (  J  w'44 3>>8 1: >@  r$c$V^8dQhRRRRRR/#)rr7defer.Deferred[None]r0zCallable[[Failure], object]rr)r s"r!r"rNzs$ & &% &1L &  &r$c @aaV3RlpV3RlpVPW44#)c2<SPRV: 24R#)z%Process terminated with non-Failure: N)fail)resultr,s&r!cb4StandardInputOutputTests._requireFailure..cb}s II=fZH Ir$c<S!V4#r&r)errr0s&r!eb4StandardInputOutputTests._requireFailure..ebs C= r$) addCallbacks)r,r7r0rbrfsf&f r!_requireFailure(StandardInputOutputTests._requireFailurezs J !~~b%%r$c aaaSP4o\P!RS,4\4oSPpSP SRS4VVV3RlpSP W4#)zl Verify that a protocol connected to L{StandardIO} can disconnect itself using C{transport.loseConnection}. zChild process logging to sstdio_test_loseconncD<\S4;_uu_4pVF.p\P!RVP4,4K0 RRR4SP ^SP 4VP \P4R# +'giLM;i)zChild logged: N) openrmsgrstripfailIfInr*trapr ProcessDone)r;fline errorLogFilepr,s& r!r<BStandardInputOutputTests.test_loseConnection..processEndedsfl##qDGG,t{{}<=$ MM!QVV $ KK)) * $#s 5B B )mktemprrnrr)rZri)r,r7r<rurvsf @@r!test_loseConnection,StandardInputOutputTests.test_loseConnections^ {{}  +l:; ) + NN 14lC +##A44r$c$V^8dQhRRRRRR/#)rexamplerLoutboolrr]r)r s"r!r"rNs$!% r$c aaVP4p\4o\P!4SnRVV3RllpSPP V4RpVP SPV4pVPSW4V#)c V^8dQhRRRR/#)rignoredrrr]r)r s"r!r"LStandardInputOutputTests.exampleOutputsAndZeroExitCode..__annotate__s  T &: r$c<SPpS'dSPP4V#SPP4V#r&)r)r closeStdout closeStdin)rr7r}rvs& r!cbBytesGStandardInputOutputTests.exampleOutputsAndZeroExitCode..cbBytess=A '')H &&(Hr$cDVP\P4R#r&)rqrrr)r;s&r!r<LStandardInputOutputTests.exampleOutputsAndZeroExitCode..processEndeds KK)) *r$)rxrrr'r addCallbackrirZ)r,r|r}rurr<r7rvs&&f @r!exampleOutputsAndZeroExitCode6StandardInputOutputTests.exampleOutputsAndZeroExitCodes{{{} ) + >>+   $$W- +  !1!1< @ 1g4r$cV^8dQhRR/#rrr]r)r s"r!r"rNsJJ)=Jr$c $VPR4#)z When stdin is closed and the protocol connected to it implements L{IHalfCloseableProtocol}, the protocol's C{readConnectionLost} method is called. stdio_test_halfcloserr+s&r!test_readConnectionLost0StandardInputOutputTests.test_readConnectionLosts 112HIIr$cV^8dQhRR/#rr)r s"r!r"rNsPP.BPr$c $VPR4#) When stdin is closed and the protocol connnected to it implements L{IHalfCloseableProtocol} but its C{readConnectionLost} method raises an exception its regular C{connectionLost} method will be called. stdio_test_halfclose_buggyrr+s&r!test_buggyReadConnectionLost5StandardInputOutputTests.test_buggyReadConnectionLosts 112NOOr$cV^8dQhRR/#rr)r s"r!r"rNs  /C r$c (VPRRR7#)r stdio_test_halfclose_buggy_writeT)r}rr+s&r!test_buggyWriteConnectionLost6StandardInputOutputTests.test_buggyWriteConnectionLosts! 11 .D2  r$c aa\4oSPSR\RR7TT3RlpSP SPT4# \dp\ \ T44hRp?ii;i)z Verify that a write made directly to stdout using L{os.write} after StandardIO has finished is reliably received by the process reading that stdout. sstdio_test_lastwriteT)usePTYNc<SPSP^,P\4RSP: R24VP \ P 4R#)ze Asserts that the parent received the bytes written by the child immediately after the child starts. z Received z) from child, did not find expected bytes.N) assertTruer*endswithUNIQUE_LAST_WRITE_STRINGrqrrrr;rvr,s&r!r<EStandardInputOutputTests.test_lastWriteReceived..processEndedsM OOq ""#;<AFF:%NO  KK)) *r$)rrZr ValueErrorrrLrir))r,er<rvsf @r!test_lastWriteReceived/StandardInputOutputTests.test_lastWriteReceivedso * + #   *,DT   +##ANNLAA #3q6" " #sA A.A))A.c aa\4oSPpSPSR4VV3RlpSPW4#)zk Verify that the transport of a protocol connected to L{StandardIO} has C{getHost} and C{getPeer} methods. sstdio_test_hostpeerc<SP^,P4wrSPV4SPV4VP\P 4R#)N)r* splitlinesrrqrrr)r;hostpeerrvr,s& r!r<?StandardInputOutputTests.test_hostAndPeer..processEndedsE--/JD OOD ! OOD ! KK)) *r$rr)rZrir,r7r<rvsf @r!test_hostAndPeer)StandardInputOutputTests.test_hostAndPeers? * + NN 145 + ##A44r$c aa\4oSPpSPSR4VV3RlpSPW4#)zx Verify that the C{write} method of the transport of a protocol connected to L{StandardIO} sends bytes to standard out. sstdio_test_writec<SPSP^,R4VP\P4R#rsok!N assertEqualr*rqrrrrs&r!r<9StandardInputOutputTests.test_write..processEnded-   QVVAY / KK)) *r$rrsf @r! test_write#StandardInputOutputTests.test_writes? * + NN 112 +##A44r$c aa\4oSPpSPSR4VV3RlpSPW4#)z Verify that the C{writeSequence} method of the transport of a protocol connected to L{StandardIO} sends bytes to standard out. sstdio_test_writeseqc<SPSP^,R4VP\P4R#rrrs&r!r<AStandardInputOutputTests.test_writeSequence..processEnded rr$rrsf @r!test_writeSequence+StandardInputOutputTests.test_writeSequences? * + NN 145 +##A44r$c VP4p\VR4;_uu_4p\R4FpVPRV3,4K RRR4V# +'giT#;i)wbi%d N)rxrmrangewrite)r,junkPathjunkFileis& r! _junkPath"StandardInputOutputTests._junkPath&sX;;= (D ! !X4[w!~.!"" !s ,A A, c aaaaaa\4oSPp.o\\^d44oVVVV3RloSP SR4oSP P S4VVVV3RlpSPW4#)zh Verify that the transport of a protocol connected to L{StandardIO} is a working L{IProducer} provider. c<S'dZSPRSP43,4SPSR,4\P!RSR4R#R#)rg{Gz?N)appendpoprr callLater)ignr1proctoWritewrittens&r!r1>StandardInputOutputTests.test_producer..connectionMade8sGw'++-)99: 72;'!!$=r$sstdio_test_producerc<SPSP^,RPS44SPSR\ S43,4VP \ P4R#)rr$z*Connection lost with %d writes left to go.N)rr*join assertFalselenrqrrr)r;rvr,rrs&r!r<.processEndedBsW   QVVAY(9 :   EWW  KK)) *r$)rr)rVrrZr(rri)r,r7r<r1rvrrrsf @@@@@r! test_producer&StandardInputOutputTests.test_producer-sw * + NNuSz" > > !!!%;< "">2 + +##A44r$c aaa\4oSPpSP4oSPSRS4VVV3RlpSP W4#)zh Verify that the transport of a protocol connected to L{StandardIO} is a working L{IConsumer} provider. sstdio_test_consumerc<\SR4;_uu_4pSPSP^,VP44RRR4VP \ P 4R# +'giL1;i)rbN)rmrr*readrqrrr)r;rsrrvr,s& r!r<.processEndedWsPh%%  AFFH5& KK)) *&%s 2A11 B )rr)rrZri)r,r7r<rrvsf @@r! test_consumer&StandardInputOutputTests.test_consumerKsM * + NN>># 14h? + ##A44r$zpStandardIO does not accept stdout as an argument to Windows. Testing redirection to a file is therefore harder.c aaa a a a \P!4p\V4p\P!SP 44o S P R4;SnpSPVP4\VP4R7p\P!4'g\\P!4wrVSP\PV4SP\PV4WTR&\ P"!V3/VBo^o \$P&!4o VV V V 3Rlo \(P*!^S 4V V V V3RlpVP-V4V#)a If L{StandardIO} is created with a file descriptor which refers to a normal file (ie, a file from the filesystem), L{StandardIO.write} writes bytes to that file. In particular, it does not immediately consider the file closed or call its protocol's C{connectionLost} method. r)stdoutstdinc<SF6pVS8XdSP4R#SPRV3,4M \P!^S4R#)N%d)loseConnectionrr r)value connectioncounthowManyspins r!rAStandardInputOutputTests.test_normalFileStandardOut..spinsNG#--/  %!12    a &r$c <SP\S4S^,4SPSP4RPR\ S4444R#)rr$c36"TFpRV3,xK R#5i)rNr).0rs& r! VStandardInputOutputTests.test_normalFileStandardOut..cbLost..s+Q.QEQDLL.sN)rnext getContentrr)r;rrpathr,s&r!cbLostCStandardInputOutputTests.test_normalFileStandardOut..cbLostsH   T%['A+ 6   !388+Q%.+Q#Q r$)rr'rrFilePathrxrmnormal addCleanupclosedictfilenor isWindowsospiper StandardIO itertoolsrr rr) r, onConnLostrIrkwargsrwrrrrrrs f @@@@@r!test_normalFileStandardOut3StandardInputOutputTests.test_normalFileStandardOut^s^^% / ;  /#yy. f  %V]]_-!!##779DA OOBHHa ( OOBHHa (7O%%e6v6 ! ' ' !T"   v&r$)r)F)r>r?r@rArrrskiprZriryrrrrrrrrrrrrr rDrr$r!rFrFSs n = E '  @ &5,2JP %BN5"5 5 5<5&  = 3  3r$rF)-rB __future__rrrrStypingrrunittestrtwisted.internetrrrr r twisted.internet.interfacesr r twisted.internet.protocolr twisted.pythonrrtwisted.python.failurertwisted.python.reflectrtwisted.python.runtimertwisted.test.test_tcprtwisted.trial.unittestrrrrenvironrXpathseprrrrFrr$r!rs # CCJ5(*0+A5:   **//#((3 ,)+H$<$<)+XCxCr$