관리-도구
편집 파일: common.cpython-311.pyc
� b��f � �p � d Z ddlZddlZddlmZ ddlmZ ddlm Z ddl m Z ddl m Z G d � d � � ZdS ) zG This module contains basic part of continuous tracingg implementation � N)�List)�gettext� )�continuous_storage)� XRayError��ContinuousTaskc �d � e Zd ZdZd� Zdefd�Zdee fd�Z dee fd�Z de ddfd �Z dS ) �ContinuousCommonz+ Base class for continuous tracing c � � t | _ t j d� � | _ | � � � | _ d S )N� continuous)r �storage�logging� getLogger�logger�load_tracing_configuration� tracing_conf��selfs �M/opt/cloudlinux/venv/lib64/python3.11/site-packages/xray/continuous/common.py�__init__zContinuousCommon.__init__ s5 � �)�� � �'� �5�5�� � � ;� ;� =� =����� �returnc � �� | j � d� � t j | j � � 5 ��fd��� � � D � � cddd� � S # 1 swxY w Y dS # t $ rC}| j � ddt |� � i�� � t � � cY d}~S d}~ww xY w)zS Load full continuous tracing configuration from the local storage z(Loading continuous tracing configurationc �" �� i | ] }|�| �� S � r ��.0�item�dbs �r � <dictcomp>z?ContinuousCommon.load_tracing_configuration.<locals>.<dictcomp>' s �� �=�=�=�4��b��h�=�=�=r Nz/Failed to load continuous tracing configuration�err��extra) r �info�shelve�openr �keys�OSError�error�str�dict)r �er s @r r z+ContinuousCommon.load_tracing_configuration s �� � � ���C�D�D�D� ���T�\�*�*� >�b�=�=�=�=�2�7�7�9�9�=�=�=� >� >� >� >� >� >� >� >� >� >� >� >���� >� >� >� >� >� >��� � � � �K� � �A� �c�!�f�f�o� � '� '� '� �6�6�M�M�M�M�M�M����� ���s@ �A0 � A#� A0 �#A'�'A0 �*A'�+A0 �0 B=�:8B8�2B=�8B=c �b � t d� | j � � � D � � � � S )zC Return existing configuration in the form of list c �& � h | ]}t d i |����S )r r )r r s r � <setcomp>z8ContinuousCommon.get_continuous_tasks.<locals>.<setcomp>3 s& � � K� K� K��^� #� #�d� #� #� K� K� Kr )�sortedr �valuesr s r �get_continuous_tasksz%ContinuousCommon.get_continuous_tasks. s9 � � � K� K��0A�0H�0H�0J�0J� K� K� K�M� M� Mr c �\ �� t j | j � � 5 �| j D ]}| j | �|< ��fd��� � � D � � cddd� � S # 1 swxY w Y dS # t $ r1}t t d� � t |� � z � � �d}~ww xY w)zJ Dump continuous tracing configuration into local storage c � �� g | ] }�| �� S r r r s �r � <listcomp>z?ContinuousCommon.dump_tracing_configuration.<locals>.<listcomp>= s �� �7�7�7�T��4��7�7�7r Nz+Failed to dump continuous configuration: %s) r& r' r r r( r) r �_r+ )r r r- r s @r �dump_tracing_configurationz+ContinuousCommon.dump_tracing_configuration5 s �� � K���T�\�*�*� 8�b� � -� 7� 7�D� #� 0�� 6�B�t�H�H�7�7�7�7�R�W�W�Y�Y�7�7�7� 8� 8� 8� 8� 8� 8� 8� 8� 8� 8� 8� 8���� 8� 8� 8� 8� 8� 8�� � K� K� K���?�@�@�3�q�6�6�I�K� K� K����� K���s: �A0 �:A#� A0 �#A'�'A0 �*A'�+A0 �0 B+�:,B&�&B+�domainNc � � | j |= t j | j � � 5 }||= ddd� � dS # 1 swxY w Y dS # t $ rD | j � d|| j d��� � t t d� � |z � � �t $ rB}t t d� |t |� � � � � � � � �d}~ww xY w)zD Remove continuous tracing configuration for domain Nz$Continuous monitoring is not enabled)r9 �tracing_entriesr# z+Continuous monitoring for %s is not enabledz4Failed to remove continuous configuration for {}: {}) r r& r' r �KeyErrorr r* r r7 r) �formatr+ )r r9 r r- s r � remove_tracing_configurationz-ContinuousCommon.remove_tracing_configurationB sc � � b��!�&�)���T�\�*�*� �b��v�J� � � � � � � � � � � � ���� � � � � � ��� K� K� K� �K� � � D�/5�8<�8I�%K� %K� � L� L� L� ��?�@�@�6�I�K� K� K�� b� b� b���H�O�O�PV�X[�\]�X^�X^�_�_�`�`�b� b� b����� b���s3 �!A �4� A �8�A �8�A �AC�=C�C) �__name__� __module__� __qualname__�__doc__r r, r r r r3 r8 r+ r> r r r r r s� � � � � � �� �>� >� >� �D� � � � � M�d�>�&:� M� M� M� M� K�D��J� K� K� K� K�b�3� b�4� b� b� b� b� b� br r )rB r r& �typingr �xrayr r7 �internal.constantsr �internal.exceptionsr �internal.typesr r r r r �<module>rH s� ��� � ���� � � � � � � � � � � � � � � � � 3� 3� 3� 3� 3� 3� +� +� +� +� +� +� +� +� +� +� +� +�<b� <b� <b� <b� <b� <b� <b� <b� <b� <br