}s. d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
m Z m Z m
Z
d dlmZ d dlmZ d dlmZmZmZ d dlmZ d dlmZmZm Z m Z m Z m Z d dl m!Z!m"Z"m#Z#m$Z$m%Z% d d l&m'Z'm(Z(m)Z)m*Z* d dl+m,Z, d d
l-m.Z. d d l/m0Z0 d d l1m2Z2 d d
l3m4Z4 edg d Z5 e j6 e7 Z8ed Z9dej fdZ:edefd Z;ddedS ) N)OptionalDictTuple)contextmanager)
namedtuple)BoundedSemaphoreLockThread)gettext)cpusersget_domains_php_infodocrootget_installed_php_versionsget_main_username_by_uidcpinfo)get_process_pidremove_pid_filewrite_pid_fileis_litespeed_runningis_nginx_running)is_user_redis_alivekill_all_users_redises reload_redis_for_user_thread
parse_redises)WposDaemonBase)WPOS_DAEMON_SOCKET_FILE)WposDaemonLockError)PendingSubscriptionWatcher User_data redis_pidlocklast_reload_timec # b K t j d } dV t j | dS )z,
Context manager for dropping umask
r N)osumask)prevs py/clwpos/daemon.py_umask_0r) 4 s/
8A;;D EEEHTNNNNN returnc t 5 t j t j } | t | | cddd S # 1 swxY w Y dS )zr
Create world-writable socket in given sock_location
or reuse existing one
:return: socket object
N)r) socketAF_UNIXbindr listen)sockobjs r( _create_socketr2 > s
-// ,--- s AA**A.1A.r" c # K | d s t t d | V | dS # | w xY w)z=
Non-blocking lock implementation for with statement
Fblockingz/Can't acquire lock. May be it already acquired.)messageN)acquirer _release)r" s r( non_blocking_lockr: K sj
<<< ' ' `!!,]*^*^____
s A A'functioninput_parametersc |r d | D ng }t j dd| g|d }t j |j d S )Nc " g | ] \ }}| d |
S )= ).0keyvalues r(
zwhmapi1..Y s* \ \ \ZS%3 0 0 0 0 \ \ \r* z/usr/sbin/whmapi1z
--output=jsonT)capture_outputdata)items
subprocessrunjsonloadsstdoutdecode)r; r< input_parameters_as_listresults r( whmapi1rP X s} `p x \ \CSCYCYC[C[ \ \ \ \vx
^ 0/8 gNf g+/1 1 1F :fm**,, - -f 55r* c R e Zd ZdZdZdZdZdZdZdZ dZ
d Z d
Z d Z
d Zd
ZdZdZdZdZeeeee e
e e e
eeeeegZee e
eeeeegZdZdZdZdZ fdZdGdede de de fd Z dede fd Z d Z!d Z"d Z#d! Z$d" Z%d# Z&d$ Z'dHd'e fd(Z(e)de*fd) Z+e)de*fd* Z,e)de*fd+ Z-d,e.j. de/e ee0e e0e* e f fd-Z1d,e.j. d.e d/efd0Z2d1ede fd2Z3 dId,e.j. d.e d/ed3e de d4e f d5Z4e)dJd7e de5fd8 Z6d,e.j. fd9Z7d,e.j. fd:Z8d,e.j. fd;Z9d,e.j. d7e fd<Z:d,e.j. fd=Z;d,e.j. fd>Zd,e.j. fdAZ?d,e.j. fdBZ@d,e.j. dd6fdCZAdD ZBd/edd6fdEZCd,e.j. d/edd6fdFZD xZES )K
WposDaemonzW
AccelerateWP daemon main class. Socket operations, redis process control, etc
z/var/lve/wpos_reloadreloadzget-redis-statuszget-litespeed-statuszget-nginx-statuszget-apache2nginx-statusphp_get_vhost_versionsphp_get_installed_versionsget_upgrade_link
get_unique_idsuite_allowed_callbackdaemon_register_upgradedaemon_get_upgrade_status&daemon_get_supported_suites_by_licensedaemon_is_owned_by_resellerdaemon_is_wp2_environment 2 c ( t i | _ g | _ d | _ d| _ d | _ d| _ t | j | _
i | _ t | _
t | _ d S )Nr T)super__init___monitoring_users_dict_username_list_to_process_socket _reload_uid_socket_thread_socket_thread_workr _MAX_CONCURRENT_CONNECTIONS_connection_semaphore_uid_connection_countsr _uid_connection_lockr _suite_watcher)self __class__s r( rd zWposDaemon.__init__ s
=?#)+&04 04#' %5d6V%W%W"68#$(FF! 8 : :r* nouser_uidis_store_last_reload_time force_reloadr+ c B | j | }|d}n|j }t | }t d|| t
||| \ }}|d dk rCt d| t |t d | j |< |S |rv| j j
r|sd} nt j } t |t | }
|
| j |< t d|t |
n,|| j v r#t d | | j |= nB# t $ r5} t | dt | icY d} ~ S d} ~ ww xY wddiS )
aP
Starts/stops redis for user and updates dict for monitoring (self._monitoring_users_dict)
:param user_uid: uid to reload redis
:param is_store_last_reload_time: True - write last reload time to user data, False - write 0
:return: dict {"result": "success"} / {"result": "error", "context": {}}
Nz.Reloading redis for user: %s, force reload: %srO successz^Redis reloading failed for user: %s, adding to monitoring list to try again in several minutesr r z)Saving user=%s to monitoring with data=%sz Removing user=%s from monitoring)re getr! r loggerinfor r r _configenable_reload_rate_limittimestr Exception exception) rp rs rt ru userdata
old_redis_pidusername
new_redis_pid result_dictr# user_redis_dataes r( _reload_redis_for_userz!WposDaemon._reload_redis_for_user s ' &266x@@H $
( 2
/99H KKH ,
0
0
0)E- *7 *7 &M; 8$ 11 CDLN N N 9B +$&&19N 9N 9N+H5""
> |< 3D] 3'($$'+y{{$"+m$&&Sc#e #e #e8G+H5 GSVWfSgSghhhh t :::KK BHMMM 3H= & & & Q c!ff% % % % % % % & )$$s% B3E 6B$E
F%*FFFc | j | }d} t |j 5 t | \ }}}|s ddd dS |r ddd dS t | }t
d| t || j | j \ }}||d dk r ddd dS t ||j d | j |< ddd n # 1 swxY w Y ne# t $ r,} t
d
| j || Y d} ~ n4d} ~ wt $ r$} t
| Y d} ~ nd} ~ ww xY wdS ) a"
One user monitoring actions
:param user_uid: uid to reload redis
:return: User remove flag:
True - user has stopped his redis (or user absent in system), remove it from monitoring list
False - redis still active, should be monitored again
NTFz/Redis instance died for username=%s, restartingrO rw r r zSLock error: %s. User %s (uid=%d) is working with his redis, skip monitoring actions)re r: r" r r ry rz r r! r r debugr6 r r )
rp rs user_datar is_redis_aliveis_user_presentr8 r! r r s
r( _user_monitoringzWposDaemon._user_monitoring sz $ :8 D "9>22
V
V5H5R5R2&
V
V
V
V
V
V
V
V " !
V
V
V
V
V
V
V
V 4H== MxXXX)E /9C*E *E& ; $X)>))K)K
V
V
V
V
V
V
V
V 9BI\e\jST9V 9V 9V+H5!
V
V
V
V
V
V
V
V
V
V
V
V
V
V
V$ # > > > LLn y(H
>
>
>
>
>
>
>
> Q usj C9 C- C9 C- C9 A C-5 C9 C-! C9 -C11C9 4C15C9 9
E"D**
E7EEc g }t dt | j t | j D ].}| | }|r| | /|D ];}|| j v r0t dt | | j |= > >D 7 < < > >?? 8 8G --g66I
8'..w777. 9 9G$555 CS\\RRR/8 9 9r* c | j rd| _ t }t dt | |D ]} t j | j }n# t $ r Y )w xY w| j
| }t dt | |r|j s| |d dS dS )zC
Process all requests - start/stop redis for users
Fz*Checking redis instance for those users=%sz2Current user data for redis instance monitoring=%sN)
_reload_config_needr ry rz r~ pwdgetpwnampw_uidKeyErrorre rx r! r )rp all_usersr r monitored_user_datas r( _reload_all_usersz WposDaemon._reload_all_users s # @',D $ I KKDc)nn U U U %
@
@ !l8 4 4 ;GG H '+&A&E&Eg&N&N# PRUViRjRjkkk* @2E2O @//??? @ @
@
@s
A$$
A10A1c J d}t }t d| |D ]F}| j |d t |d t
d i G| j s | | | j rd S t j d |dz
}|| j j
k r| d}n,# t $ r t dd Y nw xY w| j d S d S )Nr zFound existing redises: %s r z,Cloudlinux AccelerateWP daemon general errorTexc_info)r ry rz re updater r
_is_terminate
_force_reloadr r} sleepr{ monitoring_intervalr r r )rp iexisting_redisesitems r( _main_cyclezWposDaemon._main_cycle+ sa
(?? 02BCCC$ y yD ' . .QTRSW[_[a[atu9v9v9v/w x x x x$ `
`""$$$&&(((% E
1
Qt|777,,...A
`
`
` !OZ^ _____
` $ ` ` ` ` `s =/C. .?C. .&DDc l t | j | _ | j dS )z;
Create and start socket processing thread
)targetN)r
_process_socket_connectionsri startrp s r( _create_and_start_socket_threadz*WposDaemon._create_and_start_socket_threadB s5 %D,L M M M !!#####r* c ^ t | j "t d| j dS t j t r| t | _
nI# t t f$ r5}d}t |t | Y d}~dS d}~ww xY wt d | t! | j | | | d| _ | j | t/ | j t d dS )z+
Main work daemon function
NzCPID file %s existing. Cloudlinux AccelerateWP daemon already works?z5Can't create AccelerateWP daemon socket. Error is: %sz&Cloudlinux AccelerateWP daemon startedFz)Cloudlinux AccelerateWP daemon terminated)r
_PID_FILENAMEry warningr% pathexistsr _remove_socketr2 rg OSErrorIOErrorr~ rz _setup_signalsr rS r r rj ri joinr )rp r r6 s r( rI zWposDaemon.runI s 4- . . : NN`bfbt u u u F
7>>1 2 2 " ! ! ! )++DLL! MG NN7CFF + + + FFFFF
<=== t)***
,,... #( """ *+++ ?@@@@@s 0B C
*CC
c t j | j rH| t j | j dS # t t f$ r Y dS w xY wdS )z%
Force reload daemon
N)r% r isfile_WPOS_DAEMON_RELOAD_FILErS remover r r s r( r zWposDaemon._force_reloadk sy
7>>$7 8 8 KKMMM
$788888W%
s A A*)A*c t dt | j | j t j t t dt dS # t t f$ r9}t dt t | Y d}~dS d}~ww xY w)z-
Remove daemon's socket file
zRemoving socket %sNzSocket %s removedz!Can't remove socket %s. Error: %s) ry rz r rg closer% r r r r r~ )rp r s r( r zWposDaemon._remove_socketx s a KK,.E F F F|' ""$$$ I- . . . KK+-D E E E E E! a a a NN>@WY\]^Y_Y_ ` ` ` ` ` ` ` ` ` as A9A= =C.CCFr gracefulc ~ t | j }|rG t d| t j |t j n3# t $ r&}t d|| Y d}~nd}~ww xY wd}||k ra t j |d n+# t $ r t d| Y nw xY w||z
}t j
| ||k at d| t j |t j n3# t $ r&}t d|| Y d}~nd}~ww xY w|r.t d t t t | j t d dS ) z0
Stops a working daemon process
zKilling process with PID %sz4Process with pid %s is not possible to be killed: %sNr z#Process with pid %s is finally deadz:Process with pid %s did not exit in timeout, sigkilling itz7Graceful shutdown, killing all existing redis processesz&Cloudlinux AccelerateWP daemon stopped)r r ry rz r% killsignalSIGTERMr r} r SIGKILLr r )rp r timeoutintervalpidr r s r( stopzWposDaemon.stop s d 011 `
\ 93???V^,,,,
\
\
\ RTWYZ[[[[[[[[
\ Ag++GCOOOO KK EsKKKE X
8$$$ g++ XZ]^^^`GC 0000 ` ` `KK VX[]^________` + KKQ R R R "6 * * **+++ <=====sA :A
B A??BB& &%C
C D, ,
E 6 EE c H dt j t dS )zy
Get litespeed webserver status: running or not.
:return: Dict to send to clwpos-user via socket
rw rO timestampstatus)r} r r@ r* r( _get_litespeed_statusz WposDaemon._get_litespeed_status s! $$)++I]I_I_```r* c H dt j t dS )zu
Get nginx webserver status: running or not.
:return: Dict to send to clwpos-user via socket
rw r )r} r r@ r* r( _get_nginx_statusz WposDaemon._get_nginx_status s! $$)++IYI[I[\\\r* c L ddl m} dt j | dS )z|
Get apache2nginx webserver status: running or not.
:return: Dict to send to clwpos-user via socket
r is_apache2nginx_runningrw r )clcommon.utilsr r} r s r( _get_apache2nginx_statusz#WposDaemon._get_apache2nginx_status s6 ;:::::#$)++I`I`IbIbcccr* client_socket_objc 0 t j | } t | }n=# t $ r0 t j |dd|it j d Y dS w xY w t j | }nE# t j t j t j t j t t f$ r d}Y nw xY w| t j |dd|id dS d |vr+t j |d
t j d dS |d k rd|vr+t j |d
t j d dS |d } t | }n=# t $ r0 t j |dd|it j d Y dS w xY w|d | j vr+t j |dt j d dS d|||dfS |d | j vr+t j |dt j d dS d|||dfS )a,
Validate socket connection. Check:
- root connections
- connection user presense
- command validity
:return: tuple(is_connection_valid, uid, username, user_request_dict, is_root_query)
is_connection_valid:
True - Socket connection valid, should be processed. uid, username and user_request_dict filled
False - invalid connection, should be skipped. uid == -1, username and user_request_dict = None
is_root_query - True - root query, do not check reload interval
zNo user uid=%(uid)duid)rO contextr )FNNFNz>User %(username)s sent invalid query to CL AccelerateWP daemonr rO r commandz0Daemon received malformed query (command absent)rO r r z)Root request to daemon should contain uidz Daemon received invalid commandTF) socket_utilsget_uid_from_socketr r (send_dict_to_socket_connection_and_closer} 'read_unpack_response_from_socket_daemonr- errorr rJ JSONDecodeErrorstructAttributeErrorUnicodeDecodeError _DAEMON_VALID_COMMANDS_FOR_ROOT_DAEMON_VALID_COMMANDS)rp r _uidr user_requests r( _validate_socket_connectionz&WposDaemon._validate_socket_connection s /0ABB 0/55HH 0 0 0 ABSMbOTVZmPTPYP[P[C] C]
^
^
^ 0// 0 +7+_`q+r+rLL fnd.BFLR`btu LLL ABSNfOY[cNdCf Cf
g
g
g 0/ L ( ( ABSN_PTPYP[P[C] C]
^
^
^ 0/ 199L(( EFWR_TXT]T_T_Ga Gab b b 43 &D
43D99
4
4
4 EFWQfSXZ^R_TXT]T_T_Ga Gab b b 433
4 I&d.RRR EFWQrTXT]T_T_Ga Gab b b 43x t; ; "$*E E E ABSMnPTPYP[P[C] C]
^
^
^ 0/T8\588s3 & 6A A $A9 9?B;:B; E 6FFr r c * | j |d }| t j |dd|id dS |j 5 t | \ }}}|d dk r||d< t j || ddd dS # 1 swxY w Y dS )z
Get redis status for user (socket query)
:param client_socket_obj: Client socket connection
:param username: User name
:param uid: User uid
Nz"User %(username)s has no redis yetr r rO rw r )re rx r r r" r )rp r r r r r r8 r s r( _socket_user_get_redis_statusz(WposDaemon._socket_user_get_redis_status s( $ : > >sD I I ABSMqOY[cNdCf Cf
g
g
g
g
g
f
f1DS1I1I.; x(I55,:K) EFWYdeee
f
f
f
f
f
f
f
f
f
f
f
f
f
f
f
f
f
fs :BB B r# c L |dk p t j |z
| j k S )zv
Checks is reload available by checking time
:return: True - available, False - not available
r )r} _MIN_ALLOWED_RELOAD_PERIOD)rp r# s r( _is_reload_availablez WposDaemon._is_reload_available* s(
1$h 6F(FIh(hhr*
is_root_queryskip_last_time_checkc | j | }t dt | t | ||j a| |d| }t j |d< t j || t
d|| dS |j } |sM|sK| | s6t j d|| j
dd }t j || dS |j 5 | |d }t j |d< t j || t d
|| ddd dS # 1 swxY w Y dS ) a>
Reload redis for user (socket query)
:param client_socket_obj: Client socket connection
:param username: User name
:param uid: User uid
:param is_root_query: True - reload redis by root, do not check reload interval
False - user reload, check reload interval
z.[Redis reload request] Current user=%s data=%sNT)ru r zX[Redis user data not found] Cloudlinux AccelerateWP daemon reloaded for user %s (uid=%d)zSCan't reload redis for user %(user)s. Last reload was less than %(sec)s seconds ago)usersec)r rO r zT[Redis user data found] Cloudlinux AccelerateWP daemon reloaded for user %s (uid=%d))re rx ry rz r~ r! r r} r r r r# r r r" )
rp r r r r ru r r r r# s
r( _socket_user_redis_reloadz$WposDaemon._socket_user_redis_reload1 s
$ : > >s C C Dc(mmUXYbUcUcddd 3 ; 55c4l5[[K'+y{{K $ ABSU` a a a LL ^_gil
n
n
n F$5# M $B[B[\lBmBm )- &3/7@_&`&`b bK
ABSU` a a a F
^ n n 55c4@@K'+y{{K $ ABSU` a a a KK ^_gil
n
n
n n n n n n n n n n n n n n n n n n ns A FF
FNaccountc dt dt dt fd}|p
t }|r#| dt | fd| D }g }| D ]~\ }} | ||d |d ||d |d
t | d d W# t $ r |r| d
| Y {w xY w|S )N handler_name
version_idr+ c 2 | dk rdS d|v rdS | rd| v rdS | S )Nfpmzphp-fpmz
x-httpd-lsphplsapilsphpr@ )r r s r( _castz1WposDaemon._php_get_vhost_versions.._cast` s? u$$ y J.. w
'\"9"9 w r* z[PHP vhost info]: %sc 4 i | ]\ }}|d k ||S )r r@ )rA rB rC r s r(
z6WposDaemon._php_get_vhost_versions..p s8 < < <*#u #J /7 : : : : :r* r display_version handler_typephp_version_idr )vhostr versionhandler documentrootz)Error on getting php version for %s, skip)r~ r
rz rG r r r r )r ry php_vhost_datar vhosts_datarO rB rC s ` r( _php_get_vhost_versionsz"WposDaemon._php_get_vhost_versions] sr %>(<(>(> B KK.K0@0@ A A A < < < < 8I8I8K8K < < OQWXXXXXr* c X | }t j || dS )z+
Get nginx status for user
N)r r r r s r( _socket_user_nginx_statusz$WposDaemon._socket_user_nginx_status s0
--//=>OQWXXXXXr* c X | }t j || dS )z2
Get apache2nginx status for user
N)r r r r s r( _socket_user_apache2nginx_statusz+WposDaemon._socket_user_apache2nginx_status s0
4466=>OQWXXXXXr* c | |t }d|d}n)# t $ r }dt | d}Y d }~nd }~ww xY wt j || d S )N)ry rw rO rF z)Daemon cannot get vhosts data: %(reason)sr )r ry r r~ r r )rp r r
vhost_dataresponser s r( #_socket_user_php_get_vhost_versionsz.WposDaemon._socket_user_php_get_vhost_versions s 55gf5MMJ $" HH
E q66 HHHHHH =>OQYZZZZZs $
A
AA
c R dt d}t j || d S )Nrw r )r r r )rp r r s r( '_socket_user_php_get_installed_versionsz2WposDaemon._socket_user_php_get_installed_versions s7 .00
=>OQYZZZZZr* c ddl m} | }d| |t |d d d | d}t j || d S )Nr )get_server_wide_optionsrw )dns)keyls)r domainfeature)rO upgrade_url) clwpos.utilsr get_upgrade_url_for_userr r r )rp r r r# r server_optionsr s r( _get_upgrade_linkz WposDaemon._get_upgrade_link s 9888880022 )BB! hh777:1= C
=>OQYZZZZZr* c X ddl m} d || d}t j || dS )zI
Get unique identifier which we use as user's auth token
r ) get_or_create_unique_identifierrw )rO unique_idN)clwpos.billingr* r r )rp r r r* r s r( _get_unique_idzWposDaemon._get_unique_id sQ CBBBBB 88BB
=>OQYZZZZZr* c b ddl m} | \ }}d||d}t j || d S )Nr ) get_suites_status_from_licenserw )rO accelerate_wp_premiumaccelerate_wp_cdn)r% r/ r r )rp r r/ awp_premium_statusawp_cdn_statusr s r( _get_supported_suites_by_licensez+WposDaemon._get_supported_suites_by_license sZ ??????-K-K-M-M*N %7!/
=>OQYZZZZZr* c ` ddl m} ||d }d|d}t j || d S )Nr )is_user_owned_by_resellerT)
force_as_rootrw )rO is_owned_by_reseller)r% r6 r r )rp r r r6 r8 r s r( _get_is_user_owned_by_resellerz)WposDaemon._get_is_user_owned_by_reseller sZ :::::: 8 8QU V V V $8
=>OQYZZZZZr* c Z ddl m} | }d|d}t j || d S )Nr )is_wp2_environmentrw )rO is_wp2)clcommon.cpapir; r r )rp r r; r< r s r( _get_is_wp2_environmentz"WposDaemon._get_is_wp2_environment sQ 555555##%%
=>OQYZZZZZr* c F | | \ }}}}}|sdS t dt | |d | j k r| ||| dS |d | j k rL| dd }| dd dk }| |||||| dS |d | j k r|
| dS |d | j k r| | dS |d | j
k r| | dS |d | j k r| || dS |d | j k r| | dS |d | j k r-| ||| dd dS |d | j k r| || dS |d | j k r"| j || j dS |d | j k r | j ||| dS |d | j k r2| j ||| dd dS |d | j k r| | dS |d | j! k r| " || dS |d | j# k r| $ | dS dS # tJ $ rv t & d
d tO j( |d
tS j) d Y dS # tT $ r t + d Y Y dS w xY ww xY w)z
Process client's socket connection (Works in thread)
:param client_socket_obj: Client socket connection
NzIncome user request=%sr ru rr skip_last_reload_timeyesr# object_cachez"Socket connection processing errorTr zInternal daemon errorr z!Broken pipe during error response),r ry rz r~ _DAEMON_GET_REDIS_STATUS_COMMANDr _DAEMON_RELOAD_COMMANDrx r $_DAEMON_GET_LITESPEED_STATUS_COMMANDr _DAEMON_GET_NGINX_STATUS_COMMANDr '_DAEMON_GET_APACHE2NGINX_STATUS_COMMANDr %DAEMON_PHP_GET_VHOST_VERSIONS_COMMANDr )DAEMON_PHP_GET_INSTALLED_VERSIONS_COMMANDr DAEMON_GET_UPGRADE_LINK_COMMANDr( DAEMON_GET_UNIQUE_ID_COMMANDr- DAEMON_SUITE_ALLOWED_CALLBACKro rX rg DAEMON_REGISTER_UPGRADE_ATTEMPTadd_pending_upgrade_task!DAEMON_GET_UPGRADE_ATTEMPT_STATUSget_upgrade_task_status&DAEMON_GET_SUPPORTED_SUITES_BY_LICENSEr4 DAEMON_IS_USER_OWNED_BY_RESELLERr9 DAEMON_IS_WP2_ENVIRONMENTr> r r r r r} BrokenPipeErrorr ) rp r is_connection_validr r r r ru r s r( _handle_client_socket_connectionz+WposDaemon._handle_client_socket_connection s
8 D001BCC
L h m&
KK0#l2C2C D D D I&$*OOO223DhPSTTTTT i(D,GGG + / / E E '3'7'78OQU'V'VZ_'_$../@/7/2/'R'RT T T T T i(D,MMM##$5x@@@@@ i(D,NNN#::;Ldl[[[[[ i(D,PPP#<<=NP\^abbbbb i(D,RRR#;;????? KJ D D D AD Q Q Q
D EFWd{ KO KT KV KV ZW ZW X X X X X X"
D
D
D BCCCCCCC
D Ds L AL 3AL &L 8&L &L 'L 1&L
Process socket connections (works in thread)
z4Cloudlinux AccelerateWP daemon socket thread startedr r NFr4 )r argsz Failed to start handler threadzSocket connection errorTr z4Cloudlinux AccelerateWP daemon socket thread stopped)ry rz rj selectrg acceptr r r r rn rm rx _MAX_CONNECTIONS_PER_UIDrl r7 _release_uid_connectionr
(_handle_client_socket_connection_trackedr r r9 r- r )rp readabler8 _sock_objectr r ts r( r z&WposDaemon._process_socket_connections( s JKKK& O #]DL>2r1 E ENHa (
O
O O+7+>+>+@+@(%q! * >?P Q Q$ ! ! !)//111 ! 2 g g 6::3BBdFccc - 3 3 5 5 5 $g g g g g g g <@;V;Z;Z[^`a;b;bef;f3C8 g g g g g g g g g g g g g g g
5==u=MM ! 44S999)//111 2 "$*W):C(@ B B B $ 2 2 2 (()IJJJ 2::<<< 44S999)//11111 2
| O O O$$%>$NNNNNO9 & O< JKKKKKs
H"A76H7 BHB
H":D H(&D HD H!D "AH,,FHA&H?HHH+H65H6c | j 5 | j |d dz
}|dk r | j |d n
|| j |< ddd dS # 1 swxY w Y dS )zYDecrement the per-UID active connection counter and remove the entry if it drops to zero.r r N)rn rm rx pop)rp r counts r( r\ z"WposDaemon._release_uid_connectionM s
& 9 9/33C;;a?Ezz+//T::::38+C0 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9s A A A$'A$c | | | j | | dS # | j | | w xY w)zn
Wrapper around _handle_client_socket_connection that tracks per-UID active connection counts
N)rV rl r9 r\ )rp r r s r( r] z3WposDaemon._handle_client_socket_connection_trackedV s} . 1 12C D D D & . . 0 0 0 ( ( - - - - -
& . . 0 0 0 ( ( - - - -s A 0A7)rr )Fr^ r )rr F)NNN)F__name__
__module__ __qualname____doc__r rD rC rE rF rG rH rI rJ rK rL rM rO rQ rR rS r r r _REDIS_SOCKET_WAIT_TIMEOUTrk r[ rd intboolr~ r r r r r r r rI r r r staticmethoddictr r r r- r r r r r r r r r r r r r r( r- r4 r9 r> rV r r\ r]
__classcell__)rq s @r( rR rR ` s 6 %'9$+A('9$.G+,D)0L-&8##2 $<!&?#(C%-U*'D$ ; (,(/-1'$').(! " '$)%.(! '# "$ !# "$ ; ; ; ; ;&2% 2%s 2%t 2%cf 2%rv 2% 2% 2% 2%h# # # # # #J9 9 9$@ @ @*` ` `.$ $ $ A A AD a a a$> $>T $> $> $> $>R a4 a a a \a ]t ] ] ] \] dd d d d \dK9V] K9uUY[^`hil`mU]^bUceiVj Pk K9 K9 K9 K9Zfv} fX[ fbe f f f f,iS iT i i i i 7;?D *n *n6= *n,/*n'**n 26*n 14 *n
9= *n *n *n *nX # # #Z^ # # # \#JYv} Y Y Y YY6= Y Y Y YY&- Y Y Y Y
[V]
[]`
[
[
[
[ [ [ [ [ [[6= [ [ [ [" [
[ [ [ [[&- [ [ [ [[
[ [ [ [[ [ [ [ [=D&- =DTX =D =D =D =D~#L #L #LJ93 94 9 9 9 9.&- .^a .fj . . . . . . . .r* rR )N)?loggingr% r rH r} rJ r- rY r r typingr r r
contextlibr collectionsr threadingr r r
clwposr r8 r= r r
r r r r r r r r r r clwpos.daemon_redis_libr r r r clwpos.socket_utilsr clwpos.daemon_baser clwpos.constantsr clwpos.cl_wpos_exceptionsr "clwpos.daemon_subscription_handlerr r getLoggerre ry r) r2 r: r~ rP rR r@ r* r( r| s
( ( ( ( ( ( ( ( ( ( % % % % % % " " " " " " 4 4 4 4 4 4 4 4 4 4 + * * * * * - - - - - - 4 4 4 4 4 4 9 9 9 9 9 9 I I I I I I J{$M$M$M N N 8 $ $
D 6 6c 6Xd38n-E 6 6 6 6~ . ~ . ~ . ~ . ~ . ~ . ~ . ~ . ~ . ~ .r*