Pepper quota support

webkit/fileapi/file_system_file_util_proxy.cc

 // 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 "webkit/fileapi/file_system_file_util_proxy.h"
 
 #include "base/message_loop_proxy.h"
 #include "webkit/fileapi/file_system_context.h"
 #include "webkit/fileapi/file_system_file_util.h"
 #include "webkit/fileapi/file_system_operation_context.h"
@@ skipping 54 matching lines @@
         FROM_HERE,
         NewRunnableMethod(this, &MessageLoopRelay::RunCallback));
   }
 
   scoped_refptr<base::MessageLoopProxy> origin_message_loop_proxy_;
   base::PlatformFileError error_code_;
   fileapi::FileSystemOperationContext context_;
   fileapi::FileSystemFileUtil* file_system_file_util_;
 };
 
-class RelayCreateOrOpen : public MessageLoopRelay {
+class RelayCreateOrOpenAndQuerySize : public MessageLoopRelay {
  public:
-  RelayCreateOrOpen(
+  RelayCreateOrOpenAndQuerySize(
       const fileapi::FileSystemOperationContext& context,
       scoped_refptr<base::MessageLoopProxy> message_loop_proxy,
       const FilePath& file_path,
       int file_flags,
       fileapi::FileSystemFileUtilProxy::CreateOrOpenCallback* callback)
       : MessageLoopRelay(context),
         message_loop_proxy_(message_loop_proxy),
         file_path_(file_path),
         file_flags_(file_flags),
+        file_size_(-1),
         callback_(callback),
         file_handle_(base::kInvalidPlatformFileValue),
         created_(false) {
     DCHECK(callback);
   }
 
  protected:
-  virtual ~RelayCreateOrOpen() {
+  virtual ~RelayCreateOrOpenAndQuerySize() {
     if (file_handle_ != base::kInvalidPlatformFileValue)
       fileapi::FileSystemFileUtilProxy::Close(*context(),
           message_loop_proxy_, file_handle_, NULL);
   }
 
   virtual void RunWork() {
-    set_error_code(
-        file_system_file_util()->CreateOrOpen(
-            context(), file_path_, file_flags_, &file_handle_, &created_));
+    file_size_ = -1;
+    base::PlatformFileError error;
+    error = file_system_file_util()->CreateOrOpen(
+        context(), file_path_, file_flags_, &file_handle_, &created_);
+    if (error == base::PLATFORM_FILE_OK) {
+      if (created_) {
+        file_size_ = 0;
+      } else {
+        base::PlatformFileInfo file_info;
+        FilePath platform_path;
+        error = file_system_file_util()->GetFileInfo(
+            context(), file_path_, &file_info, &platform_path);
+        file_size_ = file_info.size;
+      }
+    }
+    set_error_code(error);
   }
 
   virtual void RunCallback() {
     callback_->Run(error_code(), base::PassPlatformFile(&file_handle_),
-                   created_);
+                   created_, file_size_);
     delete callback_;
   }
 
  private:
   scoped_refptr<base::MessageLoopProxy> message_loop_proxy_;
   FilePath file_path_;
   int file_flags_;
+  int file_size_;
   fileapi::FileSystemFileUtilProxy::CreateOrOpenCallback* callback_;
   base::PlatformFile file_handle_;
   bool created_;
 };
 
 class RelayWithStatusCallback : public MessageLoopRelay {
  public:
   RelayWithStatusCallback(
       const fileapi::FileSystemOperationContext& context,
       fileapi::FileSystemFileUtilProxy::StatusCallback* callback)
@@ skipping 308 matching lines @@
            scoped_refptr<base::MessageLoopProxy> message_loop_proxy,
            scoped_refptr<MessageLoopRelay> relay) {
   return relay->Start(message_loop_proxy, from_here);
 }
 
 }  // namespace
 
 namespace fileapi {
 
 // static
-bool FileSystemFileUtilProxy::CreateOrOpen(
+bool FileSystemFileUtilProxy::CreateOrOpenAndQuerySize(
     const FileSystemOperationContext& context,
     scoped_refptr<MessageLoopProxy> message_loop_proxy,
     const FilePath& file_path, int file_flags,
     CreateOrOpenCallback* callback) {
-  return Start(FROM_HERE, message_loop_proxy, new RelayCreateOrOpen(context,
-      message_loop_proxy, file_path, file_flags, callback));
+  return Start(FROM_HERE, message_loop_proxy,
+      new RelayCreateOrOpenAndQuerySize(context,
+          message_loop_proxy, file_path, file_flags, callback));
 }
 
 // static
 bool FileSystemFileUtilProxy::Close(
     const FileSystemOperationContext& context,
     scoped_refptr<MessageLoopProxy> message_loop_proxy,
     base::PlatformFile file_handle,
     StatusCallback* callback) {
   return Start(FROM_HERE, message_loop_proxy,
                new RelayClose(context, file_handle, callback));
@@ skipping 104 matching lines @@
     const FileSystemOperationContext& context,
     scoped_refptr<MessageLoopProxy> message_loop_proxy,
     const FilePath& path,
     int64 length,
     StatusCallback* callback) {
   return Start(FROM_HERE, message_loop_proxy,
                new RelayTruncate(context, path, length, callback));
 }
 
 }  // namespace fileapi