Yf$^dZddlZddlZddlmZddlmZddlmZddl m Z m Z ddl m Z mZddlmZdd lmZGd d e ZGd d e ZGdde ZGdde ZeeeeeeeedS)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)platformceZdZdZegZdZdS)&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}. c|}|tjt|dS)zf The reactor instance returned by C{buildReactor} provides L{IReactorSocket}. N) buildReactor assertTruer verifyObjectr)selfreactors S/var/www/html/env/lib/python3.11/site-packages/twisted/internet/test/test_socket.py test_providerz4IReactorSocketVerificationTestsBuilder.test_provider-s: ##%% +NGDDEEEEEN)__name__ __module__ __qualname____doc__rrequiredInterfacesrrrr r s= ))FFFFFrr c*eZdZdZegZdZdZdZdS)!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}. c|}tj}|}||tj|j|tjt}tj r-| |j dtjdS| |j dtjdS)z An implementation of L{IReactorSocket.adoptStreamPort} raises L{socket.error} if passed an integer which is not associated with a socket. rN)rsocketfilenoclose assertRaiseserroradoptStreamPortAF_INETrr isWindows assertEqualargserrno WSAENOTSOCKEBADFrrprober!excs rtest_invalidDescriptorz8AdoptStreamPortErrorsTestsBuilder.test_invalidDescriptorBs ##%%   L  #  N OO        7   SXa[%*; < < < < <   SXa[%+ 6 6 6 6 6rcb|}tj}|d|d||jd}|t|j| |tdS)z An implementation of L{IReactorSocket.adoptStreamPort} raises L{UnsupportedAddressFamily} if passed an address family it does not support. z 127.0.0.1rN) rr bindlisten addCleanupr"r#rr%r!rrrport arbitrarys rtest_invalidAddressFamilyz;AdoptStreamPortErrorsTestsBuilder.test_invalidAddressFamilyZs ##%%} "### A  ###   $  # KKMM  OO      rcftjjdddj t}| fd} | tdtfddS)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. r2r3Fc(tjj}t jr-|jdtj dS|jdtj dS)Nr) r#r r$acceptr r'r(r)r*WSAEWOULDBLOCKEAGAINignoredr/ portSocketrs rstoppedzFAdoptStreamPortErrorsTestsBuilder.test_stopOnlyCloses..stoppedsy##FL*2CDDC!## <  !e.BCCCCC  !el;;;;;rz"Failed to accept on original port.c4fdS)Nc,SNstoprBrs rzYAdoptStreamPortErrorsTestsBuilder.test_stopOnlyCloses....7<<>>r addCallbackdrsrrKzGAdoptStreamPortErrorsTestsBuilder.test_stopOnlyCloses..Q]]+I+I+I+IJJrN)rr r7r"r5r6 setblockingr%r!familyr stopListeningrN addErrbackr r runrr9rDrPrCrs` @@@rtest_stopOnlyClosesz5AdoptStreamPortErrorsTestsBuilder.test_stopOnlyClosesqs6##%%]__   ()))()))!u%%%&&     !2MOO       < < < < < < g S>??? JJJJJ     rN rrrrrrr0r;rXrrrrr6sV))7770   .(((((rrceZdZdZegZdZdS)'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}. c|}tj}||jd}|t |j||tdS)z An implementation of L{IReactorSocket.adoptStreamConnection} raises L{UnsupportedAddressFamily} if passed an address family it does not support. r4N) rr r7r"r#radoptStreamConnectionr!r)rr connectionr:s rr;zAAdoptStreamConnectionErrorsTestsBuilder.test_invalidAddressFamilys~ ##%%]__   ()))   $  )       OO      rN)rrrrrrr;rrrr[r[s8))     rr[c*eZdZdZegZdZdZdZdS)#AdoptDatagramPortErrorsTestsBuilderzR Builder for testing L{IReactorSocket.adoptDatagramPort} implementations. c|}tj}|}||tj|j|tjt}tj r-| |j dtjdS| |j dtjdS)z An implementation of L{IReactorSocket.adoptDatagramPort} raises L{socket.error} if passed an integer which is not associated with a socket. rN)rr r!r"r#r$adoptDatagramPortr&rr r'r(r)r*r+r,r-s rr0z:AdoptDatagramPortErrorsTestsBuilder.test_invalidDescriptors ##%%   L  %  N           7   SXa[%*; < < < < <   SXa[%+ 6 6 6 6 6rc:|}tjtjtj}||jd}|t|j| |tdS)z An implementation of L{IReactorSocket.adoptDatagramPort} raises L{UnsupportedAddressFamily} if passed an address family it does not support. r4N) rr r& SOCK_DGRAMr7r"r#rrbr!rr8s rr;z=AdoptDatagramPortErrorsTestsBuilder.test_invalidAddressFamilys ##%%}V^V->??  ###   $  % KKMM          rchtjtjtjjdd j t}| fd} |tdt!fddS)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. r2Fc*tjjd}t jr-|jdtj dS|jdtj dS)Nr3r) r#r r$recvfromr r'r(r)r*r?r@rAs rrDzHAdoptDatagramPortErrorsTestsBuilder.test_stopOnlyCloses..stopped s{##FL*2EqIIC!## <  !e.BCCCCC  !el;;;;;rz Failed to read on original port.c4fdS)Nc,SrGrHrJs rrKz[AdoptDatagramPortErrorsTestsBuilder.test_stopOnlyCloses....rLrrMrOsrrKzIAdoptDatagramPortErrorsTestsBuilder.test_stopOnlyCloses..rQrN)rr r&rdr7r"r5rRrbr!rSrrTrNrUr r rVrWs` @@@rrXz7AdoptDatagramPortErrorsTestsBuilder.test_stopOnlyClosess0##%%]6>63DEE   ()))()))u%%%((     !24D4F4F       < < < < < < g S<=== JJJJJ     rNrYrrrr`r`sV))7770   *&&&&&rr`)rr*r zope.interfacertwisted.internet.errorrtwisted.internet.interfacesrtwisted.internet.protocolrr#twisted.internet.test.reactormixinsrr twisted.python.logr twisted.python.runtimer r rr[r`globalsupdatemakeTestCaseClassesrrrrts !!!!!!;;;;;;666666EEEEEEEESSSSSSSS""""""++++++FFFFF^FFF8ccccccccL      n    FZZZZZ.ZZZz 7KKMMNNN 2FFHHIII 8LLNNOOO 4HHJJKKKKKr