Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(496)

Side by Side Diff: net/quic/chromium/quic_network_transaction_unittest.cc

Issue 2932503005: Change AlternativeServiceInfo to a class (Closed)
Patch Set: Created 3 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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
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
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
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
OLDNEW
« no previous file with comments | « net/http/http_stream_factory_impl_job_controller_unittest.cc ('k') | net/spdy/chromium/spdy_session_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698