Current File : /opt/cloudlinux/venv/lib/python3.11/site-packages/sentry_sdk/__pycache__//monitor.cpython-311.pyc
�
�|oi� � �r � d dl Z d dlZd dlmZmZ d dlZd dlmZ d dlm Z e rd dl
m Z G d� de � � Z
dS )� N)�Thread�Lock)�logger)�
TYPE_CHECKING)�Optionalc �^ � e Zd ZdZdZdd�Zd� Zd� Zd� Zd� Z d � Z
e d
� � � Z d � Z
d � Zd
S )�Monitorz�
Performs health checks in a separate thread once every interval seconds
and updates the internal state. Other parts of the SDK only read this state
and act accordingly.
zsentry.monitor�
c � � || _ || _ d| _ d| _ d | _ t � � | _ d | _ d| _ d S )NT� ) � transport�interval�_healthy�_downsample_factor�_threadr � _thread_lock�_thread_for_pid�_running)�selfr
r s �I/opt/cloudlinux/venv/lib64/python3.11/site-packages/sentry_sdk/monitor.py�__init__zMonitor.__init__ sE � �"��� ��
� ��
�"#�� ��� � �F�F��� #�� � ��
�
�
� c � � � � j t j � � k r � j �d S � j 5 � j t j � � k r� j � d d d � � d S � fd�}t � j |�� � }d|_ |� � � |� _ t j � � � _ d d d � � n # 1 swxY w Y d S )Nc � �� � j r=t j � j � � � j r� � � � � j �;d S d S �N)r �time�sleepr �run�r s �r r z(Monitor._ensure_running.<locals>._thread, sV �� ��m� #��J�t�}�-�-�-��}� #� ���
�
�
� �m� #� #� #� #� #r )�name�targetT) r �os�getpidr r r r �daemon�start)r r �threads ` r �_ensure_runningzMonitor._ensure_running# s& �� � � �2�9�;�;� .� .�4�<�3K��4�
�
� /� /��#�r�y�{�{�2�2�t�|�7O�� /� /� /� /� /� /� /� /�
#�
#�
#�
#�
#� ���7�;�;�;�F� �F�M� �L�L�N�N�N�!�D�L�#%�9�;�;�D� � /� /� /� /� /� /� /� /� /� /� /���� /� /� /� /�" �ts �%C� AC�C�Cc �V � | � � � | � � � d S r )� check_health�set_downsample_factorr s r r z Monitor.run; s, � � ������ �"�"�$�$�$�$�$r c � � | j r(| j dk rt j d� � d| _ d S | xj dz c_ t j d| j � � d S )Nr z=[Monitor] health check positive, reverting to normal sampling� zA[Monitor] health check negative, downsampling with a factor of %d)r r r �debugr s r r* z Monitor.set_downsample_factor@ s| � � �=� ��&��*�*�� �S�� � � '(�D� #� #� #� � #� #�q� (� #� #� �L�S��'�
�
�
�
�
r c �B � | j � � � | _ dS )z�
Perform the actual health checks,
currently only checks if the transport is rate-limited.
TODO: augment in the future with more checks.
N)r
�
is_healthyr r s r r) zMonitor.check_healthO s � � ��1�1�3�3��
�
�
r c �8 � | � � � | j S r )r' r r s r r/ zMonitor.is_healthyX s � � � � � � � ��}� r c �8 � | � � � | j S r )r' r r s r �downsample_factorzMonitor.downsample_factor] s � �
� � � � � ��&�&r c � � d| _ d S )NF)r r s r �killz Monitor.killc s
� � ��
�
�
r c �. � | � � � d S r )r4 r s r �__del__zMonitor.__del__g s � � � � � � � � � r N)r
)�__name__�
__module__� __qualname__�__doc__r r r' r r* r) r/ �propertyr2 r4 r6 � r r r r
s� � � � � � �� � �D� � � � �� � �0%� %� %�
�
�
� 4� 4� 4� � � �
�'� '� �X�'�
� � �� � � � r r )r" r � threadingr r �
sentry_sdk�sentry_sdk.utilsr �sentry_sdk._typesr �typingr �objectr r< r r �<module>rC s� �� � � � � � � � � "� "� "� "� "� "� "� "� � � � � #� #� #� #� #� #� +� +� +� +� +� +�� � � � � � � �\� \� \� \� \�f� \� \� \� \� \r 