$25 GRAYBYTE WORDPRESS FILE MANAGER $67

B

YI~d�!�@s�dZd
dl
Zd
dlZd
dlZd
dlZd
dlZd
dlZd
dlZddl	m
Z

ddl	mZ
ddl	mZ
ddl
mZ
dd	�Ze�ZGd
d�d�Zdd
�Ze�Zdd�ZejejejjefZe�Zdd�Zdd�ZdS))�	coroutine�iscoroutinefunction�iscoroutine�N�
)
�base_futures)
�	constants)
�format_helpers)
�loggercCs"tj
jp tj
jo ttj�d
�
�
S)NZPYTHONASYNCIODEBUG)�sys�flags�dev_mode�ignore_environment�bool�os�environ�get�rr�7/opt/alt/python37/lib64/python3.7/asyncio/coroutines.py�_is_debug_modes
rc@s�eZ
dZddd�
Zdd�Zdd�Zdd	�Zd
d�Zddd
�
Zdd�Z	e
dd��
Ze
dd��
Ze
dd��
Z
dd�Ze
dd��
Zdd�Zd
S)�CoroWrapperNcCs>|
|_||_
t�t�d
�
�
|_t|
dd�|_t|
dd�|_	dS)Nr�__name__�__qualname__)
�gen�funcr�
extract_stackr
�	_getframe�_source_traceback�getattrrr)�selfrrrrr�__init__&s




zCoroWrapper.__init__c
CsJt|�
}
|j
r4|j
d
}|
d|d�d|d��7}
d|jj�d|
�d�S)	N���z
, created at r�
:r�
<�
 �
>)�_format_coroutiner�	__class__r)r�	coro_repr�framerrr�__repr__.s





zCoroWrapper.__repr__c


Cs|S)
Nr)
rrrr�__iter__6s
zCoroWrapper.__iter__c

Cs|j�
d�
S)
N)r�send)
rrrr�__next__9s
zCoroWrapper.__next__cCs|j�
|
�
S)
N)rr+)r�valuerrrr+<s
zCoroWrapper.sendcCs|j�
|
||�S)
N)r�throw)r�typer-�	tracebackrrrr.?s
zCoroWrapper.throwc

Cs
|j�
�S)
N)r�close)
rrrrr1Bs
zCoroWrapper.closec


Cs|jj
S)
N)r�gi_frame)
rrrrr2EszCoroWrapper.gi_framec


Cs|jj
S)
N)r�
gi_running)
rrrrr3IszCoroWrapper.gi_runningc


Cs|jj
S)
N)r�gi_code)
rrrrr4MszCoroWrapper.gi_codec


Cs|S)
Nr)
rrrr�	__await__Qs
zCoroWrapper.__await__c


Cs|jj
S)
N)r�gi_yieldfrom)
rrrrr6TszCoroWrapper.gi_yieldfromc
Cs�t|d
d�}
t|
dd�}|dk	r||j
dkr||�d�}t|dd�}|rrd�t�|�
�
}|dtj�d	�7}||��7}t�	|�

dS)
Nrr2r z was never yielded fromrr�zB
Coroutine object created at (most recent call last, truncated to z last lines):
)
r�f_lasti�joinr0�format_listrZDEBUG_STACK_DEPTH�rstripr	�error)rrr(�msg�tbrrr�__del__Xs








zCoroWrapper.__del__)
N)NN)r�
__module__rrr)r*r,r+r.r1�propertyr2r3r4r5r6r?rrrrr#s

rc
sjt�
�
�
r�
St��
�
r�
�nt��
�
�
f
d
d��
�t���
�tsH�}
nt��
�
��
fdd��
}
t|
_|
S)Nc?sr�||
�
}t�
|�
s(t�|�
s(t|t�r4|EdH}n:y
|j}Wntk
rR


YnXt|tj	j
�rn|�EdH}|S)
N)rZisfuture�inspectZisgenerator�
isinstancerr5�AttributeError�collections�abc�	Awaitable)�args�kwZresZ
await_meth)
rrr�corovs










zcoroutine.<locals>.corocs@t�||
�
�
d
�}|j
r |j
d=t�
dd�|_t�
dd�|_|S)N)
rr rr)rrrrr)rH�kwds�
w)rJrrr�wrapper�s



zcoroutine.<locals>.wrapper)	rBr�isgeneratorfunction�	functools�wraps�typesr
�_DEBUG�
_is_coroutine)rrMr)rJrrr
hs







r
c

Cst�
|�
pt|d
d�tkS)NrS)rBrrrS)
rrrrr�s

rc

Cs@t|�
t
krd
St|t�r8tt
�
dkr4t
�t|�
�

d
SdSdS)NT�dF)r/�_iscoroutine_typecacherC�_COROUTINE_TYPES�len�add)
�objrrrr�s



rc

sh
t|t
���f
d
d�}
dd�}d}t|d�r:|jr:|j}nt|d�rP|jrP|j}|
|�
}|sr||�
rn|�d�S|Sd}t|d�r�|jr�|j}nt|d	�r�|jr�|j}|jp�d
}d}��
r$|jdk	�
r$t	�
|j�
�
s$t�|j�
}|dk	r�|\}}|dk�
r|�d|�d
|��}	n|�d|�d
|��}	n@|dk	�
rJ|j
}|�d|�d
|��}	n|j}|�d|�d
|��}	|	S)Nc
s`�rt�
|jd
i�St|d�r,|jr,|j}
n*t|d�rD|jrD|j}
ndt|�
j�d�}
|
�d�S)Nrrrr"z without __name__>z())rZ_format_callbackr�hasattrrrr/)rJ�	coro_name)
�is_corowrapperrr�get_name�s




z#_format_coroutine.<locals>.get_namec

Ss<y|jSt
k
r6


y|jSt
k
r0


d
SXYnXdS)NF)�
cr_runningrDr3)
rJrrr�
is_running�s






z%_format_coroutine.<locals>.is_running�cr_coder4z runningr2�cr_framez<empty co_filename>rz done, defined at r!z running, defined at z running at )rCrrZr`r4r2ra�co_filenamerrBrNrZ_get_function_source�f_lineno�co_firstlineno)
rJr]r_Z	coro_coder[Z
coro_frame�filename�lineno�sourcer'r)
r\rr%�sF
	























r%)�__all__Zcollections.abcrErOrBrr
r0rQr7rrr�logr	rrRrr
�objectrSr�
CoroutineType�
GeneratorTyperF�	CoroutinerV�setrUrr%rrrr�<module>
s,








E5