Pepper quota support

webkit/plugins/ppapi/ppb_file_io_impl.h

 // 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.
 
 #ifndef WEBKIT_PLUGINS_PPAPI_PPB_FILE_IO_IMPL_H_
 #define WEBKIT_PLUGINS_PPAPI_PPB_FILE_IO_IMPL_H_
 
 #include <queue>
 
 #include "base/basictypes.h"
+#include "base/callback.h"
 #include "base/file_path.h"
 #include "base/memory/ref_counted.h"
 #include "base/memory/scoped_callback_factory.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/platform_file.h"
 #include "ppapi/c/pp_file_info.h"
 #include "ppapi/c/pp_time.h"
 #include "ppapi/thunk/ppb_file_io_api.h"
 #include "webkit/plugins/ppapi/callbacks.h"
 #include "webkit/plugins/ppapi/plugin_delegate.h"
@@ skipping 65 matching lines @@
     // If there are pending writes, any other kind of async operation is not
     // allowed.
     OPERATION_WRITE,
     // If there is a pending operation that is neither read nor write, no
     // further async operation is allowed.
     OPERATION_EXCLUSIVE,
     // There is no pending operation right now.
     OPERATION_NONE,
   };
 
+  struct PendingOperation {
+    enum Type { UNKNOWN, WRITE, SETLENGTH };
+    PendingOperation();
+    Type type;
+
+    // For WRITE.
+    int64_t offset;
+    const char* buffer;
+    int32_t bytes_to_write;
+
+    // For SETLENGTH.
+    int64_t length;
+  };
+
   // Verifies:
   //  - that |callback| is valid (only nonblocking operation supported);
   //  - that the file is already open or not, depending on |should_be_open|; and
   //  - that no callback is already pending, or it is a read(write) request
   //    and currently the pending operations are reads(writes).
   // Returns |PP_OK| to indicate that everything is valid or |PP_ERROR_...| if
   // the call should be aborted and that code returned to the plugin.
   int32_t CommonCallValidation(bool should_be_open,
                                OperationType new_op,
                                PP_CompletionCallback callback);
 
   // Sets up a pending callback. This should only be called once it is certain
   // that |PP_OK_COMPLETIONPENDING| will be returned.
   // |read_buffer| is only used by read operations.
-  void RegisterCallback(OperationType op,
+  void RegisterCallback(std::queue<CallbackEntry>* callbacks,
+                        OperationType op,
                         PP_CompletionCallback callback,
                         char* rend_buffer);
-
-  void RunAndRemoveFirstPendingCallback(int32_t result);
+  void RunAndRemoveFirstPendingCallback(std::queue<CallbackEntry>* callbacks,
+                                        int32_t result);
 
   void StatusCallback(base::PlatformFileError error_code);
   void AsyncOpenFileCallback(base::PlatformFileError error_code,
-                             base::PassPlatformFile file);
+                             base::PassPlatformFile file,
+                             int64_t file_size);
   void QueryInfoCallback(base::PlatformFileError error_code,
                          const base::PlatformFileInfo& file_info);
   void ReadCallback(base::PlatformFileError error_code,
                     const char* data, int bytes_read);
   void WriteCallback(base::PlatformFileError error_code, int bytes_written);
+  void SetLengthCallback(base::PlatformFileError error_code);
+
+  bool DoesRequireQuotaCheck() const;
+  bool HasNoPendingWrites() const;
+  void QueryAvailableSpace(const PendingOperation& op);
+  void DidQueryAvailableSpace(int64_t avail_space);
 
   base::ScopedCallbackFactory<PPB_FileIO_Impl> callback_factory_;
 
   base::PlatformFile file_;
   PP_FileSystemType file_system_type_;
 
+  // They are valid only for files of
+  // PP_FILESYSTEMTYPE_LOCAL{PERSISTENT,TEMPORARY}.
+  GURL origin_url_;
+  int64_t file_size_;
+
+  // Valid only while there're pending write requests.
+  int64_t cached_available_space_;
+
   std::queue<CallbackEntry> callbacks_;
   OperationType pending_op_;
 
   // Output buffer pointer for |Query()|; only non-null when a callback is
   // pending for it.
   PP_FileInfo* info_;
 
+  std::queue<PendingOperation> pending_quota_checks_;
+  std::queue<CallbackEntry> pending_quota_check_callbacks_;
+
+  std::queue<int64_t> pending_write_offset_;
+  int64_t pending_setlength_length_;
+
   DISALLOW_COPY_AND_ASSIGN(PPB_FileIO_Impl);
 };
 
 }  // namespace ppapi
 }  // namespace webkit
 
 #endif  // WEBKIT_PLUGINS_PPAPI_PPB_FILE_IO_IMPL_H_