File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/zmq/eventloop/__pycache__/_deprecated.cpython-310.pyc
Back
o ;j+ � @ s� U d Z ddlZddlZddlmZ ddlmZmZmZm Z m Z m Z dZ ee d< z ddlZejZ W n eefy; Y nw ddlmZmZ dd lmZ G d d � d e�ZG d d � d �ZG dd� de�ZeZdd� ZdS )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. � N)�Tuple)�ETERM�POLLERR�POLLIN�POLLOUT�Poller�ZMQError� �tornado_version� )�PeriodicCallback� PollIOLoop)�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 �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__r �M/opt/saltstack/salt/lib/python3.10/site-packages/zmq/eventloop/_deprecated.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 �start4 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 @ 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 r% )r �_pollerr r r r r L � 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 r0 r r1 )r3 r2 r r r � _remap_events[ s zZMQPoller._remap_eventsc C � | j �|| �|��S r% )r, �registerr4 �r �fdr2 r r r r7 g � zZMQPoller.registerc C r6 r% )r, �modifyr4 r8 r r r r; j r: zZMQPoller.modifyc C s | j �|�S r% )r, � unregister)r r9 r r r r< m r- zZMQPoller.unregisterc s" � j �d| �}� fdd�|D �S )zgpoll in seconds rather than milliseconds. Event masks will be IOLoop.READ/WRITE/ERROR i� c s g | ] \}}|� � |�f�qS r )r5 )�.0r9 Zevtr r r � <listcomp>v s z"ZMQPoller.poll.<locals>.<listcomp>)r, �poll)r �timeoutr3 r r r r? p s zZMQPoller.pollc C s d S r% r r r r r �closex s zZMQPoller.closeN) r& r' r( r) r � staticmethodr4 r5 r7 r; r< r? rA r r r r r+ E s r+ c sJ e Zd ZdZeZd � fdd� Zedd� �Zedd� �Z � fd d �Z � Z S ) � ZMQIOLoopzfZMQ subclass of tornado's IOLoop Minor modifications, so that .current/.instance return self Nc s. |d u r| � � n|}t� jdd|i|�� d S )N�implr )� _zmq_implr � initialize)r rD �kwargsr r r rF � s zZMQIOLoop.initializec O �L t dkr t�| � tj|i |��}t|| �s$tjd| �d|��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()`. �� �$IOLoop.current expected instance of �, got � �� stacklevel)r r � configure�instance� isinstancer r �RuntimeWarning��cls�argsrG Zloopr r r rQ � s �zZMQIOLoop.instancec O rH )u& Returns the current thread’s IOLoop.rI rK rL rM rN )r r rP �currentrR r r rS rT r r r rW � s �zZMQIOLoop.currentc sF zt � �� W d S ty" } z|jtkrn� W Y d }~d S d }~ww r% )r r! r �errnor )r �er r r r! � s ���zZMQIOLoop.startr% ) r& r' r( r) r+ rE rF � classmethodrQ rW r! r* r r r r rC | s rC c C sX ddl m} | j�� r| j�� t�� u sJ d��tdkr$| j�t� dS t�� | j_dS )a, 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 ��ioloopz"tornado IOLoop already initializedrI N) �tornador\ r. Z initializedrQ r rP rC Z _instancer[ r r r �install� s ��r^ ) r) r r �typingr Zzmqr r r r r r r �__annotations__r] � version_info� ImportError�AttributeErrorZminitornado.ioloopr r Zminitornado.logr r r+ rC r. r^ r r r r �<module> s& � %7=
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings