Edit File: lvedestroyer.cpython-311.pyc
� L( e� � �v � d dl mZ d dlmZ d dlmZ d dlZd dlZdZ G d� de � � Z G d� d e� � Z dS ) � )�absolute_import)�map)�LveStatsPluginNz/usr/sbin/lvectlc �& � e Zd Zd� Zd� Zd� Zd� ZdS )� LVERecordc �0 � || _ d| _ || _ d S �Nr )�cpu�count� iterations)�selfr r s ��/builddir/build/BUILDROOT/lve-stats-4.2.1-1.el8.x86_64/opt/cloudlinux/venv/lib/python3.11/site-packages/lvestats/plugins/other/lvedestroyer.py�__init__zLVERecord.__init__ s � ������ �$����� c �& � | xj dz c_ d S )N� )r �r s r �incz LVERecord.inc s � � � � �a�� � � � r c �" � | j | j k S �N)r r r s r �checkzLVERecord.check s � ��z�T�_�,�,r c �f � | j |j k s |j dk rd| _ |j | _ dS dS )Nr TF)r �nprocr �r �stats r � has_changedzLVERecord.has_changed s5 � � �8�t�x� � �4�:��>�>��D�J��x�D�H��4��ur N)�__name__� __module__� __qualname__r r r r � r r r r sP � � � � � �%� %� %� � � �-� -� -�� � � � r r c �D � e Zd Zd� Zd� Zd� Zdefd�Zd� Zd� Z d� Z d � Z d S ) � LVEDestroyerc � � t j t � � | _ d | _ d| _ i | _ g | _ d| _ d S )Nr F) �logging� getLoggerr �log� default_statr �lves�to_be_destroyed�_enabledr s r r zLVEDestroyer.__init__' s= � ��$�X�.�.��� �������� � !�� � �� � � r c � � d| _ t |d � � | _ | j dk rd| _ i | _ d | _ d S # t t f$ r Y d S w xY w)NFr r T)r* �intr r( r' �KeyError� ValueError)r �configs r � set_configzLVEDestroyer.set_config/ sr � � �� � � !�&� �"6� 7� 7�D�O����"�"� $�� ��D�I� $�D� � � ���*�%� � � � �D�D� ���s �:A �A�Ac �4 � | j r|| _ g | _ d S d S r )r* r' r) r s r � set_defaultzLVEDestroyer.set_default: s, � � �=� &� $�D� �#%�D� � � � &� &r �returnc �( � |j | j j k p}|j | j j k ph|j | j j k pS|j | j j k p>|j | j j k p)|j | j j k p|j | j j k S r )r r' �io�lmem�lep�lmemphy�lcpuw�lnprocr s r �is_stat_trackedz LVEDestroyer.is_stat_tracked? s� � ���T� .� 2�2� =��G�t� 0� 3�3�=��I��!2�!7�7�=� �H�� 1� 5�5�=� �L�D�$5�$=�=� =� �J�$�"3�"9�9� =� �K�4�#4�#;�;� >r c �( � | j |j }|� |� � sj|� � � r@| j � |j � � | j � |j � � d S |� � � d S d S r )r( �idr r r) �append�popr )r r �rs r � check_lvezLVEDestroyer.check_lveI s� � � �I�d�g� ���}�}�T�"�"� ��w�w�y�y� ��$�+�+�D�G�4�4�4�� � � �d�g�&�&�&�&�&��������� � r c � � | j r|j }|dk r| � |� � d S || j v r| � |� � d S | � |� � rd S t |j | j � � | j |< d S d S r ) r* r= r2 r( rA r; r r r )r r r= s r �add_statzLVEDestroyer.add_statR s� � � �=� E���B��Q�w�w�� � ��&�&�&����T�Y������t�$�$�$�$�$��%�%�d�+�+� E��� )�$�(�D�O� D� D�� �"� � � � E� Er c �< � | j �r| j �r t j t dgt j t j t j �� � }| j � dd� t t | j � � � � � � |� d� t t | j � � � � � � � � � d S # t $ r$ | j � dt � � Y d S w xY wd S d S )Nz destroy-many)�stdin�stdout�stderrzDestroying: %s� z$Error: failed to run %s destroy-many)r* r) � subprocess�Popen�LVECTL�PIPEr& �info�joinr �str� communicate�encode�OSError�error)r �ps r �process_destroyz LVEDestroyer.process_destroy_ s � � �=� S��#� S� S�"�(� � �0� (�o� )�� )�� 0� 0� 0�A� �H�M�M�"2�C�H�H�S��d�FZ�=[�=[�4\�4\�]�]�]��M�M�#�(�(�3�s�D�4H�+I�+I�"J�"J�"Q�"Q�"S�"S�T�T�T�T�T�� � S� S� S��H�N�N�#I�6�R�R�R�R�R�R�S���� S� S� S� Ss �CC) �)*D�Dc �� � |d }| � |d � � |� � � D ]}| � |� � �| � � � d S )N�statsr )r2 �valuesrC rU )r �lve_datarW r s r �executezLVEDestroyer.executeo sh � ���!�� ����q��"�"�"��L�L�N�N� � �D� �M�M�$� � � � � � � � � � � � r N) r r r r r0 r2 �boolr; rA rC rU rZ r r r r" r" & s� � � � � � � � � � � � �&� &� &� >�t� >� >� >� >�� � � E� E� E�S� S� S� � � � � r r" ) � __future__r �builtinsr �lvestats.core.pluginr rI r$ rK �objectr r" r r r �<module>r` s� �� '� &� &� &� &� &� � � � � � � /� /� /� /� /� /� � � � � ���� ��� � � � �� � � �(N � N � N � N � N �>� N � N � N � N � N r