$65 GRAYBYTE WORDPRESS FILE MANAGER $67

3

��2a�a�
@s�
dd
dddddddd	d
ddg
Zd
dl
Zd
dlZd
dlZd
dlZd
dlZddlmZ
ddlm	Z	
ddlm
Z

ddlmZ
ddlmZ
ddl
m
Z

Gdd�dej�ZeZyd
dlZWnek
r�


YnXejZZejjZejjZejjZe
dded�dd��
Zdd�Ze
dd�
dd��
Ze
dd��
Zddd�d d�Ze
d.dd�
d!d��
Zdd�
d"d#�Zee�d<de_[dd�
d$d�Z e
d%d&��
Z!Gd'd(�d(ej�Z"dd)d*�d+d	�Z#dd�
d,d
�Z$d-d�Z%dS)/�Task�FIRST_COMPLETED�FIRST_EXCEPTION�
ALL_COMPLETED�wait�wait_for�as_completed�sleep�async�gather�shield�
ensure_future�run_coroutine_threadsafe�N�
)
�
base_tasks)
�compat)
�
coroutines)
�events)
�futures)
�	coroutinecs�eZ
dZej�ZiZd
Zeddd�
�
Z	eddd�
�
Z
dd�
�f
dd	�
Zej
rTd
d�Zdd
�Zdd�
dd�Zddd�dd�Zdd�Zd�f
dd�	Zdd�Z�ZS)r
TNcCs|
dkrtj
�}
|jj|
�
S)
N)r�get_event_loop�_current_tasks�get)�cls�loop�r�*/opt/alt/python36/lib64/python3.6/tasks.py�current_task.s

zTask.current_taskcs$�dkrtj
���f
d
d�|jD�
S)Nc
sh|]}
|
j�kr|
�qSr)
�_loop)�.0�
t)
rrr�	<setcomp>Bsz!Task.all_tasks.<locals>.<setcomp>)rr�
_all_tasks)rrr)
rr�	all_tasks:s

zTask.all_tasks)
rc
sNt�j
|d
�

|jr|jd=|
|_d|_d|_|jj|j�

|j	j
j|�

dS)N)
rrF���)�super�__init__�_source_traceback�_coro�_fut_waiter�_must_cancelr�	call_soon�_step�	__class__r"�add)�self�coror)
r-rrr&Ds






z
Task.__init__c
CsH|jt
jkr8|jr8|d
d�}
|jr,|j|
d<|jj|
�

t
jj|�

dS)Nz%Task was destroyed but it is pending!)�task�messageZsource_traceback)	Z_staterZ_PENDING�_log_destroy_pendingr'rZcall_exception_handler�Future�__del__)r/�contextrrrr5Ss





zTask.__del__c

Cs
tj
|�
S)
N)rZ_task_repr_info)
r/rrr�
_repr_info^s
zTask._repr_info)
�limitc

Cstj
||
�S)
N)rZ_task_get_stack)r/r8rrr�	get_stackaszTask.get_stack)r8�filec
Cstj
||
|�S)
N)rZ_task_print_stack)r/r8r:rrr�print_stackxs	zTask.print_stackc

Cs4d
|_|j
�rd
S|jdk	r*|jj�r*dSd|_dS)NFT)Z_log_traceback�doner)�cancelr*)
r/rrrr=�s






zTask.cancelcsf|jr t
|
tj�stj�}
d
|_|j}d|_||jj|j<�zy"|
dkrT|j	d�
}n
|j
|
�
}Wn�tk
r�
}

z.|jr�d
|_|jtj��

n|j
|
j�

WYdd}
~
X�
n�tjk
r�


t�j�
Y�
n|tk
r�
}

z|j|
�

WYdd}
~
X�
nPtk
�
r(
}

z|j|
�

�WYdd}
~
X�
n Xt|dd�}|dk	�
r�|j|jk	�
rl|jj|jtdj||��
�
n||�
r�||k�
r�|jj|jtdj|�
�
�
n2d
|_|j|j�

||_|j�
r�|jj��
r�d
|_n|jj|jtdj||��
�
n^|dk�r|jj|j�

nDtj|�
�r.|jj|jtdj||��
�
n|jj|jtdj|�
�
�
Wd|jjj|j�

