L]c@s\dZddlmZmZmZddlZddlZddlZddlm Z m Z m Z m Z m Z mZyddlZejZWneefk rdZnXddlmZmZddlmZdefd YZd efd YZd efd YZdeko,dknrIedZee_neZ dZ!dS(sXtornado IOLoop API with zmq compatibility If you have tornado ≥ 3.0, this is a subclass of tornado's IOLoop, otherwise we ship a minimal subset of tornado in zmq.eventloop.minitornado. The minimal shipped version of tornado's IOLoop does not include support for concurrent futures - this will only be available if you have tornado ≥ 3.0. i(tabsolute_importtdivisiontwith_statementN(tPollertPOLLINtPOLLOUTtPOLLERRtZMQErrortETERMi(t PollIOLooptPeriodicCallback(tgen_logtDelayedCallbackcBs,eZdZddZdZdZRS(sSchedules the given callback to be called once. The callback is called once, after callback_time milliseconds. `start` must be called after the DelayedCallback is created. The timeout is calculated from when `start` is called. cCs?tjdtt|d}tt|j|||dS(NsDDelayedCallback is deprecated. Use loop.add_timeout instead.gMbP?(twarningstwarntDeprecationWarningtmaxtsuperR t__init__(tselftcallbackt callback_timetio_loop((s8lib/python2.7/site-packages/zmq/eventloop/_deprecated.pyR.s cCsIt|_t|_tj|jd|_|jj|j|jdS(sStarts the timer.g@@N( tTruet_runningt _firstrunttimeRt _next_timeoutRt add_timeoutt_run(R((s8lib/python2.7/site-packages/zmq/eventloop/_deprecated.pytstart5s  cCsO|js dSt|_y|jWn$tk rJtjddtnXdS(NsError in delayed callbacktexc_info(RtFalseRt ExceptionR terrorR(R((s8lib/python2.7/site-packages/zmq/eventloop/_deprecated.pyR<s   N(t__name__t __module__t__doc__tNoneRRR(((s8lib/python2.7/site-packages/zmq/eventloop/_deprecated.pyR %s  t ZMQPollercBsbeZdZdZedZedZdZdZdZ dZ dZ RS( sA poller that can be used in the tornado IOLoop. This simply wraps a regular zmq.Poller, scaling the timeout by 1000, so that it is in seconds rather than milliseconds. cCst|_dS(N(Rt_poller(R((s8lib/python2.7/site-packages/zmq/eventloop/_deprecated.pyRLscCsXd}|tj@r |tO}n|tj@r:|tO}n|tj@rT|tO}n|S(sEtranslate IOLoop.READ/WRITE/ERROR event masks into zmq.POLLIN/OUT/ERRi(tIOLooptREADRtWRITERtERRORR(teventstz_events((s8lib/python2.7/site-packages/zmq/eventloop/_deprecated.pyt _map_eventsOs      cCsXd}|t@r |tjO}n|t@r:|tjO}n|t@rT|tjO}n|S(sEtranslate zmq.POLLIN/OUT/ERR event masks into IOLoop.READ/WRITE/ERRORi(RR)R*RR+RR,(R.R-((s8lib/python2.7/site-packages/zmq/eventloop/_deprecated.pyt _remap_events[s   cCs|jj||j|S(N(R(tregisterR/(RtfdR-((s8lib/python2.7/site-packages/zmq/eventloop/_deprecated.pyR1gscCs|jj||j|S(N(R(tmodifyR/(RR2R-((s8lib/python2.7/site-packages/zmq/eventloop/_deprecated.pyR3jscCs|jj|S(N(R(t unregister(RR2((s8lib/python2.7/site-packages/zmq/eventloop/_deprecated.pyR4mscCsB|jjd|}g|D]!\}}||j|f^qS(sopoll in seconds rather than milliseconds. Event masks will be IOLoop.READ/WRITE/ERROR i(R(tpollR0(RttimeoutR.R2tevt((s8lib/python2.7/site-packages/zmq/eventloop/_deprecated.pyR5pscCsdS(N((R((s8lib/python2.7/site-packages/zmq/eventloop/_deprecated.pytclosexs( R#R$R%Rt staticmethodR/R0R1R3R4R5R8(((s8lib/python2.7/site-packages/zmq/eventloop/_deprecated.pyR'Es      t ZMQIOLoopcBsGeZdZeZddZedZedZ dZ RS(sjZMQ subclass of tornado's IOLoop Minor modifications, so that .current/.instance return self cKs>|dkr|jn|}tt|jd||dS(Ntimpl(R&t _zmq_implRR:t initialize(RR;tkwargs((s8lib/python2.7/site-packages/zmq/eventloop/_deprecated.pyR=scOsdtdkrtj|ntj||}t||s`tjd||ftddn|S(s Returns a global `IOLoop` instance. Most applications have a single, global `IOLoop` running on the main thread. Use this method to get this instance from another thread. To get the current thread's `IOLoop`, use `current()`. is.IOLoop.current expected instance of %r, got %rt stackleveli(i(ttornado_versionR t configuretinstancet isinstanceR RtRuntimeWarning(tclstargsR>tloop((s8lib/python2.7/site-packages/zmq/eventloop/_deprecated.pyRBs cOsdtdkrtj|ntj||}t||s`tjd||ftddn|S(s/Returns the current thread’s IOLoop. is.IOLoop.current expected instance of %r, got %rR?i(i(R@R RAtcurrentRCR RRD(RERFR>RG((s8lib/python2.7/site-packages/zmq/eventloop/_deprecated.pyRHs cCsFytt|jWn(tk rA}|jtkr;qBnXdS(N(RR:RRterrnoR(Rte((s8lib/python2.7/site-packages/zmq/eventloop/_deprecated.pyRs N( R#R$R%R'R<R&R=t classmethodRBRHR(((s8lib/python2.7/site-packages/zmq/eventloop/_deprecated.pyR:|s  icCs&ddlm}|jj||S(sBbackport IOLoop.close to 3.0 from 3.1 (supports fd.close() method)i(R (t zmq.eventloop.minitornado.ioloopR R8t__get__(Rtall_fdst mini_loop((s8lib/python2.7/site-packages/zmq/eventloop/_deprecated.pytbackport_closescCs|ddlm}|jj sG|jjtjksGtdtdkrf|jjtntj|j_ dS(s4set the tornado IOLoop instance with the pyzmq IOLoop. After calling this function, tornado's IOLoop.instance() and pyzmq's IOLoop.instance() will return the same object. An assertion error will be raised if tornado's IOLoop has been initialized prior to calling this function. i(tioloops"tornado IOLoop already initializediN(i( ttornadoRQR)t initializedRBtAssertionErrorR@RAR:t _instance(RQ((s8lib/python2.7/site-packages/zmq/eventloop/_deprecated.pytinstalls ' ((ii(ii("R%t __future__RRRtosRR tzmqRRRRRRRRt version_infoR@t ImportErrortAttributeErrortminitornado.ioloopR R tminitornado.logR R tobjectR'R:R RPR8R)RV(((s8lib/python2.7/site-packages/zmq/eventloop/_deprecated.pyt s(   .    79