OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 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 | 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/power/renderer_freezer.h" | 5 #include "chrome/browser/chromeos/power/renderer_freezer.h" |
6 | 6 |
7 #include <cstring> // needed for strlen() | |
8 | |
9 #include "base/bind.h" | 7 #include "base/bind.h" |
10 #include "base/files/file_util.h" | |
11 #include "base/logging.h" | 8 #include "base/logging.h" |
12 #include "base/message_loop/message_loop.h" | 9 #include "base/message_loop/message_loop.h" |
13 #include "chromeos/dbus/dbus_thread_manager.h" | 10 #include "chromeos/dbus/dbus_thread_manager.h" |
14 | 11 |
15 namespace chromeos { | 12 namespace chromeos { |
16 | 13 |
17 namespace { | 14 RendererFreezer::RendererFreezer(scoped_ptr<RendererFreezer::Delegate> delegate) |
18 const char kFreezerStatePath[] = | 15 : frozen_(false), |
19 "/sys/fs/cgroup/freezer/chrome_renderers/freezer.state"; | 16 delegate_(delegate.Pass()), |
20 const char kFreezeCommand[] = "FROZEN"; | 17 weak_factory_(this) { |
21 const char kThawCommand[] = "THAWED"; | 18 if (delegate_->CanFreezeRenderers()) |
| 19 DBusThreadManager::Get()->GetPowerManagerClient()->AddObserver(this); |
| 20 } |
22 | 21 |
23 } // namespace | 22 RendererFreezer::~RendererFreezer() { |
| 23 if (delegate_->CanFreezeRenderers()) |
| 24 DBusThreadManager::Get()->GetPowerManagerClient()->RemoveObserver(this); |
| 25 } |
24 | 26 |
25 void RendererFreezer::SuspendImminent() { | 27 void RendererFreezer::SuspendImminent() { |
26 // SuspendImminent() might end up being called multiple times before we run | 28 // If there was already a callback pending, this will cancel it and create a |
27 // OnReadyToSuspend() (crbug.com/414396). In case a callback is already | 29 // new one. |
28 // pending, we only store the new callback and do nothing else. | 30 suspend_readiness_callback_.Reset( |
29 if (suspend_readiness_callback_.is_null()) { | 31 base::Bind(&RendererFreezer::OnReadyToSuspend, |
30 // There is no callback pending so post the task. | 32 weak_factory_.GetWeakPtr(), |
31 base::MessageLoop::current()->PostTask( | 33 DBusThreadManager::Get() |
32 FROM_HERE, | 34 ->GetPowerManagerClient() |
33 base::Bind(&RendererFreezer::OnReadyToSuspend, | 35 ->GetSuspendReadinessCallback())); |
34 weak_factory_.GetWeakPtr())); | |
35 } | |
36 | 36 |
37 // Always update the callback because only the most recent one matters. | 37 base::MessageLoop::current()->PostTask( |
38 suspend_readiness_callback_ = DBusThreadManager::Get() | 38 FROM_HERE, suspend_readiness_callback_.callback()); |
39 ->GetPowerManagerClient() | |
40 ->GetSuspendReadinessCallback(); | |
41 } | 39 } |
42 | 40 |
43 void RendererFreezer::SuspendDone(const base::TimeDelta& sleep_duration) { | 41 void RendererFreezer::SuspendDone(const base::TimeDelta& sleep_duration) { |
| 42 // If we get a SuspendDone before we've had a chance to run OnReadyForSuspend, |
| 43 // we should cancel it because we no longer want to freeze the renderers. If |
| 44 // we've already run it then cancelling the callback shouldn't really make a |
| 45 // difference. |
| 46 suspend_readiness_callback_.Cancel(); |
| 47 |
44 if (!frozen_) | 48 if (!frozen_) |
45 return; | 49 return; |
46 | 50 |
47 if (base::WriteFile(state_path_, kThawCommand, strlen(kThawCommand)) != | 51 if (!delegate_->ThawRenderers()) { |
48 static_cast<int>(strlen(kThawCommand))) { | |
49 // We failed to write the thaw command and the renderers are still frozen. | 52 // We failed to write the thaw command and the renderers are still frozen. |
50 // We are in big trouble because none of the tabs will be responsive so | 53 // We are in big trouble because none of the tabs will be responsive so |
51 // let's crash the browser instead. | 54 // let's crash the browser instead. |
52 PLOG(FATAL) << "Unable to thaw processes in the cgroup freezer."; | 55 LOG(FATAL) << "Unable to thaw renderers."; |
53 } | 56 } |
54 | 57 |
55 frozen_ = false; | 58 frozen_ = false; |
56 } | 59 } |
57 | 60 |
58 void RendererFreezer::OnReadyToSuspend() { | 61 void RendererFreezer::OnReadyToSuspend( |
59 if (base::WriteFile(state_path_, kFreezeCommand, strlen(kFreezeCommand)) != | 62 const base::Closure& power_manager_callback) { |
60 static_cast<int>(strlen(kFreezeCommand))) { | 63 if (delegate_->FreezeRenderers()) |
61 PLOG(WARNING) << "Unable to freeze processes in the cgroup freezer."; | |
62 } else { | |
63 frozen_ = true; | 64 frozen_ = true; |
64 } | |
65 | 65 |
66 CHECK(!suspend_readiness_callback_.is_null()); // crbug.com/414396 | 66 DCHECK(!power_manager_callback.is_null()); |
67 suspend_readiness_callback_.Run(); | 67 power_manager_callback.Run(); |
68 suspend_readiness_callback_.Reset(); | |
69 } | |
70 | |
71 RendererFreezer::RendererFreezer() | |
72 : state_path_(base::FilePath(kFreezerStatePath)), | |
73 enabled_(base::PathExists(state_path_) && | |
74 base::PathIsWritable(state_path_)), | |
75 frozen_(false), | |
76 weak_factory_(this) { | |
77 if (enabled_) { | |
78 DBusThreadManager::Get()->GetPowerManagerClient()->AddObserver(this); | |
79 } else { | |
80 LOG(WARNING) << "Cgroup freezer does not exist or is not writable. " | |
81 << "Processes will not be frozen during suspend."; | |
82 } | |
83 } | |
84 | |
85 RendererFreezer::~RendererFreezer() { | |
86 if (enabled_) | |
87 DBusThreadManager::Get()->GetPowerManagerClient()->RemoveObserver(this); | |
88 } | 68 } |
89 | 69 |
90 } // namespace chromeos | 70 } // namespace chromeos |
OLD | NEW |