$31 GRAYBYTE WORDPRESS FILE MANAGER $73



��Yf�)�@s(dd
dgZddl
Z
ddlZddlZddlZddlZddlZddlZddlm	Z	
ddlm
Z

ddlmZ
dd	lm
Z

ejd
Zejjo�eejjd�
�
ZyejZejZWnek
r



dZdZYn
Xy
ejZWnek
r9



dd
�ZYn
XyddlmZm Z!
Wne"k
rr



dZZ!Yn
Xdd�Z#e#�Z$[#dd�Z%Gdd�d�Z&dd�Ze'�Z(dd
�Zej)e&fZ*edk	r�
e*ef
7Z*edk	ref
e*Z*dd�Z+dd�Z,dS)�	coroutine�iscoroutinefunction�iscoroutine�N�
)
�compat)
�events)
�futures)
�loggerZ
YIELD_FROMZPYTHONASYNCIODEBUGc


Csd
S)NF�)
�funcr
r
�7/opt/alt/python35/lib64/python3.5/asyncio/coroutines.py�<lambda>.sr
)�	Coroutine�	AwaitablecCsaGd
d�d�}dd�}
d}|�}|
|�
}t|�

|j
|�

|j|f
kS)	Nc@s@eZ
dZd
d�Zdd�Zdd�Zdd�Zd	S)
z!has_yield_from_bug.<locals>.MyGenc

Ss
d|_dS)
N)
�	send_args)
�selfr
r
r�__init__:s
z*has_yield_from_bug.<locals>.MyGen.__init__c


Ss|S)
Nr
)
rr
r
r�__iter__<s
z*has_yield_from_bug.<locals>.MyGen.__iter__c


Ssd
S)N�*r
)
rr
r
r�__next__>s
z*has_yield_from_bug.<locals>.MyGen.__next__c
Ws
|
|_dS)
N)
r)rZwhatr
r
r�send@s
	
z&has_yield_from_bug.<locals>.MyGen.sendN)�__name__�
__module__�__qualname__rrrrr
r
r
r�MyGen9s
rc

ss
|EdH
dS)
Nr
)
�genr
r
r�yield_from_genCs
z*has_yield_from_bug.<locals>.yield_from_genr��)rrr)�nextrr)rr�valuer�coror
r
r�has_yield_from_bug8s


	





r"c

Cs
t|d�S)
N)
�CoroWrapper)
rr
r
r�
debug_wrapperOsr$c@s3
eZ
dZd
dd�
Zdd�Zdd�Zdd	�ZerTd
d�Zndd�Zd
d
d
d�Z	dd�Z
edd��
Zedd��
Z
edd��
Zejr#
dd�Zedd��
Zedd��
Zedd��
Zedd ��
Zed!d"��
Zd#d$�Zd
S)%r#NcCs[|
|_||_
tjtjd
�
�
|_t|
dd�|_t|
dd�|_	dS)Nrrr)
rr�	traceback�
extract_stack�sys�	_getframe�_source_traceback�getattrrr)rrrr
r
rrZs
	
	


zCoroWrapper.__init__c
CsRt|�
}
|j
r>|j
d}|
d|d|d
f7}
d|jj|
fS)Nrz, created at %s:%srz<%s %s>���)�_format_coroutiner)�	__class__r)r�	coro_repr�framer
r
r�__repr__bs


	



zCoroWrapper.__repr__c


Cs|S)
Nr
)
rr
r
rris
zCoroWrapper.__iter__c

Cs|jj
d�
S)
N)rr)
rr
r
rrls
zCoroWrapper.__next__c
GsHtj
�}|j}|jj|jtkr8|
d
}
|jj|
�
S)Nr)	r'r(�f_back�f_code�co_code�f_lasti�_YIELD_FROMrr)rr r/Zcallerr
r
rrts


	


zCoroWrapper.sendcCs|jj
|
�
S)
N)rr)rr r
r
rr|s
cCs|jj
|
||�S)
N)r�throw)r�typer r%r
r
rr6s
zCoroWrapper.throwc


Cs
|jj
�S)
N)r�close)
rr
r
rr8�s
zCoroWrapper.closec


Cs
|jj
S)
N)r�gi_frame)
rr
r
rr9�szCoroWrapper.gi_framec


Cs
|jj
S)
N)r�
gi_running)
rr
r
rr:�szCoroWrapper.gi_runningc


Cs
|jj
S)
N)r�gi_code)
rr
r
rr;�szCoroWrapper.gi_codec
Cs@t|j
d
d�}
|
dk	r<tdj|j
|
��
�
|S)N�cr_awaitz;Cannot await on coroutine {!r} while it's awaiting for {!r})r*r�RuntimeError�format)rr<r
r
r�	__await__�s





