�
��Vc� c s � d Z ddlZej dk r ed� � �ddlZddlZddlZddlZddlZddl Z ddl
Z
dZ dZ ej
Z
ej Z ej � � Zdde d �d
�Z G d � d � � Z G d
� dej � � ZdS )z)Various Windows specific bits and pieces.� NZwin32z
win32 only)�pipe�Popen�PIPE�
PipeHandlei F)TT)�duplex�
overlapped�bufsizec
sR � 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}dx} }
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)zELike os.pipe() but with overlapped support and using handles not fds.z \\.\pipe\python-pipe-{:d}-{:d}-)Zprefixr i NT�r )�tempfileZmktempZformat�osZgetpidZnext�
_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 ZaddressZopenmodeZaccessZobsizeZibsizeZflags_and_attribsZh1Zh2Zovs �./usr/lib64/python3.11/asyncio/windows_utils.pyr r s� � ��o�1�8�8� �I�K�K��m�,�,�.� .�/� /� /�G� � $��-���%��(=�=�� �'�����.���&���G��� ��5�5�H��!�}� 1��G�0�0���!�}� � #� 8��� ���N�B���
�
$� �X�w� 0�
�v�v�w� ;�W�\�K� K�� �
� �V�Q�� �g�.C� �w�|�-� -�� �
%�b�T�
:�
:�
:��
� � �t�$�$�$��2�v�
���
� $� � �� #� #� #�
� $� � �� #� #� #�
���s
�B E7 �7/F&c sp � e Zd ZdZd� Zd� Zed� � � Zd� Ze j
d�d�Z e j
fd�Zd � Zd
� Zd S ) 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 s � || _ d S �N��_handle��self�handle� r �__init__zPipeHandle.__init__V s
� � �� � � � c sP � | j � d| j ��}nd}d| j j � d|� d�S )Nzhandle=Zclosedz<z z>)r � __class__�__name__r r r �__repr__zPipeHandle.__repr__Y s@ � � �<� �/�t�|�/�/�F�F� �F�6�4�>�*�6�6�V�6�6�6�6r c s � | j S r r �r � r r zPipeHandle.handle` s
� ��|�r c s< � | j �t d� � �| j S )Nz I/O operation on closed pipe)r Z
ValueErrorr r r �filenozPipeHandle.filenod s# � � �<� =� � ;�<�<� <��|�r )r
c sF � | j � || j � � d | _ d S d S r r )r r
r r �closezPipeHandle.closei s3 � � �<� � �K�� � %� %� %� �D�L�L�L� � r c sl � | j �, |d| ��t | �� � | � � � d S d S )Nz unclosed )Zsource)r ZResourceWarningr )r Z_warnr r �__del__zPipeHandle.__del__n sG � � �<� � �E�&�d�&�&��� E� E� E� E� �J�J�L�L�L�L�L� � r c s � | S r � r r r � __enter__zPipeHandle.__enter__s s � �� r c s. � | � � � d S r )r )r ZtZvZtbs r �__exit__zPipeHandle.__exit__v s � � �
�
� � � � � r N)r �
__module__� __qualname__�__doc__r r Zpropertyr r r r
r �warningsZwarnr r! r" r r r r r Q s� � � � � � �� � � � �7� 7� 7� � � � �X� � � � �
$+�#6� � � � � �
%�M� � � � �
� � �� � � � r r c s$ � � e Zd ZdZd� fd� Z� xZS )r z�Replacement for subprocess.Popen using overlapped pipe handles.
The stdin, stdout, stderr are None or instances of PipeHandle.
Nc s� �� |� d� � rJ �|� dd� � dk sJ �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)
NZuniversal_newlinesr r )FTT)r r )TFr )�stdin�stdout�stderr)Zgetr r �msvcrtZopen_osfhandler
ZO_RDONLY�STDOUTZsuperr r r' r( r) r r
r )r Zargsr' r( r) ZkwdsZ stdin_rfdZ
stdout_wfdZ
stderr_wfdZstdin_whZ stdout_rhZ stderr_rhZstdin_rhZ stdout_whZ stderr_whZhr s �r r zPopen.__init__� s� �� ��8�8� 0�1�1�1�1�1��x�x� �1�%�%��*�*�*�*�.2�2� �2�J��+/�/��/�9�y� �D�=� �!%� �t�!L�!L�!L� �H�h� �-�h�� �D�D�I�I� �I� �T�>� �#'�=�#A�#A�#A� �I�y� �.�y�!�<�<�J�J� �J� �T�>� �#'�=�#A�#A�#A� �I�y� �.�y�!�<�<�J�J�
�v�
� �#�J�J� �J� %� �E�G�G� �T�
8��:�$.�
8�
8�26�
8�
8�
8� �
2� '�� 1� 1��
��
4� (�� 3� 3�� ��
4� (�� 3� 3�� ��� � � �9�5�
+�
+��� +��'��*�*�*�� ���� ��}�
$����#�#�#���~�
%����$�$�$���~�
%����$�$�$�$�$�
%�
%�� ��}�
$����#�#�#���~�
%����$�$�$���~�
%����$�$�$�$�
%���s �= E �AG# � !E?�?G# �#A I)NNN)r r# r$ r% r Z
__classcell__)r s @r r r } sG �� � � � � �� �+%� +%� +%� +%� +%� +%� +%� +%� +%� +%r r )r% ZsysZplatformZ ImportErrorr Z itertoolsr* r
Z
subprocessr r& Z__all__ZBUFSIZEr r+ Zcountr r r r r r r �<module>r, s' �� /� /�
�
�
�
��<�7�� $�
�+�l�
#�
#�#� ���� � � � �
�
�
�
� � � � � � � � � ���� ���� 0�� ����� � �� � ��!�!�
� �\�7� +� +� +� +� +�b&� &� &� &� &� &� &� &�X0%� 0%� 0%� 0%� 0%�J� � 0%� 0%� 0%� 0%� 0%r