summaryrefslogtreecommitdiff
path: root/perfstatsd/cpu_usage.cpp
diff options
context:
space:
mode:
authorTom Cherry <tomcherry@google.com>2020-01-10 17:09:45 -0800
committerTom Cherry <tomcherry@google.com>2020-01-13 07:06:05 -0800
commit4a2c84ca96fb8cde96accfb22f82d0666b6f8374 (patch)
treea62429eac5b169180b4bb075daed19b2ae104659 /perfstatsd/cpu_usage.cpp
parent45cac1658faa54a039c71bab9e1429139b17c42e (diff)
perfstatsd: replace LOG_TO() macros with LOG()
perfstatsd always writes to the SYSTEM log, so instead of using LOG_TO(), it can use the normal LOG() macros as long as it calls InitLogging() with a default to the SYSTEM log. Test: perfstatsd writes to the SYSTEM log still Change-Id: Ib15867589c0b5679cc14f9fe8694ef48fc0e599e
Diffstat (limited to 'perfstatsd/cpu_usage.cpp')
-rw-r--r--perfstatsd/cpu_usage.cpp49
1 files changed, 25 insertions, 24 deletions
diff --git a/perfstatsd/cpu_usage.cpp b/perfstatsd/cpu_usage.cpp
index 6bbeb2d..5a26ace 100644
--- a/perfstatsd/cpu_usage.cpp
+++ b/perfstatsd/cpu_usage.cpp
@@ -51,22 +51,22 @@ void CpuUsage::setOptions(const std::string &key, const std::string &value) {
key == CPU_TOPCOUNT) {
uint32_t val = 0;
if (!base::ParseUint(value, &val)) {
- LOG_TO(SYSTEM, ERROR) << "Invalid value: " << value;
+ LOG(ERROR) << "Invalid value: " << value;
return;
}
if (key == PROCPROF_THRESHOLD) {
mProfileThreshold = val;
- LOG_TO(SYSTEM, INFO) << "set profile threshold " << mProfileThreshold;
+ LOG(INFO) << "set profile threshold " << mProfileThreshold;
} else if (key == CPU_DISABLED) {
mDisabled = (val != 0);
- LOG_TO(SYSTEM, INFO) << "set disabled " << mDisabled;
+ LOG(INFO) << "set disabled " << mDisabled;
} else if (key == CPU_DEBUG) {
cDebug = (val != 0);
- LOG_TO(SYSTEM, INFO) << "set debug " << cDebug;
+ LOG(INFO) << "set debug " << cDebug;
} else if (key == CPU_TOPCOUNT) {
mTopcount = val;
- LOG_TO(SYSTEM, INFO) << "set top count " << mTopcount;
+ LOG(INFO) << "set top count " << mTopcount;
}
}
}
@@ -98,7 +98,7 @@ void CpuUsage::profileProcess(std::string *out) {
!base::ParseUint(fields[14], &stime) ||
!base::ParseUint(fields[15], &cutime) ||
!base::ParseUint(fields[16], &cstime)) {
- LOG_TO(SYSTEM, ERROR) << "Invalid proc data\n" << pidStat;
+ LOG(ERROR) << "Invalid proc data\n" << pidStat;
continue;
}
std::string proc = fields[1];
@@ -120,10 +120,10 @@ void CpuUsage::profileProcess(std::string *out) {
float usageRatio = (float)(diffUsage * 100.0 / mDiffCpu);
if (cDebug && usageRatio > 100) {
- LOG_TO(SYSTEM, INFO) << "pid: " << pid << " , ratio: " << usageRatio
- << " , prev usage: " << mPrevProcdata[pid].usage
- << " , cur usage: " << totalUsage
- << " , total cpu diff: " << mDiffCpu;
+ LOG(INFO) << "pid: " << pid << " , ratio: " << usageRatio
+ << " , prev usage: " << mPrevProcdata[pid].usage
+ << " , cur usage: " << totalUsage
+ << " , total cpu diff: " << mDiffCpu;
}
ProcData data;
@@ -147,7 +147,7 @@ void CpuUsage::profileProcess(std::string *out) {
}
closedir(dir);
} else {
- LOG_TO(SYSTEM, ERROR) << "Fail to open /proc/";
+ LOG(ERROR) << "Fail to open /proc/";
}
}
@@ -186,7 +186,7 @@ void CpuUsage::getOverallUsage(std::chrono::system_clock::time_point &now, std::
!base::ParseUint(fields[base + 5], &irq) ||
!base::ParseUint(fields[base + 6], &softirq) ||
!base::ParseUint(fields[base + 7], &steal)) {
- LOG_TO(SYSTEM, ERROR) << "Invalid /proc/stat data\n" << line;
+ LOG(ERROR) << "Invalid /proc/stat data\n" << line;
continue;
}
@@ -207,10 +207,9 @@ void CpuUsage::getOverallUsage(std::chrono::system_clock::time_point &now, std::
float ioRatio = (float)(diffIo * 100.0 / mDiffCpu);
if (cDebug) {
- LOG_TO(SYSTEM, INFO)
- << "prev total: " << mPrevUsage.cpuUsage
- << " , cur total: " << cpuUsage << " , diffusage: " << diffUsage
- << " , diffcpu: " << mDiffCpu << " , ratio: " << mTotalRatio;
+ LOG(INFO) << "prev total: " << mPrevUsage.cpuUsage
+ << " , cur total: " << cpuUsage << " , diffusage: " << diffUsage
+ << " , diffcpu: " << mDiffCpu << " , ratio: " << mTotalRatio;
}
mPrevUsage.cpuUsage = cpuUsage;
@@ -227,16 +226,18 @@ void CpuUsage::getOverallUsage(std::chrono::system_clock::time_point &now, std::
// calculate total cpu usage of each core
uint32_t c = 0;
if (!base::ParseUint(core, &c)) {
- LOG_TO(SYSTEM, ERROR) << "Invalid core: " << core;
+ LOG(ERROR) << "Invalid core: " << core;
continue;
}
uint64_t diffUsage = cpuUsage - mPrevCoresUsage[c].cpuUsage;
float coreTotalRatio = (float)(diffUsage * 100.0 / mDiffCpu);
if (cDebug) {
- LOG_TO(SYSTEM, INFO)
- << "core " << c << " , prev cpu usage: " << mPrevCoresUsage[c].cpuUsage
- << " , cur cpu usage: " << cpuUsage << " , diffusage: " << diffUsage
- << " , difftotalcpu: " << mDiffCpu << " , ratio: " << coreTotalRatio;
+ LOG(INFO) << "core " << c
+ << " , prev cpu usage: " << mPrevCoresUsage[c].cpuUsage
+ << " , cur cpu usage: " << cpuUsage
+ << " , diffusage: " << diffUsage
+ << " , difftotalcpu: " << mDiffCpu
+ << " , ratio: " << coreTotalRatio;
}
mPrevCoresUsage[c].cpuUsage = cpuUsage;
@@ -248,7 +249,7 @@ void CpuUsage::getOverallUsage(std::chrono::system_clock::time_point &now, std::
}
out->append("\n");
} else {
- LOG_TO(SYSTEM, ERROR) << "Fail to read /proc/stat";
+ LOG(ERROR) << "Fail to read /proc/stat";
}
}
@@ -263,7 +264,7 @@ void CpuUsage::refresh(void) {
if (mTotalRatio >= mProfileThreshold) {
if (cDebug)
- LOG_TO(SYSTEM, INFO) << "Total CPU usage over " << mProfileThreshold << "%";
+ LOG(INFO) << "Total CPU usage over " << mProfileThreshold << "%";
std::string profileResult;
profileProcess(&profileResult);
if (mProfileProcess) {
@@ -279,6 +280,6 @@ void CpuUsage::refresh(void) {
if (cDebug) {
auto ms = std::chrono::duration_cast<std::chrono::milliseconds>(
std::chrono::system_clock::now() - now);
- LOG_TO(SYSTEM, INFO) << "Took " << ms.count() << " ms, data bytes: " << out.length();
+ LOG(INFO) << "Took " << ms.count() << " ms, data bytes: " << out.length();
}
}