관리-도구
편집 파일: monitor.cpython-38.pyc
U �Mg~ � @ sf d dl Z d dlZd dlmZmZ d dlZd dlmZ d dlm Z e rPd dlm Z dZ G dd� d�Z dS ) � N)�Thread�Lock)�logger)� TYPE_CHECKING)�Optional� c @ sb e Zd ZdZdZddd�Zdd� Zdd � Zd d � Zd d � Z dd� Z e dd� �Z dd� Z dd� ZdS )�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.monitorr c C s6 || _ || _d| _d| _d | _t� | _d | _d| _d S )NTr ) � transport�interval�_healthy�_downsample_factor�_threadr � _thread_lock�_thread_for_pid�_running)�selfr r � r �@/opt/hc_python/lib/python3.8/site-packages/sentry_sdk/monitor.py�__init__ s zMonitor.__init__c s� � j t�� kr � jdk r dS � j�� � j t�� krJ� jdk rJW 5 Q R � dS � fdd�}t� j|d�}d|_z |�� W n& t k r� d� _ Y W 5 Q R � dS X |� _t�� � _ W 5 Q R X dS )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 s& � j r"t�� j� � j r � �� q d S �N)r �time�sleepr �runr �r r r r 7 s z(Monitor._ensure_running.<locals>._thread)�name�targetTF) r �os�getpidr r r r �daemon�start� RuntimeErrorr )r r �threadr r r �_ensure_running' s zMonitor._ensure_runningc C s | � � | �� d S r )� check_health�set_downsample_factorr r r r r M s z Monitor.runc C sL | j r"| jdkrt�d� d| _n&| jtk r:| jd7 _t�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 �debug�downsample_factor�MAX_DOWNSAMPLE_FACTORr r r r r$ R s � �z Monitor.set_downsample_factorc C s | 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 r r r r# b s zMonitor.check_healthc C s | � � | jS r )r" r r r r r r) k s zMonitor.is_healthyc C s | � � | jS r )r" r r r r r r' p s zMonitor.downsample_factorc C s d| _ d S )NF)r r r r r �killv s z Monitor.killc C s | � � d S r )r* r r r r �__del__z s zMonitor.__del__N)r )�__name__� __module__� __qualname__�__doc__r r r" r r$ r# r) �propertyr' r* r+ r r r r r s & r ) r r � threadingr r Z sentry_sdkZsentry_sdk.utilsr �typingr r r( r r r r r �<module> s