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

Unified Diff: chrome/browser/chromeos/drive/file_cache.cc

Issue 16628003: drive: Remove FileCacheObserver::OnCacheCommitted (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Fix PinAndUnpin Created 7 years, 6 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 | « chrome/browser/chromeos/drive/file_cache.h ('k') | chrome/browser/chromeos/drive/file_cache_observer.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: chrome/browser/chromeos/drive/file_cache.cc
diff --git a/chrome/browser/chromeos/drive/file_cache.cc b/chrome/browser/chromeos/drive/file_cache.cc
index c04d0dad8cbdaf463fd3624dc8b2b16f1738b272..2ddf0e321a8f9b7428cdc5b8adf0896ed1d12e4e 100644
--- a/chrome/browser/chromeos/drive/file_cache.cc
+++ b/chrome/browser/chromeos/drive/file_cache.cc
@@ -485,28 +485,7 @@ FileError FileCache::Store(const std::string& resource_id,
const base::FilePath& source_path,
FileOperationType file_operation_type) {
AssertOnSequencedWorkerPool();
- return StoreInternal(resource_id, md5, source_path, file_operation_type,
- CACHED_FILE_FROM_SERVER);
-}
-
-void FileCache::StoreLocallyModifiedOnUIThread(
- const std::string& resource_id,
- const std::string& md5,
- const base::FilePath& source_path,
- FileOperationType file_operation_type,
- const FileOperationCallback& callback) {
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
- DCHECK(!callback.is_null());
-
- base::PostTaskAndReplyWithResult(
- blocking_task_runner_,
- FROM_HERE,
- base::Bind(&FileCache::StoreInternal,
- base::Unretained(this),
- resource_id, md5, source_path, file_operation_type,
- CACHED_FILE_LOCALLY_MODIFIED),
- base::Bind(&FileCache::OnCommitDirty,
- weak_ptr_factory_.GetWeakPtr(), resource_id, callback));
+ return StoreInternal(resource_id, md5, source_path, file_operation_type);
}
void FileCache::PinOnUIThread(const std::string& resource_id,
@@ -733,21 +712,6 @@ FileError FileCache::MarkDirty(const std::string& resource_id,
return FILE_ERROR_OK;
}
-void FileCache::CommitDirtyOnUIThread(const std::string& resource_id,
- const std::string& md5,
- const FileOperationCallback& callback) {
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
- DCHECK(!callback.is_null());
-
- // TODO(hashimoto): Move logic around OnCommitDirty to FileSystem and remove
- // this method.
- base::MessageLoopProxy::current()->PostTask(
- FROM_HERE,
- base::Bind(&FileCache::OnCommitDirty,
- weak_ptr_factory_.GetWeakPtr(), resource_id, callback,
- FILE_ERROR_OK));
-}
-
FileError FileCache::ClearDirty(const std::string& resource_id,
const std::string& md5) {
AssertOnSequencedWorkerPool();
@@ -942,8 +906,7 @@ void FileCache::DestroyOnBlockingPool() {
FileError FileCache::StoreInternal(const std::string& resource_id,
const std::string& md5,
const base::FilePath& source_path,
- FileOperationType file_operation_type,
- CachedFileOrigin origin) {
+ FileOperationType file_operation_type) {
AssertOnSequencedWorkerPool();
int64 file_size = 0;
@@ -960,25 +923,21 @@ FileError FileCache::StoreInternal(const std::string& resource_id,
GetCacheEntry(resource_id, std::string(), &cache_entry);
CacheSubDirectoryType sub_dir_type = CACHE_TYPE_TMP;
- if (origin == CACHED_FILE_FROM_SERVER) {
- // If file is dirty or mounted, return error.
- if (cache_entry.is_dirty() || cache_entry.is_mounted()) {
- LOG(WARNING) << "Can't store a file to replace a "
- << (cache_entry.is_dirty() ? "dirty" : "mounted")
- << " file: res_id=" << resource_id
- << ", md5=" << md5;
- return FILE_ERROR_IN_USE;
- }
+ // If file is dirty or mounted, return error.
+ if (cache_entry.is_dirty() || cache_entry.is_mounted()) {
+ LOG(WARNING) << "Can't store a file to replace a "
+ << (cache_entry.is_dirty() ? "dirty" : "mounted")
+ << " file: res_id=" << resource_id
+ << ", md5=" << md5;
+ return FILE_ERROR_IN_USE;
+ }
- // If file was previously pinned, store it in persistent dir.
- if (cache_entry.is_pinned())
- sub_dir_type = CACHE_TYPE_PERSISTENT;
- } else {
+ // If file was previously pinned, store it in persistent dir.
+ if (cache_entry.is_pinned())
sub_dir_type = CACHE_TYPE_PERSISTENT;
- }
base::FilePath dest_path = GetCacheFilePath(resource_id, md5, sub_dir_type,
- origin);
+ CACHED_FILE_FROM_SERVER);
bool success = false;
switch (file_operation_type) {
case FILE_OPERATION_MOVE:
@@ -1018,7 +977,7 @@ FileError FileCache::StoreInternal(const std::string& resource_id,
cache_entry.set_md5(md5);
cache_entry.set_is_present(true);
cache_entry.set_is_persistent(sub_dir_type == CACHE_TYPE_PERSISTENT);
- cache_entry.set_is_dirty(origin == CACHED_FILE_LOCALLY_MODIFIED);
+ cache_entry.set_is_dirty(false);
metadata_->AddOrUpdateCacheEntry(resource_id, cache_entry);
}
@@ -1167,20 +1126,6 @@ void FileCache::OnUnpinned(const std::string& resource_id,
base::Unretained(this), 0));
}
-void FileCache::OnCommitDirty(const std::string& resource_id,
- const FileOperationCallback& callback,
- FileError error) {
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
- DCHECK(!callback.is_null());
-
- callback.Run(error);
-
- if (error == FILE_ERROR_OK)
- FOR_EACH_OBSERVER(FileCacheObserver,
- observers_,
- OnCacheCommitted(resource_id));
-}
-
bool FileCache::HasEnoughSpaceFor(int64 num_bytes,
const base::FilePath& path) {
int64 free_space = 0;
« no previous file with comments | « chrome/browser/chromeos/drive/file_cache.h ('k') | chrome/browser/chromeos/drive/file_cache_observer.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698