B
Yg> @ s d Z ddlZddlZddlZddlZddlZddlZddlZddl m
Z
ddl m Z ddl m Z ddl
mZ dd Ze ZG d
d d Zd d
Ze Zdd ZejejejjefZe Z dd Z dd Z dS )) coroutineiscoroutinefunction iscoroutine N ) base_futures) constants)format_helpers)loggerc C s" t jjp t jj o ttjdS )NZPYTHONASYNCIODEBUG)sysflagsdev_modeignore_environmentboolosenvironget r r 7/opt/alt/python37/lib64/python3.7/asyncio/coroutines.py_is_debug_mode s r c @ s e Zd Zd ddZdd Zdd Zdd Zd
d Zd d d
Zdd Z e
dd Z e
dd Z e
dd Z
dd Ze
dd Zdd ZdS ) CoroWrapperNc C sZ t |s t |s t||| _|| _tt d| _
t |dd | _ t |dd | _
d S )Nr __name__ __qualname__)inspect isgeneratorr AssertionErrorgenfuncr
extract_stackr
_getframe_source_tracebackgetattrr r )selfr r r r r __init__& s zCoroWrapper.__init__c C sJ t | }| jr4| jd }|d|d d|d 7 }d| jj d| dS ) Nz
, created at r :r < >)_format_coroutiner __class__r )r! coro_reprframer r r __repr__. s
zCoroWrapper.__repr__c C s | S )Nr )r! r r r __iter__6 s zCoroWrapper.__iter__c C s | j d S )N)r send)r! r r r __next__9 s zCoroWrapper.__next__c C s | j |S )N)r r. )r! valuer r r r. < s zCoroWrapper.sendc C s | j |||S )N)r throw)r! typer0 tracebackr r r r1 ? s zCoroWrapper.throwc C s
| j S )N)r close)r! r r r r4 B s zCoroWrapper.closec C s | j jS )N)r gi_frame)r! r r r r5 E s zCoroWrapper.gi_framec C s | j jS )N)r
gi_running)r! r r r r6 I s zCoroWrapper.gi_runningc C s | j jS )N)r gi_code)r! r r r r7 M s zCoroWrapper.gi_codec C s | S )Nr )r! r r r __await__Q s zCoroWrapper.__await__c C s | j jS )N)r gi_yieldfrom)r! r r r r9 T s zCoroWrapper.gi_yieldfromc C s t | dd }t |dd }|d k r||jdkr|| d}t | dd}|rrdt|}|dtj d 7 }|| 7 }t | d S )
Nr r5 r# z was never yielded fromr r zB
Coroutine object created at (most recent call last, truncated to z last lines):
)
r f_lastijoinr3 format_listr ZDEBUG_STACK_DEPTHrstripr error)r! r r+ msgtbr r r __del__X s
zCoroWrapper.__del__)N)NN)r
__module__r r" r, r- r/ r. r1 r4 propertyr5 r6 r7 r8 r9 rB r r r r r # s
r c sj t rS t r ntfdd t tsH }nt fdd}t|_|S )zDecorator 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|tr4|E d H }n:y
|j}W n tk
rR Y n X t|tj j
rn| E d H }|S )N) r Zisfuturer r
isinstancer r8 AttributeError collectionsabc Awaitable)argskwZresZ
await_meth)r r r corov s
zcoroutine..coroc s@ t | |d}|jr |jd= tdd |_tdd |_|S )N)r r# r r )r r r r r )rJ kwdsw)rL r r r wrapper s zcoroutine..wrapper) r r isgeneratorfunction functoolswrapstypesr _DEBUG
_is_coroutine)r rO r )rL r r r h s
r c C s t | pt| ddtkS )z6Return True if func is a decorated coroutine function.rU N)r r r rU )r r r r r s
r c C s@ t | tkrdS t| tr8ttdk r4tt | dS dS dS )z)Return True if obj is a coroutine object.Td FN)r2 _iscoroutine_typecacherE _COROUTINE_TYPESlenadd)objr r r r s
r c
st t | s tt| t fdd}dd }d }t| drF| jrF| j}nt| dr\| jr\| j}|| }|s~|| rz| dS |S d }t| dr| jr| j}nt| d r| jr| j}|j pd
}d } r0| j
d k r0t | j
s0t
| j
}|d k r|\}}|d kr| d | d
| } n| d| d
| } n@|d k rV|j}| d| d
| } n|j}| d | d
| } | S )Nc s` rt | jdi S t| dr,| jr,| j}n*t| drD| jrD| j}ndt| j d}| dS )Nr r r r% z without __name__>z())r Z_format_callbackr hasattrr r r2 )rL coro_name)is_corowrapperr r get_name s z#_format_coroutine..get_namec S s< y| j S tk
r6 y| jS tk
r0 dS X Y nX d S )NF)
cr_runningrF r6 )rL r r r
is_running s z%_format_coroutine..is_runningcr_coder7 z runningr5 cr_framezr z done, defined at r$ z running, defined at z running at )r r rE r r\ rb r7 r5 rc co_filenamer r rP r Z_get_function_sourcef_linenoco_firstlineno)
rL r_ ra Z coro_coder] Z
coro_framefilenamelinenosourcer* r )r^ r r( sH
r( ) __all__Zcollections.abcrG rQ r r r
r3 rS r: r r r logr r rT r r objectrU r
CoroutineType
GeneratorTyperH CoroutinerX setrW r r( r r r r s, E5