73 ~ d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlmZ d dl m
Z
m Z m Z d dl
mZ d dlmZmZmZ d dlmZ d dlmZ d dlmZ d d lmZ d d
lmZm Z m Z m Z d d l m Z d d l!m"Z# ej$ e% Z&d
Z'de(de
e) fdZ*de(de
e) fdZ+de(de(de
e) fdZ,dede)fdZ-dede(fdZ.defdZ/de)de0fd Z1d e)de e0e0e2f fd Z3d e(de e) fd Z4 d(de(d"e e) d#e(de e e) e2f fd$Z5de
e e)e)f fd%Z6d&ej7 de e e)e)f fd'Z8dS )) N)Logger)ListOptionalTuple)drop_privileges) run_commandExternalProgramFailedis_user_present)cpusers)get_main_username_by_uid)REDIS_SERVER_BIN_FILE) WposError)
USER_WPOS_DIRis_run_under_userdrop_permissions_if_neededrun_in_cagefs_if_needed) NoPackage)gettextz /opt/alt/redis/bin/redis-cli file_pathreturnc d}t j | sd} t || gd }| d }|d d d }g }| d D ]G} | t | 8# t $ r Y Dw xY w|S # t t f$ r Y nw xY wg S )
z
Retrieves list of PID list processes, which uses file (using fuser utility)
This can find any process (for example php), not only redis service process
:param file_path: Filename to check
:return: PID list
z/usr/bin/fuserz /sbin/fuserFreturn_full_output
r : ) ospathexistsr splitstripappendint
ValueErrorr
IndexError)r fuser_binarystd_out
lines_list
s_pid_listpid_lists_pids py/clwpos/daemon_redis_lib.py_get_pids_for_filer. 1 s $L
7>>, ' ' %$
|Y 7ERRR ]]4((
]((--a06688
%%c** E
EKKMM 2 23333
!: .
Is6 A4C! 4CC!
C C! C C! !C54C5usernamec t dddd| gd }n# t $ r g cY S w xY w| d }t | dk rg S g }|d d
}|D ]^}| }|rF | t
| N# t $ r Y Zw xY w_|S ) zz
Update PID list in cache for user using /bin/ps utility
:param: username: Username to scan
:return: None
z/bin/psz-opidz-uFr r r N)r r r! lenr" r# r$ r% )r/ r( r)
user_pid_listlines r- _get_user_pidsr6 Q s y$tX F[`aaa t$$J
: MABB J zz||
$$S %6%67777
s ((<4B11
B>=B>home_dirc t j |t d }t | }t | }g }|D ]}||v r| | |S )z
Get redis PID list for user
:param username: user name
:param home_dir: User's homedir
:return: PID list or [] if user has no redis
redis.sock)r r joinr r. r6 r# )r/ r7 redis_socket_file
pid_list_sock user_pidsr+ r1 s r- _get_user_redis_pidsr> q sn X}lKK&'899M x((IH ! ! ) OOC O _loggerr1 c t st d t j |t j t
j d t j |t j n# t $ r Y nw xY wn;# t $ r.}|
d|t | Y d}~nd}~ww xY w| dt | dS )zj
Kill process by pid
:param _logger: Logger to log errors
:param pid: Process pid to kill
z;Internal error! Trying to kill process with root privileges z+Can't kill redis process, pid %s; error: %sNzKilled process with pid=%s)
r r r killsignalSIGTERMtimesleepSIGKILLOSErrorwarningstrinfo)r@ r1 es r- kill_process_by_pidrN s WUVVVT
V^$$$
1
GC ( ( ( ( D T T TEsCPQFFSSSSSSSST LL-s3xx88888s; 3B A3 2B 3
B =B ?B B
B<$B77B<loggerc H t | sdS t j | }t |j |j }| dt | | t | 5 |D ]}t | | ddd dS # 1 swxY w Y dS )zq
Kill all user's redice processes
:param logger: Logger to log errors
:param username: User name
Nz%Killing redis with pid=%s for user=%s)
r
pwdgetpwnamr> pw_namepw_dirrL rK r rN )rO r/ user_pwdredis_pid_list redis_pids r- _kill_all_redises_for_userrX s 8 $ $ |H%%H)(*:HOLLN
KK7^9L9LhWWW " " 3 3' 3 3I 2 2 2 2 33 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3s 3BB Bc t }nN# t t t t f$ r.}| dt
| Y d}~dS d}~ww xY w|D ]}t | | dS )z[
Find and kill lost redices for all panel users
:param logger: Daemon's logger
z"Can't get user list from panel: %sN)r rI IOErrorr& r rJ rK rX )rO usersrM r/ s r- kill_all_users_redisesr\ s
Wj) 4 ;SVVDDD 5 5"6844445 5s A #AA uidc
T t | }t j | }n9# t $ r, t dt
| Y dS w xY wt j |j
t d }t d|dg}t | 5 t | }t d|t
|j t
|j t
|j ddd n # 1 swxY w Y |j dk S ) a$
/opt/alt/redis/bin/redis-cli -s /home/cltest1/.clwpos/redis.sock ping
Could not connect to Redis at /home/cltest1/.clwpos/redis.sock: No such file or directory
echo $?
1
/opt/alt/redis/bin/redis-cli -s /home/cltest1/.clwpos/redis.sock ping
PONG
echo $?
0
4Redis check error for user %s. No user with such uidFr9 z-spingzDRedis health check for user=%s, return code=%s, stdout=%s, stderr=%sNr )r rQ rR KeyErrorrO rJ rK r r r: rT r _REDIS_CLI_BIN_FILEr r rL
returncodestdoutstderr)r] r/ rU redis_socket_pathredis_ping_cmdoutputs r- redis_socket_health_checkri sR +C00<)) MsSVxxXXXuu X_m\RR)41BFKN #H - - ( (( 88 Z )**
&&
&& ( ( (( ( ( ( ( ( ( ( ( ( ( ( ( ( ( !!s" #& 2A A $A$DDDuser_idc " t j | }|j }n\# t $ rO t dt
| ddt d dt
| idfcY S w xY w t | }ne# t $ rX}t d|t
| ddt d t
| |d dfcY d
}~S d
}~ww xY w|sddt d d |d dfS ddd
difS )a
Check user's redis is alive
:param user_id: uid to check sockets
return True/False - redis alive/not alive
:return: Tuple: (redis is working/not working, is user present, errors dict)
error - (False, False {"result": "error", "context": "..."})
r_ Fz9Redis check error for user with uid %(uid)s. No such userr] resultcontextz+Redis check error for user %s. Error is: %sTz1Redis CLI start error %(error)s for user %(user)s)erroruserNz1Redis CLI check error %(error)s for user %(user)sz=Redis is not pingable for user, most likely it is not startedrm success)
rQ getpwuidrS ra rO rJ rK _ri Exception)rj rU r/ is_redis_aliverM s r- is_user_redis_aliverv s @<((# @ @ @MsSZ||\\\e*e(f(f*/W )> @ @ @ @ @ @@
Q27;; Q Q QDhPSTUPVPVWWWd*](^(^47FFH)N)N Q Q Q Q Q Q Q Q QQ
<dq)\']']2q19); ); < < < < ), ,,s/ AA76A7;B
C-A
C("C-(C-redis_pid_filenamec v t d D ]} t | d 5 }t | }t j |d |cddd c S # 1 swxY w Y x# t t t f$ r t j d Y w xY wdS )z
Get redis process PID from redis pid file. Wait up to 10 seconds
:param redis_pid_filename: Redis PID filename
:return: Redis PID or None on error (pid file absent/invalid or redis not started)
d rr Ng?) rangeopenr$ readr" r rC rI rZ r% rF rG )rw ifr1 s r- &_get_redis_pid_from_pid_file_with_waitr s 3ZZ (#..
!!&&((..**++Q
*- JsOOOOO 4s5 BA
A<- B<B BB B+B65B6no
old_redis_pid force_reloadc t j | }nH# t t f$ r4 t d| dt
d d| idfcY S w xY wt d| t | | t j
d| t | |gdt j t j d
}| \ }}nk# t t f$ rW}t d | t | dt
d | t | d
dfcY d}~S d}~ww xY w t j | }|d dk rd|fS n9# t t j t$ f$ r dt
d | |ddfcY S w xY wt& j |j t. d } d}
| dd rt3 | }
|
ddifS )a
Reloads redis for supplied user via helper script. Should be trun in thread
:param username: Username to setup redis
:param old_redis_pid: Old Redis PID for kill
:param force_reload: reload redis w/o checks
:return: Tuple:
If redis was started for user - (PID of new redis process, {"result": "success"})
else - redis was not started - (None, {"result": "error", "context": ""})
z1Can't reload redis for user '%s'. User not found.Nz7Can't reload redis for user '%(user)s'. User not found.rp rl zYCalling redis_reloader with parameters: username: %s, old redis pid: %s, force reload: %sz,/usr/share/cloudlinux/wpos/redis_reloader.pyFT)shellrd re textz-Reload redis error for user '%s'. Error is %sz8Reload redis error for user '%(user)s'. Error is %(msg)s)rp msgrm rq z rN rX r\ boolri dictrv r r r Processr r? r- r s
( ( ( ( ( ( ( ( ( ( * * * * * *
# " " " " " 3 3 3 3 3 3 2 2 2 2 2 2 / / / / / / 5 4 4 4 4 4
8 $ $4 # $s) @ S T#Y @3 # $s) "9 9c 9 9 9 9,3v 3 3 3 3 3$ 56 5 5 5 5"3 "4 " " " ": - -tT4/?)@ - - - ->s xPS} * 6:,, ,,3 ,,08
,,/2,,>CHSMSWDW>X,, ,, ,, ,,^ #tE#s(O, # # # # FN xc3h/H r?