+ DfjRt^RIt^RIt^RIHt^RIHtHtHt^RI H t ^RI H t H t ^RIHt^RIHt^RIHt^R IHt^R IHt^R IHt^R IHt!R R]P84t!RR]P84t!RR]P>4t !RR]PB4t"!RR]P84t#!RR]PB4t$!RR]PB4t%!RR4t&!RR]&]PN4t(!RR 4t)!R!R"]PB])4t*!R#R$])4t+!R%R&4t,!R'R(]&]PZ4t.!R)R*]PB]+],4t/!R+R,]&]P`4t1!R-R.]PB]+],4t2!R/R0]&]Pf4t4!R1R2]PB]+],4t5!R3R44t6!R5R6]P84t7!R7R8]PB4t8!R9R:]Pr4t:R#);z, Test cases for L{twisted.protocols.basic}. N)BytesIO)ListOptionalType) verifyObject)protocoltask) IProducer)connectionDone)basic) iterbytesFailure) proto_helpers)unittestc:a]tRt^toRtRtRtRtRtRt Vt R#)FlippingLineTesterzL A line receiver that flips between line and raw data modes after one byte.  c.VnR#Nlinesselfs&C/usr/lib/python3/dist-packages/twisted/protocols/test/test_basic.py__init__FlippingLineTester.__init__!s  c \VPPV4VP4R#)z Set the mode to raw. N)rappend setRawModerlines&&r lineReceivedFlippingLineTester.lineReceived$s  $ rc 6VPVR,4R#)z Set the mode back to line. :NNN) setLineModerdatas&&rrawDataReceived"FlippingLineTester.rawDataReceived+s b"rrN) __name__ __module__ __qualname____firstlineno____doc__ delimiterrr#r*__static_attributes____classdictcell__ __classdict__s@rrrs%I##rrcNa]tRt^2toRtRt^@tR RltRtRt Rt Rt R t Vt R#) LineTestera A line receiver that parses data received and make actions on some tokens. @type delimiter: C{bytes} @ivar delimiter: character used between received lines. @type MAX_LENGTH: C{int} @ivar MAX_LENGTH: size of a line when C{lineLengthExceeded} will be called. @type clock: L{twisted.internet.task.Clock} @ivar clock: clock simulating reactor callLater. Pass it to constructor if you want to use the pause/rawpause functionalities. rNc WnR#)z0 If given, use a clock to make callLater calls. N)clock)rr9s&&rrLineTester.__init__Bs  rc .VnR#z+ Create/clean data received on connection. Nreceivedrs&rconnectionMadeLineTester.connectionMadeH  rc VPPV4VR8XdVP4R #VR8Xd9VP4VPP ^VP 4R #VR8XddVP4VP4VPPR4VPP ^VP 4R #VR8XdVP4R #VR,R8Xd\VR,4Vn R #VPR4'dVPPVR 4R #VPR 4'dVPP4R #R #) zd Receive line and make some action for some tokens: pause, rawpause, stop, len, produce, unproduce. rpauserawpausestop:NNslen :rFNNproduceF unproduceN)r>rr pauseProducingr9 callLaterresumeProducing stopProducingintlength startswith transportregisterProducerunregisterProducerr!s&&rr#LineTester.lineReceivedNs T" 3; OO  X     ! JJ D$8$8 9 [    ! OO  MM  % JJ D$8$8 9 W_    "X d2h-DK __Z ( ( NN + +D% 8 __\ * * NN - - /+rc VRVPWPRr!VP\V4, VnVPR,V,VPR&VP^8XdVPV4R#R#)zR Read raw data, until the quantity specified by a previous 'len' line is reached. N)rNlenr>r')rr)rests&& rr*LineTester.rawDataReceivedgsn -DKK(${{}*=dkkCI-  MM"-4 b ;;!    T " rc \V4VP^,8d'VPWP^,R4R#R#)z, Adjust line mode when long lines received. N)rV MAX_LENGTHr'r!s&&rlineLengthExceededLineTester.lineLengthExceededrs; t9t* *   T//A"5"78 9 +r)r9rNr>r)r,r-r.r/r0r1rZrr?r#r*r[r2r3r4s@rr7r72s4 IJ  02 #::rr7c8a]tRt^ztoRtRt^@tRtRtRt Vt R#)LineOnlyTesterz! A buffering line only receiver. rc .VnR#r<r=rs&rr?LineOnlyTester.connectionMaderArc <VPPV4R#)z Save received data. Nr>rr!s&&rr#LineOnlyTester.lineReceiveds T"rr=N) r,r-r.r/r0r1rZr?r#r2r3r4s@rr^r^zs%IJ ##rr^ca]tRt^toRtRt.ROtRtRt.ROt ] R.,t Rt Rt .ROt .ROtRtR t.ROtR tR tR tR tRtRtRtRtRtRtRtVtR#)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 ac \^^ 4Fp\P!4p\4pVP \ P !V44\\VP4V,^,4F7pVPWA,V^,V,pVPV4K9 VPVPVP4K R#)zT Test buffering for different packet size, checking received matches expected data. N) rangerStringIOWithoutClosingr7makeConnectionr FileWrapperrVbuffer dataReceived assertEqualoutputr>r packet_sizetaiss& r test_bufferLineReceiverTests.test_buffers !B?KK1q5K2GHq!@   T[[!** 5(rs!twiddle1 twiddle2 pause twiddle3 twiddle3c l\^^ 4EF"p\P!4p\P!4p\ V4pVP \P!V44\\VP4V,^,4F7pVPWQ,V^,V,pVPV4K9 VPVPVP4VP^4VPVP VP4EK% R#)zW Test pause inside data receiving. It uses fake clock to see if pausing/resuming work. N)rgrrhrClockr7rirrjrVpauseBufrlrm pauseOutput1r>advance pauseOutput2rrprqr9rrrsrts& r test_pausingLineReceiverTests.test_pausings !Br|rawpauseOutput2r~s& rtest_rawPausing!LineReceiverTests.test_rawPausings!B MM!    T111:: >(rs"twiddle1 twiddle2 stop more stuff c \^^ 4Fp\P!4p\4pVP \ P !V44\\VP4V,^,4F7pVPWA,V^,V,pVPV4K9 VPVPVP4K R#)z Test stop inside producing. N) rgrrhr7rirrjrVstop_bufrlrm stop_outputr>ros& rtest_stopProducing$LineReceiverTests.test_stopProducings!B)rrrrqs& rtest_lineReceiverAsProducer-LineReceiverTests.test_lineReceiverAsProducersW L  0 0 2 --a01 DE  JJN rc n!RR\P4pV!4pVP!R4VPVPR4VPVP R4VP!R4VPVPR4VPVP R4R #) z L{LineReceiver.clearLineBuffer} removes all buffered data and returns it as a C{bytes} and can be called from beneath C{dataReceived}. c&a]tRtRtoRtRtVtR#)@LineReceiverTests.test_clearLineBuffer..ClearingReceiveric<WnVP4VnR#r)r"clearLineBufferrWr!s&&rr#MLineReceiverTests.test_clearLineBuffer..ClearingReceiver.lineReceiveds  002 r)r"rWN)r,r-r.r/r#r2r3r4s@rClearingReceiverrs 3 3rrs foo bar bazfoosbar bazsquux squuxrN)r LineReceiverrlrmr"rW)rrrs& rtest_clearLineBuffer&LineReceiverTests.test_clearLineBuffers  3u11 3 $%23 /  6 k* 0 ,rc L\4p\P!4pVP\P !V44\ P!4pVPRV,4VPRV,RPVP44R#)z3 Test switching modes many times on the same data. sx xxrN) rrrhrirrjsysgetrecursionlimitrlrmjoinr)rprotorPlimits& rtest_stackRecursion%LineReceiverTests.test_stackRecursion*st#$!88:  X11)<=%%' 7U?+ sxx '<=rc \P!4p\P!4pVP V4VP RVP ^,,R,4VPVP4R#z` C{LineReceiver} disconnects the transport if it receives a line longer than its C{MAX_LENGTH}. r rN r rrStringTransportrirlrZ assertTrue disconnectingrrrPs& rtest_maximumLineLength(LineReceiverTests.test_maximumLineLength5c ""$!113  Y' 45#3#3a#788CD  //0rc \4p^Vn\P!4pVP V4RVP^, ,pVP V4VP VP RR4VP VP RRV,4VPVP4VP\VP4^4VPW1P^,4R#)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). rNrU) r7rZrrrirlr1 assertFalserrmrVr>)rrrqr"s& r&test_maximumLineLengthPartialDelimiter8LineReceiverTests.test_maximumLineLengthPartialDelimiter@s   ) ) + Qu''!+, 4  5??3B/0 5??23/$67 ) U^^,a0 ~~a01rc `\P!4pRVn\P!4pVP V4VP RVP,VPR\VP4^, ,4VPVP4R#)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 rN) r rr1rrrirlrZrVrrrs& r(test_notQuiteMaximumLineLengthUnfinished:LineReceiverTests.test_notQuiteMaximumLineLengthUnfinishedVs""$"!113  Y'  E$$ $8R#eoo:NQR:R(S S  001rc \P!4pRVn\P!4pVP V4VP 4VPR4pVPV\4R#)zN C{LineReceiver.dataReceived} forwards errors returned by C{rawDataReceived}. c\R4#)oops) RuntimeErrorr)s&r5LineReceiverTests.test_rawDataError..os \&-ArsdataN) r rr*rrrir rlassertIsInstancer)rrrPwhys& rtest_rawDataError#LineReceiverTests.test_rawDataErrorisb ""$ A!113  Y'   ) c<0rc r\P!4pVP\VPR4R#)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/DeLrc r\P!4pVP\VPR4R#)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/A5IrN) slen 10 0123456789len 5s1234 slen 20sfoo 123s0123456789 012345678slen 0sfoo 5rs67890slen 1a)twiddle1twiddle2rC)rrrrDr)rrrrDs12345rw)rrrE)r,r-r.r/r0rkrnrurzr{r}rrrrrrrrrrrrrrrrrr2r3r4s@rreres F$F 68H7L;-/L<"JKLOO? :H5K ;  -, > 12,2& 1MJJrrec6a]tRtRtoRtRtRtRtRtVt R#)ExcessivelyLargeLineCatcheriz Helper for L{LineReceiverLineLengthExceededTests}. @ivar longLines: A L{list} of L{bytes} giving the values C{lineLengthExceeded} has been called with. c.VnR#r longLinesrs&rr?*ExcessivelyLargeLineCatcher.connectionMades rc R#)z Disregard any received lines. Nrr!s&&rr#(ExcessivelyLargeLineCatcher.lineReceivedsrc <VPPV4R#)z6 Record any data that exceeds the line length limits. N)rrr(s&&rr[.ExcessivelyLargeLineCatcher.lineLengthExceededs d#rrN) r,r-r.r/r0r?r#r[r2r3r4s@rrrs $$rrcNa]tRtRtoRtRtRtRtRtRt Rt R t R t Vt R #) #LineReceiverLineLengthExceededTestsizG Tests for L{twisted.protocols.basic.LineReceiver.lineLengthExceeded}. c\4Vn^VPn\P!4VnVPP VP 4R#)N)rrrZrrrPrirs&rsetUp)LineReceiverLineLengthExceededTests.setUps>02 ! &668 !!$..1rc RVPP^,^,,pVPPV4VPV.VPP4R#)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)rrZrlrmrr excessives& rtest_longUnendedLine8LineReceiverLineLengthExceededTests.test_longUnendedLinesP DJJ11A59:   * )djj&:&:;rc $RVPP^,^,,pVPPRVPP,V,4VP V.VPP 4R#)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. rN)rrZrlr1rmrrs& rtest_longLineAfterShortLine?LineReceiverLineLengthExceededTests.test_longLineAfterShortLinesdDJJ11A59:  tzz';'; ;i GH )djj&:&:;rc 6VPPPRVPP^,^,,.^,4pVPP V4VP V.VPP 4R#)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}. rN)rr1rrZrlrmrrs& rtest_longLineWithDelimiter>LineReceiverLineLengthExceededTests.test_longLineWithDelimitersrJJ((-- TZZ**Q.2 3 4q 8   * )djj&:&:;rc $RVPP^,^,,VPP,^,pVPPV4VP V.VPP 4R#)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}. rN)rrZr1rlrmrrs& rtest_multipleLongLines:LineReceiverLineLengthExceededTests.test_multipleLongLinesseTZZ22Q6:;djj>R>RRVWW   * )djj&:&:;rc \P!4p\P!4pVP V4VP RVP ^,,R,4VPVP4R#rrrs& rr:LineReceiverLineLengthExceededTests.test_maximumLineLengthrrc *\P!4p\P!4pVP V4VP RVP \VP4,,4VPVP4R#)zm C{LineReceiver} disconnects the transport it if receives a non-finished line longer than its C{MAX_LENGTH}. rN) r rrrrirlrZrVr1rrrs& rtest_maximumLineLengthRemainingCLineReceiverLineLengthExceededTests.test_maximumLineLengthRemainingsg ""$!113  Y' 45#3#3c%//6J#JKL  //0r)rrPN)r,r-r.r/r0rrrrrrrr2r3r4s@rrrs22 < < < < 1 1 1rrc:a]tRtRtoRtRtRtRtRtRt Vt R#) LineOnlyReceiverTestsiz8 Tests for L{twisted.protocols.basic.LineOnlyReceiver}. s7foo bleakness desolation plastic forks c 0\P!4p\4pVPV4\ VP 4FpVP V4K VPVPVP PR4RR4R#)zG Test buffering over line protocol: data received should match buffer. rNrU) rrr^rir rkrlrmr>split)rrqrrcs& rru!LineOnlyReceiverTests.test_buffersq  ) ) +   4;;'A NN1 ( T[[%6%6u%=cr%BCrc 0\4p\P!4pVPV4VP RVP \ VP4,^,,R,4VPVP4R#)zu C{LineOnlyReceiver} disconnects the transport if it receives a line longer than its C{MAX_LENGTH} + len(delimiter). rrN) r^rrrirlrZrVr1rrrs& r!test_greaterThanMaximumLineLength7LineOnlyReceiverTests.test_greaterThanMaximumLineLengthsp  !113  Y'  E$$s5??';;a? @8 K   //0rc r\P!4pVP\VPR4R#)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/A5IrrN) r,r-r.r/r0rkrurrr2r3r4s@rrrs(F D 1JJrrcLa]tRtRtoRtRt^2t^t]3V3RlRllt Rt Vt R#) TestMixinic.VnR#rr=rs&rr?TestMixin.connectionMades  rc<VPPV4R#rrbrrts&&rstringReceivedTestMixin.stringReceiveds Qrc$<V^8dQhRS[RR/#)reasonreturnNr )formatr5s"r __annotate__TestMixin.__annotate__#sW$rc^VnR#)r&N)closed)rr s&&rconnectionLostTestMixin.connectionLost#s  r)rr>N) r,r-r.r/r?rrZrr rr2r3r4s@rrrs- J F/=rrc&a]tRtRtoRtRtVtR#) TestNetstringi'crVPPV4VPPV4R#r)r>rrPwriters&&rrTestNetstring.stringReceived(s& Q QrrN)r,r-r.r/rr2r3r4s@rrr's  rrc@a]tRtRto.tRtRtRtV3RltRt Vt R#)LPTestCaseMixini-Nc r\P!4pVP4pVPV4V#)zl Return a new instance of C{self.protocol} connected to a new instance of L{proto_helpers.StringTransport}. )rrrri)rrqrrs& r getProtocolLPTestCaseMixin.getProtocol1s0  ) ) + MMO rc VPF[pVP4p\V4FpVPV4K VP VP P 4K] R#)z? Assert that illegal strings cause the transport to be closed. N)illegalStringsrr rlrrPrrrtrrs& r test_illegalLPTestCaseMixin.test_illegal;sR$$A  "Aq\q!" OOAKK55 6 %rcP<V^8dQh/S[S[S[,,;R&R;R&#)r r!Optional[Type[protocol.Protocol]]rrrbytes)r r5s"rr LPTestCaseMixin.__annotate__-s$T%[).18rr) r,r-r.r/rrrr!__annotate_func__r2r3r4s@rrr-s ,.N48H7rrca]tRtRtoRt.ROt.ROt]tRt Rt Rt Rt Rt RtR tR tR tR tR tRtRtRtRtRtRtRtRtRtRtRtRtVt R#)NetstringReceiverTestsiFz9 Tests for L{twisted.protocols.basic.NetstringReceiver}. c\P!4Vn\4VnVPP VP4R#r)rrrPrnetstringReceiverrirs&rrNetstringReceiverTests.setUpVs4&668!. --dnn=rc \^^ 4Fp\P!4p\4pRVnVP V4VP FpVPV4K VP4p\\V4V,^,4F7pWVV,V^,V,pV'gK&VPV4K9 VPVPVP 4K R#)z9 Strings can be received in chunks of different lengths. iN) rgrrrrZristrings sendStringvaluerVrlrmr>)rrprqrrrtoutrss& rru"NetstringReceiverTests.test_buffer[s!Brs&rtest_receiveEmptyNetstring1NetstringReceiverTests.test_receiveEmptyNetstringms6 ++F3 //883%@rc VPPR4VPVPPR.4R#)z+ One-character netstrings can be received. 1:a,rNr5rs&rtest_receiveOneCharacter/NetstringReceiverTests.test_receiveOneCharacterts6 ++G4 //884&Arc VPPR4VPVPPR.4R#)z+ Two-character netstrings can be received. s2:ab,abNr5rs&rtest_receiveTwoCharacters0NetstringReceiverTests.test_receiveTwoCharacters{s6 ++H5 //885'Brc VPPR4VPVPPR.4R#)z Netstrings with embedded netstrings. This test makes sure that the parser does not become confused about the ',' and ':' characters appearing inside the data portion of the netstring. s4:1:a,,r9Nr5rs&rtest_receiveNestedNetstring2NetstringReceiverTests.test_receiveNestedNetstrings6 ++J7 //887)Drc VPPR4VPVPP4R#)z< Netstrings containing more data than expected are refused. s2:aaa,Nr,rlrrPrrs&rtest_moreDataThanSpecified1NetstringReceiverTests.test_moreDataThanSpecifieds. ++I6 445rc VPPR4VPVPP4R#)zk Netstrings that should be empty according to their length specification are refused if they contain data. s0:a,NrDrs&r$test_moreDataThanSpecifiedBorderCase;NetstringReceiverTests.test_moreDataThanSpecifiedBorderCase. ++G4 445rc VPPR4VPVPP4R#)zH Netstrings without leading digits that specify the length are refused. s:aaa,NrDrs&rtest_missingNumber)NetstringReceiverTests.test_missingNumber. ++H5 445rc VPPR4VPVPP4R#)zO Netstrings without a colon between length specification and data are refused. s3aaa,NrDrs&rtest_missingColon(NetstringReceiverTests.test_missingColonrNrc VPPR4VPVPP4R#)zA Netstrings that have no leading digits nor a colon are refused. saaa,NrDrs&rtest_missingNumberAndColon1NetstringReceiverTests.test_missingNumberAndColonrJrc VPPR4VPVPP4R#)z1 Netstrings consisting only of data are refused. saaaNrDrs&r test_onlyData$NetstringReceiverTests.test_onlyDatas. ++F3 445rc VPPR4VPPR4VPVPPR.4VP VPP 44R#)z- Netstrings can be received in two portions. s4:aasaa,saaaaN)r,rlrmr>r_payloadCompleters&rtest_receiveNetstringPortions_16NetstringReceiverTests.test_receiveNetstringPortions_1se ++G4 ++F3 //887)D ..??ABrc RFpVPPV4K VPVPPR.4R#)zv Netstrings can be received in more than two portions, even if the length specification is split across two portions. rN)1s0:01234s56789,r5rparts& rtest_receiveNetstringPortions_26NetstringReceiverTests.test_receiveNetstringPortions_2s@ 7D  " " / / 57 //88=/Jrc RFpVPPV4K VPVPPR.4R#)z5 Netstrings can be received one character at a time. r=N)2:rbr^r5r_s& rtest_receiveNetstringPortions_36NetstringReceiverTests.test_receiveNetstringPortions_3s@3D  " " / / 53 //885'Brc bVPPR4VPVPP44VP VPP R.4VPPR4VP VPP RR.4R#)z A stream of two netstrings can be received in two portions, where the first portion contains the complete first netstring and the length specification of the second netstring. s1:a,1rs:b,rfN)r,rlrrYrmr>rs&rtest_receiveTwoNetstrings0NetstringReceiverTests.test_receiveTwoNetstringss ++H5 ..??AB //884&A ++F3 //884,Grc VPP^,pVPPRP\ V4RRV,344VP VP P4R#)z[ Netstrings with a length specification exceeding the specified C{MAX_LENGTH} are refused. rrerN)r,rZrlrr&rrPr)rtooLongs& rtest_maxReceiveLimit+NetstringReceiverTests.test_maxReceiveLimitsa ((33a7 ++ HHeGndD7N; <  445rc RVPnVPP4VPVPP^ 4R#)z_ C{_consumeLength} returns the expected length of the netstring, including the trailing comma. 12:N)r,_remainingData_consumeLengthrm_expectedPayloadSizers&rtest_consumeLength)NetstringReceiverTests.test_consumeLengths@ 17- --/ //DDbIrc RVPn^ VPnVPP4VP VPP ^ 4R#)zt C{_consumeLength} works as expected if the length specification contains the value of C{MAX_LENGTH} (border case). rqN)r,rrrZrsrmrtrs&rtest_consumeLengthBorderCase14NetstringReceiverTests.test_consumeLengthBorderCase1sN 17-,.) --/ //DDbIrc RVPn^ VPnVP\P VPP 4R#)z C{_consumeLength} raises a L{basic.NetstringParseError} if the length specification exceeds the value of C{MAX_LENGTH} by 1 (border case). rqNr,rrrZrr NetstringParseErrorrsrs&rtest_consumeLengthBorderCase24NetstringReceiverTests.test_consumeLengthBorderCase2sE 17-,.)   % %t'='='L'L rc RVPn^ VPnVP\P VPP 4R#)z C{_consumeLength} raises a L{basic.NetstringParseError} if the length specification exceeds the value of C{MAX_LENGTH} by more than 1. s1000:Nr{rs&rtest_consumeLengthBorderCase34NetstringReceiverTests.test_consumeLengthBorderCase3 sE 19-,.)   % %t'='='L'L rc r\P!4pVP\VPR4R#)zu When L{NetstringReceiver.stringReceived} is not overridden in a subclass, calling it raises C{NotImplementedError}. rN)r NetstringReceiverrrrrs& r!test_stringReceivedNotImplemented8NetstringReceiverTests.test_stringReceivedNotImplementeds+ '') -u/C/CUKr)r,rPN)helloworldshowsaresyou123s:todaysaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa)s9999999999999999999999sabcs4:abcdes751:aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaab,)!r,r-r.r/r0r/rrrrrur6r:r>rArErHrLrPrSrVrZrargrjrnrurxr}rrr2r3r4s@rr*r*FsUGNH> 7$ABCE666666CKC H 6JJ    LLrr*cda]tRtRtoRtRtRtRtRtRt Rt Rt Rt Rt R tV3R ltR tVtR#) IntNTestCaseMixiniz, TestCase mixin for int-prefixed protocols. Nc  <VP4pVPFUp\\P!VP \ V44V,4FpVPV4K KW VPVPVP4R#)z. Test receiving data find the same data send. N) rr/r structpack structFormatrVrlrmr>)rr rtrs& r test_receiveIntNTestCaseMixin.test_receive(sn    Av{{1>>3q6BQFGq!H T\\2rc VPFRpVP4p\V4FpVPV4K VP VP .4KT R#)z; Send partial data, nothing should be definitely received. N)partialStringsrr rlrmr>rs& r test_partialIntNTestCaseMixin.test_partial2sP$$A  "Aq\q!"   QZZ , %rc VP4pVPR4VPVPP 4\ P !VP^4R,4R#)z" Test sending data over protocol. Nbbbbbbbbbbbbbbbb)rr0rmrPr1rrrrr s& r test_sendIntNTestCaseMixin.test_send<sR     Y  KK   Q^^R!@9!L rc .pVP4pVPVn^ VnVP \ P !VP^ 44VPV^ .4R#)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. N) rrlengthLimitExceededrZrlrrrrm)rrNr s& rtest_lengthLimitExceeded*IntNTestCaseMixin.test_lengthLimitExceededFsW      &   v{{1>>267 "&rc VP4p^ VnVP\P!VP ^ 4R,4VP VP.4R#)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}. Ns xxxxxxxxxxx)rrZrlrrrrmr>rs& rtest_longStringNotDelivered-IntNTestCaseMixin.test_longStringNotDeliveredSsM      v{{1>>26BC R(rc r\P!4pVP\VPR4R#)zv When L{IntNStringReceiver.stringReceived} is not overridden in a subclass, calling it raises C{NotImplementedError}. rN)r IntNStringReceiverrrrrs& rr3IntNTestCaseMixin.test_stringReceivedNotImplemented^s+ ((* -u/C/CUKrc<V^8dQh/R;R&S[S[S[,,;R&S[S[S[,,;R&S[S[S[,,;R&#)r r$rr/rrr%)r r5s"rr IntNTestCaseMixin.__annotate__sT 28  d5k ") T%[)0T%[)0rr)r,r-r.r/r0rr/rrrrrrrrr(r2r3r4s@rrrsG59H%)G,0N,0N3-  ' )LArrcBa]tRtRtoRtRtRtRtRtRt Rt Vt R #) 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 d\P!VP\V44V,#)zO Return C{data} prefixed with message length in C{protocol.structFormat} form. )rrrrV)rrr)s&&&r makeMessageRecvdAttributeMixin.makeMessagens$ {{800#d)aa.oVP4oVV3RlpVSn\P!SP^4R,p\P!SP^4R,pSP W#,4VP SV.4R#)z In stringReceived, recvd contains the remaining data that was passed to dataReceived that was not part of the current message. c><SPSP4R#rrrecvd)receivedStringr results&rrKRecvdAttributeMixin.test_recvdContainsRemainingData..stringReceived}s MM!'' "rNaaaaasbbbb)rrrrrrlrm)rrcompleteMessageincompleteMessager rs& @@rtest_recvdContainsRemainingData3RecvdAttributeMixin.test_recvdContainsRemainingDataus}      #* ++anna8HE"KK:hG :; "3!45rc aaa VP4o.o RpVPSV4oVVV 3RlpVSnRpRpVPSV4pVPSV4pSPWV,4VP S W1.4R#)zr In stringReceived, if recvd is changed, messages should be parsed from it rather than the input to dataReceived. cH<S'gSSnSPV4R#r)rr)rmessageCr rs&rr=RecvdAttributeMixin.test_recvdChanged..stringReceiveds" MM. )rNscccccrsbbbbb)rrrrlrm) rpayloadCrpayloadApayloadBmessageAmessageBrr rs & @@@rtest_recvdChanged%RecvdAttributeMixin.test_recvdChangeds    ##Ax0 * *##Ax0##Ax0 x*+ (!56rc aaaVP4o.pRoVPF5pVPVPSV44VPS4K7 .oVVV3RlpVSnSP RP V44SP R4VPSVP4VPSPR4R#)z Data already parsed by L{IntNStringReceiver.dataReceived} is not reparsed if C{stringReceived} consumes some of the L{IntNStringReceiver.recvd} buffer. scd<SPV4SP\S4RSnR#r)rrrV)rSWITCHrrs&rr:RecvdAttributeMixin.test_switching..stringReceiveds% MM. )++c&km4EKrrN) rr/rrrrlrrmr)rmixrtrrrrs& @@@rtest_switching"RecvdAttributeMixin.test_switchings   "$A JJt''q1 2 JJv  5 . 388C=) 7# . g.rc 8aaVP4oRp\V4^, SnVPSV4p.oVV3RlpVSnSP V4VP S^,\V44VP S^,V4R#)z The L{IntNStringReceiver.recvd} buffer contains all data not yet processed by L{IntNStringReceiver.dataReceived} if the C{lengthLimitExceeded} event occurs. stoo longc`<SPV4SPSP4R#rr)rNrrs&rrPRecvdAttributeMixin.test_recvdInLengthLimitExceeded..lengthLimitExceededs MM& ! MM%++ &rN)rrVrZrrrlrm)rDATAmessagerrrs& @@rtest_recvdInLengthLimitExceeded3RecvdAttributeMixin.test_recvdInLengthLimitExceededs   "t9q=""5$/ '%8! 7# CI. G,rrN) r,r-r.r/r0rrrrrr2r3r4s@rrrgs) D6$7./8--rrc]tRtRtRtRtR#) TestInt32izw A L{basic.Int32StringReceiver} storing received strings in an array. @ivar received: array holding received strings. rNr,r-r.r/r0r2rrrrrrrcDa]tRtRtoRt]tRR.tR.t.R Ot Rt Rt Vt R#) Int32Testsiz' Test case for int32-prefixed protocol rs aaaaaac VP4pVPR4VPVPP 4R4VP R4VPVP R.4R#)z/ Test specific behavior of the 32-bits length. rsfoosubarubarNrr0rmrPr1rlr>rs& r test_dataInt32Tests.test_datas_     V **,.DE ./ gY/rrNr)s hello therer) r,r-r.r/r0rrr/rrrr2r3r4s@rrrs2HYG/0N;N00rrc]tRtRtRtRtR#) TestInt16izw A L{basic.Int16StringReceiver} storing received strings in an array. @ivar received: array holding received strings. rNrrrrrrrrrcJa]tRtRtoRt]tRR .tR.t.R Ot Rt Rt Rt Vt R#) Int16Testsiz' Test case for int16-prefixed protocol rsaaaaaac VP4pVPR4VPVPP 4R4VP R4VPVP R.4R#)z/ Test specific behavior of the 16-bits length. rsfoosubarrNrrs& rrInt16Tests.test_datas]     V **,n= ' gY/rc VP4pR^VP^,,^,,pVP\VPV4R#z1 Send too much data: that should cause an error. rfNr prefixLengthrAssertionErrorr0rr tooSends& rtest_tooLongSendInt16Tests.test_tooLongSend E    ! 23a78 .!,,@rrNr)rr)r,r-r.r/r0rrr/rrrrr2r3r4s@rrrs9HYG'(N3N0AArrc]tRtRtRtRtR#)TestInt8izv A L{basic.Int8StringReceiver} storing received strings in an array. @ivar received: array holding received strings. rNrrrrrrrrrcJa]tRtRtoRt]tRR .tR.t.R Ot Rt Rt Rt Vt R#) Int8Testsiz& Test case for int8-prefixed protocol rsaaaaaac VP4pVPR4VPVPP 4R4VP R4VPVP R.4R#)z. Test specific behavior of the 8-bits length. rsfoosubarrNrrs& rrInt8Tests.test_data%s]     V **,j9 {# gY/rc VP4pR^VP^,,^,,pVP\VPV4R#rrrs& rrInt8Tests.test_tooLongSend/rrrNr)sdzadzr)r,r-r.r/r0rrr/rrrrr2r3r4s@rrrs9HYG'(N-N0AArrcDa]tRtRtoRtRtRtRtRtRt Rt Rt Vt R #) OnlyProducerTransporti8za Transport which isn't really a transport, just looks like one to someone not looking very hard. Fc.VnR#rrrs&rrOnlyProducerTransport.__init__As  rcRVnR#)TNpausedrs&rrI$OnlyProducerTransport.pauseProducingDs  rcRVnR#)FNrrs&rrK%OnlyProducerTransport.resumeProducingGs  rc<VPPV4R#r)r)r)rr&s&&rrOnlyProducerTransport.writeJs r)r)rN) r,r-r.r/r0rrrrIrKrr2r3r4s@rrr8s/ FM  rrc*a]tRtRtoRtRtRtVtR#)ConsumingProtocoliNz; Protocol that really, really doesn't want any more bytes. c\VPPV4VP4R#r)rPrrIr!s&&rr#ConsumingProtocol.lineReceivedSs  T" rrN)r,r-r.r/r0r#r2r3r4s@rrrNsrrc*a]tRtRtoRtRtRtVtR#) ProducerTestsiXzE Tests for L{basic._PausableMixin} and L{basic.LineReceiver.paused}. c \4p\4pVPV4VPR4VP VP .4VP VP4VP VP4VPR4VP VP R.4VPVP4VPVP4VP4VP VP R.4VP VP4VP VP4VPR4VP VP RR.4VPVP4VPVP4VP4VP VP .RO4VPVP4VPVP4VPR4VP VP .RO4VPVP4VPVP4VP4VP VP .R O4VPVP4VPVP4VP4VP VP .R O4VP VP4VP VP4R#) 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 rs goodbye N)r rr)r rrr) rrrirlrmr)rrrrK)rprqs& rtest_pauseResumeProducerTests.test_pauseResume]sN   ! #  z" $ " " |$ /!23 ! !  /!23 " " ,- /8!<= ! !  !FG ! ! ~& !FG ! !  !RS ! !  !RS " "rrN)r,r-r.r/r0r r2r3r4s@rrrXsA#A#rrcHa]tRtRtoRtRtRtRtRtRt Rt R t Vt R #) FileSenderTestsiz Tests for L{basic.FileSender}. c n\P!4pVP\\V44R#)z@ L{basic.FileSender} implements the L{IPullProducer} interface. N)r FileSenderrrr )rsenders& rtest_interfaceFileSenderTests.test_interfaces%!!#  Y78rc \R4p\P!4p\P!4pVP W4VP VPV4VPVP4R#)z When L{basic.FileSender.beginFileTransfer} is called, it registers itself with provided consumer, as a non-streaming producer. Test contentN) rrrr rbeginFileTransferrmproducerr streaming)rsourceconsumerrs& rtest_producerRegistered'FileSenderTests.test_producerRegisteredsb ) 002!!#  2 **F3 ++,rc \R4p\P!4p\P!4pVP W4pVP 4VP 4VPVP4VPRVPV44VPRVP44R#)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 rrrK assertIsNonerrmsuccessResultOfr1rrrrds& r test_transferFileSenderTests.test_transfers ) 002!!#  $ $V 6   (++, t33A67 (..*:;rc b\R4p\P!4p\P!4p^VnVP W4pVP4VPRVP44VP4VPRVP44VP4VPRVP44VP4VPRVPV44VPRVP44R#)zR L{basic.FileSender} reads at most C{CHUNK_SIZE} every time it resumes producing. rsTestsTest conrN) rrrr r CHUNK_SIZErrKrmr1r r!s& rtest_transferMultipleChunks+FileSenderTests.test_transferMultipleChunkss ) 002!!#  $ $V 6  (.."23  hnn&67  (..*:;  t33A67 (..*:;rc \Rp\R4p\P!4p\P!4pVP W#V4pVP 4VP 4VPRVPV44VPRVP44R#)zu L{basic.FileSender.beginFileTransfer} takes a C{transform} argument which allows to manipulate the data on the fly. c"VP4#r)swapcase)chunks&r transform=FileSenderTests.test_transferWithTransform..transforms>># #rrTs tEST CONTENTN) rrrr rrrKrmr r1)rr-rrrr"s& rtest_transferWithTransform*FileSenderTests.test_transferWithTransforms  $) 002!!#  $ $Vy A   t33A67 (..*:;rc H\R4p\P!4p\P!4pVP W4pVP 4VPV4pVP\4VPR\VP44R#)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 rrrLfailureResultOftrap Exceptionrmstrr1)rrrrr"failures& rtest_abortedTransfer$FileSenderTests.test_abortedTransfers| ) 002!!#  $ $V 6&&q) Y >GMM@RSrrN) r,r-r.r/r0rrr#r'r0r8r2r3r4s@rrrs/9 -<$<.<(TTrr);r0rriortypingrrrzope.interface.verifyrtwisted.internetrrtwisted.internet.interfacesr twisted.internet.protocolr twisted.protocolsr twisted.python.compatr twisted.python.failurer twisted.testr twisted.trialrrrr7rr^SynchronousTestCasererrrrrrrr*rrInt32StringReceiverrrInt16StringReceiverrrInt8StringReceiverrrrrrTestCaserrrrrJs  ''.+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