| 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 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 53 false, | 53 false, |
| 54 }; | 54 }; |
| 55 | 55 |
| 56 } // namespace | 56 } // namespace |
| 57 | 57 |
| 58 ChromotingHost::ChromotingHost( | 58 ChromotingHost::ChromotingHost( |
| 59 SignalStrategy* signal_strategy, | 59 SignalStrategy* signal_strategy, |
| 60 DesktopEnvironmentFactory* desktop_environment_factory, | 60 DesktopEnvironmentFactory* desktop_environment_factory, |
| 61 scoped_ptr<protocol::SessionManager> session_manager, | 61 scoped_ptr<protocol::SessionManager> session_manager, |
| 62 scoped_refptr<base::SingleThreadTaskRunner> audio_task_runner, | 62 scoped_refptr<base::SingleThreadTaskRunner> audio_task_runner, |
| 63 scoped_refptr<base::SingleThreadTaskRunner> capture_task_runner, | 63 scoped_refptr<base::SingleThreadTaskRunner> video_capture_task_runner, |
| 64 scoped_refptr<base::SingleThreadTaskRunner> encode_task_runner, | 64 scoped_refptr<base::SingleThreadTaskRunner> video_encode_task_runner, |
| 65 scoped_refptr<base::SingleThreadTaskRunner> network_task_runner) | 65 scoped_refptr<base::SingleThreadTaskRunner> network_task_runner) |
| 66 : desktop_environment_factory_(desktop_environment_factory), | 66 : desktop_environment_factory_(desktop_environment_factory), |
| 67 session_manager_(session_manager.Pass()), | 67 session_manager_(session_manager.Pass()), |
| 68 audio_task_runner_(audio_task_runner), | 68 audio_task_runner_(audio_task_runner), |
| 69 capture_task_runner_(capture_task_runner), | 69 video_capture_task_runner_(video_capture_task_runner), |
| 70 encode_task_runner_(encode_task_runner), | 70 video_encode_task_runner_(video_encode_task_runner), |
| 71 network_task_runner_(network_task_runner), | 71 network_task_runner_(network_task_runner), |
| 72 signal_strategy_(signal_strategy), | 72 signal_strategy_(signal_strategy), |
| 73 clients_count_(0), | 73 clients_count_(0), |
| 74 state_(kInitial), | 74 state_(kInitial), |
| 75 protocol_config_(protocol::CandidateSessionConfig::CreateDefault()), | 75 protocol_config_(protocol::CandidateSessionConfig::CreateDefault()), |
| 76 login_backoff_(&kDefaultBackoffPolicy), | 76 login_backoff_(&kDefaultBackoffPolicy), |
| 77 authenticating_client_(false), | 77 authenticating_client_(false), |
| 78 reject_authenticating_client_(false) { | 78 reject_authenticating_client_(false) { |
| 79 DCHECK(signal_strategy); | 79 DCHECK(signal_strategy); |
| 80 DCHECK(network_task_runner_->BelongsToCurrentThread()); | 80 DCHECK(network_task_runner_->BelongsToCurrentThread()); |
| (...skipping 226 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 307 *response = protocol::SessionManager::ACCEPT; | 307 *response = protocol::SessionManager::ACCEPT; |
| 308 | 308 |
| 309 LOG(INFO) << "Client connected: " << session->jid(); | 309 LOG(INFO) << "Client connected: " << session->jid(); |
| 310 | 310 |
| 311 // Create a client object. | 311 // Create a client object. |
| 312 scoped_ptr<protocol::ConnectionToClient> connection( | 312 scoped_ptr<protocol::ConnectionToClient> connection( |
| 313 new protocol::ConnectionToClient(session)); | 313 new protocol::ConnectionToClient(session)); |
| 314 scoped_refptr<ClientSession> client = new ClientSession( | 314 scoped_refptr<ClientSession> client = new ClientSession( |
| 315 this, | 315 this, |
| 316 audio_task_runner_, | 316 audio_task_runner_, |
| 317 capture_task_runner_, | 317 video_capture_task_runner_, |
| 318 encode_task_runner_, | 318 video_encode_task_runner_, |
| 319 network_task_runner_, | 319 network_task_runner_, |
| 320 connection.Pass(), | 320 connection.Pass(), |
| 321 desktop_environment_factory_, | 321 desktop_environment_factory_, |
| 322 max_session_duration_); | 322 max_session_duration_); |
| 323 clients_.push_back(client); | 323 clients_.push_back(client); |
| 324 clients_count_++; | 324 clients_count_++; |
| 325 } | 325 } |
| 326 | 326 |
| 327 void ChromotingHost::set_protocol_config( | 327 void ChromotingHost::set_protocol_config( |
| 328 scoped_ptr<protocol::CandidateSessionConfig> config) { | 328 scoped_ptr<protocol::CandidateSessionConfig> config) { |
| (...skipping 93 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 422 OnShutdown()); | 422 OnShutdown()); |
| 423 | 423 |
| 424 for (std::vector<base::Closure>::iterator it = shutdown_tasks_.begin(); | 424 for (std::vector<base::Closure>::iterator it = shutdown_tasks_.begin(); |
| 425 it != shutdown_tasks_.end(); ++it) { | 425 it != shutdown_tasks_.end(); ++it) { |
| 426 it->Run(); | 426 it->Run(); |
| 427 } | 427 } |
| 428 shutdown_tasks_.clear(); | 428 shutdown_tasks_.clear(); |
| 429 } | 429 } |
| 430 | 430 |
| 431 } // namespace remoting | 431 } // namespace remoting |
| OLD | NEW |