j fC% @ s d d d g Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z d d l m
Z
d d l m Z d d l m
Z
e j d
Z e j j o e e j j d Z y
e j Z Wn e k
r d Z Yn Xy
e j Z Wn e k
r*d d
Z Yn Xy d d l m Z m Z Wn e k
rcd Z Z Yn Xd d Z! e! Z" [! d d Z# Gd d d Z$ d d Z d d Z e j% e$ f Z& e d k re& e f 7Z& n d d Z' d d Z( d S) coroutineiscoroutinefunction iscoroutine N )compat)events)futures)loggerZ
YIELD_FROMZPYTHONASYNCIODEBUGc C s d S)NF )funcr
r
7/opt/alt/python34/lib64/python3.4/asyncio/coroutines.py* s r
) Coroutine Awaitablec C sa Gd d d } d d } d } | } | | } t | | j | | j | f k S) Nc @ s@ e Z d Z d d Z d d Z d d Z d d Z d S)
z!has_yield_from_bug..MyGenc S s
d | _ d S)N) send_args)selfr
r
r __init__6 s z*has_yield_from_bug..MyGen.__init__c S s | S)Nr
)r r
r
r __iter__8 s z*has_yield_from_bug..MyGen.__iter__c S s d S)N* r
)r r
r
r __next__: s z*has_yield_from_bug..MyGen.__next__c W s
| | _ d S)N)r )r Zwhatr
r
r send< s z&has_yield_from_bug..MyGen.sendN)__name__
__module__ __qualname__r r r r r
r
r
r MyGen5 s r c s s
| Dd Hd S)Nr
)genr
r
r yield_from_gen? s z*has_yield_from_bug..yield_from_genr )r r r )nextr r )r r valuer coror
r
r has_yield_from_bug4 s
r" c C s
t | d S)N) CoroWrapper)r r
r
r
debug_wrapperK s r$ c @ s0 e Z d Z d d d Z d d Z d d Z d d Z e rT d
d Z n d d Z d
d Z d d Z
e d d Z e d d Z
e d d Z e j r d d Z e d d Z e d d Z e d d Z e d d Z e d! d" Z n d# d$ Z d S)%r# Nc C s[ | | _ | | _ t j t j d | _ t | d d | _ t | d d | _ d S)Nr r r )
r r traceback
extract_stacksys _getframe_source_tracebackgetattrr r )r r r r
r
r r V s
zCoroWrapper.__init__c C sU t | } | j rA | j d } | d | d | d f 7} n d | j j | f S)Nr z, created at %s:%sr z<%s %s>)_format_coroutiner) __class__r )r coro_reprframer
r
r __repr__^ s
zCoroWrapper.__repr__c C s | S)Nr
)r r
r
r r e s zCoroWrapper.__iter__c C s | j j d S)N)r r )r r
r
r r h s zCoroWrapper.__next__c G sK t j } | j } | j j | j t k r; | d } n | j j | S)Nr ) r' r( f_backf_codeco_codef_lasti _YIELD_FROMr r )r r r/ Zcallerr
r
r r p s
zCoroWrapper.sendc C s | j j | S)N)r r )r r r
r
r r x s c C s | j j | S)N)r throw)r excr
r
r r6 { s zCoroWrapper.throwc C s
| j j S)N)r close)r r
r
r r8 ~ s zCoroWrapper.closec C s
| j j S)N)r gi_frame)r r
r
r r9 s zCoroWrapper.gi_framec C s
| j j S)N)r
gi_running)r r
r
r r: s zCoroWrapper.gi_runningc C s
| j j S)N)r gi_code)r r
r
r r; s zCoroWrapper.gi_codec C sC t | j d d } | d k r? t d j | j | n | 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 j S)N)r gi_yieldfrom)r r
r
r r@ s zCoroWrapper.gi_yieldfromc C s
| j j S)N)r r< )r r
r
r r< s zCoroWrapper.cr_awaitc C s
| j j S)N)r
cr_running)r r
r
r rA s zCoroWrapper.cr_runningc C s
| j j S)N)r cr_code)r r
r
r rB s zCoroWrapper.cr_codec C s
| j j S)N)r cr_frame)r r
r
r rC s zCoroWrapper.cr_framec C s t | d d } t | d d } | d k rE t | d d } n | d k r | j d k r d | } t | d f } | r d j t j | } | d 7} | | j 7} n t j | n d S)
Nr r9 rC r z%r was never yielded fromr) z6
Coroutine object created at (most recent call last):
r+ )r* r4 joinr% format_listrstripr error)r r r/ msgtbr
r
r __del__ s
zCoroWrapper.__del__)r r r r r0 r r _YIELD_FROM_BUGr r6 r8 propertyr9 r: r; r ZPY35r? r@ r< rA rB rC rK r
r
r
r r# S s( r# c s t r St j r( n! t j f d d t ss t d k rd } q t } n$ t j f d d } d | _ | S)zDecorator to mark coroutines.
If the coroutine is not yielded from before it is destroyed,
an error message is logged.
c ? s | | } t | t j s0 t j | r> | Dd H} nQ t d k r y
| j } Wn t k
rk Yq Xt | t r | Dd H} q n | S)N)
isinstancer ZFutureinspectZ isgenerator
_AwaitableABCr? AttributeError)argskwresZ
await_meth)r r
r r! s !
zcoroutine..coroNc s_ t | | d } | j r1 | j d =n t d d | _ t d d | _ | S)Nr r r r r+ )r# r) r* r r )rR kwdsw)r! r r
r wrapper s
zcoroutine..wrapperT) _inspect_iscoroutinefunctionrO isgeneratorfunction functoolswraps_DEBUG_types_coroutine
_is_coroutine)r rW r
)r! r r r s ! $
c C s t | d d p t | S)z6Return True if func is a decorated coroutine function.r^ F)r* rX )r r
r
r r s c C s
t | t S)z)Return True if obj is a coroutine object.)rN _COROUTINE_TYPES)objr
r
r r s c C s d } t | t rH | j } | j } | d k rN d j | } qN n | } | d k ro t j | f } n y
| j } Wn t k
r | j } Yn Xy
| j
} Wn t k
r | j } Yn X| j } d } t | t rjt
j | j rj| j d k rjt j | j } | d k r2| \ } } n | d k rTd | | | f } qd | | | f } nG | d k r| j } d | | | f } n | j } d | | | f } | S)Nz{}()r z%s done, defined at %s:%sz %s running, defined at %s:%sz%s running at %s:%s)rN r# r r r> r Z_format_callbackr; rQ rB r9 rC co_filenamerO rY Z_get_function_sourcef_linenoco_firstlineno) r! Z coro_namer Z coro_codeZ
coro_framefilenamelinenosourcer. r
r
r r, sL
r, ))__all__rZ rO Zopcodeosr' r% typesrD r r r logr Zopmapr5 flagsignore_environmentboolenvirongetr\ r r] rQ r rX Zcollections.abcr Z
_CoroutineABCr rP ImportErrorr" rL r$ r#
GeneratorTyper_ r r, r
r
r
r sN
i 8