כh2SrSSKrSSKrSSKrSSKrSSKJr SSKJ r J r SSK J r J r SSKJrJr SSKJrJrJrJrJrJrJrJrJrJrJr SSKJr SS KJ r SS K!J"r" \"\ RFRI\ 5(+S 5"S S \"55r%\"\ RFRI\ 5(+S 5"SS\"55r&g!\a SrNf=f)z Whitebox tests for TCP APIs. N)skipIf) interfacesreactor) gatherResults maybeDeferred)Protocol ServerFactory) _ACCEPT_ERRORSEAGAIN ECONNABORTED EINPROGRESSEMFILEENFILEENOBUFSENOMEMEPERM EWOULDBLOCKPort)log)platform)TestCasez?This test only applies to reactors that implement IReactorFDsetcp\rSrSrSrSrSrSrSr\ "\ R"5S:HS5S 5r S r g ) PlatformAssumptionsTests)z, Test assumptions about platform behaviors. i c /Ul[bSSKJn [ U"55S-n[R "[R 5Ul[R"[R X RS45 US-Ul gg)Nr) _listOpenFDsd) openSocketsresourcetwisted.internet.processrlen getrlimit RLIMIT_NOFILEoriginalFileLimit setrlimit socketLimit)selfrnewLimits cC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/test/test_tcp_internals.pysetUpPlatformAssumptionsTests.setUp4sy   ><>*Q.H%-%7%78N8N%OD "   &&3I3I!3L(M  (#~D  cxUR(a;URR5R5 UR(aM;[bg[R"[R 5Sn[ URSU5n[R"[R X!45 gg)Nrr) r popcloser!r$r%minr&r')r)currentHardLimit newSoftLimits r+tearDown!PlatformAssumptionsTests.tearDownFs    " ( ( *   (11(2H2HI!L t55a8:JKL   x55 7W X r.cf[R"5nURRU5 U$)zd Create and return a new socket object, also tracking it so it can be closed in the test tear down. )socketr append)r)ss r+r8PlatformAssumptionsTests.socketRs( MMO "r.win32zhWindows requires an unacceptably large amount of resources to provoke this behavior in the naive manner.cUR5nURS5 UR5SnURS5 UR5nUR S5 [ UR 5HnUR5 M URS5 URURSU45S[45 UR[R UR"5nURURS[[45 g![a*nURS[[4;aSnA MeSnAff=f) z Test that the platform accept(2) call fails with either L{EMFILE} or L{ENOBUFS} when there are too many file descriptors open. ) 127.0.0.1rrFrNz7Could provoke neither EMFILE nor ENOBUFS from platform.r>)r8bind getsocknamelisten setblockingranger(OSErrorargsrrfailassertIn connect_exr assertRaiseserroraccept)r)portserverPortNumberclientieexcs r+test_acceptOutOfFiles.PlatformAssumptionsTests.test_acceptOutOfFiles[s{{} "#++-a0 A5!t''(A  ) IIO P   {,<= >K@P  dkk: chhqkFG#45% 66!9 11  sD"" E,EEE)r r&r(N)__name__ __module__ __qualname____firstlineno____doc__r(r,r5r8rrgetTyperS__static_attributes__r.r+rr)sM K.$ Y g% 5 %6  %6r.rcd\rSrSrSrSrSrSrSrSr Sr S r \ "\ R"5S :HS 5S 5r\ "\ R"5S :HS 5S5r\ "\R$R'S5S:HS5S5r\ "\ R"5S :HS5S5rSrSrg)SelectReactorTestsz/ Tests for select-specific failure conditions. ct/Ul/Ul[R"URR5 gN)portsmessagesr addObserverr9r)s r+r,SelectReactorTests.setUps&    ,,-r.c[R"URR5 [ UR Vs/sHn[ UR5PM sn5$s snfra)rremoveObserverrcr9rrbr stopListening)r)ps r+r5SelectReactorTests.tearDownsD 4==//0djjQjmAOO\rSrSrSrU4SjrSrg)9SelectReactorTests._acceptFailureTest..FakeSocketz1 Pretend to be a socket in an overloaded system. cD>[T[R"T55era)rEosstrerror)r)socketErrorNumbers r+rL@SelectReactorTests._acceptFailureTest..FakeSocket.accepts/=N1OPPr.r\NrUrVrWrXrYrLr[)rzsr+ FakeSocketrus  Q Qr.r}rr>rmr8z/Could not accept new connection ({acceptError}) log_format acceptErrorz)Log event for failed accept not found in N) r rMpatchdoReaderrno errorcodercget assertGreaterr#) r)rzr}rqrMexpectedFormatexpectedErrorCodemsgmatchingMessagess ` r+_acceptFailureTest%SelectReactorTests._acceptFailureTests Q Q /yyG{y; 4:<0 J!OO,=> }}  % %7@GGM*.??@%     ! @D O  s59Cc,UR[5$)z C{accept(2)} can fail with C{EMFILE} when there are too many open file descriptors in the process. Test that this doesn't negatively impact any other existing connections. C{EMFILE} mainly occurs on Linux when the open file rlimit is encountered. )rrres r+test_tooManyFilesFromAccept.SelectReactorTests.test_tooManyFilesFromAccept&&v..r.c,UR[5$)z Similar to L{test_tooManyFilesFromAccept}, but test the case where C{accept(2)} fails with C{ENOBUFS}. This mainly occurs on Windows and FreeBSD, but may be possible on Linux and other platforms as well. )rrres r+test_noBufferSpaceFromAccept/SelectReactorTests.test_noBufferSpaceFromAccepts&&w//r.c,UR[5$)z Similar to L{test_tooManyFilesFromAccept}, but test the case where C{accept(2)} fails with C{ECONNABORTED}. It is not clear whether this is actually possible for TCP connections on modern versions of Linux. )rr res r+ test_connectionAbortedFromAccept3SelectReactorTests.test_connectionAbortedFromAccepts&&|44r.r<z(Windows accept(2) cannot generate ENFILEc,UR[5$)z Similar to L{test_tooManyFilesFromAccept}, but test the case where C{accept(2)} fails with C{ENFILE}. This can occur on Linux when the system has exhausted (!) its supply of inodes. )rrres r+test_noFilesFromAccept)SelectReactorTests.test_noFilesFromAcceptrr.z(Windows accept(2) cannot generate ENOMEMc,UR[5$)as Similar to L{test_tooManyFilesFromAccept}, but test the case where C{accept(2)} fails with C{ENOMEM}. On Linux at least, this can sensibly occur, even in a Python program (which eats memory like no ones business), when memory has become fragmented or low memory has been filled (d_alloc calls kmem_cache_alloc calls kmalloc - kmalloc only allocates out of low memory). )rrres r+test_noMemoryFromAccept*SelectReactorTests.test_noMemoryFromAccepts&&v..r.INFRASTRUCTUREAZUREPIPELINESz(Hangs on Azure Pipelines due to firewallc6^^[5n[UlURSUSS9mUR TR 5 /mU4SjnUR U5 U4SjnTR U"55 STlTR5 URTRS5 TR U"55 TR5 URTRS5 TR5 URTRS5 g)z L{tcp.Port.doRead} increases the number of consecutive C{accept} calls it performs if all of the previous C{accept} calls succeed; otherwise, it reduces the number to the amount of successful calls. rr>rmc8>THnUR5 M gra)r1)rOclientss r+closeAll7SelectReactorTests.test_acceptScaling..closeAlls! "r.c>[R"[R[R5nURSTR 5R 45 U$)Nr>)r8AF_INET SOCK_STREAMconnectgetHostrM)rOrMs r+r6SelectReactorTests.test_acceptScaling..connects?]]6>>63E3EFF NNK)<)<= >Mr.rN) r rprotocolrM addCleanuprir9 numberAcceptsrr assertEqual)r)rqrrrrMs @@r+test_acceptScaling%SelectReactorTests.test_acceptScalings /#yyG{y; **+  !  wy!  4--q1wy!  ++Q/  ++Q/r.z'Windows accept(2) cannot generate EPERMc^^^SmS/m"UUU4SjS5n[T5H2nTR[RU"5R5 M4 TRTR U"5R5 S/m[ 5nTRSUSS9nSUlTRUSU"55 UR5 TRURS5 g ) z C{accept(2)} returning C{EPERM} is treated as a transient failure and the call retried no more than the maximum number of consecutive C{accept(2)} calls. {rc*>\rSrSrSrUUU4SjrSrg)LSelectReactorTests.test_permissionFailure..FakeSocketWithAcceptLimiti<{ Pretend to be a socket in an overloaded system whose C{accept} method can only be called C{maximumNumberOfAccepts} times. c>TS==S- ss'TST:aTRS5 [[[R"[55e)Nrrz(Maximum number of accept calls exceeded.)rGrErrxry)oself acceptCallsmaximumNumberOfAcceptsr)s r+rLSSelectReactorTests.test_permissionFailure..FakeSocketWithAcceptLimit.acceptCsAA!#q>$::IIHIeR[[%788r.r\Nr|)rrr)sr+FakeSocketWithAcceptLimitr<s   9 9r.rr>rmr8rN) rDrJr8rKrLfailureExceptionr rMrrr assertEquals)r)r_rqrMrrs` @@r+test_permissionFailure)SelectReactorTests.test_permissionFailure2s"%c  9 9-.A   fll,E,G,N,N O/ $//1J1L1S1STc /yyG{y;  4#<#>?  $,,a0r.c^[[5nUR[[[ /5 [ SU55S-m"U4SjS5n[5nURSUSS9nURUSU"55 UR5 UR[R5nURS[U55 URUSR R"ST5 g ) ze A C{socket.error} raised by C{accept(2)} whose C{errno} is unknown to the recovery logic is logged. c3T# UHn[U[5(dMUv M g7fra) isinstanceint).0rKs r+ BSelectReactorTests.test_unknownSocketErrorRaise..gsI;%*UC2H;s( (rc&>\rSrSrSrU4SjrSrg)YSelectReactorTests.test_unknownSocketErrorRaise..FakeSocketWithUnknownAcceptErrorijrc>[TS5e)Nzunknown socket error message)rE)runknownAcceptErrors r+rL`SelectReactorTests.test_unknownSocketErrorRaise..FakeSocketWithUnknownAcceptError.acceptqs02PQQr.r\Nr|)rsr+ FakeSocketWithUnknownAcceptErrorrjs   R Rr.rrr>rmr8N)listr extendr rrmaxr rMrrflushLoggedErrorsr8rKrr#valuerF)r) knownErrorsrrqrMfailuresrs @r+test_unknownSocketErrorRaise/SelectReactorTests.test_unknownSocketErrorRaise^s >* FE;78 I;I IA M  R R /yyG{y; 4#C#EF ))&,,7 CM* !**//24FGr.)rcrbN)rUrVrWrXrYr,r5rMrrrrrrrZrrrxenvironrrrrr[r\r.r+r^r^s . S' R /05 H   ' )+UV/W/ H   ' )+UV /W /  '(,<<2'0 '0R H   ' )+TU)1V)1VHr.r^)'rYrrxr8r! ImportErrorunittestrtwisted.internetrrtwisted.internet.deferrrtwisted.internet.protocolrr twisted.internet.tcpr r r r rrrrrrrtwisted.pythonrtwisted.python.runtimertwisted.trial.unittestr IReactorFDSet providedByrr^r\r.r+rs  0?=    ++  ++G44EX6xX6 X6v  ++G44EpHpH pH{HsC CC