j+UdZddlZddlZddlmZddlmZmZmZm Z m Z m Z dZ ee d< ddlZejZ n #eef$rYnwxYwddlmZmZdd lmZGd d eZGd d ZGddeZeZdZdS)uXtornado 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. N)Tuple)ETERMPOLLERRPOLLINPOLLOUTPollerZMQErrortornado_version)PeriodicCallback PollIOLoop)gen_logc0eZdZdZdfd ZdZdZxZS)DelayedCallbackzSchedules 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. Nctjdtt|d}t |||dS)NzDDelayedCallback is deprecated. Use loop.add_timeout instead.gMbP?)warningswarnDeprecationWarningmaxsuper__init__)selfcallback callback_timeio_loop __class__s f/var/www/finuniver-perm.ru/html/student/venv/lib/python3.11/site-packages/zmq/eventloop/_deprecated.pyrzDelayedCallback.__init__*sR  )    M400  =':::::cd|_d|_tj|jdz z|_|j|j|jdS)zStarts the timer.Tg@@N)_running _firstruntimer _next_timeoutr add_timeout_runrs rstartzDelayedCallback.start4sN !Y[[4+=+FF   !3TY?????rc|jsdSd|_ |dS#t$rtjddYdSwxYw)NFzError in delayed callbackT)exc_info)r!r Exceptionrerrorr's rr&zDelayedCallback._run;sm}  F  F MMOOOOO F F F M5 E E E E E E E Fs( A  A N)__name__ __module__ __qualname____doc__rr(r& __classcell__rs@rrr so;;;;;;@@@FFFFFFFrrcbeZdZdZdZedZedZdZdZ dZ dZ d Z d S) ZMQPollerzA 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. c,t|_dSr-)r_pollerr's rrzZMQPoller.__init__Lsxx rcd}|tjzr |tz}|tjzr |tz}|tjzr |t z}|S)zEtranslate IOLoop.READ/WRITE/ERROR event masks into zmq.POLLIN/OUT/ERRr)IOLoopREADrWRITErERRORr)eventsz_eventss r _map_eventszZMQPoller._map_eventsOsY FK    H FL   H FL   Hrcd}|tzr|tjz}|tzr|tjz}|t zr|tjz}|S)zEtranslate zmq.POLLIN/OUT/ERR event masks into IOLoop.READ/WRITE/ERRORr)rr9r:rr;rr<)r>r=s r _remap_eventszZMQPoller._remap_events[sY f  " fk !F g  # fl "F g  # fl "F rc^|j|||Sr-)r7registerr?rfdr=s rrCzZMQPoller.registergs(|$$R)9)9&)A)ABBBrc^|j|||Sr-)r7modifyr?rDs rrGzZMQPoller.modifyjs(|""2t'7'7'?'?@@@rc6|j|Sr-)r7 unregister)rrEs rrIzZMQPoller.unregisterms|&&r***rcZjd|z}fd|DS)zgpoll in seconds rather than milliseconds. Event masks will be IOLoop.READ/WRITE/ERROR icDg|]\}}||fSr )rA).0rEevtrs r z"ZMQPoller.poll..vs0HHH)2sT'',,-HHHr)r7poll)rtimeoutr>s` rrOzZMQPoller.pollps8 <$$TG^44HHHHxHHHHrcdSr-r r's rclosezZMQPoller.closexs rN) r.r/r0r1r staticmethodr?rArCrGrIrOrRr rrr5r5Es      \   \ CCCAAA+++III     rr5c^eZdZdZeZdfd ZedZedZ fdZ xZ S) ZMQIOLoopzfZMQ subclass of tornado's IOLoop Minor modifications, so that .current/.instance return self Nc n||n|}tjdd|i|dS)Nimplr ) _zmq_implr initialize)rrWkwargsrs rrYzZMQIOLoop.initializesC#'rs AAAAAAAAAAAAAAAA NNN*OO^$   D =<<<<<<<$$$$$$"F"F"F"F"F&"F"F"FJ4 4 4 4 4 4 4 4 n99999 999z 44444s 6AA