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