Edit File: res_mem_collector.cpython-311.pyc
� L( e� � �V � d dl mZ d dlmZ d dlmZ d dlmZ dZ G d� de� � Z dS ) � )�absolute_import)�range)�LveStatsPlugin)� run_commandz/usr/sbin/lvepsc �` � e Zd ZdZdZ ed� � � Zed� � � Zd� Zed� � � Z dS )�ResMEMCollectori� � c �Z � i }d}d}t dt | � � � � D ]|}| | � � � }t |� � dk r"|�|dz ||< d}t |d � � }�Qt |� � dk r|t |d � � z }�}|�|dz ||< |S )as parse the output of lveps -p -n -o id:10,mem:15 lveps returns memory in megabytes. The data for LVE is taken from /proc/lve/list the data for processes is taken from /proc/PID/... and is what we need. :param: lines list of lines, as outputed by lveps :return: dictionary with LVE id as keys, and memory in bytes as values Nr � � � )r �len�split�int�float)�lines�result�lve_id�mem�i�vals ��/builddir/build/BUILDROOT/lve-stats-4.2.1-1.el8.x86_64/opt/cloudlinux/venv/lib/python3.11/site-packages/lvestats/plugins/other/res_mem_collector.py�parse_mem_per_lvez!ResMEMCollector.parse_mem_per_lve s� � � �������q�#�e�*�*�%�%� %� %�A���(�.�.�"�"�C��3�x�x�1�}�}��%�%(�3�Y�F�6�N��� �S��V������S���Q� � ��u�S��V�}�}�$��� � � �3�Y�F�6�N�� � c � � t t ddddg� � } t � | � d� � � � S )zm Get amount of memory processes inside LVE use :return: dictionary of LVE_ID <-> MEM z-pz-nz-oz id:10,mem:15� )r � LVEPS_COMMANDr r r )� lveps_outputs r �get_mem_per_lvez ResMEMCollector.get_mem_per_lve1 s> � � #�M�4��t�^�#T�U�U� � �0�0� �1C�1C�D�1I�1I�J�J�Jr c �V � | � || � � � � � d S )N)�update_lve_datar )�self�lve_datas r �executezResMEMCollector.execute: s* � � � � �X�t�';�';�'=�'=�>�>�>�>�>r c � � | d }|D ]B}|| }||v r-|j }|| }|r||k r||_ �-|| |_ �;d|_ �CdS )a0 updates lve_data['stats'] pmem values for all LVEs Only update LVEs already in lve_data['stats'], skip others :param lve_data: plugin's lve_data :param pmem_dict: dictionary of LVE id <-> memory used in bytes :return: updated stats structure in lve_data �statsr N)�lmemphy�memphy)r# � pmem_dictr& r �stat�limit�pmems r r! z ResMEMCollector.update_lve_data= s| � � ��!��� � �F���=�D���"�"� � �� ��(��� 4�T�E�\�\�"'�D�K�K�"+�F�"3�D�K�K� �� � � � r N) �__name__� __module__� __qualname__�order�timeout� staticmethodr r r$ r! � r r r r s� � � � � � � �E��G�� �� � �\��0 �K� K� �\�K�?� ?� ?� � � � �\� � � r r N) � __future__r �builtinsr �lvestats.core.pluginr �clcommon.utilsr r r r3 r r �<module>r8 s� �� '� &� &� &� &� &� � � � � � � /� /� /� /� /� /� &� &� &� &� &� &�!� �C � C � C � C � C �n� C � C � C � C � C r