Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(213)

Side by Side Diff: net/http/http_network_transaction_unittest.cc

Issue 8340012: Close idle connections / SPDY sessions when needed. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: OVERRIDE Created 9 years, 1 month ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
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
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
OLDNEW
« no previous file with comments | « no previous file | net/http/http_proxy_client_socket_pool.h » ('j') | net/socket/client_socket_handle.cc » ('J')

Powered by Google App Engine
This is Rietveld 408576698