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); |
-} |