File: //opt/alt/python37/lib/python3.7/site-packages/xray/internal/__pycache__/fpm_utils.cpython-37.pyc
B
�*Ud� � @ sZ d dl mZ d dlmZ ddlmZmZ ddlmZ ddl m
Z
m Z eG dd� d��Z d S )
� )� dataclass)�Optional� )�fpm_stat_storage�fpm_reload_timeout)� XRayError)� dbm_storage� timestampc @ sT e Zd ZU dZeed< eee d�dd��Z dd� Z
e d�dd �Z e
d�d
d �Zd S )
�FPMReloadControllerzA
Class to control the frequency of FPM service reloading
� fpm_service)�returnc
C sz y@t t��.}yt|| j �� �S tk
r2 dS X W dQ R X W n4 tk
rt } ztd|� �dd��W dd}~X Y nX dS )zC
Get the timestamp of latest reload of FPM service
Nz2Failed to get the timestamp of latest FPM reload: �warning)�flag)r r �intr �decode�KeyError� RuntimeErrorr )�self�_fpm_reload_stat�e� r �H/opt/alt/python37/lib/python3.7/site-packages/xray/internal/fpm_utils.py�
latest_reload s
z!FPMReloadController.latest_reloadc
C sd y(t t��}tt� �|| j< W dQ R X W n6 tk
r^ } ztd|� d�dd��W dd}~X Y nX dS )zD
Save the timestamp of latest reload of FPM service
Nz2Failed to save the timestamp of latest FPM reload z , but main operation executedr
)r )r r �strr r r r )r r r r r r �save_latest_reload' s
z&FPMReloadController.save_latest_reloadc C s. yt � | j d S ttfk
r( dS X dS )zM
Get the time delta between current time and saved timestamp
�< g N@N)r r � TypeErrorr )r r r r �delta4 s zFPMReloadController.deltac C s | � � tkS )z7
Check if FPM reload should be blocked
)r r )r r r r �restrictA s z FPMReloadController.restrictN)�__name__�
__module__� __qualname__�__doc__r �__annotations__�propertyr r r r �floatr �boolr r r r r r
s
r
N)
� dataclassesr �typingr � constantsr r �
exceptionsr �utilsr r r
r r r r �<module> s