Move storage-related files from webkit/ to new top-level directory storage/

storage/browser/fileapi/sandbox_file_stream_writer.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 "webkit/browser/fileapi/sandbox_file_stream_writer.h"
+#include "storage/browser/fileapi/sandbox_file_stream_writer.h"
 
 #include "base/files/file_util_proxy.h"
 #include "base/sequenced_task_runner.h"
 #include "net/base/io_buffer.h"
 #include "net/base/net_errors.h"
-#include "webkit/browser/blob/file_stream_reader.h"
-#include "webkit/browser/fileapi/file_observers.h"
-#include "webkit/browser/fileapi/file_stream_writer.h"
-#include "webkit/browser/fileapi/file_system_context.h"
-#include "webkit/browser/fileapi/file_system_operation_runner.h"
-#include "webkit/browser/quota/quota_manager_proxy.h"
-#include "webkit/common/fileapi/file_system_util.h"
+#include "storage/browser/blob/file_stream_reader.h"
+#include "storage/browser/fileapi/file_observers.h"
+#include "storage/browser/fileapi/file_stream_writer.h"
+#include "storage/browser/fileapi/file_system_context.h"
+#include "storage/browser/fileapi/file_system_operation_runner.h"
+#include "storage/browser/quota/quota_manager_proxy.h"
+#include "storage/common/fileapi/file_system_util.h"
 
