Index: chrome/browser/sync_file_system/local/canned_syncable_file_system.cc |
diff --git a/chrome/browser/sync_file_system/local/canned_syncable_file_system.cc b/chrome/browser/sync_file_system/local/canned_syncable_file_system.cc |
index 868fa43d7ff8163f7814426cf751803cac464edf..6deee21f12175772d9e1b4b0f9e397a00f86acdd 100644 |
--- a/chrome/browser/sync_file_system/local/canned_syncable_file_system.cc |
+++ b/chrome/browser/sync_file_system/local/canned_syncable_file_system.cc |
@@ -235,7 +235,7 @@ void CannedSyncableFileSystem::SetUp(QuotaMode quota_mode) { |
if (quota_mode == QUOTA_ENABLED) { |
quota_manager_ = new QuotaManager(false /* is_incognito */, |
data_dir_.path(), |
- io_task_runner_, |
+ io_task_runner_.get(), |
base::ThreadTaskRunnerHandle::Get().get(), |
storage_policy.get()); |
} |
@@ -251,11 +251,11 @@ void CannedSyncableFileSystem::SetUp(QuotaMode quota_mode) { |
additional_backends.push_back(SyncFileSystemBackend::CreateForTesting()); |
file_system_context_ = new FileSystemContext( |
- io_task_runner_, |
- file_task_runner_, |
+ io_task_runner_.get(), |
+ file_task_runner_.get(), |
storage::ExternalMountPoints::CreateRefCounted().get(), |
storage_policy.get(), |
- quota_manager_ ? quota_manager_->proxy() : NULL, |
+ quota_manager_.get() ? quota_manager_->proxy() : NULL, |
additional_backends.Pass(), |
std::vector<storage::URLRequestAutoMountHandler>(), |
data_dir_.path(), |
@@ -269,8 +269,8 @@ void CannedSyncableFileSystem::TearDown() { |
file_system_context_ = NULL; |
// Make sure we give some more time to finish tasks on other threads. |
- EnsureLastTaskRuns(io_task_runner_); |
- EnsureLastTaskRuns(file_task_runner_); |
+ EnsureLastTaskRuns(io_task_runner_.get()); |
+ EnsureLastTaskRuns(file_task_runner_.get()); |
} |
FileSystemURL CannedSyncableFileSystem::URL(const std::string& path) const { |
@@ -298,7 +298,7 @@ File::Error CannedSyncableFileSystem::OpenFileSystem() { |
if (backend()->sync_context()) { |
// Register 'this' as a sync status observer. |
RunOnThread( |
- io_task_runner_, |
+ io_task_runner_.get(), |
FROM_HERE, |
base::Bind(&CannedSyncableFileSystem::InitializeSyncStatusObserver, |
base::Unretained(this))); |
@@ -321,8 +321,8 @@ SyncStatusCode CannedSyncableFileSystem::MaybeInitializeFileSystemContext( |
DCHECK(sync_context); |
base::RunLoop run_loop; |
sync_status_ = sync_file_system::SYNC_STATUS_UNKNOWN; |
- VerifySameTaskRunner(io_task_runner_, |
- sync_context->io_task_runner_); |
+ VerifySameTaskRunner(io_task_runner_.get(), |
+ sync_context->io_task_runner_.get()); |
sync_context->MaybeInitializeFileSystemContext( |
origin_, |
file_system_context_.get(), |
@@ -336,7 +336,7 @@ SyncStatusCode CannedSyncableFileSystem::MaybeInitializeFileSystemContext( |
File::Error CannedSyncableFileSystem::CreateDirectory( |
const FileSystemURL& url) { |
return RunOnThread<File::Error>( |
- io_task_runner_, |
+ io_task_runner_.get(), |
FROM_HERE, |
base::Bind(&CannedSyncableFileSystem::DoCreateDirectory, |
base::Unretained(this), |
@@ -345,7 +345,7 @@ File::Error CannedSyncableFileSystem::CreateDirectory( |
File::Error CannedSyncableFileSystem::CreateFile(const FileSystemURL& url) { |
return RunOnThread<File::Error>( |
- io_task_runner_, |
+ io_task_runner_.get(), |
FROM_HERE, |
base::Bind(&CannedSyncableFileSystem::DoCreateFile, |
base::Unretained(this), |
@@ -354,30 +354,28 @@ File::Error CannedSyncableFileSystem::CreateFile(const FileSystemURL& url) { |
File::Error CannedSyncableFileSystem::Copy( |
const FileSystemURL& src_url, const FileSystemURL& dest_url) { |
- return RunOnThread<File::Error>( |
- io_task_runner_, |
- FROM_HERE, |
- base::Bind(&CannedSyncableFileSystem::DoCopy, |
- base::Unretained(this), |
- src_url, |
- dest_url)); |
+ return RunOnThread<File::Error>(io_task_runner_.get(), |
+ FROM_HERE, |
+ base::Bind(&CannedSyncableFileSystem::DoCopy, |
+ base::Unretained(this), |
+ src_url, |
+ dest_url)); |
} |
File::Error CannedSyncableFileSystem::Move( |
const FileSystemURL& src_url, const FileSystemURL& dest_url) { |
- return RunOnThread<File::Error>( |
- io_task_runner_, |
- FROM_HERE, |
- base::Bind(&CannedSyncableFileSystem::DoMove, |
- base::Unretained(this), |
- src_url, |
- dest_url)); |
+ return RunOnThread<File::Error>(io_task_runner_.get(), |
+ FROM_HERE, |
+ base::Bind(&CannedSyncableFileSystem::DoMove, |
+ base::Unretained(this), |
+ src_url, |
+ dest_url)); |
} |
File::Error CannedSyncableFileSystem::TruncateFile( |
const FileSystemURL& url, int64 size) { |
return RunOnThread<File::Error>( |
- io_task_runner_, |
+ io_task_runner_.get(), |
FROM_HERE, |
base::Bind(&CannedSyncableFileSystem::DoTruncateFile, |
base::Unretained(this), |
@@ -390,7 +388,7 @@ File::Error CannedSyncableFileSystem::TouchFile( |
const base::Time& last_access_time, |
const base::Time& last_modified_time) { |
return RunOnThread<File::Error>( |
- io_task_runner_, |
+ io_task_runner_.get(), |
FROM_HERE, |
base::Bind(&CannedSyncableFileSystem::DoTouchFile, |
base::Unretained(this), |
@@ -402,7 +400,7 @@ File::Error CannedSyncableFileSystem::TouchFile( |
File::Error CannedSyncableFileSystem::Remove( |
const FileSystemURL& url, bool recursive) { |
return RunOnThread<File::Error>( |
- io_task_runner_, |
+ io_task_runner_.get(), |
FROM_HERE, |
base::Bind(&CannedSyncableFileSystem::DoRemove, |
base::Unretained(this), |
@@ -413,7 +411,7 @@ File::Error CannedSyncableFileSystem::Remove( |
File::Error CannedSyncableFileSystem::FileExists( |
const FileSystemURL& url) { |
return RunOnThread<File::Error>( |
- io_task_runner_, |
+ io_task_runner_.get(), |
FROM_HERE, |
base::Bind(&CannedSyncableFileSystem::DoFileExists, |
base::Unretained(this), |
@@ -423,7 +421,7 @@ File::Error CannedSyncableFileSystem::FileExists( |
File::Error CannedSyncableFileSystem::DirectoryExists( |
const FileSystemURL& url) { |
return RunOnThread<File::Error>( |
- io_task_runner_, |
+ io_task_runner_.get(), |
FROM_HERE, |
base::Bind(&CannedSyncableFileSystem::DoDirectoryExists, |
base::Unretained(this), |
@@ -434,7 +432,7 @@ File::Error CannedSyncableFileSystem::VerifyFile( |
const FileSystemURL& url, |
const std::string& expected_data) { |
return RunOnThread<File::Error>( |
- io_task_runner_, |
+ io_task_runner_.get(), |
FROM_HERE, |
base::Bind(&CannedSyncableFileSystem::DoVerifyFile, |
base::Unretained(this), |
@@ -447,7 +445,7 @@ File::Error CannedSyncableFileSystem::GetMetadataAndPlatformPath( |
base::File::Info* info, |
base::FilePath* platform_path) { |
return RunOnThread<File::Error>( |
- io_task_runner_, |
+ io_task_runner_.get(), |
FROM_HERE, |
base::Bind(&CannedSyncableFileSystem::DoGetMetadataAndPlatformPath, |
base::Unretained(this), |
@@ -460,19 +458,19 @@ File::Error CannedSyncableFileSystem::ReadDirectory( |
const storage::FileSystemURL& url, |
FileEntryList* entries) { |
return RunOnThread<File::Error>( |
- io_task_runner_, |
+ io_task_runner_.get(), |
FROM_HERE, |
base::Bind(&CannedSyncableFileSystem::DoReadDirectory, |
- base::Unretained(this), |
- url, |
- entries)); |
+ base::Unretained(this), |
+ url, |
+ entries)); |
} |
int64 CannedSyncableFileSystem::Write( |
net::URLRequestContext* url_request_context, |
const FileSystemURL& url, |
scoped_ptr<storage::BlobDataHandle> blob_data_handle) { |
- return RunOnThread<int64>(io_task_runner_, |
+ return RunOnThread<int64>(io_task_runner_.get(), |
FROM_HERE, |
base::Bind(&CannedSyncableFileSystem::DoWrite, |
base::Unretained(this), |
@@ -483,7 +481,7 @@ int64 CannedSyncableFileSystem::Write( |
int64 CannedSyncableFileSystem::WriteString( |
const FileSystemURL& url, const std::string& data) { |
- return RunOnThread<int64>(io_task_runner_, |
+ return RunOnThread<int64>(io_task_runner_.get(), |
FROM_HERE, |
base::Bind(&CannedSyncableFileSystem::DoWriteString, |
base::Unretained(this), |
@@ -494,7 +492,7 @@ int64 CannedSyncableFileSystem::WriteString( |
File::Error CannedSyncableFileSystem::DeleteFileSystem() { |
EXPECT_TRUE(is_filesystem_set_up_); |
return RunOnThread<File::Error>( |
- io_task_runner_, |
+ io_task_runner_.get(), |
FROM_HERE, |
base::Bind(&FileSystemContext::DeleteFileSystem, |
file_system_context_, |
@@ -506,7 +504,7 @@ storage::QuotaStatusCode CannedSyncableFileSystem::GetUsageAndQuota( |
int64* usage, |
int64* quota) { |
return RunOnThread<storage::QuotaStatusCode>( |
- io_task_runner_, |
+ io_task_runner_.get(), |
FROM_HERE, |
base::Bind(&CannedSyncableFileSystem::DoGetUsageAndQuota, |
base::Unretained(this), |
@@ -516,37 +514,35 @@ storage::QuotaStatusCode CannedSyncableFileSystem::GetUsageAndQuota( |
void CannedSyncableFileSystem::GetChangedURLsInTracker( |
FileSystemURLSet* urls) { |
- RunOnThread( |
- file_task_runner_, |
- FROM_HERE, |
- base::Bind(&LocalFileChangeTracker::GetAllChangedURLs, |
- base::Unretained(backend()->change_tracker()), |
- urls)); |
+ RunOnThread(file_task_runner_.get(), |
+ FROM_HERE, |
+ base::Bind(&LocalFileChangeTracker::GetAllChangedURLs, |
+ base::Unretained(backend()->change_tracker()), |
+ urls)); |
} |
void CannedSyncableFileSystem::ClearChangeForURLInTracker( |
const FileSystemURL& url) { |
- RunOnThread( |
- file_task_runner_, |
- FROM_HERE, |
- base::Bind(&LocalFileChangeTracker::ClearChangesForURL, |
- base::Unretained(backend()->change_tracker()), |
- url)); |
+ RunOnThread(file_task_runner_.get(), |
+ FROM_HERE, |
+ base::Bind(&LocalFileChangeTracker::ClearChangesForURL, |
+ base::Unretained(backend()->change_tracker()), |
+ url)); |
} |
void CannedSyncableFileSystem::GetChangesForURLInTracker( |
const FileSystemURL& url, |
FileChangeList* changes) { |
- RunOnThread( |
- file_task_runner_, |
- FROM_HERE, |
- base::Bind(&LocalFileChangeTracker::GetChangesForURL, |
- base::Unretained(backend()->change_tracker()), |
- url, changes)); |
+ RunOnThread(file_task_runner_.get(), |
+ FROM_HERE, |
+ base::Bind(&LocalFileChangeTracker::GetChangesForURL, |
+ base::Unretained(backend()->change_tracker()), |
+ url, |
+ changes)); |
} |
SyncFileSystemBackend* CannedSyncableFileSystem::backend() { |
- return SyncFileSystemBackend::GetBackend(file_system_context_); |
+ return SyncFileSystemBackend::GetBackend(file_system_context_.get()); |
} |
FileSystemOperationRunner* CannedSyncableFileSystem::operation_runner() { |
@@ -723,7 +719,7 @@ void CannedSyncableFileSystem::DoGetUsageAndQuota( |
const storage::StatusCallback& callback) { |
EXPECT_TRUE(io_task_runner_->RunsTasksOnCurrentThread()); |
EXPECT_TRUE(is_filesystem_opened_); |
- DCHECK(quota_manager_); |
+ DCHECK(quota_manager_.get()); |
quota_manager_->GetUsageAndQuota( |
origin_, storage_type(), |
base::Bind(&DidGetUsageAndQuota, callback, usage, quota)); |