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 "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 | 8 |
9 #include <memory> | 9 #include <memory> |
10 #include <string> | 10 #include <string> |
(...skipping 1888 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1899 bidi_request_info.priority = LOWEST; | 1899 bidi_request_info.priority = LOWEST; |
1900 | 1900 |
1901 TestBidirectionalDelegate delegate; | 1901 TestBidirectionalDelegate delegate; |
1902 stream_impl->Start(&bidi_request_info, NetLogWithSource(), | 1902 stream_impl->Start(&bidi_request_info, NetLogWithSource(), |
1903 /*send_request_headers_automatically=*/true, &delegate, | 1903 /*send_request_headers_automatically=*/true, &delegate, |
1904 nullptr); | 1904 nullptr); |
1905 delegate.WaitUntilDone(); | 1905 delegate.WaitUntilDone(); |
1906 | 1906 |
1907 scoped_refptr<IOBuffer> buffer = new net::IOBuffer(1); | 1907 scoped_refptr<IOBuffer> buffer = new net::IOBuffer(1); |
1908 EXPECT_THAT(stream_impl->ReadData(buffer.get(), 1), IsOk()); | 1908 EXPECT_THAT(stream_impl->ReadData(buffer.get(), 1), IsOk()); |
1909 EXPECT_EQ(kProtoQUIC1SPDY3, stream_impl->GetProtocol()); | 1909 EXPECT_EQ(kProtoQUIC, stream_impl->GetProtocol()); |
1910 EXPECT_EQ("200", delegate.response_headers().find(":status")->second); | 1910 EXPECT_EQ("200", delegate.response_headers().find(":status")->second); |
1911 EXPECT_EQ(0, GetSocketPoolGroupCount(session()->GetTransportSocketPool( | 1911 EXPECT_EQ(0, GetSocketPoolGroupCount(session()->GetTransportSocketPool( |
1912 HttpNetworkSession::NORMAL_SOCKET_POOL))); | 1912 HttpNetworkSession::NORMAL_SOCKET_POOL))); |
1913 EXPECT_EQ(0, GetSocketPoolGroupCount(session()->GetSSLSocketPool( | 1913 EXPECT_EQ(0, GetSocketPoolGroupCount(session()->GetSSLSocketPool( |
1914 HttpNetworkSession::NORMAL_SOCKET_POOL))); | 1914 HttpNetworkSession::NORMAL_SOCKET_POOL))); |
1915 EXPECT_EQ(0, GetSocketPoolGroupCount(session()->GetTransportSocketPool( | 1915 EXPECT_EQ(0, GetSocketPoolGroupCount(session()->GetTransportSocketPool( |
1916 HttpNetworkSession::WEBSOCKET_SOCKET_POOL))); | 1916 HttpNetworkSession::WEBSOCKET_SOCKET_POOL))); |
1917 EXPECT_EQ(0, GetSocketPoolGroupCount(session()->GetSSLSocketPool( | 1917 EXPECT_EQ(0, GetSocketPoolGroupCount(session()->GetSSLSocketPool( |
1918 HttpNetworkSession::WEBSOCKET_SOCKET_POOL))); | 1918 HttpNetworkSession::WEBSOCKET_SOCKET_POOL))); |
1919 EXPECT_TRUE(waiter.used_proxy_info().is_direct()); | 1919 EXPECT_TRUE(waiter.used_proxy_info().is_direct()); |
(...skipping 103 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2023 | 2023 |
2024 TestBidirectionalDelegate delegate; | 2024 TestBidirectionalDelegate delegate; |
2025 stream_impl->Start(&bidi_request_info, NetLogWithSource(), | 2025 stream_impl->Start(&bidi_request_info, NetLogWithSource(), |
2026 /*send_request_headers_automatically=*/true, &delegate, | 2026 /*send_request_headers_automatically=*/true, &delegate, |
2027 nullptr); | 2027 nullptr); |
2028 delegate.WaitUntilDone(); | 2028 delegate.WaitUntilDone(); |
2029 | 2029 |
2030 // Make sure the BidirectionalStream negotiated goes through QUIC. | 2030 // Make sure the BidirectionalStream negotiated goes through QUIC. |
2031 scoped_refptr<IOBuffer> buffer = new net::IOBuffer(1); | 2031 scoped_refptr<IOBuffer> buffer = new net::IOBuffer(1); |
2032 EXPECT_THAT(stream_impl->ReadData(buffer.get(), 1), IsOk()); | 2032 EXPECT_THAT(stream_impl->ReadData(buffer.get(), 1), IsOk()); |
2033 EXPECT_EQ(kProtoQUIC1SPDY3, stream_impl->GetProtocol()); | 2033 EXPECT_EQ(kProtoQUIC, stream_impl->GetProtocol()); |
2034 EXPECT_EQ("200", delegate.response_headers().find(":status")->second); | 2034 EXPECT_EQ("200", delegate.response_headers().find(":status")->second); |
2035 // There is no Http2 socket pool. | 2035 // There is no Http2 socket pool. |
2036 EXPECT_EQ(0, GetSocketPoolGroupCount(session()->GetTransportSocketPool( | 2036 EXPECT_EQ(0, GetSocketPoolGroupCount(session()->GetTransportSocketPool( |
2037 HttpNetworkSession::NORMAL_SOCKET_POOL))); | 2037 HttpNetworkSession::NORMAL_SOCKET_POOL))); |
2038 EXPECT_EQ(0, GetSocketPoolGroupCount(session()->GetSSLSocketPool( | 2038 EXPECT_EQ(0, GetSocketPoolGroupCount(session()->GetSSLSocketPool( |
2039 HttpNetworkSession::NORMAL_SOCKET_POOL))); | 2039 HttpNetworkSession::NORMAL_SOCKET_POOL))); |
2040 EXPECT_EQ(0, GetSocketPoolGroupCount(session()->GetTransportSocketPool( | 2040 EXPECT_EQ(0, GetSocketPoolGroupCount(session()->GetTransportSocketPool( |
2041 HttpNetworkSession::WEBSOCKET_SOCKET_POOL))); | 2041 HttpNetworkSession::WEBSOCKET_SOCKET_POOL))); |
2042 EXPECT_EQ(0, GetSocketPoolGroupCount(session()->GetSSLSocketPool( | 2042 EXPECT_EQ(0, GetSocketPoolGroupCount(session()->GetSSLSocketPool( |
2043 HttpNetworkSession::WEBSOCKET_SOCKET_POOL))); | 2043 HttpNetworkSession::WEBSOCKET_SOCKET_POOL))); |
(...skipping 221 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2265 session->GetTransportSocketPool( | 2265 session->GetTransportSocketPool( |
2266 HttpNetworkSession::WEBSOCKET_SOCKET_POOL))); | 2266 HttpNetworkSession::WEBSOCKET_SOCKET_POOL))); |
2267 EXPECT_EQ(1, GetSocketPoolGroupCount( | 2267 EXPECT_EQ(1, GetSocketPoolGroupCount( |
2268 session->GetSSLSocketPool(HttpNetworkSession::WEBSOCKET_SOCKET_POOL))); | 2268 session->GetSSLSocketPool(HttpNetworkSession::WEBSOCKET_SOCKET_POOL))); |
2269 EXPECT_TRUE(waiter.used_proxy_info().is_direct()); | 2269 EXPECT_TRUE(waiter.used_proxy_info().is_direct()); |
2270 } | 2270 } |
2271 | 2271 |
2272 } // namespace | 2272 } // namespace |
2273 | 2273 |
2274 } // namespace net | 2274 } // namespace net |
OLD | NEW |