FM / generic

/opt/cloudlinux/venv/lib/python3.11/site-packages/lvestats/plugins/generic/

/opt/cloudlinux/venv/lib/python3.11/site-packages/lvestats/plugins/generic

Name	Size	Mode	Actions
burster/	-	0755	rm
__pycache__/	-	0755	rm
aggregators.py	5576	0644	edit dl rm
analyzers.py	11587	0644	edit dl rm
cleaners.py	4253	0644	edit dl rm
cm_collector.py	10833	0644	edit dl rm
collectors.py	3388	0644	edit dl rm
dbgov_saver.py	6898	0644	edit dl rm
dbsaver.py	5790	0644	edit dl rm
dbsaver_x60.py	10267	0644	edit dl rm
lvestats_memory_usage.py	1573	0644	edit dl rm
persistors.py	13830	0644	edit dl rm
snapshot_saver.py	17096	0644	edit dl rm
statsnotifier.py	52068	0644	edit dl rm
__init__.py	219	0644	edit dl rm

Edit: /opt/cloudlinux/venv/lib/python3.11/site-packages/lvestats/plugins/generic/lvestats_memory_usage.py (1573B)

# coding=utf-8
#
# Copyright © Cloud Linux GmbH & Cloud Linux Software, Inc 2010-2019 All Rights Reserved
#
# Licensed under CLOUD LINUX LICENSE AGREEMENT
# http://cloudlinux.com/docs/LICENSE.TXT

import logging
import os

import psutil
from guppy import hpy

from lvestats.core.plugin import LveStatsPlugin

class LVEStatsMemoryUsage(LveStatsPlugin):
    def __init__(self):
        self.log = logging.getLogger('plugin.LVEStatsMemoryUsage')
        self.now = 0  # This changes in MainLoop
        self.period = 60 * 60
        self.threshold = 512
        try:
            self._process = psutil.Process(os.getpid())
        except AttributeError:
            self._process = None
            self.log.error("Process attribute in psutil is not available. psutil.__version__=%s", psutil.__version__)
        self._hpy = hpy()
        self._hpy.setrelheap()

@staticmethod
    def split(value):
        return str(value).split("\n")

def execute(self, lve_data):
        if self._process is None:
            return
        rss = self._process.memory_info()[0] / float(1024 * 1024)
        self.log.debug(str(rss))
        if rss >= self.threshold:
            heap = self._hpy.heap()[:10]
            result = {
                'heap': self.split(heap),
                'byid': self.split(heap.byid),
                'byvia': self.split(heap.byvia),
                'byrcs': self.split(heap.byrcs),
            }
            self.log.error("LVEStats uses too much memory", extra=result)
        elif rss < self.threshold / 2:
            self._hpy.setrelheap()

# coding=utf-8 # # Copyright © Cloud Linux GmbH & Cloud Linux Software, Inc 2010-2019 All Rights Reserved # # Licensed under CLOUD LINUX LICENSE AGREEMENT # http://cloudlinux.com/docs/LICENSE.TXT import logging import os import psutil from guppy import hpy from lvestats.core.plugin import LveStatsPlugin class LVEStatsMemoryUsage(LveStatsPlugin): def __init__(self): self.log = logging.getLogger('plugin.LVEStatsMemoryUsage') self.now = 0 # This changes in MainLoop self.period = 60 * 60 self.threshold = 512 try: self._process = psutil.Process(os.getpid()) except AttributeError: self._process = None self.log.error("Process attribute in psutil is not available. psutil.__version__=%s", psutil.__version__) self._hpy = hpy() self._hpy.setrelheap() @staticmethod def split(value): return str(value).split("\n") def execute(self, lve_data): if self._process is None: return rss = self._process.memory_info()[0] / float(1024 * 1024) self.log.debug(str(rss)) if rss >= self.threshold: heap = self._hpy.heap()[:10] result = { 'heap': self.split(heap), 'byid': self.split(heap.byid), 'byvia': self.split(heap.byvia), 'byrcs': self.split(heap.byrcs), } self.log.error("LVEStats uses too much memory", extra=result) elif rss < self.threshold / 2: self._hpy.setrelheap()