h8SrSSKrSSKrSSKrSSKJr SSKJrJrJ r J r J r J r J r SSKJrJr SSKJr SSKJr SSKJr SS KJr \r\(a\R4(dSr"S S \5r"S S \5r"SS\5r"SS\5r"SS\5rSr "SS\ RB5r"\"\ RF"\ S5(+S5"SS\55r$\"\ RJ"\ S5(+S5"SS\55r&"SS\ RN5r("SS \ RR5r*"S!S"\5r+"S#S$5r,"S%S&\RZ5r."S'S(\,5r/"S)S*\5r0"S+S,\5r1"S-S.\5r2g!\a SrGNNf=f)/zB Tests for lots of functionality provided by L{twisted.internet}. N)skipIf)abstractbasedefererror interfacesprotocolreactor)Deferredpassthru) Connector)util)TestCase)sslc\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rSrSrSrSrSrSrSrSrSrSrSrg)ThreePhaseEventTestszI Tests for the private implementation helpers for system event triggers. cfSUl[5Ul[R"5Ulg)zB Create a trigger, an argument, and an event to be used by tests. cgN)xs a/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/test/test_internet.py,ThreePhaseEventTests.setUp..(sN)triggerobjectargr_ThreePhaseEventeventselfs rsetUpThreePhaseEventTests.setUp$s$& 8**, rcUR[URRSURUR 5 g)z\ L{_ThreePhaseEvent.addTrigger} should raise L{KeyError} when called with an invalid phase. xxxN) assertRaisesKeyErrorr! addTriggerrrr"s rtest_addInvalidPhase)ThreePhaseEventTests.test_addInvalidPhase,s/  djj++UDLL$(( rcURRSURUR5 UR URR URUR404/5 g)z L{_ThreePhaseEvent.addTrigger} should accept C{'before'} as a phase, a callable, and some arguments and add the callable with the arguments to the before list. beforeN)r!r*rr assertEqualr.r"s rtest_addBeforeTrigger*ThreePhaseEventTests.test_addBeforeTrigger5P h dhh? **dllTXXK-L,MNrcURRSURUR5 UR URR URUR404/5 g)z L{_ThreePhaseEvent.addTrigger} should accept C{'during'} as a phase, a callable, and some arguments and add the callable with the arguments to the during list. duringN)r!r*rrr/r4r"s rtest_addDuringTrigger*ThreePhaseEventTests.test_addDuringTrigger>r2rcURRSURUR5 UR URR URUR404/5 g)z L{_ThreePhaseEvent.addTrigger} should accept C{'after'} as a phase, a callable, and some arguments and add the callable with the arguments to the after list. afterN)r!r*rrr/r8r"s rtest_addAfterTrigger)ThreePhaseEventTests.test_addAfterTriggerGsP gt||TXX> ))T\\DHH;,K+LMrcURRSURUR5nURR U5 UR URR /5 g)z L{_ThreePhaseEvent.removeTrigger} should accept an opaque object previously returned by L{_ThreePhaseEvent.addTrigger} and remove the associated trigger. r.N)r!r*rr removeTriggerr/r.r#handles rtest_removeTrigger'ThreePhaseEventTests.test_removeTriggerPsP &&xtxxH   ( **B/rcjUR[URR[ 55 g)z L{_ThreePhaseEvent.removeTrigger} should raise L{ValueError} when given an object not previously returned by L{_ThreePhaseEvent.addTrigger}. N)r( ValueErrorr!r<rr"s rtest_removeNonexistentTrigger2ThreePhaseEventTests.test_removeNonexistentTriggerZs" *djj&>&>IrcURRSURUR5nURR U5 UR [ URRU5 g)z L{_ThreePhaseEvent.removeTrigger} should raise L{ValueError} the second time it is called with an object returned by L{_ThreePhaseEvent.addTrigger}. r.N)r!r*rrr<r(rBr=s rtest_removeRemovedTrigger.ThreePhaseEventTests.test_removeRemovedTriggerasR &&xtxxH   ( *djj&>&>GrcUR[URRSURUR 4045 g)z L{_ThreePhaseEvent.removeTrigger} should raise L{ValueError} if it is given a trigger handle which resembles a valid trigger handle aside from its phase being incorrect. r'N)r(r)r!r<rrr"s rtest_removeAlmostValidTrigger2ThreePhaseEventTests.test_removeAlmostValidTriggerks7  djj.. txxkSU0V rc\/nURRSURS5 URRSURS5 URRSURS5 URRSURS5 URRSURS5 URRSURS 5 URU/5 URR 5 URU/S Q5 g ) zl L{_ThreePhaseEvent.fireEvent} should call I{before}, I{during}, and I{after} phase triggers in that order. r8firstr8r4rMr4r.rMr.secondr.rQr4rQr8)rOrPrNrRrLrSN)r!r*appendr/ fireEventr#eventss rtest_fireEvent#ThreePhaseEventTests.test_fireEventus  gv}}6HI h 7JK h 7JK h 7KL h 7KL gv}}6IJ $     rc^/n[5mURRSU4Sj5 URRSURS5 URRSURS5 UR U/5 URR 5 UR U/5 TR S5 UR USS/5 g)z L{_ThreePhaseEvent.fireEvent} should wait for any L{Deferred} returned by a I{before} phase trigger before proceeding to I{during} events. r.c>T$rr beforeResultsrr>ThreePhaseEventTests.test_asynchronousBefore.. rr4r8N)r r!r*rTr/rUcallback)r#rWr]s @rtest_asynchronousBefore,ThreePhaseEventTests.test_asynchronousBefores z  h(<= h x@ gv}}g> $  $d# (G!45rc^/n"SS[5mU4SjnURRSU5 URRSURS5 URRSURS5 URR 5 UR USS/5 UR T5nUR [U5S5 g)zy If a before-phase trigger raises a synchronous exception, it should be logged and the remaining triggers should be run. c\rSrSrSrg)HThreePhaseEventTests.test_beforeTriggerException..DummyExceptionrN__name__ __module__ __qualname____firstlineno____static_attributes__rrrDummyExceptionre rrmc>T"5errrmsrraisingTriggerHThreePhaseEventTests.test_beforeTriggerException..raisingTrigger  " "rr.r4N Exceptionr!r*rTrUr/flushLoggedErrorslenr#rWrqerrorsrms @rtest_beforeTriggerException0ThreePhaseEventTests.test_beforeTriggerExceptions  Y  # h7 h x@ h x@  (H!56''7 Va(rc^/n"SS[5mU4SjnURRSU5 URRSURS5 URRSURS5 URR 5 UR USS/5 UR T5nUR [U5S5 g)zy If a during-phase trigger raises a synchronous exception, it should be logged and the remaining triggers should be run. c\rSrSrSrg)HThreePhaseEventTests.test_duringTriggerException..DummyExceptionrNrgrrrrmrrnrrmc>T"5errrpsrrqHThreePhaseEventTests.test_duringTriggerException..raisingTriggerrsrr4r8rtNrurys @rtest_duringTriggerException0ThreePhaseEventTests.test_duringTriggerExceptions  Y  # h7 h x@ gv}}g>  (G!45''7 Va(rcv^^/nUU4SjnTRRSURS5mTRRSU5 TRRSURS5 TR[S[ TRR 5 TRUSS/5 g)z| If a before-phase trigger tries to remove another before-phase trigger which has already run, a warning should be emitted. c<>TRRT5 grr!r< beforeHandler#srr<WThreePhaseEventTests.test_synchronousRemoveAlreadyExecutedBefore..removeTriggers JJ $ $\ 2rr.rOrPzdRemoving already-fired system event triggers will raise an exception in a future version of Twisted.N)r!r*rT assertWarnsDeprecationWarning__file__rUr/)r#rWr<rs` @r+test_synchronousRemoveAlreadyExecutedBefore@ThreePhaseEventTests.test_synchronousRemoveAlreadyExecutedBefores  3zz,, fmm%8  h 6 h 7KL   8  JJ   "57K!LMrcD^^/nTRRSUU4Sj5 TRRSURS5mTRRSURS5 TRR5 TR US/5 g)z~ If a before-phase trigger removes another before-phase trigger which has not yet run, the removed trigger should not be run. r.c:>TRRT5$rrrsrrJThreePhaseEventTests.test_synchronousRemovePendingBefore.. 0H0H0VrrOrPNr!r*rTrUr/)r#rWrs` @r#test_synchronousRemovePendingBefore8ThreePhaseEventTests.test_synchronousRemovePendingBefore  h(VWzz,, fmm%8  h 7KL  "6!78rcD^^/nTRRSUU4Sj5 TRRSURS5mTRRSURS5 TRR5 TR US/5 g)zg If a before-phase trigger removes a during-phase trigger, the during-phase trigger should not be run. r.c:>TRRT5$rr duringHandler#srrJThreePhaseEventTests.test_synchronousBeforeRemovesDuring..rrr4r8Nrr#rWrs` @r#test_synchronousBeforeRemovesDuring8ThreePhaseEventTests.test_synchronousBeforeRemovesDuringsw  h(VWzz,,Xv}}hO  gv}}g>  '+rc^/n[5mURRSU4Sj5 URRSURS5nURRSURS5 URR 5 URR U5 TR S5 URUS/5 g)z If a before-phase trigger returns a L{Deferred} and later removes a during-phase trigger before the L{Deferred} fires, the during-phase trigger should not be run. r.c>T$rrr\srrKThreePhaseEventTests.test_asynchronousBeforeRemovesDuring..r_rr4r8N)r r!r*rTrUr<r`r/)r#rWrr]s @r$test_asynchronousBeforeRemovesDuring9ThreePhaseEventTests.test_asynchronousBeforeRemovesDurings z  h(<=zz,,Xv}}hO  gv}}g>    .d# '+rc&^^^/mU4SjnTRRSU5 TRRSUU4Sj5 TRRSU5mTRR5 TRTS/5 g)z If a before-phase trigger removes a during-phase trigger which is identical to an already-executed before-phase trigger aside from their phases, no warning should be emitted and the during-phase trigger should not be run. c(>TRS5 g)NrrTrWsrr]ThreePhaseEventTests.test_synchronousBeforeRemovesConspicuouslySimilarDuring..triggers MM) $rr.c:>TRRT5$rr) duringTriggerr#srr^ThreePhaseEventTests.test_synchronousBeforeRemovesConspicuouslySimilarDuring..s 0H0H0Wrr4rN)r!r*rUr/)r#rrrWs` @@r7test_synchronousBeforeRemovesConspicuouslySimilarDuringLThreePhaseEventTests.test_synchronousBeforeRemovesConspicuouslySimilarDuring sr % h0 h(WX --h@   )-rcD^^/nTRRSUU4Sj5 TRRSURS5mTRRSURS5 TRR5 TR US/5 g)z~ If a during-phase trigger removes another during-phase trigger which has not yet run, the removed trigger should not be run. r4c:>TRRT5$rrrsrrJThreePhaseEventTests.test_synchronousRemovePendingDuring..%rrrNrRNrrs` @r#test_synchronousRemovePendingDuring8ThreePhaseEventTests.test_synchronousRemovePendingDuringrrc/nURRSURS5 URRSURS5 URRSURS5 URR5 URR5 UR U/SQ5 g)zU A trigger should only be called on the first call to L{_ThreePhaseEvent.fireEvent}. r.r4r8)r.r4r8NrrVs rtest_triggersRunOnce)ThreePhaseEventTests.test_triggersRunOnce-s  h x@ h x@ gv}}g>   !>?rc^^/mUU4SjnTRRSTRS5 TRRSU5 TRR5 TR TSS/5 g)z The temporary list L{_ThreePhaseEvent.finishedBefore} should be emptied and the state reset to C{'BASE'} before the first during-phase trigger executes. c>TRS5 TRTRR/5 TRTRRS5 g)Nr4BASE)rTr/r!finishedBeforestate)rWr#srrNThreePhaseEventTests.test_finishedBeforeTriggersCleared..duringTriggerBsC MM( #   TZZ66 ;   TZZ--v 6rr.r4Nr)r#rrWs` @r"test_finishedBeforeTriggersCleared7ThreePhaseEventTests.test_finishedBeforeTriggersCleared:sd  7 h x@ h 6  (H!56r)rr!rN)rhrirjrk__doc__r$r+r0r5r9r?rCrFrIrXrar{rrrrrrrrrrlrrrrrsw- OON0JH  66")*)*N0 9 ,, .$ 9 @7rrc~\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rSrSrSrSrSrSrSrg)SystemEventTestsiMa Tests for the reactor's implementation of the C{fireSystemEvent}, C{addSystemEventTrigger}, and C{removeSystemEventTrigger} methods of the L{IReactorCore} interface. @ivar triggers: A list of the handles to triggers which have been added to the reactor. c/Ulg)z9 Create an empty list in which to store trigger handles. Ntriggersr"s rr$SystemEventTests.setUpWs  rcUR(aEURR5n[R"U5 UR(aMDgg![[ 4a N'f=f)z1 Remove all remaining triggers from the reactor. N)rpopr removeSystemEventTriggerrBr)r#rs rtearDownSystemEventTests.tearDown]sTmmmm'')G 009mmm)  sAA+*A+cj[R"XU5nURRU5 U$)zC Add a trigger to the reactor and remember it in C{self.triggers}. )r addSystemEventTriggerrrT)r#r!phasefuncts rr*SystemEventTests.addTriggerhs-  ) )% = Qrcf[R"U5 URRU5 g)zL Remove a trigger by its handle from the reactor and from C{self.triggers}. N)r rrremovers rr<SystemEventTests.removeTriggerps$ ((1 W%rc^Sn/mU4SjnURXU5 URT/5 [R"U5 URTS/5 g)Ntestc(>TRS5 grrrsrr.trigger| MM$ rr*r/r fireSystemEvent)r#r eventTyperrWs @r_addSystemEventTriggerTest+SystemEventTests._addSystemEventTriggerTestxsR   '2 $ * $(rc&URS5 g)z L{IReactorCore.addSystemEventTrigger} should accept the C{'before'} phase and not call the given object until the right event is fired. r.Nrr"s rtest_beforePhase!SystemEventTests.test_beforePhase ''1rc&URS5 g)z L{IReactorCore.addSystemEventTrigger} should accept the C{'during'} phase and not call the given object until the right event is fired. r4Nrr"s rtest_duringPhase!SystemEventTests.test_duringPhaserrc&URS5 g)z L{IReactorCore.addSystemEventTrigger} should accept the C{'after'} phase and not call the given object until the right event is fired. r8Nrr"s rtest_afterPhase SystemEventTests.test_afterPhases ''0rcPSnUR[URSUS5 g)zp L{IReactorCore.addSystemEventTrigger} should reject phases other than C{'before'}, C{'during'}, or C{'after'}. rr'cgrrrrrr4SystemEventTests.test_unknownPhase..strN)r(r)r*)r#rs rtest_unknownPhase"SystemEventTests.test_unknownPhases#   (DOOUI|Trc^Sn/mU4SjnU4SjnURSX5 URSX5 URT/5 [R"U5 URTSS/5 g)z L{IReactorCore.addSystemEventTrigger} should call triggers added to the C{'before'} phase before it calls triggers added to the C{'during'} phase. rc(>TRS5 gNr.rrsr beforeTriggerASystemEventTests.test_beforePreceedsDuring..beforeTrigger MM( #rc(>TRS5 gNr4rrsrrASystemEventTests.test_beforePreceedsDuring..duringTriggerrrr.r4Nr)r#rrrrWs @rtest_beforePreceedsDuring*SystemEventTests.test_beforePreceedsDuringsj   $ $ ); ); $ * (H!56rc^Sn/mU4SjnU4SjnURSX5 URSX5 URT/5 [R"U5 URTSS/5 g)z L{IReactorCore.addSystemEventTrigger} should call triggers added to the C{'during'} phase before it calls triggers added to the C{'after'} phase. rc(>TRS5 grrrsrr@SystemEventTests.test_duringPreceedsAfter..duringTriggerrrc(>TRS5 g)Nr8rrsr afterTrigger?SystemEventTests.test_duringPreceedsAfter..afterTrigger MM' "rr4r8Nr)r#rrrrWs @rtest_duringPreceedsAfter)SystemEventTests.test_duringPreceedsAftersj   $ # ); 9 $ * (G!45rc@^^[5mSn/mU4SjnU4SjnURSX5 URSX5 URT/5 [R"U5 URT/5 TR S5 URTS/5 g)z If a trigger added to the C{'before'} phase of an event returns a L{Deferred}, the C{'during'} phase should be delayed until it is called back. rc>T$rr)triggerDeferredsrrBSystemEventTests.test_beforeReturnsDeferred..beforeTriggers " "rc(>TRS5 grrrsrrBSystemEventTests.test_beforeReturnsDeferred..duringTriggerrrr.r4Nr r*r/r rr`)r#rrrrWrs @@rtest_beforeReturnsDeferred+SystemEventTests.test_beforeReturnsDeferreds #*  # $ ); ); $ * $  & (,rc^^^[5m[5mSn/mU4SjnU4SjnU4SjnURSX5 URSX5 URSX5 URT/5 [R"U5 URT/5 TR S5 URT/5 TR S5 URTS/5 g)z If more than one trigger added to the C{'before'} phase of an event return L{Deferred}s, the C{'during'} phase should be delayed until they are all called back. rc>T$rr firstDeferredsrfirstBeforeTriggerNSystemEventTests.test_multipleBeforeReturnDeferred..firstBeforeTrigger  rc>T$rr)secondDeferredsrsecondBeforeTriggerOSystemEventTests.test_multipleBeforeReturnDeferred..secondBeforeTriggers ! !rc(>TRS5 grrrsrrISystemEventTests.test_multipleBeforeReturnDeferred..duringTriggerrrr.r4Nr )r#rrrrrWrrs @@@r!test_multipleBeforeReturnDeferred2SystemEventTests.test_multipleBeforeReturnDeferreds ! !  ! " $ )@ )A ); $ * $t$ $% (,rc^^^Sn/m[5m[5mU4SjnU4SjnUU4SjnU4SjnURSX5 URSX5 URSX5 URSX5 URT/5 [R"U5 URTS/5 TR S5 URTSS/5 g) a1 If a trigger added to the C{'before'} phase of an event calls back a L{Deferred} returned by an earlier trigger in the C{'before'} phase of the same event, the remaining C{'before'} triggers for that event should be run and any further L{Deferred}s waited on before proceeding to the C{'during'} events. rc>T$rrrsrraSystemEventTests.test_subsequentBeforeTriggerFiresPriorBeforeDeferred..firstBeforeTriggerrrc(>TRS5 gr)r`rsrrbSystemEventTests.test_subsequentBeforeTriggerFiresPriorBeforeDeferred..secondBeforeTriggers  " "4 (rc*>TRS5 T$rrrWrsrthirdBeforeTriggeraSystemEventTests.test_subsequentBeforeTriggerFiresPriorBeforeDeferred..thirdBeforeTriggers MM( #! !rc(>TRS5 grrrsrr\SystemEventTests.test_subsequentBeforeTriggerFiresPriorBeforeDeferred..duringTriggerrrr.r4Nr ) r#rrrr"rrWrrs @@@r4test_subsequentBeforeTriggerFiresPriorBeforeDeferredESystemEventTests.test_subsequentBeforeTriggerFiresPriorBeforeDeferreds  ! ! ) " $ )@ )A )@ ); $ * (,% (H!56rc^Sn/mU4SjnU4SjnURSX5 URURSX55 URT/5 [R"U5 URTS/5 g)zl A trigger removed with L{IReactorCore.removeSystemEventTrigger} should not be called when the event fires. rc(>TRS5 g)NrMrrsrrJSystemEventTests.test_removeSystemEventTrigger..firstBeforeTrigger.rrc(>TRS5 g)NrQrrsrrKSystemEventTests.test_removeSystemEventTrigger..secondBeforeTrigger1rrr.rMN)r*r<r/r r)r#rrrrWs @rtest_removeSystemEventTrigger.SystemEventTests.test_removeSystemEventTrigger&sr   # $ )@ 4??8YTU $ * '+rc HURSSS5nURU5 UR[[R S5 UR[ [R U5 UR[[R USSUSSS-45 g)a Passing an object to L{IReactorCore.removeSystemEventTrigger} which was not returned by a previous call to L{IReactorCore.addSystemEventTrigger} or which has already been passed to C{removeSystemEventTrigger} should result in L{TypeError}, L{KeyError}, or L{ValueError} being raised. r4rcgrrrrrrKSystemEventTests.test_removeNonExistentSystemEventTrigger..BsdrNr)r'rt)r*r<r( TypeErrorr rrBr))r#bs r(test_removeNonExistentSystemEventTrigger9SystemEventTests.test_removeNonExistentSystemEventTrigger:s OOHfl ; 1 )W%E%EtL *g&F&FJ  g661x!A$qr(?R8S rc`^^^ /mSn[5mUU4SjnU4SjnSn[5m UU 4SjnU4SjnURSX5 URSX5 URSXE5 URSXF5 URT/5 [R"U5 URTS /5 [R"U5 URTS S /5 TR S 5 URT/S Q5 T R S 5 URT/S Q5 g )z L{IReactorCore.fireSystemEvent} should behave the same way for a particular system event regardless of whether Deferreds are being waited on for a different system event. z first-eventc*>TRS5 T$)Nr.rMr)rWrsrbeforeFirstEventQSystemEventTests.test_interactionBetweenDifferentEvents..beforeFirstEventUs MM- . rc(>TRS5 g)Nr8rMrrsrafterFirstEventPSystemEventTests.test_interactionBetweenDifferentEvents..afterFirstEventYs MM, -rz second-eventc*>TRS5 T$)Nr.rQrr!srbeforeSecondEventRSystemEventTests.test_interactionBetweenDifferentEvents..beforeSecondEvent_s MM. /! !rc(>TRS5 g)Nr8rQrrsrafterSecondEventQSystemEventTests.test_interactionBetweenDifferentEvents..afterSecondEventcs MM- .rr.r8r8r@N)r8r@r<)r8r@r<rDr ) r# firstEventr9r= secondEventrArErWrrs @@@r&test_interactionBetweenDifferentEvents7SystemEventTests.test_interactionBetweenDifferentEventsJs "   ! .% ! " / *? = +A ? $  + "5!67  , "57K!LM t$  S %    rrN)rhrirjrkrr$rr*r<rrrrrrrr rr&r-r4rIrlrrrrrMs^ & )221U7*6*-0->"7H,( > rrc`\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rSrSrg) TimeTestsiz1 Tests for the IReactorTime part of the reactor. c\[R"5nURX- U-U5 g)a L{twisted.internet.reactor.seconds} should return something like a number. 1. This test specifically does not assert any relation to the "system time" as returned by L{time.time} or L{twisted.python.runtime.seconds}, because at some point we may find a better option for scheduling calls than wallclock-time. 2. This test *also* does not assert anything about the type of the result, because operations may not return ints or floats: For example, datetime-datetime == timedelta(0). N)r secondsr/)r#nows r test_secondsTimeTests.test_secondss&oo S#.rc[RnS[l[R"SS5nURUR 5S5 U[lUR 5 g!U[lf=f)z L{reactor.callLater} should use the reactor's seconds factory to produce the time at which the DelayedCall will be called. cgNdrrrrrITimeTests.test_callLaterUsesReactorSecondsInDelayedCall..#rcgrrrrrrrVriN)r rN callLaterr/getTimecancelr#osecondscalls r-test_callLaterUsesReactorSecondsInDelayedCall7TimeTests.test_callLaterUsesReactorSecondsInDelayedCall\ ??% '$$Q 5D   T\\^S 1&GO 'GO 8A22 A?c[RnS[l[R"SS5nURUR5S5 U[lUR 5 g!U[lf=f)z L{reactor.callLater} should propagate its own seconds factory to the DelayedCall to use as its own seconds factory. cgrTrrrrrWTimeTests.test_callLaterUsesReactorSecondsAsDelayedCallSecondsFactory..rWrrXcgrrrrrrrhrZrrUN)r rNr\r/r^r_s r;test_callLaterUsesReactorSecondsAsDelayedCallSecondsFactoryETimeTests.test_callLaterUsesReactorSecondsAsDelayedCallSecondsFactoryrdrec[5n[R"SURS5 UR UR S5 U$)zK Test that a DelayedCall really calls the function it is supposed to call. rN)r r r\r` addCallbackr/r#ds rtest_callLaterTimeTests.test_callLaters: J!QZZ. d&&-rc[R"S[[5nURUR5 UR nUR S5 URUR U5 g)zC A L{DelayedCall} that is reset will be scheduled at the new time. rtN)r r\r addCleanupr^timeresetassertNotEqual)r#raorigTimes rtest_callLaterResetTimeTests.test_callLaterResetsP  Hh7  $99 1  DIIx0rc^^^/mU4Sjn[R"SU5nUR5 [5mUUU4Sjn[R"S[RSU5 T$)z< Test that when a DelayedCall is cancelled it does not run. c(>TRS5 grr)calledsrfunction2TimeTests.test_cancelDelayedCall..functionrrrc>TRT/5 TRS5 g![a TR5 gf=fr)r/r` BaseExceptionerrback)r}ror#srcheck/TimeTests.test_cancelDelayedCall..checks@ !  , 4 !   s'AA)r r\r^r )r#r~rarr}ros` @@rtest_cancelDelayedCall TimeTests.test_cancelDelayedCalls[   H-  J ! !W..59rc[R"SS5nUR5 UR[R UR5 g)zg Test that cancelling a DelayedCall which has already been cancelled raises the appropriate exception. rcgrrrrrr;TimeTests.test_cancelCancelledDelayedCall..sDrN)r r\r^r(rAlreadyCancelled)r#ras rtest_cancelCancelledDelayedCall)TimeTests.test_cancelCancelledDelayedCalls9   L1  %00$++>rc^^^^[5mUUU4Sjn[R"SU5mT$)z Test that cancelling a DelayedCall in the DelayedCall's function as that function is being invoked by the DelayedCall raises the appropriate exception. c>TR[RTR5 TR S5 g![ a TR 5 gf=frr(r AlreadyCalledr^r`rrraror#srlater@TimeTests.test_cancelCalledDelayedCallSynchronous..laterJ !!!%"5"5t{{C 4 !   *?AArr r r\)r#rraros` @@r'test_cancelCalledDelayedCallSynchronous1TimeTests.test_cancelCalledDelayedCallSynchronouss* J !  E*rcl^^^^[5mUUU4SjmU4Sjn[R"SU5mT$)zd Test that cancelling a DelayedCall after it has run its function raises the appropriate exception. c>TR[RTR5 TR S5 g![ a TR 5 gf=frrrsrrATimeTests.test_cancelCalledDelayedCallAsynchronous..checkrrc4>[R"ST5 gNr)r r\)rsrrATimeTests.test_cancelCalledDelayedCallAsynchronous..laters   a 'rrr)r#rrarros` @@@r(test_cancelCalledDelayedCallAsynchronous2TimeTests.test_cancelCalledDelayedCallAsynchronous s/ J ! (  E*rc[R"SS5nURUR5[R"5S-- S:5 UR 5 g!UR 5 f=f)N cgrrrrrr-TimeTests.testCallLaterTime.. s$rrt)r r\ assertTruer]rur^rns rtestCallLaterTimeTimeTests.testCallLaterTimesS   b, /  OOAIIK499;+;.)strrr)rrXcgrrrrrrr1trhelloworldy$@c>[T5 gr)str)ignoreddcs r calledBack.calledBack7s Gr) r r\rrvr^ranger rmr`)r#rrors @rtestDelayedCallStringification(TimeTests.testDelayedCallStringification&s  q"3SB ? B   B  B    | FKBi ")7!3S 97C  B  B  J " ": .   q!**d 3 Brc Sn[R"SSS0SSU5nURUR5S5 UR S5 URUR5S5 g ) zw Test that the C{seconds} argument to DelayedCall gets used instead of the default timing function, if it is not None. cg)NrrrrrrN9TimeTests.testDelayedCallSecondsOverride..secondsEsrrXcgrrrrrr:TimeTests.testDelayedCallSecondsOverride..Irrrcgrrrs rrrIrZrcgrrrs rrrIsr N)r DelayedCallr/r]rv)r#rNrs rtestDelayedCallSecondsOverride(TimeTests.testDelayedCallSecondsOverride?sa     |R_ow  q)   r*rrN)rhrirjrkrrPrbrjrpryrrrrrrrrlrrrrLrLsC/"  16?&*2+rrLcv\rSrSr\"\R "\S5(+S5S5rSr Sr Sr Sr S r g) !CallFromThreadStopsAndWakeUpTestsiPNz-Nothing to wake up for without thread supportcT^[5mU4Sjn[R"U5 T$)Nct>[R"S5 [R"TRS5 g)Ng?)rusleepr callFromThreadr`)rosrwake:CallFromThreadStopsAndWakeUpTests.testWakeUp..wakeYs" JJsO  " "1::t 4r)r r callInThread)r#rros @r testWakeUp,CallFromThreadStopsAndWakeUpTests.testWakeUpQs& J 5 T"rcSUlg)NTstoppedr"s r_stopCallFromThreadCallback=CallFromThreadStopsAndWakeUpTests._stopCallFromThreadCallbackas  rc[R"URU5 [R"SUR5 gr)r r_callFromThreadCallback2r\rrns r_callFromThreadCallback9CallFromThreadStopsAndWakeUpTests._callFromThreadCallbackds.t<rcURUR5 URS5 g![a UR 5 gf=fr)rrr`rrrns rr:CallFromThreadStopsAndWakeUpTests._callFromThreadCallback2hs?  OODLL ) JJt    IIK s/A  A cSUl[R"5n[R"UR U5 U$)z Ensure that callFromThread from inside a callFromThread callback doesn't sit in an infinite loop and lets other things happen too. F)rrr r rrrns rtestCallFromThreadStops9CallFromThreadStopsAndWakeUpTests.testCallFromThreadStopsqs2  NN t;;Q?rr)rhrirjrkrrIReactorThreadsr rrrrrrlrrrrrPsC  & &w 557   ? rrcJ\rSrSrSrSrSrSrSrSr Sr S r S r S r g ) DelayedTestsi}cbSUlSUl0Ul[R"5Ulgr)finishedcountertimersrr deferredr"s rr$DelayedTests.setUp~s%   ( rcfURR5HnUR5 M gr)rvaluesr^)r#rs rrDelayedTests.tearDowns"##%A HHJ&rcURR5n[[R"55n/nUHnXB;dM UR U5 M U(aSUlURUS[U5-5 g)Nrtz7Should have been missing no calls, instead was missing ) rrlistr getDelayedCallsrTr assertFalserepr)r#l1l2missingrs r checkTimersDelayedTests.checkTimerssw [[   ! '))+ , B|r" DM   7m  rc>URU UR5 gr)rrr#tags rr`DelayedTests.callbacks KK  rc^URU5 URSUR5 g)N)r`addTimerrs rrmDelayedTests.addCallbacks  c b$--(rcjSUlURU5 URRS5 g)Nrt)rr`rrs rdoneDelayedTests.dones'  c t$rc[R"US-X R5URUR'U=RS- slUR 5 g)N{Gz?rt)r r\rrr)r#whenr`s rrDelayedTests.addTimersH$+$5$5 4K<<%  DLL!   rc^[[S5(dgTR5 TRSTR5 TRSTR 5 TRSTR 5 TR nTRSTR 5 TRSTR5 TRSTR 5 TRUR5 TRU TR5 TRRU4Sj5 TR$) Nr#c$>TR5$r)r)rr#s rr2DelayedTests.testGetDelayedCalls..sD,<,<,>r) hasattrr rrrr`rrmrr^r)r#whichs` rtestGetDelayedCalls DelayedTests.testGetDelayedCallssw 122   b$))$ b$--( b$--(  b$--( b$**+ b$--( E!!# KK   !!">?}}rc^^[R"STRRS5mTR TR 55 UU4SjnTRR U5 TR$)z= L{IDelayedCall.active} returns False once the call has run. rTcF>TRTR55 U$r)ractive)successdcallr#s rcheckDeferredCall3DelayedTests.test_active..checkDeferredCalls   U\\^ ,Nr)r r\rr`rrrm)r#rrs` @r test_activeDelayedTests.test_activesY!!$ (>(>E  '  !!"34}}r)rrrrN)rhrirjrkr$rrr`rmrrrrrlrrrrr}s/)  *)% , rra import %(reactor)s %(reactor)s.install() from twisted.internet import reactor class Foo: def __init__(self): reactor.callWhenRunning(self.start) self.timer = reactor.callLater(3, self.failed) def start(self): reactor.resolve('localhost').addBoth(self.done) def done(self, res): print('done', res) reactor.stop() def failed(self): print('failed') self.timer = None reactor.stop() f = Foo() reactor.run() c2\rSrSrSrSrSrSrSrSr g) ChildResolveProtocolicXlgr) onCompletion)r#rs r__init__ChildResolveProtocol.__init__s(rc /Ul/Ulgr)outputrr"s rconnectionMade#ChildResolveProtocol.connectionMades  rc:URRU5 gr)r!rT)r#outs r outReceived ChildResolveProtocol.outReceiveds 3rc:URRU5 gr)rrT)r#errs r errReceived ChildResolveProtocol.errReceiveds #rctURRXRUR45 SUlgr)rr`r!r)r#reasons r processEnded!ChildResolveProtocol.processEndeds+ ""FKK#DE r)rrr!N) rhrirjrkrr"r&r*r.rlrrrrrs) !rrz8cannot run test: reactor doesn't support IReactorProcessc\rSrSrSrSrg) ResolveTestsicJ^[RRTR55n[ US5n[ R nUR[SU0-5 SSS5 [RR5n[RR[R5US'[5n[U5n[ R "U[R"SSU4U5 U4SjnUR%U5 U$!,(df  N=f)Nwr PYTHONPATHpythonz-uc >UupnSRU5nS[RRS5-nX$:wa@TR SR UR 5USRU555 gg)Nrsdone 127.0.0.1asciizThe child process failed to produce the desired results: Reason for termination was: {!r} Output stream was: {!r} Error stream was: {!r} )joinoslinesepencodefailformatgetErrorMessage)resultr-r!rexpected_outputr#s r cbFinished1ResolveTests.testChildResolve..cbFinishedss&, #VUXXf%F/"**2C2CG2LLO( 6 fV335vsxxO)r)r9pathabspathmktempopenr riwriteresolve_helperenvironcopypathsepr8sysr r spawnProcess executablerm)r# helperPath helperFile reactorNameenvhelperDeferred helperProtorAs` rtestChildResolveResolveTests.testChildResolvesWW__T[[]3 *c "j!,,K   ^y+.FF G # jjooJJOOCHH5L!*>:  (D*)Es  " "":.E# "s +D D"rN)rhrirjrkrUrlrrrr1r1s 'rr1z&Nothing to test without thread supportc6\rSrSrSrSrSrSrSrSr Sr g ) CallFromThreadTestsi0z% Task scheduling from threads tests. c0SUl[5Ulgr)rr rr"s rr$CallFromThreadTests.setUp9s   rc0[R"U0UD6 g)z Override in subclasses. N)r r)r#argskwargss rscheduleCallFromThreadTests.schedule=s //rcn^U4Sjn[S5HnTRU5 M TR$)zj L{IReactorThreads.callFromThread} can be used to schedule a large number of calls in the reactor thread. c>T=RS- slTRS:XaTRRS5 gg)NrtrUTrrr`r"sraddAndMaybeFinishVCallFromThreadTests.test_lotsOfThreadsAreScheduledCorrectly..addAndMaybeFinishIs4 LLA L||s" &&t,#rrU)rr^r)r#rcis` r'test_lotsOfThreadsAreScheduledCorrectly;CallFromThreadTests.test_lotsOfThreadsAreScheduledCorrectlyCs1  - sA MM+ ,}}rcx^^/mUU4SjnTRRU5 TRTRS5 TRTRS5 TRTRS5 TR[R TRR S5 TR$)z? Callbacks should be invoked in the order they were scheduled. c.>TRT/SQ5 g)N)rtrsr)r/)_orderr#s rrECallFromThreadTests.test_threadsAreRunInScheduledOrder..checkYs   UI .rrtrsrN)rrmr^rTr rr`)r#rrks` @r"test_threadsAreRunInScheduledOrder6CallFromThreadTests.test_threadsAreRunInScheduledOrderSs / !!%( ellA& ellA& ellA& g,,dmm.D.DdK}}rc^U4SjnTRU5 TRTRS5 TR$)zE Scheduled tasks should not be run until the reactor starts running. cJ>STlTRRS5 g)NrtTrbr"sr incAndFinishUCallFromThreadTests.test_scheduledThreadsNotRunUntilReactorRuns..incAndFinishisDL MM " "4 (rr)r^r/rr)r#rqs` r+test_scheduledThreadsNotRunUntilReactorRuns?CallFromThreadTests.test_scheduledThreadsNotRunUntilReactorRunsds6  ) l# q)}}r)rrN) rhrirjrkrr$r^rfrmrsrlrrrrXrX0s #0  "rrXc\rSrSrSrSrg) MyProtocoliuz Sample protocol. rN)rhrirjrkrrlrrrrvrvusrrvc\rSrSrSr\rSrg) MyFactoryi{z Sample factory. rN)rhrirjrkrrvr rlrrrrxrx{sHrrxc\rSrSrSrSrg) ProtocolTestsic[5nURS5nURURU5 UR X!R 5 gr)rx buildProtocolr/factoryassertIsInstancer )r#r}r s r testFactoryProtocolTests.testFactorysC+((. ))73 h(8(89rrN)rhrirjrkrrlrrrrzrzs:rrzc0\rSrSrSrSrSrSrSrSr g) DummyProduceriao Very uninteresting producer implementation used by tests to ensure the right methods are called by the consumer with which it is registered. @type events: C{list} of C{str} @ivar events: The producer/consumer related events which have happened to this producer. Strings in this list may be C{'resume'}, C{'stop'}, or C{'pause'}. Elements are added as they occur. c/Ulgrrr"s rrDummyProducer.__init__s  rc:URRS5 g)NresumerWrTr"s rresumeProducingDummyProducer.resumeProducings 8$rc:URRS5 g)Nstoprr"s r stopProducingDummyProducer.stopProducings 6"rc:URRS5 g)Npauserr"s rpauseProducingDummyProducer.pauseProducings 7#rrN) rhrirjrkrrrrrrlrrrrrs%#$rrc0\rSrSrSrSrSrSrSr\r Sr g) SillyDescriptoriz A descriptor whose data buffer gets filled very fast. Useful for testing FileDescriptor's IConsumer interface, since the data buffer fills as soon as at least four characters are written to it, and gets emptied in a single doWrite() cycle. rTc[U5$)z Always write all data. )rx)r#datas r writeSomeDataSillyDescriptor.writeSomeDatas4yrcg)z! Do nothing: bypass the reactor. Nrr"s r startWritingSillyDescriptor.startWritingsrrN) rhrirjrkr bufferSize connectedrr stopWritingrlrrrrrs$JI  Krrc8^\rSrSrSrU4SjrU4SjrSrU=r$)ReentrantProduceria Similar to L{DummyProducer}, but with a resumeProducing method which calls back into an L{IConsumer} method of the consumer against which it is registered. @ivar consumer: The consumer with which this producer has been or will be registered. @ivar methodName: The name of the method to call on the consumer inside C{resumeProducing}. @ivar methodArgs: The arguments to pass to the consumer method invoked in C{resumeProducing}. cF>[TU]5 XlX lX0lgr)superrconsumer methodName methodArgs)r#rrr __class__s rrReentrantProducer.__init__s  $$rc|>[TU]5 [URUR5"UR 6 gr)rrgetattrrrr)r#rs rr!ReentrantProducer.resumeProducings) ! t/Ar)rrr) rhrirjrkrrrrl __classcell__)rs@rrrs % BBrrcH\rSrSrSrSrSrSrSrSr Sr S r S r S r g ) ProducerTestsiz4 Test abstract.FileDescriptor's consumer interface. c[R"5nSUl[5nUR US5 UR UR S/5 UR[UR[5S5 g)z Verify that registering a non-streaming producer invokes its resumeProducing() method and that you can only register one producer at a time. rtrrN) rFileDescriptorrrregisterProducerr/rWr( RuntimeErrorr#fddps rtest_doubleProducer!ProducerTests.test_doubleProducersb  $ $ & _ B" XJ/ ,(;(;]_aPrc[R"5nSUl[5nUR US5 UR UR S/5 g)zt Verify that registering a producer when the connection has already been closed invokes its stopProducing() method. rtrrN)rr disconnectedrrr/rWrs rtest_unconnectedFileDescriptor,ProducerTests.test_unconnectedFileDescriptorsF  $ $ & _ B" VH-rc2[5n[5nURUSS9 URURS/5 URSS2 US:XaUR /SQ5 OUR S5 URUR/5 g)z Pull consumers don't get their C{pauseProducing} method called if the descriptor buffer fills up. @param _methodName: Either 'write', or 'writeSequence', indicating which transport method to write data to. F streamingrN writeSequence)1234s1234)rrrr/rWrrG)r#r descriptorproducers r_dontPausePullConsumerTest(ProducerTests._dontPausePullConsumerTests%&  ?##H#> 8*5 OOA   (  $ $%= >   W % "-rc$URS5$)z Verify that FileDescriptor does not call producer.pauseProducing() on a non-streaming pull producer in response to a L{IConsumer.write} call which results in a full write buffer. Issue #2286. rGrr"s r!test_dontPausePullConsumerOnWrite/ProducerTests.test_dontPausePullConsumerOnWrite s ..w77rc$URS5$)a Like L{test_dontPausePullConsumerOnWrite}, but for a call to C{writeSequence} rather than L{IConsumer.write}. C{writeSequence} is not part of L{IConsumer}, but L{abstract.FileDescriptor} has supported consumery behavior in response to calls to L{writeSequence} forever. rrr"s r)test_dontPausePullConsumerOnWriteSequence7ProducerTests.test_dontPausePullConsumerOnWriteSequences..??rc[5nUS:Xa/SQnOSn[X!U5nURUSS9 [X!5"U5 UR UR S/5 UR SS2 UR 5 UR UR SS/5 UR SS2 UR 5 UR UR SS/5 g)Nr)spsamsspamTrrr)rrrrr/rWdoWrite)r#rrrrs r_reentrantStreamingProducerTest-ProducerTests._reentrantStreamingProducerTests$&  (&DD$ZTB##H#=  '- 7)4 OOA   8W*=> OOA   8W*=>rc$URS5$)zl Verify that FileDescriptor tracks producer's paused state correctly. Issue #811, fixed in revision r12857. rGrr"s r)test_reentrantStreamingProducerUsingWrite7ProducerTests.test_reentrantStreamingProducerUsingWrite?s 33G<&*L   rzIReactorUDP is neededc[R"S[R"55nUR 5R nUR [U5R[U55SSX!4-5 UR5$r) r listenUDPr DatagramProtocolrrrwrrrrs rtestUDP PortStringificationTests.testUDP\sk   a!:!:!< =!!  FKKF $b*>&*L   rzIReactorSSL is neededzSSL support is missingcp[R"[S5n[R"S[ R "5URX"55nUR5RnUR[U5R[U55SSXC4-5 UR5$)Nz server.pemrrr)rsibpathrr listenSSLr rDefaultOpenSSLContextFactoryrrrwrrr)r#rpemrrs rtestSSL PortStringificationTests.testSSLesll8\2    x%%')I)I#)S !!  FKKF $b*>&*L   rr)rhrirjrkrr IReactorTCPr r IReactorUDPr IReactorSSLrrrlrrrrrRs &&w5 57NO!P! &&w5 57NO!P! &&w5 57NO G-. !/P !rrc\rSrSrSrSrg)ConnectorReprTestsisc[SS[5S[55nSnU[U5UR54-nUR [ U5U5 g)N localhostirzA)r ridgetDestinationr/r)r#cexpects r test_tcp_repr ConnectorReprTests.test_tcp_reprtsM k3!VX >W2a5!"2"2"455 a&)rrN)rhrirjrkrrlrrrrrss*rr)3rr9rLruunittestrtwisted.internetrrrrrr r twisted.internet.deferr r twisted.internet.tcpr twisted.pythonrtwisted.trial.unittestrr_ssl ImportError supportedrrrLrrrHProcessProtocolrIReactorProcessr1rrXProtocolrvFactoryrxrzrrrrrrrrrrrs  XXX5*+, Cs}} Ck78k7\ { x{ | B+B+J**ZW8Wt.!833!&""7D11>(8( (V""7D11,>(> >B""   :H:$$0h--4B B6wEHwEt!x!B**{* CsF FF