d}XdS)NF�_asyncio_future_blockingz6Task {!r} got Future {!r} attached to a different loopz!Task cannot await on itself: {!r}z;yield was used instead of yield from in task {!r} with {!r}zIyield was used instead of yield from for generator in task {!r} with {!r}zTask got bad yield: {!r})r*�
isinstancer�CancelledErrorr(r)r-rr�send�throw�
StopIteration�
set_exception�
set_result�valuer%r=�	Exception�
BaseException�getattrr+r,�RuntimeError�formatr>�add_done_callback�_wakeup�inspectZisgenerator�pop)r/�excr0�resultZblocking)
r-rrr,�s~


















































z
Task._stepcCsJy|
j�
Wn,t
k
r8
}
z|j|�

WYdd}~Xn
X|j�
d}dS)
N)rQrGr,)r/�futurerPrrrrM�s



zTask._wakeup)
N)
N)
N)�__name__�
__module__�__qualname__�weakref�WeakSetr"rr3�classmethodrr#r&rZPY34r5r7r9r;r=r,rM�
__classcell__rr)
r-rr
s 


	
!T)r�timeout�return_whenc
#s�tj
|�
stj|�
r&td
t|�
j�
�
|s2td�
�
|tt	t
fkrNtdj|�
�
�
�dkr^tj
���f
dd�t|�
D�
}t|||��EdHS)Nz expect a list of futures, not %sz#Set of coroutines/Futures is empty.zInvalid return_when value: {}c
sh|]}
t|
�d��qS)
)
r)
r)r�
f)
rrrr!7
szwait.<locals>.<setcomp>)r�isfuturer�iscoroutine�	TypeError�typerS�
ValueErrorrrrrKrr�set�_wait)�fsrrZr[r)
rrr
s





c
Gs|j�s|j
d�

dS)
N)r<rE)�waiter�argsrrr�_release_waiter<
s

rg)
rc
cs�|dkrtj
�}|
dkr"|EdHS|j�}|j|
t|�}tjt|�}t||d
�}|j|�

zhy|EdH
Wn*t	j
k
r�


|j|�

|j�
�YnX|j
�r�|j�S|j|�

|j�
t	j��
Wd|j�
XdS)N)
r)rr�
create_future�
call_laterrg�	functools�partialrrLrr@�remove_done_callbackr=r<rQ�TimeoutError)�futrZrre�timeout_handle�cbrrrrA
s,
















c#s�|j��d�|
dk	r"|j
|
t���t|�
���
��fd
d�}x|D]}|j|�

qBWz�EdH
Wd�dk	rt�j�
Xt�t�}}x4|D],}|j|�

|j�r�|j	|�

q�|j	|�

q�W||fS)Nc

s\�d
8��dk
s6�
tks6�
t
krX|j�rX|j�dk	rX�dk	rF�j�
�j�sX�jd�

dS)Nrr)rr�	cancelled�	exceptionr=r<rE)
r\)�counterr[rorerr�_on_completion|
s







z_wait.<locals>._on_completion)
rhrirg�lenrLr=rbrlr<r.)rdrZr[rrtr\r<�pendingr)rsr[rorerrco
s&















rc)rrZc
#s�tj
|�
stj|�
r&td
t|�
j�
�
�dk	r2�ntj���f
dd�t	|�
D�
�ddl
m}
|�d�
�
d���
�fdd�}�
��fd	d
��t�
f
dd��
}x�D]}|j
��

q�W�r�|dk	rʈj||��xtt��
�
D]}|�V
q�WdS)
Nz expect a list of futures, not %sc
sh|]}
t|
�d��qS)
)
r)
r)rr\)
rrrr!�
szas_completed.<locals>.<setcomp>r)
�Queue)
rc
s.x �D]}|j��

�
j
d�

qW�j�
dS)
N)rl�
put_nowait�clear)
r\)rtr<�todorr�_on_timeout�
s





z!as_completed.<locals>._on_timeoutc

s6�sdS�j|�

�j
|�

�r2�
dk	r2�
j�
dS)
N)�removerxr=)
r\)r<rorzrrrt�
s







z$as_completed.<locals>._on_completionc
3s$�j�EdH}|dkrt
j�
|j�S)
N)rrrmrQ)
r\)
r<rr�
_wait_for_one�
s

z#as_completed.<locals>._wait_for_one)rr]rr^r_r`rSrrrbZqueuesrwrrLri�rangeru)rdrrZrwr{r}r\�
_r)rtr<rrorzrr�
s 












