Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/tornado/platform/__pycache__/asyncio.cpython-39.pyc
Ðазад
a _�h�2 � @ s( d Z ddlZddlZddlZddlmZ ddlmZ ddl m Z m Z ddl Z ddl Z ddl mZmZmZmZmZmZ e jr�ddl mZmZmZ ed�ZG d d � d e �ZG d d � d e�ZG d d� de�Ze j e j d�dd�Z e j e j d�dd�Z ej dk�re e d��re j!Z"ne j#Z"G dd� de"�Z$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. This makes it possible to combine the two libraries on the same event loop. .. deprecated:: 5.0 While the code in this module is still used, it is now enabled automatically when `asyncio` is available, so applications should no longer need to refer to this module directly. .. 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. � N)� get_ident��convert_yielded)�IOLoop� _Selectable)�Any�TypeVar� Awaitable�Callable�Union�Optional)�Set�Dict�Tuple�_Tc sH e Zd Zejedd�� fdd� Zd,edd�dd�Ze e e f e d e dd �d d �Z e e e f e dd �dd�Ze e e f dd�dd�Ze e dd �dd�Zdd�dd�Zdd�dd�Zee d eeed�dd �Zedd �d d �Ze eedd �d!d"�Ze eedd �d#d$�Zeejj e d%e f ee e d&�d'd(�Z ejj dd)�d*d+�Z � Z!S )-�BaseAsyncIOLoopN)� asyncio_loop�kwargs�returnc s� |� _ i � _t� � _t� � _d� _ttj�D ]}|� � r,tj|= q,� tj|< d� _ t t � �j f i |�� d d�� fdd� }� �|� d S )NFr �r c s t � � _d S �N)r �_thread_identity� ��selfr ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/tornado/platform/asyncio.py�assign_thread_identityH s z:BaseAsyncIOLoop.initialize.<locals>.assign_thread_identity)r �handlers�set�readers�writers�closing�listr �_ioloop_for_asyncioZ is_closedr �superr � initialize� add_callback)r r r �loopr �� __class__r r r% * s zBaseAsyncIOLoop.initializeF��all_fdsr c C sT d| _ t| j�D ]*}| j| \}}| �|� |r| �|� qtj| j= | j�� d S �NT) r! r" r �remove_handlerZclose_fdr r# r �close)r r+ �fd�fileobj� handler_funcr r r r. M s zBaseAsyncIOLoop.close).N)r/ �handler�eventsr c C s� | � |�\}}|| jv r$td| ��||f| j|< |tj@ r^| j�|| j|tj� | j� |� |tj @ r�| j� || j|tj � | j � |� d S )Nzfd %s added twice) �split_fdr � ValueErrorr �READr � add_reader�_handle_eventsr �add�WRITE� add_writerr )r r/ r2 r3 r0 r r r � add_handler\ s zBaseAsyncIOLoop.add_handler)r/ r3 r c C s� | � |�\}}|tj@ rF|| jvrh| j�|| j|tj� | j�|� n"|| jv rh| j�|� | j� |� |tj @ r�|| j vr�| j� || j|tj � | j �|� n"|| j v r�| j� |� | j � |� d S r )r4 r r6 r r r7 r8 r9 � remove_reader�remover: r r; � remove_writer)r r/ r3 r0 r r r �update_handlerj s z BaseAsyncIOLoop.update_handler)r/ r c C sl | � |�\}}|| jvr d S || jv r>| j�|� | j�|� || jv r`| j�|� | j�|� | j|= d S r )r4 r r r r= r> r r? )r r/ r0 r r r r- } s z BaseAsyncIOLoop.remove_handlerc C s | j | \}}|||� d S r )r )r r/ r3 r0 r1 r r r r8 � s z BaseAsyncIOLoop._handle_eventsr c C sf z t �� }W n ttfy& d }Y n0 z,| �� t �| j� | j�� W t �|� n t �|� 0 d S r )�asyncio�get_event_loop� RuntimeError�AssertionErrorZ_setup_logging�set_event_loopr Z run_forever)r Zold_loopr r r �start� s zBaseAsyncIOLoop.startc C s | j �� d S r )r �stopr r r r rG � s zBaseAsyncIOLoop.stop)�when�callback�argsr r c O s4 | j �td|| �� �| jtj|g|�R i |���S )Nr )r Z call_later�max�time� _run_callback� functools�partial)r rH rI rJ r r r r �call_at� s �zBaseAsyncIOLoop.call_at)�timeoutr c C s |� � d S r )�cancel)r rQ r r r �remove_timeout� s z BaseAsyncIOLoop.remove_timeout)rI rJ r r c O sZ t � | jkr| jj}n| jj}z$|| jtj|g|�R i |��� W n tyT Y n0 d S r ) r r r � call_soon�call_soon_threadsaferM rN rO rC )r rI rJ r rT r r r r& � s $ z BaseAsyncIOLoop.add_callbackc O s@ z(| j �| jtj|g|�R i |��� W n ty: Y n0 d S r )r rU rM rN rO rC )r rI rJ r r r r �add_callback_from_signal� s � z(BaseAsyncIOLoop.add_callback_from_signal.)�executor�funcrJ r c G s | j j||g|�R � S r )r �run_in_executor)r rW rX rJ r r r rY � s z BaseAsyncIOLoop.run_in_executor)rW r c C s | j �|�S r )r �set_default_executor)r rW r r r rZ � s z$BaseAsyncIOLoop.set_default_executor)F)"�__name__� __module__� __qualname__rA �AbstractEventLoopr r% �boolr. r �intr r r< r@ r- r8 rF rG �float�objectrP rS r& rV r � concurrentZfuturesZExecutorr r rY rZ � __classcell__r r r( r r ) s4 �#� � � � r c s6 e Zd ZdZedd�� fdd� Zdd�dd�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()``). .. deprecated:: 5.0 Now used automatically when appropriate; it is no longer necessary to refer to this class directly. .. versionchanged:: 5.0 Closing an `AsyncIOMainLoop` now closes the underlying asyncio loop. N�r r c s t t| �jt�� fi |�� d S r )r$ re r% rA rB )r r r( r r r% � s zAsyncIOMainLoop.initializer c C s d S r r r r r r � make_current� s z AsyncIOMainLoop.make_current)r[ r\ r] �__doc__r r% rg rd r r r( r re � s re c sZ e Zd ZdZedd�� fdd� Zdedd�� fdd � Zdd �d d �Zdd �d d�Z � Z S )� 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. Each ``AsyncIOLoop`` creates a new ``asyncio.EventLoop``; this object can be accessed with the ``asyncio_loop`` attribute. .. versionchanged:: 5.0 When an ``AsyncIOLoop`` becomes the current `.IOLoop`, it also sets the current `asyncio` event loop. .. deprecated:: 5.0 Now used automatically when appropriate; it is no longer necessary to refer to this class directly. Nrf c sL d| _ t�� }z tt| �j|fi |�� W n tyF |�� � Y n0 d S �NF)� is_currentrA �new_event_loopr$ ri r% � Exceptionr. )r r r' r( r r r% � s zAsyncIOLoop.initializeFr* c s$ | j r| �� tt| �j|d� d S )N)r+ )rk Z clear_currentr$ ri r. )r r+ r( r r r. s zAsyncIOLoop.closer c C sH | j s8zt�� | _W n ttfy0 d | _Y n0 d| _ t�| j� d S r, )rk rA rB � old_asynciorC rD rE r r r r r rg s zAsyncIOLoop.make_currentc C s | j rt�| j� d| _ d S rj )rk rA rE rn r r r r �_clear_current_hook s z AsyncIOLoop._clear_current_hook)F) r[ r\ r] rh r r% r_ r. rg ro rd r r r( r ri � s ri )�asyncio_futurer c C s | S )z�Convert an `asyncio.Future` to a `tornado.concurrent.Future`. .. versionadded:: 4.1 .. deprecated:: 5.0 Tornado ``Futures`` have been merged with `asyncio.Future`, so this method is now a no-op. r )rp r r r �to_tornado_future s rq )�tornado_futurer c C s t | �S )as 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`. .. deprecated:: 5.0 Tornado ``Futures`` have been merged with `asyncio.Future`, so this method is now equivalent to `tornado.gen.convert_yielded`. r )rr r r r �to_asyncio_future' s rs �win32� WindowsSelectorEventLoopPolicyc s( e Zd ZdZejd�� fdd� Z� ZS )�AnyThreadEventLoopPolicyaD Event loop policy that allows loop creation on any thread. The default `asyncio` event loop policy only automatically creates event loops in the main threads. Other threads must create event loops explicitly or `asyncio.get_event_loop` (and therefore `.IOLoop.current`) will fail. Installing this policy allows event loops to be created automatically on any thread, matching the behavior of Tornado versions prior to 5.0 (or 5.0 on Python 2). Usage:: asyncio.set_event_loop_policy(AnyThreadEventLoopPolicy()) .. versionadded:: 5.0 r c s> z t � �� W S ttfy8 | �� }| �|� | Y S 0 d S r )r$ rB rC rD rl rE )r r' r( r r rB Q s z'AnyThreadEventLoopPolicy.get_event_loop)r[ r\ r] rh rA r^ rB rd r r r( r rv ? s rv )%rh �concurrent.futuresrc rN �sys� threadingr Z tornado.genr Ztornado.ioloopr r rA �typingr r r r r r � TYPE_CHECKINGr r r r r re ri �Futurerq rs �platform�hasattrru Z _BasePolicyZDefaultEventLoopPolicyrv r r r r �<module> s, (3
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка