֛h$SrSSKrSSKrSSKJr SSKJr SSKJr SSK J r J r SSK J r Jr SSKJr SS KJr "S S \ 5r"S S \ 5r"SS\ 5r"SS\ 5r\"5R1\R355 \"5R1\R355 \"5R1\R355 \"5R1\R355 g)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)platformc$\rSrSrSr\/rSrSrg)&IReactorSocketVerificationTestsBuildera# 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}. cxUR5nUR[R"[U55 g)zN The reactor instance returned by C{buildReactor} provides L{IReactorSocket}. N) buildReactor assertTruer verifyObjectr)selfreactors eC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/internet/test/test_socket.py test_provider4IReactorSocketVerificationTestsBuilder.test_provider-s+ ##% ++NGDEN) __name__ __module__ __qualname____firstlineno____doc__rrequiredInterfacesr__static_attributes__rrrr r s ))Frr c0\rSrSrSr\/rSrSrSr Sr g)!AdoptStreamPortErrorsTestsBuilder6a[ 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}. cUR5n[R"5nUR5nUR5 UR [R UR U[R[55n[R"5(a.URURS[R5 gURURS[R5 g)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_invalidDescriptor8AdoptStreamPortErrorsTestsBuilder.test_invalidDescriptorBs ##%   LL  # #  NN O          SXXa[%*;*; <   SXXa[%++ 6rc>UR5n[R"5nURS5 URS5 UR UR 5 SnUR [URUR5U[55 g)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_invalidAddressFamily;AdoptStreamPortErrorsTestsBuilder.test_invalidAddressFamilyZsu ##%}} "# A  #   $  # # KKM  O  rc^^^^TR5m[R"5mTRTR5 TR S5 TR S5 TR S5 TRTR5TR[55nUR5mUU4SjnTRU5 TR[S5 [TUU4Sj5 TR!5 g)a  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. r8r9FcD>TR[RTR5n[R "5(a.TR URS[R5 gTR URS[R5 g)Nr) r(r%r)acceptr r,r-r.r/WSAEWOULDBLOCKEAGAINignoredr4 portSocketrs rstoppedFAdoptStreamPortErrorsTestsBuilder.test_stopOnlyCloses..stoppedsj##FLL*2C2CDC!!##  !e.B.BC  !ell;rz"Failed to accept on original port.c.>TRU4Sj5$)Nc$>TR5$NstoprIrs rYAdoptStreamPortErrorsTestsBuilder.test_stopOnlyCloses.... 7<<>r addCallbackdrsrrSGAdoptStreamPortErrorsTestsBuilder.test_stopOnlyCloses..Q]]+IJrN)rr%r=r'r;r< setblockingr*r&familyr stopListeningrW addErrbackr r runrr?rKrYrJrs` @@@rtest_stopOnlyCloses5AdoptStreamPortErrorsTestsBuilder.test_stopOnlyClosesqs##%]]_   (()()!u%&&    !2!2MO      < g S>? J   rrN rrrrrrrr5rArbr rrrr"r"6s!))70 .(rr"c$\rSrSrSr\/rSrSrg)'AdoptStreamConnectionErrorsTestsBuilderaa 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}. cUR5n[R"5nURUR5 SnUR [ UR UR5U[55 g)z An implementation of L{IReactorSocket.adoptStreamConnection} raises L{UnsupportedAddressFamily} if passed an address family it does not support. r:N) rr%r=r'r(radoptStreamConnectionr&r)rr connectionr@s rrAAAdoptStreamConnectionErrorsTestsBuilder.test_invalidAddressFamilysb ##%]]_   (()   $  ) )      O  rrN) rrrrrrrrAr rrrrfrfs)) rrfc0\rSrSrSr\/rSrSrSr Sr g)#AdoptDatagramPortErrorsTestsBuilderzJ Builder for testing L{IReactorSocket.adoptDatagramPort} implementations. cUR5n[R"5nUR5nUR5 UR [R UR U[R[55n[R"5(a.URURS[R5 gURURS[R5 g)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/r0r1r2s rr5:AdoptDatagramPortErrorsTestsBuilder.test_invalidDescriptors ##%   LL  % %  NN            SXXa[%*;*; <   SXXa[%++ 6rc6UR5n[R"[R[R5nUR UR 5 SnUR [URUR5U[55 g)z An implementation of L{IReactorSocket.adoptDatagramPort} raises L{UnsupportedAddressFamily} if passed an address family it does not support. r:N) rr%r+ SOCK_DGRAMr=r'r(rrpr&rr>s rrA=AdoptDatagramPortErrorsTestsBuilder.test_invalidAddressFamilysm ##%}}V^^V->->?  #   $  % % KKM     rc0^^^^TR5m[R"[R[R5mTR TR 5 TR S5 TRS5 TRTR5TR[55nUR5mUU4SjnTRU5 TR[S5 [!TUU4Sj5 TR#5 g)a 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. r8FcF>TR[RTRS5n[R "5(a.TR URS[R5 gTR URS[R5 g)Nr9r) r(r%r)recvfromr r,r-r.r/rFrGrHs rrKHAdoptDatagramPortErrorsTestsBuilder.test_stopOnlyCloses..stopped sl##FLL*2E2EqIC!!##  !e.B.BC  !ell;rz Failed to read on original port.c.>TRU4Sj5$)Nc$>TR5$rOrPrRs rrS[AdoptDatagramPortErrorsTestsBuilder.test_stopOnlyCloses....rUrrVrXsrrSIAdoptDatagramPortErrorsTestsBuilder.test_stopOnlyCloses..r[rN)rr%r+rsr=r'r;r\rpr&r]rr^rWr_r r r`ras` @@@rrb7AdoptDatagramPortErrorsTestsBuilder.test_stopOnlyClosess##%]]6>>63D3DE   (()()u%((    !2!24D4F      < g S<= J   rrNrdrrrrmrms!))70 *&rrm)rr/r%zope.interfacertwisted.internet.errorrtwisted.internet.interfacesrtwisted.internet.protocolrr#twisted.internet.test.reactormixinsrr twisted.python.logr twisted.python.runtimer r r"rfrmglobalsupdatemakeTestCaseClassesrrrrs !;6ES"+F^F8ccL  n  FZ.Zz 7KKMN 2FFHI 8LLNO 4HHJKr