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/chromoting_host.h" | 5 #include "remoting/host/chromoting_host.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/callback.h" | 8 #include "base/callback.h" |
9 #include "base/logging.h" | 9 #include "base/logging.h" |
10 #include "base/message_loop_proxy.h" | 10 #include "base/message_loop_proxy.h" |
(...skipping 249 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
260 void ChromotingHost::OnSessionRouteChange( | 260 void ChromotingHost::OnSessionRouteChange( |
261 ClientSession* session, | 261 ClientSession* session, |
262 const std::string& channel_name, | 262 const std::string& channel_name, |
263 const protocol::TransportRoute& route) { | 263 const protocol::TransportRoute& route) { |
264 DCHECK(network_task_runner_->BelongsToCurrentThread()); | 264 DCHECK(network_task_runner_->BelongsToCurrentThread()); |
265 FOR_EACH_OBSERVER(HostStatusObserver, status_observers_, | 265 FOR_EACH_OBSERVER(HostStatusObserver, status_observers_, |
266 OnClientRouteChange(session->client_jid(), channel_name, | 266 OnClientRouteChange(session->client_jid(), channel_name, |
267 route)); | 267 route)); |
268 } | 268 } |
269 | 269 |
270 void ChromotingHost::OnClientResolutionChanged(ClientSession* session, | |
271 const SkISize& size, | |
272 const SkIPoint& dpi) { | |
273 DCHECK(network_task_runner_->BelongsToCurrentThread()); | |
274 FOR_EACH_OBSERVER(HostStatusObserver, status_observers_, | |
275 OnClientResolutionChanged(session->client_jid(), | |
276 size, dpi)); | |
277 } | |
278 | |
279 void ChromotingHost::OnSessionManagerReady() { | 270 void ChromotingHost::OnSessionManagerReady() { |
280 DCHECK(network_task_runner_->BelongsToCurrentThread()); | 271 DCHECK(network_task_runner_->BelongsToCurrentThread()); |
281 // Don't need to do anything here, just wait for incoming | 272 // Don't need to do anything here, just wait for incoming |
282 // connections. | 273 // connections. |
283 } | 274 } |
284 | 275 |
285 void ChromotingHost::OnIncomingSession( | 276 void ChromotingHost::OnIncomingSession( |
286 protocol::Session* session, | 277 protocol::Session* session, |
287 protocol::SessionManager::IncomingSessionResponse* response) { | 278 protocol::SessionManager::IncomingSessionResponse* response) { |
288 DCHECK(network_task_runner_->BelongsToCurrentThread()); | 279 DCHECK(network_task_runner_->BelongsToCurrentThread()); |
(...skipping 119 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
408 for (std::vector<base::Closure>::iterator it = shutdown_tasks_.begin(); | 399 for (std::vector<base::Closure>::iterator it = shutdown_tasks_.begin(); |
409 it != shutdown_tasks_.end(); ++it) { | 400 it != shutdown_tasks_.end(); ++it) { |
410 it->Run(); | 401 it->Run(); |
411 } | 402 } |
412 shutdown_tasks_.clear(); | 403 shutdown_tasks_.clear(); |
413 | 404 |
414 weak_factory_.InvalidateWeakPtrs(); | 405 weak_factory_.InvalidateWeakPtrs(); |
415 } | 406 } |
416 | 407 |
417 } // namespace remoting | 408 } // namespace remoting |
OLD | NEW |