Implement lossy pref behavior for JsonPrefStore.

net/http/transport_security_persister.cc

 // Copyright (c) 2012 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 "net/http/transport_security_persister.h"
 
 #include "base/base64.h"
 #include "base/bind.h"
 #include "base/files/file_path.h"
 #include "base/files/file_util.h"
@@ skipping 76 matching lines @@
 }
 
 }  // namespace
 
 TransportSecurityPersister::TransportSecurityPersister(
     TransportSecurityState* state,
     const base::FilePath& profile_path,
     const scoped_refptr<base::SequencedTaskRunner>& background_runner,
     bool readonly)
     : transport_security_state_(state),
-      writer_(profile_path.AppendASCII("TransportSecurity"), background_runner),
+      writer_(new base::ImportantFileWriterImpl(
+          profile_path.AppendASCII("TransportSecurity"),
+          background_runner)),
       foreground_runner_(base::MessageLoop::current()->message_loop_proxy()),
       background_runner_(background_runner),
       readonly_(readonly),
       weak_ptr_factory_(this) {
   transport_security_state_->SetDelegate(this);
 
   base::PostTaskAndReplyWithResult(
       background_runner_.get(), FROM_HERE,
-      base::Bind(&LoadState, writer_.path()),
+      base::Bind(&LoadState, writer_->path()),
       base::Bind(&TransportSecurityPersister::CompleteLoad,
                  weak_ptr_factory_.GetWeakPtr()));
 }
 
 TransportSecurityPersister::~TransportSecurityPersister() {
   DCHECK(foreground_runner_->RunsTasksOnCurrentThread());
 
-  if (writer_.HasPendingWrite())
-    writer_.DoScheduledWrite();
+  if (writer_->HasPendingWrite())
+    writer_->DoScheduledWrite();
 
   transport_security_state_->SetDelegate(NULL);
 }
 
 void TransportSecurityPersister::StateIsDirty(
     TransportSecurityState* state) {
   DCHECK(foreground_runner_->RunsTasksOnCurrentThread());
   DCHECK_EQ(transport_security_state_, state);
 
   if (!readonly_)
-    writer_.ScheduleWrite(this);
+    writer_->ScheduleWrite(this);
 }
 
 bool TransportSecurityPersister::SerializeData(std::string* output) {
   DCHECK(foreground_runner_->RunsTasksOnCurrentThread());
 
   base::DictionaryValue toplevel;
   base::Time now = base::Time::Now();
   TransportSecurityState::Iterator state(*transport_security_state_);
   for (; state.HasNext(); state.Advance()) {
     const std::string& hostname = state.hostname();
@@ skipping 175 matching lines @@
   bool dirty = false;
   if (!LoadEntries(state, &dirty)) {
     LOG(ERROR) << "Failed to deserialize state: " << state;
     return;
   }
   if (dirty)
     StateIsDirty(transport_security_state_);
 }
 
 }  // namespace net