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_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 9353 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
9364 data_writes2, arraysize(data_writes2)); | 9364 data_writes2, arraysize(data_writes2)); |
9365 StaticSocketDataProvider* data[] = { &data1, &data2 }; | 9365 StaticSocketDataProvider* data[] = { &data1, &data2 }; |
9366 | 9366 |
9367 SimpleGetHelperResult out = SimpleGetHelperForData(data, arraysize(data)); | 9367 SimpleGetHelperResult out = SimpleGetHelperForData(data, arraysize(data)); |
9368 | 9368 |
9369 EXPECT_EQ(OK, out.rv); | 9369 EXPECT_EQ(OK, out.rv); |
9370 EXPECT_EQ("HTTP/1.0 200 OK", out.status_line); | 9370 EXPECT_EQ("HTTP/1.0 200 OK", out.status_line); |
9371 EXPECT_EQ("hello world", out.response_data); | 9371 EXPECT_EQ("hello world", out.response_data); |
9372 } | 9372 } |
9373 | 9373 |
| 9374 TEST_F(HttpNetworkTransactionSpdy3Test, CloseOldSpdySessionToOpenNewOne) { |
| 9375 HttpStreamFactory::SetNextProtos(SpdyNextProtos()); |
| 9376 int old_max_sockets_per_group = |
| 9377 ClientSocketPoolManager::max_sockets_per_group(); |
| 9378 int old_max_sockets_per_proxy_server = |
| 9379 ClientSocketPoolManager::max_sockets_per_proxy_server(); |
| 9380 int old_max_sockets_per_pool = |
| 9381 ClientSocketPoolManager::max_sockets_per_pool(); |
| 9382 ClientSocketPoolManager::set_max_sockets_per_group(1); |
| 9383 ClientSocketPoolManager::set_max_sockets_per_proxy_server(1); |
| 9384 ClientSocketPoolManager::set_max_sockets_per_pool(1); |
| 9385 |
| 9386 // Use two different hosts with different IPs so they don't get pooled. |
| 9387 SessionDependencies session_deps; |
| 9388 session_deps.host_resolver->rules()->AddRule("a.com", "10.0.0.1"); |
| 9389 session_deps.host_resolver->rules()->AddRule("b.com", "10.0.0.2"); |
| 9390 scoped_refptr<HttpNetworkSession> session(CreateSession(&session_deps)); |
| 9391 |
| 9392 SSLSocketDataProvider ssl1(ASYNC, OK); |
| 9393 ssl1.SetNextProto(SSLClientSocket::kProtoSPDY21); |
| 9394 SSLSocketDataProvider ssl2(ASYNC, OK); |
| 9395 ssl2.SetNextProto(SSLClientSocket::kProtoSPDY21); |
| 9396 session_deps.socket_factory.AddSSLSocketDataProvider(&ssl1); |
| 9397 session_deps.socket_factory.AddSSLSocketDataProvider(&ssl2); |
| 9398 |
| 9399 scoped_ptr<spdy::SpdyFrame> host1_req(ConstructSpdyGet( |
| 9400 "https://www.a.com", false, 1, LOWEST)); |
| 9401 MockWrite spdy1_writes[] = { |
| 9402 CreateMockWrite(*host1_req, 1), |
| 9403 }; |
| 9404 scoped_ptr<spdy::SpdyFrame> host1_resp(ConstructSpdyGetSynReply(NULL, 0, 1)); |
| 9405 scoped_ptr<spdy::SpdyFrame> host1_resp_body(ConstructSpdyBodyFrame(1, true)); |
| 9406 MockRead spdy1_reads[] = { |
| 9407 CreateMockRead(*host1_resp, 2), |
| 9408 CreateMockRead(*host1_resp_body, 3), |
| 9409 MockRead(ASYNC, ERR_IO_PENDING, 4), |
| 9410 }; |
| 9411 |
| 9412 scoped_ptr<OrderedSocketData> spdy1_data( |
| 9413 new OrderedSocketData( |
| 9414 spdy1_reads, arraysize(spdy1_reads), |
| 9415 spdy1_writes, arraysize(spdy1_writes))); |
| 9416 session_deps.socket_factory.AddSocketDataProvider(spdy1_data.get()); |
| 9417 |
| 9418 scoped_ptr<spdy::SpdyFrame> host2_req(ConstructSpdyGet( |
| 9419 "https://www.b.com", false, 1, LOWEST)); |
| 9420 MockWrite spdy2_writes[] = { |
| 9421 CreateMockWrite(*host2_req, 1), |
| 9422 }; |
| 9423 scoped_ptr<spdy::SpdyFrame> host2_resp(ConstructSpdyGetSynReply(NULL, 0, 1)); |
| 9424 scoped_ptr<spdy::SpdyFrame> host2_resp_body(ConstructSpdyBodyFrame(1, true)); |
| 9425 MockRead spdy2_reads[] = { |
| 9426 CreateMockRead(*host2_resp, 2), |
| 9427 CreateMockRead(*host2_resp_body, 3), |
| 9428 MockRead(ASYNC, ERR_IO_PENDING, 4), |
| 9429 }; |
| 9430 |
| 9431 scoped_ptr<OrderedSocketData> spdy2_data( |
| 9432 new OrderedSocketData( |
| 9433 spdy2_reads, arraysize(spdy2_reads), |
| 9434 spdy2_writes, arraysize(spdy2_writes))); |
| 9435 session_deps.socket_factory.AddSocketDataProvider(spdy2_data.get()); |
| 9436 |
| 9437 MockWrite http_write[] = { |
| 9438 MockWrite("GET / HTTP/1.1\r\n" |
| 9439 "Host: www.a.com\r\n" |
| 9440 "Connection: keep-alive\r\n\r\n"), |
| 9441 }; |
| 9442 |
| 9443 MockRead http_read[] = { |
| 9444 MockRead("HTTP/1.1 200 OK\r\n"), |
| 9445 MockRead("Content-Type: text/html; charset=iso-8859-1\r\n"), |
| 9446 MockRead("Content-Length: 6\r\n\r\n"), |
| 9447 MockRead("hello!"), |
| 9448 }; |
| 9449 StaticSocketDataProvider http_data(http_read, arraysize(http_read), |
| 9450 http_write, arraysize(http_write)); |
| 9451 session_deps.socket_factory.AddSocketDataProvider(&http_data); |
| 9452 |
| 9453 HostPortPair host_port_pair_a("www.a.com", 443); |
| 9454 HostPortProxyPair host_port_proxy_pair_a( |
| 9455 host_port_pair_a, ProxyServer::Direct()); |
| 9456 EXPECT_FALSE( |
| 9457 session->spdy_session_pool()->HasSession(host_port_proxy_pair_a)); |
| 9458 |
| 9459 TestCompletionCallback callback; |
| 9460 HttpRequestInfo request1; |
| 9461 request1.method = "GET"; |
| 9462 request1.url = GURL("https://www.a.com/"); |
| 9463 request1.load_flags = 0; |
| 9464 scoped_ptr<HttpNetworkTransaction> trans(new HttpNetworkTransaction(session)); |
| 9465 |
| 9466 int rv = trans->Start(&request1, callback.callback(), BoundNetLog()); |
| 9467 EXPECT_EQ(ERR_IO_PENDING, rv); |
| 9468 EXPECT_EQ(OK, callback.WaitForResult()); |
| 9469 |
| 9470 const HttpResponseInfo* response = trans->GetResponseInfo(); |
| 9471 ASSERT_TRUE(response != NULL); |
| 9472 ASSERT_TRUE(response->headers != NULL); |
| 9473 EXPECT_EQ("HTTP/1.1 200 OK", response->headers->GetStatusLine()); |
| 9474 EXPECT_TRUE(response->was_fetched_via_spdy); |
| 9475 EXPECT_TRUE(response->was_npn_negotiated); |
| 9476 |
| 9477 std::string response_data; |
| 9478 ASSERT_EQ(OK, ReadTransaction(trans.get(), &response_data)); |
| 9479 EXPECT_EQ("hello!", response_data); |
| 9480 trans.reset(); |
| 9481 EXPECT_TRUE( |
| 9482 session->spdy_session_pool()->HasSession(host_port_proxy_pair_a)); |
| 9483 |
| 9484 HostPortPair host_port_pair_b("www.b.com", 443); |
| 9485 HostPortProxyPair host_port_proxy_pair_b( |
| 9486 host_port_pair_b, ProxyServer::Direct()); |
| 9487 EXPECT_FALSE( |
| 9488 session->spdy_session_pool()->HasSession(host_port_proxy_pair_b)); |
| 9489 HttpRequestInfo request2; |
| 9490 request2.method = "GET"; |
| 9491 request2.url = GURL("https://www.b.com/"); |
| 9492 request2.load_flags = 0; |
| 9493 trans.reset(new HttpNetworkTransaction(session)); |
| 9494 |
| 9495 rv = trans->Start(&request2, callback.callback(), BoundNetLog()); |
| 9496 EXPECT_EQ(ERR_IO_PENDING, rv); |
| 9497 EXPECT_EQ(OK, callback.WaitForResult()); |
| 9498 |
| 9499 response = trans->GetResponseInfo(); |
| 9500 ASSERT_TRUE(response != NULL); |
| 9501 ASSERT_TRUE(response->headers != NULL); |
| 9502 EXPECT_EQ("HTTP/1.1 200 OK", response->headers->GetStatusLine()); |
| 9503 EXPECT_TRUE(response->was_fetched_via_spdy); |
| 9504 EXPECT_TRUE(response->was_npn_negotiated); |
| 9505 ASSERT_EQ(OK, ReadTransaction(trans.get(), &response_data)); |
| 9506 EXPECT_EQ("hello!", response_data); |
| 9507 EXPECT_FALSE( |
| 9508 session->spdy_session_pool()->HasSession(host_port_proxy_pair_a)); |
| 9509 EXPECT_TRUE( |
| 9510 session->spdy_session_pool()->HasSession(host_port_proxy_pair_b)); |
| 9511 |
| 9512 HostPortPair host_port_pair_a1("www.a.com", 80); |
| 9513 HostPortProxyPair host_port_proxy_pair_a1( |
| 9514 host_port_pair_a1, ProxyServer::Direct()); |
| 9515 EXPECT_FALSE( |
| 9516 session->spdy_session_pool()->HasSession(host_port_proxy_pair_a1)); |
| 9517 HttpRequestInfo request3; |
| 9518 request3.method = "GET"; |
| 9519 request3.url = GURL("http://www.a.com/"); |
| 9520 request3.load_flags = 0; |
| 9521 trans.reset(new HttpNetworkTransaction(session)); |
| 9522 |
| 9523 rv = trans->Start(&request3, callback.callback(), BoundNetLog()); |
| 9524 EXPECT_EQ(ERR_IO_PENDING, rv); |
| 9525 EXPECT_EQ(OK, callback.WaitForResult()); |
| 9526 |
| 9527 response = trans->GetResponseInfo(); |
| 9528 ASSERT_TRUE(response != NULL); |
| 9529 ASSERT_TRUE(response->headers != NULL); |
| 9530 EXPECT_EQ("HTTP/1.1 200 OK", response->headers->GetStatusLine()); |
| 9531 EXPECT_FALSE(response->was_fetched_via_spdy); |
| 9532 EXPECT_FALSE(response->was_npn_negotiated); |
| 9533 ASSERT_EQ(OK, ReadTransaction(trans.get(), &response_data)); |
| 9534 EXPECT_EQ("hello!", response_data); |
| 9535 EXPECT_FALSE( |
| 9536 session->spdy_session_pool()->HasSession(host_port_proxy_pair_a)); |
| 9537 EXPECT_FALSE( |
| 9538 session->spdy_session_pool()->HasSession(host_port_proxy_pair_b)); |
| 9539 |
| 9540 HttpStreamFactory::SetNextProtos(std::vector<std::string>()); |
| 9541 ClientSocketPoolManager::set_max_sockets_per_pool(old_max_sockets_per_pool); |
| 9542 ClientSocketPoolManager::set_max_sockets_per_proxy_server( |
| 9543 old_max_sockets_per_proxy_server); |
| 9544 ClientSocketPoolManager::set_max_sockets_per_group(old_max_sockets_per_group); |
| 9545 } |
| 9546 |
9374 } // namespace net | 9547 } // namespace net |
OLD | NEW |