ó [³XMc@søddlmZddlmZddlmZmZmZmZm Z ej Z ddl m Z dej fd„ƒYZdefd„ƒYZd ejfd „ƒYZd ejfd „ƒYZd ejfd„ƒYZdejfd„ƒYZdS(iÿÿÿÿ(tset(tunittest(t interfacesttasktreactortdeferterror(tfailuretTestableLoopingCallcBseZd„ZRS(cOs&tt|ƒj||Ž||_dS(N(tsuperRt__init__tclock(tselfR tatkw((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyR s(t__name__t __module__R (((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyRst TestExceptioncBseZRS((RR(((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyRst ClockTestCasecBs•eZdZd„Zd„Zd„Zd„Zd„Zd„Zd„Z d„Z d „Z d „Z d „Z d „Zd „Zd„Zd„ZRS(s< Test the non-wallclock based clock implementation. cCs&tjƒ}|j|jƒdƒdS(sV Test that the L{seconds} method of the fake clock returns fake time. iN(RtClockt assertEqualstseconds(R tc((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyt testSeconds s cCsptjƒ}|jdd„dddƒ}|jtjj|ƒƒ|j|jƒdƒ|j|j ƒƒdS(s{ Test that calls can be scheduled for later with the fake clock and hands back an L{IDelayedCall}. icSsdS(N(tNone(R tb((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyt.sRiN( RRt callLatert failUnlessRt IDelayedCallt providedByRtgetTimetactive(R Rtcall((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyt testCallLater(s  cCsKtjƒ}|jdd„dddƒ}|jƒ|j|jƒƒdS(s3 Test that calls can be cancelled. icSsdS(N(R(R R((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyR9sRiN(RRRtcanceltfailIfR (R RR!((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyttestCallLaterCancelled4s  cCs_tjƒ}|jdd„dddƒ}|jdd„dddƒ}|j||kƒd S( s[ Test that the DelayedCall returned is not one previously created. i cSsdS(N(R(R R((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyRDsiRicSsdS(N(R(R R((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyREsiiN(RRRR$(R Rtcall1tcall2((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyttest_callLaterOrdering>s csg‰tjƒ}|jd‡fd†ƒ}|jdƒ|jˆgƒ|jdƒ|jˆdgƒ|j|jƒƒdS(sE Test that advancing the clock will fire some calls. ics ˆjdƒS(N(tappendR((tevents(s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyROsiN(RRRtadvanceRRR$R (R RR!((R*s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyt testAdvanceIs   csAtjƒ}‡‡fd†}|jd|ƒ‰|jdƒdS(s Test attemping to cancel the call in a callback. AlreadyCalled should be raised, not for example a ValueError from removing the call from Clock.calls. This requires call.called to be set before the callback is called. csˆjtjˆjƒdS(N(t assertRaisesRt AlreadyCalledR#((R R!(s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pytcb`siN(RRRR+(R RR/((R R!s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyttestAdvanceCancelWs csšg‰tjƒ}|jd‡fd†dddƒ}|jdƒ|j|jƒdƒ|jdƒ|jˆgƒ|jdƒ|jˆdgƒdS( s1 Test that calls can be delayed. icsˆj||fƒS(N(R)(R R(R*(s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyRlsRigø?gð?N(ii(RRRtdelayRRR+(R RR!((R*s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyttestCallLaterDelayedfs $   cs§g‰tjƒ}|jd‡fd†dddƒ}|jdƒ|jdƒ|j|jƒdƒ|jdƒ|jˆgƒ|jdƒ|jˆdgƒdS( sL Test that calls can have their time reset to a later time. icsˆj||fƒS(N(R)(R R(R*(s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyR{siRiiN(ii(RRRR+tresetRR(R RR!((R*s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyttestCallLaterResetLaterus $    cs}g‰tjƒ}|jd‡fd†dddƒ}|jdƒ|j|jƒdƒ|jdƒ|jˆdgƒdS( sO Test that calls can have their time reset to an earlier time. icsˆj||fƒS(N(R)(R R(R*(s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyR‹siRiiN(ii(RRRR3RRR+(R RR!((R*s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyttestCallLaterResetSooner…s $  cCshtjƒ}|jdd„ƒ}|jdd„ƒ}|jƒ}|jt||gƒt|ƒƒdS(sB Test that we can get a list of all delayed calls icSsdS(N(R(tx((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyR—sicSsdS(N(R(R6((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyR˜sN(RRRtgetDelayedCallsRR(R RR!R'tcalls((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyttest_getDelayedCalls’s   cCs&tjƒ}|j|jƒgƒdS(sk Test that we get an empty list from getDelayedCalls on a newly constructed Clock. N(RRRR7(R R((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyttest_getDelayedCallsEmptyŸs cCs,tjƒ}|jtjj|ƒdƒdS(Ns#Clock does not provide IReactorTime(RRRRt IReactorTimeR(R R((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyttest_providesIReactorTime¨s csg‰d d g}tjƒ‰‡‡fd†}ˆjd|dƒ}|jdƒˆjd|dƒˆjdgdƒ|jˆ|ƒd S( s4 The order of calls scheduled by L{task.Clock.callLater} is honored when adding a new call via calling L{task.Clock.callLater} again. For example, if L{task.Clock.callLater} is invoked with a callable "A" and a time t0, and then the L{IDelayedCall} which results from that is C{reset} to a later time t2 which is greater than t0, and I{then} L{task.Clock.callLater} is invoked again with a callable "B", and time t1 which is less than t2 but greater than t0, "B" will be invoked before "A". Rg@R g@csˆj|ˆjƒfƒS(N(R)R(tn(R tresult(s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyR½sgð?iiN(Rg@(R g@(RRRR3tpumpt assertEqual(R texpectedtlogtimetcall_a((R R>s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyttest_callLaterKeepsCallsOrdered®s    csg‰d d g}tjƒ‰‡‡fd†}ˆjd|dƒ}ˆjd|dƒ|jdƒˆjdgdƒ|jˆ|ƒd S( s: The order of calls scheduled by L{task.Clock.callLater} is honored when re-scheduling an existing call via L{IDelayedCall.reset} on the result of a previous call to C{callLater}. For example, if L{task.Clock.callLater} is invoked with a callable "A" and a time t0, and then L{task.Clock.callLater} is invoked again with a callable "B", and time t1 greater than t0, and finally the L{IDelayedCall} for "A" is C{reset} to a later time, t2, which is greater than t1, "B" will be invoked before "A". Rg@R g@csˆj|ˆjƒfƒS(N(R)R(R=(R R>(s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyRÖsgð?iiN(Rg@(R g@(RRRR3R?R@(R RARBRC((R R>s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyt$test_callLaterResetKeepsCallsOrderedÇs    csŸg‰d d g}tjƒ‰‡‡fd†}ˆjd|dƒ‰‡fd†}ˆjd|ƒˆjd|dƒˆjd gd ƒ|jˆ|ƒd S(s9 The order of calls scheduled by L{task.Clock.callLater} is honored when re-scheduling an existing call via L{IDelayedCall.reset} on the result of a previous call to C{callLater}, even when that call to C{reset} occurs within the callable scheduled by C{callLater} itself. Rg@Rg@csˆj|ˆjƒfƒS(N(R)R(R=(R R>(s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyRêsg@csˆjdƒdS(Ng@(R3((tcall_b(s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyR ísgð?gà?i N(Rg@(Rg@(RRRR?R@(R RARBR ((R RFR>s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyt.test_callLaterResetInsideCallKeepsCallsOrderedàs  (RRt__doc__RR"R%R(R,R0R2R4R5R9R:R<RDRERG(((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyRs         t LoopTestCasecBsqeZdZd„Zd„Zd„Zd„Zd„Zd„Zd„Z d„Z d „Z d „Z d „Z RS( s[ Tests for L{task.LoopingCall} based on a fake L{IReactorTime} implementation. cCs)tjd„ƒ}|j|jtƒdS(sG L{LoopingCall}'s default clock should be the reactor. cSsdS(N(R(((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyRsN(Rt LoopingCallR@R R(R R!((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyttest_defaultClockýscsIg‰d ‰tjƒ‰‡‡‡fd†}tj|ƒ}ˆ|_d‰|jdƒ|jˆdgƒ|jˆjƒˆƒˆjdƒ|jˆdgƒd‰ˆjdƒ|jˆddgƒ|jˆjƒdƒˆjdƒ|jˆddgƒd‰ˆjdƒ|jˆdddgƒ|jˆjƒdƒd S( sÖ When more time than the defined interval passes during the execution of a callback, L{LoopingCall} should schedule the next call for the next interval which is still in the future. cs$ˆjˆjƒƒˆjˆƒdS(N(R)RR+((R t callDurationttimes(s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyt aCallbacksigà?iig@g @iN( RRRRJR tstartR@RR+(R RNR!((R RLRMs:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyttest_callbackTimeSkipss,       csÏg‰tjƒ‰‡‡fd†}tj|ƒ}ˆ|_|jdƒ|jˆdgƒˆjdƒ|jˆddgƒˆjdƒ|jˆdddgƒˆjdƒ|jˆdddgƒdS(s  When more time than the defined interval passes between when L{LoopingCall} schedules itself to run again and when it actually runs again, it should schedule the next call for the next interval which is still in the future. csˆjˆjƒƒdS(N(R)R((R RM(s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyRNAsgà?iiiiN(RRRJR ROR@R+(R RNR!((R RMs:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyttest_reactorTimeSkips8s      cs,g‰tjƒ‰‡‡fd†}tjj|ƒ}ˆ|_d}d}|j|ƒ|jˆd gƒˆj||ƒ|jˆd ||dfgƒˆjd||ƒ|jˆd ||dfd|d|dfgƒˆjdƒ|jˆd ||dfd|d|dfgƒd S(s­ When L{LoopingCall} schedules itself to run again, if more than the specified interval has passed, it should schedule the next call for the next interval which is still in the future. If it was created using L{LoopingCall.withCount}, a positional argument will be inserted at the beginning of the argument list, indicating the number of calls that should have been made. csˆjˆjƒ|fƒdS(N(R)R(tnumCalls(R RM(s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyRNesgà?g{®Gáz„?iiiiiN(ii(ii(ii(ii(RRRJt withCountR ROR@R+(R RNR!tINTERVALtREALISTIC_DELAY((R RMs:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyttest_reactorTimeCountSkipsZs&        cs g‰tjƒ‰‡‡fd†}tjj|ƒ}ˆ|_d}d}|j|ƒ|jˆjƒd ƒˆj||ƒ|jˆjƒ||dfƒˆj|dƒ|jˆjƒd||dfƒˆj|dƒ|jˆjƒd ||dfƒd S( s1 L{LoopingCall.withCount} counts only calls that were expected to be made. So, if more than one, but less than two intervals pass between invocations, it won't increase the count above 1. For example, a L{LoopingCall} with interval T expects to be invoked at T, 2T, 3T, etc. However, the reactor takes some time to get around to calling it, so in practice it will be called at T+something, 2T+something, 3T+something; and due to other things going on in the reactor, "something" is variable. It won't increase the count unless "something" is greater than T. So if the L{LoopingCall} is invoked at T, 2.75T, and 3T, the count has not increased, even though the distance between invocation 1 and invocation 2 is 1.75T. csˆjˆjƒ|fƒdS(N(R)R(tcount(R RM(s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyRNšsgà?g{®Gáz„?iigü?g@gÐ?g@N(ii( RRRJRSR ROR@tpopR+(R RNR!RTRU((R RMs:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyttest_countLengthyIntervalCountsŠs    $c sDdddg}tjƒ}g‰dd‡fd†}t||ddddƒ}|jdƒ}g‰‡fd†}|j|ƒ|j|ƒ|jtˆƒdd tˆƒfƒxZˆD]R\}}} } |j|dƒ|j|dƒ|j| dƒ|j| dƒq¼W|j ƒ|j ˆd |ƒ|j |j ƒdS( Ngš™™™™™©?gš™™™™™¹?csˆj||||fƒdS(N(R)(R RRtd(tL(s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pytfoo½sR RRZcsˆj|ƒdS(N(R)(R>(t theResult(s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyt saveResultÄsisgot %d iterations, not 3i( RRRRROt addCallbackR?RtlentstoptassertIdenticalR$R8( R ttimingsR R\tlctDR^R RRRZ((R]R[s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyttestBasicFunction³s(    csÒdddg}tjƒ}g}t||jdƒ}|jddtƒ}g‰‡fd†}|j|ƒ|j|ƒ|j t |ƒddt |ƒfƒ|j ƒ|j ˆd|ƒ|j |jƒdS(Ngš™™™™™©?gš™™™™™¹?tnowcsˆj|ƒdS(N(R)(R>(R](s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyR^äsisgot %d iterations, not 2i(RRRR)RROtFalseR_R?RR`RaRbR$R8(R RcR R[RdRZR^((R]s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyttestDelayedStartÚs    cCs,tjd„ƒ}|jt|jdƒdS(NcSsdS(N(R(((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyRósiÿÿÿÿ(RRJR-t ValueErrorRO(R Rd((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyt testBadDelayòscsng‰‡fd†}tjƒ}t||ƒ}|j|dtƒ|jƒ|jˆƒ|j|jƒdS(NcsˆjdƒdS(N(R)R((tran(s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyR\úsRg(RRRRORhRaR$R8(R R1R\R Rd((Rls:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyt _stoppingTestøs   cCs |jdƒS(Ni(Rm(R ((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyttestStopAtOncescCs |jdƒS(Ni (Rm(R ((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyttestStoppingBeforeDelayedStart s(RRRHRKRPRQRVRYRfRiRkRmRnRo(((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyRIøs  3 " 0 ) '   tReactorLoopTestCasecBsPeZd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Z RS(cCs4d„}tj|dƒ}|j|jdƒtƒS(NcSst|ƒ‚dS(N(R(R6((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyR\stbargš™™™™™¹?(RRJt assertFailureROR(R R\Rd((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyt testFailures cs:‡fd†}tj|dƒ‰|jˆjdƒtƒS(Ncsˆjƒt|ƒ‚dS(N(RaR(R6(Rd(s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyR\s Rqgš™™™™™¹?(RRJRrROR(R R\((Rds:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyttestFailAndStopscsUg‰‡‡fd†}tj|ƒ‰ˆjdƒ}‡‡fd†}|j|ƒS(Ncs0ˆjdƒtˆƒdkr,ˆjƒndS(Ni(R)RR`Ra((RlRd(s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyR\%s icsˆjtˆƒdƒdS(Ni(RR`(tign(RlR (s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pytstopped,s(RRJROR_(R R\RZRv((RlR Rds:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyttestEveryIteration"s cs]tjƒ‰‡fd†}tj|ƒ|_|jjddtƒtjd|j ˆƒˆS(NcsˆjtjdƒƒdS(Ns'This task also should never get called.(terrbackRtDefaultException((RZ(s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyR\5s iRgi( RtDeferredRRJt_lcRORhRRt!_callback_for_testStopAtOnceLater(R R\((RZs:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyttestStopAtOnceLater1s  cCs'|jjƒtjd|jdƒdS(Nitsuccess(R{RaRRtcallback(R RZ((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyR|>s csgddg}tjƒ‰‡‡fd†}tˆ|ƒ‰ˆjdƒˆj|ƒ|jˆjƒdS(Ngš™™™™™É?gš™™™™™é?cs<tjƒ}|j‡fd†ƒˆjd|jdƒ|S(Ncs ˆjƒS(N(Ra(t_(Rd(s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyRJsi(RRzR_RRR(RZ(RdR (s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyR\Hs (RRRROR?R$R8(R RcR\((RdR s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyttestWaitDeferredBs    cssdg}tjƒ‰‡fd†}tˆ|ƒ}|jdƒ}|j|tƒˆj|ƒ|jˆjƒ|S(Ng333333Ó?cs)tjƒ}ˆjd|jtƒƒ|S(Ng333333Ó?(RRzRRxR(RZ(R (s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyR\]s i( RRRRORrRR?R$R8(R RcR\RdRZ((R s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyttestFailurePropagationSs   csætjƒ}tjƒ‰g‰‡‡fd†}tjj|ƒ}||_|jddtƒ‰|j ˆgƒ|j ddgƒ|j t ˆƒdƒˆj dƒ|j dgƒ|j t ˆƒdƒ|j ˆddgƒdS( s? In the case that the function passed to L{LoopingCall.withCount} returns a deferred, which does not fire before the next interval elapses, the function should not be run again. And if a function call is skipped in this fashion, the appropriate count should be provided. cs+ˆj|ƒtˆƒdkr#ˆSdSdS(Ni(R)R`R(t possibleCount(tdeferredCountsRZ(s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyt countTrackerws gš™™™™™É?Rggš™™™™™Ù?iiiN(RRRRzRJRSR RORhRR?R`RR(R t testClockR…Rd((RZR„s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyttest_deferredWithCountks     ( RRRsRtRwR}R|RR‚R‡(((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyRps     tDeferLaterTestscBs)eZdZd„Zd„Zd„ZRS(s' Tests for L{task.deferLater}. csŸg‰tƒ‰‡‡fd†}tjƒ}tj|d|dddƒ}|j|jˆƒ|jdƒ|jˆgƒ|jdƒ|jˆdgƒ|S(sœ The L{Deferred} returned by L{task.deferLater} is called back after the specified delay with the result of the function passed in. csˆj||fƒˆS(N(R)(R\Rq(tflagtresults(s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pytcallable¤siR\Rqii(sfooRq(tobjectRRt deferLaterR_RbR+R@(R R‹R RZ((RŠR‰s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyt test_callbacks    cCsGd„}tjƒ}tj|d|ƒ}|jdƒ|j|tƒS(sƒ The L{Deferred} returned by L{task.deferLater} is errbacked if the supplied function raises an exception. cSs tƒ‚dS(N(R(((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyR‹·si(RRRR+RrR(R R‹R RZ((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyt test_errback²s    cspg‰tjƒ‰tjˆdˆjdƒ}|jƒ‡‡‡fd†}ˆj|tjƒ|j |ƒ|S(sŒ The L{Deferred} returned by L{task.deferLater} can be cancelled to prevent the call from actually being performed. ics'ˆjgˆjƒƒˆjˆƒdS(N(RR7t assertFalse(tignored(R tcalledR (s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyt cbCancelledÉsN( RRRR)RR#RrRtCancelledErrorR_(R RZR“((R R R’s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyt test_cancelÀs   (RRRHRŽRR•(((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyRˆ™s  N(ttwisted.python.compatRt twisted.trialRttwisted.internetRRRRRRttwisted.pythonRRJRt ExceptionRtTestCaseRRIRpRˆ(((s:/usr/lib/python2.7/dist-packages/twisted/test/test_task.pyts( Üÿ‹