File: systemresourcewatcher.cpp

package info (click to toggle)
kylin-process-manager 4.0.0.0-1.1
  • links: PTS, VCS
  • area: main
  • in suites: forky, sid, trixie
  • size: 844 kB
  • sloc: cpp: 7,336; xml: 182; makefile: 4
file content (96 lines) | stat: -rw-r--r-- 2,862 bytes parent folder | download
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
/*
 * Copyright 2023 KylinSoft Co., Ltd.
 *
 * This program is free software: you can redistribute it and/or modify it under
 * the terms of the GNU General Public License as published by the Free Software
 * Foundation, either version 3 of the License, or (at your option) any later
 * version.
 *
 * This program is distributed in the hope that it will be useful, but WITHOUT
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
 * FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License along with
 * this program. If not, see <https://www.gnu.org/licenses/>.
 */

#include "systemresourcewatcher.h"
#include <QFile>
#include <QJsonDocument>
#include <QJsonArray>
#include <QTimer>
#include <QThread>
#include <QDebug>
#include <sys/epoll.h>
#include <errno.h>
#include <fcntl.h>
#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <libproc2/meminfo.h>

#include "common.h"

SystemResourceWatcher::SystemResourceWatcher(QObject *parent)
    : ResourceWatcher{parent}
    , m_stop(false)
    , m_timer(new QTimer(this))
{
    connect(m_timer, &QTimer::timeout, this, &SystemResourceWatcher::detectMemory);
    ConfManager &confMgr = common::Singleton<ConfManager>::GetInstance();
    m_resourceThrehold = confMgr.resourceThreshold(ConfManager::Memory);
    m_detectEffectiveNumber = confMgr.detectEffectiveNumber(ConfManager::Memory);
    if (m_detectEffectiveNumber == 0) {
        m_detectEffectiveNumber = 5;
    }
}

void SystemResourceWatcher::stop()
{
    m_stop = true;
}

unsigned long SystemResourceWatcher::getAvailableMem()
{
    meminfo_info *meminfo = nullptr;
    procps_meminfo_new(&meminfo);
    if (!meminfo) {
        return 0;
    }

    meminfo_result *memResult = procps_meminfo_get(meminfo, MEMINFO_MEM_AVAILABLE);
    if (!memResult) {
        return 0;
    }

    procps_meminfo_unref(&meminfo);
    return memResult->result.ul_int;
}

void SystemResourceWatcher::detectMemory()
{
    uint mbMainAvailable =  getAvailableMem() / (double)1024;
    if (mbMainAvailable > m_resourceThrehold.value(ConfManager::Low)) {
        return;
    }
    if (mbMainAvailable <= m_resourceThrehold.value(ConfManager::Low) &&
           mbMainAvailable > m_resourceThrehold.value(ConfManager::Medium)) {
        Q_EMIT ResourceThresholdWarning("Memory", 1);
        return;
    }

    if (mbMainAvailable <= m_resourceThrehold.value(ConfManager::Medium) &&
           mbMainAvailable > m_resourceThrehold.value(ConfManager::High)) {
        Q_EMIT ResourceThresholdWarning("Memory", 2);
        return;
    }

    if (mbMainAvailable <= m_resourceThrehold.value(ConfManager::High)) {
        Q_EMIT ResourceThresholdWarning("Memory", 3);
    }
}

void SystemResourceWatcher::start()
{
    m_timer->start(1000);
}