zCoroWrapper.__await__c


Cs
|jj
S)
N)r�gi_yieldfrom)
rr
r
rr@�szCoroWrapper.gi_yieldfromc


Cs
|jj
S)
N)rr<)
rr
r
rr<�szCoroWrapper.cr_awaitc


Cs
|jj
S)
N)r�
cr_running)
rr
r
rrA�szCoroWrapper.cr_runningc


Cs
|jj
S)
N)r�cr_code)
rr
r
rrB�szCoroWrapper.cr_codec


Cs
|jj
S)
N)r�cr_frame)
rr
r
rrC�szCoroWrapper.cr_framec
Cs�t|d
d�}
t|
dd�}|dkrBt|
dd�}|dk	r�|j
d	kr�d|}t|df�}|r�djtj|�
�
}|d7}||j�7}tj|�

dS)
Nrr9rCrz%r was never yielded fromr)�z6
Coroutine object created at (most recent call last):
r+)r*r4�joinr%�format_list�rstripr	�error)rrr/�msg�tbr
r
r�__del__�s











zCoroWrapper.__del__)rrrrr0rr�_YIELD_FROM_BUGrr6r8�propertyr9r:r;rZPY35r?r@r<rArBrCrKr
r
r
rr#Ws(	r#c
s�t�
�
r�
St
j�
�
r(�
�n!tj�
�
�
f
d
d��
�tsstdkrd�}
q�t��
}
n$tj�
�
��
fdd��
}
t|
_|
S)z�Decorator to mark coroutines.

    If the coroutine is not yielded from before it is destroyed,
    an error message is logged.
    c?s��||
�}tj
|�
s<tj|�
s<t|t�rJ|EdH}nKtdk	r�y
|j}Wntk
rw


YnXt|t�r�|�EdH}|S)
N)	rZisfuture�inspectZisgenerator�
isinstancer#�
_AwaitableABCr?�AttributeError)�args�kw�resZ
await_meth)
rr
rr!�s










zcoroutine.<locals>.coroNcs\t�||
�d
�
�

}|j
r.|j
d=t�
dd�|_t�
dd�|_|S)Nrrrrr+)r#r)r*rr)rR�kwds�
w)r!rr
r�wrapper�s
	



zcoroutine.<locals>.wrapper)�_inspect_iscoroutinefunctionrN�isgeneratorfunction�	functools�wraps�_DEBUG�_types_coroutine�
_is_coroutine)rrWr
)r!rrr
�s
	!

	$
	
c

Cs"t|d
d�t
kp!t|�
S)z6Return True if func is a decorated coroutine function.r^N)r*r^rX)
rr
r
rr�s
c

Cs
t|t
�S)
z)Return True if obj is a coroutine object.)rO�_COROUTINE_TYPES)
�objr
r
rr
sc

"Csft|d
�r�t|d�r�t
|dt
|dt|�
j��}
dj|
�
}
d}y
|j}Wn4tk
r�


y
|j}Wntk
r�


Yn
XYn
X|r�dj|
�
S|
Sd}
t|t	�r�|j
}|j}
|
dk	r
dj|
�
}
n|}|
dkr#
tj
|fi�}
y
|j}Wntk
rM



|j}Yn
Xy
|j}Wntk
rx



|j}Yn
X|j}d}t|t	�rtj|j
�
r|j
dk	rtj|j
�
}|dk	r�
|\}}|dkrd	|
||f}	qbd
|
||f}	nG|dk	rF|j}d|
||f}	n|j}d	|
||f}	|	S)NrBr;rrz{}()Fz
{} runningrz%s done, defined at %s:%sz%s running, defined at %s:%sz%s running at %s:%s)�hasattrr*r7rr>rArQr:rOr#rrrZ_format_callbackr;rBr9rC�co_filenamerNrYZ_get_function_source�f_lineno�co_firstlineno)
r!Z	coro_nameZrunningrZ	coro_codeZ
coro_frame�filename�lineno�sourcer.r
r
rr,
sl 


















	
	












	












	

	

r,)-�__all__rZrNZopcode�osr'r%�typesrDrrr�logr	Zopmapr5�flags�ignore_environment�bool�environ�getr\r
r]�
CoroutineTypeZ_types_CoroutineTyperQrrX�collections.abcrZ
_CoroutineABCrrP�ImportErrorr"rLr$r#�objectr^�
GeneratorTyper_rr,r
r
r
r�<module>
sX













	











	
i: