+ Dfj$Rt^RIt^RIt^RIHt^RIHt^RIHt^RI H t H t ^RI H t Ht^RIHt^RIHt!R R ] 4t!R R ] 4t!R R] 4t!RR] 4t]!4P1]P344]!4P1]P344]!4P1]P344]!4P1]P344R#)aD Tests for implementations of L{IReactorSocket}. Generally only tests for failure cases are found here. Success cases for this interface are tested elsewhere. For example, the success case for I{AF_INET} is in L{twisted.internet.test.test_tcp}, since that case should behave exactly the same as L{IReactorTCP.listenTCP}. N)verify)UnsupportedAddressFamily)IReactorSocket)DatagramProtocol ServerFactory)ReactorBuilderneedsRunningReactor)err)platformc0a]tRt^toRt].tRtRtVt R#)&IReactorSocketVerificationTestsBuildera# Builder for testing L{IReactorSocket} implementations for required methods and method signatures. L{ReactorBuilder} already runs L{IReactorSocket.providedBy} to ensure that these tests will only be run on reactor classes that claim to implement L{IReactorSocket}. These tests ensure that reactors which claim to provide the L{IReactorSocket} interface actually have all the required methods and that those methods have the expected number of arguments. These tests will be skipped for reactors which do not claim to provide L{IReactorSocket}. c zVP4pVP\P!\V44R#)zN The reactor instance returned by C{buildReactor} provides L{IReactorSocket}. N) buildReactor assertTruer verifyObjectr)selfreactors& C/usr/lib/python3/dist-packages/twisted/internet/test/test_socket.py test_provider4IReactorSocketVerificationTestsBuilder.test_provider-s+ ##% ++NGDEN) __name__ __module__ __qualname____firstlineno____doc__rrequiredInterfacesr__static_attributes____classdictcell__ __classdict__s@rr r s! ))FFrr c<a]tRt^6toRt].tRtRtRt Rt Vt R#)!AdoptStreamPortErrorsTestsBuildera[ Builder for testing L{IReactorSocket.adoptStreamPort} implementations. Generally only tests for failure cases are found here. Success cases for this interface are tested elsewhere. For example, the success case for I{AF_INET} is in L{twisted.internet.test.test_tcp}, since that case should behave exactly the same as L{IReactorTCP.listenTCP}. c VP4p\P!4pVP4pVP4VP \P VP V\P\44p\P!4'd4VPVP^,\P4R#VPVP^,\P4R#)z An implementation of L{IReactorSocket.adoptStreamPort} raises L{socket.error} if passed an integer which is not associated with a socket. N)rsocketfilenoclose assertRaiseserroradoptStreamPortAF_INETrr isWindows assertEqualargserrno WSAENOTSOCKEBADFrrprober&excs& rtest_invalidDescriptor8AdoptStreamPortErrorsTestsBuilder.test_invalidDescriptorBs ##%   LL  # #  NN O          SXXa[%*;*; <   SXXa[%++ 6rc @VP4p\P!4pVPR4VP^4VP VP 4RpVP \VPVP4V\44R#)z An implementation of L{IReactorSocket.adoptStreamPort} raises L{UnsupportedAddressFamily} if passed an address family it does not support. Nz 127.0.0.1) rr%bindlisten addCleanupr'r(rr*r&rrrport arbitrarys& rtest_invalidAddressFamily;AdoptStreamPortErrorsTestsBuilder.test_invalidAddressFamilyZsu ##%}} "# A  #   $  # # KKM  O  rc aaaaSP4o\P!4oSPSP4SP R4SP ^4SP R4SPSP4SP\44pVP4oVV3RlpSPV4SP\R4\SVV3Rl4SP!4R#)a  When the L{IListeningPort} returned by L{IReactorSocket.adoptStreamPort} is stopped using C{stopListening}, the underlying socket is closed but not shutdown. This allows another process which still has a reference to it to continue accepting connections over it. FcZ<SP\PSP4p\P !4'd4SP VP^,\P4R#SP VP^,\P4R#)r9N) r(r%r)acceptr r,r-r.r/WSAEWOULDBLOCKEAGAINignoredr4 portSocketrs& rstoppedFAdoptStreamPortErrorsTestsBuilder.test_stopOnlyCloses..stoppedsj##FLL*2C2CDC!!##  !e.B.BC  !ell;rz"Failed to accept on original port.c.<SPV3Rl4#)c$<SP4#NstoprIrs&rYAdoptStreamPortErrorsTestsBuilder.test_stopOnlyCloses.... 7<<>r addCallbackdrsrrSGAdoptStreamPortErrorsTestsBuilder.test_stopOnlyCloses..Q]]+IJrNr8)rr%r=r'r;r< setblockingr*r&familyr stopListeningrW addErrbackr rrunrr?rKrYrJrsf @@@rtest_stopOnlyCloses5AdoptStreamPortErrorsTestsBuilder.test_stopOnlyClosesqs##%]]_   (()()!u%&&    !2!2MO      < g S>? J   rrN rrrrrrrr5rArbrrr s@rr#r#6s)))70 .((rr#c0a]tRt^toRt].tRtRtVt R#)'AdoptStreamConnectionErrorsTestsBuilderaa Builder for testing L{IReactorSocket.adoptStreamConnection} implementations. Generally only tests for failure cases are found here. Success cases for this interface are tested elsewhere. For example, the success case for I{AF_INET} is in L{twisted.internet.test.test_tcp}, since that case should behave exactly the same as L{IReactorTCP.listenTCP}. c VP4p\P!4pVPVP4RpVP \ VP VP4V\44R#)z An implementation of L{IReactorSocket.adoptStreamConnection} raises L{UnsupportedAddressFamily} if passed an address family it does not support. Nr:) rr%r=r'r(radoptStreamConnectionr&r)rr connectionr@s& rrAAAdoptStreamConnectionErrorsTestsBuilder.test_invalidAddressFamilysb ##%]]_   (()   $  ) )      O  rrN) rrrrrrrrArrr s@rrfrfs))  rrfc<a]tRt^toRt].tRtRtRt Rt Vt R#)#AdoptDatagramPortErrorsTestsBuilderzJ Builder for testing L{IReactorSocket.adoptDatagramPort} implementations. c VP4p\P!4pVP4pVP4VP \P VP V\P\44p\P!4'd4VPVP^,\P4R#VPVP^,\P4R#)z An implementation of L{IReactorSocket.adoptDatagramPort} raises L{socket.error} if passed an integer which is not associated with a socket. N)rr%r&r'r(r)adoptDatagramPortr+rr r,r-r.r/r0r1r2s& rr5:AdoptDatagramPortErrorsTestsBuilder.test_invalidDescriptors ##%   LL  % %  NN            SXXa[%*;*; <   SXXa[%++ 6rc 8VP4p\P!\P\P4pVP VP 4RpVP \VPVP4V\44R#)z An implementation of L{IReactorSocket.adoptDatagramPort} raises L{UnsupportedAddressFamily} if passed an address family it does not support. Nr:) rr%r+ SOCK_DGRAMr=r'r(rrnr&rr>s& rrA=AdoptDatagramPortErrorsTestsBuilder.test_invalidAddressFamilysm ##%}}V^^V->->?  #   $  % % KKM     rc 2aaaaSP4o\P!\P\P4oSP SP 4SP R4SPR4SPSP4SP\44pVP4oVV3RlpSPV4SP\R4\!SVV3Rl4SP#4R#)a When the L{IListeningPort} returned by L{IReactorSocket.adoptDatagramPort} is stopped using C{stopListening}, the underlying socket is closed but not shutdown. This allows another process which still has a reference to it to continue reading and writing to it. Fc\<SP\PSP^4p\P !4'd4SP VP^,\P4R#SP VP^,\P4R#)N) r(r%r)recvfromr r,r-r.r/rFrGrHs& rrKHAdoptDatagramPortErrorsTestsBuilder.test_stopOnlyCloses..stopped sl##FLL*2E2EqIC!!##  !e.B.BC  !ell;rz Failed to read on original port.c.<SPV3Rl4#)c$<SP4#rOrPrRs&rrS[AdoptDatagramPortErrorsTestsBuilder.test_stopOnlyCloses....rUrrVrXsrrSIAdoptDatagramPortErrorsTestsBuilder.test_stopOnlyCloses..r[rNr8)rr%r+rqr=r'r;r\rnr&r]rr^rWr_r rr`rasf @@@rrb7AdoptDatagramPortErrorsTestsBuilder.test_stopOnlyClosess##%]]6>>63D3DE   (()()u%((    !2!24D4F      < g S<= J   rrNrdr s@rrlrls)))70 *&&rrl)rr/r%zope.interfacertwisted.internet.errorrtwisted.internet.interfacesrtwisted.internet.protocolrr#twisted.internet.test.reactormixinsrrtwisted.python.logr twisted.python.runtimer r r#rfrlglobalsupdatemakeTestCaseClassesrrrrs !;6ES"+F^F8ccL  n  FZ.Zz 7KKMN 2FFHI 8LLNO 4HHJKr