File manager

3


 \��@s�dZd
dl
Z
e
jdkred�
�
d
dlZd
dlZd
dlZd
dlZd
dlZd
dl	Z	d
dl
Z
d
dlZddddd	gZd
Z
e	jZe	jZej�Zeed�r�ejZnejejd
fdd�
Zdde
d�dd�ZGdd	�d	�ZGdd�de	j�ZdS)z*
Various Windows specific bits and pieces
�NZwin32z
win32 only�
socketpair�pipe�Popen�PIPE�
PipeHandlei c
Cs
|tj
krd
}n|tjkr d}ntd�
�
|
tjkr:td�
�
|dkrJtd�
�
tj||
|�}z�|j|df�

|jd�

|j�dd	�\}}tj||
|�}yP|jd
�

y|j	||f�

Wnt
tfk
r�


YnX|jd�

|j�\}}	Wn


|j
�
�YnXWd|j
�
X||fS)z�A socket pair usable as a self-pipe, for Windows.

        Origin: https://gist.github.com/4325783, by Geert Jansen.
        Public domain.
        z	127.0.0.1z::1z?Only AF_INET and AF_INET6 socket address families are supportedz)Only SOCK_STREAM socket type is supportedr
zOnly protocol zero is supported�
N�FT)�socket�AF_INETZAF_INET6�
ValueError�SOCK_STREAMZbindZlistenZgetsocknameZsetblockingZconnect�BlockingIOError�InterruptedErrorZaccept�close)
Zfamily�type�proto�hostZlsockZaddrZportZcsockZssock�
_�r�-/usr/lib64/python3.6/asyncio/windows_utils.pyr%s8




























FT)�duplex�
overlapped�bufsizecCs"
tj
d
tj�tt�
fd�
}|r>tj}tjtj	B}||}}ntj
}tj	}d|}}|tjO}|
drp|tjO}|
dr�tj}nd}d}	}
yZtj
||tjd||tjtj�}	tj||dtjtj|tj�}
tj|	dd�}|jd�

|	|
fS


|	dk	�
rtj|	�

|
dk	�
rtj|
�

�YnXdS)zELike os.pipe() but with overlapped support and using handles not fds.z\\.\pipe\python-pipe-%d-%d-)
�prefixr
rNT)
r)�tempfileZmktemp�os�getpid�next�
_mmap_counter�_winapiZPIPE_ACCESS_DUPLEXZGENERIC_READZ
GENERIC_WRITEZPIPE_ACCESS_INBOUNDZFILE_FLAG_FIRST_PIPE_INSTANCEZFILE_FLAG_OVERLAPPEDZCreateNamedPipeZ	PIPE_WAITZNMPWAIT_WAIT_FOREVERZNULLZ
CreateFileZ
OPEN_EXISTINGZConnectNamedPipeZGetOverlappedResult�CloseHandle)rrrZaddressZopenmode�accessZobsizeZibsizeZflags_and_attribsZh1Zh2ZovrrrrSs@






























c@s\eZ
dZd
Zdd�Zdd�Zedd��
Zdd	�Ze	j
d
�
dd�Zd
d�Zdd�Z
dd�ZdS)rz�Wrapper for an overlapped pipe handle which is vaguely file-object like.

    The IOCP event loop can use these instead of socket objects.
    cCs
|
|_dS)
N)
�_handle)�self�handlerrr�__init__�s
zPipeHandle.__init__c
Cs*|jdk	rd
|j}
nd}
d|j
j|
fS)Nz	handle=%r�closedz<%s %s>)r"�	__class__�__name__)r#r$rrr�__repr__�s



zPipeHandle.__repr__c


Cs|jS)
N)
r")
r#rrrr$�szPipeHandle.handlec

Cs|jdkrt
d
�
�
|jS)NzI/O operatioon on closed pipe)r"r)
r#rrr�fileno�s



zPipeHandle.fileno)
r c

Cs|jdk	r|
|j�

d|_dS)
N)
r")r#r rrrr�s




zPipeHandle.closec

Cs*|jdk	r&t
jd
|t|d�
|j�
dS)Nzunclosed %r)
�source)r"�warnings�warn�ResourceWarningr)
r#rrr�__del__�s




zPipeHandle.__del__c


Cs|S)
Nr)
r#rrr�	__enter__�s
zPipeHandle.__enter__c
Cs|j�
dS)
N)
r)r#�
t�
v�tbrrr�__exit__�s
zPipeHandle.__exit__N)r(�
__module__�__qualname__�__doc__r%r)�propertyr$r*rr rr/r0r4rrrrr�s
cs"eZ
dZd
Zd�f
dd�	Z�ZS)rz�Replacement for subprocess.Popen using overlapped pipe handles.

    The stdin, stdout, stderr are None or instances of PipeHandle.
    Ncs�
|jd
�
st
�
|jdd�dks$t
�
d}}}d}	}
}|tkrdtd	dd�\}}	tj|tj�}n|}|tkr�td
d�
\}
}
tj|
d�}n|}|tkr�tdd�
\}}tj|d�}n|tkr�|}n|}z�y t	�j
|
f
|||d�|��

Wn8


x(|	|
|fD]}|dk	�r�tj|�

�q�W�Yn>X|	dk	�
r6t
|	�
|_|
dk	�
rJt
|
�
|_|dk	�
r^t
|�
|_Wd|tk�
rvtj|�

|tk�
r�tj|�

|tk�
r�tj|�

XdS)NZuniversal_newlinesrr
FT)rr)
r)�stdin�stdout�stderr)FT)TF)TF)�get�AssertionErrorrr�msvcrtZopen_osfhandler�O_RDONLY�STDOUT�superr%rr rr9r:r;r)r#�argsr9r:r;�kwdsZ	stdin_rfdZ
stdout_wfdZ
stderr_wfdZstdin_whZ	stdout_rhZ	stderr_rhZstdin_rhZ	stdout_whZ	stderr_wh�
h)
r'rrr%�sL











































zPopen.__init__)NNN)r(r5r6r7r%�
__classcell__rr)
r'rr�s
)TT)r7�sys�platform�ImportErrorr�	itertoolsr>rr	�
subprocessrr,�__all__ZBUFSIZErr@�countr�hasattrrr
rrrrrrrr�<module>s,












.0-