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 <algorithm> | 5 #include <algorithm> |
6 #include <memory> | 6 #include <memory> |
7 #include <ostream> | 7 #include <ostream> |
8 #include <string> | 8 #include <string> |
9 #include <utility> | 9 #include <utility> |
10 #include <vector> | 10 #include <vector> |
(...skipping 615 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
626 http_server_properties_.SetAlternativeService(server, alternative_service, | 626 http_server_properties_.SetAlternativeService(server, alternative_service, |
627 expiration); | 627 expiration); |
628 } | 628 } |
629 | 629 |
630 void ExpectBrokenAlternateProtocolMapping() { | 630 void ExpectBrokenAlternateProtocolMapping() { |
631 const url::SchemeHostPort server(request_.url); | 631 const url::SchemeHostPort server(request_.url); |
632 const AlternativeServiceInfoVector alternative_service_info_vector = | 632 const AlternativeServiceInfoVector alternative_service_info_vector = |
633 http_server_properties_.GetAlternativeServiceInfos(server); | 633 http_server_properties_.GetAlternativeServiceInfos(server); |
634 EXPECT_EQ(1u, alternative_service_info_vector.size()); | 634 EXPECT_EQ(1u, alternative_service_info_vector.size()); |
635 EXPECT_TRUE(http_server_properties_.IsAlternativeServiceBroken( | 635 EXPECT_TRUE(http_server_properties_.IsAlternativeServiceBroken( |
636 alternative_service_info_vector[0].alternative_service)); | 636 alternative_service_info_vector[0].alternative_service())); |
637 } | 637 } |
638 | 638 |
639 void ExpectQuicAlternateProtocolMapping() { | 639 void ExpectQuicAlternateProtocolMapping() { |
640 const url::SchemeHostPort server(request_.url); | 640 const url::SchemeHostPort server(request_.url); |
641 const AlternativeServiceInfoVector alternative_service_info_vector = | 641 const AlternativeServiceInfoVector alternative_service_info_vector = |
642 http_server_properties_.GetAlternativeServiceInfos(server); | 642 http_server_properties_.GetAlternativeServiceInfos(server); |
643 EXPECT_EQ(1u, alternative_service_info_vector.size()); | 643 EXPECT_EQ(1u, alternative_service_info_vector.size()); |
644 EXPECT_EQ(kProtoQUIC, | 644 EXPECT_EQ( |
645 alternative_service_info_vector[0].alternative_service.protocol); | 645 kProtoQUIC, |
| 646 alternative_service_info_vector[0].alternative_service().protocol); |
646 EXPECT_FALSE(http_server_properties_.IsAlternativeServiceBroken( | 647 EXPECT_FALSE(http_server_properties_.IsAlternativeServiceBroken( |
647 alternative_service_info_vector[0].alternative_service)); | 648 alternative_service_info_vector[0].alternative_service())); |
648 } | 649 } |
649 | 650 |
650 void AddHangingNonAlternateProtocolSocketData() { | 651 void AddHangingNonAlternateProtocolSocketData() { |
651 std::unique_ptr<StaticSocketDataProvider> hanging_data; | 652 std::unique_ptr<StaticSocketDataProvider> hanging_data; |
652 hanging_data.reset(new StaticSocketDataProvider()); | 653 hanging_data.reset(new StaticSocketDataProvider()); |
653 MockConnect hanging_connect(SYNCHRONOUS, ERR_IO_PENDING); | 654 MockConnect hanging_connect(SYNCHRONOUS, ERR_IO_PENDING); |
654 hanging_data->set_connect_data(hanging_connect); | 655 hanging_data->set_connect_data(hanging_connect); |
655 hanging_data_.push_back(std::move(hanging_data)); | 656 hanging_data_.push_back(std::move(hanging_data)); |
656 socket_factory_.AddSocketDataProvider(hanging_data_.back().get()); | 657 socket_factory_.AddSocketDataProvider(hanging_data_.back().get()); |
657 socket_factory_.AddSSLSocketDataProvider(&ssl_data_); | 658 socket_factory_.AddSSLSocketDataProvider(&ssl_data_); |
(...skipping 2332 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2990 AddHangingNonAlternateProtocolSocketData(); | 2991 AddHangingNonAlternateProtocolSocketData(); |
2991 CreateSession(); | 2992 CreateSession(); |
2992 | 2993 |
2993 SendRequestAndExpectHttpResponse("hello world"); | 2994 SendRequestAndExpectHttpResponse("hello world"); |
2994 | 2995 |
2995 url::SchemeHostPort http_server("https", kDefaultServerHostName, 443); | 2996 url::SchemeHostPort http_server("https", kDefaultServerHostName, 443); |
2996 AlternativeServiceInfoVector alternative_service_info_vector = | 2997 AlternativeServiceInfoVector alternative_service_info_vector = |
2997 http_server_properties_.GetAlternativeServiceInfos(http_server); | 2998 http_server_properties_.GetAlternativeServiceInfos(http_server); |
2998 ASSERT_EQ(1u, alternative_service_info_vector.size()); | 2999 ASSERT_EQ(1u, alternative_service_info_vector.size()); |
2999 const AlternativeService alternative_service = | 3000 const AlternativeService alternative_service = |
3000 alternative_service_info_vector[0].alternative_service; | 3001 alternative_service_info_vector[0].alternative_service(); |
3001 EXPECT_EQ(kProtoQUIC, alternative_service.protocol); | 3002 EXPECT_EQ(kProtoQUIC, alternative_service.protocol); |
3002 EXPECT_EQ(kDefaultServerHostName, alternative_service.host); | 3003 EXPECT_EQ(kDefaultServerHostName, alternative_service.host); |
3003 EXPECT_EQ(137, alternative_service.port); | 3004 EXPECT_EQ(137, alternative_service.port); |
3004 } | 3005 } |
3005 | 3006 |
3006 TEST_P(QuicNetworkTransactionTest, ConfirmAlternativeService) { | 3007 TEST_P(QuicNetworkTransactionTest, ConfirmAlternativeService) { |
3007 MockRead http_reads[] = { | 3008 MockRead http_reads[] = { |
3008 MockRead("HTTP/1.1 200 OK\r\n"), MockRead(kQuicAlternativeServiceHeader), | 3009 MockRead("HTTP/1.1 200 OK\r\n"), MockRead(kQuicAlternativeServiceHeader), |
3009 MockRead("hello world"), | 3010 MockRead("hello world"), |
3010 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), | 3011 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ), |
(...skipping 1791 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
4802 | 4803 |
4803 request_.url = GURL("https://mail.example.org/pushed.jpg"); | 4804 request_.url = GURL("https://mail.example.org/pushed.jpg"); |
4804 ChunkedUploadDataStream upload_data(0); | 4805 ChunkedUploadDataStream upload_data(0); |
4805 upload_data.AppendData("1", 1, true); | 4806 upload_data.AppendData("1", 1, true); |
4806 request_.upload_data_stream = &upload_data; | 4807 request_.upload_data_stream = &upload_data; |
4807 SendRequestAndExpectQuicResponse("and hello!"); | 4808 SendRequestAndExpectQuicResponse("and hello!"); |
4808 } | 4809 } |
4809 | 4810 |
4810 } // namespace test | 4811 } // namespace test |
4811 } // namespace net | 4812 } // namespace net |
OLD | NEW |