U  W[q$ã@sdZddlZddlZddlmZddlmZddlmZddl m Z ddl m Z m Z ddlmZmZdd lmZdd lmZGd d „d eƒZGd d„deƒ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)Úerr)ÚIReactorSocket)ÚUnsupportedAddressFamily)ÚDatagramProtocolÚ ServerFactory)ÚReactorBuilderÚneedsRunningReactor)Ú_PY3)Ú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)Ú buildReactorZ assertTruerZ verifyObjectr)ÚselfÚreactor©rúC/usr/lib/python3/dist-packages/twisted/internet/test/test_socket.pyÚ test_provider/s ÿz4IReactorSocketVerificationTestsBuilder.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}. cCst| ¡}t ¡}| ¡}| ¡| tj|j|tjtƒ¡}t   ¡r\t r\|  |j dtj¡n|  |j dtj¡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 Ú isWindowsr Ú assertEqualÚargsÚerrnoÚ WSAENOTSOCKÚEBADF©rrZproberÚexcrrrÚtest_invalidDescriptorEsþ 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*FcsJˆ tjˆj¡}t ¡r2tr2ˆ |jdt j ¡nˆ |jdt j ¡dS)Nr) rrrZacceptr r r r!r"r#ÚWSAEWOULDBLOCKÚEAGAIN©Úignoredr'©Ú portSocketrrrÚstoppedƒs zFAdoptStreamPortErrorsTestsBuilder.test_stopOnlyCloses..stoppedz"Failed to accept on original port.csˆ ‡fdd„¡S)Ncsˆ ¡S©N©Ústop©r6©rrrÚ‘ózYAdoptStreamPortErrorsTestsBuilder.test_stopOnlyCloses....©Ú addCallbackr©Údrrrr?‘r@zGAdoptStreamPortErrorsTestsBuilder.test_stopOnlyCloses..N)r rr.rr,r-Ú setblockingrrÚfamilyrÚ stopListeningrBÚ addErrbackrr Úrun©rr0r9r©rDr8rrrÚtest_stopOnlyClosesns(    ÿ   þz5AdoptStreamPortErrorsTestsBuilder.test_stopOnlyClosesN© rrrrrrr(r2rLrrrrr:s 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)rrZ connectionr1rrrr2£s ýzAAdoptStreamConnectionErrorsTestsBuilder.test_invalidAddressFamilyN)rrrrrrr2rrrrrN—s rNc@s.eZdZdZegZdd„Zdd„Zdd„ZdS) Ú#AdoptDatagramPortErrorsTestsBuilderzR Builder for testing L{IReactorSocket.adoptDatagramPort} implementations. cCst| ¡}t ¡}| ¡}| ¡| tj|j|tjtƒ¡}t   ¡r\t r\|  |j dtj¡n|  |j dtj¡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%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.rrrrPrrr/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)FcsLˆ tjˆjd¡}t ¡r4tr4ˆ |jdt j ¡nˆ |jdt j ¡dS)Nr*r) rrrZrecvfromr r r r!r"r#r3r4r5r7rrr9ûs zHAdoptDatagramPortErrorsTestsBuilder.test_stopOnlyCloses..stoppedz Failed to read on original port.csˆ ‡fdd„¡S)Ncsˆ ¡Sr:r;r=r>rrr?r@z[AdoptDatagramPortErrorsTestsBuilder.test_stopOnlyCloses....rArrCrrr?r@zIAdoptDatagramPortErrorsTestsBuilder.test_stopOnlyCloses..N)r rrrQr.rr,rErPrrFrrGrBrHrr rIrJrrKrrLçs&   ÿ   þz7AdoptDatagramPortErrorsTestsBuilder.test_stopOnlyClosesNrMrrrrrO·s rO)rr#rZzope.interfacerZtwisted.python.logrZtwisted.internet.interfacesrZtwisted.internet.errorrZtwisted.internet.protocolrrZ#twisted.internet.test.reactormixinsrr Ztwisted.python.compatr Ztwisted.python.runtimer r rrNrOÚglobalsÚupdateZmakeTestCaseClassesrrrrÚs"       ] W