�
_�*j� � �t � d dl Z d dlZd dlZd dlmZmZ d dlmZ d dlZd dl m
Z
erd dlm Z dZ G d� d� Z
y) � N)�Lock�Thread)�
TYPE_CHECKING)�logger)�Optional�
c � � e Zd ZU dZdZded< ded< dddd ed
d fd �Zdd
�Zdd�Z dd�Z
dd�Z dd�Z d
e
fd�Zed
efd�� Zdd�Zy )�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.monitorzOptional[Thread]�_threadz
Optional[int]�_thread_for_pid� transportz sentry_sdk.transport.Transport�interval�returnNc � �� || _ || _ d| _ d| _ d| _ | j � t
t d� r<t j | j
� �d�fd� }t j |�� y y )NTr �register_at_forkc �( �� �� } | � | � y y �N� )�method�
weak_resets ��A/opt/hc_python/lib/python3.12/site-packages/sentry_sdk/monitor.py�_reset_in_childz)Monitor.__init__.<locals>._reset_in_child5 s �� �#� ���%��H� &� )�after_in_child�r N) r
r �_healthy�_downsample_factor�_running�_reset_thread_state�hasattr�os�weakref�
WeakMethodr )�selfr
r r r s @r �__init__zMonitor.__init__ ss �� � <E��� '��
� ��
�'(�� � ��
� � � �"� �2�)� *� �+�+�D�,D�,D�E�J�
�
� � �� ?� +r c �> � d | _ t � | _ d | _ y r )r r � _thread_lockr �r$ s r r zMonitor._reset_thread_state< s � ��� � �F��� #�� r c � � � � j t j � k( r
� j �y� j 5 � j t j � k( r� j �
ddd� yd� fd� }t � j |�� }d|_ |j � |� _ t j � � _ ddd� y# t $ r d� _
Y ddd� yw xY w# 1 sw Y yxY w)a-
Check that the monitor has an active thread to run in, or create one if not.
Note that this might fail (e.g. in Python 3.12 it's not possible to
spawn new threads at interpreter shutdown). In that case self._running
will be False after running this function.
Nc � �� � j rIt j � j � � j r� j � � j r�Hy y r )r �time�sleepr �runr( s �r r z(Monitor._ensure_running.<locals>._threadP s3 �� ��m�m��J�J�t�}�}�-��}�}� ���
� �m�mr )�name�targetTFr ) r r! �getpidr r' r r. �daemon�start� RuntimeErrorr )r$ r �threads ` r �_ensure_runningzMonitor._ensure_runningA s� �� � � � �2�9�9�;� .�4�<�<�3K��
�
�
��#�#�r�y�y�{�2�t�|�|�7O�� �
�
#� ����7�;�F� �F�M�
�� � �� "�D�L�#%�9�9�;�D� �+ �. �� �
� !&��
��% �
�
�� �. �s5 �/C0�4$C0�C�) C0�C-�"C0�,C-�-C0�0C9c �D � | j � | j � y r )� check_health�set_downsample_factorr( s r r- z Monitor.rune s � � ���� �"�"�$r c � � | j r,| j dkD rt j d� d| _ y | j t
k r| xj dz
c_ t j d| j � y )Nr z=[Monitor] health check positive, reverting to normal sampling� zA[Monitor] health check negative, downsampling with a factor of %d)r r r �debug�downsample_factor�MAX_DOWNSAMPLE_FACTORr( s r r8 z Monitor.set_downsample_factori sh � � �=�=��&�&��*�� � �S�� '(�D� #��%�%�(=�=��'�'�1�,�'� �L�L�S��'�'�
r c �B � | j j � | _ y)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 r7 zMonitor.check_healthx s � � ���1�1�3��
r c �: � | j � | j S r )r5 r r( s r r? zMonitor.is_healthy� s � � � � � ��}�}� r c �: � | j � | j S r )r5 r r( s r r< zMonitor.downsample_factor� s � � � � � ��&�&�&r c � � d| _ y )NF)r r( s r �killz Monitor.kill� s � � ��
r )r r )�__name__�
__module__� __qualname__�__doc__r. �__annotations__�floatr% r r5 r- r8 r7 �boolr? �property�intr< rC r r r r
r
s� � �� �D�
� �$�$� NP� @�9� @�EJ� @�
� @�>$�
"�H%�
� 4� �D� � �'�3� '� �'� r r
)r! r+ r" � threadingr r �typingr �
sentry_sdk�sentry_sdk.utilsr r r= r
r r r �<module>rQ s4 �� � � � "� � � #�� � � �y � y r