[XMc@s\dZddlZddlZddlmZddlmZmZddlm Z ddl m Z m Z ddl mZdefd YZd ejfd YZd ejfd YZdejfdYZdejfdYZdejfdYZdejfdYZdejfdYZdejfdYZdS(s Test cases for defer module. iN(tunittest(treactortdefer(tClock(tfailuretlog(t unsignedIDt GenericErrorcBseZRS((t__name__t __module__(((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRstDeferredTestCasecBseZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZ dZ!d Z"d!Z#d"Z$d#Z%d$Z&d%Z'd&Z(d'Z)d(Z*d)Z+d*Z,d+Z-d,Z.d-Z/d.Z0d/Z1d0Z2RS(1cCsd|_d|_d|_dS(N(tNonetcallbackResultsterrbackResultstcallback2Results(tself((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pytsetUps  cOs||f|_|dS(Ni(R (Rtargstkw((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt _callbackscOs||f|_dS(N(R(RRR((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt _callback2 scOs||f|_dS(N(R (RRR((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt_errback#scCsYtj}|j|j|jd|j|jd|j|jdifdS(Nthello(R( RtDeferredt addCallbackRtcallbacktfailUnlessEqualR R R (Rtdeferred((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttestCallbackWithoutArgs&s   cCs\tj}|j|jd|jd|j|jd|j|jdifdS(NtworldR(shellosworld( RRRRRRR R R (RR((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttestCallbackWithArgs-s   cCsftj}|j|jdd|jd|j|jd|j|jdidd6fdS(NRR(shello( RRRRRRR R R (RR((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttestCallbackWithKwArgs4s    cCstj}|j|j|j|j|jd|j|jd|j|j dif|j|j difdS(NR(shello(shello( RRRRRRRR R R R(RR((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttestTwoCallbacks<s     cCs tj}tj}tj}tj|||g}g}|d}d}|j|||jd|j||jtd|jd|j|d|ddt |ddj f|dgtj dftj dftj dfgdS( NcSs|j|dS(N(textend(t resultListtresult((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pytcbMscSsdS(N(R (terr((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pytcatchOst1t2t3iii( RRt DeferredListt addCallbacksRt addErrbackterrbackRRtstrtvaluetSUCCESStFAILURE(Rtdefr1tdefr2tdefr3tdlR#R$R&((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttestDeferredListGs$         "   cCs~g}|d}tjg}|j||j|ggg|(tjgdd}|j||j|gdS(NcSs|j|dS(N(tappend(R"R#((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyR$gstfireOnOneCallbacki(RR*R+R(RR#R$R5((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttestEmptyDeferredListes   c Cs6tj}tj}tj}tj|||gdd}g}|j|jd}|j||jd|j|g|jtd|jt |d|d}|j t |j tj d|j f|j}|j|jj t|j|jjjd|j|jddS( NtfireOnOneErrbackicSsdS(N(R (R%((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyR&}sR's from def2isHissubclass(aFailure.type, defer.FirstError) failed: failure's type is %r(s from def2(RRR*R,R7RRR-Rtlent failUnlesst issubclassttypet FirstErrorR/t subFailureRtindex( RR2R3R4R5R#R&taFailuret firstError((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttestDeferredListFireOnOneErrorss(        cCstj}tj|g}g}|j|jg}|j|j|jtd|jd|dj j d|jdt ||jd|dddj j ddS(NtBangii( RRR*R,R7RR-RRR/RR;(Rtd1R5t errorTrapR#((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt!testDeferredListDontConsumeErrorss cCstj}tj|gdt}g}|j|jg}|j|j|jtd|j g||j dt ||j d|dddj j ddS(Nt consumeErrorsREii( RRR*tTrueR,R7RR-RRR;R/R(RRFR5RGR#((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttestDeferredListConsumeErrorss cCstj}tj}|jtdtj||gdt}g}|j|j|jdt ||jddS(NRER:icSsdS(N(R (te((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyts( RRR-RR*RJR,R7RR;(RRFtd2R5R#((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt7testDeferredListFireOnOneErrorWithAlreadyFiredDeferredss  cCstj}tj}|jtd|jdtj||g}g}|j|j|jdt ||j ddS(NREiicSsdS(N(R (RL((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRMs( RRR-RRR*RR7RR;R,(RRFRNR5R#((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt)testDeferredListWithAlreadyFiredDeferredss   cCs<g}tjd}|j|j|j|dgdS(Ntsuccess(RtsucceedRR7t assertEquals(Rtltd((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttestImmediateSuccessscCsLg}tjtd}|j|j|jt|djddS(Ntfaili(RRWRR,R7RSR.R/(RRTRU((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttestImmediateFailurescCspg}tjtd}|j|j|j|j|g|j|jt|dj ddS(NRWi( RRWRtpauseR,R7RStunpauseR.R/(RRTRU((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttestPausedFailures  cCsg}tjjdj|j}|jd|jt|djt g}tjjdj|j}|jd|jt|djt dS(NcSsddS(Nii((t_((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRMsiicSstjtS(N(RtFailuretZeroDivisionError(R\((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRMs( RRRR,R7Rtassert_t isinstanceR/R^(RRTRU((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttestCallbackErrorss$   cCs4tj}|j|j|j|jdS(N(RRRYRRRZ(RRU((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttestUnpauseBeforeCallbacks  cCstj}tj}|j|j|d|j|j|jd|jdksjtd|jd|jdkstd|j |jdddkstd|jfdS(NcSs|S(N((trRN((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRMsis Should not have been called yet.is&Still should not have been called yet.is/Result should have been from second deferred:%s( RRRYRRRR R tAssertionErrorRZ(RRURN((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttestReturnDeferreds      cst}tjj|jtj}|jfd|jdg}|j|j|j|gj |j||gdS(s When a paused Deferred with a result is returned from a callback on another Deferred, the other Deferred is chained to the first and waits for it to be unpaused. csS(N((tignored(tpaused(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRMsN( tobjectRRRRYRR R7RSRZ(RtexpectedtchainedR#((Rgs;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt$test_chainedPausedDeferredWithResults       cstj}tj|jfd|jd|jjdg}j|j|j|dgdS(s A paused Deferred encountered while pushing a result forward through a chain does not prevent earlier Deferreds from continuing to execute their callbacks. csS(N((Rf(tsecond(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRM+sN(RRRRR RYR7RS(RtfirstR#((Rls;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_pausedDeferredChained#s     cCsg}tjtjdtjdgj|j|j|ddggg}tjdtjtg}tj|j|j|jt |d|j t |dt j |djddS(NiiicSsdS(Ni((RL((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRM@s(Rt gatherResultsRRRR7RSRWt ValueErrorR,R;R_R`RR](RRTR5((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttestGatherResults4s1cCs_gg}}tjdd}|j|j|j|j|g|j|dg|S(s L{defer.maybeDeferred} should retrieve the result of a synchronous function and pass it to its resulting L{defer.Deferred}. cSs|dS(Ni((tx((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRMIsi i(Rt maybeDeferredR+R7RS(RtStERU((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_maybeDeferredSyncCs  cCsgg}}y ddWntk r:}t|}nXtjdd}|j|j|j|j|g|jt|d|jt|dj||S(s L{defer.maybeDeferred} should catch exception raised by a synchronous function and errback its resulting L{defer.Deferred} with it. t10icSs|dS(Ni((Rr((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRMZsii( t TypeErrorR.RRsR+R7RSR;R/(RRtRuRLRiRU((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_maybeDeferredSyncErrorPs  csDtjtjfd}jd|j|jdS(s L{defer.maybeDeferred} should let L{defer.Deferred} instance pass by so that original result is the same. csS(N(((RU(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRMhstSuccess(RRRsRRRS(RRN((RUs;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_maybeDeferredAsyncbs  csMtjtjfd}jtjt|j|tS(s L{defer.maybeDeferred} should let L{defer.Deferred} instance pass by so that L{failure.Failure} returned by the original instance is the same. csS(N(((RU(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRMts(RRRsR-RR]t RuntimeErrort assertFailure(RRN((RUs;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_maybeDeferredAsyncErrorms csggtjfd}tjd}|j|jd|jjjj|jj|jg|jd d d dgd S( s When a L{Deferred} encounters a result which is another L{Deferred} which is waiting on a third L{Deferred}, the middle L{Deferred}'s callbacks are executed after the third L{Deferred} fires and before the first receives a result. csmjd|ftjd}fd}fd}|j|j||jj|S(Ns start-of-cbtinnercsjdS(Nt firstCallbackR(s firstCallbacksinner(R7(R#(Rtresults(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRs csjd|f|dS(NtsecondCallbacki(R7(R#(R(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRs(R7RRRRR,(R#RURR(RtfailuresR(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyR$stoutertoranges start-of-cbRRRt orangeorangeN(s start-of-cbsouter(s firstCallbacksinner(ssecondCallbackR(RRRRRRR7R,t assertEqual(RR$R((RRRs;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_innerCallbacksPreservedys"    csggtjfd}tjd}|j||jj|jdd gjd|jg|jd d ddgfgdS( s The continue callback of a L{Deferred} waiting for another L{Deferred} is not necessarily the first one. This is somewhat a whitebox test checking that we search for that callback among the whole list of callbacks. cs{jd|ftj}fd}fd}|j||j||jj|jd|S(NR$cs#jd|ftjgS(NR(R7RRo(Rf(taR(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRscsjd|fdS(NR(R7(R#(R(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRs(R7RRRR,RR (R#RURR(RRR(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyR$s    RR$RtwithersRN(scbsouter(s firstCallbackN(scbsouter(s firstCallbackN( RRRRRR,R7RSR R(RR$R((RRRs;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_continueCallbackNotFirsts   csggtjfd}tj}|j||jfd|jj|jd|jd d gjd|jg|jd d ddgfdgd S(s A callback added to a L{Deferred} after a previous callback attached another L{Deferred} as a result is run after the callbacks of the other L{Deferred} are run. cs{jd|ftj}fd}fd}|j||j||jj|jd|S(NR$cs#jd|ftjgS(NR(R7RRo(Rf(RR(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRscsjd|fdS(NR(R7(R#(R(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRs(R7RRRR,RR (R#RURR(RRR(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyR$s    cs jdS(Ntfinal(R7(Rr(R(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRMsRR$RRRRN(scbsouter(s firstCallbackN(scbsouter(s firstCallbackN(RRRR,R7RRSR (RR$R((RRRs;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_callbackOrderPreserveds"     cstjgfdfd}fd}j|j|jd|jdddgdS(s A callback added to a L{Deferred} by a callback on that L{Deferred} should be added to the end of the callback chain. csjddS(Ni(R7(R#(tcalled(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt callback3scsjddS(Ni(R7(R#(R(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt callback2scsjdjdS(Ni(R7R(R#(RRR(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt callback1s iiiN(RRRRR R(RRR((RRRs;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_reentrantRunCallbackss    csmtjgfdfd}j|jdjddgdS(s A callback added to a L{Deferred} by a callback on that L{Deferred} should not be executed until the running callback returns. csjddS(Ni(R7(R#(R(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyR scs1jdjjdgdS(Ni(R7RRS(R#(RRRR(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRs  iiN(RRRRR R(RR((RRRRs;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_nonReentrantCallbackss   csdtjfdfd}j|jdjtfd}j|S(s After an exception is raised by a callback which was added to a L{Deferred} by a callback on that L{Deferred}, the L{Deferred} should call the first errback with a L{Failure} wrapping that exception. scallback raised exceptioncstdS(N(t Exception(R#(texceptionMessage(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRscsjdS(N(R(R#(RR(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyR!scsj|jfdS(N(RR(t exception(RR(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pytcbFailed&sN(RRRRR R}R(RRR((RRRRs;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt%test_reentrantRunCallbacksWithFailures    cst}tj|tj}|jfd|jdg}j|j|j|dd|j|j|j|d|dS(s  If a first L{Deferred} with a result is returned from a callback on a second L{Deferred}, the result of the second L{Deferred} becomes the result of the first L{Deferred} and the result of the first L{Deferred} becomes C{None}. csS(N((tign(Rm(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRM6siiN( RhRRRRRRR R7tassertIdentical(RR#RlR((Rms;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_synchronousImplicitChain,s   cstjtj}|jfd|jdg}j|jg}|j|j|j|g|j|gt}j||j|dg|j||gdS(s9 If a first L{Deferred} without a result is returned from a callback on a second L{Deferred}, the result of the second L{Deferred} becomes the result of the first L{Deferred} as soon as the first L{Deferred} has one and the result of the first L{Deferred} becomes C{None}. csS(N((R(Rm(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRMIsN(RRRRR R7RSRh(RRlt firstResultt secondResultR#((Rms;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_asynchronousImplicitChain@s     cCstjtd}tj}|j|d|j|t|jdg}|j|j|j |dd|S(s If a first L{Deferred} with a L{Failure} result is returned from a callback on a second L{Deferred}, the first L{Deferred}'s result is converted to L{None} and no unhandled error is logged when it is garbage collected. sFirst Deferred's FailurecSs|S(N((RRm((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRMdsiN( RRWR|RRR}RR R7R(RRmRlR((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt"test_synchronousImplicitErrorChain[s  cstjtj}|jfd|jd|j|tg}j|jg}|j|j|j|g|j|gj td|j|dg|jt |ddS(sP Let C{a} and C{b} be two L{Deferred}s. If C{a} has no result and is returned from a callback on C{b} then when C{a} fails, C{b}'s result becomes the L{Failure} that was C{a}'s result, the result of C{a} becomes C{None} so that no unhandled error is logged when it is garbage collected. csS(N((R(Rm(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRMxssFirst Deferred's FailureiN( RRRRR R}R|R7RSR-R;(RRlRR((Rms;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt#test_asynchronousImplicitErrorChainms   cstjtjjfdtj}|jfdg}|j|jt}jd|jd|j|gj||j||gdS(s L{Deferred} chaining is transitive. In other words, let A, B, and C be Deferreds. If C is returned from a callback on B and B is returned from a callback on A then when C fires, A fires. csS(N((R(Rm(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRMscsS(N((R(Rl(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRMsN(RRRR7RhRR RS(Rtthirdt thirdResultR#((RlRms;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt'test_doubleAsynchronousImplicitChainings       csggtjfd}tjd}|j||jj|jd d gjdjj|jj|jgd|jd ddd gd S(s L{Deferred}s can have callbacks that themselves return L{Deferred}s. When these "inner" L{Deferred}s fire (even asynchronously), the callback chain continues. csmjd|ftjd}fd}fd}|j|j||jj|S(Ns start-of-cbRcsjdS(NRR(s firstCallbacksinner(R7(R#(RR(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRs csjd|f|dS(NRi(R7(R#(R(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRs(R7RRRRR,(R#RURR(RRR(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyR$sRs start-of-cbRRRs&Got errbacks but wasn't expecting any.RRN(s start-of-cbsouter(s firstCallbacksinner(s start-of-cbsouter(s firstCallbacksinner(ssecondCallbacksorange(RRRRRR7RSRR,(RR$R((RRRs;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt'test_nestedAsynchronousChainedDeferredss(    csggtjfd}tjd}|j||jj|jd d gjd|jjjj|jgd|jd d ddgfddggd S(sK L{Deferred}s can have callbacks that themselves return L{Deferred}s. These L{Deferred}s can have other callbacks added before they are returned, which subtly changes the callback chain. When these "inner" L{Deferred}s fire (even asynchronously), the outer callback chain continues. csqjd|ftjd}fd}fd}|j||j||jj|S(Ns start-of-cbRcs#jd|fjdS(NRcSs|gS(N((Rr((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRMs(R7R(Rf(RR(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRscsjd|f|dS(NRi(R7(R#(R(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRs(R7RRRRR,(R#RURR(RRR(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyR$s  Rs start-of-cbRRRs&Got errbacks but wasn't expecting any.RN(s start-of-cbsouter(s firstCallbacksinner(s start-of-cbsouter(s firstCallbacksinner(RRRRRR7RSRR,(RR$R((RRRs;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt9test_nestedAsynchronousChainedDeferredsWithExtraCallbackss(     cCs<tj}tj}|j||j|j|dS(sT When we chain a L{Deferred}, that chaining is recorded explicitly. N(RRt chainDeferredRt _chainedTo(RRtb((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt&test_chainDeferredRecordsExplicitChain&s   cCsItj}tj}|j||jd|j|jddS(sR Any recorded chaining is cleared once the chaining is resolved, since it no longer exists. In other words, if one L{Deferred} is recorded as depending on the result of another, and I{that} L{Deferred} has fired, then the dependency is resolved and we no longer benefit from recording it. N(RRRRR RR(RRR((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt%test_explicitChainClearedWhenResolved0s    csRtj}tj|jfd|jd|j|jdS(s We can chain L{Deferred}s implicitly by adding callbacks that return L{Deferred}s. When this chaining happens, we record it explicitly as soon as we can find out about it. csS(N((Rf(R(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRMHsN(RRRRR RR(RR((Rs;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt&test_chainDeferredRecordsImplicitChain@s    cCs?tj}tt|}|jt|d|fdS(s The C{repr()} of a L{Deferred} contains the class name and a representation of the internal Python ID. sN(RRthexRRStrepr(RRUtaddress((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt test_reprMs cCsCtj}|jd|jt|dtt|dS(sb If a L{Deferred} has been fired, then its C{repr()} contains its result. Rs)N(RRRRSRRR(RRU((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_reprWithResultXs    cCsatj}tj}|j||jt|dtt|tt|fdS(s If a L{Deferred} C{a} has been fired, but is waiting on another L{Deferred} C{b} that appears in its callback chain, then C{repr(a)} says that it is waiting on C{b}. s*N(RRRRSRRR(RRR((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_reprWithChainingds     cs/fd}j|d|ddS(sw The depth of the call stack does not grow as more L{Deferred} instances are chained together. csgfd}tj}gt|D]}tj^q.}|}tj|j}|j|d|j|x/|r|j}|j|d|}qW|jfd|jdx|D]}|jdqWjgjddS(NcsjttjdS(N(R7R;t tracebackt extract_stack(Rf(tstack(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pytrecordStackDepthyscSs|S(N((RR((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRMscSs|S(N((RR((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRMscsS(N((R(tlast(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRMsi(RRtrangetpopRRR RS(thowManyRttopRftinnerDeferredstoriginalInnersRtnewInner(R(RRs;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pytchainDeferredsws( %         iiN(RS(RR((Rs;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_boundedStackDepthrs#cstj}tjtj|jfdjfdjd|jdjdg}j|j|j|dgdS(s Given three Deferreds, one chained to the next chained to the next, callbacks on the middle Deferred which are added after the chain is created are called once the last Deferred fires. This is more of a regression-style test. It doesn't exercise any particular code path through the current implementation of Deferred, but it does exercise a broken codepath through one of the variations of the implementation proposed as a resolution to ticket #411. csS(N((Rf(Rl(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRMscsS(N((Rf(R(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRMsN(RRRRR R7RS(RRmtL((RRls;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt:test_resultOfDeferredResultOfDeferredOfFiredDeferredCalleds      (3RR RRRRRRRR R6R9RDRHRKRORPRVRXR[RaRbReRkRnRqRvRyR{R~RRRRRRRRRRRRRRRRRRRRR(((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyR sb          (             % ) *        ; A   +tFirstErrorTestscBs)eZdZdZdZdZRS(s" Tests for L{FirstError}. cCsetd}y |Wntj}nXtj|d}|jt|dt|fdS(s The repr of a L{FirstError} instance includes the repr of the value of the sub-failure and the index which corresponds to the L{FirstError}. s some textisFirstError[#3, %s]N(RpRR]RR?RR(Rtexctfterror((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRs   cCsetd}y |Wntj}nXtj|d}|jt|dt|fdS(s The str of a L{FirstError} instance includes the str of the sub-failure and the index which corresponds to the L{FirstError}. s some textisFirstError[#5, %s]N(RpRR]RR?RR.(RRRR((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_strs   cCsy ddWntj}nXtj|d}tj|d}ytdWntj}nXtj|d}|j||k|j||k|j||k|j||k|j|dkdS(s L{FirstError} instances compare equal to each other if and only if their failure and index compare equal. L{FirstError} instances do not compare equal to instances of other types. iii tbari i N(RR]RR?Rpt assertTruet assertFalse(Rt firstFailuretonet anotherOnet secondFailuretanother((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_comparisons  (RR t__doc__RRR(((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRs  tAlreadyCalledTestCasecBseZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZRS(cCs tj|_tjtdS(N(Rt getDebuggingt_deferredWasDebuggingt setDebuggingRJ(R((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRscCstj|jdS(N(RRR(R((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttearDownscOsdS(N((RRR((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRscOsdS(N((RRR((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRscCs|jddS(NR(R(RRU((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt_call_1scCs|jddS(Nttwice(R(RRU((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt_call_2 scCs|jtjtdS(N(R-RR]R|(RRU((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt_err_1 scCs|jtjtdS(N(R-RR]R|(RRU((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt_err_2 scCsLtj}|j|j|j|j||jtj|j|dS(N( RRR+RRRtfailUnlessRaisestAlreadyCalledErrorR(RRU((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttestAlreadyCalled_CCs  cCsLtj}|j|j|j|j||jtj|j|dS(N( RRR+RRRRRR(RRU((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttestAlreadyCalled_CEs  cCsLtj}|j|j|j|j||jtj|j|dS(N( RRR+RRRRRR(RRU((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttestAlreadyCalled_EEs  cCsLtj}|j|j|j|j||jtj|j|dS(N( RRR+RRRRRR(RRU((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttestAlreadyCalled_EC"s  cCsad}xA|D]9}|jd|r |jd|r |d7}q q W|j||kdS(Nis %s:s %si(t startswithtendswithR<(RtlinetypetfunctlinesRitcounttline((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt_count)s  cCs|jdjd}|jd||d|jdd|d|jdd|d|jdd|d|jdd|d|jd ||d|jd ||ddS( Nis tCiRRRRtI(RtsplitR(RRLtcallertinvoker1tinvoker2R((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt_check1scCstj}|j|j|j|j|y|j|Wn,tjk rn}|j|dddnX|j ddS(NttestAlreadyCalledDebug_CCRRs2second callback failed to raise AlreadyCalledError( RRR+RRRRRRRW(RRURL((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyR?s  cCstj}|j|j|j|j|y|j|Wn,tjk rn}|j|dddnX|j ddS(NttestAlreadyCalledDebug_CERRs1second errback failed to raise AlreadyCalledError( RRR+RRRRRRRW(RRURL((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRJs  cCstj}|j|j|j|j|y|j|Wn,tjk rn}|j|dddnX|j ddS(NttestAlreadyCalledDebug_ECRRs2second callback failed to raise AlreadyCalledError( RRR+RRRRRRRW(RRURL((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRUs  cCstj}|j|j|j|j|y|j|Wn,tjk rn}|j|dddnX|j ddS(NttestAlreadyCalledDebug_EERRs1second errback failed to raise AlreadyCalledError( RRR+RRRRRRRW(RRURL((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyR`s  cCstjttj}|j|j|j|j|y|j|Wn&tj k ru}|j |j nX|j ddS(Ns2second callback failed to raise AlreadyCalledError( RRtFalseRR+RRRRRtfailIfRRW(RRURL((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttestNoDebuggingks   cCstjttj}|jdtjt|jdtjttj}|jdtjt|jddS(NcSsdS(N(R (R((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRM}scSsdS(N(R (R((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRMs(RRRRtaddBothRJRR (RRU((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttestSwitchDebuggingxs        (RR RRRRRRRRRRRRRRRRRRRR(((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRs(               tDeferredCancellerTestcBseZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZRS(cCs(d|_d|_d|_d|_dS(Ni(R R R RtcancellerCallCount(R((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRs   cCs|j|jdkdS(Nii(ii(RR(R((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRscCs ||_|S(N(R (Rtdata((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRs cCs ||_dS(N(R(RR((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRscCs ||_dS(N(R (RR((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRscCs\tj}|j|j|j|j|j|jjtj |j|j ddS(s A L{defer.Deferred} without a canceller must errback with a L{defer.CancelledError} and not callback. N( RRR+RRtcancelRSR R>tCancelledErrorR R (RRU((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_noCancellers   cCsrtj}|j|j|j|j|jd|jtj |jd|jtj |j t dS(s A L{defer.Deferred} without a canceller, when cancelled must allow a single extra call to callback, and raise L{defer.AlreadyCalledError} if callbacked or errbacked thereafter. N( RRR+RRRRR t assertRaisesRR-R(RRU((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt!test_raisesAfterCancelAndCallbacks    cCsutj}|j|j|j|j|jt|jtj |j d|jtj |jtdS(s A L{defer.Deferred} without a canceller, when cancelled must allow a single extra call to errback, and raise L{defer.AlreadyCalledError} if callbacked or errbacked thereafter. N( RRR+RRRR-RRRRR (RRU((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt test_raisesAfterCancelAndErrbacks   cCsctj}|j|j|j|j|j}|jd|j|j ||jdS(s A L{Deferred} without a canceller, when cancelled and then callbacked, ignores multiple cancels thereafter. N( RRR+RRRR RR R(RRUtcurrentFailure((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt5test_noCancellerMultipleCancelsAfterCancelAndCallbacks     cCstj}|j|j|j|j|j|jjtj |j}|j t |j|jjtj |j|j ||jdS(s A L{defer.Deferred} without a canceller, when cancelled and then errbacked, ignores multiple cancels thereafter. N( RRR+RRRRSR R>RR-RR(RRUR((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt4test_noCancellerMultipleCancelsAfterCancelAndErrbacks    cCsotj}|j|j|j|j|j|jjtj |j}|j|j ||jdS(s Calling cancel multiple times on a deferred with no canceller results in a L{defer.CancelledError}. Subsequent calls to cancel do not cause an error. N( RRR+RRRRSR R>RR(RRUR((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_noCancellerMultipleCancels    csfd}tjd|}|jjj|jjjjtj j}|jj |jjj ddS(s, Verify that calling cancel multiple times on a deferred with a canceller that does not errback results in a L{defer.CancelledError} and that subsequent calls to cancel do not cause an error and that after all that, the canceller was only called once. csjd7_dS(Ni(R(RU(R(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyR st cancelleriN( RRR+RRRRSR R>RRR(RRRUR((Rs;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_cancellerMultipleCancels   csfd}tjd|}|jjj|jjjdjjj tj j tj |j dj tj |jtdS(s Verify that a L{defer.Deferred} calls its specified canceller when it is cancelled, and that further call/errbacks raise L{defer.AlreadyCalledError}. csjd7_dS(Ni(R(RU(R(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRsRiN(RRR+RRRRSRR R>RRRRR R-R(RRRU((Rs;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_simpleCancellers csHfd}tjd|jjjjdS(sQ Verify that a canceller is given the correct deferred argument. csj|dS(N(R(RF(RRU(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyR1sRN(RRR+RRR(RR((RRUs;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_cancellerArg-scsfd}tjd|}|jjj|jd|jjjdjj djj ddS(so Test that cancelling a deferred after it has been callbacked does not cause an error. cs#jd7_|jtdS(Ni(RR-R(RU(R(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyR=sRsbiff!iN( RRR+RRRRRSRR R R (RRRU((Rs;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_cancelAfterCallback8s  csfd}tjd|}|jjj|jt|jjj djj j tjj ddS(s Test that cancelling a L{Deferred} after it has been errbacked does not result in a L{defer.CancelledError}. cs#jd7_|jtdS(Ni(RR-R(RU(R(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRNsRiN(RRR+RRR-RRRSRR R>R R (RRRU((Rs;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_cancelAfterErrbackIs csnfd}tjd|}|jjj|jjjdjjj t dS(s? Test a canceller which errbacks its deferred. cs#jd7_|jtdS(Ni(RR-R(RU(R(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyR^sRiN( RRR+RRRRSRR R>R(RRRU((Rs;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_cancellerThatErrbacksZs  cs~fd}tjd|}|jjj|jjjdjjdjj ddS(s< Test a canceller which calls its deferred. cs jd7_|jddS(Nishello!(RR(RU(R(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRlsRishello!N( RRR+RRRRSRR R R (RRRU((Rs;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_cancellerThatCallbackshs csfd}fd}tjd|tjd|}|jd|jfd|j|jjjj j dj j j tj dS(s Verify that a Deferred, a, which is waiting on another Deferred, b, returned from one of its callbacks, will propagate L{defer.CancelledError} when a is cancelled. csjd7_dS(Ni(R(RU(R(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt innerCancel}scsjtdS(N(R_R(RU(R(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRsRcsS(N((R(R(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRMsiN(RRRR RRR+RRRSRR R>R(RRRR((RRs;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_cancelNestedDeferredws  (RR RRRRRRRRRRRRRR R R R R R(((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRs&                t LogTestCasecBs_eZdZdZdZdZdZdZdZdZ dZ d Z RS( s+ Test logging of unhandled errors. cCs g|_tj|jjdS(s< Add a custom observer to observer logging. N(tcRt addObserverR7(R((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRs cCstj|jjdS(s& Remove the observer. N(RtremoveObserverRR7(R((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRscCs$g|jD]}|dr |^q S(NtisError(R(RRL((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt _loggedErrorsscCsH|j}|jt|d|ddjt|jtdS(sV Check the output of the log observer to see if the error is present. iiRN(RRSR;ttrapR^tflushLoggedErrors(Rtc2((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRs cCs7tjjdjdtj|jdS(s Verify that when a L{Deferred} with no references to it is fired, and its final result (the one not handled by any callback) is an exception, that exception will be logged immediately. cSsddS(Nii((Rr((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRMsiN(RRRRtgctcollectR(R((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt test_errorLogs cCs(d}|tj|jdS(sD Same as L{test_errorLog}, but with an inner frame. cSs-tj}|jd|jddS(NcSsddS(Nii((Rr((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRMsi(RRRR(RU((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt_subErrorLogWithInnerFrameRefs N(RRR(RR((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_errorLogWithInnerFrameRefs  cCs(d}|tj|jdS(sQ Same as L{test_errorLogWithInnerFrameRef}, plus create a cycle. cSs9tj}|j|d||_|jddS(NcSsddS(Nii((RrRU((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRMsi(RRRt_dR(RU((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt_subErrorLogWithInnerFrameCycles  N(RRR(RR((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt test_errorLogWithInnerFrameCycles  cCstj}|jd|jdg}g}|j|j|j|j|g|jt|d|dj t ~~~t j |j|j gdS(s If one Deferred with an error result is returned from a callback on another Deferred, when the first Deferred is garbage collected it does not log its error. cSstjtdS(Ntzoop(RRWR|(R((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRMsiiN(RRRRR R+R7RSR;RRRRR(RRURterrors((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_chainedErrorCleanups    csetjtd}tj|jfdd}tj|j|j gdS(s If a Deferred with a failure result has an errback which chains it to another Deferred, the initial failure is cleared by the errback so it is not logged. soh nocsS(N((Rf(tgood(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRMsN( RRWRRR,R RRRSR(Rtbad((R$s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_errorClearedByChainings    ( RR RRRRRRRR R#R&(((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRs     tDeferredTestCaseIIcBs,eZdZdZdZdZRS(cCs d|_dS(Ni(t callbackRan(R((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRscCs#tjg}|j|jdS(sTesting empty DeferredList.N(RR*Rtcb_empty(RR5((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttestDeferredListEmpty scCsd|_|jg|dS(Ni(R(R(Rtres((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyR)s cCs|j|jddS(NsCallback was never run.(R<R((R((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRs(RR RR*R)R(((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyR's   tOtherPrimitivescBsteZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z RS( cCs|jd7_dS(Ni(tcounter(RR#((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt_incrscCs d|_dS(Ni(R-(R((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRscsGtj}|jjjj|jjjd|jjjj|jjjd|j j|jjjd|j j |jjjdj t |j t}t}tjfd}|j |dd|}j|jjj||jfd|jjjj|jjjdj|jj|j|jjjd|jjfd}|jjjjtj|j j |jdS( Niics ||_S(N(R(RR(tcontrolDeferred(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pythelper5s RRcstd|S(NR#(tsetattr(Rr(R(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRM=sicstd|S(NR#(R1(Rr(R(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRMHs(Rt DeferredLocktacquireRR.R<tlockedRSR-treleaseRRRxtrunRhRRRR#RRR>R(Rtlockt firstUniquet secondUniqueR0tresultDeferredRU((RR/s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttestLocksD         csBfd}tj}|j}|j||jdS(s When canceling a L{Deferred} from a L{DeferredLock} that already has the lock, the cancel should have no effect. csjddS(NsUnexpected errback call!(RW(R\(R(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt_failOnErrbackUsN(RR2R3R,R(RR<R7RU((Rs;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_cancelLockAfterAcquiredPs    cCsCtj}|j|j}|j|tj|jdS(s When canceling a L{Deferred} from a L{DeferredLock} that does not yet have the lock (i.e., the L{Deferred} has not fired), the cancel should cause a L{defer.CancelledError} failure. N(RR2R3R}RR(RR7RU((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_cancelLockBeforeAcquired]s    c s d}tj|}tjfd}g}t}|j|d|d|}|j|j|j|j|j|g|j|j |j d|j|j d|j|j dd|_ xDtdd|D]/}|jj|j|j|j |qWgfd}fd} |jj|| } | j|jtg|jj|j|j|j ||j|j|j |dx<tdd|D]'}|j|j|j |dqWdS( Ni cs ||_S(N(targ(RR?(R/(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyR0os RR?iicsjtdS(N(R7R(Rc(RQ(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRWscsjtdS(N(R7RJ(Rc(RQ(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRRs(RtDeferredSemaphoreRRhR6RR7R.RSR?RR RR-RR3R+RRJR5( RtNtsemR0Rt uniqueObjectR:tiRWRRRU((RQR/s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt testSemaphorejs>       cCs0|jttjd|jttjddS(sz If the token count passed to L{DeferredSemaphore} is less than one then L{ValueError} is raised. iiN(RRpRR@(R((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_semaphoreInvalidTokensscsEfd}tjd}|j}|j||jdS(s When canceling a L{Deferred} from a L{DeferredSemaphore} that already has the semaphore, the cancel should have no effect. csjddS(NsUnexpected errback call!(RW(R\(R(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyR<siN(RR@R3R,R(RR<RBRU((Rs;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt!test_cancelSemaphoreAfterAcquireds   cCsFtjd}|j|j}|j|tj|j|S(s When canceling a L{Deferred} from a L{DeferredSemaphore} that does not yet have the semaphore (i.e., the L{Deferred} has not fired), the cancel should cause a L{defer.CancelledError} failure. i(RR@R3R}RR(RRBRU((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt"test_cancelSemaphoreBeforeAcquireds    cCs d\}}tj||}g}x*t|D]}|jj|jq1W|jtj|jx;t|D]-}|j||j |t|dqtWx;t|D]-}|j|||j |t|qW|jtj |jdg}xKt|D]=}|jj|j|j |t|||dqWtj}g}x*t|D]}|jj|jqoWx!t|D]}|j|qW|j |t|tjdd}|jtj |jdtjdd}|jtj|jdS(Niitsizeitbacklog(ii( Rt DeferredQueueRtgetRR7RtQueueUnderflowtputRSt QueueOverflowR (RRAtMtqueuetgottenRD((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt testQueues8  % csOfd}tj}|j}|j||jd|jdS(s When canceling a L{Deferred} from a L{DeferredQueue} that already has a result, the cancel should have no effect. csjddS(NsUnexpected errback call!(RW(R\(R(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyR<sN(RRKRLR,RNR R(RR<RQRU((Rs;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt#test_cancelQueueAfterSynchronousGets     csTtjj}j|tj|jfd}|j|S(s When canceling a L{Deferred} from a L{DeferredQueue} that does not have a result (i.e., the L{Deferred} has not fired), the cancel causes a L{defer.CancelledError} failure. If the queue has a result later on, it doesn't try to fire the deferred. cs&jdjjjdS(N(RNR RLRR(tignore(RQR(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyR$s (RRKRLR}RRR(RRUR$((RQRs;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_cancelQueueAfterGets    (RR R.RR;R=R>RERFRGRHRSRTRV(((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyR,s   3 .   & tDeferredFilesystemLockTestCasecBsMeZdZdZdZdZdZdZdZdZ RS(s8 Test the behavior of L{DeferredFilesystemLock} cCs1t|_tj|jd|j|_dS(Nt scheduler(RtclockRtDeferredFilesystemLocktmktempR7(R((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyR s cCs|jjdd}|S(sI Test that the lock can be acquired when no lock is held ttimeouti(R7tdeferUntilLocked(RRU((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_waitUntilLockedWithNoLockscCsY|j|jj|jjdd}|j|tj|jjdgd|S(ss Test that the lock can not be acquired when the lock is held for longer than the timeout. R\g@ii (R<R7R]R}Rt TimeoutErrorRYtpump(RRU((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt%test_waitUntilLockedWithTimeoutLockeds cs{fd}jjjjjdjjjjdd}|j|jjdgd|S(s| Test that a lock can be acquired while a lock is held but the lock is unlocked before our timeout. cs!|jtjjddS(NsShould not have timed out(RRR_RW(R(R(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt onTimeout-siR\i (R<R7RYt callLatertunlockR]R,R`(RRbRU((Rs;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt'test_waitUntilLockedWithTimeoutUnlocked(s cCs,tj|j}|j|jtdS(sE Test that the default scheduler is set up properly. N(RRZR[RSt _schedulerR(RR7((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_defaultScheduler<scCsk|jj|jjd|jj|jj}|jj}|j|tj|jjd|S(s| Test that an appropriate exception is raised when attempting to use deferUntilLocked concurrently. i( R7RYRcRdR]R}RtAlreadyTryingToLockErrortadvance(RRURN((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_concurrentUsageEs csefd}jjjjdjjjj}|j|jjd|S(sO Test that a DeferredFilesystemLock can be used multiple times cs jjjj}|S(N(R7RdR](RRU(R(s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyt lockAquired[s i(R7RYRcRdR]RRi(RRkRU((Rs;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyttest_multipleUsagesWs  ( RR RRR^RaReRgRjRl(((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyRWs    (RRRt twisted.trialRttwisted.internetRRttwisted.internet.taskRttwisted.pythonRRttwisted.python.utilRRRtTestCaseR RRRRR'R,RW(((s;/usr/lib/python2.7/dist-packages/twisted/test/test_defer.pyts&Dv