File manager

o

0�ik7�@s
	dZd
dl
Zd
dlZd
dlZd
dlZd
dlmZ
ddlm	Z	
ddlm
Z

ddlmZ
ddlmZ
e	j
Z
e	jZe	jZe	jZejdZGd	d
�d
�ZeZdd�Zd
d�Zdd�Zdd�Zdd�Zdd�Zdd�
dd�Zzd
dlZWn
eyz


YdSwejZZdS))�Future�wrap_future�isfuture�N)
�GenericAlias�
)
�base_futures)
�events)
�
exceptions)
�format_helpersc@s�eZ
dZ	eZd
Zd
Zd
Zd
Zd
Z	d
Z
dZdZd
d�
dd�Z
ejZdd�Zdd	�Zee�
Zed
d��
Zejdd��
Zd
d�Zdd�Zd(dd�
Zdd�Zdd�Zdd�Zdd�Zdd�Z d
d�
dd�Z!d d!�Z"d"d#�Z#d$d%�Z$d&d'�Z%e%Z&d
S))r
NF�
�loopc

CsF	|
durt�
�|_n|
|_g|_|j��r!t�t�d
�
�
|_	dSdS)Nr)
r�_get_event_loop�_loop�
_callbacksZ	get_debugr
�
extract_stack�sys�	_getframe�_source_traceback��selfr�r�6/opt/alt/python310/lib64/python3.10/asyncio/futures.py�__init__Hs







��zFuture.__init__c

Csd
�|j
jd�|���
�S)Nz<{} {}>�
 )�format�	__class__�__name__�join�
_repr_info�
rrrr�__repr__Zs


�zFuture.__repr__c
CsF|jsdS|j
}
|jj�d
�|
|d�}|jr|j|d<|j�|�

dS)Nz exception was never retrieved)�message�	exception�futureZsource_traceback)�_Future__log_traceback�
_exceptionrrrrZcall_exception_handler)r�exc�contextrrr�__del__^s



�


zFuture.__del__c


Cs|jS�
N)
r$rrrr�_log_tracebackpszFuture._log_tracebackcCs|
rtd
�
�
d|_
dS)Nz'_log_traceback can only be set to FalseF)�
ValueErrorr$)r�valrrrr*ts


c
Cs	|j}
|
durt
d
�
�
|
S)Nz!Future object is not initialized.)r�RuntimeErrorrrrr�get_loopzs





zFuture.get_loopc
Cs4	|jdurt
��}
nt
�|j�
}
|j|
_d|_|
Sr))�_cancel_messager	�CancelledError�_cancelled_exc�__context__�rr&rrr�_make_cancelled_error�s





zFuture._make_cancelled_errorcCs.	d
|_|j
tkrd
St|_
|
|_|��
dS)NFT)r$�_state�_PENDING�
_CANCELLEDr/�_Future__schedule_callbacks)r�msgrrr�cancel�s







z
Future.cancelc
CsJ	|jdd�}
|
sdSg|jdd�<|
D]
\}}|j
j|||d
�
qdS�N�
r')rr�	call_soon)rZ	callbacks�callback�ctxrrrZ__schedule_callbacks�s




�zFuture.__schedule_callbacksc

Cs	|jt
kSr))r5r7rrrr�	cancelled�s


zFuture.cancelledc

Cs	|jt
kSr))r5r6rrrr�done�s

zFuture.donec
CsP	|jt
kr|��}
|
�
|jtkrt�d
�
�
d|_|jdu
r%|j�|j	�
�
|j
S)NzResult is not ready.F)r5r7r4�	_FINISHEDr	�InvalidStateErrorr$r%�with_traceback�
_exception_tb�_resultr3rrr�result�s












z
Future.resultc
Cs8	|jt
kr|��}
|
�
|jtkrt�d
�
�
d|_|jS)NzException is not set.F)r5r7r4rBr	rCr$r%r3rrrr"�s









zFuture.exceptionr<c
CsF	|jt
kr|jj|
||d
�
dS|durt��}|j�|
|f�

dSr;)r5r6rr=�contextvarsZcopy_contextr�append)r�fnr'rrr�add_done_callback�s




