SyncFS: Support resolveLocalFileSystemURL on SyncFileSystem

content/child/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/child/fileapi/file_system_dispatcher.h"
 
 #include "base/callback.h"
 #include "base/file_util.h"
 #include "base/message_loop/message_loop_proxy.h"
 #include "base/process/process.h"
 #include "content/child/child_thread.h"
 #include "content/common/fileapi/file_system_messages.h"
 
 namespace content {
 
 class FileSystemDispatcher::CallbackDispatcher {
  public:
   typedef CallbackDispatcher self;
   typedef FileSystemDispatcher::StatusCallback StatusCallback;
   typedef FileSystemDispatcher::MetadataCallback MetadataCallback;
   typedef FileSystemDispatcher::ReadDirectoryCallback ReadDirectoryCallback;
   typedef FileSystemDispatcher::OpenFileSystemCallback OpenFileSystemCallback;
+  typedef FileSystemDispatcher::ResolveURLCallback ResolveURLCallback;
   typedef FileSystemDispatcher::WriteCallback WriteCallback;
   typedef FileSystemDispatcher::OpenFileCallback OpenFileCallback;
 
   static CallbackDispatcher* Create(const StatusCallback& callback) {
     CallbackDispatcher* dispatcher = new CallbackDispatcher;
     dispatcher->status_callback_ = callback;
     dispatcher->error_callback_ = callback;
     return dispatcher;
   }
   static CallbackDispatcher* Create(const MetadataCallback& callback,
@@ skipping 17 matching lines @@
     dispatcher->error_callback_ = error_callback;
     return dispatcher;
   }
   static CallbackDispatcher* Create(const OpenFileSystemCallback& callback,
                                     const StatusCallback& error_callback) {
     CallbackDispatcher* dispatcher = new CallbackDispatcher;
     dispatcher->filesystem_callback_ = callback;
     dispatcher->error_callback_ = error_callback;
     return dispatcher;
   }
+  static CallbackDispatcher* Create(const ResolveURLCallback& callback,
+                                    const StatusCallback& error_callback) {
+    CallbackDispatcher* dispatcher = new CallbackDispatcher;
+    dispatcher->resolve_callback_ = callback;
+    dispatcher->error_callback_ = error_callback;
+    return dispatcher;
+  }
   static CallbackDispatcher* Create(const WriteCallback& callback,
                                     const StatusCallback& error_callback) {
     CallbackDispatcher* dispatcher = new CallbackDispatcher;
     dispatcher->write_callback_ = callback;
     dispatcher->error_callback_ = error_callback;
     return dispatcher;
   }
   static CallbackDispatcher* Create(const OpenFileCallback& callback,
                                     const StatusCallback& error_callback) {
     CallbackDispatcher* dispatcher = new CallbackDispatcher;
@@ skipping 28 matching lines @@
       const std::vector<fileapi::DirectoryEntry>& entries,
       bool has_more) {
     directory_callback_.Run(entries, has_more);
   }
 
   void DidOpenFileSystem(const std::string& name,
                          const GURL& root) {
     filesystem_callback_.Run(name, root);
   }
 
+  void DidResolveURL(const std::string& name,
+                     const GURL& root,
+                     const base::FilePath& file_path,
+                     bool is_directory) {
+    resolve_callback_.Run(name, root, file_path, is_directory);
+  }
+
   void DidWrite(int64 bytes, bool complete) {
     write_callback_.Run(bytes, complete);
   }
 
   void DidOpenFile(base::PlatformFile file,
                    int file_open_id,
                    quota::QuotaLimitType quota_policy) {
     open_callback_.Run(file, file_open_id, quota_policy);
   }
 
  private:
   CallbackDispatcher() {}
 
   StatusCallback status_callback_;
   MetadataCallback metadata_callback_;
   CreateSnapshotFileCallback snapshot_callback_;
   ReadDirectoryCallback directory_callback_;
   OpenFileSystemCallback filesystem_callback_;
+  ResolveURLCallback resolve_callback_;
   WriteCallback write_callback_;
   OpenFileCallback open_callback_;
 
   StatusCallback error_callback_;
 
   DISALLOW_COPY_AND_ASSIGN(CallbackDispatcher);
 };
 
 FileSystemDispatcher::FileSystemDispatcher() {
 }
 
 FileSystemDispatcher::~FileSystemDispatcher() {
   // Make sure we fire all the remaining callbacks.
   for (IDMap<CallbackDispatcher, IDMapOwnPointer>::iterator
            iter(&dispatchers_); !iter.IsAtEnd(); iter.Advance()) {
     int request_id = iter.GetCurrentKey();
     CallbackDispatcher* dispatcher = iter.GetCurrentValue();
     DCHECK(dispatcher);
     dispatcher->DidFail(base::PLATFORM_FILE_ERROR_ABORT);
     dispatchers_.Remove(request_id);
   }
 }
 
 bool FileSystemDispatcher::OnMessageReceived(const IPC::Message& msg) {
   bool handled = true;
   IPC_BEGIN_MESSAGE_MAP(FileSystemDispatcher, msg)
     IPC_MESSAGE_HANDLER(FileSystemMsg_DidOpenFileSystem, OnDidOpenFileSystem)
+    IPC_MESSAGE_HANDLER(FileSystemMsg_DidResolveURL, OnDidResolveURL)
     IPC_MESSAGE_HANDLER(FileSystemMsg_DidSucceed, OnDidSucceed)
     IPC_MESSAGE_HANDLER(FileSystemMsg_DidReadDirectory, OnDidReadDirectory)
     IPC_MESSAGE_HANDLER(FileSystemMsg_DidReadMetadata, OnDidReadMetadata)
     IPC_MESSAGE_HANDLER(FileSystemMsg_DidCreateSnapshotFile,
                         OnDidCreateSnapshotFile)
     IPC_MESSAGE_HANDLER(FileSystemMsg_DidFail, OnDidFail)
     IPC_MESSAGE_HANDLER(FileSystemMsg_DidWrite, OnDidWrite)
     IPC_MESSAGE_HANDLER(FileSystemMsg_DidOpenFile, OnDidOpenFile)
     IPC_MESSAGE_UNHANDLED(handled = false)
   IPC_END_MESSAGE_MAP()
   return handled;
 }
 
 void FileSystemDispatcher::OpenFileSystem(
     const GURL& origin_url, fileapi::FileSystemType type,
     long long size, bool create,
     const OpenFileSystemCallback& success_callback,
     const StatusCallback& error_callback) {
   int request_id = dispatchers_.Add(
       CallbackDispatcher::Create(success_callback, error_callback));
   ChildThread::current()->Send(new FileSystemHostMsg_Open(
           request_id, origin_url, type, size, create));
 }
 
+void FileSystemDispatcher::ResolveURL(
+    const GURL& filesystem_url,
+    const ResolveURLCallback& success_callback,
+    const StatusCallback& error_callback) {
+  int request_id = dispatchers_.Add(
+      CallbackDispatcher::Create(success_callback, error_callback));
+  ChildThread::current()->Send(new FileSystemHostMsg_ResolveURL(
+          request_id, filesystem_url));
+}
+
 void FileSystemDispatcher::DeleteFileSystem(
     const GURL& origin_url,
     fileapi::FileSystemType type,
     const StatusCallback& callback) {
   int request_id = dispatchers_.Add(CallbackDispatcher::Create(callback));
   ChildThread::current()->Send(new FileSystemHostMsg_DeleteFileSystem(
           request_id, origin_url, type));
 }
 
 void FileSystemDispatcher::Move(
@@ skipping 151 matching lines @@
 void FileSystemDispatcher::OnDidOpenFileSystem(int request_id,
                                                const std::string& name,
                                                const GURL& root) {
   DCHECK(root.is_valid());
   CallbackDispatcher* dispatcher = dispatchers_.Lookup(request_id);
   DCHECK(dispatcher);
   dispatcher->DidOpenFileSystem(name, root);
   dispatchers_.Remove(request_id);
 }
 
+void FileSystemDispatcher::OnDidResolveURL(int request_id,
+                                           const std::string& name,
+                                           const GURL& root,
+                                           const base::FilePath& file_path,
+                                           bool is_directory) {
+  DCHECK(root.is_valid());
+  CallbackDispatcher* dispatcher = dispatchers_.Lookup(request_id);
+  DCHECK(dispatcher);
+  dispatcher->DidResolveURL(name, root, file_path, is_directory);
+  dispatchers_.Remove(request_id);
+}
+
 void FileSystemDispatcher::OnDidSucceed(int request_id) {
   CallbackDispatcher* dispatcher = dispatchers_.Lookup(request_id);
   DCHECK(dispatcher);
   dispatcher->DidSucceed();
   dispatchers_.Remove(request_id);
 }
 
 void FileSystemDispatcher::OnDidReadMetadata(
     int request_id, const base::PlatformFileInfo& file_info) {
   CallbackDispatcher* dispatcher = dispatchers_.Lookup(request_id);
@@ skipping 45 matching lines @@
     quota::QuotaLimitType quota_policy) {
   CallbackDispatcher* dispatcher = dispatchers_.Lookup(request_id);
   DCHECK(dispatcher);
   dispatcher->DidOpenFile(IPC::PlatformFileForTransitToPlatformFile(file),
                           file_open_id,
                           quota_policy);
   dispatchers_.Remove(request_id);
 }
 
 }  // namespace content