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

Side by Side Diff: components/grpc_support/test/get_stream_engine.cc

Issue 2546533003: Respect QuicAllowed policy for new streams (Closed)
Patch Set: IOS io_thread also initializes DynamicSharedParams Created 4 years 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 2016 The Chromium Authors. All rights reserved. 1 // Copyright 2016 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 "base/lazy_instance.h" 5 #include "base/lazy_instance.h"
6 #include "base/macros.h" 6 #include "base/macros.h"
7 #include "base/memory/ptr_util.h" 7 #include "base/memory/ptr_util.h"
8 #include "base/memory/ref_counted.h" 8 #include "base/memory/ref_counted.h"
9 #include "base/strings/string_number_conversions.h" 9 #include "base/strings/string_number_conversions.h"
10 #include "base/strings/stringprintf.h" 10 #include "base/strings/stringprintf.h"
(...skipping 29 matching lines...) Expand all
40 auto mock_host_resolver = base::MakeUnique<net::MockHostResolver>(); 40 auto mock_host_resolver = base::MakeUnique<net::MockHostResolver>();
41 host_resolver_.reset( 41 host_resolver_.reset(
42 new net::MappedHostResolver(std::move(mock_host_resolver))); 42 new net::MappedHostResolver(std::move(mock_host_resolver)));
43 UpdateHostResolverRules(); 43 UpdateHostResolverRules();
44 mock_cert_verifier_.reset(new net::MockCertVerifier()); 44 mock_cert_verifier_.reset(new net::MockCertVerifier());
45 mock_cert_verifier_->set_default_result(net::OK); 45 mock_cert_verifier_->set_default_result(net::OK);
46 server_properties_.reset(new net::HttpServerPropertiesImpl()); 46 server_properties_.reset(new net::HttpServerPropertiesImpl());
47 47
48 // Need to enable QUIC for the test server. 48 // Need to enable QUIC for the test server.
49 auto params = base::MakeUnique<net::HttpNetworkSession::Params>(); 49 auto params = base::MakeUnique<net::HttpNetworkSession::Params>();
50 params->enable_quic = true; 50 auto dynamic_shared_params =
51 base::MakeUnique<net::HttpNetworkSession::DynamicSharedParams>();
52 params->dynamic_shared_params = dynamic_shared_params.get();
53
54 dynamic_shared_params->enable_quic = true;
51 params->enable_http2 = true; 55 params->enable_http2 = true;
52 net::AlternativeService alternative_service(net::kProtoQUIC, "", 443); 56 net::AlternativeService alternative_service(net::kProtoQUIC, "", 443);
53 url::SchemeHostPort quic_hint_server("https", kTestServerHost, 443); 57 url::SchemeHostPort quic_hint_server("https", kTestServerHost, 443);
54 server_properties_->SetAlternativeService( 58 server_properties_->SetAlternativeService(
55 quic_hint_server, alternative_service, base::Time::Max()); 59 quic_hint_server, alternative_service, base::Time::Max());
56 params->quic_host_whitelist.insert(kTestServerHost); 60 params->quic_host_whitelist.insert(kTestServerHost);
57 61
58 request_context_->set_cert_verifier(mock_cert_verifier_.get()); 62 request_context_->set_cert_verifier(mock_cert_verifier_.get());
59 request_context_->set_host_resolver(host_resolver_.get()); 63 request_context_->set_host_resolver(host_resolver_.get());
60 request_context_->set_http_server_properties(server_properties_.get()); 64 request_context_->set_http_server_properties(server_properties_.get());
61 request_context_->set_http_network_session_params(std::move(params)); 65 request_context_->set_http_network_session_params(std::move(params));
66 request_context_->set_http_network_session_dynamic_shared_params(
67 std::move(dynamic_shared_params));
62 68
63 request_context_->Init(); 69 request_context_->Init();
64 } 70 }
65 return request_context_.get(); 71 return request_context_.get();
66 } 72 }
67 73
68 scoped_refptr<base::SingleThreadTaskRunner> GetNetworkTaskRunner() 74 scoped_refptr<base::SingleThreadTaskRunner> GetNetworkTaskRunner()
69 const override { 75 const override {
70 return task_runner_; 76 return task_runner_;
71 } 77 }
(...skipping 49 matching lines...) Expand 10 before | Expand all | Expand 10 after
121 127
122 stream_engine* GetTestStreamEngine(int port) { 128 stream_engine* GetTestStreamEngine(int port) {
123 CreateRequestContextGetterIfNecessary(); 129 CreateRequestContextGetterIfNecessary();
124 g_request_context_getter_.Get()->SetTestServerPort(port); 130 g_request_context_getter_.Get()->SetTestServerPort(port);
125 static stream_engine engine; 131 static stream_engine engine;
126 engine.obj = g_request_context_getter_.Get().get(); 132 engine.obj = g_request_context_getter_.Get().get();
127 return &engine; 133 return &engine;
128 } 134 }
129 135
130 } // namespace grpc_support 136 } // namespace grpc_support
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698