+ DfjA4Rt^RIHt^RIHt^RIHt^RIHt^RIH t ^RI H t H t H t HtHtHtHtHtHt^RIHtHt^RIHtHtHtHt^R IHt^R IHt!R R ]4t !R R]4t!!RR4t"!RR]4t#!RR]4t$!RR]4t%R#)z( Tests for L{twisted.internet.testing}. ) annotations)Callable) verifyObject)Protocol) IPv4Address) IAddress IConnector IConsumerIListeningPort IPushProducer IReactorSSL IReactorTCP IReactorUNIX ITransport) ClientFactoryFactory) MemoryReactorNonStreamingProducerRaisingMemoryReactorStringTransport)namedAny)TestCasec]tRt^&tRtRRltRRltRRltRR ltR R lt R R lt RRlt RRlt RRlt RRltRRltRRltRRltRRltRRltR R!ltR"R#ltR$R%ltR&R'ltR(tR)#)*StringTransportTestsz8 Tests for L{twisted.internet.testing.StringTransport}. cV^8dQhRR/#returnNone)formats"D/usr/lib/python3/dist-packages/twisted/internet/test/test_testing.py __annotate__!StringTransportTests.__annotate__+s++t+c $\4VnR#N)r transportselfs&r!setUpStringTransportTests.setUp+s (*r$cV^8dQhRR/#rr)r s"r!r"r#.sAAAr$c VP\\VP44VP\\VP44VP\\ VP44R#)zY L{StringTransport} instances provide L{ITransport}, L{IPushProducer}, and L{IConsumer}. N) assertTruerrr'r r r(s&r!test_interfaces$StringTransportTests.test_interfaces.sI  Z@A  ]DNNCD  Y?@r$cV^8dQhRR/#rr)r s"r!r"r#7s ; ;t ;r$c \4p\4pVPPW4VPVPPV4VPVPP V4R#)zb L{StringTransport.registerProducer} records the arguments supplied to it as instance attributes. N)objectr'registerProducerassertIsproducer streamingr)r6r7s& r!test_registerProducer*StringTransportTests.test_registerProducer7sT 8H  ''< dnn--x8 dnn.. :r$cV^8dQhRR/#rr)r s"r!r"r#Bs 2 2 2r$c P\4pVPPVR4VP\VPP\4R4VP VPP V4VPVPP4R#)za L{StringTransport.registerProducer} raises L{RuntimeError} if a producer is already registered. TFN) r3r'r4 assertRaises RuntimeErrorr5r6r.r7)r)r6s& r!test_disallowedRegisterProducer4StringTransportTests.test_disallowedRegisterProducerBsr 8 ''$7  $..9968U  dnn--x8 001r$cV^8dQhRR/#rr)r s"r!r"r#Os 2 2 2r$c \4p\4pVPPVR4VPP4VP VPP 4VPPVR4VP VPP V4VPVPP4R#)z L{StringTransport.unregisterProducer} causes the transport to forget about the registered producer and makes it possible to register a new one. FTN) r3r'r4unregisterProducer assertIsNoner6r5r.r7)r) oldProducer newProducers& r!test_unregisterProducer,StringTransportTests.test_unregisterProducerOs h h  '' U; ))+ $..112 '' T: dnn--{; 001r$cV^8dQhRR/#rr)r s"r!r"r#^sKKKr$c ZVP\VPP4R#)zh L{StringTransport.unregisterProducer} raises L{RuntimeError} if called when no producer is registered. N)r=r>r'rCr(s&r!test_invalidUnregisterProducer3StringTransportTests.test_invalidUnregisterProducer^s ,(I(IJr$cV^8dQhRR/#rr)r s"r!r"r#esDD4Dr$c RVPVPPR4R#)z? L{StringTransport.producerState} is initially C{'producing'}. producingN) assertEqualr' producerStater(s&r!test_initialProducerState.StringTransportTests.test_initialProducerStatees 55{Cr$cV^8dQhRR/#rr)r s"r!r"r#ksAATAr$c VPP4VPVPPR4R#)za L{StringTransport.pauseProducing} changes the C{producerState} of the transport to C{'paused'}. pausedN)r'pauseProducingrPrQr(s&r!test_pauseProducing(StringTransportTests.test_pauseProducingks. %%' 55x@r$cV^8dQhRR/#rr)r s"r!r"r#ssDDdDr$c VPP4VPP4VPVPPR4R#)ze L{StringTransport.resumeProducing} changes the C{producerState} of the transport to C{'producing'}. rON)r'rWresumeProducingrPrQr(s&r!test_resumeProducing)StringTransportTests.test_resumeProducingss> %%' &&( 55{Cr$cV^8dQhRR/#rr)r s"r!r"r#|sBBDBr$c VPP4VPVPPR4R#)zc L{StringTransport.stopProducing} changes the C{'producerState'} of the transport to C{'stopped'}. stoppedN)r' stopProducingrPrQr(s&r!test_stopProducing'StringTransportTests.test_stopProducing|s. $$& 55yAr$cV^8dQhRR/#rr)r s"r!r"r#sGG$Gr$c VPP4VP\VPP4R#)z] L{StringTransport.pauseProducing} raises L{RuntimeError} if the transport has been stopped. N)r'rbr=r>rWr(s&r! test_stoppedTransportCannotPause5StringTransportTests.test_stoppedTransportCannotPauses. $$& ,(E(EFr$cV^8dQhRR/#rr)r s"r!r"r#sHH4Hr$c VPP4VP\VPP4R#)z^ L{StringTransport.resumeProducing} raises L{RuntimeError} if the transport has been stopped. N)r'rbr=r>r\r(s&r!!test_stoppedTransportCannotResume6StringTransportTests.test_stoppedTransportCannotResumes. $$& ,(F(FGr$cV^8dQhRR/#rr)r s"r!r"r#sGGGr$c VPP4VP\VPP4R#)zb L{StringTransport.pauseProducing} raises L{RuntimeError} if the transport is being disconnected. N)r'loseConnectionr=r>rWr(s&r!&test_disconnectingTransportCannotPause;StringTransportTests.test_disconnectingTransportCannotPauses. %%' ,(E(EFr$cV^8dQhRR/#rr)r s"r!r"r#sHHHr$c VPP4VP\VPP4R#)zc L{StringTransport.resumeProducing} raises L{RuntimeError} if the transport is being disconnected. N)r'ror=r>r\r(s&r!'test_disconnectingTransportCannotResume2r$cV^8dQhRR/#rr)r s"r!r"rs666r$c 2\4pVPRR\44VPRR\4R43Fkp\ \ V4VP 4p\ \V4VPVPR4VPVPR4Km VPR\44p\ \ V4VP 4p\ \V4VPVPR4R#)z L{MemoryReactor.connectTCP}, L{MemoryReactor.connectSSL}, and L{MemoryReactor.connectUNIX} will return an L{IConnector} whose C{getDestination} method returns an L{IAddress} with attributes which reflect the values passed. ztest.example.comi Ns /fake/path) r connectTCPr connectSSLrrgetDestinationrrPhostport connectUNIXname)r)r connectorrs& r!test_connectDestination$ReactorTests.test_connectDestinations&  $ $%7} O  $ $%7}PT U I Y /..0G 7 +   W\\+= >   W\\4 0 "--m]_M Z+**,Xw' }5r$cV^8dQhRR/#rr)r s"r!r"rs;;;r$c .\4pVPR\44VPR\4R43Fkp\ \ V4VP 4p\ \V4VPVPR4VPVPR4Km VPR\44p\ \ V4VP 4p\ \V4VPVPR4R#)a^ L{MemoryReactor.listenTCP}, L{MemoryReactor.listenSSL} and L{MemoryReactor.listenUNIX} will return an L{IListeningPort} whose C{getHost} method returns an L{IAddress}; C{listenTCP} and C{listenSSL} will have a default host of C{'0.0.0.0'}, and a port that reflects the value passed, and C{listenUNIX} will have a name that reflects the path passed. i2 Nz0.0.0.0s/path/to/socket) r listenTCPr listenSSLrr r~rrPrr listenUNIXr)r)rrrs& r!test_listenDefaultHost#ReactorTests.test_listenDefaultHosts&  # #D') 4  # #D')T : D  .llnG 7 +   W\\9 5   W\\4 0 ''(:GIF^T*,,.Xw' '9:r$cV^8dQhRR/#rr)r s"r!r"r33d3r$c \4p\4pVPV4VPV4VPVP 4V.4VP V4VPVP 4.4R#)z. Adding, removing, and listing readers works. N)r3r addReaderrP getReaders removeReader)r)readerreactors& r! test_readersReactorTests.test_readersp/&!&! ++-x8V$ ++-r2r$cV^8dQhRR/#rr)r s"r!r"r'rr$c \4p\4pVPV4VPV4VPVP 4V.4VP V4VPVP 4.4R#)z. Adding, removing, and listing writers works. N)r3r addWriterrP getWriters removeWriter)r)writerrs& r! test_writersReactorTests.test_writers'rr$rN) rrrrrrrrrrrrrr$r!rrs*236.;23 33r$rcJ]tRtRtRtRRltRRltRRltR R ltR t R #) TestConsumeri8zH A very basic test consumer for use with the NonStreamingProducerTests. cV^8dQhRR/#rr)r s"r!r"TestConsumer.__annotate__=s33$3r$c 0.VnRVnRVnR#r&)writesr6producerStreamingr(s&r!__init__TestConsumer.__init__=s#% $ .2r$c$V^8dQhRRRRRR/#)rr6r3r7boolrrr)r s"r!r"rBs!+++D+T+r$c WnW nR#)z Registers a single producer with this consumer. Just keeps track of it. @param producer: The producer to register. @param streaming: Whether the producer is a streaming one or not. Nr6rr8s&&&r!r4TestConsumer.registerProducerBs! !*r$cV^8dQhRR/#rr)r s"r!r"rLs&&D&r$c "RVnRVnR#)z3 Forget the producer we had previously registered. Nrr(s&r!rCTestConsumer.unregisterProducerLs !%r$c V^8dQhRRRR/#)rdatabytesrrr)r s"r!r"rSs!!%!D!r$c <VPPV4R#)zb Some data was written to the consumer: stores it for later use. @param data: The data to write. N)rappend)r)rs&&r!writeTestConsumer.writeSs 4 r$)r6rrN) rrrrrrr4rCrrrr$r!rr8s 3 +&!!r$rc2]tRtRtRtRRltRRltRtR#) NonStreamingProducerTestsi\z> Tests for the L{NonStreamingProducer} to validate behaviour. cV^8dQhRR/#rr)r s"r!r"&NonStreamingProducerTests.__annotate__asBB$Br$c `\4p\V4pVPVR4VPVPV4VPVP V4VP VP4\^ 4FpVP4K .ROpVPVP4VPVP4VPVP 4VPVPV4VP\VP4R#)zw When the L{NonStreamingProducer} has resumeProducing called 10 times, it writes the counter each time and then fails. FN) 0123456789)rrr4r5r6consumerrxrranger\rDrPrr=r>)r)rr6_expectedWritess& r!test_producesOnly10Times2NonStreamingProducerTests.test_producesOnly10Timesas  >'1!!(E2 h''2 h''2 334rA  $ $ &V (++, (445 (++, .9 ,(@(@Ar$cV^8dQhRR/#rr)r s"r!r"r{s A AD Ar$c \4p\V4pVPVR4VP4VP \ VP 4R#)zJ When the L{NonStreamingProducer} is paused, it raises a L{RuntimeError}. FN)rrr4r\r=r>rW)r)rr6s& r!test_cannotPauseProduction4NonStreamingProducerTests.test_cannotPauseProduction{sI  >'1!!(E2   " ,(?(?@r$rN)rrrrrrrrrr$r!rr\sB4 A Ar$rc,]tRtRt]RRl4tRtR#) _SupportsNameicV^8dQhRR/#)rrstrr)r s"r!r"_SupportsName.__annotate__s  # r$c R#r&rr(s&r!r_SupportsName.__name__s r$rN)rrrrpropertyrrr$r!rrs   r$rc]tRtRtRtRRltRRltRRltR R ltR R lt R Rlt RRlt RRlt RRlt RRltRRltRRltRRltRRltRR ltR!tR"#)#DeprecationTestsiz0 Deprecations in L{twisted.test.proto_helpers}. c$V^8dQhRRRRRR/#)rtestzCallable[..., object]objrrrr)r s"r!r"DeprecationTests.__annotate__s"//0/}//r$c :RVP 2pVPV.4pVP\V^,R,4VP^\ V44VP W4^,R,4VP V\V44R#)ztwisted.internet.testing.categorymessageN)r flushWarningsrPDeprecationWarninglenassertInr5r)r)r r new_pathwarningss&&& r!helperDeprecationTests.helpersz.s||n=%%tf- +Xa[-DE CM* h I 67 c8H-.r$cV^8dQhRR/#rr)r s"r!r"r JJ4Jr$c J^RIHpVPVPV4R#))AccumulatingProtocolN)twisted.test.proto_helpersrrtest_accumulatingProtocol)r)rs& r!r*DeprecationTests.test_accumulatingProtocolC D224HIr$cV^8dQhRR/#rr)r s"r!r"r sHH$Hr$c J^RIHpVPVPV4R#)r)LineSendingProtocolN)rr"rtest_lineSendingProtocol)r)r"s& r!r#)DeprecationTests.test_lineSendingProtocolsB D113FGr$cV^8dQhRR/#rr)r s"r!r"r sLLDLr$c J^RIHpVPVPV4R#)r)FakeDatagramTransportN)rr'rtest_fakeDatagramTransport)r)r's& r!r(+DeprecationTests.test_fakeDatagramTransportsD D335JKr$cV^8dQhRR/#rr)r s"r!r"r s@@d@r$c J^RIHpVPVPV4R#)r)rN)rrrtest_stringTransport)r)rs& r!r,%DeprecationTests.test_stringTransports> D--?r$cV^8dQhRR/#rr)r s"r!r"r s  t r$c J^RIHpVPVPV4R#)r) StringTransportWithDisconnectionN)rr0r%test_stringTransportWithDisconnection)r)r0s& r!r16DeprecationTests.test_stringTransportWithDisconnectionsO  6 68X r$cV^8dQhRR/#rr)r s"r!r"r sNNTNr$c J^RIHpVPVPV4R#)r)StringIOWithoutClosingN)rr5rtest_stringIOWithoutClosing)r)r5s& r!r6,DeprecationTests.test_stringIOWithoutClosingsE D446LMr$cV^8dQhRR/#rr)r s"r!r"r s>>T>r$c J^RIHpVPVPV4R#)r)_FakeConnectorN)rr:rtest__fakeConnector)r)r:s& r!r;$DeprecationTests.test__fakeConnectors= D,,n=r$cV^8dQhRR/#rr)r s"r!r"r s444r$c J^RIHpVPVPV4R#)r) _FakePortN)rr?rtest__fakePort)r)r?s& r!r@DeprecationTests.test__fakePorts8 D''3r$cV^8dQhRR/#rr)r s"r!r"r s< 4 < F J J R JJr$rN)&r __future__rtypingrzope.interface.verifyrrtwisted.internet.addressrtwisted.internet.interfacesrrr r r r r rrtwisted.internet.protocolrrtwisted.internet.testingrrrrtwisted.python.reflectrtwisted.trial.unittestrrrrrrrrr$r!rfs#.0   = ,+e48e4Pg38g3T!!!!H+A+A\ H SJxSJr$