h8SrSSKJr SSKrSSKrSSKrSSKJrJr SSK J r SSK J r J r JrJrJr SSKJrJr SSKJr SS KJrJr SS KJr SS KJr SS KJr SS KJ r SSK!J"r"J#r# Sr$\%"\RL5r'\RPRS\RT5\'S'"SS\R*5r+"SS\#5r,g)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! PYTHONPATHcN\rSrSr%SrSrS\S'S\S'S SjrS rS r S r S r g)StandardIOTestProcessProtocol'a 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 transportcz[R"5Ul[R"5Ul0UlgN)rDeferred onConnection onCompletiondataselfs ^/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/test/test_stdio.py__init__&StandardIOTestProcessProtocol.__init__=s'27..2B27..2B&( c:URRS5 gr)r callbackr#s r%connectionMade,StandardIOTestProcessProtocol.connectionMadeBs ""4(r(cURRUS5U-URU'URb%URSso0lURU5 gg)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"getrr*)r$namebytesds r%childDataReceived/StandardIOTestProcessProtocol.childDataReceivedEsU ))--c2U: $    *%)%8%8$ "A" JJt  +r(c:URRU5 gr)r!r*)r$reasons r% processEnded*StandardIOTestProcessProtocol.processEndedOs ""6*r()r"r!r r)returnNone) __name__ __module__ __qualname____firstlineno____doc__r__annotations__r&r+r2r6__static_attributes__r(r%rr's.$37N/6  ) )+r(rc.\rSrSr\R "5(a \"S5cSrSSjrSSjr Sr SSSjjr SS jr SS jr SS jrS rS rSrSrSrSrSr\"\R "5S5S5rSrg)StandardInputOutputTestsS win32processNzIOn windows, spawnProcess is not available in the absence of win32process.c.[U[5(aUR5n[RSSU-[ R R/[U5-n[[ 5R"U[RU4S[0UD6$)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) isinstancer0decodesys executabler __class__r;listr spawnProcess properEnv)r$protosiblingargskwprocargss r% _spawnProcess&StandardInputOutputTests._spawnProcessZs( gu % %nn&G NN  g %    ( (  J  w'44 3>>8 1: >@  r(c@^^U4SjnU4SjnURX45$)Nc0>TRSU<35 g)Nz%Process terminated with non-Failure: )fail)resultr$s r%cb4StandardInputOutputTests._requireFailure..cb}s II=fZH Ir(c>T"U5$rrA)errr*s r%eb4StandardInputOutputTests._requireFailure..ebs C= r() addCallbacks)r$r1r*r[r_s` ` r%_requireFailure(StandardInputOutputTests._requireFailurezs J !~~b%%r(c^^^TR5m[R"ST-5 [5mTRnTR TST5 UUU4SjnTR X5$)zl Verify that a protocol connected to L{StandardIO} can disconnect itself using C{transport.loseConnection}. zChild process logging to sstdio_test_loseconnc&>[T5nUH*n[R"SUR5-5 M, SSS5 TR STR 5 UR [R5 g!,(df  NJ=f)NzChild logged: ) openrmsgrstripfailIfInr"trapr ProcessDone)r5fline errorLogFilepr$s r%r6BStandardInputOutputTests.test_loseConnection..processEndedscl#qDGG,t{{}<=$ MM!QVV $ KK)) * $#s 1B B)mktemprrhrr!rUrb)r$r1r6rorps` @@r%test_loseConnection,StandardInputOutputTests.test_loseConnections^ {{}  +l:; ) + NN 14lC +##A44r(c^^UR5n[5m[R"5TlSUU4SjjnTRR U5 SnUR TRU5nURTX5 U$)Nc>TRnT(aTRR5 U$TRR5 U$r)r!r closeStdout closeStdin)ignoredr1outrps r%cbBytesGStandardInputOutputTests.exampleOutputsAndZeroExitCode..cbBytess=A '')H &&(Hr(cBUR[R5 gr)rkrrl)r5s r%r6LStandardInputOutputTests.exampleOutputsAndZeroExitCode..processEndeds KK)) *r()ryr9r8defer.Deferred[None])rrrrrr addCallbackrbrU)r$examplerzror{r6r1rps ` @r%exampleOutputsAndZeroExitCode6StandardInputOutputTests.exampleOutputsAndZeroExitCodes{{{} ) + >>+   $$W- +  !1!1< @ 1g4r(c$URS5$)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(c$URS5$) 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(c"URSSS9$)r stdio_test_halfclose_buggy_writeT)rzrr#s r%test_buggyWriteConnectionLost6StandardInputOutputTests.test_buggyWriteConnectionLosts! 11 .D2  r(c^^[5mTRTS[SS9 UU4SjnTR TRU5$![an[ [ U55eSnAff=f)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>TRTRSR[5STR<S35 UR [ R 5 g)ze Asserts that the parent received the bytes written by the child immediately after the child starts. rfz Received z) from child, did not find expected bytes.N) assertTruer"endswithUNIQUE_LAST_WRITE_STRINGrkrrlr5rpr$s r%r6EStandardInputOutputTests.test_lastWriteReceived..processEndedsM OOq ""#;<AFF:%NO  KK)) *r()rrUr ValueErrorrstrrbr!)r$er6rps` @r%test_lastWriteReceived/StandardInputOutputTests.test_lastWriteReceivedso * + #   *,DT   +##ANNLAA #3q6" " #sA A*A%%A*c^^[5mTRnTRTS5 UU4SjnTRX5$)zk Verify that the transport of a protocol connected to L{StandardIO} has C{getHost} and C{getPeer} methods. sstdio_test_hostpeerc>TRSR5upTRU5 TRU5 UR[R 5 g)Nrf)r" splitlinesrrkrrl)r5hostpeerrpr$s r%r6?StandardInputOutputTests.test_hostAndPeer..processEndedsE--/JD OOD ! OOD ! KK)) *r(rr!rUrbr$r1r6rps` @r%test_hostAndPeer)StandardInputOutputTests.test_hostAndPeers? * + NN 145 + ##A44r(c^^[5mTRnTRTS5 UU4SjnTRX5$)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>TRTRSS5 UR[R5 gNrfsok! assertEqualr"rkrrlrs r%r69StandardInputOutputTests.test_write..processEnded-   QVVAY / KK)) *r(rrs` @r% test_write#StandardInputOutputTests.test_writes? * + NN 112 +##A44r(c^^[5mTRnTRTS5 UU4SjnTRX5$)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>TRTRSS5 UR[R5 grrrs r%r6AStandardInputOutputTests.test_writeSequence..processEnded rr(rrs` @r%test_writeSequence+StandardInputOutputTests.test_writeSequences? * + NN 145 +##A44r(cUR5n[US5n[S5HnURSU4-5 M SSS5 U$!,(df  U$=f)Nwbi%d )rrrgrangewrite)r$junkPathjunkFileis r% _junkPath"StandardInputOutputTests._junkPath&sU;;= (D !X4[w!~.!"" !s (A Ac^^^^^^[5mTRn/m[[S55mUUUU4SjmTR TS5mTR R T5 UUUU4SjnTRX5$)zh Verify that the transport of a protocol connected to L{StandardIO} is a working L{IProducer} provider. dc>T(aPTRSTR54-5 TRTS5 [R"STS5 gg)Nrg{Gz?)appendpoprr callLater)ignr+proctoWritewrittens r%r+>StandardInputOutputTests.test_producer..connectionMade8sGw'++-)99: 72;'!!$=r(sstdio_test_producerc>TRTRSSRT55 TRTS[ T54-5 UR [ R5 g)Nrfr(z*Connection lost with %d writes left to go.)rr"join assertFalselenrkrrl)r5rpr$rrs r%r6.processEndedBsW   QVVAY(9 :   EWW  KK)) *r()rr!rMrrUr rrb)r$r1r6r+rprrrs` @@@@@r% test_producer&StandardInputOutputTests.test_producer-sw * + NNuSz" > > !!!%;< "">2 + +##A44r(c^^^[5mTRnTR5mTRTST5 UUU4SjnTR X5$)zh Verify that the transport of a protocol connected to L{StandardIO} is a working L{IConsumer} provider. sstdio_test_consumerc>[TS5nTRTRSUR55 SSS5 UR [ R 5 g!,(df  N.=f)Nrbrf)rgrr"readrkrrl)r5rmrrpr$s r%r6.processEndedWsMh%  AFFH5& KK)) *&%s .A$$ A2)rr!rrUrb)r$r1r6rrps` @@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^^^ ^ ^ ^ [R"5n[U5n[R"TR 55m T R S5=TlnTRUR5 [UR5S9n[R"5(d[[R"5upVTR[RU5 TR[RU5 XTS'[ R""U40UD6mSm [$R&"5m UU U U 4Sjm [(R*"ST 5 U U U U4SjnUR-U5 U$)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>TH0nUT:XaTR5 gTRSU4-5 O [R"ST5 g)N%dr)loseConnectionrr r)value connectioncounthowManyspins r%rAStandardInputOutputTests.test_normalFileStandardOut..spinsNG#--/  %!12    a &r(rc >TR[T5TS-5 TRTR5SRS[ T5555 g)Nrfr(c3.# UH nSU4-v M g7f)rNrA).0rs r% VStandardInputOutputTests.test_normalFileStandardOut..cbLost..s+Q.QEQDL.s)rnext getContentrr)r5rrpathr$s r%cbLostCStandardInputOutputTests.test_normalFileStandardOut..cbLostsH   T%['A+ 6   !388+Q%.+Q#Q r()rrrrFilePathrrrgnormal addCleanupclosedictfilenor isWindowsospiper StandardIO itertoolsrr rr) r$ onConnLostrPrkwargsrwrrrrrrs ` @@@@@r%test_normalFileStandardOut3StandardInputOutputTests.test_normalFileStandardOut^s^^% / ;  /#yy. f  %V]]_-!!##779DA OOBHHa ( OOBHHa (7O%%e6v6 ! ' ' !T"   v&r()r) rPrrQz str | bytesrRrrSrr8r )r1rr*zCallable[[Failure], object]r8r)F)rrrzboolr8r)r8r)r:r;r<r=rrrskiprUrbrsrrrrrrrrrrrrrr@rAr(r%rCrCSs n = E '  $ /: CF NQ  @ &% &1L &  &5.).!% 2JP %BN5"5 5 5<5&  = 3  3r(rC)-r> __future__rrrrJtypingrrunittestrtwisted.internetrrr r r twisted.internet.interfacesr r twisted.internet.protocolrtwisted.pythonrrtwisted.python.failurertwisted.python.reflectrtwisted.python.runtimertwisted.test.test_tcprtwisted.trial.unittestrrrrenvironrOpathseprrrrCrAr(r%rs # CCJ5(*0+A5:   **//#((3 ,)+H$<$<)+XCxCr(