-namespace fileapi {
+namespace storage {
 
 namespace {
 
 // Adjust the |quota| value in overwriting case (i.e. |file_size| > 0 and
 // |file_offset| < |file_size|) to make the remaining quota calculation easier.
 // Specifically this widens the quota for overlapping range (so that we can
 // simply compare written bytes against the adjusted quota).
-int64 AdjustQuotaForOverlap(int64 quota,
-                            int64 file_offset,
-                            int64 file_size) {
+int64 AdjustQuotaForOverlap(int64 quota, int64 file_offset, int64 file_size) {
   DCHECK_LE(file_offset, file_size);
   if (quota < 0)
     quota = 0;
   int64 overlap = file_size - file_offset;
   if (kint64max - overlap > quota)
     quota += overlap;
   return quota;
 }
 
 }  // namespace
 
 SandboxFileStreamWriter::SandboxFileStreamWriter(
     FileSystemContext* file_system_context,
     const FileSystemURL& url,
     int64 initial_offset,
     const UpdateObserverList& observers)
     : file_system_context_(file_system_context),
       url_(url),
       initial_offset_(initial_offset),
       observers_(observers),
       file_size_(0),
       total_bytes_written_(0),
       allowed_bytes_to_write_(0),
       has_pending_operation_(false),
       default_quota_(kint64max),
       weak_factory_(this) {
   DCHECK(url_.is_valid());
 }
 
-SandboxFileStreamWriter::~SandboxFileStreamWriter() {}
+SandboxFileStreamWriter::~SandboxFileStreamWriter() {
+}
 
-int SandboxFileStreamWriter::Write(
-    net::IOBuffer* buf, int buf_len,
-    const net::CompletionCallback& callback) {
+int SandboxFileStreamWriter::Write(net::IOBuffer* buf,
+                                   int buf_len,
+                                   const net::CompletionCallback& callback) {
   has_pending_operation_ = true;
   if (local_file_writer_)
     return WriteInternal(buf, buf_len, callback);
 
   net::CompletionCallback write_task =
       base::Bind(&SandboxFileStreamWriter::DidInitializeForWrite,
                  weak_factory_.GetWeakPtr(),
-                 make_scoped_refptr(buf), buf_len, callback);
+                 make_scoped_refptr(buf),
+                 buf_len,
+                 callback);
   file_system_context_->operation_runner()->CreateSnapshotFile(
-      url_, base::Bind(&SandboxFileStreamWriter::DidCreateSnapshotFile,
-                       weak_factory_.GetWeakPtr(), write_task));
+      url_,
+      base::Bind(&SandboxFileStreamWriter::DidCreateSnapshotFile,
+                 weak_factory_.GetWeakPtr(),
+                 write_task));
   return net::ERR_IO_PENDING;
 }
 
 int SandboxFileStreamWriter::Cancel(const net::CompletionCallback& callback) {
   if (!has_pending_operation_)
     return net::ERR_UNEXPECTED;
 
   DCHECK(!callback.is_null());
   cancel_callback_ = callback;
   return net::ERR_IO_PENDING;
 }
 
 int SandboxFileStreamWriter::WriteInternal(
-    net::IOBuffer* buf, int buf_len,
+    net::IOBuffer* buf,
+    int buf_len,
     const net::CompletionCallback& callback) {
   // allowed_bytes_to_write could be negative if the file size is
   // greater than the current (possibly new) quota.
   DCHECK(total_bytes_written_ <= allowed_bytes_to_write_ ||
          allowed_bytes_to_write_ < 0);
   if (total_bytes_written_ >= allowed_bytes_to_write_) {
     has_pending_operation_ = false;
     return net::ERR_FILE_NO_SPACE;
   }
 
   if (buf_len > allowed_bytes_to_write_ - total_bytes_written_)
     buf_len = allowed_bytes_to_write_ - total_bytes_written_;
 
   DCHECK(local_file_writer_.get());
-  const int result = local_file_writer_->Write(
-      buf, buf_len,
-      base::Bind(&SandboxFileStreamWriter::DidWrite, weak_factory_.GetWeakPtr(),
-                 callback));
+  const int result =
+      local_file_writer_->Write(buf,
+                                buf_len,
+                                base::Bind(&SandboxFileStreamWriter::DidWrite,
+                                           weak_factory_.GetWeakPtr(),
+                                           callback));
   if (result != net::ERR_IO_PENDING)
     has_pending_operation_ = false;
   return result;
 }
 
 void SandboxFileStreamWriter::DidCreateSnapshotFile(
     const net::CompletionCallback& callback,
     base::File::Error file_error,
     const base::File::Info& file_info,
     const base::FilePath& platform_path,
-    const scoped_refptr<webkit_blob::ShareableFileReference>& file_ref) {
+    const scoped_refptr<storage::ShareableFileReference>& file_ref) {
   DCHECK(!file_ref.get());
 
   if (CancelIfRequested())
     return;
   if (file_error != base::File::FILE_OK) {
     callback.Run(net::FileErrorToNetError(file_error));
     return;
   }
   if (file_info.is_directory) {
     // We should not be writing to a directory.
@@ skipping 22 matching lines @@
     allowed_bytes_to_write_ = default_quota_;
     callback.Run(net::OK);
     return;
   }
 
   DCHECK(quota_manager_proxy->quota_manager());
   quota_manager_proxy->quota_manager()->GetUsageAndQuota(
       url_.origin(),
       FileSystemTypeToQuotaStorageType(url_.type()),
       base::Bind(&SandboxFileStreamWriter::DidGetUsageAndQuota,
-                 weak_factory_.GetWeakPtr(), callback));
+                 weak_factory_.GetWeakPtr(),
+                 callback));
 }
 
 void SandboxFileStreamWriter::DidGetUsageAndQuota(
     const net::CompletionCallback& callback,
     quota::QuotaStatusCode status,
-    int64 usage, int64 quota) {
+    int64 usage,
+    int64 quota) {
   if (CancelIfRequested())
     return;
   if (status != quota::kQuotaStatusOk) {
     LOG(WARNING) << "Got unexpected quota error : " << status;
     callback.Run(net::ERR_FAILED);
     return;
   }
 
   allowed_bytes_to_write_ = quota - usage;
   callback.Run(net::OK);
 }
 
 void SandboxFileStreamWriter::DidInitializeForWrite(
-    net::IOBuffer* buf, int buf_len,
+    net::IOBuffer* buf,
+    int buf_len,
     const net::CompletionCallback& callback,
     int init_status) {
   if (CancelIfRequested())
     return;
   if (init_status != net::OK) {
     has_pending_operation_ = false;
     callback.Run(init_status);
     return;
   }
   allowed_bytes_to_write_ = AdjustQuotaForOverlap(
       allowed_bytes_to_write_, initial_offset_, file_size_);
   const int result = WriteInternal(buf, buf_len, callback);
   if (result != net::ERR_IO_PENDING)
     callback.Run(result);
 }
 
-void SandboxFileStreamWriter::DidWrite(
-    const net::CompletionCallback& callback,
-    int write_response) {
+void SandboxFileStreamWriter::DidWrite(const net::CompletionCallback& callback,
+                                       int write_response) {
   DCHECK(has_pending_operation_);
   has_pending_operation_ = false;
 
   if (write_response <= 0) {
     if (CancelIfRequested())
       return;
     callback.Run(write_response);
     return;
   }
 
@@ skipping 26 matching lines @@
   DCHECK(!has_pending_operation_);
   DCHECK(cancel_callback_.is_null());
 
   // Write() is not called yet, so there's nothing to flush.
   if (!local_file_writer_)
     return net::OK;
 
   return local_file_writer_->Flush(callback);
 }
 
-}  // namespace fileapi
+}  // namespace storage