OLD | NEW |
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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 <string> | 9 #include <string> |
10 #include <vector> | 10 #include <vector> |
(...skipping 9227 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
9238 EXPECT_EQ("HTTP/1.1 200 OK", response->headers->GetStatusLine()); | 9238 EXPECT_EQ("HTTP/1.1 200 OK", response->headers->GetStatusLine()); |
9239 EXPECT_TRUE(response->was_fetched_via_spdy); | 9239 EXPECT_TRUE(response->was_fetched_via_spdy); |
9240 EXPECT_TRUE(response->was_npn_negotiated); | 9240 EXPECT_TRUE(response->was_npn_negotiated); |
9241 ASSERT_EQ(OK, ReadTransaction(&trans2, &response_data)); | 9241 ASSERT_EQ(OK, ReadTransaction(&trans2, &response_data)); |
9242 EXPECT_EQ("hello!", response_data); | 9242 EXPECT_EQ("hello!", response_data); |
9243 | 9243 |
9244 HttpStreamFactory::set_next_protos(std::vector<std::string>()); | 9244 HttpStreamFactory::set_next_protos(std::vector<std::string>()); |
9245 HttpStreamFactory::set_use_alternate_protocols(false); | 9245 HttpStreamFactory::set_use_alternate_protocols(false); |
9246 } | 9246 } |
9247 | 9247 |
| 9248 TEST_F(HttpNetworkTransactionTest, CloseOldSpdySessionToOpenNewOne) { |
| 9249 HttpStreamFactory::set_next_protos(SpdyNextProtos()); |
| 9250 int old_max_sockets_per_group = |
| 9251 ClientSocketPoolManager::max_sockets_per_group(); |
| 9252 int old_max_sockets_per_proxy_server = |
| 9253 ClientSocketPoolManager::max_sockets_per_proxy_server(); |
| 9254 int old_max_sockets_per_pool = |
| 9255 ClientSocketPoolManager::max_sockets_per_pool(); |
| 9256 ClientSocketPoolManager::set_max_sockets_per_group(1); |
| 9257 ClientSocketPoolManager::set_max_sockets_per_proxy_server(1); |
| 9258 ClientSocketPoolManager::set_max_sockets_per_pool(1); |
| 9259 |
| 9260 // Use two different hosts with different IPs so they don't get pooled. |
| 9261 SessionDependencies session_deps; |
| 9262 session_deps.host_resolver->rules()->AddRule("a.com", "10.0.0.1"); |
| 9263 session_deps.host_resolver->rules()->AddRule("b.com", "10.0.0.2"); |
| 9264 scoped_refptr<HttpNetworkSession> session(CreateSession(&session_deps)); |
| 9265 |
| 9266 SSLSocketDataProvider ssl1(true, OK); |
| 9267 ssl1.next_proto_status = SSLClientSocket::kNextProtoNegotiated; |
| 9268 ssl1.next_proto = "spdy/2"; |
| 9269 ssl1.was_npn_negotiated = true; |
| 9270 SSLSocketDataProvider ssl2(true, OK); |
| 9271 ssl2.next_proto_status = SSLClientSocket::kNextProtoNegotiated; |
| 9272 ssl2.next_proto = "spdy/2"; |
| 9273 ssl2.was_npn_negotiated = true; |
| 9274 session_deps.socket_factory.AddSSLSocketDataProvider(&ssl1); |
| 9275 session_deps.socket_factory.AddSSLSocketDataProvider(&ssl2); |
| 9276 |
| 9277 scoped_ptr<spdy::SpdyFrame> host1_req(ConstructSpdyGet( |
| 9278 "https://www.a.com", false, 1, LOWEST)); |
| 9279 MockWrite spdy1_writes[] = { |
| 9280 CreateMockWrite(*host1_req, 1), |
| 9281 }; |
| 9282 scoped_ptr<spdy::SpdyFrame> host1_resp(ConstructSpdyGetSynReply(NULL, 0, 1)); |
| 9283 scoped_ptr<spdy::SpdyFrame> host1_resp_body(ConstructSpdyBodyFrame(1, true)); |
| 9284 MockRead spdy1_reads[] = { |
| 9285 CreateMockRead(*host1_resp, 2), |
| 9286 CreateMockRead(*host1_resp_body, 3), |
| 9287 MockRead(true, ERR_IO_PENDING, 4), |
| 9288 }; |
| 9289 |
| 9290 scoped_refptr<OrderedSocketData> spdy1_data( |
| 9291 new OrderedSocketData( |
| 9292 spdy1_reads, arraysize(spdy1_reads), |
| 9293 spdy1_writes, arraysize(spdy1_writes))); |
| 9294 session_deps.socket_factory.AddSocketDataProvider(spdy1_data); |
| 9295 |
| 9296 scoped_ptr<spdy::SpdyFrame> host2_req(ConstructSpdyGet( |
| 9297 "https://www.b.com", false, 1, LOWEST)); |
| 9298 MockWrite spdy2_writes[] = { |
| 9299 CreateMockWrite(*host2_req, 1), |
| 9300 }; |
| 9301 scoped_ptr<spdy::SpdyFrame> host2_resp(ConstructSpdyGetSynReply(NULL, 0, 1)); |
| 9302 scoped_ptr<spdy::SpdyFrame> host2_resp_body(ConstructSpdyBodyFrame(1, true)); |
| 9303 MockRead spdy2_reads[] = { |
| 9304 CreateMockRead(*host2_resp, 2), |
| 9305 CreateMockRead(*host2_resp_body, 3), |
| 9306 MockRead(true, ERR_IO_PENDING, 4), |
| 9307 }; |
| 9308 |
| 9309 scoped_refptr<OrderedSocketData> spdy2_data( |
| 9310 new OrderedSocketData( |
| 9311 spdy2_reads, arraysize(spdy2_reads), |
| 9312 spdy2_writes, arraysize(spdy2_writes))); |
| 9313 session_deps.socket_factory.AddSocketDataProvider(spdy2_data); |
| 9314 |
| 9315 MockWrite http_write[] = { |
| 9316 MockWrite("GET / HTTP/1.1\r\n" |
| 9317 "Host: www.a.com\r\n" |
| 9318 "Connection: keep-alive\r\n\r\n"), |
| 9319 }; |
| 9320 |
| 9321 MockRead http_read[] = { |
| 9322 MockRead("HTTP/1.1 200 OK\r\n"), |
| 9323 MockRead("Content-Type: text/html; charset=iso-8859-1\r\n"), |
| 9324 MockRead("Content-Length: 6\r\n\r\n"), |
| 9325 MockRead("hello!"), |
| 9326 }; |
| 9327 |
| 9328 StaticSocketDataProvider http_data(http_read, arraysize(http_read), |
| 9329 http_write, arraysize(http_write)); |
| 9330 session_deps.socket_factory.AddSocketDataProvider(&http_data); |
| 9331 |
| 9332 HostPortPair host_port_pair_a("www.a.com", 443); |
| 9333 HostPortProxyPair host_port_proxy_pair_a( |
| 9334 host_port_pair_a, ProxyServer::Direct()); |
| 9335 EXPECT_FALSE( |
| 9336 session->spdy_session_pool()->HasSession(host_port_proxy_pair_a)); |
| 9337 |
| 9338 TestOldCompletionCallback callback; |
| 9339 HttpRequestInfo request1; |
| 9340 request1.method = "GET"; |
| 9341 request1.url = GURL("https://www.a.com/"); |
| 9342 request1.load_flags = 0; |
| 9343 scoped_ptr<HttpNetworkTransaction> trans(new HttpNetworkTransaction(session)); |
| 9344 |
| 9345 int rv = trans->Start(&request1, &callback, BoundNetLog()); |
| 9346 EXPECT_EQ(ERR_IO_PENDING, rv); |
| 9347 EXPECT_EQ(OK, callback.WaitForResult()); |
| 9348 |
| 9349 const HttpResponseInfo* response = trans->GetResponseInfo(); |
| 9350 ASSERT_TRUE(response != NULL); |
| 9351 ASSERT_TRUE(response->headers != NULL); |
| 9352 EXPECT_EQ("HTTP/1.1 200 OK", response->headers->GetStatusLine()); |
| 9353 EXPECT_TRUE(response->was_fetched_via_spdy); |
| 9354 EXPECT_TRUE(response->was_npn_negotiated); |
| 9355 |
| 9356 std::string response_data; |
| 9357 ASSERT_EQ(OK, ReadTransaction(trans.get(), &response_data)); |
| 9358 EXPECT_EQ("hello!", response_data); |
| 9359 trans.reset(); |
| 9360 EXPECT_TRUE( |
| 9361 session->spdy_session_pool()->HasSession(host_port_proxy_pair_a)); |
| 9362 |
| 9363 HostPortPair host_port_pair_b("www.b.com", 443); |
| 9364 HostPortProxyPair host_port_proxy_pair_b( |
| 9365 host_port_pair_b, ProxyServer::Direct()); |
| 9366 EXPECT_FALSE( |
| 9367 session->spdy_session_pool()->HasSession(host_port_proxy_pair_b)); |
| 9368 HttpRequestInfo request2; |
| 9369 request2.method = "GET"; |
| 9370 request2.url = GURL("https://www.b.com/"); |
| 9371 request2.load_flags = 0; |
| 9372 trans.reset(new HttpNetworkTransaction(session)); |
| 9373 |
| 9374 rv = trans->Start(&request2, &callback, BoundNetLog()); |
| 9375 EXPECT_EQ(ERR_IO_PENDING, rv); |
| 9376 EXPECT_EQ(OK, callback.WaitForResult()); |
| 9377 |
| 9378 response = trans->GetResponseInfo(); |
| 9379 ASSERT_TRUE(response != NULL); |
| 9380 ASSERT_TRUE(response->headers != NULL); |
| 9381 EXPECT_EQ("HTTP/1.1 200 OK", response->headers->GetStatusLine()); |
| 9382 EXPECT_TRUE(response->was_fetched_via_spdy); |
| 9383 EXPECT_TRUE(response->was_npn_negotiated); |
| 9384 ASSERT_EQ(OK, ReadTransaction(trans.get(), &response_data)); |
| 9385 EXPECT_EQ("hello!", response_data); |
| 9386 EXPECT_FALSE( |
| 9387 session->spdy_session_pool()->HasSession(host_port_proxy_pair_a)); |
| 9388 EXPECT_TRUE( |
| 9389 session->spdy_session_pool()->HasSession(host_port_proxy_pair_b)); |
| 9390 |
| 9391 HostPortPair host_port_pair_a1("www.a.com", 80); |
| 9392 HostPortProxyPair host_port_proxy_pair_a1( |
| 9393 host_port_pair_a1, ProxyServer::Direct()); |
| 9394 EXPECT_FALSE( |
| 9395 session->spdy_session_pool()->HasSession(host_port_proxy_pair_a1)); |
| 9396 HttpRequestInfo request3; |
| 9397 request3.method = "GET"; |
| 9398 request3.url = GURL("http://www.a.com/"); |
| 9399 request3.load_flags = 0; |
| 9400 trans.reset(new HttpNetworkTransaction(session)); |
| 9401 |
| 9402 rv = trans->Start(&request3, &callback, BoundNetLog()); |
| 9403 EXPECT_EQ(ERR_IO_PENDING, rv); |
| 9404 EXPECT_EQ(OK, callback.WaitForResult()); |
| 9405 |
| 9406 response = trans->GetResponseInfo(); |
| 9407 ASSERT_TRUE(response != NULL); |
| 9408 ASSERT_TRUE(response->headers != NULL); |
| 9409 EXPECT_EQ("HTTP/1.1 200 OK", response->headers->GetStatusLine()); |
| 9410 EXPECT_FALSE(response->was_fetched_via_spdy); |
| 9411 EXPECT_FALSE(response->was_npn_negotiated); |
| 9412 ASSERT_EQ(OK, ReadTransaction(trans.get(), &response_data)); |
| 9413 EXPECT_EQ("hello!", response_data); |
| 9414 EXPECT_FALSE( |
| 9415 session->spdy_session_pool()->HasSession(host_port_proxy_pair_a)); |
| 9416 EXPECT_FALSE( |
| 9417 session->spdy_session_pool()->HasSession(host_port_proxy_pair_b)); |
| 9418 |
| 9419 HttpStreamFactory::set_next_protos(std::vector<std::string>()); |
| 9420 ClientSocketPoolManager::set_max_sockets_per_pool(old_max_sockets_per_pool); |
| 9421 ClientSocketPoolManager::set_max_sockets_per_proxy_server( |
| 9422 old_max_sockets_per_proxy_server); |
| 9423 ClientSocketPoolManager::set_max_sockets_per_group(old_max_sockets_per_group); |
| 9424 } |
| 9425 |
9248 } // namespace net | 9426 } // namespace net |
OLD | NEW |