a
i @ s d Z ddlZejdkr edddlZddlZddlZddlZddlZddl 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. Nwin32z
win32 only)pipePopenPIPE
PipeHandlei F)TT)duplex
overlappedbufsizec
C s$ t jdt ttd}| r>tj}tj tj
B }|| }}ntj }tj
}d| }}|tj O }|d rp|tj
O }|d rtj
}nd}d } }
z\t||tjd||tjtj} t||dtjtj|tj}
tj| dd} | d | |
fW S | durt| |
durt|
Y n0 dS )zELike os.pipe() but with overlapped support and using handles not fds.z \\.\pipe\python-pipe-{:d}-{:d}-)prefixr NTr )tempfilemktempformatosgetpidnext
_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 addressZopenmodeaccessZobsizeZibsizeZflags_and_attribsZh1Zh2Zov r -/usr/lib64/python3.9/asyncio/windows_utils.pyr sJ
r c @ sb e Zd ZdZdd Zdd Zedd Zdd Ze j
d
d d Z e j
fd
dZdd Zdd ZdS )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 C s
|| _ d S N_handleselfhandler r r __init__V s zPipeHandle.__init__c C s2 | j d urd| j }nd}d| jj d| dS )Nzhandle=closed< >)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 rtd| 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 r r )r r r r r closei s
zPipeHandle.closec C s* | j d ur&|d| t| d | d S )Nz unclosed )source)r ResourceWarningr+ )r _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/ r0 r4 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 | drJ | dddks"J d } }}d } }
} |tkrbtddd\} } t| tj}n|}|tkrtdd\}
}
t|
d}n|}|tkrtdd\} }t|d}n|tkr|}n|}zz t j |f|||d | W n0 | |
| fD ]}|d urt
| q Y n>0 | d ur,t | | _
|
d ur@t |
| _| d urTt | | _W |tkrjt| |tkr~t| |tkrt| n>|tkrt| |tkrt| |tkrt| 0 d S )
Nuniversal_newlinesr r )FTT)r r )TFr )stdinstdoutstderr)getr r msvcrtopen_osfhandler O_RDONLYSTDOUTsuperr r r r r< r= r> r+ )r argsr< r= r> kwdsZ stdin_rfdZ
stdout_wfdZ
stderr_wfdZstdin_whZ stdout_rhZ stderr_rhZstdin_rhZ stdout_whZ stderr_whhr% r r r s^
zPopen.__init__)NNN)r& r5 r6 r7 r
__classcell__r r rH r r } s r )r7 sysplatform ImportErrorr itertoolsr@ r
subprocessr
r9 __all__BUFSIZEr rC countr r r r r r r r