@jC- 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-5.0.5-1.el8.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 ss
W% [) [ !,,y$// "hI&! &__ . . MCXm%<===A$==d33L
FF<875\TX5G5GX\^c d d d q>A%%z$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
MS] * *w#'!!}
--}
--}
--w#'!!v |s|++4
J#* $ $ 3#333yCI%%#/114 q SX%9%94ur( c || _ | |j | j | | _ t | r| || | _ | || | _ |
J d |dk s
J d |j
|j
k r:t t d|j
|j
z
z |z ||z z | _
|j
|j
k r|j
|j
z
| _
|j |j k r|j |j z
| _ |j |j k r|j |j z
| _ |j |j k r|j |j z
| _ |j |j k r9t t t$ |j |j z
z |z | _ | j dk rA|j |j k r1t t |j |j z
|z | _ | j
dk rd| _
n-| j
| j cxk rdk rn n| j | _
d| _ |j | _ | j
dk s|j |j cxk rdk r8n n5|j | _ | j
s!|j |j cxk rdk r
n nd| _
nd| _
|j | _ |j | _ | j dk s|j |j cxk rdk r8n n5|j | _ | j s!|j |j cxk rdk r
n nd| _ nd| _ |j | _ | j dk r9|j | _ | j | j cxk rdk rn n| j | _ d| _ t$ |j z | _ | j dk rd| _ n-| j | j cxk rdk rn n| j | _ d| _ |j | _ |j | _ | j dk s|j |j cxk rdk r8n n5|j | _ | j s!|j |j cxk rdk r
n nd| _ nd| _ |j | _ | j dk s|j |j cxk rdk r>n 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 s! ::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 DN H >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 E s I B $ & & && & &! ! !Fq# q# q#fT T T" " " " "r( )loggingrL r lvestats.core.pluginr rQ rl rq STATSr
__author__ getLoggerlogr! objectr rH r( r& r s / / / / / / i DPRUZZ]ccfll
g
##*, *, *, *, *,~ *, *, *,Z{" {" {" {" {"v {" {" {" {" {"r(