PATH:
opt
/
cloudlinux
/
venv
/
lib
/
python3.11
/
site-packages
/
lvestats
/
plugins
/
other
/
__pycache__
� �Ŝ%Љ�w� �^ � d dl Z d dlZd dlmZ dZ G d� de� � Z G d� de� � ZdS )� N)�LveStatsPluginz/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.14-2.el9.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_default8 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_lveG 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; r0 r& r? r9 r r r )r r �id_s r �add_statzLVEDestroyer.add_statP s� � � �=� F��'�C��a�x�x�� � ��&�&�&����d�i� � ����t�$�$�$�$�$��%�%�d�+�+� F���!*�4�8�T�_�!E�!E�� �#���� F� Fr c �n � | j �r*| j �r$ t j t dgt j t j t j �� � 5 }| j � dd� t t | j � � � � � � |� d� t t | j � � � � � � � � � d d d � � d S # 1 swxY w Y 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�join�map�str� communicate�encode�OSError�error)r �procs r �process_destroyz LVEDestroyer.process_destroy] s� � � �=� S��#� S� S�#�)� � �0� (�o� )�� )�� � � � \� � �� � �&6�����S�$�J^�A_�A_�8`�8`�a�a�a� �(�(����#�c�4�;O�2P�2P�)Q�)Q�)X�)X�)Z�)Z�[�[�[�\� \� \� \� \� \� \� \� \� \� \� \���� \� \� \� \� \� \�� � S� S� S��H�N�N�#I�6�R�R�R�R�R�R�S���� S� S� S� Ss6 �=D �BC5�( D �5C9�9D �<C9�=D �*D0�/D0c �� � |d }| � |d � � |� � � D ]}| � |� � �| � � � d S )N�statsr )r0 �valuesrB rU )r �lve_datarW r s r �executezLVEDestroyer.executen sh � ���!�� ����q��"�"�"��L�L�N�N� � �D� �M�M�$� � � � � � � � � � � � r N) r r r r r. r0 �boolr9 r? rB rU rZ r r r r r $ s� � � � � � � � � � � � �&� &� &� >�t� >� >� >� >�� � � F� F� F�S� S� S�" � � � � r r )r" rH �lvestats.core.pluginr rJ �objectr r r r r �<module>r^ s� �� ���� � � � � /� /� /� /� /� /� ��� � � � �� � � �(O � O � O � O � O �>� O � O � O � O � O r
[+]
..
[-] res_mem_collector.cpython-311.pyc
[open]
[-] json_stats_saver.cpython-311.pyc
[open]
[-] __init__.cpython-311.pyc
[open]
[-] v1_db_migrator.cpython-311.pyc
[open]
[-] lvedestroyer.cpython-311.pyc
[open]