File: //usr/lib64/python3.6/site-packages/zmq/eventloop/__pycache__/_deprecated.cpython-36.opt-1.pyc
3
VS�_� � @ s d Z ddlmZmZmZ ddlZddlZddlZddlm Z m
Z
m Z m Z m
Z
mZ yddlZejZW n eefk
r~ f ZY nX ddlmZmZ ddlmZ G dd � d e�ZG d
d � d e�ZG d d
� d
e�Z de ko�dk n r�ddd�Z e e _ e Z dd� Z dS )uX tornado 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.
� )�absolute_import�division�with_statementN)�Poller�POLLIN�POLLOUT�POLLERR�ZMQError�ETERM� )�
PollIOLoop�PeriodicCallback)�gen_logc 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/_deprecated.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 �start5 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 < s zDelayedCallback._run)N)�__name__�
__module__� __qualname__�__doc__r r r �
__classcell__r r )r r r % s r c @ sX e Zd ZdZdd� Zedd� �Zedd� �Zdd � Zd
d � Z d d
� Z
dd� Z dd� Z dS )� ZMQPollerz�A 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 C s t � | _d S )N)r �_poller)r r r r r L s zZMQPoller.__init__c C s> d}| t j@ r|tO }| t j@ r(|tO }| t j@ r:|tO }|S )zEtranslate IOLoop.READ/WRITE/ERROR event masks into zmq.POLLIN/OUT/ERRr )�IOLoop�READr �WRITEr �ERRORr )�events�z_eventsr r r � _map_eventsO s
zZMQPoller._map_eventsc C s> d}| t @ r|tjO }| t@ r(|tjO }| t@ r:|tjO }|S )zEtranslate zmq.POLLIN/OUT/ERR event masks into IOLoop.READ/WRITE/ERRORr )r r+ r, r r- r r. )r0 r/ r r r �
_remap_events[ s
zZMQPoller._remap_eventsc C s | j j|| j|��S )N)r* �registerr1 )r �fdr/ r r r r3 g s zZMQPoller.registerc C s | j j|| j|��S )N)r* �modifyr1 )r r4 r/ r r r r5 j s zZMQPoller.modifyc C s | j j|�S )N)r* �
unregister)r r4 r r r r6 m s zZMQPoller.unregisterc s" � j jd| �}� fdd�|D �S )zopoll in seconds rather than milliseconds.
Event masks will be IOLoop.READ/WRITE/ERROR
i� c s g | ]\}}|� j |�f�qS r )r2 )�.0r4 Zevt)r r r �
<listcomp>v s z"ZMQPoller.poll.<locals>.<listcomp>)r* �poll)r Ztimeoutr0 r )r r r9 p s zZMQPoller.pollc C s d S )Nr )r r r r �closex s zZMQPoller.closeN)
r$ r% r& r' r � staticmethodr1 r2 r3 r5 r6 r9 r: r r r r r) E s r) c sJ e Zd ZdZeZd � fdd� Zedd� �Zedd� �Z � fd d
�Z
� Z S ) � ZMQIOLoopzjZMQ subclass of tornado's IOLoop
Minor modifications, so that .current/.instance return self
Nc s2 |d kr| j � n|}tt| �jf d|i|�� d S )N�impl)� _zmq_implr r< �
initialize)r r= �kwargs)r r r r? � s zZMQIOLoop.initializec O sD t dkrtj| � tj||�}t|| �s@tjd| |f tdd� |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()`.
� z.IOLoop.current expected instance of %r, got %r� )�
stacklevel)rA )�tornado_versionr � configure�instance�
isinstancer r �RuntimeWarning)�cls�argsr@ �loopr r r rF � s
zZMQIOLoop.instancec O sD t dkrtj| � tj||�}t|| �s@tjd| |f tdd� |S )u/ Returns the current thread’s IOLoop.
rA z.IOLoop.current expected instance of %r, got %rrB )rC )rA )rD r rE �currentrG r r rH )rI rJ r@ rK r r r rL � s
zZMQIOLoop.currentc sH yt t| �j� W n0 tk
rB } z|jtkr0n� W Y d d }~X nX d S )N)r r< r r �errnor
)r �e)r r r r � s
zZMQIOLoop.start)N) r$ r% r& r' r) r> r? � classmethodrF rL r r( r r )r r r< | s r< rA Fc C s ddl m} |jj| �|�S )zBbackport IOLoop.close to 3.0 from 3.1 (supports fd.close() method)r )r )Z zmq.eventloop.minitornado.ioloopr r: �__get__)r Zall_fdsZ mini_loopr r r �backport_close� s rQ c C s2 ddl m} tdkr"| jjt� n tj� | j_dS )a4 set 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.
r )�iolooprA N)rA )�tornadorR rD r+ rE r< rF Z _instance)rR r r r �install� s rT )rA r )rA r )F)!r' Z
__future__r r r �osr r Zzmqr r r r r r
rS � version_inforD � ImportError�AttributeErrorZminitornado.ioloopr r
Zminitornado.logr r �objectr) r< rQ r: r+ rT r r r r �<module>
s(
79