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 9532 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
9543 data_writes2, arraysize(data_writes2)); | 9543 data_writes2, arraysize(data_writes2)); |
9544 StaticSocketDataProvider* data[] = { &data1, &data2 }; | 9544 StaticSocketDataProvider* data[] = { &data1, &data2 }; |
9545 | 9545 |
9546 SimpleGetHelperResult out = SimpleGetHelperForData(data, arraysize(data)); | 9546 SimpleGetHelperResult out = SimpleGetHelperForData(data, arraysize(data)); |
9547 | 9547 |
9548 EXPECT_EQ(OK, out.rv); | 9548 EXPECT_EQ(OK, out.rv); |
9549 EXPECT_EQ("HTTP/1.0 200 OK", out.status_line); | 9549 EXPECT_EQ("HTTP/1.0 200 OK", out.status_line); |
9550 EXPECT_EQ("hello world", out.response_data); | 9550 EXPECT_EQ("hello world", out.response_data); |
9551 } | 9551 } |
9552 | 9552 |
9553 TEST_F(HttpNetworkTransactionSpdy3Test, CloseIdleSpdySessionToOpenNewOne) { | |
9554 HttpStreamFactory::SetNextProtos(SpdyNextProtos()); | |
9555 int old_max_sockets_per_group = | |
9556 ClientSocketPoolManager::max_sockets_per_group( | |
9557 HttpNetworkSession::NORMAL_SOCKET_POOL); | |
9558 int old_max_sockets_per_proxy_server = | |
9559 ClientSocketPoolManager::max_sockets_per_proxy_server( | |
9560 HttpNetworkSession::NORMAL_SOCKET_POOL); | |
9561 int old_max_sockets_per_pool = | |
9562 ClientSocketPoolManager::max_sockets_per_pool( | |
9563 HttpNetworkSession::NORMAL_SOCKET_POOL); | |
9564 ClientSocketPoolManager::set_max_sockets_per_group( | |
9565 HttpNetworkSession::NORMAL_SOCKET_POOL, 1); | |
9566 ClientSocketPoolManager::set_max_sockets_per_proxy_server( | |
9567 HttpNetworkSession::NORMAL_SOCKET_POOL, 1); | |
9568 ClientSocketPoolManager::set_max_sockets_per_pool( | |
9569 HttpNetworkSession::NORMAL_SOCKET_POOL, 1); | |
9570 | |
9571 // Use two different hosts with different IPs so they don't get pooled. | |
9572 SessionDependencies session_deps; | |
9573 session_deps.host_resolver->rules()->AddRule("a.com", "10.0.0.1"); | |
9574 session_deps.host_resolver->rules()->AddRule("b.com", "10.0.0.2"); | |
9575 scoped_refptr<HttpNetworkSession> session(CreateSession(&session_deps)); | |
9576 | |
9577 SSLSocketDataProvider ssl1(ASYNC, OK); | |
9578 ssl1.SetNextProto(kProtoSPDY3); | |
9579 SSLSocketDataProvider ssl2(ASYNC, OK); | |
9580 ssl2.SetNextProto(kProtoSPDY3); | |
9581 session_deps.socket_factory.AddSSLSocketDataProvider(&ssl1); | |
9582 session_deps.socket_factory.AddSSLSocketDataProvider(&ssl2); | |
9583 | |
9584 scoped_ptr<SpdyFrame> host1_req(ConstructSpdyGet( | |
9585 "https://www.a.com", false, 1, LOWEST)); | |
9586 MockWrite spdy1_writes[] = { | |
9587 CreateMockWrite(*host1_req, 1), | |
9588 }; | |
9589 scoped_ptr<SpdyFrame> host1_resp(ConstructSpdyGetSynReply(NULL, 0, 1)); | |
9590 scoped_ptr<SpdyFrame> host1_resp_body(ConstructSpdyBodyFrame(1, true)); | |
9591 MockRead spdy1_reads[] = { | |
9592 CreateMockRead(*host1_resp, 2), | |
9593 CreateMockRead(*host1_resp_body, 3), | |
9594 MockRead(ASYNC, ERR_IO_PENDING, 4), | |
9595 }; | |
9596 | |
9597 scoped_ptr<OrderedSocketData> spdy1_data( | |
9598 new OrderedSocketData( | |
9599 spdy1_reads, arraysize(spdy1_reads), | |
9600 spdy1_writes, arraysize(spdy1_writes))); | |
9601 session_deps.socket_factory.AddSocketDataProvider(spdy1_data.get()); | |
9602 | |
9603 scoped_ptr<SpdyFrame> host2_req(ConstructSpdyGet( | |
9604 "https://www.b.com", false, 1, LOWEST)); | |
9605 MockWrite spdy2_writes[] = { | |
9606 CreateMockWrite(*host2_req, 1), | |
9607 }; | |
9608 scoped_ptr<SpdyFrame> host2_resp(ConstructSpdyGetSynReply(NULL, 0, 1)); | |
9609 scoped_ptr<SpdyFrame> host2_resp_body(ConstructSpdyBodyFrame(1, true)); | |
9610 MockRead spdy2_reads[] = { | |
9611 CreateMockRead(*host2_resp, 2), | |
9612 CreateMockRead(*host2_resp_body, 3), | |
9613 MockRead(ASYNC, ERR_IO_PENDING, 4), | |
9614 }; | |
9615 | |
9616 scoped_ptr<OrderedSocketData> spdy2_data( | |
9617 new OrderedSocketData( | |
9618 spdy2_reads, arraysize(spdy2_reads), | |
9619 spdy2_writes, arraysize(spdy2_writes))); | |
9620 session_deps.socket_factory.AddSocketDataProvider(spdy2_data.get()); | |
9621 | |
9622 MockWrite http_write[] = { | |
9623 MockWrite("GET / HTTP/1.1\r\n" | |
9624 "Host: www.a.com\r\n" | |
9625 "Connection: keep-alive\r\n\r\n"), | |
9626 }; | |
9627 | |
9628 MockRead http_read[] = { | |
9629 MockRead("HTTP/1.1 200 OK\r\n"), | |
9630 MockRead("Content-Type: text/html; charset=iso-8859-1\r\n"), | |
9631 MockRead("Content-Length: 6\r\n\r\n"), | |
9632 MockRead("hello!"), | |
9633 }; | |
9634 StaticSocketDataProvider http_data(http_read, arraysize(http_read), | |
9635 http_write, arraysize(http_write)); | |
9636 session_deps.socket_factory.AddSocketDataProvider(&http_data); | |
9637 | |
9638 HostPortPair host_port_pair_a("www.a.com", 443); | |
9639 HostPortProxyPair host_port_proxy_pair_a( | |
9640 host_port_pair_a, ProxyServer::Direct()); | |
9641 EXPECT_FALSE( | |
9642 session->spdy_session_pool()->HasSession(host_port_proxy_pair_a)); | |
9643 | |
9644 TestCompletionCallback callback; | |
9645 HttpRequestInfo request1; | |
9646 request1.method = "GET"; | |
9647 request1.url = GURL("https://www.a.com/"); | |
9648 request1.load_flags = 0; | |
9649 scoped_ptr<HttpNetworkTransaction> trans(new HttpNetworkTransaction(session)); | |
9650 | |
9651 int rv = trans->Start(&request1, callback.callback(), BoundNetLog()); | |
9652 EXPECT_EQ(ERR_IO_PENDING, rv); | |
9653 EXPECT_EQ(OK, callback.WaitForResult()); | |
9654 | |
9655 const HttpResponseInfo* response = trans->GetResponseInfo(); | |
9656 ASSERT_TRUE(response != NULL); | |
9657 ASSERT_TRUE(response->headers != NULL); | |
9658 EXPECT_EQ("HTTP/1.1 200 OK", response->headers->GetStatusLine()); | |
9659 EXPECT_TRUE(response->was_fetched_via_spdy); | |
9660 EXPECT_TRUE(response->was_npn_negotiated); | |
9661 | |
9662 std::string response_data; | |
9663 ASSERT_EQ(OK, ReadTransaction(trans.get(), &response_data)); | |
9664 EXPECT_EQ("hello!", response_data); | |
9665 trans.reset(); | |
9666 EXPECT_TRUE( | |
9667 session->spdy_session_pool()->HasSession(host_port_proxy_pair_a)); | |
9668 | |
9669 HostPortPair host_port_pair_b("www.b.com", 443); | |
9670 HostPortProxyPair host_port_proxy_pair_b( | |
9671 host_port_pair_b, ProxyServer::Direct()); | |
9672 EXPECT_FALSE( | |
9673 session->spdy_session_pool()->HasSession(host_port_proxy_pair_b)); | |
9674 HttpRequestInfo request2; | |
9675 request2.method = "GET"; | |
9676 request2.url = GURL("https://www.b.com/"); | |
9677 request2.load_flags = 0; | |
9678 trans.reset(new HttpNetworkTransaction(session)); | |
9679 | |
9680 rv = trans->Start(&request2, callback.callback(), BoundNetLog()); | |
9681 EXPECT_EQ(ERR_IO_PENDING, rv); | |
9682 EXPECT_EQ(OK, callback.WaitForResult()); | |
9683 | |
9684 response = trans->GetResponseInfo(); | |
9685 ASSERT_TRUE(response != NULL); | |
9686 ASSERT_TRUE(response->headers != NULL); | |
9687 EXPECT_EQ("HTTP/1.1 200 OK", response->headers->GetStatusLine()); | |
9688 EXPECT_TRUE(response->was_fetched_via_spdy); | |
9689 EXPECT_TRUE(response->was_npn_negotiated); | |
9690 ASSERT_EQ(OK, ReadTransaction(trans.get(), &response_data)); | |
9691 EXPECT_EQ("hello!", response_data); | |
9692 EXPECT_FALSE( | |
9693 session->spdy_session_pool()->HasSession(host_port_proxy_pair_a)); | |
9694 EXPECT_TRUE( | |
9695 session->spdy_session_pool()->HasSession(host_port_proxy_pair_b)); | |
9696 | |
9697 HostPortPair host_port_pair_a1("www.a.com", 80); | |
9698 HostPortProxyPair host_port_proxy_pair_a1( | |
9699 host_port_pair_a1, ProxyServer::Direct()); | |
9700 EXPECT_FALSE( | |
9701 session->spdy_session_pool()->HasSession(host_port_proxy_pair_a1)); | |
9702 HttpRequestInfo request3; | |
9703 request3.method = "GET"; | |
9704 request3.url = GURL("http://www.a.com/"); | |
9705 request3.load_flags = 0; | |
9706 trans.reset(new HttpNetworkTransaction(session)); | |
9707 | |
9708 rv = trans->Start(&request3, callback.callback(), BoundNetLog()); | |
9709 EXPECT_EQ(ERR_IO_PENDING, rv); | |
9710 EXPECT_EQ(OK, callback.WaitForResult()); | |
9711 | |
9712 response = trans->GetResponseInfo(); | |
9713 ASSERT_TRUE(response != NULL); | |
9714 ASSERT_TRUE(response->headers != NULL); | |
9715 EXPECT_EQ("HTTP/1.1 200 OK", response->headers->GetStatusLine()); | |
9716 EXPECT_FALSE(response->was_fetched_via_spdy); | |
9717 EXPECT_FALSE(response->was_npn_negotiated); | |
9718 ASSERT_EQ(OK, ReadTransaction(trans.get(), &response_data)); | |
9719 EXPECT_EQ("hello!", response_data); | |
9720 EXPECT_FALSE( | |
9721 session->spdy_session_pool()->HasSession(host_port_proxy_pair_a)); | |
9722 EXPECT_FALSE( | |
9723 session->spdy_session_pool()->HasSession(host_port_proxy_pair_b)); | |
9724 | |
9725 HttpStreamFactory::SetNextProtos(std::vector<std::string>()); | |
9726 ClientSocketPoolManager::set_max_sockets_per_pool( | |
9727 HttpNetworkSession::NORMAL_SOCKET_POOL, old_max_sockets_per_pool); | |
9728 ClientSocketPoolManager::set_max_sockets_per_proxy_server( | |
9729 HttpNetworkSession::NORMAL_SOCKET_POOL, old_max_sockets_per_proxy_server); | |
9730 ClientSocketPoolManager::set_max_sockets_per_group( | |
9731 HttpNetworkSession::NORMAL_SOCKET_POOL, old_max_sockets_per_group); | |
9732 } | |
9733 | |
9734 } // namespace net | 9553 } // namespace net |
OLD | NEW |