hsFSrSSKrSSKrSSKrSSKJr SSKJr SSKJ r SSK J r SSK r SSK JrJrJrJrJr SSKJr SS KJrJr SS KJr SS KJr SS KJrJr SS KJ r SSK!J"r"J#r# S`Sjr$"SS\RJ5r&"SS\RN5r("SS5r)"SS\)\RN5r*"SS\)\RV5r,"SS\#5r-"SS\#5r."SS\R^5r0"S S!\,5r1"S"S#\#5r2"S$S%\#5r3"S&S'\#5r4"S(S)\RJ5r5"S*S+\RJ5r6"S,S-\RV5r7"S.S/\#5r8"S0S1\RJ5r9"S2S3\RJ5r:"S4S5\RJ5r;"S6S7\;5r<"S8S95r="S:S;\#\=5r>"S<S=\R~5r@"S>S?\R5rB"S@SA\#5rC"SBSC\RJ5rD"SDSE\RJ5rE"SFSG\RV5rF"SHSI\R~5rG"SJSK\R5rH"SLSM\#5rI\ "\5"SNSO\55rJ"SPSQ\RN5rK"SRSS\#5rL"STSU\#5rM"SVSW\#5rN"SXSY\#5rO"SZS[\#5rP"S\S]\#5rQSSKRrR\RR"\RR5SS^-rU\V"\>S_\U5 g!\Wa gf=f)az. Tests for implementations of L{IReactorTCP}. Nwraps)Optional)skipIf) implementer)defererror interfacesprotocolreactor) IPv4Address)IHalfCloseableProtocol IPullProducer)AccumulatingProtocol)policies)errmsg)platform)SkipTestTestCasec^^^SSKJn [R"5mUU4SjnUR U5mU4SjnTR U5 TR U5nURTR5 T$)z Poor excuse for an event notification helper. This polls a condition and calls back a Deferred when it is seen to be true. Do not use this function. r)taskcF>T"5nU(aTRU5 ggNcallback)resd predicates \/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/test/test_tcp.pycheckloopUntil..check)sk  JJsO c(>TR5 U$r)stop)resultcalls r r%loopUntil..stop0s  r#) twisted.internetrrDeferred LoopingCall addCallbackstart addErrbackerrback)rintervalrr!r%d2r'rs` @@r loopUntilr2sa& A   E "DMM$ H BMM!)) Hr#c \rSrSrSrSrSrg)ClosingProtocol:cN[S5 URR5 g)NzClosingProtocol.connectionMader transportloseConnectionselfs r connectionMadeClosingProtocol.connectionMade;s ,- %%'r#cX[S5 UR[R5 g)NzClosingProtocol.connectionLost)rtrapr ConnectionDoner;reasons r connectionLostClosingProtocol.connectionLost?s ,- E(()r#N__name__ __module__ __qualname____firstlineno__r<rC__static_attributes__rEr#r r4r4:s (*r#r4cR\rSrSr%SrSrSr\\R\ S'Sr Sr Sr g)ClosingFactoryDz' Factory that closes port immediately. NportcTURR5Ul[5$r)rO stopListening _cleanerUpperr4)r;conns r buildProtocolClosingFactory.buildProtocolLs !YY446  r#cURc-UR(deURR5$UR$)z< Clean-up for tests to wait for the port to stop listening. )rRrOrQr:s r cleanUpClosingFactory.cleanUpPs=    %99 999**, ,!!!r#)rR)rGrHrIrJ__doc__rRrOrr IListeningPort__annotations__rTrWrKrEr#r rMrMDs-M04D(:,, -4! "r#rMc\rSrSr%Sr\rSr\\ R\\ S'Sr \\ R\\ S'Sr \\\ S'SrSrS rS rg) MyProtocolFactoryMixin\a Mixin for factories which create L{AccumulatingProtocol} instances. @type protocolFactory: no-argument callable @ivar protocolFactory: Factory for protocols - takes the place of the typical C{protocol} attribute of factories (but that name is used by this class for something else). @type protocolConnectionMade: L{None} or L{defer.Deferred} @ivar protocolConnectionMade: When an instance of L{AccumulatingProtocol} is connected, if this is not L{None}, the L{Deferred} will be called back with the protocol instance and the attribute set to L{None}. @type protocolConnectionLost: L{None} or L{defer.Deferred} @ivar protocolConnectionLost: When an instance of L{AccumulatingProtocol} is created, this will be set as its C{closedDeferred} attribute and then this attribute will be set to L{None} so the L{defer.Deferred} is not used by more than one protocol. @ivar protocol: The most recently created L{AccumulatingProtocol} instance which was returned from C{buildProtocol}. @type called: C{int} @ivar called: A counter which is incremented each time C{buildProtocol} is called. @ivar peerAddresses: A C{list} of the addresses passed to C{buildProtocol}. NprotocolConnectionMadeprotocolConnectionLost lastProtocolrc/Ulgr) peerAddressesr:s r __init__MyProtocolFactoryMixin.__init__s r#cURRU5 U=RS- slUR5nXlUR UlSUlX lU$)zQ Create a L{AccumulatingProtocol} and set it up to be able to perform callbacks. N)rcappendcalledprotocolFactoryfactoryr`closedDeferredrar;addrps r rT$MyProtocolFactoryMixin.buildProtocolsZ !!$' q  " 66&*#r#)rarcr`)rGrHrIrJrYrrjr_rrr*r[r`rarirdrTrKrEr#r r]r]\sa:+OMQHU^^4H%IJQMQHU^^4H%IJQ37L(/07 F  r#r]c\rSrSrSrSrg)MyServerFactoryzA Server factory which creates L{AccumulatingProtocol} instances. rEN)rGrHrIrJrYrKrEr#r rrrrsr#rrc\rSrSr%SrSrSr\RS\ S'\RS\ S'Sr Sr S r S r S rg) MyClientFactoryzA Client factory which creates L{AccumulatingProtocol} instances. rNdeferred failDeferredc[RU5 [R"5Ul[R"5Ulgr)r]rdrr*rwrxr:s r rdMyClientFactory.__init__s-''-( !NN,r#cTSUlX lURRS5 gNrg)failedrBrxrr; connectorrBs r clientConnectionFailed&MyClientFactory.clientConnectionFaileds"   ""4(r#cFX lURRS5 gr) lostReasonrwrr~s r clientConnectionLost$MyClientFactory.clientConnectionLosts  t$r#cSUlgr|stoppedr:s r stopFactoryMyClientFactory.stopFactorys  r#)rwrxr}rrBr)rGrHrIrJrYr}rrr*r[rdrrrrKrEr#r rurusEFGnnT""..&&- ) %r#rucP\rSrSrSrSrSrSrSrSr Sr S r S r S r S rg )ListeningTestsc[5n[R"SUSS9nURUR5 UR [ RRU55 g)zN L{IReactorTCP.listenTCP} returns an object which provides L{IListeningPort}. r 127.0.0.1 interfaceN) rrr listenTCP addCleanuprQ assertTruer rZ providedByr;fp1s r test_listenListeningTests.test_listensO     q!{ ; (()  11<[R"TTSS9nUR5$)Nrr)r rrQ)ignoredrOrns r cbStopListening9ListeningTests.testStopListening..cbStopListenings&$$Q[AD%%' 'r#) rrr rgetHostrOr maybeDeferredrQr,)r;rOrrrrs @@r testStopListening ListeningTests.testStopListenings`    A= LLN   (    2 2 3 o&r#cb[5n[R"SUSS9nUR5$Nrrr)rrr rrQrs r testNumberedInterface$ListeningTests.testNumberedInterfaces-     q!{ ;!!r#cZ^^^[5n[R"SU5m[TR 5R 5mTR [T5RT5S:H5 UUU4Sjn[R"TR5nURU5$)Nrc^>TR[T5RT5S:g5 g)Nr) assertFalsereprfind)ignroportNor;s r stoppedListening5ListeningTests.testPortRepr..stoppedListenings#   T!W\\&1R7 8r#) rrr rstrrrOrrrrrrQr,)r;rrrrors` @@r testPortReprListeningTests.testPortReprs~     a #QYY[%%& af-34 9    0}}-..r#c^^[5n[R"5=o!l[R "SU5mTR TR5 [5n[R"5=oCl[R"STR5RU5nTR UR5 UU4Sjn[R"X$/5RU5$)zi Check that the repr string of the server transport get the good port number if the server listens on 0. rrc>UupTR5RnTR[UR5SUS35 URR 5 URR 5 g)Nz)rrO assertEqualrr8r9)r& serverProto clientProto portNumberrOr;s r r!-ListeningTests.test_serverRepr..checksj'- $K,,J   [**+.zl!<   ! ! 0 0 2  ! ! 0 0 2r#)rrrr*r_r rrrQru connectTCPrrO disconnect gatherResultsr,)r;serverserverConnMadeclientclientConnMaderr!rOs` @r test_serverReprListeningTests.test_serverReprs !"9>9II6  F+ **+ "9>9II6&&{DLLN4G4GP   ,,- 3""N#CDPPQVWWr#c^^^^[5m[R"STSS9mTRTR5 UUUU4SjnSm[ R "TR5nURU5 U$)zv Stop and then try to restart a L{tcp.Port}: after a restart, the server should be able to handle client connections. rrrc>TR5 [5n[R"5Tl[R"5Ul[ R "STR5RU5nTRUR5 [R"TRUR/5RT5$Nr) startListeningrurr*r_r rrrOrrrr,rrrcloserOr; serverFactorys r r=ListeningTests.test_restartListening..cbStopListening s    !$&F38>>3CM 0,1NN,.close.'- $K  ! ! 0 0 2  ! ! 0 0 2r#)rrr rrrQrrr,)r;rrrrOrs` @@@r test_restartListening$ListeningTests.test_restartListeningsk ()   M[I **+ ! ! 3    2 2 3 o&r#c[5nSnX!l[R"SUSS9nUR UR 5[ 5$)z If the server factory raises an exception in C{stopFactory}, the deferred returned by L{tcp.Port.stopListening} should fail with the corresponding error. c[S5eNzAn error RuntimeErrorrEr#r raiseException8ListeningTests.test_exceptInStop..raiseException' z* *r#rrr)rrrr r assertFailurerQrr;rrrOs r test_exceptInStop ListeningTests.test_exceptInStopsI ()  +%3!  M[I!!$"4"4"6 EEr#c^^^^[5mSnUTl[R"STSS9mTR TR 5 UUUU4SjnSmTR TR 5[5RU5$)z Even if the server factory raise an exception in C{stopFactory}, the corresponding C{tcp.Port} instance should be in a sane state and can be restarted. c[S5errrEr#r r>ListeningTests.test_restartAfterExcept..raiseException7rr#rrrc>T?TR5 [5n[R"5Tl[R"5Ul[ R"STR5RU5nTRUR5 [R"TR UR /5RT5$r)rrrurr*r_r rrrOrrrr,rs r r?ListeningTests.test_restartAfterExcept..cbStopListening>s)    !$&F38>>3CM 0,1NN,.closeKrr#) rrrr rrrQrrr,)r;rrrrOrs` @@@r test_restartAfterExcept&ListeningTests.test_restartAfterExcept/s ()  +%3 !  M[I **+ ! ! 3 !!$"4"4"6 EQQ   r#c^[5n[R"SUSS9nUR5RnUR S5 [ 5m[R"5Ul [R"5Tl [R"SUT5 U4SjnTRRU5$)z If C{connectionLost} is called directly on a port object, it succeeds (and doesn't expect the presence of a C{deferred} attribute). C{connectionLost} is called by L{reactor.disconnectAll} at shutdown. rrrNcX>TRR[R5 grrBr?r ConnectionRefusedError)rrs r r!;ListeningTests.test_directConnectionLostCall..checkes MM  u;; .raiseExceptiontrr#rrrN)rrrr r assertRaisesrrCrs r test_exceptInConnectionLostCall.ListeningTests.test_exceptInConnectionLostCalljsE()  +%3!  M[I ,(;(;TBr#rEN)rGrHrIrJrrrrrrrrrrrKrEr#r rrs9B(" /X6<F # J6,Cr#rcN\rSrSrSrSrSrSrSrSr Sr S r S r S r S rg ) LoopbackTestsi|z Test loopback connections. cJ^^^[5n[R"SUSS9mTUlTR UR 5 TR 5Rn[5m[R"SUT5 UUU4SjnTRRU5$)zb A port created with L{IReactorTCP.listenTCP} can be connected to with L{IReactorTCP.connectTCP}. rrrc>TRTRR5 TRTR5 TRR [ R5 gr)rramade disconnectedrr?r r@)xclientFrOr;s r r!.checksG OOG0055 6 OOD-- .    # #E$8$8 9r#) rMr rrOrrWrrurrwr,)r;rrr!rrOs` @@r test_closePortInProtocolFactory-LoopbackTests.test_closePortInProtocolFactorys    A=  "\\^(( !#; G< : ++E22r#cH[USS5"[R5 g)Nr?cgrrE)rs r ,LoopbackTests._trapCnxDone..str#)getattrr r@)r;objs r _trapCnxDoneLoopbackTests._trapCnxDonesV^,U-A-ABr#c^[5n[R"5nX2l[R "SUSS9nUR UR5 UR5Rn[5n[R"5nXvl[R"SXV5 [R"X7/5nU4Sjn URU 5 U$)zq Invoke the given callback with a client protocol and a server protocol which have been connected to each other. rrrc>UupT"X5 URR5 URR5 grr)r&serverProtocolclientProtocolrs r connected>LoopbackTests._connectedClientAndServerTest..connecteds7-3 *N ^ 4  $ $ 3 3 5  $ $ 3 3 5r#)rrrr*r_r rrrQrrOrurrr,) r;rrrrOrrr connsMaders ` r _connectedClientAndServerTest+LoopbackTests._connectedClientAndServerTests () )/=,  M[I **+\\^(( !#))7&; <''(HI  6 i(r#c2^U4SjnTRU5$)z The transport of a protocol connected with L{IReactorTCP.connectTCP} or L{IReactor.TCP.listenTCP} can have its I{TCP_NODELAY} state inspected and manipulated with L{ITCPTransport.getTcpNoDelay} and L{ITCPTransport.setTcpNoDelay}. c6>X4HnURnTRUR5S5 URS5 TRUR5S5 URS5 TRUR5S5 M gNrrg)r8r getTcpNoDelay setTcpNoDelayr rror8r;s r r!,LoopbackTests.test_tcpNoDelay..checks$5KK   !8!8!:A>''*  !8!8!:A>''*  !8!8!:A> 6r#rr;r!s` r test_tcpNoDelayLoopbackTests.test_tcpNoDelays ?11%88r#c2^U4SjnTRU5$)z The transport of a protocol connected with L{IReactorTCP.connectTCP} or L{IReactor.TCP.listenTCP} can have its I{SO_KEEPALIVE} state inspected and manipulated with L{ITCPTransport.getTcpKeepAlive} and L{ITCPTransport.setTcpKeepAlive}. c6>X4HnURnTRUR5S5 URS5 TRUR5S5 URS5 TRUR5S5 M gr)r8rgetTcpKeepAlivesetTcpKeepAlivers r r!.LoopbackTests.test_tcpKeepAlive..checks$5KK   !:!:!TRR[R5 grr)rrs r r!(LoopbackTests.testFailing..checks NN   < < =r#)rur rrxr,)r;r!rs @r testFailingLoopbackTests.testFailings=!#;GQ? >##//66r#c^^^^/m[S5HKn[R"5nURS5 URS5 TR U5 MM [ R "T5 [R"[[R5mUUUU4SjmT"5nTRU[R5 U4SjnURU5 U4SjnURU5 U$)zv Assert that the error number of the ConnectionRefusedError is ECONNREFUSED, and not some other socket related error. rrrgc>UUU4SjnTR5nUR5up#UR5 TRX#5nUR U5 U$)Ncx>URR5 T(aT"5$TRS5 g)z< Darn. Kill it and try again, if there are any tries left. z?Could not fail to connect - could not test errno for that case.N)r8r9fail)protor; serverSocketstryConnectFailures r r]LoopbackTests.test_connectionRefusedErrorNumber..tryConnectFailure..connecteds0..0 ,.. Ur#)pop getsocknamerrr,) r serverSocket serverHost serverPortconnectDeferred clientCreatorr;r5r6s r r6JLoopbackTests.test_connectionRefusedErrorNumber..tryConnectFailuresY ),,.L%1%=%=%? "J    +66zNO  ' ' 2" "r#cZ>TRUR[R5 gr)rosErrorerrno ECONNREFUSED)excr;s r connRefusedDLoopbackTests.test_connectionRefusedErrorNumber..connRefuseds   S[[%*<*< =r#cd>T(a'TR5R5 T(aM'U$r)r8r) passthroughr5s r cleanup@LoopbackTests.test_connectionRefusedErrorNumber..cleanup#s(!!#))+ - r#)rangesocketbindlistenrhrandomshuffler ClientCreatorr Protocolrr rr,addBoth) r;ir:refusedDeferredrErIr>r5r6s ` @@@r !test_connectionRefusedErrorNumber/LoopbackTests.test_connectionRefusedErrorNumbers2 rA!==?L   . /    "   .  }% ..w8I8IJ  # #(,- ?E,H,HI > ##K0  (r#cvUR[R[RSS[ 55 g)z] Connecting to a named service which does not exist raises L{error.ServiceNameUnknownError}. rthisbetternotexistN)rr ServiceNameUnknownErrorr rrur:s r test_connectByServiceFail'LoopbackTests.test_connectByServiceFail+s0   ) )        r#c^^^ [5m [R"5nUT l[R "ST SS9nTR UR5 UR5Rm[5n[R"5nXClU4SjnTR[SU5 [R"SSU5 [R"X/5nUU 4SjnURU5 U$)z L{IReactorTCP.connectTCP} accepts the name of a service instead of a port number and connects to the port number associated with that service, as defined by L{socket.getservbyname}. rrrc">US:XaUS:XaT$g)Nhttptcpr/rE) serviceName protocolNamers r fakeGetServicePortByNameELoopbackTests.test_connectByService..fakeGetServicePortByNameHsf$)>!!r# getservbynamer_c>UupTRTRS5 URR5 URR5 g)Nz7Server factory was not called upon to build a protocol.)rrir8r9)r&r rr;rs r r6LoopbackTests.test_connectByService..connectedSsI-3 *N OO$$I   $ $ 3 3 5  $ $ 3 3 5r#)rrrr*r_r rrrQrrOrupatchrLrrr,) r;rrO clientFactoryrrcconnMaderrrs ` @@r test_connectByService#LoopbackTests.test_connectByService8s () )/= ,  M[I **+\\^(( ') )/=,  6?,DE; >&&'GH 6 Y'r#rEN)rGrHrIrJrYrr rrr$r,rVr[rkrKrEr#r rr|s73(C89&9&7EN  %r#rc(\rSrSrSrSrSrSrSrg)StartStopFactoryi`rcbUR(dUR(a[eSUlgr|startedrrr:s r startFactoryStartStopFactory.startFactoryd <<4<<  r#cbUR(aUR(a[eSUlgr|rpr:s r rStartStopFactory.stopFactoryis||t||  r#)rqrN) rGrHrIrJrqrrrrrKrEr#r rnrn`sGG r#rnc.\rSrSrSrSrSrSrSrSr g)ClientStartStopFactoryiorcl[R"U/UQ70UD6 [R"5Ulgr)rurdrr* whenStopped)r;akws r rdClientStartStopFactory.__init__ss)  00R0 >>+r#cbUR(dUR(a[eSUlgr|rpr:s r rr#ClientStartStopFactory.startFactorywrtr#cUR(aUR(a[eSUlURR S5 g)NrgT)rqrrrzrr:s r r"ClientStartStopFactory.stopFactory|s0||t||   !!$'r#)rqrrzN) rGrHrIrJrqrrdrrrrKrEr#r rxrxosGG, (r#rxc$\rSrSrSrSrSrSrg) FactoryTestsizTests for factories.c^^^ [5m[R"STSS9nTRUR5 TR TR TR4S5 [R"STSS9n[R"STSS9m TR TR TR4S5 [R"UR5n[R"UR5n[R"X4/5nUU U4SjnURU5 UU4SjnURU5 U$)z The factory passed to L{IReactorTCP.listenTCP} should be started only when it transitions from being used on no ports to being used on one port and should be stopped only when it transitions from being used on one port to being used on no ports. rrrrgrct>TRTRTR4S5 TR5$)Nr)rrqrrQ)rrp3r;s r cbClosed3FactoryTests.test_serverStartStop..cbCloseds/   aii3V <##% %r#cV>TRTRTR4S5 g)N)rgrg)rrqr)rrr;s r cbClosedAll6FactoryTests.test_serverStartStop..cbClosedAlls   aii3V TR$rr)rksr r3FactoryTests.test_clientStartStop..s r#) rMr rrOrrWrrxrrrqr2)r;rrorrks @r test_clientStartStop!FactoryTests.test_clientStartStops}     ak :  "YY[%% (*; G< (011r#rEN)rGrHrIrJrYrrrKrEr#r rrs+Z2r#rc*\rSrSrSrSrSrSrSrg)CannotBindTestsizQ Tests for correct behavior when a reactor cannot bind to the required TCP port. c[5n[R"SUSS9nURUR5 UR 5R nUR 5nURURS5 URURS5 URUR U5 UR[R[RX1SS9 g)zk L{IReactorTCP.listenTCP} raises L{error.CannotListenError} if the address to listen on is already in use. rrrTCPN) rrr rrrQrrOrtypehostrr CannotListenError)r;rrrdests r test_cannotBindCannotBindTests.test_cannotBinds     q!{ ; (() JJL  zz| E* K0 A&   # #W%6%6   r#c4^^[T5UU4Sj5nU$)z>Returns closure that when called calls f and then callbacks d.c:>T"U0UD6nTRS5 U$)Nr)argsr|rtnrrs r newf/CannotBindTests._fireWhenDoneFunc..newfs T.R.C JJrNJr#r)r;rrrs `` r _fireWhenDoneFunc!CannotBindTests._fireWhenDoneFuncs" q     r#c|^^^^^^^ ^ [R"5n[5nTRXR5Ul[ R "SUSS9m TRT R5 UU U4SjnUU4SjmUUU U U4SjmU4SjmU4SjmUU4S jm U4S jmURU5 U$) z L{IReactorTCP.connectTCP} calls C{Factory.clientConnectionFailed} with L{error.ConnectBindError} if the bind address specified is already in use. rrrc>[R"5n[5nTRXR5Ul[ R "STR5RUSS9 URTU5 U$)Nrr0 bindAddress) rr*rurrTr rrrOr,)resultsrcf1_conmaderor;s r _connect12CannotBindTests.test_clientBind.._connect1si A!#C $ 6 6q:K:K LC    QYY[--s@P  MM(C (Hr#c>[R"5nTRX!RR5URlUR TU5 U$r)rr*rrar<r,)rrr_check1connect2r;s r r1CannotBindTests.test_clientBind.._conmadesL A.2.D.D##22/C   + MM/3 /Hr#c>T RURRS5 [R"5n[R"5nURR R 5Rn[5nT RX%R5Ul T RX5R5Ul [R"ST R 5RUSU4S9 URTX5 URTX5 [R"X#/5nURT X5 U$)Nrgrr)rrarrr*r8rrOrurrrr rr, DeferredList) rrrr1rOcf2dl _check2failed_check2stopped_stopror;s r r8CannotBindTests.test_clientBind.._check1connect2s   S--22A 6!B!B##--557<3 4##RH-B NN5# +Ir#c>TRURS5 URR[R 5 TR URR[R 55 U$r|)rr}rBr?r ConnectBindErrorrr!rrrr;s r r6CannotBindTests.test_clientBind.._check2failedsS   SZZ + JJOOE22 3 OOCJJ,,U-C-CD ENr#c@>TRURS5 U$r|rrrs r r7CannotBindTests.test_clientBind.._check2stopped!s   S[[! ,Nr#c>[R"5nURTU5 TRX1R5UlUR R R5 U$r)rr*r,rrrar8r9)rrrr_check1cleanupr;s r r.CannotBindTests.test_clientBind.._stop%sP A MM.# ."44QHCO    & & 5 5 7Hr#c>>TRURS5 gr|r)rrr;s r r7CannotBindTests.test_clientBind.._check1cleanup,s   S[[! ,r#) rr*rrrrrr rrrQr,) r; theDeferredsfrrrrrrrros ` @@@@@@@r test_clientBindCannotBindTests.test_clientBinds nn&  00ooN   a{ ; (    (     -  *r#rEN) rGrHrIrJrYrrrrKrEr#r rrs  ( Gr#rc\rSrSrSrSrSrg)LocalRemoteAddressTestsi3zc Tests for correct getHost/getPeer values and that the correct address is passed to buildProtocol. c^^^^^ [5n[R"5UlURm [R "SUSS9mTR TR5 TR5Rn[5m[R"5=nTl [R"SUT5mUUU4SjnURU5 UU 4SjnURU5 U$)zg L{IListeningPort.getHost} returns the same address as a client connection's L{ITCPTransport.getPeer}. rrrc>TRTR5/TR5 TRTR5TRRR 55 gr)rrrcrar8getPeer)rrirOr;s r r!7LocalRemoteAddressTests.test_hostAddress..checkIsP   dlln-}/J/J K     : : D D L L N r#c(>TR5 T$r)r)rrserverConnectionLosts r rI9LocalRemoteAddressTests.test_hostAddress..cleanupQs  "' 'r#)rrrr*r`r rrrQrrOrur_rr,) r;rr onConnectionr!rIrirrOrs ` @@@@r test_hostAddress(LocalRemoteAddressTests.test_hostAddress9s () /4~~/? ,,CC  M[I **+ LLN  ') >Cnn>NN };&&{A}E     ' (   )r#rEN)rGrHrIrJrYrrKrEr#r rr3s  !r#rc\rSrSrSrSrg)WriterProtocoli]cURRS5 /SQnURRU5 URR5nURS:wa[ SU35 SUR lURR5nURS:wa[ SU35 SUR lSUR l URR5 g)NHello Cleveland! )Goodbye cruel world rz!getPeer returned non-TCP socket: rgz!getHost returned non-TCP socket: ) r8write writeSequencerrrrkproblemrdoner9)r;seqpeeruss r r<WriterProtocol.connectionMade^s 237 $$S)~~%%' 99  3D6: ;#$DLL ^^ # # % 77e  3B48 9#$DLL   %%'r#rENrGrHrIrJr<rKrEr#r rr]s(r#rc \rSrSrSrSrSrg)ReaderProtocolitcBUR=RU- slgr)rkdatar;rs r dataReceivedReaderProtocol.dataReceivedus T!r#c&SURlgr|rkrrAs r rCReaderProtocol.connectionLostx r#rENrGrHrIrJrrCrKrEr#r rrts "r#rc \rSrSrSrSrSrg)WriterClientFactoryi|c SUlSUlg)Nrr#)rrr:s r rdWriterClientFactory.__init__}s  r#c2[5nXlX lU$r)rrkrarms r rT!WriterClientFactory.buildProtocols   r#)rrraNrGrHrIrJrdrTrKrEr#r rr|s r#rc$\rSrSrSrSrSrSrg)WriteDataTestsizk Test that connected TCP sockets can actually write data. Try to exercise the entire ITransport interface. c^^^[R"5m[TlSTlSTl[ T5n[ R"SUSS9nTRUR5 UR5Rn[5m[ T5n[ R"SX45 UUU4Sjn[R"UR UR /5nUR#U5$)zj L{ITCPTransport.write} and L{ITCPTransport.writeSequence} send bytes to the other end of the connection. rrrc>TRTRS5 TRTRS:HS5 TRTRS5 SR/SQ5nTRTRU:HS5 g)N&writer didn't finish, it probably diedrzwriter indicated an error$client didn't see connection droppedr#)rrrrrz.client didn't receive all the data it expected)rrrjoinr)rexpectedrrr;s r r!)WriteDataTests.test_writer..checksn OOAFF$L M OOAIIN,G H OOGLL*P QxxPH OO (@ r#)r Factoryrrr WiredFactoryr rrrQrrOrrrr onDisconnectr,) r;wrappedFrorwrappedClientFr!rrrs ` @@r test_writerWriteDataTests.test_writers    #  ?   a[ A ( IIK  %'%g.;:    !6!68S8S T U}}U##r#cv^^ ^ ^ [RRS:Xa [S5e[R "5m [R "5m "U U 4SjS[ R5n[ R"5nXl[R"SUSS9nURUR5 UR5n[[5"SS 55m"UU U 4S jS [ R5n[5m UT lT R"nU 4S jnUR%U5 ['S UR(SUR*35 [R,"UR(UR*T 5 ['S5 UR/U[0R25$)z A TCP transport which is written to after the connection has been shut down should notify its protocol that the connection has been lost, even if the TCP transport is not actively being monitored for read events (ie, pauseProducing was called on it). IOCPReactora(iocpreactor does not, in fact, stop reading immediately after pauseProducing is called. This results in a bonus disconnection notification. Under some circumstances, it might be possible to not receive this notifications (specifically, pauseProducing, deliver some data, proceed with this test). c2>\rSrSrSrU4SjrU4SjrSrg)JWriteDataTests.test_writeAfterShutdownWithoutReading..Disconnecteriz Protocol for the server side of the connection which disconnects itself in a callback on clientPaused and publishes notification when its connection is actually lost. cL>^[S5 U4SjnTRU5 g)z; Set up a callback on clientPaused to lose the connection. zDisconnector.connectionMadecf>[S5 TRR5 [S5 g)Nz&Disconnector.connectionMade disconnectzloseConnection calledr7)rr;s r rmWriteDataTests.test_writeAfterShutdownWithoutReading..Disconnecter.connectionMade..disconnects%@ANN113/0r#N)rr,)r;r clientPauseds` r r<YWriteDataTests.test_writeAfterShutdownWithoutReading..Disconnecter.connectionMades#121 ((4r#cT>[S5 TRS5 [S5 g)zD Notify observers that the server side of the connection has ended. zDisconnecter.connectionLostNzserverLost called back)rr)r;rB serverLosts r rCYWriteDataTests.test_writeAfterShutdownWithoutReading..Disconnecter.connectionLosts% 12##D),-r#rEN)rGrHrIrJrYr<rCrK)rrsr Disconnecterrs  5 . .r#rrrrc*\rSrSrSrSrSrSrSrg)FWriteDataTests.test_writeAfterShutdownWithoutReading..Infiniteiz A producer which will write to its consumer as long as resumeProducing is called. @ivar consumer: The L{IConsumer} which will be written to. cXlgrconsumer)r;rs r rdOWriteDataTests.test_writeAfterShutdownWithoutReading..Infinite.__init__s ( r#cf[S5 URRS5 [S5 g)NzInfinite.resumeProducingxz*Infinite.resumeProducing wrote to consumer)rrrr:s r resumeProducingVWriteDataTests.test_writeAfterShutdownWithoutReading..Infinite.resumeProducings&./ ##D)@Ar#c[S5 g)NzInfinite.stopProducing)rr:s r stopProducingTWriteDataTests.test_writeAfterShutdownWithoutReading..Infinite.stopProducings ,-r#rN) rGrHrIrJrYrdr"r%rKrEr#r Infiniters  ) B  .r#r'c*>\rSrSrSrUUU4SjrSrg)MWriteDataTests.test_writeAfterShutdownWithoutReading..UnreadingWriteriz[ Trivial protocol which pauses its transport immediately and then writes some bytes to it. c>^[S5 TRR5 TRS5 [S5 UU4SjnTR U5 g)NzUnreadingWriter.connectionMadezclientPaused called backc>[S5 T"TR5n[S5 TRRUS5 [S5 g)Nz$UnreadingWriter.connectionMade writez5UnreadingWriter.connectionMade write created producerFz8UnreadingWriter.connectionMade write registered producer)rr8registerProducer)rproducerr'r;s r rkWriteDataTests.test_writeAfterShutdownWithoutReading..UnreadingWriter.connectionMade..writesB>? (7HOPNN33HeDRSr#)rr8pauseProducingrr,)r;rr'rrs` r r<\WriteDataTests.test_writeAfterShutdownWithoutReading..UnreadingWriter.connectionMade sI45--/%%d+./T$&&u-r#rEN)rGrHrIrJrYr<rK)r'rrsr UnreadingWriterr)s   . .r#r1c2>[S5 TR$)N cbClientLost)rr)rrs r r3JWriteDataTests.test_writeAfterShutdownWithoutReading..cbClientLost,s  $$ $r#zConnecting to :zReturning Deferred)r __class__rGrrr*r rR ServerFactoryrrrQrrrrurjrwr,rrrOrrr ConnectionLost) r;rrrOrnr1rr3r'rrrs @@@@r %test_writeAfterShutdownWithoutReading4WriteDataTests.test_writeAfterShutdownWithoutReadingse    % % 6? ~~' ^^%  . .8,, .<'')&  FkB **+||~ ] # . . $ .& . .h// .B!"!0% % ((6 nTYYKq 45499dii8 !!!"68L8LMMr#rEN)rGrHrIrJrYr r9rKrEr#r rrs $@INr#rc\rSrSrSrSrg)ConnectionLosingProtocoli:cURRS5 URR5 URR 5 URR R UR5 g)N1)r8rr9master_connectionMadeportsrhr:s r r<'ConnectionLosingProtocol.connectionMade;sP T" %%' ##%   0r#rENrrEr#r r<r<:s1r#r<c \rSrSrSrSrSrg) NoopProtocoliBc[R"5UlURRR UR5 gr)rr*rr? serverConnsrhr:s r r<NoopProtocol.connectionMadeCs,! &&tvv.r#c:URRS5 gNT)rrrAs r rCNoopProtocol.connectionLostGs r#)rNrFrEr#r rDrDBs /r#rDc$\rSrSrSrSrSrSrg)ConnectionLostNotifyingProtocoliKaG Protocol which fires a Deferred which was previously passed to its initializer when the connection is lost. @ivar onConnectionLost: The L{Deferred} which will be fired in C{connectionLost}. @ivar lostConnectionReason: L{None} until the connection is lost, then a reference to the reason passed to C{connectionLost}. cSUlXlgrlostConnectionReasononConnectionLost)r;rPs r rd(ConnectionLostNotifyingProtocol.__init__Ws$(! 0r#cFXlURRU5 gr)rOrPrrAs r rC.ConnectionLostNotifyingProtocol.connectionLost[s$*! &&t,r#rNN)rGrHrIrJrYrdrCrKrEr#r rLrLKs 1-r#rLc\rSrSrSrSrSrg)HandleSavingProtocoli`z Protocol which grabs the platform-specific socket handle and saves it as an attribute on itself when the connection is established. cjUR5Ul[RR X5$)zD Save the platform-specific socket handle for future introspection. ) getHandlehandler rRmakeConnection)r;r8s r rY#HandleSavingProtocol.makeConnectiongs+  ))+   //@@r#)rXN)rGrHrIrJrYrYrKrEr#r rUrU`s  Ar#rUc6\rSrSrSrSrSrSrSrSr Sr g ) ProperlyCloseFilesMixinipz9 Tests for platform resources properly being cleaned up. c[5e)z Bind a server port to which connections will be made. The server should use the given protocol factory. @return: The L{IListeningPort} for the server created. NotImplementedErrorr;addressrrks r createServer$ProperlyCloseFilesMixin.createServeru "##r#c[5e)z Establish a connection to the given address using the given L{ClientCreator} instance. @return: A Deferred which will fire with the connected protocol instance. r^r;rarr>s r connectClient%ProperlyCloseFilesMixin.connectClient~rdr#c[5e)zm Return the exception class which will be raised when an operation is attempted on a closed platform handle. r^r:s r getHandleExceptionType.ProperlyCloseFilesMixin.getHandleExceptionTypes "##r#c[R"5(a$[R"[R 5$[R"[R 5$)z Return a L{hamcrest.core.matcher.Matcher} that matches the errno expected to result from writing to a closed platform socket handle. )r isWindowshamcrestequal_torB WSAENOTSOCKEBADFr:s r getHandleErrorCodeMatcher1ProperlyCloseFilesMixin.getHandleErrorCodeMatchers?     $$U%6%67 7  --r#c^^^ ^ [R"5m [R"5nU 4SjUlTR SSU5m [R"5mT R 5n[R "[U4Sj5nTRURURU5nUU 4SjnURU5 U4SjnURU5 U 4SjnURU5 U$)zX Test that lost connections properly have their underlying socket resources cleaned up. c>[T5$r)rL)onServerConnectionLostsr rAProperlyCloseFilesMixin.test_properlyCloseFiles..s)H "* r#rrc>[T5$r)rU)onClientConnectionLostsr rrws 12HIr#c>URRS5 URR5 [R"TT/5$)z Disconnect the client. Return a Deferred which fires when both the client and the server have received disconnect notification. s0some bytes to make sure the connection is set up)r8rr9rr)rryrvs r clientConnectedHProperlyCloseFilesMixin.test_properlyCloseFiles..clientConnectedsD    " "#V W    + + -&&(>@V'WX Xr#c>UupURR[R5(d[ URS5 URR[R5(d[ URS5 TR 5nTR TR5URRS5n[R"URSU5 g)zH Verify that the underlying platform socket handle has been cleaned up. z,Client lost connection for unexpected reasonz,Server lost connection for unexpected reasonsbytesrN) rOr!r ConnectionClosedrrrrrjrXsendrn assert_thatr)r&rrerrorCodeMatcher exceptionr;s r clientDisconnectedKProperlyCloseFilesMixin.test_properlyCloseFiles..clientDisconnecteds $NF..44U5K5KLL//B..44U5K5KLL//B $==? ))++-v}}/A/A8I  q!  r#ct>^[R"TR5nURU4Sj5 U$)zT Shut down the server port. Return a Deferred which fires when this has completed. c>T$rrE)rrHs r rRProperlyCloseFilesMixin.test_properlyCloseFiles..cleanup..s;r#)rrrQr,)rHr&r<s` r rI@ProperlyCloseFilesMixin.test_properlyCloseFiles..cleanups/ (()A)ABF   6 7Mr#) rr*r r7rbrrQr rgrrOr,rS) r;r serverAddrr>clientDeferredr{rrIryrvr<s ` @@@r test_properlyCloseFiles/ProperlyCloseFilesMixin.test_properlyCloseFiless "'!1 ..0 " &&{A}E !&!1'')  .. I ++ OOZ__m  Y ""?3 2 ""#56  w'r#rEN) rGrHrIrJrYrbrgrjrrrrKrEr#r r\r\ps!$$$ .Fr#r\c*\rSrSrSrSrSrSrSrg)ProperlyCloseFilesTestsiz Test that the sockets created by L{IReactorTCP.connectTCP} are cleaned up when the connection they are associated with is closed. c,[R"X#US9$)z5 Create a TCP server using L{IReactorTCP.listenTCP}. r)r rr`s r rb$ProperlyCloseFilesTests.createServers  HHr#c$URX5$)z6 Create a TCP client using L{IReactorTCP.connectTCP}. )rrfs r rg%ProperlyCloseFilesTests.connectClients''<.RememberingWrapperi#a0 Simple wrapper factory which records the addresses which are passed to its L{buildProtocol} method and delegates actual protocol creation to another factory. @ivar addresses: A list of the objects passed to buildProtocol. @ivar factory: The wrapped factory to which protocol creation is delegated. c/UlXlgr addressesrk)r;rks r rd7AddressTests.setUp..RememberingWrapper.__init__.s!#& r#cnURRU5 URRU5$)zX Append the given address to C{self.addresses} and forward the call to C{self.factory}. )rrhrkrT)r;rns r rT.RememberingWrapper.buildProtocol5s+ %%d+||11$77r#rN)rGrHrIrJrYrdrTrKrEr#r RememberingWrapperr#s  ' 8r#rrrr)r ClientFactoryrrrrr*rr_serverConnLostr` serverWrapperrurrclientConnLost clientWrapperr rrOrrrrr)r;rs r setUpAddressTests.setUpsA 8!7!7 8:&' CH>>CSSdkk@CH>>CSSdkk@0 <&' CH>>CSSdkk@CH>>CSSdkk@/ <%%a););{S  ++ II    $ $dii&7&7&9&>&>@R@R ""D$7$79L9L#MNNr#cURR5 [R"URUR [R "URR5/5$)zN Disconnect the client/server pair and shutdown the port created in L{setUp}. ) rrrrrrrrOrQr:s r tearDownAddressTests.tearDownTsV !!#""######DII$;$;<   r#cURRRR5nURRRR 5nUR URR[SURUR5/5 UR URR[SURUR5/5 g)a5 L{ClientFactory.buildProtocol} should be invoked with the address of the server to which a connection has been established, which should be the same as the address reported by the C{getHost} method of the transport of the server protocol and as the C{getPeer} method of the transport of the client protocol. rN) rrar8rrrrrrr rrO)r;r; clientPeers r test_buildProtocolClient%AddressTests.test_buildProtocolClientbs[[--77??A [[--77??A      ( (   A B      ( (   A B r#) rrrrrrOrrrrN) rGrHrIrJrYrrrrKrEr#r rrs9Ov   r#rc\rSrSrSrSrg)LargeBufferWriterProtocoliwc^TRRSTRRS- -5 U4Sjn[R "SU5 g)NXrgc>TRRS5 STRlTRR 5 g)Nrrg)r8rrkrr9r:sr finish8LargeBufferWriterProtocol.connectionMade..finishs1 NN  & !DLL  NN ) ) +r#gMbP?)r8rrklenr callLater)r;rs` r r<(LargeBufferWriterProtocol.connectionMade}s@ TT\\%5%5%9:; , %(r#rENrrEr#r rrws )r#rc \rSrSrSrSrSrg)LargeBufferReaderProtocolicTUR=R[U5- slgr)rkrrs r r&LargeBufferReaderProtocol.dataReceiveds CI%r#c&SURlgr|rrAs r rC(LargeBufferReaderProtocol.connectionLostrr#rENrrEr#r rrs &r#rc \rSrSrSrSrSrg)LargeBufferReaderClientFactoryic SUlSUlgNr)rrr:s r rd'LargeBufferReaderClientFactory.__init__s r#c2[5nXlX lU$r)rrkrarms r rT,LargeBufferReaderClientFactory.buildProtocols % ' r#)rrarNrrEr#r rrs r#rc\rSrSrSrSrSrg) FireOnCloseizYA wrapper around a protocol that makes it fire a deferred when connectionLost is called. c[RRX5 URRR S5 gr)rrrCrkrwrrAs r rCFireOnClose.connectionLosts.  //= &&t,r#rEN)rGrHrIrJrYrCrKrEr#r rrs -r#rc\rSrSr\rSrSrg)FireOnCloseFactoryicv[RRX5 [R"5Ulgr)rrrdrr*rwrs r rdFireOnCloseFactory.__init__s$  ))$?( r#)rwN)rGrHrIrJrr rdrKrEr#r rrs H)r#rc"\rSrSrSrSrSrSrg)LargeBufferTestsiz0Test that buffering large amounts of data works.ic^^^[R"5m[TlSTlSTlTR Tl[T5n[R"SUSS9nTRUR5 UR5Rn[5m[T5n[R"SX45 [ R""UR$UR$/5nUUU4SjnUR'U5$)Nrrrc~>TRTRS5 TRTRTR:STRTR4-5 TRTRTR:*STRTR4-5 TRTRS5 g)Nrz9client didn't receive all the data it expected (%d != %d)z8client did receive more data than it expected (%d != %d)r)rrrdatalen)rrrr;s r r!*LargeBufferTests.testWriter..checks OOAFF$L M OO t||+ ' T\\:;  OO t||+ ' T\\:;  OOGLL*P Qr#)r rrrrrrrr rrrQrrOrrrrrwr,) r;r rorr rr!rrs ` @@r testWriterLargeBufferTests.testWriters    .   %a(   a[ A ( IIK  02+G4;:   !2!2N4K4K L M R}}U##r#rEN)rGrHrIrJrYrrrKrEr#r rrs:G$r#rc(\rSrSrSrSrSrSrSrg) MyHCProtocoliFcXSUlUR(aURS5 ggrI)readHalfClosedwriteHalfClosedrCr:s r readConnectionLostMyHCProtocol.readConnectionLosts&"       % r#cXSUlUR(aURS5 ggrI)rrrCr:s r writeConnectionLost MyHCProtocol.writeConnectionLosts&#       % r#)rrN) rGrHrIrJrrrrrKrEr#r rrsNO& &r#rc"\rSrSrSrSrSrSrg) MyHCFactoryirNc\U=RS- sl[5nXlX lU$r|)rirrkrarms r rTMyHCFactory.buildProtocols' q N r#)ra)rGrHrIrJrir_rTrKrEr#r rrs F!r#rc<\rSrSrSrSrSrSrSrSr Sr S r g ) HalfCloseTestsizTest half-closing connections.cd^^[5=Tln[R"SUSS9=TlmTR TR 5 [U4Sj5n[R"[[5Tl URUU4Sj5 URTR5 U$)Nrrrc>TR$r)r)rosr r&HalfCloseTests.setUp..s akkr#c>TRRTR5RTR5R5$r)cfrrrrO)_ror;s r rrs. 2 2199;3C3CQYY[EUEU Vr#)rrr rrorrQr2r rQrrr,_setUp)r;rrros` @r rHalfCloseTests.setUps} ]"&&q!{CC ( ) *((,? VW dkk"r#c^UTl[R"5=TlTRlTR TRR RS5 [U4Sj5$)Nrgc6>[TRSS5SL$)Nra)rrr:sr r'HalfCloseTests._setUp..s!Fd!Rr#) rrr*clientProtoConnectionLostrlrr8rr2r;rs` r rHalfCloseTests._setUpsQ FKnnFVV&)C ..88!<RSSr#cP^TRTRRS5 TRRR 5 [ R "TRR5nURU4Sj5 URTR5 U$)Nrc>TR$r)r)rr;s r r)HalfCloseTests.tearDown.. s $"@"@r#) rrclosedr8r9rrrorQr, _tearDown)r;rs` r rHalfCloseTests.tearDownso ++Q/ ,,.    4 4 5 @A dnn%r#c^^TRTRRS5 TRTRRRS5 [ R "5mUU4SjnUTRRlTRRRR5 TRU4Sj5 T$)Nrgrc^>STRRlTRS5 gr|)rrarr)rBrr;s r _connectionLost1HalfCloseTests._tearDown.._connectionLosts!)*DFF   & JJt r#cd>TRTRRRS5$r|)rrrarrr;s r r*HalfCloseTests._tearDown..s" 0 01D1D1K1KQ Or#) rrrrrarr*rCr8r9r,)r;rr rs` @r r HalfCloseTests._tearDowns ++Q/ ,,33Q7 NN  .=* %%446 OPr#c^^^^TRmTRmTRmTRS5 [ U4Sj5nU4SjnUUU4SjnUUU4SjnUR U5R U5R U5$)Nhelloc4>[TR5S:H$r)r_tempDataBuffertsr r5HalfCloseTests.testCloseWriteCloser..&sc!"3"349r#cB>TR5 [U4Sj5$)Nc>TR$r)_writeDisconnectedrsr rHHalfCloseTests.testCloseWriteCloser..loseWrite..*s Q%9%9r#)loseWriteConnectionr2)rrs r loseWrite6HalfCloseTests.testCloseWriteCloser..loseWrite(s ! ! #9: :r#c>TRTR5 TRTR5 TRTR5 [ U4Sj5$)Nc0>TRR$r)rarrsr rDHalfCloseTests.testCloseWriteCloser..check..0sQ^^%B%Br#)rrrrrr2)rrrr;s r r!2HalfCloseTests.testCloseWriteCloser..check,sG   V]] + OOF22 3   V22 3BC Cr#c>TRRnU"S5 U"S5 TRS[TRR55 TRTR R S5 TRTR R5 TRTR R5 g)Nrslalala fooled yourr) r8rrrrrarrrrr)rwrrr;s r r2HalfCloseTests.testCloseWriteCloser..write2s  &&A iL " #   QF$4$4$D$D E F   Q^^00( ;   Q^^22 3 OOANN99 :r#)rrr8rr2r,)r;rrr!rrrrs` @@@r testCloseWriteCloser#HalfCloseTests.testCloseWriteCloser sn FF     9 : ; D  ;}}Y'33E:FFuMMr#c^^TRmTRRR5 [R "[ U4Sj5[ U4Sj5/5nURUU4Sj5 U$)Nc0>TRR$r)rarr#sr r;HalfCloseTests.testWriteCloseNotification..Cs!.."@"@r#c0>TRR$r)rrr:sr rr-Ds$++"<"TRTRRS5$)NF)rrar)rrr;s r rr-Gs 0 01N1NPU Vr#)rrar8rrrr2r,)r;rrs` @r testWriteCloseNotification)HalfCloseTests.testWriteCloseNotification=s] FF   446   @A<=   VWr#)rrrrroN) rGrHrIrJrYrrrr r)r0rKrEr#r rrs%( T N: r#rc2\rSrSrSrSrSrSrSrSr g) 0HalfCloseNoNotificationAndShutdownExceptionTestsiKc[5=Uln[R"5URl[ R "SUSS9=Uln[R"[ [5RUR5RUR5R5nURUR 5 U$r)rrrrr*r_r rror rQrrrrrOr, _gotClient)r;rrors r r6HalfCloseNoNotificationAndShutdownExceptionTests.setUpLs$&&(-(8%&&q!{CC  " "7,@ A L L IIK  aiik..  doo&r#c:XlURR$r)rrr_rs r r5;HalfCloseNoNotificationAndShutdownExceptionTests._gotClientXs vv,,,r#c~URRR5 URR 5$r)rr8r9rorQr:s r r9HalfCloseNoNotificationAndShutdownExceptionTests.tearDown_s+ ,,.vv##%%r#c^TRRRS5 TRRR5 [R "5=TR Rln[R "5=TRlnURU4Sj5 URU4Sj5 [R"X/5$)z TCP protocols support half-close connections, but not all of them support being notified of write closes. In this case, test that half-closing the connection causes the peer's connection to be closed. rcd>TRTRRRS5$)Nr)rrrarrs r rUHalfCloseNoNotificationAndShutdownExceptionTests.testNoNotification..ns" 0 01D1D1I1I8 Tr#cb>TRTRRR5$rrrrarrs r rr=o0C0C0J0J Kr#) rr8rrrr*rrarlr,rr;rr1s` r testNoNotificationCHalfCloseNoNotificationAndShutdownExceptionTests.testNoNotificationcs ##H- 113161AA*Q*/..*:: "R TU KL""A7++r#c^TRRRR5 TRRR S5 TRRR 5 [R"5=TRRl n[R"5=TRl nURU4Sj5 [R"X/5$)z` If the other side has already closed its connection, loseWriteConnection should pass silently. rcb>TRTRRR5$rr?rs r rXHalfCloseNoNotificationAndShutdownExceptionTests.testShutdownException..|r@r#) rrar8r9rrrrr*rlr,rrAs` r testShutdownExceptionFHalfCloseNoNotificationAndShutdownExceptionTests.testShutdownExceptionrs %%446 ##D) 113161AA*Q*/..*:: "R KL""A7++r#)rrroN) rGrHrIrJrr5rrBrGrKrEr#r r3r3Ks -& , ,r#r3c6\rSrSrSrSrSrSrSrSr Sr g ) HalfCloseBuggyApplicationTestsizA Test half-closing connections where notification code has bugs. cB^[5Tl[R"5TRl[ R "STRSS9TlTRTRR5 TRR5n[R"[ [5nURURUR5nU4SjnUR!U5 [R""TRRU/5$)zd Set up a server and connect a client to it. Return a Deferred which only fires once this is done. rrrc>UTlgr)r)rr;s r setClient7HalfCloseBuggyApplicationTests.setUp..setClients "0D r#)rrrr*r_r rrOrrQrr rQrrrr,r)r;rncreatorrrMs` r r$HalfCloseBuggyApplicationTests.setUps )]49NN4D1%%a););{S   //0yy  "((,? ++DIItyyA 1 ""9-""    6 6 G  r#c[S5e)zH Fake implementation of a callback which illegally raises an exception. zONO I AM BUGGY CODEr)r;rs r aBug#HalfCloseBuggyApplicationTests.aBugs 011r#c^[R"5=nTRlTRRR 5 U4SjnUR U5 U$)zf Helper for testing that an exception is logged by the time the client protocol loses its connection. cf>TR[5nTR[U5S5 gr|)flushLoggedErrorsrrr)rerrorsr;s r r!EHalfCloseBuggyApplicationTests._notificationRaisesTest..checks'++L9F   S[! ,r#)rr*rrlr8rr,)r;rr!s` r _notificationRaisesTest6HalfCloseBuggyApplicationTests._notificationRaisesTestsQ 7BYY'':++--r#cXURURlUR5$)z If C{writeConnectionLost} raises an exception when the transport calls it to notify the protocol of that event, the exception should be logged and the protocol should be disconnected completely. )rRrrrYr:s r test_writeNotificationRaises;HalfCloseBuggyApplicationTests.test_writeNotificationRaisess% 37))/++--r#)rrOrN) rGrHrIrJrYrrRrYr\r_rKrEr#r rJrJs  *2 ..r#rJc\rSrSrSrSrSrg)LogTestsiz, Test logging facility of TCP base classes. c2^^[5n[5n[R"5Ul[ R "SUSS9nTRUR5 [ R"UR5RUR5RU5mTRTR5 TRTRR S5 UU4SjnURR#U5 UR$)z` Check that the log customization of the client transport happens once the client is connected. rrr UninitializedcR>TRTRRS5 g)NzAccumulatingProtocol,client)rr8logstr)rrr;s r cb+LogTests.test_logstrClientSetup..cbs   Y00779V Wr#)rrrurr*r_r rrrQrrrrOrrr8rfr,)r;rrrOrgrs` @r test_logstrClientSetupLogTests.test_logstrClientSetups !" "(-(8%  FkB **+&&t||~':':DLLNURnTRU[R"5[R"5-5 URR 5 TR U[R"5[R"5-5 [R"5nURT5 [R"SURU5 U$r) r8assertInr getReaders getWritersr/ assertNotInrr*r,rr)r4trrcheckAfterConnectionMader;s r checkInConnectionMadeVPauseProducingTests.test_pauseProducingInConnectionMade..checkInConnectionMadesB MM"g002W5G5G5II J OO * * ,   R!3!3!58J8J8L!L M A MM2 3   aU 3Hr#c>URnTRU[R"5[R"5-5 gr)r8rrr rprq)r4rsr;s r rtYPauseProducingTests.test_pauseProducingInConnectionMade..checkAfterConnectionMades3B   R!3!3!58J8J8L!L Mr#)rrrurr*r_r rrrQrrrrOrr,)r;rrrOrrurts` @r #test_pauseProducingInConnectionMade7PauseProducingTests.test_pauseProducingInConnectionMades!" "(-(8%  FkB **+&&t||~':':DLLNTRURR5$r)rr8r9)r4r;s r r3CallBackOrderTests.test_loseOrder..s$//%//*H*HIr#cp>[R"STRRR5 g)z" protocol.connectionMade callback rN)r rrar8r9)rrs r _cbCM0CallBackOrderTests.test_loseOrder.._cbCM"s'   a!4!4!>!>!M!M Nr#rrrcg)z' factory.clientConnectionLost callback CCLrErs r _cbCCL1CallBackOrderTests.test_loseOrder.._cbCCL0sr#cg)z" protocol.connectionLost callback CLrErs r _cbCL0CallBackOrderTests.test_loseOrder.._cbCL6sr#c.>TRUSS/5 g)Nrr)r)rr;s r _cbGather4CallBackOrderTests.test_loseOrder.._cbGather<s   S4- 0r#)rrrr*r,r_rur`r rrrQrrrrOrrrw) r;rrrOrrrrrrs ` @r test_loseOrder!CallBackOrderTests.test_loseOrders0 !"(-(8(D(D I) %!"(-(8%(-(8% O %%11%8  FkB **+&&t||~':':DLLNrs  &HH0M9&'+5 8*h''*"X++"044n,h.D.D ,h.D.D8DCXDCNaHaH x'' (_((>28>2Blhl^'h'T(X&&(.X&& (00 oNXoNd1x0018$$-h&7&7-* A: A ppfh(?6 100 1-8++-` 8` F) 1 1)" 1 1 X%;%; -(**-)11)#$x#$L #$&'&%&" ((( VXVr2,x2,j@.X@.F-x->*-(*-Z6(6(r@""8#9#9:1=BI #^Y?   s&LL L