VH|u d Z ddlZej dk r ed ddlZddlZddlZddlZddlZddl Z ddl
Z
dZ dZ ej
Z
ej Z ej Zdde d d
Z G d d Z G d
dej ZdS )z)Various Windows specific bits and pieces. Nwin32z
win32 only)pipePopenPIPE
PipeHandlei F)TT)duplex
overlappedbufsizec
R t j d t j t t }| r*t j }t j t j
z }||}}n t j }t j
}d|}}|t j z }|d r|t j
z }|d r
t j
}nd}dx} }
t j ||t j d||t j t j } t j ||dt j t j |t j }
t j | d } | d | |
fS # | t j | |
t j |
xY w)zELike os.pipe() but with overlapped support and using handles not fds.z \\.\pipe\python-pipe-{:d}-{:d}-)prefixr NTr )tempfilemktempformatosgetpidnext
_mmap_counter_winapiPIPE_ACCESS_DUPLEX GENERIC_READ
GENERIC_WRITEPIPE_ACCESS_INBOUND FILE_FLAG_FIRST_PIPE_INSTANCEFILE_FLAG_OVERLAPPEDCreateNamedPipe PIPE_WAITNMPWAIT_WAIT_FOREVERNULL
CreateFile
OPEN_EXISTINGConnectNamedPipeGetOverlappedResult CloseHandle) r r r
addressopenmodeaccessobsizeibsizeflags_and_attribsh1h2ovs # # #
> # # #
s
B E7 7/F&c p e Zd ZdZd Zd Zed Zd Ze j
ddZ e j
fdZd Zd
Zd S ) r zWrapper for an overlapped pipe handle which is vaguely file-object like.
The IOCP event loop can use these instead of socket objects.
c || _ d S N_handleselfhandles r/ __init__zPipeHandle.__init__V s
c P | j d| j }nd}d| j j d| dS )Nzhandle=closed< >)r4 __class____name__r5 s r/ __repr__zPipeHandle.__repr__Y s> < #/t|//FF F64>*66V6666r9 c | j S r2 r3 r6 s r/ r7 zPipeHandle.handle` s
|r9 c < | j t d | j S )Nz I/O operation on closed pipe)r4
ValueErrorrC s r/ filenozPipeHandle.filenod s! < ;<< <|r9 )r% c F | j || j d | _ d S d S r2 r3 )r6 r% s r/ closezPipeHandle.closei s/ < # K % % % DLLL $ #r9 c l | j , |d| t | | d S d S )Nz unclosed )source)r4 ResourceWarningrH )r6 _warns r/ __del__zPipeHandle.__del__n sC < # E&d&& E E E E JJLLLLL $ #r9 c | S r2 rC s r/ __enter__zPipeHandle.__enter__s s r9 c . | d S r2 )rH )r6 tvtbs r/ __exit__zPipeHandle.__exit__v s
r9 N)r@
__module__ __qualname____doc__r8 rA propertyr7 rF r r% rH warningswarnrM rP rU rO r9 r/ r r Q s 7 7 7 X
$+#6
%M
r9 r c $ e Zd ZdZd fd Z xZS )r zReplacement for subprocess.Popen using overlapped pipe handles.
The stdin, stdout, stderr are None or instances of PipeHandle.
Nc | d rJ | dd dk sJ d x}x}}d x} x}
} |t k r4t dd \ } } t j | t
j }n|}|t k r)t d \ }
}
t j |
d }n|}|t k r)t d \ } }t j |d }n|t k r|}n|} t j |f|||d | | t | | _ |
t |
| _ | t | | _
n$# | |
| fD ]}|t j | xY w|t k rt j | |t k rt j | |t k rt j | d S d S # |t k rt j | |t k rt j | |t k rt j | w w xY w)
Nuniversal_newlinesr
r )FTT)r r )TFr )stdinstdoutstderr)getr r msvcrtopen_osfhandler O_RDONLYSTDOUTsuperr8 r r_ r` ra r r% rH )r6 argsr_ r` ra kwds stdin_rfd
stdout_wfd
stderr_wfdstdin_wh stdout_rh stderr_rhstdin_rh stdout_wh stderr_whhr? s r/ r8 zPopen.__init__ s} 88 011111xx 1%%****.22 2J+///9y D==!% t!L!L!L Hh -h DDII I T>>#'=#A#A#A Iy .y!<