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 s> || _ || _tjtjd| _t|dd | _t|dd | _ d S )Nr r r )
r 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 s4 t j }|j}|jj|j tkr(|d }| jj|S )Nr ) r' r( f_backf_codeco_codef_lasti _YIELD_FROMr r )r r! r/ 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
r6 s zCoroWrapper.throwc C s
| j j S )N)r close)r r r r
r9 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
rA 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
rB s zCoroWrapper.cr_runningc C s | j jS )N)r cr_code)r r r r
rC s zCoroWrapper.cr_codec C s | j jS )N)r cr_frame)r r r r
rD 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: rD r z%r was never yielded fromr) zB
Coroutine object created at (most recent call last, truncated to z last lines):
r+ )
r* r4 joinr8 format_listr ZDEBUG_STACK_DEPTHrstripr
error)r r r/ msgtbr r r
__del__ s zCoroWrapper.__del__)N)NN)r r r r r0 r r _YIELD_FROM_BUGr r6 r9 propertyr: r; r< r ZPY35r@ rA r= rB rC rD rL r r r r
r$ X s(
r$ c sp t r S tjr ntjfdd tsNtd krD }qft }ntj fdd}t|_|S )Nc ? 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 ZisfutureinspectZ isgenerator
isinstancer$
_AwaitableABCr@ AttributeError)argskwresZ
await_meth)r r r
r" s
zcoroutine.<locals>.coroc s@ t | |d}|jr |jd= tdd |_tdd |_|S )N)r r r r r+ )r$ r) r* r r )rS kwdsw)r" r r r
wrapper s zcoroutine.<locals>.wrapper) _inspect_iscoroutinefunctionrO isgeneratorfunction functoolswraps_DEBUG_types_coroutine
_is_coroutine)r rX r )r" r r
r s
c C s t | dd tkpt| S )Nr_ )r* r_ rY )r r r r
r s c C s
t | tS )N)rP _COROUTINE_TYPES)objr r r
r s c
C s t | d rt | d rt| dt| dt| j}dj|}d}y
| j}W n4 tk
r~ y
| j}W n tk
rx Y nX Y nX |rdj|S |S d }t| t r| j
}| j }|d k rdj|}n| }|d krt j
|f i }d }t | dr| jr| j}nt | dr| jr| j}d }t | dr0| jr0| j}nt | d rJ| jrJ| j}d
}|rb|jrb|j}d }|}t| t rtj| j
r| j
d k rt j| j
} | d k r| \}}|d krd |||f }nd
|||f }n:|d k r|j}d|||f }n|r|j}d |||f }|S )NrC r< r r z{}()Fz
{} runningrD r: z<empty co_filename>r z%s done, defined at %s:%sz %s running, defined at %s:%sz%s running at %s:%s)hasattrr* r7 r r? rB rR r; rP r$ r r r Z_format_callbackrC r< rD r: co_filenamerO rZ Z_get_function_sourcef_linenoco_firstlineno)
r" Z coro_nameZrunningr Z coro_codeZ
coro_framefilenamelinenor. sourcer r r
r, sx
r, ).__all__r[ rO Zopcodeosr' r8 typesrE r r r r logr
Zopmapr5 flagsignore_environmentboolenvirongetr] r r^
CoroutineTypeZ_types_CoroutineTyperR r rY collections.abcr Z
_CoroutineABCr rQ ImportErrorr# rM r% r$ objectr_
GeneratorTyper` r r, r r r r
<module> sZ
j:
All system for education purposes only. For more tools: Telegram @jackleet