֛hSrSSKrSSKrSSKJr SSKJrJrJr SSK J r SSK J r J r SSKJr SSKJr SS KJr SS KJr SS KJr SS KJr SS KJr "SS\R85r"SS\R85r"SS\R>5r "SS\RB5r""SS\R85r#"SS\RB5r$"SS\RB5r%"SS5r&"SS\&\RN5r("S S!5r)"S"S#\RB\)5r*"S$S%\)5r+"S&S'5r,"S(S)\&\RZ5r."S*S+\RB\+\,5r/"S,S-\&\R`5r1"S.S/\RB\+\,5r2"S0S1\&\Rf5r4"S2S3\RB\+\,5r5"S4S55r6"S6S7\R85r7"S8S9\RB5r8"S:S;\Rr5r:g)rs rr@LineOnlyTester.connectionMaderBrc:URRU5 g)z Save received data. Nr?r r"s rr$LineOnlyTester.lineReceiveds T"rr>N) r-r.r/r0r1r2r[r@r$r3r4rrr_r_zsIJ #rr_c\rSrSrSrSr/SQrSrSr/SQr \ S/-r S r S r /S Qr /S QrS rSr/SQrSrSrSrSrSrSrSrSrSrSrSrg)LineReceiverTestszP Test L{twisted.protocols.basic.LineReceiver}, using the C{LineTester} wrapper. slen 10 0123456789len 5 1234 len 20 foo 123 0123456789 012345678len 0 foo 5 1234567890123456789012345678901234567890123456789012345678901234567890 len 1 a) slen 10 0123456789len 5s1234 slen 20sfoo 123s0123456789 012345678slen 0sfoo 5rs67890slen 1ac[SS5Hn[R"5n[5nUR [ R "U55 [[UR5U-S-5H+nURXA-US-U-nURU5 M- URURUR5 M g)zT Test buffering for different packet size, checking received matches expected data. r' N) rangerStringIOWithoutClosingr6makeConnectionr FileWrapperrWbuffer dataReceived assertEqualoutputr?r packet_sizetaiss r test_bufferLineReceiverTests.test_buffers !B?KK1q5K2GHq!@   T[[!** 5(rs!twiddle1 twiddle2 pause twiddle3 )twiddle1twiddle2rDtwiddle3cB[SS5GHn[R"5n[R"5n[ U5nUR [R"U55 [[UR5U-S-5H+nURXQ-US-U-nURU5 M- URURUR5 URS5 URUR UR5 GM g)zW Test pause inside data receiving. It uses fake clock to see if pausing/resuming work. r'rmrN)rnrror Clockr6rprrqrWpauseBufrsrt pauseOutput1r?advance pauseOutput2rrwrxr:ryrzr{s r test_pausingLineReceiverTests.test_pausings !B MM!    T111:: >(rs"twiddle1 twiddle2 stop more stuff )r~rrFc[SS5Hn[R"5n[5nUR [ R "U55 [[UR5U-S-5H+nURXA-US-U-nURU5 M- URURUR5 M g)z Test stop inside producing. r'rmN) rnrror6rprrqrWstop_bufrsrt stop_outputr?rvs rtest_stopProducing$LineReceiverTests.test_stopProducings!B.ClearingReceiveric:XlUR5Ulgr)r#clearLineBufferrXr"s rr$MLineReceiverTests.test_clearLineBuffer..ClearingReceiver.lineReceiveds  002 r)r#rXN)r-r.r/r0r$r3r4rrClearingReceiverrs 3rrs foo bar bazfoosbar bazsquux squuxrN)r LineReceiverrsrtr#rX)rrrs rtest_clearLineBuffer&LineReceiverTests.test_clearLineBuffers  3u11 3 $%23 /  6 k* 0 ,rc:[5n[R"5nUR[R "U55 [ R"5nURSU-5 URSU-SRUR55 g)z3 Test switching modes many times on the same data. sx xxrN) rrrorprrqsysgetrecursionlimitrsrtjoinr)rprotorQlimits rtest_stackRecursion%LineReceiverTests.test_stackRecursion*st#$!88:  X11)<=%%' 7U?+ sxx '<=rc[R"5n[R"5nUR U5 UR SUR S--S-5 URUR5 gz` C{LineReceiver} disconnects the transport if it receives a line longer than its C{MAX_LENGTH}. rr' rN r rrStringTransportrprsr[ assertTrue disconnectingrrrQs rtest_maximumLineLength(LineReceiverTests.test_maximumLineLength5c ""$!113  Y' 45#3#3a#788CD  //0rc[5nSUl[R"5nUR U5 SURS- -nUR U5 UR UR SS5 UR UR SSU-5 URUR5 UR[UR5S5 URX1RS5 g)aF C{LineReceiver} doesn't disconnect the transport when it receives a finished line as long as its C{MAX_LENGTH}, when the second-to-last packet ended with a pattern that could have been -- and turns out to have been -- the start of a delimiter, and that packet causes the total input to exceed C{MAX_LENGTH} + len(delimiter). rGrr'NrVr) r6r[rrrprsr2 assertFalserrtrWr?)rrrxr#s r&test_maximumLineLengthPartialDelimiter8LineReceiverTests.test_maximumLineLengthPartialDelimiter@s   ) ) + Qu''!+, 4  5??3B/0 5??23/$67 ) U^^,a0 ~~a01rcF[R"5nSUl[R"5nUR U5 UR SUR-URS[UR5S- -5 URUR5 g)a C{LineReceiver} doesn't disconnect the transport it if receives a non-finished line whose length, counting the delimiter, is longer than its C{MAX_LENGTH} but shorter than its C{MAX_LENGTH} + len(delimiter). (When the first part that exceeds the max is the beginning of the delimiter.) s rNr') r rr2rrrprsr[rWrrrs r(test_notQuiteMaximumLineLengthUnfinished:LineReceiverTests.test_notQuiteMaximumLineLengthUnfinishedVs""$"!113  Y'  E$$ $8R#eoo:NQR:R(S S  001rc[R"5nSUl[R"5nUR U5 UR 5 URS5nURU[5 g)zN C{LineReceiver.dataReceived} forwards errors returned by C{rawDataReceived}. c[S5$)Noops) RuntimeErrorr*s r5LineReceiverTests.test_rawDataError..os \&-ArsdataN) r rr+rrrpr!rsassertIsInstancer)rrrQwhys rtest_rawDataError#LineReceiverTests.test_rawDataErrorisb ""$ A!113  Y'   ) c<0rcp[R"5nUR[URS5 g)zq When L{LineReceiver.rawDataReceived} is not overridden in a subclass, calling it raises C{NotImplementedError}. fooN)r r assertRaisesNotImplementedErrorr+rrs r"test_rawDataReceivedNotImplemented4LineReceiverTests.test_rawDataReceivedNotImplementedvs+ ""$ -u/D/DeLrcp[R"5nUR[URS5 g)zn When L{LineReceiver.lineReceived} is not overridden in a subclass, calling it raises C{NotImplementedError}. rN)r rrrr$rs rtest_lineReceivedNotImplemented1LineReceiverTests.test_lineReceivedNotImplemented~s+ ""$ -u/A/A5Irr4N)r-r.r/r0r1rrrur|rrrrrrrrrrrrrrrrrrrrr3r4rrrgrgs F$F 68H7L;-/L<"JKLOO? :H5K ;  -, > 12,2& 1MJrrgc*\rSrSrSrSrSrSrSrg)ExcessivelyLargeLineCatcheriz Helper for L{LineReceiverLineLengthExceededTests}. @ivar longLines: A L{list} of L{bytes} giving the values C{lineLengthExceeded} has been called with. c/Ulgr longLinesrs rr@*ExcessivelyLargeLineCatcher.connectionMades rcg)z Disregard any received lines. Nr4r"s rr$(ExcessivelyLargeLineCatcher.lineReceivedsrc:URRU5 g)z6 Record any data that exceeds the line length limits. N)rr r)s rr\.ExcessivelyLargeLineCatcher.lineLengthExceededs d#rrN) r-r.r/r0r1r@r$r\r3r4rrrrs $rrcB\rSrSrSrSrSrSrSrSr Sr S r S r g ) #LineReceiverLineLengthExceededTestsizG Tests for L{twisted.protocols.basic.LineReceiver.lineLengthExceeded}. c[5UlSURl[R"5UlURR UR 5 g)N)rrr[rrrQrprs rsetUp)LineReceiverLineLengthExceededTests.setUps>02 ! &668 !!$..1rcSURRS-S--nURRU5 URU/URR5 g)z If more bytes than C{LineReceiver.MAX_LENGTH} arrive containing no line delimiter, all of the bytes are passed as a single string to L{LineReceiver.lineLengthExceeded}. rN)rr[rsrtrr excessives rtest_longUnendedLine8LineReceiverLineLengthExceededTests.test_longUnendedLinesP DJJ11A59:   * )djj&:&:;rcSURRS-S--nURRSURR-U-5 UR U/URR 5 g)a If L{LineReceiver.dataReceived} is called with bytes representing a short line followed by bytes that exceed the length limit without a line delimiter, L{LineReceiver.lineLengthExceeded} is called with all of the bytes following the short line's delimiter. rrN)rr[rsr2rtrrs rtest_longLineAfterShortLine?LineReceiverLineLengthExceededTests.test_longLineAfterShortLinesdDJJ11A59:  tzz';'; ;i GH )djj&:&:;rcURRRSURRS-S--/S-5nURR U5 UR U/URR 5 g)z If L{LineReceiver.dataReceived} is called with more than C{LineReceiver.MAX_LENGTH} bytes containing a line delimiter somewhere not in the first C{MAX_LENGTH} bytes, the entire byte string is passed to L{LineReceiver.lineLengthExceeded}. rrN)rr2rr[rsrtrrs rtest_longLineWithDelimiter>LineReceiverLineLengthExceededTests.test_longLineWithDelimitersrJJ((-- TZZ**Q.2 3 4q 8   * )djj&:&:;rcSURRS-S--URR-S-nURRU5 UR U/URR 5 g)z If L{LineReceiver.dataReceived} is called with more than C{LineReceiver.MAX_LENGTH} bytes containing multiple line delimiters somewhere not in the first C{MAX_LENGTH} bytes, the entire byte string is passed to L{LineReceiver.lineLengthExceeded}. rrN)rr[r2rsrtrrs rtest_multipleLongLines:LineReceiverLineLengthExceededTests.test_multipleLongLinesseTZZ22Q6:;djj>R>RRVWW   * )djj&:&:;rc[R"5n[R"5nUR U5 UR SUR S--S-5 URUR5 grrrs rr:LineReceiverLineLengthExceededTests.test_maximumLineLengthrrc[R"5n[R"5nUR U5 UR SUR [UR5--5 URUR5 g)zm C{LineReceiver} disconnects the transport it if receives a non-finished line longer than its C{MAX_LENGTH}. rN) r rrrrprsr[rWr2rrrs rtest_maximumLineLengthRemainingCLineReceiverLineLengthExceededTests.test_maximumLineLengthRemainingsg ""$!113  Y' 45#3#3c%//6J#JKL  //0r)rrQN) r-r.r/r0r1rrrrrrrr3r4rrrrs*2 < < < < 1 1rrc.\rSrSrSrSrSrSrSrSr g) LineOnlyReceiverTestsiz8 Tests for L{twisted.protocols.basic.LineOnlyReceiver}. s7foo bleakness desolation plastic forks c.[R"5n[5nURU5 [ UR 5HnUR U5 M URURUR RS5SS5 g)zG Test buffering over line protocol: data received should match buffer. rNrV) rrr_rpr rrrsrtr?split)rrxrycs rr|!LineOnlyReceiverTests.test_buffersq  ) ) +   4;;'A NN1 ( T[[%6%6u%=cr%BCrc[5n[R"5nURU5 UR SUR [ UR5-S--S-5 URUR5 g)zu C{LineOnlyReceiver} disconnects the transport if it receives a line longer than its C{MAX_LENGTH} + len(delimiter). rr'rN) r_rrrprsr[rWr2rrrs r!test_greaterThanMaximumLineLength7LineOnlyReceiverTests.test_greaterThanMaximumLineLengthsp  !113  Y'  E$$s5??';;a? @8 K   //0rcp[R"5nUR[URS5 g)zr When L{LineOnlyReceiver.lineReceived} is not overridden in a subclass, calling it raises C{NotImplementedError}. rN)r LineOnlyReceiverrrr$rs rr5LineOnlyReceiverTests.test_lineReceivedNotImplementeds+ &&( -u/A/A5Irr4N) r-r.r/r0r1rrr|rrr3r4rrrrsF D 1Jrrc@\rSrSrSrSrSrSr\4S\ SS4S jjr S r g) TestMixinic/Ulgrr>rs rr@TestMixin.connectionMades  rc:URRU5 grrdrr{s rstringReceivedTestMixin.stringReceiveds Qrr7rreasonreturnNcSUlg)Nr')closed)rr s rconnectionLostTestMixin.connectionLost#s  r)rr?) r-r.r/r0r@r r[rr rrr3r4rrrrs3 J F/=W$rrc\rSrSrSrSrg) TestNetstringi'cpURRU5 URRU5 gr)r?r rQwriter s rr TestNetstring.stringReceived(s& Q Qrr4N)r-r.r/r0r r3r4rrrr's rrcJ\rSrSr%/r\\\\S'Sr S\S'Sr Sr Sr g) LPTestCaseMixini-illegalStringsN!Optional[Type[protocol.Protocol]]rcr[R"5nUR5nURU5 U$)zl Return a new instance of C{self.protocol} connected to a new instance of L{proto_helpers.StringTransport}. )rrrrp)rrxrys r getProtocolLPTestCaseMixin.getProtocol1s0  ) ) + MMO rcURH[nUR5n[U5HnURU5 M UR UR R 5 M] g)z? Assert that illegal strings cause the transport to be closed. N)rrr rsrrQrrr{rrs r test_illegalLPTestCaseMixin.test_illegal;sR$$A  "Aq\q!" OOAKK55 6 %rr4) r-r.r/r0rrrbytes__annotations__rrr!r3r4rrrr-s*,.NHT%[).48H187rrc\rSrSrSr/SQr/SQr\rSr Sr Sr Sr S r S rS rS rS rSrSrSrSrSrSrSrSrSrSrSrSrSrSrg)NetstringReceiverTestsiFz9 Tests for L{twisted.protocols.basic.NetstringReceiver}. )helloworldshowsaresyou123s:todaysaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa)s9999999999999999999999sabcs4:abcdes751:aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaab,c[R"5Ul[5UlURR UR5 gr)rrrQrnetstringReceiverrprs rrNetstringReceiverTests.setUpVs4&668!. --dnn=rc[SS5Hn[R"5n[5nSUlUR U5 UR HnURU5 M UR5n[[U5U-S-5H*nXVU-US-U-nU(dMURU5 M, URURUR 5 M g)z9 Strings can be received in chunks of different lengths. r'rmiN) rnrrrr[rpstrings sendStringvaluerWrsrtr?)rrwrxryr{outrzs rr|"NetstringReceiverTests.test_buffer[s!B 7$ABCE666666CKC H 6JJ    Lrr&c\rSrSr%SrSrS\S'Sr\\ \ \S'Sr \\ \ \S'Sr \\ \ \S'S r S rS rS rS rSrSrg)IntNTestCaseMixiniz, TestCase mixin for int-prefixed protocols. Nrrr-rpartialStringsc 2UR5nURHQn[[R"UR [ U55U-5HnURU5 M MS URURUR5 g)z. Test receiving data find the same data send. N) rr-r structpack structFormatrWrsrtr?)rr r{rs r test_receiveIntNTestCaseMixin.test_receive(sn    Av{{1>>3q6BQFGq!H T\\2rcURHRnUR5n[U5HnURU5 M UR UR /5 MT g)z; Send partial data, nothing should be definitely received. N)rrr rsrtr?rs r test_partialIntNTestCaseMixin.test_partial2sP$$A  "Aq\q!"   QZZ , %rcUR5nURS5 URURR 5[ R "URS5S-5 g)z" Test sending data over protocol. bbbbbbbbbbbbbbbbN)rr.rtrQr/rrrrr s r test_sendIntNTestCaseMixin.test_send<sR     Y  KK   Q^^R!@9!L rc/nUR5nURUlSUlUR [ R "URS55 URUS/5 g)z When a length prefix is received which is greater than the protocol's C{MAX_LENGTH} attribute, the C{lengthLimitExceeded} method is called with the received length prefix. rmr{N) rr lengthLimitExceededr[rsrrrrt)rrOr s rtest_lengthLimitExceeded*IntNTestCaseMixin.test_lengthLimitExceededFsW      &   v{{1>>267 "&rcUR5nSUlUR[R"UR S5S-5 UR UR/5 g)z If a length prefix for a string longer than C{MAX_LENGTH} is delivered to C{dataReceived} at the same time as the entire string, the string is not passed to C{stringReceived}. rmr{s xxxxxxxxxxxN)rr[rsrrrrtr?rs rtest_longStringNotDelivered-IntNTestCaseMixin.test_longStringNotDeliveredSsM      v{{1>>26BC R(rcp[R"5nUR[URS5 g)zv When L{IntNStringReceiver.stringReceived} is not overridden in a subclass, calling it raises C{NotImplementedError}. rN)r IntNStringReceiverrrr rs rr3IntNTestCaseMixin.test_stringReceivedNotImplemented^s+ ((* -u/C/CUKrr4)r-r.r/r0r1rr$r-rrr#rrrrrrrrr3r4rrrrsl59H18%)GXd5k "),0NHT%[)0,0NHT%[)03-  ' )Lrrc6\rSrSrSrSrSrSrSrSr Sr g ) RecvdAttributeMixinigz Mixin defining tests for string receiving protocols with a C{recvd} attribute which should be settable by application code, to be combined with L{IntNTestCaseMixin} on a L{TestCase} subclass c\[R"UR[U55U-$)zO Return C{data} prefixed with message length in C{protocol.structFormat} form. )rrrrW)rrr*s r makeMessageRecvdAttributeMixin.makeMessagens$ {{800#d)TRTR5 grr recvd)receivedStringr results rr KRecvdAttributeMixin.test_recvdContainsRemainingData..stringReceived}s MM!'' "raaaaasbbbbN)rr rrrrsrt)rr completeMessageincompleteMessager rs @@rtest_recvdContainsRemainingData3RecvdAttributeMixin.test_recvdContainsRemainingDataus}      #* ++anna8HE"KK:hG :; "3!45rc^^^ UR5m/m SnURTU5mUUU 4SjnUTlSnSnURTU5nURTU5nTRXV-5 UR T X1/5 g)zr In stringReceived, if recvd is changed, messages should be parsed from it rather than the input to dataReceived. sccccccD>T(dTTlTRU5 gr)rr )rmessageCr rs rr =RecvdAttributeMixin.test_recvdChanged..stringReceiveds" MM. )rrsbbbbbN)rrr rsrt) rpayloadCr payloadApayloadBmessageAmessageBrr rs @@@rtest_recvdChanged%RecvdAttributeMixin.test_recvdChangeds    ##Ax0 * *##Ax0##Ax0 x*+ (!56rc^^^UR5m/nSmURH5nURURTU55 URT5 M7 /mUUU4SjnUTlTR SR U55 TR S5 URTUR5 URTRS5 g)z Data already parsed by L{IntNStringReceiver.dataReceived} is not reparsed if C{stringReceived} consumes some of the L{IntNStringReceiver.recvd} buffer. scb>TRU5 TR[T5STlgr)r rrW)rSWITCHrrs rr :RecvdAttributeMixin.test_switching..stringReceiveds% MM. )++c&km4EKrrN) rr-r rr rsrrtr)rmixr{r rrrs @@@rtest_switching"RecvdAttributeMixin.test_switchings   "$A JJt''q1 2 JJv  5 . 388C=) 7# . g.rc^^UR5mSn[U5S- TlURTU5n/mUU4SjnUTlTR U5 UR TS[U55 UR TSU5 g)z The L{IntNStringReceiver.recvd} buffer contains all data not yet processed by L{IntNStringReceiver.dataReceived} if the C{lengthLimitExceeded} event occurs. stoo longr'c^>TRU5 TRTR5 grr)rOrrs rrPRecvdAttributeMixin.test_recvdInLengthLimitExceeded..lengthLimitExceededs MM& ! MM%++ &rrN)rrWr[rrrsrt)rDATAmessagerrrs @@rtest_recvdInLengthLimitExceeded3RecvdAttributeMixin.test_recvdInLengthLimitExceededs   "t9q=""5$/ '%8! 7# CI. G,rr4N) r-r.r/r0r1rrrrrr3r4rrrrgs! D6$7./8-rrc\rSrSrSrSrg) TestInt32izw A L{basic.Int32StringReceiver} storing received strings in an array. @ivar received: array holding received strings. r4Nr-r.r/r0r1r3r4rrrrrrc8\rSrSrSr\rSS/rS/r/SQr Sr Sr g ) Int32Testsiz' Test case for int32-prefixed protocol rkrs aaaaaa)s hello therercUR5nURS5 URURR 5S5 UR S5 URUR S/5 g)z/ Test specific behavior of the 32-bits length. rsfoosubarubarNrr.rtrQr/rsr?rs r test_dataInt32Tests.test_datas_     V **,.DE ./ gY/rr4N) r-r.r/r0r1rrr-rrrr3r4rrrrs*HYG/0N;N0rrc\rSrSrSrSrg) TestInt16izw A L{basic.Int16StringReceiver} storing received strings in an array. @ivar received: array holding received strings. r4Nrr4rrrrrrrc>\rSrSrSr\rSS/rS/r/SQr Sr Sr S r g ) Int16Testsiz' Test case for int16-prefixed protocol rkrsaaaaaa)rrcUR5nURS5 URURR 5S5 UR S5 URUR S/5 g)z/ Test specific behavior of the 16-bits length. rsfoosubarrNrrs rrInt16Tests.test_datas]     V **,n= ' gY/rcUR5nSSURS--S--nUR[URU5 gz1 Send too much data: that should cause an error. rdrr'Nr prefixLengthrAssertionErrorr.rr tooSends rtest_tooLongSendInt16Tests.test_tooLongSend E    ! 23a78 .!,,@rr4N) r-r.r/r0r1rrr-rrrrr3r4rrrrs0HYG'(N3N0Arrc\rSrSrSrSrg)TestInt8izv A L{basic.Int8StringReceiver} storing received strings in an array. @ivar received: array holding received strings. r4Nrr4rrrrrrrc>\rSrSrSr\rSS/rS/r/SQr Sr Sr S r g ) Int8Testsiz& Test case for int8-prefixed protocol rkrsaaaaaa)sdzadzrcUR5nURS5 URURR 5S5 UR S5 URUR S/5 g)z. Test specific behavior of the 8-bits length. rsfoosubarrNrrs rrInt8Tests.test_data%s]     V **,j9 {# gY/rcUR5nSSURS--S--nUR[URU5 grrrs rrInt8Tests.test_tooLongSend/rrr4N) r-r.r/r0r1rrr-rrrrr3r4rrrrs0HYG'(N-N0Arrc8\rSrSrSrSrSrSrSrSr Sr Sr g ) OnlyProducerTransporti8za Transport which isn't really a transport, just looks like one to someone not looking very hard. Fc/Ulgrrrs rrOnlyProducerTransport.__init__As  rcSUlg)NTpausedrs rrJ$OnlyProducerTransport.pauseProducingDs  rcSUlg)NFrrs rrL%OnlyProducerTransport.resumeProducingGs  rc:URRU5 gr)r*r )rr#s rrOnlyProducerTransport.writeJs r)r*rN) r-r.r/r0r1rrrrJrLrr3r4rrrr8s' FM rrc\rSrSrSrSrSrg)ConsumingProtocoliNz; Protocol that really, really doesn't want any more bytes. cZURRU5 UR5 gr)rQrrJr"s rr$ConsumingProtocol.lineReceivedSs  T" rr4N)r-r.r/r0r1r$r3r4rrrrNs rrc\rSrSrSrSrSrg) ProducerTestsiXzE Tests for L{basic._PausableMixin} and L{basic.LineReceiver.paused}. c[5n[5nURU5 URS5 UR UR /5 UR UR5 UR UR5 URS5 UR UR S/5 URUR5 URUR5 UR5 UR UR S/5 UR UR5 UR UR5 URS5 UR UR SS/5 URUR5 URUR5 UR5 UR UR /SQ5 URUR5 URUR5 URS5 UR UR /SQ5 URUR5 URUR5 UR5 UR UR /SQ5 URUR5 URUR5 UR5 UR UR /SQ5 UR UR5 UR UR5 g ) a When L{basic.LineReceiver} is paused, it doesn't deliver lines to L{basic.LineReceiver.lineReceived} and delivers them immediately upon being resumed. L{ConsumingProtocol} is a L{LineReceiver} that pauses itself after every line, and writes that line to its transport. shello, sworld hello, worldshello world r')r r'r(s goodbye )r r'r(rN) rrrprsrtr*rrrrL)rprxs rtest_pauseResumeProducerTests.test_pauseResume]sN   ! #  z" $ " " |$ /!23 ! !  /!23 " " ,- /8!<= ! !  !FG ! ! ~& !FG ! !  !RS ! !  !RS " "rr4N)r-r.r/r0r1r r3r4rrrrXs A#rrc<\rSrSrSrSrSrSrSrSr Sr S r g ) FileSenderTestsiz Tests for L{basic.FileSender}. cl[R"5nUR[[U55 g)z@ L{basic.FileSender} implements the L{IPullProducer} interface. N)r FileSenderrrr )rsenders rtest_interfaceFileSenderTests.test_interfaces%!!#  Y78rc[S5n[R"5n[R"5nUR X5 UR URU5 URUR5 g)z When L{basic.FileSender.beginFileTransfer} is called, it registers itself with provided consumer, as a non-streaming producer. Test contentN) rrrr rbeginFileTransferrtproducerr streaming)rsourceconsumerrs rtest_producerRegistered'FileSenderTests.test_producerRegisteredsb ) 002!!#  2 **F3 ++,rc[S5n[R"5n[R"5nUR X5nUR 5 UR 5 URUR5 URSURU55 URSUR55 g)z L{basic.FileSender} sends the content of the given file using a C{IConsumer} interface via C{beginFileTransfer}. It returns a L{Deferred} which fires with the last byte sent. rtN) rrrr rrrL assertIsNonerrtsuccessResultOfr/rrrrds r test_transferFileSenderTests.test_transfers ) 002!!#  $ $V 6   (++, t33A67 (..*:;rc`[S5n[R"5n[R"5nSUlUR X5nUR5 URSUR55 UR5 URSUR55 UR5 URSUR55 UR5 URSURU55 URSUR55 g)zR L{basic.FileSender} reads at most C{CHUNK_SIZE} every time it resumes producing. rrGsTestsTest conrN) rrrr r CHUNK_SIZErrLrtr/r r!s rtest_transferMultipleChunks+FileSenderTests.test_transferMultipleChunkss ) 002!!#  $ $V 6  (.."23  hnn&67  (..*:;  t33A67 (..*:;rcZSn[S5n[R"5n[R"5nUR X#U5nUR 5 UR 5 URSURU55 URSUR55 g)zu L{basic.FileSender.beginFileTransfer} takes a C{transform} argument which allows to manipulate the data on the fly. c"UR5$r)swapcase)chunks r transform=FileSenderTests.test_transferWithTransform..transforms>># #rrTs tEST CONTENTN) rrrr rrrLrtr r/)rr-rrrr"s rtest_transferWithTransform*FileSenderTests.test_transferWithTransforms  $) 002!!#  $ $Vy A   t33A67 (..*:;rcF[S5n[R"5n[R"5nUR X5nUR 5 URU5nUR[5 URS[UR55 g)z The C{Deferred} returned by L{basic.FileSender.beginFileTransfer} fails with an C{Exception} if C{stopProducing} when the transfer is not complete. rz#Consumer asked us to stop producingN) rrrr rrrMfailureResultOftrap Exceptionrtstrr/)rrrrr"failures rtest_abortedTransfer$FileSenderTests.test_abortedTransfers| ) 002!!#  $ $V 6&&q) Y >GMM@RSrr4N) r-r.r/r0r1rrr#r'r0r8r3r4rrrrs&9 -<$<.<(Trr);r1rriortypingrrrzope.interface.verifyrtwisted.internetrr twisted.internet.interfacesr twisted.internet.protocolr twisted.protocolsr twisted.python.compatr twisted.python.failurer twisted.testr twisted.trialrrrr6rr_SynchronousTestCasergrrrrrrrr&rrInt32StringReceiverrrInt16StringReceiverrrInt8StringReceiverrrrrrTestCaserr4rrrJs  ''.+14#+*&"#++#0E:##E:P#U++#*uJ44uJp$%"4"4$.L1(*F*FL1^)JH88)JX   Iu66 772ULX99?ULpFLFLRg-g-T 5440--/@BU0* 544A--/@BUA:y%22A,,.?ATA:  ,**F#H00F#RdTh''dTr