/opt/cloudlinux/venv/lib/python3.11/site-packages/clwpos/__pycache__/
/opt/cloudlinux/venv/lib/python3.11/site-packages/clwpos/__pycache__
NameSizeModeActions
billing.cpython-311.opt-1.pyc93200644editdlrm
billing.cpython-311.pyc93200644editdlrm
cl_wpos_exceptions.cpython-311.opt-1.pyc77200644editdlrm
cl_wpos_exceptions.cpython-311.pyc77200644editdlrm
constants.cpython-311.opt-1.pyc64540644editdlrm
constants.cpython-311.pyc65160644editdlrm
create_user_uid_dirs.cpython-311.opt-1.pyc12310644editdlrm
create_user_uid_dirs.cpython-311.pyc12310644editdlrm
cron.cpython-311.opt-1.pyc30780644editdlrm
cron.cpython-311.pyc30780644editdlrm
daemon.cpython-311.opt-1.pyc467460644editdlrm
daemon.cpython-311.pyc467460644editdlrm
daemon_base.cpython-311.opt-1.pyc42180644editdlrm
daemon_base.cpython-311.pyc42180644editdlrm
daemon_config.cpython-311.opt-1.pyc14400644editdlrm
daemon_config.cpython-311.pyc14400644editdlrm
daemon_redis_lib.cpython-311.opt-1.pyc207820644editdlrm
daemon_redis_lib.cpython-311.pyc207820644editdlrm
daemon_subscription_handler.cpython-311.opt-1.pyc296670644editdlrm
daemon_subscription_handler.cpython-311.pyc296670644editdlrm
data_collector_utils.cpython-311.opt-1.pyc133400644editdlrm
data_collector_utils.cpython-311.pyc133400644editdlrm
logsetup.cpython-311.opt-1.pyc69940644editdlrm
logsetup.cpython-311.pyc69940644editdlrm
papi.cpython-311.opt-1.pyc160660644editdlrm
papi.cpython-311.pyc160660644editdlrm
parse.cpython-311.opt-1.pyc41240644editdlrm
parse.cpython-311.pyc41240644editdlrm
redis_configuration_pid_file_cleaner.cpython-311.opt-1.pyc13500644editdlrm
redis_configuration_pid_file_cleaner.cpython-311.pyc13500644editdlrm
report_generator.cpython-311.opt-1.pyc329570644editdlrm
report_generator.cpython-311.pyc329570644editdlrm
scoped_cache.cpython-311.opt-1.pyc22210644editdlrm
scoped_cache.cpython-311.pyc22210644editdlrm
socket_utils.cpython-311.opt-1.pyc72000644editdlrm
socket_utils.cpython-311.pyc72000644editdlrm
stats.cpython-311.opt-1.pyc145360644editdlrm
stats.cpython-311.pyc145360644editdlrm
utils.cpython-311.opt-1.pyc1110890644editdlrm
utils.cpython-311.pyc1110890644editdlrm
whmcs_utils.cpython-311.opt-1.pyc170700644editdlrm
whmcs_utils.cpython-311.pyc170700644editdlrm
wpos_admin.cpython-311.opt-1.pyc890820644editdlrm
wpos_admin.cpython-311.pyc890820644editdlrm
wpos_hooks.cpython-311.opt-1.pyc115290644editdlrm
wpos_hooks.cpython-311.pyc115290644editdlrm
wpos_req_scanner.cpython-311.opt-1.pyc66440644editdlrm
wpos_req_scanner.cpython-311.pyc66440644editdlrm
wp_config.cpython-311.opt-1.pyc42070644editdlrm
wp_config.cpython-311.pyc42070644editdlrm
wp_utils.cpython-311.opt-1.pyc233820644editdlrm
wp_utils.cpython-311.pyc233820644editdlrm
__init__.cpython-311.opt-1.pyc6570644editdlrm
__init__.cpython-311.pyc6570644editdlrm
Edit: /opt/cloudlinux/venv/lib/python3.11/site-packages/clwpos/__pycache__/daemon.cpython-311.pyc (46746B)
P#[ddlZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl m Z m Z m Z ddlmZddlmZddlmZmZmZddlmZddlmZmZmZmZmZmZddl m!Z!m"Z"m#Z#m$Z$m%Z%dd l&m'Z'm(Z(m)Z)m*Z*ddl+m,Z,dd l-m.Z.dd l/m0Z0dd l1m2Z2dd l3m4Z4edgdZ5ej6e7Z8edZ9dejfdZ:edefdZ;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_redisesreload_redis_for_user_thread parse_redises)WposDaemonBase)WPOS_DAEMON_SOCKET_FILE)WposDaemonLockError)PendingSubscriptionWatcher User_data redis_pidlocklast_reload_timec#Ktjd} dVtj|dS#tj|wxYw)z, Context manager for dropping umask rN)osumask)prevs py/clwpos/daemon.py_umask_0r)3sH 8A;;D  s 2Areturnct5tjtj}|t||cdddS#1swxYwYdS)zr Create world-writable socket in given sock_location or reuse existing one :return: socket object N)r)socketAF_UNIXbindrlisten)sockobjs r(_create_socketr1Cs -// ,--- sAA**A.1A.r"c#K|dsttd |V|dS#|wxYw)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_lockr9Psj <<< ' '`!!,]*^*^____   s AA'functioninput_parametersc|rd|Dng}tjdd|g|d}tj|jdS)Nc"g|] \}}|d| S)=).0keyvalues r( zwhmapi1..^s*\\\ZS%3 0 0 0 0\\\z/usr/sbin/whmapi1z --output=jsonT)capture_outputdata)items subprocessrunjsonloadsstdoutdecode)r:r;input_parameters_as_listresults r(whmapi1rP]s}`px\\CSCYCYC[C[\\\\vx ^ oxS:RSdhF :fm**,, - -f 55rDcpeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZeeeee e e e e eeeeegZee e eeeeegZdZdZdZdZdZdZfdZdIdededede fdZ!dedefdZ"dZ#d Z$d!Z%d"Z&d#Z'de(j(fd$Z)d%Z*d&Z+dJd)efd*Z,e-de.fd+Z/e-de.fd,Z0e-de.fd-Z1d.e(j(de2eee3ee3e.effd/Z4d.e(j(d0ed1efd2Z5d3edefd4Z6 dKd.e(j(d0ed1ed5eded6ef d7Z7e-dLd9ede8fd:Z9d.e(j(fd;Z:d.e(j(fd<Z;d.e(j(fd=ZZ=d.e(j(fd?Z>d.e(j(fd@Z?d.e(j(fdAZ@d.e(j(fdBZAd.e(j(fdCZBd.e(j(fdDZCd.e(j(dd8fdEZDdFZEd1edd8fdGZFd.e(j(d1edd8fdHZGxZHS)M 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_environment2c(ti|_g|_d|_d|_d|_d|_t|j |_ i|_ t|_ t|_dS)NrT)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(rezWposDaemon.__init__s  =?#)+&04 04#' %5d6V%W%W"68#$(FF!8::rDnouser_uidis_store_last_reload_time force_reloadr*cB |j|}|d}n|j}t|}td||t |||\}}|ddkrCtd|t|td|j|<|S|rv|j j r|sd} ntj } t|t| } | |j|<td|t| n,||jvr#td ||j|=nB#t$r5} t| dt| icYd} ~ Sd} ~ wwxYwddiS) 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: %srOsuccessz^Redis reloading failed for user: %s, adding to monitoring list to try again in several minutesrr z)Saving user=%s to monitoring with data=%sz Removing user=%s from monitoring)rfgetr!rloggerinforrr _configenable_reload_rate_limittimestr Exception exception) rqrtrurvuserdata old_redis_pidusername new_redis_pid result_dictr#user_redis_dataes r(_reload_redis_for_userz!WposDaemon._reload_redis_for_users' &266x@@H $ ( 2 /99H KKH(T` a a a)EhP]_k)l)l &M;8$ 11 t 9B+$&&1999+H5#" >|<3D]3'($$'+y{{$"+m$&&cs"t"t"t8G+H5 GSVWfSgSghhhht:::KK BHMMM3H= & & &   Q   c!ff% % % % % % % &)$$s%B3E6B$E F%*FFFc|j|}d} t|j5t|\}}}|s ddddS|r ddddSt |}t d|t||j|j\}}||ddkr ddddSt||jd |j|<dddn #1swxYwYne#t$r,} t d | j ||Yd} ~ n4d} ~ wt$r$} t | Yd} ~ nd} ~ wwxYwdS) 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, restartingrOrxrr zSLock error: %s. User %s (uid=%d) is working with his redis, skip monitoring actions)rfr9r"rrrzr{rr!rrdebugr5rr) rqrt user_dataris_redis_aliveis_user_presentr7r!rrs r(_user_monitoringzWposDaemon._user_monitoringsM $:8D  "9>22  5H5R5R2&         "!         4H== MxXXX)Ed9(CM**& ;$X)>))K)K         9B'inq999+H5!               &#    LLe                Q         usjC9C- C9 C- C9AC-5 C9C-! C9-C11C94C15C99 E"D** E7EEcg}tdt|jt |jD].}||}|r||/|D];}||jvr0tdt||j|=>?? 8 8G--g66I 8'..w777. 9 9G$555 CS\\RRR/8 9 9rDc|jrd|_t}tdt ||D]} t j|j}n#t$rY)wxYw|j |}tdt ||r|j s| |ddSdS)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 rzr{rpwdgetpwnampw_uidKeyErrorrfryr!r)rq all_usersrrmonitored_user_datas r(_reload_all_userszWposDaemon._reload_all_users&s  # @',D $ I KKDc)nn U U U% @ @!l844;GGH'+&A&E&Eg&N&N# PRUViRjRjkkk*@2E2O@//??? @ @ @ @s A$$ A10A1c Jd}t}td||D]F}|j|dt |dt diG|js || |jrdStj d|dz }||j j kr|d}n,#t$rtddYnwxYw|jdSdS)NrzFound existing redises: %sr z,Cloudlinux AccelerateWP daemon general errorTexc_info)rrzr{rfupdaterr _is_terminate _force_reloadrr~sleepr|monitoring_intervalrrr)rqiexisting_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..&DDclt|j|_|jdS)z; Create and start socket processing thread )targetN)r _process_socket_connectionsrjstartrqs r(_create_and_start_socket_threadz*WposDaemon._create_and_start_socket_threadRs5%D,LMMM !!#####rDcdt|j"td|jdS||_td|t|j| | | d|_ |j |t!|jtddS)z+ Main work daemon function NzCPID file %s existing. Cloudlinux AccelerateWP daemon already works?z&Cloudlinux AccelerateWP daemon startedFz)Cloudlinux AccelerateWP daemon terminated)r _PID_FILENAMErzwarning_create_socket_with_retryrhr{_setup_signalsrrSrrrkrjjoin_remove_socketrrs r(rIzWposDaemon.runYs 4- . . : NN`bfbt u u u F5577  <=== t)***  ,,... #(    """ *+++ ?@@@@@rDc td|jdzD]}tjt r| tcS#ttf$r]}t d||jt|||jkrtj|jYd}~d}~wwxYwt d|jt!d)a Create the daemon socket, removing a stale socket file first. Retries because at boot the filesystem holding the socket may still be read-only: the stale file can't be unlinked and bind() fails with EADDRINUSE (CLPRO-3351). If all attempts fail, exits with a non-zero code so that systemd (Restart=on-failure) restarts the service instead of leaving it dead until manual intervention. rzHCan't create AccelerateWP daemon socket (attempt %s of %s). Error is: %sNzkFailed to create AccelerateWP daemon socket after %s attempts, exiting so that systemd restarts the service)range_SOCKET_CREATE_ATTEMPTSr%pathexistsrrr1OSErrorIOErrorrzrrr~r_SOCKET_CREATE_RETRY_PERIOD SystemExit)rqattemptrs r(rz$WposDaemon._create_socket_with_retryrsQ >$7 8 8  KKMMM  $788888W%       sAA*)A*c tdt|j|jt jttdtdS#ttf$r9}t dtt|Yd}~dSd}~wwxYw)z- Remove daemon's socket file zRemoving socket %sNzSocket %s removedz!Can't remove socket %s. Error: %s) rzr{rrhcloser%rrrrr)rqrs r(rzWposDaemon._remove_sockets a KK,.E F F F|' ""$$$ I- . . . KK+-D E E E E E! a a a NN>@WY\]^Y_Y_ ` ` ` ` ` ` ` ` ` asA9A==C.CCFrgracefulc~t|j}|rG td|t j|t jn3#t$r&}td||Yd}~nd}~wwxYwd}||kra t j|dn+#t$rtd|YnwxYw||z }tj |||katd| t j|t j n3#t$r&}td||Yd}~nd}~wwxYw|r.tdttt|jtddS) z0 Stops a working daemon process zKilling process with PID %sz4Process with pid %s is not possible to be killed: %sNrz#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)rrrzr{r%killsignalSIGTERMrr~rSIGKILLrr)rqrtimeoutintervalpidrrs r(stopzWposDaemon.stopsd011  ` \ 93???V^,,,, \ \ \ RTWYZ[[[[[[[[ \Ag++GCOOOOKK EsKKKEX  8$$$g++ XZ]^^^`GC0000```KK VX[]^________`  + KKQ R R R "6 * * **+++ <=====sA:A BA??BB&&%C C D,, E6EEcHdtjtdS)zy Get litespeed webserver status: running or not. :return: Dict to send to clwpos-user via socket rxrO timestampstatus)r~rr?rDr(_get_litespeed_statusz WposDaemon._get_litespeed_statuss! $$)++I]I_I_```rDcHdtjtdS)zu Get nginx webserver status: running or not. :return: Dict to send to clwpos-user via socket rxr)r~rr?rDr(_get_nginx_statuszWposDaemon._get_nginx_statuss! $$)++IYI[I[\\\rDcLddlm}dtj|dS)z| Get apache2nginx webserver status: running or not. :return: Dict to send to clwpos-user via socket ris_apache2nginx_runningrxr)clcommon.utilsrr~rs r(_get_apache2nginx_statusz#WposDaemon._get_apache2nginx_statuss6 ;:::::#$)++I`I`IbIbcccrDclient_socket_objc0tj|} t|}n=#t$r0tj|dd|it jdYdSwxYw tj|}nE#tjtj tj tjttf$rd}YnwxYw|tj|dd|iddSd |vr+tj|d t jd dS|d krd|vr+tj|d t jd dS|d} t|}n=#t$r0tj|dd|it jdYdSwxYw|d |jvr+tj|dt jd dSd|||dfS|d |jvr+tj|dt jd dSd|||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)rOcontextr)FNNFNz>User %(username)s sent invalid query to CL AccelerateWP daemonrrOrcommandz0Daemon received malformed query (command absent)rOrrz)Root request to daemon should contain uidzDaemon received invalid commandTF) socket_utilsget_uid_from_socketrr(send_dict_to_socket_connection_and_closer~'read_unpack_response_from_socket_daemonr,errorrrJJSONDecodeErrorstructAttributeErrorUnicodeDecodeError_DAEMON_VALID_COMMANDS_FOR_ROOT_DAEMON_VALID_COMMANDS)rqr_uidr user_requests r(_validate_socket_connectionz&WposDaemon._validate_socket_connections/0ABB 0/55HH 0 0 0  A!.CQVX\P]lplulwlw#x#x   0//  0  +7+_`q+r+rLL fnd.BFLR`btu   LLL    A!^ *H5   0/ L ( (  A!M\`\e\g\ghh   0/ 199L((E%2]lplulwlw'x'x43&D 43D99 4 4 4E%4%]a]f]h]hii433  4 I&d.RRRE%2Sbfbkbmbm'n'n43xt; ;  "$*E E E  A!.O^b^g^i^i#j#j   0/T8\588s3&6A A $A99?B;:B; E6FFrrc*|j|d}|tj|dd|iddS|j5t |\}}}|ddkr||d<tj||ddddS#1swxYwYdS)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 yetrrrOrxr)rfryrrr"r)rqrrrrrr7rs r(_socket_user_get_redis_statusz(WposDaemon._socket_user_get_redis_status>s $:>>sDII    A!.R`jlt_u#v#v      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#cL|dkptj|z |jkS)zv Checks is reload available by checking time :return: True - available, False - not available r)r~_MIN_ALLOWED_RELOAD_PERIOD)rqr#s r(_is_reload_availablezWposDaemon._is_reload_availableTs(  1$h 6F(FIh(hhrD is_root_queryskip_last_time_checkc |j|}tdt |t |||ja||d|}tj|d<tj ||t d||dS|j } |sM|sK| | s6tjd||j dd }tj ||dS|j5||d}tj|d<tj ||td ||ddddS#1swxYwYdS) 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)rvrzX[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)rrOrzT[Redis user data found] Cloudlinux AccelerateWP daemon reloaded for user %s (uid=%d))rfryrzr{rr!rr~rrrr#rrr") rqrrrrrvrrrr#s r(_socket_user_redis_reloadz$WposDaemon._socket_user_redis_reload[s" $:>>sCC  Dc(mmUXYbUcUcddd   3 ;55c4l5[[K'+y{{K $  ABSU` a a a LLj    F$5# M $B[B[\lBmBm "Y[[o$,T5TUUK  ABSU` a a a F ^  55c4@@K'+y{{K $  ABSU` a a a KKfhpru                      sAFF FNaccountc dtdtdtfd}|p t} fd|D}|r#|dt|g}|D]~\}} |||d|d||d |d t |d d W#t $r|r|d |Y{wxYw|S)N handler_name version_idr*c2|dkrdSd|vrdS|rd|vrdS|S)Nfpmzphp-fpmz x-httpd-lsphplsapilsphpr?)rrs r(_castz1WposDaemon._php_get_vhost_versions.._casts?u$$ y J..w '\"9"9w rDc4i|]\}}|dk||S)rr?)r@rArBrs r( z6WposDaemon._php_get_vhost_versions..s0lll*#uuU_O`dkOkOk3OkOkOkrDz[PHP vhost info]: %srdisplay_version handler_typephp_version_idr)vhostrversionhandler documentrootz)Error on getting php version for %s, skip)rr rGr{rrrr)rrzphp_vhost_datar  vhosts_datarOrArBs` r(_php_get_vhost_versionsz"WposDaemon._php_get_vhost_versionsse    %>(<(>(>  llll 8I8I8K8KlllK  B KK.K0@0@ A A A%++--  JC  !$#(#4#():#;#(5~)>FV@W#X#X(/ Q    W$$%PRUVVV    sAC"DDcX|}tj||dS)z/ Get litespeed status for user N)rrrrqrrOs r(_socket_user_litespeed_statusz(WposDaemon._socket_user_litespeed_statuss0 1133=>OQWXXXXXrDcX|}tj||dS)z+ Get nginx status for user N)rrrrs r(_socket_user_nginx_statusz$WposDaemon._socket_user_nginx_statuss0 --//=>OQWXXXXXrDcX|}tj||dS)z2 Get apache2nginx status for user N)rrrrs r( _socket_user_apache2nginx_statusz+WposDaemon._socket_user_apache2nginx_statuss0 4466=>OQWXXXXXrDc ||t}d|d}n)#t$r}dt|d}Yd}~nd}~wwxYwt j||dS)N)rzrxrOrFz)Daemon cannot get vhosts data: %(reason)sr)rrzrrrr)rqrr vhost_dataresponsers r(#_socket_user_php_get_vhost_versionsz.WposDaemon._socket_user_php_get_vhost_versionss 55gf5MMJ $"HH h h h(S`cde`f`fggHHHHHH h =>OQYZZZZZs$ A AA cRdtd}tj||dS)Nrxr )rrr)rqrr"s r('_socket_user_php_get_installed_versionsz2WposDaemon._socket_user_php_get_installed_versionss7.00   =>OQYZZZZZrDcddlm}|}d||t|ddd|d}t j||dS)Nr)get_server_wide_optionsrx)dns)keyls)rdomainfeature)rO upgrade_url) clwpos.utilsr'get_upgrade_url_for_userrrr)rqrrr+r'server_optionsr"s r(_get_upgrade_linkzWposDaemon._get_upgrade_links 9888880022)BB!&*J*J*J1*Ma*PZaC   =>OQYZZZZZrDcXddlm}d||d}tj||dS)zI Get unique identifier which we use as user's auth token r)get_or_create_unique_identifierrx)rO unique_idN)clwpos.billingr2rr)rqrrr2r"s r(_get_unique_idzWposDaemon._get_unique_idsL CBBBBB$-<[<[\dOQYZZZZZrDcbddlm}|\}}d||d}tj||dS)Nr)get_suites_status_from_licenserx)rOaccelerate_wp_premiumaccelerate_wp_cdn)r-r7rr)rqrr7awp_premium_statusawp_cdn_statusr"s r( _get_supported_suites_by_licensez+WposDaemon._get_supported_suites_by_licensesZ??????-K-K-M-M*N%7!/   =>OQYZZZZZrDc`ddlm}||d}d|d}tj||dS)Nr)is_user_owned_by_resellerT) force_as_rootrx)rOis_owned_by_reseller)r-r>rr)rqrrr>r@r"s r(_get_is_user_owned_by_resellerz)WposDaemon._get_is_user_owned_by_resellersT::::::88QUVVV$-G[\\=>OQYZZZZZrDcZddlm}|}d|d}tj||dS)Nr)is_wp2_environmentrx)rOis_wp2)clcommon.cpapirCrr)rqrrCrDr"s r(_get_is_wp2_environmentz"WposDaemon._get_is_wp2_environmentsJ555555##%%$-@@=>OQYZZZZZrDcR ||\}}}}}|sdStdt||d|jkr||||dS|d|jkrR|dd}|dvrd}|dddk}|||||||dS|d|j kr| |dS|d|j kr| |dS|d|j kr||dS|d|jkr|||dS|d|jkr||dS|d|jkr-||||d d dS|d|jkr|||dS|d|jkr"|j||jdS|d|jkr|j|||dS|d|jkr2|j|||d d dS|d|jkr| |dS|d|j!kr|"||dS|d|j#kr|$|dSdS#tJ$rvt&d d  tOj(|dtSj)dYdS#tT$rt+dYYdSwxYwwxYw)z Process client's socket connection (Works in thread) :param client_socket_obj: Client socket connection NzIncome user request=%srrvrs)yesrsskip_last_reload_timerHr+ object_cachez"Socket connection processing errorTrzInternal daemon errorrz!Broken pipe during error response),rrzr{r _DAEMON_GET_REDIS_STATUS_COMMANDr_DAEMON_RELOAD_COMMANDryr$_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_COMMANDr0DAEMON_GET_UNIQUE_ID_COMMANDr5DAEMON_SUITE_ALLOWED_CALLBACKrprXrhDAEMON_REGISTER_UPGRADE_ATTEMPTadd_pending_upgrade_task!DAEMON_GET_UPGRADE_ATTEMPT_STATUSget_upgrade_task_status&DAEMON_GET_SUPPORTED_SUITES_BY_LICENSEr< DAEMON_IS_USER_OWNED_BY_RESELLERrADAEMON_IS_WP2_ENVIRONMENTrFrrrrr~BrokenPipeErrorr) rqris_connection_validrrrrrvrs r( _handle_client_socket_connectionz+WposDaemon._handle_client_socket_connections < DNRNnNn!OO K h m'  KK0#l2C2C D D DI&$*OOO223DhPSTTTTTi(D,GGG+//EE  }44#'L'3'7'78OQU'V'VZ_'_$..%xm\Sgi(D,UUU223DEEEEEi(D,QQQ../@AAAAAi(D,XXX556GHHHHHi(D,VVV889JHUUUUUi(D,ZZZ<<=NOOOOOi(D,PPP&&'8(LDTDTU^`nDoDopppppi(D,MMM##$5x@@@@@i(D,NNN#::;Ldl[[[[[i(D,PPP#<<=NP\^abbbbbi(D,RRR#;;%sL,<,?????KJ D D D   AD  Q Q Q DE%2IX\XaXcXc'd'd# D D DBCCCCCCC D  DsL&AL&3A!L&&L&>&L&&&L&'L&7&L& Process socket connections (works in thread) z4Cloudlinux AccelerateWP daemon socket thread startedrrNFr3)rargszFailed to start handler threadzSocket connection errorTrz4Cloudlinux AccelerateWP daemon socket thread stopped)rzr{rkselectrhacceptrrrrrornry_MAX_CONNECTIONS_PER_UIDrmr6_release_uid_connectionr (_handle_client_socket_connection_trackedrrr8r,r)rqreadabler7 _sock_objectrrts r(rz&WposDaemon._process_socket_connectionsYs   JKKK& O#]DL>2r1EENHa ( O O O+7+>+>+@+@(%q!*>?PQQ$!!!)//111 !2gg6::3BBdFccc-33555$ggggggg<@;V;Z;Z[^`a;b;bef;f3C8 ggggggggggggggg  5==u=MM!44S999)//111 2"$*W_pru^vwww $222(()IJJJ2::<<<44S999)//11111 2 |OOO$$%>$NNNNNO7& O:  JKKKKKs H"A76H7BHB H":D H(&D HD H!D "AH,,FHA&H?HHH+H65H6c|j5|j|ddz }|dkr|j|dn ||j|<ddddS#1swxYwYdS)zYDecrement the per-UID active connection counter and remove the entry if it drops to zero.rrN)rornrypop)rqrcounts r(rdz"WposDaemon._release_uid_connection}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 9sA A  A$'A$c |||j||dS#|j||wxYw)zn Wrapper around _handle_client_socket_connection that tracks per-UID active connection counts N)r^rmr8rd)rqrrs r(rez3WposDaemon._handle_client_socket_connection_trackeds} .  1 12C D D D  & . . 0 0 0  ( ( - - - - -  & . . 0 0 0  ( ( - - - -s A0A7)rs)Fr^r)rsF)NNN)I__name__ __module__ __qualname____doc__rrLrKrMrNrOrPrQrRrSrTrUrWrYrZr[rrr_REDIS_SOCKET_WAIT_TIMEOUTrlrcrrreintboolrrrrrrrrrIr,rrrr staticmethoddictrrrrrrrrrrrrrrr#r%r0r5r<rArFr^rrdre __classcell__)rrs@r(rRrRfs 6%'9$+A('9$.G+,D)0L-&8##2 $<!&?#(C%-U*'D$ ;(,(/-1'$').(!" '$)%.(! '#"$!#"$  "#;;;;;&2%2%s2%t2%cf2%rv2%2%2%2%h((((((T999"@@@*```.$$$AAA26=@    a a a$>$>T$>$>$>$>Ra4aaa\a]t]]]\]ddddd\dM9!'M9 tS(3-$= >M9M9M9M9^fv}fX[fbeffff,iSiTiiii!%*22!=22 2  2  2#2222h(((Z^(((\(TYv}YYYYY6=YYYYY&-YYYY [V] []` [ [ [ [[[[[[ [6= [ [ [ [[ [[[[ [&- [ [ [ [[ [[[[[[[[[AD&-ADTXADADADADF"L"L"LH93949999.&-.^a.fj........rDrR)N)?loggingr%rrHr~rJr,rarrtypingrrr contextlibr collectionsr threadingrr r clwposr r7rEr r rrrrrrrrrrclwpos.daemon_redis_librrrrclwpos.socket_utilsrclwpos.daemon_baserclwpos.constantsrclwpos.cl_wpos_exceptionsr"clwpos.daemon_subscription_handlerrr getLoggerrmrzr)r1r9rrPrRr?rDr(rs  ((((((((((%%%%%%""""""4444444444tsssssssssssss +*****------444444999999IIIIII J{$M$M$M N N  8 $ $         D    66c6Xd38n-E6666h .h .h .h .h .h .h .h .h .h .rD