OLD | NEW |
| (Empty) |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | |
2 // Use of this source code is governed by a BSD-style license that can be | |
3 // found in the LICENSE file. | |
4 | |
5 #include "base/chromeos/memory_pressure_monitor.h" | |
6 | |
7 #include <fcntl.h> | |
8 #include <sys/select.h> | |
9 | |
10 #include "base/metrics/histogram_macros.h" | |
11 #include "base/posix/eintr_wrapper.h" | |
12 #include "base/process/process_metrics.h" | |
13 #include "base/single_thread_task_runner.h" | |
14 #include "base/thread_task_runner_handle.h" | |
15 #include "base/time/time.h" | |
16 | |
17 namespace base { | |
18 namespace chromeos { | |
19 | |
20 namespace { | |
21 | |
22 // The time between memory pressure checks. While under critical pressure, this | |
23 // is also the timer to repeat cleanup attempts. | |
24 const int kMemoryPressureIntervalMs = 1000; | |
25 | |
26 // The time which should pass between two moderate memory pressure calls. | |
27 const int kModerateMemoryPressureCooldownMs = 10000; | |
28 | |
29 // Number of event polls before the next moderate pressure event can be sent. | |
30 const int kModerateMemoryPressureCooldown = | |
31 kModerateMemoryPressureCooldownMs / kMemoryPressureIntervalMs; | |
32 | |
33 // Threshold constants to emit pressure events. | |
34 const int kNormalMemoryPressureModerateThresholdPercent = 60; | |
35 const int kNormalMemoryPressureCriticalThresholdPercent = 95; | |
36 const int kAggressiveMemoryPressureModerateThresholdPercent = 35; | |
37 const int kAggressiveMemoryPressureCriticalThresholdPercent = 70; | |
38 | |
39 // The possible state for memory pressure level. The values should be in line | |
40 // with values in MemoryPressureListener::MemoryPressureLevel and should be | |
41 // updated if more memory pressure levels are introduced. | |
42 enum MemoryPressureLevelUMA { | |
43 MEMORY_PRESSURE_LEVEL_NONE = 0, | |
44 MEMORY_PRESSURE_LEVEL_MODERATE, | |
45 MEMORY_PRESSURE_LEVEL_CRITICAL, | |
46 NUM_MEMORY_PRESSURE_LEVELS | |
47 }; | |
48 | |
49 // This is the file that will exist if low memory notification is available | |
50 // on the device. Whenever it becomes readable, it signals a low memory | |
51 // condition. | |
52 const char kLowMemFile[] = "/dev/chromeos-low-mem"; | |
53 | |
54 // Converts a |MemoryPressureThreshold| value into a used memory percentage for | |
55 // the moderate pressure event. | |
56 int GetModerateMemoryThresholdInPercent( | |
57 MemoryPressureMonitor::MemoryPressureThresholds thresholds) { | |
58 return thresholds == MemoryPressureMonitor:: | |
59 THRESHOLD_AGGRESSIVE_CACHE_DISCARD || | |
60 thresholds == MemoryPressureMonitor::THRESHOLD_AGGRESSIVE | |
61 ? kAggressiveMemoryPressureModerateThresholdPercent | |
62 : kNormalMemoryPressureModerateThresholdPercent; | |
63 } | |
64 | |
65 // Converts a |MemoryPressureThreshold| value into a used memory percentage for | |
66 // the critical pressure event. | |
67 int GetCriticalMemoryThresholdInPercent( | |
68 MemoryPressureMonitor::MemoryPressureThresholds thresholds) { | |
69 return thresholds == MemoryPressureMonitor:: | |
70 THRESHOLD_AGGRESSIVE_TAB_DISCARD || | |
71 thresholds == MemoryPressureMonitor::THRESHOLD_AGGRESSIVE | |
72 ? kAggressiveMemoryPressureCriticalThresholdPercent | |
73 : kNormalMemoryPressureCriticalThresholdPercent; | |
74 } | |
75 | |
76 // Converts free percent of memory into a memory pressure value. | |
77 MemoryPressureListener::MemoryPressureLevel GetMemoryPressureLevelFromFillLevel( | |
78 int actual_fill_level, | |
79 int moderate_threshold, | |
80 int critical_threshold) { | |
81 if (actual_fill_level < moderate_threshold) | |
82 return MemoryPressureListener::MEMORY_PRESSURE_LEVEL_NONE; | |
83 return actual_fill_level < critical_threshold | |
84 ? MemoryPressureListener::MEMORY_PRESSURE_LEVEL_MODERATE | |
85 : MemoryPressureListener::MEMORY_PRESSURE_LEVEL_CRITICAL; | |
86 } | |
87 | |
88 // This function will be called less then once a second. It will check if | |
89 // the kernel has detected a low memory situation. | |
90 bool IsLowMemoryCondition(int file_descriptor) { | |
91 fd_set fds; | |
92 struct timeval tv; | |
93 | |
94 FD_ZERO(&fds); | |
95 FD_SET(file_descriptor, &fds); | |
96 | |
97 tv.tv_sec = 0; | |
98 tv.tv_usec = 0; | |
99 | |
100 return HANDLE_EINTR(select(file_descriptor + 1, &fds, NULL, NULL, &tv)) > 0; | |
101 } | |
102 | |
103 } // namespace | |
104 | |
105 MemoryPressureMonitor::MemoryPressureMonitor( | |
106 MemoryPressureThresholds thresholds) | |
107 : current_memory_pressure_level_( | |
108 MemoryPressureListener::MEMORY_PRESSURE_LEVEL_NONE), | |
109 moderate_pressure_repeat_count_(0), | |
110 moderate_pressure_threshold_percent_( | |
111 GetModerateMemoryThresholdInPercent(thresholds)), | |
112 critical_pressure_threshold_percent_( | |
113 GetCriticalMemoryThresholdInPercent(thresholds)), | |
114 low_mem_file_(HANDLE_EINTR(::open(kLowMemFile, O_RDONLY))), | |
115 weak_ptr_factory_(this) { | |
116 StartObserving(); | |
117 LOG_IF(ERROR, !low_mem_file_.is_valid()) << "Cannot open kernel listener"; | |
118 } | |
119 | |
120 MemoryPressureMonitor::~MemoryPressureMonitor() { | |
121 StopObserving(); | |
122 } | |
123 | |
124 void MemoryPressureMonitor::ScheduleEarlyCheck() { | |
125 ThreadTaskRunnerHandle::Get()->PostTask( | |
126 FROM_HERE, Bind(&MemoryPressureMonitor::CheckMemoryPressure, | |
127 weak_ptr_factory_.GetWeakPtr())); | |
128 } | |
129 | |
130 MemoryPressureListener::MemoryPressureLevel | |
131 MemoryPressureMonitor::GetCurrentPressureLevel() const { | |
132 return current_memory_pressure_level_; | |
133 } | |
134 | |
135 // static | |
136 MemoryPressureMonitor* MemoryPressureMonitor::Get() { | |
137 return static_cast<MemoryPressureMonitor*>( | |
138 base::MemoryPressureMonitor::Get()); | |
139 } | |
140 | |
141 void MemoryPressureMonitor::StartObserving() { | |
142 timer_.Start(FROM_HERE, | |
143 TimeDelta::FromMilliseconds(kMemoryPressureIntervalMs), | |
144 Bind(&MemoryPressureMonitor:: | |
145 CheckMemoryPressureAndRecordStatistics, | |
146 weak_ptr_factory_.GetWeakPtr())); | |
147 } | |
148 | |
149 void MemoryPressureMonitor::StopObserving() { | |
150 // If StartObserving failed, StopObserving will still get called. | |
151 timer_.Stop(); | |
152 } | |
153 | |
154 void MemoryPressureMonitor::CheckMemoryPressureAndRecordStatistics() { | |
155 CheckMemoryPressure(); | |
156 | |
157 // Record UMA histogram statistics for the current memory pressure level. | |
158 MemoryPressureLevelUMA memory_pressure_level_uma(MEMORY_PRESSURE_LEVEL_NONE); | |
159 switch (current_memory_pressure_level_) { | |
160 case MemoryPressureListener::MEMORY_PRESSURE_LEVEL_NONE: | |
161 memory_pressure_level_uma = MEMORY_PRESSURE_LEVEL_NONE; | |
162 break; | |
163 case MemoryPressureListener::MEMORY_PRESSURE_LEVEL_MODERATE: | |
164 memory_pressure_level_uma = MEMORY_PRESSURE_LEVEL_MODERATE; | |
165 break; | |
166 case MemoryPressureListener::MEMORY_PRESSURE_LEVEL_CRITICAL: | |
167 memory_pressure_level_uma = MEMORY_PRESSURE_LEVEL_CRITICAL; | |
168 break; | |
169 } | |
170 | |
171 UMA_HISTOGRAM_ENUMERATION("ChromeOS.MemoryPressureLevel", | |
172 memory_pressure_level_uma, | |
173 NUM_MEMORY_PRESSURE_LEVELS); | |
174 } | |
175 | |
176 void MemoryPressureMonitor::CheckMemoryPressure() { | |
177 MemoryPressureListener::MemoryPressureLevel old_pressure = | |
178 current_memory_pressure_level_; | |
179 | |
180 // If we have the kernel low memory observer, we use it's flag instead of our | |
181 // own computation (for now). Note that in "simulation mode" it can be null. | |
182 // TODO(skuhne): We need to add code which makes sure that the kernel and this | |
183 // computation come to similar results and then remove this override again. | |
184 // TODO(skuhne): Add some testing framework here to see how close the kernel | |
185 // and the internal functions are. | |
186 if (low_mem_file_.is_valid() && IsLowMemoryCondition(low_mem_file_.get())) { | |
187 current_memory_pressure_level_ = | |
188 MemoryPressureListener::MEMORY_PRESSURE_LEVEL_CRITICAL; | |
189 } else { | |
190 current_memory_pressure_level_ = GetMemoryPressureLevelFromFillLevel( | |
191 GetUsedMemoryInPercent(), | |
192 moderate_pressure_threshold_percent_, | |
193 critical_pressure_threshold_percent_); | |
194 | |
195 // When listening to the kernel, we ignore the reported memory pressure | |
196 // level from our own computation and reduce critical to moderate. | |
197 if (low_mem_file_.is_valid() && | |
198 current_memory_pressure_level_ == | |
199 MemoryPressureListener::MEMORY_PRESSURE_LEVEL_CRITICAL) { | |
200 current_memory_pressure_level_ = | |
201 MemoryPressureListener::MEMORY_PRESSURE_LEVEL_MODERATE; | |
202 } | |
203 } | |
204 | |
205 // In case there is no memory pressure we do not notify. | |
206 if (current_memory_pressure_level_ == | |
207 MemoryPressureListener::MEMORY_PRESSURE_LEVEL_NONE) { | |
208 return; | |
209 } | |
210 if (old_pressure == current_memory_pressure_level_) { | |
211 // If the memory pressure is still at the same level, we notify again for a | |
212 // critical level. In case of a moderate level repeat however, we only send | |
213 // a notification after a certain time has passed. | |
214 if (current_memory_pressure_level_ == | |
215 MemoryPressureListener::MEMORY_PRESSURE_LEVEL_MODERATE && | |
216 ++moderate_pressure_repeat_count_ < | |
217 kModerateMemoryPressureCooldown) { | |
218 return; | |
219 } | |
220 } else if (current_memory_pressure_level_ == | |
221 MemoryPressureListener::MEMORY_PRESSURE_LEVEL_MODERATE && | |
222 old_pressure == | |
223 MemoryPressureListener::MEMORY_PRESSURE_LEVEL_CRITICAL) { | |
224 // When we reducing the pressure level from critical to moderate, we | |
225 // restart the timeout and do not send another notification. | |
226 moderate_pressure_repeat_count_ = 0; | |
227 return; | |
228 } | |
229 moderate_pressure_repeat_count_ = 0; | |
230 MemoryPressureListener::NotifyMemoryPressure(current_memory_pressure_level_); | |
231 } | |
232 | |
233 // Gets the used ChromeOS memory in percent. | |
234 int MemoryPressureMonitor::GetUsedMemoryInPercent() { | |
235 base::SystemMemoryInfoKB info; | |
236 if (!base::GetSystemMemoryInfo(&info)) { | |
237 VLOG(1) << "Cannot determine the free memory of the system."; | |
238 return 0; | |
239 } | |
240 // TODO(skuhne): Instead of adding the kernel memory pressure calculation | |
241 // logic here, we should have a kernel mechanism similar to the low memory | |
242 // notifier in ChromeOS which offers multiple pressure states. | |
243 // To track this, we have crbug.com/381196. | |
244 | |
245 // The available memory consists of "real" and virtual (z)ram memory. | |
246 // Since swappable memory uses a non pre-deterministic compression and | |
247 // the compression creates its own "dynamic" in the system, it gets | |
248 // de-emphasized by the |kSwapWeight| factor. | |
249 const int kSwapWeight = 4; | |
250 | |
251 // The total memory we have is the "real memory" plus the virtual (z)ram. | |
252 int total_memory = info.total + info.swap_total / kSwapWeight; | |
253 | |
254 // The kernel internally uses 50MB. | |
255 const int kMinFileMemory = 50 * 1024; | |
256 | |
257 // Most file memory can be easily reclaimed. | |
258 int file_memory = info.active_file + info.inactive_file; | |
259 // unless it is dirty or it's a minimal portion which is required. | |
260 file_memory -= info.dirty + kMinFileMemory; | |
261 | |
262 // Available memory is the sum of free, swap and easy reclaimable memory. | |
263 int available_memory = | |
264 info.free + info.swap_free / kSwapWeight + file_memory; | |
265 | |
266 DCHECK(available_memory < total_memory); | |
267 int percentage = ((total_memory - available_memory) * 100) / total_memory; | |
268 return percentage; | |
269 } | |
270 | |
271 } // namespace chromeos | |
272 } // namespace base | |
OLD | NEW |