| Server IP : 184.154.167.98 / Your IP : 3.147.54.52 Web Server : Apache System : Linux pink.dnsnetservice.com 4.18.0-553.22.1.lve.1.el8.x86_64 #1 SMP Tue Oct 8 15:52:54 UTC 2024 x86_64 User : puertode ( 1767) PHP Version : 8.2.26 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /usr/lib64/python3.8/asyncio/__pycache__/ |
Upload File : |
U
e5d�� � @ sr d Z ddlZddlZddlZddlZddlZddlZddlZddl Z ddl
m Z ddl
m Z ddl
m
Z
ddl
mZ ddl
mZ dd l mZ e�d�jZdAd
d �ZdBd d
�ZdCdd�Zdd� ZG dd� dej�ZeZz ddlZW n e k
r� Y n X ej ZZ dd�dd�Z ejj Z ejj Z ejj!Z!dde!d�dd�Z"dd� Z#dd �d d �Z$d d � Z%d!d"� Z&ddd#�d$d%�Z'ej(d&d'� �Z)dDdd �d(d)�Z*dd �d*d+�Z+ej(d,d-� �Z,ee,_G d.d/� d/ej-�Z.dd0d1�d2d3�Z/dd �d4d5�Z0d6d7� Z1e �2� Z3i Z4d8d9� Z5d:d;� Z6d<d=� Z7d>d?� Z8e5Z9e8Z:e6Z;e7Z<z$dd@lm5Z5m8Z8m6Z6m7Z7m3Z3m4Z4 W n e k
�r\ Y nX e5Z=e8Z>e6Z?e7Z@dS )E)�Task� create_task�FIRST_COMPLETED�FIRST_EXCEPTION�
ALL_COMPLETED�wait�wait_for� as_completed�sleep�gather�shield�
ensure_future�run_coroutine_threadsafe� current_task� all_tasks�_register_task�_unregister_task� _enter_task� _leave_task� N� )�
base_tasks)�
coroutines)�events)�
exceptions)�futures)�
_is_coroutinec C s | d krt �� } t�| �S �N)r �get_running_loop�_current_tasks�get��loop� r" �%/usr/lib64/python3.8/asyncio/tasks.pyr " s r c s^ � d krt �� � d}z tt�}W qL tk
rF |d7 }|dkrB� Y qX qLq� fdd�|D �S )Nr r �� c s& h | ] }t �|�� kr|�� s|�qS r" )r � _get_loop�done��.0�tr r" r# � <setcomp>< s �z all_tasks.<locals>.<setcomp>)r r �list�
_all_tasks� RuntimeError�r! �iZtasksr" r r# r ) s r c s^ � d krt �� � d}z tt�}W qL tk
rF |d7 }|dkrB� Y qX qLq� fdd�|D �S )Nr r r$ c s h | ]}t �|�� kr|�qS r" )r r% r' r r" r# r* U s z$_all_tasks_compat.<locals>.<setcomp>)r �get_event_loopr+ r, r- r. r" r r# �_all_tasks_compat@ s r1 c C s4 |d k r0z
| j }W n tk
r& Y n
X ||� d S r )�set_name�AttributeError)�task�namer2 r" r" r# �_set_task_nameX s
r6 c s� e Zd ZdZed$dd��Zed%dd��Zddd�� fdd �
Z� fd
d �Zd d
� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd�dd�Zddd�d d �Zd d � Zd&� fd d!� Zd"d#� Z� ZS )'r TNc C s( t jdtdd� |d kr t�� }t|�S )NzVTask.current_task() is deprecated since Python 3.7, use asyncio.current_task() instead� ��
stacklevel)�warnings�warn�DeprecationWarningr r0 r ��clsr! r" r" r# r t s �zTask.current_taskc C s t jdtdd� t|�S )NzPTask.all_tasks() is deprecated since Python 3.7, use asyncio.all_tasks() insteadr7 r8 )r: r; r< r1 r= r" r" r# r � s
�zTask.all_tasks)r! r5 c s� t � j|d� | jr | jd= t�|�s:d| _td|����|d krRdt� � �| _n
t |�| _d| _
d | _ || _ t
�� | _| jj| j| jd� t| � d S )Nr ���Fz a coroutine was expected, got zTask-��context)�super�__init__�_source_tracebackr � iscoroutine�_log_destroy_pending� TypeError�_task_name_counter�_name�str� _must_cancel� _fut_waiter�_coro� contextvarsZ copy_context�_context�_loop� call_soon� _Task__stepr )�self�coror! r5 �� __class__r" r# rC � s
z
Task.__init__c sF | j tjkr8| jr8| dd�}| jr,| j|d< | j�|� t� �� d S )Nz%Task was destroyed but it is pending!)r4 �messageZsource_traceback) Z_stater Z_PENDINGrF rD rP Zcall_exception_handlerrB �__del__)rS rA rU r" r# rX � s �
z Task.__del__c C s
t �| �S r )r Z_task_repr_info�rS r" r" r# �
_repr_info� s zTask._repr_infoc C s | j S r )rM rY r" r" r# �get_coro� s z
Task.get_coroc C s | j S r )rI rY r" r" r# �get_name� s z
Task.get_namec C s t |�| _d S r )rJ rI )rS �valuer" r" r# r2 � s z
Task.set_namec C s t d��d S )Nz*Task does not support set_result operation�r- )rS �resultr" r" r# �
set_result� s zTask.set_resultc C s t d��d S )Nz-Task does not support set_exception operationr^ )rS � exceptionr" r" r# �
set_exception� s zTask.set_exception)�limitc C s t �| |�S r )r Z_task_get_stack)rS rc r" r" r# � get_stack� s zTask.get_stack)rc �filec C s t �| ||�S r )r Z_task_print_stack)rS rc re r" r" r# � print_stack� s zTask.print_stackc C s4 d| _ | �� rdS | jd k r*| j�� r*dS d| _dS �NFT)Z_log_tracebackr& rL �cancelrK rY r" r" r# rh � s
z Task.cancelc
s� | � � r t�d| �d|����| jr>t|tj�s8t�� }d| _| j}d | _t| j | � �zfz"|d krp|� d �}n
|� |�}W n� t
k
r� } z*| jr�d| _t� �� nt� �|j� W 5 d }~X Y �n� tjk
r� t� �� Y �n� ttfk
�r } zt� �|� � W 5 d }~X Y �n� tk
�rL } zt� �|� W 5 d }~X Y �npX t|dd �}|d k �r@t�|�| j k �r�td| �d|�d��}| j j| j|| j d� n�|�r|| k�r�td | ���}| j j| j|| j d� n8d|_ |j | j | j d� || _| j�r>| j�� �r>d| _n*td
| �d |���}| j j| j|| j d� n||d k�r`| j j| j| j d� n\t �!|��r�td | �d |���}| j j| j|| j d� n$td
|���}| j j| j|| j d� W 5 t
| j | � d } X d S )Nz_step(): already done: z, F�_asyncio_future_blockingzTask z got Future z attached to a different loopr@ z Task cannot await on itself: z-yield was used instead of yield from in task z with z;yield was used instead of yield from for generator in task zTask got bad yield: )"r& r ZInvalidStateErrorrK �
isinstance�CancelledErrorrM rL r rP r �send�throw�
StopIterationrB rh r` r] �KeyboardInterrupt�
SystemExitrb �
BaseException�getattrr r% r- rQ rR rO ri �add_done_callback�
_Task__wakeup�inspectZ isgenerator)rS �excrT r_ Zblocking�new_excrU r" r# Z__step s� �
� �
� � � � �
� � �
z Task.__stepc
C sJ z |� � W n, tk
r8 } z| �|� W 5 d }~X Y n
X | �� d } d S r )r_ rq rR )rS �futurerv r" r" r# Z__wakeup[ s z
Task.__wakeup)N)N)N)�__name__�
__module__� __qualname__rF � classmethodr r rC rX rZ r[ r\ r2 r` rb rd rf rh rR rt �
__classcell__r" r" rU r# r b s$ !Tr )r5 c C s t �� }|�| �}t||� |S r )r r r r6 )rT r5 r! r4 r" r" r# r x s
r )r! �timeout� return_whenc � s� t �| �st�| �r(tdt| �j� ���| s4td��|tt t
fkrPtd|� ���� d krbt � � � nt
jdtdd� � fdd�t| �D �} t| ||� �I d H S ) Nz expect a list of futures, not z#Set of coroutines/Futures is empty.zInvalid return_when value: �[The loop argument is deprecated since Python 3.8, and scheduled for removal in Python 3.10.r7 r8 c s h | ]}t |� d ��qS �r �r �r( �fr r" r# r* � s zwait.<locals>.<setcomp>)r �isfuturer rE rG �typery �
ValueErrorr r r r r r: r; r< �set�_wait)�fsr! r~ r r" r r# r � s
�r c G s | � � s| �d � d S r )r& r` )�waiter�argsr" r" r# �_release_waiter� s r� r c
� s� |d krt �� }ntjdtdd� |d kr4| I d H S |dkr�t| |d�} | �� rX| �� S t| |d�I d H z | �� W n. t j
k
r� } zt � � |�W 5 d }~X Y n
X t � � �|� � }|�
|t|�}t�t|�}t| |d�} | �|� z�z|I d H W nP t j
k
�rF | �� �r$| �� Y W �dS | �|� t| |d�I d H � Y nX | �� �r^| �� W �*S | �|� t| |d�I d H t � � �W 5 |�� X d S )Nr� r7 r8 r r )r r r: r; r< r r& r_ �_cancel_and_waitr rk � TimeoutError�
create_future�
call_laterr� � functools�partialrs rh �remove_done_callback)�futr~ r! rv r� �timeout_handle�cbr" r" r# r � sL
�
r c
� s� |� � �d �|d k r"|�|t���t| �� � ���fdd�}| D ]}|�|� q@z�I d H W 5 �d k rp��� | D ]}|�|� qtX t� t� }}| D ]"}|�� r�|� |� q�|� |� q�||fS )Nc sZ � d8 � � dks4�t ks4�tkrV| �� sV| �� d k rV�d k rD��� ��� sV��d � d S )Nr r )r r � cancelledra rh r& r` �r� �Zcounterr r� r� r" r# �_on_completion s ���
�z _wait.<locals>._on_completion)
r� r� r� �lenrs rh r� r� r& �add)r� r~ r r! r� r� r& Zpendingr" r� r# r� � s( r� c � sF |� � }t�t|�}| �|� z| �� |I d H W 5 | �|� X d S r )r� r� r� r� rs r� rh )r� r! r� r� r" r" r# r� & s
r� )r! r~ c # s� t �| �st�| �r(tdt| �j� ���ddlm} |�d���d krPt �
� �nt j dt
dd� �fdd �t| �D ��d �� ��fd
d �}���fd d
�� �fdd�}�D ]}|�� � q��r�|d k r҈�||��tt���D ] }|� V q�d S )Nz#expect an iterable of futures, not r )�Queuer r� r7 r8 c s h | ]}t |� d ��qS r� r� r� r r" r# r* U s z as_completed.<locals>.<setcomp>c s* �D ]} | � � � ��d � q��� d S r )r� �
put_nowait�clearr� )r� r& �todor" r# � _on_timeoutX s
z!as_completed.<locals>._on_timeoutc s4 �sd S �� | � � �| � �s0�d k r0��� d S r )�remover� rh r� )r& r� r� r" r# r� ^ s
z$as_completed.<locals>._on_completionc � s$ � � � I d H } | d kr tj�| �� S r )r r r� r_ r� )r& r" r# �
_wait_for_onef s z#as_completed.<locals>._wait_for_one)r r� r rE rG r� ry Zqueuesr� r r0 r: r; r< r� rs r� �ranger� )r� r! r~ r� r� r� r� �_r" )r� r& r! r� r� r# r 7 s*
� r c c s
d V d S r r" r" r" r" r# �__sleep0u s r� c � sr | dkrt � I d H |S |d kr*t�� }ntjdtdd� |�� }|�| tj ||�}z|I d H W �S |�
� X d S )Nr r� r7 r8 ) r� r r r: r; r< r� r� r Z _set_result_unless_cancelledrh )Zdelayr_ r! rx �hr" r" r# r � s$
� �r c C s� t �| �r6|d krt�� }|�| �}|jr2|jd= |S t�| �rb|d k r^|t�| �k r^t d��| S t
� | �r|t t
| �|d�S td��d S )Nr? zRThe future belongs to a different loop than the one specified as the loop argumentr z:An asyncio.Future, a coroutine or an awaitable is required)r rE r r0 r rD r r� r% r� ru Z isawaitabler �_wrap_awaitablerG )Zcoro_or_futurer! r4 r" r" r# r � s
r c c s | � � E d H S r )� __await__)Z awaitabler" r" r# r� � s r� c s* e Zd Zdd�� fdd�
Zdd� Z� ZS )�_GatheringFutureNr c s t � j|d� || _d| _d S )Nr F)rB rC � _children�_cancel_requested)rS �childrenr! rU r" r# rC � s z_GatheringFuture.__init__c C s6 | � � r dS d}| jD ]}|�� rd}q|r2d| _|S rg )r& r� rh r� )rS ZretZchildr" r" r# rh � s
z_GatheringFuture.cancel)ry rz r{ rC rh r} r" r" rU r# r� � s r� F)r! �return_exceptionsc s� |s<| d krt �� } ntjdtdd� | �� ���g � �S � ����fdd�}i }g � d�d�|D ]f}||kr�t|| d�}| d kr�t� |�} ||k r�d|_
�d 7 �|||< |� |� n|| }� � |� qdt
� | d���S )
Nr� r7 r8 c s� �d7 ��� � r$| �� s | �� d S �sd| �� rFt�� }��|� d S | �� }|d k rd��|� d S ��kr�g }� D ]8} | �� r�t�� }n| �� }|d kr�| �� }|�|� qt�jrĈ�t�� � n
�� |� d S )Nr )
r& r� ra r rk rb r_ �appendr� r` )r� rv Zresults�res�r� Z nfinishedZnfuts�outerr� r" r# �_done_callback s4
z gather.<locals>._done_callbackr r Fr )r r0 r: r; r< r� r` r r r% rF rs r� r� )r! r� Zcoros_or_futuresr� Z
arg_to_fut�argr� r" r� r# r
� s:
�
1
r
c st |d k rt jdtdd� t| |d����� r0�S t���}|�� ��fdd�� � �fdd�}��� � ��|� �S ) Nr� r7 r8 r c s\ � � � r | � � s| �� d S | � � r.� �� n*| �� }|d k rJ� �|� n� �| �� � d S r )r� ra rh rb r` r_ )�innerrv �r� r" r# �_inner_done_callbacku s
z$shield.<locals>._inner_done_callbackc s �� � s��� � d S r )r& r� r� )r� r� r" r# �_outer_done_callback� s z$shield.<locals>._outer_done_callback) r: r; r< r r& r r% r� rs )r� r! r� r" )r� r� r� r# r P s �
r c s: t �� �std��tj�� �� ��fdd�}��|� �S )Nz A coroutine object is requiredc
sl zt �t� �d��� W nN ttfk
r2 � Y n6 tk
rf } z��� rT��| � � W 5 d } ~ X Y nX d S )Nr )r Z
_chain_futurer rp ro rq Z set_running_or_notify_cancelrb )rv �rT rx r! r" r# �callback� s
z*run_coroutine_threadsafe.<locals>.callback)r rE rG �
concurrentr �FutureZcall_soon_threadsafe)rT r! r� r" r� r# r
� s
r
c C s t �| � d S r )r, r� �r4 r" r" r# r � s r c C s4 t �| �}|d k r(td|�d|�d���|t | < d S )NzCannot enter into task z while another task z is being executed.�r r r- �r! r4 r r" r" r# r � s
r c C s2 t �| �}||k r(td|�d|�d���t | = d S )Nz
Leaving task z! does not match the current task �.r� r� r" r" r# r � s
r c C s t �| � d S r )r, �discardr� r" r" r# r � s r )r r r r r, r )N)N)N)N)A�__all__Zconcurrent.futuresr� rN r� ru � itertools�typesr: �weakref� r r r r r r �count�__next__rH r r r1 r6 Z _PyFuturer Z_PyTaskZ_asyncio� ImportErrorZ_CTaskr r r r r r� r r� r� r � coroutiner� r r r� r� r� r
r r
ZWeakSetr, r r r r r Z_py_register_taskZ_py_unregister_taskZ_py_enter_taskZ_py_leave_taskZ_c_register_taskZ_c_unregister_taskZ
_c_enter_taskZ
_c_leave_taskr" r" r" r# �<module> s�
#H,>
x?$