← Back
Editing: popen_forkserver.cpython-312.pyc
� �֦i� � �� � d dl Z d dlZddlmZmZ ej s ed� �ddlmZ ddlm Z ddlm Z ddlm Z d gZ G d � d e � Z G d � d e j � Zy) � N� )� reduction�set_spawning_popenz,No support for sending fds between processes)� forkserver)� popen_fork)�spawn)�util�Popenc � � e Zd Zd� Zd� Zy)�_DupFdc � � || _ y �N)�ind)�selfr s �9/usr/lib64/python3.12/multiprocessing/popen_forkserver.py�__init__z_DupFd.__init__ s � ���� c �D � t j � | j S r )r �get_inherited_fdsr )r s r �detachz _DupFd.detach s � ��+�+�-�d�h�h�7�7r N)�__name__� __module__� __qualname__r r � r r r r s � ��8r r c �P � � e Zd ZdZeZ� fd�Zd� Zd� Ze j fd�Z � xZ S )r r c �2 �� g | _ t �| � |� y r )�_fds�superr )r � process_obj� __class__s �r r zPopen.__init__! s �� ��� � ����%r c �h � | j j |� t | j � dz S )Nr )r �append�len)r �fds r �duplicate_for_childzPopen.duplicate_for_child% s' � � � � ���� ��4�9�9�~��!�!r c � � t j |j � }t j � }t | � t j ||� t j ||� t d � t j | j � \ | _ }t j |� }t j | t j || j f� | _ t% |dd�� 5 }|j' |j) � � d d d � t j* | j � | _ y # t d � w xY w# 1 sw Y �>xY w)N�wbT)�closefd)r �get_preparation_data�_name�io�BytesIOr r �dumpr �connect_to_new_processr �sentinel�os�dupr �Finalize� close_fds� finalizer�open�write� getbuffer� read_signed�pid)r r � prep_data�buf�w� _parent_w�fs r �_launchz Popen._launch) s� � ��.�.�{�/@�/@�A� ��j�j�l���4� � %� �N�N�9�c� *� �N�N�;�� ,� �t� $�%�<�<�T�Y�Y�G��� �q� �F�F�1�I� � � � �t�T�^�^�(1�4�=�=�'A�C��� �!�T�4� (�A� �G�G�C�M�M�O� $� )� �)�)�$�-�-�8���� �t� $�� )� (�s � ,E �7 E� E�E c �F � | j �cddlm} |t j k( rdnd } || j g|� sy t j | j � | _ | j S | j S # t t f$ r d| _ Y | j S w xY w)Nr )�wait� ) � returncode�multiprocessing.connectionrA r0 �WNOHANGr/ r r8 �OSError�EOFError)r �flagrA �timeouts r �pollz Popen.poll= s� � � �?�?� "� 7� �2�:�:�-�a�4�G��� � ���1�� &�",�"8�"8�� � �"G��� ��� �t��� �� �X�&� &� #&������ � &�s � $A< �<B � B ) r r r �methodr �DupFdr r% r? r0 rE rJ � __classcell__)r s @r r r s* �� � �F� �E�&�"�9�( � � � r )r+ r0 �contextr r �HAVE_SEND_HANDLE� ImportError� r r r r �__all__�objectr r r r r �<module>rT sV �� � � 2��!�!� �D� E�E� � � � � �)�� 8�V� 8�- �J� � � - r
Save File
Cancel