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 "remoting/host/it2me_host_user_interface.h" | 5 #include "remoting/host/it2me_host_user_interface.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "remoting/host/chromoting_host.h" | 8 #include "remoting/host/chromoting_host.h" |
9 #include "remoting/host/chromoting_host_context.h" | 9 #include "remoting/host/chromoting_host_context.h" |
10 #include "remoting/host/continue_window.h" | 10 #include "remoting/host/continue_window.h" |
11 #include "remoting/host/disconnect_window.h" | 11 #include "remoting/host/disconnect_window.h" |
12 #include "remoting/host/local_input_monitor.h" | 12 #include "remoting/host/local_input_monitor.h" |
13 | 13 |
14 namespace { | 14 namespace { |
15 | 15 |
16 // Milliseconds before the continue window is shown. | 16 // Milliseconds before the continue window is shown. |
17 static const int kContinueWindowShowTimeoutMs = 10 * 60 * 1000; | 17 static const int kContinueWindowShowTimeoutMs = 10 * 60 * 1000; |
18 | 18 |
19 // Milliseconds before the continue window is automatically dismissed and | 19 // Milliseconds before the continue window is automatically dismissed and |
20 // the connection is closed. | 20 // the connection is closed. |
21 static const int kContinueWindowHideTimeoutMs = 60 * 1000; | 21 static const int kContinueWindowHideTimeoutMs = 60 * 1000; |
22 | 22 |
23 } // namespace | 23 } // namespace |
24 | 24 |
25 namespace remoting { | 25 namespace remoting { |
26 | 26 |
27 class It2MeHostUserInterface::TimerTask { | |
28 public: | |
29 TimerTask(base::MessageLoopProxy* message_loop, | |
30 const base::Closure& task, | |
31 int delay_ms) | |
32 : thread_proxy_(message_loop) { | |
33 thread_proxy_.PostDelayedTask(FROM_HERE, task, delay_ms); | |
34 } | |
35 | |
36 private: | |
37 ScopedThreadProxy thread_proxy_; | |
38 }; | |
39 | |
40 | |
41 It2MeHostUserInterface::It2MeHostUserInterface(ChromotingHostContext* context) | 27 It2MeHostUserInterface::It2MeHostUserInterface(ChromotingHostContext* context) |
42 : HostUserInterface(context) { | 28 : HostUserInterface(context), |
| 29 ALLOW_THIS_IN_INITIALIZER_LIST(timer_weak_factory_(this)) { |
43 } | 30 } |
44 | 31 |
45 It2MeHostUserInterface::~It2MeHostUserInterface() { | 32 It2MeHostUserInterface::~It2MeHostUserInterface() { |
46 DCHECK(ui_message_loop()->BelongsToCurrentThread()); | 33 DCHECK(ui_message_loop()->BelongsToCurrentThread()); |
47 | 34 |
48 ShowContinueWindow(false); | 35 ShowContinueWindow(false); |
49 StartContinueWindowTimer(false); | |
50 } | 36 } |
51 | 37 |
52 void It2MeHostUserInterface::Start(ChromotingHost* host, | 38 void It2MeHostUserInterface::Start(ChromotingHost* host, |
53 const base::Closure& disconnect_callback) { | 39 const base::Closure& disconnect_callback) { |
54 DCHECK(network_message_loop()->BelongsToCurrentThread()); | 40 DCHECK(network_message_loop()->BelongsToCurrentThread()); |
55 | 41 |
56 HostUserInterface::Start(host, disconnect_callback); | 42 HostUserInterface::Start(host, disconnect_callback); |
57 continue_window_ = ContinueWindow::Create(); | 43 continue_window_ = ContinueWindow::Create(); |
58 } | 44 } |
59 | 45 |
(...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
96 disconnect_window.Pass(), | 82 disconnect_window.Pass(), |
97 local_input_monitor.Pass()); | 83 local_input_monitor.Pass()); |
98 continue_window_ = continue_window.Pass(); | 84 continue_window_ = continue_window.Pass(); |
99 } | 85 } |
100 | 86 |
101 void It2MeHostUserInterface::ContinueSession(bool continue_session) { | 87 void It2MeHostUserInterface::ContinueSession(bool continue_session) { |
102 DCHECK(ui_message_loop()->BelongsToCurrentThread()); | 88 DCHECK(ui_message_loop()->BelongsToCurrentThread()); |
103 | 89 |
104 if (continue_session) { | 90 if (continue_session) { |
105 get_host()->PauseSession(false); | 91 get_host()->PauseSession(false); |
106 timer_task_.reset(); | |
107 StartContinueWindowTimer(true); | 92 StartContinueWindowTimer(true); |
108 } else { | 93 } else { |
109 DisconnectSession(); | 94 DisconnectSession(); |
110 } | 95 } |
111 } | 96 } |
112 | 97 |
113 void It2MeHostUserInterface::OnContinueWindowTimer() { | 98 void It2MeHostUserInterface::OnContinueWindowTimer() { |
114 DCHECK(ui_message_loop()->BelongsToCurrentThread()); | 99 DCHECK(ui_message_loop()->BelongsToCurrentThread()); |
115 | 100 |
116 get_host()->PauseSession(true); | 101 get_host()->PauseSession(true); |
117 ShowContinueWindow(true); | 102 ShowContinueWindow(true); |
118 | 103 |
119 timer_task_.reset(new TimerTask( | 104 // Cancel any pending timer and post one to hide the continue window. |
120 ui_message_loop(), | 105 timer_weak_factory_.InvalidateWeakPtrs(); |
| 106 ui_message_loop()->PostDelayedTask( |
| 107 FROM_HERE, |
121 base::Bind(&It2MeHostUserInterface::OnShutdownHostTimer, | 108 base::Bind(&It2MeHostUserInterface::OnShutdownHostTimer, |
122 base::Unretained(this)), | 109 timer_weak_factory_.GetWeakPtr()), |
123 kContinueWindowHideTimeoutMs)); | 110 kContinueWindowHideTimeoutMs); |
124 } | 111 } |
125 | 112 |
126 void It2MeHostUserInterface::OnShutdownHostTimer() { | 113 void It2MeHostUserInterface::OnShutdownHostTimer() { |
127 DCHECK(ui_message_loop()->BelongsToCurrentThread()); | 114 DCHECK(ui_message_loop()->BelongsToCurrentThread()); |
128 | 115 |
129 ShowContinueWindow(false); | 116 ShowContinueWindow(false); |
130 DisconnectSession(); | 117 DisconnectSession(); |
131 } | 118 } |
132 | 119 |
133 void It2MeHostUserInterface::ShowContinueWindow(bool show) { | 120 void It2MeHostUserInterface::ShowContinueWindow(bool show) { |
134 DCHECK(ui_message_loop()->BelongsToCurrentThread()); | 121 DCHECK(ui_message_loop()->BelongsToCurrentThread()); |
135 | 122 |
136 if (show) { | 123 if (show) { |
137 continue_window_->Show(get_host(), base::Bind( | 124 continue_window_->Show(get_host(), base::Bind( |
138 &It2MeHostUserInterface::ContinueSession, base::Unretained(this))); | 125 &It2MeHostUserInterface::ContinueSession, base::Unretained(this))); |
139 } else { | 126 } else { |
140 continue_window_->Hide(); | 127 continue_window_->Hide(); |
141 } | 128 } |
142 } | 129 } |
143 | 130 |
144 void It2MeHostUserInterface::StartContinueWindowTimer(bool start) { | 131 void It2MeHostUserInterface::StartContinueWindowTimer(bool start) { |
145 DCHECK(ui_message_loop()->BelongsToCurrentThread()); | 132 DCHECK(ui_message_loop()->BelongsToCurrentThread()); |
146 | 133 |
| 134 // Abandon previous timer events by invalidating their weak pointer to us. |
| 135 timer_weak_factory_.InvalidateWeakPtrs(); |
147 if (start) { | 136 if (start) { |
148 timer_task_.reset(new TimerTask( | 137 ui_message_loop()->PostDelayedTask( |
149 ui_message_loop(), | 138 FROM_HERE, |
150 base::Bind(&It2MeHostUserInterface::OnContinueWindowTimer, | 139 base::Bind(&It2MeHostUserInterface::OnContinueWindowTimer, |
151 base::Unretained(this)), | 140 timer_weak_factory_.GetWeakPtr()), |
152 kContinueWindowShowTimeoutMs)); | 141 kContinueWindowShowTimeoutMs); |
153 } else { | |
154 timer_task_.reset(); | |
155 } | 142 } |
156 } | 143 } |
157 | 144 |
158 } // namespace remoting | 145 } // namespace remoting |
OLD | NEW |