Reduce copy on QuotaFileIO::Write

webkit/plugins/ppapi/quota_file_io.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/plugins/ppapi/quota_file_io.h"
 
 #include <algorithm>
 
 #include "base/bind.h"
 #include "base/location.h"
 #include "base/memory/weak_ptr.h"
 #include "base/message_loop_proxy.h"
 #include "base/stl_util.h"
+#include "base/task_runner_util.h"
 #include "webkit/plugins/ppapi/host_globals.h"
 #include "webkit/plugins/ppapi/ppapi_plugin_instance.h"
 #include "webkit/plugins/ppapi/resource_helper.h"
 
 using base::PlatformFile;
 using base::PlatformFileError;
 using quota::StorageType;
 
 namespace webkit {
 namespace ppapi {
 
 namespace {
 StorageType PPFileSystemTypeToQuotaStorageType(PP_FileSystemType type) {
   switch (type) {
     case PP_FILESYSTEMTYPE_LOCALPERSISTENT:
       return quota::kStorageTypePersistent;
     case PP_FILESYSTEMTYPE_LOCALTEMPORARY:
       return quota::kStorageTypeTemporary;
     default:
       return quota::kStorageTypeUnknown;
   }
   NOTREACHED();
   return quota::kStorageTypeUnknown;
 }
+
+int WriteAdapter(PlatformFile file, int64 offset,
+                 scoped_ptr<char[]> data, int size) {
+  return base::WritePlatformFile(file, offset, data.get(), size);
+}
+
 }  // namespace
 
 class QuotaFileIO::PendingOperationBase {
  public:
   virtual ~PendingOperationBase() {}
 
   // Either one of Run() or DidFail() is called (the latter is called when
   // there was more than one error during quota queries).
   virtual void Run() = 0;
   virtual void DidFail(PlatformFileError error) = 0;
@@ skipping 45 matching lines @@
       return;
     }
     DCHECK(buffer_.get());
 
     PluginDelegate* plugin_delegate = quota_io_->GetPluginDelegate();
     if (!plugin_delegate) {
       DidFail(base::PLATFORM_FILE_ERROR_FAILED);
       return;
     }
 
-    if (!base::FileUtilProxy::Write(
-            plugin_delegate->GetFileThreadMessageLoopProxy(),
-            quota_io_->file_, offset_, buffer_.get(), bytes_to_write_,
-            base::Bind(&WriteOperation::DidFinish,
+    if (!base::PostTaskAndReplyWithResult(
+            plugin_delegate->GetFileThreadMessageLoopProxy(), FROM_HERE,
+            base::Bind(&WriteAdapter,
+                       quota_io_->file_, offset_,
+                       base::Passed(&buffer_), bytes_to_write_),
+            base::Bind(&WriteOperation::DidWrite,
                        weak_factory_.GetWeakPtr()))) {
       DidFail(base::PLATFORM_FILE_ERROR_FAILED);
       return;
     }
   }
 
   virtual void DidFail(PlatformFileError error) OVERRIDE {
     DidFinish(error, 0);
   }
 
   bool finished() const { return finished_; }
 
   virtual void WillRunCallback() {
     base::MessageLoopProxy::current()->PostTask(
         FROM_HERE,
         base::Bind(&WriteOperation::RunCallback, weak_factory_.GetWeakPtr()));
   }
 
  private:
+  void DidWrite(int bytes_written) {
+    base::PlatformFileError error = bytes_written > 0 ?
+        base::PLATFORM_FILE_OK : base::PLATFORM_FILE_ERROR_FAILED;
+    DidFinish(error, bytes_written);
+  }
+
   void DidFinish(PlatformFileError status, int bytes_written) {
     finished_ = true;
     status_ = status;
     bytes_written_ = bytes_written;
     int64_t max_offset =
         (status != base::PLATFORM_FILE_OK) ? 0 : offset_ + bytes_written;
     // This may delete itself by calling RunCallback.
     quota_io_->DidWrite(this, max_offset);
   }
 
   virtual void RunCallback() {
     DCHECK_EQ(false, callback_.is_null());
     callback_.Run(status_, bytes_written_);
     delete this;
   }
 
   const int64_t offset_;
-  scoped_array<char> buffer_;
+  scoped_ptr<char[]> buffer_;
   const int32_t bytes_to_write_;
   WriteCallback callback_;
   bool finished_;
   PlatformFileError status_;
   int64_t bytes_written_;
   base::WeakPtrFactory<WriteOperation> weak_factory_;
 };
 
 class QuotaFileIO::SetLengthOperation : public PendingOperationBase {
  public:
@@ skipping 241 matching lines @@
 
 
   PluginDelegate* plugin_delegate = GetPluginDelegate();
   if (plugin_delegate)
     plugin_delegate->DidUpdateFile(file_url_, delta);
   inflight_operations_ = 0;
 }
 
 }  // namespace ppapi
 }  // namespace webkit