Current File : /opt/cloudlinux/venv/lib/python3.11/site-packages/coverage/__pycache__//multiproc.cpython-311.pyc
�
�|oi � � � d Z ddlZddlZddlZddlZddlZddlZddlmZm Z dZ
ej j Z
e
j Z G d� de
� � Z G d� d� � Zd ed
dfd �ZdS ) z>Monkey-patching to add multiprocessing support for coverage.py� N)�Any�Dictz_coverage$patchedc � � e Zd ZdZd� ZdS )�ProcessWithCoveragez<A replacement for multiprocess.Process that starts coverage.c � � ddl m} |dd�� � }d|_ |� � � |j }|�J �|� d� � r|� d� � n[# t $ rN t d � � t j
t j �
� � t j �
� � � w xY w t | g|�R i |��|� d� � r|� d � � |� � � |� � � |� d� � r|� d � � S S # |� d� � r|� d � � |� � � |� � � |� d� � r|� d � � w w xY w)
z,Wrapper around _bootstrap to start coverage.r )�CoverageT)� data_suffix� auto_dataFN� multiprocz!Calling multiprocessing bootstrapz0Exception during multiprocessing bootstrap init:)�filez"Finished multiprocessing bootstrapzSaved multiprocessing data)�coverager �_warn_preimported_source�start�_debug�should�write� Exception�print� traceback� print_exc�sys�stdout�flush�original_bootstrap�stop�save)�self�args�kwargsr �cov�debugs �f/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib64/python3.11/site-packages/coverage/multiproc.py�
_bootstrapz ProcessWithCoverage._bootstrap s� � �
� )� )� )� )� )� )��(�t�t�<�<�<�C�+0�C� (� �I�I�K�K�K��J�E��$�$�$��|�|�K�(�(�
A�� � � ?�@�@�@���� � � � �D� E� E� E� � �S�Z� 0� 0� 0� 0� �J� � � � � � � ����
:�%�d�<�T�<�<�<�V�<�<��|�|�K�(�(�
B�� � � @�A�A�A� �H�H�J�J�J� �H�H�J�J�J��|�|�K�(�(�
:�� � � 8�9�9�9�9�
:�� �|�|�K�(�(�
B�� � � @�A�A�A� �H�H�J�J�J� �H�H�J�J�J��|�|�K�(�(�
:�� � � 8�9�9�9�9�
:���s �A#A& �&AB>�E �A?GN)�__name__�
__module__� __qualname__�__doc__r# � � r" r r s) � � � � � �F�F�:� :� :� :� :r) r c �^ � e Zd ZdZdeddfd�Zdeeef fd�Zdeeef ddfd�ZdS ) �StowawayzLAn object to pickle, so when it is unpickled, it can apply the monkey-patch.�rcfile�returnNc � � || _ d S )N�r, )r r, s r" �__init__zStowaway.__init__7 s
� � �� � � r) c � � d| j iS �Nr, r/ )r s r" � __getstate__zStowaway.__getstate__: s � ��$�+�&�&r) �statec �0 � t |d � � d S r2 )�patch_multiprocessing)r r4 s r" � __setstate__zStowaway.__setstate__= s � � �e�H�o�.�.�.�.�.r) ) r$ r% r& r' �strr0 r r3 r7 r( r) r" r+ r+ 5 s� � � � � � �V�V� �s� �t� � � � �'�d�3��8�n� '� '� '� '�/�$�s�C�x�.� /�T� /� /� /� /� /� /r) r+ r, r- c � � �� t t t � � rdS t j t
_ t j � � � � t j d< ddlm
} |j �dt dt t t f f�� fd� }||_ n# t t f$ r Y nw xY wt# t t d� � dS ) z�Monkey-patch the multiprocessing module.
This enables coverage measurement of processes started by multiprocessing.
This involves aggressive monkey-patching.
`rcfile` is the path to the rcfile being used.
N�COVERAGE_RCFILEr )�spawn�namer- c �B �� �| � � }t �� � |d< |S )z@Get the original preparation data, and also insert our stowaway.�stowaway)r+ )r< �d� original_get_preparation_datar, s ��r" �"get_preparation_data_with_stowawayzApatch_multiprocessing.<locals>.get_preparation_data_with_stowaway` s) �� �-�-�d�3�3�A� $�V� ,� ,�A�j�M��Hr) T)�hasattr�multiprocessing�PATCHED_MARKERr r# �OriginalProcess�os�path�abspath�environr; �get_preparation_datar8 r r � ImportError�AttributeError�setattr)r, r; rA r@ s ` @r" r6 r6 A s� ��� � ���/�/� ���!4�!?�O� � %'�G�O�O�F�$;�$;�B�J� �!� H�)�)�)�)�)�)�(-�(B�%� �S� �T�#�s�(�^� � � � � � � � &H��"�"��
� � (�
�
�
� ��
���� �O�^�T�2�2�2�2�2s �"
B � B2�1B2)r' rC �multiprocessing.processrF �os.pathr r �typingr r rD �process� BaseProcessrE r# r r r+ r8 r6 r( r) r" �<module>rS s �� E� D� � � � � � � � � � � � � ����
�
�
�
� � � � � � � � � � � � �
%�� "�)�5��$�/� �:� :� :� :� :�/� :� :� :�: /� /� /� /� /� /� /� /�'3�#� '3�$� '3� '3� '3� '3� '3� '3r) 