o
0i @ s d Z ddlZejdkredddlZddlZddlZddlZddlZddl Z ddl
Z
dZ dZ ej
Z
ejZe Zdde d d
d ZG d d
d
ZG dd dejZdS )z)Various Windows specific bits and pieces. NZwin32z
win32 only)pipePopenPIPE
PipeHandlei F)TT)duplex
overlappedbufsizec
C s t jdt ttd}| r tj}tj tj
B }||}}n tj }tj
}d|}}|tj O }|d r8|tj
O }|d r@tj
}nd}d } }
z.t||tjd||tjtj} t||dtjtj|tj}
tj| dd} | d | |
fW S | durt| |
durt|
)zELike os.pipe() but with overlapped support and using handles not fds.z \\.\pipe\python-pipe-{:d}-{:d}-)prefixr NTr )tempfileZmktempformatosgetpidnext
_mmap_counter_winapiZPIPE_ACCESS_DUPLEXZ GENERIC_READZ
GENERIC_WRITEZPIPE_ACCESS_INBOUNDZ FILE_FLAG_FIRST_PIPE_INSTANCEZFILE_FLAG_OVERLAPPEDZCreateNamedPipeZ PIPE_WAITZNMPWAIT_WAIT_FOREVERZNULLZ
CreateFileZ
OPEN_EXISTINGZConnectNamedPipeZGetOverlappedResult CloseHandle) r r r ZaddressZopenmodeaccessZobsizeZibsizeZflags_and_attribsZh1Zh2Zov r )r __class____name__r r r r __repr__Y s
zPipeHandle.__repr__c C s | j S r r r r r r r ` s zPipeHandle.handlec C s | j d u r td| j S )Nz I/O operation on closed pipe)r
ValueErrorr% r r r filenod s
zPipeHandle.fileno)r c C s" | j d ur|| j d | _ d S d S r r )r r r r r closei s
zPipeHandle.closec C s. | j d ur|d| t| d | d S d S )Nz unclosed )source)r ResourceWarningr( )r Z_warnr r r __del__n s
zPipeHandle.__del__c C s | S r r r% r r r __enter__s s zPipeHandle.__enter__c C s | d S r )r( )r tvtbr r r __exit__v s zPipeHandle.__exit__N)r#
__module__ __qualname____doc__r r$ propertyr r' r r r( warningswarnr+ r, r0 r r r r r Q s
r c s" e Zd ZdZd fdd Z ZS )r zReplacement for subprocess.Popen using overlapped pipe handles.
The stdin, stdout, stderr are None or instances of PipeHandle.
Nc s d } }}d } }
} |t kr tddd\} } t| tj}n|}|t kr4tdd\}
}
t|
d}n|}|t krHtdd\} }t|d}n |tkrO|}n|}zazt j|f|||d| W n | |
| fD ] }|d urvt
| qk | d urt | | _ |
d urt |
| _
| d urt | | _W |t krt| |t krt| |t krt| d S d S |t krt| |t krt| |t krt| w w )N)FTT)r r )TFr r )stdinstdoutstderr)r r msvcrtZopen_osfhandler O_RDONLYSTDOUTsuperr r r r r7 r8 r9 r( )r argsr7 r8 r9 kwdsZ stdin_rfdZ
stdout_wfdZ
stderr_wfdZstdin_whZ stdout_rhZ stderr_rhZstdin_rhZ stdout_whZ stderr_whhr" r r r sb
zPopen.__init__)NNN)r# r1 r2 r3 r
__classcell__r r rA r r } s r )r3 sysplatform ImportErrorr itertoolsr: r
subprocessr r5 __all__ZBUFSIZEr r< countr r r r r r r r s&
1,