[c@`sdZddlmZmZmZddlZddlZddlZddlZddl Z ddl Z ddl m Z ddlmZddlmZmZmZmZmZddlmZmZddlmZddlZ ddlZ ddlZ ddlZ dd lm Z dd l!m"Z"m#Z#dd l$m%Z%dd l&m'Z'ddl(Z&dd l)m*Z*ddl+m,Z,ddl-m.Z.m/Z/ddl(m0Z0ddl1m2Z2e ede3fdYZ4e eedefdYZ5de5fdYZ6dZ7e eede3fdYZ8de&j9j0fdYZ:de,fdYZ;e<e'j=dre'j=j>e d Z?ndS(!sBBridges between the Twisted reactor and Tornado IOLoop. This module lets you run applications and libraries written for Twisted in a Tornado application. It can be used in two modes, depending on which library's underlying event loop you want to use. This module has been tested with Twisted versions 11.0.0 and newer. i(tabsolute_importtdivisiontprint_functionN(tDeferred(tPosixReactorBase(t IReactorFDSett IDelayedCallt IReactorTimetIReadDescriptortIWriteDescriptor(tfailuretlog(terror(t implementer(tFuturetfuture_set_exc_info(tutf8(tgen(tapp_log(tResolver(t NullContexttwrap(tIOLoop(ttimedelta_to_secondstTornadoDelayedCallcB`sMeZdZdZdZdZdZdZdZdZ RS(sDelayedCall object for Tornado.cO`se||_tj||||_|jj||_|jjj|j|j|_ t |_ dS(N( t_reactort functoolstpartialt_functsecondst_timet_io_loopt add_timeoutt_calledt_timeouttTruet_active(tselftreactorRtftargstkw((s7lib/python2.7/site-packages/tornado/platform/twisted.pyt__init__;s  cC`sHt|_|jj|y|jWntjddtnXdS(Ns_called caught exceptiontexc_info(tFalseR$Rt_removeDelayedCallRRR R#(R%((s7lib/python2.7/site-packages/tornado/platform/twisted.pyR!Cs  cC`s|jS(N(R(R%((s7lib/python2.7/site-packages/tornado/platform/twisted.pytgetTimeKscC`s3t|_|jjj|j|jj|dS(N(R,R$RRtremove_timeoutR"R-(R%((s7lib/python2.7/site-packages/tornado/platform/twisted.pytcancelNs cC`sJ|jjj|j|j|7_|jjj|j|j|_dS(N(RRR/R"RR R!(R%R((s7lib/python2.7/site-packages/tornado/platform/twisted.pytdelaySscC`sQ|jjj|j|jj||_|jjj|j|j|_dS(N(RRR/R"RRR R!(R%R((s7lib/python2.7/site-packages/tornado/platform/twisted.pytresetYscC`s|jS(N(R$(R%((s7lib/python2.7/site-packages/tornado/platform/twisted.pytactive_s( t__name__t __module__t__doc__R*R!R.R0R1R2R3(((s7lib/python2.7/site-packages/tornado/platform/twisted.pyR8s      tTornadoReactorcB`seZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZdZRS(s{Twisted reactor built on the Tornado IOLoop. `TornadoReactor` implements the Twisted reactor interface on top of the Tornado IOLoop. To use it, simply call `install` at the beginning of the application:: import tornado.platform.twisted tornado.platform.twisted.install() from twisted.internet import reactor When the app is ready to start, call ``IOLoop.current().start()`` instead of ``reactor.run()``. It is also possible to create a non-global reactor by calling ``tornado.platform.twisted.TornadoReactor()``. However, if the `.IOLoop` and reactor are to be short-lived (such as those used in unit tests), additional cleanup may be required. Specifically, it is recommended to call:: reactor.fireSystemEvent('shutdown') reactor.disconnectAll() before closing the `.IOLoop`. .. versionchanged:: 5.0 The ``io_loop`` argument (deprecated since version 4.1) has been removed. .. deprecated:: 5.1 This class will be removed in Tornado 6.0. Use ``twisted.internet.asyncioreactor.AsyncioSelectorReactor`` instead. c`stjjj_i_i_i_i_t j j ddj fd}jj |dS(Ntduringtshutdownc`sjsjdndS(Ntstartup(t_startedtfireSystemEvent((R%(s7lib/python2.7/site-packages/tornado/platform/twisted.pytstart_if_necessarys (ttornadotioloopRtcurrentRt_readerst_writerst_fdst _delayedCallsRR*taddSystemEventTriggertcrasht add_callback(R%R=((R%s7lib/python2.7/site-packages/tornado/platform/twisted.pyR*s     cC`s |jjS(N(Rttime(R%((s7lib/python2.7/site-packages/tornado/platform/twisted.pyRscO`s)t|||||}t|j|<|S(N(RR#RD(R%RR'R(R)tdc((s7lib/python2.7/site-packages/tornado/platform/twisted.pyt callLaters cC`s#g|jD]}|jr |^q S(N(RDR$(R%tx((s7lib/python2.7/site-packages/tornado/platform/twisted.pytgetDelayedCallsscC`s ||jkr|j|=ndS(N(RD(R%RI((s7lib/python2.7/site-packages/tornado/platform/twisted.pyR-scO`sFt|std|t|jj|||WdQXdS(Ns%s is not callable(tcallabletAssertionErrorRRRG(R%R'R(R)((s7lib/python2.7/site-packages/tornado/platform/twisted.pytcallFromThreads cC`sdS(N((R%((s7lib/python2.7/site-packages/tornado/platform/twisted.pyt installWakerscC`sdS(N((R%((s7lib/python2.7/site-packages/tornado/platform/twisted.pytwakeUpscC`s||jkrdS|j|\}}|rd}|jdkrStj}n%|tj@rxtj||j }n|dkr|tj @rtj}n|dk r|j ||j t j|qn|rd}|jdkrtj}n%|tj@r'tj||j}n|dkrO|tj @rOtj}n|dk r|j||jt j|qndS(Ni(RCtNonetfilenoR tConnectionLostRtREADR tcallWithLoggertdoReadtERRORt removeReadertreadConnectionLostR tFailuretWRITEtdoWritet removeWritertwriteConnectionLost(R%tfdteventstreadertwriterterr((s7lib/python2.7/site-packages/tornado/platform/twisted.pyt_invoke_callbacks2      cC`s||jkrdS|j}||j|<||jkr|j|\}}||f|j|<|r|jj|tjtjBqn?t4|df|j|<|jj ||j tjWdQXdS(N( RARSRCRtupdate_handlerRRUR\RRRt add_handlerRe(R%RbR`t_Rc((s7lib/python2.7/site-packages/tornado/platform/twisted.pyt addReaders  # cC`s||jkrdS|j}||j|<||jkr|j|\}}||f|j|<|r|jj|tjtjBqn?t4d|f|j|<|jj ||j tjWdQXdS(N( RBRSRCRRfRRUR\RRRRgRe(R%RcR`RbRh((s7lib/python2.7/site-packages/tornado/platform/twisted.pyt addWriters  # cC`s||jkr|jj|}|j|\}}|rfd|f|j|<|jj|tjq|j|=|jj|ndS(N( RAtpopRCRRRRfRR\tremove_handler(R%RbR`RhRc((s7lib/python2.7/site-packages/tornado/platform/twisted.pyRYs cC`s||jkr|jj|}|j|\}}|rf|df|j|<|jj|tjq|j|=|jj|ndS(N( RBRkRCRRRRfRRURl(R%RcR`RbRh((s7lib/python2.7/site-packages/tornado/platform/twisted.pyR^ s cC`s|j|j|jS(N(t _removeAllRARB(R%((s7lib/python2.7/site-packages/tornado/platform/twisted.pyt removeAllscC`s |jjS(N(RAtkeys(R%((s7lib/python2.7/site-packages/tornado/platform/twisted.pyt getReadersscC`s |jjS(N(RBRo(R%((s7lib/python2.7/site-packages/tornado/platform/twisted.pyt getWriters!scC`s6tj|tj|jd}|jj|dS(NR9(RtstopRRR<RRG(R%t fire_shutdown((s7lib/python2.7/site-packages/tornado/platform/twisted.pyRr's cC`stj||jjdS(N(RRFRRr(R%((s7lib/python2.7/site-packages/tornado/platform/twisted.pyRF,s cC`stddS(Nt doIteration(tNotImplementedError(R%R1((s7lib/python2.7/site-packages/tornado/platform/twisted.pyRt0scC`s|jjdS(N(Rtstart(R%((s7lib/python2.7/site-packages/tornado/platform/twisted.pytmainLoop3s (R4R5R6R*RRJRLR-RORPRQReRiRjRYR^RnRpRqRrRFRtRw(((s7lib/python2.7/site-packages/tornado/platform/twisted.pyR7cs*#                  t _TestReactorcB`s5eZdZdZdddZdddZRS(sSubclass of TornadoReactor for use in unittests. This can't go in the test.py file because of import-order dependencies with the Twisted reactor test builder. cC`s8tjtdttt|jtjdS(Nt make_current(Rt clear_currentR#tsuperRxR*(R%((s7lib/python2.7/site-packages/tornado/platform/twisted.pyR*Es  i2tcC`s4|sd}ntt|j||d|d|S(Ns 127.0.0.1tbacklogt interface(R{Rxt listenTCP(R%tporttfactoryR}R~((s7lib/python2.7/site-packages/tornado/platform/twisted.pyRLs i cC`s4|sd}ntt|j||d|d|S(Ns 127.0.0.1R~t maxPacketSize(R{Rxt listenUDP(R%RtprotocolR~R((s7lib/python2.7/site-packages/tornado/platform/twisted.pyRSs (R4R5R6R*RR(((s7lib/python2.7/site-packages/tornado/platform/twisted.pyRx?s cC`s't}ddlm}|||S(sInstall this package as the default Twisted reactor. ``install()`` must be called very early in the startup process, before most other twisted-related imports. Conversely, because it initializes the `.IOLoop`, it cannot be called before `.fork_processes` or multi-process `~.TCPServer.start`. These conflicting requirements make it difficult to use `.TornadoReactor` in multi-process mode, and an external process manager such as ``supervisord`` is recommended instead. .. versionchanged:: 5.0 The ``io_loop`` argument (deprecated since version 4.1) has been removed. .. deprecated:: 5.1 This functio will be removed in Tornado 6.0. Use ``twisted.internet.asyncioreactor.install`` instead. i(tinstallReactor(R7ttwisted.internet.mainR(R&R((s7lib/python2.7/site-packages/tornado/platform/twisted.pytinstallZs  t_FDcB`sHeZdZdZdZdZdZeZZdZ RS(cC`s:||_||_||_t|_t|_t|_dS(N(R`tfileobjthandlerR,treadingtwritingtlost(R%R`RR((s7lib/python2.7/site-packages/tornado/platform/twisted.pyR*us      cC`s|jS(N(R`(R%((s7lib/python2.7/site-packages/tornado/platform/twisted.pyRS}scC`s,|js(|j|jtjjjndS(N(RRRR>R?RRU(R%((s7lib/python2.7/site-packages/tornado/platform/twisted.pyRWs cC`s,|js(|j|jtjjjndS(N(RRRR>R?RR\(R%((s7lib/python2.7/site-packages/tornado/platform/twisted.pyR]s cC`s5|js1|j|jtjjjt|_ndS(N(RRRR>R?RRXR#(R%treason((s7lib/python2.7/site-packages/tornado/platform/twisted.pytconnectionLosts cC`sdS(NR|((R%((s7lib/python2.7/site-packages/tornado/platform/twisted.pyt logPrefixs( R4R5R*RSRWR]RR_RZR(((s7lib/python2.7/site-packages/tornado/platform/twisted.pyRss      t TwistedIOLoopcB`sweZdZd dZedZdZdZdZ dZ dZ dZ d Z d Zd ZRS( sIOLoop implementation that runs on Twisted. `TwistedIOLoop` implements the Tornado IOLoop interface on top of the Twisted reactor. Recommended usage:: from tornado.platform.twisted import TwistedIOLoop from twisted.internet import reactor TwistedIOLoop().install() # Set up your tornado application as usual using `IOLoop.instance` reactor.run() Uses the global Twisted reactor by default. To create multiple ``TwistedIOLoops`` in the same process, you must pass a unique reactor when constructing each one. Not compatible with `tornado.process.Subprocess.set_exit_callback` because the ``SIGCHLD`` handlers used by Tornado and Twisted conflict with each other. See also :meth:`tornado.ioloop.IOLoop.install` for general notes on installing alternative IOLoops. .. deprecated:: 5.1 The `asyncio` event loop will be the only available implementation in Tornado 6.0. cK`sStt|j||dkr=ddl}|jj}n||_i|_dS(Ni(R{Rt initializeRRttwisted.internet.reactortinternetR&tfds(R%R&tkwargsttwisted((s7lib/python2.7/site-packages/tornado/platform/twisted.pyRs    cC`sn|j}|jjx!|jjD]}|jq&W|rjx'|jD]}|j|jqMWndS(N(RR&RnRLR0tvaluestclose_fdR(R%tall_fdsRtcR`((s7lib/python2.7/site-packages/tornado/platform/twisted.pytcloses  cC`s||jkr"td|n|j|\}}t||t||j|<|tjjj@rt |j|_ |j j |j|n|tjjj @rt |j|_|j j|j|ndS(Nsfd %s added twice(Rt ValueErrortsplit_fdRRR>R?RRUR#RR&RiR\RRj(R%R`RRaR((s7lib/python2.7/site-packages/tornado/platform/twisted.pyRgscC`s-|j|\}}|tjjj@re|j|jst|j|_|jj |j|qn:|j|jrt |j|_|jj |j|n|tjjj @r|j|j s)t|j|_ |jj|j|q)n:|j|j r)t |j|_ |jj|j|ndS(N(RR>R?RRURRR#R&RiR,RYR\RRjR^(R%R`RaR((s7lib/python2.7/site-packages/tornado/platform/twisted.pyRfscC`s|j|\}}||jkr(dSt|j|_|j|jrb|jj|j|n|j|jr|jj|j|n|j|=dS(N( RRR#RRR&RYRR^(R%R`R((s7lib/python2.7/site-packages/tornado/platform/twisted.pyRlscC`sbtjdt}z%|j|j|jjWd|dkrStjn |jXdS(Ntinstance( RR@R,t_setup_loggingRyR&trunRRRz(R%t old_current((s7lib/python2.7/site-packages/tornado/platform/twisted.pyRvs    cC`s|jjdS(N(R&RF(R%((s7lib/python2.7/site-packages/tornado/platform/twisted.pyRrscO`st|tjr.t||jd}n-t|tjrOt|}n td|j j ||j t j t|||S(NisUnsupported deadline %r(t isinstancetnumberstRealtmaxRHtdatetimet timedeltaRt TypeErrorR&RJt _run_callbackRRR(R%tdeadlinetcallbackR(RR1((s7lib/python2.7/site-packages/tornado/platform/twisted.pyR s   cC`s|jr|jndS(N(R3R0(R%ttimeout((s7lib/python2.7/site-packages/tornado/platform/twisted.pyR/s cO`s/|jj|jtjt|||dS(N(R&RORRRR(R%RR(R((s7lib/python2.7/site-packages/tornado/platform/twisted.pyRG s cO`s|j|||dS(N(RG(R%RR(R((s7lib/python2.7/site-packages/tornado/platform/twisted.pytadd_callback_from_signalsN(R4R5R6RRRR,RRgRfRlRvRrR R/RGR(((s7lib/python2.7/site-packages/tornado/platform/twisted.pyRs      tTwistedResolvercB`s,eZdZdZejddZRS(sTwisted-based asynchronous resolver. This is a non-blocking and non-threaded resolver. It is recommended only when threads cannot be used, since it has limitations compared to the standard ``getaddrinfo``-based `~tornado.netutil.Resolver` and `~tornado.netutil.DefaultExecutorResolver`. Specifically, it returns at most one result, and arguments other than ``host`` and ``family`` are ignored. It may fail to resolve when ``family`` is not ``socket.AF_UNSPEC``. Requires Twisted 12.1 or newer. .. versionchanged:: 5.0 The ``io_loop`` argument (deprecated since version 4.1) has been removed. cC`stjjj|_tjjjd}tjjj d|j}tjj jdd|j}tjj j |||g|_ dS(Ns /etc/hostsR&s/etc/resolv.conf(R>tplatformRR7R&tnamesthostsRtcachet CacheResolvertclienttresolvet ResolverChaintresolver(R%t host_resolvertcache_resolvert real_resolver((s7lib/python2.7/site-packages/tornado/platform/twisted.pyR%s  ic c`s{tjjj|r'|}tj}ntjjj|rN|}tj}n|jj t |}t }|j |j |V}t|tjry|jWqtjjjk r}t|qXnKtjjj|rtj}n*tjjj|rtj}n tj}|tjkrS||krStd||fn|||ffg} tj| dS(Ns%Requested socket family %d but got %d(RRtabstractt isIPAddresstsockettAF_INETt isIPv6AddresstAF_INET6Rt getHostByNameRRtaddBotht set_resultRR R[traiseExceptionRR t DomainErrortIOErrort AF_UNSPECt ExceptionRtReturn( R%thostRtfamilytresolvedtresolved_familytdeferredtfuttetresult((s7lib/python2.7/site-packages/tornado/platform/twisted.pyR1s2      (R4R5R6RRt coroutineR(((s7lib/python2.7/site-packages/tornado/platform/twisted.pyRs tregisterc`s/tfd}|jj|S(Nc`s;y|jtdWnttjnXdS(Nserrback called without error(RRRtsysR+(R (R'(s7lib/python2.7/site-packages/tornado/platform/twisted.pyterrbackYs  (Rt addCallbacksR(tdR((R's7lib/python2.7/site-packages/tornado/platform/twisted.pyRhUs (@R6t __future__RRRRRRRRttwisted.internet.abstractRttwisted.internet.deferRttwisted.internet.posixbaseRttwisted.internet.interfacesRRRRR ttwisted.pythonR R ttwisted.internetR ttwisted.names.cachettwisted.names.clientttwisted.names.hoststtwisted.names.resolvetzope.interfaceR ttornado.concurrentRRttornado.escapeRR>Rttornado.ioloopt tornado.logRttornado.netutilRttornado.stack_contextRRRt tornado.utilRtobjectRR7RxRRR?RRthasattrtconvert_yieldedRRh(((s7lib/python2.7/site-packages/tornado/platform/twisted.pytsL      (      * @