3
\+ @ s d ddgZ ddlZddlZddlZddlZddlZddlZddlZddlm Z ddlm
Z
ddlm Z dd lm Z dd
l
mZ ejd Zejj oeejjd ZyejZejZW n ek
r dZdZY nX y
ej Z W n ek
r d
d Z Y nX yddl m Z m!Z" W n e#k
r* d Z Z"Y nX dd Z$e$ Z%[$dd Z&G dd dZ'dd Ze( Z)dd Z ej*e'fZ+e dk re+e f7 Z+edk refe+ Z+dd Z,dd Z-dS ) coroutineiscoroutinefunction iscoroutine N )compat) constants)events) base_futures)loggerZ
YIELD_FROMZPYTHONASYNCIODEBUGc C s dS )NF )funcr r */usr/lib64/python3.6/asyncio/coroutines.py<lambda>/ s r ) Coroutine Awaitablec C sF G dd d} dd }d}| }||}t | |j| |j|fkS ) Nc @ s, e Zd Zdd Zdd Zdd Zdd Zd S )
z!has_yield_from_bug.<locals>.MyGenc S s
d | _ d S )N) send_args)selfr r r
__init__; s z*has_yield_from_bug.<locals>.MyGen.__init__c S s | S )Nr )r r r r
__iter__= s z*has_yield_from_bug.<locals>.MyGen.__iter__c S s dS )N* r )r r r r
__next__? s z*has_yield_from_bug.<locals>.MyGen.__next__c W s
|| _ d S )N)r )r Zwhatr r r
sendA s z&has_yield_from_bug.<locals>.MyGen.sendN)__name__
__module__ __qualname__r r r r r r r r
MyGen: s r c s s | E d H d S )Nr )genr r r
yield_from_genD s z*has_yield_from_bug.<locals>.yield_from_genr )r r r )nextr r )r r valuer coror r r
has_yield_from_bug9 s
r# c C s
t | d S )N) CoroWrapper)r r r r
debug_wrapperP s r% c @ s e Zd Zd%ddZdd Zdd Zdd Zer8d
d Znd d Zd&d
dZ dd Z
e dd Z e dd Z
e dd Zejrdd Ze dd Ze dd Ze d d Ze d d Ze d!d" Zd#d$ ZdS )'r$ Nc C sZ t j|s t j|s t||| _|| _tjtj d| _
t |dd | _ t |dd | _
d S )Nr r r )inspect isgeneratorr AssertionErrorr r r
extract_stacksys _getframe_source_tracebackgetattrr r )r r r r r r
r [ s zCoroWrapper.__init__c C s@ t | }| jr0| jd }|d|d |d f 7 }d| jj|f S )Nr z, created at %s:%sr z<%s %s>)_format_coroutiner, __class__r )r coro_reprframer r r
__repr__c s
zCoroWrapper.__repr__c C s | S )Nr )r r r r
r j s zCoroWrapper.__iter__c C s | j jd S )N)r r )r r r r
r m s zCoroWrapper.__next__c G sB t j }|j}|jdks t|jj|j tkr6|d }| jj |S )Nr )
r* r+ f_backf_lastir( f_codeco_code _YIELD_FROMr r )r r! r2 Zcallerr r r
r u s zCoroWrapper.sendc C s | j j|S )N)r r )r r! r r r
r } s c C s | j j|||S )N)r throw)r typer! tracebackr r r
r9 s zCoroWrapper.throwc C s
| j j S )N)r close)r r r r
r< s zCoroWrapper.closec C s | j jS )N)r gi_frame)r r r r
r= s zCoroWrapper.gi_framec C s | j jS )N)r
gi_running)r r r r
r> s zCoroWrapper.gi_runningc C s | j jS )N)r gi_code)r r r r
r? s zCoroWrapper.gi_codec C s, t | jdd }|d k r(tdj| j|| S )Ncr_awaitz;Cannot await on coroutine {!r} while it's awaiting for {!r})r- r RuntimeErrorformat)r r@ r r r
__await__ s zCoroWrapper.__await__c C s | j jS )N)r gi_yieldfrom)r r r r
rD s zCoroWrapper.gi_yieldfromc C s | j jS )N)r r@ )r r r r
r@ s zCoroWrapper.cr_awaitc C s | j jS )N)r
cr_running)r r r r
rE s zCoroWrapper.cr_runningc C s | j jS )N)r cr_code)r r r r
rF s zCoroWrapper.cr_codec C s | j jS )N)r cr_frame)r r r r
rG s zCoroWrapper.cr_framec C s t | dd }t |dd }|d kr,t |dd }|d k r|jd
krd| }t | df }|rdjtj|}|dtj d 7 }||j 7 }tj | d S ) Nr r= rG r z%r was never yielded fromr, zB
Coroutine object created at (most recent call last, truncated to z last lines):
r. )
r- r5 joinr; format_listr ZDEBUG_STACK_DEPTHrstripr
error)r r r2 msgtbr r r
__del__ s zCoroWrapper.__del__)N)NN)r r r r r3 r r _YIELD_FROM_BUGr r9 r< propertyr= r> r? r ZPY35rC rD r@ rE rF rG rO r r r r
r$ X s(
r$ c sp t r S tjr ntjfdd tsNtdkrD }qft }ntj fdd}t|_|S )zDecorator to mark coroutines.
If the coroutine is not yielded from before it is destroyed,
an error message is logged.
c ? sv | |}t j|s(tj|s(t|tr4|E d H }n>td k rry
|j}W n tk
rZ Y nX t|trr| E d H }|S )N) r Zisfuturer& r'
isinstancer$
_AwaitableABCrC AttributeError)argskwresZ
await_meth)r r r
r" s
zcoroutine.<locals>.coroNc s@ t | |d}|jr |jd= tdd |_tdd |_|S )N)r r r r r. )r$ r, r- r r )rU kwdsw)r" r r r
wrapper s zcoroutine.<locals>.wrapper) _inspect_iscoroutinefunctionr& isgeneratorfunction functoolswraps_DEBUG_types_coroutine
_is_coroutine)r rZ r )r" r r
r s
c C s t | ddtkpt| S )z6Return True if func is a decorated coroutine function.ra N)r- ra r[ )r r r r
r s c C s
t | tS )z)Return True if obj is a coroutine object.)rR _COROUTINE_TYPES)objr r r
r s c
C s& t | s tt| d rt| d rt| dt| dt| j}dj|}d}y
| j}W n4 tk
r y
| j }W n tk
r Y nX Y nX |rdj|S |S d }t
| t r| j }| j
}|d k rdj|}n| }|d krtj|f i }d }t| do| jr| j}nt| dr | jr | j}d }t| dr>| jr>| j}nt| d rX| jrX| j}d
}|rp|jrp|j}d }|}t
| t rtj| j r| j d k rtj| j } | d k r| \}}|d krd |||f }nd
|||f }n:|d k r|j}d|||f }n|r"|j}d |||f }|S )NrF r? r r z{}()Fz
{} runningrG r= z<empty co_filename>r z%s done, defined at %s:%sz %s running, defined at %s:%sz%s running at %s:%s)r r( hasattrr- r: r rB rE rT r> rR r$ r r r Z_format_callbackrF r? rG r= co_filenamer& r\ Z_get_function_sourcef_linenoco_firstlineno)
r" Z coro_nameZrunningr Z coro_codeZ
coro_framefilenamelinenor1 sourcer r r
r/ sz
r/ ).__all__r] r& Zopcodeosr* r; typesrH r r r r logr
Zopmapr8 flagsignore_environmentboolenvirongetr_ r r`
CoroutineTypeZ_types_CoroutineTyperT r r[ collections.abcr Z
_CoroutineABCr rS ImportErrorr# rP r% r$ objectra
GeneratorTyperb r r/ r r r r
<module> sZ
j:
All system for education purposes only. For more tools: Telegram @jackleet