ikan Uploader :
Directory : /opt/alt/python37/lib64/python3.7/asyncio/__pycache__/
Upload File : |
| Current File : //opt/alt/python37/lib64/python3.7/asyncio/__pycache__/windows_utils.cpython-37.pyc |
B
� f� � @ s� d Z ddlZejdkr ed��ddlZddlZddlZddlZddlZddl Z ddl
Z
dZ dZ ej
Z
ejZe�� Zdde d �d
d �ZG d d
� d
�ZG dd� dej�ZdS )z)Various Windows specific bits and pieces.� NZwin32z
win32 only)�pipe�Popen�PIPE�
PipeHandlei F)TT)�duplex�
overlapped�bufsizec
C s" t jd�t�� tt��d�}| r>tj}tj tj
B }|| }}ntj }tj
}d| }}|tj O }|d rp|tj
O }|d r�tj
}nd}d } }
yZt�||tjd||tjtj�} t�||dtjtj|tj�}
tj| dd�} | �d� | |
fS | dk �rt�| � |
dk �rt�|
� � Y nX dS )zELike os.pipe() but with overlapped support and using handles not fds.z \\.\pipe\python-pipe-{:d}-{:d}-)�prefixr � NT)r )�tempfileZmktemp�format�os�getpid�next�
_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 ZaddressZopenmode�accessZobsizeZibsizeZflags_and_attribsZh1Zh2Zov� r �:/opt/alt/python37/lib64/python3.7/asyncio/windows_utils.pyr sB
r c @ s\ e Zd ZdZdd� Zdd� Zedd� �Zdd � Ze j
d
�d d �Z d
d� Z dd� Z
dd� ZdS )r z�Wrapper 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)�_handle)�self�handler r r �__init__V s zPipeHandle.__init__c C s2 | j d k rd| j ��}nd}d| jj� d|� d�S )Nzhandle=�closed�<� �>)r � __class__�__name__)r r r r r �__repr__Y s
zPipeHandle.__repr__c C s | j S )N)r )r r r r r ` s zPipeHandle.handlec C s | j d krtd��| j S )Nz I/O operation on closed pipe)r �
ValueError)r r r r �filenod s
zPipeHandle.fileno)r c C s | j d k r|| j � d | _ d S )N)r )r r r r r �closei s
zPipeHandle.closec C s, | j d k r(tjd| ��t| d� | �� d S )Nz unclosed )�source)r �warnings�warn�ResourceWarningr# )r r r r �__del__n s
zPipeHandle.__del__c C s | S )Nr )r r r r � __enter__t s zPipeHandle.__enter__c C s | � � d S )N)r# )r �t�v�tbr r r �__exit__w s zPipeHandle.__exit__N)r �
__module__� __qualname__�__doc__r r �propertyr r" r r r# r( r) r- r r r r r Q s r c s" e Zd ZdZd� fdd� Z� ZS )r z�Replacement for subprocess.Popen using overlapped pipe handles.
The stdin, stdout, stderr are None or instances of PipeHandle.
Nc s� |� d�rt�|� dd�dks"t�d } }}d } }
} |tkrbtddd�\} } t�| tj�}n|}|tkr�tdd�\}
}
t�|
d�}n|}|tkr�tdd�\} }t�|d�}n|tkr�|}n|}z�y t � j
|f|||d �|�� W n4 x$| |
| fD ]}|d k r�t � |� q�W � Y n>X | d k �r0t
| �| _|
d k �rDt
|
�| _| d k �rXt
| �| _W d |tk�rpt�|� |tk�r�t�|� |tk�r�t�|� X d S )
NZuniversal_newlinesr r )FTT)r r )TF)r )�stdin�stdout�stderr)�get�AssertionErrorr r �msvcrtZopen_osfhandler
�O_RDONLY�STDOUT�superr r r r r2 r3 r4 r# )r �argsr2 r3 r4 �kwdsZ stdin_rfdZ
stdout_wfdZ
stderr_wfdZstdin_whZ stdout_rhZ stderr_rhZstdin_rhZ stdout_whZ stderr_wh�h)r r r r � sL
zPopen.__init__)NNN)r r. r/ r0 r �
__classcell__r r )r r r ~ s r )r0 �sys�platform� ImportErrorr � itertoolsr7 r
�
subprocessr r% �__all__ZBUFSIZEr r9 �countr r r r r r r r �<module> s$
1-
........