File: //opt/saltstack/salt/lib/python3.10/site-packages/zmq/eventloop/__pycache__/ioloop.cpython-310.pyc
o
�N�g� � @ s> U d Z ddlZddlZddlmZ z"ddlZddlmZ ddlmZ e ej
d�s2e de edd � ��W n e yH d
dl
mZ d
dlmZ Y nw ejZG d d � d e�Zd
d� Zde_eed< dejv rkd
dlmZ nej
Ze�� eur~e�� Ze�� eustG dd� de�ZeZ
dd� Zdejv r�d
dlm
Z
mZmZ dS 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.
� N)�Any)�ioloop)�gen_log�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 �dt� t|d�}t� �|||� d S )NzDDelayedCallback is deprecated.
Use loop.add_timeout instead.g����MbP?)�warnings�warn�DeprecationWarning�max�super�__init__)�self�callback�
callback_time�io_loop�� __class__� �H/opt/saltstack/salt/lib/python3.10/site-packages/zmq/eventloop/ioloop.pyr + s �
zDelayedCallback.__init__c C s6 d| _ d| _t�� | jd | _| j�| 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 sB | j sd S d| _ z| �� W d S ty tjddd� Y d S w )NFzError in delayed callbackT)�exc_info)r r � Exceptionr �errorr r r r r < s �zDelayedCallback._run�N)�__name__�
__module__� __qualname__�__doc__r r r �
__classcell__r r r r r ! s
r c C s$ t jrd 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( F s
�r( F�_IOLoopz
.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 � t� �� S r )r( r r )r �args�kwargsr r r r d s
zZMQIOLoop.__init__c O �( t j�| � t� t jj|i |��}|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- Zloopr r r r1 i s
zZMQIOLoop.instancec O r. )u& Returns the current thread’s IOLoop.)r r/ r0 r( �currentr2 r r r r4 x s zZMQIOLoop.current) r! r" r# r$ r � classmethodr1 r4 r% r r r r r+ ^ s
r+ c C s t � tj�t� dS )zRDEPRECATED
pyzmq 17 no longer needs any special integration for tornado.
N)r( r r/ r0 r+ r r r r �install� s r6 )r/ r+ r6 )r$ r r
�typingr Ztornador Z tornado.logr �hasattrr/ � ImportError�getattrZ minitornadoZminitornado.logZPeriodicCallbackr r( r) �__annotations__r! r+ r* r r6 r r r r �<module> sD �� �%
�&