c

csX|d
krdV
|
S|dkr"tj
�}|j�}|jj|tj||
�}z
|EdHS|j�
XdS)Nr)rrrhrrirZ_set_result_unless_cancelledr=)ZdelayrQrrR�
hrrrr�
s









c

Cstj
d
tdd�
t||
d�S)Nz;asyncio.async() function is deprecated, use ensure_future()�)
�
stacklevel)
r)�warnings�warn�DeprecationWarningr)�coro_or_futurerrrr�async_�
s

r�c

Cs�tj
|�
r(|
dk	r$|
|jk	r$td
�
�
|Stj|�
r^|
dkrBtj�}
|
j|�
}|j	rZ|j	d=|St
jr~tj
|�
r~tt|�
|
d�Std�
�
dS)Nz$loop argument must agree with Futurer)
rz:An asyncio.Future, a coroutine or an awaitable is requiredr$)rr]rrarr^rrZcreate_taskr'rZPY35rNZisawaitabler�_wrap_awaitabler_)r�rr1rrrr�
s














c

cs|j�EdHS)
N)
�	__await__)
Z	awaitablerrrr�sr�cs*eZ
dZd
d�
�f
dd�
Zdd�Z�ZS)�_GatheringFutureN)
rc
st�j
|d
�

|
|_d|_dS)N)
rF)r%r&�	_children�_cancel_requested)r/�childrenr)
r-rrr&$s


z_GatheringFuture.__init__c
Cs:|j�rd
Sd
}
x|j
D]}|j�rd}
qW|
r6d|_|
S)NFT)r<r�r=r�)r/�retZchildrrrr=)s







z_GatheringFuture.cancel)rSrTrUr&r=rYrr)
r-rr�sr�F)r�return_exceptionscs
|s*|dkrtj
�}|j���jg�

�Si�xjt|�
D]^}tj|�
sht||d
�}|dkr`|j}d|_	n&|}|dkr||j}n|j|k	r�t
d�
�
|�|<q8W�f
dd�|D�
}t|�
�
t||d
��d�dg
�
��
����fdd�}x&t
|�
D]\}}|jtj||��

q�W�S)	N)
rFz)futures are tied to different event loopsc
sg|]}
�|
�qSrr)r�arg)
�
arg_to_futrr�
<listcomp>hszgather.<locals>.<listcomp>rcs��j�r|
j
�s|
j�
dS|
j
�r@tj�}�sl�j|�

dSn,|
jdk	rf|
j�}�sl�j|�

dSn|
j}|�|<�
d
7�
�
�kr��jr��jtj��

n
�j	��

dS)Nr)
r<rqrrrr@rDZ
_exceptionZ_resultr�rE)�
irn�res)�	nchildren�	nfinished�outer�resultsr�rr�_done_callbackns*


















zgather.<locals>._done_callback)rrrhrErbrr]rrr3rarur��	enumeraterLrjrk)rr�Zcoros_or_futuresr�rnr�r�r�r)r�r�r�r�r�r�rr
8s8
























c

s@t||
d
�}|j
�r|S|j}
|
j���f
dd�}|j|�

�S)N)
rc
s\�j�r|j�s|j
�
dS|j�r.�j�
n*|j
�}
|
dk	rJ�j|
�

n�j|j��

dS)
N)rqrrr=rDrErQ)�innerrP)
r�rrr��s






zshield.<locals>._done_callback)rr<rrhrL)r�rr�r�r)
r�rr�s




cs:tj
��
std
�
�
tjj��
��
�fdd�}�j|�

�
S)NzA coroutine object is requiredc
sTytj
t��d
��
�
Wn6tk
rN
}
z�
j�r<�
j|�

�WYdd}~XnXdS)N)
r)rZ
_chain_futurerrGZset_running_or_notify_cancelrD)
rP)r0rRrrr�callback�s






z*run_coroutine_threadsafe.<locals>.callback)rr^r_�
concurrentrr4Zcall_soon_threadsafe)r0rr�r)r0rRrrr
�s





)
N)&�__all__�concurrent.futuresr�rjrNr�rV�rrrrrrr4r
Z_PyTaskZ_asyncio�ImportErrorZ_CTaskrrrrrgrrcrrr��globalsrSrr�r�r
rr
rrrr�<module>sX












s







--8




W5