֛h6$ SrSSKrSSKrSSKrSSKrSSKrSSKJr SSKJ r SSK J r SSK JrJr SSKJrJrJr SSKJrJr SS KJrJrJrJr SS KJrJrJr SS K J!r! SS K"J#r# SS K$J%r% SSK&J'r'J(r( SSK)J*r* SSK+J,r,J-r-J.r.J/r/ SSK0J1r1 "SS\-Rd5r3"SS\-Rh5r5\"\Rl5"SS55r7"SS5r8Sr9"SS5r:"SS\#5r;SSjr<"S S!\-Rz5r>"S"S#\-Rz5r?"S$S%\-R5rA"S&S'\-R5rC\-R"\A\C5 "S(S)\-R5rES*rF\-R"\E\F5 "S+S,\-Rz5rH"S-S.\-R5rJ"S/S0\-Rz5rK"S1S2\-R5rL"S3S4\-R5rN\-R"\L\N5 "S5S6\-R5rO\-R"\J\O5 "S7S8\-Rz5rP"S9S:\-Rz5rQ"S;S<\-Rz5rR"S=S>\-Rz5rS"S?S@\-R\-R5rT\-R"\T\T5 "SASB\-R\-R5rU\-R"\U\U5 "SCSD\-R\-R5rV\-R"\V\V5 "SESF\-R5rX"SGSH\-R5rY"SISJ\1R5r["SKSL\-R5r]"SMSN\1R5r_"SOSP\1R5r`SQraSqbSqcSRrd"SSST\-Rz5re"SUSV\-Rz5rf"SWSX\1R5rg"SYSZ\.R5ri"S[S\\.R5rk"S]S^\-Rz5rl\-R"\i\k5 "S_S`\1R5rm"SaSb\n5ro"ScSd\-R5rp"SeSf\-Rz5rq"SgSh\/R5rs\"\-R5"SiSj\-Rh55ru"SkSl5rv"SmSn\-Rd5rw"SoSp\v5rx"SqSr\1R5ry"SsSt\1R5rz\"\-R5"SuSv55r{"SwSx\1R5r|"SySz\5r}\"\}5"S{S|55r~"S}S~\1R5r"SS\1R5rg)z Tests for Perspective Broker module. TODO: update protocol level tests to use new connection API, leaving only specific tests for old API. N)deque)BytesIO)Dict) Interface implementer)checkers credentialsportal)UnauthorizedLoginUnhandledCredentials)addressmainprotocolreactor)Deferred gatherResultssucceed)ConnectionRefusedError)_FakeConnector)WrappingFactory)failurelog) iterbytes)jellypbpublishutil)unittestc\rSrSrSrSrg)Dummy'c0[U[5(agg)Nz hello world!zgoodbye, cruel world!) isinstanceDummyPerspectiveselfusers _C:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/spread/test/test_pb.pyview_doNothingDummy.view_doNothing(s d, - -!*N)__name__ __module__ __qualname____firstlineno__r)__static_attributes__r,r+r(r r 's+r+r c\rSrSrSrSrSrg)r$/z= An L{IPerspective} avatar which will be used in some tests. c[5$N)r r&s r(perspective_getDummyViewPoint.DummyPerspective.perspective_getDummyViewPoint4s wr+r,N)r-r.r/r0__doc__r7r1r,r+r(r$r$/s r+r$c\rSrSrSrSrg) DummyRealm8c^UH'nU[RLdMU[U5S4s $ g)Ncgr5r,r,r+r(*DummyRealm.requestAvatar..=s$r+)r IPerspectiver$)r&avatarIdmind interfacesifaces r( requestAvatarDummyRealm.requestAvatar:s+E'.x8,FF r+r,N)r-r.r/r0rFr1r,r+r(r;r;8sGr+r;c0\rSrSrSrSrSrSrSrSr g) IOPump@z Utility to pump data between clients and servers for protocol testing. Perhaps this is a utility worthy of being in protocol.py? c4XlX lX0lX@lgr5)clientserverclientIOserverIO)r&rLrMrNrOs r(__init__IOPump.__init__Gs    r+cSUl[R"5S-nUR(dZUR5(aD[R"5U:agUR(dUR5(aMBgggg)z Pump until there is no more input or output or until L{stop} is called. This does not run any timers, so don't use it with any code that calls reactor.callLater. FN)_stoptimepump)r&timeouts r(flush IOPump.flushMsU ))+/**yy{W$****r+cSUlg)zL Stop a running L{flush} operation, even if data remains to be transferred. TN)rTr6s r(stop IOPump.stopZs  r+cURRS5 URRS5 URR5nURR5nURRS5 URRS5 URR 5 URR 5 UR R R5 URR R5 [U5HnURRU5 M [U5HnUR RU5 M U(dU(agg)z@ Move data back and forth. Returns whether any data was moved. r) rNseekrOreadtruncaterL transport_checkProducerrMr dataReceived)r&cDatasDatabytes r(rV IOPump.pumpas  1 1 ""$ ""$ 1 1     ,,. ,,.e$D KK $ $T *%e$D KK $ $T *% Er+)rTrLrNrMrON) r-r.r/r0r9rPrXr[rVr1r,r+r(rIrI@s ! r+rIc^SnTRU5nURU5n[5n[5nUR[R"U55 UR[R"U55 [ XEXg5nSn U4Sjn UR X5 UR X5 UR U 5 UR5 XEU4$)a8 Create a server and a client and connect the two with an L{IOPump}. @param test: the test case where the client and server will be used. @type test: L{twisted.trial.unittest.TestCase} @param clientFactory: The factory that creates the client object. @type clientFactory: L{twisted.spread.pb.PBClientFactory} @param serverFactory: The factory that creates the server object. @type serverFactory: L{twisted.spread.pb.PBServerFactory} @return: a 3-tuple of (client, server, pump) @rtype: (L{twisted.spread.pb.Broker}, L{twisted.spread.pb.Broker}, L{IOPump}) ) 127.0.0.1cUR(d4UR[R"[R 55 ggr5) disconnectedconnectionLostrFailurerCONNECTION_DONE)brokers r(maybeDisconnect/connectServerAndClient..maybeDisconnects-""  ! !'//$2F2F"G H#r+cj>TRS[R"[R5S9 g)N) connectorreason)clientConnectionLostrrnrro) clientFactorysr(disconnectClientFactory7connectServerAndClient..disconnectClientFactorys, **7??43G3G#H + r+) buildProtocolStringIOmakeConnectionr FileWrapperrI addCleanuprV) testrw serverFactoryaddr clientBroker serverBrokerclientTransportserverTransportrVrqrxs ` r(connectServerAndClientr{s& D ..t4L ..t4LjOjO 4 4_ EF 4 4_ EF ,o ODI  OOO2OOO2OO+,IIK t ++r+c*\rSrSrSrSrSrSrSrg)_ReconnectingFakeConnectorStatez Manages connection notifications for a L{_ReconnectingFakeConnector} instance. @ivar notifications: pending L{Deferreds} that will fire when the L{_ReconnectingFakeConnector}'s connect method is called c"[5Ulgr5)r notificationsr6s r(rP(_ReconnectingFakeConnectorState.__init__s "Wr+cP[5nURRU5 U$)z Connection notification. @return: A L{Deferred} that fires when this instance's L{twisted.internet.interfaces.IConnector.connect} method is called. @rtype: L{Deferred} )rr appendleft)r&notifiers r(notifyOnConnect/_ReconnectingFakeConnectorState.notifyOnConnects$: %%h/r+cUR(a=URR5RU5 UR(aM<gg)z! Fire all pending notifications. N)rpopcallbackr6s r( notifyAll)_ReconnectingFakeConnectorState.notifyAlls8     " " $ - -d 3   r+)rN) r-r.r/r0r9rPrrr1r,r+r(rrs% 4r+rc8^\rSrSrSrU4SjrU4SjrSrU=r$)_ReconnectingFakeConnectorzW A fake L{IConnector} that can fire L{Deferred}s when its C{connect} method is called. c0>[TU]U5 X lg)z @param address: An L{IAddress} provider that represents this connector's destination. @type address: An L{IAddress} provider. @param state: The state instance @type state: L{_ReconnectingFakeConnectorState} N)superrP_state)r&r state __class__s r(rP#_ReconnectingFakeConnector.__init__s ! r+cV>[TU]5 URR5 g)z= A C{connect} implementation that calls C{reconnectCallback} N)rconnectrr)r&rs r(r"_ReconnectingFakeConnector.connects  r+)r) r-r.r/r0r9rPrr1 __classcell__)rs@r(rrs   r+rcU=(d [5n[R"SS9n[R"[ R "X/55n[R"5n[XU5$)z Connect a client and server L{Broker} together with an L{IOPump} @param realm: realm to use, defaulting to a L{DummyRealm} @returns: a 3-tuple (client, server, pump). guest)guest) r;r'InMemoryUsernamePasswordDatabaseDontUserPBServerFactoryr PortalPBClientFactoryr)rrealmcheckerrrws r(connectedServerAndClientrsV  !Z\E>>XNG&&v}}UI'FGM&&(M !$} EEr+c \rSrSrSrSrSrg) SimpleRemotecXlUS-$Nr^argr&rs r( remote_thunkSimpleRemote.remote_thunkQwr+c[5er5) Exceptionrs r( remote_knuthSimpleRemote.remote_knuths kr+rN)r-r.r/r0rrr1r,r+r(rrs r+rc\rSrSrSrSrg) NestedRemoteic[5$r5)rr6s r(remote_getSimpleNestedRemote.remote_getSimples ~r+r,N)r-r.r/r0rr1r,r+r(rrsr+rc\rSrSrSrSrg) SimpleCopyic4SUlSS0UlS/UlgNr^HelloWorldrxyzr6s r(rPSimpleCopy.__init__7#r+rNr-r.r/r0rPr1r,r+r(rrr+rc\rSrSrSrg)SimpleLocalCopyi r,Nr-r.r/r0r1r,r+r(rr r+rc8\rSrSr%Sr0r\\S4\S'Sr Sr g)SimpleFactoryCopyizQ @cvar allIDs: hold every created instances of this class. @type allIDs: C{dict} allIDsc6XlU[RU'gr5)idrr)r&rs r(rPSimpleFactoryCopy.__init__s'+  $r+)rN) r-r.r/r0r9rrint__annotations__rPr1r,r+r(rrs# .0FD)) */,r+rcURSS5nUc[S[U535eU[R;a[S[R35e[RUnU(d [S5eU$)z` Factory of L{SimpleFactoryCopy}, getting a created instance given the C{id} found in C{state}. rNz&factory copy state has no 'id' member zfactory class has no ID: z&factory method found no object with id)get RuntimeErrorreprrr)rstateIdinsts r(createFactoryCopyr!s~ iid#GCDK=QRR'...67H7O7O6PQRR  # #G ,D CDD Kr+c \rSrSrSrSrSrg) NestedCopyi4c[5$r5)rr6s r(remote_getCopyNestedCopy.remote_getCopy5s |r+c[U5$r5)r)r&values r(remote_getFactoryNestedCopy.remote_getFactory8s  ''r+r,N)r-r.r/r0rrr1r,r+r(rr4s (r+rc\rSrSrSrSrg) SimpleCachei<c4SUlSS0UlS/Ulgrrr6s r( __init___SimpleCache.__init___=rr+rN)r-r.r/r0rr1r,r+r(rr<rr+rc \rSrSrSrSrSrg)NestedComplicatedCacheiCc"[5Ulgr5)VeryVeryComplicatedCacheablecr6s r(rPNestedComplicatedCache.__init__Ds -/r+cUR$r5rr6s r(remote_getCache&NestedComplicatedCache.remote_getCacheGs vv r+rN)r-r.r/r0rPrr1r,r+r(rrCs 0r+rc,\rSrSrSrSrSrSrSrg)riKc.SUlSUlSUlg)Nr^rrfoor6s r(rP%VeryVeryComplicatedCacheable.__init__Lsr+cJSUlURRSS5 g)Nr)robserver callRemoter6s r(setFoo4$VeryVeryComplicatedCacheable.setFoo4Qs   *r+cVX lURURURS.$)Nr)rrrrr& perspectivers r(getStateToCacheAndObserveFor9VeryVeryComplicatedCacheable.getStateToCacheAndObserveForUs  VV$&&::r+c[R"S5 URS5 X R:XaSUlgg)Nzstopped observingend)rmsgrrr s r(stoppedObserving-VeryVeryComplicatedCacheable.stoppedObservingYs3 #$E" }} $ DM %r+)rrrrN) r-r.r/r0rPrr rr1r,r+r(rrKs +;!r+rc \rSrSrSrSrSrg)RatherBaroqueCachei`cXlgr5r)r&newFoos r( observe_fooRatherBaroqueCache.observe_fooasr+c0[R"S5 g)Nzthe end of things)rrr6s r( observe_endRatherBaroqueCache.observe_endds #$r+rN)r-r.r/r0rrr1r,r+r(rr`s %r+rc,\rSrSrSrSrSrSrSrg)SimpleLocalCacheikc:URRU5 gr5)__dict__update)r&rs r(setCopyableState!SimpleLocalCache.setCopyableStatels U#r+cUR$r5)checkr6s r( checkMethodSimpleLocalCache.checkMethodo zzr+cU$r5r,r6s r( checkSelfSimpleLocalCache.checkSelfrs r+cgrr,r6s r(r$SimpleLocalCache.checkusr+r,N) r-r.r/r0r!r%r)r$r1r,r+r(rrks$r+rc&\rSrSrSrSrSrSrg) NestedCachei|c"[5Ulgr5)rrr6s r(rPNestedCache.__init__}s r+c2URUR/$r5rr6s r(rNestedCache.remote_getCachesr+cURUL$r5r2r&caches r(remote_putCacheNestedCache.remote_putCachesvvr+r2N)r-r.r/r0rPrr7r1r,r+r(r.r.|s r+r.c,\rSrSrSrSrSrSrSrg) Observableic/Ulgr5 observersr6s r(rPObservable.__init__s r+c:URRU5 gr5)r=appendr&obss r(remote_observeObservable.remote_observe c"r+c:URRU5 gr5)r=removerAs r(remote_unobserveObservable.remote_unobserverEr+cNURHnURSX5 M g)Nnotify)r=r)r&objrs r(rKObservable.notifys H   $ 4'r+r<N) r-r.r/r0rPrCrHrKr1r,r+r(r:r:s##5r+r:c,\rSrSrSrSrSrSrSrg)DeferredRemoteicSUlg)Nrrunr6s r(rPDeferredRemote.__init__s r+cXlUS-$rrQrs r(runMeDeferredRemote.runMerr+cS5e)Nzshouldn't have been run!r,rs r( dontRunMeDeferredRemote.dontRunMes ,,,qr+cr[5nURURUR5 XlU$)zW Return a L{Deferred} to be fired on client side. When fired, C{self.runMe} is called. )r addCallbacksrUrXd)r&r\s r(remote_doItLaterDeferredRemote.remote_doItLaters+ J tzz4>>2r+)r\rRN) r-r.r/r0rPrUrXr]r1r,r+r(rOrOs-r+rOc"\rSrSrSrSrSrSrg)ObserverirNc\X lURS-UlURSU5 g)Nr^ unobserve)rLnotifiedr)r&otherrLs r( remote_notifyObserver.remote_notifys' )  d+r+)rcrL)r-r.r/r0rcrLrer1r,r+r(r`r`sH C,r+r`c\rSrSrSrSrg) NewStyleCopyicXlgr5s)r&rks r(rPNewStyleCopy.__init__sr+rjNrr,r+r(rhrhsr+rhc,\rSrSrSrSrSrSrSrSr g) NewStyleCopy2irr^cp[=RS- sl[RU5nSUlU$)Nr^r)rn allocatedobject__new__r)r&rs r(rrNewStyleCopy2.__new__s-1$~~d#  r+c6[=RS- slgr)rn initializedr6s r(rPNewStyleCopy2.__init__s!!Q&!r+r,N) r-r.r/r0rprurrrrPr1r,r+r(rnrnsIK E 'r+rnc\rSrSrSrSrg)NewStyleCacheCopyicUR$r5)rr s r(r .NewStyleCacheCopy.getStateToCacheAndObserveFors }}r+r,N)r-r.r/r0r r1r,r+r(rxrxsr+rxc \rSrSrSrSrSrg)EchoericU$r5r,r&sts r( remote_echoEchoer.remote_echos r+c X4$r5r,)r&rkws r(remote_echoWithKeywordsEchoer.remote_echoWithKeywordss xr+r,N)r-r.r/r0rrr1r,r+r(r|r|s r+r|c \rSrSrSrSrSrg)CachedReturnericXlgr5r6r5s r(rPCachedReturner.__init__s r+cUR$r5rr~s r(remote_giveMeCache!CachedReturner.remote_giveMeCacher'r+rN)r-r.r/r0rPrr1r,r+r(rrs r+rc2\rSrSrSrSrSrSrSrSr g) NewStyleTestsic[R"[55Ul[R"5n[ XURS9uo lUlURUR55Ul g)zI Create a pb server using L{Echoer} protocol and connect a client to it. )rrwrN) rrr|rrrrMrVsuccessResultOf getRootObjectref)r&rwrLs r(setUpNewStyleTests.setUpsb //9**, )?$BTBT* & TY'' (C(C(EFr+cFS[lS[lS[lg)zX Close client and server connections, reset values of L{NewStyleCopy2} class variables. rr^N)rnrprurr6s r(tearDownNewStyleTests.tearDowns #$ $% ! r+c^^[S5mTRRST5nTRR 5 UU4SjnUR U5 U$)zI Create a new style object, send it over the wire, and check the result. rechoc>TRU[5 TRURS5 TR UTL5 g)Nr)assertIsInstancerh assertEqualrk assertFalseresorigr&s r(cb'NewStyleTests.test_newStyle..cbs9  ! !#| 4   SUUG ,   SD[ )r+rhrrrVrX addCallbackr&r\rrs` @r( test_newStyleNewStyleTests.test_newStylesKG$ HH   -  * br+c:^^[5mTR[RS5 TR[RS5 TRR ST5nTR R5 UU4SjnURU5 U$)z> Send a new style object and check the number of allocations. r^rc>TRU[5 TRURS5 TR[RS5 TR[R S5 TR UT5 g)Nrrr^)rrnrrrpru assertIsNotrs r(r$NewStyleTests.test_alloc..cbsc  ! !#} 5   SYY *   ]44a 8   ]66 :   S$ 'r+) rnrrprurrrVrXrrs` @r( test_allocNewStyleTests.test_alloc st 00!4 22A6 HH   -  ( br+c^^[S5mTRRSTSSS9nTRR 5 UU4SjnUR U5 U$)zW Create a new style object with keywords, send it over the wire, and check the result. value1echoWithKeywordsonetwokeyword1keyword2c.>TRU[5 TRUS[5 TRUS[5 TR USR S5 TR UST5 TR USSSS.5 g)Nrr^rrrr)rtuplerhdictrrkrrs r(r3NewStyleTests.test_newStyleWithKeywords..cb.s  ! !#u -  ! !#a&, 7  ! !#a&$ /   SVXXx 0   SVT *   SV%U%K Lr+rrs` @r(test_newStyleWithKeywords'NewStyleTests.test_newStyleWithKeywords#sZ H% HH   uu    M br+)rVrrMrN) r-r.r/r0rrrrrr1r,r+r(rrs G  ,r+rc(\rSrSrSrSrSrSrSrg)ConnectionNotifyServerFactoryi:aJ A server factory which stores the last connection and fires a L{Deferred} on connection made. This factory can handle only one client connection. @ivar protocolInstance: the last protocol instance. @type protocolInstance: C{pb.Broker} @ivar connectionMade: the deferred fired upon connection. @type connectionMade: C{Deferred} Nc`[RRX5 [5Ulg)z Initialize the factory. N)rrrPrconnectionMade)r&roots r(rP&ConnectionNotifyServerFactory.__init__Is" ##D/&jr+c`XlURSso lUbURS5 gg)z6 Store the protocol and fire the connection deferred. N)protocolInstancerr)r&rr\s r(clientConnectionMade2ConnectionNotifyServerFactory.clientConnectionMadePs3!)!%!4!4d  = JJt  r+)rr) r-r.r/r0r9rrPrr1r,r+r(rr:s )r+rc&\rSrSrSrSrSrSrg)NewStyleCachedTestsiZc^[5TlSTRl[R"S[ [ TR555Tl[R"5n[R"STRR5RU5 U4SjnUR5RU5nTRRR n[#X4/5$)zQ Create a pb server using L{CachedReturner} protocol and connect a client to it. rr localhostc>UTlgr5)r)rr&s r(gotRoot*NewStyleCachedTests.setUp..gotRooths DHr+)rxrrkr listenTCPrrrMrr connectTCPgetHostportrrfactoryrr)r&rwrd1d2s` r(rNewStyleCachedTests.setUp[s &'  '' ,^DII-FG  **, ; (;(;(=(B(BMR  ( ( * 6 6w ? [[ / /bX&&r+cURRRRR 5 UR R RR 5 URR5$)z& Close client and server connections. )rMrrrbloseConnectionrrp stopListeningr6s r(rNewStyleCachedTests.tearDownosS ,,66EEG !!002{{((**r+c^TRRSTR5nU4SjnURUS5 URUS5 U$)z A new-style cacheable object can be retrieved and re-retrieved over a single connection. The value of an attribute of the cacheable can be accessed on the receiving side. giveMeCachec >TRU[5 TRSUR5 TR TR U5 U(a-UTlTRRSTR 5$g)Nrr) rrxrrkrrrrr)ragainr&s r(r2NewStyleCachedTests.test_newStyleCache..cbsh  ! !#'8 9   Wcee ,   TYY ,xx**=$))DD r+TF)rrrr)r&r\rs` r(test_newStyleCache&NewStyleCachedTests.test_newStyleCachewsH HH   tyy 9 E b$ b% r+)rrrrMN)r-r.r/r0rrrr1r,r+r(rrZs'(+r+rc~\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rSrSrSrSrSrSrSrg) BrokerTestsiNcR[R"S5 g![a gf=f)NNone-None-TESTING.pub)osunlinkOSErrorr6s r(rBrokerTests.tearDowns&  II- .   s  &&c,URSU35 g)Nz&This should cause a return value, not fail)r&errors r( thunkErrorBadBrokerTests.thunkErrorBads :5'BCr+cXlgr5) thunkResultr&results r(thunkResultGoodBrokerTests.thunkResultGoods!r+cgr5r,)r&tbs r(thunkErrorGoodBrokerTests.thunkErrorGood r+c,URSU35 g)Nz This should cause an error, not rrs r(thunkResultBadBrokerTests.thunkResultBads 4VH=>r+c [US9upn"SS[R5n"SS[R5nURSU"55 UR S5nU"5nU"5nUR SXx5 UR 5 UR 5 UR 5 URURUS5 URURS5URS55 g) Nrc\rSrSrSrSrg)%BrokerTests.test_reference..XicXlgr5caughtrs r( remote_catch2BrokerTests.test_reference..X.remote_catchs! r+rN)r-r.r/r0rr1r,r+r(Xrs "r+rc\rSrSrSrSrg)%BrokerTests.test_reference..Yic(URSU5 g)Ncatchrr&abs r( remote_throw2BrokerTests.test_reference..Y.remote_throws Wa(r+r,N)r-r.r/r0rr1r,r+r(Yrs )r+rrthrowzX should have caught Z) rr ReferenceablesetNameForLocal remoteForNamerrVassertIsrr remoteMethod) r&rrkrVrrrrrs r(test_referenceBrokerTests.test_references-48 d "   " )   ) #qs# OOC  C C Wa#    ahh#;< 0!..2IJr+c[US9upnX4X!44HupE[5nURSU5 URS5nSUlUR SURS- 5R URUR5 UR5 UR5 URURURS5 M g)Nrrthunkr^zresult wasn't received.) rrrrexpectedThunkResultrr[rrrVrr)r&rrkrVrrrbars r( test_resultBrokerTests.test_results-48 dFQFNDA.C  eS )//%(C'(D $ NN7D$<$ ))++A.7r+c[US9upn[5n[5nURSU5 UR S5nUR SU5 UR 5 URS5 UR 5 UR 5 URS5 UR 5 UR 5 URURS5 URURSS5 g)Nrr observer^r&z didn't notifyznotified too much) rr:r`rrrrVrKassertIsNotNonerLr)r&rrkrVr rras r( test_observeBrokerTests.test_observes-48 d L J #q! __S ! i#          QUUO4 #67r+cb[US9upn[5nURSU5 URS5nUR 5 UR 5 /nUR S5R UR5 UR 5 UR 5 URURS5 URRS5 URURSS5 UR 5 UR 5 URUSSS 5 g) Nrr\ doItLaterzDeferred method run too early.rSzDeferred method run too late.rzIncorrect result.) rrOrrrVrrr@rrRr\rr)r&rrkrVr\r.resultss r( test_deferBrokerTests.test_defers-48 d   #q! OOC    [!--gnn=    @A  Q #BC   Q(;>Y & JJL    /r+c[US9upn[5n[5nURnUR SU5 UR SU5 UR S5nUR S5n/n UR S5RU R5RU R5 UR S5RU R5RU R5 /n UR S5RU R5 UR S5RU R5 UR5 URU SRS5 URU SRS5 URU SRS5 UR5 UR5 URU SRS 5 UR[!U 5S5 U SSn UR#U R%5R&U S 5 UR#U R)5U S 5 /n UR S U 5RU R5 UR5 UR+U S5 URUR-S5UR-S55 U R.n U SR.nUR1XR2S 5 A A UR5 A A UR5 [4R6S:a[8R:"5 UR5 UR=XR2S5 UR=XR>S5 UR=XR2S5 UR=XR>S5 URAURBS5 g)NrrLxxxgetCacherr^rrrzpotential refcounting issuez!other potential refcounting issueputCachezremote cache doesn't have itrDzServer still had it after GCzClient still had it after GCz!Server still had complex after GCz!Client still had complex after GCzobserver was not removed)"rr.rrrrrrr@ addErrbackrXrrrrrr,assertIdenticalr%__self__r)r+rrErFremotelyCachedObjectsrHrIrJrKrLlocallyCachedObjects assertIsNoner)r&rrkrVrLobj2vcco2o3collcomplexcpcol2rE baroqueLuids r( test_cacheBrokerTests.test_cache4s-48 dm%'ff %% %& __U # __U # j!--dkk:EEdkkR j!--dkk:EEdkkR j!--gnn= j!--gnn=  q) q) +   + TA& !WQZ  NN  % %r+H  R\\^R1TU j"%11$++>  Q  4booj6QRwwajoo  d335ST      >>Y & JJL  668VW 557UV  002U   //1T  #,,(BCr+c[R"S5 [US9upn[ 5nUR SU5 UR S5n/nURS5RURUR5 UR5 UR5nURURS5 URURS5 URUR S5 URUR"S5 [US9upnUR SU5 UR S5nURS5RURUR5 UR5 UR5nURUR"S5 g![a GNf=f)NrrrgetPubr^r)rrrr GetPublisherrrrr[r@rrXrractivateCalled isActivatedyayIGotPublished_wasCleanWhenLoaded)r&rrkrVrraccumrLs r(test_publishableBrokerTests.test_publishablevsh  II- ..48 dn %%ooe$ x --ellD? (() ++,r+)rrrN) r-r.r/r0r9rrrrrr1r,r+r(rrLs!D  $!-r+rc\rSrSrSrg)FreakOutir,Nrr,r+r(rrrr+rc\rSrSrSrSrg)ric[5er5)r)r&ps r(getStateToCopyForBadCopyable.getStateToCopyFors jr+r,N)r-r.r/r0rr1r,r+r(rrsr+rc\rSrSrSrSrg)ricgr5r,)r&bcs r(remote_setBadCopyBadCopySet.remote_setBadCopysr+r,N)r-r.r/r0rr1r,r+r(rrsr+rc.\rSrSrSrSrSSjrSrSrg) LocalRemoteTestirc US-$rr,)r&rs r( sync_add1LocalRemoteTest.sync_add1s 1u r+c X-$r5r,)r&rrs r( async_addLocalRemoteTest.async_adds u r+c[5er5rr6s r( async_failLocalRemoteTest.async_fails nr+r,N)rr^) r-r.r/r0reportAllTracebacksrrrr1r,r+r(rrsr+rc>\rSrSrSrS=rrSrSrSr Sr Sr S r g ) MyPerspectiveiz @ivar loggedIn: set to C{True} when the avatar is logged in. @type loggedIn: C{bool} @ivar loggedOut: set to C{True} when the avatar is logged out. @type loggedOut: C{bool} FcXlgr5rBr&rBs r(rPMyPerspective.__init__s r+cUR$)zD Return the avatar identifier which was used to access this avatar. r r6s r(perspective_getAvatarId%MyPerspective.perspective_getAvatarIds}}r+c[5$r5)MyViewr6s r(perspective_getViewPoint&MyPerspective.perspective_getViewPoints xr+c X-$)z Add the given objects and return the result. This is a method unavailable on L{Echoer}, so it can only be invoked by authenticated users who received their avatar from L{TestRealm}. r,r s r(perspective_addMyPerspective.perspective_adds u r+cSUlgNT loggedOutr6s r(logoutMyPerspective.logout r+)rBrN) r-r.r/r0r9loggedInrrPrrrrr1r,r+r(r r s,! Hy! r+r c&\rSrSrSr\rSrSrSr g) TestRealmia A realm which repeatedly gives out a single instance of L{MyPerspective} for non-anonymous logins and which gives out a new instance of L{Echoer} for each anonymous login. @ivar lastPerspective: The L{MyPerspective} most recently created and returned from C{requestAvatar}. @ivar perspectiveFactory: A one-argument callable which will be used to create avatars to be returned from C{requestAvatar}. NcLU[R:XdeUS:XdeU[RLa[R[ 5S4$UR U5UlSUR l[RUR UR R4$)z Verify that the mind and interface supplied have the expected values (this should really be done somewhere else, like inside a test method) and return an avatar appropriate for the given identifier. BRAINS!cgr5r,r,r+r(r?)TestRealm.requestAvatar..sdr+T) rrAr ANONYMOUSr|perspectiveFactorylastPerspectiver r)r&rBrC interfaces r(rFTestRealm.requestAvatars BOO+++y   x)) )??FHl: :#'#:#:8#DD ,0D )OOT%9%94;O;O;V;VW Wr+)r)) r-r.r/r0r9r r(r)rFr1r,r+r(r"r"s 'O Xr+r"c\rSrSrSrSrg)ric"[U[5$r5)r#r r%s r( view_checkMyView.view_checks$ ..r+r,N)r-r.r/r0r.r1r,r+r(rrs/r+rc$\rSrSrSrSrSrSrg) LeakyRealmizQ A realm which hangs onto a reference to the mind object in its logout function. cXlg)zx Create a L{LeakyRealm}. @param mindEater: a callable that will be called with the C{mind} object when it is available N _mindEater)r& mindEaters r(rPLeakyRealm.__init__s $r+cz^^URT5 URU5m[RTUU4Sj4$)Nc(>TTR54$r5)r)rCperspsr(r?*LeakyRealm.requestAvatar..su||~0Fr+)r4r(rrA)r&rBrCr*r9s ` @r(rFLeakyRealm.requestAvatars1 ''1(FGGr+r3N)r-r.r/r0r9rPrFr1r,r+r(r1r1s $Hr+r1c\rSrSrSrSrSrg)NewCredLeakTestsi z' Tests to try to trigger memory leaks. c^^^^ STlU4Sjn[T[U5S9unm m/mURS5nUR SS5nSnUR U5 UUU 4SjnUR U5 TR 5 TRTS /5 [R"5 TRTR55 g) z The server does not leak a reference when the client disconnects suddenly, even if the cred logout function forms a reference cycle with the perspective. Nc<>[R"U5Tlgr5)weakrefrmindRef)rCr&s r( setMindRef4NewCredLeakTests.test_logoutLeak..setMindRefs";;t,DLr+)rrrloginrcnUup[5nURS[R"US5U5$)Nrespondr)rrrrF)r challenge challengerrCs r( cbResponse4NewCredLeakTests.test_logoutLeak..cbResponse$s6$% !I>D((2::i:D r+c>TR5 TRS5 TR[R"[ S555 g)Nr^boom)r[r@rmrrnr)_connectionBrokenrVrs r(rm8NewCredLeakTests.test_logoutLeak..connectionLost-s6 IIK  # #A &  ' ' V8L(M Nr+r^) rArr1rrrrXrrJrKrY) r&rBrrr\rIrmrNrVrs ` @@@r(test_logoutLeak NewCredLeakTests.test_logoutLeaks  -,DZ 3, ( lD ))&1 OOGX .  j! O n%  )A3/  $,,.)r+)rAN)r-r.r/r0r9rPr1r,r+r(r=r= s .*r+r=c\rSrSrSrSrSSjr\R"\ R54Sjr Sr Sr S rS rS rS rS rSrSrSrSrSrSrSrSrg) NewCredTestsi?z5 Tests related to the L{twisted.cred} support in PB. c[5Ul[R"UR5Ul[ UR5Ul[ R"5Ulg)z Create a portal with no checkers and wrap it around a simple test realm. Set up a PB server on a TCP port which serves perspectives using that portal. N) r"rr rrrrrrwr6s r(rNewCredTests.setUpDsC [ mmDJJ/ :4;;G//1r+NcP[XRUR5uUlUlUl[ 5Ul[[R"SSS5UR5Ul URR5RUR5 g)an Connect a client obtained from C{clientFactory} and a server obtained from the current server factory via an L{IOPump}, then assign them to the appropriate instance variables @ivar clientFactory: the broker client factory @ivar clientFactory: L{pb.PBClientFactory} instance @ivar client: the client broker @type client: L{pb.Broker} @ivar server: the server broker @type server: L{pb.Broker} @ivar pump: the IOPump connecting the client and server @type pump: L{IOPump} @ivar connector: A connector whose connect method recreates the above instance variables @type connector: L{twisted.internet.base.IConnector} TCPrjiN)rrwrrLrMrVrconnectorStaterr IPv4AddressrtrrestablishClientAndServer)r&_ignoreds r(rZ%NewCredTests.establishClientAndServerOs,/E $$d&8&8/ + T[$)>?3   {D 94;N;N  ++-99$:W:WXr+cURURRR5 URR U5 UR R URU5 g)aL Asserts that the client broker's transport was closed and then mimics the event loop by calling the broker's connectionLost callback with C{reason}, followed by C{self.clientFactory}'s C{clientConnectionLost} @param reason: (optional) the reason to pass to the client broker's connectionLost callback @type reason: L{Failure} N)r+rLrbr*rmrwrvrt)r&rus r(completeClientLostConnection)NewCredTests.completeClientLostConnectionosN  --445 ""6* //Gr+c^TR5 TRR5nU4SjnU4SjnURU5 URU5 U$)z Assert that L{PBClientFactory.getRootObject}'s Deferred fires with a L{RemoteReference}, and that disconnecting it runs its disconnection callbacks. cH>TRU[R5 U$r5)rrRemoteReference)rootObjr&s r( gotRootObject6NewCredTests.test_getRootObject..gotRootObjects  ! !'2+=+= >Nr+c>[5nURUR5 TRR 5 TR 5 U$r5)rrrrw disconnectr^)rcdisconnectedDeferredr&s r(rg3NewCredTests.test_getRootObject..disconnectsD#+:  & &';'D'D E    ) ) +  - - /' 'r+rZrwrr)r&rootObjDeferredrdrgs` r(test_getRootObjectNewCredTests.test_getRootObjectsS %%',,::<  ( ##M2##J/r+c^TR5 TRR5nU4SjnURU5$)z{ Test that when a connection is lost, calling a method on a RemoteReference obtained from it raises L{DeadReferenceError}. c>^[5nTRUR5 UU4SjnURU5 TRR 5 TR 5 U$)Nc\>TR[RTRS5 g)Nmethod) assertRaisesrDeadReferenceErrorr)ignrcr&s r(lostConnectionSNewCredTests.test_deadReferenceError..gotRootObject..lostConnections!!!""7"79K9KXVr+)rrrrrwrgr^)rcrhrur&s` r(rd;NewCredTests.test_deadReferenceError..gotRootObjectsZ#+:  & &';'D'D E W ! , ,^ <    ) ) +  - - /' 'r+rj)r&rkrds` r(test_deadReferenceError$NewCredTests.test_deadReferenceErrors= %%',,::< (**=99r+c^"SS[R5nU"5TlTR5 TRR 5nU4SjnUR U5$)z Test that if the L{reconnecting} flag is passed with a True value then a remote call made from a disconnection notification callback gets a result successfully. c\rSrSrSrSrSrg)=NewCredTests.test_clientConnectionLost..ReconnectOnceiFcUR(+nSUl[RRXX#5nU(aUR 5 U$r)reconnectedAlreadyrrrvr)r&rtru reconnectingrs r(rvRNewCredTests.test_clientConnectionLost..ReconnectOnce.clientConnectionLostsI#'#:#:: *.'++@@V %%' r+)r~N)r-r.r/r0r~rvr1r,r+r( ReconnectOncer|s !&  r+rc>TRU[R5 [5nUR UR 5 TR R5 TR5 U4SjnURU5$)Ncf>TRR5nU4SjnURU5$)Nc>TRU[R5 [5nUR UR 5 TR R5 TR5 U$r5) rrrbrrrrwrgr^)anotherRootObjr\r&s r(gotAnotherRootObjectqNewCredTests.test_clientConnectionLost..gotRootObject..disconnected..gotAnotherRootObjectsU)).":L:LM A"55ajjA&&113557Hr+)rwrr)rtr\rr&s r(rlSNewCredTests.test_clientConnectionLost..gotRootObject..disconnecteds.&&446}}%9::r+) rrrbrrrrwrgr^r)rcr\rlr&s r(rd=NewCredTests.test_clientConnectionLost..gotRootObjectsf  ! !'2+=+= > A  & &qzz 2    ) ) +  - - / ;==. .r+)rrrwrZrr)r&rrkrds` r(test_clientConnectionLost&NewCredTests.test_clientConnectionLostsY B.. +_ %%',,::< /0**=99r+cUR5 URRS5nUR[R "[ 555 UR[R"[R55 g)z| Test that if a Broker loses its connection without receiving any bytes, it doesn't raise any exceptions or log any errors. )rji90N) rZrrzr|rr}r{rmrrnrro)r& serverProtos r(test_immediateClose NewCredTests.test_immediateCloses_ %%'((667KL ""8#7#7 #CD""7??43G3G#HIr+c[R"5nUR[R"SS55nUR S[ R"[S555 URU[5$)z L{PBClientFactory.login} returns a L{Deferred} which is errbacked with the L{ConnectionRefusedError} if the underlying connection is refused. foobarNz!Test simulated refused connection) rrrDr UsernamePasswordclientConnectionFailedrrnr assertFailure)r&rw loginDeferreds r(test_loginConnectionRefused(NewCredTests.test_loginConnectionRefusedsp **, %++  ( ( 8  ,,  OO&'JK  !!-1GHHr+c@^^TRR[R"SS95 [R "SS5nSn[ 5mTRRX5nUU4SjnU4SjnURU5 URU5 U4SjnURU5 TR5 TRR5 [R"5 TRR5 TRS5 U$) z Test that login can be performed with IUsernamePassword credentials and that when the connection is dropped the avatar is logged out. passr'userr$c>TRTRRR5 TR U[ R 5 T$r5)r+rr)r rrrb)r loginCompletedr&s r(cbLogin.NewCredTests.test_loginLogout..cbLogins; OODJJ66?? @  ! !+r/A/A B! !r+cZ>TRR5 TR5 gr5)rwrgr^ignoredr&s r( cbDisconnect3NewCredTests.test_loginLogout..cbDisconnects!    ) ) +  - - /r+cd>TRTRRR5 gr5)r+rr)rrs r(cbLogout/NewCredTests.test_loginLogout..cbLogout&s OODJJ66@@ Ar+N)r registerCheckerrrr rrrwrDrrZrVrXrJrKr)r&credsrCr\rrrrs` @r(test_loginLogoutNewCredTests.test_loginLogouts ##  < <' J ,,Wg>!    $ $U 1 "  0 g l# B h %%'   %r+cB^^[5m"U4SjS[R5nUTRlTR R [R"SS95 TRR[R"SS5S5nU4SjnURU5 U4SjnURU5 TR5 TRR!5 ["R$"5 TRR!5 U$) z If a L{RemoteReference} to an L{IPerspective} avatar is decrefed and there remain no other references to the avatar on the server, the avatar is garbage collected and the logout method called. c,>\rSrSrSrSrU4SjrSrg)=NewCredTests.test_logoutAfterDecref..EventPerspectivei>z9 An avatar which fires a Deferred when it is logged out. cgr5r,r s r(rPFNewCredTests.test_logoutAfterDecref..EventPerspective.__init__Csr+c(>TRS5 gr5)r)r&rs r(rDNewCredTests.test_logoutAfterDecref..EventPerspective.logoutFs""4(r+r,N)r-r.r/r0r9rPrr1rsr(EventPerspectiver>s   ) )r+rrrrr$c>T$r5r,)avatarrs r( cbLoggedIn7NewCredTests.test_logoutAfterDecref..cbLoggedInSs  r+cf>TRTRRR05 gr5)rrr _localCleanuprs r( cbLoggedOut8NewCredTests.test_logoutAfterDecref..cbLoggedOutZs(   T//@@NNPR Sr+)rrAvatarrr(r rrrrwrDr rrrZrVrXrJrK)r&rr\rrrs` @r(test_logoutAfterDecref#NewCredTests.test_logoutAfterDecref6s J  )ryy ))9 % ##  < < H     $ $  ( ( 8)   j! T k" %%'   r+c^TRR[R"SSS95 TRR [ R"SS5S5nTRR [ R"SS5S5n[X/5nSnURU5 U4SjnURU5 TR5 TRR5 U$) z Two different correct login attempts can be made on the same root object at the same time and produce two different resulting avatars. rsquux)rbazrr$bazc`Uup[URS5URS5/5$)N getAvatarId)rr)rfirstseconds r(r5NewCredTests.test_concurrentLogin..cbLoggedIn}s4$OU !!-0&2C2CM2RS r+cV>UupTRUS5 TRUS5 g)Nrr)r)rrrr&s r( cbAvatarIds6NewCredTests.test_concurrentLogin..cbAvatarIdss*ME   UF +   VV ,r+) r rrrrwrDr rrrrZrVrX)r& firstLogin secondLoginr\rrs` r(test_concurrentLogin!NewCredTests.test_concurrentLoginls ##  < <W U ''--  ( ( 8) ((..  ( ( 99  :3 4  j! - k" %%' r+c^TRR[R"SS95 TRR [ R"SS55nTRR [ R"SS55nTRU[5 TRU[5 [X/5nU4SjnURU5 TR5 TRR5 U$)zb Test that a login attempt with an invalid user or invalid password fails in the appropriate way. rrs nosuchuserrs wrongpasscf>TR[5nTR[U5S5 g)Nr)flushLoggedErrorsr rr,ignoreerrorsr&s r(cleanup;NewCredTests.test_badUsernamePasswordLogin..cleanups(++,=>F   S[! ,r+)r rrrrwrDr rrr rrrZrVrX)r&rrr\rs` r(test_badUsernamePasswordLogin*NewCredTests.test_badUsernamePasswordLogins ##  < <' J ''--  ( ( @ ((..  ( (, ?  :'89 ;(9: :3 4 - g %%' r+ctURR[R"55 URR [ R"5S5nSnURU5 URURS5 UR5 URR5 U$)z Verify that a PB server using a portal configured with a checker which allows IAnonymous credentials can be logged into using IAnonymous credentials. r$c&URSS5$Nr{r r s r(r4NewCredTests.test_anonymousLogin..cbLoggedIn))&#6 6r+r) r rrAllowAnonymousAccessrwrDr AnonymousrrrZrVrX)r&r\rs r(test_anonymousLogin NewCredTests.test_anonymousLogins ##H$A$A$CD    $ $[%:%:%TR[5nTR[U5S5 gr)rr rr,rs r(r=NewCredTests.test_anonymousLoginNotPermitted..cleanups(++,@AF   S[! ,r+)r rrrrwrDr rrr rrZrVrX)r&r\rs` r(test_anonymousLoginNotPermitted,NewCredTests.test_anonymousLoginNotPermitteds ##  < <& I     $ $[%:%:%.cbLoginrr+r)r rrrrrwrDr rrrrZrVrXr&r\rs r('test_anonymousLoginWithMultipleCheckers4NewCredTests.test_anonymousLoginWithMultipleCheckerss ##H$A$A$CD ##  < <' J     $ $[%:%:%.cbLogins))%b9 9r+r)r rrrrrwrDr rrrrZrVrXrs r(+test_authenticatedLoginWithMultipleCheckers8NewCredTests.test_authenticatedLoginWithMultipleCheckerss ##H$A$A$CD ##  < <' J     $ $  ( (' :I  : g d&&, %%' r+cURR[R"SS95 URR [ R"SS5S5nSnURU5 SnURU5 URUR5 UR5 URR5 U$)zJ Verify that a viewpoint can be retrieved after authenticating with cred. rrrr$c$URS5$)N getViewPointr rs r(r'NewCredTests.test_view..cbLogins)).9 9r+c$URS5$)Nr$r ) viewpoints r(cbView&NewCredTests.test_view..cbViews''0 0r+) r rrrrwrDr rrr+rZrVrX)r&r\rrs r( test_viewNewCredTests.test_view s ##  < <' J     $ $  ( (' :I  : g 1 f doo& %%' r+) rLrwrtrXr rVrrMrr5)r-r.r/r0r9rrZrrnrror^rlrxrrrrrrrrrrrrr1r,r+r(rSrS?sy 2YB__T%9%9:H(6:01:fJI$/b4l#J>(,.2r+rSc&\rSrSrSrSrSrSrg)NonSubclassingPerspectivei(cgr5r,r s r(rP"NonSubclassingPerspective.__init__*rr+clURX05nURX@5nURX#U45$r5) unserialize serialize)r&rpmessager|kwargss r(perspectiveMessageReceived4NonSubclassingPerspective.perspectiveMessageReceived.s8!!$-##F1 788r+cSUlgrrr6s r(r NonSubclassingPerspective.logout4rr+rN)r-r.r/r0rPr rr1r,r+r(rr(s 9 r+rc$\rSrSrSrSrSrSrg)NSPTestsi8zs Tests for authentication against a realm where the L{IPerspective} implementation is not a subclass of L{Avatar}. c[5Ul[URl[R "UR5Ul[ R"5UlURRSS5 URRUR5 [[R"UR55Ul[R "SURSS9UlUR%UR"R&5 UR"R)5R"Ulg)Nrrrrj)r*)r"rrr(r rrrraddUserrrrrrrrrr~rrportnor6s r(rNSPTests.setUp>s[ (A %mmDJJ/ GGI  Wg. ##DLL1&r'9'9$++'FG %%aM   //0ii'').. r+c\^^[R"5mTR[R"SS5S5n[ R "STRT5 URS5 URTRSSSS 045 UU4S jnURU5 U$) zw An L{IPerspective} implementation which does not subclass L{Avatar} can expose remote methods for the client to call. rrr$rjc$URSSSS9$)NANYTHINGherer)rr )rs r(r?#NSPTests.test_NSP..Rs ZU Kr+r)rrrc>TR5 TRRHnURR 5 M gr5)rgr protocolsrbr)rrrr&s r(r"NSPTests.test_NSP..cleanupUs3    \\++ **,,r+) rrrDr rrrrrr)r&r\rrs` @r(test_NSPNSPTests.test_NSPJs $$& MM+66wH) T; W= KL d&&Y(OP - gr+)rrrr rrN)r-r.r/r0r9rrr1r,r+r(rr8s /r+rc$\rSrSrSrSrSrSrg) IForwardedi^z9 Interface used for testing L{util.LocalAsyncForwarder}. cg)z Simple synchronous method. Nr,r,r+r( forwardMeIForwarded.forwardMecr+cg)z Simple asynchronous method. Nr,r,r+r(forwardDeferredIForwarded.forwardDeferredhr#r+r,N)r-r.r/r0r9r!r%r1r,r+r(rr^s  r+rc2\rSrSrSrSrSrSrSrSr Sr g) Forwardedinz Test implementation of L{IForwarded}. @ivar forwarded: set if C{forwardMe} is called. @type forwarded: C{bool} @ivar unforwarded: set if C{dontForwardMe} is called. @type unforwarded: C{bool} FcSUlg)z& Set a local flag to test afterwards. TN) forwardedr6s r(r!Forwarded.forwardMe|s r+cSUlg)z^ Set a local flag to test afterwards. This should not be called as it's not in the interface. TN) unforwardedr6s r( dontForwardMeForwarded.dontForwardMes  r+c[S5$)z Asynchronously return C{True}. T)rr6s r(r%Forwarded.forwardDeferredst}r+)r*r-N) r-r.r/r0r9r*r-r!r.r%r1r,r+r(r(r(ns"IK  r+r(c6\rSrSrSrSrSrSrSrSr Sr g ) SpreadUtilTestsiz# Tests for L{twisted.spread.util}. c\[5nURURSS5S5 g)zS Call a synchronous method of a L{util.LocalAsRemote} object and check the result. add1rrN)rrrrs r( test_syncSpreadUtilTests.test_syncs'   fa0!4r+c[5n[5nURSSSS9nURU[5 UR UR S5 U$)zU Call an asynchronous method of a L{util.LocalAsRemote} object and check the result. rrr)rr?)rrrrrr)r&rr\s r( test_asyncSpreadUtilTests.test_asyncsQ     LLQL ' a* d&&*r+cv^[5nURS5nU4SjnURU4SjU5 U$)z7 Test an asynchronous failure on a remote method call. rcp>TRU[R5 UR[5 gr5)rrrntrapr)rr&s r(eb*SpreadUtilTests.test_asyncFail..ebs#  ! !!W__ 5 FF< r+c&>TRS5$)Nzsupposed to failr)rr&s r(r?0SpreadUtilTests.test_asyncFail..s499-?#@r+)rrr[)r&rr\r>s` r(test_asyncFailSpreadUtilTests.test_asyncFails6   LL  ! @"Er+cj[5nURS5nURU"S5S5 g)z= Test the C{remoteMethod} facility of L{util.LocalAsRemote}. r5rrN)rrr)r&rms r(test_remoteMethod!SpreadUtilTests.test_remoteMethods.   NN6 " 1q!r+c[5n[R"U[5nUR S5 UR UR 5 UR S5 URUR5 UR S5n/nURUR5 URUSS5 g)zM Test a call to L{util.LocalAsyncForwarder} using L{Forwarded} local object. r!r.r%rr^N) r(rLocalAsyncForwarderrrr+r*rr-rr@r)r&rlfrrr-s r(test_localAsyncForwarder(SpreadUtilTests.test_localAsyncForwarders K  % %a 4 k"  $ o& ' ]], -  qxx  1q!r+r,N) r-r.r/r0r9r6r9rBrFrLr1r,r+r(r3r3s 5  ""r+r3c0\rSrSrSrSrSrSrSrSr g) PBWithSecurityOptionsTestsiz Test security customization. c[R"5nURS5nURUR[ R 5 g)zT By default, client broker should use C{jelly.globalSecurity} as security settings. N)rrrzrsecurityrglobalSecurityr&rrps r(!test_clientDefaultSecurityOptions $$VX.&&t, foou';';rs "166F==CC936'+33"+BKK+ryy V]]GGG88v0,f44B  4 F2##2##  bmm *o6 , ,   !24EF(!!(",,R--!2<<!*%%68JK r~~ +'78""" 5!! 5R%%,,r,2;;  , 5 'BKK '-7 bnn +->?RWWRWWOH00OdB$6$6@4(++4nR (##R j    #  # #B$$ #i5(##i5X'g))'  g%% 2##/73@-**@-F y "++ !! d((  R__ BII  FXXB/R[[/ HH*3*x((3*lf8$$fR R__   #x  #L     ZB="h''="@)1!2!2)1r+