OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 #include "chrome/browser/chromeos/memory/low_memory_observer.h" | 5 #include "chrome/browser/memory/low_memory_observer_chromeos.h" |
6 | 6 |
7 #include <fcntl.h> | 7 #include <fcntl.h> |
8 | 8 |
9 #include "base/bind.h" | 9 #include "base/bind.h" |
10 #include "base/memory/scoped_ptr.h" | 10 #include "base/memory/scoped_ptr.h" |
11 #include "base/message_loop/message_loop.h" | 11 #include "base/message_loop/message_loop.h" |
12 #include "base/sys_info.h" | 12 #include "base/sys_info.h" |
13 #include "base/time/time.h" | 13 #include "base/time/time.h" |
14 #include "base/timer/timer.h" | 14 #include "base/timer/timer.h" |
15 #include "chrome/browser/browser_process.h" | 15 #include "chrome/browser/browser_process.h" |
16 #include "chrome/browser/browser_process_platform_part_chromeos.h" | 16 #include "chrome/browser/browser_process_platform_part_chromeos.h" |
17 #include "chrome/browser/chromeos/memory/oom_priority_manager.h" | 17 #include "chrome/browser/memory/oom_priority_manager.h" |
18 #include "content/public/browser/browser_thread.h" | 18 #include "content/public/browser/browser_thread.h" |
19 | 19 |
20 using content::BrowserThread; | 20 using content::BrowserThread; |
21 | 21 |
22 namespace chromeos { | |
23 | |
24 namespace { | 22 namespace { |
25 // This is the file that will exist if low memory notification is available | 23 // This is the file that will exist if low memory notification is available |
26 // on the device. Whenever it becomes readable, it signals a low memory | 24 // on the device. Whenever it becomes readable, it signals a low memory |
27 // condition. | 25 // condition. |
28 const char kLowMemFile[] = "/dev/chromeos-low-mem"; | 26 const char kLowMemFile[] = "/dev/chromeos-low-mem"; |
29 | 27 |
30 // This is the minimum amount of time in milliseconds between checks for | 28 // This is the minimum amount of time in milliseconds between checks for |
31 // low memory. | 29 // low memory. |
32 const int kLowMemoryCheckTimeoutMs = 750; | 30 const int kLowMemoryCheckTimeoutMs = 750; |
33 } // namespace | 31 } // namespace |
34 | 32 |
| 33 namespace memory { |
| 34 |
35 //////////////////////////////////////////////////////////////////////////////// | 35 //////////////////////////////////////////////////////////////////////////////// |
36 // LowMemoryObserverImpl | 36 // LowMemoryObserverImpl |
37 // | 37 // |
38 // Does the actual work of observing. The observation work happens on the FILE | 38 // Does the actual work of observing. The observation work happens on the FILE |
39 // thread, and the discarding of tabs happens on the UI thread. | 39 // thread, and the discarding of tabs happens on the UI thread. |
40 // If low memory is detected, then we discard a tab, wait | 40 // If low memory is detected, then we discard a tab, wait |
41 // kLowMemoryCheckTimeoutMs milliseconds and then start watching again to see | 41 // kLowMemoryCheckTimeoutMs milliseconds and then start watching again to see |
42 // if we're still in a low memory state. This is to keep from discarding all | 42 // if we're still in a low memory state. This is to keep from discarding all |
43 // tabs the first time we enter the state, because it takes time for the | 43 // tabs the first time we enter the state, because it takes time for the |
44 // tabs to deallocate their memory. A timer isn't the perfect solution, but | 44 // tabs to deallocate their memory. A timer isn't the perfect solution, but |
(...skipping 10 matching lines...) Expand all Loading... |
55 void StartObservingOnFileThread(); | 55 void StartObservingOnFileThread(); |
56 | 56 |
57 // Stop watching the low memory file for readability. | 57 // Stop watching the low memory file for readability. |
58 // May be safely called if StartObserving has not been called. | 58 // May be safely called if StartObserving has not been called. |
59 // This method should only be called from the FILE thread. | 59 // This method should only be called from the FILE thread. |
60 void StopObservingOnFileThread(); | 60 void StopObservingOnFileThread(); |
61 | 61 |
62 private: | 62 private: |
63 friend class base::RefCountedThreadSafe<LowMemoryObserverImpl>; | 63 friend class base::RefCountedThreadSafe<LowMemoryObserverImpl>; |
64 | 64 |
65 ~LowMemoryObserverImpl() { | 65 ~LowMemoryObserverImpl() { StopObservingOnFileThread(); } |
66 StopObservingOnFileThread(); | |
67 } | |
68 | 66 |
69 // Start a timer to resume watching the low memory file descriptor. | 67 // Start a timer to resume watching the low memory file descriptor. |
70 void ScheduleNextObservation(); | 68 void ScheduleNextObservation(); |
71 | 69 |
72 // Actually start watching the file descriptor. | 70 // Actually start watching the file descriptor. |
73 void StartWatchingDescriptor(); | 71 void StartWatchingDescriptor(); |
74 | 72 |
75 // Delegate to receive events from WatchFileDescriptor. | 73 // Delegate to receive events from WatchFileDescriptor. |
76 class FileWatcherDelegate : public base::MessageLoopForIO::Watcher { | 74 class FileWatcherDelegate : public base::MessageLoopForIO::Watcher { |
77 public: | 75 public: |
(...skipping 10 matching lines...) Expand all Loading... |
88 BrowserThread::PostTask(BrowserThread::UI, FROM_HERE, callback); | 86 BrowserThread::PostTask(BrowserThread::UI, FROM_HERE, callback); |
89 owner_->ScheduleNextObservation(); | 87 owner_->ScheduleNextObservation(); |
90 } | 88 } |
91 | 89 |
92 // Sends off a discard request to the OomPriorityManager. Must be run on | 90 // Sends off a discard request to the OomPriorityManager. Must be run on |
93 // the UI thread. | 91 // the UI thread. |
94 static void DiscardTab() { | 92 static void DiscardTab() { |
95 CHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 93 CHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
96 if (g_browser_process && | 94 if (g_browser_process && |
97 g_browser_process->platform_part()->oom_priority_manager()) { | 95 g_browser_process->platform_part()->oom_priority_manager()) { |
98 g_browser_process->platform_part()-> | 96 g_browser_process->platform_part() |
99 oom_priority_manager()->LogMemoryAndDiscardTab(); | 97 ->oom_priority_manager() |
| 98 ->LogMemoryAndDiscardTab(); |
100 } | 99 } |
101 } | 100 } |
102 | 101 |
103 private: | 102 private: |
104 LowMemoryObserverImpl* owner_; | 103 LowMemoryObserverImpl* owner_; |
105 DISALLOW_COPY_AND_ASSIGN(FileWatcherDelegate); | 104 DISALLOW_COPY_AND_ASSIGN(FileWatcherDelegate); |
106 }; | 105 }; |
107 | 106 |
108 scoped_ptr<base::MessageLoopForIO::FileDescriptorWatcher> watcher_; | 107 scoped_ptr<base::MessageLoopForIO::FileDescriptorWatcher> watcher_; |
109 FileWatcherDelegate watcher_delegate_; | 108 FileWatcherDelegate watcher_delegate_; |
(...skipping 28 matching lines...) Expand all Loading... |
138 DCHECK_CURRENTLY_ON(BrowserThread::FILE); | 137 DCHECK_CURRENTLY_ON(BrowserThread::FILE); |
139 watcher_.reset(NULL); | 138 watcher_.reset(NULL); |
140 ::close(file_descriptor_); | 139 ::close(file_descriptor_); |
141 file_descriptor_ = -1; | 140 file_descriptor_ = -1; |
142 } | 141 } |
143 } | 142 } |
144 | 143 |
145 void LowMemoryObserverImpl::ScheduleNextObservation() { | 144 void LowMemoryObserverImpl::ScheduleNextObservation() { |
146 timer_.Start(FROM_HERE, | 145 timer_.Start(FROM_HERE, |
147 base::TimeDelta::FromMilliseconds(kLowMemoryCheckTimeoutMs), | 146 base::TimeDelta::FromMilliseconds(kLowMemoryCheckTimeoutMs), |
148 this, | 147 this, &LowMemoryObserverImpl::StartWatchingDescriptor); |
149 &LowMemoryObserverImpl::StartWatchingDescriptor); | |
150 } | 148 } |
151 | 149 |
152 void LowMemoryObserverImpl::StartWatchingDescriptor() { | 150 void LowMemoryObserverImpl::StartWatchingDescriptor() { |
153 DCHECK(watcher_.get()); | 151 DCHECK(watcher_.get()); |
154 DCHECK_CURRENTLY_ON(BrowserThread::FILE); | 152 DCHECK_CURRENTLY_ON(BrowserThread::FILE); |
155 DCHECK(base::MessageLoopForIO::current()); | 153 DCHECK(base::MessageLoopForIO::current()); |
156 if (file_descriptor_ < 0) | 154 if (file_descriptor_ < 0) |
157 return; | 155 return; |
158 if (!base::MessageLoopForIO::current()->WatchFileDescriptor( | 156 if (!base::MessageLoopForIO::current()->WatchFileDescriptor( |
159 file_descriptor_, | 157 file_descriptor_, |
160 false, // persistent=false: We want it to fire once and reschedule. | 158 false, // persistent=false: We want it to fire once and reschedule. |
161 base::MessageLoopForIO::WATCH_READ, | 159 base::MessageLoopForIO::WATCH_READ, watcher_.get(), |
162 watcher_.get(), | |
163 &watcher_delegate_)) { | 160 &watcher_delegate_)) { |
164 LOG(ERROR) << "Unable to watch " << kLowMemFile; | 161 LOG(ERROR) << "Unable to watch " << kLowMemFile; |
165 } | 162 } |
166 } | 163 } |
167 | 164 |
168 //////////////////////////////////////////////////////////////////////////////// | 165 //////////////////////////////////////////////////////////////////////////////// |
169 // LowMemoryObserver | 166 // LowMemoryObserver |
170 | 167 |
171 LowMemoryObserver::LowMemoryObserver() : observer_(new LowMemoryObserverImpl) {} | 168 LowMemoryObserver::LowMemoryObserver() : observer_(new LowMemoryObserverImpl) { |
| 169 } |
172 | 170 |
173 LowMemoryObserver::~LowMemoryObserver() { Stop(); } | 171 LowMemoryObserver::~LowMemoryObserver() { |
| 172 Stop(); |
| 173 } |
174 | 174 |
175 void LowMemoryObserver::Start() { | 175 void LowMemoryObserver::Start() { |
176 BrowserThread::PostTask( | 176 BrowserThread::PostTask( |
177 BrowserThread::FILE, | 177 BrowserThread::FILE, FROM_HERE, |
178 FROM_HERE, | |
179 base::Bind(&LowMemoryObserverImpl::StartObservingOnFileThread, | 178 base::Bind(&LowMemoryObserverImpl::StartObservingOnFileThread, |
180 observer_.get())); | 179 observer_.get())); |
181 } | 180 } |
182 | 181 |
183 void LowMemoryObserver::Stop() { | 182 void LowMemoryObserver::Stop() { |
184 BrowserThread::PostTask( | 183 BrowserThread::PostTask( |
185 BrowserThread::FILE, | 184 BrowserThread::FILE, FROM_HERE, |
186 FROM_HERE, | |
187 base::Bind(&LowMemoryObserverImpl::StopObservingOnFileThread, | 185 base::Bind(&LowMemoryObserverImpl::StopObservingOnFileThread, |
188 observer_.get())); | 186 observer_.get())); |
189 } | 187 } |
190 | 188 |
191 } // namespace chromeos | 189 } // namespace memory |
OLD | NEW |