+ DfjRt^RIt^RIHt^RIHt^RIHt^RIH t H t H t ^RI H t ^RIHtHt^RIHtHtHtHtHt^R IHtHt^R IHt^R IHt^R IHtH t ^R I!H"t"^RI#H$t$H%t%Rt&]!]4!RR44t']!]]'4]!]4!RR44t(]!]]'4!RR]%4t)!RR]%4t*!RR4t+RRlt,] 3Rlt-Rt.!RR]$4t/R#) z Tests for (new code in) L{twisted.application.internet}. @var AT_LEAST_ONE_ATTEMPT: At least enough seconds for L{ClientService} to make one attempt. N) implementer) verifyClass)internet) ClientServiceStreamServerEndpointService TimerService)task)CancelledErrorDeferred)IFileDescriptorReceiverIHalfCloseableProtocolIListeningPortIStreamClientEndpointIStreamServerEndpoint)FactoryProtocol)Clock)StringTransport) formatEventglobalLogPublisher)Failure)SynchronousTestCaseTestCasecR#)zE A fake target function for testing TimerService which does nothing. NrH/usr/lib/python3/dist-packages/twisted/application/test/test_internet.pyfakeTargetFunctionr)s rcZa]tRt^0toRtRtRtRt]!4t ^t Rt Rt Rt RtRtVtR#) FakeServeraA In-memory implementation of L{IStreamServerEndpoint}. @ivar result: The L{Deferred} resulting from the call to C{listen}, after C{listen} has been called. @ivar factory: The factory passed to C{listen}. @ivar cancelException: The exception to errback C{self.result} when it is cancelled. @ivar port: The L{IListeningPort} which C{listen}'s L{Deferred} will fire with. @ivar listenAttempts: The number of times C{listen} has been invoked. @ivar failImmediately: If set, the exception to fail the L{Deferred} returned from C{listen} before it is returned. Nc$\4VnR#N)FakePortportselfs&r__init__FakeServer.__init__Ls J rc aS;P^, unVSn\V3RlR7SnSPe&SPP SP4SP#)z Return a Deferred and store it for future use. (Implementation of L{IStreamServerEndpoint}). @param factory: the factory to listen with @return: a L{Deferred} stored in L{FakeServer.result} c:<VPSP4#r!)errbackcancelException)dr%s&r#FakeServer.listen..Zs199T=Q=Q3Rr) canceller)listenAttemptsfactoryr resultfailImmediatelyr*)r%r1sf&rlistenFakeServer.listenOsX q  )RS    + KK   4 4 5{{rc PVPPVP4R#)z Test code should invoke this method after causing C{listen} to be invoked in order to fire the L{Deferred} previously returned from C{listen}. N)r2callbackr#r$s&rstartedListeningFakeServer.startedListening_s TYY'rc PVPPPR4R#)z Test code should invoke this method after causing C{stopListening} to be invoked on the port fired from the L{Deferred} returned from C{listen} in order to cause the L{Deferred} returned from C{stopListening} to fire. N)r#deferredr7r$s&rstoppedListeningFakeServer.stoppedListeninggs ##D)r)r1r#r2)__name__ __module__ __qualname____firstlineno____doc__r2r1r3r r+r0r&r4r8r<__static_attributes____classdictcell__ __classdict__s@rrr0sA(FGO$&ON (**rrc:a]tRt^ttoRtRtRtRtRtRt Vt R#)r"zg Fake L{IListeningPort} implementation. @ivar deferred: The L{Deferred} returned by C{stopListening}. Nc 8\4VnVP#)zH Stop listening. @return: a L{Deferred} stored in L{FakePort.deferred} )r r;r$s&r stopListeningFakePort.stopListening~s !  }}rcR#r!rr$s&rgetHostFakePort.getHost rcR#r!rr$s&rstartListeningFakePort.startListeningrNrr;) r>r?r@rArBr;rIrLrPrCrDrEs@rr"r"ts% H   rr"cpa]tRt^toRtRtRtRRltRtRt Rt R t R t R t R tR tRtRtVtR#)EndpointServiceTestsz, Tests for L{twisted.application.internet}. c \4Vn\4Vn\ VPVP4VnR#)zX Construct a stub server, a stub factory, and a L{StreamServerEndpointService} to test. N)r fakeServerrr1rsvcr$s&rsetUpEndpointServiceTests.setUps, %,y .t Mrc VPP4VPVPVPP4R#)zo L{StreamServerEndpointService.privilegedStartService} calls its endpoint's C{listen} method with its factory. N)rWprivilegedStartServiceassertIdenticalr1rVr$s&rtest_privilegedStartService0EndpointServiceTests.test_privilegedStartServices2 '') T\\4??+B+BCrNc \4VPnRVPnTP \T;'gVPP 4R#)a L{StreamServerEndpointService.startService} should raise synchronously if the L{Deferred} returned by its wrapped L{IStreamServerEndpoint.listen} has already fired with an errback and the L{StreamServerEndpointService}'s C{_raiseSynchronously} flag has been set. This feature is necessary to preserve compatibility with old behavior of L{twisted.internet.strports.service}, which is to return a service which synchronously raises an exception from C{startService} (so that, among other things, twistd will not start running). However, since L{IStreamServerEndpoint.listen} may fail asynchronously, it is a bad idea to rely on this behavior. @param thunk: If specified, a callable to execute in place of C{startService}. TN)ZeroDivisionErrorrVr3rW_raiseSynchronously assertRaises startService)r%thunks&&r(test_synchronousRaiseRaisesSynchronously=EndpointServiceTests.test_synchronousRaiseRaisesSynchronouslysB +<*=''+$ +U-K-Kdhh6K6KLrc PVPVPP4R#)z L{StreamServerEndpointService.privilegedStartService} should behave the same as C{startService} with respect to L{EndpointServiceTests.test_synchronousRaiseRaisesSynchronously}. N)rerWr[r$s&rtest_synchronousRaisePrivileged4EndpointServiceTests.test_synchronousRaisePrivilegeds 55dhh6U6UVrc VPP4VPPP \ 44VP \ 4pVP\V4^4R#)z L{StreamServerEndpointService.startService} and L{StreamServerEndpointService.privilegedStartService} should both log an exception when the L{Deferred} returned from their wrapped L{IStreamServerEndpoint.listen} fails. N) rWrcrVr2r*r`flushLoggedErrors assertEquallenr%loggeds& rtest_failReportsError*EndpointServiceTests.test_failReportsErrorsU  &&'8':;''(9: Va(rc RVPnVPP4VPPP \ 44VP\ 4pVP\V4^4R#)a L{StreamServerEndpointService.startService} and L{StreamServerEndpointService.privilegedStartService} should both log an exception when the L{Deferred} returned from their wrapped L{IStreamServerEndpoint.listen} fails asynchronously, even if C{_raiseSynchronously} is set. TN) rWrarcrVr2r*r`rkrlrmrns& r!test_asynchronousFailReportsError6EndpointServiceTests.test_asynchronousFailReportsErrorsa(,$  &&'8':;''(9: Va(rc \4VPnVPP 4VP \4pVP \V4^4R#)z Without the C{_raiseSynchronously} compatibility flag, failing immediately has the same behavior as failing later; it logs the error. N)r`rVr3rWrcrkrlrmrns& r test_synchronousFailReportsError5EndpointServiceTests.test_synchronousFailReportsErrorsH +<*=' ''(9: Va(rc VPP4VPVPVPP4VP VPP R4R#)z L{StreamServerEndpointService.startService} sets the C{running} flag, and calls its endpoint's C{listen} method with its factory, if it has not yet been started. TN)rWrcr\r1rVrlrunningr$s&rtest_startServiceUnstarted/EndpointServiceTests.test_startServiceUnstartedsL  T\\4??+B+BC ))40rc VP4VPP4VPVPP ^4VPVPP R4R#)z L{StreamServerEndpointService.startService} sets the C{running} flag, but nothing else, if the service has already been started. TN)r]rWrcrlrVr0ryr$s&rtest_startServiceStarted-EndpointServiceTests.test_startServiceStartedsT ((*  77; ))40rc VPP4VPP4VPP 4VPP 4p.pVP VP4VP\V4^4VPP4VP\V4^4VPVPP4R#)z L{StreamServerEndpointService.stopService} calls C{stopListening} on the L{IListeningPort} returned from its endpoint, returns the C{Deferred} from stopService, and sets C{running} to C{False}. N) rWr[rVr8rc stopService addCallbackappendrlrmr< assertFalseryr%r2ls& rtest_stopService%EndpointServiceTests.test_stopServices '') ((* %%' 188$ Q# ((* Q# ))*rc VPP4VPP4p.pVPVP4VP VR.4VP VP \4.4R#)z L{StreamServerEndpointService.stopService} cancels the L{Deferred} returned by C{listen} if it has not yet fired. No error will be logged about the cancellation of the listen attempt. N)rWr[raddBothrrlrkr rs& r#test_stopServiceBeforeStartFinished8EndpointServiceTests.test_stopServiceBeforeStartFinishedsh '')%%' qxx  TF# //?Drc `\4VPnVPP 4VPP 4p.pVP VP4VPVR.4VP\4pVP\V4^4R#)z L{StreamServerEndpointService.stopService} cancels the L{Deferred} returned by C{listen} if it has not fired yet. An error will be logged if the resulting exception is not L{CancelledError}. N) r`rVr+rWr[rrrrlrkrm)r%r2rstoppingErrorss& r test_stopServiceCancelStartError5EndpointServiceTests.test_stopServiceCancelStartErrors +<*=' '')%%' 188$ TF#//0AB ^,a0r)r1rVrWr!)r>r?r@rArBrXr]rerhrprsrvrzr}rrrrCrDrEs@rrTrTsPNDM(W ) ))11+$ E 1 1rrTc`a]tRtRtoRtRtRtRtRtRt Rt R t R t R t R tR tVtR#)TimerServiceTestsi,a  Tests for L{twisted.application.internet.TimerService}. @type timer: L{TimerService} @ivar timer: service to test @type clock: L{task.Clock} @ivar clock: source of time @type deferred: L{Deferred} @ivar deferred: deferred returned by L{TimerServiceTests.call}. c \^VP4Vn\P!4;VnVPn\ 4VnR#)z! Set up a timer service to test. N)rcalltimerrrclockr r;r$s&rrXTimerServiceTests.setUp:s8"!TYY/ (, 4 TZZ%  rc VP#)zb Function called by L{TimerService} being tested. @returns: C{self.deferred} @rtype: L{Deferred} rRr$s&rrTimerServiceTests.callBs}}rc VPP4VPVPPR4VP VPP \ P4VPVPVPP P4VPVPP PR4R#)zw When L{TimerService.startService} is called, it marks itself as running, creates a L{task.LoopingCall} and starts it. zService is startedzLoopingCall is startedN) rrc assertTrueryassertIsInstance_loopr LoopingCallr\rr$s&rtest_startService#TimerServiceTests.test_startServiceKs !  **,@A djj..0@0@A TZZ)9)9)?)?@  ((002JKrc .pVPR/3VPnVPP4VP R.V4R#)zQ When L{TimerService.startService} is called, it calls the function immediately. Nr!)rrrrcrl)r%r2s& r$test_startServiceRunsCallImmediately6TimerServiceTests.test_startServiceRunsCallImmediatelyVsA !=='26  ! $(rc a\P!4oV3RlpVP\RV4VPP 4VP SVPPP4R#)z L{TimerService.startService} uses L{internet._maybeGlobalReactor} to choose the reactor to pass to L{task.LoopingCall} uses the global reactor. c<S#r!r) maybeReactor otherClocks&r getOtherClockKTimerServiceTests.test_startServiceUsesGlobalReactor..getOtherClockhs  r_maybeGlobalReactorN) rrpatchrrrcr\rr)r%rrs& @r"test_startServiceUsesGlobalReactor4TimerServiceTests.test_startServiceUsesGlobalReactor`sX ZZ\   82MB ! Z)9)9)?)?@rc dVPP4VPP4pVPV4VP RVPP 4VP P\44VPVPV4R4R#)z When L{TimerService.stopService} is called while a call is in progress. the L{Deferred} returned doesn't fire until after the call finishes. TN) rrcrassertNoResultrlryr;r7objectr\successResultOfr%r,s& rtest_stopServiceWaits'TimerServiceTests.test_stopServiceWaitsos} ! JJ " " $ A tzz112 vx( T11!4d;rc VPP4VPP\ 44VPP 4pVP VPV4R4R#)z} When L{TimerService.stopService} is called while a call isn't in progress. the L{Deferred} returned has already been fired. N)rrcr;r7rrr\rrs& rtest_stopServiceImmediately-TimerServiceTests.test_stopServiceImmediately{sU ! vx( JJ " " $ T11!4d;rc hVPP4VPP\ \ 444VP \ 4pVP^\V44VPP4pVPVPV4R4R#)z When function passed to L{TimerService} returns a deferred that errbacks, the exception is logged, and L{TimerService.stopService} doesn't raise an error. N) rrcr;r*rr`rkrlrmrr\r)r%errorsr,s& rtest_failedCallLogsError*TimerServiceTests.test_failedCallLogsErrors ! g&7&9:;''(9: CK( JJ " " $ T11!4d;rc \^\4pVP4\P!V4pVP 4\P !V4p\4p\VRV4pVPWE4R#)zY When pickling L{internet.TimerService}, it won't pickle L{internet.TimerService._loop}. rN rrrcpickledumpsrloadsrgetattrr\r%r dumpedTimer loadedTimernothingvalues& r$test_pickleTimerServiceNotPickleLoop6TimerServiceTests.test_pickleTimerServiceNotPickleLoopshQ 23 ll5)  ll;/ ( Wg6 W,rc \^\4pVP4\P!V4pVP 4\P !V4p\4p\VRV4pVPWE4R#)za When pickling L{internet.TimerService}, it won't pickle L{internet.TimerService._loopFinished}. _loopFinishedNrrs& r,test_pickleTimerServiceNotPickleLoopFinished>TimerServiceTests.test_pickleTimerServiceNotPickleLoopFinishedshQ 23 ll5)  ll;/ ( _g> W,r)rr;rN)r>r?r@rArBrXrrrrrrrrrrCrDrEs@rrr,sC # L) A << <- --rrc*a]tRtRtoRtRtRtVtR#)ConnectInformationia Information about C{endpointForTesting} @ivar connectQueue: a L{list} of L{Deferred} returned from C{connect}. If these are not already fired, you can fire them with no value and they will trigger building a factory. @ivar constructedProtocols: a L{list} of protocols constructed. @ivar passedFactories: a L{list} of L{IProtocolFactory}; the ones actually passed to the underlying endpoint / i.e. the reactor. c0.Vn.Vn.VnR#r! connectQueueconstructedProtocolspassedFactoriesr$s&rr&ConnectInformation.__init__s$&!!rrN)r>r?r@rArBr&rCrDrEs@rrrs ""rrclaa\\4!VV3RlR44p\4oSV!43#)a( Make a sample endpoint for testing. @param fireImmediately: If true, fire all L{Deferred}s returned from C{connect} immedaitely. @return: a 2-tuple of C{(information, endpoint)}, where C{information} is a L{ConnectInformation} describing the operations in progress on C{endpoint}. c0<a]tRtRtoVV3RltRtVtR#).endpointForTesting..ClientTestEndpointic<a\4pSPPS4VPVV3Rl4pSPPV4S'dVP R4V#)c<SPR4pSPPV4\4pVP V4V#r!) buildProtocolrrrmakeConnection)ignoredprotocol transportr1infos& rcreateProtocolNendpointForTesting..ClientTestEndpoint.connect..createProtocolsB"006))00:+- '' 2rN)r rrrrr7)r%r1r2rfireImmediatelyrs&f rconnect6endpointForTesting..ClientTestEndpoint.connects`ZF  ' ' 0          $ $V ,%MrrN)r>r?r@rArrCrD)rFrrs@rClientTestEndpointrs  rr)rrr)rrrsf @rendpointForTestingrs;&'($  D #% %%rcxaa.oSPSP4VPVV3Rl4V3Rl#)a Catch the global log stream. @param testCase: The test case to add a cleanup to. @param logPublisher: the log publisher to add and remove observers for. @return: a 0-argument callable that returns a list of textual log messages for comparison. @rtype: L{list} of L{unicode} c:<SPSP4#r!)removeObserverr) logPublisherlogssrr-catchLogs..s ; ;DKK HrcD<SUu.uFp\V4NK up#uupir!)r)eventrs rr-rsD9D5K&D99s) addObserverr addCleanup)testCaserrs&f@r catchLogsrs1 DT[[) HI 99rgY@ca]tRtRtoRtRR]R3RltRtRtRt R t R t R t R t R tRtRtRtRtV3RlRltRtRtRtRtRtRtRtRtRtRtRtRtR t R!t!R"t"R#t#R$t$R%t%R&t&Vt'R'#)(ClientServiceTestsiz Tests for L{ClientService}. TFc naaaa a a/pVP\4R7VPV4VR,o \VR7wrx.;o Vn!V VV3RlR\4p V !4;Vnp \ W3/VBoV VV3Rlp SPV 4V'dSP4VS3#)a Create a L{ClientService} along with a L{ConnectInformation} indicating the connections in progress on its endpoint. @param fireImmediately: Should all of the endpoint connection attempts fire synchronously? @type fireImmediately: L{bool} @param startService: Should the L{ClientService} be started before being returned? @type startService: L{bool} @param protocolType: a 0-argument callable returning a new L{IProtocol} provider to be used for application-level protocol connections. @param kw: Arbitrary keyword arguments to be passed on to L{ClientService} @return: a 2-tuple of L{ConnectInformation} (for information about test state) and L{ClientService} (the system under test). The L{ConnectInformation} has 2 additional attributes; C{applicationFactory} and C{applicationProtocols}, which refer to the unwrapped protocol factory and protocol instances passed in to L{ClientService} respectively. rrrc><aa]tRtRtoZtVVV3RltRtVtV;t#)>ClientServiceTests.makeReconnector..RememberingFactoryi2c\<S'dR#\SV`V4pSPV4V#r!)superrr)r%addrr2 __class__applicationProtocolsrefuseConnectionss&& rrLClientServiceTests.makeReconnector..RememberingFactory.buildProtocol5s+$.t4$++F3 rr) r>r?r@rArrrCrD __classcell__)rrFr protocolTypers@@rRememberingFactoryr2s#H  rrc<RSnSP'dSP4SPSP 4.4R#r!) _protocolryrrlgetDelayedCalls)rr%servicesrstop0ClientServiceTests.makeReconnector..stop@s; $G ##%   U224b 9r) updaterrrrapplicationFactoryrrrc)r%rrcrrkwnkwcqendpointrr1rrrrsf&&ff, @@@rmakeReconnector"ClientServiceTests.makeReconnectorsB  ! 2G )/J :<;r6   +=*>>9S9 :    "7{rc xVPRR7wrVP\VP4^4R#)z< When the service is started, a connection attempt is made. FrN)rrlrmr)r%r rs& rr$ClientServiceTests.test_startServiceMs2**5*A  R__-q1rc VP4wrVPpVPVP^4VP^,pVP 4VPVP^4R#)z Although somewhat obscure, L{IProtocolFactory} includes both C{doStart} and C{doStop} methods; ensure that when these methods are called on the factory that was passed to the reactor, the factory that was passed from the application receives them. N)rr rlnumPortsrdoStart)r%r rfirstAppFactoryfirstPassedFactorys& rtest_startStopFactory(ClientServiceTests.test_startStopFactoryTsh**, // 1115//2""$ 1115rc DVP4wrVP4pVPV4VP^,pVP VP P R4VP\\444VPV4R#)z When the service is stopped, no further connect attempts are made. The returned L{Deferred} fires when all outstanding connections have been stopped. TN) rrrrrlr disconnectingconnectionLostr Exceptionrr%r rr,rs& rtest_stopServiceWhileConnected1ClientServiceTests.test_stopServiceWhileConnectedbs **,     ! A**1- ++994@ 45 Qrc VP4wrVP4pVPV4VP^,pVP VP P R4VP4VPV4VP \VP4^4VP\\R444VP \VP4^4R#)z When L{ClientService} is restarted after having been connected, it waits to start connecting until after having disconnected. Tzsynthetic connectionLostN) rrrrrlrrrcrmrrrrs& r#test_startServiceWaitsForDisconnect6ClientServiceTests.test_startServiceWaitsForDisconnectps **,     ! A**1- ++994@ A R445q9 2L(M NO R445q9rc hVPRR7wrVP^,PR4VP^,pVP 4pVP V4VP 4pVP V4VP4VP V4VP V4VPVPPR4VP\\R444VPV4VP^,PR4VP\VP4^4VP!VPV4VP"^,4VP 4pVP V4R#)z When L{ClientService} is stopping - that is, L{ClientService.stopService} has been called, but the L{Deferred} it returns has not fired yet - calling L{startService} will cause a new connection to be made, and new calls to L{whenConnected} to succeed. FrNTzsynthetic connection lost)rrr7rrr whenConnectedrcrlrrrrrrrmr\r)r%r rfirststopped nextProtocol secondStoppeds& rtest_startServiceWhileStopping1ClientServiceTests.test_startServiceWhileStoppingsZ**5*A  ##D)''*%%' G$,,.  L) L) G$ 66= WY/J%KLM W% ##D) R445q9    .0G0G0J  ++-  M*rc VPRR7wrVP4pVPV4VPVP 4\ 4VP 4VPR,PR4VPVPR,VPVP 444R#)z When L{ClientService} is stopped - that is, L{ClientService.stopService} has been called and the L{Deferred} it returns has fired - calling L{startService} will cause a new connection to be made, and new calls to L{whenConnected} to succeed. FrN) rrrfailureResultOfr%r rcrr7r\r)r%r rr's& rtest_startServiceWhileStopped0ClientServiceTests.test_startServiceWhileStoppeds**5*A %%' W% W224nE $$T*   # #B ')=)=g>S>S>U)V rc 4\\\4!RR\44pVP VR7wr#VP ^,pVP \P!V44VP \P!V44R#)a If the protocol objects returned by the factory given to L{ClientService} provide special "marker" interfaces for their transport - L{IHalfCloseableProtocol} or L{IFileDescriptorReceiver} - those interfaces will be provided by the protocol objects passed on to the reactor. c]tRtRtRtRtR#)EClientServiceTests.test_interfacesForTransport..FancyProtocoliz! Provider of various interfaces. rN)r>r?r@rArBrCrrr FancyProtocolr3s rr4)rN)rr r rrrr providedBy)r%r4r r reactorFacings& rtest_interfacesForTransport.ClientServiceTests.test_interfacesForTransports~ +-D E H  F  ** *F //2  /::=IJ .99-HIrc \4pVPRVR7wr#VP^,P\ 44VP \ 4VP\VP4^4VP4pVP^,P\ 44VPV4R#)zE When the service is stopped while retrying, the retry is cancelled. FrrN) rrrr*radvanceAT_LEAST_ONE_ATTEMPTrlrmrrr%rr rr,s& rtest_stopServiceWhileRetrying0ClientServiceTests.test_stopServiceWhileRetryings**5*N  ""9;/ *+ R__-q1    ! ""9;/ Qrc \4pVPRVR7wr#VP\VP4^4VP VP^,4VP 4pVPV4R#)z^ When the service is stopped while initially connecting, the connection attempt is cancelled. Fr:N)rrrlrmrrrrr=s& rtest_stopServiceWhileConnecting2ClientServiceTests.test_stopServiceWhileConnectingsn **5*N  R__-q1 BOOA./    ! Qrc f\4pVPVR7wr#VP4pVPVP 4.4VP VP V4VP^,4VP VP^,PVP^,4VP\VP^,4\VP^,44VPR\VP^,44R#)za When a client connects, the service keeps a reference to the new protocol and resets the delay. rrN) rrr%rlrr\rrrrassertInstrr)r%rr rawaitingProtocols& rtest_clientConnected'ClientServiceTests.test_clientConnecteds ***7 "002 ..0"5   !1 2B4K4KA4N    # #A & 0 0"2I2I!2L  ''* + ''* +  ""1% & rc \4pVPRVR7wr#VP\VP4^4VP^,P \ \444VP4pVPV4VPR4VP\4VP\VP4^4R#)zt When a client connection fails, the service removes its reference to the protocol and tries again after a timeout. Fr:c,VP\4#r!)trapr )rs&rr-@ClientServiceTests.test_clientConnectionFailed..s n1MrN) rrrlrmrr*rrr%r addErrbackr;r<r%rr rr%s& rtest_clientConnectionFailed.ClientServiceTests.test_clientConnectionFaileds **5*N  R__-q1 ""79;#78--/  M*   !MN *+ R__-q1rc :\4pVPVRR7wr#VP\VP4^4VP^,P R4VP\VP4^4VP VPVP44VP^,4VP^,P\\444VP\4VP\VP4^4VP^,P R4VP VPVP44VP^,4R#)zf When a client connection is lost, the service removes its reference to the protocol and calls retry. F)rrN)rrrlrmrr7r\rr%rrrrrr;r<)r%rr rs& rtest_clientConnectionLost,ClientServiceTests.test_clientConnectionLosts0 ***N  R__-q1 ##D) R__-q1   !6!6!8 92;R;RST;U  "11')+2FG *+ R__-q1 ##D)   !6!6!8 92;R;RST;U rc<V^8dQhRR/#)returnNr)formatrFs"r __annotate__ClientServiceTests.__annotate__s$+$+d$+rc aa\4pSPVV3Rl4SPVRRR7wr#SP\ VP 4^4VP P ^4PR4SP\ VP 4^4VP4oSPS4VP\4SP\ VP 4^4VP P ^4PR4SPS4R#)z When the client factory refuses connections by returning None from buildProtocol, the factory keeps attempting new connections. c0<SPS\4#r!)r.r )r%r%srr-AClientServiceTests.test_clientConnectionRefused.."s 4 4]N SrFT)rrrN) rrrrlrmrpopr7r%rr;r<rNsf @rtest_clientConnectionRefused/ClientServiceTests.test_clientConnectionRefuseds  ST**!" +  R__-q1 A''- R__-q1--/  M*  *+ R__-q1 A''- M*rc F\4pVPVR7wr#VP4pVP^,P \ \ 444VPVP4\4VPVP4R#)z When a client connection is lost while the service is stopping, the protocol stopping deferred is called and the reference to the protocol is removed. rN) rrrrrrIndentationErrorr.r%r rcalledr=s& r&test_clientConnectionLostWhileStopping9ClientServiceTests.test_clientConnectionLostWhileStopping>sy ***7     ! "11':J:L2MN W224nE !rc VPRRR7wrVP\VP4^4VP 4VP\VP4^4\ V4pVP 4VP\VP4^4VP RV!4^,4R#)z If L{ClientService} is started when it's already started, it will log a complaint and do nothing else (in particular it will not make additional connections). F)rrcz$Duplicate ClientService.startServiceN)rrlrmrrcrrD)r%r rmessagess& rtest_startTwice"ClientServiceTests.test_startTwiceKs **5u*U  R__-q1 R__-q1T? R__-q1 '>q'AB " "Q " 7''+ X0rc \4pVPRVR7wr#VP4pVP4pVP^R7pVPV4VPV4VPV4VP 4VP \ 4VPV\4VPV\4VPV\4R#)zn L{ClientService.whenConnected} returns a L{Deferred} that fails when L{ClientService.stopService} is called. Fr:rjN) rrr%rrr;r<r.r )r%rr rrlrmrns& rtest_whenConnectedStopService0ClientServiceTests.test_whenConnectedStopServices **5*N   ! ! #  ! ! #  ! !A ! 6 A A A *+ Q/ Q/ Q/rc ,\4pVPRVR7wr#VPP^4P \ R44VP 4pVPVP4.4VPV4R#)z When L{ClientService.stopService} is called while waiting between connection attempts, the pending reconnection attempt is cancelled and the service is stopped immediately. Fr: no connectionN) rrrr]r*rrrlrrr=s& rtest_retryCancelled&ClientServiceTests.test_retryCancelledsy **5*N  A&&y'AB    ! ..0"5 Qrc \4pVPRRVR7wr#VP4pVPVP V44R#)z Calling L{ClientService.stopService} before L{ClientService.startService} returns a L{Deferred} that has already fired with L{None}. F)rrcrNrrr assertIsNoner)r%r_rr,s& r"test_stopServiceBeforeStartService5ClientServiceTests.test_stopServiceBeforeStartServicesR ))!U*     ! $..q12rc \4pVPRVR7wr#VP4pVP^,P \ R44VP 4VP4pVPVPV4P\4VPVPV4P\4R#)z L{ClientService.whenConnected} returns a L{Deferred} that errbacks with L{CancelledError} if L{ClientService.stopService} is called between connection attempts. Fr:rN) rrr%rr*rrrr.rr )r%rr rbeforeErrbackAndStopafterErrbackAndStops& r'test_whenConnectedErrbacksOnStopService:ClientServiceTests.test_whenConnectedErrbacksOnStopServices**5*N &446 ""9_#=>%335   !5 6 < .prepareConnection2 QK1 KrT)rrcN)rrl)r%rr rrs& @r-test_prepareConnectionCalledWhenServiceStarts@ClientServiceTests.test_prepareConnectionCalledWhenServiceStarts+sE 3 **/d+  HQK(rc a.oV3RlpVPVR7wr#VPVP^,S^,4R#)zN The C{prepareConnection} callable is passed the connected protocol instance. c*<SPV4R#r!r)proto newProtocolss&rrVClientServiceTests.test_prepareConnectionCalledWithProtocol..prepareConnectionAs    &rrN)rr\r)r%rr rrs& @r(test_prepareConnectionCalledWithProtocol;ClientServiceTests.test_prepareConnectionCalledWithProtocol:sL   '**/+  R44Q7aIrc a^.oV3Rlp\4pVPVRVR7wr4VP^,P\ R44VP ^S^,4VP \4VP^,PR4VP ^S^,4R#)zN The C{prepareConnection} callback is invoked only once a connection is made. c2<S^;;,^, uu&R#rrrs&rr]ClientServiceTests.test_prepareConnectionCalledAfterConnectionMade..prepareConnectionPrrF)rrrzconnection attempt failedN) rrrr*rrlr;r<r7r%rrr rrs& @r/test_prepareConnectionCalledAfterConnectionMadeBClientServiceTests.test_prepareConnectionCalledAfterConnectionMadeIs 3 **/e+  ""9-H#IJ HQK( *+ ##D) HQK(rc Ja^.oV3Rlp\4pVPWR7wr4VP^S^,4VP^,P \ \ 444VP\4VP^S^,4R#)zi The C{prepareConnection} callback is invoked each time a connection is made, including on reconnection. c2<S^;;,^, uu&R#rrrs&rrUClientServiceTests.test_prepareConnectionCalledOnReconnect..prepareConnectiongrrrrN) rrrlrrrrar;r<rs& @r'test_prepareConnectionCalledOnReconnect:ClientServiceTests.test_prepareConnectionCalledOnReconnect`s 3 **/+  HQK( "11':J:L2MN *+ HQK(rc a\4oV3RlpVPVR7wr#VPVP44pVP SV4R#)a The C{prepareConnection} return value is ignored when it does not indicate a failure. Even though the callback participates in the internal new-connection L{Deferred} chain for error propagation purposes, any successful result does not affect the ultimate return value. c<S#r!r)rsentinels&rrVClientServiceTests.test_prepareConnectionReturnValueIgnored..prepareConnectionsOrrN)rrrr%assertNotIdentical)r%rr rr2rs& @r(test_prepareConnectionReturnValueIgnored;ClientServiceTests.test_prepareConnectionReturnValueIgnoredwsR8 **=N*O %%g&;&;&=> &1rc aa.o\4oVV3RlpVPVR7wr#VP4pVPV4SP R4VP VP ^,VPV44R#)zw The C{prepareConnection} callable returns a deferred and calls to L{ClientService.whenConnected} wait until it fires. c*<SPV4S#r!r)rnewProtocolDeferredrs&rrVClientServiceTests.test_prepareConnectionReturningADeferred..prepareConnections    && &rrN)r rr%rr7r\rr)r%rr rwhenConnectedDeferredrrs& @@r(test_prepareConnectionReturningADeferred;ClientServiceTests.test_prepareConnectionReturningADeferreds  &j '**=N*O  ' 5 5 7 12$$T*   # #A &(<(<=R(S rc b\4pRpVPW!R7wr4VP^R7pVPV4VP \ 4VPV4VP \ 4VP \VPV4P4R#)z[ The connection attempt counts as a failure when the C{prepareConnection} callable throws. c\4hr!)ra)rs&rrJClientServiceTests.test_prepareConnectionThrows..prepareConnections "$ $rrrjN) rrr%rr;r<r\rar.type)r%rrr rrs& rtest_prepareConnectionThrows/ClientServiceTests.test_prepareConnectionThrowss  %**/+ !( 5 5 5 J 12 *+ 12 *+  d223HINN rrN)(r>r?r@rArBrrrrrr"r*r/r7r>rArGrOrRr^rcrgrrrrrrrrrrrrrrrrrrCrDrEs@rrrs  HT2 6  : +8 "J(     02" *$+$+L " MB*81t0&   3 21.10 D ) J).).2& .  rr)F)0rBrzope.interfacerzope.interface.verifyrtwisted.applicationrtwisted.application.internetrrrtwisted.internetrtwisted.internet.deferr r twisted.internet.interfacesr r r rrtwisted.internet.protocolrrtwisted.internet.taskrtwisted.internet.testingrtwisted.loggerrrtwisted.python.failurertwisted.trial.unittestrrrrr"rTrrrrr<rrrrrs &-( ";8'4:*@  "#=*=*$=*@ !:. ^   6 !:.V18V1rC-C-L""( &F&8:$z  ,z  r