| 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 <stdint.h> | 5 #include <stdint.h> |
| 6 | 6 |
| 7 #include "base/base64.h" | 7 #include "base/base64.h" |
| 8 #include "base/command_line.h" | 8 #include "base/command_line.h" |
| 9 #include "base/json/json_string_value_serializer.h" | 9 #include "base/json/json_string_value_serializer.h" |
| 10 #include "base/macros.h" | 10 #include "base/macros.h" |
| (...skipping 85 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 96 return read_sockets; | 96 return read_sockets; |
| 97 } | 97 } |
| 98 | 98 |
| 99 void WaitUntilFirstConnectionAccepted() { accept_loop_.Run(); } | 99 void WaitUntilFirstConnectionAccepted() { accept_loop_.Run(); } |
| 100 | 100 |
| 101 void WaitUntilFirstConnectionRead() { read_loop_.Run(); } | 101 void WaitUntilFirstConnectionRead() { read_loop_.Run(); } |
| 102 | 102 |
| 103 private: | 103 private: |
| 104 static uint16_t GetPort( | 104 static uint16_t GetPort( |
| 105 const net::test_server::StreamListenSocket& connection) { | 105 const net::test_server::StreamListenSocket& connection) { |
| 106 // Get the remote port of the peer, since the local port will always be the |
| 107 // port the test server is listening on. This isn't strictly correct - it's |
| 108 // possible for multiple peers to connect with the same remote port but |
| 109 // different remote IPs - but the tests here assume that connections to the |
| 110 // test server (running on localhost) will always come from localhost, and |
| 111 // thus the peer port is all thats needed to distinguish two connections. |
| 112 // This also would be problematic if the OS reused ports, but that's not |
| 113 // something to worry about for these tests. |
| 106 net::IPEndPoint address; | 114 net::IPEndPoint address; |
| 107 EXPECT_EQ(net::OK, connection.GetLocalAddress(&address)); | 115 EXPECT_EQ(net::OK, connection.GetPeerAddress(&address)); |
| 108 return address.port(); | 116 return address.port(); |
| 109 } | 117 } |
| 110 | 118 |
| 111 enum SocketStatus { SOCKET_ACCEPTED, SOCKET_READ_FROM }; | 119 enum SocketStatus { SOCKET_ACCEPTED, SOCKET_READ_FROM }; |
| 112 | 120 |
| 113 typedef base::hash_map<uint16_t, SocketStatus> SocketContainer; | 121 typedef base::hash_map<uint16_t, SocketStatus> SocketContainer; |
| 114 SocketContainer sockets_; | 122 SocketContainer sockets_; |
| 115 | 123 |
| 116 base::RunLoop accept_loop_; | 124 base::RunLoop accept_loop_; |
| 117 base::RunLoop read_loop_; | 125 base::RunLoop read_loop_; |
| (...skipping 225 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 343 browser(), | 351 browser(), |
| 344 GURL(test_server()->GetURL("files/predictor/dns_prefetch.html"))); | 352 GURL(test_server()->GetURL("files/predictor/dns_prefetch.html"))); |
| 345 WaitUntilHostHasBeenRequested(kChromiumHostname); | 353 WaitUntilHostHasBeenRequested(kChromiumHostname); |
| 346 ASSERT_FALSE(HasHostBeenRequested(kInvalidLongHostname)); | 354 ASSERT_FALSE(HasHostBeenRequested(kInvalidLongHostname)); |
| 347 ASSERT_EQ(hostnames_requested_before_load + 1, RequestedHostnameCount()); | 355 ASSERT_EQ(hostnames_requested_before_load + 1, RequestedHostnameCount()); |
| 348 } | 356 } |
| 349 | 357 |
| 350 // Tests that preconnect warms up a socket connection to a test server. | 358 // Tests that preconnect warms up a socket connection to a test server. |
| 351 // Note: This test uses a data URI to serve the preconnect hint, to make sure | 359 // Note: This test uses a data URI to serve the preconnect hint, to make sure |
| 352 // that the network stack doesn't just re-use its connection to the test server. | 360 // that the network stack doesn't just re-use its connection to the test server. |
| 353 IN_PROC_BROWSER_TEST_F(PredictorBrowserTest, Preconnect) { | 361 IN_PROC_BROWSER_TEST_F(PredictorBrowserTest, PreconnectNonCORS) { |
| 354 GURL preconnect_url = embedded_test_server()->base_url(); | 362 GURL preconnect_url = embedded_test_server()->base_url(); |
| 355 std::string preconnect_content = | 363 std::string preconnect_content = |
| 356 "<link rel=\"preconnect\" href=\"" + preconnect_url.spec() + "\">"; | 364 "<link rel=\"preconnect\" href=\"" + preconnect_url.spec() + "\">"; |
| 357 NavigateToDataURLWithContent(preconnect_content); | 365 NavigateToDataURLWithContent(preconnect_content); |
| 358 connection_listener_->WaitUntilFirstConnectionAccepted(); | 366 connection_listener_->WaitUntilFirstConnectionAccepted(); |
| 359 EXPECT_EQ(1u, connection_listener_->GetAcceptedSocketCount()); | 367 EXPECT_EQ(1u, connection_listener_->GetAcceptedSocketCount()); |
| 360 EXPECT_EQ(0u, connection_listener_->GetReadSocketCount()); | 368 EXPECT_EQ(0u, connection_listener_->GetReadSocketCount()); |
| 361 } | 369 } |
| 362 | 370 |
| 363 // Tests that preconnect warms up a socket connection to a test server, | 371 // Tests that preconnect warms up a socket connection to a test server, |
| 364 // and that that socket is later used when fetching a resource. | 372 // and that that socket is later used when fetching a resource. |
| 365 // Note: This test uses a data URI to serve the preconnect hint, to make sure | 373 // Note: This test uses a data URI to serve the preconnect hint, to make sure |
| 366 // that the network stack doesn't just re-use its connection to the test server. | 374 // that the network stack doesn't just re-use its connection to the test server. |
| 367 IN_PROC_BROWSER_TEST_F(PredictorBrowserTest, PreconnectAndUse) { | 375 IN_PROC_BROWSER_TEST_F(PredictorBrowserTest, PreconnectAndFetchNonCORS) { |
| 368 GURL preconnect_url = embedded_test_server()->base_url(); | 376 GURL preconnect_url = embedded_test_server()->base_url(); |
| 369 // First navigation to content with a preconnect hint. | 377 // First navigation to content with a preconnect hint. |
| 370 std::string preconnect_content = | 378 std::string preconnect_content = |
| 371 "<link rel=\"preconnect\" href=\"" + preconnect_url.spec() + "\">"; | 379 "<link rel=\"preconnect\" href=\"" + preconnect_url.spec() + "\">"; |
| 372 NavigateToDataURLWithContent(preconnect_content); | 380 NavigateToDataURLWithContent(preconnect_content); |
| 373 connection_listener_->WaitUntilFirstConnectionAccepted(); | 381 connection_listener_->WaitUntilFirstConnectionAccepted(); |
| 374 EXPECT_EQ(1u, connection_listener_->GetAcceptedSocketCount()); | 382 EXPECT_EQ(1u, connection_listener_->GetAcceptedSocketCount()); |
| 375 EXPECT_EQ(0u, connection_listener_->GetReadSocketCount()); | 383 EXPECT_EQ(0u, connection_listener_->GetReadSocketCount()); |
| 376 | 384 |
| 377 // Second navigation to content with an img. | 385 // Second navigation to content with an img. |
| 378 std::string img_content = | 386 std::string img_content = |
| 379 "<img src=\"" + preconnect_url.spec() + "test.gif\">"; | 387 "<img src=\"" + preconnect_url.spec() + "test.gif\">"; |
| 380 NavigateToDataURLWithContent(img_content); | 388 NavigateToDataURLWithContent(img_content); |
| 381 connection_listener_->WaitUntilFirstConnectionRead(); | 389 connection_listener_->WaitUntilFirstConnectionRead(); |
| 382 EXPECT_EQ(1u, connection_listener_->GetAcceptedSocketCount()); | 390 EXPECT_EQ(1u, connection_listener_->GetAcceptedSocketCount()); |
| 383 EXPECT_EQ(1u, connection_listener_->GetReadSocketCount()); | 391 EXPECT_EQ(1u, connection_listener_->GetReadSocketCount()); |
| 384 } | 392 } |
| 385 | 393 |
| 394 // Tests that preconnect warms up a CORS connection to a test |
| 395 // server, and that socket is later used when fetching a CORS resource. |
| 396 // Note: This test uses a data URI to serve the preconnect hint, to make sure |
| 397 // that the network stack doesn't just re-use its connection to the test server. |
| 398 IN_PROC_BROWSER_TEST_F(PredictorBrowserTest, PreconnectAndFetchCORS) { |
| 399 GURL preconnect_url = embedded_test_server()->base_url(); |
| 400 // First navigation to content with a preconnect hint. |
| 401 std::string preconnect_content = "<link rel=\"preconnect\" href=\"" + |
| 402 preconnect_url.spec() + "\" crossorigin>"; |
| 403 NavigateToDataURLWithContent(preconnect_content); |
| 404 connection_listener_->WaitUntilFirstConnectionAccepted(); |
| 405 EXPECT_EQ(1u, connection_listener_->GetAcceptedSocketCount()); |
| 406 EXPECT_EQ(0u, connection_listener_->GetReadSocketCount()); |
| 407 |
| 408 // Second navigation to content with a font. |
| 409 std::string font_content = "<script>var font = new FontFace('FontA', 'url(" + |
| 410 preconnect_url.spec() + |
| 411 "test.woff2)');font.load();</script>"; |
| 412 NavigateToDataURLWithContent(font_content); |
| 413 connection_listener_->WaitUntilFirstConnectionRead(); |
| 414 EXPECT_EQ(1u, connection_listener_->GetAcceptedSocketCount()); |
| 415 EXPECT_EQ(1u, connection_listener_->GetReadSocketCount()); |
| 416 } |
| 417 |
| 418 // Tests that preconnect warms up a non-CORS connection to a test |
| 419 // server, but that socket is not used when fetching a CORS resource. |
| 420 // Note: This test uses a data URI to serve the preconnect hint, to make sure |
| 421 // that the network stack doesn't just re-use its connection to the test server. |
| 422 IN_PROC_BROWSER_TEST_F(PredictorBrowserTest, PreconnectNonCORSAndFetchCORS) { |
| 423 GURL preconnect_url = embedded_test_server()->base_url(); |
| 424 // First navigation to content with a preconnect hint. |
| 425 std::string preconnect_content = |
| 426 "<link rel=\"preconnect\" href=\"" + preconnect_url.spec() + "\">"; |
| 427 NavigateToDataURLWithContent(preconnect_content); |
| 428 connection_listener_->WaitUntilFirstConnectionAccepted(); |
| 429 EXPECT_EQ(1u, connection_listener_->GetAcceptedSocketCount()); |
| 430 EXPECT_EQ(0u, connection_listener_->GetReadSocketCount()); |
| 431 |
| 432 // Second navigation to content with a font. |
| 433 std::string font_content = "<script>var font = new FontFace('FontA', 'url(" + |
| 434 preconnect_url.spec() + |
| 435 "test.woff2)');font.load();</script>"; |
| 436 NavigateToDataURLWithContent(font_content); |
| 437 connection_listener_->WaitUntilFirstConnectionRead(); |
| 438 EXPECT_EQ(2u, connection_listener_->GetAcceptedSocketCount()); |
| 439 EXPECT_EQ(1u, connection_listener_->GetReadSocketCount()); |
| 440 } |
| 441 |
| 442 // Tests that preconnect warms up a CORS connection to a test server, |
| 443 // but that socket is not used when fetching a non-CORS resource. |
| 444 // Note: This test uses a data URI to serve the preconnect hint, to make sure |
| 445 // that the network stack doesn't just re-use its connection to the test server. |
| 446 IN_PROC_BROWSER_TEST_F(PredictorBrowserTest, PreconnectCORSAndFetchNonCORS) { |
| 447 GURL preconnect_url = embedded_test_server()->base_url(); |
| 448 // First navigation to content with a preconnect hint. |
| 449 std::string preconnect_content = "<link rel=\"preconnect\" href=\"" + |
| 450 preconnect_url.spec() + "\" crossorigin>"; |
| 451 NavigateToDataURLWithContent(preconnect_content); |
| 452 connection_listener_->WaitUntilFirstConnectionAccepted(); |
| 453 EXPECT_EQ(1u, connection_listener_->GetAcceptedSocketCount()); |
| 454 EXPECT_EQ(0u, connection_listener_->GetReadSocketCount()); |
| 455 |
| 456 // Second navigation to content with an img. |
| 457 std::string img_content = |
| 458 "<img src=\"" + preconnect_url.spec() + "test.gif\">"; |
| 459 NavigateToDataURLWithContent(img_content); |
| 460 connection_listener_->WaitUntilFirstConnectionRead(); |
| 461 EXPECT_EQ(2u, connection_listener_->GetAcceptedSocketCount()); |
| 462 EXPECT_EQ(1u, connection_listener_->GetReadSocketCount()); |
| 463 } |
| 464 |
| 386 } // namespace chrome_browser_net | 465 } // namespace chrome_browser_net |
| 387 | 466 |
| OLD | NEW |