H:j d dl mZ d dlmZ d dlmZmZ G d de Z G d de Z G d d e Z d
S ) ) defaultdict)LveStatsPlugin)LVEUsageFAULTSc & e Zd ZdZddZd Zd ZdS )AggregatedLveUsage c > t j | | d| _ d S )Ng )r __init__time)self lve_versions /builddir/build/BUILDROOT/lve-stats-5.0.4-1.el8.x86_64/opt/cloudlinux/venv/lib/python3.11/site-packages/lvestats/plugins/generic/aggregators.pyr zAggregatedLveUsage.__init__ s $ ,,, c | xj |j pdz
c_ |j r| xj |j |j z z
c_ | xj |j |j z z
c_ | xj |j |j z z
c_ | xj |j |j z z
c_ | xj |j |j z z
c_ | xj |j |j z z
c_ | xj |j |j z z
c_ | xj |j z
c_ | xj |j z
c_ | xj
|j
z
c_
| xj |j z
c_ | xj |j z
c_ | xj
|j
z
c_
t |j | j | _ t |j | j | _ t |j | j | _ t |j | j | _ t |j | j | _ t |j | j | _ t |j | j | _ | j p|j | _ | j p|j | _ d S )Nr )r
cpu_usage mem_usagemepio_usageiopsmemphynproc cpu_fault mem_fault mep_faultio_fault memphy_fault nproc_faultmaxlmemlcpulepiolmemphylnprocliopshas_changed_limitshas_changed_nproc)r lveusages r addzAggregatedLveUsage.add s X]'a' = 9 NNh 08= @ @NN NNh 08= @ @NN HH x}4 4HH MMX . > >MM II 6 6II KK8?X]: :KK JJ(.8=8 8JJ (,, (,, (,,
**
X 22 H 00
ty11
ty11 x|TX..hk47++8+T\:: (/4;77 44
"&"9"XX=X !%!7!U8;U r c | j dk r| xj | j z c_ | xj | j z c_ | xj | j z c_ | xj | j z c_ | xj | j z c_ | xj | j z c_ | xj | j z c_ | j | j cxk rdk r n n d| _ d S d| _ d S d S )Nr )
r
r r r r r r r r'
iops_faultr s r aggregatez AggregatedLveUsage.aggregate4 s 9q== NNdi 'NN NNdi 'NN HH !HH MMTY &MM II "II KK49 $KK JJ$) #JJ yDJ*********"#"# =r N)r
)__name__
__module__ __qualname__ __slots__r r+ r0 r r r r r
sO I V V V@$ $ $ $ $r r c , e Zd Zd Zd Zd Zd Zd ZdS )LveUsageAggregator5Sc 0 d| _ d| _ d| _ d S )N
lve_usages_5s lve_usage_5sT)
get_data_from set_data_tosnapshots_enabledr/ s r r z LveUsageAggregator5S.__init__F s ,)!% r c h | dd dk | _ dS )%
:param dict config:
disable_snapshotsfalsetrueN)getlowerr< r configs r
set_configz LveUsageAggregator5S.set_configK s3 "(,?!I!I!O!O!Q!QU[![ r c i }t | t | z }|D ]!\ }}| |d |z ||< "|S )z?
:param dict dict1:
:param dict dict2:
r )listitemsrB )r dict1dict2resultrI attr_namecounts r dict_sum_valuesz$LveUsageAggregator5S.dict_sum_valuesQ sn
U[[]]##d5;;==&9&99 % A A Iu &
9a 8 85 @F9
r c $ | j r| di }| D ]V\ }}t D ]I}t || }|dk r1||vri ||< || |d |z || |< JW||d< dS dS )z]
:type lve_data: dict
:type lve_usage: dict[int, AggregatedLveUsage]
faultsr N)r< rB rI r getattr)r lve_data lve_usage
old_faultslve_idusagerM faults r aggregate_faultsz%LveUsageAggregator5S.aggregate_faults\ s
! ,! h33J!* !2!2
e
e
!' e eI #E9 5 5E qyy!3313Jv .8B68J8N8NyZ[8\8\_d8d
6*95 e ",HX , ,r c || j }t t }|D ]7}| D ] \ }}|| | !8| D ]}| i }| D ]8\ }} |dk r| ||< | s| j s| j r| ||< 9||| j
< | || dS )z'
:param dict lve_data:
r N) r: r r rI r+ valuesr0 has_interesting_valuesr( r) r; rY )
r rS
lve_usages
aggregatediteration_datarV rT aggregated_lve_usagerL rW s
r executez LveUsageAggregator5S.executel s: d 01
!344
( 2 2N%3%9%9%;%;
2
2! 6"&&y1111
2 %/$5$5$7$7 - - * * , , , , ' - - / / ' 'MFE{{!&v++--
' /
' .
' "'v%+!" h/////r N)r1 r2 r3 r rF rO rY ra r r r r6 r6 E sb & & &
\ \ \ , , , 0 0 0 0 0r r6 c 0 e Zd Zd Zd Zd Z fdZ xZS )LveUsageAggregatorc 0 d| _ d| _ d| _ d S )N< r] rT )periodr: r; r/ s r r zLveUsageAggregator.__init__ s )&r c F | d| j | _ dS )r> aggregation_periodN)rB rf rD s r rF z LveUsageAggregator.set_config s jj!5t{CC r c d S Nr )r rS rT s r rY z#LveUsageAggregator.aggregate_faults s r c ^ t | g || j < d S rj )superra r: )r rS __class__s r ra zLveUsageAggregator.execute s,
!!!')#$$$r )r1 r2 r3 r rF rY ra
__classcell__)rm s @r rc rc sh ' ' '
D D D
* * * * * * * * *r rc N)
collectionsr lvestats.core.pluginr "lvestats.plugins.generic.analyzersr r r r6 rc r r r rr s $ # # # # # / / / / / / ? ? ? ? ? ? ? ?5$ 5$ 5$ 5$ 5$ 5$ 5$ 5$pA0 A0 A0 A0 A0> A0 A0 A0L* * * * *- * * * * *r