U
e5d]" @ s d Z ddlZddlZddlZddlZddlZddlZddlZddl Z ddl
m Z ddl
m Z ddl
m
Z
ddlmZ 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 */usr/lib64/python3.8/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 s> || _ || _ttd| _t|dd | _t|dd | _ d S )Nr __name__ __qualname__)
genfuncr
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__7 s zCoroWrapper.__iter__c C s | j d S r* r sendr+ r r r __next__: s zCoroWrapper.__next__c C s | j |S r* r- )r valuer r r r. = s zCoroWrapper.sendc C s | j |||S r* )r throw)r typer0 tracebackr r r r1 @ s zCoroWrapper.throwc C s
| j S r* )r closer+ r r r r4 C s zCoroWrapper.closec C s | j jS r* )r gi_framer+ r r r r5 F s zCoroWrapper.gi_framec C s | j jS r* )r
gi_runningr+ r r r r6 J s zCoroWrapper.gi_runningc C s | j jS r* )r gi_coder+ r r r r7 N s zCoroWrapper.gi_codec C s | S r* r r+ r r r __await__R s zCoroWrapper.__await__c C s | j jS r* )r gi_yieldfromr+ r r r r9 U 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__Y 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 sz t jdtdd tr S tr. ntfdd t t
sX }nt fdd}t |_ |S )zDecorator to mark coroutines.
If the coroutine is not yielded from before it is destroyed,
an error message is logged.
zN"@coroutine" decorator is deprecated since Python 3.8, use "async def" instead )
stacklevelc ? sr | |}t |s(t|s(t|tr4|E d H }n:z
|j}W n tk
rR Y n X t|tj j
rn| E d H }|S r* ) r ZisfutureinspectZ isgenerator
isinstancer r8 AttributeError collectionsabc Awaitable)argskwresZ
await_methr r r coroz s
zcoroutine..coroc s@ t | |d}|jr |jd= tdd |_tdd |_|S )NrP r r r )r r r r r )rM kwdswrQ r r r wrapper s zcoroutine..wrapper) warningswarnDeprecationWarningrG r isgeneratorfunction functoolswrapstypesr _DEBUG
_is_coroutine)r rU r rT r r i s"
r c C s t | pt| ddtkS )z6Return True if func is a decorated coroutine function.r^ N)rG r r r^ rP 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_typecacherH _COROUTINE_TYPESlenadd)objr r r r s
r c
sh t | t fdd}dd }d }t| dr:| jr:| j}nt| drP| jrP| j}|| }|sr|| rn| dS |S d }t| dr| jr| j}nt| d r| jr| j}|jpd
}d } r$| jd k r$t
| js$t | j}|d k r|\}}|d kr| d | d
| } n| d| d
| } n@|d k rJ|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 )rQ coro_nameZis_corowrapperr r get_name s z#_format_coroutine..get_namec S sH z| j W S tk
rB z | jW Y S tk
r< Y Y dS X Y nX d S )NF)
cr_runningrI r6 )rQ 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 )rH r re rk r7 r5 rl co_filenamer rG rY r Z_get_function_sourcef_linenoco_firstlineno)
rQ rh rj Z coro_coderf Z
coro_framefilenamelinenosourcer' r rg r r% sJ
r% ) __all__Zcollections.abcrJ rZ rG r r
r3 r\ rV r: r r r logr r r] r r objectr^ r
CoroutineType
GeneratorTyperK Coroutinera setr` r r% r r r r s2 E8