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

Side by Side Diff: net/http/http_stream_factory_impl_unittest.cc

Issue 2111953002: Minor test cleanup. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 4 years, 5 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
« no previous file with comments | « net/http/bidirectional_stream_unittest.cc ('k') | net/quic/quic_stream_factory_test.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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 "net/http/http_stream_factory_impl.h" 5 #include "net/http/http_stream_factory_impl.h"
6 6
7 #include <stdint.h> 7 #include <stdint.h>
8 #include <string> 8 #include <string>
9 #include <utility> 9 #include <utility>
10 #include <vector> 10 #include <vector>
(...skipping 1521 matching lines...) Expand 10 before | Expand all | Expand 10 after
1532 EXPECT_EQ(0, GetSocketPoolGroupCount(session->GetSSLSocketPool( 1532 EXPECT_EQ(0, GetSocketPoolGroupCount(session->GetSSLSocketPool(
1533 HttpNetworkSession::WEBSOCKET_SOCKET_POOL))); 1533 HttpNetworkSession::WEBSOCKET_SOCKET_POOL)));
1534 EXPECT_TRUE(waiter.used_proxy_info().is_direct()); 1534 EXPECT_TRUE(waiter.used_proxy_info().is_direct());
1535 } 1535 }
1536 1536
1537 class HttpStreamFactoryBidirectionalQuicTest 1537 class HttpStreamFactoryBidirectionalQuicTest
1538 : public ::testing::Test, 1538 : public ::testing::Test,
1539 public ::testing::WithParamInterface<QuicVersion> { 1539 public ::testing::WithParamInterface<QuicVersion> {
1540 protected: 1540 protected:
1541 HttpStreamFactoryBidirectionalQuicTest() 1541 HttpStreamFactoryBidirectionalQuicTest()
1542 : clock_(new MockClock), 1542 : default_url_(kDefaultUrl),
1543 clock_(new MockClock),
1543 client_packet_maker_(GetParam(), 1544 client_packet_maker_(GetParam(),
1544 0, 1545 0,
1545 clock_, 1546 clock_,
1546 "www.example.org", 1547 "www.example.org",
1547 Perspective::IS_CLIENT), 1548 Perspective::IS_CLIENT),
1548 server_packet_maker_(GetParam(), 1549 server_packet_maker_(GetParam(),
1549 0, 1550 0,
1550 clock_, 1551 clock_,
1551 "www.example.org", 1552 "www.example.org",
1552 Perspective::IS_SERVER), 1553 Perspective::IS_SERVER),
(...skipping 40 matching lines...) Expand 10 before | Expand all | Expand 10 after
1593 session_.reset(new HttpNetworkSession(params_)); 1594 session_.reset(new HttpNetworkSession(params_));
1594 session_->quic_stream_factory()->set_require_confirmation(false); 1595 session_->quic_stream_factory()->set_require_confirmation(false);
1595 } 1596 }
1596 1597
1597 void AddQuicAlternativeService() { 1598 void AddQuicAlternativeService() {
1598 const AlternativeService alternative_service(QUIC, "www.example.org", 443); 1599 const AlternativeService alternative_service(QUIC, "www.example.org", 443);
1599 AlternativeServiceInfoVector alternative_service_info_vector; 1600 AlternativeServiceInfoVector alternative_service_info_vector;
1600 base::Time expiration = base::Time::Now() + base::TimeDelta::FromDays(1); 1601 base::Time expiration = base::Time::Now() + base::TimeDelta::FromDays(1);
1601 alternative_service_info_vector.push_back( 1602 alternative_service_info_vector.push_back(
1602 AlternativeServiceInfo(alternative_service, expiration)); 1603 AlternativeServiceInfo(alternative_service, expiration));
1603 url::SchemeHostPort server("https", "www.example.org", 443);
1604 http_server_properties_.SetAlternativeServices( 1604 http_server_properties_.SetAlternativeServices(
1605 server, alternative_service_info_vector); 1605 url::SchemeHostPort(default_url_), alternative_service_info_vector);
1606 }; 1606 };
1607 1607
1608 test::QuicTestPacketMaker& client_packet_maker() { 1608 test::QuicTestPacketMaker& client_packet_maker() {
1609 return client_packet_maker_; 1609 return client_packet_maker_;
1610 } 1610 }
1611 test::QuicTestPacketMaker& server_packet_maker() { 1611 test::QuicTestPacketMaker& server_packet_maker() {
1612 return server_packet_maker_; 1612 return server_packet_maker_;
1613 } 1613 }
1614 1614
1615 MockClientSocketFactory& socket_factory() { return socket_factory_; } 1615 MockClientSocketFactory& socket_factory() { return socket_factory_; }
1616 1616
1617 HttpNetworkSession* session() { return session_.get(); } 1617 HttpNetworkSession* session() { return session_.get(); }
1618 1618
1619 const GURL default_url_;
1620
1619 private: 1621 private:
1620 MockClock* clock_; // Owned by QuicStreamFactory 1622 MockClock* clock_; // Owned by QuicStreamFactory
1621 test::QuicTestPacketMaker client_packet_maker_; 1623 test::QuicTestPacketMaker client_packet_maker_;
1622 test::QuicTestPacketMaker server_packet_maker_; 1624 test::QuicTestPacketMaker server_packet_maker_;
1623 MockClientSocketFactory socket_factory_; 1625 MockClientSocketFactory socket_factory_;
1624 std::unique_ptr<HttpNetworkSession> session_; 1626 std::unique_ptr<HttpNetworkSession> session_;
1625 test::MockRandom random_generator_; 1627 test::MockRandom random_generator_;
1626 MockCertVerifier cert_verifier_; 1628 MockCertVerifier cert_verifier_;
1627 ProofVerifyDetailsChromium verify_details_; 1629 ProofVerifyDetailsChromium verify_details_;
1628 MockCryptoClientStreamFactory crypto_client_stream_factory_; 1630 MockCryptoClientStreamFactory crypto_client_stream_factory_;
1629 HttpServerPropertiesImpl http_server_properties_; 1631 HttpServerPropertiesImpl http_server_properties_;
1630 TransportSecurityState transport_security_state_; 1632 TransportSecurityState transport_security_state_;
1631 MultiLogCTVerifier ct_verifier_; 1633 MultiLogCTVerifier ct_verifier_;
1632 CTPolicyEnforcer ct_policy_enforcer_; 1634 CTPolicyEnforcer ct_policy_enforcer_;
1633 MockHostResolver host_resolver_; 1635 MockHostResolver host_resolver_;
1634 std::unique_ptr<ProxyService> proxy_service_; 1636 std::unique_ptr<ProxyService> proxy_service_;
1635 scoped_refptr<SSLConfigServiceDefaults> ssl_config_service_; 1637 scoped_refptr<SSLConfigServiceDefaults> ssl_config_service_;
1636 HttpNetworkSession::Params params_; 1638 HttpNetworkSession::Params params_;
1637 }; 1639 };
1638 1640
1639 INSTANTIATE_TEST_CASE_P(Version, 1641 INSTANTIATE_TEST_CASE_P(Version,
1640 HttpStreamFactoryBidirectionalQuicTest, 1642 HttpStreamFactoryBidirectionalQuicTest,
1641 ::testing::ValuesIn(QuicSupportedVersions())); 1643 ::testing::ValuesIn(QuicSupportedVersions()));
1642 1644
1643 TEST_P(HttpStreamFactoryBidirectionalQuicTest, 1645 TEST_P(HttpStreamFactoryBidirectionalQuicTest,
1644 RequestBidirectionalStreamImplQuicAlternative) { 1646 RequestBidirectionalStreamImplQuicAlternative) {
1645 GURL url = GURL("https://www.example.org");
1646
1647 MockQuicData mock_quic_data; 1647 MockQuicData mock_quic_data;
1648 SpdyPriority priority = 1648 SpdyPriority priority =
1649 ConvertRequestPriorityToQuicPriority(DEFAULT_PRIORITY); 1649 ConvertRequestPriorityToQuicPriority(DEFAULT_PRIORITY);
1650 size_t spdy_headers_frame_length; 1650 size_t spdy_headers_frame_length;
1651 mock_quic_data.AddWrite(client_packet_maker().MakeRequestHeadersPacket( 1651 mock_quic_data.AddWrite(client_packet_maker().MakeRequestHeadersPacket(
1652 1, test::kClientDataStreamId1, /*should_include_version=*/true, 1652 1, test::kClientDataStreamId1, /*should_include_version=*/true,
1653 /*fin=*/true, priority, 1653 /*fin=*/true, priority,
1654 client_packet_maker().GetRequestHeaders("GET", "https", "/"), 1654 client_packet_maker().GetRequestHeaders("GET", "https", "/"),
1655 &spdy_headers_frame_length)); 1655 &spdy_headers_frame_length));
1656 size_t spdy_response_headers_frame_length; 1656 size_t spdy_response_headers_frame_length;
(...skipping 14 matching lines...) Expand all
1671 socket_factory().AddSSLSocketDataProvider(&ssl_data); 1671 socket_factory().AddSSLSocketDataProvider(&ssl_data);
1672 1672
1673 // Set up QUIC as alternative_service. 1673 // Set up QUIC as alternative_service.
1674 AddQuicAlternativeService(); 1674 AddQuicAlternativeService();
1675 Initialize(); 1675 Initialize();
1676 1676
1677 // Now request a stream. 1677 // Now request a stream.
1678 SSLConfig ssl_config; 1678 SSLConfig ssl_config;
1679 HttpRequestInfo request_info; 1679 HttpRequestInfo request_info;
1680 request_info.method = "GET"; 1680 request_info.method = "GET";
1681 request_info.url = GURL("https://www.example.org"); 1681 request_info.url = default_url_;
1682 request_info.load_flags = 0; 1682 request_info.load_flags = 0;
1683 1683
1684 StreamRequestWaiter waiter; 1684 StreamRequestWaiter waiter;
1685 std::unique_ptr<HttpStreamRequest> request( 1685 std::unique_ptr<HttpStreamRequest> request(
1686 session()->http_stream_factory()->RequestBidirectionalStreamImpl( 1686 session()->http_stream_factory()->RequestBidirectionalStreamImpl(
1687 request_info, DEFAULT_PRIORITY, ssl_config, ssl_config, &waiter, 1687 request_info, DEFAULT_PRIORITY, ssl_config, ssl_config, &waiter,
1688 BoundNetLog())); 1688 BoundNetLog()));
1689 1689
1690 waiter.WaitForStream(); 1690 waiter.WaitForStream();
1691 EXPECT_TRUE(waiter.stream_done()); 1691 EXPECT_TRUE(waiter.stream_done());
1692 EXPECT_FALSE(waiter.websocket_stream()); 1692 EXPECT_FALSE(waiter.websocket_stream());
1693 ASSERT_FALSE(waiter.stream()); 1693 ASSERT_FALSE(waiter.stream());
1694 ASSERT_TRUE(waiter.bidirectional_stream_impl()); 1694 ASSERT_TRUE(waiter.bidirectional_stream_impl());
1695 BidirectionalStreamImpl* stream_impl = waiter.bidirectional_stream_impl(); 1695 BidirectionalStreamImpl* stream_impl = waiter.bidirectional_stream_impl();
1696 1696
1697 BidirectionalStreamRequestInfo bidi_request_info; 1697 BidirectionalStreamRequestInfo bidi_request_info;
1698 bidi_request_info.method = "GET"; 1698 bidi_request_info.method = "GET";
1699 bidi_request_info.url = GURL("https://www.example.org/"); 1699 bidi_request_info.url = default_url_;
1700 bidi_request_info.end_stream_on_headers = true; 1700 bidi_request_info.end_stream_on_headers = true;
1701 bidi_request_info.priority = LOWEST; 1701 bidi_request_info.priority = LOWEST;
1702 1702
1703 TestBidirectionalDelegate delegate; 1703 TestBidirectionalDelegate delegate;
1704 stream_impl->Start(&bidi_request_info, BoundNetLog(), 1704 stream_impl->Start(&bidi_request_info, BoundNetLog(),
1705 /*send_request_headers_automatically=*/true, &delegate, 1705 /*send_request_headers_automatically=*/true, &delegate,
1706 nullptr); 1706 nullptr);
1707 delegate.WaitUntilDone(); 1707 delegate.WaitUntilDone();
1708 1708
1709 scoped_refptr<IOBuffer> buffer = new net::IOBuffer(1); 1709 scoped_refptr<IOBuffer> buffer = new net::IOBuffer(1);
1710 EXPECT_EQ(OK, stream_impl->ReadData(buffer.get(), 1)); 1710 EXPECT_EQ(OK, stream_impl->ReadData(buffer.get(), 1));
1711 EXPECT_EQ(kProtoQUIC1SPDY3, stream_impl->GetProtocol()); 1711 EXPECT_EQ(kProtoQUIC1SPDY3, stream_impl->GetProtocol());
1712 EXPECT_EQ("200", delegate.response_headers().find(":status")->second); 1712 EXPECT_EQ("200", delegate.response_headers().find(":status")->second);
1713 EXPECT_EQ(0, GetSocketPoolGroupCount(session()->GetTransportSocketPool( 1713 EXPECT_EQ(0, GetSocketPoolGroupCount(session()->GetTransportSocketPool(
1714 HttpNetworkSession::NORMAL_SOCKET_POOL))); 1714 HttpNetworkSession::NORMAL_SOCKET_POOL)));
1715 EXPECT_EQ(0, GetSocketPoolGroupCount(session()->GetSSLSocketPool( 1715 EXPECT_EQ(0, GetSocketPoolGroupCount(session()->GetSSLSocketPool(
1716 HttpNetworkSession::NORMAL_SOCKET_POOL))); 1716 HttpNetworkSession::NORMAL_SOCKET_POOL)));
1717 EXPECT_EQ(0, GetSocketPoolGroupCount(session()->GetTransportSocketPool( 1717 EXPECT_EQ(0, GetSocketPoolGroupCount(session()->GetTransportSocketPool(
1718 HttpNetworkSession::WEBSOCKET_SOCKET_POOL))); 1718 HttpNetworkSession::WEBSOCKET_SOCKET_POOL)));
1719 EXPECT_EQ(0, GetSocketPoolGroupCount(session()->GetSSLSocketPool( 1719 EXPECT_EQ(0, GetSocketPoolGroupCount(session()->GetSSLSocketPool(
1720 HttpNetworkSession::WEBSOCKET_SOCKET_POOL))); 1720 HttpNetworkSession::WEBSOCKET_SOCKET_POOL)));
1721 EXPECT_TRUE(waiter.used_proxy_info().is_direct()); 1721 EXPECT_TRUE(waiter.used_proxy_info().is_direct());
1722 } 1722 }
1723 1723
1724 // Tests that when QUIC is not enabled for bidirectional streaming, HTTP/2 is 1724 // Tests that when QUIC is not enabled for bidirectional streaming, HTTP/2 is
1725 // used instead. 1725 // used instead.
1726 TEST_P(HttpStreamFactoryBidirectionalQuicTest, 1726 TEST_P(HttpStreamFactoryBidirectionalQuicTest,
1727 RequestBidirectionalStreamImplQuicNotEnabled) { 1727 RequestBidirectionalStreamImplQuicNotEnabled) {
1728 GURL url = GURL("https://www.example.org");
1729
1730 // Make the http job fail. 1728 // Make the http job fail.
1731 std::unique_ptr<StaticSocketDataProvider> http_job_data; 1729 std::unique_ptr<StaticSocketDataProvider> http_job_data;
1732 http_job_data.reset(new StaticSocketDataProvider()); 1730 http_job_data.reset(new StaticSocketDataProvider());
1733 MockConnect failed_connect(ASYNC, ERR_CONNECTION_REFUSED); 1731 MockConnect failed_connect(ASYNC, ERR_CONNECTION_REFUSED);
1734 http_job_data->set_connect_data(failed_connect); 1732 http_job_data->set_connect_data(failed_connect);
1735 socket_factory().AddSocketDataProvider(http_job_data.get()); 1733 socket_factory().AddSocketDataProvider(http_job_data.get());
1736 SSLSocketDataProvider ssl_data(ASYNC, OK); 1734 SSLSocketDataProvider ssl_data(ASYNC, OK);
1737 socket_factory().AddSSLSocketDataProvider(&ssl_data); 1735 socket_factory().AddSSLSocketDataProvider(&ssl_data);
1738 1736
1739 // Set up QUIC as alternative_service. 1737 // Set up QUIC as alternative_service.
1740 AddQuicAlternativeService(); 1738 AddQuicAlternativeService();
1741 DisableQuicBidirectionalStream(); 1739 DisableQuicBidirectionalStream();
1742 Initialize(); 1740 Initialize();
1743 1741
1744 // Now request a stream. 1742 // Now request a stream.
1745 SSLConfig ssl_config; 1743 SSLConfig ssl_config;
1746 HttpRequestInfo request_info; 1744 HttpRequestInfo request_info;
1747 request_info.method = "GET"; 1745 request_info.method = "GET";
1748 request_info.url = GURL("https://www.example.org"); 1746 request_info.url = default_url_;
1749 request_info.load_flags = 0; 1747 request_info.load_flags = 0;
1750 1748
1751 StreamRequestWaiter waiter; 1749 StreamRequestWaiter waiter;
1752 std::unique_ptr<HttpStreamRequest> request( 1750 std::unique_ptr<HttpStreamRequest> request(
1753 session()->http_stream_factory()->RequestBidirectionalStreamImpl( 1751 session()->http_stream_factory()->RequestBidirectionalStreamImpl(
1754 request_info, DEFAULT_PRIORITY, ssl_config, ssl_config, &waiter, 1752 request_info, DEFAULT_PRIORITY, ssl_config, ssl_config, &waiter,
1755 BoundNetLog())); 1753 BoundNetLog()));
1756 1754
1757 waiter.WaitForStream(); 1755 waiter.WaitForStream();
1758 EXPECT_TRUE(waiter.stream_done()); 1756 EXPECT_TRUE(waiter.stream_done());
1759 EXPECT_FALSE(waiter.websocket_stream()); 1757 EXPECT_FALSE(waiter.websocket_stream());
1760 ASSERT_FALSE(waiter.stream()); 1758 ASSERT_FALSE(waiter.stream());
1761 ASSERT_FALSE(waiter.bidirectional_stream_impl()); 1759 ASSERT_FALSE(waiter.bidirectional_stream_impl());
1762 // Since the alternative service job is not started, we will get the error 1760 // Since the alternative service job is not started, we will get the error
1763 // from the http job. 1761 // from the http job.
1764 ASSERT_EQ(ERR_CONNECTION_REFUSED, waiter.error_status()); 1762 ASSERT_EQ(ERR_CONNECTION_REFUSED, waiter.error_status());
1765 } 1763 }
1766 1764
1767 // Tests that if Http job fails, but Quic job succeeds, we return 1765 // Tests that if Http job fails, but Quic job succeeds, we return
1768 // BidirectionalStreamQuicImpl. 1766 // BidirectionalStreamQuicImpl.
1769 TEST_P(HttpStreamFactoryBidirectionalQuicTest, 1767 TEST_P(HttpStreamFactoryBidirectionalQuicTest,
1770 RequestBidirectionalStreamImplHttpJobFailsQuicJobSucceeds) { 1768 RequestBidirectionalStreamImplHttpJobFailsQuicJobSucceeds) {
1771 GURL url = GURL("https://www.example.org");
1772
1773 // Set up Quic data. 1769 // Set up Quic data.
1774 MockQuicData mock_quic_data; 1770 MockQuicData mock_quic_data;
1775 SpdyPriority priority = 1771 SpdyPriority priority =
1776 ConvertRequestPriorityToQuicPriority(DEFAULT_PRIORITY); 1772 ConvertRequestPriorityToQuicPriority(DEFAULT_PRIORITY);
1777 size_t spdy_headers_frame_length; 1773 size_t spdy_headers_frame_length;
1778 mock_quic_data.AddWrite(client_packet_maker().MakeRequestHeadersPacket( 1774 mock_quic_data.AddWrite(client_packet_maker().MakeRequestHeadersPacket(
1779 1, test::kClientDataStreamId1, /*should_include_version=*/true, 1775 1, test::kClientDataStreamId1, /*should_include_version=*/true,
1780 /*fin=*/true, priority, 1776 /*fin=*/true, priority,
1781 client_packet_maker().GetRequestHeaders("GET", "https", "/"), 1777 client_packet_maker().GetRequestHeaders("GET", "https", "/"),
1782 &spdy_headers_frame_length)); 1778 &spdy_headers_frame_length));
(...skipping 15 matching lines...) Expand all
1798 socket_factory().AddSSLSocketDataProvider(&ssl_data); 1794 socket_factory().AddSSLSocketDataProvider(&ssl_data);
1799 1795
1800 // Set up QUIC as alternative_service. 1796 // Set up QUIC as alternative_service.
1801 AddQuicAlternativeService(); 1797 AddQuicAlternativeService();
1802 Initialize(); 1798 Initialize();
1803 1799
1804 // Now request a stream. 1800 // Now request a stream.
1805 SSLConfig ssl_config; 1801 SSLConfig ssl_config;
1806 HttpRequestInfo request_info; 1802 HttpRequestInfo request_info;
1807 request_info.method = "GET"; 1803 request_info.method = "GET";
1808 request_info.url = GURL("https://www.example.org"); 1804 request_info.url = default_url_;
1809 request_info.load_flags = 0; 1805 request_info.load_flags = 0;
1810 1806
1811 StreamRequestWaiter waiter; 1807 StreamRequestWaiter waiter;
1812 std::unique_ptr<HttpStreamRequest> request( 1808 std::unique_ptr<HttpStreamRequest> request(
1813 session()->http_stream_factory()->RequestBidirectionalStreamImpl( 1809 session()->http_stream_factory()->RequestBidirectionalStreamImpl(
1814 request_info, DEFAULT_PRIORITY, ssl_config, ssl_config, &waiter, 1810 request_info, DEFAULT_PRIORITY, ssl_config, ssl_config, &waiter,
1815 BoundNetLog())); 1811 BoundNetLog()));
1816 1812
1817 waiter.WaitForStream(); 1813 waiter.WaitForStream();
1818 EXPECT_TRUE(waiter.stream_done()); 1814 EXPECT_TRUE(waiter.stream_done());
1819 EXPECT_FALSE(waiter.websocket_stream()); 1815 EXPECT_FALSE(waiter.websocket_stream());
1820 ASSERT_FALSE(waiter.stream()); 1816 ASSERT_FALSE(waiter.stream());
1821 ASSERT_TRUE(waiter.bidirectional_stream_impl()); 1817 ASSERT_TRUE(waiter.bidirectional_stream_impl());
1822 BidirectionalStreamImpl* stream_impl = waiter.bidirectional_stream_impl(); 1818 BidirectionalStreamImpl* stream_impl = waiter.bidirectional_stream_impl();
1823 1819
1824 BidirectionalStreamRequestInfo bidi_request_info; 1820 BidirectionalStreamRequestInfo bidi_request_info;
1825 bidi_request_info.method = "GET"; 1821 bidi_request_info.method = "GET";
1826 bidi_request_info.url = GURL("https://www.example.org/"); 1822 bidi_request_info.url = default_url_;
1827 bidi_request_info.end_stream_on_headers = true; 1823 bidi_request_info.end_stream_on_headers = true;
1828 bidi_request_info.priority = LOWEST; 1824 bidi_request_info.priority = LOWEST;
1829 1825
1830 TestBidirectionalDelegate delegate; 1826 TestBidirectionalDelegate delegate;
1831 stream_impl->Start(&bidi_request_info, BoundNetLog(), 1827 stream_impl->Start(&bidi_request_info, BoundNetLog(),
1832 /*send_request_headers_automatically=*/true, &delegate, 1828 /*send_request_headers_automatically=*/true, &delegate,
1833 nullptr); 1829 nullptr);
1834 delegate.WaitUntilDone(); 1830 delegate.WaitUntilDone();
1835 1831
1836 // Make sure the BidirectionalStream negotiated goes through QUIC. 1832 // Make sure the BidirectionalStream negotiated goes through QUIC.
(...skipping 238 matching lines...) Expand 10 before | Expand all | Expand 10 after
2075 session->GetTransportSocketPool( 2071 session->GetTransportSocketPool(
2076 HttpNetworkSession::WEBSOCKET_SOCKET_POOL))); 2072 HttpNetworkSession::WEBSOCKET_SOCKET_POOL)));
2077 EXPECT_EQ(1, GetSocketPoolGroupCount( 2073 EXPECT_EQ(1, GetSocketPoolGroupCount(
2078 session->GetSSLSocketPool(HttpNetworkSession::WEBSOCKET_SOCKET_POOL))); 2074 session->GetSSLSocketPool(HttpNetworkSession::WEBSOCKET_SOCKET_POOL)));
2079 EXPECT_TRUE(waiter.used_proxy_info().is_direct()); 2075 EXPECT_TRUE(waiter.used_proxy_info().is_direct());
2080 } 2076 }
2081 2077
2082 } // namespace 2078 } // namespace
2083 2079
2084 } // namespace net 2080 } // namespace net
OLDNEW
« no previous file with comments | « net/http/bidirectional_stream_unittest.cc ('k') | net/quic/quic_stream_factory_test.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698