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
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
|
// Copyright 2021 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "components/memory_pressure/memory_pressure_level_reporter.h"
#include "base/functional/bind.h"
#include "base/memory/memory_pressure_listener.h"
#include "base/metrics/histogram_functions.h"
#include "base/strings/strcat.h"
#include "base/task/sequenced_task_runner.h"
#include "base/time/time.h"
namespace memory_pressure {
MemoryPressureLevelReporter::MemoryPressureLevelReporter(
MemoryPressureLevel initial_pressure_level)
: current_pressure_level_(initial_pressure_level) {
StartPeriodicTimer();
}
MemoryPressureLevelReporter::~MemoryPressureLevelReporter() {
// Make sure that the data about the last interval gets reported.
ReportHistogram(base::TimeTicks::Now());
}
void MemoryPressureLevelReporter::OnMemoryPressureLevelChanged(
MemoryPressureLevel new_level) {
const base::TimeTicks now = base::TimeTicks::Now();
ReportHistogram(now);
// Records the duration of the latest pressure session, there are 4
// transitions of interest:
// - Moderate -> None
// - Moderate -> Critical
// - Critical -> Moderate
// - Critical -> None
// |new_level| can be equal to |periodic_reporting_timer_| if this gets called
// by the one shot reporting timer, do nothing in this case.
if ((new_level != current_pressure_level_) &&
(current_pressure_level_ !=
MemoryPressureLevel::MEMORY_PRESSURE_LEVEL_NONE)) {
constexpr char kHistogramPrefix[] = "Memory.PressureWindowDuration.";
std::string histogram_name;
DCHECK(!current_pressure_level_begin_.is_null());
switch (current_pressure_level_) {
// From:
case MemoryPressureLevel::MEMORY_PRESSURE_LEVEL_MODERATE: {
// To:
if (new_level == MemoryPressureLevel::MEMORY_PRESSURE_LEVEL_NONE) {
histogram_name = base::StrCat({kHistogramPrefix, "ModerateToNone"});
} else { // MemoryPressureLevel::MEMORY_PRESSURE_LEVEL_CRITICAL
histogram_name =
base::StrCat({kHistogramPrefix, "ModerateToCritical"});
}
break;
}
// From:
case MemoryPressureLevel::MEMORY_PRESSURE_LEVEL_CRITICAL: {
// To:
if (new_level == MemoryPressureLevel::MEMORY_PRESSURE_LEVEL_NONE) {
histogram_name = base::StrCat({kHistogramPrefix, "CriticalToNone"});
} else { // MemoryPressureLevel::MEMORY_PRESSURE_LEVEL_MODERATE
histogram_name =
base::StrCat({kHistogramPrefix, "CriticalToModerate"});
}
break;
}
case MemoryPressureLevel::MEMORY_PRESSURE_LEVEL_NONE:
default:
NOTREACHED();
}
base::UmaHistogramCustomTimes(histogram_name,
now - current_pressure_level_begin_,
base::Seconds(1), base::Minutes(10), 50);
}
current_pressure_level_begin_ = now;
current_pressure_level_ = new_level;
StartPeriodicTimer();
}
void MemoryPressureLevelReporter::ReportHistogram(base::TimeTicks now) {
auto duration = now - current_pressure_level_begin_;
auto duration_s = duration.InSeconds();
accumulator_buckets_[current_pressure_level_] +=
duration - base::Seconds(duration_s);
auto accumulated_seconds =
accumulator_buckets_[current_pressure_level_].InSeconds();
if (accumulated_seconds > 0) {
duration_s += accumulated_seconds;
accumulator_buckets_[current_pressure_level_] -=
base::Seconds(accumulated_seconds);
}
if (duration_s) {
// We can't use UmaHistogramEnumeration here as it doesn't support
// |AddCount|.
base::LinearHistogram::FactoryGet(
"Memory.PressureLevel2", 1, MemoryPressureLevel::kMaxValue + 1,
MemoryPressureLevel::kMaxValue + 2,
base::HistogramBase::kUmaTargetedHistogramFlag)
->AddCount(current_pressure_level_, duration_s);
}
}
void MemoryPressureLevelReporter::StartPeriodicTimer() {
// Don't try to start the timer in tests that don't support it.
if (!base::SequencedTaskRunner::HasCurrentDefault()) {
return;
}
periodic_reporting_timer_.Start(
FROM_HERE, base::Minutes(5),
base::BindOnce(&MemoryPressureLevelReporter::OnMemoryPressureLevelChanged,
// Unretained is safe because |this| owns this timer.
base::Unretained(this), current_pressure_level_));
}
} // namespace memory_pressure
|
