File: //opt/imh-python/lib/python3.9/asyncio/__pycache__/futures.cpython-39.opt-2.pyc
a
b�h�6 � @ s� d Z ddlZddlZddlZddlZddlmZ ddlmZ ddlm Z ddlm
Z
ej Z ej Z ej
Z
ejZejd ZG dd � d �ZeZd
d � Zd d
� Zdd� Zdd� Zdd� Zdd� Zdd�dd�Zz ddlZW n ey� Y n 0 ej ZZ dS ))�Future� wrap_future�isfuture� N� )� base_futures)�events)�
exceptions)�format_helpersc @ s� e Zd ZeZdZdZdZdZdZ dZ
dZ dZ dd�dd�Z
ejZdd� Zdd � Zd
d � Zed d
� �Zejdd
� �Zdd� Zdd� Zd*dd�Zdd� Zdd� Zdd� Z dd � Z d d � Z dd �d d!�Z d"d#� Z d$d%� Z!d&d'� Z"d(d)� Z#e#Z$dS )+r NF��loopc C s@ |d u rt �� | _n|| _g | _| j�� r<t�t�d��| _ d S )Nr )
r �get_event_loop�_loop�
_callbacksZ get_debugr �
extract_stack�sys� _getframe�_source_traceback��selfr � r �0/opt/imh-python/lib/python3.9/asyncio/futures.py�__init__G s
�zFuture.__init__c C s d� | jjd�| �� ��S )Nz<{} {}>� )�format� __class__�__name__�join�
_repr_info�r r r r �__repr__Y s
�zFuture.__repr__c C sF | j s
d S | j}| jj� d�|| d�}| jr6| j|d< | j�|� d S )Nz exception was never retrieved)�message� exception�futureZsource_traceback)�_Future__log_traceback�
_exceptionr r r r
Zcall_exception_handler)r �exc�contextr r r �__del__] s �
zFuture.__del__c C s | S �Nr )�cls�typer r r �__class_getitem__m s zFuture.__class_getitem__c C s | j S r( )r# r r r r �_log_tracebackp s zFuture._log_tracebackc C s t |�rtd��d| _d S )Nz'_log_traceback can only be set to FalseF)�bool�
ValueErrorr# )r �valr r r r, t s c C s | j }|d u rtd��|S )Nz!Future object is not initialized.)r
� RuntimeErrorr r r r �get_loopz s zFuture.get_loopc C s2 | j d u rt�� }n t�| j �}| j|_d | _|S r( )�_cancel_messager �CancelledError�_cancelled_exc� __context__�r r% r r r �_make_cancelled_error� s
z Future._make_cancelled_errorc C s, d| _ | jtkrdS t| _|| _| �� dS )NFT)r# �_state�_PENDING�
_CANCELLEDr2 �_Future__schedule_callbacks)r �msgr r r �cancel� s
z
Future.cancelc C sH | j d d � }|sd S g | j d d �< |D ]\}}| jj|| |d� q(d S �N�r& )r r
� call_soon)r Z callbacks�callback�ctxr r r Z__schedule_callbacks� s zFuture.__schedule_callbacksc C s
| j tkS r( )r8 r: r r r r � cancelled� s zFuture.cancelledc C s
| j tkS r( )r8 r9 r r r r �done� s z Future.donec C sF | j tkr| �� }|�| j tkr*t�d��d| _| jd ur@| j�| jS )NzResult is not ready.F) r8 r: r7 � _FINISHEDr �InvalidStateErrorr# r$ �_resultr6 r r r �result� s
z
Future.resultc C s6 | j tkr| �� }|�| j tkr*t�d��d| _| jS )NzException is not set.F)r8 r: r7 rE r rF r# r$ r6 r r r r! � s
zFuture.exceptionr? c C sB | j tkr | jj|| |d� n |d u r.t�� }| j�||f� d S r> )r8 r9 r
r@ � contextvarsZ copy_contextr �append)r �fnr& r r r �add_done_callback� s
zFuture.add_done_callbackc s< � fdd�| j D �}t| j �t|� }|r8|| j d d �< |S )Nc s g | ]\}}|� kr||f�qS r r )�.0�frB �rK r r �
<listcomp>� s �z/Future.remove_done_callback.<locals>.<listcomp>)r �len)r rK Zfiltered_callbacksZ
removed_countr rO r �remove_done_callback� s
�zFuture.remove_done_callbackc C s8 | j tkr t�| j � d| ����|| _t| _ | �� d S )N�: )r8 r9 r rF rG rE r; )r rH r r r �
set_result� s
zFuture.set_resultc C sb | j tkr t�| j � d| ����t|t�r0|� }t|�tu rDtd��|| _t | _ | �
� d| _ d S )NrS zPStopIteration interacts badly with generators and cannot be raised into a FutureT) r8 r9 r rF �
isinstancer* �
StopIteration� TypeErrorr$ rE r; r# )r r! r r r �
set_exception s
zFuture.set_exceptionc c s, | � � sd| _| V | � � s$td��| �� S )NTz await wasn't used with future)rD �_asyncio_future_blockingr0 rH r r r r � __await__ s zFuture.__await__)N)%r �
__module__� __qualname__r9 r8 rG r$ r
r r2 r4 rY r# r r Z_future_repr_infor r r' r+ �propertyr, �setterr1 r7 r= r; rC rD rH r! rL rR rT rX rZ �__iter__r r r r r s@
r c C s* z
| j }W n ty Y n0 |� S | jS r( )r1 �AttributeErrorr
)�futr1 r r r � _get_loop( s
rb c C s | � � r d S | �|� d S r( )rC rT )ra rH r r r � _set_result_unless_cancelled4 s rc c C sX t | �}|tjju r tj| j� S |tjju r8tj| j� S |tjju rPtj| j� S | S d S r( )r* �
concurrent�futuresr3 r �args� TimeoutErrorrF )r% Z exc_classr r r �_convert_future_exc; s rh c C sR |� � r| �� | �� s d S |�� }|d ur<| �t|�� n|�� }| �|� d S r( )rC r= � set_running_or_notify_cancelr! rX rh rH rT )rd �sourcer! rH r r r � _set_concurrent_future_stateG s rk c C sT |� � r d S | � � r |�� n2| �� }|d ur>|�t|�� n| �� }|�|� d S r( )rC r= r! rX rh rH rT )rj �destr! rH r r r �_copy_future_stateV s
rm c s� t ��s t�tjj�s td��t ��s<t�tjj�s<td��t ��rLt��nd �t ��r`t��nd �dd� � ���fdd�}� ���fdd�}��|� ��|� d S ) Nz(A future is required for source argumentz-A future is required for destination argumentc S s" t | �rt|| � n
t| |� d S r( )r rm rk )r" �otherr r r �
_set_statez s z!_chain_future.<locals>._set_statec s2 | � � r.�d u s�� u r"��� n ���j� d S r( )rC r= �call_soon_threadsafe)� destination)� dest_looprj � source_loopr r �_call_check_cancel� s
z)_chain_future.<locals>._call_check_cancelc sJ �� � r �d ur ��� r d S �d u s,��u r8� �| � n��� �| � d S r( )rC Z is_closedrp )rj )ro rr rq rs r r �_call_set_state� s �� z&_chain_future.<locals>._call_set_state)r rU rd re r rW rb rL )rj rq rt ru r )ro rr rq rj rs r �
_chain_futurej s � �
rv r
c C s2 t | �r | S |d u r t�� }|�� }t| |� |S r( )r r r Z
create_futurerv )r" r Z
new_futurer r r r � s
r ) �__all__�concurrent.futuresrd rI �loggingr � r r r r r r9 r: rE �DEBUGZ STACK_DEBUGr Z _PyFuturerb rc rh rk rm rv r Z_asyncio� ImportErrorZ_CFuturer r r r �<module> s:
*