| OLD | NEW |
| 1 // Copyright (c) 2013 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2013 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/spdy/spdy_test_util_common.h" | 5 #include "net/spdy/spdy_test_util_common.h" |
| 6 | 6 |
| 7 #include <cstddef> | 7 #include <cstddef> |
| 8 | 8 |
| 9 #include "base/compiler_specific.h" | 9 #include "base/compiler_specific.h" |
| 10 #include "base/memory/scoped_ptr.h" | 10 #include "base/memory/scoped_ptr.h" |
| (...skipping 343 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 354 enable_ip_pooling(true), | 354 enable_ip_pooling(true), |
| 355 enable_compression(false), | 355 enable_compression(false), |
| 356 enable_ping(false), | 356 enable_ping(false), |
| 357 enable_user_alternate_protocol_ports(false), | 357 enable_user_alternate_protocol_ports(false), |
| 358 protocol(protocol), | 358 protocol(protocol), |
| 359 stream_initial_recv_window_size(kSpdyStreamInitialWindowSize), | 359 stream_initial_recv_window_size(kSpdyStreamInitialWindowSize), |
| 360 time_func(&base::TimeTicks::Now), | 360 time_func(&base::TimeTicks::Now), |
| 361 force_spdy_over_ssl(false), | 361 force_spdy_over_ssl(false), |
| 362 force_spdy_always(false), | 362 force_spdy_always(false), |
| 363 use_alternate_protocols(false), | 363 use_alternate_protocols(false), |
| 364 enable_websocket_over_spdy(false), |
| 364 net_log(NULL) { | 365 net_log(NULL) { |
| 365 DCHECK(next_proto_is_spdy(protocol)) << "Invalid protocol: " << protocol; | 366 DCHECK(next_proto_is_spdy(protocol)) << "Invalid protocol: " << protocol; |
| 366 | 367 |
| 367 // Note: The CancelledTransaction test does cleanup by running all | 368 // Note: The CancelledTransaction test does cleanup by running all |
| 368 // tasks in the message loop (RunAllPending). Unfortunately, that | 369 // tasks in the message loop (RunAllPending). Unfortunately, that |
| 369 // doesn't clean up tasks on the host resolver thread; and | 370 // doesn't clean up tasks on the host resolver thread; and |
| 370 // TCPConnectJob is currently not cancellable. Using synchronous | 371 // TCPConnectJob is currently not cancellable. Using synchronous |
| 371 // lookups allows the test to shutdown cleanly. Until we have | 372 // lookups allows the test to shutdown cleanly. Until we have |
| 372 // cancellable TCPConnectJobs, use synchronous lookups. | 373 // cancellable TCPConnectJobs, use synchronous lookups. |
| 373 host_resolver->set_synchronous_mode(true); | 374 host_resolver->set_synchronous_mode(true); |
| (...skipping 13 matching lines...) Expand all Loading... |
| 387 enable_ip_pooling(true), | 388 enable_ip_pooling(true), |
| 388 enable_compression(false), | 389 enable_compression(false), |
| 389 enable_ping(false), | 390 enable_ping(false), |
| 390 enable_user_alternate_protocol_ports(false), | 391 enable_user_alternate_protocol_ports(false), |
| 391 protocol(protocol), | 392 protocol(protocol), |
| 392 stream_initial_recv_window_size(kSpdyStreamInitialWindowSize), | 393 stream_initial_recv_window_size(kSpdyStreamInitialWindowSize), |
| 393 time_func(&base::TimeTicks::Now), | 394 time_func(&base::TimeTicks::Now), |
| 394 force_spdy_over_ssl(false), | 395 force_spdy_over_ssl(false), |
| 395 force_spdy_always(false), | 396 force_spdy_always(false), |
| 396 use_alternate_protocols(false), | 397 use_alternate_protocols(false), |
| 398 enable_websocket_over_spdy(false), |
| 397 net_log(NULL) { | 399 net_log(NULL) { |
| 398 DCHECK(next_proto_is_spdy(protocol)) << "Invalid protocol: " << protocol; | 400 DCHECK(next_proto_is_spdy(protocol)) << "Invalid protocol: " << protocol; |
| 399 } | 401 } |
| 400 | 402 |
| 401 SpdySessionDependencies::~SpdySessionDependencies() {} | 403 SpdySessionDependencies::~SpdySessionDependencies() {} |
| 402 | 404 |
| 403 // static | 405 // static |
| 404 HttpNetworkSession* SpdySessionDependencies::SpdyCreateSession( | 406 HttpNetworkSession* SpdySessionDependencies::SpdyCreateSession( |
| 405 SpdySessionDependencies* session_deps) { | 407 SpdySessionDependencies* session_deps) { |
| 406 net::HttpNetworkSession::Params params = CreateSessionParams(session_deps); | 408 net::HttpNetworkSession::Params params = CreateSessionParams(session_deps); |
| (...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 446 session_deps->enable_user_alternate_protocol_ports; | 448 session_deps->enable_user_alternate_protocol_ports; |
| 447 params.spdy_default_protocol = session_deps->protocol; | 449 params.spdy_default_protocol = session_deps->protocol; |
| 448 params.spdy_stream_initial_recv_window_size = | 450 params.spdy_stream_initial_recv_window_size = |
| 449 session_deps->stream_initial_recv_window_size; | 451 session_deps->stream_initial_recv_window_size; |
| 450 params.time_func = session_deps->time_func; | 452 params.time_func = session_deps->time_func; |
| 451 params.next_protos = session_deps->next_protos; | 453 params.next_protos = session_deps->next_protos; |
| 452 params.trusted_spdy_proxy = session_deps->trusted_spdy_proxy; | 454 params.trusted_spdy_proxy = session_deps->trusted_spdy_proxy; |
| 453 params.force_spdy_over_ssl = session_deps->force_spdy_over_ssl; | 455 params.force_spdy_over_ssl = session_deps->force_spdy_over_ssl; |
| 454 params.force_spdy_always = session_deps->force_spdy_always; | 456 params.force_spdy_always = session_deps->force_spdy_always; |
| 455 params.use_alternate_protocols = session_deps->use_alternate_protocols; | 457 params.use_alternate_protocols = session_deps->use_alternate_protocols; |
| 458 params.enable_websocket_over_spdy = session_deps->enable_websocket_over_spdy; |
| 456 params.net_log = session_deps->net_log; | 459 params.net_log = session_deps->net_log; |
| 457 return params; | 460 return params; |
| 458 } | 461 } |
| 459 | 462 |
| 460 SpdyURLRequestContext::SpdyURLRequestContext(NextProto protocol, | 463 SpdyURLRequestContext::SpdyURLRequestContext(NextProto protocol, |
| 461 bool force_spdy_over_ssl, | 464 bool force_spdy_over_ssl, |
| 462 bool force_spdy_always) | 465 bool force_spdy_always) |
| 463 : storage_(this) { | 466 : storage_(this) { |
| 464 DCHECK(next_proto_is_spdy(protocol)) << "Invalid protocol: " << protocol; | 467 DCHECK(next_proto_is_spdy(protocol)) << "Invalid protocol: " << protocol; |
| 465 | 468 |
| (...skipping 769 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1235 } | 1238 } |
| 1236 } | 1239 } |
| 1237 | 1240 |
| 1238 void SpdyTestUtil::SetPriority(RequestPriority priority, | 1241 void SpdyTestUtil::SetPriority(RequestPriority priority, |
| 1239 SpdySynStreamIR* ir) const { | 1242 SpdySynStreamIR* ir) const { |
| 1240 ir->set_priority(ConvertRequestPriorityToSpdyPriority( | 1243 ir->set_priority(ConvertRequestPriorityToSpdyPriority( |
| 1241 priority, spdy_version())); | 1244 priority, spdy_version())); |
| 1242 } | 1245 } |
| 1243 | 1246 |
| 1244 } // namespace net | 1247 } // namespace net |
| OLD | NEW |