+ j2Rt^RIt^RIt^RIt^RIt^RIHt^RIH t H t ^RI H t H t ^RIHtHt^RIHtHtHtHtHtHtHtHtHtHtHt^RIHt^RIH t ^R I!H"t"]!] PFPI] 4'*R 4!R R ]"44t%]!] PFPI] 4'*R 4!R R]"44t&R# ]dRtLi;i)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 IReactorFDsetc|a]tRt^)toRtRtRtRtRt] !] P!4R8HR4R4t R t VtR #) PlatformAssumptionsTestsz, Test assumptions about platform behaviors. i c>.Vn\e^RIHp\ V!44^,p\P !\P 4Vn\P!\P W P^,34V^d,Vn R#R#)N) _listOpenFDs) openSocketsresourcetwisted.internet.processrlen getrlimit RLIMIT_NOFILEoriginalFileLimit setrlimit socketLimit)selfrnewLimits& A/usr/lib/python3/dist-packages/twisted/test/test_tcp_internals.pysetUpPlatformAssumptionsTests.setUp4sy   ><>*Q.H%-%7%78N8N%OD "   &&3I3I!3L(M  (#~D  cnVP'd+VPP4P4K<\eq\P!\P 4^,p\ VP^,V4p\P!\P W!34R#R#N) rpopcloserrr minr!r")r$currentHardLimit newSoftLimits& r&tearDown!PlatformAssumptionsTests.tearDownFs    " ( ( *   (11(2H2HI!L t55a8:JKL   x55 7W X r)c f\P!4pVPPV4V#)zd Create and return a new socket object, also tracking it so it can be closed in the test tear down. )socketrappend)r$ss& r&r4PlatformAssumptionsTests.socketRs( MMO "r)win32zhWindows requires an unacceptably large amount of resources to provoke this behavior in the naive manner.c VP4pVPR4VP4^,pVP^4VP4pVP R4\ VP 4FpVP4K VPR4VPVPRV34^\34VP\P VP"4pVPVP^,\\34R# \d0pTP^,\\39dRp?KhRp?ii;i)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.1FNz7Could provoke neither EMFILE nor ENOBUFS from platform.)r:)r4bind getsocknamelisten setblockingranger#OSErrorargsr rfailassertIn 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%6"E E  E%)rr!r#N)__name__ __module__ __qualname____firstlineno____doc__r#r'r1r4rrgetTyperO__static_attributes____classdictcell__ __classdict__s@r&rr)sP K.$ Y g% 5 %6  %6r)rcpa]tRt^toRtRtRtRtRtRt Rt Rt ] !] P!4R 8HR 4R 4t] !] P!4R 8HR 4R 4t] !]P$P'R4R8HR4R4t] !] P!4R 8HR4R4tRtRtVtR#)SelectReactorTestsz/ Tests for select-specific failure conditions. cv.Vn.Vn\P!VPP4R#r+)portsmessagesr addObserverr5r$s&r&r'SelectReactorTests.setUps&    ,,-r)c\P!VPP4\ VP Uu.uFp\ VP4NK up4#uupir+)rremoveObserverr_r5rr^r stopListening)r$ps& r&r1SelectReactorTests.tearDownsD 4==//0djjQjmAOO.FakeSocketz1 Pretend to be a socket in an overloaded system. cD<\S\P!S44hr+)rAosstrerror)r$socketErrorNumbers&r&rH@SelectReactorTests._acceptFailureTest..FakeSocket.accepts/=N1OPPr)NrQrRrSrTrUrHrWrX)rZrus@r& FakeSocketrqs  Q Qr)ryr:rir4z/Could not accept new connection ({acceptError}) log_format acceptErrorz)Log event for failed accept not found in N) rrIpatchdoReaderrno errorcoder_get assertGreaterr) r$ruryrmrIexpectedFormatexpectedErrorCodemsgmatchingMessagess &f r&_acceptFailureTest%SelectReactorTests._acceptFailureTests Q Q /yyG{y; 4:<0 J!OO,=> }}  % %7@@GGM*.??@%     ! @D O  s <C#C#c ,VP\4#)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. )rr ras&r&test_tooManyFilesFromAccept.SelectReactorTests.test_tooManyFilesFromAccept&&v..r)c ,VP\4#)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. )rrras&r&test_noBufferSpaceFromAccept/SelectReactorTests.test_noBufferSpaceFromAccepts&&w//r)c ,VP\4#)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 ras&r& test_connectionAbortedFromAccept3SelectReactorTests.test_connectionAbortedFromAccepts&&|44r)r8z(Windows accept(2) cannot generate ENFILEc ,VP\4#)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. )rrras&r&test_noFilesFromAccept)SelectReactorTests.test_noFilesFromAcceptrr)z(Windows accept(2) cannot generate ENOMEMc ,VP\4#)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). )rrras&r&test_noMemoryFromAccept*SelectReactorTests.test_noMemoryFromAccepts&&v..r)INFRASTRUCTUREAZUREPIPELINESz(Hangs on Azure Pipelines due to firewallc >aa\4p\VnVP^VRR7oVP SP 4.oV3RlpVP V4V3RlpSP V!44^SnSP4VPSP^4SP V!44SP4VPSP^4SP4VPSP^4R#)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. r:ric:<SFpVP4K R#r+)r-)rKclientss r&closeAll7SelectReactorTests.test_acceptScaling..closeAlls! "r)c<\P!\P\P4pVPRSP 4P 34V#)r:)r4AF_INET SOCK_STREAMconnectgetHostrI)rKrIs r&r6SelectReactorTests.test_acceptScaling..connects?]]6>>63E3EFF NNK)<)<= >Mr)N) rrprotocolrI addCleanuprer5 numberAcceptsr}r assertEqual)r$rmrrrrIs& @@r&test_acceptScaling%SelectReactorTests.test_acceptScalings /#yyG{y; **+  !  wy!  4--q1wy!  ++Q/  ++Q/r)z'Windows accept(2) cannot generate EPERMc aaa^{o^.o!VVV3RlR4p\S4F2pSP\PV!4P4K4 SPSP V!4P4^.o\ 4pSP^VRR7p^{VnSPVRV!44VP4SPVP^4R#)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. c6<a]tRtRtoRtVVV3RltRtVtR#)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<S^;;,^, uu&S^,S8dSPR4\\\P!\44h)r;z(Maximum number of accept calls exceeded.)rCrArrsrt)oself acceptCallsmaximumNumberOfAcceptsr$s&r&rHSSelectReactorTests.test_permissionFailure..FakeSocketWithAcceptLimit.acceptCsAA!#q>$::IIHIeR[[%788r)rwNrx)rZrrr$s@r&FakeSocketWithAcceptLimitr<s   9 9r)rr:rir4N) r@rFr4rGrHfailureExceptionrrIrr|r} assertEquals)r$r_rmrIrrsf @@r&test_permissionFailure)SelectReactorTests.test_permissionFailure2s"%c  9 9-.A   fll,E,G,N,N O/ $//1J1L1S1STc /yyG{y;  4#<#>?  $,,a0r)c a\\4pVP\\\ .4\ RV44^,o!V3RlR4p\4pVP^VRR7pVPVRV!44VP4VP\P4pVP^\V44VPV^,P P"^,S4R#)ze A C{socket.error} raised by C{accept(2)} whose C{errno} is unknown to the recovery logic is logged. c3V"TFp\V\4'gKVxK! R#5ir+) isinstanceint).0rGs& r& BSelectReactorTests.test_unknownSocketErrorRaise..gsI;%*UC2H;s) )c2<a]tRtRtoRtV3RltRtVtR#)YSelectReactorTests.test_unknownSocketErrorRaise..FakeSocketWithUnknownAcceptErrorijrc<\SR4h)zunknown socket error message)rA)runknownAcceptErrors&r&rH`SelectReactorTests.test_unknownSocketErrorRaise..FakeSocketWithUnknownAcceptError.acceptqs02PQQr)rwNrx)rZrs@r& FakeSocketWithUnknownAcceptErrorrjs   R Rr)rr:rir4N)listr extendr rrmaxrrIr|r}flushLoggedErrorsr4rGrrvaluerB)r$ knownErrorsrrmrIfailuresrs& @r&test_unknownSocketErrorRaise/SelectReactorTests.test_unknownSocketErrorRaise^s >* FE;78 I;I IA M  R R /yyG{y; 4#C#EF ))&,,7 CM* !**//24FGr))r_r^N)rQrRrSrTrUr'r1rIrrrrrrrVrrrsenvironrrrrrWrXrYs@r&r\r\s . S' R /05 H   ' )+UV/W/ H   ' )+UV /W /  '(,<<2'0 '0R H   ' )+TU)1V)1VHHr)r\)'rUr~rsr4r ImportErrorunittestrtwisted.internetrrtwisted.internet.deferrrtwisted.internet.protocolrrtwisted.internet.tcpr r r r r rrrrrrtwisted.pythonrtwisted.python.runtimertwisted.trial.unittestr IReactorFDSet providedByrr\rwr)r&rs  0?=    ++  ++G44EX6xX6 X6v  ++G44EpHpH pH{HsC CC