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

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

Issue 1290243007: Shift URLRequestContextStorage over to taking scoped_ptrs. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@Paul_BuilderGrab
Patch Set: Lots of fixes driven by try jobs. Created 5 years, 3 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
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 369 matching lines...) Expand 10 before | Expand all | Expand 10 after
380 380
381 // Note: The CancelledTransaction test does cleanup by running all 381 // Note: The CancelledTransaction test does cleanup by running all
382 // tasks in the message loop (RunAllPending). Unfortunately, that 382 // tasks in the message loop (RunAllPending). Unfortunately, that
383 // doesn't clean up tasks on the host resolver thread; and 383 // doesn't clean up tasks on the host resolver thread; and
384 // TCPConnectJob is currently not cancellable. Using synchronous 384 // TCPConnectJob is currently not cancellable. Using synchronous
385 // lookups allows the test to shutdown cleanly. Until we have 385 // lookups allows the test to shutdown cleanly. Until we have
386 // cancellable TCPConnectJobs, use synchronous lookups. 386 // cancellable TCPConnectJobs, use synchronous lookups.
387 host_resolver->set_synchronous_mode(true); 387 host_resolver->set_synchronous_mode(true);
388 } 388 }
389 389
390 SpdySessionDependencies::SpdySessionDependencies(NextProto protocol, 390 SpdySessionDependencies::SpdySessionDependencies(
391 ProxyService* proxy_service) 391 NextProto protocol,
392 scoped_ptr<ProxyService> proxy_service)
392 : host_resolver(new MockHostResolver), 393 : host_resolver(new MockHostResolver),
393 cert_verifier(new MockCertVerifier), 394 cert_verifier(new MockCertVerifier),
394 transport_security_state(new TransportSecurityState), 395 transport_security_state(new TransportSecurityState),
395 proxy_service(proxy_service), 396 proxy_service(proxy_service.Pass()),
396 ssl_config_service(new SSLConfigServiceDefaults), 397 ssl_config_service(new SSLConfigServiceDefaults),
397 socket_factory(new MockClientSocketFactory), 398 socket_factory(new MockClientSocketFactory),
398 deterministic_socket_factory(new DeterministicMockClientSocketFactory), 399 deterministic_socket_factory(new DeterministicMockClientSocketFactory),
399 http_auth_handler_factory( 400 http_auth_handler_factory(
400 HttpAuthHandlerFactory::CreateDefault(host_resolver.get())), 401 HttpAuthHandlerFactory::CreateDefault(host_resolver.get())),
401 enable_ip_pooling(true), 402 enable_ip_pooling(true),
402 enable_compression(false), 403 enable_compression(false),
403 enable_ping(false), 404 enable_ping(false),
404 enable_user_alternate_protocol_ports(false), 405 enable_user_alternate_protocol_ports(false),
405 protocol(protocol), 406 protocol(protocol),
(...skipping 64 matching lines...) Expand 10 before | Expand all | Expand 10 after
470 params.use_alternative_services = session_deps->use_alternative_services; 471 params.use_alternative_services = session_deps->use_alternative_services;
471 params.net_log = session_deps->net_log; 472 params.net_log = session_deps->net_log;
472 return params; 473 return params;
473 } 474 }
474 475
475 SpdyURLRequestContext::SpdyURLRequestContext(NextProto protocol) 476 SpdyURLRequestContext::SpdyURLRequestContext(NextProto protocol)
476 : storage_(this) { 477 : storage_(this) {
477 DCHECK(next_proto_is_spdy(protocol)) << "Invalid protocol: " << protocol; 478 DCHECK(next_proto_is_spdy(protocol)) << "Invalid protocol: " << protocol;
478 479
479 storage_.set_host_resolver(scoped_ptr<HostResolver>(new MockHostResolver)); 480 storage_.set_host_resolver(scoped_ptr<HostResolver>(new MockHostResolver));
480 storage_.set_cert_verifier(new MockCertVerifier); 481 storage_.set_cert_verifier(scoped_ptr<CertVerifier>(new MockCertVerifier));
481 storage_.set_transport_security_state(new TransportSecurityState); 482 storage_.set_transport_security_state(
483 make_scoped_ptr(new TransportSecurityState));
482 storage_.set_proxy_service(ProxyService::CreateDirect()); 484 storage_.set_proxy_service(ProxyService::CreateDirect());
483 storage_.set_ssl_config_service(new SSLConfigServiceDefaults); 485 storage_.set_ssl_config_service(new SSLConfigServiceDefaults);
484 storage_.set_http_auth_handler_factory(HttpAuthHandlerFactory::CreateDefault( 486 storage_.set_http_auth_handler_factory(
485 host_resolver())); 487 HttpAuthHandlerFactory::CreateDefault(host_resolver()));
486 storage_.set_http_server_properties( 488 storage_.set_http_server_properties(
487 scoped_ptr<HttpServerProperties>(new HttpServerPropertiesImpl())); 489 scoped_ptr<HttpServerProperties>(new HttpServerPropertiesImpl()));
488 storage_.set_job_factory(new URLRequestJobFactoryImpl()); 490 storage_.set_job_factory(
491 scoped_ptr<URLRequestJobFactory>(new URLRequestJobFactoryImpl()));
489 HttpNetworkSession::Params params; 492 HttpNetworkSession::Params params;
490 params.client_socket_factory = &socket_factory_; 493 params.client_socket_factory = &socket_factory_;
491 params.host_resolver = host_resolver(); 494 params.host_resolver = host_resolver();
492 params.cert_verifier = cert_verifier(); 495 params.cert_verifier = cert_verifier();
493 params.transport_security_state = transport_security_state(); 496 params.transport_security_state = transport_security_state();
494 params.proxy_service = proxy_service(); 497 params.proxy_service = proxy_service();
495 params.ssl_config_service = ssl_config_service(); 498 params.ssl_config_service = ssl_config_service();
496 params.http_auth_handler_factory = http_auth_handler_factory(); 499 params.http_auth_handler_factory = http_auth_handler_factory();
497 params.network_delegate = network_delegate(); 500 params.network_delegate = network_delegate();
498 params.enable_spdy_compression = false; 501 params.enable_spdy_compression = false;
499 params.enable_spdy_ping_based_connection_checking = false; 502 params.enable_spdy_ping_based_connection_checking = false;
500 params.spdy_default_protocol = protocol; 503 params.spdy_default_protocol = protocol;
501 params.http_server_properties = http_server_properties(); 504 params.http_server_properties = http_server_properties();
502 scoped_refptr<HttpNetworkSession> network_session( 505 scoped_refptr<HttpNetworkSession> network_session(
503 new HttpNetworkSession(params)); 506 new HttpNetworkSession(params));
504 SpdySessionPoolPeer pool_peer(network_session->spdy_session_pool()); 507 SpdySessionPoolPeer pool_peer(network_session->spdy_session_pool());
505 pool_peer.SetEnableSendingInitialData(false); 508 pool_peer.SetEnableSendingInitialData(false);
506 storage_.set_http_transaction_factory(new HttpCache( 509 storage_.set_http_transaction_factory(
507 network_session.get(), HttpCache::DefaultBackend::InMemory(0))); 510 scoped_ptr<HttpTransactionFactory>(new HttpCache(
511 network_session.get(), HttpCache::DefaultBackend::InMemory(0))));
508 } 512 }
509 513
510 SpdyURLRequestContext::~SpdyURLRequestContext() { 514 SpdyURLRequestContext::~SpdyURLRequestContext() {
511 AssertNoURLRequests(); 515 AssertNoURLRequests();
512 } 516 }
513 517
514 bool HasSpdySession(SpdySessionPool* pool, const SpdySessionKey& key) { 518 bool HasSpdySession(SpdySessionPool* pool, const SpdySessionKey& key) {
515 return pool->FindAvailableSession(key, BoundNetLog()) != NULL; 519 return pool->FindAvailableSession(key, BoundNetLog()) != NULL;
516 } 520 }
517 521
(...skipping 821 matching lines...) Expand 10 before | Expand all | Expand 10 after
1339 } 1343 }
1340 } 1344 }
1341 1345
1342 void SpdyTestUtil::SetPriority(RequestPriority priority, 1346 void SpdyTestUtil::SetPriority(RequestPriority priority,
1343 SpdySynStreamIR* ir) const { 1347 SpdySynStreamIR* ir) const {
1344 ir->set_priority(ConvertRequestPriorityToSpdyPriority( 1348 ir->set_priority(ConvertRequestPriorityToSpdyPriority(
1345 priority, spdy_version())); 1349 priority, spdy_version()));
1346 } 1350 }
1347 1351
1348 } // namespace net 1352 } // namespace net
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698