+ jbRt^RIHtHtHtHt^RIHt^RIH t ^RI H t ^RI H t HtHtHt^RIHt!RR4t!R R ]]4t!R R ]]4tR #)z$ Test the memcache client protocol. )Deferred DeferredList TimeoutError gatherResults)ConnectionDone)Clock) StringTransportWithDisconnection) ClientErrorMemCacheProtocol NoSuchCommand ServerError)TestCaseca]tRt^toRtRtRtRtRtRt Rt Rt R t R t R tR tR tRtRtRtRtRtRtRtRtRtVtR#) CommandMixinzG Setup and tests for basic invocation of L{MemCacheProtocol} commands. c \4h)zX Helper test method to test the resulting C{Deferred} of a L{MemCacheProtocol} command. )NotImplementedErrorselfdsendrecvresults&&&&& zz JJ " "FF#3 4  J _fk :   rc  hVPVPPRR.4RRRRRR/4#)zq When L{MemCacheProtocol.getMultiple} is called with non-available keys, the corresponding tuples are (0, None). rr/r0sVALUE cow 1 3 bar END )r"r+r1r&s&rtest_getMultipleWithEmpty&CommandMixin.test_getMultipleWithEmptyBs> zz JJ " "FF#3 4  . [&) 4   rc ^VPVPPRR4RRR4#)zn L{MemCacheProtocol.set} returns a L{Deferred} which is called back with C{True} when the operation succeeds. rr"sset foo 0 0 3 bar STORED T)rr$setr&s&rtest_setCommandMixin.test_setN0 zz JJNN66 * '     rc ^VPVPPRR4RRR4#)zn L{MemCacheProtocol.add} returns a L{Deferred} which is called back with C{True} when the operation succeeds. rr"add foo 0 0 3 bar r:Trr$addr&s&rtest_addCommandMixin.test_addZr>rc ^VPVPPRR4RRR4#)zr L{MemCacheProtocol.replace} returns a L{Deferred} which is called back with C{True} when the operation succeeds. rr"replace foo 0 0 3 bar r:Trr$replacer&s&r test_replaceCommandMixin.test_replacefs2 zz JJ  vv . +     rc ^VPVPPRR4RRR4#)z Test an erroneous add: if a L{MemCacheProtocol.add} is called but the key already exists on the server, it returns a B{NOT STORED} answer, which calls back the resulting L{Deferred} with C{False}. rr"r@ NOT STORED FrAr&s&r test_errorAddCommandMixin.test_errorAddrs0 zz JJNN66 * '     rc ^VPVPPRR4RRR4#)z Test an erroneous replace: if a L{MemCacheProtocol.replace} is called but the key doesn't exist on the server, it returns a B{NOT STORED} answer, which calls back the resulting L{Deferred} with C{False}. rr"rFrLFrGr&s&rtest_errorReplaceCommandMixin.test_errorReplaces2 zz JJ  vv . +     rc \VPVPPR4RRR4#)zx L{MemCacheProtocol.delete} returns a L{Deferred} which is called back with C{True} when the server notifies a success. r" delete bar s DELETED Trr$deleter&s&r test_deleteCommandMixin.test_deletes. zz JJ  f %'8.$  rc \VPVPPR4RRR4#)z Test an error during a delete: if key doesn't exist on the server, it returns a B{NOT FOUND} answer which calls back the resulting L{Deferred} with C{False}. r"rSs NOT FOUND FrTr&s&rtest_errorDeleteCommandMixin.test_errorDeletes/ zz JJ  f %'8:JE  rc \VPVPPR4RR^4#)z Test incrementing a variable: L{MemCacheProtocol.increment} returns a L{Deferred} which is called back with the incremented value of the given key. rs incr foo 1 4 rr$ incrementr&s&rtest_incrementCommandMixin.test_increment* zz$**..v68I8UVWWrc \VPVPPR4RR^4#)z Test decrementing a variable: L{MemCacheProtocol.decrement} returns a L{Deferred} which is called back with the decremented value of the given key. rs decr foo 1 5 rr$ decrementr&s&rtest_decrementCommandMixin.test_decrementrarc ^VPVPPR^4RR^4#)zy L{MemCacheProtocol.increment} takes an optional argument C{value} which replaces the default value of 1 when specified. rs incr foo 8 r\r]r&s&rtest_incrementValCommandMixin.test_incrementVal0 zz JJ  +->!  rc ^VPVPPR^4RR^4#)zy L{MemCacheProtocol.decrement} takes an optional argument C{value} which replaces the default value of 1 when specified. rs decr foo 3 rcrdr&s&rtest_decrementValCommandMixin.test_decrementValrkrc  bVPVPP4RRRRRR/4#)z Test retrieving server statistics via the L{MemCacheProtocol.stats} command: it parses the data sent by the server and calls back the resulting L{Deferred} with a dictionary of the received statistics. sstats "STAT foo bar STAT egg spam END rr"eggspamrr$statsr&s&r test_statsCommandMixin.test_statss7 zz JJ     7 VVW -   rc  dVPVPPR4RRRRRR/4#)a L{MemCacheProtocol.stats} takes an optional C{bytes} argument which, if specified, is sent along with the I{STAT} command. The I{STAT} responses from the server are parsed as key/value pairs and returned as a C{dict} (as in the case where the argument is not specified). sblahs stats blah rprr"rqrrrsr&s&rtest_statsWithArgument#CommandMixin.test_statsWithArguments9zz JJ  W %  7 VVW -   rc ZVPVPP4RRR4#)z Test version retrieval via the L{MemCacheProtocol.version} command: it returns a L{Deferred} which is called back with the version sent by the server. s version s VERSION 1.1 s1.1)rr$versionr&s&r test_versionCommandMixin.test_versions, zz JJ   .2Df  rc ZVPVPP4RRR4#)zz L{MemCacheProtocol.flushAll} returns a L{Deferred} which is called back with C{True} if the server acknowledges success. s flush_all sOK T)rr$flushAllr&s&r test_flushAllCommandMixin.test_flushAlls' zz$**--/1A9dSSrN)__name__ __module__ __qualname____firstlineno____doc__rr'r,r3r7r<rCrIrMrPrVrYr_rfrirmrurxr|r__static_attributes____classdictcell__ __classdict__s@rrrsx$  Y                XX       TTrrca]tRt^toRtRtRtRtRtRt Rt Rt R t R t R tR tR tRtRtRtRtRtRtRtRtRtRtRtRtRtRtRtRt Rt!Rt"R t#Vt$R!#)" MemCacheTestsz1 Test client protocol class L{MemCacheProtocol}. c *\4Vn\4VnVPPVPn\ 4VnVPVP nVPPVP 4R#)zc Create a memcache client, connect it to a string protocol, and make it use a deterministic clock. N) r r$rclock callLaterr transportprotocolmakeConnectionr&s&rsetUpMemCacheTests.setUps] &' W #zz33 9;"&** !!$..1rc aaVV3RlpSPSPP4V4VPV4SPP V4V#)a Implementation of C{_test} which checks that the command sends C{send} data, and that upon reception of C{recv} the result is C{result}. @param d: the resulting deferred from the memcache command. @type d: C{Deferred} @param send: the expected data to be sent. @type send: C{bytes} @param recv: the data to simulate as reception. @type recv: C{bytes} @param result: the expected result. @type result: C{any} c,<SPVS4R#N) assertEqual)resrrs&rcbMemCacheTests._test..cbs   S& )r)rrvalue addCallbackr$ dataReceived)rrrrrrsf&&&f rrMemCacheTests._testsJ$ * --/6 b %rc VPPR4VP\VPPR4R#)z If the value returned doesn't match the expected key of the current C{get} command, an error is raised in L{MemCacheProtocol.dataReceived}. rsVALUE bar 0 7 spamegg END N)r$r% assertRaises RuntimeErrorrr&s&rtest_invalidGetResponse%MemCacheTests.test_invalidGetResponses5 v   JJ # # 2 rc VPPRR.4VP\VPPR4R#)z If the value returned doesn't match one the expected keys of the current multiple C{get} command, an error is raised error in L{MemCacheProtocol.dataReceived}. rr"sVALUE egg 0 7 spamegg END N)r$r2rrrr&s&rtest_invalidMultipleGetResponse-MemCacheTests.test_invalidMultipleGetResponse%s< /0   JJ # # 2 rc VPPRR4VP\VPPR4R#)z If an END is received in response to an operation that isn't C{get}, C{gets}, or C{stats}, an error is raised in L{MemCacheProtocol.dataReceived}. skeysvaluer*N)r$r;rrrr&s&rtest_invalidEndResponse%MemCacheTests.test_invalidEndResponse2s2 vx( , (?(?Lrc aSPPR4pSPPR4p\4pVPSPnSP P SPP4SPV\4SPV\4V3RlpVPV4SPV\4\WV.4#)z Test the timeout on outgoing requests: when timeout is detected, all current commands fail with a L{TimeoutError}, and the connection is closed. rr"c><SP\V4R4R#)zConnection timeoutN)rstr)errorrs&r checkMessage0MemCacheTests.test_timeOut..checkMessageJs   SZ)= >r) r$r%rcallbackconnectionLostradvancepersistentTimeOut assertFailurerrrr)rd1d2d3rsf r test_timeOutMemCacheTests.test_timeOut;s ZZ^^F # ZZ^^F # Z$&KK ! 4::778 2|, 2|, ? |$ 2~.bb\**rc aSPPR4pSPPSPP^, 4SPP R4V3RlpVP V4V#)zI When a request gets a response, no pending timeout call remains around. rrc<SPVR4SP\SPP4^4R#)r!Nr )rlenrcalls)rrs&rcheck0MemCacheTests.test_timeoutRemoved..checkZs2   V[ 1   S!1!12A 6r)r$r%rrrrr)rrrsf rtest_timeoutRemoved!MemCacheTests.test_timeoutRemovedQsc JJNN6 " 4::77!;<  BC 7 erc VPPR4p\4pVPVPnVPP R4VP PVPP4VPV\4VPV\4\W.4#)z Test the timeout when raw mode was started: the timeout is not reset until all the data has been received, so we can have a L{TimeoutError} when waiting for raw data. rsVALUE foo 0 10 12345) r$r%rrrrrrrrrrrrrrs& rtest_timeOutRawMemCacheTests.test_timeOutRawas ZZ^^F # Z$&KK !  :; 4::778 2|, 2~.bX&&rc VPP4p\4pVPVPnVPP R4VP PVPP4VPV\4VPV\4\W.4#)zn Test the timeout when stat command has started: the timeout is not reset until the final B{END} is received. sSTAT foo bar ) r$rtrrrrrrrrrrrrs& rtest_timeOutStatMemCacheTests.test_timeOutStatqs ZZ    Z$&KK !  34 4::778 2|, 2~.bX&&rc aaaSPPR4pSPPR4o\4pVPSPnSP P SPP^, 4SPPR4VVV3RlpV3RloVPV4SPV\4V#)zt When two requests are sent, a timeout call remains around for the second request, and its timeout time is correct. rr"rcR<SPVR4SP\SPP4^4\ SP P 4FpSPP^4K SPS\4PS4#)r!r ) rrrrranger$rrrrr)ri checkTimerrs& rr3MemCacheTests.test_timeoutPipelining..checks{   V[ 1   S!1!12A 64::778 ""1%9%%b,7CCIN Nrc<SPSPP4^SPP,^, 4R#)N)rrsecondsr$r)ignoredrs&rr7MemCacheTests.test_timeoutPipelining..checkTimes7   TZZ//11tzz7S7S3SVW3W Xr) r$r%rrrrrrrrrr)rrrrrrsf @@rtest_timeoutPipelining$MemCacheTests.test_timeoutPipelinings ZZ^^F # ZZ^^F # Z$&KK ! 4::77!;<  BC O Y u 2~. rc VPPR4p\4pVPVPnVP P VPP^, 4VPPR4pVP P ^4VPV\4VPV\4VPV\4\WV.4#)zu Check that timeout is not resetted for every command, but keep the timeout from the first command without response. rr") r$r%rrrrrrrrrr)rrrrs& rtest_timeoutNotReset"MemCacheTests.test_timeoutNotResets ZZ^^F # Z$&KK ! 4::77!;< ZZ^^F # 1 2|, 2|, 2~.bb\**rc <VPPR4pVPPVPP4VP V\ 4VPPR4pVP V\4\W.4#)z C{timeoutConnection} cleans the list of commands that it fires with C{TimeoutError}: C{connectionLost} doesn't try to fire them again, but sets the disconnected state so that future commands fail with a C{RuntimeError}. rr") r$r%rrrrrrrrs& rtest_timeoutCleanDeferreds(MemCacheTests.test_timeoutCleanDeferredssqZZ^^F # 4::778 2|, ZZ^^F # 2|,bX&&rc aSPPR4pSPPR4pSPP4\ W.RR7pV3RlpVP V4#)zT When disconnection occurs while commands are still outstanding, the commands fail. rr"T) consumeErrorscj<VF+wrSPV4VP\4K- R#r) assertFalsetrapr)resultssuccessrrs& r checkFailures8MemCacheTests.test_connectionLost..checkFailuress)#*  ) N+$+r)r$r%rloseConnectionrr)rrrdonersf rtest_connectionLost!MemCacheTests.test_connectionLosts_ ZZ^^F # ZZ^^F # %%'RHD9 ,  ..rc \VPVPPRR4\4pVPVPP R4\4pVPVPP R4\4pVPVPP RR4\4pVPVPPRR4\4pVPVPPRR.4\4p\WW4WV.4#)z An error is raised when trying to use a too long key: the called command returns a L{Deferred} which fails with a L{ClientError}. r"rsaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa) rr$r;r r^r%appendprependr2r)rrrrd4d5d6s& rtest_tooLongKeyMemCacheTests.test_tooLongKeys    z6 BK P    4 4Z @+ N    z :K H    1 1*f E{ S    2 2:v F T    JJ " "FJ#7 8+ bbb566rc VPPRRR^^R4pVPVPP 4R4VP V\ 4VPPR4V#)z When an unknown command is sent directly (not through public API), the server answers with an B{ERROR} token, and the command fails with L{NoSuchCommand}. rqrr"rsegg foo 0 0 3 bar sERROR )r$_setrrrrr rrrs& rtest_invalidCommand!MemCacheTests.test_invalidCommandse JJOOFFFAq# > --/1LM 1m,  -rc (aRpSPPRV4pSPSPP 4R4SP V\ 4V3RlpVPV4SPPR4V#)z Test the L{ClientError} error: when the server sends a B{CLIENT_ERROR} token, the originating command fails with L{ClientError}, and the error contains the text sent by the server. eggspammrset foo 0 0 8 eggspamm cP<SP\V4\R44R#)sWe don't like egg and spamNrrreprerrrs&rr-MemCacheTests.test_clientError..checks   SXt,I'J Krs)CLIENT_ERROR We don't like egg and spam ) r$r;rrrrr rrrarrsf rtest_clientErrorMemCacheTests.test_clientErrorsx  JJNN61 % --/1QR 1k* L e  NOrc (aRpSPPRV4pSPSPP 4R4SP V\ 4V3RlpVPV4SPPR4V#)z Test the L{ServerError} error: when the server sends a B{SERVER_ERROR} token, the originating command fails with L{ServerError}, and the error contains the text sent by the server. rrrcP<SP\V4\R44R#)szomgNrrs&rr-MemCacheTests.test_serverError..checks   SXtG} 5rsSERVER_ERROR zomg ) r$r;rrrrr rrrsf rtest_serverErrorMemCacheTests.test_serverErrorsw  JJNN61 % --/1QR 1k* 6 e  89rc  VPVPPRR4\4pVPVPP R4\4pVPVPP ^4\4pVPVPP R4\4pVPVPPRR4\4pVPVPPRR4\4pVPVPPR^.4\4p\WW4WVV.4#)zA Using a non-string key as argument to commands raises an error. foor"eggbarrq) rr$r;r r^r%rUrrr2r)rrrrrrrd7s& rtest_unicodeKeyMemCacheTests.test_unicodeKey s   uf ={ K    4 4U ;[ I    q 1; ?    1 1% 8+ F    1 1% @+ N    2 25& A; O    6 6{ C[ Qbbbb9::rc bVPVPPRR4\4#)z+ Using a non-string value raises an error. rr )rr$r;r r&s&rtest_unicodeValueMemCacheTests.test_unicodeValues&!!$**.."?MMrc VPPR4pVPVPR4VPP RR4pVPVPR4VPPR4pVPVPR 4VPVP P 4R4VPPR4\WV.4#) z Multiple requests can be sent subsequently to the server, and the protocol orders the responses correctly and dispatch to the corresponding client command. rr"s spamspamspamTrqs0get foo set bar 0 0 12 spamspamspam get egg s;VALUE foo 0 3 bar END STORED VALUE egg 0 4 spam END r )r!rr) r$r%rrr;rrrr)rrrrs& rtest_pipeliningMemCacheTests.test_pipelinings ZZ^^F # t''5 ZZ^^FO 4 t''. ZZ^^F # t''6  NN " G   0 bb\**rc VPPR4pVPVPR4VPVPP 4R4VPP R4VPP R4VPP R4VPP R4V#)z| If the value retrieved by a C{get} arrive in chunks, the protocol is able to reconstruct it and to produce the good value. rrsVALUE foo 0 10 0123456s789s ENDs )r!s 0123456789)r$r%rrrrrrs& rtest_getInChunksMemCacheTests.test_getInChunks6s JJNN6 " d&&(:; --/@  <= '  + (rc ^VPVPPRR4RRR4#)z L{MemCacheProtocol.append} behaves like a L{MemCacheProtocol.set} method: it returns a L{Deferred} which is called back with C{True} when the operation succeeds. rr"sappend foo 0 0 3 bar r:T)rr$rr&s&r test_appendMemCacheTests.test_appendDs2 zz JJ  ff - *     rc ^VPVPPRR4RRR4#)z L{MemCacheProtocol.prepend} behaves like a L{MemCacheProtocol.set} method: it returns a L{Deferred} which is called back with C{True} when the operation succeeds. rr"sprepend foo 0 0 3 bar r:T)rr$rr&s&r test_prependMemCacheTests.test_prependQs2 zz JJ  vv . +     rc ^VPVPPRR4RRR4#)z L{MemCacheProtocol.get} handles an additional cas result when C{withIdentifier} is C{True} and forward it in the resulting L{Deferred}. rT gets foo sVALUE foo 0 3 1234 bar END )r!1234r"r#r&s&r test_getsMemCacheTests.test_gets^s0 zz JJNN64 (  3   rc ^VPVPPRR4RRR4#)z{ Test getting a non-available key with gets: it succeeds but return L{None} as value, C{0} as flag and an empty cas value. rTr!r*r!rNr#r&s&rtest_emptyGetsMemCacheTests.test_emptyGetsks- zz JJNN64 (/:~  rc  jVPVPPRR.R4RRRRRR/4#)zy L{MemCacheProtocol.getMultiple} handles an additional cas field in the returned tuples if C{withIdentifier} is C{True}. rr"Tgets foo bar 8VALUE foo 0 3 1234 egg VALUE bar 0 4 2345 spam END r!s2345rrr!r"rqr1r&s&rtest_getsMultipleMemCacheTests.test_getsMultipletsB zz JJ " "FF#3T :  U *F4H I   rc  |VPVPP\RR.4R4RRRRRR/4#)z? L{MemCacheProtocol.getMultiple} accepts any iterable of keys. rr"Tr*r+r,r-)rr$r2iterr&s&rtest_getsMultipleIterableKeys+MemCacheTests.test_getsMultipleIterableKeyssGzz JJ " "4(8#94 @  U *F4H I   rc  jVPVPPRR.R4RRRRRR/4#)z When getting a non-available key with L{MemCacheProtocol.getMultiple} when C{withIdentifier} is C{True}, the other keys are retrieved correctly, and the non-available key gets a tuple of C{0} as flag, L{None} as value, and an empty cas value. rr"Tr*sVALUE foo 0 3 1234 egg END r&r-r1r&s&rtest_getsMultipleWithEmpty(MemCacheTests.test_getsMultipleWithEmptysAzz JJ " "FF#3T :  3 ^V-A B   rc bVPVPPRRRR7RRR4#)z L{MemCacheProtocol.checkAndSet} passes an additional cas identifier that the server handles to check if the data has to be updated. rr"r"cascas foo 0 0 3 1234 bar r:Trr$ checkAndSetr&s&rtest_checkAndSetMemCacheTests.test_checkAndSets7 zz JJ " "66w " ? ,     rc bVPVPPRRRR7RRR4#)zl When L{MemCacheProtocol.checkAndSet} response is C{EXISTS}, the resulting L{Deferred} fires with C{False}. rr"r"r8r:sEXISTS Fr;r&s&rtest_casUnknowKeyMemCacheTests.test_casUnknowKeys7 zz JJ " "66w " ? ,     rrr$rN)%rrrrrrrrrrrrrrrrrrrrrrrrrrrrr#r'r.r2r5r=r@rrrs@rrrs 24    M+, ' ':+" '/" 7 $$ ;N +.                   rrc0a]tRtRtoRtRtRtRtVtR#)CommandFailureTestsizN Tests for correct failure of commands on a disconnected L{MemCacheProtocol}. c ^\4Vn\4VnVPPVPn\ 4VnVPVP nVPPVP 4VP P4R#)zE Create a disconnected memcache client, using a deterministic clock. N) r r$rrrrrrrrr&s&rrCommandFailureTests.setUpsm&' W #zz33 9;"&** !!$..1 %%'rc .VPV\4#)z Implementation of C{_test} which checks that the command fails with C{RuntimeError} because the transport is disconnected. All the parameters except C{d} are ignored. )rrrs&&&&&rrCommandFailureTests._tests !!!\22rrBN) rrrrrrrrrrs@rrDrDs (33rrDN)rtwisted.internet.deferrrrrtwisted.internet.errorrtwisted.internet.taskrtwisted.internet.testingrtwisted.protocols.memcacher r r r twisted.trial.unittestr rrrDrrrrOsY WV1'E ,UTUTpA L(A H3,3r