OwlCyberSecurity - MANAGER
Edit File: multiproc.cpython-311.pyc
� ��bg � � � 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 �e/builddir/build/BUILD/cloudlinux-venv-1.0.7/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)