File manager

3


 \+�@s�
dd
dgZddl
Z
ddlZddlZddlZddlZddlZddlZddlm	Z	
ddlm
Z

ddlmZ
dd	lmZ
dd
l
mZ
ejdZejjo�eejjd�
�
ZyejZejZWnek
r�


dZdZYnXy
ejZWnek
r�


d
d�ZYnXyddlmZ m!Z"
Wne#k
�
r*


dZ Z"YnXdd�Z$e$�Z%[$dd�Z&Gdd�d�Z'dd�Ze(�Z)dd
�Zej*e'fZ+e dk	�
r�e+e f
7Z+edk	�
r�ef
e+Z+dd�Z,dd�Z-dS)�	coroutine�iscoroutinefunction�iscoroutine�N�
)
�compat)
�	constants)
�events)
�base_futures)
�loggerZ
YIELD_FROMZPYTHONASYNCIODEBUGc


Csd
S)NF�)
�funcrr�*/usr/lib64/python3.6/asyncio/coroutines.py�<lambda>/sr)�	Coroutine�	AwaitablecCsFGd
d�d�}dd�}
d}|�}|
|�
}t|�

|j
|�

|j|f
kS)	Nc@s,eZ
dZd
d�Zdd�Zdd�Zdd�Zd	S)
z!has_yield_from_bug.<locals>.MyGenc

Ss
d|_dS)
N)
�	send_args)
�selfrrr
�__init__;s
z*has_yield_from_bug.<locals>.MyGen.__init__c


Ss|S)
Nr)
rrrr
�__iter__=s
z*has_yield_from_bug.<locals>.MyGen.__iter__c


Ssd
S)N�*r)
rrrr
�__next__?s
z*has_yield_from_bug.<locals>.MyGen.__next__c
Ws
|
|_dS)
N)
r)rZwhatrrr
�sendAs

z&has_yield_from_bug.<locals>.MyGen.sendN)�__name__�
__module__�__qualname__rrrrrrrr
�MyGen:s
rc

ss|EdH
dS)
Nr)
�genrrr
�yield_from_genDs
z*has_yield_from_bug.<locals>.yield_from_genr��)rrr)�nextrr)rr�valuer�cororrr
�has_yield_from_bug9s







r#c

Cs
t|d�S)
N)
�CoroWrapper)
rrrr
�
debug_wrapperPsr%c@s�eZ
dZd%dd�
Zdd�Zdd�Zdd	�Zer8d
d�Zndd�Zd&d
d�
Z	dd�Z
edd��
Zedd��
Z
edd��
Zejr�dd�Zedd��
Zedd��
Zedd��
Zedd ��
Zed!d"��
Zd#d$�Zd
S)'r$NcCs>|
|_||_
tjtjd
�
�
|_t|
dd�|_t|
dd�|_	dS)Nrrr)
rrr�
extract_stack�sys�	_getframe�_source_traceback�getattrrr)rrrrrr
r[s




zCoroWrapper.__init__c
Cs@t|�
}
|j
r0|j
d}|
d|d|d
f7}
d|jj|
fS)Nrz, created at %s:%srz<%s %s>���)�_format_coroutiner)�	__class__r)r�	coro_repr�framerrr
�__repr__cs






zCoroWrapper.__repr__c


Cs|S)
Nr)
rrrr
rjs
zCoroWrapper.__iter__c

Cs|jj
d�
S)
N)rr)
rrrr
rms
zCoroWrapper.__next__c
Gs4tj
�}|j}|jj|jtkr(|
d
}
|jj|
�
S)Nr)	r'r(�f_back�f_code�co_code�f_lasti�_YIELD_FROMrr)rr!r/Zcallerrrr
rus




zCoroWrapper.sendcCs|jj
|
�
S)
N)rr)rr!rrr
r}s
cCs|jj
|
||�S)
N)r�throw)r�typer!�	tracebackrrr
r6�s
zCoroWrapper.throwc


Cs
|jj
�S)
N)r�close)
rrrr
r9�s
zCoroWrapper.closec


Cs|jj
S)
N)r�gi_frame)
rrrr
r:�szCoroWrapper.gi_framec


Cs|jj
S)
N)r�
gi_running)
rrrr
r;�szCoroWrapper.gi_runningc


