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

Side by Side Diff: net/spdy/spdy_test_util_common.cc

Issue 284423002: Remove HttpStreamFactory's NPN/SPDY globals, except for spdy_enabled. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Fix merge Created 6 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
« no previous file with comments | « net/spdy/spdy_test_util_common.h ('k') | net/test/net_test_suite.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright (c) 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 32 matching lines...) Expand 10 before | Expand all | Expand 10 after
43 scheme->assign(gurl.scheme()); 43 scheme->assign(gurl.scheme());
44 host->assign(gurl.host()); 44 host->assign(gurl.host());
45 if (gurl.has_port()) { 45 if (gurl.has_port()) {
46 host->append(":"); 46 host->append(":");
47 host->append(gurl.port()); 47 host->append(gurl.port());
48 } 48 }
49 } 49 }
50 50
51 } // namespace 51 } // namespace
52 52
53 std::vector<NextProto> SpdyNextProtos() { 53 NextProtoVector SpdyNextProtos() {
54 std::vector<NextProto> next_protos; 54 NextProtoVector next_protos;
55 for (int i = kProtoMinimumVersion; i <= kProtoMaximumVersion; ++i) { 55 for (int i = kProtoMinimumVersion; i <= kProtoMaximumVersion; ++i) {
56 next_protos.push_back(static_cast<NextProto>(i)); 56 next_protos.push_back(static_cast<NextProto>(i));
57 } 57 }
58 return next_protos; 58 return next_protos;
59 } 59 }
60 60
61 // Chop a frame into an array of MockWrites. 61 // Chop a frame into an array of MockWrites.
62 // |data| is the frame to chop. 62 // |data| is the frame to chop.
63 // |length| is the length of the frame to chop. 63 // |length| is the length of the frame to chop.
64 // |num_chunks| is the number of chunks to create. 64 // |num_chunks| is the number of chunks to create.
(...skipping 285 matching lines...) Expand 10 before | Expand all | Expand 10 after
350 deterministic_socket_factory(new DeterministicMockClientSocketFactory), 350 deterministic_socket_factory(new DeterministicMockClientSocketFactory),
351 http_auth_handler_factory( 351 http_auth_handler_factory(
352 HttpAuthHandlerFactory::CreateDefault(host_resolver.get())), 352 HttpAuthHandlerFactory::CreateDefault(host_resolver.get())),
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),
361 force_spdy_always(false),
362 use_alternate_protocols(false),
360 net_log(NULL) { 363 net_log(NULL) {
361 DCHECK(next_proto_is_spdy(protocol)) << "Invalid protocol: " << protocol; 364 DCHECK(next_proto_is_spdy(protocol)) << "Invalid protocol: " << protocol;
362 365
363 // Note: The CancelledTransaction test does cleanup by running all 366 // Note: The CancelledTransaction test does cleanup by running all
364 // tasks in the message loop (RunAllPending). Unfortunately, that 367 // tasks in the message loop (RunAllPending). Unfortunately, that
365 // doesn't clean up tasks on the host resolver thread; and 368 // doesn't clean up tasks on the host resolver thread; and
366 // TCPConnectJob is currently not cancellable. Using synchronous 369 // TCPConnectJob is currently not cancellable. Using synchronous
367 // lookups allows the test to shutdown cleanly. Until we have 370 // lookups allows the test to shutdown cleanly. Until we have
368 // cancellable TCPConnectJobs, use synchronous lookups. 371 // cancellable TCPConnectJobs, use synchronous lookups.
369 host_resolver->set_synchronous_mode(true); 372 host_resolver->set_synchronous_mode(true);
(...skipping 10 matching lines...) Expand all
380 deterministic_socket_factory(new DeterministicMockClientSocketFactory), 383 deterministic_socket_factory(new DeterministicMockClientSocketFactory),
381 http_auth_handler_factory( 384 http_auth_handler_factory(
382 HttpAuthHandlerFactory::CreateDefault(host_resolver.get())), 385 HttpAuthHandlerFactory::CreateDefault(host_resolver.get())),
383 enable_ip_pooling(true), 386 enable_ip_pooling(true),
384 enable_compression(false), 387 enable_compression(false),
385 enable_ping(false), 388 enable_ping(false),
386 enable_user_alternate_protocol_ports(false), 389 enable_user_alternate_protocol_ports(false),
387 protocol(protocol), 390 protocol(protocol),
388 stream_initial_recv_window_size(kSpdyStreamInitialWindowSize), 391 stream_initial_recv_window_size(kSpdyStreamInitialWindowSize),
389 time_func(&base::TimeTicks::Now), 392 time_func(&base::TimeTicks::Now),
393 force_spdy_over_ssl(false),
394 force_spdy_always(false),
395 use_alternate_protocols(false),
390 net_log(NULL) { 396 net_log(NULL) {
391 DCHECK(next_proto_is_spdy(protocol)) << "Invalid protocol: " << protocol; 397 DCHECK(next_proto_is_spdy(protocol)) << "Invalid protocol: " << protocol;
392 } 398 }
393 399
394 SpdySessionDependencies::~SpdySessionDependencies() {} 400 SpdySessionDependencies::~SpdySessionDependencies() {}
395 401
396 // static 402 // static
397 HttpNetworkSession* SpdySessionDependencies::SpdyCreateSession( 403 HttpNetworkSession* SpdySessionDependencies::SpdyCreateSession(
398 SpdySessionDependencies* session_deps) { 404 SpdySessionDependencies* session_deps) {
399 net::HttpNetworkSession::Params params = CreateSessionParams(session_deps); 405 net::HttpNetworkSession::Params params = CreateSessionParams(session_deps);
(...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after
434 params.http_server_properties = 440 params.http_server_properties =
435 session_deps->http_server_properties.GetWeakPtr(); 441 session_deps->http_server_properties.GetWeakPtr();
436 params.enable_spdy_compression = session_deps->enable_compression; 442 params.enable_spdy_compression = session_deps->enable_compression;
437 params.enable_spdy_ping_based_connection_checking = session_deps->enable_ping; 443 params.enable_spdy_ping_based_connection_checking = session_deps->enable_ping;
438 params.enable_user_alternate_protocol_ports = 444 params.enable_user_alternate_protocol_ports =
439 session_deps->enable_user_alternate_protocol_ports; 445 session_deps->enable_user_alternate_protocol_ports;
440 params.spdy_default_protocol = session_deps->protocol; 446 params.spdy_default_protocol = session_deps->protocol;
441 params.spdy_stream_initial_recv_window_size = 447 params.spdy_stream_initial_recv_window_size =
442 session_deps->stream_initial_recv_window_size; 448 session_deps->stream_initial_recv_window_size;
443 params.time_func = session_deps->time_func; 449 params.time_func = session_deps->time_func;
450 params.next_protos = session_deps->next_protos;
444 params.trusted_spdy_proxy = session_deps->trusted_spdy_proxy; 451 params.trusted_spdy_proxy = session_deps->trusted_spdy_proxy;
452 params.force_spdy_over_ssl = session_deps->force_spdy_over_ssl;
453 params.force_spdy_always = session_deps->force_spdy_always;
454 params.use_alternate_protocols = session_deps->use_alternate_protocols;
445 params.net_log = session_deps->net_log; 455 params.net_log = session_deps->net_log;
446 return params; 456 return params;
447 } 457 }
448 458
449 SpdyURLRequestContext::SpdyURLRequestContext(NextProto protocol) 459 SpdyURLRequestContext::SpdyURLRequestContext(NextProto protocol,
460 bool force_spdy_over_ssl,
461 bool force_spdy_always)
450 : storage_(this) { 462 : storage_(this) {
451 DCHECK(next_proto_is_spdy(protocol)) << "Invalid protocol: " << protocol; 463 DCHECK(next_proto_is_spdy(protocol)) << "Invalid protocol: " << protocol;
452 464
453 storage_.set_host_resolver(scoped_ptr<HostResolver>(new MockHostResolver)); 465 storage_.set_host_resolver(scoped_ptr<HostResolver>(new MockHostResolver));
454 storage_.set_cert_verifier(new MockCertVerifier); 466 storage_.set_cert_verifier(new MockCertVerifier);
455 storage_.set_transport_security_state(new TransportSecurityState); 467 storage_.set_transport_security_state(new TransportSecurityState);
456 storage_.set_proxy_service(ProxyService::CreateDirect()); 468 storage_.set_proxy_service(ProxyService::CreateDirect());
457 storage_.set_ssl_config_service(new SSLConfigServiceDefaults); 469 storage_.set_ssl_config_service(new SSLConfigServiceDefaults);
458 storage_.set_http_auth_handler_factory(HttpAuthHandlerFactory::CreateDefault( 470 storage_.set_http_auth_handler_factory(HttpAuthHandlerFactory::CreateDefault(
459 host_resolver())); 471 host_resolver()));
460 storage_.set_http_server_properties( 472 storage_.set_http_server_properties(
461 scoped_ptr<HttpServerProperties>(new HttpServerPropertiesImpl())); 473 scoped_ptr<HttpServerProperties>(new HttpServerPropertiesImpl()));
462 net::HttpNetworkSession::Params params; 474 net::HttpNetworkSession::Params params;
463 params.client_socket_factory = &socket_factory_; 475 params.client_socket_factory = &socket_factory_;
464 params.host_resolver = host_resolver(); 476 params.host_resolver = host_resolver();
465 params.cert_verifier = cert_verifier(); 477 params.cert_verifier = cert_verifier();
466 params.transport_security_state = transport_security_state(); 478 params.transport_security_state = transport_security_state();
467 params.proxy_service = proxy_service(); 479 params.proxy_service = proxy_service();
468 params.ssl_config_service = ssl_config_service(); 480 params.ssl_config_service = ssl_config_service();
469 params.http_auth_handler_factory = http_auth_handler_factory(); 481 params.http_auth_handler_factory = http_auth_handler_factory();
470 params.network_delegate = network_delegate(); 482 params.network_delegate = network_delegate();
471 params.enable_spdy_compression = false; 483 params.enable_spdy_compression = false;
472 params.enable_spdy_ping_based_connection_checking = false; 484 params.enable_spdy_ping_based_connection_checking = false;
473 params.spdy_default_protocol = protocol; 485 params.spdy_default_protocol = protocol;
486 params.force_spdy_over_ssl = force_spdy_over_ssl;
487 params.force_spdy_always = force_spdy_always;
474 params.http_server_properties = http_server_properties(); 488 params.http_server_properties = http_server_properties();
475 scoped_refptr<HttpNetworkSession> network_session( 489 scoped_refptr<HttpNetworkSession> network_session(
476 new HttpNetworkSession(params)); 490 new HttpNetworkSession(params));
477 SpdySessionPoolPeer pool_peer(network_session->spdy_session_pool()); 491 SpdySessionPoolPeer pool_peer(network_session->spdy_session_pool());
478 pool_peer.SetEnableSendingInitialData(false); 492 pool_peer.SetEnableSendingInitialData(false);
479 storage_.set_http_transaction_factory(new HttpCache( 493 storage_.set_http_transaction_factory(new HttpCache(
480 network_session.get(), HttpCache::DefaultBackend::InMemory(0))); 494 network_session.get(), HttpCache::DefaultBackend::InMemory(0)));
481 } 495 }
482 496
483 SpdyURLRequestContext::~SpdyURLRequestContext() { 497 SpdyURLRequestContext::~SpdyURLRequestContext() {
(...skipping 736 matching lines...) Expand 10 before | Expand all | Expand 10 after
1220 } 1234 }
1221 } 1235 }
1222 1236
1223 void SpdyTestUtil::SetPriority(RequestPriority priority, 1237 void SpdyTestUtil::SetPriority(RequestPriority priority,
1224 SpdySynStreamIR* ir) const { 1238 SpdySynStreamIR* ir) const {
1225 ir->set_priority(ConvertRequestPriorityToSpdyPriority( 1239 ir->set_priority(ConvertRequestPriorityToSpdyPriority(
1226 priority, spdy_version())); 1240 priority, spdy_version()));
1227 } 1241 }
1228 1242
1229 } // namespace net 1243 } // namespace net
OLDNEW
« no previous file with comments | « net/spdy/spdy_test_util_common.h ('k') | net/test/net_test_suite.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698