| 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 |