H:j d dl Z d dlZd dlZd dlZd dlmZmZmZ d dlmZ d dl m
Z
d dl m Z d dl
mZ d dlmZ d dlmZmZ d d lmZmZ d
Z e j e j e j d Z e j d
Z e e j d e e j! e" e G d d Z# G d ded Z$ G d de Z%dS ) N) TypedDict
NamedTupleSelf)ChainMap)ProcLve)PyLve) LVE_DEFAULT)LVEStat)read_raw_config get_boolean)OverloadCheckerread_times_from_procz+/var/run/cloudlinux/effective-normal-limits)level BurstWatcherz"/var/log/lvestats-burstwatcher.logz%%(asctime)s %(levelname)s %(message)sc H e Zd Zd dZd dZd ZdefdZd Zd Z d e
fd
Z dS ) ServicereturnNc . t | _ | j st d t }|j | _ t |j |j
t | _ i | _
i | _ d S )Nzpylve initialization failed)idle_time_thresholdmax_samples_number get_stats)r _pylve
initialize RuntimeError_Configread_from_config_fileenabled_enabledr
r max_samplesr _overload_checker_current_bursting_lves_effective_normal_limits)selfconfigs /builddir/build/BUILDROOT/lve-stats-5.0.4-1.el8.x86_64/opt/cloudlinux/venv/lib/python3.11/site-packages/lvestats/burstwatcher/service.py__init__zService.__init__# s gg {%%'' > <== =..00
!0 & : % 1*"
"
"
')#(*%%% c , d} t j d | j s | r=| | | n |dz dk r| d}|dz
})Nr T )timesleepr _is_server_overloaded _load_effective_normal_limits_get_current_bursting_lves_disable_bursting)r# cnts r% runz Service.run2 s
JqMMM=
))++
22444//111&&((((rQ 22444 1HC
r' c t t dd 5 }t j | }t | dk r|| _ d d d n # 1 swxY w Y nB# t t t j f$ r# t dt Y nw xY wt dt | j d S )NrzUTF-8)encodingr z7Can`t load cached effective normal limits from file: %sz*Loaded effective normal limits for %s lves)
open EFFECTIVE_NORMAL_LIMITS_PATHjsonloadsreadlenr" OSErrorIOErrorJSONDecodeErrorlogger exceptiondebug)r# f loaded_effective_normal_limitss r% r. z%Service._load_effective_normal_limitsC s$ v2C'JJJ
Sa15AFFHH1E1E.566::4RD1
S
S
S
S
S
S
S
S
S
S
S
S
S
S
S $"67 v v v VXt u u u u u v A3tGdCeCefffffs5 A2 AA& A2 &A**A2 -A*.A2 2z6Service._get_current_bursting_lves..T s/ ggg4WT8#3#3#5#566gggr' T)without_limitsc h | ]j}|j j t |j i d k K|j dk Vt |j kS )cpur )rR r" getstrid)rL statr# s r% z5Service._get_current_bursting_lves..V sq '
'
'
!x48<>ae>CfCfggg '
'
'
'
%.'
'
'
# 0$2MNNNNNr' c | j D ]8}|dk rt d #| | 9t d d S )N0zSkipping lve_id=0z Disabled bursting server-wide)r! r? rA _disable_bursting_for_lve)r# _ids r% r0 zService._disable_bursting\ sc . 0 0Cczz 0111 * *3 / / / / 455555r' id_c
t d| | j |i }| j di } | j }t
| d| dt d |_ t
| d| dt d |_ t
| d| dt d |_
t
| d| dt d |_ t
| d| dt d |_ t
| d| dt d |_
t
| d | d t d |_ t
| d
| d
t d
|_ | j t
| |d | d
d S # t" $ r }t% j | Y d }~d S d }~ww xY w)Nz Disabling bursting for LVE %sr[ iorR ncpumemeppmemnprociopszCan't setup lve with id z; error code {code})err_msg)r? rA r" rS r liblve_settingsintr ls_iols_cpuls_cpus ls_memory ls_enters
ls_memory_phyls_nprocls_iops lve_setupRuntimeWarningloggingr@ )r# r^
lve_limitsdefault_limits lve_settingsrws r% r\ z!Service._disable_bursting_for_lvef s 4c:::266sB??
6::3CC " ;6688L!$Z^^D.:L:LTS^_cSd:e:e%f%f!g!gL "%jnnUNP>PQWYdekYl>m>m'n'n#o#oL %( ~?Q?QRWYdejYk?l?l)m)m%n%nL "%( n>P>PQUWbcgWh>i>i)j)j%k%kL "),Z^^FNDVDVW]_jkq_rDsDs-t-t)u)uL &$'
w@R@RSZ\gho\p@q@q(r(r$s$sL !#&z~~fn>P>PQWYdekYl>m>m'n'n#o#oL K ! !C,0e30e0e0e
"
" " " b ! ! ! ! ! ! ! ! ! "s I?K
K= K88K=)r N) __name__
__module__ __qualname__r& r2 r. boolr- r/ r0 rT r\ rJ r' r% r r " s
+
+
+
+ "g g g,t , , , ,
O O O6 6 6"S " " " " " "r' r c . e Zd ZU eed< eed< eed< dS )
_RawConfigbursting_enabled bursting_critical_load_threshold"bursting_critical_load_samples_numN)ry rz r{ r| __annotations__rT rJ r' r% r~ r~ s6 &))))(++++++r' r~ F)totalc J e Zd ZU edefd Zeed< eed< e ed< dS )r r c t j t t t }n,# t
$ r t d i }Y nw xY wdddd}i }i }dt dfd t d
fd t d ffD ][\ }}} || }n# t $ r Y w xY w || } n)# t $ r }
t |
||< Y d }
~
Nd }
~
ww xY w| ||< \|rJt d
d
d | D t di t! || } | | z
x} rt d| | S )N)_loggerzConfig file not found!Fg?r* )r r r r r r r r r z%Failed to parse some config keys:
%s
c 3 , K | ]\ }}d | d| V dS )z* z: NrJ )rL kes r% z0_Config.read_from_config_file.. s2 MMDAq-q--A--MMMMMMr' z Using default values for: %srJ )typingcastr~ r r? FileNotFoundErrorwarningr floatri KeyError
ValueErrorrT joinitemsr r keysinfo)
cls
raw_configdefault_paramsexternal_paramserror_by_raw_keyraw_key extractorparam raw_valuevaluer r#
defaults_useds
r% r z _Config.read_from_config_file s Z 1P1P1PQQJJ NN3 4 4 4JJJ
#'
i 8
/8M N
13
F*
+ + %GY
&w /
! ),,
,/FF )
&+OE " " NN8 MM4D4J4J4L4LMMMMM
CC/>BBCC + 0 0 2 2_5I5I5K5K K KM G KK6
F F F s9 -0 &AA
B
B B $ B00
C:CCr r r N)
ry rz r{ classmethodr r r| r r ri rJ r' r% r r s[ ,d , , , [,\ MMM r' r )&rt r8 r+ r r r r collectionsr clcommon.clprocr lveapir lvectllibr lvestatr
'lvestats.plugins.generic.burster.configr r )lvestats.plugins.generic.burster.overloadr
r r7 basicConfigINFO getLoggerr? FileHandlerhandler setFormatter FormattersetLevelDEBUG
addHandlerr r~ r rJ r' r% r s
. . . . . . . . . . # # # # # # ! ! ! ! ! ! P P P P P P P P [ [ [ [ [ [ [ [ L ', ' ' ' ' > * * '
B
C
C &W&'NOO P P P ' Z" Z" Z" Z" Z" Z" Z" Z"z, , , , ,% , , , , 2 2 2 2 2j 2 2 2 2 2r'