[Cronet] Enable persistence mode for Sdch

components/cronet/android/url_request_context_adapter.cc

 // Copyright 2014 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "components/cronet/android/url_request_context_adapter.h"
 
 #include <limits>
 
 #include "base/bind.h"
 #include "base/files/file_util.h"
 #include "base/files/scoped_file.h"
 #include "base/message_loop/message_loop.h"
+#include "base/prefs/pref_filter.h"
 #include "base/single_thread_task_runner.h"
 #include "components/cronet/url_request_context_config.h"
 #include "net/android/network_change_notifier_factory_android.h"
 #include "net/base/net_errors.h"
 #include "net/base/net_util.h"
 #include "net/base/network_change_notifier.h"
 #include "net/base/network_delegate_impl.h"
 #include "net/cert/cert_verifier.h"
 #include "net/http/http_auth_handler_factory.h"
 #include "net/http/http_network_layer.h"
@@ skipping 120 matching lines @@
 
 void URLRequestContextAdapter::InitRequestContextOnNetworkThread() {
   DCHECK(GetNetworkTaskRunner()->BelongsToCurrentThread());
   DCHECK(config_);
   // TODO(mmenke):  Add method to have the builder enable SPDY.
   net::URLRequestContextBuilder context_builder;
   context_builder.set_network_delegate(new BasicNetworkDelegate());
   context_builder.set_proxy_config_service(proxy_config_service_.get());
   config_->ConfigureURLRequestContextBuilder(&context_builder);
 
+  // Set up pref file if storage path is specified.
+  if (!config_->storage_path.empty()) {

[mmenke, 2015/05/20 18:33:42]

Wonder if it's really worth hooking this up to the legacy API.

[xunjieli, 2015/05/20 21:06:12]

Send out an email. If there's no strong interest, I will drop the persistence
support for the legacy API.

+    base::FilePath filepath(config_->storage_path);
+    filepath = filepath.Append(FILE_PATH_LITERAL("local_prefs_legacy.json"));
+    if (!file_thread_) {
+      file_thread_.reset(new base::Thread("Network File Thread"));
+      file_thread_->Start();
+    }
+    json_pref_store_ = new JsonPrefStore(filepath, file_thread_->task_runner(),
+                                         scoped_ptr<PrefFilter>());
+    json_pref_store_->ReadPrefsAsync(nullptr);
+    context_builder.SetFileTaskRunner(file_thread_->task_runner());
+  }
+
   context_.reset(context_builder.Build());
 
   if (config_->enable_sdch) {
     DCHECK(context_->sdch_manager());
     sdch_owner_.reset(
         new net::SdchOwner(context_->sdch_manager(), context_.get()));
+    if (json_pref_store_)
+      sdch_owner_->EnablePersistentStorage(json_pref_store_.get());
   }
 
   // Currently (circa M39) enabling QUIC requires setting probability threshold.
   if (config_->enable_quic) {
     context_->http_server_properties()
         ->SetAlternativeServiceProbabilityThreshold(0.0f);
     for (size_t hint = 0; hint < config_->quic_hints.size(); ++hint) {
       const URLRequestContextConfig::QuicHint& quic_hint =
           *config_->quic_hints[hint];
       if (quic_hint.host.empty()) {
@@ skipping 141 matching lines @@
     write_to_file_observer_.reset();
   }
 }
 
 void NetLogObserver::OnAddEntry(const net::NetLog::Entry& entry) {
   VLOG(2) << "Net log entry: type=" << entry.type()
           << ", source=" << entry.source().type << ", phase=" << entry.phase();
 }
 
 }  // namespace cronet