| Index: remoting/host/chromoting_host_unittest.cc
|
| diff --git a/remoting/host/chromoting_host_unittest.cc b/remoting/host/chromoting_host_unittest.cc
|
| index 2a4920b4320c2c092f4574047211331575ec488b..784f8ff6b0c3391d88805dc860921cf4db43b98d 100644
|
| --- a/remoting/host/chromoting_host_unittest.cc
|
| +++ b/remoting/host/chromoting_host_unittest.cc
|
| @@ -67,7 +67,7 @@ class ChromotingHostTest : public testing::Test {
|
| }
|
|
|
| virtual void SetUp() OVERRIDE {
|
| - ui_task_runner_ = new AutoThreadTaskRunner(
|
| + task_runner_ = new AutoThreadTaskRunner(
|
| message_loop_.message_loop_proxy(),
|
| base::Bind(&ChromotingHostTest::QuitMainMessageLoop,
|
| base::Unretained(this)));
|
| @@ -83,16 +83,16 @@ class ChromotingHostTest : public testing::Test {
|
|
|
| session_manager_ = new protocol::MockSessionManager();
|
|
|
| - host_ = new ChromotingHost(
|
| + host_.reset(new ChromotingHost(
|
| &signal_strategy_,
|
| desktop_environment_factory_.get(),
|
| scoped_ptr<protocol::SessionManager>(session_manager_),
|
| - ui_task_runner_, // Audio
|
| - ui_task_runner_, // Input
|
| - ui_task_runner_, // Video capture
|
| - ui_task_runner_, // Video encode
|
| - ui_task_runner_, // Network
|
| - ui_task_runner_); // UI
|
| + task_runner_, // Audio
|
| + task_runner_, // Input
|
| + task_runner_, // Video capture
|
| + task_runner_, // Video encode
|
| + task_runner_, // Network
|
| + task_runner_)); // UI
|
| host_->AddStatusObserver(&host_status_observer_);
|
|
|
| xmpp_login_ = "host@domain";
|
| @@ -182,41 +182,40 @@ class ChromotingHostTest : public testing::Test {
|
| protocol::ConnectionToClient* connection_ptr = connection.get();
|
| scoped_ptr<ClientSession> client(new ClientSession(
|
| host_.get(),
|
| - ui_task_runner_, // Audio
|
| - ui_task_runner_, // Input
|
| - ui_task_runner_, // Video capture
|
| - ui_task_runner_, // Video encode
|
| - ui_task_runner_, // Network
|
| - ui_task_runner_, // UI
|
| + task_runner_, // Audio
|
| + task_runner_, // Input
|
| + task_runner_, // Video capture
|
| + task_runner_, // Video encode
|
| + task_runner_, // Network
|
| + task_runner_, // UI
|
| connection.Pass(),
|
| desktop_environment_factory_.get(),
|
| base::TimeDelta()));
|
|
|
| - ClientSession* client_raw = client.get();
|
| - connection_ptr->set_host_stub(client_raw);
|
| -
|
| - ui_task_runner_->PostTask(
|
| - FROM_HERE, base::Bind(&ChromotingHostTest::AddClientToHost,
|
| - host_, base::Passed(&client)));
|
| + connection_ptr->set_host_stub(client.get());
|
|
|
| if (authenticate) {
|
| - ui_task_runner_->PostTask(
|
| - FROM_HERE, base::Bind(&ClientSession::OnConnectionAuthenticated,
|
| - base::Unretained(client_raw), connection_ptr));
|
| + task_runner_->PostTask(
|
| + FROM_HERE,
|
| + base::Bind(&ClientSession::OnConnectionAuthenticated,
|
| + base::Unretained(client.get()), connection_ptr));
|
| if (!reject) {
|
| - ui_task_runner_->PostTask(
|
| + task_runner_->PostTask(
|
| FROM_HERE,
|
| base::Bind(&ClientSession::OnConnectionChannelsConnected,
|
| - base::Unretained(client_raw), connection_ptr));
|
| + base::Unretained(client.get()), connection_ptr));
|
| }
|
| } else {
|
| - ui_task_runner_->PostTask(
|
| + task_runner_->PostTask(
|
| FROM_HERE, base::Bind(&ClientSession::OnConnectionClosed,
|
| - base::Unretained(client_raw), connection_ptr,
|
| + base::Unretained(client.get()), connection_ptr,
|
| protocol::AUTHENTICATION_FAILED));
|
| }
|
|
|
| - get_client(connection_index) = client_raw;
|
| + get_client(connection_index) = client.get();
|
| +
|
| + // |host| is responsible for deleting |client| from now on.
|
| + host_->clients_.push_back(client.release());
|
| }
|
|
|
| virtual void TearDown() OVERRIDE {
|
| @@ -292,23 +291,16 @@ class ChromotingHostTest : public testing::Test {
|
| }
|
| }
|
|
|
| - static void AddClientToHost(scoped_refptr<ChromotingHost> host,
|
| - scoped_ptr<ClientSession> client) {
|
| - // |host| is responsible for deleting |client| from now on.
|
| - host->clients_.push_back(client.release());
|
| - }
|
| -
|
| void ShutdownHost() {
|
| - ui_task_runner_->PostTask(
|
| + task_runner_->PostTask(
|
| FROM_HERE,
|
| - base::Bind(&ChromotingHost::Shutdown, host_,
|
| - base::Bind(&ChromotingHostTest::ReleaseUiTaskRunner,
|
| - base::Unretained(this))));
|
| + base::Bind(&ChromotingHostTest::StopAndReleaseTaskRunner,
|
| + base::Unretained(this)));
|
| }
|
|
|
| - void ReleaseUiTaskRunner() {
|
| - ui_task_runner_ = NULL;
|
| - host_ = NULL;
|
| + void StopAndReleaseTaskRunner() {
|
| + host_.reset();
|
| + task_runner_ = NULL;
|
| desktop_environment_factory_.reset();
|
| }
|
|
|
| @@ -394,11 +386,11 @@ class ChromotingHostTest : public testing::Test {
|
|
|
| protected:
|
| MessageLoop message_loop_;
|
| - scoped_refptr<AutoThreadTaskRunner> ui_task_runner_;
|
| + scoped_refptr<AutoThreadTaskRunner> task_runner_;
|
| MockConnectionToClientEventHandler handler_;
|
| MockSignalStrategy signal_strategy_;
|
| scoped_ptr<MockDesktopEnvironmentFactory> desktop_environment_factory_;
|
| - scoped_refptr<ChromotingHost> host_;
|
| + scoped_ptr<ChromotingHost> host_;
|
| MockHostStatusObserver host_status_observer_;
|
| protocol::MockSessionManager* session_manager_;
|
| std::string xmpp_login_;
|
|
|