3< d dl Z d dlmZ d dlmZ dZdZdZdZdez ez ez Z d Z
e j d
Z G d d e Z
G d
d
e ZdS ) N)LVEStat)LveStatsPlugini ) cpu_fault memphy_fault mem_faultio_fault
iops_fault mep_fault nproc_fault)lcpulmemphylmemioliopsleplnproc) cpu_usagememphy mem_usageio_usageiopsmepnproc) lve_versiontimehas_changed_limitshas_changed_nprociseletskLVEUsagec e Zd ZdZd Zd ZdS )LVEUsageAnalyzerzO
Calculates lve usage and updates it in lve_data, in field 'lve_usage'
c || _ d S N)config)selfr$ s /builddir/build/BUILDROOT/lve-stats-4.3.2-1.el9.x86_64/opt/cloudlinux/venv/lib/python3.11/site-packages/lvestats/plugins/generic/analyzers.py
set_configzLVEUsageAnalyzer.set_config s
c |d }|d }|d= | dd }| j |d< |d }|d }i }| D ]\ }} t |d }
| |d } |
| | ||r
| j |z
nd| |d k s.| j d k s#| j d k s| |
| | r|
||< | d
g } | | |g|d < t |
|d < | |d
< dS )
z'
:param dict lve_data:
stats old_statsold_nowNtotalHzprocs LVE_VERSION)r r
lve_usages
lve_usages_5slve_active_ids) getnowitemsr calcr r is_lve_data_changedappendlistkeys)
r% lve_data new_statsr+ r, total_hzr. result_idlve_statu lve_stat_oldr0 s
r& executezLVEUsageAnalyzer.execute sq
W% [) [ !,,y$// "hI&! &__ . . MCXm%<===A$==d33L
FF<875\TX5G5GX\^c d d daxx ~)) |a''$0Q5J5Jz$LVEUsage.__repr__..} s3 @@all3.?.?@!@@@@@@r( :z, >)dirgetattr
isinstancestrintfloatbooltype)r% representationrY vs r& __repr__zLVEUsage.__repr__{ s @@SYY@@@ / /Aa A!c3tT$ZZ @AA
/ Q,,,,,.# r( c t j j j j f rdS t fdt
D rdS dS )NTc 3 8 K | ]}t | V d S r# r^ )rX rY r% s r& rZ z2LVEUsage.has_interesting_values.. s- 11Qa 111111r( F)anyr r r r FAULTSr% s `r& has_interesting_valuesz LVEUsage.has_interesting_values sX
DM49E F F 4 1111&111 2 2 4ur( c h t D ])}t ||d t ||d k r dS *dS )O
:type old: lvestat.LVEStat
:type new: lvestat.LVEStat
NTF)LIMITSr^ )r% newoldattrs r& _has_changed_limitsz LVEUsage._has_changed_limits sH
DsD$''73d+C+CCCtt Dur( c " |j |j k S )rp )r )r% rr rs s r& _has_changed_nproczLVEUsage._has_changed_nproc s
yCI%%r( c " |dk r|S ||z dz S )z`
New kernel format lcpu is 100 times bigger than previous. So that it's 0-10000
rN d rH )r% r lve_verr. s r& rO z*LVEUsage.convert_lcpu_to_new_kernel_format s# a<<K %<#% %r( c |j |j k sp|j |j k s`|j |j k sP|j |j k s@|j |j k s0|j |j k s |j |j k s|j |j k rdS |j |j k s0|j |j k s |j
|j
k s|j |j k rdS | j dk r|j
|j
k rdS dS )z
Check if LVE data is changed
:param old: Previous data
:param new: Current data
:return: True - changes, false - not
TrN F)r r r r
r r r r r r r r r r )r% rs rr s r& r7 z LVEUsage.is_lve_data_changed s =CM ) )7cg%%=CM11=CM11=CM117cg%%6SV##<3<//4
J#* $ $(8Cn n;|j | _ | j s$|j |j cxk rdk rn d S d| _ d S d S d S d| _ |j | _ d S )Nz)oldstats is not None, but time is unknownr z#oldstats is not None, but time is 0i' rN )!r rO rP r r rc ru r rw r r ra roundr r
r r r rQ r r r r r r r r r r r
r r r )r% rs rr hzr r. s r& r6 z
LVEUsage.calc s6 ::37DDTV[\\ 99 I&*&>&>sC&H&HD #%)%<%}s},,!$ !> #"222$'$4s7G$G! 00#&?S_#D |cl** #E" s|0K*Lt*S$T$T U U
1$$8ch&& #E38ch+>$*F$G$G H HDI >A DNN
^ty
,
,
,
,1
,
,
,
,
, !YDN NNa NNH >A #(!>!>!>!>Q!>!>!>!>!> XDN>
#cmsx&C&C&C&C!&C&C&C&C&C!" DN ]DN7 >A CG!7!7!7!7a!7!7!7!7!7wDH>
#cg&<&<&<&<1&<&<&<&<&#>#>#>Q#>#>#>#>#> DJ#
% SZ(C(C(C(C!(C(C(C(C(C(C#$
%
%(C(C !D DJJJr( c f dt | j z dz t | j z dz S )Nz (cpu_usage=z, mep=))r` r r rm s r& __str__zLVEUsage.__str__ s/ s4> 2 22X=DH
MPSSSr( c " t | | S r# rj )r% keys r& __getitem__zLVEUsage.__getitem__" s tS!!!r( N)rD rE rF
LVEUSAGESLOTS __slots__rK r rR rg rn ru rw rO r7 r6 r r rH r( r& r r C s I B ( & & && & & :Z# Z# Z#xT T T" " " " "r( )loggingrL r lvestats.core.pluginr rQ rl rq STATSr
__author__ getLoggerlogr! objectr rH r( r& r s / / / / / / i DPRUZZ]ccfll
g
##(, (, (, (, (,~ (, (, (,V`" `" `" `" `"v `" `" `" `" `"r(