֛hѦ SrSSKrSSKrSSKrSSKrSSKrSSKJr SSKJ r J r J r J r J r JrJr SSKJr SSKJrJr SSKJrJr SSKrSSKJrJr SS KJrJrJrJ r J!r!J"r" SS K#J$r$J%r% SS K&J'r'J(r(J)r)J*r*J+r+J,r,J-r-J.r.J/r/ SS K0J1r1J2r2J3r3J4r4J5r5J6r6J7r7J8r8J9r9J:r:J;r; SS Kr>J?r? SSK@JArAJBrBJCrCJDrDJErEJFrFJGrG SSKHJIrIJJrJJKrKJLrLJMrMJNrNJOrOJPrPJQrQ SSKRJSrSJTrTJUrU SSKVJWrWJXrX SSKYJZrZ SSK[J\r\ SSK]J^r^ SSK_J`r` SSKaJbrbJcrcJdrdJere SSKfJgrgJhrhJiri SSKjJkrk SSKlJmrm SrnSrp\R "\R\R5rp\pRS5 SrtSru\pb\pR5 \`R"5(aSSKzJ{r{ \{Rr}Sr~OSS KzJr \GRr}Sr~S"rS#r"S$S%5r"S&S'\i5r"S(S)\>5r\"\65"S*S+55r\"\6\5 "S,S-\i5r"S.S/\i5r"S0S1\L5r"S2S3\5r\"\:5"S4S555r"S6S7\S\K\O5r"S8S9\5r\"\t\u5"S:S;\55r"S<S=\S5r"S>S?\5r\"\t\u5"S@SA\55rSBr"SCSD\5r\"\5\R"SSE9"SFSG555r\"\~SH5"SISJ\h55rSKr\"\~SH5"SLSM\h55r"SNSO\M5r"SPSQ5r"SRSS\5r"STSU\5r"SVSW5r"SXSY\S\\\5r"SZS[\S\\\5r"S\S]\>5rS^rS_rS`r"SaSb\S5r"ScSd5r"SeSf5r"SgSh\\\S5r"SiSj\\\S5r\"5GRS\GRU55 \"5GRS\GRU55 \"5GRS\GRU55 \"5GRS\GRU55 \"5GRS\GRU55 \"5GRS\GRU55 \"5GRS\GRU55 \"5GRS\GRU55 \"5GRS\GRU55 "SkSl\J5r"SmSn\J5r"SoSp\J5r"SqSr\5r"SsSt\J5r"SuSv\J5r"SwSx\J5r"SySz\5r"S{S|\5r"S}S~\5r"SS\5r"SS\J5r"SS\J5r"SS\5r"SS\5r"SS\5r"SS\5r"SS5r"SS\S\5r\"5GRS\GRU55 \"\t\u5"SS\i55r"SS\h5r\"\~SH5"SS\h55r"SS\h5rg!\oa SrnGNf=f!\varwSrtS\w3ruSrwCwGNSrwCwff=f!\oa S!r}GNf=f)zU Tests for implementations of L{IReactorTCP} and the TCP parts of L{IReactorSocket}. Nwraps)CallableClassVarListMappingOptionalSequenceType)skipIf) Interface implementer) verifyClass verifyObject) IPv4Address IPv6Address)Deferred DeferredListfail gatherResults maybeDeferredsucceed)TCP4ClientEndpointTCP4ServerEndpoint) ConnectBindErrorConnectionAbortedConnectionClosedConnectionDoneConnectionLostConnectionRefusedErrorDNSLookupError NoProtocol UserError) IConnectorIHalfCloseableProtocolILoggingContext IPullProducer IPushProducer IReactorFDSetIReactorSocket IReactorTCP IReactorTimeIResolverSimple ITLSTransport) ClientFactoryProtocol ServerFactory) ConnectionServer _BuffersLogs_FileDescriptorReservation_IFileDescriptorReservation_NullFileDescriptorReservation _resolveIPv6) BrokenContextFactoryConnectableProtocolConnectionTestsMixinEndpointCreatorLogObserverMixinStopStreamClientTestsMixin findFreePortrunProtocolsWithReactor)ReactorBuilderneedsRunningReactor stopOnError) MemoryReactorStringTransport)Logger)log)Failure)platform)ClientStartStopFactoryClosingFactoryMyClientFactoryMyServerFactory)SkipTestSynchronousTestCaseTestCase)SSL)ClientContextFactoryTF)::1rzIPv6 not available. ) _win32ifaces) _posixifacesc/$NrZbC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/internet/test/test_tcp.pyr]sBr[cD[5nU(aUS$[S5e)aP Find and return a configured link local IPv6 address including a scope identifier using the % separation syntax. If the system has no link local IPv6 addresses, raise L{SkipTest} instead. @raise SkipTest: if no link local address can be found or if the C{netifaces} module is not available. @return: a C{str} giving the address rz#Link local IPv6 address unavailable)getLinkLocalIPv6AddressesrO) addressess r\getLinkLocalIPv6Addressras%*+I| 8 99r[cUup#SU;dSU;a[R"X#5SSnOX#4nURU5 g)a Connect a socket to the given destination. @param client: A C{socket.socket}. @param destination: A tuple of (host, port). The host is a C{str}, the port a C{int}. If the C{host} is an IPv6 IP, the address is resolved using C{getaddrinfo} and the first version found is used. %:rN)socket getaddrinfoconnect)client destinationhostportaddresss r\rhrhsELT d{cTk$$T03A6, NN7r[cH\rSrSrSrSrSrSrSrSr Sr S r S r S r g ) FakeSocketz A fake for L{socket.socket} objects. @ivar data: A C{str} giving the data which will be returned from L{FakeSocket.recv}. @ivar sendBuffer: A C{list} of the objects passed to L{FakeSocket.send}. cXl/UlgrY)data sendBufferselfrrs r\__init__FakeSocket.__init__s r[cXlgrY)blocking)rurys r\ setblockingFakeSocket.setblockings r[cUR$rYrr)rusizes r\recvFakeSocket.recvs yyr[cNURRU5 [U5$)z I{Send} all of C{bytes} by accumulating it into C{self.sendBuffer}. @return: The length of C{bytes}, indicating all the data has been accepted. )rsappendlenrubytess r\sendFakeSocket.sends  u%5zr[cg)z Shutdown is not implemented. The method is provided since real sockets have it and some code expects it. No behavior of L{FakeSocket} is affected by a call to it. NrZ)ruhows r\shutdownFakeSocket.shutdownr[cg)z Close is not implemented. The method is provided since real sockets have it and some code expects it. No behavior of L{FakeSocket} is affected by a call to it. NrZrus r\closeFakeSocket.closerr[cg)z Setsockopt is not implemented. The method is provided since real sockets have it and some code expects it. No behavior of L{FakeSocket} is affected by a call to it. NrZ)ruargss r\ setsockoptFakeSocket.setsockoptrr[cg)z Return a fake file descriptor. If actually used, this will have no connection to this L{FakeSocket} and will probably cause surprising results. rZrs r\filenoFakeSocket.filenos r[)ryrrrsN)__name__ __module__ __qualname____firstlineno____doc__rvrzrrrrrr__static_attributes__rZr[r\roros/!   r[roc*\rSrSrSrSrSrSrSrg)FakeSocketTestszL Test that the FakeSocket can be used by the doRead method of L{Connection} ct[S5nURS5 URURS5 g)NsomeDatar)rorz assertEqualryruskts r\ test_blockingFakeSocketTests.test_blockings,%  q)r[c\[S5nURURS5S5 g)Nr )rorrrs r\ test_recvFakeSocketTests.test_recvs$% "{3r[c[S5nURS5nURUS5 URURS/5 g)zp L{FakeSocket.send} accepts the entire string passed to it, adds it to its send buffer, and returns its length. r[sfooN)rorrrs)rurcounts r\ test_sendFakeSocketTests.test_sendsA o  " &2r[rZN) rrrrrrrrrrZr[r\rrs* 43r[rc\rSrSrSrSrSrg) FakeProtocolizD An L{IProtocol} that returns a value from its dataReceived method. cg)zY Return something other than L{None} to trigger a deprecation warning for that behavior. rZrZrts r\ dataReceivedFakeProtocol.dataReceiveds r[rZNrrrrrrrrZr[r\rrs r[rcH\rSrSrSrSrSrSrSrSr Sr S r S r S r g ) _FakeFDSetReactoriag An in-memory implementation of L{IReactorFDSet}, which records the current sets of active L{IReadDescriptor} and L{IWriteDescriptor}s. @ivar _readers: The set of L{IReadDescriptor}s active on this L{_FakeFDSetReactor} @type _readers: L{set} @ivar _writers: The set of L{IWriteDescriptor}s active on this L{_FakeFDSetReactor} @ivar _writers: L{set} c@[5Ul[5UlgrY)set_readers_writersrs r\rv_FakeFDSetReactor.__init__s  r[c:URRU5 grY)raddrureaders r\ addReader_FakeFDSetReactor.addReader! &!r[cZXR;aURRU5 ggrY)rremovers r\ removeReader_FakeFDSetReactor.removeReader$# ]] " MM  ( #r[c:URRU5 grY)rrruwriters r\ addWriter_FakeFDSetReactor.addWriter(rr[cZXR;aURRU5 ggrY)rrrs r\ removeWriter_FakeFDSetReactor.removeWriter+rr[chUR5UR5-nUR5 U$rY) getReaders getWritersrvruresults r\ removeAll_FakeFDSetReactor.removeAll/s("T__%66  r[c,[UR5$rY)listrrs r\r_FakeFDSetReactor.getReaders4DMM""r[c,[UR5$rY)rrrs r\r_FakeFDSetReactor.getWriters7rr[)rrN)rrrrrrvrrrrrrrrrZr[r\rrs/ ")") ##r[rc6\rSrSrSrSrSrSrSrSr Sr g ) TCPServerTestsi>z4 Whitebox tests for L{twisted.internet.tcp.Server}. c[5Ul"SS5n[S5Ul[ 5Ul[ URUR SU"5SUR5Ulg)Nc\rSrSrSrSrg)&TCPServerTests.setUp..FakePortiFrrZN)rrrr_realPortNumberrrZr[r\FakePortrFsOr[rr[)rUr)rreactorrorr0protocolr3server)rurs r\setUpTCPServerTests.setUpCsS(*   c?   HHdmmWhj$   r[cURR[[S555 URR S5 UR UR R/5 g)zY L{Server.write} discards bytes passed to it if called after it has lost its connection. Simulated lost connection hello worldN)rconnectionLostrI Exceptionwriterrrsrs r\test_writeAfterDisconnect(TCPServerTests.test_writeAfterDisconnectOsM ""795P+Q#RS .) ,,b1r[cFSURlUR5 g)z} L{Server.write} discards bytes passed to it if called after it has lost its connection when the connection had started TLS. TN)rTLSrrs r\!test_writeAfterDisconnectAfterTLS0TCPServerTests.test_writeAfterDisconnectAfterTLSXs   &&(r[cURR[[S555 URR S/5 UR UR R/5 g)za L{Server.writeSequence} discards bytes passed to it if called after it has lost its connection. rrN)rrrIr writeSequencerrrsrs r\!test_writeSequenceAfterDisconnect0TCPServerTests.test_writeSequenceAfterDisconnect`sP ""795P+Q#RS !!>"23 ,,b1r[cFSURlUR5 g)z L{Server.writeSequence} discards bytes passed to it if called after it has lost its connection when the connection had started TLS. TN)rrrrs r\)test_writeSequenceAfterDisconnectAfterTLS8TCPServerTests.test_writeSequenceAfterDisconnectAfterTLSis   ..0r[)rrrrN) rrrrrrrrrrrrZr[r\rr>s   2)21r[rcL\rSrSrSrSrSr\"\(+S5S5r Sr g) TCPConnectionTestsirz8 Whitebox tests for L{twisted.internet.tcp.Connection}. cB[S5n[5n[X5nUR5 UR [R /5nUR USS[5 UR USSS5 UR [U5S5 g)z| When an L{IProtocol} implementation that returns a value from its C{dataReceived} method, a deprecated warning is emitted. rrcategorymessagezReturning a value other than None from twisted.internet.test.test_tcp.FakeProtocol.dataReceived is deprecated since Twisted 11.0.0.rN) rorr2doRead flushWarningsrrDeprecationWarningr)rurrconnwarningss r\test_doReadWarningIsRaised-TCPConnectionTests.test_doReadWarningIsRaisedws %>#( %%|'@'@&AB !Z02DE  QK " 2 X*r[cz[S5n[5n[X5nURUR5 g)zg The C{TLS} attribute of a L{Connection} instance is C{False} before L{Connection.startTLS} is called. r[N)rorr2 assertFalserrurrrs r\test_noTLSBeforeStartTLS+TCPConnectionTests.test_noTLSBeforeStartTLSs0 o>#( "r[zNo SSL support availablec[S5n[5n[X[5S9nSUlUR [ 5S5 URUR5 g)ze The C{TLS} attribute of a L{Connection} instance is C{True} after L{Connection.startTLS} is called. r[rTN) rorr2r_tlsClientDefaultstartTLSrS assertTruerr s r\test_tlsAfterStartTLS(TCPConnectionTests.test_tlsAfterStartTLSsN o>#1B1DE!% *,d3 !r[rZN) rrrrrr rr useSSLrrrZr[r\rrrs/+&# J23 "4 "r[rc(\rSrSrSrSrSrSrSrg) TCPCreatorizG Create IPv4 TCP endpoints for L{runProtocolsWithReactor}-based tests. 127.0.0.1c,[USURS9$)z$ Create a server-side TCP endpoint. r interface)rr)rurs r\rTCPCreator.servers"'1GGr[cB[XRUR5$)zh Create a client end point that will connect to the given address. @type serverAddress: L{IPv4Address} )rrrl)rur serverAddresss r\riTCPCreator.clients "'>>=;M;MNNr[rZN) rrrrrrrrirrZr[r\rrsIH Or[rc\rSrSrSrSrSrg) TCP6Creatoria. Create IPv6 TCP endpoints for C{ReactorBuilder.runProtocolsWithReactor}-based tests. The endpoint types in question here are still the TCP4 variety, since these simply pass through IPv6 address literals to the reactor, and we are only testing address literals, not name resolution (as name resolution has not yet been implemented). See http://twistedmatrix.com/trac/ticket/4470 for more specific information about new endpoint classes. The naming is slightly misleading, but presumably if you're passing an IPv6 literal, you know what you're asking for. c"[5UlgrYrarrs r\rvTCP6Creator.__init__ 02r[rN)rrrrrrvrrZr[r\r#r#s  3r[r#cP\rSrSrSrS\\\44SjrS S\S\\ SS4S jjr S r g ) FakeResolverizJ A resolver implementation based on a C{dict} mapping names to addresses. namescXlgrYr*)rur*s r\rvFakeResolver.__init__s r[nametimeoutreturnz Deferred[str]c[URU5$![a [[ SU-55s$f=f)z Return the address mapped to C{name} if it exists, or raise a C{DNSLookupError}. @param name: The name to resolve. @param timeout: The lookup timeout, ignore here. zFakeResolver couldn't find )rr*KeyErrorrr!)rur.r/s r\ getHostByNameFakeResolver.getHostByNamesC N4::d+, , N'Dt'KLM M Ns !>>r,N)rZ) rrrrrrstrrvr intr3rrZr[r\r)r)sDgc3h/ N# N N N Nr[r)c`\rSrSrSr\4rSr\S5r \S5r Sr Sr Sr S rS rS rg) TCPClientTestsBaseiaU Base class for builders defining tests related to L{IReactorTCP.connectTCP}. Classes which uses this in must provide all of the documented instance variables in order to specify how the test works. These are documented as instance variables rather than declared as methods due to some peculiar inheritance ordering concerns, but they are effectively abstract methods. @ivar endpoints: A client/server endpoint creator appropriate to the address family being tested. @type endpoints: L{twisted.internet.test.connectionmixins.EndpointCreator} @ivar interface: An IP address literal to locally bind a socket to as well as to connect to. This can be any valid interface for the local host. @type interface: C{str} @ivar port: An unused local listening port to listen on and connect to. This will be used in conjunction with the C{interface}. (Depending on what they're testing, some tests will locate their own port with L{findFreePort} instead.) @type port: C{int} @ivar family: an address family constant, such as L{socket.AF_INET}, L{socket.AF_INET6}, or L{socket.AF_UNIX}, which indicates the address family of the transport type under test. @type family: C{int} @ivar addressClass: the L{twisted.internet.interfaces.IAddress} implementor associated with the transport type under test. Must also be a 3-argument callable which produces an instance of same. @type addressClass: C{type} @ivar fakeDomainName: A fake domain name to use, to simulate hostname resolution and to distinguish between hostnames and IP addresses where necessary. @type fakeDomainName: C{str} NcURb$URR5R$[URUR 5S$)z Return the port number to connect to, using C{self._port} set up by C{listen} if available. @return: The port number to connect to. @rtype: C{int} r)_portgetHostrlr@rfamilyrs r\rlTCPClientTestsBase.port sA :: !::%%',, ,DNNDKK8;;r[c.URR$)z; Return the interface attribute from the endpoints object. ) endpointsrrs r\rTCPClientTestsBase.interfaces ~~'''r[cXURSX RS9UlUR$)z Start a TCP server with the given C{factory}. @param reactor: The reactor to create the TCP port in. @param factory: The server factory. @return: A TCP port instance. rr) listenTCPrr:rurfactorys r\listenTCPClientTestsBase.listen!s)&&q'^^&L zzr[cPURURURU5$)z Start a TCP client with the given C{factory}. @param reactor: The reactor to create the connection in. @param factory: The client factory. @return: A TCP connector instance. ) connectTCPrrlrCs r\rhTCPClientTestsBase.connect.s!!!$..$))WEEr[c^^ ^ ^ [5m TR5m [5nT Ul[ TT 5 "SS[ 5m TR RT 5RU5nU U U4SjnURU5nU4SjnSnURXV5 U 4SjnURU5nUR[R5 U 4Sjn URU 5 TRT 5 g) zZ When the factory's C{buildProtocol} returns L{None} the connection is gracefully closed. c\rSrSrSrSrg)ETCPClientTestsBase.test_buildProtocolReturnsNone..NoneFactoryiGcgrYrZ)rurms r\ buildProtocolSTCPClientTestsBase.test_buildProtocolReturnsNone..NoneFactory.buildProtocolHsr[rZNrrrrrNrrZr[r\ NoneFactoryrLGs r[rQc>T"5nTRRTUR55nURU5$rY)r?rir;rh)rl clientFactoryendpointrQrrus r\listenedBTCPClientTestsBase.test_buildProtocolReturnsNone..listenedMs7'MM~~,,WdllnEH##M2 2r[c2>TRSU<S35 g)Nz.Stream client endpoint connect succeeded with z%, should have failed with NoProtocol.)r)rrus r\connectSucceededJTCPClientTestsBase.test_buildProtocolReturnsNone..connectSucceededTs II9AD r[c.UR[5 grY)trapr")reasons r\ connectFailedGTCPClientTestsBase.test_buildProtocolReturnsNone..connectFailedZs KK #r[c>T$rYrZ)ignoredrs r\ connectedCTCPClientTestsBase.test_buildProtocolReturnsNone..connected_s " !r[c&>TR5 grYstop)r`rs r\ disconnectedFTCPClientTestsBase.test_buildProtocolReturnsNone..disconnectedjs LLNr[N)r buildReactorrNprotocolConnectionLostrDr1r?rrE addCallback addCallbacks addErrbackrHerr runReactor) ru serverFactory listeningrU connectingrXr]ra disconnectingrfrQrrs ` @@@r\test_buildProtocolReturnsNone0TCPClientTestsBase.test_buildProtocolReturnsNone:s "##%') /= , D'" - NN))'299-H  3 **84    $  0@ " #..y9    )  !!,/  r[c^^ ^ ^ ^ ^ [TRTR5SSupTR5m TRm T R [ T TR055 T RS[R"[5US9m T R5nSSSS.m "U U 4SjS[5n[T 5m UT l U U U UU 4Sjn[T U5 TRT 5 T R (a)TR#T R R%55 S R'T S R(T S R*[-T S 55nU/[/[0R2"TRT R45SS S S5-nU/[/[0R2"TRUR65SS S S5-nTR9T S TR:"S/UQ765 TR9T STR:"S/UQ765 TR9[=T S 5U5 g)ar A client's transport's C{getHost} and C{getPeer} return L{IPv4Address} instances which have the dotted-quad string form of the resolved address of the local and remote endpoints of the connection respectively as their C{host} attribute, not the hostname originally passed in to L{connectTCP}, if a hostname was used. Nrr)rkpeerinstancec$>\rSrSrUU4SjrSrg)7TCPClientTestsBase.test_addresses..CheckAddressic|>UR5TS'UR5TS'UTS'TR5 g)Nrkrwrx)r;getPeerre)ru transportr transportDatas r\makeConnectionFTCPClientTestsBase.test_addresses..CheckAddress.makeConnections<(1(9(9(; f%(1(9(9(; f%,5 j) r[rZNrrrrrr)rr~sr\ CheckAddressrzs   r[rc(>[TRTR5nTRUS4n[R"SU35 TR TTR 5RTUS9 USTlg![a Mf=f)Nrz!Connect attempt with bindAddress ) bindAddress) r@rr<rHmsgrHr;rl boundPortr)rlrrS fakeDomainrrurs r\ connectMe4TCPClientTestsBase.test_addresses..connectMes#DNNDKK@#~~tAw7 ;K=IJ &&"(--%$/ '/31gM+ (s*B BBz<{} to {} at {:x}>rxrrkTCPrw)r@rr<rhfakeDomainNameinstallResolverr)rBr1 forProtocolr0r;r>rrCrn failReasonr getTracebackformat __class__addridrrfrgrrlr addressClassrepr)rurkr`r rr transportReprr serverPortrSrrrr~s` @@@@@r\test_addresses!TCPClientTestsBase.test_addressesus!%T^^T[[A"1E ##%((  j$..-I JK"" }((2d# ( !%tF   8 W !-   $ GY/   # # IIm..;;= >,33 * % / / * % * * }Z( ) FT   t~~}/F/F G J2 Nqr R  Vd   t~~}/A/A B1 Eb I!" M   v.0A0A%0T)0TU v.0A0A%0U*0UV mJ78-Hr[c^^^^^ ^ ^ TR5m [5m/m [R"[5nT R SUTR S9nTRRT UR55n[5n[Ul URU5mUU U4Sjm U 4SjmUUU U 4Sjn[T U5 TRT 5 TR[!T 5SST 35 [#T S[$5(aT SR'5 T SS:Xa [)S 5eTR[R*[-T S55 g ) z If the context factory passed to L{ITCPTransport.startTLS} raises an exception from its C{getContext} method, that exception is raised by L{ITCPTransport.startTLS}. rrc>[R"UR5(dTRS5 gTRTR [ URR T55 g)Nskip)r. providedByr}r assertRaises ValueErrorr)r brokenFactoryresultsrus r\ra5TCPClientTestsBase.test_badContext..connectedsS ++H,>,>??v&%%"H$6$6$?$?r[c(>TRU5 grYr)failurers r\r]9TCPClientTestsBase.test_badContext..connectFaileds NN7 #r[ct>TRT5 TRT5 TRU4Sj5 g)Nc$>TR5$rYrdignrs r\r]ETCPClientTestsBase.test_badContext..whenRun..s  r[)rjrladdBoth)connectDeferredr]rarsr\whenRun3TCPClientTestsBase.test_badContext..whenRuns.  ' ' 2  & &} 5  # #$> ?r[rzmore than one callback result: rz&Reactor does not support ITLSTransportN)rhr9r1rr0rBrr?rir;r/rrhrCrnrr isinstancerIraiseExceptionrOrr5) rurorlrTrSrrrr]rarrs ` @@@@@@r\test_badContext"TCPClientTestsBase.test_badContexts* ##%,. %11(;   MT^^ L>>(($,,.A% !) "**=9  $ @ @ GW-   Wq,KG9*UV gaj' * * AJ % % ' 1: CD D -55s71:Gr[)r:)rrrrrr+requiredInterfacesr:propertyrlrrErhrsrrrrZr[r\r8r8s\$L& E  < <((  F9!vHIT0Hr[r8cF\rSrSrSrSr\Rr\ r \ "5r Sr g)TCP4ClientTestsBuilderizY Builder configured with IPv4 parameters for tests related to L{IReactorTCP.connectTCP}. zsome-fake.domain.example.comrZN)rrrrrrrfAF_INETr<rrrr?rrZr[r\rrs# 4N ^^FL Ir[rc:\rSrSrSr\R r\r Sr Sr g)TCP6ClientTestsBuilderizY Builder configured with IPv6 parameters for tests related to L{IReactorTCP.connectTCP}. cX[5UlURRUlgrY)r#r?rrrs r\rTCP6ClientTestsBuilder.setUp s!%#nn66r[)r?rN) rrrrrrfAF_INET6r<rrrrrZr[r\rrs __FL 7r[rc0\rSrSrSr\4rSrSrSr Sr g)TCPConnectorTestsBuilderizM Tests for the L{IConnector} provider returned by L{IReactorTCP.connectTCP}. c^^^ [5nUR5mTRSXRS9nX!lUR 5Rn/m/m [ 5nUU 4SjUlTRUl TRURX45nUR[R"U55 UR5nURUR S5 URUR"UR5 URURU5 UR$R'U4Sj5 UR)T5 T SR+[,5 URTXU/5 g)a% L{IReactorTCP.connectTCP} returns an object which provides L{IConnector}. The destination of the connector is the address which was passed to C{connectTCP}. The same connector object is passed to the factory's C{startedConnecting} method as to the factory's C{clientConnectionLost} method. rrcH>TRU5TRU54$rYr) connectorr\seenConnectors seenFailuress r\r]ATCPConnectorTestsBuilder.test_connectorIdentity../s%  ! !) ,    'H r[rc$>TR5$rYrd_rs r\r]r< GLLNr[N)rLrhrBrrlr;rKclientConnectionLostrstartedConnectingrHrr$rgetDestinationrtyperk whenStoppedrrnr[r) rurotcpPort portNumberrSrdestrrrs @@@r\test_connectorIdentity/TCPConnectorTestsBuilder.test_connectorIdentitys9'( ##%##A}#O$__&++  .0 . *+9*?*? '&&t~~zQ   --i89'') E* DNN3 J/!!))*BC  Q^, ))?@r[c8^^^^^[5nTR5mTRSUTRS9nUR 5R m/mUU4Sjn[ 5mUTlTRRU4Sj5 TRUUUU4Sj5 TRT5 T(a"TRTSR55 TRR[ 5 TR#TR$S5 g)z Calling L{IConnector.stopConnecting} in C{Factory.startedConnecting} results in C{Factory.clientConnectionFailed} being called with L{error.UserError} as the reason. rrc>UR5 g![a, TR[55 TR 5 gf=frY)stopConnectingrrrIre)r fatalErrorsrs r\rATCPConnectorTestsBuilder.test_userFail..startedConnectingPs< ((* ""79-  s3A  A c$>TR5$rYrdrs r\r]8TCPConnectorTestsBuilder.test_userFail..Zrr[c>>TRTRTT5$rY)rHr)rSrrrusr\r]r]sG&&t~~z=Qr[rN)rNrhrBrr;rlrKrrrcallWhenRunningrnrrr\r[r#rfailed)rurorrrSrrrs` @@@@r\ test_userFail&TCPConnectorTestsBuilder.test_userFailCs () ##%##A}#O__&++   /0 *; '!!))*BC Q    IIk!n113 4!!), --q1r[c^^^[5nUR5mTRSXRS9nX!lUR 5Rn[ 5mSnUTlTRURUT5 /mUUU4SjnTRRU5 URT5 TRR[5 URTS/5 g)zn Calling L{IConnector.connect} in C{Factory.clientConnectionLost} causes a new connection attempt to be made. rrc$UR5 grY)rh)rr\s r\rETCPConnectorTestsBuilder.test_reconnect..clientConnectionLostts    r[c>TRnTRURUR45 TR 5 grY) lastProtocolrmadeclosedre)r`prSprotocolMadeAndClosedrs r\reconnectFailed@TCPConnectorTestsBuilder.test_reconnect..reconnectFailed|s2**A ! ( (!&&!((); < LLNr[)rrN)rLrhrBrrlr;rMrrH failDeferredrjrnr\r[r r) rurorrrrrSrrs @@@r\test_reconnect'TCPConnectorTestsBuilder.test_reconnectgs '( ##%##A}#O$__&++ ')  .B *4>>:}E "  ""..?  !!"89 .9r[rZN) rrrrrr+rrrrrrZr[r\rrs#&$AL"2H:r[rc4\rSrSrSr\R r\r Sr g)TCP4ConnectorTestsBuilderirrZN) rrrrrrfrr<rrrrZr[r\rrsI ^^FLr[rc6\rSrSr\R r\rSr Sr g)TCP6ConnectorTestsBuilderic"[5UlgrYr%rs r\rTCP6ConnectorTestsBuilder.setUpr'r[rN) rrrrrfrr<rrrrrZr[r\rrs __FL3r[rch[R"X5nURUR5 U$)z Create a socket for the duration of the given test. @param test: the test to add cleanup to. @param addressFamily: an C{AF_*} constant @param socketType: a C{SOCK_*} constant. @return: a socket object. )rf addCleanupr)test addressFamily socketTypers r\createTestSocketrs' -- 2COOCII Jr[c*\rSrSrSrSrSrSrSrg)_IExhaustsFileDescriptorsiz A way to trigger C{EMFILE}. cg)z Open file descriptors until C{EMFILE} is reached. This can raise any exception except an L{OSError} whose C{errno} is C{EMFILE}. Any exception raised to the caller implies L{release}. NrZrZr[r\exhaust!_IExhaustsFileDescriptors.exhaustrr[cgz4 Release all file descriptors opened by L{exhaust}. NrZrZr[r\release!_IExhaustsFileDescriptors.releaserr[cg) Return the number of opened file descriptors. @return: The number of opened file descriptors; this will be zero if this instance has not opened any. @rtype: L{int} NrZrZr[r\r_IExhaustsFileDescriptors.countrr[rZN rrrrrrrrrrZr[r\rrs   r[r) auto_attribsc"\rSrSr%Sr\"5r\\\S'\ R"SSS9r \ /\ 4\S'\ R"\RSS9r\ \ /S4\S '\ R"\ R""\5SSS 9r\\ \S 'S rS rSrSrg)_ExhaustsFileDescriptorsia? A class that triggers C{EMFILE} by creating as many file descriptors as necessary. @ivar fileDescriptorFactory: A factory that creates a new file descriptor. @type fileDescriptorFactory: A L{callable} that accepts no arguments and returns an integral file descriptor, suitable for passing to L{os.close}. _logc.[R"S5$Nr)osduprZr[r\r]!_ExhaustsFileDescriptors.s q r[F)defaultr_fileDescriptorFactoryN_close)rinitr_fileDescriptorsc[R"5 UR5nURR U5 M.![ a)nUR [ R:XaSnAO eSnAff=fURRSUR5S9 g![a UR5 ef=f)z3 Open file descriptors until C{EMFILE} is reached. NzCEMFILE reached by opening {openedFileDescriptors} file descriptors.)openedFileDescriptors) gccollectrrrOSErrorerrnoEMFILEr inforrrrufdes r\r _ExhaustsFileDescriptors.exhausts  5446B ))004ww%,,. IINN=&*jjl     LLN  s9B%AB% A9A4.B%3A44A99B%%CcUR(a@URR5nURU5 UR(aM?gg![a*nUR[R :XaSnAMeSnAff=fr)rpoprrrEBADFrs r\r _ExhaustsFileDescriptors.releasesg##&&**,B  B### 77ekk) sA BBBBc,[UR5$)r)rrrs r\r_ExhaustsFileDescriptors.counts4(())r[rZ)rrrrrrGr r__annotations__attribrrr6rrrFactoryrrrrrrrrZr[r\r r s $XD(6 %04!1HRW-%)GGBHH5$IFHcUD[ !I"&'' T"U#d3i4 *r[r 9Reserved EMFILE file descriptor not supported on Windows.cT\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rg)ExhaustsFileDescriptorsTestsiz( Tests for L{_ExhaustsFileDescriptors}. cl[5UlURURR5 grY)r  exhausterrrrs r\r"ExhaustsFileDescriptorsTests.setUps$13 ../r[cR[[R5R5 g)zH Attempt to open a file; if successful, the file is immediately closed. N)openrdevnullrrs r\ openAFile&ExhaustsFileDescriptorsTests.openAFiles RZZ r[c8[[UR5 g)zM L{_ExhaustsFileDescriptors} instances provide L{_IExhaustsFileDescriptors}. N)rrr0rs r\test_providesInterface3ExhaustsFileDescriptorsTests.test_providesInterface"s .?r[chURURR5S5 URR5 UR URR5S5 URR 5 URURR5S5 g)zP L{_ExhaustsFileDescriptors.count} returns the number of open file descriptors. rN)rr0rr assertGreaterrrs r\ test_count'ExhaustsFileDescriptorsTests.test_count)s{ --/3   4>>//115   --/3r[cURURR5 URR5 UR [ UR 5nURUR[R5 g)zc L{_ExhaustsFileDescriptors.exhaust} causes the process to exhaust its available file descriptors. N) rr0rrrIOErrorr5rrr)ru exceptions r\test_exhaustTriggersEMFILE7ExhaustsFileDescriptorsTests.test_exhaustTriggersEMFILE4sX ../  %%gt~~>  %,,7r[c`Sn[U5nUR[UR5 g)z An L{OSError} raised within L{_ExhaustsFileDescriptors.exhaust} with an C{errno} other than C{EMFILE} is reraised to the caller. c<[[RS-S5e)Nrz Not EMFILE)rrrrZr[r\ raiseOSErrorLExhaustsFileDescriptorsTests.test_exhaustRaisesOSError..raiseOSErrorEs%,,*L9 9r[N)r rrr)rurEr0s r\test_exhaustRaisesOSError6ExhaustsFileDescriptorsTests.test_exhaustRaisesOSError>s) :-\:  '9#4#45r[cURR5 URR5 UR5 g)zK L{_ExhaustsFileDescriptors.release} releases all opened file descriptors. N)r0rrr5rs r\ test_release)ExhaustsFileDescriptorsTests.test_releaseKs.     r[c^/mU4Sjn[U5nURUR5 UR[UR 5 UR [T5S5 UR UR5S5 THRnUR[[RU5nUR UR[R5 MT g)z{ L{_ExhaustsFileDescriptors.exhaust} closes any opened file descriptors if an exception occurs during its exhaustion loop. c>[T5S:Xa [S5e[R"S5nTR U5 U$)Nrz9test_fileDescriptorsReleasedOnFailure fake open exceptionr)rrrrrrfileDescriptorss r\failsAfterThree[ExhaustsFileDescriptorsTests.test_fileDescriptorsReleasedOnFailure..failsAfterThree\sB?#q( RVVAY&&r* r[rrN)r rrrrrrrrrrfstatrr$)rurPr0rr@rOs @r\%test_fileDescriptorsReleasedOnFailureBExhaustsFileDescriptorsTests.test_fileDescriptorsReleasedOnFailureUs  -_=   ))* *i&7&78 _-q1 *A.!B))'288R@I   Y__ekk :"r[cT^/mU4Sjn[U5nURUR5 UR5 UR UR 5S5 [ R"TS5 UR5 URUR 5S5 g)z{ L{_ExhaustsFileDescriptors.release} continues to close opened file descriptors even when closing one fails with C{EBADF}. cV>[R"S5nTRU5 U$r )rrrrNs r\recordFileDescriptorsTExhaustsFileDescriptorsTests.test_releaseIgnoresEBADF..recordFileDescriptorsxs#B  " "2 &Ir[rN) r rrrr;rrrr)rurWr0rOs @r\test_releaseIgnoresEBADF5ExhaustsFileDescriptorsTests.test_releaseIgnoresEBADFqs   --BC   ))* 9??,a0 #$ *A.r[c^/mU4SjnSn[XS9nURUR5S5 UR5 UR UR5S5 UR [ UR5 g)z An L{OSError} raised within L{_ExhaustsFileDescriptors.release} with an C{errno} other than C{EBADF} is reraised to the caller. c>[T5S:Xa[[RS5eTR S5 TS$)NrzToo many filesr)rrrrr)fakeFileDescriptorssr\ opensThreeJExhaustsFileDescriptorsTests.test_releaseRaisesOSError..opensThrees<&'1,ell,<==  & &r *&r* *r[c[SS5e)N z&test_releaseRaisesOSError fake OSError)r)rs r\ failingCloseLExhaustsFileDescriptorsTests.test_releaseRaisesOSError..failingCloses"FG Gr[)rrN)r rrrr;rrr)rur^rbr0r]s @r\test_releaseRaisesOSError6ExhaustsFileDescriptorsTests.test_releaseRaisesOSErrorsr ! +  H-ZL  *A. 9??,a0 '9#4#45r[)r0N)rrrrrrr5r8r<rArGrJrSrYrdrrZr[r\r.r.s:0 !@ 48 6;8/.6r[r.cv^^^^^ ^^URTR5 [5m[5nUTlS/mUU4SjnUR U5 [ 5m [R"T5(a*U UUUUU4SjnTRSTRSU5 O>T"TT5n U R5n T"TU T 5 TRTR5 UU4Sjn T RRU 5 T RRU 5 U"T5 /n URU R 5 UR#U S5 UR%T R5 UR'T R5 UR)[*T R,R.5 g)a Assert that an L{IListeningPort} immediately closes an accepted peer socket when the number of open file descriptors exceeds the soft resource limit. @param testCase: The test case under which to run this assertion. @type testCase: L{trial.unittest.SynchronousTestCase} @param exhauster: The file descriptor exhauster. @type exhauster: L{_ExhaustsFileDescriptors} @param reactor: The reactor under test. @param runReactor: A callable that will synchronously run the provided reactor. @param listen: A callback to bind to a port. @type listen: A L{callable} that accepts two arguments: the provided C{reactor}; and a L{ServerFactory}. It must return an L{IListeningPort} provider. @param connect: A callback to connect a client to the listening port. @type connect: A L{callable} that accepts three arguments: the provided C{reactor}; the address returned by L{IListeningPort.getHost}; and a L{ClientFactory}. Its return value is ignored. Fc0>TR5 STS'g)NTrrd)rrserverConnectionCompleteds r\stopReactorIfServerAccepted=assertPeerClosedOnEMFILE..stopReactorIfServerAccepteds '+!!$r[cl>T"TT5nUR5nT"TUT5 TR5 grY)r;r)rl listeningHostrSrhr0rErros r\inner'assertPeerClosedOnEMFILE..inners2'=1D LLNM G]M :    r[rcH>TR5 TR5 U$rY)rre)rr0rs r\"stopReactorAndCloseFileDescriptorsDassertPeerClosedOnEMFILE..stopReactorAndCloseFileDescriptorss  r[z1Server accepted connection; EMFILE not triggered.N)rrrNrprotocolConnectionMaderjrMr,r callLaterr;rrdeferredrrrr assertNoResultsuccessResultOfrr lostReasonr)testCaser0rrnrErhserverConnectionMaderirmrlrlrpnoResultrSrhros `` `` @@@r\assertPeerClosedOnEMFILEr{sqH  ))*#%M#:+?M(!&,$$%@A#%Mw''   !W..59g}-   6 1 12 ""#EF&&'IJwH  1 #VW M667 ]334   //r[cT\rSrSrSr\"\5"SS55rSrSr Sr Sr g ) AssertPeerClosedOnEMFILETestsiz( Tests for L{assertPeerClosedOnEMFILE}. c*\rSrSrSrSrSrSrSrg)+AssertPeerClosedOnEMFILETests.NullExhausteriz! An exhauster that does nothing. cg)z* See L{_IExhaustsFileDescriptors.exhaust} NrZrs r\r3AssertPeerClosedOnEMFILETests.NullExhauster.exhaust rr[cg)z* See L{_IExhaustsFileDescriptors.release} NrZrs r\r3AssertPeerClosedOnEMFILETests.NullExhauster.releaserr[cg)z( See L{_IExhaustsFileDescriptors.count} NrZrs r\r1AssertPeerClosedOnEMFILETests.NullExhauster.countrr[rZNrrZr[r\ NullExhausterrs      r[rc@[5Ul[5UlgrY)rErrPrxrs r\r#AssertPeerClosedOnEMFILETests.setUps$ +- r[c@[[UR55 g)zB L{NullExhauster} instances provide L{_IExhaustsFileDescriptors}. N)rrrrs r\#test_nullExhausterProvidesInterfaceAAssertPeerClosedOnEMFILETests.test_nullExhausterProvidesInterfaces .0B0B0DEr[c N^UR5nS/mU4SjnU4SjnSnURURR[URUUR UUUS9nUR S[U55 URUR R5 g)z} If the exhauster fails to trigger C{EMFILE} and a connection reaches the server, the reactor is stopped and the test fails. Nc>UR5 TSR[SSS55nUR[ 55 g)Nrrri)runrNrrrF)rprotoros r\rn[AssertPeerClosedOnEMFILETests.test_reactorStoppedOnSuccessfulConnection..runReactor+s@ KKM!!$22E;5E  !2 3r[cX>URSSU5nUR5 UTS'U$)Nrir)rBdoStart)rrDrlros r\rEWAssertPeerClosedOnEMFILETests.test_reactorStoppedOnSuccessfulConnection..listen2s0$$[$@D OO &M! Kr[c*URSSU5 g)Nrr)rH)rrmrDs r\rhXAssertPeerClosedOnEMFILETests.test_reactorStoppedOnSuccessfulConnection..connect8s   {Aw 7r[rxr0rrnrErhr) rrrxfailureExceptionr{rassertInr5r running)rur0rnrErhr@ros @r\)test_reactorStoppedOnSuccessfulConnectionGAssertPeerClosedOnEMFILETests.test_reactorStoppedOnSuccessfulConnection#s &&(   4   8%% MM * * $]]LL!&   hI/ --.r[)rrxN) rrrrrrrrrrrrrZr[r\r}r}s6*+,(.F$/r[r}cB\rSrSrSrSrSr\"\S5S5r Sr g) StreamTransportTestsMixiniJzJ Mixin defining tests which apply to any port/connection based transport. c UR5nUR5n[[5"SS[55nU"5nUR X$5nUR US5nURU4USS5 g)z\ When a port starts, a message including a description of the associated factory is logged. c\rSrSrSrSrg)NStreamTransportTestsMixin.test_startedListeningLogMessage..SomeFactoryiWcg)N Crazy FactoryrZrs r\ logPrefixXStreamTransportTestsMixin.test_startedListeningLogMessage..SomeFactory.logPrefixYs&r[rZN)rrrrrrrZr[r\ SomeFactoryrWs 'r[rrrrN)observerhrr&r1getListeningPort#getExpectedStartListeningLogMessager)ruloggedMessagesrrrDrexpectedMessages r\test_startedListeningLogMessage9StreamTransportTestsMixin.test_startedListeningLogMessageOs ##% _ % '- ' & '-  ! !' 3BB1oV /+^A->y-IJr[cD^^^^^/mU4SjmUR5mURT[55mURT5n[R "T5 UU4SjmUUU4SjnTR U5 TR5 URUT5 g)z When a connection is lost, an informative message should be logged (see L{getExpectedConnectionLostLogMsg}): an address identifying the port and the fact that it was closed. cP>TR[R"U55 grY)rrHtextFromEventDict) eventDictrs r\logConnectionLostMsgQStreamTransportTestsMixin.test_connectionLostLogMsg..logConnectionLostMsgjs  ! !#"7"7 "B Cr[cR>[R"T5 TR5 grY)rHremoveObserverre)r`rrs r\ stopReactorHStreamTransportTestsMixin.test_connectionLostLogMsg..stopReactorrs   3 4 LLNr[cz>[R"T5 [TR5R T5 grY)rH addObserverr stopListeningrj)rrrsr\doStopListeningLStreamTransportTestsMixin.test_connectionLostLogMsg..doStopListeningvs' OO0 1 !// * 6 6{ Cr[N) rhrr1getExpectedConnectionLostLogMsgrHrrrr)rurrrrrrrs @@@@@r\test_connectionLostLogMsg3StreamTransportTestsMixin.test_connectionLostLogMsgas D##%  ! !'=? ;>>qA ,-  D 0  o~6r[r,c [U[5UR5URURUR S9 g)z" See L{assertPeerClosedOnEMFILE}. rN)r{r rhrnrconnectToListenerrs r\test_closePeerOnEMFILE0StreamTransportTestsMixin.test_closePeerOnEMFILEs: !.0%%'((**  r[rZN) rrrrrrrr SKIP_EMFILErrrZr[r\rrJs/K$7< KTU  V  r[rc"\rSrSrSrSrSrSrg)ConnectToTCPListenerMixiniaB Provides L{connectToListener} for TCP transports. @ivar LISTENER_HOST: The host on which the port is expected to be listening. This is specific to avoid compatibility issues with Windows, which cannot connect to the wildcard host. @type LISTENER_HOST: L{str} @see: U{http://twistedmatrix.com/trac/ticket/1472} rcPURURURU5$)al Connect to the given listening TCP port. @param reactor: The reactor under test. @type reactor: L{IReactorTCP} @param address: The listening port's address. Only the C{port} component is used; see L{LISTENER_HOST}. @type address: L{IPv4Address} or L{IPv6Address} @param factory: The client factory. @type factory: L{ClientFactory} @return: The connector )rH LISTENER_HOSTrl)rurrmrDs r\r+ConnectToTCPListenerMixin.connectToListeners# !!$"4"4gllGLLr[rZN)rrrrrrrrrZr[r\rrs  MMr[rc"\rSrSrSrSSjrSrg)ListenTCPMixinizL Mixin which uses L{IReactorTCP.listenTCP} to hand out listening TCP ports. c"URX2US9$)z Get a TCP port from a reactor. r)rB)rurrDrlrs r\rListenTCPMixin.getListeningPorts  ) DDr[rZNrrUrrrrrrrrZr[r\rrs Er[rc"\rSrSrSrSSjrSrg)SocketTCPMixinizU Mixin which uses L{IReactorSocket.adoptStreamPort} to hand out listening TCP ports. cN[R"U5(aSU;a-[Rn[R"XC5SSnO[R nXC4n[R"U5nUR U5 URS5 URS5 URUR5URU5UR5 UR5 $[S5e!UR5 UR5 f=f)zQ Get a TCP port from a reactor, wrapping an already-initialized file descriptor. rdrrerFz'Reactor does not provide IReactorSocket)r*rrfrrgrbindrErzadoptStreamPortrr<rrO)rurrDrlrdomainrmportSocks r\rSocketTCPMixin.getListeningPorts  $ $W - -i ,,Y=a@C$+}}V,H MM' " OOA    ' !..OO%x ! DE E ! s ,*D"D$rZNrrrZr[r\rrs  Fr[rc\\rSrSr%Sr\4r\\\ \ \ S'Sr Sr Sr\"\\5S5r\"\\5S5rS rS r\"\\5S 5r\"\\5S 5rS rSr\"\\5S5r\"\\5S5rSr\"\\5S5r\"\\5S5rSrg)TCPPortTestsMixiniz$ Tests for L{IReactorTCP.listenTCP} rc>SX!R5R4-$)zI Get the message expected to be logged when a TCP port starts listening. z%s starting on %dr;rl)rurlrDs r\r5TCPPortTestsMixin.getExpectedStartListeningLogMessages#g||~/B/B%CCCr[c>SUR5RS3$)z: Get the expected connection lost message for a TCP port. z (TCP Port z Closed)r)rurls r\r1TCPPortTestsMixin.getExpectedConnectionLostLogMsgs DLLN//099r[cUR5nURU[55nUR5nUR U[ 5 g)zr When no interface is passed to L{IReactorTCP.listenTCP}, the returned listening port listens on an IPv4 address. N)rhrr1r;assertIsInstancer)rurrlrms r\test_portGetHostOnIPv4(TCPPortTestsMixin.test_portGetHostOnIPv4sA ##%$$Wmo>,,. g{3r[cNUR5n[[RSS9SSup#UR U[ 5X25nUR 5nURU[5 URSUR5 URX5R5 g)z When listening on an IPv6 address, L{IListeningPort.getHost} returns an L{IPv6Address} with C{host} and C{port} attributes reflecting the address the port is bound to. rT)r<rNrv) rhr@rfrrr1r;rrrrkrl)rurrkrrlrms r\test_portGetHostOnIPv6(TCPPortTestsMixin.test_portGetHostOnIPv6s##%'v%PQSRST$$WmozP,,. g{3  - \\2r[c[5nUR5nURU[5SU5nUR 5nUR U[ 5 URXR5 g)a When a link-local IPv6 address including a scope identifier is passed as the C{interface} argument to L{IReactorTCP.listenTCP}, the resulting L{IListeningPort} reports its address as an L{IPv6Address} with a host value that includes the scope identifier. rN) rarhrr1r;rrrrk)ru linkLocalrrlrms r\test_portGetHostOnIPv6ScopeID/TCPPortTestsMixin.test_portGetHostOnIPv6ScopeID s_,- ##%$$Wmoq)L,,. g{3 LL1r[c^"U4SjS[5nU"5nUR5mURTUSU5nURS5 [ XR 5R UR 5R45 URT5 UR$![aDnURUR[R[R45 SnANfSnAff=f)a Connect C{client} to a server listening on C{interface} started with L{IReactorTCP.listenTCP} and return the address passed to the factory's C{buildProtocol} method. @param client: A C{SOCK_STREAM} L{socket.socket} created with an address family such that it will be able to connect to a server listening on C{interface}. @param interface: A C{str} giving an address for a server to listen on. This should almost certainly be the loopback address for some address family supported by L{IReactorTCP.listenTCP}. @return: Whatever object, probably an L{IAddress} provider, is passed to a server factory's C{buildProtocol} method when C{client} establishes a connection. c">\rSrSrU4SjrSrg)CTCPPortTestsMixin._buildProtocolAddressTest..ObserveAddressi.cD>TR5 Xl[5$rY)reobservedAddressr0)rurmrs r\rNQTCPPortTestsMixin._buildProtocolAddressTest..ObserveAddress.buildProtocol/s '.$z!r[)rNrPrsr\ObserveAddressr.s  " "r[rrFN)r1rhrrzrhr;rkrlrrr EINPROGRESS EWOULDBLOCKrnr)rurirrrDrlr rs @r\_buildProtocolAddressTest+TCPPortTestsMixin._buildProtocolAddressTests& "] " !"##%$$Wgq)D5! K F\\^00$,,.2E2EF G  &&&  K MM!''E$5$5u7H7H#I J J Ks=B++ C95:C44C9cSn[U[R[R5nUR X!5nUR [ S/UR5Q76U5 g)z When a connection is accepted over IPv4, an L{IPv4Address} is passed to the factory's C{buildProtocol} method giving the peer's address. rrN)rrfr SOCK_STREAMrrr getsockname)rurrirs r\test_buildProtocolIPv4Address/TCPPortTestsMixin.test_buildProtocolIPv4AddressAsT  !$8J8JK88K UBV-?-?-ABOTr[c*Sn[U[R[R5nUR X!5nUR 5n[R "U[R5SnUR[SXTS5U5 g)z When a connection is accepted to an IPv6 address, an L{IPv6Address} is passed to the factory's C{buildProtocol} method giving the peer's address. rTrrrN) rrfrrrr getnameinfoNI_NUMERICHOSTrrrurrirrwhostnames r\test_buildProtocolIPv6Address/TCPPortTestsMixin.test_buildProtocolIPv6AddressKsw !$9K9KL88K!!#%%dF,A,AB1E UH1g>Pr[c<[5n[U[R[R5nUR X!5nUR 5n[R"U[R5SnUR[SU/USSQ76U5 g)z When a connection is accepted to a link-local IPv6 address, an L{IPv6Address} is passed to the factory's C{buildProtocol} method giving the peer's address, including a scope identifier. rrrN) rarrfrrrrrrrrrs r\$test_buildProtocolIPv6AddressScopeID6TCPPortTestsMixin.test_buildProtocolIPv6AddressScopeID[s,- !$9K9KL88K!!#%%dF,A,AB1E UH@tABx@/Rr[c^^"UU4SjS[5nUR5m[5nXElUR TUSU5nUR S5 [ XR5RUR5R45 URT5 UR $![aDnURUR[R[R45 SnANfSnAff=f)a% Connect C{client} to a server listening on C{interface} started with L{IReactorTCP.listenTCP} and return the address returned by one of the server transport's address lookup methods, C{getHost} or C{getPeer}. @param client: A C{SOCK_STREAM} L{socket.socket} created with an address family such that it will be able to connect to a server listening on C{interface}. @param interface: A C{str} giving an address for a server to listen on. This should almost certainly be the loopback address for some address family supported by L{IReactorTCP.listenTCP}. @param which: A C{str} equal to either C{"getHost"} or C{"getPeer"} determining which address will be returned. @return: Whatever object, probably an L{IAddress} provider, is returned from the method indicated by C{which}. c$>\rSrSrUU4SjrSrg)ITCPPortTestsMixin._serverGetConnectionAddressTest..ObserveAddressicf>TR5 [UT5"5URlgrY)regetattrrDrm)rur}rwhichs r\rXTCPPortTestsMixin._serverGetConnectionAddressTest..ObserveAddress.makeConnections" '.y%'@'B $r[rZNr)rrsr\rrs C Cr[rrFN)r0rhr1rrrzrhr;rkrlrrrrrrnrm) rurirrrrDrlr rs ` @r\_serverGetConnectionAddressTest1TCPPortTestsMixin._serverGetConnectionAddressTestks* C CX C ##%/)$$Wgq)D5! K F\\^00$,,.2E2EF G   K MM!''E$5$5u7H7H#I J J Ks=B66 D:C??DcSn[U[R[R5nUR X!S5nUR [ S/UR5Q76U5 g)z When a connection is accepted over IPv4, the server L{ITransport.getHost} method returns an L{IPv4Address} giving the address on which the server accepted the connection. rr;rN)rrfrrr rr getpeername)rurri hostAddresss r\test_serverGetHostOnIPv4*TCPPortTestsMixin.test_serverGetHostOnIPv4V  !$8J8JK::6iX  UBV-?-?-ABKPr[c.Sn[U[R[R5nUR X!S5nUR 5n[R "U[R5SnUR[SU/USSQ76U5 g)z When a connection is accepted over IPv6, the server L{ITransport.getHost} method returns an L{IPv6Address} giving the address on which the server accepted the connection. rTr;rrrN) rrfrrr r rrrrrurrirrwrs r\test_serverGetHostOnIPv6*TCPPortTestsMixin.test_serverGetHostOnIPv6 !$9K9KL::6iX !!#%%dF,A,AB1E UH@tABx@+Nr[c>[5n[U[R[R5nUR X!S5nUR 5n[R"U[R5SnUR[SU/USSQ76U5 g)z When a connection is accepted over IPv6, the server L{ITransport.getHost} method returns an L{IPv6Address} giving the address on which the server accepted the connection, including the scope identifier. r;rrrN) rarrfrrr r rrrrrs r\test_serverGetHostOnIPv6ScopeID1TCPPortTestsMixin.test_serverGetHostOnIPv6ScopeID,- !$9K9KL::6iX !!#%%dF,A,AB1E UH@tABx@+Nr[cSn[U[R[R5nUR X!S5nUR [ S/UR5Q76U5 g)z When a connection is accepted over IPv4, the server L{ITransport.getPeer} method returns an L{IPv4Address} giving the address of the remote end of the connection. rr|rN)rrfrrr rrr)rurri peerAddresss r\test_serverGetPeerOnIPv4*TCPPortTestsMixin.test_serverGetPeerOnIPv4rr[c.Sn[U[R[R5nUR X!S5nUR 5n[R "U[R5SnUR[SU/USSQ76U5 g)z When a connection is accepted over IPv6, the server L{ITransport.getPeer} method returns an L{IPv6Address} giving the address on the remote end of the connection. rTr|rrrN) rrfrrr rrrrrrurrirrwrs r\test_serverGetPeerOnIPv6*TCPPortTestsMixin.test_serverGetPeerOnIPv6rr[c>[5n[U[R[R5nUR X!S5nUR 5n[R"U[R5SnUR[SU/USSQ76U5 g)z When a connection is accepted over IPv6, the server L{ITransport.getPeer} method returns an L{IPv6Address} giving the address on the remote end of the connection, including the scope identifier. r|rrrN) rarrfrrr rrrrrr s r\test_serverGetPeerOnIPv6ScopeID1TCPPortTestsMixin.test_serverGetPeerOnIPv6ScopeIDrr[rZN) rrrrrr+rr r r r r(rrrr ipv6Skipipv6SkipReasonrrrrrrr rrrrr!r$rrZr[r\rrs8@Kn$y/!:;LD : 4 Hn% 3& 3 Hn% 2& 2$'LU Hn% Q& Q Hn% S& S$L Q Hn% O& O Hn%O&O Q Hn% O& O Hn%O&Or[rc\rSrSrSrg)TCPPortTestsBuilderirZNrrrrrrZr[r\r)r)  r[r)c\rSrSrSrg)TCPFDPortTestsBuilderirZNr*rZr[r\r-r-r+r[r-c*\rSrSrSrSrSrSrSrg)StopStartReadingProtocoliz< Protocol that pauses and resumes the transport a few times c4SUlURS5 g)Nr[r)rrpauseResumeProducingrs r\connectionMade'StopStartReadingProtocol.connectionMades  !!!$r[cnURR5 URR5 U(a5URRR SUR US- 5 gURRR SURRRU5 g)z/ Toggle transport read state, then count down. rrN) r}pauseProducingresumeProducingrDrrsr1readycallback)rucounters r\r1-StopStartReadingProtocol.pauseResumeProducingsz %%' &&(  LL * *1d.G.GST U LL * *1dll.@.@.I.I4 Pr[c[R"S[U55 U=RU- sl[UR5S:Xa0URR R UR5 gg)Nzgot datai@)rHrrrrrDrer8rts r\r%StopStartReadingProtocol.dataReceivedsS  CI& T tyy>X % LL   & &tyy 1 &r[r}N) rrrrrr2r1rrrZr[r\r/r/s% Q2r[r/c0^[T5U4Sj5nU$)a Decorate a L{ReactorBuilder} test function which tests one reactor and one connected transport. Run that test method in the context of C{connectionMade}, and immediately drop the connection (and end the test) when that completes. @param testMethod: A unit test method on a L{ReactorBuilder} test suite; taking two additional parameters; a C{reactor} as built by the L{ReactorBuilder}, and an L{ITCPTransport} provider. @type testMethod: 3-argument C{function} @return: a no-argument test method. @rtype: 1-argument C{function} c>^^[5m"UUU4SjS[5nU"5n[TUT[55 g)Nc&>\rSrSrUUU4SjrSrg)BoneTransportTest..actualTestMethod..ServerProtocoli+c>T"TURUR5 URbURR5 TRbTRR5 gg!URbURR5 TRbTRR5 ff=frY)rr}loseConnection)rubuilderother testMethods r\r2QoneTransportTest..actualTestMethod..ServerProtocol.connectionMade,s9w dnnE~~155726683~~155726683s A11ACrZNrrrrr2r)rCrDrEsr\ServerProtocolr@+s  9 9r[rH)r:rAr)rCrHserverProtocolrDrEs` @r\actualTestMethod*oneTransportTest..actualTestMethod's7#% 9 90 9() Mr[r)rErJs` r\oneTransportTestrLs&  :NN r[c[R"U5(a URX!R55 gURX!R5 UR UR 5 g)a. Use the given test to assert that the given transport is actively reading in the given reactor. @note: Maintainers; for more information on why this is a function rather than a method on a test case, see U{this document on how we structure test tools } @param testCase: a test case to perform the assertion upon. @type testCase: L{TestCase} @param reactor: A reactor, possibly one providing L{IReactorFDSet}, or an IOCP reactor. @param transport: An L{ITCPTransport} N)r)rrrhandlesrreadingrxrr}s r\ assertReadingrQ;sT$(()%7%7%9: )__5I--.r[c[R"U5(a URX!R55 gUR UR 5 g)a5 Use the given test to assert that the given transport is I{not} actively reading in the given reactor. @note: Maintainers; for more information on why this is a function rather than a method on a test case, see U{this document on how we structure test tools } @param testCase: a test case to perform the assertion upon. @type testCase: L{TestCase} @param reactor: A reactor, possibly one providing L{IReactorFDSet}, or an IOCP reactor. @param transport: An L{ITCPTransport} N)r)r assertNotInrr rOrPs r\assertNotReadingrTUsB$((Y(:(:(<= Y../r[c`\rSrSrSr\4rSr\S5r \S5r \S5r Sr Sr S rg ) TCPConnectionTestsBuilderinzH Builder defining tests relating to L{twisted.internet.tcp.Connection}. c^^ ^ ^ [5m TR5=m T lSS/nT RRnX!;a%[ R "5(a [S5e[T l [5T l [5T l T RST 5nUR5RnU U UU 4SjnU4Sjm [!T SU5n[#5n[$Ul ['UR)U5T R/5R+XS5nUR-[.R05 TR3T 5 g) z\ This test verifies transport socket read state after multiple pause/resumeProducing calls. Glib2Reactor Gtk2Reactorz.This test is broken on gtk/glib under Windows.rc >TRUS5 TRUS5 USSUSS4nUSRRSS-SS--5 TRR TX5R U4Sj5$)z4 Send several IOCPReactor's buffers' worth of data. rrx yc$>TR5$rYrdrs r\r]RTCPConnectionTestsBuilder.test_stopStartReading..proceed..s GLLNr[)rr}rrerj)protosrlcleanuprrusfs r\proceed@TCPConnectionTestsBuilder.test_stopStartReading..proceeds OOF1I & OOF1I &AYq\6!9Q</F 1I   % %dh&7$(:K&K L77&&w=II* r[c>TRUSS-SS--S5 [[USRR5[USRR5[UR 5/5$)zd Make sure IOCPReactor didn't start several WSARecv operations that clobbered each other's results. r[r\r]zdid not get the right datarr)rrrr}rBr)rrr`rlrus r\ra@TCPConnectionTestsBuilder.test_stopStartReading..cleanups}   !DH$55,   !&)"5"5"D"DE!&)"5"5"D"DE!$"4"45 r[rN)r1rhrrrrJ isWindowsrOr/rrr7rerBr;rlrr/r0rrhrjrlrHrmrn) ruskippedReactorsreactorClassNamerrlrccccfdrarrbs ` @@@r\test_stopStartReading/TCPConnectionTestsBuilder.test_stopStartReadingus _#0022"*)=9",,55  .83E3E3G3GKL L. :*   a $yy{   $ d ; _ "**R."((3 4 @ @ L SWW  r[ctUR5 [XU5 UR5 [XU5 g)zb When a L{Server} is connected, its C{resumeProducing} method adds it as a reader to the reactor. N)r5rTr6rQrurrs r\test_resumeProducing.TCPConnectionTestsBuilder.test_resumeProducings0 / dV,r[c\UR5 UR5 [XU5 g)z When a L{Server} has already started disconnecting via C{loseConnection}, its C{resumeProducing} method does not add it as a reader to its reactor. N)rBr6rTrps r\&test_resumeProducingWhileDisconnecting@TCPConnectionTestsBuilder.test_resumeProducingWhileDisconnectings&  /r[cUR[[S555 [XU5 UR 5 [XU5 g)z} When a L{Server} has already lost its connection, its C{resumeProducing} method does not add it as a reader to its reactor. dummyN)rrIrrTr6rps r\%test_resumeProducingWhileDisconnected?TCPConnectionTestsBuilder.test_resumeProducingWhileDisconnecteds< gi&89:/ /r[c"SS[5n"SS[5nU"5n[XU"5[55 URUR/SQ5 g)a Alice connects to Bob. Alice writes some bytes and then shuts down the connection. Bob receives the bytes from the connection and then pauses the transport object. Shortly afterwards Bob resumes the transport object. At that point, Bob is notified that the connection has been closed. This is no problem for most reactors. The underlying event notification API will probably just remind them that the connection has been closed. It is a little tricky for win32eventreactor (MsgWaitForMultipleObjects). MsgWaitForMultipleObjects will only deliver the close notification once. The reactor needs to remember that notification until Bob resumes the transport. c,\rSrSrSrSrSrSrSrg)QTCPConnectionTestsBuilder.test_connectionLostAfterPausedTransport..Pauseric/UlgrYeventsrs r\rvZTCPConnectionTestsBuilder.test_connectionLostAfterPausedTransport..Pauser.__init__s   r[cURRS5 URR5 URR SUR 5 g)Npausedr)rrr}r5rrsresumers r\r^TCPConnectionTestsBuilder.test_connectionLostAfterPausedTransport..Pauser.dataReceiveds< ""8,--/ &&q$++6r[cnURRS5 URR5 g)Nresumed)rrr}r6rs r\rXTCPConnectionTestsBuilder.test_connectionLostAfterPausedTransport..Pauser.resumes$ ""9-..0r[cfURRS5 [R"X5 g)Nlost)rrr:rrur\s r\r`TCPConnectionTestsBuilder.test_connectionLostAfterPausedTransport..Pauser.connectionLosts" ""6*#224@r[r~N) rrrrrvrrrrrZr[r\Pauserr|s ! 7  1 Ar[rc\rSrSrSrSrg)QTCPConnectionTestsBuilder.test_connectionLostAfterPausedTransport..ClienticnURRS5 URR5 g)Nssome bytes for you)r}rrBrs r\r2`TCPConnectionTestsBuilder.test_connectionLostAfterPausedTransport..Client.connectionMades%$$%:;--/r[rZNrGrZr[r\Clientrs 0r[r)rrrN)r:rArrr)rurrpausers r\'test_connectionLostAfterPausedTransportATCPConnectionTestsBuilder.test_connectionLostAfterPausedTransportsL  A( A$ 0( 0 fh E (EFr[c[[5"SS[55n"SS[5n[X"5U"5[ 55 g)a If one side half-closes its connection, and then the other side of the connection calls C{loseWriteConnection}, and then C{loseConnection} in {writeConnectionLost}, the connection is closed correctly. This rather obscure case used to fail (see ticket #3037). c \rSrSrSrSrSrg)HTCPConnectionTestsBuilder.test_doubleHalfClose..ListenerProtocolic8URR5 grY)r}loseWriteConnectionrs r\readConnectionLost[TCPConnectionTestsBuilder.test_doubleHalfClose..ListenerProtocol.readConnectionLosts224r[c8URR5 grYr}rBrs r\writeConnectionLost\TCPConnectionTestsBuilder.test_doubleHalfClose..ListenerProtocol.writeConnectionLost--/r[rZN)rrrrrrrrZr[r\ListenerProtocolrs  5 0r[rc\rSrSrSrSrg)>TCPConnectionTestsBuilder.test_doubleHalfClose..Clienti c8URR5 grYrrs r\r2MTCPConnectionTestsBuilder.test_doubleHalfClose..Client.connectionMade rr[rZNrGrZr[r\rr s 0r[rN)rr%r:rAr)rurrs r\test_doubleHalfClose.TCPConnectionTestsBuilder.test_doubleHalfClosesI + , 02 0 - 0 0( 0 &6&8&(JLQr[rZN)rrrrrr+rrmrLrqrtrxrrrrZr[r\rVrVns`&6!p--0000)GVRr[rVcZ\rSrSr%Sr\4r\\\ \ \ S'Sr Sr SrSrSrS rg ) WriteSequenceTestsMixinizE Test for L{twisted.internet.abstract.FileDescriptor.writeSequence}. rc:[USS5bX!lgX!lg)z Set the write buffer size for the given transport, mananing possible differences (ie, IOCP). Bug #4322 should remove the need of that hack. writeBufferSizeN)rr bufferSize)rur}values r\setWriteBufferSize*WriteSequenceTestsMixin.setWriteBufferSizes 9/ 6 B(- %#( r[c^U4SjnTR5nTRUS[R5nUR U5 UR [ R5 TRU5 g)zF C{writeSequence} sends the data even if C{write} hasn't been called. cf>^UumpUU4SjnX1lTRR/SQ5 g)Nc>[R"SU-5 TRUS5 TRR 5 g)Nzdata received: %rsSome sequence splitted)rHrrr}rB)rrrirus r\r^WriteSequenceTestsMixin.test_writeSequeceWithoutWrite..connected..dataReceived+s8+d23  '@A  //1r[)sSome s sequence ssplitted)rr}r) protocolsrrlrrirus @r\raHWriteSequenceTestsMixin.test_writeSequeceWithoutWrite..connected(s/#, FF 2 #/     * *+P Qr[rN rhgetConnectedClientAndServerrfrrjrlrHrmrnrurarrls` r\test_writeSequeceWithoutWrite5WriteSequenceTestsMixin.test_writeSequeceWithoutWrite#sY R##%  , ,Wk6>> R i  SWW  r[c^U4SjnTR5nTRUS[R5nUR U5 UR [ R5 TRU5 g)zW C{writeSequence} with an element in the sequence of type unicode raises C{TypeError}. c>UupnTR[URRS/5nTR [ U5S5 URR 5 g)NzUnicode is not kosherzData must be bytes)r TypeErrorr}rrr5rB)rrirrlexcrus r\raWWriteSequenceTestsMixin.test_writeSequenceWithUnicodeRaisesException..connected@s]#, FD##6++99> R i  SWW  r[c|^^[[5"SS55nU"5mUU4SjnTR5nTRUS[R 5nUR U5 UR[R5 TRU5 TRTRSS/5 g)zc C{writeSequence} pauses its streaming producer if too much data is buffered, and then resumes it. c4\rSrSrSrSrSrSrSrSr Sr g)JWriteSequenceTestsMixin.test_streamingProducer..SaveActionProduceriWNc/UlgrYactionsrs r\rvSWriteSequenceTestsMixin.test_streamingProducer..SaveActionProducer.__init__\ ! r[c:URRS5 g)Npauserrrs r\r5YWriteSequenceTestsMixin.test_streamingProducer..SaveActionProducer.pauseProducing_s ##G,r[cURRS5 URRR 5 UR RR 5 g)Nr)rrrir}unregisterProducerrrBrs r\r6ZWriteSequenceTestsMixin.test_streamingProducer..SaveActionProducer.resumeProducingbsB ##H- %%88:  %%446r[c:URRS5 gNrerrs r\ stopProducingXWriteSequenceTestsMixin.test_streamingProducer..SaveActionProducer.stopProducingl ##F+r[r) rrrrrirrvr5r6rrrZr[r\SaveActionProducerrWs FF " - 7 ,r[rcP>USSupUTlUTlURRTS5 TR TR /5 TR URS5 URRS/S-5 TR TR S/5 g)NrvT2xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxr)rirr}registerProducerrrrr)rrirproducerrus r\raAWriteSequenceTestsMixin.test_streamingProducer..connectedqs&r]NF$HO$HO    - -h =   X--r 2  # #F$4$4c :    * *I;+; <   X--y 9r[rrrN) rr(rhrrfrrjrlrHrmrnrr)rurrarrlrs` @r\test_streamingProducer.WriteSequenceTestsMixin.test_streamingProducerQs ] # , , $ ,.&' :##%  , ,Wk6>> R i  SWW   ))GX+>?r[c^^^Tm[[5"U4SjS55nU"5mUU4SjnTR5nTRUS[R 5nUR U5 UR[R5 TRU5 TRTRSS/5 g)zi C{writeSequence} pauses its producer if too much data is buffered only if this is a streaming producer. c2>\rSrSrSrSrU4SjrSrSrg)MWriteSequenceTestsMixin.test_nonStreamingProducer..SaveActionProduceriNc/UlgrYrrs r\rvVWriteSequenceTestsMixin.test_nonStreamingProducer..SaveActionProducer.__init__rr[cb>URRS5 URRS5S:Xa%URRR 5 gTR URRS5 URRRS/S-5 g)Nrrvrrr)rrrrir} stopConsumingrr)rurs r\r6]WriteSequenceTestsMixin.test_nonStreamingProducer..SaveActionProducer.resumeProducings{ ##H-<<%%h/14KK))779++DKK,A,A3GKK))77 b8HIr[c:URRS5 grrrs r\r[WriteSequenceTestsMixin.test_nonStreamingProducer..SaveActionProducer.stopProducingrr[r) rrrrrirvr6rr)rsr\rrsF " J ,r[rc>USnUTlURRTS5 TRTRS/5 g)NrFr)rir}rrr)rrirrus r\raDWriteSequenceTestsMixin.test_nonStreamingProducer..connectedsCq\F$HO    - -h >   X--z :r[rrN) rr'rhrrfrrjrlrHrmrnrr)rurrarrlrrs` @@r\test_nonStreamingProducer1WriteSequenceTestsMixin.test_nonStreamingProducers  ] # , , $ ,"&' ;##%  , ,Wk6>> R i  SWW   ))Hh+?@r[rZN)rrrrrr+rr r r r r(rrrrrrrZr[r\rrsB@Kn$y/!:;L)!.!.3@j*Ar[rcH\rSrSrSrSrSrSr\"\ \ 5S5r Sr g) "TCPTransportServerAddressTestMixiniz= Test mixing for TCP server address building and log prefix. c[5e)z| Helper method returnine a L{Deferred} firing with a tuple of a client protocol, a server protocol, and a running TCP port. )NotImplementedError)rurrrs r\r>TCPTransportServerAddressTestMixin.getConnectedClientAndServers "##r[c^^^UUU4SjnTR5nTRUTU5nURU5 UR[R 5 TR U5 g)zD Helper method to test TCP server addresses on either IPv4 or IPv6. c>UupnTRSURR<SUR5R<S3[ UR55 TRSURR<ST<3URR 5 URRunTRUT5 TRSUR5 TRTUR5 URR5 g!URR5 f=f)NzzAccumulatingProtocol,,r) rr} sessionnor;rlr5logstrrD peerAddressesrrrkrB)rrirrlr adressClassrrus r\raHTCPTransportServerAddressTestMixin._testServerAddress..connecteds#, FD 2  ''114<<>3F3FH(()   ''119>$$++ !' < < %%k;?   (8(89  K,<,<=  //1  //1s C>D!!D=N)rhrrjrlrHrmrn)rurrrrarrls`` ` r\_testServerAddress5TCPTransportServerAddressTestMixin._testServerAddresssT  2.##%  , ,Wi O i  SWW  r[cLURS[R[5$)z L{Server} instances have a string representation indicating on which port they're running, and the connected address is stored on the C{peerAddresses} attribute of the factory. r)rrfrrrs r\test_serverAddressTCP49TCPTransportServerAddressTestMixin.test_serverAddressTCP4s &&{FNNKPPr[c\UR[5[R[5$)z IPv6 L{Server} instances have a string representation indicating on which port they're running, and the connected address is stored on the C{peerAddresses} attribute of the factory. )rrarfrrrs r\test_serverAddressTCP69TCPTransportServerAddressTestMixin.test_serverAddressTCP6s%&& # %v   r[rZN) rrrrrrrrr r&r'rrrZr[r\rrs3$ !DQ Hn% & r[rc\rSrSrSrSrSrg)TCPTransportTestsBuilderizL Test standard L{ITCPTransport}s built with C{listenTCP} and C{connectTCP}. c^^ ^ [5n[5Ul[5Ul[ 5n[5Ul[5UlTR SXBS9m [ URUR/5nU4SjnURU5 [ URUR/5n[5m U U 4Sjn URU 5 TRUT R5RU5 T $)zy Return a L{Deferred} firing with a L{MyClientFactory} and L{MyServerFactory} connected pair, and the listening C{Port}. rrc(>TR5 U$rYrdrrs r\reBTCPTransportTestsBuilder.getConnectedClientAndServer..stop s LLNMr[c>Uup[R"SU-5 [R"SU-5 TRXT45 gNzclient connected %szserver connected %srHrr8rrirrtrls r\startCTCPTransportTestsBuilder.getConnectedClientAndServer..start A&NF GG)F2 3 GG)F2 3   vt4 5r[) rNrrrrirMrBrrrjrHr;rl) rurrrrri lostDeferredre startDeferredrrtrls ` @@r\r4TCPTransportTestsBuilder.getConnectedClientAndServers !"(0 %(0 % "(0 %(0 %  F @$  * *F,I,I J   T"%  * *F,I,I J : 6 !!%(9dlln&9&96Br[rZN)rrrrrrrrZr[r\rrs )r[rc&\rSrSrSr\\4rSrSr g)!AdoptStreamConnectionTestsBuilderi( z> Test server transports built using C{adoptStreamConnection}. c^^^ ^ ^ [5n[5Ul[5m [5T l[5T l[ 5n[5Ul[5UlTR SXBS9m UUU 4SjnURR U5 [URT R/5nU4SjnURU5 [5m T RU5 [URT R/5n U U 4Sjn U R U 5 TRUT R5RU5 T $)a Return a L{Deferred} firing with a L{MyClientFactory} and L{MyServerFactory} connected pair, and the listening C{Port}. The particularity is that the server protocol has been obtained after doing a C{adoptStreamConnection} against the original server connection. rrc>TRUR5 TRUR5 TRURR 5TT5 grY)rr}radoptStreamConnectionr)rrrrs r\firtServerConnectedZAdoptStreamConnectionTestsBuilder.getConnectedClientAndServer..firtServerConnectedE sI   1   1  ) )&&(- r[cJ>TR(aTR5 U$rY)rrers r\reKAdoptStreamConnectionTestsBuilder.getConnectedClientAndServer..stopR s Mr[c>Uup[R"SU-5 [R"SU-5 TRXT45 gr r r s r\rLAdoptStreamConnectionTestsBuilder.getConnectedClientAndServer..start` rr[) rNrrrrirMrBrjrrrlrHr;rl)rurrr firstServerrirrrerrrtrlrs ` ` @@@r\r=AdoptStreamConnectionTestsBuilder.getConnectedClientAndServer1 s&' -5Z * "(0 %(0 % "(0 %(0 %  K E  **667JK$  * *F,I,I J   T":D!%  * *F,I,I J  6 !!%(9dlln&9&96Br[rZN) rrrrrr)r*rrrrZr[r\rr( s(88r[rc\rSrSrSrSrSrg)ServerAbortsTwiceiw z Call abortConnection() twice. clURR5 URR5 grY)r}abortConnectionrts r\rServerAbortsTwice.dataReceived| s" &&( &&(r[rZNrrZr[r\r"r"w )r[r"c\rSrSrSrSrSrg)ServerAbortsThenLosesi z6 Call abortConnection() followed by loseConnection(). clURR5 URR5 grY)r}r$rBrts r\r"ServerAbortsThenLoses.dataReceived s" &&( %%'r[rZNrrZr[r\r(r( (r[r(c\rSrSrSrSrSrg)AbortServerWritingProtocoli z, Protocol that writes data upon connection. c:URRS5 g)zG Tell the client that the connection is set up and it's time to abort. sreadyNr}rrs r\r2)AbortServerWritingProtocol.connectionMade s X&r[rZNrrrrrr2rrZr[r\r-r- s 'r[r-c\rSrSrSrSrSrg)ReadAbortServerProtocoli z Server that should never receive any data, except 'X's which are written by the other side of the connection before abortConnection, and so might possibly arrive. cHURSS5(a [S5eg)NXr[zUnexpectedly received data.)replacerrts r\r$ReadAbortServerProtocol.dataReceived s$ <<c " "9: : #r[rZNrrZr[r\r3r3 s  ;r[r3c\rSrSrSrSrSrg) NoReadServeri z Stop reading immediately on connection. This simulates a lost connection that will cause the other side to time out, and therefore call abortConnection(). c8URR5 grY)r} stopReadingrs r\r2NoReadServer.connectionMade s ""$r[rZNr1rZr[r\r9r9 s %r[r9c8\rSrSrSrSrSrSrSrSr Sr Sr g ) EventualNoReadServeri z Like NoReadServer, except we Wait until some bytes have been delivered before stopping reading. This means TLS handshake has finished, where applicable. FcUR(d?SUlURRUS5 URRS5 gg)NTFhello)gotDatar}rrrts r\r!EventualNoReadServer.dataReceived s;||DL NN + +D% 8 NN  *r[cjUR(agSUlURR5 gNT)stoppedReadingr}r;rs r\r6$EventualNoReadServer.resumeProducing s&    " ""$r[cgrYrZrs r\r5#EventualNoReadServer.pauseProducing  r[cgrYrZrs r\r"EventualNoReadServer.stopProducing rIr[)rArEN) rrrrrrArErr6r5rrrZr[r\r>r> s' GN+ %  r[r>c"\rSrSrSrSrSrSrg)BaseAbortingClienti z' Base class for abort-testing clients. FchUR(a [S5e[R"X5 g)Nz,BUG: connectionLost was called re-entrantly!)inReactorMethod RuntimeErrorr:rrs r\r!BaseAbortingClient.connectionLost s%   MN N**48r[rZN)rrrrrrOrrrZr[r\rMrM sO9r[rMc\rSrSrSrSrSrg)WritingButNotAbortingClienti z Write data, but don't abort. c:URRS5 g)Nr@r/rs r\r2*WritingButNotAbortingClient.connectionMade s X&r[rZNr1rZr[r\rSrS s 'r[rSc$\rSrSrSrSrSrSrg)AbortingClienti z1 Call abortConnection() after writing some data. c@SUlUR5 SUlg)z6 Some data was received, so the connection is set up. TFN)rO writeAndAbortrts r\rAbortingClient.dataReceived s  $ $r[cURRSS-5 URR5 URRSS-5 g)Nr5i'Y)r}rr$rs r\rYAbortingClient.writeAndAbort s@ TE\* &&( TE\*r[)rON)rrrrrrrYrrZr[r\rWrW s%+r[rWc\rSrSrSrSrSrg)AbortingTwiceClienti z8 Call abortConnection() twice, after writing some data. cb[RU5 URR5 grY)rWrYr}r$rs r\rY!AbortingTwiceClient.writeAndAbort s $$T* &&(r[rZNrrrrrrYrrZr[r\r_r_ r&r[r_c\rSrSrSrSrSrg)AbortingThenLosingClienti z3 Call abortConnection() and then loseConnection(). cb[RU5 URR5 grY)rWrYr}rBrs r\rY&AbortingThenLosingClient.writeAndAbort s $$T* %%'r[rZNrbrZr[r\rdrd r+r[rdc>\rSrSrSrSrSrSrSrSr Sr S r S r g ) ProducerAbortingClienti z9 Call abortConnection from doWrite, via resumeProducing. TFcURRSS-5 SUlURRUS5 SUlg)NslalalaiTF)r}rinRegisterProducerrrs r\rProducerAbortingClient.write s= Y/0"& ''e4"'r[c$UR5 grYrrs r\r2%ProducerAbortingClient.connectionMade  r[cvSUlUR(dURR5 SUlg)NTF)rOrjr}r$rs r\r6&ProducerAbortingClient.resumeProducing s+#&& NN * * ,$r[cSUlgrD)producerStoppedrs r\r$ProducerAbortingClient.stopProducing$ s #r[cUR(d [S5eUR(a [S5e[R"X5 g)Nz&BUG: stopProducing() was never called.z(BUG: connectionLost called re-entrantly!)rsrPrOr:rrs r\r%ProducerAbortingClient.connectionLost' s:##GH H   IJ J**48r[)rOrjrsN) rrrrrrOrsrr2r6rrrrZr[r\rhrh s,OO( % $9r[rhcN\rSrSrSrSrSrSrSrSr Sr Sr S r S r S rS rg )StreamingProducerClienti/ a Call abortConnection() when the other side has stopped reading. In particular, we want to call abortConnection() only once our local socket hits a state where it is no longer writeable. This helps emulate the most common use case for abortConnection(), closing a connection after a timeout, with write buffers being full. Since it's very difficult to know when this actually happens, we just write a lot of data, and assume at that point no more writes will happen. Frc$UR5 grYrmrs r\r2&StreamingProducerClient.connectionMade@ ror[cURRUS5 [S5H!nURRSS-5 M# g)zP Write large amount to transport, then wait for a while for buffers to fill up. Tds 1234567890i}N)r}rranger)ruis r\rStreamingProducerClient.writeC s= ''d3sA NN !6 7r[cSUlg)NF)rrs r\r6'StreamingProducerClient.resumeProducingL s  r[cgrYrZrs r\r%StreamingProducerClient.stopProducingO rIr[cUR(agSUlURRSUR5 g)a Called when local buffer fills up. The goal is to hit the point where the local file descriptor is not writeable (or the moral equivalent). The fact that pauseProducing has been called is not sufficient, since that can happen when Twisted's buffers fill up but OS hasn't gotten any writes yet. We want to be as close as possible to every buffer (including OS buffers) being full. So, we wait a bit more after this for Twisted to write out a few chunks, then abortConnection. NTg{Gz?)rrrsdoAbortrs r\r5&StreamingProducerClient.pauseProducingR s/ ;;   tT\\2r[cUR(d[R"[S55 SUlUR R 5 SUlg)Nz&BUG: We should be paused a this point.TF)rrHrmrPrOr}r$rs r\rStreamingProducerClient.doAbortg s;{{ GGL!IJ K# &&($r[cxURRR5 [R"X5 grY) otherProtocolr} startReadingr:rrs r\r&StreamingProducerClient.connectionLostn s( $$113**48r[)rOrN)rrrrrr extraWritesrOr2rr6rr5rrrrZr[r\rxrx/ s; FKO8 3*%9r[rxc$\rSrSrSrSrSrSrg)StreamingProducerClientLaterit zL Call abortConnection() from dataReceived, after bytes have been exchanged. cHURRS5 SUlg)Nr@F)r}rrArs r\r2+StreamingProducerClientLater.connectionMadez s X& r[cVUR(dSUlUR5 ggrD)rArrts r\r)StreamingProducerClientLater.dataReceived~ s||DL JJLr[)rANrrrrrr2rrrZr[r\rrt s r[rc$\rSrSrSrSrSrSrg)ProducerAbortingClientLateri z Call abortConnection from doWrite, via resumeProducing. Try to do so after some bytes have already been exchanged, so we don't interrupt SSL handshake. cgrYrZrs r\r2*ProducerAbortingClientLater.connectionMade s r[c$UR5 grYrmrts r\r(ProducerAbortingClientLater.dataReceived ror[rZNrrZr[r\rr s r[rc\rSrSrSrSrSrg)DataReceivedRaisingClienti zF Call abortConnection(), and then throw exception, from dataReceived. cLURR5 [S5e)NONO)r}r$ZeroDivisionErrorrts r\r&DataReceivedRaisingClient.dataReceived s &&(&&r[rZNrrZr[r\rr s 'r[rc$\rSrSrSrSrSrSrg)ResumeThrowsClienti zD Call abortConnection() and throw exception from resumeProducing(). cpUR(d%URR5 [S5eg)Nzono!)rjr}r$rrs r\r6"ResumeThrowsClient.resumeProducing s+&& NN * * ,#F+ +'r[c0[R"X5 grY)r:rrs r\r!ResumeThrowsClient.connectionLost s **48r[rZN)rrrrrr6rrrZr[r\rr s, 9r[rc\rSrSr%SrSr\\\S'SSjr Sr Sr Sr S r S r\"\R"R%S S 5R'5S :H=(a \R*"5S5S5r\"\R"R%S S 5R'5S :H=(a \R*"5S5S5rSrSrSrSrSrg)AbortConnectionMixini z/ Unit tests for L{ITransport.abortConnection}. Nr?cn[[4n[[4n[(a(U[R 4-nU[R 4-nU"5nU"5nXvlXgl[XX`R5nURUR5/5 URUR5/5 Ub+URURRU4U-5 O&URURRU5 URURRU5 g)z A test runner utility function, which hooks up a matched pair of client and server protocols. We then run the reactor until both sides have disconnected, and then verify that the right exception resulted. N)rrrrrRErrorrrAr?rrgetDelayedCallsrdisconnectReasonr) ru clientClass serverClassclientConnectionLostReasonclientExpectedExceptionsserverExpectedExceptionsrirrs r\ runAbortTest!AbortConnectionMixin.runAbortTest s%6~#F $2N#C  6'?399,'N $'?399,'N $%%)$O **,b1 002B7 % 1  ! !''--+-0HH   ! !''--/G  f55;;=UVr[c6UR[[5$)z abortConnection() is called in dataReceived. The protocol should be disconnected, but connectionLost should not be called re-entrantly. )rrWr3rs r\test_dataReceivedAbort+AbortConnectionMixin.test_dataReceivedAbort s   1HIIr[c6UR[[5$)zq abortConnection() is called twice by client. No exception should be thrown, and the connection will be closed. )rr_r3rs r\ test_clientAbortsConnectionTwice5AbortConnectionMixin.test_clientAbortsConnectionTwice s   !46MNNr[c6UR[[5$)z Client calls abortConnection(), followed by loseConnection(). No exception should be thrown, and the connection will be closed. )rrdr3rs r\.test_clientAbortsConnectionThenLosesConnectionCAbortConnectionMixin.test_clientAbortsConnectionThenLosesConnection s   !9;RSSr[c<UR[[[S9$)zq abortConnection() is called twice by server. No exception should be thrown, and the connection will be closed. r)rrSr"rrs r\ test_serverAbortsConnectionTwice5AbortConnectionMixin.test_serverAbortsConnectionTwice s%   ' '5!  r[c<UR[[[S9$)z Server calls abortConnection(), followed by loseConnection(). No exception should be thrown, and the connection will be closed. r)rrSr(rrs r\.test_serverAbortsConnectionThenLosesConnectionCAbortConnectionMixin.test_serverAbortsConnectionThenLosesConnection s%   ' !'5!  r[CIrUtruezFlaky on macOS on Azure.c8UR[[5 g)z abortConnection() is called in resumeProducing, before any bytes have been exchanged. The protocol should be disconnected, but connectionLost should not be called re-entrantly. N)rrhr:rs r\test_resumeProducingAbort.AbortConnectionMixin.test_resumeProducingAbort s 02EFr[c6UR[[5$)z| abortConnection() is called in resumeProducing, after some bytes have been exchanged. The protocol should be disconnected. )rrr-rs r\test_resumeProducingAbortLater3AbortConnectionMixin.test_resumeProducingAbortLater s  ')C  r[c8UR[[5 g)aC abortConnection() triggered by the write buffer being full. In particular, the server side stops reading. This is supposed to simulate a realistic timeout scenario where the client notices the server is no longer accepting data. The protocol should be disconnected, but connectionLost should not be called re-entrantly. N)rrxr9rs r\test_fullWriteBuffer)AbortConnectionMixin.test_fullWriteBuffer( s 1<@r[c6UR[[5$)z abortConnection() is triggered by a write buffer being full. However, this buffer is filled after some bytes have been exchanged, allowing a TLS handshake if we're testing TLS. The connection will then be lost. )rrr>rs r\%test_fullWriteBufferAfterByteExchange:AbortConnectionMixin.test_fullWriteBufferAfterByteExchange5 s  !=?STTr[cUR[[[S9 UR [5nUR [ U5S5 g)a dataReceived calls abortConnection(), and then raises an exception. The connection will be lost, with the thrown exception (C{ZeroDivisionError}) as the reason on the client. The idea here is that bugs should not be masked by abortConnection, in particular unexpected exceptions. rrN)rrr-rflushLoggedErrorsrrruerrorss r\test_dataReceivedThrows,AbortConnectionMixin.test_dataReceivedThrows? sG  % &'8  ''(9: Va(r[cUR[[[S9 UR [5nUR [ U5S5 g)a resumeProducing calls abortConnection(), and then raises an exception. The connection will be lost, with the thrown exception (C{ZeroDivisionError}) as the reason on the client. The idea here is that bugs should not be masked by abortConnection, in particular unexpected exceptions. rrN)rrr:rrrrrs r\test_resumeProducingThrows/AbortConnectionMixin.test_resumeProducingThrowsP sG   '8  ''(9: Va(r[rZrY)rrrrrr?r r<r(rrrrrrr renvirongetlowerrJisMacOSXrrrrrrrrZr[r\rr s ,0Ix(/#WJJOT      tR &&(F2Jx7H7H7J"G G  tR &&(F2Jx7H7H7J"   AU)")r[rc,\rSrSrSr\4r\"5rSr g)AbortConnectionTestsib z- TCP-specific L{AbortConnectionMixin} tests. rZN) rrrrrr+rrr?rrZr[r\rrb s& Ir[rc`\rSrSrSrSr\"\R"5S5S5r Sr Sr g) SimpleUtilityTestsio zB Simple, direct tests for helpers within L{twisted.internet.tcp}. cUR[R[SS5nUR UR S[R 5 g)z L{_resolveIPv6} raises a L{socket.gaierror} (L{socket.EAI_NONAME}) when invoked with a non-numeric host. (In other words, it is passing L{socket.AI_NUMERICHOST} to L{socket.getaddrinfo} and will not accidentally block if it receives bad input.) localhostrrNrrfgaierrorr8rr EAI_NONAMErurms r\test_resolveNumericHost*SimpleUtilityTests.test_resolveNumericHostu s<{AN !f&7&78r[z@The AI_NUMERICSERV flag is not supported by Microsoft providers.cUR[R[SS5nUR UR S[R 5 g)z L{_resolveIPv6} raises a L{socket.gaierror} (L{socket.EAI_NONAME}) when invoked with a non-numeric port. (In other words, it is passing L{socket.AI_NUMERICSERV} to L{socket.getaddrinfo} and will not accidentally block if it receives bad input.) rThttprNrrs r\test_resolveNumericService-SimpleUtilityTests.test_resolveNumericService s<ufM !f&7&78r[c[SS5nUR[U5S5 URUS[5 URUS[5 URUSSS5 g)zJ L{_resolveIPv6} discovers the flow info and scope ID of an IPv6 address. rTrvrerN)rTrv)r8rrrr6rs r\test_resolveIPv6#SimpleUtilityTests.test_resolveIPv6 sf eQ' Va( fQi- fQi- Z0r[rZN) rrrrrrr rJrgrrrrZr[r\rro s99 J 9  91r[rc0\rSrSrSrSrSrSrSrSr g) BuffersLogsTestsi z Tests for L{_BuffersLogs}. c~SUl/Ul[URURR5Ulg)Nz name.space) namespacerr4r logBufferrs r\rBuffersLogsTests.setUp s,% %dnndkk6H6HIr[cURnURS5 URUR5 SSS5 g!,(df  g=f)zR The context manager's logger does not log to provided observer inside the block. An eventN)rrr r)ruloggers r\test_buffersInBlock$BuffersLogsTests.test_buffersInBlock s5 ^^v KK #   T[[ )^^s -A AcvURnURS5 URUR5 SSS5 UR S[ UR55 URunUR USS5 UR USUR 5 g!,(df  Nv=f)z_ The context manager flushes its buffered logs when the block terminates without an exception. rNr log_format log_namespace)rrr rrrr)rurevents r\test_flushesOnExit#BuffersLogsTests.test_flushesOnExit s ^^v KK #   T[[ ) C ,-++ |,j9 /@ ^s -B** B8c"SS[5nURU5 URnURS5 UR UR 5 U"5e!,(df  O=fSSS5 O!,(df  O=fUR S[UR 55 UR unUR USS5 UR USUR5 g)zb The context manager flushes its buffered logs when the block terminates because of an exception. c\rSrSrSrSrg)GBuffersLogsTests.test_flushesOnExitWithException..TestExceptioni z( An exception only raised by this test. rZNrrrrrrrZr[r\ TestExceptionr  r[rrNrrr) rrrrr rrrr)rurrrs r\test_flushesOnExitWithException0BuffersLogsTests.test_flushesOnExitWithException s  I    } -6 J'  -#o% . - - C ,-++ |,j9 /@s A=4A"" A0 ,A== B )rrrN) rrrrrrrrr rrZr[r\rr sJ * AAr[rcT\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rg)FileDescriptorReservationTestsi z* Tests for L{_FileDescriptorReservation}. cj^/TlTR5TlU4Sjn[U5Tlg)Nc>TRR[TRS55 TRS$)Nwr)reservedFileObjectsrr3tempfilersr\fakeFileFactory=FileDescriptorReservationTests.setUp..fakeFileFactory s3  $ $ + +D,D E++B/ /r[)rmktemprr5 reservedFD)rurs` r\r$FileDescriptorReservationTests.setUp s+#%    05_Er[c8[[UR5 g)zQ L{_FileDescriptorReservation} instances provide L{_IFileDescriptorReservation}. N)rr6rrs r\r85FileDescriptorReservationTests.test_providesInterface s 0$//Br[c@UR[UR5S5 [S5HjnURR 5 UR[UR5S5 UR URSR5 Ml g)zP Multiple acquisitions without releases open the reservation file exactly once. rrrN)rrrr}rreserver r)rurs r\test_reserveOpensFileOnce8FileDescriptorReservationTests.test_reserveOpensFileOnce sw T556:rA OO # # %   S!9!9:A >   T55a8?? @r[c[5nURUR5 UR5 UR UR R 55 UR R5 UR UR R 55 UR[[5nUR[U5S5 URUSRR[R5 g)z If reserving the file descriptor fails because of C{EMFILE}, the exception is suppressed but logged and the reservation remains unavailable. rrN)r rrrr r availablerrrr?rrrrr)rur0rs r\test_reserveEMFILELogged7FileDescriptorReservationTests.test_reserveEMFILELogged s -.   ))* 2245 ! 2245''9 Va( .. =r[c[[[4H/nU4Sjn[U5nUR XR 5 M1 g)z Any exception raised while opening the reserve file that is not an L{OSError} or L{IOError} whose errno is C{EMFILE} is allowed through to the caller. c6U"[RS-S5e)Nrr)rr) errorClasss r\ failsWithWFileDescriptorReservationTests.test_reserveRaisesNonEMFILEExceptions..failsWith s !19==r[N)rr?rr5rr)rur#r$ reserveFDs r\%test_reserveRaisesNonEMFILEExceptionsDFileDescriptorReservationTests.test_reserveRaisesNonEMFILEExceptions s? #GZ8J&0 >39=I   j*;*; <9r[cURURR55 URR5 UR URR55 g)zE The reservation is available after the file descriptor is reserved. N)r rrrrrs r\test_available-FileDescriptorReservationTests.test_available sH 2245 ! 1134r[cUR[5 UR SSS5 SSS5 g!,(df  N=f!,(df  g=f)zX A reservation without an open file used as a context manager raises a L{RuntimeError}. N)rrPrrs r\test_enterFailsWithoutFile9FileDescriptorReservationTests.test_enterFailsWithoutFile$ s8   | ,<!- , - ,s A6A A A AczURR5 URURR55 UR UR URR55 SSS5 URURR55 g!,(df  N8=f)zY Entering a reservation closes its file for the duration of the context manager's block. N)rrrrr rs r\!test_enterClosesFileExitOpensFile@FileDescriptorReservationTests.test_enterClosesFileExitOpensFile- su ! 1134 __   T__668 9 1134_s *B,, B:c"SS[5nURR5 URU5 UR U"5e!,(df  O=fSSS5 g!,(df  g=f)zq An exception raised within a reservation context manager's block does not prevent the file from being reopened. c\rSrSrSrSrg)SFileDescriptorReservationTests.test_exitOpensFileOnException..TestExceptioni> z& An exception only used by this test. rZNrrZr[r\rr4> rr[rN)rrrr)rurs r\test_exitOpensFileOnException.AllowedExceptioniO z) The exception allowed out of the block. rZNrrZr[r\AllowedExceptionr9O rr[r:c\rSrSrSrSrg)cFileDescriptorReservationTests.test_exitSuppressesReservationException..SuppressedExceptioniT z5 An exception raised by the file descriptor factory. rZNrrZr[r\SuppressedExceptionr<T rr[r=FcZ>TS(aT"5eSTS'[R"5$)NrT)ioBytesIO)r=calledsr\+failsWithSuppressedExceptionAfterSecondOpen{FileDescriptorReservationTests.test_exitSuppressesReservationException..failsWithSuppressedExceptionAfterSecondOpen[ s(ay)++ q zz|#r[Nr) rr5rrrrrrr)rur:rBrrr=rAs @@r\'test_exitSuppressesReservationExceptionFFileDescriptorReservationTests.test_exitSuppressesReservationExceptionH s y   )   $0 7    ,,./   / 0&((1 0 0''(;< Va(s6B9B B B B*)rrrN)rrrrrrr8rrr'r*r-r0r5rDrrZr[r\r r  s<FC A>$ =5= 5& &)r[r c0\rSrSrSrSrSrSrSrSr g) "NullFileDescriptorReservationTestsiq z. Tests for L{_NullFileDescriptorReservation}. c"[5UlgrY)r7nullReservedFDrs r\r(NullFileDescriptorReservationTests.setUpv s <>r[c8[[UR5 g)zL L{_NullFileDescriptorReservation} provides L{_IFileDescriptorReservation}. N)rr6rIrs r\r89NullFileDescriptorReservationTests.test_providesInterfacey s 0$2E2EFr[cVURURR55 g)z7 The null reserved file descriptor is never available. Nr rIrrs r\r*1NullFileDescriptorReservationTests.test_available s! ,,6689r[cFURURR55 UR URURR55 SSS5 URURR55 g!,(df  N8=f)z> The null reserved file descriptor is a null context manager. NrNrs r\test_contextManager6NullFileDescriptorReservationTests.test_contextManager sr ,,6689    T00::< =! ,,6689! s *B B )rIN) rrrrrrr8r*rQrrZr[r\rGrGq s?G: :r[rG)rrrr?rrf functoolsrtypingrrrrr r r unittestr zope.interfacer rzope.interface.verifyrrr)twisted.internet.addressrrtwisted.internet.deferrrrrrrtwisted.internet.endpointsrrtwisted.internet.errorrrrrrr r!r"r#twisted.internet.interfacesr$r%r&r'r(r)r*r+r,r-r.twisted.internet.protocolr/r0r1twisted.internet.tcpr2r3r4r5r6r7r8&twisted.internet.test.connectionmixinsr9r:r;r<r=r>r?r@rA#twisted.internet.test.reactormixinsrBrCrDtwisted.internet.testingrErFtwisted.loggerrGtwisted.pythonrHtwisted.python.failurerItwisted.python.runtimerJtwisted.test.test_tcprKrLrMrNtwisted.trial.unittestrOrPrQOpenSSLrRtwisted.internet.sslrSr ImportErrorsrrrr&r'rr rrgtwisted.internet.testrVwin32GetLinkLocalIPv6Addressesr_rrWposixGetLinkLocalIPv6Addressesrarhrorrrrrrr#r)r8rrrrrrrr r.r{r}rrrrrr)r-r/rLrQrTrVrrrrglobalsupdatemakeTestCaseClassesr"r(r-r3r9r>rMrSrWr_rdrhrxrrrrrrrrr rGrZr[r\rrs  NNN1; =N       ML    D!*+ KJ: F foov'9'9:AFF: HN=GGI 2 , K KKP6%1$O$O!K:"$99x3h32 8  ])#)#)#X M,-11X11h-"-"`OO,3*3$ _NNN.MH)=?UMH` / .!7/7"7,p:~p:f 8 .!3 83"3"  : &'TD*D*(D*N PQN6#6N6RN6bYx PQI/$7I/RI/XA 0A HMMB E. E"F."FJGOGOT      2x26!H/402aRaRH^A^AB? ? D0&(?0fA&(?AH ';;=> ';;=> $88:; &::<= *>>@A *>>@A *>>@A )==?@ 2FFHI)+)(/( '!4 ' ;8 ; %& % . < 9, 9'"4'+'+,).)(~(909DB91B9J #:  "8  ''9/9"p)p)f>+? %99;<.!-1-1"-1`4A*4An PQV)%8V)RV)r:)<:]` F0H+A3/N0& /$.!/s< X%8X4Y%X10X14Y :YY  YY