Edit File: coroutines.cpython-36.pyc
3 \+ � @ s� d ddgZ ddlZddlZddlZddlZddlZddlZddlZddlm Z ddlm Z ddlm Z dd lm Z dd l mZ ejd Zejj o�eejjd ��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� d�Z'dd � Ze(� Z)dd� Z ej*e'fZ+e dk �r�e+e f7 Z+edk �r�efe+ Z+dd� Z,dd� Z-dS )� coroutine�iscoroutinefunction� 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%dd�Zdd� Zdd� Zdd � Zer8d d � Znd d � Zd&d d�Z dd� Z e dd� �Z e dd� �Z e dd� �Zejr�dd� 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_stack�sys� _getframe�_source_traceback�getattrr 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_repr�framer 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_back�f_lastir( �f_code�co_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 )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 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 kr�d| }t | df �}|r�djtj|��}|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_DEPTH�rstripr �error)r r r2 �msg�tbr 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 tj��r �� ntj���fdd��� tsNtdkrD� }qft� �}ntj��� �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 ? sv � | |�}t j|�s(tj|�s(t|t�r4|E d H }n>td k rry |j}W n tk rZ Y nX t|t�rr|� E d H }|S )N) r Zisfuturer& r' � isinstancer$ � _AwaitableABCrC �AttributeError)�args�kw�resZ await_meth)r r r r" � s zcoroutine.<locals>.coroNc s@ t � | |��d�}|jr |jd= t�dd �|_t�dd �|_|S )N)r r r r r. )r$ r, r- r r )rU �kwds�w)r" r r r �wrapper� s zcoroutine.<locals>.wrapper)� _inspect_iscoroutinefunctionr& �isgeneratorfunction� functools�wraps�_DEBUG�_types_coroutine� _is_coroutine)r rZ r )r" r r r � s c C s t | dd�tkpt| �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 | t�S )z)Return True if obj is a coroutine object.)rR �_COROUTINE_TYPES)�objr r r r s c C s& t | �s t�t| d� r�t| d� r�t| dt| dt| �j��}dj|�}d}y | j}W n4 tk r� y | j }W n tk r� Y nX Y nX |r�dj|�S |S d }t | t �r�| j }| j }|d k r�dj|�}n| }|d kr�tj|f i �}d }t| d�o�| j�r| j}nt| d��r | j�r | j}d }t| d��r>| j�r>| j}nt| d ��rX| j�rX| j}d }|�rp|j�rp|j}d }|}t | t ��r�tj| j � �r�| j d k �r�tj| j �} | d k �r�| \}}|d k�r�d |||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_source�f_lineno�co_firstlineno) r" Z coro_nameZrunningr Z coro_codeZ coro_frame�filename�linenor1 �sourcer r r r/ sz r/ ).�__all__r] r& Zopcode�osr* r; �typesrH r r r r �logr Zopmapr8 �flags�ignore_environment�bool�environ�getr_ 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: