��Yf�)�@s(dddgZddlZddlZddlZddlZddlZddlZddlZddlm Z ddlm Z ddlmZdd lm Z ejd Zejjo�eejjd��ZyejZejZWnek rdZdZYnXy ejZWnek r9dd �ZYnXyddlmZm Z!Wne"k rrdZZ!YnXdd�Z#e#�Z$[#dd�Z%Gdd�d�Z&dd�Ze'�Z(dd�Zej)e&fZ*edk r�e*ef7Z*edk refe*Z*dd�Z+dd�Z,dS)� coroutine�iscoroutinefunction�iscoroutine�N�)�compat)�events)�futures)�loggerZ YIELD_FROMZPYTHONASYNCIODEBUGcCsdS)NF�)�funcr r �7/opt/alt/python35/lib64/python3.5/asyncio/coroutines.py�.sr )� Coroutine� AwaitablecCsaGdd�d�}dd�}d}|�}||�}t|�|j|�|j|fkS) Nc@s@eZdZdd�Zdd�Zdd�Zdd�Zd S) z!has_yield_from_bug..MyGencSs d|_dS)N)� send_args)�selfr r r�__init__:sz*has_yield_from_bug..MyGen.__init__cSs|S)Nr )rr r r�__iter__<sz*has_yield_from_bug..MyGen.__iter__cSsdS)N�*r )rr r r�__next__>sz*has_yield_from_bug..MyGen.__next__cWs ||_dS)N)r)rZwhatr r r�send@s z&has_yield_from_bug..MyGen.sendN)�__name__� __module__�__qualname__rrrrr r r r�MyGen9srcss |EdHdS)Nr )�genr r r�yield_from_genCsz*has_yield_from_bug..yield_from_genr��)rrr)�nextrr)rr�valuer�coror r r�has_yield_from_bug8s r"cCs t|d�S)N)�CoroWrapper)rr r r� debug_wrapperOsr$c@s3eZdZddd�Zdd�Zdd�Zdd �ZerTd d�Zndd�Zddd d�Z dd�Z edd��Zedd��Z edd��Zejr#dd�Zedd��Zedd��Zedd��Zedd ��Zed!d"��Zd#d$�ZdS)%r#NcCs[||_||_tjtjd��|_t|dd�|_t|dd�|_ dS)Nrrr) rr� traceback� extract_stack�sys� _getframe�_source_traceback�getattrrr)rrrr r rrZs zCoroWrapper.__init__cCsRt|�}|jr>|jd}|d|d|df7}d|jj|fS)Nrz, created at %s:%srz<%s %s>��)�_format_coroutiner)� __class__r)r� coro_repr�framer r r�__repr__bs zCoroWrapper.__repr__cCs|S)Nr )rr r rriszCoroWrapper.__iter__cCs|jjd�S)N)rr)rr r rrlszCoroWrapper.__next__cGsHtj�}|j}|jj|jtkr8|d}|jj|�S)Nr) r'r(�f_back�f_code�co_code�f_lasti�_YIELD_FROMrr)rr r/Zcallerr r rrts zCoroWrapper.sendcCs|jj|�S)N)rr)rr r r rr|scCs|jj|||�S)N)r�throw)r�typer r%r r rr6szCoroWrapper.throwcCs |jj�S)N)r�close)rr r rr8�szCoroWrapper.closecCs |jjS)N)r�gi_frame)rr r rr9�szCoroWrapper.gi_framecCs |jjS)N)r� gi_running)rr r rr:�szCoroWrapper.gi_runningcCs |jjS)N)r�gi_code)rr r rr;�szCoroWrapper.gi_codecCs@t|jdd�}|dk r<tdj|j|��|S)N�cr_awaitz;Cannot await on coroutine {!r} while it's awaiting for {!r})r*r�RuntimeError�format)rr<r r r� __await__�szCoroWrapper.__await__cCs |jjS)N)r�gi_yieldfrom)rr r rr@�szCoroWrapper.gi_yieldfromcCs |jjS)N)rr<)rr r rr<�szCoroWrapper.cr_awaitcCs |jjS)N)r� cr_running)rr r rrA�szCoroWrapper.cr_runningcCs |jjS)N)r�cr_code)rr r rrB�szCoroWrapper.cr_codecCs |jjS)N)r�cr_frame)rr r rrC�szCoroWrapper.cr_framecCs�t|dd�}t|dd�}|dkrBt|dd�}|dk r�|jd kr�d|}t|df�}|r�djtj|��}|d7}||j�7}tj|�dS) Nrr9rCrz%r was never yielded fromr)�z6 Coroutine object created at (most recent call last): r+)r*r4�joinr%�format_list�rstripr �error)rrr/�msg�tbr r r�__del__�s zCoroWrapper.__del__)rrrrr0rr�_YIELD_FROM_BUGrr6r8�propertyr9r:r;rZPY35r?r@r<rArBrCrKr r r rr#Ws( r#cs�t��r�Stj��r(��n!tj��fdd��tsstdkrd�}q�t��}n$tj��fdd��}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��||�}tj|�s<tj|�s<t|t�rJ|EdH}nKtdk r�y |j}Wntk rwYnXt|t�r�|�EdH}|S)N) rZisfuture�inspectZisgenerator� isinstancer#� _AwaitableABCr?�AttributeError)�args�kw�resZ await_meth)rr rr!�s zcoroutine..coroNcs\t�||�d��}|jr.|jd=t�dd�|_t�dd�|_|S)Nrrrrr+)r#r)r*rr)rR�kwds�w)r!rr r�wrapper�s zcoroutine..wrapper)�_inspect_iscoroutinefunctionrN�isgeneratorfunction� functools�wraps�_DEBUG�_types_coroutine� _is_coroutine)rrWr )r!rrr�s ! $ cCs"t|dd�tkp!t|�S)z6Return True if func is a decorated coroutine function.r^N)r*r^rX)rr r rr�scCs t|t�S)z)Return True if obj is a coroutine object.)rO�_COROUTINE_TYPES)�objr r rrsc "Csft|d�r�t|d�r�t|dt|dt|�j��}dj|�}d}y |j}Wn4tk r�y |j}Wntk r�YnXYnX|r�dj|�S|Sd}t|t �r�|j }|j}|dk rdj|�}n|}|dkr#tj |fi�}y |j}Wntk rM|j}YnXy |j}Wntk rx|j}YnX|j}d}t|t �rtj|j �r|j dk rtj|j �}|dk r�|\}}|dkrd |||f} qbd |||f} nG|dk rF|j}d|||f} n|j}d |||f} | S)NrBr;rrz{}()Fz {} runningrz%s done, defined at %s:%sz%s running, defined at %s:%sz%s running at %s:%s)�hasattrr*r7rr>rArQr:rOr#rrrZ_format_callbackr;rBr9rC�co_filenamerNrYZ_get_function_source�f_lineno�co_firstlineno) r!Z coro_nameZrunningrZ coro_codeZ coro_frame�filename�lineno�sourcer.r r rr,sl r,)-�__all__rZrNZopcode�osr'r%�typesrDrrr�logr Zopmapr5�flags�ignore_environment�bool�environ�getr\rr]� CoroutineTypeZ_types_CoroutineTyperQrrX�collections.abcrZ _CoroutineABCrrP�ImportErrorr"rLr$r#�objectr^� GeneratorTyper_rr,r r r r�sX i: