| 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 |