← Back
Editing: coroutines.cpython-34.pyo
� j fC% � @ 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 Wn e k r� d Z Yn Xy e j Z Wn e k r*d d � Z Yn Xy d d l m Z m Z Wn e k rcd Z Z Yn Xd d � Z! e! � Z" [! d d � Z# Gd d � d � Z$ d d � Z d d � Z e j% e$ f Z& e d k r�e& e f 7Z& n 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/python34/lib64/python3.4/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__6 s z*has_yield_from_bug.<locals>.MyGen.__init__c S s | S)Nr )r r r r �__iter__8 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 �MyGen5 s r c s s | Dd Hd S)Nr )�genr r r �yield_from_gen? s z*has_yield_from_bug.<locals>.yield_from_genr � � )r r r )�nextr r )r r �valuer �coror r r �has_yield_from_bug4 s r" c C s t | d � S)N)� CoroWrapper)r r r r � debug_wrapperK s r$ c @ s0 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 � 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 n d# d$ � Z d S)%r# Nc C s[ | | _ | | _ t j t j d � � | _ t | d d � | _ t | d d � | _ d S)Nr r r ) r r � traceback� extract_stack�sys� _getframe�_source_traceback�getattrr r )r r r r r r r V s zCoroWrapper.__init__c C sU t | � } | j rA | j d } | d | d | d f 7} n 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__^ s zCoroWrapper.__repr__c C s | S)Nr )r r r r r e s zCoroWrapper.__iter__c C s | j j d � S)N)r r )r r r r r h s zCoroWrapper.__next__c G sK t j � } | j } | j j | j t k r; | d } n | j j | � S)Nr ) r' r( �f_back�f_code�co_code�f_lasti� _YIELD_FROMr r )r r r/ Zcallerr r r r p s zCoroWrapper.sendc C s | j j | � S)N)r r )r r r r r r x s c C s | j j | � S)N)r �throw)r �excr r r r6 { s zCoroWrapper.throwc C s | j j � S)N)r �close)r r r r r8 ~ s zCoroWrapper.closec C s | j j S)N)r �gi_frame)r r r r r9 � 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 sC t | j d d � } | d k r? t d j | j | � � � n | 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 r@ � 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 rA � s zCoroWrapper.cr_runningc C s | j j S)N)r �cr_code)r r r r rB � s zCoroWrapper.cr_codec C s | j j S)N)r �cr_frame)r r r r rC � s zCoroWrapper.cr_framec C s� t | d d � } t | d d � } | d k rE t | d d � } n | d k r� | j d k r� d | } t | d f � } | r� d j t j | � � } | d 7} | | j � 7} n t j | � n d S) Nr r9 rC r z%r was never yielded fromr) � z6 Coroutine object created at (most recent call last): r+ )r* r4 �joinr% � format_list�rstripr �error)r r r/ �msg�tbr r r �__del__� s zCoroWrapper.__del__)r r r r r0 r r �_YIELD_FROM_BUGr r6 r8 �propertyr9 r: r; r ZPY35r? r@ r< rA rB rC rK r r r r r# S 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 � � } d | _ | 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 | t j � s0 t j | � r> | Dd H} nQ t d k r� y | j } Wn t k rk Yq� Xt | t � r� | � Dd H} q� n | S)N)� isinstancer ZFuture�inspectZ isgenerator� _AwaitableABCr? �AttributeError)�args�kw�resZ await_meth)r r r r! � s ! zcoroutine.<locals>.coroNc s_ t � | | � d � �} | j r1 | j d =n t � d d � | _ t � d d � | _ | S)Nr r r r r+ )r# r) r* r r )rR �kwds�w)r! r r r �wrapper� s zcoroutine.<locals>.wrapperT)� _inspect_iscoroutinefunctionrO �isgeneratorfunction� functools�wraps�_DEBUG�_types_coroutine� _is_coroutine)r rW r )r! r r r � s ! $ c C s t | d d � p t | � S)z6Return True if func is a decorated coroutine function.r^ F)r* rX )r r r r r � s c C s t | t � S)z)Return True if obj is a coroutine object.)rN �_COROUTINE_TYPES)�objr r r r � s c C s� d } t | t � rH | j } | j } | d k rN d j | � } qN n | } | d k ro t j | f � } n y | j } Wn t k r� | j } Yn Xy | j } Wn t k r� | j } Yn X| j } d } t | t � rjt j | j � rj| j d k rjt j | j � } | d k r2| \ } } n | d k rTd | | | f } q�d | | | f } nG | d k r�| j } d | | | f } n | j } d | | | f } | S)Nz{}()r z%s done, defined at %s:%sz %s running, defined at %s:%sz%s running at %s:%s)rN r# r r r> r Z_format_callbackr; rQ rB r9 rC � co_filenamerO rY Z_get_function_source�f_lineno�co_firstlineno) r! Z coro_namer Z coro_codeZ coro_frame�filename�lineno�sourcer. r r r r, sL r, ))�__all__rZ rO Zopcode�osr' r% �typesrD r r r �logr Zopmapr5 �flags�ignore_environment�bool�environ�getr\ r r] rQ r rX Zcollections.abcr Z _CoroutineABCr rP � ImportErrorr" rL r$ r# � GeneratorTyper_ r r, r r r r �<module> sN i 8
Save File
Cancel