OLD | NEW |
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 Loading... |
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 Loading... |
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 Loading... |
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 Loading... |
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 Loading... |
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 Loading... |
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 Loading... |
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 Loading... |
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 Loading... |
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 Loading... |
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 Loading... |
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 Loading... |
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 Loading... |
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 Loading... |
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 Loading... |
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 Loading... |
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 Loading... |
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 Loading... |
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 |
OLD | NEW |