File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/ext/tornado/platform/__pycache__/asyncio.cpython-310.pyc
Back
o ;jX � @ s� d Z ddlmZmZmZ ddlZddlZddlm Z ddl m Z ddl m Z zddlZW n" eyN Z zzddlZW n eyC e�w W Y dZ[ndZ[ww G dd� de �ZG d d � d e�ZG d d � d e�Zd d� Zdd� Zee d�r}e �eje� dS dS )a Bridges between the `asyncio` module and Tornado IOLoop. .. versionadded:: 3.2 This module integrates Tornado with the ``asyncio`` module introduced in Python 3.4 (and available `as a separate download <https://pypi.python.org/pypi/asyncio>`_ for Python 3.3). This makes it possible to combine the two libraries on the same event loop. Most applications should use `AsyncIOMainLoop` to run Tornado on the default ``asyncio`` event loop. Applications that need to run event loops on multiple threads may use `AsyncIOLoop` to create multiple loops. .. note:: Tornado requires the `~asyncio.AbstractEventLoop.add_reader` family of methods, so it is not compatible with the `~asyncio.ProactorEventLoop` on Windows. Use the `~asyncio.SelectorEventLoop` instead. � )�absolute_import�division�print_functionN)�convert_yielded)�IOLoop)� stack_contextc st e Zd Zd� fdd� Zddd�Zdd� Zdd � Zd d � Zd d � Zdd� Z dd� Z dd� Z dd� Z dd� Z e Z� ZS )�BaseAsyncIOLoopFc sB t t| �jdi |�� || _|| _i | _t� | _t� | _d| _ d S )NF� ) �superr � initialize� asyncio_loop� close_loop�handlers�set�readers�writers�closing)�selfr r �kwargs�� __class__r �U/opt/saltstack/salt/lib/python3.10/site-packages/salt/ext/tornado/platform/asyncio.pyr - s zBaseAsyncIOLoop.initializec C sT d| _ t| j�D ]}| j| \}}| �|� |r | �|� q| jr(| j�� d S d S )NT)r �listr �remove_handlerZclose_fdr r �close)r Zall_fds�fd�fileobj� handler_funcr r r r 8 s ��zBaseAsyncIOLoop.closec C s� | � |�\}}|| jv rtd| ��|t�|�f| j|< |tj@ r2| j�|| j |tj� | j � |� |tj @ rJ| j� || j |tj � | j� |� d S d S )Nzfd %s added twice)�split_fdr � ValueErrorr �wrapr �READr � add_reader�_handle_eventsr �add�WRITE� add_writerr )r r �handler�eventsr r r r � add_handlerB s � ��zBaseAsyncIOLoop.add_handlerc C s� | � |�\}}|tj@ r#|| jvr"| j�|| j|tj� | j�|� n|| jv r4| j�|� | j� |� |tj @ rS|| j vrQ| j� || j|tj � | j �|� d S d S || j v rf| j� |� | j � |� d S d S �N)r r r! r r r" r# r$ � remove_reader�remover% r r& � remove_writer)r r r( r r r r �update_handlerP s, � � �� �z BaseAsyncIOLoop.update_handlerc C sl | � |�\}}|| jvrd S || jv r | j�|� | j�|� || jv r0| j�|� | j�|� | j|= d S r* )r r r r r+ r, r r- )r r r r r r r e s z BaseAsyncIOLoop.remove_handlerc C s | j | \}}|||� d S r* )r )r r r( r r r r r r# q s z BaseAsyncIOLoop._handle_eventsc C sf t jdd�}z | �� | �� | j�� W |d u r t �� d S |�� d S |d u r.t �� w |�� w )NF)�instance)r �currentZ_setup_loggingZ make_currentr Z run_foreverZ clear_current)r Z old_currentr r r �startu s � zBaseAsyncIOLoop.startc C s | j �� d S r* )r �stop)r r r r r2 � s zBaseAsyncIOLoop.stopc O s: | j �td|| �� �| jtjt�|�g|�R i |���S )Nr ) r Z call_later�max�time� _run_callback� functools�partialr r )r Zwhen�callback�argsr r r r �call_at� s �zBaseAsyncIOLoop.call_atc C s |� � d S r* )�cancel)r �timeoutr r r �remove_timeout� s z BaseAsyncIOLoop.remove_timeoutc O s< | j rtd��| j�| jtjt�|�g|�R i |��� d S )NzIOLoop is closing) r � RuntimeErrorr Zcall_soon_threadsafer5 r6 r7 r r )r r8 r9 r r r r � add_callback� s �z BaseAsyncIOLoop.add_callback)F)�__name__� __module__� __qualname__r r r) r. r r# r1 r2 r: r= r? Zadd_callback_from_signal� __classcell__r r r r r , s r c � e Zd ZdZ� fdd�Z� ZS )�AsyncIOMainLoopa� ``AsyncIOMainLoop`` creates an `.IOLoop` that corresponds to the current ``asyncio`` event loop (i.e. the one returned by ``asyncio.get_event_loop()``). Recommended usage:: from salt.ext.tornado.platform.asyncio import AsyncIOMainLoop import asyncio AsyncIOMainLoop().install() asyncio.get_event_loop().run_forever() See also :meth:`tornado.ioloop.IOLoop.install` for general notes on installing alternative IOLoops. c s$ t t| �jt�� fddi|�� d S )Nr F)r rE r �asyncioZget_event_loop)r r r r r r � s � �zAsyncIOMainLoop.initialize�r@ rA rB �__doc__r rC r r r r rE � � rE c rD )� AsyncIOLoopa# ``AsyncIOLoop`` is an `.IOLoop` that runs on an ``asyncio`` event loop. This class follows the usual Tornado semantics for creating new ``IOLoops``; these loops are not necessarily related to the ``asyncio`` default event loop. Recommended usage:: from salt.ext.tornado.ioloop import IOLoop IOLoop.configure('tornado.platform.asyncio.AsyncIOLoop') IOLoop.current().start() Each ``AsyncIOLoop`` creates a new ``asyncio.EventLoop``; this object can be accessed with the ``asyncio_loop`` attribute. c sD t �� }ztt| �j|fddi|�� W d S ty! |�� � w )Nr T)rF Znew_event_loopr rJ r � Exceptionr )r r Zloopr r r r � s " �zAsyncIOLoop.initializerG r r r r rJ � rI rJ c C s$ t jjj�� }t jjj�| |� |S )z]Convert an `asyncio.Future` to a `tornado.concurrent.Future`. .. versionadded:: 4.1 )�salt�ext�tornado� concurrent�Future� chain_future)Zasyncio_future�tfr r r �to_tornado_future� s rS c C s& t | �} t�� }tjjj�| |� |S )z�Convert a Tornado yieldable object to an `asyncio.Future`. .. versionadded:: 4.1 .. versionchanged:: 4.3 Now accepts any yieldable object, not just `tornado.concurrent.Future`. )r rF rP rL rM rN rO rQ )Ztornado_future�afr r r �to_asyncio_future� s rU �register)rH � __future__r r r r6 Zsalt.ext.tornado.concurrentrL Zsalt.ext.tornado.genr Zsalt.ext.tornado.ioloopr Zsalt.ext.tornador rF � ImportError�eZtrolliusr rE rJ rS rU �hasattrrV rP r r r r �<module> s4 � ��� o �
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings