XMAN Replicator

Path: /opt/cloudlinux/venv/lib/python3.11/site-packages/sentry_sdk/

Name	Size	Rights	Date	Actions
[.]	<DIR>	drwxr-xr-x	2026-02-11 06:01	🔄 🗑️ 🗑️📁 ⬇️ 🔒
[..]	<DIR>	drwxr-xr-x	2026-06-17 05:00	🔄 🗑️ 🗑️📁 ⬇️ 🔒
__init__.py	1,056 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
[__pycache__]	<DIR>	drwxr-xr-x	2026-02-11 06:08	🔄 🗑️ 🗑️📁 ⬇️ 🔒
_compat.py	2,795 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
_functools.py	4,957 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
_lru_cache.py	5,390 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
_queue.py	11,267 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
_types.py	2,247 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
_werkzeug.py	3,790 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
api.py	6,192 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
attachments.py	1,811 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
client.py	22,890 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
consts.py	8,697 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
[crons]	<DIR>	drwxr-xr-x	2026-02-11 06:01	🔄 🗑️ 🗑️📁 ⬇️ 🔒
debug.py	1,132 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
envelope.py	9,591 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
hub.py	27,050 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
[integrations]	<DIR>	drwxr-xr-x	2026-02-11 06:01	🔄 🗑️ 🗑️📁 ⬇️ 🔒
monitor.py	3,037 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
profiler.py	33,978 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
py.typed	0 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
scope.py	24,844 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
scrubber.py	3,893 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
serializer.py	13,285 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
session.py	5,561 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
sessions.py	5,900 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
tracing.py	29,739 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
tracing_utils.py	12,287 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
tracing_utils_py2.py	1,244 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
tracing_utils_py3.py	2,146 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
transport.py	18,570 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
utils.py	46,676 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒
worker.py	4,254 B	-rw-r--r--	2026-01-20 13:01	✏️ 🔄 🗑️ ⬇️ 🔒

View: monitor.py

import os
import time
from threading import Thread, Lock

import sentry_sdk
from sentry_sdk.utils import logger
from sentry_sdk._types import TYPE_CHECKING

if TYPE_CHECKING:
    from typing import Optional


class Monitor(object):
    """
    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.
    """

    name = "sentry.monitor"

    def __init__(self, transport, interval=10):
        # type: (sentry_sdk.transport.Transport, float) -> None
        self.transport = transport  # type: sentry_sdk.transport.Transport
        self.interval = interval  # type: float

        self._healthy = True
        self._downsample_factor = 1  # type: int

        self._thread = None  # type: Optional[Thread]
        self._thread_lock = Lock()
        self._thread_for_pid = None  # type: Optional[int]
        self._running = True

    def _ensure_running(self):
        # type: () -> None
        if self._thread_for_pid == os.getpid() and self._thread is not None:
            return None

        with self._thread_lock:
            if self._thread_for_pid == os.getpid() and self._thread is not None:
                return None

            def _thread():
                # type: (...) -> None
                while self._running:
                    time.sleep(self.interval)
                    if self._running:
                        self.run()

            thread = Thread(name=self.name, target=_thread)
            thread.daemon = True
            thread.start()
            self._thread = thread
            self._thread_for_pid = os.getpid()

        return None

    def run(self):
        # type: () -> None
        self.check_health()
        self.set_downsample_factor()

    def set_downsample_factor(self):
        # type: () -> None
        if self._healthy:
            if self._downsample_factor > 1:
                logger.debug(
                    "[Monitor] health check positive, reverting to normal sampling"
                )
            self._downsample_factor = 1
        else:
            self._downsample_factor *= 2
            logger.debug(
                "[Monitor] health check negative, downsampling with a factor of %d",
                self._downsample_factor,
            )

    def check_health(self):
        # type: () -> None
        """
        Perform the actual health checks,
        currently only checks if the transport is rate-limited.
        TODO: augment in the future with more checks.
        """
        self._healthy = self.transport.is_healthy()

    def is_healthy(self):
        # type: () -> bool
        self._ensure_running()
        return self._healthy

    @property
    def downsample_factor(self):
        # type: () -> int
        self._ensure_running()
        return self._downsample_factor

    def kill(self):
        # type: () -> None
        self._running = False

    def __del__(self):
        # type: () -> None
        self.kill()

🛸 XMAN Replicator

View: monitor.py

PHP Console

SQL Console