+ DfjRt^RIt^RIt^RIt^RIHt^RIHtHtHtH t Ht^RI H t ^RI H t ^RIHt^RIHt^RIHt^R IHt^R IHtHtHt^R IHt^R IHt^R IH t ^RI!H"t"H#t#H$t$]!]]4PQ4Rt)Rt*!RR]4t.!RR]4t/R# ]%d]PLR8XdhRt'LQi;i ]+dt,Rt)]-!],4t*Rt,A,LORt,A,ii;i)z, Tests for L{twisted.internet.iocpreactor}. N)array)AF_INETAF_INET6 SOCK_STREAM SOL_SOCKETsocket)pack)skipIf) verifyClass) IPushProducer)msg)TestCase) iocpsupporttcpudp) FileHandle)SO_UPDATE_ACCEPT_CONTEXT)IReadWriteHandle)EVENTS_PER_LOOP KEY_NORMAL IOCPReactorwin32z%This test only applies to IOCPReactorFTcNa]tRt^1toRtRtRt]!]] 4R4t Rt Vt R#) SupportTestszb Tests for L{twisted.internet.iocpreactor.iocpsupport}, low-level reactor implementation helpers. c  6\RV: 24\V\4pVPVP4VP R 4VP ^4\V\4pVPVP4VPR4VPW#P4^,34\V\4pVPVP4\RR 4pVP!^\"P$!VP'4VP'4VR44\)\+^44F7pVP-\.\0\3RVP'444M VP!WP;4R,VP4R,3\"P<!VP'4V44R# \dFpTPTP\P\P34Rp?ELyRp?ii;i \d3p T P\5\R48wdhT^8XdhRp ? MRp ? ii;i\6P8!R4EKJ) a Create a C{SOCK_STREAM} connection to localhost using a socket with an address family of C{family} and assert that the result of L{iocpsupport.get_accept_addrs} is consistent with the result of C{socket.getsockname} and C{socket.getpeername}. A port starts listening (is bound) at the low-level socket without calling accept() yet. A client is then connected. After the client is connected IOCP accept() is called, which is the target of these tests. Most of the time, the socket is ready instantly, but sometimes the socket is not ready right away after calling IOCP accept(). It should not take more than 5 seconds for a socket to be ready, as the client connection is already made over the loopback interface. These are flaky tests. Tweak the failure rate by changing the number of retries and the wait/sleep between retries. If you will need to update the retries to wait more than 5 seconds for the port to be available, then there might a bug in the code and not the test (or a very, very busy VM running the tests). z family = FNBP WSAENOTCONNg?:NN)rs)r rr addCleanupclosebindlisten setblockingconnect getsocknameOSErrorassertInerrno EINPROGRESS EWOULDBLOCKr assertEqual_iocpacceptfilenoreversedrange setsockoptrrrgetattrtimesleep getpeernameget_accept_addrs) selffamily localhostportclienteserverbuffattemptsRemaining socketErrors &&& A/usr/lib/python3/dist-packages/twisted/internet/test/test_iocp.py_acceptAddressTestSupportTests._acceptAddressTest7s4 iz "#fk*  # ' A ,  %5! K NNI'7'7'9!'<= > ,  %S+& ELL tTU!)%(!3  !! 8$sDKKM:R"4B  '')"-v/A/A/CB/G H  " "6==?D 9 S K MM!''E$5$5u7H7H#I J J K0 $$}(EE%)*  JJsOs0'G/3I/ H?::H::H? I? (I::I?c 2VP\R4R#)a L{iocpsupport.get_accept_addrs} returns a three-tuple of address information about the socket associated with the file descriptor passed to it. For a connection using IPv4: - the first element is C{AF_INET} - the second element is a two-tuple of a dotted decimal notation IPv4 address and a port number giving the peer address of the connection - the third element is the same type giving the host address of the connection z 127.0.0.1N)rDrr9s&rCtest_ipv4AcceptAddress#SupportTests.test_ipv4AcceptAddresss 5c 2VP\R4R#)aP Like L{test_ipv4AcceptAddress}, but for IPv6 connections. In this case: - the first element is C{AF_INET6} - the second element is a two-tuple of a hexadecimal IPv6 address literal and a port number giving the peer address of the connection - the third element is the same type giving the host address of the connection z::1N)rDrrGs&rCtest_ipv6AcceptAddress#SupportTests.test_ipv6AcceptAddresss %0rJN) __name__ __module__ __qualname____firstlineno____doc__rDrHr ipv6Skipipv6SkipReasonrL__static_attributes____classdictcell__ __classdict__s@rCrr1s1 P d 6 Hn% 1& 1rJrc8a]tRt^toRtRtRtRtRtVt R#)IOCPReactorTestsc z\4pVP4VPVPR44R#)zL Test reactor behavior (doIteration) when there are no pending time events. N)rwakeUp assertFalse doIteration)r9irs& rCtest_noPendingTimerEvents*IOCPReactorTests.test_noPendingTimerEventss+ ]  -.rJc VP\\\P44VP\\\ P 44R#)zI Verify that IOCP socket-representing classes implement IReadWriteHandle N) assertTruer rr ConnectionrPortrGs&rCtest_reactorInterfaces'IOCPReactorTests.test_reactorInterfacess4  $4cnnEF  $4chh?@rJc LVP\\\44R#)z8 Verify that L{Filehandle} implements L{IPushProducer}. N)rdr r rrGs&rCtest_fileHandleInterfaces*IOCPReactorTests.test_fileHandleInterfacess  M:>?rJc !RR4p\4pV!4p\P!VPV4p\ \ ^,4F$pVP P^\V4K& VPR4VPVP\ 4VP^4VPVP\ ^,4R#)zn Verify that we don't lose an event when more than EVENTS_PER_LOOP events occur in the same reactor iteration c0a]tRt^to^tRtRtRtVtR#);IOCPReactorTests.test_maxEventsPerIteration..FakeFDcR#)FakeFDrNrGs&rC logPrefixEIOCPReactorTests.test_maxEventsPerIteration..FakeFD.logPrefixsrJc8V;P^, unR#)N)counter)r9rcbytesevts&&&&rCcb>IOCPReactorTests.test_maxEventsPerIteration..FakeFD.cbs ! rJrNN) rOrPrQrRrurqryrVrWrXs@rCrprnsG  " "rJrpN) rr.Eventryr2rr< postEventrr_r-ru)r9rpr`fdevent_s& rCtest_maxEventsPerIteration+IOCPReactorTests.test_maxEventsPerIterations  " "] X BEE2&*+A GG  aU 3, t _5 q _q%89rJrNN) rOrPrQrRrargrjrrVrWrXs@rCr[r[s /A@ ::rJr[)0rSr*sysr5rrrrrrstructrunittestr zope.interface.verifyr twisted.internet.interfacesr twisted.python.logr twisted.trial.unittestr twisted.internet.iocpreactorrr.rr%twisted.internet.iocpreactor.abstractr"twisted.internet.iocpreactor.constr'twisted.internet.iocpreactor.interfacesr$twisted.internet.iocpreactor.reactorrrr ImportErrorplatformskipr"rTrUr(r>strrr[rNrJrCrs EE-5"+3KK@KH 8[!'') HNr18r1j.:x.:M3 ||w 2D 3HVNs*&B"/C"C?CC CC