Cs|jj
S)
N)r�gi_code)
rrrr
r<�szCoroWrapper.gi_codec
Cs,t|j
d
d�}
|
dk	r(tdj|j
|
��
�
|S)N�cr_awaitz;Cannot await on coroutine {!r} while it's awaiting for {!r})r*r�RuntimeError�format)rr=rrr
�	__await__�s





zCoroWrapper.__await__c


Cs|jj
S)
N)r�gi_yieldfrom)
rrrr
rA�szCoroWrapper.gi_yieldfromc


Cs|jj
S)
N)rr=)
rrrr
r=�szCoroWrapper.cr_awaitc


Cs|jj
S)
N)r�
cr_running)
rrrr
rB�szCoroWrapper.cr_runningc


Cs|jj
S)
N)r�cr_code)
rrrr
rC�szCoroWrapper.cr_codec


Cs|jj
S)
N)r�cr_frame)
rrrr
rD�szCoroWrapper.cr_framec
Cs�t|d
d�}
t|
dd�}|dkr,t|
dd�}|dk	r�|j
d
kr�d|}t|df�}|r�djtj|�
�
}|dtj�d	�7}||j�7}tj	|�

dS)Nrr:rDrz%r was never yielded fromr)�zB
Coroutine object created at (most recent call last, truncated to z last lines):
r+)
r*r4�joinr8�format_listrZDEBUG_STACK_DEPTH�rstripr
�error)rrr/�msg�tbrrr
�__del__�s









zCoroWrapper.__del__)
N)NN)rrrrr0rr�_YIELD_FROM_BUGrr6r9�propertyr:r;r<rZPY35r@rAr=rBrCrDrLrrrr
r$Xs(


r$c
spt�
�
r�
St
j�
�
r�
�ntj�
�
�
f
d
d��
�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�||
�
}tj
|�
s(tj|�
s(t|t�r4|EdH}n>tdk	rry
|j}Wntk
rZ


YnXt|t�rr|�EdH}|S)
N)	r	Zisfuture�inspectZisgenerator�
isinstancer$�
_AwaitableABCr@�AttributeError)�args�kw�resZ
await_meth)
rrr
r"�s












zcoroutine.<locals>.coroNcs@t�||
�
�
d
�}|j
r |j
d=t�
dd�|_t�
dd�|_|S)N)
rrrrr+)r$r)r*rr)rS�kwds�
w)r"rrr
�wrapper�s



zcoroutine.<locals>.wrapper)�_inspect_iscoroutinefunctionrO�isgeneratorfunction�	functools�wraps�_DEBUG�_types_coroutine�
_is_coroutine)rrXr)r"rr
r
�s






c

Cst|d
d�t
kpt|�
S)z6Return True if func is a decorated coroutine function.r_N)r*r_rY)
rrrr
r�s
c

Cs
t|t
�S)
z)Return True if obj is a coroutine object.)rP�_COROUTINE_TYPES)
�objrrr
r
sc

Cst|d
�r�t|d�r�t
|dt
|dt|�
j��}
dj|
�
}
d}y
|j}Wn4tk
r~


y
|j}Wntk
rx


YnXYnX|r�dj|
�
S|
Sd}
t|t	�r�|j
}|j}
|
dk	r�dj|
�
}
n|}|
dkr�tj
|fi�}
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
dk	�
r�tj|j
�
}	|	dk	�
r�|	\}}|dk�
r�d|
||f}nd
|
||f}n:|dk	�
r�|j}d|
||f}n|�r|j}d|
||f}|S)NrCr<rrz{}()Fz
{} runningrDr:z<empty co_filename>rz%s done, defined at %s:%sz%s running, defined at %s:%sz%s running at %s:%s)�hasattrr*r7rr?rBrRr;rPr$rrrZ_format_callbackrCr<rDr:�co_filenamerOrZZ_get_function_source�f_lineno�co_firstlineno)
r"Z	coro_nameZrunningrZ	coro_codeZ
coro_frame�filename�linenor.�sourcerrr
r,
sx




















































r,).�__all__r[rOZopcode�osr'r8�typesrErrrr	�logr
Zopmapr5�flags�ignore_environment�bool�environ�getr]r
r^�
CoroutineTypeZ_types_CoroutineTyperRrrY�collections.abcrZ
_CoroutineABCrrQ�ImportErrorr#rMr%r$�objectr_�
GeneratorTyper`rr,rrrr
�<module>
sZ

























j: