��Yf�) � @ 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 e j Z Wn e k
r d Z d Z Yn Xy
e j Z Wn e k
r9d d
� Z Yn Xy d d l m Z m Z! Wn e" k
rrd Z Z! Yn Xd d � Z# e# � Z$ [# d d � Z% Gd d � d � Z& d d � Z e' � Z( d d � Z e j) e& f Z* e d k r�e* e f 7Z* e d k r e f e* Z* d d � Z+ d d � Z, d S)� coroutine�iscoroutinefunction� iscoroutine� N� )�compat)�events)�futures)�loggerZ
YIELD_FROMZPYTHONASYNCIODEBUGc C s d S)NF� )�funcr
r
�7/opt/alt/python35/lib64/python3.5/asyncio/coroutines.py�<lambda>. 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.<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 d S)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 �send@ s z&has_yield_from_bug.<locals>.MyGen.sendN)�__name__�
__module__� __qualname__r r r r r
r
r
r �MyGen9 s r c s s
| Ed Hd S)Nr
)�genr
r
r �yield_from_genC s z*has_yield_from_bug.<locals>.yield_from_genr � � )r r r )�nextr r )r r �valuer �coror
r
r �has_yield_from_bug8 s
r" c C s
t | d � S)N)� CoroWrapper)r r
r
r �
debug_wrapperO s r$ c @ s3 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 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 d# d$ � Z d S)%r# Nc C s� t j | � s* t j | � s* t | � � | | _ | | _ t j t j d � � | _
t | d d � | _ t | d d � | _
d S)Nr r r )�inspect� isgeneratorr �AssertionErrorr r � traceback�
extract_stack�sys� _getframe�_source_traceback�getattrr r )r r r r
r
r r Z s * zCoroWrapper.__init__c C sR t | � } | j r> | j d } | d | d | d f 7} d | j j | f S)Nr z, created at %s:%sr z<%s %s>���)�_format_coroutiner, � __class__r )r � coro_repr�framer
r
r �__repr__b s
zCoroWrapper.__repr__c C s | S)Nr
)r r
r
r r i s zCoroWrapper.__iter__c C s | j j d � S)N)r r )r r
r
r r l s zCoroWrapper.__next__c G s] t j � } | j } | j d k s* t � | j j | j t k rM | d } | j j | � S)Nr )
r* r+ �f_back�f_lastir' �f_code�co_code� _YIELD_FROMr r )r r r2 Zcallerr
r
r r t 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 r( r
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 j S)N)r �gi_frame)r r
r
r r< � 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 s@ t | j d d � } | d k r< t d j | j | � � � | S)N�cr_awaitz;Cannot await on coroutine {!r} while it's awaiting for {!r})r- r � RuntimeError�format)r r? r
r
r � __await__� s zCoroWrapper.__await__c C s
| j j S)N)r � gi_yieldfrom)r r
r
r rC � 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 rD � s zCoroWrapper.cr_runningc C s
| j j S)N)r �cr_code)r r
r
r rE � s zCoroWrapper.cr_codec C s
| j j S)N)r �cr_frame)r r
r
r rF � s zCoroWrapper.cr_framec C s� t | d d � } t | d d � } | d k rB t | d d � } | d k r� | j d k r� d | } t | d f � } | r� d j t j | � � } | d 7} | | j � 7} t j | � d S)
Nr r< rF r z%r was never yielded fromr, � z6
Coroutine object created at (most recent call last):
r. )r- r5 �joinr( � format_list�rstripr �error)r r r2 �msg�tbr
r
r �__del__� s
zCoroWrapper.__del__)r r r r r3 r r �_YIELD_FROM_BUGr r9 r; �propertyr< r= r> r ZPY35rB rC r? rD rE rF rN r
r
r
r r# W 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 � � } t | _ | S)z�Decorator to mark coroutines.
If the coroutine is not yielded from before it is destroyed,
an error message is logged.
c ? s� � | | � } t j | � s< t j | � s< t | t � rJ | Ed H} nK t d k r� y
| j } Wn t k
rw Yn Xt | t � r� | � Ed H} | S)N) r Zisfuturer% r& �
isinstancer# �
_AwaitableABCrB �AttributeError)�args�kw�resZ
await_meth)r r
r r! � s
zcoroutine.<locals>.coroNc s\ t � | | � d � �} | j r. | j d =t � d d � | _ t � d d � | _ | S)Nr r r r r. )r# r, r- r r )rT �kwds�w)r! r r
r �wrapper� s
zcoroutine.<locals>.wrapper)� _inspect_iscoroutinefunctionr% �isgeneratorfunction� functools�wraps�_DEBUG�_types_coroutine�
_is_coroutine)r rY r
)r! r r r � s ! $
c C s" t | d d � t k p! t | � S)z6Return True if func is a decorated coroutine function.r` N)r- r` rZ )r r
r
r r � s c C s
t | t � S)z)Return True if obj is a coroutine object.)rQ �_COROUTINE_TYPES)�objr
r
r r s c
" C sx t | � s t � t | d � r� t | d � r� t | d t | d t | � j � � } d j | � } d } y
| j } Wn4 t k
r� y
| j } Wn t k
r� Yn XYn X| r� d j | � S| Sd } t
| t � r| j } | j
} | d k rd j | � } n | } | d k r5t j | f i � } y
| j } Wn t k
r_| j } Yn Xy
| j } Wn t k
r�| j } Yn X| j } d } t
| t � r-t j | j � r-| j d k r-t j | j � } | d k r�| \ } } | d k rd | | | f } qtd
| | | f } nG | d k rX| j } d | | | f } n | j } d | | | f } | S) NrE r> r r z{}()Fz
{} runningr z%s done, defined at %s:%sz %s running, defined at %s:%sz%s running at %s:%s)r r' �hasattrr- r: r rA rD rS r= rQ r# r r r Z_format_callbackr> rE r< rF � co_filenamer% r[ Z_get_function_source�f_lineno�co_firstlineno)
r! Z coro_nameZrunningr Z coro_codeZ
coro_frame�filename�lineno�sourcer1 r
r
r r/ sn
r/ )-�__all__r\ r% Zopcode�osr* r( �typesrG r r r �logr Zopmapr8 �flags�ignore_environment�bool�environ�getr^ r r_ �
CoroutineTypeZ_types_CoroutineTyperS r rZ �collections.abcr Z
_CoroutineABCr rR � ImportErrorr" rO r$ r# �objectr` �
GeneratorTypera r r/ r
r
r
r �<module> sX
i :