0" , d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlmZm Z d dl
m Z d dl m
Z
d dlmZ d dlmZ d dlmZ d d lmZ d d
lmZ d d lmZ d d lmZm Z d d
l m Z m Z d dl m!Z!m"Z" d dl#m$Z$ d dl%m&Z& d dl'm(Z(m)Z)m*Z* d dl+m,Z, d dl-m.Z. dZ/ e, Z0de1de1fdZ2de1de1de1de1de1d e1d e1fd Z3d ede1de1d ee1 dee1 f
d!Z4d ede1d"e5de1d#e6de7f d$Z8d%e7de1ddfd&Z9d'ede1d e1de6fd(Z:d)e5de7fd*Z; d0de1d)e5d'e e d-e7d.e1de6f d/ZError happened while writing redis config for user '%(user)s' )userr< )r. r& fullmatchstr
IGNORECASEr intr) r r DEFAULT_MAX_CACHE_MEMORY_USER_REDIS_CONF_PATTERNformatr! r" joindirnamer makedirsOSErrorIOErrorr
_r ) r/ r0 r1 r2 r r3 r4 r6 _maxmemory_matchredis_config_contentr< s r- _write_redis_config_for_userrP O s ..?@@J|M3y>>2=QQ +s3C3I3I!3L3L/M/MiiiiQiiiii 7 3:: RW__-> ? ?MM% ;
RW\\,
>>
] K
T 2 2 2 2 2" ] ] ]A&N$O$O$%&]$^$^2>++ K+t,,
1E1T1Tttt 5 is_cagefs_missingc t j | }| r
t |g}n
dt |g}| dt | d\ }}t j |t |j |j t
j
t
j
} | d \ }}n# t
j $ r Y nw xY w| dt |
t |
t j |j t$ d } t' | }
| d t |
|
t) d d
S ) z#
Run subprocess with redis
z/bin/cagefs_enter.proxiedz"[Start redis] Executing command=%s)rq rq )
preexec_fnstdoutstderr )timeoutz Captured stdout=%s, stderr=%s redis.pidz[Start redis] Redis pid=%sNz'Redis instance was not started for user)pwdgetpwnamr inforB
subprocessPopenr pw_uidpw_gidPIPE communicateTimeoutExpireddecoder! r" rH pw_dirr r rK ) rr r r/ _loggeruser_pwdcommandru rv processr4 redis_pids r-
__start_redisr sj |H%%H Z(*;< /0EGXY LL5s7||DDD NFF (/8?;; G
,,Q,77 $
LL0#fmmoo2F2FFMMOOH\H\]]]7<< LLL6|DDI LL-s9~~>>>?@@@ 4s B2 2CCr c t j | }| d| t j |j t }t j |d }t j |d }t j |d }t ||j ||||| | d|||| t t j }t | ||| dddS # t t f$ rU} t j }
| d ||
t% d
d t' | id cY d
} ~ S d
} ~ ww xY w)al
Start redis server for supplied user (calls under user)
:param _logger: Daemon's logger
:param username: Username to setup redis
:param maxmemory: maxmemory value to write to redis config
:return: dict
If redis was started for user - {"result": "success"}
else - redis was not started - {"result": "error", "context": "...."}
Starting redis for username=%sz
redis.sockz
redis.confry zaRedis config for user=%s is saved with parameters:socket_path=%s, config_path=%s, pidfile_path=%ssuccessTresult
redis_enabledz;Error while starting redis server for user %s. Error is: %sz,Error while starting redis server: %(error)serrorr r? N)rz r{ r| r! r" rH r r rP r
r CAGEFSr rK rL traceback
format_excrU rM rB ) r r/ r3 r wpos_dirr2 r r4 is_cagefs_availablerY str_excs r- _start_redis_server_for_userr s |H%%H LL18<<<w||HO];;H X|<< X|<<7<<+66L 8?HFWYj!*L: : : LL # "" . 8 H H--/@(GTTT#d;;; W . . .&((UW_ahiii JKK #SVV,. . . . . . . ..s )0D F +A
E;5F ;F
old_redis_pidc | dk rdS t st d t j | d n # t $ r Y dS t
$ r Y nw xY wt
t | dS )a
Check existing process by PID and kill it:
- If old_redis_pid == -1, nothing will kill, return False
- else check process existance.
if exi
:param old_redis_pid: PID to check and kill
:return: True - Can't kill process not owned by current user, this is error, continue work not allowed
False - Process absent or was killed succesfully, continue work allowed
Fz;Internal error! Trying to kill process with root privilegesr T)r r
r! killPermissionErrorProcessLookupErrorr rQ )r s r- _check_redis_process_and_killr s u WUVVV
q!!!! tt
... 5s =
A
AAFnois_log_debug_level force_reloadc |t }| d| t | t | t | dd t | rt d | |ddS t
| }| }no# t $ rb}|r$| d| t | |st d d
| idcY d}~S | d i }Y d}~nd}~ww xY wt j | }t || |j
|j | } | s|d k rE| d
| t || | dt j S dddS )a%
Reloads redis for supplied user without logging and killing old redis process
Calls only from redis_reloader.py script
:param username: Username to setup redis
:param old_redis_pid: Redis PID to kill, -1 - no PID to kill
:param _logger: Daemon's logger
:param is_log_debug_level: True - log messages/ False - no
:param force_reload: reload redis w/o conditions
:return: dict
If redis was started for user - {"result": "success"}
else - redis was not started - {"result": "error", "context": "...."}
Nz_[Reload redis for user]: Request to reload redis for username=%s, old redis pid=%s,force_reloadF)effective_or_realset_envz@Can't kill old redis process for user '%(user)s'. PID is %(pid)s)r@ pidr z unconditional reloadyesr max_cache_memoryr r )rQ r| rB r r rM r read_configr rU rz r{ rp r r r rd rE )
r/ r r r r user_config_class user_configrY pw_useris_redis_enables
r- reload_redis_for_userr * s LL ]##\""
$ $ $ UEJJJJ$]33 E ^__$,]CCE E E &x 0 0'3355 n OO Z\dfijkflfl m m m b c c & 13 3
3
3
3
3
3
3
LLi j j j KKKKKK l8$$G.w/6~w~{\ \O b,%// 5x@@@+GX,7OO D"C>>D)NFr )=rz r! r& r r} loggingr typingr r secureior clcommon.clpwdr clcommon.cpapir clcommon.constr r
clcommon.utilsr clwposr rM clwpos.cl_wpos_exceptionsr
clwpos.daemon_redis_libr r clwpos.utilsr r clwpos.user.configr r clwpos.optimization_featuresr clwpos.feature_suitesr clwpos.constantsr r r clwpos.logsetupr clcommon.cpapi.cpapiexceptionsr rF rQ rB r. rP r_ rD dictboolrp r r r r rq r- r s
! ! ! ! ! ! ! ! , , , , , , / / / / / / & & & & & & " " " " " " 5 5 5 5 5 5 ! ! ! ! ! ! / / / / / / _ _ _ _ _ _ _ _ 9 9 9 9 9 9 9 9 6 6 6 6 6 6 6 6 = = = = = = 5 5 5 5 5 5 f f f f f f f f f f & & & & & & 4 4 4 4 4 4 $
C C $'R3 'Rc 'Rs 'Rgj 'R47'RDG'RWZ'R 'R 'R 'RT F c QT >B3i LPQTI B#V #s # #TW #/3#8<# # # #L#T #c #Y] # # # #L#.& #.C #.C #.TX #. #. #. #.L < Z^PT39 39C 39 39hvFV 39.239JM39Y]39 39 39 39 39 39rq