PATH:
opt
/
cloudlinux
/
venv
/
lib
/
python3.11
/
site-packages
/
xray
/
internal
/
__pycache__
/
Editing: fpm_utils.cpython-311.pyc
� �*fi� � � � d dl mZ d dlmZ d dlmZ ddlmZm Z ddl m Z ddl m Z mZ e G d� d � � � � Zd S ) � )� dataclass)�Optional)�gettext� )�fpm_stat_storage�fpm_reload_timeout)� XRayError)� dbm_storage� timestampc �d � e Zd ZU dZeed< edee fd�� � Z d� Z de fd�Z de fd�ZdS ) �FPMReloadControllerzA Class to control the frequency of FPM service reloading � fpm_service�returnc �r � t t � � 5 } t || j � � � � � cddd� � S # t $ r Y ddd� � dS w xY w# 1 swxY w Y dS # t $ r3}t t d� � t |� � z d�� � �d}~ww xY w)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_reload s8 � � � � -�.�.� �2B� � � /��0@� A� H� H� J� J�K�K� � � � � � � � �� � � � � � � � � � � � � � ���� � � � ���� � � � � � �� � � � ���H�I�I�C�PQ�F�F�R� � � � � ����� ���s] �A9 �A,�+A� A9 � A)�A,� A9 �(A)�)A,�,A0�0A9 �3A0�4A9 �9 B6�.B1�1B6c �( � t t � � 5 }t t � � � � || j < ddd� � dS # 1 swxY w Y dS # t $ r3}t t d� � t |� � z d�� � �d}~ww xY w)zD Save the timestamp of latest reload of FPM service NzQFailed to save the timestamp of latest FPM reload %s, but main operation executedr r )r r r r r r r r r s 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 � � | j z dz S # t t f$ r Y dS w xY w)zM Get the time delta between current time and saved timestamp �< g N@)r r � TypeErrorr �r s r �deltazFPMReloadController.delta5 sI � � � �K�K�$�"4�4��:� :���9�%� � � � �4�4� ���s � �0�0c �< � | � � � t k S )z7 Check if FPM reload should be blocked )r& r r% s r �restrictz FPMReloadController.restrictB s � � �z�z�|�|� 1�1�1� N)�__name__� __module__� __qualname__�__doc__r �__annotations__�propertyr r r r! �floatr& �boolr( � r) r r r s� � � � � � � �� � ���� � �x��}� � � � �X� � � � � �u� � � � �2�$� 2� 2� 2� 2� 2� 2r) r N)� dataclassesr �typingr �xrayr r � constantsr r � exceptionsr �utilsr r r r2 r) r �<module>r9 s� �� "� !� !� !� !� !� � � � � � � � � � � � � ;� ;� ;� ;� ;� ;� ;� ;� !� !� !� !� !� !� )� )� )� )� )� )� )� )� �42� 42� 42� 42� 42� 42� 42� ��42� 42� 42r)
SAVE
CANCEL