/
lib64
/
python3.12
/
multiprocessing
/
__pycache__
/
up file
home
� �֦i � � � d dl Z d dlZd dlZd dlZd dlZddlmZ ddlmZ ddlm Z dgZ ej dk( re dgz Z G d � de � Z ne d gz Z G d � d e � Z G d � d e � Z e� Zej" Zy)� N� )�process)� reduction)�util�stop�win32� DupSocketc � � e Zd Z d� Zd� Zy)r c �z �� |j � ��fd�}t j |�j � | _ y )Nc �J �� �j |� }| j |� y �N)�share� send_bytes)�conn�pidr �new_socks ��8/usr/lib64/python3.12/multiprocessing/resource_sharer.py�sendz DupSocket.__init__.<locals>.send s �� � ���s�+������&� )�dup�_resource_sharer�register�close�_id)�self�sockr r s @r �__init__zDupSocket.__init__ s- �� ��x�x�z�H� '� (�0�0��x�~�~�F�D�Hr c � � t j | j � 5 }|j � }t j |� cd d d � S # 1 sw Y y xY wr )r �get_connectionr � recv_bytes�socket� fromshare)r r r s r �detachzDupSocket.detach$ s? � � C�!�0�0����:�d� ���)�� �'�'��.� ;�:�:�s �%A�AN��__name__� __module__� __qualname__r r# � r r r r s � �-� G� /r �DupFdc � � e Zd Z d� Zd� Zy)r) c �z �� t j |� ��fd�}�fd�}t j ||� | _ y )Nc �4 �� t j | �|� y r )r � send_handle)r r �new_fds �r r z DupFd.__init__.<locals>.send1 s �� ��%�%�d�F�C�8r c �0 �� t j � � y r )�osr )r. s �r r z DupFd.__init__.<locals>.close3 s �� ����� r )r0 r r r r )r �fdr r r. s @r r zDupFd.__init__/ s. �� ��V�V�B�Z�F� 9� !�'�0�0��u�=�D�Hr c � � t j | j � 5 }t j |� cd d d � S # 1 sw Y y xY wr )r r r r � recv_handle)r r s r r# z DupFd.detach7 s3 � � ?�!�0�0����:�d� �,�,�T�2� ;�:�:�s �A � A Nr$ r( r r r) r) - s � �;� >� 3r c �D � e Zd Z d� Zd� Zed� � Zd d�Zd� Zd� Z d� Z y) �_ResourceSharerc �� � d| _ i | _ t j � | _ d | _ d | _ d | _ t j | t j � y )Nr ) �_key�_cache� threading�Lock�_lock� _listener�_address�_threadr �register_after_forkr5 � _afterfork)r s r r z_ResourceSharer.__init__? sI � ��� ��� � �^�^�%�� � ��� �� ��� � � � ���'A�'A�Br c � � | j 5 | j �| j � | xj dz c_ ||f| j | j < | j | j fcd d d � S # 1 sw Y y xY w)Nr )r; r= �_startr7 r8 )r r r s r r z_ResourceSharer.registerH s\ � �9� �Z�Z��}�}�$�� � � � �I�I��N�I�&*�E�]�D�K�K�� � � "��M�M�4�9�9�-� �Z�Z�s �A$A<�<Bc � � ddl m} | \ }} ||t j � j �� }|j |t j � f� |S )Nr ��Client��authkey)� connectionrE r �current_processrG r r0 �getpid)�identrE �address�key�cs r r z _ResourceSharer.get_connectionQ sH � �J�&� � ��� �7�G�$;�$;�$=�$E�$E� F�� ����R�Y�Y�[�!�"��r Nc � � ddl m} | j 5 | j �� || j t j � j �� }|j d � |j � | j j |� | j j � rt j d� | j j � d | _ d | _ d | _ | j j! � D ] \ }\ }} |� � | j j# � d d d � y # 1 sw Y y xY w)Nr rD rF z._ResourceSharer thread did not stop when asked)rH rE r; r= r rI rG r r r> �join�is_aliver � sub_warningr< r8 �items�clear)r �timeoutrE rN rM r r s r r z_ResourceSharer.stopZ s� � �H�&� �Z�Z��}�}�(��4�=�=�#*�#:�#:�#<�#D�#D�F�����t� ���� �� � �!�!�'�*��<�<�(�(�*��$�$� &;� <����$�$�&� #�� � $�� �!%���*.�+�+�*;�*;�*=�&�C� �$���G� +>�� � �!�!�#�! �Z�Z�s �D D;�;Ec �: � | j j � D ] \ }\ }} |� � | j j � | j j � | j �| j j � d | _ d | _ d | _ y r ) r8 rS rT r; �_at_fork_reinitr< r r= r> )r rM r r s r r@ z_ResourceSharer._afterforko sv � �"&�+�+�"3�"3�"5� �C� �$�� �G� #6� � � ���� � � �"�"�$� �>�>� %� �N�N� � � "� ��� �� ��� r c �B � ddl m} t j d� |t j � j d�� | _ | j j | _ t j | j �� }d|_ |j � || _ y )Nr )�Listenerz0starting listener and thread for sending handles� )rG �backlog)�targetT)rH rY r �debugr rI rG r< rL r= r9 �Thread�_serve�daemon�startr> )r rY �ts r rB z_ResourceSharer._startz sl � �(� � � �E�F�!�'�*A�*A�*C�*K�*K�UX�Y��� ���.�.�� � � � �D�K�K� 0����� ��� ��� r c �* � t t d� r6t j t j t j � � | j j � 5 }|j � }|� d d d � y |\ }}| j j |� \ }} |||� |� d d d � �v# |� w xY w# 1 sw Y �xY w# t j � s$t j t j � � Y �UxY w)N�pthread_sigmask)�hasattr�signalrd � SIG_BLOCK� valid_signalsr< �accept�recvr8 �popr � is_exiting�sys� excepthook�exc_info)r r �msgrM �destination_pidr r s r r_ z_ResourceSharer._serve� s� � � �6�,� -� � "� "�6�#3�#3�V�5I�5I�5K� L�� 4��^�^�*�*�,�� �)�)�+�C��{� � -�,� ,/�(�C� �"&�+�+�/�/�#�"6�K�D�%� � �T�?�3� �� -� �� ��� -�,�� 4����(��N�N�C�L�L�N�3�sH � C �#C �7C � #C �$ B>�-C �5C �> C�C � C�C �:Dr ) r% r& r' r r � staticmethodr r r@ rB r_ r( r r r5 r5 = s8 � �8�C�.� �� ��$�* � �4r r5 )r0 rf r! rm r9 � r �contextr r �__all__�platform�objectr r) r5 r r r( r r �<module>rx s� �� � � � � � � � � �(�� �<�<�7�� � �}� �G� /�F� /� ��y��G� 3�� 3� Y4�f� Y4�x #�$� �� � �r