Edit File: aggregators.cpython-311.pyc
� L( e� � � � d dl mZ d dlmZ d dlmZ d dlmZmZ G d� de� � Z G d� de� � Z G d � d e � � Z d S ) � )�absolute_import)� 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.1-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, r1 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_enabledr0 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�itemsrC )r �dict1�dict2�resultrJ � 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= rC rJ r �getattr)r �lve_data� lve_usage� old_faults�lve_id�usagerN �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 ]}|� � � �t � � }|� � � D ]8\ }} |dk r| ||< �| � � � s| j s| j r| ||< �9||| j < | � ||� � g || j < dS )z' :param dict lve_data: r N) r; r r rJ r, �valuesr1 �dict�has_interesting_valuesr) r* r< rZ ) r rT � lve_usages� aggregated�iteration_datarW rU �aggregated_lve_usagerM rX s r �executez LveUsageAggregator5S.executel sK � � �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)r2 r3 r4 r rG rP rZ rc r r r r7 r7 E sb � � � � � �&� &� &� \� \� \� � � �,� ,� ,� *� *� *� *� *r r7 c � � e Zd Zd� Zd� Zd� ZdS )�LveUsageAggregatorc �0 � d| _ d| _ d| _ d S )N�< r_ rU )�periodr; r< r0 s r r zLveUsageAggregator.__init__� s � ��� � )���&����r c �F � |� d| j � � | _ dS )r? �aggregation_periodN)rC rh rE s r rG z LveUsageAggregator.set_config� s � � �j�j�!5�t�{�C�C�� � � r c � � d S )Nr )r rT rU s r rZ z#LveUsageAggregator.aggregate_faults� s � � �r N)r2 r3 r4 r rG rZ r r r re re � sD � � � � � �'� '� '� D� D� D� � � � � r re N) � __future__r � collectionsr �lvestats.core.pluginr �"lvestats.plugins.generic.analyzersr r r r7 re r r r �<module>rp s� �� '� &� &� &� &� &� #� #� #� #� #� #� /� /� /� /� /� /� ?� ?� ?� ?� ?� ?� ?� ?�5$� 5$� 5$� 5$� 5$�� 5$� 5$� 5$�pC*� C*� C*� C*� C*�>� C*� C*� C*�L � � � � �-� � � � � r