mediaview: Introduce ArcDocumentsProviderRoot.

chrome/browser/chromeos/arc/fileapi/arc_documents_provider_async_file_util.cc

 // Copyright 2016 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 "chrome/browser/chromeos/arc/fileapi/arc_documents_provider_async_file_util.h"
 
+#include <utility>
+
+#include "base/bind.h"
 #include "base/callback.h"
 #include "base/files/file.h"
 #include "base/files/file_path.h"
 #include "base/logging.h"
+#include "chrome/browser/chromeos/arc/fileapi/arc_documents_provider_root.h"
+#include "chrome/browser/chromeos/arc/fileapi/arc_documents_provider_root_map.h"
+#include "chrome/browser/chromeos/arc/fileapi/arc_documents_provider_util.h"
 #include "content/public/browser/browser_thread.h"
 #include "storage/browser/blob/shareable_file_reference.h"
+#include "storage/browser/fileapi/file_system_operation_context.h"
+#include "storage/browser/fileapi/file_system_url.h"
 
 using content::BrowserThread;
 
 namespace arc {
 
-ArcDocumentsProviderAsyncFileUtil::ArcDocumentsProviderAsyncFileUtil() =
-    default;
+ArcDocumentsProviderAsyncFileUtil::ArcDocumentsProviderAsyncFileUtil(
+    ArcDocumentsProviderRootMap* roots)
+    : roots_(roots), weak_ptr_factory_(this) {}
 
 ArcDocumentsProviderAsyncFileUtil::~ArcDocumentsProviderAsyncFileUtil() =
     default;
 
 void ArcDocumentsProviderAsyncFileUtil::CreateOrOpen(
     std::unique_ptr<storage::FileSystemOperationContext> context,
     const storage::FileSystemURL& url,
     int file_flags,
     const CreateOrOpenCallback& callback) {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
@@ skipping 22 matching lines @@
   NOTREACHED();  // Read-only file system.
   callback.Run(base::File::FILE_ERROR_ACCESS_DENIED);
 }
 
 void ArcDocumentsProviderAsyncFileUtil::GetFileInfo(
     std::unique_ptr<storage::FileSystemOperationContext> context,
     const storage::FileSystemURL& url,
     int fields,
     const GetFileInfoCallback& callback) {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
-  NOTIMPLEMENTED();  // TODO(crbug.com/671511): Implement this function.
-  callback.Run(base::File::FILE_ERROR_NOT_FOUND, base::File::Info());
+  DCHECK_EQ(storage::kFileSystemTypeArcDocumentsProvider, url.type());
+
+  base::FilePath path;
+  ArcDocumentsProviderRoot* root = roots_->ParseAndLookup(url, &path);
+  if (!root) {
+    callback.Run(base::File::FILE_ERROR_NOT_FOUND, base::File::Info());
+    return;
+  }
+
+  root->GetFileInfo(
+      path,
+      base::Bind(&ArcDocumentsProviderAsyncFileUtil::OnGetFileInfo,
+                 // It is guaranteed that |this| outlives |context|, so keep
+                 // |context| until the operation finishes.
+                 base::Unretained(this), base::Passed(std::move(context)),
+                 callback));
 }
 
 void ArcDocumentsProviderAsyncFileUtil::ReadDirectory(
     std::unique_ptr<storage::FileSystemOperationContext> context,
     const storage::FileSystemURL& url,
     const ReadDirectoryCallback& callback) {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
-  NOTIMPLEMENTED();  // TODO(crbug.com/671511): Implement this function.
-  callback.Run(base::File::FILE_ERROR_NOT_FOUND, EntryList(),
-               false /* has_more */);
+  DCHECK_EQ(storage::kFileSystemTypeArcDocumentsProvider, url.type());
+
+  base::FilePath path;
+  ArcDocumentsProviderRoot* root = roots_->ParseAndLookup(url, &path);
+  if (!root) {
+    callback.Run(base::File::FILE_ERROR_NOT_FOUND, EntryList(), false);
+    return;
+  }
+
+  root->ReadDirectory(
+      path,
+      base::Bind(&ArcDocumentsProviderAsyncFileUtil::OnReadDirectory,
+                 // It is guaranteed that |this| outlives |context|, so keep
+                 // |context| until the operation finishes.
+                 // In this case we can't use base::Passed() because the
+                 // callback is called multiple times with |has_more| = true.
+                 base::Unretained(this), base::Owned(context.release()),

[Luis Héctor Chávez, 2016/12/14 20:53:50]

Who will be responsible of deleting |context|, then? IIUC it is currently
leaking since you're not even giving the pointer to the callback.

Shouldn't you at least store |context| somewhere in |this| (say, in a
std::vector or std::unordered_map) and then remove it from there if |has_more| =
false in OnReadDirectory?

[Shuhei Takahashi, 2016/12/15 02:37:55]

Hmm, maybe. I've changed the code to explicitly reset a unique_ptr. In this way,
even in the worst case, deleting the last callback instance will release the
context.

+                 callback));
 }
 
 void ArcDocumentsProviderAsyncFileUtil::Touch(
     std::unique_ptr<storage::FileSystemOperationContext> context,
     const storage::FileSystemURL& url,
     const base::Time& last_access_time,
     const base::Time& last_modified_time,
     const StatusCallback& callback) {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
   NOTREACHED();  // Read-only file system.
@@ skipping 74 matching lines @@
     std::unique_ptr<storage::FileSystemOperationContext> context,
     const storage::FileSystemURL& url,
     const CreateSnapshotFileCallback& callback) {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
   NOTIMPLEMENTED();  // TODO(crbug.com/671511): Implement this function.
   callback.Run(base::File::FILE_ERROR_FAILED, base::File::Info(),
                base::FilePath(),
                scoped_refptr<storage::ShareableFileReference>());
 }
 
+void ArcDocumentsProviderAsyncFileUtil::OnGetFileInfo(
+    std::unique_ptr<storage::FileSystemOperationContext> context,
+    const GetFileInfoCallback& callback,
+    base::File::Error result,
+    const base::File::Info& file_info) {
+  DCHECK_CURRENTLY_ON(BrowserThread::IO);
+  callback.Run(result, file_info);
+}
+
+void ArcDocumentsProviderAsyncFileUtil::OnReadDirectory(
+    storage::FileSystemOperationContext* context,
+    const ReadDirectoryCallback& callback,
+    base::File::Error result,
+    const EntryList& file_list,
+    bool has_more) {
+  DCHECK_CURRENTLY_ON(BrowserThread::IO);
+  callback.Run(result, file_list, has_more);
+}
+
 }  // namespace arc