$74 GRAYBYTE WORDPRESS FILE MANAGER $52

B

YI~d2�@s�dZd
dl
Zd
dlZd
dlZd
dlZddlmZ
ddlmZ
ddlm	Z	
ej
Z
ejZejZej
Z
ejZejZejZejdZGdd�d�ZeZd	d
�Zdd�Zd
d�Zdd�Zdd�Zdd�
dd�Zyd
dlZWnek
r�


YnXejZZdS))�CancelledError�TimeoutError�InvalidStateError�Future�wrap_future�isfuture�N�
)
�base_futures)
�events)
�format_helpersc@s�eZ
dZeZd
Zd
Zd
Zd
ZdZ	dZ
d
d�
dd�Zej
Zdd�Zdd	�Zed
d��
Zejdd��
Zd
d�Zdd�Zdd�Zdd�Zdd�Zdd�Zdd�Zd
d�
dd�Zdd�Zd d!�Zd"d#�Zd$d%�ZeZ d
S)&rNF)
�loopc

Cs@|
dkrt�
�|_n|
|_g|_|j��r<t�t�d
�
�
|_	dS)Nr)
r
�get_event_loop�_loop�
_callbacksZ	get_debugr�
extract_stack�sys�	_getframe�_source_traceback)�selfr�r�4/opt/alt/python37/lib64/python3.7/asyncio/futures.py�__init__Gs





zFuture.__init__c

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


zFuture.__repr__c
CsF|js
dS|j
}
|jj�d
�|
|d�}|jr6|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_tracebackmszFuture._log_tracebackcCst|
�
rt
d
�
�
d|_dS)Nz'_log_traceback can only be set to FalseF)�bool�
ValueErrorr")r�valrrrr'qs

c
Cs|j}
|
dkrt
d
�
�
|
S)Nz!Future object is not initialized.)r�RuntimeError)rrrrr�get_loopws


zFuture.get_loopc

Cs&d
|_|j
tkrd
St|_
|��
dS)NFT)r"�_state�_PENDING�
_CANCELLED�_Future__schedule_callbacks)
rrrr�cancel~s





z
Future.cancelc
CsL|jdd�}
|
sdSg|jdd�<x"|
D]\}}|j
j|||d
�
q*WdS)N)
r%)rr�	call_soon)rZ	callbacks�callback�ctxrrrZ__schedule_callbacks�s



zFuture.__schedule_callbacksc

Cs
|jt
kS)
N)r-r/)
rrrr�	cancelled�szFuture.cancelledc

Cs
|jt
kS)
N)r-r.)
rrrr�done�szFuture.donec

Cs<|jt
krt�
|jtkr td
�
�
d|_|jdk	r6|j�
|jS)NzResult is not ready.F)r-r/r
�	_FINISHEDrr"r#�_result)
rrrr�result�s









z
Future.resultc

Cs,|jt
krt�
|jtkr td
�
�
d|_|jS)NzException is not set.F)r-r/r
r7rr"r#)
rrrrr �s






zFuture.exception)
r%c
CsB|jt
kr|jj|
||d
�
n |dkr.t��}|j�|
|f�

dS)N)
r%)r-r.rr2�contextvarsZcopy_contextr�append)r�fnr%rrr�add_done_callback�s




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

z/Future.remove_done_callback.<locals>.<listcomp>)r�len)rr<Zfiltered_callbacksZ
removed_countr)
r<r�remove_done_callback�s





zFuture.remove_done_callbackcCs4|jt
krtd
�|j|��
�
|
|_t|_|��
dS)Nz{}: {!r})r-r.rrr8r7r0)rr9rrr�
set_result�s





zFuture.set_resultcCs^|jt
krtd
�|j|��
�
t|
t�r,|
�}
t|
�
tkr@td�
�
|
|_t	|_|�
�
d|_dS)Nz{}: {!r}zPStopIteration interacts badly with generators and cannot be raised into a FutureT)r-r.rr�
isinstance�type�
StopIteration�	TypeErrorr#r7r0r")rr rrr�
set_exception�s









zFuture.set_exceptionc

cs,|��sd
|_
|V
|��s$td�
�
|��S)NTzawait wasn't used with future)r6�_asyncio_future_blockingr+r9)
rrrr�	__await__
s





zFuture.__await__)!r�
__module__�__qualname__r.r-r8r#rrrIr"rr	Z_future_repr_inforrr&�propertyr'�setterr,r1r0r5r6r9r r=rBrCrHrJ�__iter__rrrrr s4



rc
Cs,y
|j}
Wnt
k
r


YnX|
�S|jS)
N)r,�AttributeErrorr)�futr,rrr�	_get_loop
s




rRcCs|��rdS|�
|
�

dS)
N)r5rC)rQr9rrr�_set_result_unless_cancelled
s

rScCsN|
��r|�
�
|��sdS|
��}|dk	r8|�|�

n|
��}|�|�

dS)
N)r5r1Zset_running_or_notify_cancelr rHr9rC)�
concurrent�sourcer r9rrr�_set_concurrent_future_state&
s






rVcCsP|
��rdS|��r|
�
�
n.|��}|dk	r:|
�|�

n|��}|
�|�

dS)
N)r5r1r rHr9rC)rU�destr r9rrr�_copy_future_state5
s





rXcs�t��
st
�tjj�std
�
�
t��
s<t
�tjj�s<td�
�
t��
rLt��
nd�t��
r`t��
nd�
dd���
��fdd�}��
��fdd�}��|�

��|�

dS)	Nz(A future is required for source argumentz-A future is required for destination argumentcSs"t|�
rt
|
|�
n
t||
�
dS)
N)rrXrV)r!�otherrrr�
_set_stateY
s

z!_chain_future.<locals>._set_statec

s2|��r.�dks��kr"�
�
�
n���
j
�

dS)
N)r5r1�call_soon_threadsafe)
�destination)�	dest_looprU�source_looprr�_call_check_cancel_
s



z)_chain_future.<locals>._call_check_cancelc

sJ���r�
dk	r�
�
�rdS�
dks,�
�kr8��|�
n�
���|�
dS)
N)r5Z	is_closedr[)
rU)rZr]r\r^rr�_call_set_statef
s




z&_chain_future.<locals>._call_set_state)rrDrTZfuturesrrGrRr=)rUr\r_r`r)rZr]r\rUr^r�
_chain_futureI
s








	

ra)
rc

Cs2t|�
r|S|
dkrt
��}
|
��}t||�
|S)
N)rr
r
Z
create_futurera)r!rZ
new_futurerrrrs
s





r)�__all__�concurrent.futuresrTr:Zloggingr�r	r
rr
rrrr.r/r7�DEBUGZSTACK_DEBUGrZ	_PyFuturerRrSrVrXrarZ_asyncio�ImportErrorZ_CFuturerrrr�<module>s:










q*