ó [³XMc@sŽdZeZddlZddlmZddlmZddlm Z ddl m Z m Z de fd„ƒYZ eƒje jƒƒdS( s0 Tests for implementations of L{IReactorFDSet}. iÿÿÿÿN(t IReactorFDSet(tFileDescriptor(tReactorBuilder(t EINPROGRESSt EWOULDBLOCKtReactorFDSetTestsBuildercBsqeZdZegZd„Zd„Zd„Zd„Zd„Z d„Z d„Z d„Z d „Z d „ZRS( s> Builder defining tests relating to L{IReactorFDSet}. cCstjƒ}|jdƒ|jdƒ|j|jƒtjƒ}|j|jƒ|jtƒy!|jd|jƒdfƒWnRtj k rµ}|j |j dt t fƒn tk rÔ}|jdƒnX|jƒ\}}|j|jƒ||fS(sL Return the two sockets which make up a new TCP connection. s 127.0.0.1iisBConnect should have succeeded or raised EINPROGRESS or EWOULDBLOCK(s 127.0.0.1i(tsockettbindtlistent addCleanuptcloset setblockingtFalsetconnectt getsocknameterrortassertIntargsRRt Exceptiontfailtaccept(tselft serverSockettclienttetservertaddr((sD/usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyt_connectedPairs      ! cCsC|jƒ}|jƒ\}}t|ƒ}|j|_|||fS(N(t buildReactorRRtfileno(RtreactorRRtfd((sD/usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyt _simpleSetup3s    cs[|jƒ\‰‰}‡‡fd†}|ˆ_ˆjˆƒ|jdƒ|jˆƒdS(s© C{reactor.addReader()} accepts an L{IReadDescriptor} provider and calls its C{doRead} method when there may be data available on its C{fileno}. csˆjˆƒˆjƒdS(N(t removeReadertstop((RR(sD/usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyt removeAndStopEs txN(R tdoReadt addReadertsendallt runReactor(RRR#((RRsD/usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyttest_addReader>s    csˆjƒ\}}}‡fd†}||_|j|ƒ|j|ƒ|jdƒ|jd|jd|jƒˆj|ƒdS(sÈ L{reactor.removeReader()} accepts an L{IReadDescriptor} provider previously passed to C{reactor.addReader()} and causes it to no longer be monitored for input events. csˆjdƒdS(NsdoRead should not be called(R((R(sD/usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyRYsR$iN(R R%R&R!R't callLaterR"R((RRRRR((RsD/usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyttest_removeReaderQs    csN|jƒ\‰‰}‡‡fd†}|ˆ_ˆjˆƒ|jˆƒdS(s³ C{reactor.addWriter()} accepts an L{IWriteDescriptor} provider and calls its C{doWrite} method when it may be possible to write to its C{fileno}. csˆjˆƒˆjƒdS(N(t removeWriterR"((RR(sD/usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyR#qs N(R tdoWritet addWriterR((RRR#((RRsD/usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyttest_addWriteris   cCså|jƒ}t|d|dƒ}t|d|ƒ}t|d|ƒ}|jƒ\}}|j||ƒƒ|j||ƒƒ||ƒ|j||ƒƒ|j||ƒƒ||ƒ|j||ƒƒ|j||ƒƒdS(s= Helper for getReaders and getWriters tests. tgettstaddtremoveN(RtgetattrRt assertNotInR(RtkindRR0R2R3RR((sD/usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyt _getFDTest{s   cCs|jdƒdS(s¡ L{IReactorFDSet.getReaders} reflects the additions and removals made with L{IReactorFDSet.addReader} and L{IReactorFDSet.removeReader}. tReaderN(R7(R((sD/usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyttest_getReaders’scstˆjƒ\}}}‡fd†}||_|j|ƒ|j|ƒ|jd|jd|jƒˆj|ƒdS(sÊ L{reactor.removeWriter()} accepts an L{IWriteDescriptor} provider previously passed to C{reactor.addWriter()} and causes it to no longer be monitored for outputability. csˆjdƒdS(NsdoWrite should not be called(R((R(sD/usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyR¢siN(R R-R.R,R*R"R((RRRRR((RsD/usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyttest_removeWriteršs   cCs|jdƒdS(s¡ L{IReactorFDSet.getWriters} reflects the additions and removals made with L{IReactorFDSet.addWriter} and L{IReactorFDSet.removeWriter}. tWriterN(R7(R((sD/usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyttest_getWriters±scs¸ˆjƒ}ˆjƒ\}}}‡fd†|_‡fd†|_|jdƒ|j|ƒ|j|ƒ|jƒ}|jd|jd|j ƒˆj |ƒˆj ||gƒdS(s¯ C{reactor.removeAll()} removes all registered L{IReadDescriptor} providers and all registered L{IWriteDescriptor} providers and returns them. cs ˆjdƒS(NsdoRead should not be called(R((R(sD/usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pytÃscs ˆjdƒS(NsdoWrite should not be called(R((R(sD/usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyR=ÄsR$iN( RR R%R-R'R&R.t removeAllR*R"R(t assertEqual(RRRRtremoved((RsD/usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyttest_removeAll¹s      (t__name__t __module__t__doc__RtrequiredInterfacesRR R)R+R/R7R9R:R<RA(((sD/usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyRs         (RDttypet __metaclass__Rttwisted.internet.interfacesRttwisted.internet.abstractRt#twisted.internet.test.reactormixinsRttwisted.internet.tcpRRRtglobalstupdatetmakeTestCaseClasses(((sD/usr/lib/python2.7/dist-packages/twisted/internet/test/test_fdset.pyts Â