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$NcCsZtj
|
�
stj|
�
st|
�
�
|
|_||_tjtj	d
�
�
|_
t|
dd�|_t|
dd�|_
dS)Nrrr)�inspect�isgeneratorr�AssertionErrorrr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
GsBtj
�}|j}|jd
kst�
|jj|jtkr6|
d
}
|jj	|
�
S)Nr)
r*r+�f_back�f_lastir(�f_code�co_code�_YIELD_FROMrr)rr!r2Zcallerrrr
rus





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


Cs
|jj
�S)
N)r�close)
rrrr
r<�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
rD�szCoroWrapper.gi_yieldfromc


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


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


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


Cs|jj
S)
N)r�cr_frame)
rrrr
rG�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=rGrz%r was never yielded fromr,�zB
Coroutine object created at (most recent call last, truncated to z last lines):
r.)
r-r5�joinr;�format_listrZDEBUG_STACK_DEPTH�rstripr
�error)rrr2�msg�tbrrr
�__del__�s









zCoroWrapper.__del__)
N)NN)rrrrr3rr�_YIELD_FROM_BUGrr9r<�propertyr=r>r?rZPY35rCrDr@rErFrGrOrrrr
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	Zisfuturer&r'�
isinstancer$�
_AwaitableABCrC�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)rU�kwds�
w)r"rrr
�wrapper�s



zcoroutine.<locals>.wrapper)�_inspect_iscoroutinefunctionr&�isgeneratorfunction�	functools�wraps�_DEBUG�_types_coroutine�
_is_coroutine)rrZr)r"rr
r
�s






c

Cst|d
d�t
kpt|�
S)z6Return True if func is a decorated coroutine function.raN)r-rar[)
rrrr
r�s
c

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

Cs&t|�
st
�
t|d
�r�t|d�r�t|dt|dt|�
j��}
dj|
�
}
d}y
|j}Wn4tk
r�


y
|j	}Wntk
r�


YnXYnX|r�dj|
�
S|
Sd}
t
|t�r�|j}|j
}
|
dk	r�dj|
�
}
n|}|
dkr�tj|fi�}
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dk	�
r�tj|j�
}	|	dk	�
r�|	\}}|dk�
r�d|
||f}nd
|
||f}n:|dk	�r|j}d|
||f}n|�r"|j}d|
||f}|S)NrFr?rrz{}()Fz
{} runningrGr=z<empty co_filename>rz%s done, defined at %s:%sz%s running, defined at %s:%sz%s running at %s:%s)rr(�hasattrr-r:rrBrErTr>rRr$rrrZ_format_callbackrFr?rGr=�co_filenamer&r\Z_get_function_source�f_lineno�co_firstlineno)
r"Z	coro_nameZrunningrZ	coro_codeZ
coro_frame�filename�linenor1�sourcerrr
r/
sz





















































r/).�__all__r]r&Zopcode�osr*r;�typesrHrrrr	�logr
Zopmapr8�flags�ignore_environment�bool�environ�getr_r
r`�
CoroutineTypeZ_types_CoroutineTyperTrr[�collections.abcrZ
_CoroutineABCrrS�ImportErrorr#rPr%r$�objectra�
GeneratorTyperbrr/rrrr
�<module>
sZ

























j: