o
0i]" @ 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 jjpt jj ottjdS )NZPYTHONASYNCIODEBUG)sysflagsdev_modeignore_environmentboolosenvironget r r 9/opt/alt/python310/lib64/python3.10/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 |st |sJ ||| _|| _ttd| _ t
|dd | _ t
|dd | _ d S )Nr __name__ __qualname__)
inspect isgeneratorr genfuncr
extract_stackr
_getframe_source_tracebackgetattrr r )selfr r r r r __init__' s zCoroWrapper.__init__c C sJ t | }| jr| 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 Nr r r r r __iter__7 zCoroWrapper.__iter__c C s | j d S r- r sendr. r r r __next__: zCoroWrapper.__next__c C s | j |S r- r1 )r valuer r r r2 = r4 zCoroWrapper.sendc C s | j |||S r- )r throw)r typer5 tracebackr r r r6 @ s zCoroWrapper.throwc C s
| j S r- )r closer. r r r r9 C s
zCoroWrapper.closec C | j jS r- )r gi_framer. r r r r; F zCoroWrapper.gi_framec C r: r- )r
gi_runningr. r r r r= J r< zCoroWrapper.gi_runningc C r: r- )r gi_coder. r r r r> N r< zCoroWrapper.gi_codec C r, r- r r. r r r __await__R r0 zCoroWrapper.__await__c C r: r- )r gi_yieldfromr. r r r r@ U r< zCoroWrapper.gi_yieldfromc C s t | dd }t |dd }|d ur@|jdkrB| d}t | dd}|r9dt|}|dtj d 7 }|| 7 }t | d S d S d S )
Nr r; r" z was never yielded fromr r zB
Coroutine object created at (most recent call last, truncated to z last lines):
)
r f_lastijoinr8 format_listr ZDEBUG_STACK_DEPTHrstripr error)r r r* msgtbr r r __del__Y s
zCoroWrapper.__del__r- )NN)r
__module__r r! r+ r/ r3 r2 r6 r9 propertyr; r= r> r? r@ rI r r r r r $ s$
r c sz t jdtdd trS tr n tfdd t t
s, }n t 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 ? sz | i |}t |st|st|tr |E d H }|S z|j}W n
ty- Y |S w t|tj j
r;| E d H }|S r- ) r Zisfuturer r
isinstancer r? AttributeError collectionsabc Awaitable)argskwresZ
await_methr r r coroz s
zcoroutine..coroc sD t | i |d}|jr|jd= tdd |_tdd |_|S )NrV r" r r )r r r r r )rS kwdswrW r r r wrapper s zcoroutine..wrapper) warningswarnDeprecationWarningr r isgeneratorfunction functoolswrapstypesr _DEBUG
_is_coroutine)r r[ r rZ r r i s"
r c C s t | p t| ddtu S )z6Return True if func is a decorated coroutine function.rd N)r r r rd rV r r r r s
r c C s< t | tv rdS t| tr ttdk rtt | dS dS )z)Return True if obj is a coroutine object.Td F)r7 _iscoroutine_typecacherN _COROUTINE_TYPESlenadd)objr r r r s
r c
sp t | sJ t| t fdd}dd }d }t| dr#| jr#| j}n t| dr.| jr.| j}|| }|s?|| r=| dS |S d }t| drM| jrM| j}n t| d rX| jrX| j}|jp\d
}d } r| j d urt
| j st
| j }|d urz|\}}|d u r| d | d
| } | S | d| d
| } | S |d ur|j}| d| d
| } | S |j}| d | d
| } | S )Nc s` r
t | jdi S t| dr| jr| j}nt| dr"| jr"| j}n dt| j d}| dS )Nr r r r$ z without __name__>z())r Z_format_callbackr hasattrr r r7 )rW coro_nameZis_corowrapperr r get_name s
z#_format_coroutine..get_namec S s< z| j W S ty z| jW Y S ty Y Y dS w w )NF)
cr_runningrO r= )rW r r r
is_running s z%_format_coroutine..is_runningcr_coder> z runningr; cr_framezr z done, defined at r# z running, defined at z running at )r rN r rk rq r> r; rr co_filenamer r r_ r Z_get_function_sourcef_linenoco_firstlineno)
rW rn rp Z coro_coderl Z
coro_framefilenamelinenosourcer) r rm r r' sP
r' ) __all__Zcollections.abcrP r` r r r
r8 rb r\ rA r r r logr r rc r r objectrd r
CoroutineType
GeneratorTyperQ Coroutinerg setrf r r' r r r r s2 E8