| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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_network_transaction.h" | 5 #include "net/http/http_network_transaction.h" |
| 6 | 6 |
| 7 #include <math.h> // ceil | 7 #include <math.h> // ceil |
| 8 #include <stdarg.h> | 8 #include <stdarg.h> |
| 9 #include <stdint.h> | 9 #include <stdint.h> |
| 10 #include <limits> | 10 #include <limits> |
| (...skipping 12894 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 12905 scoped_ptr<SpdyFrame> host2_resp_body( | 12905 scoped_ptr<SpdyFrame> host2_resp_body( |
| 12906 spdy_util_.ConstructSpdyBodyFrame(3, true)); | 12906 spdy_util_.ConstructSpdyBodyFrame(3, true)); |
| 12907 MockRead spdy_reads[] = { | 12907 MockRead spdy_reads[] = { |
| 12908 CreateMockRead(*host1_resp, 1), | 12908 CreateMockRead(*host1_resp, 1), |
| 12909 CreateMockRead(*host1_resp_body, 2), | 12909 CreateMockRead(*host1_resp_body, 2), |
| 12910 CreateMockRead(*host2_resp, 4), | 12910 CreateMockRead(*host2_resp, 4), |
| 12911 CreateMockRead(*host2_resp_body, 5), | 12911 CreateMockRead(*host2_resp_body, 5), |
| 12912 MockRead(ASYNC, 0, 6), | 12912 MockRead(ASYNC, 0, 6), |
| 12913 }; | 12913 }; |
| 12914 | 12914 |
| 12915 IPAddress ip; | 12915 IPEndPoint peer_addr(IPAddress::IPv4Localhost(), 443); |
| 12916 ASSERT_TRUE(ip.AssignFromIPLiteral("127.0.0.1")); | |
| 12917 IPEndPoint peer_addr = IPEndPoint(ip, 443); | |
| 12918 MockConnect connect(ASYNC, OK, peer_addr); | 12916 MockConnect connect(ASYNC, OK, peer_addr); |
| 12919 SequencedSocketData spdy_data(connect, spdy_reads, arraysize(spdy_reads), | 12917 SequencedSocketData spdy_data(connect, spdy_reads, arraysize(spdy_reads), |
| 12920 spdy_writes, arraysize(spdy_writes)); | 12918 spdy_writes, arraysize(spdy_writes)); |
| 12921 session_deps_.socket_factory->AddSocketDataProvider(&spdy_data); | 12919 session_deps_.socket_factory->AddSocketDataProvider(&spdy_data); |
| 12922 | 12920 |
| 12923 TestCompletionCallback callback; | 12921 TestCompletionCallback callback; |
| 12924 HttpRequestInfo request1; | 12922 HttpRequestInfo request1; |
| 12925 request1.method = "GET"; | 12923 request1.method = "GET"; |
| 12926 request1.url = GURL("https://www.example.org/"); | 12924 request1.url = GURL("https://www.example.org/"); |
| 12927 request1.load_flags = 0; | 12925 request1.load_flags = 0; |
| (...skipping 77 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 13005 scoped_ptr<SpdyFrame> host2_resp_body( | 13003 scoped_ptr<SpdyFrame> host2_resp_body( |
| 13006 spdy_util_.ConstructSpdyBodyFrame(3, true)); | 13004 spdy_util_.ConstructSpdyBodyFrame(3, true)); |
| 13007 MockRead spdy_reads[] = { | 13005 MockRead spdy_reads[] = { |
| 13008 CreateMockRead(*host1_resp, 1), | 13006 CreateMockRead(*host1_resp, 1), |
| 13009 CreateMockRead(*host1_resp_body, 2), | 13007 CreateMockRead(*host1_resp_body, 2), |
| 13010 CreateMockRead(*host2_resp, 4), | 13008 CreateMockRead(*host2_resp, 4), |
| 13011 CreateMockRead(*host2_resp_body, 5), | 13009 CreateMockRead(*host2_resp_body, 5), |
| 13012 MockRead(ASYNC, 0, 6), | 13010 MockRead(ASYNC, 0, 6), |
| 13013 }; | 13011 }; |
| 13014 | 13012 |
| 13015 IPAddress ip; | 13013 IPEndPoint peer_addr(IPAddress::IPv4Localhost(), 443); |
| 13016 ASSERT_TRUE(ip.AssignFromIPLiteral("127.0.0.1")); | |
| 13017 IPEndPoint peer_addr = IPEndPoint(ip, 443); | |
| 13018 MockConnect connect(ASYNC, OK, peer_addr); | 13014 MockConnect connect(ASYNC, OK, peer_addr); |
| 13019 SequencedSocketData spdy_data(connect, spdy_reads, arraysize(spdy_reads), | 13015 SequencedSocketData spdy_data(connect, spdy_reads, arraysize(spdy_reads), |
| 13020 spdy_writes, arraysize(spdy_writes)); | 13016 spdy_writes, arraysize(spdy_writes)); |
| 13021 session_deps_.socket_factory->AddSocketDataProvider(&spdy_data); | 13017 session_deps_.socket_factory->AddSocketDataProvider(&spdy_data); |
| 13022 | 13018 |
| 13023 TestCompletionCallback callback; | 13019 TestCompletionCallback callback; |
| 13024 HttpRequestInfo request1; | 13020 HttpRequestInfo request1; |
| 13025 request1.method = "GET"; | 13021 request1.method = "GET"; |
| 13026 request1.url = GURL("https://www.example.org/"); | 13022 request1.url = GURL("https://www.example.org/"); |
| 13027 request1.load_flags = 0; | 13023 request1.load_flags = 0; |
| (...skipping 108 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 13136 scoped_ptr<SpdyFrame> host2_resp_body( | 13132 scoped_ptr<SpdyFrame> host2_resp_body( |
| 13137 spdy_util_.ConstructSpdyBodyFrame(3, true)); | 13133 spdy_util_.ConstructSpdyBodyFrame(3, true)); |
| 13138 MockRead spdy_reads[] = { | 13134 MockRead spdy_reads[] = { |
| 13139 CreateMockRead(*host1_resp, 1), | 13135 CreateMockRead(*host1_resp, 1), |
| 13140 CreateMockRead(*host1_resp_body, 2), | 13136 CreateMockRead(*host1_resp_body, 2), |
| 13141 CreateMockRead(*host2_resp, 4), | 13137 CreateMockRead(*host2_resp, 4), |
| 13142 CreateMockRead(*host2_resp_body, 5), | 13138 CreateMockRead(*host2_resp_body, 5), |
| 13143 MockRead(ASYNC, 0, 6), | 13139 MockRead(ASYNC, 0, 6), |
| 13144 }; | 13140 }; |
| 13145 | 13141 |
| 13146 IPAddress ip; | 13142 IPEndPoint peer_addr(IPAddress::IPv4Localhost(), 443); |
| 13147 ASSERT_TRUE(ip.AssignFromIPLiteral("127.0.0.1")); | |
| 13148 IPEndPoint peer_addr = IPEndPoint(ip, 443); | |
| 13149 MockConnect connect(ASYNC, OK, peer_addr); | 13143 MockConnect connect(ASYNC, OK, peer_addr); |
| 13150 SequencedSocketData spdy_data(connect, spdy_reads, arraysize(spdy_reads), | 13144 SequencedSocketData spdy_data(connect, spdy_reads, arraysize(spdy_reads), |
| 13151 spdy_writes, arraysize(spdy_writes)); | 13145 spdy_writes, arraysize(spdy_writes)); |
| 13152 session_deps_.socket_factory->AddSocketDataProvider(&spdy_data); | 13146 session_deps_.socket_factory->AddSocketDataProvider(&spdy_data); |
| 13153 | 13147 |
| 13154 TestCompletionCallback callback; | 13148 TestCompletionCallback callback; |
| 13155 HttpRequestInfo request1; | 13149 HttpRequestInfo request1; |
| 13156 request1.method = "GET"; | 13150 request1.method = "GET"; |
| 13157 request1.url = GURL("https://www.example.org/"); | 13151 request1.url = GURL("https://www.example.org/"); |
| 13158 request1.load_flags = 0; | 13152 request1.load_flags = 0; |
| (...skipping 2800 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 15959 base::MessageLoop::current()->RunUntilIdle(); | 15953 base::MessageLoop::current()->RunUntilIdle(); |
| 15960 | 15954 |
| 15961 EXPECT_TRUE(trans.GetResponseInfo()->was_fetched_via_spdy); | 15955 EXPECT_TRUE(trans.GetResponseInfo()->was_fetched_via_spdy); |
| 15962 HttpRequestHeaders headers; | 15956 HttpRequestHeaders headers; |
| 15963 ASSERT_TRUE(trans.GetFullRequestHeaders(&headers)); | 15957 ASSERT_TRUE(trans.GetFullRequestHeaders(&headers)); |
| 15964 EXPECT_TRUE(headers.HasHeader(HttpRequestHeaders::kTokenBinding)); | 15958 EXPECT_TRUE(headers.HasHeader(HttpRequestHeaders::kTokenBinding)); |
| 15965 } | 15959 } |
| 15966 #endif // !defined(OS_IOS) | 15960 #endif // !defined(OS_IOS) |
| 15967 | 15961 |
| 15968 } // namespace net | 15962 } // namespace net |
| OLD | NEW |