eQL > d dl mZ d dlmZ dZ G d de ZdS ) ) run_command)LveStatsPluginz/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 )rangelensplitintfloat)linesresultlve_idmemivals /builddir/build/BUILDROOT/lve-stats-4.3.2-1.el9.x86_64/opt/cloudlinux/venv/lib/python3.11/site-packages/lvestats/plugins/other/res_mem_collector.pyparse_mem_per_lvez!ResMEMCollector.parse_mem_per_lve s q#e**%% % %A(..""C3xx1}}%%(3YF6N SVSQ uSV}}$ 3YF6N
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_lve0 s> #M4t^#TUU 00 1C1CD1I1IJJJr c V | || d S )N)update_lve_datar )selflve_datas r executezResMEMCollector.execute9 s* Xt';';'='=>>>>>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)lmemphymemphy)r" pmem_dictr% r statlimitpmems r r z ResMEMCollector.update_lve_data< s| !
F=D"" ( 4TE\\"'DKK"+F"3DKK
r N)
__name__
__module__ __qualname__ordertimeout staticmethodr r r# r r r r r s EG \0 K K \K? ? ? \ r r N)clcommon.utilsr lvestats.core.pluginr r r r2 r r r5 sn ' & & & & & / / / / / /!
C C C C C n C C C C C r