o ¯bã$ã@sôdZddlZddlZddlmZddlmZddlmZddl m Z m Z ddl m Z mZddlmZdd lmZGd d „d e ƒZGd d „d e ƒZGdd„de ƒZGdd„de ƒZeƒ e ¡¡eƒ e ¡¡eƒ e ¡¡eƒ e ¡¡dS)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)ÚReactorBuilderÚneedsRunningReactor)Úerr)Úplatformc@óeZdZdZegZdd„ZdS)Ú&IReactorSocketVerificationTestsBuilderaO 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}. cCs| ¡}| t t|¡¡dS)zf The reactor instance returned by C{buildReactor} provides L{IReactorSocket}. N)Ú buildReactorÚ assertTruerÚ verifyObjectr)ÚselfÚreactor©rúC/usr/lib/python3/dist-packages/twisted/internet/test/test_socket.pyÚ test_provider-sz4IReactorSocketVerificationTestsBuilder.test_providerN)Ú__name__Ú __module__Ú __qualname__Ú__doc__rÚrequiredInterfacesrrrrrr s r c@ó.eZdZdZegZdd„Zdd„Zdd„ZdS) Ú!AdoptStreamPortErrorsTestsBuilderas 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}. cCór| ¡}t ¡}| ¡}| ¡| tj|j|tjtƒ¡}t   ¡r-|  |j dt j¡dS|  |j dt j¡dS)z« An implementation of L{IReactorSocket.adoptStreamPort} raises L{socket.error} if passed an integer which is not associated with a socket. rN)r ÚsocketÚfilenoÚcloseÚ assertRaisesÚerrorÚadoptStreamPortÚAF_INETrr Ú isWindowsÚ assertEqualÚargsÚerrnoÚ WSAENOTSOCKÚEBADF©rrÚproberÚexcrrrÚtest_invalidDescriptorBóûz8AdoptStreamPortErrorsTestsBuilder.test_invalidDescriptorcCsR| ¡}t ¡}| d¡| d¡| |j¡d}| t|j|  ¡|t ƒ¡dS)z¬ An implementation of L{IReactorSocket.adoptStreamPort} raises L{UnsupportedAddressFamily} if passed an address family it does not support. ©z 127.0.0.1rééN) r rÚbindÚlistenÚ addCleanuprr rr"rr©rrÚportÚ arbitraryrrrÚtest_invalidAddressFamilyZs   ûz;AdoptStreamPortErrorsTestsBuilder.test_invalidAddressFamilycsœˆ ¡‰t ¡‰ˆ ˆj¡ˆ d¡ˆ d¡ˆ d¡ˆ ˆ ¡ˆj t ƒ¡}|  ¡‰‡‡fdd„}ˆ  |¡ˆ  td¡tˆ‡‡fdd„ƒˆ ¡d S) a9 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. r/r0FcsHˆ tjˆj¡}t ¡rˆ |jdtj ¡dSˆ |jdtj ¡dS)Nr) r rr!Úacceptr r$r%r&r'ÚWSAEWOULDBLOCKÚEAGAIN©Úignoredr,©Ú portSocketrrrÚstoppedˆszFAdoptStreamPortErrorsTestsBuilder.test_stopOnlyCloses..stoppedz"Failed to accept on original port.cóˆ ‡fdd„¡S)Ncóˆ ¡S©N©Ústop©r=©rrrÚ–ózYAdoptStreamPortErrorsTestsBuilder.test_stopOnlyCloses....©Ú addCallbackr©ÚdrrrrH–ózGAdoptStreamPortErrorsTestsBuilder.test_stopOnlyCloses..N)r rr4rr2r3Ú setblockingr"rÚfamilyrÚ stopListeningrKÚ addErrbackr rÚrun©rr6r@r©rMr?rrrÚtest_stopOnlyClosesqs"    ÿ ÿ z5AdoptStreamPortErrorsTestsBuilder.test_stopOnlyClosesN© rrrrrrr-r8rVrrrrr6s   rc@r )Ú'AdoptStreamConnectionErrorsTestsBuildera} 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}. cCs>| ¡}t ¡}| |j¡d}| t|j| ¡|tƒ¡dS)z² An implementation of L{IReactorSocket.adoptStreamConnection} raises L{UnsupportedAddressFamily} if passed an address family it does not support. r1N) r rr4rr rÚadoptStreamConnectionrr)rrÚ connectionr7rrrr8©s ûzAAdoptStreamConnectionErrorsTestsBuilder.test_invalidAddressFamilyN)rrrrrrr8rrrrrXœs rXc@r) Ú#AdoptDatagramPortErrorsTestsBuilderzR Builder for testing L{IReactorSocket.adoptDatagramPort} implementations. cCr)z­ An implementation of L{IReactorSocket.adoptDatagramPort} raises L{socket.error} if passed an integer which is not associated with a socket. rN)r rrrr r!ÚadoptDatagramPortr#rr r$r%r&r'r(r)r*rrrr-Ær.z:AdoptDatagramPortErrorsTestsBuilder.test_invalidDescriptorcCsF| ¡}t tjtj¡}| |j¡d}| t|j|  ¡|t ƒ¡dS)z® An implementation of L{IReactorSocket.adoptDatagramPort} raises L{UnsupportedAddressFamily} if passed an address family it does not support. r1N) r rr#Ú SOCK_DGRAMr4rr rr\rrr5rrrr8Þs ûz=AdoptDatagramPortErrorsTestsBuilder.test_invalidAddressFamilycsšˆ ¡‰t tjtj¡‰ˆ ˆj¡ˆ d¡ˆ d¡ˆ ˆ  ¡ˆj t ƒ¡}|  ¡‰‡‡fdd„}ˆ  |¡ˆ td¡tˆ‡‡fdd„ƒˆ ¡dS) a7 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. r/FcsJˆ tjˆjd¡}t ¡rˆ |jdtj ¡dSˆ |jdtj ¡dS)Nr0r) r rr!Úrecvfromr r$r%r&r'r:r;r<r>rrr@ szHAdoptDatagramPortErrorsTestsBuilder.test_stopOnlyCloses..stoppedz Failed to read on original port.crA)NcrBrCrDrFrGrrrHrIz[AdoptDatagramPortErrorsTestsBuilder.test_stopOnlyCloses....rJrrLrrrHrNzIAdoptDatagramPortErrorsTestsBuilder.test_stopOnlyCloses..N)r rr#r]r4rr2rOr\rrPrrQrKrRr rrSrTrrUrrVós    ÿ ÿ z7AdoptDatagramPortErrorsTestsBuilder.test_stopOnlyClosesNrWrrrrr[¿s  r[)rr'rÚzope.interfacerÚtwisted.internet.errorrÚtwisted.internet.interfacesrÚtwisted.internet.protocolrrÚ#twisted.internet.test.reactormixinsrrÚtwisted.python.logr Útwisted.python.runtimer r rrXr[ÚglobalsÚupdateÚmakeTestCaseClassesrrrrÚs$      f#]