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

Unified Diff: webkit/fileapi/obfuscated_file_util.cc

Issue 15442002: Move FileAPI sandboxed filesystem related code from webkit/fileapi to webkit/browser/fileapi (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: rebased Created 7 years, 7 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
« no previous file with comments | « webkit/fileapi/obfuscated_file_util.h ('k') | webkit/fileapi/obfuscated_file_util_unittest.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: webkit/fileapi/obfuscated_file_util.cc
diff --git a/webkit/fileapi/obfuscated_file_util.cc b/webkit/fileapi/obfuscated_file_util.cc
deleted file mode 100644
index 581c2a1b7f9919aa567f3f7be9d6d0d808b44fb6..0000000000000000000000000000000000000000
--- a/webkit/fileapi/obfuscated_file_util.cc
+++ /dev/null
@@ -1,1365 +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 "webkit/fileapi/obfuscated_file_util.h"
-
-#include <queue>
-#include <string>
-#include <vector>
-
-#include "base/file_util.h"
-#include "base/format_macros.h"
-#include "base/logging.h"
-#include "base/message_loop.h"
-#include "base/stl_util.h"
-#include "base/stringprintf.h"
-#include "base/strings/string_number_conversions.h"
-#include "base/strings/sys_string_conversions.h"
-#include "base/utf_string_conversions.h"
-#include "googleurl/src/gurl.h"
-#include "webkit/base/origin_url_conversions.h"
-#include "webkit/fileapi/file_observers.h"
-#include "webkit/fileapi/file_system_context.h"
-#include "webkit/fileapi/file_system_operation_context.h"
-#include "webkit/fileapi/file_system_url.h"
-#include "webkit/fileapi/file_system_util.h"
-#include "webkit/fileapi/native_file_util.h"
-#include "webkit/fileapi/sandbox_mount_point_provider.h"
-#include "webkit/fileapi/syncable/syncable_file_system_util.h"
-#include "webkit/quota/quota_manager.h"
-
-// Example of various paths:
-// void ObfuscatedFileUtil::DoSomething(const FileSystemURL& url) {
-// base::FilePath virtual_path = url.path();
-// base::FilePath local_path = GetLocalFilePath(url);
-//
-// NativeFileUtil::DoSomething(local_path);
-// file_util::DoAnother(local_path);
-// }
-
-namespace fileapi {
-
-namespace {
-
-typedef SandboxDirectoryDatabase::FileId FileId;
-typedef SandboxDirectoryDatabase::FileInfo FileInfo;
-
-const int64 kFlushDelaySeconds = 10 * 60; // 10 minutes
-
-void InitFileInfo(
- SandboxDirectoryDatabase::FileInfo* file_info,
- SandboxDirectoryDatabase::FileId parent_id,
- const base::FilePath::StringType& file_name) {
- DCHECK(file_info);
- file_info->parent_id = parent_id;
- file_info->name = file_name;
-}
-
-// Costs computed as per crbug.com/86114, based on the LevelDB implementation of
-// path storage under Linux. It's not clear if that will differ on Windows, on
-// which base::FilePath uses wide chars [since they're converted to UTF-8 for storage
-// anyway], but as long as the cost is high enough that one can't cheat on quota
-// by storing data in paths, it doesn't need to be all that accurate.
-const int64 kPathCreationQuotaCost = 146; // Bytes per inode, basically.
-const int64 kPathByteQuotaCost = 2; // Bytes per byte of path length in UTF-8.
-
-int64 UsageForPath(size_t length) {
- return kPathCreationQuotaCost +
- static_cast<int64>(length) * kPathByteQuotaCost;
-}
-
-bool AllocateQuota(FileSystemOperationContext* context, int64 growth) {
- if (context->allowed_bytes_growth() == quota::QuotaManager::kNoLimit)
- return true;
-
- int64 new_quota = context->allowed_bytes_growth() - growth;
- if (growth > 0 && new_quota < 0)
- return false;
- context->set_allowed_bytes_growth(new_quota);
- return true;
-}
-
-void UpdateUsage(
- FileSystemOperationContext* context,
- const FileSystemURL& url,
- int64 growth) {
- context->update_observers()->Notify(
- &FileUpdateObserver::OnUpdate, MakeTuple(url, growth));
-}
-
-void TouchDirectory(SandboxDirectoryDatabase* db, FileId dir_id) {
- DCHECK(db);
- if (!db->UpdateModificationTime(dir_id, base::Time::Now()))
- NOTREACHED();
-}
-
-const base::FilePath::CharType kTemporaryDirectoryName[] = FILE_PATH_LITERAL("t");
-const base::FilePath::CharType kPersistentDirectoryName[] = FILE_PATH_LITERAL("p");
-const base::FilePath::CharType kSyncableDirectoryName[] = FILE_PATH_LITERAL("s");
-
-} // namespace
-
-using base::PlatformFile;
-using base::PlatformFileError;
-
-class ObfuscatedFileEnumerator
- : public FileSystemFileUtil::AbstractFileEnumerator {
- public:
- ObfuscatedFileEnumerator(
- SandboxDirectoryDatabase* db,
- FileSystemOperationContext* context,
- ObfuscatedFileUtil* obfuscated_file_util,
- const FileSystemURL& root_url,
- bool recursive)
- : db_(db),
- context_(context),
- obfuscated_file_util_(obfuscated_file_util),
- origin_(root_url.origin()),
- type_(root_url.type()),
- recursive_(recursive),
- current_file_id_(0) {
- base::FilePath root_virtual_path = root_url.path();
- FileId file_id;
-
- if (!db_->GetFileWithPath(root_virtual_path, &file_id))
- return;
-
- FileRecord record = { file_id, root_virtual_path };
- recurse_queue_.push(record);
- }
-
- virtual ~ObfuscatedFileEnumerator() {}
-
- virtual base::FilePath Next() OVERRIDE {
- ProcessRecurseQueue();
- if (display_stack_.empty())
- return base::FilePath();
-
- current_file_id_ = display_stack_.back();
- display_stack_.pop_back();
-
- FileInfo file_info;
- base::FilePath platform_file_path;
- base::PlatformFileError error =
- obfuscated_file_util_->GetFileInfoInternal(
- db_, context_, origin_, type_, current_file_id_,
- &file_info, &current_platform_file_info_, &platform_file_path);
- if (error != base::PLATFORM_FILE_OK)
- return Next();
-
- base::FilePath virtual_path =
- current_parent_virtual_path_.Append(file_info.name);
- if (recursive_ && file_info.is_directory()) {
- FileRecord record = { current_file_id_, virtual_path };
- recurse_queue_.push(record);
- }
- return virtual_path;
- }
-
- virtual int64 Size() OVERRIDE {
- return current_platform_file_info_.size;
- }
-
- virtual base::Time LastModifiedTime() OVERRIDE {
- return current_platform_file_info_.last_modified;
- }
-
- virtual bool IsDirectory() OVERRIDE {
- return current_platform_file_info_.is_directory;
- }
-
- private:
- typedef SandboxDirectoryDatabase::FileId FileId;
- typedef SandboxDirectoryDatabase::FileInfo FileInfo;
-
- struct FileRecord {
- FileId file_id;
- base::FilePath virtual_path;
- };
-
- void ProcessRecurseQueue() {
- while (display_stack_.empty() && !recurse_queue_.empty()) {
- FileRecord entry = recurse_queue_.front();
- recurse_queue_.pop();
- if (!db_->ListChildren(entry.file_id, &display_stack_)) {
- display_stack_.clear();
- return;
- }
- current_parent_virtual_path_ = entry.virtual_path;
- }
- }
-
- SandboxDirectoryDatabase* db_;
- FileSystemOperationContext* context_;
- ObfuscatedFileUtil* obfuscated_file_util_;
- GURL origin_;
- FileSystemType type_;
- bool recursive_;
-
- std::queue<FileRecord> recurse_queue_;
- std::vector<FileId> display_stack_;
- base::FilePath current_parent_virtual_path_;
-
- FileId current_file_id_;
- base::PlatformFileInfo current_platform_file_info_;
-};
-
-class ObfuscatedOriginEnumerator
- : public ObfuscatedFileUtil::AbstractOriginEnumerator {
- public:
- typedef SandboxOriginDatabase::OriginRecord OriginRecord;
- ObfuscatedOriginEnumerator(
- SandboxOriginDatabase* origin_database,
- const base::FilePath& base_file_path)
- : base_file_path_(base_file_path) {
- if (origin_database)
- origin_database->ListAllOrigins(&origins_);
- }
-
- virtual ~ObfuscatedOriginEnumerator() {}
-
- // Returns the next origin. Returns empty if there are no more origins.
- virtual GURL Next() OVERRIDE {
- OriginRecord record;
- if (!origins_.empty()) {
- record = origins_.back();
- origins_.pop_back();
- }
- current_ = record;
- return webkit_base::GetOriginURLFromIdentifier(UTF8ToUTF16(record.origin));
- }
-
- // Returns the current origin's information.
- virtual bool HasFileSystemType(FileSystemType type) const OVERRIDE {
- if (current_.path.empty())
- return false;
- base::FilePath::StringType type_string =
- ObfuscatedFileUtil::GetDirectoryNameForType(type);
- if (type_string.empty()) {
- NOTREACHED();
- return false;
- }
- base::FilePath path = base_file_path_.Append(current_.path).Append(type_string);
- return file_util::DirectoryExists(path);
- }
-
- private:
- std::vector<OriginRecord> origins_;
- OriginRecord current_;
- base::FilePath base_file_path_;
-};
-
-ObfuscatedFileUtil::ObfuscatedFileUtil(
- const base::FilePath& file_system_directory)
- : file_system_directory_(file_system_directory) {
-}
-
-ObfuscatedFileUtil::~ObfuscatedFileUtil() {
- DropDatabases();
-}
-
-PlatformFileError ObfuscatedFileUtil::CreateOrOpen(
- FileSystemOperationContext* context,
- const FileSystemURL& url, int file_flags,
- PlatformFile* file_handle, bool* created) {
- PlatformFileError error = CreateOrOpenInternal(context, url, file_flags,
- file_handle, created);
- if (*file_handle != base::kInvalidPlatformFileValue &&
- file_flags & base::PLATFORM_FILE_WRITE &&
- context->quota_limit_type() == quota::kQuotaLimitTypeUnlimited) {
- DCHECK_EQ(base::PLATFORM_FILE_OK, error);
- DCHECK_EQ(kFileSystemTypePersistent, url.type());
- context->file_system_context()->GetQuotaUtil(url.type())->
- StickyInvalidateUsageCache(url.origin(), url.type());
- }
- return error;
-}
-
-PlatformFileError ObfuscatedFileUtil::Close(
- FileSystemOperationContext* context,
- base::PlatformFile file) {
- return NativeFileUtil::Close(file);
-}
-
-PlatformFileError ObfuscatedFileUtil::EnsureFileExists(
- FileSystemOperationContext* context,
- const FileSystemURL& url,
- bool* created) {
- SandboxDirectoryDatabase* db = GetDirectoryDatabase(
- url.origin(), url.type(), true);
- if (!db)
- return base::PLATFORM_FILE_ERROR_FAILED;
-
- FileId file_id;
- if (db->GetFileWithPath(url.path(), &file_id)) {
- FileInfo file_info;
- if (!db->GetFileInfo(file_id, &file_info)) {
- NOTREACHED();
- return base::PLATFORM_FILE_ERROR_FAILED;
- }
- if (file_info.is_directory())
- return base::PLATFORM_FILE_ERROR_NOT_A_FILE;
- if (created)
- *created = false;
- return base::PLATFORM_FILE_OK;
- }
- FileId parent_id;
- if (!db->GetFileWithPath(VirtualPath::DirName(url.path()), &parent_id))
- return base::PLATFORM_FILE_ERROR_NOT_FOUND;
-
- FileInfo file_info;
- InitFileInfo(&file_info, parent_id,
- VirtualPath::BaseName(url.path()).value());
-
- int64 growth = UsageForPath(file_info.name.size());
- if (!AllocateQuota(context, growth))
- return base::PLATFORM_FILE_ERROR_NO_SPACE;
- PlatformFileError error = CreateFile(
- context, base::FilePath(), url.origin(), url.type(), &file_info, 0, NULL);
- if (created && base::PLATFORM_FILE_OK == error) {
- *created = true;
- UpdateUsage(context, url, growth);
- context->change_observers()->Notify(
- &FileChangeObserver::OnCreateFile, MakeTuple(url));
- }
- return error;
-}
-
-PlatformFileError ObfuscatedFileUtil::CreateDirectory(
- FileSystemOperationContext* context,
- const FileSystemURL& url,
- bool exclusive,
- bool recursive) {
- SandboxDirectoryDatabase* db = GetDirectoryDatabase(
- url.origin(), url.type(), true);
- if (!db)
- return base::PLATFORM_FILE_ERROR_FAILED;
-
- // TODO(kinuko): Remove this dirty hack when we fully support directory
- // operations or clean up the code if we decided not to support directory
- // operations. (http://crbug.com/161442)
- if (url.type() == kFileSystemTypeSyncable &&
- !sync_file_system::IsSyncFSDirectoryOperationEnabled()) {
- return base::PLATFORM_FILE_ERROR_INVALID_OPERATION;
- }
-
- FileId file_id;
- if (db->GetFileWithPath(url.path(), &file_id)) {
- FileInfo file_info;
- if (exclusive)
- return base::PLATFORM_FILE_ERROR_EXISTS;
- if (!db->GetFileInfo(file_id, &file_info)) {
- NOTREACHED();
- return base::PLATFORM_FILE_ERROR_FAILED;
- }
- if (!file_info.is_directory())
- return base::PLATFORM_FILE_ERROR_NOT_A_DIRECTORY;
- return base::PLATFORM_FILE_OK;
- }
-
- std::vector<base::FilePath::StringType> components;
- VirtualPath::GetComponents(url.path(), &components);
- FileId parent_id = 0;
- size_t index;
- for (index = 0; index < components.size(); ++index) {
- base::FilePath::StringType name = components[index];
- if (name == FILE_PATH_LITERAL("/"))
- continue;
- if (!db->GetChildWithName(parent_id, name, &parent_id))
- break;
- }
- if (!recursive && components.size() - index > 1)
- return base::PLATFORM_FILE_ERROR_NOT_FOUND;
- bool first = true;
- for (; index < components.size(); ++index) {
- FileInfo file_info;
- file_info.name = components[index];
- if (file_info.name == FILE_PATH_LITERAL("/"))
- continue;
- file_info.modification_time = base::Time::Now();
- file_info.parent_id = parent_id;
- int64 growth = UsageForPath(file_info.name.size());
- if (!AllocateQuota(context, growth))
- return base::PLATFORM_FILE_ERROR_NO_SPACE;
- if (!db->AddFileInfo(file_info, &parent_id)) {
- NOTREACHED();
- return base::PLATFORM_FILE_ERROR_FAILED;
- }
- UpdateUsage(context, url, growth);
- context->change_observers()->Notify(
- &FileChangeObserver::OnCreateDirectory, MakeTuple(url));
- if (first) {
- first = false;
- TouchDirectory(db, file_info.parent_id);
- }
- }
- return base::PLATFORM_FILE_OK;
-}
-
-PlatformFileError ObfuscatedFileUtil::GetFileInfo(
- FileSystemOperationContext* context,
- const FileSystemURL& url,
- base::PlatformFileInfo* file_info,
- base::FilePath* platform_file_path) {
- SandboxDirectoryDatabase* db = GetDirectoryDatabase(
- url.origin(), url.type(), false);
- if (!db)
- return base::PLATFORM_FILE_ERROR_NOT_FOUND;
- FileId file_id;
- if (!db->GetFileWithPath(url.path(), &file_id))
- return base::PLATFORM_FILE_ERROR_NOT_FOUND;
- FileInfo local_info;
- return GetFileInfoInternal(db, context,
- url.origin(), url.type(),
- file_id, &local_info,
- file_info, platform_file_path);
-}
-
-scoped_ptr<FileSystemFileUtil::AbstractFileEnumerator>
- ObfuscatedFileUtil::CreateFileEnumerator(
- FileSystemOperationContext* context,
- const FileSystemURL& root_url) {
- return CreateFileEnumerator(context, root_url, false /* recursive */);
-}
-
-PlatformFileError ObfuscatedFileUtil::GetLocalFilePath(
- FileSystemOperationContext* context,
- const FileSystemURL& url,
- base::FilePath* local_path) {
- SandboxDirectoryDatabase* db = GetDirectoryDatabase(
- url.origin(), url.type(), false);
- if (!db)
- return base::PLATFORM_FILE_ERROR_NOT_FOUND;
- FileId file_id;
- if (!db->GetFileWithPath(url.path(), &file_id))
- return base::PLATFORM_FILE_ERROR_NOT_FOUND;
- FileInfo file_info;
- if (!db->GetFileInfo(file_id, &file_info) || file_info.is_directory()) {
- NOTREACHED();
- // Directories have no local file path.
- return base::PLATFORM_FILE_ERROR_NOT_FOUND;
- }
- *local_path = DataPathToLocalPath(
- url.origin(), url.type(), file_info.data_path);
-
- if (local_path->empty())
- return base::PLATFORM_FILE_ERROR_NOT_FOUND;
- return base::PLATFORM_FILE_OK;
-}
-
-PlatformFileError ObfuscatedFileUtil::Touch(
- FileSystemOperationContext* context,
- const FileSystemURL& url,
- const base::Time& last_access_time,
- const base::Time& last_modified_time) {
- SandboxDirectoryDatabase* db = GetDirectoryDatabase(
- url.origin(), url.type(), false);
- if (!db)
- return base::PLATFORM_FILE_ERROR_NOT_FOUND;
- FileId file_id;
- if (!db->GetFileWithPath(url.path(), &file_id))
- return base::PLATFORM_FILE_ERROR_NOT_FOUND;
-
- FileInfo file_info;
- if (!db->GetFileInfo(file_id, &file_info)) {
- NOTREACHED();
- return base::PLATFORM_FILE_ERROR_FAILED;
- }
- if (file_info.is_directory()) {
- if (!db->UpdateModificationTime(file_id, last_modified_time))
- return base::PLATFORM_FILE_ERROR_FAILED;
- return base::PLATFORM_FILE_OK;
- }
- base::FilePath local_path = DataPathToLocalPath(
- url.origin(), url.type(), file_info.data_path);
- return NativeFileUtil::Touch(
- local_path, last_access_time, last_modified_time);
-}
-
-PlatformFileError ObfuscatedFileUtil::Truncate(
- FileSystemOperationContext* context,
- const FileSystemURL& url,
- int64 length) {
- base::PlatformFileInfo file_info;
- base::FilePath local_path;
- base::PlatformFileError error =
- GetFileInfo(context, url, &file_info, &local_path);
- if (error != base::PLATFORM_FILE_OK)
- return error;
-
- int64 growth = length - file_info.size;
- if (!AllocateQuota(context, growth))
- return base::PLATFORM_FILE_ERROR_NO_SPACE;
- error = NativeFileUtil::Truncate(local_path, length);
- if (error == base::PLATFORM_FILE_OK) {
- UpdateUsage(context, url, growth);
- context->change_observers()->Notify(
- &FileChangeObserver::OnModifyFile, MakeTuple(url));
- }
- return error;
-}
-
-PlatformFileError ObfuscatedFileUtil::CopyOrMoveFile(
- FileSystemOperationContext* context,
- const FileSystemURL& src_url,
- const FileSystemURL& dest_url,
- bool copy) {
- // Cross-filesystem copies and moves should be handled via CopyInForeignFile.
- DCHECK(src_url.origin() == dest_url.origin());
- DCHECK(src_url.type() == dest_url.type());
-
- SandboxDirectoryDatabase* db = GetDirectoryDatabase(
- src_url.origin(), src_url.type(), true);
- if (!db)
- return base::PLATFORM_FILE_ERROR_FAILED;
-
- FileId src_file_id;
- if (!db->GetFileWithPath(src_url.path(), &src_file_id))
- return base::PLATFORM_FILE_ERROR_NOT_FOUND;
-
- FileId dest_file_id;
- bool overwrite = db->GetFileWithPath(dest_url.path(),
- &dest_file_id);
-
- FileInfo src_file_info;
- base::PlatformFileInfo src_platform_file_info;
- base::FilePath src_local_path;
- base::PlatformFileError error = GetFileInfoInternal(
- db, context, src_url.origin(), src_url.type(), src_file_id,
- &src_file_info, &src_platform_file_info, &src_local_path);
- if (error != base::PLATFORM_FILE_OK)
- return error;
- if (src_file_info.is_directory())
- return base::PLATFORM_FILE_ERROR_NOT_A_FILE;
-
- FileInfo dest_file_info;
- base::PlatformFileInfo dest_platform_file_info; // overwrite case only
- base::FilePath dest_local_path; // overwrite case only
- if (overwrite) {
- base::PlatformFileError error = GetFileInfoInternal(
- db, context, dest_url.origin(), dest_url.type(), dest_file_id,
- &dest_file_info, &dest_platform_file_info, &dest_local_path);
- if (error == base::PLATFORM_FILE_ERROR_NOT_FOUND)
- overwrite = false; // fallback to non-overwrite case
- else if (error != base::PLATFORM_FILE_OK)
- return error;
- else if (dest_file_info.is_directory())
- return base::PLATFORM_FILE_ERROR_INVALID_OPERATION;
- }
- if (!overwrite) {
- FileId dest_parent_id;
- if (!db->GetFileWithPath(VirtualPath::DirName(dest_url.path()),
- &dest_parent_id)) {
- return base::PLATFORM_FILE_ERROR_NOT_FOUND;
- }
-
- dest_file_info = src_file_info;
- dest_file_info.parent_id = dest_parent_id;
- dest_file_info.name =
- VirtualPath::BaseName(dest_url.path()).value();
- }
-
- int64 growth = 0;
- if (copy)
- growth += src_platform_file_info.size;
- else
- growth -= UsageForPath(src_file_info.name.size());
- if (overwrite)
- growth -= dest_platform_file_info.size;
- else
- growth += UsageForPath(dest_file_info.name.size());
- if (!AllocateQuota(context, growth))
- return base::PLATFORM_FILE_ERROR_NO_SPACE;
-
- /*
- * Copy-with-overwrite
- * Just overwrite data file
- * Copy-without-overwrite
- * Copy backing file
- * Create new metadata pointing to new backing file.
- * Move-with-overwrite
- * transaction:
- * Remove source entry.
- * Point target entry to source entry's backing file.
- * Delete target entry's old backing file
- * Move-without-overwrite
- * Just update metadata
- */
- error = base::PLATFORM_FILE_ERROR_FAILED;
- if (copy) {
- if (overwrite) {
- error = NativeFileUtil::CopyOrMoveFile(
- src_local_path,
- dest_local_path,
- true /* copy */);
- } else { // non-overwrite
- error = CreateFile(context, src_local_path,
- dest_url.origin(), dest_url.type(),
- &dest_file_info, 0, NULL);
- }
- } else {
- if (overwrite) {
- if (db->OverwritingMoveFile(src_file_id, dest_file_id)) {
- if (base::PLATFORM_FILE_OK !=
- NativeFileUtil::DeleteFile(dest_local_path))
- LOG(WARNING) << "Leaked a backing file.";
- error = base::PLATFORM_FILE_OK;
- } else {
- error = base::PLATFORM_FILE_ERROR_FAILED;
- }
- } else { // non-overwrite
- if (db->UpdateFileInfo(src_file_id, dest_file_info))
- error = base::PLATFORM_FILE_OK;
- else
- error = base::PLATFORM_FILE_ERROR_FAILED;
- }
- }
-
- if (error != base::PLATFORM_FILE_OK)
- return error;
-
- if (overwrite) {
- context->change_observers()->Notify(
- &FileChangeObserver::OnModifyFile,
- MakeTuple(dest_url));
- } else {
- context->change_observers()->Notify(
- &FileChangeObserver::OnCreateFileFrom,
- MakeTuple(dest_url, src_url));
- }
-
- if (!copy) {
- context->change_observers()->Notify(
- &FileChangeObserver::OnRemoveFile, MakeTuple(src_url));
- TouchDirectory(db, src_file_info.parent_id);
- }
-
- TouchDirectory(db, dest_file_info.parent_id);
-
- UpdateUsage(context, dest_url, growth);
- return error;
-}
-
-PlatformFileError ObfuscatedFileUtil::CopyInForeignFile(
- FileSystemOperationContext* context,
- const base::FilePath& src_file_path,
- const FileSystemURL& dest_url) {
- SandboxDirectoryDatabase* db = GetDirectoryDatabase(
- dest_url.origin(), dest_url.type(), true);
- if (!db)
- return base::PLATFORM_FILE_ERROR_FAILED;
-
- base::PlatformFileInfo src_platform_file_info;
- if (!file_util::GetFileInfo(src_file_path, &src_platform_file_info))
- return base::PLATFORM_FILE_ERROR_NOT_FOUND;
-
- FileId dest_file_id;
- bool overwrite = db->GetFileWithPath(dest_url.path(),
- &dest_file_id);
-
- FileInfo dest_file_info;
- base::PlatformFileInfo dest_platform_file_info; // overwrite case only
- if (overwrite) {
- base::FilePath dest_local_path;
- base::PlatformFileError error = GetFileInfoInternal(
- db, context, dest_url.origin(), dest_url.type(), dest_file_id,
- &dest_file_info, &dest_platform_file_info, &dest_local_path);
- if (error == base::PLATFORM_FILE_ERROR_NOT_FOUND)
- overwrite = false; // fallback to non-overwrite case
- else if (error != base::PLATFORM_FILE_OK)
- return error;
- else if (dest_file_info.is_directory())
- return base::PLATFORM_FILE_ERROR_INVALID_OPERATION;
- }
- if (!overwrite) {
- FileId dest_parent_id;
- if (!db->GetFileWithPath(VirtualPath::DirName(dest_url.path()),
- &dest_parent_id)) {
- return base::PLATFORM_FILE_ERROR_NOT_FOUND;
- }
- if (!dest_file_info.is_directory())
- return base::PLATFORM_FILE_ERROR_FAILED;
- InitFileInfo(&dest_file_info, dest_parent_id,
- VirtualPath::BaseName(dest_url.path()).value());
- }
-
- int64 growth = src_platform_file_info.size;
- if (overwrite)
- growth -= dest_platform_file_info.size;
- else
- growth += UsageForPath(dest_file_info.name.size());
- if (!AllocateQuota(context, growth))
- return base::PLATFORM_FILE_ERROR_NO_SPACE;
-
- base::PlatformFileError error;
- if (overwrite) {
- base::FilePath dest_local_path = DataPathToLocalPath(
- dest_url.origin(), dest_url.type(), dest_file_info.data_path);
- error = NativeFileUtil::CopyOrMoveFile(
- src_file_path, dest_local_path, true);
- } else {
- error = CreateFile(context, src_file_path,
- dest_url.origin(), dest_url.type(),
- &dest_file_info, 0, NULL);
- }
-
- if (error != base::PLATFORM_FILE_OK)
- return error;
-
- if (overwrite) {
- context->change_observers()->Notify(
- &FileChangeObserver::OnModifyFile, MakeTuple(dest_url));
- } else {
- context->change_observers()->Notify(
- &FileChangeObserver::OnCreateFile, MakeTuple(dest_url));
- }
-
- UpdateUsage(context, dest_url, growth);
- TouchDirectory(db, dest_file_info.parent_id);
- return base::PLATFORM_FILE_OK;
-}
-
-PlatformFileError ObfuscatedFileUtil::DeleteFile(
- FileSystemOperationContext* context,
- const FileSystemURL& url) {
- SandboxDirectoryDatabase* db = GetDirectoryDatabase(
- url.origin(), url.type(), true);
- if (!db)
- return base::PLATFORM_FILE_ERROR_FAILED;
- FileId file_id;
- if (!db->GetFileWithPath(url.path(), &file_id))
- return base::PLATFORM_FILE_ERROR_NOT_FOUND;
-
- FileInfo file_info;
- base::PlatformFileInfo platform_file_info;
- base::FilePath local_path;
- base::PlatformFileError error = GetFileInfoInternal(
- db, context, url.origin(), url.type(), file_id,
- &file_info, &platform_file_info, &local_path);
- if (error != base::PLATFORM_FILE_ERROR_NOT_FOUND &&
- error != base::PLATFORM_FILE_OK)
- return error;
-
- if (file_info.is_directory())
- return base::PLATFORM_FILE_ERROR_NOT_A_FILE;
-
- int64 growth = -UsageForPath(file_info.name.size()) - platform_file_info.size;
- AllocateQuota(context, growth);
- if (!db->RemoveFileInfo(file_id)) {
- NOTREACHED();
- return base::PLATFORM_FILE_ERROR_FAILED;
- }
- UpdateUsage(context, url, growth);
- TouchDirectory(db, file_info.parent_id);
-
- context->change_observers()->Notify(
- &FileChangeObserver::OnRemoveFile, MakeTuple(url));
-
- if (error == base::PLATFORM_FILE_ERROR_NOT_FOUND)
- return base::PLATFORM_FILE_OK;
-
- error = NativeFileUtil::DeleteFile(local_path);
- if (base::PLATFORM_FILE_OK != error)
- LOG(WARNING) << "Leaked a backing file.";
- return base::PLATFORM_FILE_OK;
-}
-
-PlatformFileError ObfuscatedFileUtil::DeleteDirectory(
- FileSystemOperationContext* context,
- const FileSystemURL& url) {
- SandboxDirectoryDatabase* db = GetDirectoryDatabase(
- url.origin(), url.type(), true);
- if (!db)
- return base::PLATFORM_FILE_ERROR_FAILED;
-
- FileId file_id;
- if (!db->GetFileWithPath(url.path(), &file_id))
- return base::PLATFORM_FILE_ERROR_NOT_FOUND;
- FileInfo file_info;
- if (!db->GetFileInfo(file_id, &file_info)) {
- NOTREACHED();
- return base::PLATFORM_FILE_ERROR_FAILED;
- }
- if (!file_info.is_directory())
- return base::PLATFORM_FILE_ERROR_NOT_A_DIRECTORY;
- if (!db->RemoveFileInfo(file_id))
- return base::PLATFORM_FILE_ERROR_NOT_EMPTY;
- int64 growth = -UsageForPath(file_info.name.size());
- AllocateQuota(context, growth);
- UpdateUsage(context, url, growth);
- TouchDirectory(db, file_info.parent_id);
- context->change_observers()->Notify(
- &FileChangeObserver::OnRemoveDirectory, MakeTuple(url));
- return base::PLATFORM_FILE_OK;
-}
-
-webkit_blob::ScopedFile ObfuscatedFileUtil::CreateSnapshotFile(
- FileSystemOperationContext* context,
- const FileSystemURL& url,
- base::PlatformFileError* error,
- base::PlatformFileInfo* file_info,
- base::FilePath* platform_path) {
- // We're just returning the local file information.
- *error = GetFileInfo(context, url, file_info, platform_path);
- if (*error == base::PLATFORM_FILE_OK && file_info->is_directory) {
- *file_info = base::PlatformFileInfo();
- *error = base::PLATFORM_FILE_ERROR_NOT_A_FILE;
- }
- return webkit_blob::ScopedFile();
-}
-
-scoped_ptr<FileSystemFileUtil::AbstractFileEnumerator>
- ObfuscatedFileUtil::CreateFileEnumerator(
- FileSystemOperationContext* context,
- const FileSystemURL& root_url,
- bool recursive) {
- SandboxDirectoryDatabase* db = GetDirectoryDatabase(
- root_url.origin(), root_url.type(), false);
- if (!db) {
- return scoped_ptr<AbstractFileEnumerator>(new EmptyFileEnumerator());
- }
- return scoped_ptr<AbstractFileEnumerator>(
- new ObfuscatedFileEnumerator(db, context, this, root_url, recursive));
-}
-
-bool ObfuscatedFileUtil::IsDirectoryEmpty(
- FileSystemOperationContext* context,
- const FileSystemURL& url) {
- SandboxDirectoryDatabase* db = GetDirectoryDatabase(
- url.origin(), url.type(), false);
- if (!db)
- return true; // Not a great answer, but it's what others do.
- FileId file_id;
- if (!db->GetFileWithPath(url.path(), &file_id))
- return true; // Ditto.
- FileInfo file_info;
- if (!db->GetFileInfo(file_id, &file_info)) {
- DCHECK(!file_id);
- // It's the root directory and the database hasn't been initialized yet.
- return true;
- }
- if (!file_info.is_directory())
- return true;
- std::vector<FileId> children;
- // TODO(ericu): This could easily be made faster with help from the database.
- if (!db->ListChildren(file_id, &children))
- return true;
- return children.empty();
-}
-
-base::FilePath ObfuscatedFileUtil::GetDirectoryForOriginAndType(
- const GURL& origin,
- FileSystemType type,
- bool create,
- base::PlatformFileError* error_code) {
- base::FilePath origin_dir = GetDirectoryForOrigin(origin, create, error_code);
- if (origin_dir.empty())
- return base::FilePath();
- base::FilePath::StringType type_string = GetDirectoryNameForType(type);
- if (type_string.empty()) {
- LOG(WARNING) << "Unknown filesystem type requested:" << type;
-
- if (error_code)
- *error_code = base::PLATFORM_FILE_ERROR_INVALID_URL;
- return base::FilePath();
- }
- base::FilePath path = origin_dir.Append(type_string);
- base::PlatformFileError error = base::PLATFORM_FILE_OK;
- if (!file_util::DirectoryExists(path) &&
- (!create || !file_util::CreateDirectory(path))) {
- error = create ?
- base::PLATFORM_FILE_ERROR_FAILED :
- base::PLATFORM_FILE_ERROR_NOT_FOUND;
- }
-
- if (error_code)
- *error_code = error;
- return path;
-}
-
-bool ObfuscatedFileUtil::DeleteDirectoryForOriginAndType(
- const GURL& origin, FileSystemType type) {
- base::PlatformFileError error = base::PLATFORM_FILE_OK;
- base::FilePath origin_type_path = GetDirectoryForOriginAndType(origin, type, false,
- &error);
- if (origin_type_path.empty())
- return true;
-
- if (error != base::PLATFORM_FILE_ERROR_NOT_FOUND) {
- // TODO(dmikurube): Consider the return value of DestroyDirectoryDatabase.
- // We ignore its error now since 1) it doesn't matter the final result, and
- // 2) it always returns false in Windows because of LevelDB's
- // implementation.
- // Information about failure would be useful for debugging.
- DestroyDirectoryDatabase(origin, type);
- if (!file_util::Delete(origin_type_path, true /* recursive */))
- return false;
- }
-
- base::FilePath origin_path = VirtualPath::DirName(origin_type_path);
- DCHECK_EQ(origin_path.value(),
- GetDirectoryForOrigin(origin, false, NULL).value());
-
- // At this point we are sure we had successfully deleted the origin/type
- // directory (i.e. we're ready to just return true).
- // See if we have other directories in this origin directory.
- std::vector<FileSystemType> other_types;
- if (type != kFileSystemTypeTemporary)
- other_types.push_back(kFileSystemTypeTemporary);
- if (type != kFileSystemTypePersistent)
- other_types.push_back(kFileSystemTypePersistent);
- if (type != kFileSystemTypeSyncable)
- other_types.push_back(kFileSystemTypeSyncable);
-
- for (size_t i = 0; i < other_types.size(); ++i) {
- if (file_util::DirectoryExists(
- origin_path.Append(GetDirectoryNameForType(other_types[i])))) {
- // Other type's directory exists; just return true here.
- return true;
- }
- }
-
- // No other directories seem exist. Try deleting the entire origin directory.
- InitOriginDatabase(false);
- if (origin_database_) {
- origin_database_->RemovePathForOrigin(
- UTF16ToUTF8(webkit_base::GetOriginIdentifierFromURL(origin)));
- }
- if (!file_util::Delete(origin_path, true /* recursive */))
- return false;
-
- return true;
-}
-
-// static
-base::FilePath::StringType ObfuscatedFileUtil::GetDirectoryNameForType(
- FileSystemType type) {
- switch (type) {
- case kFileSystemTypeTemporary:
- return kTemporaryDirectoryName;
- case kFileSystemTypePersistent:
- return kPersistentDirectoryName;
- case kFileSystemTypeSyncable:
- return kSyncableDirectoryName;
- case kFileSystemTypeUnknown:
- default:
- return base::FilePath::StringType();
- }
-}
-
-ObfuscatedFileUtil::AbstractOriginEnumerator*
-ObfuscatedFileUtil::CreateOriginEnumerator() {
- std::vector<SandboxOriginDatabase::OriginRecord> origins;
-
- InitOriginDatabase(false);
- return new ObfuscatedOriginEnumerator(
- origin_database_.get(), file_system_directory_);
-}
-
-bool ObfuscatedFileUtil::DestroyDirectoryDatabase(
- const GURL& origin, FileSystemType type) {
- std::string type_string = GetFileSystemTypeString(type);
- if (type_string.empty()) {
- LOG(WARNING) << "Unknown filesystem type requested:" << type;
- return true;
- }
- std::string key =
- UTF16ToUTF8(webkit_base::GetOriginIdentifierFromURL(origin)) +
- type_string;
- DirectoryMap::iterator iter = directories_.find(key);
- if (iter != directories_.end()) {
- SandboxDirectoryDatabase* database = iter->second;
- directories_.erase(iter);
- delete database;
- }
-
- PlatformFileError error = base::PLATFORM_FILE_OK;
- base::FilePath path = GetDirectoryForOriginAndType(origin, type, false, &error);
- if (path.empty() || error == base::PLATFORM_FILE_ERROR_NOT_FOUND)
- return true;
- return SandboxDirectoryDatabase::DestroyDatabase(path);
-}
-
-// static
-int64 ObfuscatedFileUtil::ComputeFilePathCost(const base::FilePath& path) {
- return UsageForPath(VirtualPath::BaseName(path).value().size());
-}
-
-PlatformFileError ObfuscatedFileUtil::GetFileInfoInternal(
- SandboxDirectoryDatabase* db,
- FileSystemOperationContext* context,
- const GURL& origin,
- FileSystemType type,
- FileId file_id,
- FileInfo* local_info,
- base::PlatformFileInfo* file_info,
- base::FilePath* platform_file_path) {
- DCHECK(db);
- DCHECK(context);
- DCHECK(file_info);
- DCHECK(platform_file_path);
-
- if (!db->GetFileInfo(file_id, local_info)) {
- NOTREACHED();
- return base::PLATFORM_FILE_ERROR_FAILED;
- }
-
- if (local_info->is_directory()) {
- file_info->size = 0;
- file_info->is_directory = true;
- file_info->is_symbolic_link = false;
- file_info->last_modified = local_info->modification_time;
- *platform_file_path = base::FilePath();
- // We don't fill in ctime or atime.
- return base::PLATFORM_FILE_OK;
- }
- if (local_info->data_path.empty())
- return base::PLATFORM_FILE_ERROR_INVALID_OPERATION;
- base::FilePath local_path = DataPathToLocalPath(
- origin, type, local_info->data_path);
- base::PlatformFileError error = NativeFileUtil::GetFileInfo(
- local_path, file_info);
- // We should not follow symbolic links in sandboxed file system.
- if (file_util::IsLink(local_path)) {
- LOG(WARNING) << "Found a symbolic file.";
- error = base::PLATFORM_FILE_ERROR_NOT_FOUND;
- }
- if (error == base::PLATFORM_FILE_OK) {
- *platform_file_path = local_path;
- } else if (error == base::PLATFORM_FILE_ERROR_NOT_FOUND) {
- LOG(WARNING) << "Lost a backing file.";
- InvalidateUsageCache(context, origin, type);
- if (!db->RemoveFileInfo(file_id))
- return base::PLATFORM_FILE_ERROR_FAILED;
- }
- return error;
-}
-
-PlatformFileError ObfuscatedFileUtil::CreateFile(
- FileSystemOperationContext* context,
- const base::FilePath& src_file_path,
- const GURL& dest_origin,
- FileSystemType dest_type,
- FileInfo* dest_file_info, int file_flags, PlatformFile* handle) {
- if (handle)
- *handle = base::kInvalidPlatformFileValue;
- SandboxDirectoryDatabase* db = GetDirectoryDatabase(
- dest_origin, dest_type, true);
-
- PlatformFileError error = base::PLATFORM_FILE_OK;
- base::FilePath root = GetDirectoryForOriginAndType(dest_origin, dest_type, false,
- &error);
- if (error != base::PLATFORM_FILE_OK)
- return error;
-
- base::FilePath dest_local_path;
- error = GenerateNewLocalPath(db, context, dest_origin, dest_type,
- &dest_local_path);
- if (error != base::PLATFORM_FILE_OK)
- return error;
-
- bool created = false;
- if (!src_file_path.empty()) {
- DCHECK(!file_flags);
- DCHECK(!handle);
- error = NativeFileUtil::CopyOrMoveFile(
- src_file_path, dest_local_path, true /* copy */);
- created = true;
- } else {
- if (file_util::PathExists(dest_local_path)) {
- if (!file_util::Delete(dest_local_path, true /* recursive */)) {
- NOTREACHED();
- return base::PLATFORM_FILE_ERROR_FAILED;
- }
- LOG(WARNING) << "A stray file detected";
- InvalidateUsageCache(context, dest_origin, dest_type);
- }
-
- if (handle) {
- error = NativeFileUtil::CreateOrOpen(
- dest_local_path, file_flags, handle, &created);
- // If this succeeds, we must close handle on any subsequent error.
- } else {
- DCHECK(!file_flags); // file_flags is only used by CreateOrOpen.
- error = NativeFileUtil::EnsureFileExists(dest_local_path, &created);
- }
- }
- if (error != base::PLATFORM_FILE_OK)
- return error;
-
- if (!created) {
- NOTREACHED();
- if (handle) {
- DCHECK_NE(base::kInvalidPlatformFileValue, *handle);
- base::ClosePlatformFile(*handle);
- file_util::Delete(dest_local_path, false /* recursive */);
- }
- return base::PLATFORM_FILE_ERROR_FAILED;
- }
-
- // This removes the root, including the trailing slash, leaving a relative
- // path.
- dest_file_info->data_path = base::FilePath(
- dest_local_path.value().substr(root.value().length() + 1));
-
- FileId file_id;
- if (!db->AddFileInfo(*dest_file_info, &file_id)) {
- if (handle) {
- DCHECK_NE(base::kInvalidPlatformFileValue, *handle);
- base::ClosePlatformFile(*handle);
- }
- file_util::Delete(dest_local_path, false /* recursive */);
- return base::PLATFORM_FILE_ERROR_FAILED;
- }
- TouchDirectory(db, dest_file_info->parent_id);
-
- return base::PLATFORM_FILE_OK;
-}
-
-base::FilePath ObfuscatedFileUtil::DataPathToLocalPath(
- const GURL& origin, FileSystemType type, const base::FilePath& data_path) {
- PlatformFileError error = base::PLATFORM_FILE_OK;
- base::FilePath root = GetDirectoryForOriginAndType(origin, type, false, &error);
- if (error != base::PLATFORM_FILE_OK)
- return base::FilePath();
- return root.Append(data_path);
-}
-
-// TODO(ericu): How to do the whole validation-without-creation thing?
-// We may not have quota even to create the database.
-// Ah, in that case don't even get here?
-// Still doesn't answer the quota issue, though.
-SandboxDirectoryDatabase* ObfuscatedFileUtil::GetDirectoryDatabase(
- const GURL& origin, FileSystemType type, bool create) {
- std::string type_string = GetFileSystemTypeString(type);
- if (type_string.empty()) {
- LOG(WARNING) << "Unknown filesystem type requested:" << type;
- return NULL;
- }
- std::string key =
- UTF16ToUTF8(webkit_base::GetOriginIdentifierFromURL(origin)) +
- type_string;
- DirectoryMap::iterator iter = directories_.find(key);
- if (iter != directories_.end()) {
- MarkUsed();
- return iter->second;
- }
-
- PlatformFileError error = base::PLATFORM_FILE_OK;
- base::FilePath path = GetDirectoryForOriginAndType(origin, type, create, &error);
- if (error != base::PLATFORM_FILE_OK) {
- LOG(WARNING) << "Failed to get origin+type directory: " << path.value();
- return NULL;
- }
- MarkUsed();
- SandboxDirectoryDatabase* database = new SandboxDirectoryDatabase(path);
- directories_[key] = database;
- return database;
-}
-
-base::FilePath ObfuscatedFileUtil::GetDirectoryForOrigin(
- const GURL& origin, bool create, base::PlatformFileError* error_code) {
- if (!InitOriginDatabase(create)) {
- if (error_code) {
- *error_code = create ?
- base::PLATFORM_FILE_ERROR_FAILED :
- base::PLATFORM_FILE_ERROR_NOT_FOUND;
- }
- return base::FilePath();
- }
- base::FilePath directory_name;
- std::string id = UTF16ToUTF8(webkit_base::GetOriginIdentifierFromURL(origin));
-
- bool exists_in_db = origin_database_->HasOriginPath(id);
- if (!exists_in_db && !create) {
- if (error_code)
- *error_code = base::PLATFORM_FILE_ERROR_NOT_FOUND;
- return base::FilePath();
- }
- if (!origin_database_->GetPathForOrigin(id, &directory_name)) {
- if (error_code)
- *error_code = base::PLATFORM_FILE_ERROR_FAILED;
- return base::FilePath();
- }
-
- base::FilePath path = file_system_directory_.Append(directory_name);
- bool exists_in_fs = file_util::DirectoryExists(path);
- if (!exists_in_db && exists_in_fs) {
- if (!file_util::Delete(path, true)) {
- if (error_code)
- *error_code = base::PLATFORM_FILE_ERROR_FAILED;
- return base::FilePath();
- }
- exists_in_fs = false;
- }
-
- if (!exists_in_fs) {
- if (!create || !file_util::CreateDirectory(path)) {
- if (error_code)
- *error_code = create ?
- base::PLATFORM_FILE_ERROR_FAILED :
- base::PLATFORM_FILE_ERROR_NOT_FOUND;
- return base::FilePath();
- }
- }
-
- if (error_code)
- *error_code = base::PLATFORM_FILE_OK;
-
- return path;
-}
-
-void ObfuscatedFileUtil::InvalidateUsageCache(
- FileSystemOperationContext* context,
- const GURL& origin,
- FileSystemType type) {
- context->file_system_context()->GetQuotaUtil(type)->
- InvalidateUsageCache(origin, type);
-}
-
-void ObfuscatedFileUtil::MarkUsed() {
- if (timer_.IsRunning())
- timer_.Reset();
- else
- timer_.Start(FROM_HERE, base::TimeDelta::FromSeconds(kFlushDelaySeconds),
- this, &ObfuscatedFileUtil::DropDatabases);
-}
-
-void ObfuscatedFileUtil::DropDatabases() {
- origin_database_.reset();
- STLDeleteContainerPairSecondPointers(
- directories_.begin(), directories_.end());
- directories_.clear();
-}
-
-bool ObfuscatedFileUtil::InitOriginDatabase(bool create) {
- if (!origin_database_) {
- if (!create && !file_util::DirectoryExists(file_system_directory_))
- return false;
- if (!file_util::CreateDirectory(file_system_directory_)) {
- LOG(WARNING) << "Failed to create FileSystem directory: " <<
- file_system_directory_.value();
- return false;
- }
- origin_database_.reset(
- new SandboxOriginDatabase(file_system_directory_));
- }
- return true;
-}
-
-PlatformFileError ObfuscatedFileUtil::GenerateNewLocalPath(
- SandboxDirectoryDatabase* db,
- FileSystemOperationContext* context,
- const GURL& origin,
- FileSystemType type,
- base::FilePath* local_path) {
- DCHECK(local_path);
- int64 number;
- if (!db || !db->GetNextInteger(&number))
- return base::PLATFORM_FILE_ERROR_FAILED;
-
- PlatformFileError error = base::PLATFORM_FILE_OK;
- base::FilePath new_local_path = GetDirectoryForOriginAndType(origin, type,
- false, &error);
- if (error != base::PLATFORM_FILE_OK)
- return base::PLATFORM_FILE_ERROR_FAILED;
-
- // We use the third- and fourth-to-last digits as the directory.
- int64 directory_number = number % 10000 / 100;
- new_local_path = new_local_path.AppendASCII(
- base::StringPrintf("%02" PRId64, directory_number));
-
- error = NativeFileUtil::CreateDirectory(
- new_local_path, false /* exclusive */, false /* recursive */);
- if (error != base::PLATFORM_FILE_OK)
- return error;
-
- *local_path =
- new_local_path.AppendASCII(base::StringPrintf("%08" PRId64, number));
- return base::PLATFORM_FILE_OK;
-}
-
-PlatformFileError ObfuscatedFileUtil::CreateOrOpenInternal(
- FileSystemOperationContext* context,
- const FileSystemURL& url, int file_flags,
- PlatformFile* file_handle, bool* created) {
- DCHECK(!(file_flags & (base::PLATFORM_FILE_DELETE_ON_CLOSE |
- base::PLATFORM_FILE_HIDDEN | base::PLATFORM_FILE_EXCLUSIVE_READ |
- base::PLATFORM_FILE_EXCLUSIVE_WRITE)));
- SandboxDirectoryDatabase* db = GetDirectoryDatabase(
- url.origin(), url.type(), true);
- if (!db)
- return base::PLATFORM_FILE_ERROR_FAILED;
- FileId file_id;
- if (!db->GetFileWithPath(url.path(), &file_id)) {
- // The file doesn't exist.
- if (!(file_flags & (base::PLATFORM_FILE_CREATE |
- base::PLATFORM_FILE_CREATE_ALWAYS | base::PLATFORM_FILE_OPEN_ALWAYS)))
- return base::PLATFORM_FILE_ERROR_NOT_FOUND;
- FileId parent_id;
- if (!db->GetFileWithPath(VirtualPath::DirName(url.path()),
- &parent_id))
- return base::PLATFORM_FILE_ERROR_NOT_FOUND;
- FileInfo file_info;
- InitFileInfo(&file_info, parent_id,
- VirtualPath::BaseName(url.path()).value());
-
- int64 growth = UsageForPath(file_info.name.size());
- if (!AllocateQuota(context, growth))
- return base::PLATFORM_FILE_ERROR_NO_SPACE;
- PlatformFileError error = CreateFile(
- context, base::FilePath(),
- url.origin(), url.type(), &file_info,
- file_flags, file_handle);
- if (created && base::PLATFORM_FILE_OK == error) {
- *created = true;
- UpdateUsage(context, url, growth);
- context->change_observers()->Notify(
- &FileChangeObserver::OnCreateFile, MakeTuple(url));
- }
- return error;
- }
-
- if (file_flags & base::PLATFORM_FILE_CREATE)
- return base::PLATFORM_FILE_ERROR_EXISTS;
-
- base::PlatformFileInfo platform_file_info;
- base::FilePath local_path;
- FileInfo file_info;
- base::PlatformFileError error = GetFileInfoInternal(
- db, context, url.origin(), url.type(), file_id,
- &file_info, &platform_file_info, &local_path);
- if (error != base::PLATFORM_FILE_OK)
- return error;
- if (file_info.is_directory())
- return base::PLATFORM_FILE_ERROR_NOT_A_FILE;
-
- int64 delta = 0;
- if (file_flags & (base::PLATFORM_FILE_CREATE_ALWAYS |
- base::PLATFORM_FILE_OPEN_TRUNCATED)) {
- // The file exists and we're truncating.
- delta = -platform_file_info.size;
- AllocateQuota(context, delta);
- }
-
- error = NativeFileUtil::CreateOrOpen(
- local_path, file_flags, file_handle, created);
- if (error == base::PLATFORM_FILE_ERROR_NOT_FOUND) {
- // TODO(tzik): Also invalidate on-memory usage cache in UsageTracker.
- // TODO(tzik): Delete database entry after ensuring the file lost.
- InvalidateUsageCache(context, url.origin(), url.type());
- LOG(WARNING) << "Lost a backing file.";
- error = base::PLATFORM_FILE_ERROR_FAILED;
- }
-
- // If truncating we need to update the usage.
- if (error == base::PLATFORM_FILE_OK && delta) {
- UpdateUsage(context, url, delta);
- context->change_observers()->Notify(
- &FileChangeObserver::OnModifyFile, MakeTuple(url));
- }
- return error;
-}
-
-} // namespace fileapi
« no previous file with comments | « webkit/fileapi/obfuscated_file_util.h ('k') | webkit/fileapi/obfuscated_file_util_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698