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 |