관리-도구
편집 파일: aggregators.cpython-311.pyc
� �Cg� � � � d dl mZ d dlmZ d dlmZmZ G d� de� � Z G d� de� � Z G d� d e� � Z d S ) � )� defaultdict)�LveStatsPlugin)�LVEUsage�FAULTSc �& � e Zd ZdZdd�Zd� Zd� ZdS )�AggregatedLveUsage� � c �> � t j | |� � d| _ d S )Ng )r �__init__�time)�self� lve_versions ��/builddir/build/BUILDROOT/lve-stats-4.2.10-1.el8.x86_64/opt/cloudlinux/venv/lib/python3.11/site-packages/lvestats/plugins/generic/aggregators.pyr zAggregatedLveUsage.__init__ s � ���$� �,�,�,��� � � � c �� � | xj |j pdz c_ |j r�| xj |j |j z z c_ | xj |j |j z z c_ | xj |j |j z z c_ | xj |j |j z z c_ | xj |j |j z z c_ | xj |j |j z z c_ | xj |j |j z z c_ | xj |j z c_ | xj |j z c_ | xj |j z c_ | xj |j z c_ | xj |j z c_ | xj |j z c_ t |j | j � � | _ t |j | j � � | _ t |j | j � � | _ t |j | j � � | _ t |j | j � � | _ t |j | j � � | _ t |j | j � � | _ | j p|j | _ | j p|j | _ d S )Nr )r � cpu_usage� mem_usage�mep�io_usage�iops�memphy�nproc� cpu_fault� mem_fault� mep_fault�io_fault� memphy_fault� nproc_fault�max�lmem�lcpu�lep�io�lmemphy�lnproc�liops�has_changed_limits�has_changed_nproc)r �lveusages r �addzAggregatedLveUsage.add s � � � � �X�]�'�a�'� � � �=� 9� �N�N�h� 0�8�=� @� @�N�N� �N�N�h� 0�8�=� @� @�N�N� �H�H�� �x�}�4� 4�H�H� �M�M�X� .�� � >� >�M�M� �I�I�� �� �6� 6�I�I� �K�K�8�?�X�]�:� :�K�K� �J�J�(�.�8�=�8� 8�J�J� ���(�,�,��� ���(�,�,��� ���(�,�,��� � � ��*�*� � � ���X� 2�2��� ���H� 0�0����� �t�y�1�1�� ��� �t�y�1�1�� ��x�|�T�X�.�.����h�k�4�7�+�+����8�+�T�\�:�:�� ��(�/�4�;�7�7�� ��� ���4�4�� �"&�"9�"X�X�=X�� �!%�!7�!U�8�;U�� � � r c � � | j dk r�| xj | j z c_ | xj | j z c_ | xj | j z c_ | xj | j z c_ | xj | j z c_ | xj | j z c_ | xj | j z c_ | j | j cxk rdk r n n d| _ d S d| _ d S d S )Nr � ) r r r r r r r r r' � iops_fault�r s r � aggregatez AggregatedLveUsage.aggregate4 s� � � �9�q�=�=� �N�N�d�i� '�N�N� �N�N�d�i� '�N�N� �H�H�� � !�H�H� �M�M�T�Y� &�M�M� �I�I��� "�I�I� �K�K�4�9� $�K�K� �J�J�$�)� #�J�J� �y�D�J�*�*�*�*��*�*�*�*�*�"#�����"#����� �=r N)r )�__name__� __module__� __qualname__� __slots__r r+ r0 r r r r r sO � � � � � ��I�� � � � V� V� V�@$� $� $� $� $r r c �, � e Zd Zd� Zd� Zd� Zd� Zd� ZdS )�LveUsageAggregator5Sc �0 � d| _ d| _ d| _ d S )N� lve_usages_5s� lve_usage_5sT)� get_data_from� set_data_to�snapshots_enabledr/ s r r z LveUsageAggregator5S.__init__F s � � ,���)���!%�� � � r c �h � |� dd� � � � � dk | _ dS )�% :param dict config: �disable_snapshots�false�trueN)�get�lowerr< �r �configs r � set_configz LveUsageAggregator5S.set_configK s3 � � "(���,?��!I�!I�!O�!O�!Q�!Q�U[�![�� � � r c �� � i }t |� � � � � t |� � � � � z }|D ]!\ }}|� |d� � |z ||< �"|S )z? :param dict dict1: :param dict dict2: r )�list�itemsrB )r �dict1�dict2�resultrI � attr_name�counts r �dict_sum_valuesz$LveUsageAggregator5S.dict_sum_valuesQ sn � � ���U�[�[�]�]�#�#�d�5�;�;�=�=�&9�&9�9�� %� A� A� �I�u� &� � �9�a� 8� 8�5� @�F�9� � �� r c �$ � | j r�|� di � � }|� � � D ]V\ }}t D ]I}t ||� � }|dk r1||vri ||< || � |d� � |z || |< �J�W||d< dS dS )z] :type lve_data: dict :type lve_usage: dict[int, AggregatedLveUsage] �faultsr N)r< rB rI r �getattr)r �lve_data� lve_usage� old_faults�lve_id�usagerM �faults r �aggregate_faultsz%LveUsageAggregator5S.aggregate_faults\ s� � � � !� ,�!� � �h��3�3�J�!*� � �!2�!2� e� e� ���!'� e� e�I� #�E�9� 5� 5�E� �q�y�y�!��3�3�13�J�v� .�8B�6�8J�8N�8N�y�Z[�8\�8\�_d�8d� �6�*�9�5�� e� ",�H�X� � � � ,� ,r c �� � || j }t t � � }|D ]7}|� � � D ] \ }}|| � |� � �!�8|� � � D ]}|� � � �i }|� � � D ]8\ }} |dk r| ||< �| � � � s| j s| j r| ||< �9||| j < | � ||� � dS )z' :param dict lve_data: r N) r: r r rI r+ �valuesr0 �has_interesting_valuesr( r) r; rY ) r rS � lve_usages� aggregated�iteration_datarV rT �aggregated_lve_usagerL rW s r �executez LveUsageAggregator5S.executel s: � � �d� 0�1� � �!3�4�4� � (� 2� 2�N�%3�%9�%9�%;�%;� 2� 2�!�� ��6�"�&�&�y�1�1�1�1� 2� %/�$5�$5�$7�$7� -� -� � � *� *� ,� ,� ,� ,��� '� -� -� /� /� '� '�M�F�E���{�{�!&��v����+�+�-�-� '� �/� '� �.� '� "'��v���%+���!�"� � � �h��/�/�/�/�/r N)r1 r2 r3 r rF rO rY ra r r r r6 r6 E sb � � � � � �&� &� &� \� \� \� � � �,� ,� ,� 0� 0� 0� 0� 0r r6 c �0 � � e Zd Zd� Zd� Zd� Z� fd�Z� xZS )�LveUsageAggregatorc �0 � d| _ d| _ d| _ d S )N�< r] rT )�periodr: r; r/ s r r zLveUsageAggregator.__init__� s � ��� � )���&����r c �F � |� d| j � � | _ dS )r> �aggregation_periodN)rB rf rD s r rF z LveUsageAggregator.set_config� s � � �j�j�!5�t�{�C�C�� � � r c � � d S �Nr )r rS rT s r rY z#LveUsageAggregator.aggregate_faults� s � � �r c �^ �� t � � � |� � g || j < d S rj )�superra r: )r rS � __class__s �r ra zLveUsageAggregator.execute� s, �� � ������!�!�!�')���#�$�$�$r )r1 r2 r3 r rF rY ra � __classcell__)rm s @r rc rc � sh �� � � � � �'� '� '� D� D� D� � � �*� *� *� *� *� *� *� *� *r rc N) � collectionsr �lvestats.core.pluginr �"lvestats.plugins.generic.analyzersr r r r6 rc r r r �<module>rr s� �� $� #� #� #� #� #� /� /� /� /� /� /� ?� ?� ?� ?� ?� ?� ?� ?�5$� 5$� 5$� 5$� 5$�� 5$� 5$� 5$�pA0� A0� A0� A0� A0�>� A0� A0� A0�L*� *� *� *� *�-� *� *� *� *� *r