OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 "components/cronet/android/cronet_url_request_context_adapter.h" | 5 #include "components/cronet/android/cronet_url_request_context_adapter.h" |
6 | 6 |
7 #include "base/android/jni_android.h" | 7 #include "base/android/jni_android.h" |
8 #include "base/android/jni_string.h" | 8 #include "base/android/jni_string.h" |
9 #include "base/bind.h" | 9 #include "base/bind.h" |
10 #include "base/files/file_util.h" | 10 #include "base/files/file_util.h" |
(...skipping 151 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
162 void CronetURLRequestContextAdapter::InitializeOnNetworkThread( | 162 void CronetURLRequestContextAdapter::InitializeOnNetworkThread( |
163 scoped_ptr<URLRequestContextConfig> config, | 163 scoped_ptr<URLRequestContextConfig> config, |
164 const base::android::ScopedJavaGlobalRef<jobject>& | 164 const base::android::ScopedJavaGlobalRef<jobject>& |
165 jcronet_url_request_context) { | 165 jcronet_url_request_context) { |
166 DCHECK(GetNetworkTaskRunner()->BelongsToCurrentThread()); | 166 DCHECK(GetNetworkTaskRunner()->BelongsToCurrentThread()); |
167 DCHECK(!is_context_initialized_); | 167 DCHECK(!is_context_initialized_); |
168 DCHECK(proxy_config_service_); | 168 DCHECK(proxy_config_service_); |
169 // TODO(mmenke): Add method to have the builder enable SPDY. | 169 // TODO(mmenke): Add method to have the builder enable SPDY. |
170 net::URLRequestContextBuilder context_builder; | 170 net::URLRequestContextBuilder context_builder; |
171 | 171 |
172 scoped_ptr<net::NetLog> net_log(new net::NetLog); | 172 net_log_.reset(new net::NetLog); |
173 scoped_ptr<net::NetworkDelegate> network_delegate(new BasicNetworkDelegate()); | 173 scoped_ptr<net::NetworkDelegate> network_delegate(new BasicNetworkDelegate()); |
174 #if defined(DATA_REDUCTION_PROXY_SUPPORT) | 174 #if defined(DATA_REDUCTION_PROXY_SUPPORT) |
175 DCHECK(!data_reduction_proxy_); | 175 DCHECK(!data_reduction_proxy_); |
176 // For now, the choice to enable the data reduction proxy happens once, | 176 // For now, the choice to enable the data reduction proxy happens once, |
177 // at initialization. It cannot be disabled thereafter. | 177 // at initialization. It cannot be disabled thereafter. |
178 if (!config->data_reduction_proxy_key.empty()) { | 178 if (!config->data_reduction_proxy_key.empty()) { |
179 data_reduction_proxy_.reset( | 179 data_reduction_proxy_.reset(new CronetDataReductionProxy( |
180 new CronetDataReductionProxy( | 180 config->data_reduction_proxy_key, config->data_reduction_primary_proxy, |
181 config->data_reduction_proxy_key, | 181 config->data_reduction_fallback_proxy, |
182 config->data_reduction_primary_proxy, | 182 config->data_reduction_secure_proxy_check_url, config->user_agent, |
183 config->data_reduction_fallback_proxy, | 183 GetNetworkTaskRunner(), net_log_.get())); |
184 config->data_reduction_secure_proxy_check_url, | |
185 config->user_agent, | |
186 GetNetworkTaskRunner(), | |
187 net_log.get())); | |
188 network_delegate = | 184 network_delegate = |
189 data_reduction_proxy_->CreateNetworkDelegate(network_delegate.Pass()); | 185 data_reduction_proxy_->CreateNetworkDelegate(network_delegate.Pass()); |
190 ScopedVector<net::URLRequestInterceptor> interceptors; | 186 ScopedVector<net::URLRequestInterceptor> interceptors; |
191 interceptors.push_back(data_reduction_proxy_->CreateInterceptor()); | 187 interceptors.push_back(data_reduction_proxy_->CreateInterceptor()); |
192 context_builder.SetInterceptors(interceptors.Pass()); | 188 context_builder.SetInterceptors(interceptors.Pass()); |
193 } | 189 } |
194 #endif // defined(DATA_REDUCTION_PROXY_SUPPORT) | 190 #endif // defined(DATA_REDUCTION_PROXY_SUPPORT) |
195 context_builder.set_network_delegate(network_delegate.release()); | 191 context_builder.set_network_delegate(network_delegate.Pass()); |
196 context_builder.set_net_log(net_log.release()); | 192 context_builder.set_net_log(net_log_.get()); |
197 context_builder.set_proxy_config_service(proxy_config_service_.release()); | 193 context_builder.set_proxy_config_service(proxy_config_service_.Pass()); |
198 config->ConfigureURLRequestContextBuilder(&context_builder); | 194 config->ConfigureURLRequestContextBuilder(&context_builder); |
199 | 195 |
200 // Set up pref file if storage path is specified. | 196 // Set up pref file if storage path is specified. |
201 if (!config->storage_path.empty()) { | 197 if (!config->storage_path.empty()) { |
202 base::FilePath filepath(config->storage_path); | 198 base::FilePath filepath(config->storage_path); |
203 filepath = filepath.Append(FILE_PATH_LITERAL("local_prefs.json")); | 199 filepath = filepath.Append(FILE_PATH_LITERAL("local_prefs.json")); |
204 json_pref_store_ = new JsonPrefStore( | 200 json_pref_store_ = new JsonPrefStore( |
205 filepath, GetFileThread()->task_runner(), scoped_ptr<PrefFilter>()); | 201 filepath, GetFileThread()->task_runner(), scoped_ptr<PrefFilter>()); |
206 context_builder.SetFileTaskRunner(GetFileThread()->task_runner()); | 202 context_builder.SetFileTaskRunner(GetFileThread()->task_runner()); |
207 | 203 |
208 // Set up HttpServerPropertiesManager. | 204 // Set up HttpServerPropertiesManager. |
209 base::PrefServiceFactory factory; | 205 base::PrefServiceFactory factory; |
210 factory.set_user_prefs(json_pref_store_); | 206 factory.set_user_prefs(json_pref_store_); |
211 scoped_refptr<PrefRegistrySimple> registry(new PrefRegistrySimple()); | 207 scoped_refptr<PrefRegistrySimple> registry(new PrefRegistrySimple()); |
212 registry->RegisterDictionaryPref(kHttpServerProperties, | 208 registry->RegisterDictionaryPref(kHttpServerProperties, |
213 new base::DictionaryValue()); | 209 new base::DictionaryValue()); |
214 pref_service_ = factory.Create(registry.get()).Pass(); | 210 pref_service_ = factory.Create(registry.get()).Pass(); |
215 | 211 |
216 scoped_ptr<net::HttpServerPropertiesManager> http_server_properties_manager( | 212 scoped_ptr<net::HttpServerPropertiesManager> http_server_properties_manager( |
217 new net::HttpServerPropertiesManager(pref_service_.get(), | 213 new net::HttpServerPropertiesManager(pref_service_.get(), |
218 kHttpServerProperties, | 214 kHttpServerProperties, |
219 GetNetworkTaskRunner())); | 215 GetNetworkTaskRunner())); |
220 http_server_properties_manager->InitializeOnNetworkThread(); | 216 http_server_properties_manager->InitializeOnNetworkThread(); |
221 http_server_properties_manager_ = http_server_properties_manager.get(); | 217 http_server_properties_manager_ = http_server_properties_manager.get(); |
222 context_builder.SetHttpServerProperties( | 218 context_builder.SetHttpServerProperties( |
223 http_server_properties_manager.Pass()); | 219 http_server_properties_manager.Pass()); |
224 } | 220 } |
225 | 221 |
226 context_.reset(context_builder.Build()); | 222 context_ = context_builder.Build().Pass(); |
227 | 223 |
228 default_load_flags_ = net::LOAD_DO_NOT_SAVE_COOKIES | | 224 default_load_flags_ = net::LOAD_DO_NOT_SAVE_COOKIES | |
229 net::LOAD_DO_NOT_SEND_COOKIES; | 225 net::LOAD_DO_NOT_SEND_COOKIES; |
230 if (config->load_disable_cache) | 226 if (config->load_disable_cache) |
231 default_load_flags_ |= net::LOAD_DISABLE_CACHE; | 227 default_load_flags_ |= net::LOAD_DISABLE_CACHE; |
232 | 228 |
233 if (config->enable_sdch) { | 229 if (config->enable_sdch) { |
234 DCHECK(context_->sdch_manager()); | 230 DCHECK(context_->sdch_manager()); |
235 sdch_owner_.reset( | 231 sdch_owner_.reset( |
236 new net::SdchOwner(context_->sdch_manager(), context_.get())); | 232 new net::SdchOwner(context_->sdch_manager(), context_.get())); |
(...skipping 183 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
420 } | 416 } |
421 | 417 |
422 static jint SetMinLogLevel(JNIEnv* env, jclass jcaller, jint jlog_level) { | 418 static jint SetMinLogLevel(JNIEnv* env, jclass jcaller, jint jlog_level) { |
423 jint old_log_level = static_cast<jint>(logging::GetMinLogLevel()); | 419 jint old_log_level = static_cast<jint>(logging::GetMinLogLevel()); |
424 // MinLogLevel is global, shared by all URLRequestContexts. | 420 // MinLogLevel is global, shared by all URLRequestContexts. |
425 logging::SetMinLogLevel(static_cast<int>(jlog_level)); | 421 logging::SetMinLogLevel(static_cast<int>(jlog_level)); |
426 return old_log_level; | 422 return old_log_level; |
427 } | 423 } |
428 | 424 |
429 } // namespace cronet | 425 } // namespace cronet |
OLD | NEW |