File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/tornado/platform/__pycache__/asyncio.cpython-310.pyc
Back
o ;j�m � @ s� U d Z ddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlmZ ddlmZmZ ddl mZmZmZmZmZmZmZmZmZm Z e j rdddl m Z m Z G dd� de�Z!e e"e!f Z#ed �Z$e j r}e d �Z%e&� Z'ed e(d < d"dd�Z)e�*e)� G dd� de�Z+G dd� de+�Z,G dd� de+�Z-dej.d ej.fdd�Z/dej.d ej.fdd�Z0da1d e2d e jfd d �Z3G d d � d �Z4G d d!� d!ej5�Z6dS )#ak 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 is designed to use a selector-based event loop. On Windows, where a proactor-based event loop has been the default since Python 3.8, a selector event loop is emulated by running ``select`` on a separate thread. Configuring ``asyncio`` to use a selector event loop may improve performance of Tornado (but may reduce performance of other ``asyncio``-based libraries in the same process). � N��convert_yielded)�IOLoop� _Selectable) �Any�Callable�Dict�List�Optional�Protocol�Set�Tuple�TypeVar�Union)� TypeVarTuple�Unpackc @ s e Zd Zdefdd�ZdS )� _HasFileno�returnc C � d S �N� ��selfr r �L/opt/saltstack/salt/lib/python3.10/site-packages/tornado/platform/asyncio.py�fileno: s z_HasFileno.filenoN)�__name__� __module__� __qualname__�intr r r r r r 9 s r �_T�_Ts�SelectorThread�_selector_loopsr c C s� t D ]9} | j� d| _| j�� W d � n1 sw Y z| j�d� W n ty0 Y nw | jd ur;| j�� qt � � d S )NT� a) r" � _select_cond�_closing_selector�notify�_waker_w�send�BlockingIOError�_thread�join�clear)�loopr r r �_atexit_callbackI s � � � r. c sl e Zd Zdejdeddf� fdd� Zd/deddfd d �Zd e e e f d e d de ddfdd�Z d e e e f de ddfdd�Zd e e e f ddfdd�Zd e de ddfdd�Zd0dd�Zd0dd�Zded e d ededef d d �Zd eddfd!d"�Zd e d ededdfd#d$�Zd e d ededdfd%d&�Zd'eejj d(e d)e f d edd*fd+d,�Z d'ejj ddfd-d.�Z � Z S )1�BaseAsyncIOLoop� asyncio_loop�kwargsr Nc s� || _ || _ttd�rt|tj�rt|�| _i | _t� | _ t� | _ d| _ t j �� D ]}|�� r?zt j |= W q) ty> Y q)w q)t j �|| �}|| urUtd|� d|� ���t� jdi |�� d S )N�ProactorEventLoopFzIOLoop z& already associated with asyncio loop r )r0 � selector_loop�hasattr�asyncio� isinstancer2 �AddThreadSelectorEventLoop�handlers�set�readers�writers�closingr �_ioloop_for_asyncio�copyZ is_closed�KeyError� setdefault� RuntimeError�super� initialize)r r0 r1 r- Z existing_loop�� __class__r r rC _ s0 � ���zBaseAsyncIOLoop.initializeF�all_fdsc C sj d| _ t| j�D ]}| j| \}}| �|� |r | �|� qtj| j= | j| jur.| j� � | j� � d S �NT) r< �listr8 �remove_handlerZclose_fdr r= r0 r3 �close)r rF �fd�fileobj� handler_funcr r r rJ � s � zBaseAsyncIOLoop.closerK �handler�.N�eventsc C s� | � |�\}}|| jv rtd| ��||f| j|< |tj@ r/| j�|| j|tj� | j� |� |tj @ rG| j� || j|tj � | j � |� d S d S )Nzfd %s added twice) �split_fdr8 � ValueErrorr �READr3 � add_reader�_handle_eventsr: �add�WRITE� add_writerr; )r rK rN rP rL r r r � add_handler� 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 r )rQ r rS r: r3 rT rU rV � remove_reader�removerW r; rX � remove_writer)r rK rP rL r r r �update_handler� s$ � � �z BaseAsyncIOLoop.update_handlerc C sl | � |�\}}|| jvrd S || jv r | j�|� | j�|� || jv r0| j�|� | j�|� | j|= d S r )rQ r8 r: r3 rZ r[ r; r\ )r rK rL r r r rI � s z BaseAsyncIOLoop.remove_handlerc C s | j | \}}|||� d S r )r8 )r rK rP rL rM r r r rU � s z BaseAsyncIOLoop._handle_eventsc C � | j �� d S r )r0 Z run_foreverr r r r �start� � zBaseAsyncIOLoop.startc C r^ r )r0 �stopr r r r ra � r` zBaseAsyncIOLoop.stop�when�callback�argsc O s4 | j �td|| �� �| jtj|g|�R i |���S )Nr )r0 Z call_later�max�time� _run_callback� functools�partial)r rb rc rd r1 r r r �call_at� s �zBaseAsyncIOLoop.call_at�timeoutc C s |� � d S r )�cancel)r rk r r r �remove_timeout� � z BaseAsyncIOLoop.remove_timeoutc O s� zt �� | ju r | jj}n| jj}W n ty | jj}Y nw z|| jtj|g|�R i |��� W d S ty= Y d S t yF Y d S w r ) r5 Zget_running_loopr0 � call_soon�call_soon_threadsaferA rg rh ri �AttributeError)r rc rd r1 ro r r r � add_callback� s � �& �z BaseAsyncIOLoop.add_callbackc O sL t �dt� z| j�| jtj|g|�R i |��� W d S ty% Y d S w )Nz&add_callback_from_signal is deprecated) �warnings�warn�DeprecationWarningr0 rp rg rh ri rA )r rc rd r1 r r r �add_callback_from_signal� s � �z(BaseAsyncIOLoop.add_callback_from_signal�executor�func.zasyncio.Future[_T]c G � | j j||g|�R � S r )r0 �run_in_executor)r rw rx rd r r r rz � z BaseAsyncIOLoop.run_in_executorc C � | j �|�S r )r0 �set_default_executor)r rw r r r r} rn z$BaseAsyncIOLoop.set_default_executor�F�r N)!r r r r5 �AbstractEventLoopr rC �boolrJ r r r r rY r] rI rU r_ ra �float�objectrj rm rr rv r � concurrentZfuturesZExecutorr rz r} � __classcell__r r rD r r/ ^ sn ���1 ��� � ���� � ��� � � �� � r/ c s4 e Zd ZdZdeddf� fdd� Zd 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. r1 r Nc s t � jt�� fi |�� d S r )rB rC r5 �get_event_loop)r r1 rD r r rC % s zAsyncIOMainLoop.initializec C r r r r r r r � _make_current( s z AsyncIOMainLoop._make_currentr )r r r �__doc__r rC r� r� r r rD r r� s r� c sV e Zd ZdZdeddf� fdd� Zddeddf� fd d � Zdd d �Zdd d�Z � Z S )� AsyncIOLoopaa ``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:: 6.2 Support explicit ``asyncio_loop`` argument for specifying the asyncio loop to attach to, rather than always creating a new one with the default policy. .. 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. r1 r Nc s\ d| _ d }d|vrt�� |d< }z t� jdi |�� W d S ty- |d ur,|�� � w )NFr0 r )� is_currentr5 �new_event_looprB rC � ExceptionrJ )r r1 r- rD r r rC H s �zAsyncIOLoop.initializeFrF c s | j r| �� t� j|d� d S )N)rF )r� Z_clear_currentrB rJ )r rF rD r r rJ V s zAsyncIOLoop.closec C sH | j s zt�� | _W n ttfy d | _Y nw d| _ t�| j� d S rG )r� r5 r� � old_asynciorA �AssertionError�set_event_loopr0 r r r r r� [ s �zAsyncIOLoop._make_currentc C s | j rt�| j� d| _ d S d S )NF)r� r5 r� r� r r r r �_clear_current_hookd s �z AsyncIOLoop._clear_current_hookr~ r ) r r r r� r rC r� rJ r� r� r� r r rD r r� . s r� �asyncio_futurec 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 )r� r r r �to_tornado_futurej s r� �tornado_futurec 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 )r� r r r �to_asyncio_futurev s r� �namec C s^ | dkrt dt�d| ����td u r-tjdkr ttd�r tj}ntj}G dd� d|�}|atS )N�AnyThreadEventLoopPolicyzmodule z has no attribute �win32� WindowsSelectorEventLoopPolicyc s6 e Zd ZdZd� fdd� Zdejf� fdd� Z� ZS ) z-__getattr__.<locals>.AnyThreadEventLoopPolicya� 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 .. deprecated:: 6.2 ``AnyThreadEventLoopPolicy`` affects the implicit creation of an event loop, which is deprecated in Python 3.10 and will be removed in a future version of Python. At that time ``AnyThreadEventLoopPolicy`` will no longer be useful. If you are relying on it, use `asyncio.new_event_loop` or `asyncio.run` explicitly in any non-main threads that need event loops. r Nc s t � �� tjdtdd� d S )NzYAnyThreadEventLoopPolicy is deprecated, use asyncio.run or asyncio.new_event_loop instead� )� stacklevel)rB �__init__rs rt ru r rD r r r� � s �z6__getattr__.<locals>.AnyThreadEventLoopPolicy.__init__c s6 zt � �� W S ty | �� }| �|� | Y S w r )rB r� rA r� r� )r r- rD r r r� � s �z<__getattr__.<locals>.AnyThreadEventLoopPolicy.get_event_loopr ) r r r r� r� r5 r� r� r� r r rD r r� � s ) rq r �_AnyThreadEventLoopPolicy�sys�platformr4 r5 r� ZDefaultEventLoopPolicy)r� Z _BasePolicyr� r r r � __getattr__� s �-r� c @ s e Zd ZdZdZdejddfdd�Zd(dd �Zde j d fd d �Z d(d d�Z d(dd�Z d(dd�Zd(dd�Zdee dee ddfdd�Zdedeeef ddfdd �Zded ed d eddfd d!�Zded ed d eddfd"d#�Zdedefd$d%�Zdedefd&d'�ZdS ))r! aq Define ``add_reader`` methods to be called in a background select thread. Instances of this class start a second thread to run a selector. This thread is completely hidden from the user; all callbacks are run on the wrapped event loop's thread. Typically used via ``AddThreadSelectorEventLoop``, but can be attached to a running asyncio loop. F� real_loopr Nc s� t �� � _|� _t�� � _d � _d� _d � _ � � � � _ d� fdd� �� jj � �fdd�� jd� i � _ i � _t�� \� _� _� j�d� � j�d� t�� � � �� j� j� d S ) NFr c � s �� j �� I d H d S r )�_thread_manager_handle� __anext__r r r r �thread_manager_anext� s �z5SelectorThread.__init__.<locals>.thread_manager_anextc s � j ��� �S r )� _real_loopZ create_taskr �r r� r r �<lambda>� s z)SelectorThread.__init__.<locals>.<lambda>��contextr )� contextvarsZ copy_context�_main_thread_ctxr� � threading� Conditionr$ � _select_argsr% r* �_thread_managerr� ro �_readers�_writers�socket� socketpair�_waker_rr' � setblockingr" rV rT �_consume_waker�r r� r r� r r� � s( � � zSelectorThread.__init__c C s� | j rd S | j� d| _| j�� W d � n1 sw Y | �� | jd ur.| j�� t�| � | � | j � | j � � | j � � d| _ d S rG ) �_closedr$ r% r& �_wake_selectorr* r+ r" �discardrZ r� rJ r' r r r r rJ s � zSelectorThread.close)NNc C sN �t jdd| jd�| _| j�� | �� zd V W d S ty& | �� � w )NzTornado selectorT)r� �daemon�target)r� �Thread� _run_selectr* r_ � _start_select� GeneratorExitrJ r r r r r� s �� �z SelectorThread._thread_managerc C s2 | j rd S z | j�d� W d S ty Y d S w )Nr# )r� r' r( r) r r r r r� ( s �z SelectorThread._wake_selectorc C s( z | j �d� W d S ty Y d S w )Ni )r� �recvr) r r r r r� 0 s �z SelectorThread._consume_wakerc C sb | j �$ | jd u s J �t| j�� �t| j�� �f| _| j �� W d � d S 1 s*w Y d S r )r$ r� rH r� �keysr� r& r r r r r� 6 s "�z SelectorThread._start_selectc C sP | j �8 | jd u r| js| j �� | jd u r| jr | jr& W d � d S | jd us-J �| j\}}d | _W d � n1 s?w Y zt�|||�\}}}|| }W n2 ty� } z&|jttdtj�kr{t�| j � � gg g d�\}}}|rzg }n� � W Y d }~nd }~ww z| j j | j ||| jd� W n ty� Y n ty� Y nw q)NTZ WSAENOTSOCKr r� )r$ r� r% �wait�select�OSError�errno�getattr�EBADFr� r r� rp �_handle_selectr� rA rq )r Zto_readZto_write�rs�wsZxs�e�_r r r r� ? sF �� � ��� � ��zSelectorThread._run_selectr� r� c C s< |D ] }| � || j� q|D ] }| � || j� q| �� d S r )� _handle_eventr� r� r� )r r� r� �r�wr r r r� � s z SelectorThread._handle_selectrK �cb_mapc C s, z|| }W n t y Y d S w |� d S r )r? )r rK r� rc r r r r� � s � z SelectorThread._handle_eventrc rO rd c G �$ t j|g|�R � | j|< | �� d S r )rh ri r� r� �r rK rc rd r r r rT � � zSelectorThread.add_readerc G r� r )rh ri r� r� r� r r r rX � r� zSelectorThread.add_writerc C �. z| j |= W n ty Y dS w | �� dS �NFT)r� r? r� �r rK r r r rZ � � �z SelectorThread.remove_readerc C r� r� )r� r? r� r� r r r r\ � r� z SelectorThread.remove_writerr ) r r r r� r� r5 r� r� rJ �typing�AsyncGeneratorr� r� r� r� r� r �_FileDescriptorLiker� r r r� r rT rX r� rZ r\ r r r r r! � sX % B�� � � � � ��� ���� �c s� e Zd ZdZh d�Zdedef� fdd� Zdej ddfd d �Z dd d �Z d dde d ddddfdd�Z d dde d ddddfdd�Zd ddefdd�Zd ddefdd�Z� ZS ) r7 a� Wrap an event loop to add implementations of the ``add_reader`` method family. Instances of this class start a second thread to run a selector. This thread is completely hidden from the user; all callbacks are run on the wrapped event loop's thread. This class is used automatically by Tornado; applications should not need to refer to it directly. It is safe to wrap any event loop with this class, although it only makes sense for event loops that do not implement the ``add_reader`` family of methods themselves (i.e. ``WindowsProactorEventLoop``) Closing the ``AddThreadSelectorEventLoop`` also closes the wrapped event loop. > rT � _selectorrZ rX rJ r� r\ r� r c s" |t jv r t� �|�S t| j|�S r )r7 � MY_ATTRIBUTESrB �__getattribute__r� r� )r r� rD r r r� � s z+AddThreadSelectorEventLoop.__getattribute__r� Nc C s || _ t|�| _d S r )r� r! r� r� r r r r� � s z#AddThreadSelectorEventLoop.__init__c C s | j �� | j�� d S r )r� rJ r� r r r r rJ � s z AddThreadSelectorEventLoop.closerK r� rc rO rd z Unpack[_Ts]c G ry r )r� rT r� r r r rT � r{ z%AddThreadSelectorEventLoop.add_readerc G ry r )r� rX r� r r r rX � r{ z%AddThreadSelectorEventLoop.add_writerc C r| r )r� rZ r� r r r rZ � rn z(AddThreadSelectorEventLoop.remove_readerc C r| r )r� r\ r� r r r r\ � rn z(AddThreadSelectorEventLoop.remove_writerr )r r r r� r� �strr r� r5 r� r� rJ r rT rX r� rZ r\ r� r r rD r r7 � s4 ��� ���� �r7 r )7r� r5 �atexit�concurrent.futuresr� r� r� rh r� r� r� r� r� rs Z tornado.genr Ztornado.ioloopr r r r r r r r r r r r � TYPE_CHECKINGZtyping_extensionsr r r r r� r r r9 r" �__annotations__r. �registerr/ r� r� ZFuturer� r� r� r� r� r! r� r7 r r r r �<module> sJ 0 9< E e
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings