o Òó·iÝ$ã@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Ú assertTruerZ verifyObjectr)ÚselfÚreactor©rúgC:\Users\psant\Downloads\PAF backend\school\venv\Lib\site-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©rrZproberÚ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Ú addCleanuprrrr!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-r.FcsHˆ tjˆj¡}t ¡rˆ |jdtj ¡dSˆ |jdtj ¡dS)Nr) rrr Ú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©ÚdrrrrF–ózGAdoptStreamPortErrorsTestsBuilder.test_stopOnlyCloses..N)r rr2rr0r1Ú setblockingr!rÚfamilyrÚ stopListeningrIÚ addErrbackr rÚrun©rr4r>r©rKr=rrrÚtest_stopOnlyClosesqs"    ÿ ÿ z5AdoptStreamPortErrorsTestsBuilder.test_stopOnlyClosesN© rrrrrrr+r6rTrrrrr6s   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. r/N) r rr2rrrZadoptStreamConnectionrr)rrÚ connectionr5rrrr6©s ûzAAdoptStreamConnectionErrorsTestsBuilder.test_invalidAddressFamilyN)rrrrrrr6rrrrrVœs rVc@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 rrrrr Ú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. r/N) r rr"Ú SOCK_DGRAMr2rrrrYrrr3rrrr6Þ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)Nr.r) rrr Úrecvfromr r#r$r%r&r8r9r:r<rrr> szHAdoptDatagramPortErrorsTestsBuilder.test_stopOnlyCloses..stoppedz Failed to read on original port.cr?)Ncr@rArBrDrErrrFrGz[AdoptDatagramPortErrorsTestsBuilder.test_stopOnlyCloses....rHrrJrrrFrLzIAdoptDatagramPortErrorsTestsBuilder.test_stopOnlyCloses..N)r rr"rZr2rr0rMrYrrNrrOrIrPr rrQrRrrSrrTós    ÿ ÿ z7AdoptDatagramPortErrorsTestsBuilder.test_stopOnlyClosesNrUrrrrrX¿s  rX)rr&rZzope.interfacerZtwisted.internet.errorrZtwisted.internet.interfacesrZtwisted.internet.protocolrrZ#twisted.internet.test.reactormixinsrrZtwisted.python.logr Ztwisted.python.runtimer r rrVrXÚglobalsÚupdateZmakeTestCaseClassesrrrrÚs$      f#]