Index: chrome/common/important_file_writer.cc |
diff --git a/chrome/common/important_file_writer.cc b/chrome/common/important_file_writer.cc |
deleted file mode 100644 |
index 6a76dfbb362b83776d0c8f37e0d2bc5176e039df..0000000000000000000000000000000000000000 |
--- a/chrome/common/important_file_writer.cc |
+++ /dev/null |
@@ -1,157 +0,0 @@ |
-// Copyright (c) 2011 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 "chrome/common/important_file_writer.h" |
- |
-#include <stdio.h> |
- |
-#include <string> |
- |
-#include "base/bind.h" |
-#include "base/file_path.h" |
-#include "base/file_util.h" |
-#include "base/logging.h" |
-#include "base/message_loop_proxy.h" |
-#include "base/metrics/histogram.h" |
-#include "base/string_number_conversions.h" |
-#include "base/threading/thread.h" |
-#include "base/time.h" |
- |
-using base::TimeDelta; |
- |
-namespace { |
- |
-const int kDefaultCommitIntervalMs = 10000; |
- |
-enum TempFileFailure { |
- FAILED_CREATING, |
- FAILED_OPENING, |
- FAILED_CLOSING, |
- FAILED_WRITING, |
- FAILED_RENAMING, |
- TEMP_FILE_FAILURE_MAX |
-}; |
- |
-void LogFailure(const FilePath& path, TempFileFailure failure_code, |
- const std::string& message) { |
- UMA_HISTOGRAM_ENUMERATION("ImportantFile.TempFileFailures", failure_code, |
- TEMP_FILE_FAILURE_MAX); |
- DPLOG(WARNING) << "temp file failure: " << path.value() |
- << " : " << message; |
-} |
- |
-void WriteToDiskTask(const FilePath& path, const std::string& data) { |
- // Write the data to a temp file then rename to avoid data loss if we crash |
- // while writing the file. Ensure that the temp file is on the same volume |
- // as target file, so it can be moved in one step, and that the temp file |
- // is securely created. |
- FilePath tmp_file_path; |
- if (!file_util::CreateTemporaryFileInDir(path.DirName(), &tmp_file_path)) { |
- LogFailure(path, FAILED_CREATING, "could not create temporary file"); |
- return; |
- } |
- |
- int flags = base::PLATFORM_FILE_OPEN | base::PLATFORM_FILE_WRITE; |
- base::PlatformFile tmp_file = |
- base::CreatePlatformFile(tmp_file_path, flags, NULL, NULL); |
- if (tmp_file == base::kInvalidPlatformFileValue) { |
- LogFailure(path, FAILED_OPENING, "could not open temporary file"); |
- return; |
- } |
- |
- // If this happens in the wild something really bad is going on. |
- CHECK_LE(data.length(), static_cast<size_t>(kint32max)); |
- int bytes_written = base::WritePlatformFile( |
- tmp_file, 0, data.data(), static_cast<int>(data.length())); |
- base::FlushPlatformFile(tmp_file); // Ignore return value. |
- |
- if (!base::ClosePlatformFile(tmp_file)) { |
- LogFailure(path, FAILED_CLOSING, "failed to close temporary file"); |
- file_util::Delete(tmp_file_path, false); |
- return; |
- } |
- |
- if (bytes_written < static_cast<int>(data.length())) { |
- LogFailure(path, FAILED_WRITING, "error writing, bytes_written=" + |
- base::IntToString(bytes_written)); |
- file_util::Delete(tmp_file_path, false); |
- return; |
- } |
- |
- if (!file_util::ReplaceFile(tmp_file_path, path)) { |
- LogFailure(path, FAILED_RENAMING, "could not rename temporary file"); |
- file_util::Delete(tmp_file_path, false); |
- return; |
- } |
-} |
- |
-} // namespace |
- |
-ImportantFileWriter::ImportantFileWriter( |
- const FilePath& path, base::MessageLoopProxy* file_message_loop_proxy) |
- : path_(path), |
- file_message_loop_proxy_(file_message_loop_proxy), |
- serializer_(NULL), |
- commit_interval_(TimeDelta::FromMilliseconds( |
- kDefaultCommitIntervalMs)) { |
- DCHECK(CalledOnValidThread()); |
- DCHECK(file_message_loop_proxy_.get()); |
-} |
- |
-ImportantFileWriter::~ImportantFileWriter() { |
- // We're usually a member variable of some other object, which also tends |
- // to be our serializer. It may not be safe to call back to the parent object |
- // being destructed. |
- DCHECK(!HasPendingWrite()); |
-} |
- |
-bool ImportantFileWriter::HasPendingWrite() const { |
- DCHECK(CalledOnValidThread()); |
- return timer_.IsRunning(); |
-} |
- |
-void ImportantFileWriter::WriteNow(const std::string& data) { |
- DCHECK(CalledOnValidThread()); |
- if (data.length() > static_cast<size_t>(kint32max)) { |
- NOTREACHED(); |
- return; |
- } |
- |
- if (HasPendingWrite()) |
- timer_.Stop(); |
- |
- if (!file_message_loop_proxy_->PostTask( |
- FROM_HERE, base::Bind(&WriteToDiskTask, path_, data))) { |
- // Posting the task to background message loop is not expected |
- // to fail, but if it does, avoid losing data and just hit the disk |
- // on the current thread. |
- NOTREACHED(); |
- |
- WriteToDiskTask(path_, data); |
- } |
-} |
- |
-void ImportantFileWriter::ScheduleWrite(DataSerializer* serializer) { |
- DCHECK(CalledOnValidThread()); |
- |
- DCHECK(serializer); |
- serializer_ = serializer; |
- |
- if (!timer_.IsRunning()) { |
- timer_.Start(FROM_HERE, commit_interval_, this, |
- &ImportantFileWriter::DoScheduledWrite); |
- } |
-} |
- |
-void ImportantFileWriter::DoScheduledWrite() { |
- DCHECK(serializer_); |
- std::string data; |
- if (serializer_->SerializeData(&data)) { |
- WriteNow(data); |
- } else { |
- DLOG(WARNING) << "failed to serialize data to be saved in " |
- << path_.value(); |
- } |
- serializer_ = NULL; |
-} |