[XMc@sdZddlZddlmZddlmZmZmZddlm Z m Z m Z m Z m Z ddlmZdejfdYZd ejfd YZd ejfd YZd ejfdYZdejfdYZdfdYZdeejfdYZdfdYZdejefdYZdefdYZdeejfdYZdejefdYZ deej!fd YZ"d!ejefd"YZ#d#eej$fd$YZ%d%ejefd&YZ&d'e'fd(YZ(d)ejfd*YZ)d+ejfd,YZ*d-ej+fd.YZ,d/ej-fd0YZ.d1ejfd2YZ/d3ejfd4YZ0dS(5s+ Test cases for twisted.protocols package. iN(tunittest(tbasictwiret portforward(treactortprotocoltdeferttaskterror(t proto_helperst LineTestercBsJeZdZdZdZddZdZdZdZ dZ RS( s A line receiver that parses data received and make actions on some tokens. @type delimiter: C{str} @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. s i@cCs ||_dS(s@ If given, use a clock to make callLater calls. N(tclock(tselfR ((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyt__init__ scCs g|_dS(s; Create/clean data received on connection. N(treceived(R ((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pytconnectionMade'scCs(|jj||dkr)|jn|dkrX|j|jjd|jn|dkr|j|j|jjd|jjd|jn|dkr|jnj|d dkrt|d|_ nD|j dr|j j |t n|j d r$|j jnd S( s| Receive line and make some action for some tokens: pause, rawpause, stop, len, produce, unproduce. ttpauseitrawpausetstopislen tproducet unproduceN(Rtappendt setRawModetpauseProducingR t callLatertresumeProducingt stopProducingtinttlengtht startswitht transporttregisterProducertFalsetunregisterProducer(R tline((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyt lineReceived.s&         cCsl||j ||j}}|jt||_|jd||jd<|jdkrh|j|ndS(sj Read raw data, until the quantity specified by a previous 'len' line is reached. iiN(RtlenRt setLineMode(R tdatatrest((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pytrawDataReceivedHs cCs8t||jdkr4|j||jdndS(s< Adjust line mode when long lines received. iN(R%t MAX_LENGTHR&(R R#((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pytlineLengthExceededTsN( t__name__t __module__t__doc__t delimiterR*tNoneR RR$R)R+(((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyR s     tLineOnlyTestercBs,eZdZdZdZdZdZRS(s) A buffering line only receiver. s i@cCs g|_dS(s; Create/clean data received on connection. N(R(R ((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyRdscCs|jj|dS(s% Save received data. N(RR(R R#((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyR$ks(R,R-R.R/R*RR$(((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyR1]s  t WireTestCasecBs2eZdZdZdZdZdZRS(s Test wire protocols. cCstj}tj}|j||jd|jd|jd|jd|jd|j|jddS(sT Test wire.Echo protocol: send some data and check it send it back. thellotworldthowtaretyouthelloworldhowareyouN(R tStringTransportRtEchotmakeConnectiont dataReceivedt assertEqualstvalue(R ttta((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyt test_echoxs        cCs?tj}tj}|j||j|jddS(s) Test wire.Who protocol. sroot N(R R9RtWhoR;R=R>(R R?R@((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttest_whos   cCs?tj}tj}|j||j|jddS(s* Test wire.QOTD protocol. s'An apple a day keeps the doctor away. N(R R9RtQOTDR;R=R>(R R?R@((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyt test_QOTDs    cCstj}tj}|j||jd|jd|jd|jd|jd|j|jddS(s- Test wire.Discard protocol. R3R4R5R6R7RN(R R9RtDiscardR;R<t assertEqualR>(R R?R@((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyt test_discards        (R,R-R.RARCRERH(((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyR2ss   tLineReceiverTestCasec BseZdZdZdddddddd d d d d dg ZdZdZdddgZedgZdZ dZ ddddd gZ ddddddgZ dZ dZdddgZdZdZdZRS(s= Test LineReceiver, using the C{LineTester} wrapper. slen 10 0123456789len 5 1234 len 20 foo 123 0123456789 012345678len 0 foo 5 1234567890123456789012345678901234567890123456789012345678901234567890 len 1 aslen 10t 0123456789slen 5s1234 slen 20sfoo 123s0123456789 012345678slen 0sfoo 5Rt67890slen 1R@cCsxtddD]}tj}t}|jtj|xNtt|j|dD]/}|j|||d|!}|j |q_W|j |j |j qWdS(sl Test buffering for different packet size, checking received matches expected data. ii N( trangeR tStringIOWithoutClosingR R;Rt FileWrapperR%tbufferR<tfailUnlessEqualtoutputR(R t packet_sizeR?R@tits((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyt testBuffers  $s!twiddle1 twiddle2 pause twiddle3 ttwiddle1ttwiddle2Rttwiddle3cCsxtddD]}tj}tj}t|}|jtj|xNtt |j |dD]/}|j |||d|!}|j |qnW|j |j |j|jd|j |j|jqWdS(so Test pause inside data receiving. It uses fake clock to see if pausing/resuming work. ii iN(RLR RMRtClockR R;RRNR%t pause_bufR<R=t pause_output1Rtadvancet pause_output2(R RRR?R R@RSRT((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyt test_pausings   $ s/twiddle1 twiddle2 len 5 rawpause 12345twiddle3 Rt12345cCsxtddD]}tj}tj}t|}|jtj|xNtt |j |dD]/}|j |||d|!}|j |qnW|j |j |j|jd|j |j|jqWdS(s7 Test pause inside raw date receiving. ii iN(RLR RMRRYR R;RRNR%t rawpause_bufR<R=trawpause_output1RR\trawpause_output2(R RRR?R R@RSRT((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttest_rawPausings   $ s"twiddle1 twiddle2 stop more stuff RcCsxtddD]}tj}t}|jtj|xNtt|j|dD]/}|j|||d|!}|j |q_W|j |j |j qWdS(s- Test stop inside producing. ii N( RLR RMR R;RRNR%tstop_bufR<R=t stop_outputR(R RRR?R@RSRT((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttest_stopProducings  $cCs[t}tj}|jtj||jd|j|jddddgdS(s6 Test produce/unproduce in receiving. s&produce hello world unproduce goodbye Rs hello worldRtgoodbyeN( R R RMR;RRNR<R=R(R R@R?((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttest_lineReceiverAsProducers     cCsdtjfdY}|}|jd|j|jd|j|jd|jd|j|jd|j|jdd S( s L{LineReceiver.clearLineBuffer} removes all buffered data and returns it as a C{str} and can be called from beneath C{dataReceived}. tClearingReceivercBseZdZRS(cSs||_|j|_dS(N(R#tclearLineBufferR((R R#((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyR$(s (R,R-R$(((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyRi'ss foo bar baztfoosbar bazsquux tquuxRN(Rt LineReceiverR<RGR#R((R RiR((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttest_clearLineBuffer"s   (R,R-R.RORQRURZR[R]R^R`RaRbRcRdReRfRhRn(((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyRIs(         tLineOnlyReceiverTestCasecBs&eZdZdZdZdZRS(s# Test line only receiveer. s7foo bleakness desolation plastic forks cCsjtj}t}|j|x|jD]}|j|q,W|j|j|jjdd dS(sW Test buffering over line protocol: data received should match buffer. s iN( R R9R1R;ROR<R=Rtsplit(R R?R@tc((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyt test_bufferCs    cCsLtj}t}|j||jdd}|j|tjdS(sO Test sending a line too long: it should close the connection. txiN(R R9R1R;R<tassertIsInstanceRtConnectionLost(R R?R@tres((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttest_lineTooLongOs    (R,R-R.RORrRw(((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyRo9s t TestMixincBs/eZdZdZdZdZdZRS(cCs g|_dS(N(R(R ((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyR]scCs|jj|dS(N(RR(R RT((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pytstringReceivedasi2icCs d|_dS(Ni(tclosed(R treason((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pytconnectionLosths(R,R-RRyR*RzR|(((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyRx[s   t TestNetstringcBseZdZRS(cCs$|jj||jj|dS(N(RRRtwrite(R RT((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyRyos(R,R-Ry(((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyR}mstLPTestCaseMixincBs&eZgZdZdZdZRS(cCs)tj}|j}|j||S(s Return a new instance of C{self.protocol} connected to a new instance of L{proto_helpers.StringTransport}. (R R9RR;(R R?R@((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyt getProtocol{s   cCsUxN|jD]C}|j}x|D]}|j|q#W|j|jjq WdS(sO Assert that illegal strings cause the transport to be closed. N(tillegalStringsRR<t assertTrueRt disconnecting(R RTtrRq((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyt test_illegals   N(R,R-RR0RRR(((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyRus tNetstringReceiverTestCasecBseZddddddddgZdd d d gZeZd Zd ZdZdZ dZ dZ dZ dZ dZdZdZdZdZdZdZdZdZdZdZdZd Zd!Zd"ZRS(#R3R4R5R6tyou123s:todayR@it9999999999999999999999tabcs4:abcdes751:aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaab,cCs2tj|_t|_|jj|jdS(N(R R9RR}tnetstringReceiverR;(R ((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pytsetUps cCsxtddD]}tj}t}d|_|j|x|jD]}|j|qKW|j}xQtt ||dD]5}||||d|!}|r|j |qqW|j |j |jqWdS(sI Strings can be received in chunks of different lengths. ii iN( RLR R9R}R*R;tstringst sendStringR>R%R<R=R(R RRR?R@RTtoutRS((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyRrs     !c CsRgidd6dd6dddgddg}t}tj}d |_|j|x|D]}|j||j}|j||jd  }||jd dd !}|j t |t t ||j |t |q^W|j d|jg}|jt |d|j|ddd|j|ddtdS(s L{basic.NetstringReceiver.sendString} will send objects that are not strings by sending their string representation according to str(). R@itbiRqii tfinetandsyou?idt:itoffendingFunctionsiitmessagesaData passed to sendString() must be a string. Non-string support is deprecated since Twisted 10.0tcategoryN(i RRsyou?(R}R R9R*R;RR>tcleartfindR=RR%tstrt flushWarningsttest_sendNonStringsRGtDeprecationWarning( R t nonStringsR@R?RTRRR'twarnings((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyRs.#         "   cCs-|jjd|j|jjdgdS(sE Empty netstrings (with length '0') can be received. s0:,RN(RR<R=R(R ((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttest_receiveEmptyNetstringscCs-|jjd|j|jjdgdS(s; One-character netstrings can be received. s1:a,R@N(RR<R=R(R ((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttest_receiveOneCharacterscCs-|jjd|j|jjdgdS(s; Two-character netstrings can be received. s2:ab,tabN(RR<R=R(R ((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttest_receiveTwoCharactersscCs-|jjd|j|jjdgdS(s 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,,s1:a,N(RR<R=R(R ((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttest_receiveNestedNetstringscCs'|jjd|j|jjdS(sL Netstrings containing more data than expected are refused. s2:aaa,N(RR<RRR(R ((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttest_moreDataThanSpecifiedscCs'|jjd|j|jjdS(s Netstrings that should be empty according to their length specification are refused if they contain data. s0:a,N(RR<RRR(R ((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyt$test_moreDataThanSpecifiedBorderCasescCs'|jjd|j|jjdS(s` Netstrings without leading digits that specify the length are refused. s:aaa,N(RR<RRR(R ((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttest_missingNumberscCs'|jjd|j|jjdS(sg Netstrings without a colon between length specification and data are refused. s3aaa,N(RR<RRR(R ((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttest_missingColonscCs'|jjd|j|jjdS(sY Netstrings that have no leading digits nor a colon are refused. saaa,N(RR<RRR(R ((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttest_missingNumberAndColonscCs'|jjd|j|jjdS(sA Netstrings consisting only of data are refused. taaaN(RR<RRR(R ((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyt test_onlyData#scCsS|jjd|jjd|j|jjdg|j|jjdS(s= Netstrings can be received in two portions. s4:aasaa,taaaaN(RR<R=RRt_payloadComplete(R ((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttest_receiveNetstringPortions_1+scCsJx*ddddgD]}|jj|qW|j|jjdgdS(s Netstrings can be received in more than two portions, even if the length specification is split across two portions. t1s0:01234t56789t,RJN(RR<R=R(R tpart((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttest_receiveNetstringPortions_25scCs>xdD]}|jj|qW|j|jjdgdS(sE Netstrings can be received one character at a time. s2:ab,RN(RR<R=R(R R((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttest_receiveNetstringPortions_3?s cCso|jjd|j|jj|j|jjdg|jjd|j|jjddgdS(s 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,1R@s:b,RN(RR<RRR=R(R ((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttest_receiveTwoNetstringsHs cCsE|jjd}|jjd|d|f|j|jjdS(ss Netstrings with a length specification exceeding the specified C{MAX_LENGTH} are refused. is%s:%sR@N(RR*R<RRR(R ttooLong((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttest_maxReceiveLimitUs cCs3d|j_|jj|j|jjddS(sw C{_consumeLength} returns the expected length of the netstring, including the trailing comma. s12:i N(Rt_remainingDatat_consumeLengthR=t_expectedPayloadSize(R ((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttest_consumeLength`s  cCs?d|j_d|j_|jj|j|jjddS(s C{_consumeLength} works as expected if the length specification contains the value of C{MAX_LENGTH} (border case). s12:i i N(RRR*RR=R(R ((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttest_consumeLengthBorderCase1js   cCs5d|j_d|j_|jtj|jjdS(s C{_consumeLength} raises a L{basic.NetstringParseError} if the length specification exceeds the value of C{MAX_LENGTH} by 1 (border case). s12:i N(RRR*t assertRaisesRtNetstringParseErrorR(R ((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttest_consumeLengthBorderCase2us   cCs5d|j_d|j_|jtj|jjdS(s C{_consumeLength} raises a L{basic.NetstringParseError} if the length specification exceeds the value of C{MAX_LENGTH} by more than 1. s1000:i N(RRR*RRRR(R ((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttest_consumeLengthBorderCase3s   cCstjtjtjtjf|jd|jg}|jt|dx"|D]}|j|dt qQW|j|ddd|j|ddd|j|d dd |j|d dd d S(s Accessing one of the old module attributes used by the NetstringReceiver parser emits a deprecation warning. RiRiRsktwisted.protocols.basic.LENGTH was deprecated in Twisted 10.2.0: NetstringReceiver parser state is private.isitwisted.protocols.basic.DATA was deprecated in Twisted 10.2.0: NetstringReceiver parser state is private.isjtwisted.protocols.basic.COMMA was deprecated in Twisted 10.2.0: NetstringReceiver parser state is private.isktwisted.protocols.basic.NUMBER was deprecated in Twisted 10.2.0: NetstringReceiver parser state is private.N( RtLENGTHtDATAtCOMMAtNUMBERRttest_deprecatedModuleAttributesR=R%R(R Rtwarning((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyRs$      (R,R-RRR}RRRrRRRRRRRRRRRRRRRRRRRRR(((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyRs6          tIntNTestCaseMixincBsSeZdZdZdZdZdZdZdZ dZ dZ dZ RS(s4 TestCase mixin for int-prefixed protocols. cCsq|j}xH|jD]=}x4tj|jt||D]}|j|q<WqW|j|j|jdS(s> Test receiving data find the same data send. N( RRtstructtpackt structFormatR%R<R=R(R RRTRq((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyt test_receives  &cCsUxN|jD]C}|j}x|D]}|j|q#W|j|jgq WdS(sK Send partial data, nothing should be definitely received. N(tpartialStringsRR<R=R(R RTRRq((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyt test_partials   cCsI|j}|jd|j|jjtj|jdddS(s2 Test sending data over protocol. RiNtbbbbbbbbbbbbbbbbR(RRR=RR>RRR(R R((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyt test_sends  cCsZg}|j}|j|_d|_|jtj|jd|j|dgdS(s 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. i i N( RRtlengthLimitExceededR*R<RRRRG(R RR((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttest_lengthLimitExceededs    cCsL|j}d|_|jtj|jdd|j|jgdS(s 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}. i i RsNt xxxxxxxxxxx(RR*R<RRRRGR(R R((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttest_longStringNotDelivereds   N( R,R-R.R0RRRRRRRRR(((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyRs t TestInt32cBseZdZRS(s A L{basic.Int32StringReceiver} storing received strings in an array. @ivar received: array holding received strings. (R,R-R.(((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyRst Int32TestCasecBsAeZdZeZdd gZdgZdddgZdZRS( s/ Test case for int32-prefixed protocol R@Ris aaaaaats hello thereRcCsY|j}|jd|j|jjd|jd|j|jdgdS(s? Test specific behavior of the 32-bits length. RktfootubartubarN(RRR=RR>R<R(R R((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyt test_datas    R( R,R-R.RRRRRR(((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyRs   t TestInt16cBseZdZRS(s A L{basic.Int16StringReceiver} storing received strings in an array. @ivar received: array holding received strings. (R,R-R.(((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyRst Int16TestCasecBsJeZdZeZdd gZdgZdddgZdZd Z RS( s/ Test case for int16-prefixed protocol R@Risaaaaaats hello thereRcCsY|j}|jd|j|jjd|jd|j|jdgdS(s? Test specific behavior of the 16-bits length. RktfootubarRN(RRR=RR>R<R(R R((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyR"s    cCs?|j}dd|jdd}|jt|j|dS(sA Send too much data: that should cause an error. RiiiN(Rt prefixLengthRtAssertionErrorR(R RttooSend((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttest_tooLongSend-s R( R,R-R.RRRRRRR(((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyRs   tTestInt8cBseZdZRS(s A L{basic.Int8StringReceiver} storing received strings in an array. @ivar received: array holding received strings. (R,R-R.(((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyR7st Int8TestCasecBsJeZdZeZdd gZdgZdddgZdZd Z RS( s. Test case for int8-prefixed protocol R@RitaaaaaastdzadzRcCsY|j}|jd|j|jjd|jd|j|jdgdS(s> Test specific behavior of the 8-bits length. RksfoosubarRN(RRR=RR>R<R(R R((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyRJs    cCs?|j}dd|jdd}|jt|j|dS(sA Send too much data: that should cause an error. RiiiN(RRRRR(R RR((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyRUs R( R,R-R.RRRRRRR(((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyR@s   tOnlyProducerTransportcBs8eZeZeZdZdZdZdZRS(cCs g|_dS(N(R'(R ((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyR fscCs t|_dS(N(tTruetpaused(R ((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyRjscCs t|_dS(N(R!R(R ((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyRnscCs|jj|dS(N(R'R(R tbytes((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyR~rs( R,R-R!RRR RRR~(((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyR_s    tConsumingProtocolcBseZdZRS(cCs|jj||jdS(N(RR~R(R R#((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyR$zs(R,R-R$(((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyRwstProducerTestCasecBseZdZRS(cCst}t}|j||jd|j|j|j|j|j|j|jd|j|jdg|j|j|j|j|j |j|j|j|j|jd|j|jddg|j|j|j|j|j |jd|j|jdddg|j|j|j|j|j |j|jddddg|j|j|j|j|j |j|jddddg|j|j|j|jdS( Nshello, sworld s hello, worldshello world R3s goodbye R4Rg( RRR;R<tfailIfR'RR=t failUnlessR(R tpR?((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttestPauseResumes>           (R,R-R(((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyRstTestableProxyClientFactorycBseZdZdZRS(s Test proxy client factory that keeps the last created protocol instance. @ivar protoInstance: the last instance of the protocol. @type protoInstance: L{portforward.ProxyClient} cCs"tjj||}||_|S(sE Create the protocol instance and keeps track of it. (RtProxyClientFactoryt buildProtocolt protoInstance(R taddrtproto((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyRs (R,R-R.R(((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyRstTestableProxyFactorycBseZdZdZRS(sl Test proxy factory that keeps the last created protocol instance. @ivar protoInstance: the last instance of the protocol. @type protoInstance: L{portforward.ProxyServer} @ivar clientFactoryInstance: client factory used by C{protoInstance} to create forward connections. @type clientFactoryInstance: L{TestableProxyClientFactory} cs@tjj|}t_fd|_|_|S(s Create the protocol instance, keeps track of it, and makes it use C{clientFactoryInstance} as client factory. csjS(N(tclientFactoryInstance((R (s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyts(Rt ProxyFactoryRRRtclientProtocolFactoryR(R RR((R s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyRs   (R,R-R.R(((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyRs tPortforwardingcBs)eZdZdZdZdZRS(s Test port forwarding. cCs+tj|_tj|_g|_dS(N(RR:tserverProtocolRtProtocoltclientProtocolt openPorts(R ((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyRscCsy|jjjjWntk r*nXy |jjj}|jjWntk r^nXy|jjjWntk rnXy|jjjWntk rnXtj g|j D]}tj |j ^qS(N( tproxyServerFactoryRRtloseConnectiontAttributeErrorRRRRt gatherResultsRt maybeDeferredt stopListening(R tpiR((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttearDowns&    cs$tj}fd|_tjd|dd}jj|td|jj_ tjdj dd}jj|dgt j fd}|j _ fd}|j _tj}fd|_tjd|jj|S( s= Test port forwarding through Echo protocol. csjS(N(R((R (s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyRsit interfaces 127.0.0.1icsPj|tkrLjdjdjdndS(NRRs(textendR%R=tjointcallbackR0(R'(RtdR tnBytes(s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttestDataReceiveds csjjjddS(NRs(RRR~((R R (s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttestConnectionMadescsjS(N(R((R (s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyR s(Rt ServerFactoryRt listenTCPRRRtgetHosttportRRtDeferredRR<Rt ClientFactoryt connectTCP(R trealServerFactorytrealServerPorttproxyServerPortRRt clientFactory((RR R R s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttest_portforwards,       (R,R-R.RRR(((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyRs  tStringTransportTestCasecBseZdZdZRS(sA Test L{proto_helpers.StringTransport} helper behaviour. cCs&tj}|jt|jddS(sY Test that L{proto_helpers.StringTransport} doesn't accept unicode data. ufooN(R R9Rt TypeErrorR~(R RT((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyttest_noUnicode.s (R,R-R.R(((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyR)s(1R.Rt twisted.trialRttwisted.protocolsRRRttwisted.internetRRRRRt twisted.testR RmR tLineOnlyReceiverR1tTestCaseR2RIRoRxtNetstringReceiverR}RRRtInt32StringReceiverRRtInt16StringReceiverRRtInt8StringReceiverRRtobjectRRRRRRRRR(((s?/usr/lib/python2.7/dist-packages/twisted/test/test_protocols.pyts: (M9"F    2K