| Index: content/common/file_system/file_system_dispatcher.cc
|
| diff --git a/content/common/file_system/file_system_dispatcher.cc b/content/common/file_system/file_system_dispatcher.cc
|
| deleted file mode 100644
|
| index 1257cba4e04ccd5fbb800333197742a8b2ed374e..0000000000000000000000000000000000000000
|
| --- a/content/common/file_system/file_system_dispatcher.cc
|
| +++ /dev/null
|
| @@ -1,314 +0,0 @@
|
| -// 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/file_system/file_system_dispatcher.h"
|
| -
|
| -#include "base/file_util.h"
|
| -#include "base/process.h"
|
| -#include "content/common/child_thread.h"
|
| -#include "content/common/file_system_messages.h"
|
| -
|
| -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);
|
| - 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_DidSucceed, OnDidSucceed)
|
| - IPC_MESSAGE_HANDLER(FileSystemMsg_DidReadDirectory, OnDidReadDirectory)
|
| - IPC_MESSAGE_HANDLER(FileSystemMsg_DidReadMetadata, OnDidReadMetadata)
|
| - 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;
|
| -}
|
| -
|
| -bool FileSystemDispatcher::OpenFileSystem(
|
| - const GURL& origin_url, fileapi::FileSystemType type,
|
| - long long size, bool create,
|
| - fileapi::FileSystemCallbackDispatcher* dispatcher) {
|
| - int request_id = dispatchers_.Add(dispatcher);
|
| - if (!ChildThread::current()->Send(new FileSystemHostMsg_Open(
|
| - request_id, origin_url, type, size, create))) {
|
| - dispatchers_.Remove(request_id); // destroys |dispatcher|
|
| - return false;
|
| - }
|
| -
|
| - return true;
|
| -}
|
| -
|
| -bool FileSystemDispatcher::Move(
|
| - const GURL& src_path,
|
| - const GURL& dest_path,
|
| - fileapi::FileSystemCallbackDispatcher* dispatcher) {
|
| - int request_id = dispatchers_.Add(dispatcher);
|
| - if (!ChildThread::current()->Send(new FileSystemHostMsg_Move(
|
| - request_id, src_path, dest_path))) {
|
| - dispatchers_.Remove(request_id); // destroys |dispatcher|
|
| - return false;
|
| - }
|
| -
|
| - return true;
|
| -}
|
| -
|
| -bool FileSystemDispatcher::Copy(
|
| - const GURL& src_path,
|
| - const GURL& dest_path,
|
| - fileapi::FileSystemCallbackDispatcher* dispatcher) {
|
| - int request_id = dispatchers_.Add(dispatcher);
|
| - if (!ChildThread::current()->Send(new FileSystemHostMsg_Copy(
|
| - request_id, src_path, dest_path))) {
|
| - dispatchers_.Remove(request_id); // destroys |dispatcher|
|
| - return false;
|
| - }
|
| -
|
| - return true;
|
| -}
|
| -
|
| -bool FileSystemDispatcher::Remove(
|
| - const GURL& path,
|
| - bool recursive,
|
| - fileapi::FileSystemCallbackDispatcher* dispatcher) {
|
| - int request_id = dispatchers_.Add(dispatcher);
|
| - if (!ChildThread::current()->Send(
|
| - new FileSystemMsg_Remove(request_id, path, recursive))) {
|
| - dispatchers_.Remove(request_id); // destroys |dispatcher|
|
| - return false;
|
| - }
|
| -
|
| - return true;
|
| -}
|
| -
|
| -bool FileSystemDispatcher::ReadMetadata(
|
| - const GURL& path,
|
| - fileapi::FileSystemCallbackDispatcher* dispatcher) {
|
| - int request_id = dispatchers_.Add(dispatcher);
|
| - if (!ChildThread::current()->Send(
|
| - new FileSystemHostMsg_ReadMetadata(request_id, path))) {
|
| - dispatchers_.Remove(request_id); // destroys |dispatcher|
|
| - return false;
|
| - }
|
| -
|
| - return true;
|
| -}
|
| -
|
| -bool FileSystemDispatcher::Create(
|
| - const GURL& path,
|
| - bool exclusive,
|
| - bool is_directory,
|
| - bool recursive,
|
| - fileapi::FileSystemCallbackDispatcher* dispatcher) {
|
| - int request_id = dispatchers_.Add(dispatcher);
|
| - if (!ChildThread::current()->Send(new FileSystemHostMsg_Create(
|
| - request_id, path, exclusive, is_directory, recursive))) {
|
| - dispatchers_.Remove(request_id); // destroys |dispatcher|
|
| - return false;
|
| - }
|
| -
|
| - return true;
|
| -}
|
| -
|
| -bool FileSystemDispatcher::Exists(
|
| - const GURL& path,
|
| - bool is_directory,
|
| - fileapi::FileSystemCallbackDispatcher* dispatcher) {
|
| - int request_id = dispatchers_.Add(dispatcher);
|
| - if (!ChildThread::current()->Send(
|
| - new FileSystemHostMsg_Exists(request_id, path, is_directory))) {
|
| - dispatchers_.Remove(request_id); // destroys |dispatcher|
|
| - return false;
|
| - }
|
| -
|
| - return true;
|
| -}
|
| -
|
| -bool FileSystemDispatcher::ReadDirectory(
|
| - const GURL& path,
|
| - fileapi::FileSystemCallbackDispatcher* dispatcher) {
|
| - int request_id = dispatchers_.Add(dispatcher);
|
| - if (!ChildThread::current()->Send(
|
| - new FileSystemHostMsg_ReadDirectory(request_id, path))) {
|
| - dispatchers_.Remove(request_id); // destroys |dispatcher|
|
| - return false;
|
| - }
|
| -
|
| - return true;
|
| -}
|
| -
|
| -bool FileSystemDispatcher::Truncate(
|
| - const GURL& path,
|
| - int64 offset,
|
| - int* request_id_out,
|
| - fileapi::FileSystemCallbackDispatcher* dispatcher) {
|
| - int request_id = dispatchers_.Add(dispatcher);
|
| - if (!ChildThread::current()->Send(
|
| - new FileSystemHostMsg_Truncate(request_id, path, offset))) {
|
| - dispatchers_.Remove(request_id); // destroys |dispatcher|
|
| - return false;
|
| - }
|
| -
|
| - if (request_id_out)
|
| - *request_id_out = request_id;
|
| - return true;
|
| -}
|
| -
|
| -bool FileSystemDispatcher::Write(
|
| - const GURL& path,
|
| - const GURL& blob_url,
|
| - int64 offset,
|
| - int* request_id_out,
|
| - fileapi::FileSystemCallbackDispatcher* dispatcher) {
|
| - int request_id = dispatchers_.Add(dispatcher);
|
| - if (!ChildThread::current()->Send(
|
| - new FileSystemHostMsg_Write(request_id, path, blob_url, offset))) {
|
| - dispatchers_.Remove(request_id); // destroys |dispatcher|
|
| - return false;
|
| - }
|
| -
|
| - if (request_id_out)
|
| - *request_id_out = request_id;
|
| - return true;
|
| -}
|
| -
|
| -bool FileSystemDispatcher::Cancel(
|
| - int request_id_to_cancel,
|
| - fileapi::FileSystemCallbackDispatcher* dispatcher) {
|
| - int request_id = dispatchers_.Add(dispatcher);
|
| - if (!ChildThread::current()->Send(new FileSystemHostMsg_CancelWrite(
|
| - request_id, request_id_to_cancel))) {
|
| - dispatchers_.Remove(request_id); // destroys |dispatcher|
|
| - return false;
|
| - }
|
| -
|
| - return true;
|
| -}
|
| -
|
| -bool FileSystemDispatcher::TouchFile(
|
| - const GURL& path,
|
| - const base::Time& last_access_time,
|
| - const base::Time& last_modified_time,
|
| - fileapi::FileSystemCallbackDispatcher* dispatcher) {
|
| - int request_id = dispatchers_.Add(dispatcher);
|
| - if (!ChildThread::current()->Send(
|
| - new FileSystemHostMsg_TouchFile(
|
| - request_id, path, last_access_time, last_modified_time))) {
|
| - dispatchers_.Remove(request_id); // destroys |dispatcher|
|
| - return false;
|
| - }
|
| -
|
| - return true;
|
| -}
|
| -
|
| -bool FileSystemDispatcher::OpenFile(
|
| - const GURL& file_path,
|
| - int file_flags,
|
| - fileapi::FileSystemCallbackDispatcher* dispatcher) {
|
| - int request_id = dispatchers_.Add(dispatcher);
|
| - 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::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;
|
| - }
|
| - return true;
|
| -}
|
| -
|
| -void FileSystemDispatcher::OnDidOpenFileSystem(int request_id,
|
| - const std::string& name,
|
| - const GURL& root) {
|
| - DCHECK(root.is_valid());
|
| - fileapi::FileSystemCallbackDispatcher* dispatcher =
|
| - dispatchers_.Lookup(request_id);
|
| - DCHECK(dispatcher);
|
| - dispatcher->DidOpenFileSystem(name, root);
|
| - dispatchers_.Remove(request_id);
|
| -}
|
| -
|
| -void FileSystemDispatcher::OnDidSucceed(int request_id) {
|
| - fileapi::FileSystemCallbackDispatcher* dispatcher =
|
| - dispatchers_.Lookup(request_id);
|
| - DCHECK(dispatcher);
|
| - dispatcher->DidSucceed();
|
| - dispatchers_.Remove(request_id);
|
| -}
|
| -
|
| -void FileSystemDispatcher::OnDidReadMetadata(
|
| - int request_id, const base::PlatformFileInfo& file_info,
|
| - const FilePath& platform_path) {
|
| - fileapi::FileSystemCallbackDispatcher* dispatcher =
|
| - dispatchers_.Lookup(request_id);
|
| - DCHECK(dispatcher);
|
| - dispatcher->DidReadMetadata(file_info, platform_path);
|
| - dispatchers_.Remove(request_id);
|
| -}
|
| -
|
| -void FileSystemDispatcher::OnDidReadDirectory(
|
| - int request_id,
|
| - const std::vector<base::FileUtilProxy::Entry>& entries,
|
| - bool has_more) {
|
| - fileapi::FileSystemCallbackDispatcher* dispatcher =
|
| - dispatchers_.Lookup(request_id);
|
| - DCHECK(dispatcher);
|
| - dispatcher->DidReadDirectory(entries, has_more);
|
| - dispatchers_.Remove(request_id);
|
| -}
|
| -
|
| -void FileSystemDispatcher::OnDidFail(
|
| - int request_id, base::PlatformFileError error_code) {
|
| - fileapi::FileSystemCallbackDispatcher* dispatcher =
|
| - dispatchers_.Lookup(request_id);
|
| - DCHECK(dispatcher);
|
| - dispatcher->DidFail(error_code);
|
| - dispatchers_.Remove(request_id);
|
| -}
|
| -
|
| -void FileSystemDispatcher::OnDidWrite(
|
| - int request_id, int64 bytes, bool complete) {
|
| - fileapi::FileSystemCallbackDispatcher* dispatcher =
|
| - dispatchers_.Lookup(request_id);
|
| - DCHECK(dispatcher);
|
| - dispatcher->DidWrite(bytes, complete);
|
| - if (complete)
|
| - dispatchers_.Remove(request_id);
|
| -}
|
| -
|
| -void FileSystemDispatcher::OnDidOpenFile(
|
| - int request_id, IPC::PlatformFileForTransit file) {
|
| - fileapi::FileSystemCallbackDispatcher* dispatcher =
|
| - dispatchers_.Lookup(request_id);
|
| - DCHECK(dispatcher);
|
| - dispatcher->DidOpenFile(IPC::PlatformFileForTransitToPlatformFile(file),
|
| - base::kNullProcessHandle);
|
| - dispatchers_.Remove(request_id);
|
| -}
|
|
|