Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/zmq/eventloop/__pycache__/_deprecated.cpython-39.pyc
Ðазад
a a�h� � @ s d Z ddlmZmZmZ ddlZddlZddlZddlm Z m Z m Z m Z m Z mZ zddlZejZW n eefy| dZY n0 ddlmZmZ ddlmZ G d d � d e�ZG d d � d e�ZG d d� de�Z de kr�dk r�n nddd�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 �dt� t|d�}tt| ��|||� 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__r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/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 �start5 s zDelayedCallback.startc C sB | j s d S d| _ z | �� W n ty< tjddd� Y n0 d S )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 �N)r �_pollerr! 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 r0 r r1 )r3 r2 r r r � _remap_events[ s zZMQPoller._remap_eventsc C s | j �|| �|��S r, )r- �registerr4 �r �fdr2 r r r r6 g s zZMQPoller.registerc C s | j �|| �|��S r, )r- �modifyr4 r7 r r r r9 j s zZMQPoller.modifyc C s | j �|�S r, )r- � unregister)r r8 r r r r: m s zZMQPoller.unregisterc s" � j �d| �}� fdd�|D �S )zopoll in seconds rather than milliseconds. Event masks will be IOLoop.READ/WRITE/ERROR i� c s g | ]\}}|� � |�f�qS r )r5 )�.0r8 Zevtr! r r � <listcomp>v � 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 r6 r9 r: r> 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 u r| � � n|}tt| �jf d|i|�� d S )N�impl)� _zmq_implr rB � initialize)r rC �kwargsr r r rE � s zZMQIOLoop.initializec O sH t dkrt�| � tj|i |��}t|| �sDtjd| |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()`. �� �.IOLoop.current expected instance of %r, got %r� �� stacklevel)�tornado_versionr � configure�instance� isinstancer r �RuntimeWarning��cls�argsrF �loopr r r rO � s �zZMQIOLoop.instancec O sH t dkrt�| � tj|i |��}t|| �sDtjd| |f tdd� |S )u/ Returns the current thread’s IOLoop. rG rI rJ rK )rM r rN �currentrP r r rQ rR r r r rV � s �zZMQIOLoop.currentc sJ zt t| ��� W n2 tyD } z|jtkr.n� W Y d }~n d }~0 0 d S r, )r rB r" r �errnor )r �er r r r" � s zZMQIOLoop.start)N) r& r' r( r) r+ rD rE � classmethodrO rV r" r* r r r r rB | s rB )rH r )rH r Fc C s ddl m} |j�| �|�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 r[ c C sV ddl m} | j�� r0| j�� t�� u s0J d��tdkrF| j�t� n t�� | 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 ��ioloopz"tornado IOLoop already initializedrG N) �tornador] r. Z initializedrO rM rN rB Z _instancer\ r r r �install� s ��r_ )F)!r) � __future__r r r �osr r Zzmqr r r r r r r^ � version_inforM � ImportError�AttributeErrorZminitornado.ioloopr r Zminitornado.logr r �objectr+ rB r[ r@ r. r_ r r r r �<module> s( 79
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка