+ DfjѦ Rt^RIt^RIt^RIt^RIt^RIt^RIHt^RIH t H t H t H t H t HtHt^RIHt^RIHtHt^RIHtHt^RIt^RIHtHt^RIHtHtHtH t H!t!H"t"^R I#H$t$H%t%^R I&H't'H(t(H)t)H*t*H+t+H,t,H-t-H.t.H/t/^R I0H1t1H2t2H3t3H4t4H5t5H6t6H7t7H8t8H9t9H:t:H;t;^R It>H?t?^R I@HAtAHBtBHCtCHDtDHEtEHFtFHGtG^RIHHItIHJtJHKtKHLtLHMtMHNtNHOtOHPtPHQtQ^RIRHStSHTtTHUtU^RIVHWtWHXtX^RIYHZtZ^RI[H\t\^RI]H^t^^RI_H`t`^RIaHbtbHctcHdtdHete^RIfHgtgHhthHiti^RIjHktk^RIlHmtmRtnRtp]P !]P]P4tp]pPR4RttRtu]pe]pP4]`P!4'd^RIzH{t{]{Pt}Rt~M^RIzHt]EPt}Rt~R tR!t!R"R#4t!R$R%]i4t!R&R']>4t]!]64!R(R)44t]!]6]4!R*R+]i4t!R,R-]i4t!R.R/]L4t!R0R1]4t]!]:4!R2R344t!R4R5]S]K]O4t!R6R7]4t]!]t]u4!R8R9]44t!R:R;]S4t!R<R=]4t]!]t]u4!R>R?]44tR@t!RARB]4t]!]4]P!RRC7!RDRE444t]!]~RF4!RGRH]h44tRIt]!]~RF4!RJRK]h44t!RLRM]M4t!RNRO4t!RPRQ]4t!RRRS]4t!RTRU4t!RVRW]S]]]4t!RXRY]S]]]4t!RZR[]>4tR\tR]tR^t!R_R`]S4t!RaRb4t!RcRd4t!ReRf]]]S4t!RgRh]]]S4t]!4EPS]EPU44]!4EPS]EPU44]!4EPS]EPU44]!4EPS]EPU44]!4EPS]EPU44]!4EPS]EPU44]!4EPS]EPU44]!4EPS]EPU44]!4EPS]EPU44!RiRj]J4t!RkRl]J4t!RmRn]J4t!RoRp]4t!RqRr]J4t!RsRt]J4t!RuRv]J4t!RwRx]4t!RyRz]4t!R{R|]4t!R}R~]4t!RR]J4t!RR]J4t!RR]4t!RR]4t!RR]4t!RR]4t!RR4t!RR]S]4t]!4EPS]EPU44]!]t]u4!RR]i44t!RR]h4t]!]~RF4!RR]h44t!RR]h4tR# ]odRtnELi;i ]vdtwRttR]w 2tuRtwAwELRtwAwii;i ]odRt}ELi;i)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)ClientContextFactoryTFzIPv6 not available. ) _win32ifaces) _posixifacesc.#NrX@/usr/lib/python3/dist-packages/twisted/internet/test/test_tcp.pyr[sBrYcN\4pV'd V^,#\R4h)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 z#Link local IPv6 address unavailable)getLinkLocalIPv6AddressesrN) addressess rZgetLinkLocalIPv6Addressr_s%*+I| 8 99rYcVwr#RV9gRV9d&\P!W#4^,^,pMW#3pVPV4R#)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. %:N)socket getaddrinfoconnect)client destinationhostportaddresss&& rZreresELT d{cTk$$T03A6, NN7rYcTa]tRt^toRtRtRtRtRtRt Rt Rt R t R t VtR #) 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}. c Wn.VnR#rW)data sendBufferselfrns&&rZ__init__FakeSocket.__init__s rYcWnR#rW)blocking)rqrus&&rZ setblockingFakeSocket.setblockings rYcVP#rWrn)rqsizes&&rZrecvFakeSocket.recvs yyrYc NVPPV4\V4#)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. )roappendlenrqbytess&&rZsendFakeSocket.sends  u%5zrYc R#)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. NrX)rqhows&&rZshutdownFakeSocket.shutdownrYc R#)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. NrXrqs&rZcloseFakeSocket.closerrYc R#)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. NrX)rqargss&*rZ setsockoptFakeSocket.setsockoptrrYc ^#)z Return a fake file descriptor. If actually used, this will have no connection to this L{FakeSocket} and will probably cause surprising results. rXrs&rZfilenoFakeSocket.filenos rY)rurnroN)__name__ __module__ __qualname____firstlineno____doc__rrrvr{rrrrr__static_attributes____classdictcell__ __classdict__s@rZrlrls7!   rYrlc6a]tRt^toRtRtRtRtRtVt R#)FakeSocketTestszL Test that the FakeSocket can be used by the doRead method of L{Connection} cv\R4pVP^4VPVP^4R#someDataN)rlrv assertEqualrurqskts& rZ test_blockingFakeSocketTests.test_blockings,%  q)rYc^\R4pVPVP^ 4R4R#r)rlrr{rs& rZ test_recvFakeSocketTests.test_recvs$% "{3rYc \R4pVPR4pVPV^4VPVPR.4R#)zp L{FakeSocket.send} accepts the entire string passed to it, adds it to its send buffer, and returns its length. rYsfooN)rlrrro)rqrcounts& rZ test_sendFakeSocketTests.test_sendsA o  " &2rYrXN) rrrrrrrrrrrs@rZrrs* 433rYrc*a]tRtRtoRtRtRtVtR#) FakeProtocolizD An L{IProtocol} that returns a value from its dataReceived method. c R#)zY Return something other than L{None} to trigger a deprecation warning for that behavior. rXrXrps&&rZ dataReceivedFakeProtocol.dataReceiveds  rYrXNrrrrrrrrrs@rZrrsrYrcTa]tRtRtoRtRtRtRtRtRt Rt R t R t R t VtR #) _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} cB\4Vn\4VnR#rW)set_readers_writersrs&rZrr_FakeFDSetReactor.__init__s  rYc<VPPV4R#rW)raddrqreaders&&rZ addReader_FakeFDSetReactor.addReader! &!rYc`WP9dVPPV4R#R#rW)rremovers&&rZ removeReader_FakeFDSetReactor.removeReader$# ]] " MM  ( #rYc<VPPV4R#rW)rrrqwriters&&rZ addWriter_FakeFDSetReactor.addWriter(rrYc`WP9dVPPV4R#R#rW)rrrs&&rZ removeWriter_FakeFDSetReactor.removeWriter+rrYcpVP4VP4,pVP4V#rW) getReaders getWritersrrrqresults& rZ removeAll_FakeFDSetReactor.removeAll/s("T__%66  rYc,\VP4#rW)listrrs&rZr_FakeFDSetReactor.getReaders4DMM""rYc,\VP4#rW)rrrs&rZr_FakeFDSetReactor.getWriters7rrY)rrN)rrrrrrrrrrrrrrrrrs@rZrrs7 ")") ###rYrcBa]tRtRtoRtRtRtRtRtRt Rt Vt R #) TCPServerTestsi>z4 Whitebox tests for L{twisted.internet.tcp.Server}. c\4Vn!RR4p\R4Vn\ 4Vn\ VPVP RV!4RVP4VnR#)c]tRtRt^tRtR#)&TCPServerTests.setUp..FakePortiFrXN)rrrr_realPortNumberrrXrYrZFakePortrFsOrYrrYN)rS)rreactorrlrr/protocolr2server)rqrs& rZsetUpTCPServerTests.setUpCsS(*   c?   HHdmmWhj$   rYc VPP\\R444VPP R4VP VP P.4R#)zY L{Server.write} discards bytes passed to it if called after it has lost its connection. Simulated lost connection hello worldN)rconnectionLostrH Exceptionwriterrrors&rZtest_writeAfterDisconnect(TCPServerTests.test_writeAfterDisconnectOsM ""795P+Q#RS .) ,,b1rYc HRVPnVP4R#)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&rZ!test_writeAfterDisconnectAfterTLS0TCPServerTests.test_writeAfterDisconnectAfterTLSXs   &&(rYc VPP\\R444VPP R.4VP VP P.4R#)za L{Server.writeSequence} discards bytes passed to it if called after it has lost its connection. rrN)rrrHr writeSequencerrrors&rZ!test_writeSequenceAfterDisconnect0TCPServerTests.test_writeSequenceAfterDisconnect`sP ""795P+Q#RS !!>"23 ,,b1rYc HRVPnVP4R#)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&rZ)test_writeSequenceAfterDisconnectAfterTLS8TCPServerTests.test_writeSequenceAfterDisconnectAfterTLSis   ..0rY)rrrrN) rrrrrrrrrrrrrs@rZrr>s(  2)211rYrcXa]tRtRtoRtRtRt]!]'*R4R4t Rt Vt R#) TCPConnectionTestsirz8 Whitebox tests for L{twisted.internet.tcp.Connection}. c d\R4p\4p\W4pVP4VP \P .4pVP V^,R,\4VP V^,R,R4VP \V4^4R#)z| When an L{IProtocol} implementation that returns a value from its C{dataReceived} method, a deprecated warning is emitted. rcategorymessagezReturning a value other than None from twisted.internet.test.test_tcp.FakeProtocol.dataReceived is deprecated since Twisted 11.0.0.N) rlrr1doRead flushWarningsrrDeprecationWarningr)rqrrconnwarningss& rZtest_doReadWarningIsRaised-TCPConnectionTests.test_doReadWarningIsRaisedws %>#( %%|'@'@&AB !Z02DE  QK " 2 X*rYc |\R4p\4p\W4pVPVP4R#)zg The C{TLS} attribute of a L{Connection} instance is C{False} before L{Connection.startTLS} is called. rYN)rlrr1 assertFalserrqrrrs& rZtest_noTLSBeforeStartTLS+TCPConnectionTests.test_noTLSBeforeStartTLSs0 o>#( "rYzNo SSL support availablec \R4p\4p\W\4R7pRVnVP \ 4R4VPVP4R#)ze The C{TLS} attribute of a L{Connection} instance is C{True} after L{Connection.startTLS} is called. rY)rTN) rlrr1r_tlsClientDefaultstartTLSrR assertTruerr s& rZtest_tlsAfterStartTLS(TCPConnectionTests.test_tlsAfterStartTLSsN o>#1B1DE!% *,d3 !rYrXN) rrrrrrr r useSSLrrrrs@rZrrrs2+&# J23 "4 "rYrc4a]tRtRtoRtRtRtRtRtVt R#) TCPCreatorizG Create IPv4 TCP endpoints for L{runProtocolsWithReactor}-based tests. 127.0.0.1c 2\V^VPR7#)z$ Create a server-side TCP endpoint.  interface)rr)rqrs&&rZrTCPCreator.servers"'1GGrYc B\WPVP4#)zh Create a client end point that will connect to the given address. @type serverAddress: L{IPv4Address} )rrri)rqr serverAddresss&&&rZrfTCPCreator.clients "'>>=;M;MNNrYrXN) rrrrrrrrfrrrs@rZrrs#IH OOrYrc*a]tRtRtoRtRtRtVtR#) 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$\4VnR#rWr_rrs&rZrrTCP6Creator.__init__ 02rYrN)rrrrrrrrrrs@rZrrs 33rYrcLa]tRtRtoRtV3RlRltR V3RlRlltRtVtR#) FakeResolverizJ A resolver implementation based on a C{dict} mapping names to addresses. c6<V^8dQhRS[S[S[3,/#)names)rstr)formatrs"rZ __annotate__FakeResolver.__annotate__sgc3h/rYcWnR#rWr()rqr(s&&rZrrFakeResolver.__init__s rYc:<V^8dQhRS[RS[S[,RR/#)r'nametimeoutreturnz Deferred[str])r)r int)r*rs"rZr+r,s+ N N# N N NrYc \VPV,4# \d\\ RT,44u#i;i)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 )rqr1r2s&&&rZ getHostByNameFakeResolver.getHostByNamesC N4::d+, , N'Dt'KLM M Ns&AAr.N)rX) rrrrrrrr7rrrs@rZr%r%s& N N NrYr%cla]tRtRtoRt]3tRt]R4t ]R4t Rt Rt Rt R tR tR tVtR#) 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} Nc VPe%VPP4P#\VPVP 4^,#)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} )_portgetHostrir?rfamilyrs&rZriTCPClientTestsBase.port sA :: !::%%',, ,DNNDKK8;;rYc .VPP#)z; Return the interface attribute from the endpoints object. ) endpointsrrs&rZrTCPClientTestsBase.interfaces ~~'''rYc ^VP^W PR7VnVP#)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. r) listenTCPrr<rqrfactorys&&&rZlistenTCPClientTestsBase.listen!s)&&q'^^&L zzrYc PVPVPVPV4#)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. ) connectTCPrrirEs&&&rZreTCPClientTestsBase.connect.s!!!$..$))WEErYc aa a a \4o SP4o \4pS Vn\ SS 4!RR\ 4o SP PS 4PV4pV V V3RlpVPV4pV3RlpRpVPWV4V 3RlpVPV4pVP\P4V 3Rlp VPV 4SPS 4R#) zZ When the factory's C{buildProtocol} returns L{None} the connection is gracefully closed. c&a]tRtRtoRtRtVtR#)ETCPClientTestsBase.test_buildProtocolReturnsNone..NoneFactoryiGcR#rWrX)rqrjs&&rZ buildProtocolSTCPClientTestsBase.test_buildProtocolReturnsNone..NoneFactory.buildProtocolHsrYrXNrrrrrPrrrs@rZ NoneFactoryrNGs  rYrSc<S!4pSPPSVP44pVPV4#rW)rArfr=re)ri clientFactoryendpointrSrrqs& rZlistenedBTCPClientTestsBase.test_buildProtocolReturnsNone..listenedMs7'MM~~,,WdllnEH##M2 2rYc4<SPRV: R24R#)z.Stream client endpoint connect succeeded with z%, should have failed with NoProtocol.N)r)rrqs&rZconnectSucceededJTCPClientTestsBase.test_buildProtocolReturnsNone..connectSucceededTs II9AD rYc0VP\4R#rW)trapr!)reasons&rZ connectFailedGTCPClientTestsBase.test_buildProtocolReturnsNone..connectFailedZs KK #rYc<S#rWrX)ignoredrs&rZ connectedCTCPClientTestsBase.test_buildProtocolReturnsNone..connected_s " !rYc(<SP4R#rWstop)rbrs&rZ disconnectedFTCPClientTestsBase.test_buildProtocolReturnsNone..disconnectedjs LLNrYN)r buildReactorrMprotocolConnectionLostrCr0rArrG addCallback addCallbacks addErrbackrGerr runReactor) rq serverFactory listeningrW connectingrZr_rc disconnectingrhrSrrs f @@@rZtest_buildProtocolReturnsNone0TCPClientTestsBase.test_buildProtocolReturnsNone:s "##%') /= , D'" - NN))'299-H  3 **84    $  0@ " #..y9    )  !!,/  rYc <aa a a a a \SPSP4R,wrSP4o SPo S P \ S SP/44S P^\P!\4VR7o S P4pRRRRRR/o !V V 3RlR\4p\S 4o VS n V V V VV 3R lp\S V4SPS 4S P 'd*SP#S P P%44R P'S R,P(S R,P*\-S R,44pV.\/\0P2!SPS P44^,R ,R ,4,pV.\/\0P2!SPVP64^,R ,R ,4,pSP9S R,SP:!R .VO5!4SP9S R,SP:!R .VO5!4SP9\=S R,4V4R#)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. Nr'NrrhNpeerinstancec0<a]tRtRtoVV3RltRtVtR#)7TCPClientTestsBase.test_addresses..CheckAddressic~<VP4SR&VP4SR&VSR&SP4R#)rhryrzN)r=getPeerrg)rq transportr transportDatas&&rZmakeConnectionFTCPClientTestsBase.test_addresses..CheckAddress.makeConnections<(1(9(9(; f%(1(9(9(; f%,5 j) rYrXNrrrrrrr)rrrs@rZ CheckAddressr|s  rYrcB<\SPSP4pSPV^,3p\P!RV 24SP SSP 4PSVR7V^,SnR# \dKi;i)Tz!Connect attempt with bindAddress ) bindAddressN) r?rr>rGmsgrJr=ri boundPortr)rirrU fakeDomainrrqrs rZ connectMe4TCPClientTestsBase.test_addresses..connectMes#DNNDKK@#~~tAw7 ;K=IJ &&"(--%$/ '/31gM+ (s-B BBz<{} to {} at {:x}>NNTCP)r?rr>rjfakeDomainNameinstallResolverr%rDr0 forProtocolr/r=r=rrBrp failReasonr getTracebackr* __class__addridrrcrdrrir addressClassrepr)rqrhrbrrr transportReprr serverPortrUrrrrsf @@@@@rZtest_addresses!TCPClientTestsBase.test_addressesus$%T^^T[[A"E ##%((  j$..-I JK"" }((2d# ( vtZF   8 W !-   $ GY/   # # # IIm..;;= >,33 * % / / * % * * }Z( ) FT   t~~}/F/F G J2 Nr R  Vd   t~~}/A/A B1 Eb I" M   v.0A0A%0T)0TU v.0A0A%0U*0UV mJ78-HrYc aaaaa a a SP4o \4o.o \P!\4pS P ^VSP R7pSPPS VP44p\4p\Vn VPV4oVV V3Rlo V 3RloVVV V 3Rlp\S V4SPS 4SP\!S 4^RS 24\#S ^,\$4'dS ^,P'4S ^,R8Xd \)R4hSP\P*\-S ^,44R#) 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}. rc<\P!VP4'gSPR4R#SPSP \ VPP S44R#)skipN)r- providedByrr~ assertRaises ValueErrorr)r brokenFactoryresultsrqs&rZrc5TCPClientTestsBase.test_badContext..connectedsS ++H,>,>??v&%%"H$6$6$?$?rYc*<SPV4R#rWr~)failurers&rZr_9TCPClientTestsBase.test_badContext..connectFaileds NN7 #rYcv<SPS4SPS4SPV3Rl4R#)c$<SP4#rWrfignrs&rZr[ETCPClientTestsBase.test_badContext..whenRun..s  rYN)rlrnaddBoth)connectDeferredr_rcrsrZwhenRun3TCPClientTestsBase.test_badContext..whenRuns.  ' ' 2  & &} 5  # #$> ?rYzmore than one callback result: rz&Reactor does not support ITLSTransportN)rjr8r0rr/rDrrArfr=r.rrerBrprr isinstancerHraiseExceptionrNrr)) rqrqrirVrUrrrr_rcrrs f @@@@@@rZtest_badContext"TCPClientTestsBase.test_badContexts* ##%,. %11(;   MT^^ L>>(($,,.A% !) "**=9  $ @ @ GW-   Wq,KG9*UV gaj' * * AJ % % ' 1: CD D -55s71:GrY)r<)rrrrrr*requiredInterfacesr<propertyrirrGrerurrrrrs@rZr:r:se$L& E  < <((  F9!vHIT0H0HrYr:cH]tRtRtRtRt]Pt] t ] !4t Rt R#)TCP4ClientTestsBuilderizY Builder configured with IPv4 parameters for tests related to L{IReactorTCP.connectTCP}. zsome-fake.domain.example.comrXN)rrrrrrrcAF_INETr>rrrrArrXrYrZrrs# 4N ^^FL IrYrcFa]tRtRtoRt]P t]t Rt Rt Vt R#)TCP6ClientTestsBuilderizY Builder configured with IPv6 parameters for tests related to L{IReactorTCP.connectTCP}. cZ\4VnVPPVnR#rW)rrArrrs&rZrTCP6ClientTestsBuilder.setUp s!%#nn66rY)rArN) rrrrrrcAF_INET6r>rrrrrrs@rZrrs$ __FL 7 7rYrc<a]tRtRtoRt]3tRtRtRt Rt Vt R#)TCPConnectorTestsBuilderizM Tests for the L{IConnector} provider returned by L{IReactorTCP.connectTCP}. c ,aaa \4pVP4oSP^WPR7pW!nVP 4Pp.o.o \ 4pVV 3RlVnSPVn SPVPW44pVP\P!V44VP4pVPVP R4VPVP"VP4VPVPV4VP$P'V3Rl4VP)S4S ^,P+\,4VPSWU.4R#)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. rcH<SPV4SPV43#rWr) connectorr^seenConnectors seenFailuress&&rZr[ATCPConnectorTestsBuilder.test_connectorIdentity../s%  ! !) ,    'H rYrc$<SP4#rWrf_rs&rZr[r< GLLNrYN)rKrjrDrrir=rJclientConnectionLostr~startedConnectingrJrr#rgetDestinationrtyperh whenStoppedrrpr]r) rqrqtcpPort portNumberrUrdestrrrs & @@@rZtest_connectorIdentity/TCPConnectorTestsBuilder.test_connectorIdentitys9'( ##%##A}#O$__&++  .0 . *+9*?*? '&&t~~zQ   --i89'') E* DNN3 J/!!))*BC  Q^, ))?@rYc Jaaaaa\4pSP4oSP^VSPR7pVP 4P o.oVV3Rlp\ 4oVSnSPPV3Rl4SPVVVV3Rl4SPS4S'd'SPS^,P44SPP\ 4SP#SP$^4R#)z Calling L{IConnector.stopConnecting} in C{Factory.startedConnecting} results in C{Factory.clientConnectionFailed} being called with L{error.UserError} as the reason. rc<VP4R# \d.SP\44SP 4R#i;irW)stopConnectingrr~rHrg)r fatalErrorsrs&rZrATCPConnectorTestsBuilder.test_userFail..startedConnectingPs< ((* ""79-  s4A  A c$<SP4#rWrfrs&rZr[8TCPConnectorTestsBuilder.test_userFail..ZrrYc><SPSPSS4#rW)rJr)rUrrrqsrZr[r]sG&&t~~z=QrYN)rMrjrDrr=rirJrrrcallWhenRunningrprrr^r]r"rfailed)rqrqrrrUrrrsf @@@@rZ test_userFail&TCPConnectorTestsBuilder.test_userFailCs () ##%##A}#O__&++   /0 *; '!!))*BC Q    IIk!n113 4!!), --q1rYc aaa\4pVP4oSP^WPR7pW!nVP 4Pp\ 4oRpVSnSPVPVS4.oVVV3RlpSPPV4VPS4SPP\4VPSR.4R#)zn Calling L{IConnector.connect} in C{Factory.clientConnectionLost} causes a new connection attempt to be made. rc&VP4R#rW)re)rr^s&&rZrETCPConnectorTestsBuilder.test_reconnect..clientConnectionLostts    rYc<SPpSPVPVP34SP 4R#rW) lastProtocolr~madeclosedrg)rbprUprotocolMadeAndClosedrs& rZreconnectFailed@TCPConnectorTestsBuilder.test_reconnect..reconnectFailed|s2**A ! ( (!&&!((); < LLNrYN)rr)rKrjrDrrir=rLrrJ failDeferredrlrpr^r]rr) rqrqrrrrrUrrs & @@@rZtest_reconnect'TCPConnectorTestsBuilder.test_reconnectgs '( ##%##A}#O$__&++ ')  .B *4>>:}E "  ""..?  !!"89 .9rYrXN) rrrrrr*rrrrrrrs@rZrrs+&$AL"2H::rYrc6]tRtRtRt]P t]t Rt R#)TCP4ConnectorTestsBuilderirrXN) rrrrrrcrr>rrrrXrYrZrrsI ^^FLrYrcBa]tRtRto]P t]tRt Rt Vt R#)TCP6ConnectorTestsBuilderic$\4VnR#rWr!rs&rZrTCP6ConnectorTestsBuilder.setUpr#rYrN) rrrrrcrr>rrrrrrs@rZrrs __FL33rYrch\P!W4pVPVP4V#)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. )rc addCleanupr)test addressFamily socketTypers&&& rZcreateTestSocketrs' -- 2COOCII JrYc6a]tRtRtoRtRtRtRtRtVt R#)_IExhaustsFileDescriptorsiz A way to trigger C{EMFILE}. c R#)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}. NrXrXrYrZexhaust!_IExhaustsFileDescriptors.exhaustrrYc R#z4 Release all file descriptors opened by L{exhaust}. NrXrXrYrZrelease!_IExhaustsFileDescriptors.releaserrYc R#) 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} NrXrXrYrZr_IExhaustsFileDescriptors.countrrYrXN rrrrrrrrrrrs@rZrrs    rYr) auto_attribsca]tRtRtoRt]!4t]P!RRR7t ]P!] PRR7t ]P!]P!]4RRR7tRtRtR tV3R ltR tVtR #) _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}. c.\P!^4#r)osduprXrYrZr[!_ExhaustsFileDescriptors.s q rYF)defaultr)rinitrc \P!4VP4pVPP V4K/ \ d+pTP \ P8XdRp?M hRp?ii;iTPPRTP4R7R# \dTP4hi;i)z3 Open file descriptors until C{EMFILE} is reached. NzCEMFILE reached by opening {openedFileDescriptors} file descriptors.)openedFileDescriptors) gccollect_fileDescriptorFactory_fileDescriptorsr~OSErrorerrnoEMFILE_loginforrrrqfdes& rZr _ExhaustsFileDescriptors.exhausts  5446B ))004 ww%,,. IINN=&*jjl     LLN  s9B+AB+ A;A60B+5A66A;;B++Cc VP'd/VPP4pVPV4K@R# \d,pTP\P 8XdRp?KrhRp?ii;ir)rpop_closerrEBADFr s& rZr _ExhaustsFileDescriptors.releasesa###&&**,B  B$ 77ekk) sA A9A43A44A9c ,\VP4#)r)rrrs&rZr_ExhaustsFileDescriptors.counts4(())rYc<V^8dQh/S[S[,;R&S[.S[3,;R&S[S[.R3,;R&S[S[,;R&#)r'rrNr&r)rrFrr4r)r*rs"rZr+%_ExhaustsFileDescriptors.__annotate__sZ 6 %%RW-$ cUD[ !I%&3i'rYrXN)rrrrrrFrattribrrrr&Factoryrrrrr__annotate_func__rrrs@rZr r ss $XD04!1%)GGBHH5$IF"&'' T"U#4 *}rYr 9Reserved EMFILE file descriptor not supported on Windows.c`a]tRtRtoRtRtRtRtRtRt Rt R t R t R t R tR tVtR#)ExhaustsFileDescriptorsTestsiz( Tests for L{_ExhaustsFileDescriptors}. cn\4VnVPVPP4R#rW)r  exhausterrrrs&rZr"ExhaustsFileDescriptorsTests.setUps$13 ../rYc T\\P4P4R#)zH Attempt to open a file; if successful, the file is immediately closed. N)openrdevnullrrs&rZ openAFile&ExhaustsFileDescriptorsTests.openAFiles RZZ rYc :\\VP4R#)zM L{_ExhaustsFileDescriptors} instances provide L{_IExhaustsFileDescriptors}. N)rrr5rs&rZtest_providesInterface3ExhaustsFileDescriptorsTests.test_providesInterface"s .?rYc jVPVPP4^4VPP4VP VPP4^4VPP 4VPVPP4^4R#)zP L{_ExhaustsFileDescriptors.count} returns the number of open file descriptors. N)rr5rr assertGreaterrrs&rZ test_count'ExhaustsFileDescriptorsTests.test_count)s{ --/3   4>>//115   --/3rYc VPVPP4VPP4VP \ VP 4pVPVP\P4R#)zc L{_ExhaustsFileDescriptors.exhaust} causes the process to exhaust its available file descriptors. N) rr5rrrIOErrorr:rrr)rq exceptions& rZtest_exhaustTriggersEMFILE7ExhaustsFileDescriptorsTests.test_exhaustTriggersEMFILE4sX ../  %%gt~~>  %,,7rYc bRp\V4pVP\VP4R#)z An L{OSError} raised within L{_ExhaustsFileDescriptors.exhaust} with an C{errno} other than C{EMFILE} is reraised to the caller. cD\\P^,R4h)rz Not EMFILE)rrrrXrYrZ raiseOSErrorLExhaustsFileDescriptorsTests.test_exhaustRaisesOSError..raiseOSErrorEs%,,*L9 9rYN)r rrr)rqrJr5s& rZtest_exhaustRaisesOSError6ExhaustsFileDescriptorsTests.test_exhaustRaisesOSError>s) :-\:  '9#4#45rYc VPP4VPP4VP4R#)zK L{_ExhaustsFileDescriptors.release} releases all opened file descriptors. N)r5rrr:rs&rZ test_release)ExhaustsFileDescriptorsTests.test_releaseKs.     rYc a.oV3Rlp\V4pVPVP4VP\VP 4VP \S4^4VP VP4^4SFRpVP\\PV4pVP VP\P4KT R#)z{ L{_ExhaustsFileDescriptors.exhaust} closes any opened file descriptors if an exception occurs during its exhaustion loop. c<\S4^8Xd \R4h\P!^4pSP V4V#)z9test_fileDescriptorsReleasedOnFailure fake open exception)rrrrr~r!fileDescriptorss rZfailsAfterThree[ExhaustsFileDescriptorsTests.test_fileDescriptorsReleasedOnFailure..failsAfterThree\sB?#q( RVVAY&&r* rYN)r rrrrrrrrrrfstatrr')rqrVr5r!rErUs& @rZ%test_fileDescriptorsReleasedOnFailureBExhaustsFileDescriptorsTests.test_fileDescriptorsReleasedOnFailureUs  -_=   ))* *i&7&78 _-q1 *A.!B))'288R@I   Y__ekk :"rYc ^a.oV3Rlp\V4pVPVP4VP4VP VP 4^4\ P!S^,4VP4VPVP 4^4R#)z{ L{_ExhaustsFileDescriptors.release} continues to close opened file descriptors even when closing one fails with C{EBADF}. cV<\P!^4pSPV4V#r)rrr~rTs rZrecordFileDescriptorsTExhaustsFileDescriptorsTests.test_releaseIgnoresEBADF..recordFileDescriptorsxs#B  " "2 &IrYN) r rrrr@rrrr)rqr]r5rUs& @rZtest_releaseIgnoresEBADF5ExhaustsFileDescriptorsTests.test_releaseIgnoresEBADFqs   --BC   ))* 9??,a0 #$ *A.rYc a.oV3RlpRp\WR7pVPVP4^4VP4VP VP4^4VP \ VP4R#)z An L{OSError} raised within L{_ExhaustsFileDescriptors.release} with an C{errno} other than C{EBADF} is reraised to the caller. c<\S4^8Xd\\PR4hSP R4SR,#)rSzToo many filesr)rrrrr~)fakeFileDescriptorssrZ opensThreeJExhaustsFileDescriptorsTests.test_releaseRaisesOSError..opensThrees<&'1,ell,<==  & &r *&r* *rYc\^ R4h) z&test_releaseRaisesOSError fake OSError)r)r!s&rZ failingCloseLExhaustsFileDescriptorsTests.test_releaseRaisesOSError..failingCloses"FG GrY)rN)r rrrr@rrr)rqrdrhr5rcs& @rZtest_releaseRaisesOSError6ExhaustsFileDescriptorsTests.test_releaseRaisesOSErrorsr ! +  H-ZL  *A. 9??,a0 '9#4#45rY)r5N)rrrrrrr:r=rArFrLrOrYr_rjrrrs@rZr3r3sB0 !@ 48 6;8/.66rYr3czaaaaa aaVPSP4\4o\4pVSnR.oVV3RlpVP V4\ 4o \P!S4'd+V VVVVV3RlpSP^SP^V4M>S!SS4p V P4p S!SV S 4SPSP4VV3Rlp S PPV 4S PPV 4V!S4.p VPV P 4VP#V R4VP%S P4VP'S P4VP)\*S P,P.4R#)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. Fc2<SP4RS^&R#TNrf)rrserverConnectionCompleteds&rZstopReactorIfServerAccepted=assertPeerClosedOnEMFILE..stopReactorIfServerAccepteds '+!!$rYcn<S!SS4pVP4pS!SVS4SP4R#rW)r=r)ri listeningHostrUrer5rGrrqs rZinner'assertPeerClosedOnEMFILE..inners2'=1D LLNM G]M :    rYcH<SP4SP4V#rW)rrg)rr5rs&rZ"stopReactorAndCloseFileDescriptorsDassertPeerClosedOnEMFILE..stopReactorAndCloseFileDescriptorss  rYz1Server accepted connection; EMFILE not triggered.N)rrrMrprotocolConnectionMaderlrLr+r callLaterr=rrdeferredrrr~r assertNoResultsuccessResultOfrr lostReasonr)testCaser5rrprGreserverConnectionMaderprtrirsrwnoResultrUrorqs&ff&ff @@@rZassertPeerClosedOnEMFILErsqH  ))*#%M#:+?M(!&,$$%@A#%Mw''   !W..59g}-   6 1 12 ""#EF&&'IJwH  1 #VW M667 ]334   //rYc`a]tRtRtoRt]!]4!RR44tRtRt Rt Rt Vt R #) AssertPeerClosedOnEMFILETestsiz( Tests for L{assertPeerClosedOnEMFILE}. c6a]tRtRtoRtRtRtRtRtVt R#)+AssertPeerClosedOnEMFILETests.NullExhausteriz! An exhauster that does nothing. c R#)z* See L{_IExhaustsFileDescriptors.exhaust} NrXrs&rZr3AssertPeerClosedOnEMFILETests.NullExhauster.exhaust rrYc R#)z* See L{_IExhaustsFileDescriptors.release} NrXrs&rZr3AssertPeerClosedOnEMFILETests.NullExhauster.releaserrYc R#)z( See L{_IExhaustsFileDescriptors.count} NrXrs&rZr1AssertPeerClosedOnEMFILETests.NullExhauster.countrrYrXNr rs@rZ NullExhausterrs       rYrcB\4Vn\4VnR#rW)rDrrOrrs&rZr#AssertPeerClosedOnEMFILETests.setUps$ +- rYc B\\VP44R#)zB L{NullExhauster} instances provide L{_IExhaustsFileDescriptors}. N)rrrrs&rZ#test_nullExhausterProvidesInterfaceAAssertPeerClosedOnEMFILETests.test_nullExhausterProvidesInterfaces .0B0B0DErYc  VaVP4pR.oV3RlpV3RlpRpVPVPP\VPVVP VVVR7pVP R\V44VPVP P4R#)z} If the exhauster fails to trigger C{EMFILE} and a connection reaches the server, the reactor is stopped and the test fails. Nc<VP4S^,P\RRR44pVP\ 44R#)rrriN)runrPrrrE)rprotorqs& rZrp[AssertPeerClosedOnEMFILETests.test_reactorStoppedOnSuccessfulConnection..runReactor+s@ KKM!!$22E;5E  !2 3rYcX<VPRRV4pVP4VS^&V#)ri)rDdoStart)rrFrirqs&& rZrGWAssertPeerClosedOnEMFILETests.test_reactorStoppedOnSuccessfulConnection..listen2s0$$[$@D OO &M! KrYc,VPR^V4R#)rN)rJ)rrjrFs&&&rZreXAssertPeerClosedOnEMFILETests.test_reactorStoppedOnSuccessfulConnection..connect8s   {Aw 7rYrr5rrprGrer) rrrfailureExceptionrrassertInr)r running)rqr5rprGrerErqs& @rZ)test_reactorStoppedOnSuccessfulConnectionGAssertPeerClosedOnEMFILETests.test_reactorStoppedOnSuccessfulConnection#s &&(   4   8%% MM * * $]]LL!&   hI/ --.rY)rrN) rrrrrr rrrrrrrrs@rZrrs>*+,(.F$/$/rYrcNa]tRtRtoRtRtRt]!]R4R4t Rt Vt R#) StreamTransportTestsMixiniJzJ Mixin defining tests which apply to any port/connection based transport. c VP4pVP4p\\4!RR\44pV!4pVP W$4pVP VR4pVPV3V^,R,4R#)z\ When a port starts, a message including a description of the associated factory is logged. c&a]tRtRtoRtRtVtR#)NStreamTransportTestsMixin.test_startedListeningLogMessage..SomeFactoryiWcR#) Crazy FactoryrXrs&rZ logPrefixXStreamTransportTestsMixin.test_startedListeningLogMessage..SomeFactory.logPrefixYs&rYrXN)rrrrrrrrs@rZ SomeFactoryrWs ' 'rYrrrN)observerjr r%r0getListeningPort#getExpectedStartListeningLogMessager)rqloggedMessagesrrrFrexpectedMessages& rZtest_startedListeningLogMessage9StreamTransportTestsMixin.test_startedListeningLogMessageOs ##% _ % '- ' & '-  ! !' 3BB1oV /+^A->y-IJrYc Faaaaa.oV3RloVP4oVPS\44oVPS4p\P !S4VV3RloVVV3RlpSP V4SP4VPVS4R#)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. cR<SP\P!V44R#rW)r~rGtextFromEventDict) eventDictrs&rZlogConnectionLostMsgQStreamTransportTestsMixin.test_connectionLostLogMsg..logConnectionLostMsgjs  ! !#"7"7 "B CrYcT<\P!S4SP4R#rW)rGremoveObserverrg)rbrrs&rZ stopReactorHStreamTransportTestsMixin.test_connectionLostLogMsg..stopReactorrs   3 4 LLNrYc|<\P!S4\SP4P S4R#rW)rG addObserverr stopListeningrl)rrrsrZdoStopListeningLStreamTransportTestsMixin.test_connectionLostLogMsg..doStopListeningvs' OO0 1 !// * 6 6{ CrYN) rjrr0getExpectedConnectionLostLogMsgrGrrrr)rqrrrrrrrs& @@@@@rZtest_connectionLostLogMsg3StreamTransportTestsMixin.test_connectionLostLogMsgas D##%  ! !'=? ;>>qA ,-  D 0  o~6rYr1c  \V\4VP4VPVPVP R7R#)z" See L{assertPeerClosedOnEMFILE}. rN)rr rjrprconnectToListenerrs&rZtest_closePeerOnEMFILE0StreamTransportTestsMixin.test_closePeerOnEMFILEs: !.0%%'((**  rYrXN) rrrrrrrr SKIP_EMFILErrrrs@rZrrJs2K$7< KTU  V  rYrc.a]tRtRtoRtRtRtRtVtR#)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} rc PVPVPVPV4#)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 )rJ LISTENER_HOSTri)rqrrjrFs&&&&rZr+ConnectToTCPListenerMixin.connectToListeners# !!$"4"4gllGLLrYrXN) rrrrrrrrrrs@rZrrs  MMMrYrc.a]tRtRtoRtRRltRtVtR#)ListenTCPMixinizL Mixin which uses L{IReactorTCP.listenTCP} to hand out listening TCP ports. c (VPW2VR7#)z Get a TCP port from a reactor. r)rD)rqrrFrirs&&&&&rZrListenTCPMixin.getListeningPorts  ) DDrYrXNrrSrrrrrrrrrs@rZrrsEErYrc.a]tRtRtoRtRRltRtVtR#)SocketTCPMixinizU Mixin which uses L{IReactorSocket.adoptStreamPort} to hand out listening TCP ports. c b\P!V4'dRV9d6\Pp\P!WC4^,^,pM\P pWC3p\P!V4pVP V4VP^4VPR4VPVP4VPV4VP4VP4#\R4h TP4TP4i;i)zQ Get a TCP port from a reactor, wrapping an already-initialized file descriptor. rbFz'Reactor does not provide IReactorSocket)r)rrcrrdrbindrGrvadoptStreamPortrr>rrN)rqrrFrirdomainrjportSocks&&&&& rZrSocketTCPMixin.getListeningPorts  $ $W - -i ,,Y=a@C$+}}V,H MM' " OOA    ' !..OO%x ! DE E ! s 6*D "D.rXNrrrs@rZrrs FFrYrcVa]tRtRtoRt]3tRtRtRt ] !] ] 4R4t ] !] ] 4R4tRtR t] !] ] 4R 4t] !] ] 4R 4tR tR t] !] ] 4R4t] !] ] 4R4tRt] !] ] 4R4t] !] ] 4R4tV3RltRtVtR#)TCPPortTestsMixiniz$ Tests for L{IReactorTCP.listenTCP} c FRW!P4P3,#)zI Get the message expected to be logged when a TCP port starts listening. z%s starting on %dr=ri)rqrirFs&&&rZr5TCPPortTestsMixin.getExpectedStartListeningLogMessages#g||~/B/B%CCCrYc >RVP4P R2#)z: Get the expected connection lost message for a TCP port. z (TCP Port z Closed)r)rqris&&rZr1TCPPortTestsMixin.getExpectedConnectionLostLogMsgs DLLN//099rYc VP4pVPV\44pVP4pVP V\ 4R#)zr When no interface is passed to L{IReactorTCP.listenTCP}, the returned listening port listens on an IPv4 address. N)rjrr0r=assertIsInstancer)rqrrirjs& rZtest_portGetHostOnIPv4(TCPPortTestsMixin.test_portGetHostOnIPv4sA ##%$$Wmo>,,. g{3rYc ^VP4p\\PRR7R,wr#VP V\ 4W24pVP 4pVPV\4VPRVP4VPW5P4R#)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. ::1)r>rrxN) rjr?rcrrr0r=rrrrhri)rqrrhrrirjs& rZtest_portGetHostOnIPv6(TCPPortTestsMixin.test_portGetHostOnIPv6s##%'v%PQST$$WmozP,,. g{3  - \\2rYc \4pVP4pVPV\4^V4pVP 4pVP V\ 4VPWP4R#)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. N) r_rjrr0r=rrrrh)rq linkLocalrrirjs& rZtest_portGetHostOnIPv6ScopeID/TCPPortTestsMixin.test_portGetHostOnIPv6ScopeID s_,- ##%$$Wmoq)L,,. g{3 LL1rYc a!V3RlR\4pV!4pVP4oVPSV^V4pVPR4\ WP 4P VP 4P34VPS4VP# \dEpTPTP\P\P34Rp?LgRp?ii;i)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.<a]tRtRtoV3RltRtVtR#)CTCPPortTestsMixin._buildProtocolAddressTest..ObserveAddressi.cD<SP4Wn\4#rW)rgobservedAddressr/)rqrjrs&&rZrPQTCPPortTestsMixin._buildProtocolAddressTest..ObserveAddress.buildProtocol/s '.$z!rY)rNrR)rrs@rZObserveAddressr.s " "rYrFN)r0rjrrvrer=rhrirrr EINPROGRESS EWOULDBLOCKrpr)rqrfrrrFrir"rs&&& @rZ_buildProtocolAddressTest+TCPPortTestsMixin._buildProtocolAddressTests& "] " !"##%$$Wgq)D5! K F\\^00$,,.2E2EF G  &&&  K MM!''E$5$5u7H7H#I J J Ks=B++ C:6:C55C:c Rp\V\P\P4pVP W!4pVP \ R.VP4O5!V4R#)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)rrcr SOCK_STREAMrrr getsockname)rqrrfrs& rZtest_buildProtocolIPv4Address/TCPPortTestsMixin.test_buildProtocolIPv4AddressAsT  !$8J8JK88K UBV-?-?-ABOTrYc <Rp\V\P\P4pVP W!4pVP 4p\P !V\P4^,pVP\RWT^,4V4R#)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. rrN) rrcrrrr getnameinfoNI_NUMERICHOSTrrrqrrfrryhostnames& rZtest_buildProtocolIPv6Address/TCPPortTestsMixin.test_buildProtocolIPv6AddressKsw !$9K9KL88K!!#%%dF,A,AB1E UH1g>PrYc P\4p\V\P\P4pVP W!4pVP 4p\P!V\P4^,pVP\RV.VR,O5!V4R#)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. rrN) r_rrcrrrrrrrrrs& rZ$test_buildProtocolIPv6AddressScopeID6TCPPortTestsMixin.test_buildProtocolIPv6AddressScopeID[s,- !$9K9KL88K!!#%%dF,A,AB1E UH@tBx@/RrYc aa!VV3RlR\4pVP4o\4pWEnVP SV^V4pVP R4\ WP4PVP4P34VPS4VP # \dEpTPTP\P\P34Rp?LgRp?ii;i)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}. c0<a]tRtRtoVV3RltRtVtR#)ITCPPortTestsMixin._serverGetConnectionAddressTest..ObserveAddressich<SP4\VS4!4VPnR#rW)rggetattrrFrj)rqrrwhichs&&rZrXTCPPortTestsMixin._serverGetConnectionAddressTest..ObserveAddress.makeConnections" '.y%'@'B $rYrXNr)rrrs@rZrr s C CrYrFN)r/rjr0rrrvrer=rhrirrrrrrprj) rqrfrrrrFrir"rs &&&f @rZ_serverGetConnectionAddressTest1TCPPortTestsMixin._serverGetConnectionAddressTestks* C CX C ##%/)$$Wgq)D5! K F\\^00$,,.2E2EF G   K MM!''E$5$5u7H7H#I J J Ks=B66 D:DDc Rp\V\P\P4pVP W!R4pVP \ R.VP4O5!V4R#)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)rrcrrrrr getpeername)rqrrf hostAddresss& rZtest_serverGetHostOnIPv4*TCPPortTestsMixin.test_serverGetHostOnIPv4V  !$8J8JK::6iX  UBV-?-?-ABKPrYc BRp\V\P\P4pVP W!R4pVP 4p\P !V\P4^,pVP\RV.VR,O5!V4R#)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. rr=rrN) rrcrrrrrrrrrqrrfrryrs& rZtest_serverGetHostOnIPv6*TCPPortTestsMixin.test_serverGetHostOnIPv6~ !$9K9KL::6iX !!#%%dF,A,AB1E UH@tBx@+NrYc R\4p\V\P\P4pVP W!R4pVP 4p\P!V\P4^,pVP\RV.VR,O5!V4R#)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=rrN) r_rrcrrrrrrrrrs& rZtest_serverGetHostOnIPv6ScopeID1TCPPortTestsMixin.test_serverGetHostOnIPv6ScopeID,- !$9K9KL::6iX !!#%%dF,A,AB1E UH@tBx@+NrYc Rp\V\P\P4pVP W!R4pVP \ R.VP4O5!V4R#)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)rrcrrrrrr)rqrrf peerAddresss& rZtest_serverGetPeerOnIPv4*TCPPortTestsMixin.test_serverGetPeerOnIPv4rrYc BRp\V\P\P4pVP W!R4pVP 4p\P !V\P4^,pVP\RV.VR,O5!V4R#)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. rr~rrN) rrcrrrrrrrrrqrrfr$ryrs& rZtest_serverGetPeerOnIPv6*TCPPortTestsMixin.test_serverGetPeerOnIPv6rrYc R\4p\V\P\P4pVP W!R4pVP 4p\P!V\P4^,pVP\RV.VR,O5!V4R#)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~rrN) r_rrcrrrrrrrrr(s& rZtest_serverGetPeerOnIPv6ScopeID1TCPPortTestsMixin.test_serverGetPeerOnIPv6ScopeIDr"rYcV<V^8dQh/S[S[S[S[,,,;R&#r'rrr r r )r*rs"rZr+TCPPortTestsMixin.__annotate__ !$y/!:;L rYrXN)rrrrrr*rrrrr ipv6Skipipv6SkipReasonrrrrrr rrrr r%r)r,r0rrrs@rZrrs0@KnD : 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&OsrYrc]tRtRtRtR#)TCPPortTestsBuilderirXNrrrrrrXrYrZr6r6  rYr6c]tRtRtRtR#)TCPFDPortTestsBuilderirXNr7rXrYrZr:r:r8rYr:c6a]tRtRtoRtRtRtRtRtVt R#)StopStartReadingProtocoliz< Protocol that pauses and resumes the transport a few times c6RVnVP^4R#)rYN)rnpauseResumeProducingrs&rZconnectionMade'StopStartReadingProtocol.connectionMades  !!!$rYc |VPP4VPP4V'd;VPPP ^VP V^, 4R#VPPP ^VPPPV4R#)z/ Toggle transport read state, then count down. N) rpauseProducingresumeProducingrFrrzr>readycallback)rqcounters&&rZr>-StopStartReadingProtocol.pauseResumeProducingsz %%' &&(  LL * *1d.G.GST U LL * *1dll.@.@.I.I4 PrYc\P!R\V44V;PV, un\VP4R8Xd2VPP P VP4R#R#)zgot dataNi@)rGrrrnrFrgrErps&&rZr%StopStartReadingProtocol.dataReceivedsS  CI& T tyy>X % LL   & &tyy 1 &rYryN) rrrrrr?r>rrrrs@rZr<r<s% Q22rYr<c0a\S4V3Rl4pV#)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<aa\4o!VVV3RlR\4pV!4p\SVS\44R#)c2<a]tRtRtoVVV3RltRtVtR#)BoneTransportTest..actualTestMethod..ServerProtocoli+c<S!SVPVP4VPeVPP4SPeSPP4R#R# TPeTPP4SPeSPP4ii;irW)rrloseConnection)rqbuilderother testMethods&rZr?QoneTransportTest..actualTestMethod..ServerProtocol.connectionMade,s9w dnnE~~155726683~~155726683s A55ACrXNrrrrr?rr)rrPrQrRs@rZServerProtocolrM+s 9 9rYrUN)r9r@r)rPrUserverProtocolrQrRsf @rZactualTestMethod*oneTransportTest..actualTestMethod's7#% 9 90 9() MrYr)rRrWsf rZoneTransportTestrYs&  :NN rYc\P!V4'd"VPW!P44R#VPW!P4VP VP 4R#)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(rrrhandlesrreadingrrrs&&&rZ assertReadingr^;sT$(()%7%7%9: )__5I--.rYc\P!V4'd"VPW!P44R#VP VP 4R#)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 r\r]s&&&rZassertNotReadingraUsB$((Y(:(:(<= Y../rYcla]tRtRtoRt]3tRt]R4t ]R4t ]R4t Rt Rt R tVtR #) TCPConnectionTestsBuilderinzH Builder defining tests relating to L{twisted.internet.tcp.Connection}. c aa a a \4o SP4;o S nRR.pS PPpW!9d'\ P !4'd \R4h\S n \4S n \4S n S P^S 4pVP4PpV V VV 3RlpV3Rlo \!S RV4p\#4p\$Vn \'VP)V4S P.4P+WS4pVP-\.P04SP3S 4R#)z\ This test verifies transport socket read state after multiple pause/resumeProducing calls. Glib2Reactor Gtk2Reactorz.This test is broken on gtk/glib under Windows.cp<SPV^,4SPV^,4V^,^,V^,^,3pV^,PPRR,RR,,4SPP SW4P V3Rl4#)z4 Send several IOCPReactor's buffers' worth of data. xyc$<SP4#rWrfrs&rZr[RTCPConnectionTestsBuilder.test_stopStartReading..proceed..s GLLNrY )rrrrgrl)protosricleanuprrqsfs&&rZproceed@TCPConnectionTestsBuilder.test_stopStartReading..proceeds OOF1I & OOF1I &AYq\6!9Q</F 1I   % %dh&7$(:K&K L77&&w=II* rYc&<SPVRR,RR,,R4\\V^,PP4\V^,PP4\VP 4.4#)zd Make sure IOCPReactor didn't start several WSARecv operations that clobbered each other's results. rhrizdid not get the right datarl)rrrrrOr)rnrmrirqs&&&rZrn@TCPConnectionTestsBuilder.test_stopStartReading..cleanups}   !DH$55,   !&)"5"5"D"DE!&)"5"5"D"DE!$"4"45 rYrN)r0rjrrrrI isWindowsrNr<rrrDrgrDr=rirr.r/rrerlrnrGrorp) rqskippedReactorsreactorClassNamerrirpcccfdrnrros f @@@rZtest_stopStartReading/TCPConnectionTestsBuilder.test_stopStartReadingus _#0022"*)=9",,55  .83E3E3G3GKL L. :*   a $yy{   $ d ; _ "**R."((3 4 @ @ L SWW  rYc vVP4\WV4VP4\WV4R#)zb When a L{Server} is connected, its C{resumeProducing} method adds it as a reader to the reactor. N)rBrarCr^rqrrs&&&rZtest_resumeProducing.TCPConnectionTestsBuilder.test_resumeProducings0 / dV,rYc ^VP4VP4\WV4R#)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)rOrCrar}s&&&rZ&test_resumeProducingWhileDisconnecting@TCPConnectionTestsBuilder.test_resumeProducingWhileDisconnectings&  /rYc VP\\R444\WV4VP 4\WV4R#)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)rrHrrarCr}s&&&rZ%test_resumeProducingWhileDisconnected?TCPConnectionTestsBuilder.test_resumeProducingWhileDisconnecteds< gi&89:/ /rYc !RR\4p!RR\4pV!4p\WV!4\44VPVP.RO4R#)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. c8a]tRtRtoRtRtRtRtRtVt R#)QTCPConnectionTestsBuilder.test_connectionLostAfterPausedTransport..Pauseric.VnR#rWeventsrs&rZrrZTCPConnectionTestsBuilder.test_connectionLostAfterPausedTransport..Pauser.__init__s   rYcVPPR4VPP4VPP ^VP 4R#)pausedN)rr~rrBrrzresumers&&rZr^TCPConnectionTestsBuilder.test_connectionLostAfterPausedTransport..Pauser.dataReceiveds< ""8,--/ &&q$++6rYcpVPPR4VPP4R#)resumedN)rr~rrCrs&rZrXTCPConnectionTestsBuilder.test_connectionLostAfterPausedTransport..Pauser.resumes$ ""9-..0rYchVPPR4\P!W4R#)lostN)rr~r9rrqr^s&&rZr`TCPConnectionTestsBuilder.test_connectionLostAfterPausedTransport..Pauser.connectionLosts" ""6*#224@rYrN) rrrrrrrrrrrrs@rZPauserrs  ! 7  1 A ArYrc&a]tRtRtoRtRtVtR#)QTCPConnectionTestsBuilder.test_connectionLostAfterPausedTransport..ClienticpVPPR4VPP4R#)ssome bytes for youN)rrrOrs&rZr?`TCPConnectionTestsBuilder.test_connectionLostAfterPausedTransport..Client.connectionMades%$$%:;--/rYrXNrTrs@rZClientrs 0 0rYrN)rrr)r9r@rrr)rqrrpausers& rZ'test_connectionLostAfterPausedTransportATCPConnectionTestsBuilder.test_connectionLostAfterPausedTransportsL  A( A$ 0( 0 fh E (EFrYc \\4!RR\44p!RR\4p\W!4V!4\ 44R#)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,a]tRtRtoRtRtRtVtR#)HTCPConnectionTestsBuilder.test_doubleHalfClose..ListenerProtocolic:VPP4R#rW)rloseWriteConnectionrs&rZreadConnectionLost[TCPConnectionTestsBuilder.test_doubleHalfClose..ListenerProtocol.readConnectionLosts224rYc:VPP4R#rWrrOrs&rZwriteConnectionLost\TCPConnectionTestsBuilder.test_doubleHalfClose..ListenerProtocol.writeConnectionLost--/rYrXN)rrrrrrrrrs@rZListenerProtocolrs 5 0 0rYrc&a]tRtRtoRtRtVtR#)>TCPConnectionTestsBuilder.test_doubleHalfClose..Clienti c:VPP4R#rWrrs&rZr?MTCPConnectionTestsBuilder.test_doubleHalfClose..Client.connectionMade rrYrXNrTrs@rZrr s 0 0rYrN)r r$r9r@r)rqrrs& rZtest_doubleHalfClose.TCPConnectionTestsBuilder.test_doubleHalfClosesI + , 02 0 - 0 0( 0 &6&8&(JLQrYrXN)rrrrrr*rrzrYr~rrrrrrrs@rZrcrcnsi&6!p--0000)GVRRrYrccTa]tRtRtoRt]3tRtRtRt Rt Rt V3Rlt R t VtR #) WriteSequenceTestsMixinizE Test for L{twisted.internet.abstract.FileDescriptor.writeSequence}. c @\VRR4e W!nR#W!nR#)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)rqrvalues&&&rZsetWriteBufferSize*WriteSequenceTestsMixin.setWriteBufferSizes 9/ 6 B(- %#( rYc aV3RlpSP4pSPVR\P4pVP V4VP \ P4SPV4R#)zF C{writeSequence} sends the data even if C{write} hasn't been called. ch<aVworVV3RlpW1nSPP.RO4R#)c<\P!RV,4SPVR4SPP 4R#)zdata received: %rsSome sequence splittedN)rGrrrrO)rnrfrqs&rZr^WriteSequenceTestsMixin.test_writeSequeceWithoutWrite..connected..dataReceived+s8+d23  '@A  //1rYN)sSome s sequence ssplitted)rrr) protocolsrrirrfrqs& @rZrcHWriteSequenceTestsMixin.test_writeSequeceWithoutWrite..connected(s/#, FF 2 #/     * *+P QrYrN rjgetConnectedClientAndServerrcrrlrnrGrorprqrcrrysf rZtest_writeSequeceWithoutWrite5WriteSequenceTestsMixin.test_writeSequeceWithoutWrite#sY R##%  , ,Wk6>> R i  SWW  rYc aV3RlpSP4pSPVR\P4pVP V4VP \ P4SPV4R#)zW C{writeSequence} with an element in the sequence of type unicode raises C{TypeError}. c<VwrpSP\VPPR.4pSP \ V4R4VPP 4R#)zUnicode is not kosherzData must be bytesN)r TypeErrorrrrr)rO)rrfrriexcrqs& rZrcWWriteSequenceTestsMixin.test_writeSequenceWithUnicodeRaisesException..connected@s]#, FD##6++99> R i  SWW  rYc ~aa\\4!RR44pV!4oVV3RlpSP4pSPVR\P 4pVP V4VP\P4SPV4SPSPRR.4R#)zc C{writeSequence} pauses its streaming producer if too much data is buffered, and then resumes it. c@a]tRtRtoRtRtRtRtRtRt Rt Vt R#)JWriteSequenceTestsMixin.test_streamingProducer..SaveActionProduceriWNc.VnR#rWactionsrs&rZrrSWriteSequenceTestsMixin.test_streamingProducer..SaveActionProducer.__init__\ ! rYc<VPPR4R#)pauseNrr~rs&rZrBYWriteSequenceTestsMixin.test_streamingProducer..SaveActionProducer.pauseProducing_s ##G,rYcVPPR4VPPP 4VP PP 4R#)rN)rr~rfrunregisterProducerrrOrs&rZrCZWriteSequenceTestsMixin.test_streamingProducer..SaveActionProducer.resumeProducingbsB ##H- %%88:  %%446rYc<VPPR4R#rgNrrs&rZ stopProducingXWriteSequenceTestsMixin.test_streamingProducer..SaveActionProducer.stopProducingl ##F+rYr) rrrrrfrrrrBrCrrrrs@rZSaveActionProducerrWs(FF " - 7 , ,rYrcb<VR,wrVSnVSnVPPSR4SP SP .4SP VPR4VPPR.^,4SP SP R.4R#)rxTrN2xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx)rfrrregisterProducerrrrr)rrfrproducerrqs& rZrcAWriteSequenceTestsMixin.test_streamingProducer..connectedqs&r]NF$HO$HO    - -h =   X--r 2  # #F$4$4c :    * *I;+; <   X--y 9rYrrrN) r r'rjrrcrrlrnrGrorprr)rqrrcrryrsf @rZtest_streamingProducer.WriteSequenceTestsMixin.test_streamingProducerQs ] # , , $ ,.&' :##%  , ,Wk6>> R i  SWW   ))GX+>?rYc aaaSo\\4!V3RlR44pV!4oVV3RlpSP4pSPVR\P 4pVP V4VP\P4SPV4SPSPRR.4R#)zi C{writeSequence} pauses its producer if too much data is buffered only if this is a streaming producer. c><a]tRtRtoRtRtV3RltRtRtVt R#)MWriteSequenceTestsMixin.test_nonStreamingProducer..SaveActionProduceriNc.VnR#rWrrs&rZrrVWriteSequenceTestsMixin.test_nonStreamingProducer..SaveActionProducer.__init__rrYcp<VPPR4VPPR4^8Xd'VPPP 4R#SP VPPR4VPPPR.^,4R#)rrNr)rr~rrfr stopConsumingrr)rqrs&rZrC]WriteSequenceTestsMixin.test_nonStreamingProducer..SaveActionProducer.resumeProducings{ ##H-<<%%h/14KK))779++DKK,A,A3GKK))77 b8HIrYc<VPPR4R#rrrs&rZr[WriteSequenceTestsMixin.test_nonStreamingProducer..SaveActionProducer.stopProducingrrYr) rrrrrfrrrCrrr)rrs@rZrrsF " J , ,rYrc<V^,pVSnVPPSR4SPSPR.4R#)rFrN)rfrrrr)rrfrrqs& rZrcDWriteSequenceTestsMixin.test_nonStreamingProducer..connectedsCq\F$HO    - -h >   X--z :rYrrN) r r&rjrrcrrlrnrGrorprr)rqrrcrryrrsf @@rZtest_nonStreamingProducer1WriteSequenceTestsMixin.test_nonStreamingProducers  ] # , , $ ,"&' ;##%  , ,Wk6>> R i  SWW   ))Hh+?@rYcV<V^8dQh/S[S[S[S[,,,;R&#r/r0)r*rs"rZr+$WriteSequenceTestsMixin.__annotate__r2rYrXN)rrrrrr*rrrrrrr0rrrs@rZrrs:@Kn)!.!.3@j*AirYrcTa]tRtRtoRtRtRtRt]!] ] 4R4t Rt Vt R#) "TCPTransportServerAddressTestMixiniz= Test mixing for TCP server address building and log prefix. c \4h)z| Helper method returnine a L{Deferred} firing with a tuple of a client protocol, a server protocol, and a running TCP port. )NotImplementedError)rqrrrs&&&&rZr>TCPTransportServerAddressTestMixin.getConnectedClientAndServers "##rYc aaaVVV3RlpSP4pSPVSV4pVPV4VP\P 4SP V4R#)zD Helper method to test TCP server addresses on either IPv4 or IPv6. c<VwrpSPRVPP: RVP4P: R2\ VP44SPRVPP: RS: 2VPP 4VPPwpSPVS4SPRVP4SPSVP4VPP4R# TPP4i;i)zzAccumulatingProtocol,,rN) rr sessionnor=rir)logstrrF peerAddressesrrrhrO)rrfrrir$ adressClassrrqs& rZrcHTCPTransportServerAddressTestMixin._testServerAddress..connecteds#, FD 2  ''114<<>3F3FH(()   ''119>$$++ !' < < %%k;?   (8(89  K,<,<=  //1  //1s C>D""D>N)rjrrlrnrGrorp)rqrrrrcrrysff&f rZ_testServerAddress5TCPTransportServerAddressTestMixin._testServerAddresssT  2.##%  , ,Wi O i  SWW  rYc LVPR\P\4#)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)r rcrrrs&rZtest_serverAddressTCP49TCPTransportServerAddressTestMixin.test_serverAddressTCP4s &&{FNNKPPrYc \VP\4\P\4#)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. )r r_rcrrrs&rZtest_serverAddressTCP69TCPTransportServerAddressTestMixin.test_serverAddressTCP6s%&& # %v   rYrXN)rrrrrrr r r r3r4rrrrs@rZrrs6$ !DQ Hn% & rYrc*a]tRtRtoRtRtRtVtR#)TCPTransportTestsBuilderizL Test standard L{ITCPTransport}s built with C{listenTCP} and C{connectTCP}. c aa a \4p\4Vn\4Vn\ 4p\4Vn\4VnSP ^WBR7o \ VPVP.4pV3RlpVPV4\ VPVP.4p\4o V V 3Rlp VPV 4SPVS P4PV4S #)zy Return a L{Deferred} firing with a L{MyClientFactory} and L{MyServerFactory} connected pair, and the listening C{Port}. rc(<SP4V#rWrfrrs&rZrgBTCPTransportTestsBuilder.getConnectedClientAndServer..stop s LLNMrYc<Vwr\P!RV,4\P!RV,4SPWS34R#zclient connected %szserver connected %sNrGrrErrfrr{ris& rZstartCTCPTransportTestsBuilder.getConnectedClientAndServer..start A&NF GG)F2 3 GG)F2 3   vt4 5rY) rMrryrkrLrDrrrlrJr=ri) rqrrrrrf lostDeferredrg startDeferredrr{ris &f&& @@rZr4TCPTransportTestsBuilder.getConnectedClientAndServers !"(0 %(0 % "(0 %(0 %  F @$  * *F,I,I J   T"%  * *F,I,I J : 6 !!%(9dlln&9&96BrYrXN)rrrrrrrrrs@rZrrs))rYrc2a]tRtRtoRt]]3tRtRt Vt R#)!AdoptStreamConnectionTestsBuilderi( z> Test server transports built using C{adoptStreamConnection}. c aaa a a \4p\4Vn\4o \4S n\4S n\ 4p\4Vn\4VnSP ^WBR7o VVV 3RlpVPP V4\VPS P.4pV3RlpVPV4\4o S PV4\VPS P.4p V V 3Rlp V P V 4SPVS P4PV4S #)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. rc<SPVP4SPVP4SPVPP 4SS4R#rW)rrradoptStreamConnectionr)rrrrs&rZfirtServerConnectedZAdoptStreamConnectionTestsBuilder.getConnectedClientAndServer..firtServerConnectedE sI   1   1  ) )&&(- rYcL<SP'dSP4V#rW)rrgrs&rZrgKAdoptStreamConnectionTestsBuilder.getConnectedClientAndServer..stopR s MrYc<Vwr\P!RV,4\P!RV,4SPWS34R#rrrs& rZrLAdoptStreamConnectionTestsBuilder.getConnectedClientAndServer..start` rrY) rMrryrkrLrDrlrrrnrJr=ri)rqrrr firstServerrfr'rrgr rr{rirs&f&f @@@rZr=AdoptStreamConnectionTestsBuilder.getConnectedClientAndServer1 s&' -5Z * "(0 %(0 % "(0 %(0 %  K E  **667JK$  * *F,I,I J   T":D!%  * *F,I,I J  6 !!%(9dlln&9&96BrYrXN) rrrrrr(r)rrrrrs@rZr#r#( s!(888rYr#c*a]tRtRtoRtRtRtVtR#)ServerAbortsTwiceiw z Call abortConnection() twice. cnVPP4VPP4R#rW)rabortConnectionrps&&rZrServerAbortsTwice.dataReceived| s" &&( &&(rYrXNrrs@rZr0r0w ))rYr0c*a]tRtRtoRtRtRtVtR#)ServerAbortsThenLosesi z6 Call abortConnection() followed by loseConnection(). cnVPP4VPP4R#rW)rr2rOrps&&rZr"ServerAbortsThenLoses.dataReceived s" &&( %%'rYrXNrrs@rZr6r6 ((rYr6c*a]tRtRtoRtRtRtVtR#)AbortServerWritingProtocoli z, Protocol that writes data upon connection. c <VPPR4R#)zG Tell the client that the connection is set up and it's time to abort. sreadyNrrrs&rZr?)AbortServerWritingProtocol.connectionMade s X&rYrXNrrrrrr?rrrs@rZr;r; s''rYr;c*a]tRtRtoRtRtRtVtR#)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. cLVPRR4'd \R4hR#)XrYzUnexpectedly received data.N)replacerrps&&rZr$ReadAbortServerProtocol.dataReceived s$ <<c " "9: : #rYrXNrrs@rZrArA s ;;rYrAc*a]tRtRtoRtRtRtVtR#) 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(). c:VPP4R#rW)r stopReadingrs&rZr?NoReadServer.connectionMade s ""$rYrXNr?rs@rZrGrG s%%rYrGcDa]tRtRtoRtRtRtRtRtRt Rt Rt Vt R #) EventualNoReadServeri z Like NoReadServer, except we Wait until some bytes have been delivered before stopping reading. This means TLS handshake has finished, where applicable. FcVP'gARVnVPPVR4VPPR4R#R#)TFhelloN)gotDatarrrrps&&rZr!EventualNoReadServer.dataReceived s=|||DL NN + +D% 8 NN  *rYcpVP'dR#RVnVPP4R#)NT)stoppedReadingrrIrs&rZrC$EventualNoReadServer.resumeProducing s)     " ""$rYcR#rWrXrs&rZrB#EventualNoReadServer.pauseProducing  rYcR#rWrXrs&rZr"EventualNoReadServer.stopProducing rVrY)rOrRN) rrrrrrOrRrrCrBrrrrs@rZrLrL s/ GN+ %   rYrLc.a]tRtRtoRtRtRtRtVtR#)BaseAbortingClienti z' Base class for abort-testing clients. FclVP'd \R4h\P!W4R#)z,BUG: connectionLost was called re-entrantly!N)inReactorMethod RuntimeErrorr9rrs&&rZr!BaseAbortingClient.connectionLost s(    MN N**48rYrXN) rrrrrr\rrrrs@rZrZrZ sO99rYrZc*a]tRtRtoRtRtRtVtR#)WritingButNotAbortingClienti z Write data, but don't abort. c<VPPR4R#)rNNr=rs&rZr?*WritingButNotAbortingClient.connectionMade s X&rYrXNr?rs@rZr`r` s''rYr`c0a]tRtRtoRtRtRtRtVtR#)AbortingClienti z1 Call abortConnection() after writing some data. c BRVnVP4RVnR#)z6 Some data was received, so the connection is set up. TFN)r\ writeAndAbortrps&&rZrAbortingClient.dataReceived s  $ $rYcVPPRR,4VPP4VPPRR,4R#)rCi'YN)rrr2rs&rZrfAbortingClient.writeAndAbort s@ TE\* &&( TE\*rY)r\N) rrrrrrrfrrrs@rZrdrd s%++rYrdc*a]tRtRtoRtRtRtVtR#)AbortingTwiceClienti z8 Call abortConnection() twice, after writing some data. cd\PV4VPP4R#rW)rdrfrr2rs&rZrf!AbortingTwiceClient.writeAndAbort s $$T* &&(rYrXNrrrrrrfrrrs@rZrlrl r4rYrlc*a]tRtRtoRtRtRtVtR#)AbortingThenLosingClienti z3 Call abortConnection() and then loseConnection(). cd\PV4VPP4R#rW)rdrfrrOrs&rZrf&AbortingThenLosingClient.writeAndAbort s $$T* %%'rYrXNrors@rZrqrq r9rYrqcJa]tRtRtoRtRtRtRtRtRt Rt R t R t Vt R #) ProducerAbortingClienti z9 Call abortConnection from doWrite, via resumeProducing. TFcVPPRR,4RVnVPPVR4RVnR#)slalalaiTFN)rrinRegisterProducerrrs&rZrProducerAbortingClient.write s= Y/0"& ''e4"'rYc&VP4R#rWrrs&rZr?%ProducerAbortingClient.connectionMade  rYczRVnVP'gVPP4RVnR#)TFN)r\rwrr2rs&rZrC&ProducerAbortingClient.resumeProducing s.#&&& NN * * ,$rYcRVnR#rn)producerStoppedrs&rZr$ProducerAbortingClient.stopProducing$ s #rYcVP'g \R4hVP'd \R4h\P!W4R#)z&BUG: stopProducing() was never called.z(BUG: connectionLost called re-entrantly!N)rr]r\r9rrs&&rZr%ProducerAbortingClient.connectionLost' s@###GH H    IJ J**48rY)r\rwrN)rrrrrr\rrr?rCrrrrrs@rZruru s4OO( % $99rYrucZa]tRtRtoRtRt^tRtRtRt Rt Rt Rt R t R tR tVtR #) 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. Fc&VP4R#rWrzrs&rZr?&StreamingProducerClient.connectionMade@ r|rYc VPPVR4\^d4F%pVPPRR,4K' R#)zP Write large amount to transport, then wait for a while for buffers to fill up. Ts 1234567890i}N)rrranger)rqis& rZrStreamingProducerClient.writeC s= ''d3sA NN !6 7rYcRVnR#)FN)rrs&rZrC'StreamingProducerClient.resumeProducingL s  rYcR#rWrXrs&rZr%StreamingProducerClient.stopProducingO rVrYc VP'dR#RVnVPPRVP4R#)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?)rrrzdoAbortrs&rZrB&StreamingProducerClient.pauseProducingR s1 ;;;   tT\\2rYcVP'g \P!\R44RVnVP P 4RVnR#)z&BUG: We should be paused a this point.TFN)rrGror]r\rr2rs&rZrStreamingProducerClient.doAbortg s={{{ GGL!IJ K# &&($rYczVPPP4\P!W4R#rW) otherProtocolr startReadingr9rrs&&rZr&StreamingProducerClient.connectionLostn s( $$113**48rY)r\rN)rrrrrr extraWritesr\r?rrCrrBrrrrrs@rZrr/ sC FKO8 3*%99rYrc0a]tRtRtoRtRtRtRtVtR#)StreamingProducerClientLaterit zL Call abortConnection() from dataReceived, after bytes have been exchanged. cJVPPR4RVnR#)rNFN)rrrOrs&rZr?+StreamingProducerClientLater.connectionMadez s X& rYc\VP'gRVnVP4R#R#rn)rOrrps&&rZr)StreamingProducerClientLater.dataReceived~ s |||DL JJLrY)rON rrrrrr?rrrrs@rZrrt s rYrc0a]tRtRtoRtRtRtRtVtR#)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. cR#rWrXrs&rZr?*ProducerAbortingClientLater.connectionMade s rYc&VP4R#rWrzrps&&rZr(ProducerAbortingClientLater.dataReceived r|rYrXNrrs@rZrr s rYrc*a]tRtRtoRtRtRtVtR#)DataReceivedRaisingClienti zF Call abortConnection(), and then throw exception, from dataReceived. cLVPP4\R4h)ONO)rr2ZeroDivisionErrorrps&&rZr&DataReceivedRaisingClient.dataReceived s &&(&&rYrXNrrs@rZrr s''rYrc0a]tRtRtoRtRtRtRtVtR#)ResumeThrowsClienti zD Call abortConnection() and throw exception from resumeProducing(). ctVP'g&VPP4\R4hR#)zono!N)rwrr2rrs&rZrC"ResumeThrowsClient.resumeProducing s.&&& NN * * ,#F+ +'rYc2\P!W4R#rW)r9rrs&&rZr!ResumeThrowsClient.connectionLost s **48rYrXN) rrrrrrCrrrrs@rZrr s, 99rYrca]tRtRtoRtRtRRltRtRtRt Rt R t ] !] PPR R 4P!4R 8H;'d]P$!4R 4R4t] !] PPR R 4P!4R 8H;'d]P$!4R 4R4tRtRtRtRtV3RltRtVtR#)AbortConnectionMixini z/ Unit tests for L{ITransport.abortConnection}. Nc \\3p\\3p\'d1V\P 3,pV\P 3,pV!4pV!4pWvnWgn\WW`P4pVPVP4.4VPVP4.4Ve0VPVPPV3V,4M&VPVPPV4VPVPPV4R#)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)rrrrrQErrorrr@rArrgetDelayedCallsrdisconnectReasonr) rq clientClass serverClassclientConnectionLostReasonclientExpectedExceptionsserverExpectedExceptionsrfrrs &&&& rZ runAbortTest!AbortConnectionMixin.runAbortTest s%6~#F $2N#C  6'?399,'N $'?399,'N $%%)$O **,b1 002B7 % 1  ! !''--+-0HH   ! !''--/G  f55;;=UVrYc 6VP\\4#)z abortConnection() is called in dataReceived. The protocol should be disconnected, but connectionLost should not be called re-entrantly. )rrdrArs&rZtest_dataReceivedAbort+AbortConnectionMixin.test_dataReceivedAbort s   1HIIrYc 6VP\\4#)zq abortConnection() is called twice by client. No exception should be thrown, and the connection will be closed. )rrlrArs&rZ test_clientAbortsConnectionTwice5AbortConnectionMixin.test_clientAbortsConnectionTwice s   !46MNNrYc 6VP\\4#)z Client calls abortConnection(), followed by loseConnection(). No exception should be thrown, and the connection will be closed. )rrqrArs&rZ.test_clientAbortsConnectionThenLosesConnectionCAbortConnectionMixin.test_clientAbortsConnectionThenLosesConnection s   !9;RSSrYc BVP\\\R7#)zq abortConnection() is called twice by server. No exception should be thrown, and the connection will be closed. r)rr`r0rrs&rZ test_serverAbortsConnectionTwice5AbortConnectionMixin.test_serverAbortsConnectionTwice s%   ' '5!  rYc BVP\\\R7#)z Server calls abortConnection(), followed by loseConnection(). No exception should be thrown, and the connection will be closed. r)rr`r6rrs&rZ.test_serverAbortsConnectionThenLosesConnectionCAbortConnectionMixin.test_serverAbortsConnectionThenLosesConnection s%   ' !'5!  rYCIrStruezFlaky on macOS on Azure.c :VP\\4R#)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)rrur9rs&rZtest_resumeProducingAbort.AbortConnectionMixin.test_resumeProducingAbort s 02EFrYc 6VP\\4#)z| abortConnection() is called in resumeProducing, after some bytes have been exchanged. The protocol should be disconnected. )rrr;rs&rZtest_resumeProducingAbortLater3AbortConnectionMixin.test_resumeProducingAbortLater s  ')C  rYc :VP\\4R#)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)rrrGrs&rZtest_fullWriteBuffer)AbortConnectionMixin.test_fullWriteBuffer( s 1<@rYc 6VP\\4#)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. )rrrLrs&rZ%test_fullWriteBufferAfterByteExchange:AbortConnectionMixin.test_fullWriteBufferAfterByteExchange5 s  !=?STTrYc VP\\\R7VP \4pVP \ V4^4R#)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. rN)rrr;rflushLoggedErrorsrrrqerrorss& rZtest_dataReceivedThrows,AbortConnectionMixin.test_dataReceivedThrows? sG  % &'8  ''(9: Va(rYc VP\\\R7VP \4pVP \ V4^4R#)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. rN)rrr9rrrrrs& rZtest_resumeProducingThrows/AbortConnectionMixin.test_resumeProducingThrowsP sG   '8  ''(9: Va(rYc6<V^8dQh/S[S[,;R&#)r'rA)rr;)r*rs"rZr+!AbortConnectionMixin.__annotate__ s (/ rYrXrW)rrrrrrArrrrrrr renvirongetlowerrIisMacOSXrrrrrrr0rrrs@rZrr s ,0I#WJJOT      tR &&(F2JJx7H7H7J"G G  tR &&(F2JJx7H7H7J"   AU)")CrYrc.]tRtRtRt]3t]!4tRt R#)AbortConnectionTestsib z- TCP-specific L{AbortConnectionMixin} tests. rXN) rrrrrr*rrrArrXrYrZrrb s& IrYrcla]tRtRtoRtRt]!]P!4R4R4t Rt Rt Vt R#) SimpleUtilityTestsio zB Simple, direct tests for helpers within L{twisted.internet.tcp}. c VP\P\R^4pVP VP ^,\P 4R#)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.) localhostNrrcgaierrorr7rr EAI_NONAMErqros& rZtest_resolveNumericHost*SimpleUtilityTests.test_resolveNumericHostu s<{AN !f&7&78rYz@The AI_NUMERICSERV flag is not supported by Microsoft providers.c VP\P\RR4pVP VP ^,\P 4R#)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.) rhttpNrrs& rZtest_resolveNumericService-SimpleUtilityTests.test_resolveNumericService s<ufM !f&7&78rYc \R^4pVP\V4^4VPV^,\4VPV^,\4VPVR,R4R#)zJ L{_resolveIPv6} discovers the flow info and scope ID of an IPv6 address. rrxN)rr')r7rrrr4rs& rZtest_resolveIPv6#SimpleUtilityTests.test_resolveIPv6 sd eQ' Va( fQi- fQi- Z0rYrXN) rrrrrrr rIrtrrrrrs@rZrro sA9 J 9  911rYrc<a]tRtRtoRtRtRtRtRtRt Vt R#) BuffersLogsTestsi z Tests for L{_BuffersLogs}. cRVn.Vn\VPVPP4VnR#)z name.spaceN) namespacerr3r~ logBufferrs&rZrBuffersLogsTests.setUp s,% %dnndkk6H6HIrYc VP;_uu_4pVPR4VPVP4RRR4R# +'giR#;i)zR The context manager's logger does not log to provided observer inside the block. An eventN)rrr r)rqloggers& rZtest_buffersInBlock$BuffersLogsTests.test_buffersInBlock s9 ^^^v KK #   T[[ )^^^s -A  A c VP;_uu_4pVPR4VPVP4RRR4VP ^\ VP44VPwpVP VR,R4VP VR,VP 4R# +'giL;i)z_ The context manager flushes its buffered logs when the block terminates without an exception. rN log_format log_namespace)rrr rrrr)rqrevents& rZtest_flushesOnExit#BuffersLogsTests.test_flushesOnExit s ^^^v KK #   T[[ ) C ,-++ |,j9 /@ ^s -B;; C c  &!RR\4pVPV4;_uu_4VP;_uu_4pVPR4VP VP 4V!4h +'giM;iRRR4M +'giM;iTP ^\TP 44TP wpTP TR,R4TP TR,TP4R#)zb The context manager flushes its buffered logs when the block terminates because of an exception. c]tRtRtRtRtR#)GBuffersLogsTests.test_flushesOnExitWithException..TestExceptioni z( An exception only raised by this test. rXNrrrrrrrXrYrZ TestExceptionr  rYrrNr r ) rrrrr rrrr)rqrrrs& rZtest_flushesOnExitWithException0BuffersLogsTests.test_flushesOnExitWithException s  I    } - -6 J'  -#o% . - - - C ,-++ |,j9 /@sB4A2 2 B =B B )rrrN) rrrrrrr rrrrrs@rZrr s'J * AAArYrc`a]tRtRtoRtRtRtRtRtRt Rt R t R t R t R tR tVtR#)FileDescriptorReservationTestsi z* Tests for L{_FileDescriptorReservation}. cla.SnSP4SnV3Rlp\V4SnR#)c<SPP\SPR44SPR,#)wr)reservedFileObjectsr~r8tempfilersrZfakeFileFactory=FileDescriptorReservationTests.setUp..fakeFileFactory s3  $ $ + +D,D E++B/ /rYN)rmktemprr4 reservedFD)rqr sf rZr$FileDescriptorReservationTests.setUp s+#%    05_ErYc :\\VP4R#)zQ L{_FileDescriptorReservation} instances provide L{_IFileDescriptorReservation}. N)rr5r#rs&rZr=5FileDescriptorReservationTests.test_providesInterface s 0$//BrYc JVP\VP4^4\^ 4FnpVPP 4VP\VP4^4VP VP^,P4Kp R#)zP Multiple acquisitions without releases open the reservation file exactly once. N)rrrrr#reserver r)rqrs& rZtest_reserveOpensFileOnce8FileDescriptorReservationTests.test_reserveOpensFileOnce sw T556:rA OO # # %   S!9!9:A >   T55a8?? @rYc (\4pVPVP4VP4VP VP P 44VP P4VP VP P 44VP\\4pVP\V4^4VPV^,PP\P4R#)z If reserving the file descriptor fails because of C{EMFILE}, the exception is suppressed but logged and the reservation remains unavailable. N)r rrrr r# availabler(rrrDrrrrr)rqr5rs& rZtest_reserveEMFILELogged7FileDescriptorReservationTests.test_reserveEMFILELogged s -.   ))* 2245 ! 2245''9 Va( .. =rYc \\\3F/pV3Rlp\V4pVP WP 4K1 R#)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. c>V!\P^,R4h)rr)rr) errorClasss&rZ failsWithWFileDescriptorReservationTests.test_reserveRaisesNonEMFILEExceptions..failsWith s !19==rYN)rrDrr4rr()rqr1r2 reserveFDs& rZ%test_reserveRaisesNonEMFILEExceptionsDFileDescriptorReservationTests.test_reserveRaisesNonEMFILEExceptions s? #GZ8J&0 >39=I   j*;*; <9rYc VPVPP44VPP4VP VPP44R#)zE The reservation is available after the file descriptor is reserved. N)r r#r,r(rrs&rZtest_available-FileDescriptorReservationTests.test_available sH 2245 ! 1134rYc  VP\4;_uu_4VP;_uu_4RRR4RRR4R# +'giL;i +'giR#;i)zX A reservation without an open file used as a context manager raises a L{RuntimeError}. N)rr]r#rs&rZtest_enterFailsWithoutFile9FileDescriptorReservationTests.test_enterFailsWithoutFile$ s@   | , ,<!- , - , ,s!AA A A A A+ c VPP4VPVPP44VP;_uu_4VP VPP44RRR4VPVPP44R# +'giL;;i)zY Entering a reservation closes its file for the duration of the context manager's block. N)r#r(rr,r rs&rZ!test_enterClosesFileExitOpensFile@FileDescriptorReservationTests.test_enterClosesFileExitOpensFile- sw ! 1134 ___   T__668 9 1134_s *B55 C c  $!RR\4pVPP4VPV4;_uu_4VP;_uu_4V!4h +'giM;iRRR4R# +'giR#;i)zq An exception raised within a reservation context manager's block does not prevent the file from being reopened. c]tRtRtRtRtR#)SFileDescriptorReservationTests.test_exitOpensFileOnException..TestExceptioni> z& An exception only used by this test. rXNrrXrYrZrrB> rrYrN)rr#r(r)rqrs& rZtest_exitOpensFileOnExceptionA A0 +A>> B c  aa!RR\4p!RR\4oR.oVV3Rlp\V4pVP4VPVP 44VP V4;_uu_4T;_uu_4V!4h +'giM;iRRR4M +'giM;iTP S4pTP\T4^4R#)z An exception raised while re-opening the reserve file exiting a reservation's context manager block is suppressed but logged, allowing an exception raised within the block through. c]tRtRtRtRtR#)`FileDescriptorReservationTests.test_exitSuppressesReservationException..AllowedExceptioniO z) The exception allowed out of the block. rXNrrXrYrZAllowedExceptionrGO rrYrHc]tRtRtRtRtR#)cFileDescriptorReservationTests.test_exitSuppressesReservationException..SuppressedExceptioniT z5 An exception raised by the file descriptor factory. rXNrrXrYrZSuppressedExceptionrJT rrYrKFcd<S^,'dS!4hRS^&\P!4#)rT)ioBytesIO)rKcalledsrZ+failsWithSuppressedExceptionAfterSecondOpen{FileDescriptorReservationTests.test_exitSuppressesReservationException..failsWithSuppressedExceptionAfterSecondOpen[ s*ayy)++ q zz|#rYN) rr4r(rr,rrrr)rqrHrPr#rrKrOs& @@rZ'test_exitSuppressesReservationExceptionFFileDescriptorReservationTests.test_exitSuppressesReservationExceptionH s y   )   $0 7    ,,./   / 0 0&((1 0 0 0''(;< Va(s> B. B  B! B.. B> )r#rrN)rrrrrrr=r)r-r5r8r;r>rCrRrrrs@rZrr sDFC A>$ =5= 5& &)&)rYrc<a]tRtRtoRtRtRtRtRtRt Vt R#) "NullFileDescriptorReservationTestsiq z. Tests for L{_NullFileDescriptorReservation}. c$\4VnR#rW)r6nullReservedFDrs&rZr(NullFileDescriptorReservationTests.setUpv s <>rYc :\\VP4R#)zL L{_NullFileDescriptorReservation} provides L{_IFileDescriptorReservation}. N)rr5rWrs&rZr=9NullFileDescriptorReservationTests.test_providesInterfacey s 0$2E2EFrYc XVPVPP44R#)z7 The null reserved file descriptor is never available. Nr rWr,rs&rZr81NullFileDescriptorReservationTests.test_available s! ,,6689rYc \VPVPP44VP;_uu_4VPVPP44RRR4VPVPP44R# +'giL;;i)z> The null reserved file descriptor is a null context manager. Nr\rs&rZtest_contextManager6NullFileDescriptorReservationTests.test_contextManager su ,,6689    T00::< =! ,,6689! s *B B+ )rWN) rrrrrrr=r8r_rrrs@rZrUrUq s$?G: ::rYrU)rr)rrrrMrrc functoolsrtypingrrrrrr r unittestr zope.interfacer r zope.interface.verifyrrr-twisted.internet.addressrrtwisted.internet.deferrrrrrrtwisted.internet.endpointsrrtwisted.internet.errorrrrrrrr r!r"twisted.internet.interfacesr#r$r%r&r'r(r)r*r+r,r-twisted.internet.protocolr.r/r0twisted.internet.tcpr1r2r3r4r5r6r7&twisted.internet.test.connectionmixinsr8r9r:r;r<r=r>r?r@#twisted.internet.test.reactormixinsrArBrCtwisted.internet.testingrDrEtwisted.loggerrFtwisted.pythonrGtwisted.python.failurerHtwisted.python.runtimerItwisted.test.test_tcprJrKrLrMtwisted.trial.unittestrNrOrPOpenSSLrQtwisted.internet.sslrRr ImportErrorsrrrr3r4rr"rrttwisted.internet.testrTwin32GetLinkLocalIPv6Addressesr]rrUposixGetLinkLocalIPv6Addressesr_rerlrrrrrrrr%r:rrrrrrrr r3rrrrrrrr6r:r<rYr^rarcrrrr#globalsupdatemakeTestCaseClassesr0r6r;rArGrLrZr`rdrlrqrurrrrrrrrrrrUrXrYrZrs  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+8X;Y+ X87X8;YYY Y%$Y%