zFuture.add_done_callbackcs>	�f
d
d�|jD�
}t
|j�
t
|�
}|r||jdd�<|S)Nc
s g|]\}
}|
�kr|
|f�qSrr)�.0�
fr?�
rJrr�
<listcomp>�s


�z/Future.remove_done_callback.<locals>.<listcomp>)r�len)rrJZfiltered_callbacksZ
removed_countrrNr�remove_done_callback�s


�


zFuture.remove_done_callbackcCs:	|jt
krt�|j�d
|���
�
|
|_t|_|��
dS)N�: )r5r6r	rCrFrBr8)rrGrrr�
set_result�s





zFuture.set_resultcCsl	|jt
krt�|j�d
|���
�
t|
t�r|
�}
t|
�
tur#td�
�
|
|_|
j	|_
t|_|��
d|_
dS)NrRzPStopIteration interacts badly with generators and cannot be raised into a FutureT)r5r6r	rC�
isinstance�type�
StopIteration�	TypeErrorr%�
__traceback__rErBr8r$)rr"rrr�
set_exception
s












zFuture.set_exceptionc

cs.�|��sd
|_
|V
|��std�
�
|��S)NTzawait wasn't used with future)rA�_asyncio_future_blockingr-rGrrrr�	__await__
s�





zFuture.__await__r))'r�
__module__�__qualname__r6r5rFr%rrr/r1rZr$rrZ_future_repr_inforr r(�classmethodr�__class_getitem__�propertyr*�setterr.r4r:r8r@rArGr"rKrQrSrYr[�__iter__rrrrr
sD










r
c
Cs&z|j}
W|
�St
y


Y|jSwr))r.�AttributeErrorr)�futr.rrr�	_get_loop)
s
�
�recCs	|��rdS|�
|
�

dSr))r@rS)rdrGrrr�_set_result_unless_cancelled5
s



rfc
CsTt|�
}
|
t
jjurtj|j�S|
t
jjurtj|j�S|
t
jjur(tj|j�S|Sr))rU�
concurrent�futuresr0r	�args�TimeoutErrorrC)r&Z	exc_classrrr�_convert_future_exc<
s






rkcCsV	|
��r	|�
�
|��sdS|
��}|du
r |�t|�
�

dS|
��}|�|�

dSr))r@r:Zset_running_or_notify_cancelr"rYrkrGrS)rg�sourcer"rGrrr�_set_concurrent_future_stateH
s







rmcCsZ	|
��rdS|��r|
�
�
dS|��}|du
r"|
�t|�
�

dS|��}|
�|�

dSr))r@r:r"rYrkrGrS)rl�destr"rGrrr�_copy_future_stateW
s





rocs�	t��
st
�tjj�std
�
�
t��
st
�tjj�std�
�
t��
r't��
n
d�t��
r1t��
n
d�
dd���
��fdd�}��
��fdd�}��|�

��|�

dS)	Nz(A future is required for source argumentz-A future is required for destination argumentcSs$t|�
rt
|
|�
dSt||
�
dSr))rrorm)r#�otherrrr�
_set_state{
s

z!_chain_future.<locals>._set_statec

s8|��r�dus��ur�
�
�
dS���
j
�

dSdSr))r@r:�call_soon_threadsafe)
�destination)�	dest_looprl�source_looprr�_call_check_cancel�
s



�z)_chain_future.<locals>._call_check_cancelc

sX���r�
du
r�
�
�rdS�
dus�
�ur��|�
dS�
�
�r#dS�
���|�
dSr))r@Z	is_closedrr)
rl)rqrtrsrurr�_call_set_state�
s






z&_chain_future.<locals>._call_set_state)rrTrgrhr
rWrerK)rlrsrvrwr)rqrtrsrlrur�
_chain_futurek
s 

�

�



rxrc

Cs4	t|�
r|S|
durt
��}
|
��}t||�
|Sr))rrr
Z
create_futurerx)r#rZ
new_futurerrrr�
s







r)�__all__Zconcurrent.futuresrgrHZloggingr�typesr�rrr	r
rr6r7rB�DEBUGZSTACK_DEBUGr
Z	_PyFuturererfrkrmrorxrZ_asyncio�ImportErrorZ_CFuturerrrr�<module>
sB










,



