OwlCyberSecurity - MANAGER
Edit File: coroutines.cpython-36.opt-1.pyc
3 � f+������������������@���s���d�ddgZ�ddlZddlZddlZddlZddlZddlZddlZddlm Z �ddlm Z �ddlmZ�dd lmZ�dd l mZ�ejd�Zejj�o�eejjd��ZyejZejZW�n�ek r����dZdZY�nX�y ejZW�n�ek r����d d��ZY�nX�yddlmZ 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��Zej*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����7/opt/alt/python36/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��Zndd��Zd&d d�Z dd��Z edd���Zedd���Z edd���Zejr�dd��Zedd���Zedd���Zedd���Zedd ���Zed!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�inspectZisgenerator� 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�tj |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�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�)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: