OLD | NEW |
1 // Copyright (c) 2013 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2013 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 "net/proxy/proxy_resolver_v8_tracing.h" | 5 #include "net/proxy/proxy_resolver_v8_tracing.h" |
6 | 6 |
7 #include <string> | 7 #include <string> |
8 #include <utility> | 8 #include <utility> |
9 | 9 |
10 #include "base/files/file_util.h" | 10 #include "base/files/file_util.h" |
11 #include "base/memory/ptr_util.h" | 11 #include "base/memory/ptr_util.h" |
12 #include "base/path_service.h" | 12 #include "base/path_service.h" |
13 #include "base/run_loop.h" | 13 #include "base/run_loop.h" |
14 #include "base/strings/utf_string_conversions.h" | 14 #include "base/strings/utf_string_conversions.h" |
15 #include "base/synchronization/waitable_event.h" | 15 #include "base/synchronization/waitable_event.h" |
16 #include "base/threading/platform_thread.h" | 16 #include "base/threading/platform_thread.h" |
17 #include "base/threading/thread_checker.h" | 17 #include "base/threading/thread_checker.h" |
18 #include "base/values.h" | 18 #include "base/values.h" |
19 #include "net/base/net_errors.h" | 19 #include "net/base/net_errors.h" |
20 #include "net/base/test_completion_callback.h" | 20 #include "net/base/test_completion_callback.h" |
21 #include "net/dns/host_cache.h" | 21 #include "net/dns/host_cache.h" |
22 #include "net/dns/mock_host_resolver.h" | 22 #include "net/dns/mock_host_resolver.h" |
23 #include "net/log/net_log.h" | 23 #include "net/log/net_log.h" |
24 #include "net/proxy/proxy_info.h" | 24 #include "net/proxy/proxy_info.h" |
25 #include "net/test/event_waiter.h" | 25 #include "net/test/event_waiter.h" |
| 26 #include "net/test/gtest_util.h" |
| 27 #include "testing/gmock/include/gmock/gmock.h" |
26 #include "testing/gtest/include/gtest/gtest.h" | 28 #include "testing/gtest/include/gtest/gtest.h" |
27 #include "url/gurl.h" | 29 #include "url/gurl.h" |
28 | 30 |
| 31 using net::test::IsError; |
| 32 using net::test::IsOk; |
| 33 |
29 namespace net { | 34 namespace net { |
30 | 35 |
31 namespace { | 36 namespace { |
32 | 37 |
33 class ProxyResolverV8TracingTest : public testing::Test { | 38 class ProxyResolverV8TracingTest : public testing::Test { |
34 public: | 39 public: |
35 void TearDown() override { | 40 void TearDown() override { |
36 // Drain any pending messages, which may be left over from cancellation. | 41 // Drain any pending messages, which may be left over from cancellation. |
37 // This way they get reliably run as part of the current test, rather than | 42 // This way they get reliably run as part of the current test, rather than |
38 // spilling into the next test's execution. | 43 // spilling into the next test's execution. |
(...skipping 100 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
139 std::unique_ptr<ProxyResolverV8Tracing::Bindings> bindings, | 144 std::unique_ptr<ProxyResolverV8Tracing::Bindings> bindings, |
140 const char* filename) { | 145 const char* filename) { |
141 std::unique_ptr<ProxyResolverV8Tracing> resolver; | 146 std::unique_ptr<ProxyResolverV8Tracing> resolver; |
142 std::unique_ptr<ProxyResolverV8TracingFactory> factory( | 147 std::unique_ptr<ProxyResolverV8TracingFactory> factory( |
143 ProxyResolverV8TracingFactory::Create()); | 148 ProxyResolverV8TracingFactory::Create()); |
144 TestCompletionCallback callback; | 149 TestCompletionCallback callback; |
145 std::unique_ptr<ProxyResolverFactory::Request> request; | 150 std::unique_ptr<ProxyResolverFactory::Request> request; |
146 factory->CreateProxyResolverV8Tracing(LoadScriptData(filename), | 151 factory->CreateProxyResolverV8Tracing(LoadScriptData(filename), |
147 std::move(bindings), &resolver, | 152 std::move(bindings), &resolver, |
148 callback.callback(), &request); | 153 callback.callback(), &request); |
149 EXPECT_EQ(OK, callback.WaitForResult()); | 154 EXPECT_THAT(callback.WaitForResult(), IsOk()); |
150 EXPECT_TRUE(resolver); | 155 EXPECT_TRUE(resolver); |
151 return resolver; | 156 return resolver; |
152 } | 157 } |
153 | 158 |
154 TEST_F(ProxyResolverV8TracingTest, Simple) { | 159 TEST_F(ProxyResolverV8TracingTest, Simple) { |
155 MockCachingHostResolver host_resolver; | 160 MockCachingHostResolver host_resolver; |
156 MockBindings mock_bindings(&host_resolver); | 161 MockBindings mock_bindings(&host_resolver); |
157 | 162 |
158 std::unique_ptr<ProxyResolverV8Tracing> resolver = | 163 std::unique_ptr<ProxyResolverV8Tracing> resolver = |
159 CreateResolver(mock_bindings.CreateBindings(), "simple.js"); | 164 CreateResolver(mock_bindings.CreateBindings(), "simple.js"); |
160 | 165 |
161 TestCompletionCallback callback; | 166 TestCompletionCallback callback; |
162 ProxyInfo proxy_info; | 167 ProxyInfo proxy_info; |
163 | 168 |
164 resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info, | 169 resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info, |
165 callback.callback(), NULL, | 170 callback.callback(), NULL, |
166 mock_bindings.CreateBindings()); | 171 mock_bindings.CreateBindings()); |
167 | 172 |
168 EXPECT_EQ(OK, callback.WaitForResult()); | 173 EXPECT_THAT(callback.WaitForResult(), IsOk()); |
169 | 174 |
170 EXPECT_EQ("foo:99", proxy_info.proxy_server().ToURI()); | 175 EXPECT_EQ("foo:99", proxy_info.proxy_server().ToURI()); |
171 | 176 |
172 EXPECT_EQ(0u, host_resolver.num_resolve()); | 177 EXPECT_EQ(0u, host_resolver.num_resolve()); |
173 | 178 |
174 // There were no alerts or errors. | 179 // There were no alerts or errors. |
175 EXPECT_TRUE(mock_bindings.GetAlerts().empty()); | 180 EXPECT_TRUE(mock_bindings.GetAlerts().empty()); |
176 EXPECT_TRUE(mock_bindings.GetErrors().empty()); | 181 EXPECT_TRUE(mock_bindings.GetErrors().empty()); |
177 } | 182 } |
178 | 183 |
179 TEST_F(ProxyResolverV8TracingTest, JavascriptError) { | 184 TEST_F(ProxyResolverV8TracingTest, JavascriptError) { |
180 MockCachingHostResolver host_resolver; | 185 MockCachingHostResolver host_resolver; |
181 MockBindings mock_bindings(&host_resolver); | 186 MockBindings mock_bindings(&host_resolver); |
182 | 187 |
183 std::unique_ptr<ProxyResolverV8Tracing> resolver = | 188 std::unique_ptr<ProxyResolverV8Tracing> resolver = |
184 CreateResolver(mock_bindings.CreateBindings(), "error.js"); | 189 CreateResolver(mock_bindings.CreateBindings(), "error.js"); |
185 | 190 |
186 TestCompletionCallback callback; | 191 TestCompletionCallback callback; |
187 ProxyInfo proxy_info; | 192 ProxyInfo proxy_info; |
188 | 193 |
189 resolver->GetProxyForURL(GURL("http://throw-an-error/"), &proxy_info, | 194 resolver->GetProxyForURL(GURL("http://throw-an-error/"), &proxy_info, |
190 callback.callback(), NULL, | 195 callback.callback(), NULL, |
191 mock_bindings.CreateBindings()); | 196 mock_bindings.CreateBindings()); |
192 | 197 |
193 EXPECT_EQ(ERR_PAC_SCRIPT_FAILED, callback.WaitForResult()); | 198 EXPECT_THAT(callback.WaitForResult(), IsError(ERR_PAC_SCRIPT_FAILED)); |
194 | 199 |
195 EXPECT_EQ(0u, host_resolver.num_resolve()); | 200 EXPECT_EQ(0u, host_resolver.num_resolve()); |
196 | 201 |
197 // Check the output -- there was 1 alert and 1 javascript error. | 202 // Check the output -- there was 1 alert and 1 javascript error. |
198 ASSERT_EQ(1u, mock_bindings.GetAlerts().size()); | 203 ASSERT_EQ(1u, mock_bindings.GetAlerts().size()); |
199 EXPECT_EQ("Prepare to DIE!", mock_bindings.GetAlerts()[0]); | 204 EXPECT_EQ("Prepare to DIE!", mock_bindings.GetAlerts()[0]); |
200 ASSERT_EQ(1u, mock_bindings.GetErrors().size()); | 205 ASSERT_EQ(1u, mock_bindings.GetErrors().size()); |
201 EXPECT_EQ(5, mock_bindings.GetErrors()[0].first); | 206 EXPECT_EQ(5, mock_bindings.GetErrors()[0].first); |
202 EXPECT_EQ("Uncaught TypeError: Cannot read property 'split' of null", | 207 EXPECT_EQ("Uncaught TypeError: Cannot read property 'split' of null", |
203 mock_bindings.GetErrors()[0].second); | 208 mock_bindings.GetErrors()[0].second); |
204 } | 209 } |
205 | 210 |
206 TEST_F(ProxyResolverV8TracingTest, TooManyAlerts) { | 211 TEST_F(ProxyResolverV8TracingTest, TooManyAlerts) { |
207 MockCachingHostResolver host_resolver; | 212 MockCachingHostResolver host_resolver; |
208 MockBindings mock_bindings(&host_resolver); | 213 MockBindings mock_bindings(&host_resolver); |
209 | 214 |
210 std::unique_ptr<ProxyResolverV8Tracing> resolver = | 215 std::unique_ptr<ProxyResolverV8Tracing> resolver = |
211 CreateResolver(mock_bindings.CreateBindings(), "too_many_alerts.js"); | 216 CreateResolver(mock_bindings.CreateBindings(), "too_many_alerts.js"); |
212 | 217 |
213 TestCompletionCallback callback; | 218 TestCompletionCallback callback; |
214 ProxyInfo proxy_info; | 219 ProxyInfo proxy_info; |
215 | 220 |
216 resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info, | 221 resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info, |
217 callback.callback(), NULL, | 222 callback.callback(), NULL, |
218 mock_bindings.CreateBindings()); | 223 mock_bindings.CreateBindings()); |
219 | 224 |
220 EXPECT_EQ(OK, callback.WaitForResult()); | 225 EXPECT_THAT(callback.WaitForResult(), IsOk()); |
221 | 226 |
222 // Iteration1 does a DNS resolve | 227 // Iteration1 does a DNS resolve |
223 // Iteration2 exceeds the alert buffer | 228 // Iteration2 exceeds the alert buffer |
224 // Iteration3 runs in blocking mode and completes | 229 // Iteration3 runs in blocking mode and completes |
225 EXPECT_EQ("foo:3", proxy_info.proxy_server().ToURI()); | 230 EXPECT_EQ("foo:3", proxy_info.proxy_server().ToURI()); |
226 | 231 |
227 EXPECT_EQ(1u, host_resolver.num_resolve()); | 232 EXPECT_EQ(1u, host_resolver.num_resolve()); |
228 | 233 |
229 // No errors. | 234 // No errors. |
230 EXPECT_TRUE(mock_bindings.GetErrors().empty()); | 235 EXPECT_TRUE(mock_bindings.GetErrors().empty()); |
(...skipping 15 matching lines...) Expand all Loading... |
246 std::unique_ptr<ProxyResolverV8Tracing> resolver = CreateResolver( | 251 std::unique_ptr<ProxyResolverV8Tracing> resolver = CreateResolver( |
247 mock_bindings.CreateBindings(), "too_many_empty_alerts.js"); | 252 mock_bindings.CreateBindings(), "too_many_empty_alerts.js"); |
248 | 253 |
249 TestCompletionCallback callback; | 254 TestCompletionCallback callback; |
250 ProxyInfo proxy_info; | 255 ProxyInfo proxy_info; |
251 | 256 |
252 resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info, | 257 resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info, |
253 callback.callback(), NULL, | 258 callback.callback(), NULL, |
254 mock_bindings.CreateBindings()); | 259 mock_bindings.CreateBindings()); |
255 | 260 |
256 EXPECT_EQ(OK, callback.WaitForResult()); | 261 EXPECT_THAT(callback.WaitForResult(), IsOk()); |
257 | 262 |
258 EXPECT_EQ("foo:3", proxy_info.proxy_server().ToURI()); | 263 EXPECT_EQ("foo:3", proxy_info.proxy_server().ToURI()); |
259 | 264 |
260 EXPECT_EQ(1u, host_resolver.num_resolve()); | 265 EXPECT_EQ(1u, host_resolver.num_resolve()); |
261 | 266 |
262 // No errors. | 267 // No errors. |
263 EXPECT_TRUE(mock_bindings.GetErrors().empty()); | 268 EXPECT_TRUE(mock_bindings.GetErrors().empty()); |
264 | 269 |
265 // Check the alerts -- the script generated 1000 alerts. | 270 // Check the alerts -- the script generated 1000 alerts. |
266 std::vector<std::string> alerts = mock_bindings.GetAlerts(); | 271 std::vector<std::string> alerts = mock_bindings.GetAlerts(); |
(...skipping 25 matching lines...) Expand all Loading... |
292 std::unique_ptr<ProxyResolverV8Tracing> resolver = | 297 std::unique_ptr<ProxyResolverV8Tracing> resolver = |
293 CreateResolver(mock_bindings.CreateBindings(), "dns.js"); | 298 CreateResolver(mock_bindings.CreateBindings(), "dns.js"); |
294 | 299 |
295 TestCompletionCallback callback; | 300 TestCompletionCallback callback; |
296 ProxyInfo proxy_info; | 301 ProxyInfo proxy_info; |
297 | 302 |
298 resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info, | 303 resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info, |
299 callback.callback(), NULL, | 304 callback.callback(), NULL, |
300 mock_bindings.CreateBindings()); | 305 mock_bindings.CreateBindings()); |
301 | 306 |
302 EXPECT_EQ(OK, callback.WaitForResult()); | 307 EXPECT_THAT(callback.WaitForResult(), IsOk()); |
303 | 308 |
304 // The test does 13 DNS resolution, however only 7 of them are unique. | 309 // The test does 13 DNS resolution, however only 7 of them are unique. |
305 EXPECT_EQ(7u, host_resolver.num_resolve()); | 310 EXPECT_EQ(7u, host_resolver.num_resolve()); |
306 | 311 |
307 const char* kExpectedResult = | 312 const char* kExpectedResult = |
308 "122.133.144.155-" // myIpAddress() | 313 "122.133.144.155-" // myIpAddress() |
309 "null-" // dnsResolve('') | 314 "null-" // dnsResolve('') |
310 "__1_192.168.1.1-" // dnsResolveEx('host1') | 315 "__1_192.168.1.1-" // dnsResolveEx('host1') |
311 "null-" // dnsResolve('host2') | 316 "null-" // dnsResolve('host2') |
312 "166.155.144.33-" // dnsResolve('host3') | 317 "166.155.144.33-" // dnsResolve('host3') |
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
344 CreateResolver(mock_bindings.CreateBindings(), "simple_dns.js"); | 349 CreateResolver(mock_bindings.CreateBindings(), "simple_dns.js"); |
345 | 350 |
346 TestCompletionCallback callback1; | 351 TestCompletionCallback callback1; |
347 TestCompletionCallback callback2; | 352 TestCompletionCallback callback2; |
348 ProxyInfo proxy_info; | 353 ProxyInfo proxy_info; |
349 | 354 |
350 resolver->GetProxyForURL(GURL("http://foopy/req1"), &proxy_info, | 355 resolver->GetProxyForURL(GURL("http://foopy/req1"), &proxy_info, |
351 callback1.callback(), NULL, | 356 callback1.callback(), NULL, |
352 mock_bindings.CreateBindings()); | 357 mock_bindings.CreateBindings()); |
353 | 358 |
354 EXPECT_EQ(OK, callback1.WaitForResult()); | 359 EXPECT_THAT(callback1.WaitForResult(), IsOk()); |
355 | 360 |
356 // The test does 2 DNS resolutions. | 361 // The test does 2 DNS resolutions. |
357 EXPECT_EQ(2u, host_resolver.num_resolve()); | 362 EXPECT_EQ(2u, host_resolver.num_resolve()); |
358 | 363 |
359 // The first request took 2 restarts, hence on g_iteration=3. | 364 // The first request took 2 restarts, hence on g_iteration=3. |
360 EXPECT_EQ("166.155.144.11:3", proxy_info.proxy_server().ToURI()); | 365 EXPECT_EQ("166.155.144.11:3", proxy_info.proxy_server().ToURI()); |
361 | 366 |
362 resolver->GetProxyForURL(GURL("http://foopy/req2"), &proxy_info, | 367 resolver->GetProxyForURL(GURL("http://foopy/req2"), &proxy_info, |
363 callback2.callback(), NULL, | 368 callback2.callback(), NULL, |
364 mock_bindings.CreateBindings()); | 369 mock_bindings.CreateBindings()); |
365 | 370 |
366 EXPECT_EQ(OK, callback2.WaitForResult()); | 371 EXPECT_THAT(callback2.WaitForResult(), IsOk()); |
367 | 372 |
368 EXPECT_EQ(4u, host_resolver.num_resolve()); | 373 EXPECT_EQ(4u, host_resolver.num_resolve()); |
369 | 374 |
370 // This time no restarts were required, so g_iteration incremented by 1. | 375 // This time no restarts were required, so g_iteration incremented by 1. |
371 EXPECT_EQ("166.155.144.11:4", proxy_info.proxy_server().ToURI()); | 376 EXPECT_EQ("166.155.144.11:4", proxy_info.proxy_server().ToURI()); |
372 | 377 |
373 // There were no alerts or errors. | 378 // There were no alerts or errors. |
374 EXPECT_TRUE(mock_bindings.GetAlerts().empty()); | 379 EXPECT_TRUE(mock_bindings.GetAlerts().empty()); |
375 EXPECT_TRUE(mock_bindings.GetErrors().empty()); | 380 EXPECT_TRUE(mock_bindings.GetErrors().empty()); |
376 } | 381 } |
(...skipping 11 matching lines...) Expand all Loading... |
388 | 393 |
389 std::unique_ptr<ProxyResolverV8Tracing> resolver = | 394 std::unique_ptr<ProxyResolverV8Tracing> resolver = |
390 CreateResolver(mock_bindings.CreateBindings(), "global_sideffects1.js"); | 395 CreateResolver(mock_bindings.CreateBindings(), "global_sideffects1.js"); |
391 | 396 |
392 TestCompletionCallback callback; | 397 TestCompletionCallback callback; |
393 ProxyInfo proxy_info; | 398 ProxyInfo proxy_info; |
394 | 399 |
395 resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info, | 400 resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info, |
396 callback.callback(), NULL, | 401 callback.callback(), NULL, |
397 mock_bindings.CreateBindings()); | 402 mock_bindings.CreateBindings()); |
398 EXPECT_EQ(OK, callback.WaitForResult()); | 403 EXPECT_THAT(callback.WaitForResult(), IsOk()); |
399 | 404 |
400 // The script itself only does 2 DNS resolves per execution, however it | 405 // The script itself only does 2 DNS resolves per execution, however it |
401 // constructs the hostname using a global counter which changes on each | 406 // constructs the hostname using a global counter which changes on each |
402 // invocation. | 407 // invocation. |
403 EXPECT_EQ(3u, host_resolver.num_resolve()); | 408 EXPECT_EQ(3u, host_resolver.num_resolve()); |
404 | 409 |
405 EXPECT_EQ("166.155.144.11-133.199.111.4:100", | 410 EXPECT_EQ("166.155.144.11-133.199.111.4:100", |
406 proxy_info.proxy_server().ToURI()); | 411 proxy_info.proxy_server().ToURI()); |
407 | 412 |
408 // No errors. | 413 // No errors. |
(...skipping 18 matching lines...) Expand all Loading... |
427 | 432 |
428 std::unique_ptr<ProxyResolverV8Tracing> resolver = | 433 std::unique_ptr<ProxyResolverV8Tracing> resolver = |
429 CreateResolver(mock_bindings.CreateBindings(), "global_sideffects2.js"); | 434 CreateResolver(mock_bindings.CreateBindings(), "global_sideffects2.js"); |
430 | 435 |
431 TestCompletionCallback callback; | 436 TestCompletionCallback callback; |
432 ProxyInfo proxy_info; | 437 ProxyInfo proxy_info; |
433 | 438 |
434 resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info, | 439 resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info, |
435 callback.callback(), NULL, | 440 callback.callback(), NULL, |
436 mock_bindings.CreateBindings()); | 441 mock_bindings.CreateBindings()); |
437 EXPECT_EQ(OK, callback.WaitForResult()); | 442 EXPECT_THAT(callback.WaitForResult(), IsOk()); |
438 | 443 |
439 EXPECT_EQ(3u, host_resolver.num_resolve()); | 444 EXPECT_EQ(3u, host_resolver.num_resolve()); |
440 | 445 |
441 EXPECT_EQ("166.155.144.44:100", proxy_info.proxy_server().ToURI()); | 446 EXPECT_EQ("166.155.144.44:100", proxy_info.proxy_server().ToURI()); |
442 | 447 |
443 // There were no alerts or errors. | 448 // There were no alerts or errors. |
444 EXPECT_TRUE(mock_bindings.GetAlerts().empty()); | 449 EXPECT_TRUE(mock_bindings.GetAlerts().empty()); |
445 EXPECT_TRUE(mock_bindings.GetErrors().empty()); | 450 EXPECT_TRUE(mock_bindings.GetErrors().empty()); |
446 } | 451 } |
447 | 452 |
(...skipping 10 matching lines...) Expand all Loading... |
458 | 463 |
459 std::unique_ptr<ProxyResolverV8Tracing> resolver = | 464 std::unique_ptr<ProxyResolverV8Tracing> resolver = |
460 CreateResolver(mock_bindings.CreateBindings(), "global_sideffects3.js"); | 465 CreateResolver(mock_bindings.CreateBindings(), "global_sideffects3.js"); |
461 | 466 |
462 TestCompletionCallback callback; | 467 TestCompletionCallback callback; |
463 ProxyInfo proxy_info; | 468 ProxyInfo proxy_info; |
464 | 469 |
465 resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info, | 470 resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info, |
466 callback.callback(), NULL, | 471 callback.callback(), NULL, |
467 mock_bindings.CreateBindings()); | 472 mock_bindings.CreateBindings()); |
468 EXPECT_EQ(OK, callback.WaitForResult()); | 473 EXPECT_THAT(callback.WaitForResult(), IsOk()); |
469 | 474 |
470 EXPECT_EQ(20u, host_resolver.num_resolve()); | 475 EXPECT_EQ(20u, host_resolver.num_resolve()); |
471 | 476 |
472 EXPECT_EQ( | 477 EXPECT_EQ( |
473 "166.155.144.11-166.155.144.11-166.155.144.11-166.155.144.11-" | 478 "166.155.144.11-166.155.144.11-166.155.144.11-166.155.144.11-" |
474 "166.155.144.11-166.155.144.11-166.155.144.11-166.155.144.11-" | 479 "166.155.144.11-166.155.144.11-166.155.144.11-166.155.144.11-" |
475 "166.155.144.11-166.155.144.11-166.155.144.11-166.155.144.11-" | 480 "166.155.144.11-166.155.144.11-166.155.144.11-166.155.144.11-" |
476 "166.155.144.11-166.155.144.11-166.155.144.11-166.155.144.11-" | 481 "166.155.144.11-166.155.144.11-166.155.144.11-166.155.144.11-" |
477 "166.155.144.11-166.155.144.11-166.155.144.11-166.155.144.11-" | 482 "166.155.144.11-166.155.144.11-166.155.144.11-166.155.144.11-" |
478 "null:21", proxy_info.proxy_server().ToURI()); | 483 "null:21", proxy_info.proxy_server().ToURI()); |
(...skipping 19 matching lines...) Expand all Loading... |
498 | 503 |
499 std::unique_ptr<ProxyResolverV8Tracing> resolver = | 504 std::unique_ptr<ProxyResolverV8Tracing> resolver = |
500 CreateResolver(mock_bindings.CreateBindings(), "global_sideffects4.js"); | 505 CreateResolver(mock_bindings.CreateBindings(), "global_sideffects4.js"); |
501 | 506 |
502 TestCompletionCallback callback; | 507 TestCompletionCallback callback; |
503 ProxyInfo proxy_info; | 508 ProxyInfo proxy_info; |
504 | 509 |
505 resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info, | 510 resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info, |
506 callback.callback(), NULL, | 511 callback.callback(), NULL, |
507 mock_bindings.CreateBindings()); | 512 mock_bindings.CreateBindings()); |
508 EXPECT_EQ(OK, callback.WaitForResult()); | 513 EXPECT_THAT(callback.WaitForResult(), IsOk()); |
509 | 514 |
510 EXPECT_EQ(20u, host_resolver.num_resolve()); | 515 EXPECT_EQ(20u, host_resolver.num_resolve()); |
511 | 516 |
512 EXPECT_EQ("null21:34", proxy_info.proxy_server().ToURI()); | 517 EXPECT_EQ("null21:34", proxy_info.proxy_server().ToURI()); |
513 | 518 |
514 // No errors. | 519 // No errors. |
515 EXPECT_TRUE(mock_bindings.GetErrors().empty()); | 520 EXPECT_TRUE(mock_bindings.GetErrors().empty()); |
516 | 521 |
517 // 1 alert. | 522 // 1 alert. |
518 EXPECT_EQ(1u, mock_bindings.GetAlerts().size()); | 523 EXPECT_EQ(1u, mock_bindings.GetAlerts().size()); |
(...skipping 19 matching lines...) Expand all Loading... |
538 | 543 |
539 host_resolver.rules()->AddRule("host1", "145.88.13.3"); | 544 host_resolver.rules()->AddRule("host1", "145.88.13.3"); |
540 host_resolver.rules()->AddRule("host2", "137.89.8.45"); | 545 host_resolver.rules()->AddRule("host2", "137.89.8.45"); |
541 | 546 |
542 TestCompletionCallback callback; | 547 TestCompletionCallback callback; |
543 ProxyInfo proxy_info; | 548 ProxyInfo proxy_info; |
544 | 549 |
545 resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info, | 550 resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info, |
546 callback.callback(), NULL, | 551 callback.callback(), NULL, |
547 mock_bindings.CreateBindings()); | 552 mock_bindings.CreateBindings()); |
548 EXPECT_EQ(OK, callback.WaitForResult()); | 553 EXPECT_THAT(callback.WaitForResult(), IsOk()); |
549 | 554 |
550 // Fetched host1 and host2 again, since the ones done during initialization | 555 // Fetched host1 and host2 again, since the ones done during initialization |
551 // should not have been cached. | 556 // should not have been cached. |
552 EXPECT_EQ(4u, host_resolver.num_resolve()); | 557 EXPECT_EQ(4u, host_resolver.num_resolve()); |
553 | 558 |
554 EXPECT_EQ("91.13.12.1-91.13.12.2-145.88.13.3-137.89.8.45:99", | 559 EXPECT_EQ("91.13.12.1-91.13.12.2-145.88.13.3-137.89.8.45:99", |
555 proxy_info.proxy_server().ToURI()); | 560 proxy_info.proxy_server().ToURI()); |
556 | 561 |
557 // 2 alerts. | 562 // 2 alerts. |
558 ASSERT_EQ(2u, mock_bindings.GetAlerts().size()); | 563 ASSERT_EQ(2u, mock_bindings.GetAlerts().size()); |
(...skipping 62 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
621 | 626 |
622 resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info1, | 627 resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info1, |
623 base::Bind(&CrashCallback), &request1, | 628 base::Bind(&CrashCallback), &request1, |
624 mock_bindings.CreateBindings()); | 629 mock_bindings.CreateBindings()); |
625 resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info2, | 630 resolver->GetProxyForURL(GURL("http://foo/"), &proxy_info2, |
626 callback.callback(), &request2, | 631 callback.callback(), &request2, |
627 mock_bindings.CreateBindings()); | 632 mock_bindings.CreateBindings()); |
628 | 633 |
629 resolver->CancelRequest(request1); | 634 resolver->CancelRequest(request1); |
630 | 635 |
631 EXPECT_EQ(OK, callback.WaitForResult()); | 636 EXPECT_THAT(callback.WaitForResult(), IsOk()); |
632 } | 637 } |
633 | 638 |
634 // Cancel a request after it has finished running on the worker thread, and has | 639 // Cancel a request after it has finished running on the worker thread, and has |
635 // posted a task the completion task back to origin thread. | 640 // posted a task the completion task back to origin thread. |
636 TEST_F(ProxyResolverV8TracingTest, CancelWhilePendingCompletionTask) { | 641 TEST_F(ProxyResolverV8TracingTest, CancelWhilePendingCompletionTask) { |
637 MockCachingHostResolver host_resolver; | 642 MockCachingHostResolver host_resolver; |
638 MockBindings mock_bindings(&host_resolver); | 643 MockBindings mock_bindings(&host_resolver); |
639 | 644 |
640 host_resolver.rules()->AddSimulatedFailure("*"); | 645 host_resolver.rules()->AddSimulatedFailure("*"); |
641 | 646 |
(...skipping 15 matching lines...) Expand all Loading... |
657 // the origin thread. | 662 // the origin thread. |
658 mock_bindings.RunOnError(base::Bind(&ProxyResolverV8Tracing::CancelRequest, | 663 mock_bindings.RunOnError(base::Bind(&ProxyResolverV8Tracing::CancelRequest, |
659 base::Unretained(resolver.get()), | 664 base::Unretained(resolver.get()), |
660 request1)); | 665 request1)); |
661 | 666 |
662 // Start another request, to make sure it is able to complete. | 667 // Start another request, to make sure it is able to complete. |
663 resolver->GetProxyForURL(GURL("http://i-have-no-idea-what-im-doing/"), | 668 resolver->GetProxyForURL(GURL("http://i-have-no-idea-what-im-doing/"), |
664 &proxy_info2, callback.callback(), &request2, | 669 &proxy_info2, callback.callback(), &request2, |
665 mock_bindings.CreateBindings()); | 670 mock_bindings.CreateBindings()); |
666 | 671 |
667 EXPECT_EQ(OK, callback.WaitForResult()); | 672 EXPECT_THAT(callback.WaitForResult(), IsOk()); |
668 | 673 |
669 EXPECT_EQ("i-approve-this-message:42", proxy_info2.proxy_server().ToURI()); | 674 EXPECT_EQ("i-approve-this-message:42", proxy_info2.proxy_server().ToURI()); |
670 } | 675 } |
671 | 676 |
672 // This implementation of HostResolver allows blocking until a resolve request | 677 // This implementation of HostResolver allows blocking until a resolve request |
673 // has been received. The resolve requests it receives will never be completed. | 678 // has been received. The resolve requests it receives will never be completed. |
674 class BlockableHostResolver : public HostResolver { | 679 class BlockableHostResolver : public HostResolver { |
675 public: | 680 public: |
676 BlockableHostResolver() | 681 BlockableHostResolver() |
677 : num_cancelled_requests_(0), waiting_for_resolve_(false) {} | 682 : num_cancelled_requests_(0), waiting_for_resolve_(false) {} |
(...skipping 195 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
873 | 878 |
874 std::unique_ptr<ProxyResolverV8TracingFactory> factory( | 879 std::unique_ptr<ProxyResolverV8TracingFactory> factory( |
875 ProxyResolverV8TracingFactory::Create()); | 880 ProxyResolverV8TracingFactory::Create()); |
876 std::unique_ptr<ProxyResolverV8Tracing> resolver; | 881 std::unique_ptr<ProxyResolverV8Tracing> resolver; |
877 std::unique_ptr<ProxyResolverFactory::Request> request; | 882 std::unique_ptr<ProxyResolverFactory::Request> request; |
878 TestCompletionCallback callback; | 883 TestCompletionCallback callback; |
879 factory->CreateProxyResolverV8Tracing( | 884 factory->CreateProxyResolverV8Tracing( |
880 LoadScriptData("error_on_load.js"), mock_bindings.CreateBindings(), | 885 LoadScriptData("error_on_load.js"), mock_bindings.CreateBindings(), |
881 &resolver, callback.callback(), &request); | 886 &resolver, callback.callback(), &request); |
882 | 887 |
883 EXPECT_EQ(ERR_PAC_SCRIPT_FAILED, callback.WaitForResult()); | 888 EXPECT_THAT(callback.WaitForResult(), IsError(ERR_PAC_SCRIPT_FAILED)); |
884 EXPECT_FALSE(resolver); | 889 EXPECT_FALSE(resolver); |
885 } | 890 } |
886 | 891 |
887 // This tests that the execution of a PAC script is terminated when the DNS | 892 // This tests that the execution of a PAC script is terminated when the DNS |
888 // dependencies are missing. If the test fails, then it will hang. | 893 // dependencies are missing. If the test fails, then it will hang. |
889 TEST_F(ProxyResolverV8TracingTest, Terminate) { | 894 TEST_F(ProxyResolverV8TracingTest, Terminate) { |
890 MockCachingHostResolver host_resolver; | 895 MockCachingHostResolver host_resolver; |
891 MockBindings mock_bindings(&host_resolver); | 896 MockBindings mock_bindings(&host_resolver); |
892 | 897 |
893 host_resolver.rules()->AddRule("host1", "182.111.0.222"); | 898 host_resolver.rules()->AddRule("host1", "182.111.0.222"); |
894 host_resolver.rules()->AddRule("host2", "111.33.44.55"); | 899 host_resolver.rules()->AddRule("host2", "111.33.44.55"); |
895 | 900 |
896 std::unique_ptr<ProxyResolverV8Tracing> resolver = | 901 std::unique_ptr<ProxyResolverV8Tracing> resolver = |
897 CreateResolver(mock_bindings.CreateBindings(), "terminate.js"); | 902 CreateResolver(mock_bindings.CreateBindings(), "terminate.js"); |
898 | 903 |
899 TestCompletionCallback callback; | 904 TestCompletionCallback callback; |
900 ProxyInfo proxy_info; | 905 ProxyInfo proxy_info; |
901 | 906 |
902 resolver->GetProxyForURL(GURL("http://foopy/req1"), &proxy_info, | 907 resolver->GetProxyForURL(GURL("http://foopy/req1"), &proxy_info, |
903 callback.callback(), NULL, | 908 callback.callback(), NULL, |
904 mock_bindings.CreateBindings()); | 909 mock_bindings.CreateBindings()); |
905 EXPECT_EQ(OK, callback.WaitForResult()); | 910 EXPECT_THAT(callback.WaitForResult(), IsOk()); |
906 | 911 |
907 // The test does 2 DNS resolutions. | 912 // The test does 2 DNS resolutions. |
908 EXPECT_EQ(2u, host_resolver.num_resolve()); | 913 EXPECT_EQ(2u, host_resolver.num_resolve()); |
909 | 914 |
910 EXPECT_EQ("foopy:3", proxy_info.proxy_server().ToURI()); | 915 EXPECT_EQ("foopy:3", proxy_info.proxy_server().ToURI()); |
911 | 916 |
912 // No errors or alerts. | 917 // No errors or alerts. |
913 EXPECT_TRUE(mock_bindings.GetErrors().empty()); | 918 EXPECT_TRUE(mock_bindings.GetErrors().empty()); |
914 EXPECT_TRUE(mock_bindings.GetAlerts().empty()); | 919 EXPECT_TRUE(mock_bindings.GetAlerts().empty()); |
915 } | 920 } |
(...skipping 80 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
996 "__1_192.168.1.1-" // dnsResolveEx('host1') | 1001 "__1_192.168.1.1-" // dnsResolveEx('host1') |
997 "122.133.144.155-" // myIpAddress() | 1002 "122.133.144.155-" // myIpAddress() |
998 "null-" // dnsResolve('host2') | 1003 "null-" // dnsResolve('host2') |
999 "-" // dnsResolveEx('host6') | 1004 "-" // dnsResolveEx('host6') |
1000 "133.122.100.200-" // myIpAddressEx() | 1005 "133.122.100.200-" // myIpAddressEx() |
1001 "166.155.144.44" // dnsResolve('host1') | 1006 "166.155.144.44" // dnsResolve('host1') |
1002 ":99"; | 1007 ":99"; |
1003 | 1008 |
1004 for (size_t i = 0; i < kNumResults; ++i) { | 1009 for (size_t i = 0; i < kNumResults; ++i) { |
1005 size_t resolver_i = i % kNumResolvers; | 1010 size_t resolver_i = i % kNumResolvers; |
1006 EXPECT_EQ(OK, callback[i].WaitForResult()); | 1011 EXPECT_THAT(callback[i].WaitForResult(), IsOk()); |
1007 | 1012 |
1008 std::string proxy_uri = proxy_info[i].proxy_server().ToURI(); | 1013 std::string proxy_uri = proxy_info[i].proxy_server().ToURI(); |
1009 | 1014 |
1010 if (resolver_i == 0 || resolver_i == 1) { | 1015 if (resolver_i == 0 || resolver_i == 1) { |
1011 EXPECT_EQ(kExpectedForDnsJs, proxy_uri); | 1016 EXPECT_EQ(kExpectedForDnsJs, proxy_uri); |
1012 } else if (resolver_i == 2) { | 1017 } else if (resolver_i == 2) { |
1013 EXPECT_EQ("foo:99", proxy_uri); | 1018 EXPECT_EQ("foo:99", proxy_uri); |
1014 } else if (resolver_i == 3) { | 1019 } else if (resolver_i == 3) { |
1015 EXPECT_EQ("166.155.144.33:", | 1020 EXPECT_EQ("166.155.144.33:", |
1016 proxy_uri.substr(0, proxy_uri.find(':') + 1)); | 1021 proxy_uri.substr(0, proxy_uri.find(':') + 1)); |
1017 } else { | 1022 } else { |
1018 NOTREACHED(); | 1023 NOTREACHED(); |
1019 } | 1024 } |
1020 } | 1025 } |
1021 } | 1026 } |
1022 | 1027 |
1023 } // namespace | 1028 } // namespace |
1024 | 1029 |
1025 } // namespace net | 1030 } // namespace net |
OLD | NEW |