Y0 } d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlm Z d dl
m Z m Z d dlm
Z
mZ d dlmZ dZda G d d e Zd
Zd Zd Zd
Zd Zd Zd Zd Z d Z d Z d Z d Z dS ) N) reboot_lock)configdbengine)LVEVersionErrorget_lve_version)
setup_loggingz /dev/null c e Zd Z fdZ xZS )EnvironmentExceptionc V t || _ d S )N)super__init__message)selfr __class__s /builddir/build/BUILDROOT/lve-stats-4.3.2-1.el9.x86_64/opt/cloudlinux/venv/lib/python3.11/site-packages/lvestats/lib/lvestats_server.pyr z EnvironmentException.__init__ s$
)__name__
__module__ __qualname__r
__classcell__)r s @r r r s8 r r c t rt j t r t t dd 5 } t | }t j |d |cddd S # 1 swxY w Y dS # t t f$ r Y dS w xY wdS dS )z
Check if lvestats already running
:return int|None: None - if no process found; pid - if some lvestats-server found
rutf-8encodingr N) PIDFILEospathisfileopenintreadstripkillIOErrorOSError)fpids r get_process_pidr* s
27>>'** gsW555
!&&((..**++Q
! 44
s6 B( A
B B( B B( "B #B( (B=<B=c $ d} dt dt j f fd }dt j f fd }dt j f fd }t i d t
}|d
} n*t j | }| d }t d
5 |D ]6}t j |j
r ||j
t j 7t j |d| \ }} | D ] }
||
j
t j
t j |d| \ }} ||t j
t j d | D ] } ||j
t j d d d n # 1 swxY w Y | S )Nr _pid_signalc t j | | dS # t t f$ r d| Y dS w xY w)z6Kill process by pid by sending a specific signal to itz%Process with pid '%d' is already deadN)r r% r' ProcessLookupErrorinfo)r, r- logs r kill_processz!stop_server..kill_process2 sd D GD' " " " " "+, D D D HH.on_sigusr29 =uEEEEEr c 4 d| dS )r5 z*Signal 'SIGTERM' sent to child process: %sNr6 r7 s r on_terminatez!stop_server..on_terminate= r9 r stop_server) caller_name T) recursiveiX )timeout )r@ callbackg333333?)r" signalSignalspsutilProcessr r* childrenr
pid_existsr) SIGUSR2
wait_procsSIGTERMtimesleepSIGKILL) exit_coder2 r8 r; r) processchildschild_alivepr1 s @r r< r< / sD ID3 D D D D D D DF&. F F F F F FFFN F F F F F F
6
6
6C
C
{ .%%!!D!11
)
)
)
8
8
<
< $UY// < LFN;;; (ZPPPHAu
4
4 QUFN3333 (\RRRHAu Lfn - - - Jt
8
8 UY7777
8
8
8
8
8
8
8
8
8
8
8
8
8
8
8
8 s CFF F c $ d } | t _ d S )Nc " t j }t j || d| d}t j |t
| | | t j
| || d S )N)filezUncaught exception z
message='%s'
:%s) ioStringIO tracebackprint_tbloggingerrorstrgetvalueclosesys__excepthook__)_type_ex_tracesiomsgs r hookz*setup_default_exception_hook..hookZ s} kmm6,,,,>E>>>
c3s88S\\^^444 5#v.....r )rb
excepthook)ri s r setup_default_exception_hookrk Y s / / / CNNNr c D ddl m} | | |||| d S )Nr )main)lvestatsrm )cnf
singleprocessplugins
profiling_logtimes_rm s r run_mainrt e s4 IIc='=&AAAAAr c t j d }| d t j d d S )Nsigterm_handlerz SIGTERM handler. Shutting Down.r )r] getLoggerr0 r _exit)signumframer1 s r rv rv j s7
-
.
.CHH
.///HQKKKKKr c | d t j | }| d t j | }|d s|d rt j d dS dS # t $ rU}d}| t | |
| t d| d| d |d}~ww xY w) z
Check whether database connection can be
established and db schema is ok.
Raises exception if database is broken.
:type cnf: dict
:type log_: logging.Logger
:raises: EnvironmentException
z Check for running SQL serverz SELECT 1; column_error table_errorr> z/Error occurred during connecting to SQL server:
N) debugr make_db_engineexecutevalidate_databaserb exit Exceptionfatalr_ exceptionr )ro log_engine
validationexrh s r _check_db_connectionr p s JJ-... ?(--{### /77
n % M)B HQKKKKK ? ? ??
3r77 r"#5#5#5r#5#5#566B> ?s A!A< <
CACCc | d t }|dk r*d}| d t d| d dS )z
Check for possible misconfiguration
if cpu speed is reported as 0 with /proc/cpuinfo
and lve version <= 4. Raises exception, if so.
:type log_: logging.Logger
:raises: EnvironmentException
zCheck for valid LVE version zLVE version <= 4z!LVE version <= 4. Please, update.r~ N)r r r r )r lve_versionrh s r _check_valid_lve_versionr sc JJ,---!##Ka
6777"<<<<000 r c | d t }|r*d| d}| | t | dS )z
Check if another instance of lve-stats is
already running. Raises exception, if so.
:param log_: logging.Logger
:raises: EnvironmentException
z!Check for running lvestats-serverz)Lvestats-server already running with pid z . ExitingN)r r* warningr )r rcrh s r _check_running_processr sd JJ2333 B (G"GGG S"3''' ( (r c t | t | | t | nZ# t $ rM}t j |j t j Y d}~dS d}~ww xY wdS )z
Checks whether system environment works fine.
Return True if ok, False otherwise.
:type cnf: dict
:type log_: logging.Logger
:rtype: bool
NFT) r r r r rb stderrwriter flush)ro r r s r _is_environment_okr s t$$$ S$''' &&&&
$$$
uuuuu
4s .1
BABBc d }t | t j t t j d }t | | st
j d | d | }|r>| d| t j
d t j d t j
t j t j t | }|r| d | t" rl| d
t" t% t" d d
5 }| t) | d d d n # 1 swxY w Y | d t j d t j d t j t j d t j d } t j t j t% t8 d }
t% t8 d } t% t8 d } t j |
t j t j | t j t j | t j | d t j | tC | |||| d S )Nc t j S # t $ r%} t | j d| j d | d } ~ ww xY w)Nz [])r forkr' RuntimeErrorstrerrorerrno)es r r zdaemonize..fork s\ C799 C C C !* : : : : :;; B Cs
A ?A)
console_levelserverr> zStarting serverzFirst fork, pid=%dg?r zSecond fork, pid=%dzWriting pid to file %swr r zChild daemon fork ok
/r za+zStarting main() in daemon)"r r] CRITICALrk rw r rb r r rL rM r rx setsidrC rK rv r r! r r_ nicesetpgrpchdirumaskstdoutr r DEV_NULLdup2filenostdinr0 rt )
ro rp rq rr timesr r r) pidfileprevious_umasksisoses
r daemonizer s C C C #W%56666 """ X & &D c4 ( ( JJ !!!
$&&C
'---
3
IKKK
M&./222
$&&C
(#... ( JJ/ 9 9 9gsW555
(
c#hh'''
(
(
(
(
(
(
(
(
(
(
(
(
(
(
(
)***
GBKKKJLLLHSMMMXa[[NJJ
h B
h B
h BGBIIKK))++,,,GBIIKK**,,---GBIIKK**,,---II)***H^ S--?????s #FF F c |j dk r"t j t d S |j dk r2t t | |j |j |j | d S |j dk r|j rc|j r t j n t j }t | || t t | |j |j |j | d S t | |j |j |j | d S d S )Nstoprestartstart)r
file_level)actionrb r r< r rp rq rr nodaemon
debug_moder] DEBUGINFOr rk rt )ro _opts_timesr s r process_optsr s |v " "
#u*EM5;NPVWWWWW > \*/*:L J #ZJ O O O O ( * * * S%-u}e>QSY Z Z Z Z Z c5.
u?RTZ [ [ [ [ [
! r c | j s$t d t j d n| j ad }| j rt
| j }d } t j }n0# t j $ r }|
Y d }~nd }~ww xY w t || | d S # t $ rK}t j
t | t j d Y d }~d S d }~ww xY w)Nz --pidfile should be specifiedr> )r printrb r r r r" r read_config ConfigError log_and_exitr r r1 r^ r_ )optsr cfgce lve_errors r rm rm s <
-... , E z DJ
C ""
S$&&&&&
Y ((( s1 A' 'B6BBB+ +
D 5A C;;D )!rY r] r rC rb rL r[ rE lvestats.lib.commons.funcr lvestats.libr r r r lvestats.lib.commons.logsetupr r r r r r* r< rk rt rv r r r r r r rm r r r s
1 1 1 1 1 1 ) ) ) ) ) ) ) ) F F F F F F F F 7 7 7 7 7 7
9 ' ' 'T B B B
? ? ?01 1 1"
(
(
( (9@ 9@ 9@x
\
\
\ r