Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1244)

Unified Diff: webkit/browser/fileapi/async_file_util_adapter.cc

Issue 539143002: Migrate webkit/browser/ to storage/browser/ (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 6 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: webkit/browser/fileapi/async_file_util_adapter.cc
diff --git a/webkit/browser/fileapi/async_file_util_adapter.cc b/webkit/browser/fileapi/async_file_util_adapter.cc
deleted file mode 100644
index 62244b777eb7c4504f1db49417625e62412590e5..0000000000000000000000000000000000000000
--- a/webkit/browser/fileapi/async_file_util_adapter.cc
+++ /dev/null
@@ -1,352 +0,0 @@
-// Copyright (c) 2013 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/browser/fileapi/async_file_util_adapter.h"
-
-#include <vector>
-
-#include "base/bind.h"
-#include "base/sequenced_task_runner.h"
-#include "base/task_runner_util.h"
-#include "base/thread_task_runner_handle.h"
-#include "webkit/browser/fileapi/file_system_context.h"
-#include "webkit/browser/fileapi/file_system_file_util.h"
-#include "webkit/browser/fileapi/file_system_operation_context.h"
-#include "webkit/browser/fileapi/file_system_url.h"
-#include "webkit/common/blob/shareable_file_reference.h"
-#include "webkit/common/fileapi/file_system_util.h"
-
-using base::Bind;
-using base::Callback;
-using base::Owned;
-using base::Unretained;
-using storage::ShareableFileReference;
-
-namespace storage {
-
-namespace {
-
-class EnsureFileExistsHelper {
- public:
- EnsureFileExistsHelper() : error_(base::File::FILE_OK), created_(false) {}
-
- void RunWork(FileSystemFileUtil* file_util,
- FileSystemOperationContext* context,
- const FileSystemURL& url) {
- error_ = file_util->EnsureFileExists(context, url, &created_);
- }
-
- void Reply(const AsyncFileUtil::EnsureFileExistsCallback& callback) {
- callback.Run(error_, created_);
- }
-
- private:
- base::File::Error error_;
- bool created_;
- DISALLOW_COPY_AND_ASSIGN(EnsureFileExistsHelper);
-};
-
-class GetFileInfoHelper {
- public:
- GetFileInfoHelper()
- : error_(base::File::FILE_OK) {}
-
- void GetFileInfo(FileSystemFileUtil* file_util,
- FileSystemOperationContext* context,
- const FileSystemURL& url) {
- error_ = file_util->GetFileInfo(context, url, &file_info_, &platform_path_);
- }
-
- void CreateSnapshotFile(FileSystemFileUtil* file_util,
- FileSystemOperationContext* context,
- const FileSystemURL& url) {
- scoped_file_ = file_util->CreateSnapshotFile(
- context, url, &error_, &file_info_, &platform_path_);
- }
-
- void ReplyFileInfo(const AsyncFileUtil::GetFileInfoCallback& callback) {
- callback.Run(error_, file_info_);
- }
-
- void ReplySnapshotFile(
- const AsyncFileUtil::CreateSnapshotFileCallback& callback) {
- callback.Run(error_, file_info_, platform_path_,
- ShareableFileReference::GetOrCreate(scoped_file_.Pass()));
- }
-
- private:
- base::File::Error error_;
- base::File::Info file_info_;
- base::FilePath platform_path_;
- storage::ScopedFile scoped_file_;
- DISALLOW_COPY_AND_ASSIGN(GetFileInfoHelper);
-};
-
-void ReadDirectoryHelper(FileSystemFileUtil* file_util,
- FileSystemOperationContext* context,
- const FileSystemURL& url,
- base::SingleThreadTaskRunner* origin_loop,
- const AsyncFileUtil::ReadDirectoryCallback& callback) {
- base::File::Info file_info;
- base::FilePath platform_path;
- base::File::Error error = file_util->GetFileInfo(
- context, url, &file_info, &platform_path);
-
- if (error == base::File::FILE_OK && !file_info.is_directory)
- error = base::File::FILE_ERROR_NOT_A_DIRECTORY;
-
- std::vector<DirectoryEntry> entries;
- if (error != base::File::FILE_OK) {
- origin_loop->PostTask(
- FROM_HERE, base::Bind(callback, error, entries, false /* has_more */));
- return;
- }
-
- // Note: Increasing this value may make some tests in LayoutTests meaningless.
- // (Namely, read-directory-many.html and read-directory-sync-many.html are
- // assuming that they are reading much more entries than this constant.)
- const size_t kResultChunkSize = 100;
-
- scoped_ptr<FileSystemFileUtil::AbstractFileEnumerator> file_enum(
- file_util->CreateFileEnumerator(context, url));
-
- base::FilePath current;
- while (!(current = file_enum->Next()).empty()) {
- DirectoryEntry entry;
- entry.is_directory = file_enum->IsDirectory();
- entry.name = VirtualPath::BaseName(current).value();
- entry.size = file_enum->Size();
- entry.last_modified_time = file_enum->LastModifiedTime();
- entries.push_back(entry);
-
- if (entries.size() == kResultChunkSize) {
- origin_loop->PostTask(
- FROM_HERE, base::Bind(callback, base::File::FILE_OK, entries,
- true /* has_more */));
- entries.clear();
- }
- }
- origin_loop->PostTask(
- FROM_HERE, base::Bind(callback, base::File::FILE_OK, entries,
- false /* has_more */));
-}
-
-void RunCreateOrOpenCallback(
- FileSystemOperationContext* context,
- const AsyncFileUtil::CreateOrOpenCallback& callback,
- base::File file) {
- callback.Run(file.Pass(), base::Closure());
-}
-
-} // namespace
-
-AsyncFileUtilAdapter::AsyncFileUtilAdapter(
- FileSystemFileUtil* sync_file_util)
- : sync_file_util_(sync_file_util) {
- DCHECK(sync_file_util_.get());
-}
-
-AsyncFileUtilAdapter::~AsyncFileUtilAdapter() {
-}
-
-void AsyncFileUtilAdapter::CreateOrOpen(
- scoped_ptr<FileSystemOperationContext> context,
- const FileSystemURL& url,
- int file_flags,
- const CreateOrOpenCallback& callback) {
- FileSystemOperationContext* context_ptr = context.release();
- base::PostTaskAndReplyWithResult(
- context_ptr->task_runner(),
- FROM_HERE,
- Bind(&FileSystemFileUtil::CreateOrOpen, Unretained(sync_file_util_.get()),
- context_ptr, url, file_flags),
- Bind(&RunCreateOrOpenCallback, base::Owned(context_ptr), callback));
-}
-
-void AsyncFileUtilAdapter::EnsureFileExists(
- scoped_ptr<FileSystemOperationContext> context,
- const FileSystemURL& url,
- const EnsureFileExistsCallback& callback) {
- EnsureFileExistsHelper* helper = new EnsureFileExistsHelper;
- FileSystemOperationContext* context_ptr = context.release();
- const bool success = context_ptr->task_runner()->PostTaskAndReply(
- FROM_HERE,
- Bind(&EnsureFileExistsHelper::RunWork, Unretained(helper),
- sync_file_util_.get(), base::Owned(context_ptr), url),
- Bind(&EnsureFileExistsHelper::Reply, Owned(helper), callback));
- DCHECK(success);
-}
-
-void AsyncFileUtilAdapter::CreateDirectory(
- scoped_ptr<FileSystemOperationContext> context,
- const FileSystemURL& url,
- bool exclusive,
- bool recursive,
- const StatusCallback& callback) {
- FileSystemOperationContext* context_ptr = context.release();
- const bool success = base::PostTaskAndReplyWithResult(
- context_ptr->task_runner(), FROM_HERE,
- Bind(&FileSystemFileUtil::CreateDirectory,
- Unretained(sync_file_util_.get()),
- base::Owned(context_ptr), url, exclusive, recursive),
- callback);
- DCHECK(success);
-}
-
-void AsyncFileUtilAdapter::GetFileInfo(
- scoped_ptr<FileSystemOperationContext> context,
- const FileSystemURL& url,
- const GetFileInfoCallback& callback) {
- FileSystemOperationContext* context_ptr = context.release();
- GetFileInfoHelper* helper = new GetFileInfoHelper;
- const bool success = context_ptr->task_runner()->PostTaskAndReply(
- FROM_HERE,
- Bind(&GetFileInfoHelper::GetFileInfo, Unretained(helper),
- sync_file_util_.get(), base::Owned(context_ptr), url),
- Bind(&GetFileInfoHelper::ReplyFileInfo, Owned(helper), callback));
- DCHECK(success);
-}
-
-void AsyncFileUtilAdapter::ReadDirectory(
- scoped_ptr<FileSystemOperationContext> context,
- const FileSystemURL& url,
- const ReadDirectoryCallback& callback) {
- FileSystemOperationContext* context_ptr = context.release();
- const bool success = context_ptr->task_runner()->PostTask(
- FROM_HERE,
- Bind(&ReadDirectoryHelper,
- sync_file_util_.get(), base::Owned(context_ptr), url,
- base::ThreadTaskRunnerHandle::Get(), callback));
- DCHECK(success);
-}
-
-void AsyncFileUtilAdapter::Touch(
- scoped_ptr<FileSystemOperationContext> context,
- const FileSystemURL& url,
- const base::Time& last_access_time,
- const base::Time& last_modified_time,
- const StatusCallback& callback) {
- FileSystemOperationContext* context_ptr = context.release();
- const bool success = base::PostTaskAndReplyWithResult(
- context_ptr->task_runner(), FROM_HERE,
- Bind(&FileSystemFileUtil::Touch, Unretained(sync_file_util_.get()),
- base::Owned(context_ptr), url,
- last_access_time, last_modified_time),
- callback);
- DCHECK(success);
-}
-
-void AsyncFileUtilAdapter::Truncate(
- scoped_ptr<FileSystemOperationContext> context,
- const FileSystemURL& url,
- int64 length,
- const StatusCallback& callback) {
- FileSystemOperationContext* context_ptr = context.release();
- const bool success = base::PostTaskAndReplyWithResult(
- context_ptr->task_runner(), FROM_HERE,
- Bind(&FileSystemFileUtil::Truncate, Unretained(sync_file_util_.get()),
- base::Owned(context_ptr), url, length),
- callback);
- DCHECK(success);
-}
-
-void AsyncFileUtilAdapter::CopyFileLocal(
- scoped_ptr<FileSystemOperationContext> context,
- const FileSystemURL& src_url,
- const FileSystemURL& dest_url,
- CopyOrMoveOption option,
- const CopyFileProgressCallback& progress_callback,
- const StatusCallback& callback) {
- // TODO(hidehiko): Support progress_callback.
- FileSystemOperationContext* context_ptr = context.release();
- const bool success = base::PostTaskAndReplyWithResult(
- context_ptr->task_runner(), FROM_HERE,
- Bind(&FileSystemFileUtil::CopyOrMoveFile,
- Unretained(sync_file_util_.get()), base::Owned(context_ptr),
- src_url, dest_url, option, true /* copy */),
- callback);
- DCHECK(success);
-}
-
-void AsyncFileUtilAdapter::MoveFileLocal(
- scoped_ptr<FileSystemOperationContext> context,
- const FileSystemURL& src_url,
- const FileSystemURL& dest_url,
- CopyOrMoveOption option,
- const StatusCallback& callback) {
- FileSystemOperationContext* context_ptr = context.release();
- const bool success = base::PostTaskAndReplyWithResult(
- context_ptr->task_runner(), FROM_HERE,
- Bind(&FileSystemFileUtil::CopyOrMoveFile,
- Unretained(sync_file_util_.get()), base::Owned(context_ptr),
- src_url, dest_url, option, false /* copy */),
- callback);
- DCHECK(success);
-}
-
-void AsyncFileUtilAdapter::CopyInForeignFile(
- scoped_ptr<FileSystemOperationContext> context,
- const base::FilePath& src_file_path,
- const FileSystemURL& dest_url,
- const StatusCallback& callback) {
- FileSystemOperationContext* context_ptr = context.release();
- const bool success = base::PostTaskAndReplyWithResult(
- context_ptr->task_runner(), FROM_HERE,
- Bind(&FileSystemFileUtil::CopyInForeignFile,
- Unretained(sync_file_util_.get()),
- base::Owned(context_ptr), src_file_path, dest_url),
- callback);
- DCHECK(success);
-}
-
-void AsyncFileUtilAdapter::DeleteFile(
- scoped_ptr<FileSystemOperationContext> context,
- const FileSystemURL& url,
- const StatusCallback& callback) {
- FileSystemOperationContext* context_ptr = context.release();
- const bool success = base::PostTaskAndReplyWithResult(
- context_ptr->task_runner(), FROM_HERE,
- Bind(&FileSystemFileUtil::DeleteFile,
- Unretained(sync_file_util_.get()),
- base::Owned(context_ptr), url),
- callback);
- DCHECK(success);
-}
-
-void AsyncFileUtilAdapter::DeleteDirectory(
- scoped_ptr<FileSystemOperationContext> context,
- const FileSystemURL& url,
- const StatusCallback& callback) {
- FileSystemOperationContext* context_ptr = context.release();
- const bool success = base::PostTaskAndReplyWithResult(
- context_ptr->task_runner(), FROM_HERE,
- Bind(&FileSystemFileUtil::DeleteDirectory,
- Unretained(sync_file_util_.get()),
- base::Owned(context_ptr), url),
- callback);
- DCHECK(success);
-}
-
-void AsyncFileUtilAdapter::DeleteRecursively(
- scoped_ptr<FileSystemOperationContext> context,
- const FileSystemURL& url,
- const StatusCallback& callback) {
- callback.Run(base::File::FILE_ERROR_INVALID_OPERATION);
-}
-
-void AsyncFileUtilAdapter::CreateSnapshotFile(
- scoped_ptr<FileSystemOperationContext> context,
- const FileSystemURL& url,
- const CreateSnapshotFileCallback& callback) {
- FileSystemOperationContext* context_ptr = context.release();
- GetFileInfoHelper* helper = new GetFileInfoHelper;
- const bool success = context_ptr->task_runner()->PostTaskAndReply(
- FROM_HERE,
- Bind(&GetFileInfoHelper::CreateSnapshotFile, Unretained(helper),
- sync_file_util_.get(), base::Owned(context_ptr), url),
- Bind(&GetFileInfoHelper::ReplySnapshotFile, Owned(helper), callback));
- DCHECK(success);
-}
-
-} // namespace storage

Powered by Google App Engine
This is Rietveld 408576698