Index: webkit/chromeos/fileapi/memory_file_util.cc |
=================================================================== |
--- webkit/chromeos/fileapi/memory_file_util.cc (revision 195684) |
+++ webkit/chromeos/fileapi/memory_file_util.cc (working copy) |
@@ -1,587 +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 "base/bind.h" |
-#include "base/memory/weak_ptr.h" |
-#include "base/message_loop.h" |
-#include "webkit/chromeos/fileapi/memory_file_util.h" |
- |
-namespace { |
-const int kDefaultReadDirectoryBufferSize = 100; |
-} // namespace |
- |
-namespace fileapi { |
- |
-// In-memory implementation of AsyncFileStream. |
-class MemoryFileUtilAsyncFileStream : public AsyncFileStream { |
- public: |
- // |file_entry| is owned by MemoryFileUtil. |
- MemoryFileUtilAsyncFileStream(MemoryFileUtil::FileEntry* file_entry, |
- int flags) |
- : file_entry_(file_entry), |
- flags_(flags), |
- offset_(0), |
- weak_ptr_factory_(ALLOW_THIS_IN_INITIALIZER_LIST(this)) { |
- } |
- |
- // AsyncFileStream override. |
- virtual void Read(char* buffer, |
- int64 length, |
- const ReadWriteCallback& callback) OVERRIDE { |
- MessageLoop::current()->PostTask( |
- FROM_HERE, |
- base::Bind(&MemoryFileUtilAsyncFileStream::DoRead, |
- weak_ptr_factory_.GetWeakPtr(), |
- buffer, length, callback)); |
- } |
- |
- // AsyncFileStream override. |
- virtual void Write(const char* buffer, |
- int64 length, |
- const ReadWriteCallback& callback) OVERRIDE { |
- MessageLoop::current()->PostTask( |
- FROM_HERE, |
- base::Bind(&MemoryFileUtilAsyncFileStream::DoWrite, |
- weak_ptr_factory_.GetWeakPtr(), |
- buffer, length, callback)); |
- } |
- |
- // AsyncFileStream override. |
- virtual void Seek(int64 offset, |
- const SeekCallback& callback) OVERRIDE { |
- MessageLoop::current()->PostTask( |
- FROM_HERE, |
- base::Bind(&MemoryFileUtilAsyncFileStream::DoSeek, |
- weak_ptr_factory_.GetWeakPtr(), |
- offset, callback)); |
- } |
- |
- private: |
- // Callback used for Read(). |
- void DoRead(char* buffer, |
- int64 length, |
- const ReadWriteCallback& callback) { |
- |
- if ((flags_ & base::PLATFORM_FILE_READ) == 0) { |
- callback.Run(base::PLATFORM_FILE_ERROR_INVALID_OPERATION, 0); |
- return; |
- } |
- |
- // Shorten the length so the read does not overrun. |
- length = std::min(length, file_size() - offset_); |
- |
- const std::string& contents = file_entry_->contents; |
- std::copy(contents.begin() + offset_, |
- contents.begin() + offset_ + length, |
- buffer); |
- offset_ += length; |
- |
- callback.Run(base::PLATFORM_FILE_OK, length); |
- } |
- |
- // Callback used for Write(). |
- void DoWrite(const char* buffer, |
- int64 length, |
- const ReadWriteCallback& callback) { |
- if ((flags_ & base::PLATFORM_FILE_WRITE) == 0) { |
- callback.Run(base::PLATFORM_FILE_ERROR_INVALID_OPERATION, 0); |
- return; |
- } |
- |
- // Extend the contents if needed. |
- std::string* contents = &file_entry_->contents; |
- if (offset_ + length > file_size()) |
- contents->resize(offset_ + length, 0); // Fill with 0. |
- |
- std::copy(buffer, buffer + length, |
- contents->begin() + offset_); |
- file_entry_->last_modified = base::Time::Now(); |
- offset_ += length; |
- |
- callback.Run(base::PLATFORM_FILE_OK, length); |
- } |
- |
- // Callback used for Seek(). |
- void DoSeek(int64 offset, |
- const SeekCallback& callback) { |
- if (offset > file_size()) { |
- // Unlike lseek(2), we don't allow an offset larger than the file |
- // size for this file implementation. |
- callback.Run(base::PLATFORM_FILE_ERROR_INVALID_OPERATION); |
- return; |
- } |
- |
- offset_ = offset; |
- callback.Run(base::PLATFORM_FILE_OK); |
- } |
- |
- // Returns the file size as int64. |
- int64 file_size() const { |
- return static_cast<int64>(file_entry_->contents.size()); |
- } |
- |
- MemoryFileUtil::FileEntry* file_entry_; |
- const int flags_; |
- int64 offset_; |
- base::WeakPtrFactory<MemoryFileUtilAsyncFileStream> weak_ptr_factory_; |
-}; |
- |
-MemoryFileUtil::FileEntry::FileEntry() |
- : is_directory(false) { |
-} |
- |
-MemoryFileUtil::FileEntry::~FileEntry() { |
-} |
- |
-MemoryFileUtil::MemoryFileUtil(const base::FilePath& root_path) |
- : read_directory_buffer_size_(kDefaultReadDirectoryBufferSize) { |
- FileEntry root; |
- root.is_directory = true; |
- root.last_modified = base::Time::Now(); |
- |
- files_[root_path] = root; |
-} |
- |
-MemoryFileUtil::~MemoryFileUtil() { |
-} |
- |
-// Depending on the flags value the flow of file opening will be one of |
-// the following: |
-// |
-// PLATFORM_FILE_OPEN: |
-// - GetFileInfo |
-// - DidGetFileInfoForOpen |
-// - OpenVerifiedFile |
-// |
-// PLATFORM_FILE_CREATE: |
-// - Create |
-// - DidCreateOrTruncateForOpen |
-// - OpenVerifiedFile |
-// |
-// PLATFORM_FILE_OPEN_ALWAYS: |
-// - GetFileInfo |
-// - DidGetFileInfoForOpen |
-// - OpenVerifiedFile OR Create |
-// DidCreateOrTruncateForOpen |
-// OpenVerifiedFile |
-// |
-// PLATFORM_FILE_CREATE_ALWAYS: |
-// - Truncate |
-// - OpenTruncatedFileOrCreate |
-// - OpenVerifiedFile OR Create |
-// DidCreateOrTruncateForOpen |
-// OpenVerifiedFile |
-// |
-// PLATFORM_FILE_OPEN_TRUNCATED: |
-// - Truncate |
-// - DidCreateOrTruncateForOpen |
-// - OpenVerifiedFile |
-// |
-void MemoryFileUtil::Open( |
- const base::FilePath& file_path, |
- int flags, |
- const OpenCallback& callback) { |
- int create_flag = flags & (base::PLATFORM_FILE_OPEN | |
- base::PLATFORM_FILE_CREATE | |
- base::PLATFORM_FILE_OPEN_ALWAYS | |
- base::PLATFORM_FILE_CREATE_ALWAYS | |
- base::PLATFORM_FILE_OPEN_TRUNCATED); |
- switch (create_flag) { |
- case base::PLATFORM_FILE_OPEN: |
- case base::PLATFORM_FILE_OPEN_ALWAYS: |
- GetFileInfo( |
- file_path, |
- base::Bind(&MemoryFileUtil::DidGetFileInfoForOpen, |
- base::Unretained(this), file_path, flags, callback)); |
- |
- break; |
- |
- case base::PLATFORM_FILE_CREATE: |
- Create( |
- file_path, |
- base::Bind(&MemoryFileUtil::DidCreateOrTruncateForOpen, |
- base::Unretained(this), file_path, flags, 0, callback)); |
- break; |
- |
- case base::PLATFORM_FILE_CREATE_ALWAYS: |
- Truncate( |
- file_path, |
- 0, |
- base::Bind(&MemoryFileUtil::OpenTruncatedFileOrCreate, |
- base::Unretained(this), file_path, flags, callback)); |
- break; |
- |
- case base::PLATFORM_FILE_OPEN_TRUNCATED: |
- Truncate( |
- file_path, |
- 0, |
- base::Bind(&MemoryFileUtil::DidCreateOrTruncateForOpen, |
- base::Unretained(this), file_path, flags, 0, callback)); |
- break; |
- |
- default: |
- MessageLoop::current()->PostTask( |
- FROM_HERE, |
- base::Bind(callback, |
- base::PLATFORM_FILE_ERROR_INVALID_OPERATION, |
- static_cast<AsyncFileStream*>(NULL))); |
- } |
-} |
- |
-void MemoryFileUtil::GetFileInfo( |
- const base::FilePath& file_path, |
- const GetFileInfoCallback& callback) { |
- MessageLoop::current()->PostTask( |
- FROM_HERE, |
- base::Bind(&MemoryFileUtil::DoGetFileInfo, base::Unretained(this), |
- file_path.StripTrailingSeparators(), callback)); |
-} |
- |
-void MemoryFileUtil::Create( |
- const base::FilePath& file_path, |
- const StatusCallback& callback) { |
- MessageLoop::current()->PostTask( |
- FROM_HERE, |
- base::Bind(&MemoryFileUtil::DoCreate, base::Unretained(this), |
- file_path.StripTrailingSeparators(), false, callback)); |
-} |
- |
-void MemoryFileUtil::Truncate( |
- const base::FilePath& file_path, |
- int64 length, |
- const StatusCallback& callback) { |
- MessageLoop::current()->PostTask( |
- FROM_HERE, |
- base::Bind(&MemoryFileUtil::DoTruncate, base::Unretained(this), |
- file_path.StripTrailingSeparators(), length, callback)); |
-} |
- |
-void MemoryFileUtil::Touch( |
- const base::FilePath& file_path, |
- const base::Time& last_access_time, |
- const base::Time& last_modified_time, |
- const StatusCallback& callback) { |
- MessageLoop::current()->PostTask( |
- FROM_HERE, |
- base::Bind(&MemoryFileUtil::DoTouch, base::Unretained(this), |
- file_path.StripTrailingSeparators(), |
- last_modified_time, callback)); |
-} |
- |
-void MemoryFileUtil::Remove( |
- const base::FilePath& file_path, |
- bool recursive, |
- const StatusCallback& callback) { |
- if (recursive) { |
- MessageLoop::current()->PostTask( |
- FROM_HERE, |
- base::Bind(&MemoryFileUtil::DoRemoveRecursive, |
- base::Unretained(this), file_path.StripTrailingSeparators(), |
- callback)); |
- } else { |
- MessageLoop::current()->PostTask( |
- FROM_HERE, |
- base::Bind(&MemoryFileUtil::DoRemoveSingleFile, |
- base::Unretained(this), file_path.StripTrailingSeparators(), |
- callback)); |
- } |
-} |
- |
-void MemoryFileUtil::CreateDirectory( |
- const base::FilePath& dir_path, |
- const StatusCallback& callback) { |
- MessageLoop::current()->PostTask( |
- FROM_HERE, |
- base::Bind(&MemoryFileUtil::DoCreate, |
- base::Unretained(this), dir_path.StripTrailingSeparators(), |
- true, callback)); |
-} |
- |
-void MemoryFileUtil::ReadDirectory( |
- const base::FilePath& dir_path, |
- const ReadDirectoryCallback& callback) { |
- MessageLoop::current()->PostTask( |
- FROM_HERE, |
- base::Bind(&MemoryFileUtil::DoReadDirectory, |
- base::Unretained(this), dir_path.StripTrailingSeparators(), |
- base::FilePath(), callback)); |
-} |
- |
-void MemoryFileUtil::DoGetFileInfo(const base::FilePath& file_path, |
- const GetFileInfoCallback& callback) { |
- base::PlatformFileInfo file_info; |
- |
- FileIterator file_it = files_.find(file_path); |
- |
- if (file_it == files_.end()) { |
- callback.Run(base::PLATFORM_FILE_ERROR_NOT_FOUND, file_info); |
- return; |
- } |
- const FileEntry& file_entry = file_it->second; |
- |
- file_info.size = file_entry.contents.size(); |
- file_info.is_directory = file_entry.is_directory; |
- file_info.is_symbolic_link = false; |
- |
- // In this file system implementation we store only one datetime. Many |
- // popular file systems do the same. |
- file_info.last_modified = file_entry.last_modified; |
- file_info.last_accessed = file_entry.last_modified; |
- file_info.creation_time = file_entry.last_modified; |
- |
- callback.Run(base::PLATFORM_FILE_OK, file_info); |
-} |
- |
-void MemoryFileUtil::DoCreate( |
- const base::FilePath& file_path, |
- bool is_directory, |
- const StatusCallback& callback) { |
- if (FileExists(file_path)) { |
- callback.Run(base::PLATFORM_FILE_ERROR_EXISTS); |
- return; |
- } |
- |
- if (!IsDirectory(file_path.DirName())) { |
- callback.Run(base::PLATFORM_FILE_ERROR_FAILED); |
- return; |
- } |
- |
- FileEntry file; |
- file.is_directory = is_directory; |
- file.last_modified = base::Time::Now(); |
- |
- files_[file_path] = file; |
- callback.Run(base::PLATFORM_FILE_OK); |
-} |
- |
-void MemoryFileUtil::DoTruncate( |
- const base::FilePath& file_path, |
- int64 length, |
- const StatusCallback& callback) { |
- FileIterator file_it = files_.find(file_path); |
- if (file_it == files_.end()) { |
- callback.Run(base::PLATFORM_FILE_ERROR_NOT_FOUND); |
- return; |
- } |
- |
- FileEntry& file = file_it->second; |
- |
- // Fill the extended part with 0 if |length| is larger than the original |
- // contents size. |
- file.contents.resize(length, 0); |
- callback.Run(base::PLATFORM_FILE_OK); |
-} |
- |
-void MemoryFileUtil::DoTouch( |
- const base::FilePath& file_path, |
- const base::Time& last_modified_time, |
- const StatusCallback& callback) { |
- FileIterator file_it = files_.find(file_path); |
- if (file_it == files_.end()) { |
- callback.Run(base::PLATFORM_FILE_ERROR_NOT_FOUND); |
- return; |
- } |
- |
- FileEntry& file = file_it->second; |
- |
- file.last_modified = last_modified_time; |
- callback.Run(base::PLATFORM_FILE_OK); |
-} |
- |
-void MemoryFileUtil::DoRemoveSingleFile( |
- const base::FilePath& file_path, |
- const StatusCallback& callback) { |
- FileIterator file_it = files_.find(file_path); |
- if (file_it == files_.end()) { |
- callback.Run(base::PLATFORM_FILE_ERROR_NOT_FOUND); |
- return; |
- } |
- |
- FileEntry& file = file_it->second; |
- if (file.is_directory) { |
- // Check if the directory is empty. This can be done by checking if |
- // the next file is present under the directory. Note that |files_| is |
- // a map hence the file names are sorted by names. |
- FileIterator tmp_it = file_it; |
- ++tmp_it; |
- if (tmp_it != files_.end() && file_path.IsParent(tmp_it->first)) { |
- callback.Run(base::PLATFORM_FILE_ERROR_NOT_A_FILE); |
- return; |
- } |
- } |
- |
- files_.erase(file_it); |
- callback.Run(base::PLATFORM_FILE_OK); |
-} |
- |
-void MemoryFileUtil::DoRemoveRecursive( |
- const base::FilePath& file_path, |
- const StatusCallback& callback) { |
- FileIterator file_it = files_.find(file_path); |
- if (file_it == files_.end()) { |
- callback.Run(base::PLATFORM_FILE_ERROR_NOT_FOUND); |
- return; |
- } |
- |
- FileEntry& file = file_it->second; |
- if (!file.is_directory) { |
- files_.erase(file_it); |
- callback.Run(base::PLATFORM_FILE_OK); |
- return; |
- } |
- |
- // Remove the directory itself. |
- files_.erase(file_it++); |
- // Remove files under the directory. |
- while (file_it != files_.end()) { |
- if (file_path.IsParent(file_it->first)) { |
- files_.erase(file_it++); |
- } else { |
- break; |
- } |
- } |
- callback.Run(base::PLATFORM_FILE_OK); |
-} |
- |
-void MemoryFileUtil::DoReadDirectory( |
- const base::FilePath& dir_path, |
- const base::FilePath& in_from, |
- const ReadDirectoryCallback& callback) { |
- base::FilePath from = in_from; |
- read_directory_buffer_.clear(); |
- |
- if (!FileExists(dir_path)) { |
- callback.Run(base::PLATFORM_FILE_ERROR_NOT_FOUND, |
- read_directory_buffer_, true); |
- return; |
- } |
- |
- if (!IsDirectory(dir_path)) { |
- callback.Run(base::PLATFORM_FILE_ERROR_NOT_A_DIRECTORY, |
- read_directory_buffer_, true); |
- return; |
- } |
- |
- if (from.empty()) |
- from = dir_path; |
- |
- bool completed = true; |
- |
- // Here we iterate over all paths in files_ starting with the prefix |from|. |
- // It is not very efficient in case of a deep tree with many files in |
- // subdirectories. If ever we'll need efficiency from this implementation of |
- // FS, this should be changed. |
- for (ConstFileIterator it = files_.lower_bound(from); |
- it != files_.end(); |
- ++it) { |
- if (dir_path == it->first) // Skip the directory itself. |
- continue; |
- if (!dir_path.IsParent(it->first)) // Not in the directory. |
- break; |
- if (it->first.DirName() != dir_path) // a file in subdirectory |
- continue; |
- |
- if (read_directory_buffer_.size() == read_directory_buffer_size_) { |
- from = it->first; |
- completed = false; |
- break; |
- } |
- |
- const FileEntry& file = it->second; |
- DirectoryEntry entry; |
- entry.name = it->first.BaseName().value(); |
- entry.is_directory = file.is_directory; |
- entry.size = file.contents.size(); |
- entry.last_modified_time = file.last_modified; |
- |
- read_directory_buffer_.push_back(entry); |
- } |
- |
- callback.Run(base::PLATFORM_FILE_OK, read_directory_buffer_, completed); |
- |
- if (!completed) { |
- MessageLoop::current()->PostTask( |
- FROM_HERE, |
- base::Bind(&MemoryFileUtil::DoReadDirectory, |
- base::Unretained(this), dir_path, |
- from, callback)); |
- } |
-} |
- |
-void MemoryFileUtil::OpenVerifiedFile( |
- const base::FilePath& file_path, |
- int flags, |
- const OpenCallback& callback) { |
- FileIterator file_it = files_.find(file_path); |
- // The existence of the file is guranteed here. |
- DCHECK(file_it != files_.end()); |
- |
- FileEntry* file_entry = &file_it->second; |
- callback.Run(base::PLATFORM_FILE_OK, |
- new MemoryFileUtilAsyncFileStream(file_entry, flags)); |
-} |
- |
-void MemoryFileUtil::DidGetFileInfoForOpen( |
- const base::FilePath& file_path, |
- int flags, |
- const OpenCallback& callback, |
- PlatformFileError get_info_result, |
- const base::PlatformFileInfo& file_info) { |
- if (get_info_result == base::PLATFORM_FILE_OK && file_info.is_directory) { |
- callback.Run(base::PLATFORM_FILE_ERROR_NOT_A_FILE, NULL); |
- return; |
- } |
- |
- if (get_info_result == base::PLATFORM_FILE_OK) { |
- OpenVerifiedFile(file_path, flags, callback); |
- return; |
- } |
- |
- if (get_info_result == base::PLATFORM_FILE_ERROR_NOT_FOUND && |
- flags & base::PLATFORM_FILE_CREATE_ALWAYS) { |
- Create(file_path, |
- base::Bind(&MemoryFileUtil::DidCreateOrTruncateForOpen, |
- base::Unretained(this), file_path, flags, 0, callback)); |
- return; |
- } |
- |
- callback.Run(get_info_result, NULL); |
-} |
- |
-void MemoryFileUtil::OpenTruncatedFileOrCreate( |
- const base::FilePath& file_path, |
- int flags, |
- const OpenCallback& callback, |
- PlatformFileError result) { |
- if (result == base::PLATFORM_FILE_OK) { |
- OpenVerifiedFile(file_path, flags, callback); |
- return; |
- } |
- |
- if (result == base::PLATFORM_FILE_ERROR_NOT_FOUND) { |
- Create( |
- file_path, |
- base::Bind(&MemoryFileUtil::DidCreateOrTruncateForOpen, |
- base::Unretained(this), file_path, flags, 0, callback)); |
- return; |
- } |
- |
- callback.Run(result, NULL); |
-} |
- |
-void MemoryFileUtil::DidCreateOrTruncateForOpen( |
- const base::FilePath& file_path, |
- int flags, |
- int64 size, |
- const OpenCallback& callback, |
- PlatformFileError result) { |
- if (result != base::PLATFORM_FILE_OK) { |
- callback.Run(result, NULL); |
- return; |
- } |
- |
- OpenVerifiedFile(file_path, flags, callback); |
-} |
- |
-} // namespace fileapi |