File: //lib64/python3.6/asyncio/__pycache__/coroutines.cpython-36.opt-1.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 s> || _ || _tjtjd��| _t|dd �| _t|dd �| _ d S )Nr r r )
r 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 s4 t j� }|j}|jj|j tkr(|d }| jj|�S )Nr ) r' r( �f_back�f_code�co_code�f_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 )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
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
kr�d| }t | df �}|r�djtj|��}|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_DEPTH�rstripr
�error)r r r/ �msg�tbr 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 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 Zisfuture�inspectZ isgenerator�
isinstancer$ �
_AwaitableABCr@ �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 )rS �kwds�w)r" r r r
�wrapper� s zcoroutine.<locals>.wrapper)� _inspect_iscoroutinefunctionrO �isgeneratorfunction� functools�wraps�_DEBUG�_types_coroutine�
_is_coroutine)r rX r )r" r r
r � s
c C s t | dd�tkpt| �S )z6Return True if func is a decorated coroutine function.r_ N)r* r_ rY )r r r r
r � s c C s
t | t�S )z)Return True if obj is a coroutine object.)rP �_COROUTINE_TYPES)�objr r r
r s c
C s t | d� r�t | d� r�t| dt| dt| �j��}dj|�}d}y
| j}W n4 tk
r~ y
| j}W n tk
rx Y nX Y nX |r�dj|�S |S d }t| t �r�| j
}| j }|d k r�dj|�}n| }|d kr�t j
|f i �}d }t | d�r�| jr�| j}nt | d��r| j�r| j}d }t | d��r0| j�r0| j}nt | d ��rJ| j�rJ| j}d
}|�rb|j�rb|j}d }|}t| t ��r�tj| j
� �r�| j
d k �r�t j| j
�} | d k �r�| \}}|d k�r�d |||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_source�f_lineno�co_firstlineno)
r" Z coro_nameZrunningr Z coro_codeZ
coro_frame�filename�linenor. �sourcer r r
r, sx
r, ).�__all__r[ rO Zopcode�osr' r8 �typesrE r r r r �logr
Zopmapr5 �flags�ignore_environment�bool�environ�getr] 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: