Notify CloseFile from Pepper to FileSystem.

content/common/fileapi/file_system_dispatcher.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 "content/common/fileapi/file_system_dispatcher.h"
 
 #include "base/file_util.h"
 #include "base/process.h"
 #include "content/common/child_thread.h"
 #include "content/common/fileapi/file_system_messages.h"
 
+namespace {
+
+// Dummy dispatcher used only for issuing a request_id.
+class CloseFileDispatcher : public fileapi::FileSystemCallbackDispatcher {

[kinuko, 2012/06/13 06:38:29]

We usually put these dispatchers on the caller's site (as
AsyncOpenFileSystemURLCallbackTranslator does in pepper_plugin_delegate_impl.cc)
since it's not what the common FSDispatcher wants to care in general.

Or, I guess we can make this IPC send-only and don't let the browser reply?

[kinaba, 2012/06/25 11:14:02]

Sounds good. I made it into a send-only message.

+ public:
+  virtual void DidSucceed() {}
+  virtual void DidFail(base::PlatformFileError error_code) {}
+
+  virtual void DidReadMetadata(const base::PlatformFileInfo& file_info,
+                               const FilePath& platform_path) {
+    NOTREACHED();
+  }
+  virtual void DidReadDirectory(
+      const std::vector<base::FileUtilProxy::Entry>& entries,
+      bool has_more) {
+    NOTREACHED();
+  }
+  virtual void DidOpenFileSystem(const std::string& name,
+                                 const GURL& root) {
+    NOTREACHED();
+  }
+  virtual void DidWrite(int64 bytes, bool complete) {
+    NOTREACHED();
+  }
+  virtual void DidOpenFile(base::PlatformFile file) {
+    NOTREACHED();
+  }
+};
+
+}  // namespace
+
 FileSystemDispatcher::FileSystemDispatcher() {
 }
 
 FileSystemDispatcher::~FileSystemDispatcher() {
   // Make sure we fire all the remaining callbacks.
   for (IDMap<fileapi::FileSystemCallbackDispatcher, IDMapOwnPointer>::iterator
            iter(&dispatchers_); !iter.IsAtEnd(); iter.Advance()) {
     int request_id = iter.GetCurrentKey();
     fileapi::FileSystemCallbackDispatcher* dispatcher = iter.GetCurrentValue();
     DCHECK(dispatcher);
@@ skipping 201 matching lines @@
   if (!ChildThread::current()->Send(
           new FileSystemHostMsg_OpenFile(
               request_id, file_path, file_flags))) {
     dispatchers_.Remove(request_id);  // destroys |dispatcher|
     return false;
   }
 
   return true;
 }
 
+bool FileSystemDispatcher::NotifyCloseFile(const GURL& file_path) {
+  fileapi::FileSystemCallbackDispatcher* dispatcher = new CloseFileDispatcher;
+  int request_id = dispatchers_.Add(dispatcher);
+  if (!ChildThread::current()->Send(
+          new FileSystemHostMsg_NotifyCloseFile(request_id, file_path))) {
+    dispatchers_.Remove(request_id);  // destroys |dispatcher|
+    return false;
+  }
+  return true;
+}
+
 bool FileSystemDispatcher::CreateSnapshotFile(
     const GURL& blob_url,
     const GURL& file_path,
     fileapi::FileSystemCallbackDispatcher* dispatcher) {
   int request_id = dispatchers_.Add(dispatcher);
   if (!ChildThread::current()->Send(
           new FileSystemHostMsg_CreateSnapshotFile(
               request_id, blob_url, file_path))) {
     dispatchers_.Remove(request_id); // destroys |dispatcher|
     return false;
@@ skipping 61 matching lines @@
 }
 
 void FileSystemDispatcher::OnDidOpenFile(
     int request_id, IPC::PlatformFileForTransit file) {
   fileapi::FileSystemCallbackDispatcher* dispatcher =
       dispatchers_.Lookup(request_id);
   DCHECK(dispatcher);
   dispatcher->DidOpenFile(IPC::PlatformFileForTransitToPlatformFile(file));
   dispatchers_.Remove(request_id);
 }