$93 GRAYBYTE WORDPRESS FILE MANAGER $18

B

� f�!�@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)�CoroWrapperNcCsZt�
|
�
st�|
�
st|
�
�
|
|_||_t�t�	d
�
�
|_
t|
dd�|_t|
dd�|_
dS)Nr�__name__�__qualname__)�inspect�isgeneratorr�AssertionError�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)
r!rrr�__iter__6s
zCoroWrapper.__iter__c

Cs|j�
d�
S)
N)r�send)
r!rrr�__next__9s
zCoroWrapper.__next__cCs|j�
|
�
S)
N)rr.)r!�valuerrrr.<s
zCoroWrapper.sendcCs|j�
|
||�S)
N)r�throw)r!�typer0�	tracebackrrrr1?s
zCoroWrapper.throwc

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


Cs|jj
S)
N)r�gi_frame)
r!rrrr5EszCoroWrapper.gi_framec


Cs|jj
S)
N)r�
gi_running)
r!rrrr6IszCoroWrapper.gi_runningc


Cs|jj
S)
N)r�gi_code)
r!rrrr7MszCoroWrapper.gi_codec


Cs|S)
Nr)
r!rrr�	__await__Qs
zCoroWrapper.__await__c


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

dS)
Nrr5r#z was never yielded fromrr�zB
Coroutine object created at (most recent call last, truncated to z last lines):
)
r �f_lasti�joinr3�format_listrZDEBUG_STACK_DEPTH�rstripr	�error)r!rr+�msg�tbrrr�__del__Xs








zCoroWrapper.__del__)
N)NN)r�
__module__rr"r,r-r/r.r1r4�propertyr5r6r7r8r9rBrrrrr#s

rc
sjt�
�
�
r�
St��
�
r�
�nt��
�
�
f
d
d��
�t���
�tsH�}
nt��
�
��
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?sr�||
�
}t�
|�
s(t�|�
s(t|t�r4|EdH}n:y
|j}Wntk
rR


YnXt|tj	j
�rn|�EdH}|S)
N)rZisfuturerr�
isinstancerr8�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)rrr rr)rJ�kwds�
w)rLrrr�wrapper�s



zcoroutine.<locals>.wrapper)	rr�isgeneratorfunction�	functools�wraps�typesr
�_DEBUG�
_is_coroutine)rrOr)rLrrr
hs







r
c

Cst�
|�
pt|d
d�tkS)z6Return True if func is a decorated coroutine function.rUN)rrr rU)
rrrrr�s

rc

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

d
SdSdS)z)Return True if obj is a coroutine object.T�dFN)r2�_iscoroutine_typecacherE�_COROUTINE_TYPES�len�add)
�objrrrr�s



rc

st
t|�
st
�
t|t���f
d
d�}
dd�}d}t|d�rF|jrF|j}nt|d�r\|jr\|j}|
|�
}|s~||�
rz|�d�S|Sd}t|d�r�|jr�|j}nt|d	�r�|jr�|j}|j	p�d
}d}��
r0|j
dk	�
r0t�|j
�
�
s0t
�|j
�
}|dk	r�|\}}|dk�
r|�d|�d
|��}	n|�d|�d
|��}	n@|dk	�
rV|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�hasattrrrr2)rL�	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_runningrFr6)
rLrrr�
is_running�s






z%_format_coroutine.<locals>.is_running�cr_coder7z runningr5�cr_framez<empty co_filename>rz done, defined at r$z running, defined at z running at )rrrErr\rbr7r5rc�co_filenamerrrPrZ_get_function_source�f_lineno�co_firstlineno)
rLr_raZ	coro_coder]Z
coro_frame�filename�lineno�sourcer*r)
r^rr(�sH

	























r()�__all__Zcollections.abcrGrQrrr
r3rSr:rrr�logr	rrTrr
�objectrUr�
CoroutineType�
GeneratorTyperH�	CoroutinerX�setrWrr(rrrr�<module>
s,








E5