*j^ S r SSKr\R S:w a \" S5 eSSKrSSKrSSKrSSKrSSKrSSK r Sr
Sr \R r \R r
\R " 5 rSrSS \ S
.S jr " S S
5 r " S S\R& 5 rg)z)Various Windows specific bits and pieces. Nwin32z
win32 only)pipePopenPIPE
PipeHandlei F)TT)duplex
overlappedbufsizec U ( a4 [ R n[ R [ R - nX"peO#[ R n[ R nSUpeU[ R
- nUS ( a U[ R - nUS ( a [ R nOSnS=p [ R " 5 H n
SR [ R " 5 [ [ 5 [ R " S5 R 5 5 n [ R " X[ R" SXV[ R$ [ R& 5 n O [ R2 " W US[ R& [ R4 U[ R& 5 n [ R6 " USS9n
U
R9 S5 X4$ ! [( aF n U
[* : a e U R, [ R. [ R0 4; a e Sn A GM\ Sn A ff = f! Ub [ R: " U5 U b [ R: " U 5 e = f)zELike os.pipe() but with overlapped support and using handles not fds.r Nz!\\.\pipe\python-pipe-{:d}-{:d}-{} Tr
) _winapiPIPE_ACCESS_DUPLEX GENERIC_READ
GENERIC_WRITEPIPE_ACCESS_INBOUND FILE_FLAG_FIRST_PIPE_INSTANCEFILE_FLAG_OVERLAPPED itertoolscountformatosgetpidnext
_mmap_counterurandomhexCreateNamedPipe PIPE_WAITNMPWAIT_WAIT_FOREVERNULLOSError_MAX_PIPE_ATTEMPTSwinerrorERROR_PIPE_BUSYERROR_ACCESS_DENIED
CreateFile
OPEN_EXISTINGConnectNamedPipeGetOverlappedResult CloseHandle)r r
r openmodeaccessobsizeibsizeflags_and_attribsh1h2attemptsaddresseovs #
> #
s9 0A-H) AG#A2H)
H& :H!H) !H&&H) )5I c \ rS rSrSrS rS r\S 5 rS r \
R S.S jr \
R 4S jrS
rS rS rg
)r X zWrapper for an overlapped pipe handle which is vaguely file-object like.
The IOCP event loop can use these instead of socket objects.
c Xl g N_handleselfhandles r9 __init__PipeHandle.__init__] s c | U R b SU R < 3nOSnSU R R SU S3$ )Nzhandle=closed< >)r? __class____name__r@ s r9 __repr__PipeHandle.__repr__` sB << # t|| ./F F4>>**+1VHA66rE c U R $ r= r> rA s r9 rB PipeHandle.handleg s ||rE c J U R c [ S5 eU R $ )Nz I/O operation on closed pipe)r?
ValueErrorrP s r9 filenoPipeHandle.filenok s" << ;< <||rE )r- c V U R b U R nS U l U" U5 g g r= r> )rA r- rB s r9 closePipeHandle.closep s) << #\\F DL $rE c ` U R b! U" SU < 3[ U S9 U R 5 g g )Nz unclosed )source)r? ResourceWarningrW )rA _warns r9 __del__PipeHandle.__del__v s- << # IdX& E JJL $rE c U $ r= rP s r9 __enter__PipeHandle.__enter__{ s rE c $ U R 5 g r= )rW )rA tvtbs r9 __exit__PipeHandle.__exit__~ s
rE r> N)rL
__module__ __qualname____firstlineno____doc__rC rM propertyrB rT r r- rW warningswarnr] ra rg __static_attributes__r` rE r9 r r X sR 7
$+#6#6 %MM
rE r c 0 ^ \ rS rSrSrSU 4S jjrSrU =r$ )r zReplacement for subprocess.Popen using overlapped pipe handles.
The stdin, stdout, stderr are None or instances of PipeHandle.
c N > UR S5 ( a eUR SS5 S:X d eS =n=pxS =n =pU[ :X a2 [ SSS9u p[ R " U [
R 5 nOUnU[ :X a# [ SS9u p[ R " U
S5 nOUnU[ :X a# [ SS9u p[ R " US5 nOU[ :X a UnOUn [ TU ]$ " U4XgUS .UD6 U b [ U 5 U l U
b [ U
5 U l U b [ U 5 U l
U[ :X a [
R " U5 U[ :X a [
R " U5 U[ :X a [
R " U5 g g ! XU 4 H nUc M [ R " U5 M e = f! U[ :X a [
R " U5 U[ :X a [
R " U5 U[ :X a [
R " U5 f f = f)
Nuniversal_newlinesr r )FTT)r
r )TFr )stdinstdoutstderr)getr r msvcrtopen_osfhandler O_RDONLYSTDOUTsuperrC r ru rv rw r r- rW )rA argsru rv rw kwds stdin_rfd
stdout_wfd
stderr_wfdstdin_wh stdout_rh stderr_rhstdin_rh stdout_wh stderr_whhrK s r9 rC Popen.__init__ s 88 01111xx 1%***.22 2J+///9 D=!% t!L H --h DI I T>#'=#A I ..y!#'=#A I ..y!#F>>G A#H$)rw ru rv )NNN)rL ri rj rk rl rC rp
__classcell__)rK s @r9 r r s +% +%rE r )rl sysplatform ImportErrorr r ry r
subprocessrn __all__BUFSIZEr r| r r r% r r r r` rE r9 r s /
<<7
l
##
0 !
\7 2p' 'Z0%J 0%rE