U “«jÝ$ã@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@seZdZdZegZdd„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Ú assertTruerZ verifyObjectr)ÚselfÚreactor©rúE/tmp/pip-unpacked-wheel-59kc99xd/twisted/internet/test/test_socket.pyÚ test_provider-sz4IReactorSocketVerificationTestsBuilder.test_providerN)Ú__name__Ú __module__Ú __qualname__Ú__doc__rÚrequiredInterfacesrrrrrr sr c@s.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}. cCsp| ¡}t ¡}| ¡}| ¡| tj|j|tjtƒ¡}t   ¡rX|  |j dt j¡n|  |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©rrZproberÚexcrrrÚtest_invalidDescriptorBsû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Ú addCleanuprrrrrr©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)r*FcsFˆ tjˆj¡}t ¡r.ˆ |jdtj ¡nˆ |jdtj ¡dS)Nr) rrrÚacceptr r r!r"r#ÚWSAEWOULDBLOCKÚEAGAIN©Úignoredr'©Ú portSocketrrrÚstoppedˆszFAdoptStreamPortErrorsTestsBuilder.test_stopOnlyCloses..stoppedz"Failed to accept on original port.csˆ ‡fdd„¡S)Ncsˆ ¡S©N©Ústop©r7©rrrÚ–ózYAdoptStreamPortErrorsTestsBuilder.test_stopOnlyCloses....©Ú addCallbackr©Údrrrr@–rAzGAdoptStreamPortErrorsTestsBuilder.test_stopOnlyCloses..N)r rr.rr,r-Ú setblockingrrÚfamilyrÚ stopListeningrCÚ addErrbackr rÚrun©rr0r:r©rEr9rrrÚtest_stopOnlyClosesqs(    ÿ   ÿz5AdoptStreamPortErrorsTestsBuilder.test_stopOnlyClosesN© rrrrrrr(r2rMrrrrr6s  rc@seZdZdZegZdd„ZdS)Ú'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. r+N) r rr.rrrZadoptStreamConnectionrr)rrÚ connectionr1rrrr2©s ûzAAdoptStreamConnectionErrorsTestsBuilder.test_invalidAddressFamilyN)rrrrrrr2rrrrrOœs rOc@s.eZdZdZegZdd„Zdd„Zdd„ZdS) Ú#AdoptDatagramPortErrorsTestsBuilderzR Builder for testing L{IReactorSocket.adoptDatagramPort} implementations. cCsp| ¡}t ¡}| ¡}| ¡| tj|j|tjtƒ¡}t   ¡rX|  |j dt j¡n|  |j dt j¡dS)z­ An implementation of L{IReactorSocket.adoptDatagramPort} raises L{socket.error} if passed an integer which is not associated with a socket. rN)r rrrrrÚadoptDatagramPortrrr r r!r"r#r$r%r&rrrr(Æsû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. r+N) r rrÚ SOCK_DGRAMr.rrrrRrrr/rrrr2Þ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)FcsHˆ tjˆjd¡}t ¡r0ˆ |jdtj ¡nˆ |jdtj ¡dS)Nr*r) rrrÚrecvfromr r r!r"r#r4r5r6r8rrr: szHAdoptDatagramPortErrorsTestsBuilder.test_stopOnlyCloses..stoppedz Failed to read on original port.csˆ ‡fdd„¡S)Ncsˆ ¡Sr;r<r>r?rrr@rAz[AdoptDatagramPortErrorsTestsBuilder.test_stopOnlyCloses....rBrrDrrr@rAzIAdoptDatagramPortErrorsTestsBuilder.test_stopOnlyCloses..N)r rrrSr.rr,rFrRrrGrrHrCrIr rrJrKrrLrrMós&   ÿ   ÿz7AdoptDatagramPortErrorsTestsBuilder.test_stopOnlyClosesNrNrrrrrQ¿s rQ)rr#rZzope.interfacerZtwisted.internet.errorrZtwisted.internet.interfacesrZtwisted.internet.protocolrrZ#twisted.internet.test.reactormixinsrrZtwisted.python.logr Ztwisted.python.runtimer r rrOrQÚglobalsÚupdateZmakeTestCaseClassesrrrrÚs"      f#]