| OLD | NEW |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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/gcd_state_updater.h" | 5 #include "remoting/host/gcd_state_updater.h" |
| 6 | 6 |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 #include <vector> | 8 #include <vector> |
| 9 | 9 |
| 10 #include "base/strings/stringize_macros.h" | 10 #include "base/strings/stringize_macros.h" |
| (...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 55 scoped_ptr<GcdRestClient> rest_client_; | 55 scoped_ptr<GcdRestClient> rest_client_; |
| 56 FakeSignalStrategy signal_strategy_; | 56 FakeSignalStrategy signal_strategy_; |
| 57 int on_success_count_ = 0; | 57 int on_success_count_ = 0; |
| 58 int on_host_id_error_count_ = 0; | 58 int on_host_id_error_count_ = 0; |
| 59 }; | 59 }; |
| 60 | 60 |
| 61 TEST_F(GcdStateUpdaterTest, Success) { | 61 TEST_F(GcdStateUpdaterTest, Success) { |
| 62 scoped_ptr<GcdStateUpdater> updater(new GcdStateUpdater( | 62 scoped_ptr<GcdStateUpdater> updater(new GcdStateUpdater( |
| 63 base::Bind(&GcdStateUpdaterTest::OnSuccess, base::Unretained(this)), | 63 base::Bind(&GcdStateUpdaterTest::OnSuccess, base::Unretained(this)), |
| 64 base::Bind(&GcdStateUpdaterTest::OnHostIdError, base::Unretained(this)), | 64 base::Bind(&GcdStateUpdaterTest::OnHostIdError, base::Unretained(this)), |
| 65 &signal_strategy_, rest_client_.Pass())); | 65 &signal_strategy_, std::move(rest_client_))); |
| 66 | 66 |
| 67 signal_strategy_.Connect(); | 67 signal_strategy_.Connect(); |
| 68 task_runner_->RunUntilIdle(); | 68 task_runner_->RunUntilIdle(); |
| 69 net::TestURLFetcher* fetcher = url_fetcher_factory_.GetFetcherByID(0); | 69 net::TestURLFetcher* fetcher = url_fetcher_factory_.GetFetcherByID(0); |
| 70 ASSERT_TRUE(fetcher); | 70 ASSERT_TRUE(fetcher); |
| 71 EXPECT_EQ("{\"patches\":[{\"patch\":{" | 71 EXPECT_EQ("{\"patches\":[{\"patch\":{" |
| 72 "\"base\":{\"_hostVersion\":\"" STRINGIZE(VERSION) "\"," | 72 "\"base\":{\"_hostVersion\":\"" STRINGIZE(VERSION) "\"," |
| 73 "\"_jabberId\":\"local_jid\"}}," | 73 "\"_jabberId\":\"local_jid\"}}," |
| 74 "\"timeMs\":0.0}],\"requestTimeMs\":0.0}", | 74 "\"timeMs\":0.0}],\"requestTimeMs\":0.0}", |
| 75 fetcher->upload_data()); | 75 fetcher->upload_data()); |
| 76 fetcher->set_response_code(200); | 76 fetcher->set_response_code(200); |
| 77 fetcher->delegate()->OnURLFetchComplete(fetcher); | 77 fetcher->delegate()->OnURLFetchComplete(fetcher); |
| 78 EXPECT_EQ(1, on_success_count_); | 78 EXPECT_EQ(1, on_success_count_); |
| 79 | 79 |
| 80 updater.reset(); | 80 updater.reset(); |
| 81 | 81 |
| 82 EXPECT_EQ(0, on_host_id_error_count_); | 82 EXPECT_EQ(0, on_host_id_error_count_); |
| 83 } | 83 } |
| 84 | 84 |
| 85 TEST_F(GcdStateUpdaterTest, QueuedRequests) { | 85 TEST_F(GcdStateUpdaterTest, QueuedRequests) { |
| 86 scoped_ptr<GcdStateUpdater> updater(new GcdStateUpdater( | 86 scoped_ptr<GcdStateUpdater> updater(new GcdStateUpdater( |
| 87 base::Bind(&GcdStateUpdaterTest::OnSuccess, base::Unretained(this)), | 87 base::Bind(&GcdStateUpdaterTest::OnSuccess, base::Unretained(this)), |
| 88 base::Bind(&GcdStateUpdaterTest::OnHostIdError, base::Unretained(this)), | 88 base::Bind(&GcdStateUpdaterTest::OnHostIdError, base::Unretained(this)), |
| 89 &signal_strategy_, rest_client_.Pass())); | 89 &signal_strategy_, std::move(rest_client_))); |
| 90 | 90 |
| 91 // Connect, then re-connect with a different JID while the status | 91 // Connect, then re-connect with a different JID while the status |
| 92 // update for the first connection is pending. | 92 // update for the first connection is pending. |
| 93 signal_strategy_.Connect(); | 93 signal_strategy_.Connect(); |
| 94 task_runner_->RunUntilIdle(); | 94 task_runner_->RunUntilIdle(); |
| 95 signal_strategy_.Disconnect(); | 95 signal_strategy_.Disconnect(); |
| 96 task_runner_->RunUntilIdle(); | 96 task_runner_->RunUntilIdle(); |
| 97 signal_strategy_.SetLocalJid("local_jid2"); | 97 signal_strategy_.SetLocalJid("local_jid2"); |
| 98 signal_strategy_.Connect(); | 98 signal_strategy_.Connect(); |
| 99 task_runner_->RunUntilIdle(); | 99 task_runner_->RunUntilIdle(); |
| (...skipping 23 matching lines...) Expand all Loading... |
| 123 | 123 |
| 124 updater.reset(); | 124 updater.reset(); |
| 125 | 125 |
| 126 EXPECT_EQ(0, on_host_id_error_count_); | 126 EXPECT_EQ(0, on_host_id_error_count_); |
| 127 } | 127 } |
| 128 | 128 |
| 129 TEST_F(GcdStateUpdaterTest, Retry) { | 129 TEST_F(GcdStateUpdaterTest, Retry) { |
| 130 scoped_ptr<GcdStateUpdater> updater(new GcdStateUpdater( | 130 scoped_ptr<GcdStateUpdater> updater(new GcdStateUpdater( |
| 131 base::Bind(&GcdStateUpdaterTest::OnSuccess, base::Unretained(this)), | 131 base::Bind(&GcdStateUpdaterTest::OnSuccess, base::Unretained(this)), |
| 132 base::Bind(&GcdStateUpdaterTest::OnHostIdError, base::Unretained(this)), | 132 base::Bind(&GcdStateUpdaterTest::OnHostIdError, base::Unretained(this)), |
| 133 &signal_strategy_, rest_client_.Pass())); | 133 &signal_strategy_, std::move(rest_client_))); |
| 134 | 134 |
| 135 signal_strategy_.Connect(); | 135 signal_strategy_.Connect(); |
| 136 task_runner_->RunUntilIdle(); | 136 task_runner_->RunUntilIdle(); |
| 137 net::TestURLFetcher* fetcher = url_fetcher_factory_.GetFetcherByID(0); | 137 net::TestURLFetcher* fetcher = url_fetcher_factory_.GetFetcherByID(0); |
| 138 ASSERT_TRUE(fetcher); | 138 ASSERT_TRUE(fetcher); |
| 139 fetcher->set_response_code(0); | 139 fetcher->set_response_code(0); |
| 140 fetcher->delegate()->OnURLFetchComplete(fetcher); | 140 fetcher->delegate()->OnURLFetchComplete(fetcher); |
| 141 task_runner_->FastForwardBy(base::TimeDelta::FromSeconds(1)); | 141 task_runner_->FastForwardBy(base::TimeDelta::FromSeconds(1)); |
| 142 EXPECT_EQ(1.0, clock_->Now().ToDoubleT()); | 142 EXPECT_EQ(1.0, clock_->Now().ToDoubleT()); |
| 143 fetcher = url_fetcher_factory_.GetFetcherByID(0); | 143 fetcher = url_fetcher_factory_.GetFetcherByID(0); |
| 144 ASSERT_TRUE(fetcher); | 144 ASSERT_TRUE(fetcher); |
| 145 fetcher->set_response_code(200); | 145 fetcher->set_response_code(200); |
| 146 fetcher->delegate()->OnURLFetchComplete(fetcher); | 146 fetcher->delegate()->OnURLFetchComplete(fetcher); |
| 147 EXPECT_EQ(1, on_success_count_); | 147 EXPECT_EQ(1, on_success_count_); |
| 148 | 148 |
| 149 updater.reset(); | 149 updater.reset(); |
| 150 | 150 |
| 151 EXPECT_EQ(0, on_host_id_error_count_); | 151 EXPECT_EQ(0, on_host_id_error_count_); |
| 152 } | 152 } |
| 153 | 153 |
| 154 TEST_F(GcdStateUpdaterTest, UnknownHost) { | 154 TEST_F(GcdStateUpdaterTest, UnknownHost) { |
| 155 scoped_ptr<GcdStateUpdater> updater(new GcdStateUpdater( | 155 scoped_ptr<GcdStateUpdater> updater(new GcdStateUpdater( |
| 156 base::Bind(&GcdStateUpdaterTest::OnSuccess, base::Unretained(this)), | 156 base::Bind(&GcdStateUpdaterTest::OnSuccess, base::Unretained(this)), |
| 157 base::Bind(&GcdStateUpdaterTest::OnHostIdError, base::Unretained(this)), | 157 base::Bind(&GcdStateUpdaterTest::OnHostIdError, base::Unretained(this)), |
| 158 &signal_strategy_, rest_client_.Pass())); | 158 &signal_strategy_, std::move(rest_client_))); |
| 159 | 159 |
| 160 signal_strategy_.Connect(); | 160 signal_strategy_.Connect(); |
| 161 task_runner_->RunUntilIdle(); | 161 task_runner_->RunUntilIdle(); |
| 162 net::TestURLFetcher* fetcher = url_fetcher_factory_.GetFetcherByID(0); | 162 net::TestURLFetcher* fetcher = url_fetcher_factory_.GetFetcherByID(0); |
| 163 ASSERT_TRUE(fetcher); | 163 ASSERT_TRUE(fetcher); |
| 164 fetcher->set_response_code(404); | 164 fetcher->set_response_code(404); |
| 165 fetcher->delegate()->OnURLFetchComplete(fetcher); | 165 fetcher->delegate()->OnURLFetchComplete(fetcher); |
| 166 EXPECT_EQ(0, on_success_count_); | 166 EXPECT_EQ(0, on_success_count_); |
| 167 EXPECT_EQ(1, on_host_id_error_count_); | 167 EXPECT_EQ(1, on_host_id_error_count_); |
| 168 } | 168 } |
| 169 | 169 |
| 170 } // namespace remoting | 170 } // namespace remoting |
| OLD | NEW |