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

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

Issue 9251019: Fixes to socket_test_util.cc. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Renamed blocked_ -> read_in_progress_. Created 8 years, 11 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
« no previous file with comments | « net/ftp/ftp_network_transaction_unittest.cc ('k') | net/socket/socket_test_util.h » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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 2130 matching lines...) Expand 10 before | Expand all | Expand 10 after
2141 MockWrite spdy_writes[] = { CreateMockWrite(*req) }; 2141 MockWrite spdy_writes[] = { CreateMockWrite(*req) };
2142 2142
2143 scoped_ptr<spdy::SpdyFrame> resp(ConstructSpdyGetSynReply(NULL, 0, 1)); 2143 scoped_ptr<spdy::SpdyFrame> resp(ConstructSpdyGetSynReply(NULL, 0, 1));
2144 scoped_ptr<spdy::SpdyFrame> data(ConstructSpdyBodyFrame(1, true)); 2144 scoped_ptr<spdy::SpdyFrame> data(ConstructSpdyBodyFrame(1, true));
2145 MockRead spdy_reads[] = { 2145 MockRead spdy_reads[] = {
2146 CreateMockRead(*resp), 2146 CreateMockRead(*resp),
2147 CreateMockRead(*data), 2147 CreateMockRead(*data),
2148 MockRead(true, 0, 0), 2148 MockRead(true, 0, 0),
2149 }; 2149 };
2150 2150
2151 scoped_refptr<DelayedSocketData> spdy_data( 2151 scoped_ptr<DelayedSocketData> spdy_data(
2152 new DelayedSocketData( 2152 new DelayedSocketData(
2153 1, // wait for one write to finish before reading. 2153 1, // wait for one write to finish before reading.
2154 spdy_reads, arraysize(spdy_reads), 2154 spdy_reads, arraysize(spdy_reads),
2155 spdy_writes, arraysize(spdy_writes))); 2155 spdy_writes, arraysize(spdy_writes)));
2156 session_deps.socket_factory.AddSocketDataProvider(spdy_data); 2156 session_deps.socket_factory.AddSocketDataProvider(spdy_data.get());
2157 2157
2158 SSLSocketDataProvider ssl(true, OK); 2158 SSLSocketDataProvider ssl(true, OK);
2159 ssl.next_proto_status = SSLClientSocket::kNextProtoNegotiated; 2159 ssl.next_proto_status = SSLClientSocket::kNextProtoNegotiated;
2160 ssl.next_proto = "spdy/2"; 2160 ssl.next_proto = "spdy/2";
2161 ssl.was_npn_negotiated = true; 2161 ssl.was_npn_negotiated = true;
2162 ssl.protocol_negotiated = SSLClientSocket::kProtoSPDY2; 2162 ssl.protocol_negotiated = SSLClientSocket::kProtoSPDY2;
2163 session_deps.socket_factory.AddSSLSocketDataProvider(&ssl); 2163 session_deps.socket_factory.AddSSLSocketDataProvider(&ssl);
2164 2164
2165 TestCompletionCallback callback1; 2165 TestCompletionCallback callback1;
2166 2166
(...skipping 63 matching lines...) Expand 10 before | Expand all | Expand 10 after
2230 scoped_ptr<spdy::SpdyFrame> resp_data(ConstructSpdyGetSynReply(NULL, 0, 3)); 2230 scoped_ptr<spdy::SpdyFrame> resp_data(ConstructSpdyGetSynReply(NULL, 0, 3));
2231 scoped_ptr<spdy::SpdyFrame> body_data(ConstructSpdyBodyFrame(3, true)); 2231 scoped_ptr<spdy::SpdyFrame> body_data(ConstructSpdyBodyFrame(3, true));
2232 MockRead spdy_reads[] = { 2232 MockRead spdy_reads[] = {
2233 CreateMockRead(*resp_authentication, 2), 2233 CreateMockRead(*resp_authentication, 2),
2234 CreateMockRead(*body_authentication, 3), 2234 CreateMockRead(*body_authentication, 3),
2235 CreateMockRead(*resp_data, 5), 2235 CreateMockRead(*resp_data, 5),
2236 CreateMockRead(*body_data, 6), 2236 CreateMockRead(*body_data, 6),
2237 MockRead(true, 0, 7), 2237 MockRead(true, 0, 7),
2238 }; 2238 };
2239 2239
2240 scoped_refptr<OrderedSocketData> data( 2240 scoped_ptr<OrderedSocketData> data(
2241 new OrderedSocketData(spdy_reads, arraysize(spdy_reads), 2241 new OrderedSocketData(spdy_reads, arraysize(spdy_reads),
2242 spdy_writes, arraysize(spdy_writes))); 2242 spdy_writes, arraysize(spdy_writes)));
2243 session_deps.socket_factory.AddSocketDataProvider(data); 2243 session_deps.socket_factory.AddSocketDataProvider(data.get());
2244 2244
2245 SSLSocketDataProvider ssl(true, OK); 2245 SSLSocketDataProvider ssl(true, OK);
2246 ssl.next_proto_status = SSLClientSocket::kNextProtoNegotiated; 2246 ssl.next_proto_status = SSLClientSocket::kNextProtoNegotiated;
2247 ssl.next_proto = "spdy/2"; 2247 ssl.next_proto = "spdy/2";
2248 ssl.was_npn_negotiated = true; 2248 ssl.was_npn_negotiated = true;
2249 ssl.protocol_negotiated = SSLClientSocket::kProtoSPDY2; 2249 ssl.protocol_negotiated = SSLClientSocket::kProtoSPDY2;
2250 session_deps.socket_factory.AddSSLSocketDataProvider(&ssl); 2250 session_deps.socket_factory.AddSSLSocketDataProvider(&ssl);
2251 2251
2252 TestCompletionCallback callback1; 2252 TestCompletionCallback callback1;
2253 2253
(...skipping 70 matching lines...) Expand 10 before | Expand all | Expand 10 after
2324 scoped_ptr<spdy::SpdyFrame> wrapped_body( 2324 scoped_ptr<spdy::SpdyFrame> wrapped_body(
2325 ConstructSpdyBodyFrame(1, "1234567890", 10, false)); 2325 ConstructSpdyBodyFrame(1, "1234567890", 10, false));
2326 MockRead spdy_reads[] = { 2326 MockRead spdy_reads[] = {
2327 CreateMockRead(*conn_resp, 2, true), 2327 CreateMockRead(*conn_resp, 2, true),
2328 CreateMockRead(*wrapped_get_resp, 4, true), 2328 CreateMockRead(*wrapped_get_resp, 4, true),
2329 CreateMockRead(*wrapped_body, 5, true), 2329 CreateMockRead(*wrapped_body, 5, true),
2330 CreateMockRead(*wrapped_body, 6, true), 2330 CreateMockRead(*wrapped_body, 6, true),
2331 MockRead(true, 0, 7), 2331 MockRead(true, 0, 7),
2332 }; 2332 };
2333 2333
2334 scoped_refptr<OrderedSocketData> spdy_data( 2334 scoped_ptr<OrderedSocketData> spdy_data(
2335 new OrderedSocketData( 2335 new OrderedSocketData(
2336 spdy_reads, arraysize(spdy_reads), 2336 spdy_reads, arraysize(spdy_reads),
2337 spdy_writes, arraysize(spdy_writes))); 2337 spdy_writes, arraysize(spdy_writes)));
2338 session_deps.socket_factory.AddSocketDataProvider(spdy_data); 2338 session_deps.socket_factory.AddSocketDataProvider(spdy_data.get());
2339 2339
2340 SSLSocketDataProvider ssl(true, OK); 2340 SSLSocketDataProvider ssl(true, OK);
2341 ssl.next_proto_status = SSLClientSocket::kNextProtoNegotiated; 2341 ssl.next_proto_status = SSLClientSocket::kNextProtoNegotiated;
2342 ssl.next_proto = "spdy/2"; 2342 ssl.next_proto = "spdy/2";
2343 ssl.was_npn_negotiated = true; 2343 ssl.was_npn_negotiated = true;
2344 ssl.protocol_negotiated = SSLClientSocket::kProtoSPDY2; 2344 ssl.protocol_negotiated = SSLClientSocket::kProtoSPDY2;
2345 session_deps.socket_factory.AddSSLSocketDataProvider(&ssl); 2345 session_deps.socket_factory.AddSSLSocketDataProvider(&ssl);
2346 SSLSocketDataProvider ssl2(true, OK); 2346 SSLSocketDataProvider ssl2(true, OK);
2347 ssl2.was_npn_negotiated = false; 2347 ssl2.was_npn_negotiated = false;
2348 ssl2.protocol_negotiated = SSLClientSocket::kProtoUnknown; 2348 ssl2.protocol_negotiated = SSLClientSocket::kProtoUnknown;
(...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after
2399 ConstructWrappedSpdyFrame(get_resp, 1)); 2399 ConstructWrappedSpdyFrame(get_resp, 1));
2400 scoped_ptr<spdy::SpdyFrame> body(ConstructSpdyBodyFrame(1, true)); 2400 scoped_ptr<spdy::SpdyFrame> body(ConstructSpdyBodyFrame(1, true));
2401 scoped_ptr<spdy::SpdyFrame> wrapped_body(ConstructWrappedSpdyFrame(body, 1)); 2401 scoped_ptr<spdy::SpdyFrame> wrapped_body(ConstructWrappedSpdyFrame(body, 1));
2402 MockRead spdy_reads[] = { 2402 MockRead spdy_reads[] = {
2403 CreateMockRead(*conn_resp, 2, true), 2403 CreateMockRead(*conn_resp, 2, true),
2404 CreateMockRead(*wrapped_get_resp, 4, true), 2404 CreateMockRead(*wrapped_get_resp, 4, true),
2405 CreateMockRead(*wrapped_body, 5, true), 2405 CreateMockRead(*wrapped_body, 5, true),
2406 MockRead(true, 0, 1), 2406 MockRead(true, 0, 1),
2407 }; 2407 };
2408 2408
2409 scoped_refptr<OrderedSocketData> spdy_data( 2409 scoped_ptr<OrderedSocketData> spdy_data(
2410 new OrderedSocketData( 2410 new OrderedSocketData(
2411 spdy_reads, arraysize(spdy_reads), 2411 spdy_reads, arraysize(spdy_reads),
2412 spdy_writes, arraysize(spdy_writes))); 2412 spdy_writes, arraysize(spdy_writes)));
2413 session_deps.socket_factory.AddSocketDataProvider(spdy_data); 2413 session_deps.socket_factory.AddSocketDataProvider(spdy_data.get());
2414 2414
2415 SSLSocketDataProvider ssl(true, OK); 2415 SSLSocketDataProvider ssl(true, OK);
2416 ssl.next_proto_status = SSLClientSocket::kNextProtoNegotiated; 2416 ssl.next_proto_status = SSLClientSocket::kNextProtoNegotiated;
2417 ssl.next_proto = "spdy/2"; 2417 ssl.next_proto = "spdy/2";
2418 ssl.was_npn_negotiated = true; 2418 ssl.was_npn_negotiated = true;
2419 ssl.protocol_negotiated = SSLClientSocket::kProtoSPDY2; 2419 ssl.protocol_negotiated = SSLClientSocket::kProtoSPDY2;
2420 session_deps.socket_factory.AddSSLSocketDataProvider(&ssl); 2420 session_deps.socket_factory.AddSSLSocketDataProvider(&ssl);
2421 SSLSocketDataProvider ssl2(true, OK); 2421 SSLSocketDataProvider ssl2(true, OK);
2422 ssl2.next_proto_status = SSLClientSocket::kNextProtoNegotiated; 2422 ssl2.next_proto_status = SSLClientSocket::kNextProtoNegotiated;
2423 ssl2.next_proto = "spdy/2"; 2423 ssl2.next_proto = "spdy/2";
(...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after
2468 CreateMockWrite(*get, 3), 2468 CreateMockWrite(*get, 3),
2469 }; 2469 };
2470 2470
2471 scoped_ptr<spdy::SpdyFrame> resp(ConstructSpdySynReplyError(1)); 2471 scoped_ptr<spdy::SpdyFrame> resp(ConstructSpdySynReplyError(1));
2472 scoped_ptr<spdy::SpdyFrame> data(ConstructSpdyBodyFrame(1, true)); 2472 scoped_ptr<spdy::SpdyFrame> data(ConstructSpdyBodyFrame(1, true));
2473 MockRead spdy_reads[] = { 2473 MockRead spdy_reads[] = {
2474 CreateMockRead(*resp, 2, true), 2474 CreateMockRead(*resp, 2, true),
2475 MockRead(true, 0, 4), 2475 MockRead(true, 0, 4),
2476 }; 2476 };
2477 2477
2478 scoped_refptr<OrderedSocketData> spdy_data( 2478 scoped_ptr<OrderedSocketData> spdy_data(
2479 new OrderedSocketData( 2479 new OrderedSocketData(
2480 spdy_reads, arraysize(spdy_reads), 2480 spdy_reads, arraysize(spdy_reads),
2481 spdy_writes, arraysize(spdy_writes))); 2481 spdy_writes, arraysize(spdy_writes)));
2482 session_deps.socket_factory.AddSocketDataProvider(spdy_data); 2482 session_deps.socket_factory.AddSocketDataProvider(spdy_data.get());
2483 2483
2484 SSLSocketDataProvider ssl(true, OK); 2484 SSLSocketDataProvider ssl(true, OK);
2485 ssl.next_proto_status = SSLClientSocket::kNextProtoNegotiated; 2485 ssl.next_proto_status = SSLClientSocket::kNextProtoNegotiated;
2486 ssl.next_proto = "spdy/2"; 2486 ssl.next_proto = "spdy/2";
2487 ssl.was_npn_negotiated = true; 2487 ssl.was_npn_negotiated = true;
2488 ssl.protocol_negotiated = SSLClientSocket::kProtoSPDY2; 2488 ssl.protocol_negotiated = SSLClientSocket::kProtoSPDY2;
2489 session_deps.socket_factory.AddSSLSocketDataProvider(&ssl); 2489 session_deps.socket_factory.AddSSLSocketDataProvider(&ssl);
2490 SSLSocketDataProvider ssl2(true, OK); 2490 SSLSocketDataProvider ssl2(true, OK);
2491 ssl2.next_proto_status = SSLClientSocket::kNextProtoNegotiated; 2491 ssl2.next_proto_status = SSLClientSocket::kNextProtoNegotiated;
2492 ssl2.next_proto = "spdy/2"; 2492 ssl2.next_proto = "spdy/2";
(...skipping 2232 matching lines...) Expand 10 before | Expand all | Expand 10 after
4725 "http://login.example.com/", 4725 "http://login.example.com/",
4726 }; 4726 };
4727 scoped_ptr<spdy::SpdyFrame> resp( 4727 scoped_ptr<spdy::SpdyFrame> resp(
4728 ConstructSpdySynReplyError("302 Redirect", kExtraHeaders, 4728 ConstructSpdySynReplyError("302 Redirect", kExtraHeaders,
4729 arraysize(kExtraHeaders)/2, 1)); 4729 arraysize(kExtraHeaders)/2, 1));
4730 MockRead data_reads[] = { 4730 MockRead data_reads[] = {
4731 CreateMockRead(*resp.get(), 1, false), 4731 CreateMockRead(*resp.get(), 1, false),
4732 MockRead(true, 0, 2), // EOF 4732 MockRead(true, 0, 2), // EOF
4733 }; 4733 };
4734 4734
4735 scoped_refptr<DelayedSocketData> data( 4735 scoped_ptr<DelayedSocketData> data(
4736 new DelayedSocketData( 4736 new DelayedSocketData(
4737 1, // wait for one write to finish before reading. 4737 1, // wait for one write to finish before reading.
4738 data_reads, arraysize(data_reads), 4738 data_reads, arraysize(data_reads),
4739 data_writes, arraysize(data_writes))); 4739 data_writes, arraysize(data_writes)));
4740 SSLSocketDataProvider proxy_ssl(true, OK); // SSL to the proxy 4740 SSLSocketDataProvider proxy_ssl(true, OK); // SSL to the proxy
4741 proxy_ssl.next_proto_status = SSLClientSocket::kNextProtoNegotiated; 4741 proxy_ssl.next_proto_status = SSLClientSocket::kNextProtoNegotiated;
4742 proxy_ssl.next_proto = "spdy/2"; 4742 proxy_ssl.next_proto = "spdy/2";
4743 proxy_ssl.was_npn_negotiated = true; 4743 proxy_ssl.was_npn_negotiated = true;
4744 proxy_ssl.protocol_negotiated = SSLClientSocket::kProtoSPDY2; 4744 proxy_ssl.protocol_negotiated = SSLClientSocket::kProtoSPDY2;
4745 4745
(...skipping 99 matching lines...) Expand 10 before | Expand all | Expand 10 after
4845 ConstructSpdySynReplyError("404 Not Found", kExtraHeaders, 4845 ConstructSpdySynReplyError("404 Not Found", kExtraHeaders,
4846 arraysize(kExtraHeaders)/2, 1)); 4846 arraysize(kExtraHeaders)/2, 1));
4847 scoped_ptr<spdy::SpdyFrame> body( 4847 scoped_ptr<spdy::SpdyFrame> body(
4848 ConstructSpdyBodyFrame(1, "The host does not exist", 23, true)); 4848 ConstructSpdyBodyFrame(1, "The host does not exist", 23, true));
4849 MockRead data_reads[] = { 4849 MockRead data_reads[] = {
4850 CreateMockRead(*resp.get(), 1, false), 4850 CreateMockRead(*resp.get(), 1, false),
4851 CreateMockRead(*body.get(), 2, false), 4851 CreateMockRead(*body.get(), 2, false),
4852 MockRead(true, 0, 3), // EOF 4852 MockRead(true, 0, 3), // EOF
4853 }; 4853 };
4854 4854
4855 scoped_refptr<DelayedSocketData> data( 4855 scoped_ptr<DelayedSocketData> data(
4856 new DelayedSocketData( 4856 new DelayedSocketData(
4857 1, // wait for one write to finish before reading. 4857 1, // wait for one write to finish before reading.
4858 data_reads, arraysize(data_reads), 4858 data_reads, arraysize(data_reads),
4859 data_writes, arraysize(data_writes))); 4859 data_writes, arraysize(data_writes)));
4860 SSLSocketDataProvider proxy_ssl(true, OK); // SSL to the proxy 4860 SSLSocketDataProvider proxy_ssl(true, OK); // SSL to the proxy
4861 proxy_ssl.next_proto_status = SSLClientSocket::kNextProtoNegotiated; 4861 proxy_ssl.next_proto_status = SSLClientSocket::kNextProtoNegotiated;
4862 proxy_ssl.next_proto = "spdy/2"; 4862 proxy_ssl.next_proto = "spdy/2";
4863 proxy_ssl.was_npn_negotiated = true; 4863 proxy_ssl.was_npn_negotiated = true;
4864 proxy_ssl.protocol_negotiated = SSLClientSocket::kProtoSPDY2; 4864 proxy_ssl.protocol_negotiated = SSLClientSocket::kProtoSPDY2;
4865 4865
(...skipping 1983 matching lines...) Expand 10 before | Expand all | Expand 10 after
6849 MockWrite spdy_writes[] = { CreateMockWrite(*req) }; 6849 MockWrite spdy_writes[] = { CreateMockWrite(*req) };
6850 6850
6851 scoped_ptr<spdy::SpdyFrame> resp(ConstructSpdyGetSynReply(NULL, 0, 1)); 6851 scoped_ptr<spdy::SpdyFrame> resp(ConstructSpdyGetSynReply(NULL, 0, 1));
6852 scoped_ptr<spdy::SpdyFrame> data(ConstructSpdyBodyFrame(1, true)); 6852 scoped_ptr<spdy::SpdyFrame> data(ConstructSpdyBodyFrame(1, true));
6853 MockRead spdy_reads[] = { 6853 MockRead spdy_reads[] = {
6854 CreateMockRead(*resp), 6854 CreateMockRead(*resp),
6855 CreateMockRead(*data), 6855 CreateMockRead(*data),
6856 MockRead(true, 0, 0), 6856 MockRead(true, 0, 0),
6857 }; 6857 };
6858 6858
6859 scoped_refptr<DelayedSocketData> spdy_data( 6859 scoped_ptr<DelayedSocketData> spdy_data(
6860 new DelayedSocketData( 6860 new DelayedSocketData(
6861 1, // wait for one write to finish before reading. 6861 1, // wait for one write to finish before reading.
6862 spdy_reads, arraysize(spdy_reads), 6862 spdy_reads, arraysize(spdy_reads),
6863 spdy_writes, arraysize(spdy_writes))); 6863 spdy_writes, arraysize(spdy_writes)));
6864 session_deps.socket_factory.AddSocketDataProvider(spdy_data); 6864 session_deps.socket_factory.AddSocketDataProvider(spdy_data.get());
6865 6865
6866 MockConnect never_finishing_connect(false, ERR_IO_PENDING); 6866 MockConnect never_finishing_connect(false, ERR_IO_PENDING);
6867 StaticSocketDataProvider hanging_non_alternate_protocol_socket( 6867 StaticSocketDataProvider hanging_non_alternate_protocol_socket(
6868 NULL, 0, NULL, 0); 6868 NULL, 0, NULL, 0);
6869 hanging_non_alternate_protocol_socket.set_connect_data( 6869 hanging_non_alternate_protocol_socket.set_connect_data(
6870 never_finishing_connect); 6870 never_finishing_connect);
6871 session_deps.socket_factory.AddSocketDataProvider( 6871 session_deps.socket_factory.AddSocketDataProvider(
6872 &hanging_non_alternate_protocol_socket); 6872 &hanging_non_alternate_protocol_socket);
6873 6873
6874 TestCompletionCallback callback; 6874 TestCompletionCallback callback;
(...skipping 83 matching lines...) Expand 10 before | Expand all | Expand 10 after
6958 scoped_ptr<spdy::SpdyFrame> resp2(ConstructSpdyGetSynReply(NULL, 0, 3)); 6958 scoped_ptr<spdy::SpdyFrame> resp2(ConstructSpdyGetSynReply(NULL, 0, 3));
6959 scoped_ptr<spdy::SpdyFrame> data2(ConstructSpdyBodyFrame(3, true)); 6959 scoped_ptr<spdy::SpdyFrame> data2(ConstructSpdyBodyFrame(3, true));
6960 MockRead spdy_reads[] = { 6960 MockRead spdy_reads[] = {
6961 CreateMockRead(*resp1), 6961 CreateMockRead(*resp1),
6962 CreateMockRead(*data1), 6962 CreateMockRead(*data1),
6963 CreateMockRead(*resp2), 6963 CreateMockRead(*resp2),
6964 CreateMockRead(*data2), 6964 CreateMockRead(*data2),
6965 MockRead(true, 0, 0), 6965 MockRead(true, 0, 0),
6966 }; 6966 };
6967 6967
6968 scoped_refptr<DelayedSocketData> spdy_data( 6968 scoped_ptr<DelayedSocketData> spdy_data(
6969 new DelayedSocketData( 6969 new DelayedSocketData(
6970 2, // wait for writes to finish before reading. 6970 2, // wait for writes to finish before reading.
6971 spdy_reads, arraysize(spdy_reads), 6971 spdy_reads, arraysize(spdy_reads),
6972 spdy_writes, arraysize(spdy_writes))); 6972 spdy_writes, arraysize(spdy_writes)));
6973 // Socket 4 is the successful Alternate-Protocol for transaction 3. 6973 // Socket 4 is the successful Alternate-Protocol for transaction 3.
6974 session_deps.socket_factory.AddSocketDataProvider(spdy_data); 6974 session_deps.socket_factory.AddSocketDataProvider(spdy_data.get());
6975 6975
6976 // Socket 5 is the unsuccessful non-Alternate-Protocol for transaction 3. 6976 // Socket 5 is the unsuccessful non-Alternate-Protocol for transaction 3.
6977 session_deps.socket_factory.AddSocketDataProvider(&hanging_socket); 6977 session_deps.socket_factory.AddSocketDataProvider(&hanging_socket);
6978 6978
6979 scoped_refptr<HttpNetworkSession> session(CreateSession(&session_deps)); 6979 scoped_refptr<HttpNetworkSession> session(CreateSession(&session_deps));
6980 TestCompletionCallback callback1; 6980 TestCompletionCallback callback1;
6981 HttpNetworkTransaction trans1(session); 6981 HttpNetworkTransaction trans1(session);
6982 6982
6983 int rv = trans1.Start(&request, callback1.callback(), BoundNetLog()); 6983 int rv = trans1.Start(&request, callback1.callback(), BoundNetLog());
6984 EXPECT_EQ(ERR_IO_PENDING, rv); 6984 EXPECT_EQ(ERR_IO_PENDING, rv);
(...skipping 218 matching lines...) Expand 10 before | Expand all | Expand 10 after
7203 7203
7204 scoped_ptr<spdy::SpdyFrame> resp(ConstructSpdyGetSynReply(NULL, 0, 1)); 7204 scoped_ptr<spdy::SpdyFrame> resp(ConstructSpdyGetSynReply(NULL, 0, 1));
7205 scoped_ptr<spdy::SpdyFrame> data(ConstructSpdyBodyFrame(1, true)); 7205 scoped_ptr<spdy::SpdyFrame> data(ConstructSpdyBodyFrame(1, true));
7206 MockRead spdy_reads[] = { 7206 MockRead spdy_reads[] = {
7207 MockRead(true, kCONNECTResponse, arraysize(kCONNECTResponse) - 1, 1), // 1 7207 MockRead(true, kCONNECTResponse, arraysize(kCONNECTResponse) - 1, 1), // 1
7208 CreateMockRead(*resp.get(), 4), // 2, 4 7208 CreateMockRead(*resp.get(), 4), // 2, 4
7209 CreateMockRead(*data.get(), 4), // 5 7209 CreateMockRead(*data.get(), 4), // 5
7210 MockRead(true, 0, 0, 4), // 6 7210 MockRead(true, 0, 0, 4), // 6
7211 }; 7211 };
7212 7212
7213 scoped_refptr<OrderedSocketData> spdy_data( 7213 scoped_ptr<OrderedSocketData> spdy_data(
7214 new OrderedSocketData( 7214 new OrderedSocketData(
7215 spdy_reads, arraysize(spdy_reads), 7215 spdy_reads, arraysize(spdy_reads),
7216 spdy_writes, arraysize(spdy_writes))); 7216 spdy_writes, arraysize(spdy_writes)));
7217 session_deps.socket_factory.AddSocketDataProvider(spdy_data); 7217 session_deps.socket_factory.AddSocketDataProvider(spdy_data.get());
7218 7218
7219 MockConnect never_finishing_connect(false, ERR_IO_PENDING); 7219 MockConnect never_finishing_connect(false, ERR_IO_PENDING);
7220 StaticSocketDataProvider hanging_non_alternate_protocol_socket( 7220 StaticSocketDataProvider hanging_non_alternate_protocol_socket(
7221 NULL, 0, NULL, 0); 7221 NULL, 0, NULL, 0);
7222 hanging_non_alternate_protocol_socket.set_connect_data( 7222 hanging_non_alternate_protocol_socket.set_connect_data(
7223 never_finishing_connect); 7223 never_finishing_connect);
7224 session_deps.socket_factory.AddSocketDataProvider( 7224 session_deps.socket_factory.AddSocketDataProvider(
7225 &hanging_non_alternate_protocol_socket); 7225 &hanging_non_alternate_protocol_socket);
7226 7226
7227 TestCompletionCallback callback; 7227 TestCompletionCallback callback;
(...skipping 76 matching lines...) Expand 10 before | Expand all | Expand 10 after
7304 MockWrite spdy_writes[] = { CreateMockWrite(*req) }; 7304 MockWrite spdy_writes[] = { CreateMockWrite(*req) };
7305 7305
7306 scoped_ptr<spdy::SpdyFrame> resp(ConstructSpdyGetSynReply(NULL, 0, 1)); 7306 scoped_ptr<spdy::SpdyFrame> resp(ConstructSpdyGetSynReply(NULL, 0, 1));
7307 scoped_ptr<spdy::SpdyFrame> data(ConstructSpdyBodyFrame(1, true)); 7307 scoped_ptr<spdy::SpdyFrame> data(ConstructSpdyBodyFrame(1, true));
7308 MockRead spdy_reads[] = { 7308 MockRead spdy_reads[] = {
7309 CreateMockRead(*resp), 7309 CreateMockRead(*resp),
7310 CreateMockRead(*data), 7310 CreateMockRead(*data),
7311 MockRead(true, 0, 0), 7311 MockRead(true, 0, 0),
7312 }; 7312 };
7313 7313
7314 scoped_refptr<DelayedSocketData> spdy_data( 7314 scoped_ptr<DelayedSocketData> spdy_data(
7315 new DelayedSocketData( 7315 new DelayedSocketData(
7316 1, // wait for one write to finish before reading. 7316 1, // wait for one write to finish before reading.
7317 spdy_reads, arraysize(spdy_reads), 7317 spdy_reads, arraysize(spdy_reads),
7318 spdy_writes, arraysize(spdy_writes))); 7318 spdy_writes, arraysize(spdy_writes)));
7319 session_deps.socket_factory.AddSocketDataProvider(spdy_data); 7319 session_deps.socket_factory.AddSocketDataProvider(spdy_data.get());
7320 7320
7321 TestCompletionCallback callback; 7321 TestCompletionCallback callback;
7322 7322
7323 scoped_refptr<HttpNetworkSession> session(CreateSession(&session_deps)); 7323 scoped_refptr<HttpNetworkSession> session(CreateSession(&session_deps));
7324 7324
7325 scoped_ptr<HttpNetworkTransaction> trans(new HttpNetworkTransaction(session)); 7325 scoped_ptr<HttpNetworkTransaction> trans(new HttpNetworkTransaction(session));
7326 7326
7327 int rv = trans->Start(&request, callback.callback(), BoundNetLog()); 7327 int rv = trans->Start(&request, callback.callback(), BoundNetLog());
7328 EXPECT_EQ(ERR_IO_PENDING, rv); 7328 EXPECT_EQ(ERR_IO_PENDING, rv);
7329 EXPECT_EQ(OK, callback.WaitForResult()); 7329 EXPECT_EQ(OK, callback.WaitForResult());
(...skipping 855 matching lines...) Expand 10 before | Expand all | Expand 10 after
8185 ssl.protocol_negotiated = SSLClientSocket::kProtoSPDY2; 8185 ssl.protocol_negotiated = SSLClientSocket::kProtoSPDY2;
8186 session_deps.socket_factory.AddSSLSocketDataProvider(&ssl); 8186 session_deps.socket_factory.AddSSLSocketDataProvider(&ssl);
8187 8187
8188 scoped_ptr<spdy::SpdyFrame> req(ConstructSpdyGet(NULL, 0, false, 1, LOWEST)); 8188 scoped_ptr<spdy::SpdyFrame> req(ConstructSpdyGet(NULL, 0, false, 1, LOWEST));
8189 MockWrite spdy_writes[] = { CreateMockWrite(*req) }; 8189 MockWrite spdy_writes[] = { CreateMockWrite(*req) };
8190 8190
8191 MockRead spdy_reads[] = { 8191 MockRead spdy_reads[] = {
8192 MockRead(false, 0, 0) // Not async - return 0 immediately. 8192 MockRead(false, 0, 0) // Not async - return 0 immediately.
8193 }; 8193 };
8194 8194
8195 scoped_refptr<DelayedSocketData> spdy_data( 8195 scoped_ptr<DelayedSocketData> spdy_data(
8196 new DelayedSocketData( 8196 new DelayedSocketData(
8197 0, // don't wait in this case, immediate hangup. 8197 0, // don't wait in this case, immediate hangup.
8198 spdy_reads, arraysize(spdy_reads), 8198 spdy_reads, arraysize(spdy_reads),
8199 spdy_writes, arraysize(spdy_writes))); 8199 spdy_writes, arraysize(spdy_writes)));
8200 session_deps.socket_factory.AddSocketDataProvider(spdy_data); 8200 session_deps.socket_factory.AddSocketDataProvider(spdy_data.get());
8201 8201
8202 TestCompletionCallback callback; 8202 TestCompletionCallback callback;
8203 8203
8204 scoped_refptr<HttpNetworkSession> session(CreateSession(&session_deps)); 8204 scoped_refptr<HttpNetworkSession> session(CreateSession(&session_deps));
8205 scoped_ptr<HttpNetworkTransaction> trans(new HttpNetworkTransaction(session)); 8205 scoped_ptr<HttpNetworkTransaction> trans(new HttpNetworkTransaction(session));
8206 8206
8207 int rv = trans->Start(&request, callback.callback(), BoundNetLog()); 8207 int rv = trans->Start(&request, callback.callback(), BoundNetLog());
8208 EXPECT_EQ(ERR_IO_PENDING, rv); 8208 EXPECT_EQ(ERR_IO_PENDING, rv);
8209 EXPECT_EQ(ERR_CONNECTION_CLOSED, callback.WaitForResult()); 8209 EXPECT_EQ(ERR_CONNECTION_CLOSED, callback.WaitForResult());
8210 8210
(...skipping 90 matching lines...) Expand 10 before | Expand all | Expand 10 after
8301 8301
8302 // Second connection attempt passes 8302 // Second connection attempt passes
8303 MockRead(true, kAcceptConnectResponse, 8303 MockRead(true, kAcceptConnectResponse,
8304 arraysize(kAcceptConnectResponse) -1, 4), 8304 arraysize(kAcceptConnectResponse) -1, 4),
8305 8305
8306 // SPDY response 8306 // SPDY response
8307 CreateMockRead(*resp.get(), 6), 8307 CreateMockRead(*resp.get(), 6),
8308 CreateMockRead(*data.get(), 6), 8308 CreateMockRead(*data.get(), 6),
8309 MockRead(true, 0, 0, 6), 8309 MockRead(true, 0, 0, 6),
8310 }; 8310 };
8311 scoped_refptr<OrderedSocketData> data_2( 8311 scoped_ptr<OrderedSocketData> data_2(
8312 new OrderedSocketData(data_reads_2, arraysize(data_reads_2), 8312 new OrderedSocketData(data_reads_2, arraysize(data_reads_2),
8313 data_writes_2, arraysize(data_writes_2))); 8313 data_writes_2, arraysize(data_writes_2)));
8314 8314
8315 SSLSocketDataProvider ssl(true, OK); 8315 SSLSocketDataProvider ssl(true, OK);
8316 ssl.next_proto_status = SSLClientSocket::kNextProtoNegotiated; 8316 ssl.next_proto_status = SSLClientSocket::kNextProtoNegotiated;
8317 ssl.next_proto = "spdy/2"; 8317 ssl.next_proto = "spdy/2";
8318 ssl.was_npn_negotiated = true; 8318 ssl.was_npn_negotiated = true;
8319 ssl.protocol_negotiated = SSLClientSocket::kProtoSPDY2; 8319 ssl.protocol_negotiated = SSLClientSocket::kProtoSPDY2;
8320 8320
8321 MockConnect never_finishing_connect(false, ERR_IO_PENDING); 8321 MockConnect never_finishing_connect(false, ERR_IO_PENDING);
(...skipping 260 matching lines...) Expand 10 before | Expand all | Expand 10 after
8582 MockWrite spdy_writes[] = { CreateMockWrite(*req) }; 8582 MockWrite spdy_writes[] = { CreateMockWrite(*req) };
8583 8583
8584 scoped_ptr<spdy::SpdyFrame> resp(ConstructSpdyGetSynReply(NULL, 0, 1)); 8584 scoped_ptr<spdy::SpdyFrame> resp(ConstructSpdyGetSynReply(NULL, 0, 1));
8585 scoped_ptr<spdy::SpdyFrame> data(ConstructSpdyBodyFrame(1, true)); 8585 scoped_ptr<spdy::SpdyFrame> data(ConstructSpdyBodyFrame(1, true));
8586 MockRead spdy_reads[] = { 8586 MockRead spdy_reads[] = {
8587 CreateMockRead(*resp), 8587 CreateMockRead(*resp),
8588 CreateMockRead(*data), 8588 CreateMockRead(*data),
8589 MockRead(true, 0, 0), 8589 MockRead(true, 0, 0),
8590 }; 8590 };
8591 8591
8592 scoped_refptr<DelayedSocketData> spdy_data( 8592 scoped_ptr<DelayedSocketData> spdy_data(
8593 new DelayedSocketData( 8593 new DelayedSocketData(
8594 1, // wait for one write to finish before reading. 8594 1, // wait for one write to finish before reading.
8595 spdy_reads, arraysize(spdy_reads), 8595 spdy_reads, arraysize(spdy_reads),
8596 spdy_writes, arraysize(spdy_writes))); 8596 spdy_writes, arraysize(spdy_writes)));
8597 session_deps.socket_factory.AddSocketDataProvider(spdy_data); 8597 session_deps.socket_factory.AddSocketDataProvider(spdy_data.get());
8598 8598
8599 SSLSocketDataProvider ssl(true, OK); 8599 SSLSocketDataProvider ssl(true, OK);
8600 ssl.next_proto_status = SSLClientSocket::kNextProtoNegotiated; 8600 ssl.next_proto_status = SSLClientSocket::kNextProtoNegotiated;
8601 ssl.next_proto = "spdy/2"; 8601 ssl.next_proto = "spdy/2";
8602 ssl.was_npn_negotiated = true; 8602 ssl.was_npn_negotiated = true;
8603 ssl.protocol_negotiated = SSLClientSocket::kProtoSPDY2; 8603 ssl.protocol_negotiated = SSLClientSocket::kProtoSPDY2;
8604 session_deps.socket_factory.AddSSLSocketDataProvider(&ssl); 8604 session_deps.socket_factory.AddSSLSocketDataProvider(&ssl);
8605 8605
8606 scoped_refptr<HttpNetworkSession> session(CreateSession(&session_deps)); 8606 scoped_refptr<HttpNetworkSession> session(CreateSession(&session_deps));
8607 8607
(...skipping 445 matching lines...) Expand 10 before | Expand all | Expand 10 after
9053 scoped_ptr<spdy::SpdyFrame> host2_resp(ConstructSpdyGetSynReply(NULL, 0, 3)); 9053 scoped_ptr<spdy::SpdyFrame> host2_resp(ConstructSpdyGetSynReply(NULL, 0, 3));
9054 scoped_ptr<spdy::SpdyFrame> host2_resp_body(ConstructSpdyBodyFrame(3, true)); 9054 scoped_ptr<spdy::SpdyFrame> host2_resp_body(ConstructSpdyBodyFrame(3, true));
9055 MockRead spdy_reads[] = { 9055 MockRead spdy_reads[] = {
9056 CreateMockRead(*host1_resp, 2), 9056 CreateMockRead(*host1_resp, 2),
9057 CreateMockRead(*host1_resp_body, 3), 9057 CreateMockRead(*host1_resp_body, 3),
9058 CreateMockRead(*host2_resp, 5), 9058 CreateMockRead(*host2_resp, 5),
9059 CreateMockRead(*host2_resp_body, 6), 9059 CreateMockRead(*host2_resp_body, 6),
9060 MockRead(true, 0, 7), 9060 MockRead(true, 0, 7),
9061 }; 9061 };
9062 9062
9063 scoped_refptr<OrderedSocketData> spdy_data( 9063 scoped_ptr<OrderedSocketData> spdy_data(
9064 new OrderedSocketData( 9064 new OrderedSocketData(
9065 spdy_reads, arraysize(spdy_reads), 9065 spdy_reads, arraysize(spdy_reads),
9066 spdy_writes, arraysize(spdy_writes))); 9066 spdy_writes, arraysize(spdy_writes)));
9067 session_deps.socket_factory.AddSocketDataProvider(spdy_data); 9067 session_deps.socket_factory.AddSocketDataProvider(spdy_data.get());
9068 9068
9069 TestCompletionCallback callback; 9069 TestCompletionCallback callback;
9070 HttpRequestInfo request1; 9070 HttpRequestInfo request1;
9071 request1.method = "GET"; 9071 request1.method = "GET";
9072 request1.url = GURL("https://www.google.com/"); 9072 request1.url = GURL("https://www.google.com/");
9073 request1.load_flags = 0; 9073 request1.load_flags = 0;
9074 HttpNetworkTransaction trans1(session); 9074 HttpNetworkTransaction trans1(session);
9075 9075
9076 int rv = trans1.Start(&request1, callback.callback(), BoundNetLog()); 9076 int rv = trans1.Start(&request1, callback.callback(), BoundNetLog());
9077 EXPECT_EQ(ERR_IO_PENDING, rv); 9077 EXPECT_EQ(ERR_IO_PENDING, rv);
(...skipping 129 matching lines...) Expand 10 before | Expand all | Expand 10 after
9207 scoped_ptr<spdy::SpdyFrame> host2_resp(ConstructSpdyGetSynReply(NULL, 0, 3)); 9207 scoped_ptr<spdy::SpdyFrame> host2_resp(ConstructSpdyGetSynReply(NULL, 0, 3));
9208 scoped_ptr<spdy::SpdyFrame> host2_resp_body(ConstructSpdyBodyFrame(3, true)); 9208 scoped_ptr<spdy::SpdyFrame> host2_resp_body(ConstructSpdyBodyFrame(3, true));
9209 MockRead spdy_reads[] = { 9209 MockRead spdy_reads[] = {
9210 CreateMockRead(*host1_resp, 2), 9210 CreateMockRead(*host1_resp, 2),
9211 CreateMockRead(*host1_resp_body, 3), 9211 CreateMockRead(*host1_resp_body, 3),
9212 CreateMockRead(*host2_resp, 5), 9212 CreateMockRead(*host2_resp, 5),
9213 CreateMockRead(*host2_resp_body, 6), 9213 CreateMockRead(*host2_resp_body, 6),
9214 MockRead(true, 0, 7), 9214 MockRead(true, 0, 7),
9215 }; 9215 };
9216 9216
9217 scoped_refptr<OrderedSocketData> spdy_data( 9217 scoped_ptr<OrderedSocketData> spdy_data(
9218 new OrderedSocketData( 9218 new OrderedSocketData(
9219 spdy_reads, arraysize(spdy_reads), 9219 spdy_reads, arraysize(spdy_reads),
9220 spdy_writes, arraysize(spdy_writes))); 9220 spdy_writes, arraysize(spdy_writes)));
9221 session_deps.socket_factory.AddSocketDataProvider(spdy_data); 9221 session_deps.socket_factory.AddSocketDataProvider(spdy_data.get());
9222 9222
9223 TestCompletionCallback callback; 9223 TestCompletionCallback callback;
9224 HttpRequestInfo request1; 9224 HttpRequestInfo request1;
9225 request1.method = "GET"; 9225 request1.method = "GET";
9226 request1.url = GURL("https://www.google.com/"); 9226 request1.url = GURL("https://www.google.com/");
9227 request1.load_flags = 0; 9227 request1.load_flags = 0;
9228 HttpNetworkTransaction trans1(session); 9228 HttpNetworkTransaction trans1(session);
9229 9229
9230 int rv = trans1.Start(&request1, callback.callback(), BoundNetLog()); 9230 int rv = trans1.Start(&request1, callback.callback(), BoundNetLog());
9231 EXPECT_EQ(ERR_IO_PENDING, rv); 9231 EXPECT_EQ(ERR_IO_PENDING, rv);
(...skipping 130 matching lines...) Expand 10 before | Expand all | Expand 10 after
9362 CreateMockWrite(*host1_req, 1), 9362 CreateMockWrite(*host1_req, 1),
9363 }; 9363 };
9364 scoped_ptr<spdy::SpdyFrame> host1_resp(ConstructSpdyGetSynReply(NULL, 0, 1)); 9364 scoped_ptr<spdy::SpdyFrame> host1_resp(ConstructSpdyGetSynReply(NULL, 0, 1));
9365 scoped_ptr<spdy::SpdyFrame> host1_resp_body(ConstructSpdyBodyFrame(1, true)); 9365 scoped_ptr<spdy::SpdyFrame> host1_resp_body(ConstructSpdyBodyFrame(1, true));
9366 MockRead spdy1_reads[] = { 9366 MockRead spdy1_reads[] = {
9367 CreateMockRead(*host1_resp, 2), 9367 CreateMockRead(*host1_resp, 2),
9368 CreateMockRead(*host1_resp_body, 3), 9368 CreateMockRead(*host1_resp_body, 3),
9369 MockRead(true, ERR_IO_PENDING, 4), 9369 MockRead(true, ERR_IO_PENDING, 4),
9370 }; 9370 };
9371 9371
9372 scoped_refptr<OrderedSocketData> spdy1_data( 9372 scoped_ptr<OrderedSocketData> spdy1_data(
9373 new OrderedSocketData( 9373 new OrderedSocketData(
9374 spdy1_reads, arraysize(spdy1_reads), 9374 spdy1_reads, arraysize(spdy1_reads),
9375 spdy1_writes, arraysize(spdy1_writes))); 9375 spdy1_writes, arraysize(spdy1_writes)));
9376 session_deps.socket_factory.AddSocketDataProvider(spdy1_data); 9376 session_deps.socket_factory.AddSocketDataProvider(spdy1_data.get());
9377 9377
9378 scoped_ptr<spdy::SpdyFrame> host2_req(ConstructSpdyGet( 9378 scoped_ptr<spdy::SpdyFrame> host2_req(ConstructSpdyGet(
9379 "https://www.b.com", false, 1, LOWEST)); 9379 "https://www.b.com", false, 1, LOWEST));
9380 MockWrite spdy2_writes[] = { 9380 MockWrite spdy2_writes[] = {
9381 CreateMockWrite(*host2_req, 1), 9381 CreateMockWrite(*host2_req, 1),
9382 }; 9382 };
9383 scoped_ptr<spdy::SpdyFrame> host2_resp(ConstructSpdyGetSynReply(NULL, 0, 1)); 9383 scoped_ptr<spdy::SpdyFrame> host2_resp(ConstructSpdyGetSynReply(NULL, 0, 1));
9384 scoped_ptr<spdy::SpdyFrame> host2_resp_body(ConstructSpdyBodyFrame(1, true)); 9384 scoped_ptr<spdy::SpdyFrame> host2_resp_body(ConstructSpdyBodyFrame(1, true));
9385 MockRead spdy2_reads[] = { 9385 MockRead spdy2_reads[] = {
9386 CreateMockRead(*host2_resp, 2), 9386 CreateMockRead(*host2_resp, 2),
9387 CreateMockRead(*host2_resp_body, 3), 9387 CreateMockRead(*host2_resp_body, 3),
9388 MockRead(true, ERR_IO_PENDING, 4), 9388 MockRead(true, ERR_IO_PENDING, 4),
9389 }; 9389 };
9390 9390
9391 scoped_refptr<OrderedSocketData> spdy2_data( 9391 scoped_ptr<OrderedSocketData> spdy2_data(
9392 new OrderedSocketData( 9392 new OrderedSocketData(
9393 spdy2_reads, arraysize(spdy2_reads), 9393 spdy2_reads, arraysize(spdy2_reads),
9394 spdy2_writes, arraysize(spdy2_writes))); 9394 spdy2_writes, arraysize(spdy2_writes)));
9395 session_deps.socket_factory.AddSocketDataProvider(spdy2_data); 9395 session_deps.socket_factory.AddSocketDataProvider(spdy2_data.get());
9396 9396
9397 MockWrite http_write[] = { 9397 MockWrite http_write[] = {
9398 MockWrite("GET / HTTP/1.1\r\n" 9398 MockWrite("GET / HTTP/1.1\r\n"
9399 "Host: www.a.com\r\n" 9399 "Host: www.a.com\r\n"
9400 "Connection: keep-alive\r\n\r\n"), 9400 "Connection: keep-alive\r\n\r\n"),
9401 }; 9401 };
9402 9402
9403 MockRead http_read[] = { 9403 MockRead http_read[] = {
9404 MockRead("HTTP/1.1 200 OK\r\n"), 9404 MockRead("HTTP/1.1 200 OK\r\n"),
9405 MockRead("Content-Type: text/html; charset=iso-8859-1\r\n"), 9405 MockRead("Content-Type: text/html; charset=iso-8859-1\r\n"),
(...skipping 93 matching lines...) Expand 10 before | Expand all | Expand 10 after
9499 session->spdy_session_pool()->HasSession(host_port_proxy_pair_b)); 9499 session->spdy_session_pool()->HasSession(host_port_proxy_pair_b));
9500 9500
9501 HttpStreamFactory::set_next_protos(std::vector<std::string>()); 9501 HttpStreamFactory::set_next_protos(std::vector<std::string>());
9502 ClientSocketPoolManager::set_max_sockets_per_pool(old_max_sockets_per_pool); 9502 ClientSocketPoolManager::set_max_sockets_per_pool(old_max_sockets_per_pool);
9503 ClientSocketPoolManager::set_max_sockets_per_proxy_server( 9503 ClientSocketPoolManager::set_max_sockets_per_proxy_server(
9504 old_max_sockets_per_proxy_server); 9504 old_max_sockets_per_proxy_server);
9505 ClientSocketPoolManager::set_max_sockets_per_group(old_max_sockets_per_group); 9505 ClientSocketPoolManager::set_max_sockets_per_group(old_max_sockets_per_group);
9506 } 9506 }
9507 9507
9508 } // namespace net 9508 } // namespace net
OLDNEW
« no previous file with comments | « net/ftp/ftp_network_transaction_unittest.cc ('k') | net/socket/socket_test_util.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698