ó [³XMc@sÃdZeZddlZddlmZddlmZmZddl m Z ddl m Z ddl mZddlmZe d krdd lmZndZd d d „ƒYZd gZdS(s/ Tests for implementations of L{IReactorTime}. iÿÿÿÿN(t TimeoutError(tTestCasetSkipTest(t platformType(tnamedAny(tlog(tFailuretposix(tprocesstReactorBuilderc BsŒeZdZddddddddd g ZdZdZdZiZd „Z d „Z d „Z d „Z dd„Z d„ZeeƒZRS(s¬ L{TestCase} mixin which provides a reactor-creation API. This mixin defines C{setUp} and C{tearDown}, so mix it in before L{TestCase} or call its methods from the overridden ones in the subclass. @cvar skippedReactors: A dict mapping FQPN strings of reactors for which the tests defined by this class will be skipped to strings giving the skip message. @cvar requiredInterfaces: A C{list} of interfaces which the reactor must provide or these tests will be skipped. The default, C{None}, means that no interfaces are required. @ivar reactorFactory: A no-argument callable which returns the reactor to use for testing. @ivar originalHandler: The SIGCHLD handler which was installed when setUp ran and which will be re-installed when tearDown runs. @ivar _reactors: A list of FQPN strings giving the reactors for which TestCases will be created. s,twisted.internet.selectreactor.SelectReactors(twisted.internet.pollreactor.PollReactors*twisted.internet.epollreactor.EPollReactors*twisted.internet.glib2reactor.Glib2Reactors(twisted.internet.gtk2reactor.Gtk2Reactors(twisted.internet.kqreactor.KQueueReactors/twisted.internet.win32eventreactor.Win32Reactors0twisted.internet.iocpreactor.reactor.IOCPReactors$twisted.internet.cfreactor.CFReactorcCs.tdkr*tjtjtjƒ|_ndS(s› Clear the SIGCHLD handler, if there is one, to ensure an environment like the one which exists prior to a call to L{reactor.run}. RN(RtsignaltSIGCHLDtSIG_DFLtoriginalHandler(tself((sG/usr/lib/python2.7/dist-packages/twisted/internet/test/reactormixins.pytsetUp=s cCsl|jdk r(tjtj|jƒntdk rhx1tjrdtjdtjfƒtjƒq7WndS(s| Restore the original SIGCHLD handler and reap processes as long as there seem to be any remaining. s1ReactorBuilder.tearDown reaping some processes %rN( R tNoneR R RtreapProcessHandlersRtmsgtreapAllProcesses(R((sG/usr/lib/python2.7/dist-packages/twisted/internet/test/reactormixins.pyttearDownFs  cCs•|jƒt|ddƒdk r`x+|jD] }|j|ƒ|jdƒq,W|jjƒn|jƒ|jƒ}x|D]}|j ƒq}WdS(s Clean up any resources which may have been allocated for the given reactor by its creation or by a test which used it. t_internalReadersN( t_uninstallHandlertgetattrRRt removeReadertconnectionLosttcleart disconnectAlltgetDelayedCallstcancel(Rtreactortreadertcallstc((sG/usr/lib/python2.7/dist-packages/twisted/internet/test/reactormixins.pytunbuildReactorUs     c s@y$ddlm}ddlm}Wntk r7n.Xt||ƒre|j|kretdƒ‚ny|jƒ‰Wn6tj d dƒ|j ƒtt ƒj ƒƒ‚n|X|jd k r)t‡fd†|jƒ}|r)|jˆƒtdˆdjg|D]}t|ƒ^qƒfƒ‚q)n|j|jˆƒˆS( sK Create and return a reactor using C{self.reactorFactory}. iÿÿÿÿ(t CFReactor(RsuCFReactor uses APIs which manipulate global state, so it's not safe to run its own reactor-builder tests under itselfsFailed to install reactorcs|jˆƒ S(N(t providedBy(trequired(R(sG/usr/lib/python2.7/dist-packages/twisted/internet/test/reactormixins.pyt”ss%r does not provide %st,N(ttwisted.internet.cfreactorR#ttwisted.internetRt ImportErrort isinstancetreactorFactoryRRterrRtflushLoggedErrorsRtgetErrorMessagetrequiredInterfacestfilterR"tjointreprt addCleanup(RR#t globalReactortmissingtx((RsG/usr/lib/python2.7/dist-packages/twisted/internet/test/reactormixins.pyt buildReactorus2      8csm|dkr|jƒ}ng‰‡‡fd†}ˆj||ƒˆjƒˆritd|fƒ‚ndS(sº Run the reactor for at most the given amount of time. @param reactor: The reactor to run. @type timeout: C{int} or C{float} @param timeout: The maximum amount of time, specified in seconds, to allow the reactor to run. If the reactor is still running after this much time has elapsed, it will be stopped and an exception raised. If C{None}, the default test method timeout imposed by Trial will be used. This depends on the L{IReactorTime} implementation of C{reactor} for correct operation. @raise TimeoutError: If the reactor is still running after C{timeout} seconds. csˆjdƒˆjƒdS(N(tappendRtstop((ttimedOutR(sG/usr/lib/python2.7/dist-packages/twisted/internet/test/reactormixins.pyR:³s s&reactor still running after %s secondsN(Rt getTimeoutt callLatertrunR(RRttimeoutR:((RR;sG/usr/lib/python2.7/dist-packages/twisted/internet/test/reactormixins.pyt runReactoržs  cs†i}xyˆjD]n‰ˆjdƒd}ˆjd|jddƒ}dˆtf‡‡fd†ƒY}||_|||js  »