�
� Wc� � �* � 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.� N�win32z
win32 only)�pipe�Popen�PIPE�
PipeHandlei F)TT)�duplex�
overlapped�bufsizec
�� � t j dj t j � t t � � �� }| r9t j }t j t j z }||}}n&t j }t j }d|}}|t j z }|d r|t j z }|d rt j }nd}dx} }
t j ||t j d||t j t j" � } t j$ ||dt j" t j& |t j" � }
t j( | d�� } | j+ 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}-)�prefixr � NT�r )�tempfile�mktemp�format�os�getpid�next�
_mmap_counter�_winapi�PIPE_ACCESS_DUPLEX� GENERIC_READ�
GENERIC_WRITE�PIPE_ACCESS_INBOUND� FILE_FLAG_FIRST_PIPE_INSTANCE�FILE_FLAG_OVERLAPPED�CreateNamedPipe� PIPE_WAIT�NMPWAIT_WAIT_FOREVER�NULL�
CreateFile�
OPEN_EXISTING�ConnectNamedPipe�GetOverlappedResult� CloseHandle) r r r
�address�openmode�access�obsize�ibsize�flags_and_attribs�h1�h2�ovs �./usr/lib64/python3.12/asyncio/windows_utils.pyr r s� � ��o�o�1�8�8� �I�I�K��m�,�.�/� /�G� �v��-�-���%�%��(=�(=�=�� �'�����.�.���&�&���G��� ��5�5�5�H��!�}�}��G�0�0�0���!�}�}� #� 8� 8��� ���N�B���
�
$�
$� �X�w� 0� 0�
�v�v�w� ;� ;�W�\�\�K�� �
�
� �V�Q�� � �g�.C�.C� �w�|�|�-�� �
%�
%�b�T�
:�
:��
� � �t�$�$��2�v�
���
�>� � � �� #� #�
�>� � � �� #� #�
���s
� CG �5G9c � � 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 � � || _ d S �N��_handle��self�handles r/ �__init__zPipeHandle.__init__V s
� � �� � � � c �x � | j �d| j ��}nd}d| j j � d|� d�S )Nzhandle=�closed�<� �>)r4 � __class__�__name__r5 s r/ �__repr__zPipeHandle.__repr__Y sG � � �<�<� #�/�t�|�|�/�/�F�F� �F�6�4�>�>�*�*�6�6�V�6�6�6�6r9 c � � | j S r2 r3 �r6 s r/ r7 zPipeHandle.handle` s � ��|�|�r9 c �L � | j �
t d� �| j S )Nz I/O operation on closed pipe)r4 �
ValueErrorrC s r/ �filenozPipeHandle.filenod s" � � �<�<� � � ;�<� <��|�|�r9 )r% c �V � | j � || j � d | _ d S d S r2 r3 )r6 r% s r/ �closezPipeHandle.closei s0 � � �<�<� #� �K�� � � %� %� �D�L�L�L� $� #r9 c �l � | j �' |d| ��t | �� | j � d S d S )Nz unclosed )�source)r4 �ResourceWarningrH )r6 �_warns r/ �__del__zPipeHandle.__del__n s@ � � �<�<� #� �E�&�d�&�&��� E� E� E� �J�J�L�L�L�L� $� #r9 c � � | S r2 � rC s r/ � __enter__zPipeHandle.__enter__s s � �� r9 c �( � | j � d S r2 )rH )r6 �t�v�tbs r/ �__exit__zPipeHandle.__exit__v s � � �
�
� � � � r9 N)r@ �
__module__� __qualname__�__doc__r8 rA �propertyr7 rF r r% rH �warnings�warnrM rP rU rO r9 r/ r r Q s� � � � � � �� � � � �7� 7� 7� � � � � � � � �
$+�#6�#6� � � � � �
%�M�M� � � � �
� � �� � � � r9 r c �$ � � 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 �\ �� d x}x}}d x} x}
} |t k r:t 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 | � | _ |t k rt j |� |t k rt j |� |t k rt j |� d S d S # | |
| fD ] }|��t j |� � � xY w# |t k rt j |� |t k rt j |� |t k rt j |� w xY w)N)FTT)r r )TFr r )�stdin�stdout�stderr)r r �msvcrt�open_osfhandler �O_RDONLY�STDOUT�superr8 r r^ r_ r` r r% rH )r6 �argsr^ r_ r` �kwds� stdin_rfd�
stdout_wfd�
stderr_wfd�stdin_wh� stdout_rh� stderr_rh�stdin_rh� stdout_wh� stderr_wh�hr? s �r/ r8 zPopen.__init__� s= �� � /3�2� �2�J��+/�/��/�9�y� �D�=�=�!%� �t�!L�!L� �H�h� �-�-�h�� � �D�I�I� �I� �T�>�>�#'�=�#A�#A� �I�y� �.�.�y�!�<�J�J� �J� �T�>�>�#'�=�#A�#A� �I�y� �.�.�y�!�<�J�J�
�v�
�
�#�J�J� �J� %� �E�G� � �T�
8��:�$.�
8�
8�26�
8�
8�
8� �#� '�� 1��
��$� (�� 3�� ��$� (�� 3�� � ���}�}�����#�#���~�~�����$�$���~�~�����$�$�$�$� �~��# � � �9�5�
+�
+���=���'�'��*�*�*� ����� ��}�}�����#�#���~�~�����$�$���~�~�����$�$�
%�
%�
%�
%s% �!F �3=G � G �'G � G �A(H+)NNN)r@ rV rW rX r8 �
__classcell__)r? s @r/ r r } sG �� � � � � �� �+%� +%� +%� +%� +%� +%� +%� +%� +%� +%r9 r )rX �sys�platform� ImportErrorr � itertoolsra r �
subprocessr rZ �__all__�BUFSIZEr rd �countr r r r rO r9 r/ �<module>r{ s! �� /� /�
�
�
�
��<�<�7���
�+�l�
#�#� ���� � � � �
�
�
�
� � � � � � � � � ���� ���� 0�� ������ � � �� � ���!�
� �\�7� +� +� +� +� +�b&� &� &� &� &� &� &�X0%� 0%� 0%� 0%� 0%�J� � � 0%� 0%� 0%� 0%r9