ruạṛ
� T��hI � �< � d dl Z d dlZddlmZ dgZ G d� de� Zy)� N� )�util�Popenc �` � e Zd ZdZd� Zd� Zej fd�Zd d�Z d� Z d� Z d � Z d � Z d � Zy) r �forkc �j � t j � d | _ d | _ | j |� y �N)r �_flush_std_streams� returncode� finalizer�_launch)�self� process_objs �3/usr/lib64/python3.12/multiprocessing/popen_fork.py�__init__zPopen.__init__ s( � � � � �!� ��� ��� � � �[�!� c � � |S r � )r �fds r �duplicate_for_childzPopen.duplicate_for_child s � �� r c �� � | j �M t j | j |� \ }}|| j k( rt j |� | _ | j S # t $ r Y y w xY wr )r �os�waitpid�pid�OSError�waitstatus_to_exitcode)r �flagr �stss r �pollz Popen.poll sh � � �?�?� "� � �:�:�d�h�h��5���S� �d�h�h��"$�";�";�C�"@������ �� � � � �s �#A& �& A2�1A2Nc � � | j �G|�ddlm} || j g|� sy | j |dk( rt j � S d� S | j S )Nr )�waitg )r �multiprocessing.connectionr! �sentinelr r �WNOHANG)r �timeoutr! s r r! z Popen.wait$ sS � � �?�?� "��"�;��T�]�]�O�W�5� ��9�9�7�c�>�R�Z�Z�A� A�q�A� A���� r c � � | j �" t j | j |� y y # t $ r Y y t $ r | j d�� �� Y y w xY w)Ng�������?)r% )r r �killr �ProcessLookupErrorr r! )r �sigs r � _send_signalzPopen._send_signal. s] � � �?�?� "� �������#�&� #�� &� ��� ��9�9�S�9�)�1�� 2� �s � 0 � A�A�Ac �B � | j t j � y r )r* �signal�SIGTERM�r s r � terminatezPopen.terminate8 � � � ���&�.�.�)r c �B � | j t j � y r )r* r, �SIGKILLr. s r r' z Popen.kill; r0 r c �H � d}t j � \ }}t j � \ }}t j � | _ | j dk( rS t j |� t j |� |j |�� }t j |� y t j |� t j |� t j | t j ||f� | _ || _ y # t j |� w xY w)Nr r )�parent_sentinel) r �piper r �close� _bootstrap�_exitr �Finalize� close_fdsr r# )r r �code�parent_r�child_w�child_r�parent_ws r r z Popen._launch> s� � ��� �G�G�I���'� �G�G�I�����7�7�9��� �8�8�q�=� �����"�����"�"�-�-�g�-�F������� �H�H�W� � �H�H�W� � !�]�]�4�� � �,4�h�+@� B�D�N� $�D�M�� �����s �<D � D!c �> � | j �| j � y y r )r r. s r r6 z Popen.closeQ s � � �>�>� %� �N�N� � &r r )�__name__� __module__� __qualname__�methodr r r r$ r r! r* r/ r' r r6 r r r r r s= � � �F�"� � � � � � ��*�*�%�& r )r r, � r �__all__�objectr r r r �<module>rH s# �� � � � �)�� G �F� G r
cải xoăn