VH|u d dl Z e j dk r ed d dlZd dlZd dlZd dlZd dlZd dlZd dl Z dZ
dZ ej Z ej
Z
ej Zdde dd Z G d
d Z G d d
ej ZdS ) Nwin32z
win32 only)pipePopenPIPE
PipeHandlei F)TT)duplex
overlappedbufsizec
T 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}d x} }
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)Nz \\.\pipe\python-pipe-{:d}-{:d}-)prefixr Tr )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 E8 8/F'c n e Zd Z d Zd Zed Zd Zej ddZ
e j fdZ
d Zd Zd
S ) r 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__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 Z d fd Z xZS )r Nc & 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)N)FTT)r r )TFr r )stdinstdoutstderr)r r msvcrtopen_osfhandler O_RDONLYSTDOUTsuperr8 r r] r^ r_ r r% rH )r6 argsr] r^ r_ kwds stdin_rfd
stdout_wfd
stderr_wfdstdin_wh stdout_rh stderr_rhstdin_rh stdout_wh stderr_whhr? s r/ r8 zPopen.__init__ sG /32 2J+///9y D==!% t!L!L!L Hh -h DDII I T>>#'=#A#A#A Iy .y!<>#'=#A#A#A Iy .y!<