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

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

Issue 9809033: Reverting this feature, once again. *sigh* (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 8 years, 9 months 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) 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
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
OLDNEW
« no previous file with comments | « net/http/http_network_transaction_spdy21_unittest.cc ('k') | net/http/http_network_transaction_spdy3_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698