ó >Mc@s£ddlmZyLddlmZmZmZddlmZm Z m Z ddl m Z Wne k rudZnXddlmZdejfd„ƒYZd S( iÿÿÿÿ(tunittest(t iocpsupportttcptudp(t IOCPReactortEVENTS_PER_LOOPt KEY_NORMAL(tIReadWriteHandles%This test only applies to IOCPReactor(t verifyClasstIOCPReactorTestCasecBs#eZd„Zd„Zd„ZRS(cCs-tƒ}|jƒ|j|jdƒƒdS(sd Test reactor behavior (doIteration) when there are no pending time events. N(RtwakeUptfailIft doIterationtNone(tselftir((sC/usr/lib/python2.7/dist-packages/twisted/internet/test/test_iocp.pyttest_noPendingTimerEvents s  cCs$tttjƒtttjƒdS(sY Verify that IOCP socket-representing classes implement IReadWriteHandle N(RRRt ConnectionRtPort(R((sC/usr/lib/python2.7/dist-packages/twisted/internet/test/test_iocp.pyttest_reactorInterfacesscCs³ddd„ƒY}tƒ}|ƒ}tj|j|ƒ}x.ttdƒD]}|jjdt|ƒqKW|j dƒ|j |j tƒ|j dƒ|j |j tdƒdS(s† Verify that we don't lose an event when more than EVENTS_PER_LOOP events occur in the same reactor iteration tFakeFDcBs eZdZd„Zd„ZRS(icSsdS(NR((R((sC/usr/lib/python2.7/dist-packages/twisted/internet/test/test_iocp.pyt logPrefix&scSs|jd7_dS(Ni(tcounter(Rtrctbytestevt((sC/usr/lib/python2.7/dist-packages/twisted/internet/test/test_iocp.pytcb(s(t__name__t __module__RRR(((sC/usr/lib/python2.7/dist-packages/twisted/internet/test/test_iocp.pyR$s iiN(( Rt_iocptEventRtrangeRtportt postEventRR R t assertEqualsR(RRRtfdteventt_((sC/usr/lib/python2.7/dist-packages/twisted/internet/test/test_iocp.pyttest_maxEventsPerIterations    (RRRRR&(((sC/usr/lib/python2.7/dist-packages/twisted/internet/test/test_iocp.pyR s N(t twisted.trialRttwisted.internet.iocpreactorRRRRt$twisted.internet.iocpreactor.reactorRRRt'twisted.internet.iocpreactor.interfacesRt ImportErrortskiptzope.interface.verifyRtTestCaseR (((sC/usr/lib/python2.7/dist-packages/twisted/internet/test/test_iocp.pyts