ї WХдjeЦСЄ≈ddlZddlZddlmZddlmZddlmZddl m Z mZddlm Z ddlmZmZmZejd і╚ZeGd └dі╚і╚ZdS)ИN)з dataclass)зOptional)зgettextИ)зfpm_stat_storageзfpm_reload_timeout)з XRayError)зdbm_storageзfilelockз timestampз fpm_utilscСp≈eZdZUdZeed<edeefd└і╚Z d└Z defd└Zde fd└Zde fd└Zd S) зFPMReloadControllerzA Class to control the frequency of FPM service reloading зfpm_serviceзreturncСr≈ ttі╚5} t||j═і╚і╚cdddі╚S#t $rYdddі╚dSwxYw#1swxYwYdS#t$r3}ttdі╚t|і╚zd╛і╚┌d}~wwxYw)zC Get the timestamp of latest reload of FPM service Nz4Failed to get the timestamp of latest FPM reload: %sзwarning╘зflag) r rзintrзdecodeзKeyErrorзRuntimeErrorr з_зstr╘зselfз_fpm_reload_statзes ЗN/opt/cloudlinux/venv/lib64/python3.11/site-packages/xray/internal/fpm_utils.pyз latest_reloadz!FPMReloadController.latest_reloads7─П pщу-я.т.П п2BП щп/╟т0@тAвHрHяJтJяKтKП П П П Я Т П П ЬУ П П П ьП П П Я Т П П П П ЬЬЬП П П П ЬЬЬП П П П П П ЬУ П pП pП pщ²AпTяUтUуX[п\]яX^тX^я^пenпoяoтoпoЬЬЬЬП pЬЬЬs]┌A9√A,≤+AаA9а A)аA,аA9а(A)а)A,а,A0а0A9а3A0а4A9а9 B6б.B1б1B6cС(≈ ttі╚5}ttі╚і╚||j<dddі╚dS#1swxYwYdS#t $r3}t tdі╚t|і╚zd╛і╚┌d}~wwxYw)zD Save the timestamp of latest reload of FPM service NzQFailed to save the timestamp of latest FPM reload %s, but main operation executedrr)r rrrrrr rrs r зsave_latest_reloadz&FPMReloadController.save_latest_reload+sЫ─П Еу-я.т.П Fп2Bщ58Ґ╧╪я5Eт5Eп ═т!1я2П FП FП FЯ FТ FП FП FП FП FП FП FП FЬЬЬП FП FП FП FП FП FЬЕП П П щщпeяfтfуilпmnяioтioяoьПЯТП ЬЬЬЬП ЬЬЬs9┌A√$A╨AаAаAаAаAа Bа.BбBcСf≈ tі╚|jz dzS#ttf$rYdSwxYw)zM Get the time delta between current time and saved timestamp И<gN@)rr!з TypeErrorr ╘rs r зdeltazFPMReloadController.delta9sI─П У▒K■K═$т"4я4╦я:п:Ьщ²9п%П П П П░4░4П ЬЬЬs┌⌡0╞0cС<≈|═і╚tkS)z7 Check if FPM reload should be blocked )r(rr's r зrestrictzFPMReloadController.restrictFs─П▐z┼z┴|▄|у1р1п1СcС≈t⌡d|j⌡d²} tj|tjtjztjzdі╚}n4#t$r'}t═ d||і╚Yd}~dSd}~wwxYw t|і╚5|═і╚r" dddі╚tj|і╚dS|═ і╚ dddі╚tj|і╚dS#1swxYwYnM#t$r@}t═ d|j|і╚Yd}~tj|і╚dSd}~wwxYw tj|і╚dS#tj|і╚wxYw) aЬ Atomically decide whether THIS caller may perform the throttled reload and, if so, reserve the slot before returning. ``restrict`` (the check) and ``save_latest_reload`` (the reserve) must run as a single critical section shared across processes. Otherwise several concurrent user-mode user-agent processes can each observe an expired window, all pass the check, and each run the service reload -- preserving the server-wide DoS this throttle is meant to close (a tenant who owns a mod_php DirectAdmin domain firing N parallel start/stop requests triggers N global `service httpd restart`s). A cross-process exclusive flock makes check-and-reserve atomic: at most one caller per window records the timestamp and returns True; the losers re-read the just-saved timestamp under the same lock and return False. Reserve-before-act (the timestamp is saved BEFORE the reload runs, not after) is deliberate: the reservation must be visible to concurrent callers immediately, and a reload that later fails should still consume the window (the throttle errs toward FEWER restarts). Root/operator callers do not use this method -- they are never throttled. Returns True if the slot was reserved (caller must proceed with the reload); False if throttled (caller must skip). Any lock/storage failure fails safe (returns False) rather than risk an unthrottled restart. З.z.locki─z!Failed to open reload lock %s: %sNFTz(Failed to reserve reload slot for %s: %s)rrзosзopenзO_CREATзO_RDWRз O_CLOEXECзOSErrorзloggerrrr*зcloser#r )rз lock_pathзlock_fdrs r зreserve_reload_slotz'FPMReloadController.reserve_reload_slotLsЫ─У4%5п$4п$4╟dт6Fп6Fп6FпG┬ П щ■g≤iґ╛╣bЄiя)?е"д,я)NпPUяVтV┬G┬GЬщП П П щ▐N┼Nп>ю х1яMтMпMь░5░5░5░5░5ЬЬЬЬП ЬЬЬП щ≤'я"т"П П ь≈=▓=▒?■?П!ь П П П Я Т П У ▄H░WятпппПв'р'я)т)п)ьП П П Я Т П У ▄H░WятпппП П П П ЬЬЬП П П П П ЬУ П П П Е▐N┼NпEюtтGWпYZя[т[п[ь░5░5░5Е▄H░WятпппЬЬЬЬП ЬЬЬП У ▄H░WятпппЬ█B▄H░WятппЬЬЬsw■:Aа BаA;а;BбDбDб)Dц DцDдDдDдDдDдE0д Eд!Eд7E0еEеE0е0FN)з__name__з __module__з__qualname__з__doc__rз__annotations__зpropertyrrr!r#зfloatr(зboolr*r8╘r+r rrs╪──────ПППппяЮ Пp≤x╗°}ПpПpПpЯ└XПpПППП░uППППП2≤$П2П2П2П2П+═TП+П+П+П+П+П+r+r)зloggingr.зdataclassesrзtypingrзxrayrrз constantsrrз exceptionsr зutilsr rrз getLoggerr4rrAr+r ЗrJsЯПП───ь ─ ─ ─ ь!п!п!п!п!п!ьпппппЮпппппь;п;п;п;п;п;п;п;ь!п!п!п!п!п!ь3п3п3п3п3п3п3п3п3п3Ю ┬т ≤;я 'т '─ППaПaПaПaПaЯaТaЯ└ПaПaПar+