File: //usr/lib64/python3.6/site-packages/zmq/eventloop/__pycache__/ioloop.cpython-36.opt-1.pyc
3
VS�_' � @ s6 d Z ddlmZmZmZ ddlZddlZyDddlZddlm Z ddlm
Z
e e
j d�sje
deedd � ��W n, e
k
r� d
dlm
Z
d
dlm Z Y nX e
jZG d d � d e�Zd
d� Zde_de
jkr�d
dlmZ n e
j Zxej� ek r�ej� Zq�W G dd� de�ZeZ dd� Zde
jk�r2d
dlmZmZm Z dS )z�tornado IOLoop API with zmq compatibility
This module is deprecated in pyzmq 17.
To use zmq with tornado,
eventloop integration is no longer required
and tornado itself should be used.
� )�absolute_import�division�with_statementN)�gen_log)�ioloop�configurable_defaultzTornado too old: %s�version�unknown� c s2 e Zd ZdZd � fdd� Zdd� Zdd� Z� ZS )
�DelayedCallbackz�Schedules 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.
Nc s. t jdt� t|d�}tt| �j|||� d S )NzDDelayedCallback is deprecated.
Use loop.add_timeout instead.g����MbP?)�warnings�warn�DeprecationWarning�max�superr �__init__)�self�callback�
callback_time�io_loop)� __class__� � /usr/lib64/python3.6/ioloop.pyr ( s
zDelayedCallback.__init__c C s6 d| _ d| _tj� | jd | _| jj| j| j� dS )zStarts the timer.Tg @�@N)�_runningZ _firstrun�timer Z
_next_timeoutr Z add_timeout�_run)r r r r �start/ s zDelayedCallback.startc C sD | j s
d S d| _ y | j� W n" tk
r> tjddd� Y nX d S )NFzError in delayed callbackT)�exc_info)r r � Exceptionr �error)r r r r r 6 s zDelayedCallback._run)N)�__name__�
__module__� __qualname__�__doc__r r r �
__classcell__r r )r r r s r c C s$ t jr
d S dt _tjdtdd� d S )NTzlzmq.eventloop.ioloop is deprecated in pyzmq 17. pyzmq now works with default tornado and asyncio eventloops.� )�
stacklevel)� _deprecated�calledr r
r r r r r r' ? s
r' Fz
.minitornado.)� ZMQIOLoopc s8 e Zd ZdZ� fdd�Zedd� �Zedd� �Z� ZS )r) z�DEPRECATED: No longer needed as of pyzmq-17
PyZMQ tornado integration now works with the default :mod:`tornado.ioloop.IOLoop`.
c s t � tt| �j� S )N)r' r r) r )r �args�kwargs)r r r r X s zZMQIOLoop.__init__c O s$ t jj| � t� t jj||�}|S )a 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()`.
)r �IOLoop� configurer' �instance)�clsr* r+ �loopr r r r. ] s
zZMQIOLoop.instancec O s$ t jj| � t� t jj||�}|S )u/ Returns the current thread’s IOLoop.
)r r, r- r' �current)r/ r* r+ r0 r r r r1 l s zZMQIOLoop.current) r r! r" r# r � classmethodr. r1 r$ r r )r r r) R s r) c C s t � tjjt� dS )zRDEPRECATED
pyzmq 17 no longer needs any special integration for tornado.
N)r' r r, r- r) r r r r �install| s r3 )r) r3 r, )r# Z
__future__r r r r r ZtornadoZ tornado.logr r �hasattrr, � ImportError�getattrZ minitornadoZminitornado.logZPeriodicCallbackr r' r( r r) Z_IOLoopr r3 r r r r �<module> s4
'