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

Unified Diff: content/browser/fileapi/fileapi_message_filter.cc

Issue 9558006: Rename content/{common,browser}/file_system to fileapi and move blob stuff into it. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: rebase Created 8 years, 10 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: content/browser/fileapi/fileapi_message_filter.cc
diff --git a/content/browser/file_system/file_and_blob_message_filter.cc b/content/browser/fileapi/fileapi_message_filter.cc
similarity index 81%
rename from content/browser/file_system/file_and_blob_message_filter.cc
rename to content/browser/fileapi/fileapi_message_filter.cc
index 1486095356c4a04fd0f532b16042ed2ca90f2fec..ee88d38c342c31803d5e01768e59a9233bfbd5ea 100644
--- a/content/browser/file_system/file_and_blob_message_filter.cc
+++ b/content/browser/fileapi/fileapi_message_filter.cc
@@ -2,7 +2,7 @@
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
-#include "content/browser/file_system/file_and_blob_message_filter.h"
+#include "content/browser/fileapi/fileapi_message_filter.h"
#include <string>
#include <vector>
@@ -14,9 +14,9 @@
#include "base/threading/thread.h"
#include "base/time.h"
#include "content/browser/child_process_security_policy_impl.h"
-#include "content/browser/chrome_blob_storage_context.h"
-#include "content/common/file_system_messages.h"
-#include "content/common/webblob_messages.h"
+#include "content/browser/fileapi/chrome_blob_storage_context.h"
+#include "content/common/fileapi/file_system_messages.h"
+#include "content/common/fileapi/webblob_messages.h"
#include "content/public/browser/user_metrics.h"
#include "googleurl/src/gurl.h"
#include "ipc/ipc_platform_file.h"
@@ -68,7 +68,7 @@ const int kOpenFilePermissions = base::PLATFORM_FILE_CREATE |
} // namespace
-FileAndBlobMessageFilter::FileAndBlobMessageFilter(
+FileAPIMessageFilter::FileAPIMessageFilter(
int process_id,
net::URLRequestContextGetter* request_context_getter,
fileapi::FileSystemContext* file_system_context,
@@ -83,7 +83,7 @@ FileAndBlobMessageFilter::FileAndBlobMessageFilter(
DCHECK(blob_storage_context);
}
-FileAndBlobMessageFilter::FileAndBlobMessageFilter(
+FileAPIMessageFilter::FileAPIMessageFilter(
int process_id,
net::URLRequestContext* request_context,
fileapi::FileSystemContext* file_system_context,
@@ -97,10 +97,10 @@ FileAndBlobMessageFilter::FileAndBlobMessageFilter(
DCHECK(blob_storage_context);
}
-FileAndBlobMessageFilter::~FileAndBlobMessageFilter() {
+FileAPIMessageFilter::~FileAPIMessageFilter() {
}
-void FileAndBlobMessageFilter::OnChannelConnected(int32 peer_pid) {
+void FileAPIMessageFilter::OnChannelConnected(int32 peer_pid) {
BrowserMessageFilter::OnChannelConnected(peer_pid);
if (request_context_getter_.get()) {
@@ -111,7 +111,7 @@ void FileAndBlobMessageFilter::OnChannelConnected(int32 peer_pid) {
}
}
-void FileAndBlobMessageFilter::OnChannelClosing() {
+void FileAPIMessageFilter::OnChannelClosing() {
BrowserMessageFilter::OnChannelClosing();
// Unregister all the blob URLs that are previously registered in this
@@ -122,18 +122,18 @@ void FileAndBlobMessageFilter::OnChannelClosing() {
}
}
-void FileAndBlobMessageFilter::OverrideThreadForMessage(
+void FileAPIMessageFilter::OverrideThreadForMessage(
const IPC::Message& message,
BrowserThread::ID* thread) {
if (message.type() == FileSystemHostMsg_SyncGetPlatformPath::ID)
*thread = BrowserThread::FILE;
}
-bool FileAndBlobMessageFilter::OnMessageReceived(
+bool FileAPIMessageFilter::OnMessageReceived(
const IPC::Message& message, bool* message_was_ok) {
*message_was_ok = true;
bool handled = true;
- IPC_BEGIN_MESSAGE_MAP_EX(FileAndBlobMessageFilter, message, *message_was_ok)
+ IPC_BEGIN_MESSAGE_MAP_EX(FileAPIMessageFilter, message, *message_was_ok)
IPC_MESSAGE_HANDLER(FileSystemHostMsg_Open, OnOpen)
IPC_MESSAGE_HANDLER(FileSystemHostMsg_Move, OnMove)
IPC_MESSAGE_HANDLER(FileSystemHostMsg_Copy, OnCopy)
@@ -165,7 +165,7 @@ bool FileAndBlobMessageFilter::OnMessageReceived(
return handled;
}
-void FileAndBlobMessageFilter::OnOpen(
+void FileAPIMessageFilter::OnOpen(
int request_id, const GURL& origin_url, fileapi::FileSystemType type,
int64 requested_size, bool create) {
if (type == fileapi::kFileSystemTypeTemporary) {
@@ -174,10 +174,10 @@ void FileAndBlobMessageFilter::OnOpen(
content::RecordAction(UserMetricsAction("OpenFileSystemPersistent"));
}
context_->OpenFileSystem(origin_url, type, create, base::Bind(
- &FileAndBlobMessageFilter::DidOpenFileSystem, this, request_id));
+ &FileAPIMessageFilter::DidOpenFileSystem, this, request_id));
}
-void FileAndBlobMessageFilter::OnMove(
+void FileAPIMessageFilter::OnMove(
int request_id, const GURL& src_path, const GURL& dest_path) {
base::PlatformFileError error;
const int src_permissions = kReadFilePermissions | kWriteFilePermissions;
@@ -189,10 +189,10 @@ void FileAndBlobMessageFilter::OnMove(
GetNewOperation(src_path, request_id)->Move(
src_path, dest_path,
- base::Bind(&FileAndBlobMessageFilter::DidFinish, this, request_id));
+ base::Bind(&FileAPIMessageFilter::DidFinish, this, request_id));
}
-void FileAndBlobMessageFilter::OnCopy(
+void FileAPIMessageFilter::OnCopy(
int request_id, const GURL& src_path, const GURL& dest_path) {
base::PlatformFileError error;
if (!HasPermissionsForFile(src_path, kReadFilePermissions, &error) ||
@@ -203,10 +203,10 @@ void FileAndBlobMessageFilter::OnCopy(
GetNewOperation(src_path, request_id)->Copy(
src_path, dest_path,
- base::Bind(&FileAndBlobMessageFilter::DidFinish, this, request_id));
+ base::Bind(&FileAPIMessageFilter::DidFinish, this, request_id));
}
-void FileAndBlobMessageFilter::OnRemove(
+void FileAPIMessageFilter::OnRemove(
int request_id, const GURL& path, bool recursive) {
base::PlatformFileError error;
if (!HasPermissionsForFile(path, kWriteFilePermissions, &error)) {
@@ -216,10 +216,10 @@ void FileAndBlobMessageFilter::OnRemove(
GetNewOperation(path, request_id)->Remove(
path, recursive,
- base::Bind(&FileAndBlobMessageFilter::DidFinish, this, request_id));
+ base::Bind(&FileAPIMessageFilter::DidFinish, this, request_id));
}
-void FileAndBlobMessageFilter::OnReadMetadata(
+void FileAPIMessageFilter::OnReadMetadata(
int request_id, const GURL& path) {
base::PlatformFileError error;
if (!HasPermissionsForFile(path, kReadFilePermissions, &error)) {
@@ -229,10 +229,10 @@ void FileAndBlobMessageFilter::OnReadMetadata(
GetNewOperation(path, request_id)->GetMetadata(
path,
- base::Bind(&FileAndBlobMessageFilter::DidGetMetadata, this, request_id));
+ base::Bind(&FileAPIMessageFilter::DidGetMetadata, this, request_id));
}
-void FileAndBlobMessageFilter::OnCreate(
+void FileAPIMessageFilter::OnCreate(
int request_id, const GURL& path, bool exclusive,
bool is_directory, bool recursive) {
base::PlatformFileError error;
@@ -244,15 +244,15 @@ void FileAndBlobMessageFilter::OnCreate(
if (is_directory) {
GetNewOperation(path, request_id)->CreateDirectory(
path, exclusive, recursive,
- base::Bind(&FileAndBlobMessageFilter::DidFinish, this, request_id));
+ base::Bind(&FileAPIMessageFilter::DidFinish, this, request_id));
} else {
GetNewOperation(path, request_id)->CreateFile(
path, exclusive,
- base::Bind(&FileAndBlobMessageFilter::DidFinish, this, request_id));
+ base::Bind(&FileAPIMessageFilter::DidFinish, this, request_id));
}
}
-void FileAndBlobMessageFilter::OnExists(
+void FileAPIMessageFilter::OnExists(
int request_id, const GURL& path, bool is_directory) {
base::PlatformFileError error;
if (!HasPermissionsForFile(path, kReadFilePermissions, &error)) {
@@ -263,15 +263,15 @@ void FileAndBlobMessageFilter::OnExists(
if (is_directory) {
GetNewOperation(path, request_id)->DirectoryExists(
path,
- base::Bind(&FileAndBlobMessageFilter::DidFinish, this, request_id));
+ base::Bind(&FileAPIMessageFilter::DidFinish, this, request_id));
} else {
GetNewOperation(path, request_id)->FileExists(
path,
- base::Bind(&FileAndBlobMessageFilter::DidFinish, this, request_id));
+ base::Bind(&FileAPIMessageFilter::DidFinish, this, request_id));
}
}
-void FileAndBlobMessageFilter::OnReadDirectory(
+void FileAPIMessageFilter::OnReadDirectory(
int request_id, const GURL& path) {
base::PlatformFileError error;
if (!HasPermissionsForFile(path, kReadFilePermissions, &error)) {
@@ -280,11 +280,11 @@ void FileAndBlobMessageFilter::OnReadDirectory(
}
GetNewOperation(path, request_id)->ReadDirectory(
- path, base::Bind(&FileAndBlobMessageFilter::DidReadDirectory,
+ path, base::Bind(&FileAPIMessageFilter::DidReadDirectory,
this, request_id));
}
-void FileAndBlobMessageFilter::OnWrite(
+void FileAPIMessageFilter::OnWrite(
int request_id,
const GURL& path,
const GURL& blob_url,
@@ -303,10 +303,10 @@ void FileAndBlobMessageFilter::OnWrite(
GetNewOperation(path, request_id)->Write(
request_context_, path, blob_url, offset,
- base::Bind(&FileAndBlobMessageFilter::DidWrite, this, request_id));
+ base::Bind(&FileAPIMessageFilter::DidWrite, this, request_id));
}
-void FileAndBlobMessageFilter::OnTruncate(
+void FileAPIMessageFilter::OnTruncate(
int request_id,
const GURL& path,
int64 length) {
@@ -318,10 +318,10 @@ void FileAndBlobMessageFilter::OnTruncate(
GetNewOperation(path, request_id)->Truncate(
path, length,
- base::Bind(&FileAndBlobMessageFilter::DidFinish, this, request_id));
+ base::Bind(&FileAPIMessageFilter::DidFinish, this, request_id));
}
-void FileAndBlobMessageFilter::OnTouchFile(
+void FileAPIMessageFilter::OnTouchFile(
int request_id,
const GURL& path,
const base::Time& last_access_time,
@@ -334,10 +334,10 @@ void FileAndBlobMessageFilter::OnTouchFile(
GetNewOperation(path, request_id)->TouchFile(
path, last_access_time, last_modified_time,
- base::Bind(&FileAndBlobMessageFilter::DidFinish, this, request_id));
+ base::Bind(&FileAPIMessageFilter::DidFinish, this, request_id));
}
-void FileAndBlobMessageFilter::OnCancel(
+void FileAPIMessageFilter::OnCancel(
int request_id,
int request_id_to_cancel) {
FileSystemOperationInterface* write = operations_.Lookup(
@@ -346,7 +346,7 @@ void FileAndBlobMessageFilter::OnCancel(
// The cancel will eventually send both the write failure and the cancel
// success.
write->Cancel(
- base::Bind(&FileAndBlobMessageFilter::DidCancel, this, request_id));
+ base::Bind(&FileAPIMessageFilter::DidCancel, this, request_id));
} else {
// The write already finished; report that we failed to stop it.
Send(new FileSystemMsg_DidFail(
@@ -354,7 +354,7 @@ void FileAndBlobMessageFilter::OnCancel(
}
}
-void FileAndBlobMessageFilter::OnOpenFile(
+void FileAPIMessageFilter::OnOpenFile(
int request_id, const GURL& path, int file_flags) {
base::PlatformFileError error;
const int open_permissions = base::PLATFORM_FILE_OPEN |
@@ -366,10 +366,10 @@ void FileAndBlobMessageFilter::OnOpenFile(
GetNewOperation(path, request_id)->OpenFile(
path, file_flags, peer_handle(),
- base::Bind(&FileAndBlobMessageFilter::DidOpenFile, this, request_id));
+ base::Bind(&FileAPIMessageFilter::DidOpenFile, this, request_id));
}
-void FileAndBlobMessageFilter::OnWillUpdate(const GURL& path) {
+void FileAPIMessageFilter::OnWillUpdate(const GURL& path) {
GURL origin_url;
fileapi::FileSystemType type;
if (!CrackFileSystemURL(path, &origin_url, &type, NULL))
@@ -380,7 +380,7 @@ void FileAndBlobMessageFilter::OnWillUpdate(const GURL& path) {
quota_util->proxy()->StartUpdateOrigin(origin_url, type);
}
-void FileAndBlobMessageFilter::OnDidUpdate(const GURL& path, int64 delta) {
+void FileAPIMessageFilter::OnDidUpdate(const GURL& path, int64 delta) {
GURL origin_url;
fileapi::FileSystemType type;
if (!CrackFileSystemURL(path, &origin_url, &type, NULL))
@@ -393,7 +393,7 @@ void FileAndBlobMessageFilter::OnDidUpdate(const GURL& path, int64 delta) {
quota_util->proxy()->EndUpdateOrigin(origin_url, type);
}
-void FileAndBlobMessageFilter::OnSyncGetPlatformPath(
+void FileAPIMessageFilter::OnSyncGetPlatformPath(
const GURL& path, FilePath* platform_path) {
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE));
DCHECK(platform_path);
@@ -421,22 +421,22 @@ void FileAndBlobMessageFilter::OnSyncGetPlatformPath(
operation->SyncGetPlatformPath(path, platform_path);
}
-void FileAndBlobMessageFilter::OnCreateSnapshotFile(
+void FileAPIMessageFilter::OnCreateSnapshotFile(
int request_id, const GURL& blob_url, const GURL& path) {
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
GetNewOperation(path, request_id)->CreateSnapshotFile(
path,
- base::Bind(&FileAndBlobMessageFilter::DidCreateSnapshot,
+ base::Bind(&FileAPIMessageFilter::DidCreateSnapshot,
this, request_id, blob_url));
}
-void FileAndBlobMessageFilter::OnStartBuildingBlob(const GURL& url) {
+void FileAPIMessageFilter::OnStartBuildingBlob(const GURL& url) {
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
blob_storage_context_->controller()->StartBuildingBlob(url);
blob_urls_.insert(url.spec());
}
-void FileAndBlobMessageFilter::OnAppendBlobDataItem(
+void FileAPIMessageFilter::OnAppendBlobDataItem(
const GURL& url, const BlobData::Item& item) {
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
if (item.type == BlobData::TYPE_FILE &&
@@ -448,7 +448,7 @@ void FileAndBlobMessageFilter::OnAppendBlobDataItem(
blob_storage_context_->controller()->AppendBlobDataItem(url, item);
}
-void FileAndBlobMessageFilter::OnAppendSharedMemory(
+void FileAPIMessageFilter::OnAppendSharedMemory(
const GURL& url, base::SharedMemoryHandle handle, size_t buffer_size) {
DCHECK(base::SharedMemory::IsHandleValid(handle));
#if defined(OS_WIN)
@@ -467,27 +467,27 @@ void FileAndBlobMessageFilter::OnAppendSharedMemory(
blob_storage_context_->controller()->AppendBlobDataItem(url, item);
}
-void FileAndBlobMessageFilter::OnFinishBuildingBlob(
+void FileAPIMessageFilter::OnFinishBuildingBlob(
const GURL& url, const std::string& content_type) {
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
blob_storage_context_->controller()->FinishBuildingBlob(url, content_type);
}
-void FileAndBlobMessageFilter::OnCloneBlob(
+void FileAPIMessageFilter::OnCloneBlob(
const GURL& url, const GURL& src_url) {
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
blob_storage_context_->controller()->CloneBlob(url, src_url);
blob_urls_.insert(url.spec());
}
-void FileAndBlobMessageFilter::OnRemoveBlob(const GURL& url) {
+void FileAPIMessageFilter::OnRemoveBlob(const GURL& url) {
DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
blob_storage_context_->controller()->RemoveBlob(url);
blob_urls_.erase(url.spec());
}
-void FileAndBlobMessageFilter::DidFinish(int request_id,
- base::PlatformFileError result) {
+void FileAPIMessageFilter::DidFinish(int request_id,
+ base::PlatformFileError result) {
if (result == base::PLATFORM_FILE_OK)
Send(new FileSystemMsg_DidSucceed(request_id));
else
@@ -495,8 +495,8 @@ void FileAndBlobMessageFilter::DidFinish(int request_id,
UnregisterOperation(request_id);
}
-void FileAndBlobMessageFilter::DidCancel(int request_id,
- base::PlatformFileError result) {
+void FileAPIMessageFilter::DidCancel(int request_id,
+ base::PlatformFileError result) {
if (result == base::PLATFORM_FILE_OK)
Send(new FileSystemMsg_DidSucceed(request_id));
else
@@ -504,7 +504,7 @@ void FileAndBlobMessageFilter::DidCancel(int request_id,
// For Cancel we do not create a new operation, so no unregister here.
}
-void FileAndBlobMessageFilter::DidGetMetadata(
+void FileAPIMessageFilter::DidGetMetadata(
int request_id,
base::PlatformFileError result,
const base::PlatformFileInfo& info,
@@ -516,7 +516,7 @@ void FileAndBlobMessageFilter::DidGetMetadata(
UnregisterOperation(request_id);
}
-void FileAndBlobMessageFilter::DidReadDirectory(
+void FileAPIMessageFilter::DidReadDirectory(
int request_id,
base::PlatformFileError result,
const std::vector<base::FileUtilProxy::Entry>& entries,
@@ -528,10 +528,10 @@ void FileAndBlobMessageFilter::DidReadDirectory(
UnregisterOperation(request_id);
}
-void FileAndBlobMessageFilter::DidOpenFile(int request_id,
- base::PlatformFileError result,
- base::PlatformFile file,
- base::ProcessHandle peer_handle) {
+void FileAPIMessageFilter::DidOpenFile(int request_id,
+ base::PlatformFileError result,
+ base::PlatformFile file,
+ base::ProcessHandle peer_handle) {
if (result == base::PLATFORM_FILE_OK) {
IPC::PlatformFileForTransit file_for_transit =
file != base::kInvalidPlatformFileValue ?
@@ -544,10 +544,10 @@ void FileAndBlobMessageFilter::DidOpenFile(int request_id,
UnregisterOperation(request_id);
}
-void FileAndBlobMessageFilter::DidWrite(int request_id,
- base::PlatformFileError result,
- int64 bytes,
- bool complete) {
+void FileAPIMessageFilter::DidWrite(int request_id,
+ base::PlatformFileError result,
+ int64 bytes,
+ bool complete) {
if (result == base::PLATFORM_FILE_OK) {
Send(new FileSystemMsg_DidWrite(request_id, bytes, complete));
if (complete)
@@ -558,10 +558,10 @@ void FileAndBlobMessageFilter::DidWrite(int request_id,
}
}
-void FileAndBlobMessageFilter::DidOpenFileSystem(int request_id,
- base::PlatformFileError result,
- const std::string& name,
- const GURL& root) {
+void FileAPIMessageFilter::DidOpenFileSystem(int request_id,
+ base::PlatformFileError result,
+ const std::string& name,
+ const GURL& root) {
if (result == base::PLATFORM_FILE_OK) {
DCHECK(root.is_valid());
Send(new FileSystemMsg_DidOpenFileSystem(request_id, name, root));
@@ -571,7 +571,7 @@ void FileAndBlobMessageFilter::DidOpenFileSystem(int request_id,
// For OpenFileSystem we do not create a new operation, so no unregister here.
}
-void FileAndBlobMessageFilter::DidCreateSnapshot(
+void FileAPIMessageFilter::DidCreateSnapshot(
int request_id,
const GURL& blob_url,
base::PlatformFileError result,
@@ -606,7 +606,7 @@ void FileAndBlobMessageFilter::DidCreateSnapshot(
Send(new FileSystemMsg_DidReadMetadata(request_id, info, platform_path));
}
-bool FileAndBlobMessageFilter::HasPermissionsForFile(
+bool FileAPIMessageFilter::HasPermissionsForFile(
const GURL& path, int permissions, base::PlatformFileError* error) {
DCHECK(error);
*error = base::PLATFORM_FILE_OK;
@@ -644,7 +644,7 @@ bool FileAndBlobMessageFilter::HasPermissionsForFile(
}
-FileSystemOperationInterface* FileAndBlobMessageFilter::GetNewOperation(
+FileSystemOperationInterface* FileAPIMessageFilter::GetNewOperation(
const GURL& target_path,
int request_id) {
FileSystemOperationInterface* operation =
@@ -656,7 +656,7 @@ FileSystemOperationInterface* FileAndBlobMessageFilter::GetNewOperation(
return operation;
}
-void FileAndBlobMessageFilter::UnregisterOperation(int request_id) {
+void FileAPIMessageFilter::UnregisterOperation(int request_id) {
DCHECK(operations_.Lookup(request_id));
operations_.Remove(request_id);
}

Powered by Google App Engine
This is Rietveld 408576698