S>{i= nddlZddlZddlmZmZddlZddlmZddlm Z e rddl m Z dZ Gdde Zy) N)ThreadLock)logger) TYPE_CHECKING)Optional cVeZdZdZdZd dZdZdZdZdZ dZ e d Z d Z d 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.monitorc||_||_d|_d|_d|_t |_d|_d|_y)NTr) transportinterval_healthy_downsample_factor_threadr _thread_lock_thread_for_pid_running)selfr r s P/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/sentry_sdk/monitor.py__init__zMonitor.__init__s?"   "#  F# cjtjk(r jyj5jtjk(rj dddyfd}t j |}d|_|j|_tj_dddy#1swYyxYw)NcjrItjjjrj jrHyyN)rtimesleepr runrsrrz(Monitor._ensure_running.._thread/s3mmJJt}}-}} mmr)nametargetT) rosgetpidrrrrdaemonstart)rrthreads` r_ensure_runningzMonitor._ensure_running&s   299; .4<<3K    /##ryy{2t||7O / / #7;F FM LLN!DL#%99;D  /"# /"s/C4ACCcD|j|jyr) check_healthset_downsample_factorrs rrz Monitor.run>s  ""$rc|jr,|jdkDrtjdd|_y|jt kr|xjdz c_tjd|jy)Nrz=[Monitor] health check positive, reverting to normal samplingzA[Monitor] health check negative, downsampling with a factor of %d)rrrdebugdownsample_factorMAX_DOWNSAMPLE_FACTORrs rr)zMonitor.set_downsample_factorCsh ==&&* S'(D #%%(==''1,' LLS'' rcB|jj|_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_healthyrrs rr(zMonitor.check_healthSs113 rc:|j|jSr)r&rrs rr0zMonitor.is_healthy\s }}rc:|j|jSr)r&rrs rr-zMonitor.downsample_factoras &&&rcd|_y)NF)rrs rkillz Monitor.killgs  rc$|jyr)r4rs r__del__zMonitor.__del__ks  rN)r)__name__ __module__ __qualname____doc__rrr&rr)r(r0propertyr-r4r6rrr r sJ D 0%  4 '' rr )r!r threadingrr sentry_sdksentry_sdk.utilsrsentry_sdk._typesrtypingrr.objectr r<rrrCs3 "#+]f]r