Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(81)

Side by Side Diff: chrome/browser/memory/tab_manager_delegate_chromeos.h

Issue 2247433002: TabManager: Set OOM scores via a new debugd interface on ChromeOS. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: fix unittest Created 4 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « no previous file | chrome/browser/memory/tab_manager_delegate_chromeos.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright 2015 The Chromium Authors. All rights reserved. 1 // Copyright 2015 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #ifndef CHROME_BROWSER_MEMORY_TAB_MANAGER_DELEGATE_CHROMEOS_H_ 5 #ifndef CHROME_BROWSER_MEMORY_TAB_MANAGER_DELEGATE_CHROMEOS_H_
6 #define CHROME_BROWSER_MEMORY_TAB_MANAGER_DELEGATE_CHROMEOS_H_ 6 #define CHROME_BROWSER_MEMORY_TAB_MANAGER_DELEGATE_CHROMEOS_H_
7 7
8 #include <memory> 8 #include <memory>
9 #include <utility> 9 #include <utility>
10 #include <vector> 10 #include <vector>
11 11
12 #include "base/containers/hash_tables.h" 12 #include "base/containers/hash_tables.h"
13 #include "base/gtest_prod_util.h" 13 #include "base/gtest_prod_util.h"
14 #include "base/logging.h" 14 #include "base/logging.h"
15 #include "base/macros.h" 15 #include "base/macros.h"
16 #include "base/memory/weak_ptr.h" 16 #include "base/memory/weak_ptr.h"
17 #include "base/process/process.h" 17 #include "base/process/process.h"
18 #include "base/timer/timer.h" 18 #include "base/timer/timer.h"
19 #include "chrome/browser/chromeos/arc/arc_process.h" 19 #include "chrome/browser/chromeos/arc/arc_process.h"
20 #include "chrome/browser/memory/tab_manager.h" 20 #include "chrome/browser/memory/tab_manager.h"
21 #include "chrome/browser/memory/tab_stats.h" 21 #include "chrome/browser/memory/tab_stats.h"
22 #include "chrome/browser/ui/browser_list_observer.h" 22 #include "chrome/browser/ui/browser_list_observer.h"
23 #include "chromeos/dbus/debug_daemon_client.h"
23 #include "components/arc/arc_bridge_service.h" 24 #include "components/arc/arc_bridge_service.h"
24 #include "components/arc/common/process.mojom.h" 25 #include "components/arc/common/process.mojom.h"
25 #include "components/arc/instance_holder.h" 26 #include "components/arc/instance_holder.h"
26 #include "content/public/browser/notification_observer.h" 27 #include "content/public/browser/notification_observer.h"
27 #include "content/public/browser/notification_registrar.h" 28 #include "content/public/browser/notification_registrar.h"
28 #include "ui/wm/public/activation_change_observer.h" 29 #include "ui/wm/public/activation_change_observer.h"
29 30
30 namespace memory { 31 namespace memory {
31 32
32 // Possible types of Apps/Tabs processes. From most important to least 33 // Possible types of Apps/Tabs processes. From most important to least
33 // important. 34 // important.
34 enum class ProcessType { 35 enum class ProcessType {
35 // There can be only one process having process type "FOCUSED_APP" 36 // There can be only one process having process type "FOCUSED_APP"
36 // or "FOCUSED_TAB" in the system at any give time (i.e., The focused window 37 // or "FOCUSED_TAB" in the system at any give time (i.e., The focused window
37 // could be either a chrome window or an Android app. But not both. 38 // could be either a chrome window or an Android app. But not both.
38 FOCUSED_APP = 1, 39 FOCUSED_APP = 1,
39 FOCUSED_TAB = FOCUSED_APP, 40 FOCUSED_TAB = FOCUSED_APP,
40 41
41 VISIBLE_APP = 2, 42 VISIBLE_APP = 2,
42 BACKGROUND_TAB = 3, 43 BACKGROUND_TAB = 3,
43 BACKGROUND_APP = 4, 44 BACKGROUND_APP = 4,
44 UNKNOWN_TYPE = 5, 45 UNKNOWN_TYPE = 5,
45 }; 46 };
46 47
47 // The Chrome OS TabManagerDelegate is responsible for keeping the 48 // The Chrome OS TabManagerDelegate is responsible for keeping the
48 // renderers' scores up to date in /proc/<pid>/oom_score_adj. 49 // renderers' scores up to date in /proc/<pid>/oom_score_adj.
49 //
50 // Note that AdjustOomPriorities will be called on the UI thread by
51 // TabManager, but the actual work will take place on the file thread
52 // (see implementation of AdjustOomPriorities).
53 class TabManagerDelegate 50 class TabManagerDelegate
54 : public arc::InstanceHolder<arc::mojom::ProcessInstance>::Observer, 51 : public arc::InstanceHolder<arc::mojom::ProcessInstance>::Observer,
55 public aura::client::ActivationChangeObserver, 52 public aura::client::ActivationChangeObserver,
56 public content::NotificationObserver, 53 public content::NotificationObserver,
57 public chrome::BrowserListObserver { 54 public chrome::BrowserListObserver {
58 public: 55 public:
59 class MemoryStat; 56 class MemoryStat;
60 57
61 explicit TabManagerDelegate(const base::WeakPtr<TabManager>& tab_manager); 58 explicit TabManagerDelegate(const base::WeakPtr<TabManager>& tab_manager);
62 59
(...skipping 19 matching lines...) Expand all
82 79
83 // Returns oom_score_adj of a process if the score is cached by |this|. 80 // Returns oom_score_adj of a process if the score is cached by |this|.
84 // If couldn't find the score in the cache, returns -1001 since the valid 81 // If couldn't find the score in the cache, returns -1001 since the valid
85 // range of oom_score_adj is [-1000, 1000]. 82 // range of oom_score_adj is [-1000, 1000].
86 int GetCachedOomScore(base::ProcessHandle process_handle); 83 int GetCachedOomScore(base::ProcessHandle process_handle);
87 84
88 // Called when the timer fires, sets oom_adjust_score for all renderers. 85 // Called when the timer fires, sets oom_adjust_score for all renderers.
89 void AdjustOomPriorities(const TabStatsList& tab_list); 86 void AdjustOomPriorities(const TabStatsList& tab_list);
90 87
91 protected: 88 protected:
92 // Sets oom_score_adj for a list of tabs.
93 // This is a delegator to to SetOomScoreAdjForTabsOnFileThread(),
94 // also as a seam for unit test.
95 virtual void SetOomScoreAdjForTabs(
96 const std::vector<std::pair<base::ProcessHandle, int>>& entries);
97
98 // Kills an Arc process. Returns true if the kill request is successfully sent 89 // Kills an Arc process. Returns true if the kill request is successfully sent
99 // to Android. Virtual for unit testing. 90 // to Android. Virtual for unit testing.
100 virtual bool KillArcProcess(const int nspid); 91 virtual bool KillArcProcess(const int nspid);
101 92
102 // Kills a tab. Returns true if the tab is killed successfully. 93 // Kills a tab. Returns true if the tab is killed successfully.
103 // Virtual for unit testing. 94 // Virtual for unit testing.
104 virtual bool KillTab(int64_t tab_id); 95 virtual bool KillTab(int64_t tab_id);
105 96
97 // Get debugd client instance.
98 virtual chromeos::DebugDaemonClient* GetDebugDaemonClient();
99
106 private: 100 private:
107 FRIEND_TEST_ALL_PREFIXES(TabManagerDelegateTest, CandidatesSorted); 101 FRIEND_TEST_ALL_PREFIXES(TabManagerDelegateTest, CandidatesSorted);
108 FRIEND_TEST_ALL_PREFIXES(TabManagerDelegateTest, KillMultipleProcesses); 102 FRIEND_TEST_ALL_PREFIXES(TabManagerDelegateTest, KillMultipleProcesses);
109 FRIEND_TEST_ALL_PREFIXES(TabManagerDelegateTest, SetOomScoreAdj); 103 FRIEND_TEST_ALL_PREFIXES(TabManagerDelegateTest, SetOomScoreAdj);
110 104
111 class Candidate; 105 class Candidate;
112 class FocusedProcess; 106 class FocusedProcess;
113 class UmaReporter; 107 class UmaReporter;
114 108
115 friend std::ostream& operator<<(std::ostream& out, 109 friend std::ostream& operator<<(std::ostream& out,
116 const Candidate& candidate); 110 const Candidate& candidate);
117 111
118 // content::NotificationObserver: 112 // content::NotificationObserver:
119 void Observe(int type, 113 void Observe(int type,
120 const content::NotificationSource& source, 114 const content::NotificationSource& source,
121 const content::NotificationDetails& details) override; 115 const content::NotificationDetails& details) override;
122 116
123 // Pair to hold child process host id and ProcessHandle. 117 // Pair to hold child process host id and ProcessHandle.
124 typedef std::pair<int, base::ProcessHandle> ProcessInfo; 118 typedef std::pair<int, base::ProcessHandle> ProcessInfo;
125 119
126 // Cache OOM scores in memory. 120 // Cache OOM scores in memory.
127 typedef base::hash_map<base::ProcessHandle, int> ProcessScoreMap; 121 typedef base::hash_map<base::ProcessHandle, int> ProcessScoreMap;
128 122
129 // Get the list of candidates to kill, sorted by descending importance. 123 // Get the list of candidates to kill, sorted by descending importance.
130 static std::vector<Candidate> GetSortedCandidates( 124 static std::vector<Candidate> GetSortedCandidates(
131 const TabStatsList& tab_list, 125 const TabStatsList& tab_list,
132 const std::vector<arc::ArcProcess>& arc_processes); 126 const std::vector<arc::ArcProcess>& arc_processes);
133 127
134 // Posts AdjustFocusedTabScore task to the file thread. 128 // Sets OOM score for the focused tab.
135 void OnFocusTabScoreAdjustmentTimeout(); 129 void OnFocusTabScoreAdjustmentTimeout();
136 130
137 // Kills a process after getting all info of tabs and apps. 131 // Kills a process after getting all info of tabs and apps.
138 void LowMemoryKillImpl(const TabStatsList& tab_list, 132 void LowMemoryKillImpl(const TabStatsList& tab_list,
139 const std::vector<arc::ArcProcess>& arc_processes); 133 const std::vector<arc::ArcProcess>& arc_processes);
140 134
141 // Public interface to adjust OOM scores. 135 // Public interface to adjust OOM scores.
142 void AdjustOomPriorities(const TabStatsList& tab_list, 136 void AdjustOomPriorities(const TabStatsList& tab_list,
143 const std::vector<arc::ArcProcess>& arc_processes); 137 const std::vector<arc::ArcProcess>& arc_processes);
144 138
145 // Sets the score of the focused tab to the least value.
146 void AdjustFocusedTabScoreOnFileThread();
147
148 // Sets a newly focused tab the highest priority process if it wasn't. 139 // Sets a newly focused tab the highest priority process if it wasn't.
149 void AdjustFocusedTabScore(base::ProcessHandle pid); 140 void AdjustFocusedTabScore(base::ProcessHandle pid);
150 141
151 // Called by AdjustOomPriorities. Runs on the main thread. 142 // Called by AdjustOomPriorities. Runs on the main thread.
152 void AdjustOomPrioritiesImpl( 143 void AdjustOomPrioritiesImpl(
153 const TabStatsList& tab_list, 144 const TabStatsList& tab_list,
154 const std::vector<arc::ArcProcess>& arc_processes); 145 const std::vector<arc::ArcProcess>& arc_processes);
155 146
156 // Sets oom_score_adj of an ARC app.
157 void SetOomScoreAdjForApp(int nspid, int score);
158
159 // Sets oom_score_adj for a list of tabs on the file thread.
160 void SetOomScoreAdjForTabsOnFileThread(
161 const std::vector<std::pair<base::ProcessHandle, int>>& entries);
162
163 // Sets OOM score for processes in the range [|rbegin|, |rend|) to integers 147 // Sets OOM score for processes in the range [|rbegin|, |rend|) to integers
164 // distributed evenly in [|range_begin|, |range_end|). 148 // distributed evenly in [|range_begin|, |range_end|).
165 // The new score is set in |new_map|. 149 // The new score is set in |new_map|.
166 void DistributeOomScoreInRange( 150 void DistributeOomScoreInRange(
167 std::vector<TabManagerDelegate::Candidate>::const_iterator begin, 151 std::vector<TabManagerDelegate::Candidate>::const_iterator begin,
168 std::vector<TabManagerDelegate::Candidate>::const_iterator end, 152 std::vector<TabManagerDelegate::Candidate>::const_iterator end,
169 int range_begin, 153 int range_begin,
170 int range_end, 154 int range_end,
171 ProcessScoreMap* new_map); 155 ProcessScoreMap* new_map);
172 156
173 // Initiates an oom priority adjustment. 157 // Initiates an oom priority adjustment.
174 void ScheduleEarlyOomPrioritiesAdjustment(); 158 void ScheduleEarlyOomPrioritiesAdjustment();
175 159
176 // Holds a reference to the owning TabManager. 160 // Holds a reference to the owning TabManager.
177 const base::WeakPtr<TabManager> tab_manager_; 161 const base::WeakPtr<TabManager> tab_manager_;
178 162
179 // Registrar to receive renderer notifications. 163 // Registrar to receive renderer notifications.
180 content::NotificationRegistrar registrar_; 164 content::NotificationRegistrar registrar_;
181 165
182 // Timer to guarantee that the tab or app is focused for a certain amount of 166 // Timer to guarantee that the tab or app is focused for a certain amount of
183 // time. 167 // time.
184 base::OneShotTimer focus_process_score_adjust_timer_; 168 base::OneShotTimer focus_process_score_adjust_timer_;
185 // Holds the info of the newly focused tab or app. Its OOM score would be 169 // Holds the info of the newly focused tab or app. Its OOM score would be
186 // adjusted when |focus_process_score_adjust_timer_| is expired. 170 // adjusted when |focus_process_score_adjust_timer_| is expired.
187 std::unique_ptr<FocusedProcess> focused_process_; 171 std::unique_ptr<FocusedProcess> focused_process_;
188 172
189 // This lock is for |oom_score_map_|. 173 // Map maintaining the process handle - oom_score mapping.
190 base::Lock oom_score_lock_;
191 // Map maintaining the process handle - oom_score mapping. Behind
192 // |oom_score_lock_|.
193 ProcessScoreMap oom_score_map_; 174 ProcessScoreMap oom_score_map_;
194 175
195 // Util for getting system memory satatus. 176 // Util for getting system memory status.
196 std::unique_ptr<TabManagerDelegate::MemoryStat> mem_stat_; 177 std::unique_ptr<TabManagerDelegate::MemoryStat> mem_stat_;
197 178
198 // Holds a weak pointer to arc::mojom::ProcessInstance. 179 // Holds a weak pointer to arc::mojom::ProcessInstance.
199 arc::mojom::ProcessInstance* arc_process_instance_; 180 arc::mojom::ProcessInstance* arc_process_instance_;
200 // Current ProcessInstance version. 181 // Current ProcessInstance version.
201 int arc_process_instance_version_; 182 int arc_process_instance_version_;
202 183
203 // Reports UMA histograms. 184 // Reports UMA histograms.
204 std::unique_ptr<UmaReporter> uma_; 185 std::unique_ptr<UmaReporter> uma_;
205 186
(...skipping 58 matching lines...) Expand 10 before | Expand all | Expand 10 after
264 // reported if available memory is under the number. 245 // reported if available memory is under the number.
265 static int LowMemoryMarginKB(); 246 static int LowMemoryMarginKB();
266 247
267 // Reads in an integer. 248 // Reads in an integer.
268 static int ReadIntFromFile(const char* file_name, int default_val); 249 static int ReadIntFromFile(const char* file_name, int default_val);
269 }; 250 };
270 251
271 } // namespace memory 252 } // namespace memory
272 253
273 #endif // CHROME_BROWSER_MEMORY_TAB_MANAGER_DELEGATE_CHROMEOS_H_ 254 #endif // CHROME_BROWSER_MEMORY_TAB_MANAGER_DELEGATE_CHROMEOS_H_
OLDNEW
« no previous file with comments | « no previous file | chrome/browser/memory/tab_manager_delegate_chromeos.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698