tf"dZddlZddlmZddlmZmZmZddlm Z m Z m Z m Z m Z ddlmZmZddlmZddlmZGd d e jZGd d e jZGd de jZGdde jZGddejZGddejZGddej Z!Gddej"Z"Gddej Z#Gddej Z$Gddej Z%Gdd e jej&Z'Gd!d"ej Z(Gd#d$ej Z)Gd%d&eZ*Gd'd(ej+Z,Gd)d*ej Z-dS)+z Test code for policies. N)StringIO) Interface implementedBy implementer)addressdeferprotocolreactortask)StringTransport StringTransportWithDisconnection)policies)unittestc2eZdZdxZZdZdZdZdZdZ dS)SimpleProtocolrcftj|_tj|_dSN)rDeferred dConnected dDisconnectedselfs Y/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/twisted/test/test_policies.py__init__zSimpleProtocol.__init__s'.**"^--rcHd|_|jddSN) connectedrcallbackrs rconnectionMadezSimpleProtocol.connectionMades%   $$$$$rcHd|_|jddSr) disconnectedrr!rreasons rconnectionLostzSimpleProtocol.connectionLost s' ##B'''''rc&|xj|z c_dSr)bufferrdatas r dataReceivedzSimpleProtocol.dataReceived$s t rN) __name__ __module__ __qualname__r r$r)rr"r'r,rrrrs_  I F...%%%(((rrceZdZdZdZdS) SillyFactoryc||_dSrp)rr5s rrzSillyFactory.__init__)s rc|jSrr4)raddrs r buildProtocolzSillyFactory.buildProtocol,s v rN)r-r.r/rr8r0rrr2r2(s2rr2c*eZdZdZdZdZdZdZdS) EchoProtocolFcd|_dSNTpausedrs rpauseProducingzEchoProtocol.pauseProducing3s  rcd|_dS)NFr=rs rresumeProducingzEchoProtocol.resumeProducing6s  rcdSrr0rs r stopProducingzEchoProtocol.stopProducing9s rc:|j|dSr) transportwriter*s rr,zEchoProtocol.dataReceived<s T"""""rN)r-r.r/r>r?rArCr,r0rrr:r:0sU F   #####rr:ceZdZdZeZdS)Serverz8 A simple server factory using L{EchoProtocol}. N)r-r.r/__doc__r:r r0rrrHrH@sHHHrrHceZdZdZdZdZdS)TestableThrottlingFactoryzH L{policies.ThrottlingFactory} using a L{task.Clock} for tests. cHtjj|g|Ri|||_dSz @param clock: object providing a callLater method that can be used for tests. @type clock: C{task.Clock} or alike. N)rThrottlingFactoryrclockrrOargskwargss rrz"TestableThrottlingFactory.__init__Ms3 "+DB4BBB6BBB rc8|j||Sz0 Forward to the testable clock. rO callLaterrperiodfuncs rrVz#TestableThrottlingFactory.callLaterVz##FD111rNr-r.r/rIrrVr0rrrKrKH<22222rrKceZdZdZdZdZdS)TestableTimeoutFactoryzE L{policies.TimeoutFactory} using a L{task.Clock} for tests. cHtjj|g|Ri|||_dSrM)rTimeoutFactoryrrOrPs rrzTestableTimeoutFactory.__init__bs3 (??????? rc8|j||SrTrUrWs rrVz TestableTimeoutFactory.callLaterkrZrNr[r0rrr^r^]r\rr^creZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdS) WrapperTestsz> Tests for L{WrappingFactory} and L{ProtocolWrapper}. ct}tj|}|t jddd}||jj|dS)zf Make sure protocol.factory is the wrapped factory, not the wrapping factory. TCP 127.0.0.1#N) rHrWrappingFactoryr8r IPv4AddressassertIswrappedProtocolfactory)rfwfr5s rtest_protocolFactoryAttributez*WrapperTests.test_protocolFactoryAttributews_ HH  %a ( (   W0 RHH I I a'/33333rcGddt}t|Gdd}ttjt j}tjtjd|}||| | |j dS)z The transport wrapper passed to the wrapped protocol's C{makeConnection} provides the same interfaces as are provided by the original transport. ceZdZdS)=WrapperTests.test_transportInterfaces..IStubTransportNr-r.r/r0rrIStubTransportrr DrrtceZdZdS).StubTransportNrsr0rr StubTransportrws DrrxN) rrrrProtocolWrapperr ProtocolrhmakeConnection assertTrue providedByrE)rrtrxprotowrappers rtest_transportInterfacesz%WrapperTests.test_transportInterfacess     Y    ^ $ $        % $  h.///!##*8+CD+I+I5QQ}}/// 11%/BBCCCCCrct}tj|}|d|dS)z L{WrappingFactory.logPrefix} is customized to mention both the original factory and the wrapping factory. zServer (WrappingFactory)N)rHrrh assertEqual logPrefix)rserverrls rtest_factoryLogPrefixz"WrapperTests.test_factoryLogPrefixsF *622 3W5F5F5H5HIIIIIrcGdd}|}tj|}|d|dS)z If the wrapped factory doesn't have a L{logPrefix} method, L{WrappingFactory.logPrefix} falls back to the factory class name. ceZdZdS)=WrapperTests.test_factoryLogPrefixFallback..NoFactoryNrsr0rr NoFactoryrrurrzNoFactory (WrappingFactory)N)rrhrr)rrrrls rtest_factoryLogPrefixFallbackz*WrapperTests.test_factoryLogPrefixFallbacksp         *622 68I8I8K8KLLLLLrct}tj|}|t jddd}|d|jdS)z{ L{ProtocolWrapper.logPrefix} is customized to mention both the original protocol and the wrapper. rerfrgzEchoProtocol (ProtocolWrapper)N)rHrrhr8rrirr)rrrlr s rtest_protocolLogPrefixz#WrapperTests.test_protocolLogPrefixsi *622(().NoProtocolNrsr0rr NoProtocolrrurrrerfrgzNoProtocol (ProtocolWrapper)N) rHr rrhr8rrirr)rrrrlr s rtest_protocolLogPrefixFallbackz+WrapperTests.test_protocolLogPrefixFallbacks         $*622(()z1WrapperTests.test_stopConsuming..s&--2E2ErTN)rrE stopConsumingr)rrrs @rtest_stopConsumingzWrapperTests.test_stopConsumings_ ""$$*E*E*E*E' $(((((rcgGfdd}tj|}t}||||gdS)z} L{policies.WrappingFactory.startedConnecting} calls C{startedConnecting} on the underlying factory. ceZdZfdZdS)4WrapperTests.test_startedConnecting..Factoryc2|dSrr)r connectorrs rstartedConnectingzFWrapperTests.test_startedConnecting..Factory.startedConnectings i(((((rN)r-r.r/rrsrFactoryrs. ) ) ) ) ) ) )rrN)rrhrrr)rrrrrs @rtest_startedConnectingz#WrapperTests.test_startedConnecting s  ) ) ) ) ) ) ) ) ) )*779955HH !!),,, )-----rcgGfdd}tj|}t}t}||||||fgdS)z L{policies.WrappingFactory.clientConnectionLost} calls C{clientConnectionLost} on the underlying factory. ceZdZfdZdS)7WrapperTests.test_clientConnectionLost..Factoryc6||fdSrrrrr&rs rclientConnectionLostzLWrapperTests.test_clientConnectionLost..Factory.clientConnectionLost#  y&122222rN)r-r.r/rrsrrr". 3 3 3 3 3 3 3rrN)rrhrrrrrrrr&rs @rtest_clientConnectionLostz&WrapperTests.test_clientConnectionLosts  3 3 3 3 3 3 3 3 3 3*779955HH $$Y777 9f"5!677777rcgGfdd}tj|}t}t}||||||fgdS)z L{policies.WrappingFactory.clientConnectionFailed} calls C{clientConnectionFailed} on the underlying factory. ceZdZfdZdS)9WrapperTests.test_clientConnectionFailed..Factoryc6||fdSrrrs rclientConnectionFailedzPWrapperTests.test_clientConnectionFailed..Factory.clientConnectionFailed4rrN)r-r.r/rrsrrr3rrrN)rrhrrrrs @rtest_clientConnectionFailedz(WrapperTests.test_clientConnectionFailed,s  3 3 3 3 3 3 3 3 3 3*779955HH &&y&999 9f"5!677777rcrtjtjtt j}t }||_||||j | | |j dS)z L{policies.ProtocolWrapper.connectionLost} sets C{wrappedProtocol} to C{None} in order to break reference cycle between wrapper and wrapped protocols. :return: N) rryrhrHr rzr r{assertIsNotNonerkloseConnectionrrs rtest_breakReferenceCyclez%WrapperTests.test_breakReferenceCycle=s*  $VXX . .0A0C0C  566 $ y))) W4555  """ '122222rN)r-r.r/rIrorrrrrrrrrrrrrrrr0rrrcrcrs#444DDD:JJJ M M MQQQ O O O   IIIIII 5 5 5 7 7 7 ) ) )... 888"888"33333rrcceZdZdZdZdS)rhc|Srr0)rrmr5s rr zWrappingFactory.protocolQsrcxtj||jddSr)rrh startFactorydeferredr!rs rrzWrappingFactory.startFactoryTs5 --d333 t$$$$$rN)r-r.r/r rr0rrrhrhPs2%%%%%rrhc*eZdZdZdZdZdZdZdS)ThrottlingTestsz2 Tests for L{policies.ThrottlingFactory}. c t}dtdD\ tj|dt }t j|_tj d|d j fd} fd} fd } fd } fd } fd }|j ||j ||j ||j ||j ||j ||jS) z Full test using a custom server limiting number of connections. FIXME: https://twistedmatrix.com/trac/ticket/10012 This is a flaky test. c32K|]}tVdSr)r).0is r z-ThrottlingTests.test_limit..fs(==q.**======rrrf) interfacectjdtjfdjfdjS)NrfcJtjdtSNrfr connectTCPr2)rc2ns rrzAThrottlingTests.test_limit.._connect123..r',[!\"=M=MNNrcJtjdtSrr)rc3rs rrzAThrottlingTests.test_limit.._connect123..urr)r rr2r addCallbackr)resultsc1rrrs r _connect123z/ThrottlingTests.test_limit.._connect123os  {A|B/?/? @ @ @ M % %NNNNN    M % %NNNNN   # #rcdfDgddfDgdtjd|S)Ncg|] }|j Sr0)r rcs r zAThrottlingTests.test_limit.._check123..zs@@@aak@@@r)rrrcg|] }|j Sr0)r$rs rrzAThrottlingTests.test_limit.._check123..{sCCCanCCCr)rrrr)rlen protocolskeys)rrrrrtServers r _check123z-ThrottlingTests.test_limit.._check123ys   @@BB<@@@))) L L L   CCr2rlCCCYYY O O O   S!2!7!7!9!9::A > > >NrcDjjSr)rErr)rrs r_lose1z*ThrottlingTests.test_limit.._lose1s L ' ' ) ) )# #rcXtjdtjSr)r rr2r)rc4rs r _connect4z-ThrottlingTests.test_limit.._connect4s(  {A|B/?/? @ @ @= rctjdjd|S)Nrr)rr r$)rrrs r_check4z+ThrottlingTests.test_limit.._check4s8   R\1 - - -   R_a 0 0 0NrcfD]}|jtjtjjjjgSr)rErr DeferredList maybeDeferred stopListeningr)rrrrr5s r_cleanupz,ThrottlingTests.test_limit.._cleanupscV - - **,,,,%'88$$ r) rHrangerrNrhrrrr listenTCPrportr)rr wrapTServerrrrrrrrrrrrr5rs` @@@@@@@r test_limitzThrottlingTests.test_limit^s==E!HH===BB,VQ77%g.. $~//   a D D D IIKK  $ $ $ $ $ $ $ $           $ $ $ $ $  ! ! ! ! ! !              ((555((333((000((333((111((222##rct}ttj|}|t jddd}t}||_|j ||j dgdz| | d| |j ddS) zZ L{ThrottlingProtocol.writeSequence} is called on the underlying factory. rerfrbytesrsbytesbytesbytesbytesN)rHrKr Clockr8rrir r r{ writeSequencervaluewrittenThisSecond)rrrr rEs rtest_writeSequencez"ThrottlingTests.test_writeSequences+DJLL&AA(()rOadvancer|rrrrtrs rtest_writeLimitzThrottlingTests.test_writeLimits +DJLL&RPPP$$W%8 Q%O%OPP - / /  B,  -((( -((( %<=== 2B777 -4555  d### 2A666 ,3444 d### 2A666 -455555rcjt}ttj|d}|t jddd}t}||_| || d| d| | d| |j d |jd | |j d| |jd |jd | |j d| |jd || d| d| | d| |j d |jd | |j d| |jd |jd | |j d| |jd d S)zb Check the readLimit parameter: read data and check for the pause status. r) readLimitrerfrrrrr rr> producingN)rHrKr r r8rrir r r{r,rr readThisSecondrOr producerStateclearrs rtest_readLimitzThrottlingTests.test_readLimitsb +DJLL&BOOO$$W%8 Q%O%OPP - / /  B -((( -((( %<=== /444 d### /333 )8444 d### /333 );777   -((( -((( %<=== /444 d### /333 )8444 d### /333 );77777rN)r-r.r/rIrrrr!r0rrrrYs^@$@$@$D 8 8 8666<%8%8%8%8%8rrc0eZdZdZdZdZdZdZdZdS)TimeoutProtocolTestsz0 Tests for L{policies.TimeoutProtocol}. c6tj}tj}t|_t ||d}|tjddd}t}||_| |||fS)z Helper to set up an already connected protocol to be tested. @return: A new protocol with its attached clock. @rtype: Tuple of (L{policies.TimeoutProtocol}, L{task.Clock}) Nrerf90) r r r ServerFactoryrr^r8rrir r{)rrOwrappedFactoryrlr~rEs rgetProtocolAndClockz(TimeoutProtocolTests.getProtocolAndClocks !/11"0(EE%%g&9%e&T&TUU466 "  Y'''u~rc|\}}|d||j||jj|d|| |j|d||jjdS)z2 Will cancel the ongoing timeout. rN) r( setTimeoutr timeoutCallrrkr$r cancelTimeoutrrsutrOs rtest_cancelTimeoutz'TimeoutProtocolTests.test_cancelTimeouts--// U q S_--- ,9::: a  #/***  a ,9:::::rc|\}}||j|||jjdS)z< Does nothing if no timeout is already set. N)r(rr,r-rrkr$r.s rtest_cancelTimeoutNoTimeoutz0TimeoutProtocolTests.test_cancelTimeoutNoTimeout#sc--// U #/***  ,9:::::rc|\}}|j}|d|d||j|dS)z@ Does nothing if no timeout is already reached. r*N)r(rkr+rr|r$r-)rr/rO wrappedProtos rtest_cancelTimeoutAlreadyCalledz4TimeoutProtocolTests.test_cancelTimeoutAlreadyCalled/st--// U*  q a  1222 rc|\}}|d|j|||jjdS)zm Does nothing if the timeout is cancelled from another part. Ex from another thread. r*N)r(r+r,cancelr-rrkr$r.s r"test_cancelTimeoutAlreadyCancelledz7TimeoutProtocolTests.test_cancelTimeoutAlreadyCancelled=ss --// U q      ,9:::::rN) r-r.r/rIr(r0r2r5r8r0rrr#r#si,;;;& ; ; ;    ; ; ; ; ;rr#c*eZdZdZdZdZdZdZdS)TimeoutFactoryTestsz/ Tests for L{policies.TimeoutFactory}. ctj|_tj}t |_t |j|d|_|jtj ddd|_ t|_ |j |j _|j |j |j j|_dS)zq Create a testable, deterministic clock, and a set of server factory/protocol/transport. r*rerfr%N)r r rOr r&rr^rlr8rrir~r rEr{rkr4)rr's rsetUpzTimeoutFactoryTests.setUpRs Z\\ !/11"0-dj.!LL \//  {E : :   :;;"&* !!$.111 J6rc|jgd||jj|jddg||jjdS)z Make sure that when a TimeoutFactory accepts a connection, it will time out that connection if no data is read or written within the timeout period. )??r@g?r>皙?N)rOpumprr4r$r|rs r test_timeoutz TimeoutFactoryTests.test_timeoutcsq 111222 *7888 c ### )677777rcN|jgd||jj|jd|jgd||jj|jdgdz|jgd||jj|jddg||jjdS) z Make sure that writing data to a transport from a protocol constructed by a TimeoutFactory resets the timeout countdown. )r>r?r@bytes bytes bytesr>r@r@rr*r>g@N) rOrBrr4r$r~rFr r|rs rtest_sendAvoidsTimeoutz*TimeoutFactoryTests.test_sendAvoidsTimeoutqs  ((( *7888 -... ((( *7888   (a000 ((( *7888 c ### )677777rc|jgd||jj|jd|jgd||jj|jgd||jjdS)zR Make sure that receiving data also resets the timeout countdown. )r>r@r?rErFN)rOrBrr4r$r~r,r|rs rtest_receiveAvoidsTimeoutz-TimeoutFactoryTests.test_receiveAvoidsTimeouts ((( *7888  4555 ((( *7888 ((( )677777rN)r-r.r/rIr<rCrGrIr0rrr:r:MsZ777" 8 8 8888888888rr:c@eZdZdZdZdZdZdZdZd dZ d Z d Z dS) TimeoutTesterz A testable protocol with timeout facility. @ivar timedOut: set to C{True} if a timeout has been detected. @type timedOut: C{bool} r*Fc||_dS)zF Initialize the protocol with a C{task.Clock} object. N)rO)rrOs rrzTimeoutTester.__init__s rc:||jdS)z3 Upon connection, set the timeout. N)r+timeOutrs rr"zTimeoutTester.connectionMades  %%%%%rcn|tj||dS)z, Reset the timeout on data. N) resetTimeoutr rzr,r*s rr,zTimeoutTester.dataReceiveds5 &&tT22222rNc0|ddS)zD On connection lost, cancel all timeout operations. N)r+r%s rr'zTimeoutTester.connectionLosts rcd|_dS)zX Flags the timedOut variable to indicate the timeout of the connection. TN)timedOutrs rtimeoutConnectionzTimeoutTester.timeoutConnections rc0|jj||g|Ri|S)zD Override callLater to use the deterministic clock. rU)rtimeoutrYrQrRs rrVzTimeoutTester.callLaters+$tz#GTCDCCCFCCCrr) r-r.r/rIrNrSrr"r,r'rTrVr0rrrKrKsGH &&& 333  DDDDDrrKcBeZdZdZdZdZdZdZdZdZ dZ d Z d S) TimeoutMixinTestsz- Tests for L{policies.TimeoutMixin}. chtj|_t|j|_dS)zY Create a testable, deterministic clock and a C{TimeoutTester} instance. N)r r rOrKr~rs rr<zTimeoutMixinTests.setUps&Z\\ "4:.. rc|jd|t|jjddS)z Test that the callLater of the clock is used instead of L{reactor.callLater} rrN)r~r+rrrOcallsrs rtest_overriddenCallLaterz*TimeoutMixinTests.test_overriddenCallLatersC b!!! TZ-..22222rc>|jt|jgd||jj|jddg||jjdS)zq Check that the protocol does timeout at the time specified by its C{timeOut} attribute. rr?r@r@rr@N)r~r{r rOrBrrSr|rs rrCzTimeoutMixinTests.test_timeouts !!/"3"3444 ***+++ ,--- C!!!  +,,,,,rc|jt|jgd||jj|jd|jgd||jj|jddg||jjdS)zV Check that receiving data is delaying the timeout of the connection. r^s hello there)rr@r@r?rr@N) r~r{r rOrBrrSr,r|rs rtest_noTimeoutz TimeoutMixinTests.test_noTimeouts !!/"3"3444 ***+++ ,--- /// ***+++ ,--- C!!!  +,,,,,rcd|j_|jt|jd||jjd|jddg||jj |jddg| |jj dS)zy Check that setting a new value for timeout cancel the previous value and install a new timeout. Nrrg?rA) r~rNr{r r+rrOrBrrSr|rs rtest_resetTimeoutz#TimeoutMixinTests.test_resetTimeouts "  !!/"3"3444 a    +Q/// C!!! ,--- C!!!  +,,,,,rcRd|j_|jt|jd||jj|jgd||jj dS)zO Setting the timeout to L{None} cancel any timeout operations. N)rrdrdrd) r~rNr{r r+rrOrBrrSrs rr0z$TimeoutMixinTests.test_cancelTimeouts  !!/"3"3444 d### $*,---  %%% ,-----rcd|j_||jdd||jdd||jd||jjd|jddS)zM setTimeout should return the value of the previous timeout. rdrNr)r~rNrr+rrs rtest_setTimeoutReturnz'TimeoutMixinTests.test_setTimeoutReturns  ..r22A666 ..t44b999 $*//22333 +Q/// d#####rcL|jd|jd||jj|jd||jjdS)z When the timeout was already cancelled from an external place, calling setTimeout with C{None} to explicitly cancel it will clean up the timeout without raising any exception. r*rN)r~r+rOgetDelayedCallsr7rrNrrs r%test_setTimeoutCancleAlreadyCancelledz7TimeoutMixinTests.test_setTimeoutCancleAlreadyCancelled-s a    ""$$Q'..000 TZ/000 d### $*,-----rN) r-r.r/rIr<r\rCr`rbr0rfrir0rrrXrXs///333 - - - - - ---- . . . $ $ $.....rrXceZdZdZdZdZdS)!LimitTotalConnectionsFactoryTestsz/Tests for policies.LimitTotalConnectionsFactoryctj}tj|_|d|j|d}|d|j|d}|d|j|d|d|j|d|d|jdS)Nrrr)rLimitTotalConnectionsFactoryr rzrconnectionCountr8r')rrlp1p2s rtestConnectionCountingz8LimitTotalConnectionsFactoryTests.testConnectionCountingAs799#, G3444 " "4 ( ( G3444  " "4 ( ( G3444 $ G3444 $ G344444rc<tjtj_d_d}|||dj| d|djGfddtj}|_ d_ d}| d| j |dj|d|dj|d|djdS)NrceZdZfdZdS)RLimitTotalConnectionsFactoryTests.testConnectionLimiting..OverflowProtocolcd_dSr<) overflowed)rrls rr"zaLimitTotalConnectionsFactoryTests.testConnectionLimiting..OverflowProtocol.connectionMadegs%)"""rN)r-r.r/r")rlsrOverflowProtocolrtfs. * * * * * * *rrwFrr)rrmr rzconnectionLimitr8rrrnroverflowProtocolrvr{r|r')rr5rwoprls @rtestConnectionLimitingz8LimitTotalConnectionsFactoryTests.testConnectionLimitingUs799#,"#  ! !$ ' ' Q G3444 '//55666 G3444 * * * * * * *x0 * * *$4 "  " "4 ( ( $ *+++ G3444  G3444 $ G344444rN)r-r.r/rIrqr{r0rrrkrk>s899555($5$5$5$5$5rrkceZdZdZdS)WriteSequenceEchoProtocolc|ddkr|j|gdSt||dS)Nsvector!)findrEr r:r,)rbytess rr,z&WriteSequenceEchoProtocol.dataReceived}sS ::j ! !R ' ' N ( (% 1 1 1 1 1  % %dE 2 2 2 2 2rN)r-r.r/r,r0rrr}r}|s#33333rr}ceZdZdZdZdS)TestLoggingFactoryNcX|j Jdt|_|jS)Nzopen() called too many times)openFiler)rnames ropenzTestLoggingFactory.opens,}$$&D$$$  }r)r-r.r/rrr0rrrrs(Hrrc$eZdZdZdZdZdZdS)LoggingFactoryTestsz6 Tests for L{policies.TrafficLoggingFactory}. ct}t|_t}t |d}|d}||_|||j}| d|| | | d|j}| d d|| d d||| d|| d|j}| d dg||| d||j}| d |d S) zQ Check the output produced by L{policies.TrafficLoggingFactory}. test1.2.3.4i.*shere are some bytesz C 1: {!r}z S 1: {!r}s"prepare for vector! to the extremez SV 1: {!r}ConnectionDoneN)rHr}r r rr8r{rgetvalueassertInrr r,formatrr r)rr'trmr5vs rtest_thingsGetLoggedz(LoggingFactoryTests.test_thingsGetLoggeds "; , . . ~v 6 6 OO- . .   J   ! ! c1 ### -... J   ! ! k(()?@@!DDD k(()?@@!DDD $:;;;   <=== J   ! ! l))+P*QRRTUVVV $IJJJ  J   ! ! &*****rct}t|d}||jd|d||jdd|_|d||jd|||jddS)zG Test counter management with the resetCounter method. rrrrN)ri/r)rHrr_counterr8r resetCounter)rr'rms r test_counterz LoggingFactoryTests.test_counters  ~v 6 6 Q''' )*** Q'''  )*** Q'''  Q'''''rc gg  fd}|td|tj}t|_t j|d}|tj ddd}|tj ddd}dif}d if}| ||g| |j |j g d S) z When the L{policies.TrafficLoggingFactory} builds a protocol, it automatically opens a unique log file for that protocol and attaches the logfile to the built protocol. c||ft}|d|_||S)zX Mock for the open call to prevent actually opening a log file. r)rrr)rQrRio open_calls open_rvaluess r mocked_openzULoggingFactoryTests.test_loggingFactoryOpensLogfileAutomatically..mocked_opensJ   tVn - - -B1gBG    # # #Irrrrerfr%i:0)ztest-1w)ztest-2rN) patchbuiltinsr r&rrTrafficLoggingFactoryr8rrirlogfile) rrr'rl first_proto second_proto first_call second_callrrs @@r,test_loggingFactoryOpensLogfileAutomaticallyz@LoggingFactoryTests.test_loggingFactoryOpensLogfileAutomaticallys          8V[111!/11"00HH++  {E : :  ,,  {E : :  &r* &+  *k2J??? +-|/CDlSSSSSrN)r-r.r/rIrrrr0rrrrsQ + + +D((("$T$T$T$T$Trr).rIrrrzope.interfacerrrtwisted.internetrrr r r twisted.internet.testingr r twisted.protocolsr twisted.trialrrzr ClientFactoryr2r:r&rHrNrKr`r^TestCasercrhrr#r: TimeoutMixinrKrXrkr}rrrr0rrrs @@@@@@@@@@DDDDDDDDDDDDDDVVVVVVVV&&&&&&""""""X&(8) # # # # #8$ # # # X #22222 :222*22222X4222*[3[3[3[3[38$[3[3[3|%%%%%h.%%%Y8Y8Y8Y8Y8h'Y8Y8Y8xU;U;U;U;U;8,U;U;U;pR8R8R8R8R8(+R8R8R8j.D.D.D.D.DH%x'<.D.D.Dbh.h.h.h.h.)h.h.h.V;5;5;5;5;5(9;5;5;5|33333 3337\T\T\T\T\T(+\T\T\T\T\Tr