Kb* r d dl Z d dlZd dlmZmZ d dlZd dlmZ d dlm Z e rd dl
m Z G d de Z
dS ) N)ThreadLock)logger)
TYPE_CHECKING)Optionalc ^ e Zd ZdZdZddZd 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 ) transportinterval_healthy_downsample_factor_threadr _thread_lock_thread_for_pid_running)selfr
r s d/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib/python3.11/site-packages/sentry_sdk/monitor.py__init__zMonitor.__init__ sE "
"# FF #
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 timesleepr runr s r r z(Monitor._ensure_running.._thread, sV m #Jt}---} #
m # # # # #r )nametargetT) r osgetpidr r r r daemonstart)r r threads ` r _ensure_runningzMonitor._ensure_running# s& 29;; . .4<3K4
/ /#ry{{22t|7O / / / / / / / /
#
#
#
#
# 7;;;F FM LLNNN!DL#%9;;D / / / / / / / / / / / / / / /" ts %C ACCCc V | | d S r ) check_healthset_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 ( # # LS'
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 1133
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_sdksentry_sdk.utilsr sentry_sdk._typesr typingr objectr r< r r rC s " " " " " " " " # # # # # # + + + + + + \ \ \ \ \f \ \ \ \ \r