| 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 241 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 252 void ChromotingHost::OnSessionRouteChange( | 252 void ChromotingHost::OnSessionRouteChange( |
| 253 ClientSession* session, | 253 ClientSession* session, |
| 254 const std::string& channel_name, | 254 const std::string& channel_name, |
| 255 const protocol::TransportRoute& route) { | 255 const protocol::TransportRoute& route) { |
| 256 DCHECK(context_->network_task_runner()->BelongsToCurrentThread()); | 256 DCHECK(context_->network_task_runner()->BelongsToCurrentThread()); |
| 257 FOR_EACH_OBSERVER(HostStatusObserver, status_observers_, | 257 FOR_EACH_OBSERVER(HostStatusObserver, status_observers_, |
| 258 OnClientRouteChange(session->client_jid(), channel_name, | 258 OnClientRouteChange(session->client_jid(), channel_name, |
| 259 route)); | 259 route)); |
| 260 } | 260 } |
| 261 | 261 |
| 262 void ChromotingHost::OnClientDimensionsChanged(const SkISize& size) { |
| 263 DCHECK(context_->network_task_runner()->BelongsToCurrentThread()); |
| 264 FOR_EACH_OBSERVER(HostStatusObserver, status_observers_, |
| 265 OnClientDimensionsChanged(size)); |
| 266 } |
| 267 |
| 262 void ChromotingHost::OnSessionManagerReady() { | 268 void ChromotingHost::OnSessionManagerReady() { |
| 263 DCHECK(context_->network_task_runner()->BelongsToCurrentThread()); | 269 DCHECK(context_->network_task_runner()->BelongsToCurrentThread()); |
| 264 // Don't need to do anything here, just wait for incoming | 270 // Don't need to do anything here, just wait for incoming |
| 265 // connections. | 271 // connections. |
| 266 } | 272 } |
| 267 | 273 |
| 268 void ChromotingHost::OnIncomingSession( | 274 void ChromotingHost::OnIncomingSession( |
| 269 protocol::Session* session, | 275 protocol::Session* session, |
| 270 protocol::SessionManager::IncomingSessionResponse* response) { | 276 protocol::SessionManager::IncomingSessionResponse* response) { |
| 271 DCHECK(context_->network_task_runner()->BelongsToCurrentThread()); | 277 DCHECK(context_->network_task_runner()->BelongsToCurrentThread()); |
| (...skipping 129 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 401 OnShutdown()); | 407 OnShutdown()); |
| 402 | 408 |
| 403 for (std::vector<base::Closure>::iterator it = shutdown_tasks_.begin(); | 409 for (std::vector<base::Closure>::iterator it = shutdown_tasks_.begin(); |
| 404 it != shutdown_tasks_.end(); ++it) { | 410 it != shutdown_tasks_.end(); ++it) { |
| 405 it->Run(); | 411 it->Run(); |
| 406 } | 412 } |
| 407 shutdown_tasks_.clear(); | 413 shutdown_tasks_.clear(); |
| 408 } | 414 } |
| 409 | 415 |
| 410 } // namespace remoting | 416 } // namespace remoting |
| OLD | NEW |