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