Edit File: monitor.cpython-311.pyc
� v�d� � �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