Current path: usr/lib64/python3.6/asyncio/__pycache__/
⬆️ Go up: /usr/lib64/python3.6/asyncio
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: