H:ju# 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-5.0.4-1.el8.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-8)encodingr 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 )r4 z*Signal 'SIGTERM' sent to child process: %sNr5 r6 s r on_terminatez!stop_server..on_terminate= r8 r stop_server) caller_name T) recursiveiX )timeout )r? callbackg333333?)r! signalSignalspsutilProcessr r) childrenr
pid_existsr( SIGUSR2
wait_procsSIGTERMtimesleepSIGKILL) exit_coder1 r7 r: r( processchildschild_alivepr0 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 )ra
excepthook)rh s r setup_default_exception_hookrj Y s / / / CNNNr c D ddl m} | | |||| d S )Nr )main)lvestatsrl )cnf
singleprocessplugins
profiling_logtimes_rl s r run_mainrs e s4 IIc='=&AAAAAr c t j d }| d t j d d S )Nsigterm_handlerz SIGTERM handler. Shutting Down.r )r\ getLoggerr/ r _exit)signumframer0 s r ru ru j s7
-
.
.CHH
.///HQKKKKKr c | d t j | }| d t j || 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_engineexecute normalize_sqlite_journal_modevalidate_databasera exit Exceptionfatalr^ exceptionr )rn log_engine
validationexrg s r _check_db_connectionr p s JJ-...?(--{### .vt<<< /77
n % M)B HQKKKKK ? ? ??
3r77 r"#5#5#5r#5#5#566B> ?s A6B
C0AC++C0c | 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_versionrg 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 rcrg 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 ra stderrwriter flush)rn 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" r| d
t" t j t" t j t j z t j z t j z d } t j |t1 | d t j | n# t j | w xY w| d
t j d t j d t j t j d t j d } t j t j! t% tD d }
t% tD d } t% tD d } t j# |
$ t j% $ t j# | $ t j $ t j# | $ t j! $ |& d t j | tO | |||| 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 %si r zChild daemon fork ok
/r za+zStarting main() in daemon)(r r\ CRITICALrj rv r ra r r~ rK rL r rw setsidrB rJ ru r r O_WRONLYO_CREATO_TRUNC
O_NOFOLLOWr r^ encoder` nicesetpgrpchdirumaskstdoutr r DEV_NULLdup2filenostdinr/ rs )
rn ro rp rq timesr r r( fdprevious_umasksisoses
r daemonizer s C C C #W%56666 """ X & &D c4 ( ( JJ !!!
$&&C
'---
3
IKKK
M&./222
$&&C
(#... JJ/ 9 9 9"+
":RZ"G"-"WY^__B
SXX__W 5 5666
)***
GBKKKJLLLHSMMMXa[[NJJ
h B
h B
h BGBIIKK))++,,,GBIIKK**,,---GBIIKK**,,---II)***H^ S--?????s
5G G-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)actionra r r; r ro rp rq nodaemon
debug_moder\ DEBUGINFOr rj rs )rn _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= )pidfileprintra r r r r! r read_config ConfigError log_and_exitr r r0 r] r^ )optsr cfgce lve_errors r rl rl s <
-... , E z DJ
C ""
S$&&&&&
Y ((( s1 A' 'B6BBB+ +
D 5A C;;D )!rX r\ r rB ra rK rZ rD lvestats.lib.commons.funcr lvestats.libr r r r lvestats.lib.commons.logsetupr r r r r r) r; rj rs ru r r r r r r rl 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
? ? ?81 1 1"
(
(
( (<@ <@ <@~
\
\
\ r