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

Unified Diff: chrome/browser/sync_file_system/local/syncable_file_system_operation.cc

Issue 2129083002: Explicitly check various sync_file_system classes live on the IO thread. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: fix tests, remove unneeded check Created 4 years, 5 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/sync_file_system/local/syncable_file_system_operation.h ('k') | no next file » | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: chrome/browser/sync_file_system/local/syncable_file_system_operation.cc
diff --git a/chrome/browser/sync_file_system/local/syncable_file_system_operation.cc b/chrome/browser/sync_file_system/local/syncable_file_system_operation.cc
index d078c10279c77439681208b7fefebb53af782b38..09e84bc452a1f686fab09f5bf2e843f97fcdc105 100644
--- a/chrome/browser/sync_file_system/local/syncable_file_system_operation.cc
+++ b/chrome/browser/sync_file_system/local/syncable_file_system_operation.cc
@@ -12,6 +12,7 @@
#include "chrome/browser/sync_file_system/local/sync_file_system_backend.h"
#include "chrome/browser/sync_file_system/local/syncable_file_operation_runner.h"
#include "chrome/browser/sync_file_system/syncable_file_system_util.h"
+#include "content/public/browser/browser_thread.h"
#include "net/url_request/url_request.h"
#include "storage/browser/blob/shareable_file_reference.h"
#include "storage/browser/fileapi/file_system_context.h"
@@ -68,7 +69,7 @@ class SyncableFileSystemOperation::QueueableTask
private:
base::WeakPtr<SyncableFileSystemOperation> operation_;
base::Closure task_;
- std::vector<FileSystemURL> target_paths_;
+ const std::vector<FileSystemURL> target_paths_;
DISALLOW_COPY_AND_ASSIGN(QueueableTask);
};
@@ -78,7 +79,7 @@ void SyncableFileSystemOperation::CreateFile(
const FileSystemURL& url,
bool exclusive,
const StatusCallback& callback) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
if (!operation_runner_.get()) {
callback.Run(base::File::FILE_ERROR_NOT_FOUND);
return;
@@ -99,7 +100,7 @@ void SyncableFileSystemOperation::CreateDirectory(
bool exclusive,
bool recursive,
const StatusCallback& callback) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
if (!operation_runner_.get()) {
callback.Run(base::File::FILE_ERROR_NOT_FOUND);
return;
@@ -122,7 +123,7 @@ void SyncableFileSystemOperation::Copy(
ErrorBehavior error_behavior,
const CopyProgressCallback& progress_callback,
const StatusCallback& callback) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
if (!operation_runner_.get()) {
callback.Run(base::File::FILE_ERROR_NOT_FOUND);
return;
@@ -143,7 +144,7 @@ void SyncableFileSystemOperation::Move(
const FileSystemURL& dest_url,
CopyOrMoveOption option,
const StatusCallback& callback) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
if (!operation_runner_.get()) {
callback.Run(base::File::FILE_ERROR_NOT_FOUND);
return;
@@ -163,14 +164,14 @@ void SyncableFileSystemOperation::Move(
void SyncableFileSystemOperation::DirectoryExists(
const FileSystemURL& url,
const StatusCallback& callback) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
impl_->DirectoryExists(url, callback);
}
void SyncableFileSystemOperation::FileExists(
const FileSystemURL& url,
const StatusCallback& callback) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
impl_->FileExists(url, callback);
}
@@ -178,14 +179,14 @@ void SyncableFileSystemOperation::GetMetadata(
const FileSystemURL& url,
int fields,
const GetMetadataCallback& callback) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
impl_->GetMetadata(url, fields, callback);
}
void SyncableFileSystemOperation::ReadDirectory(
const FileSystemURL& url,
const ReadDirectoryCallback& callback) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
// This is a read operation and there'd be no hard to let it go even if
// directory operation is disabled. (And we should allow this if it's made
// on the root directory)
@@ -195,7 +196,7 @@ void SyncableFileSystemOperation::ReadDirectory(
void SyncableFileSystemOperation::Remove(
const FileSystemURL& url, bool recursive,
const StatusCallback& callback) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
if (!operation_runner_.get()) {
callback.Run(base::File::FILE_ERROR_NOT_FOUND);
return;
@@ -216,7 +217,7 @@ void SyncableFileSystemOperation::Write(
std::unique_ptr<storage::FileWriterDelegate> writer_delegate,
std::unique_ptr<net::URLRequest> blob_request,
const WriteCallback& callback) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
if (!operation_runner_.get()) {
callback.Run(base::File::FILE_ERROR_NOT_FOUND, 0, true);
return;
@@ -236,7 +237,7 @@ void SyncableFileSystemOperation::Write(
void SyncableFileSystemOperation::Truncate(const FileSystemURL& url,
int64_t length,
const StatusCallback& callback) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
if (!operation_runner_.get()) {
callback.Run(base::File::FILE_ERROR_NOT_FOUND);
return;
@@ -257,7 +258,7 @@ void SyncableFileSystemOperation::TouchFile(
const base::Time& last_access_time,
const base::Time& last_modified_time,
const StatusCallback& callback) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
impl_->TouchFile(url, last_access_time, last_modified_time, callback);
}
@@ -270,14 +271,14 @@ void SyncableFileSystemOperation::OpenFile(
void SyncableFileSystemOperation::Cancel(
const StatusCallback& cancel_callback) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
impl_->Cancel(cancel_callback);
}
void SyncableFileSystemOperation::CreateSnapshotFile(
const FileSystemURL& path,
const SnapshotFileCallback& callback) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
impl_->CreateSnapshotFile(path, callback);
}
@@ -285,7 +286,7 @@ void SyncableFileSystemOperation::CopyInForeignFile(
const base::FilePath& src_local_disk_path,
const FileSystemURL& dest_url,
const StatusCallback& callback) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
if (!operation_runner_.get()) {
callback.Run(base::File::FILE_ERROR_NOT_FOUND);
return;
@@ -304,14 +305,14 @@ void SyncableFileSystemOperation::CopyInForeignFile(
void SyncableFileSystemOperation::RemoveFile(
const FileSystemURL& url,
const StatusCallback& callback) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
impl_->RemoveFile(url, callback);
}
void SyncableFileSystemOperation::RemoveDirectory(
const FileSystemURL& url,
const StatusCallback& callback) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
impl_->RemoveDirectory(url, callback);
}
@@ -321,7 +322,7 @@ void SyncableFileSystemOperation::CopyFileLocal(
CopyOrMoveOption option,
const CopyFileProgressCallback& progress_callback,
const StatusCallback& callback) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
impl_->CopyFileLocal(src_url, dest_url, option, progress_callback, callback);
}
@@ -330,7 +331,7 @@ void SyncableFileSystemOperation::MoveFileLocal(
const FileSystemURL& dest_url,
CopyOrMoveOption option,
const StatusCallback& callback) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
impl_->MoveFileLocal(src_url, dest_url, option, callback);
}
@@ -361,7 +362,7 @@ SyncableFileSystemOperation::SyncableFileSystemOperation(
}
void SyncableFileSystemOperation::DidFinish(base::File::Error status) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
DCHECK(!completion_callback_.is_null());
if (operation_runner_.get())
operation_runner_->OnOperationCompleted(target_paths_);
@@ -372,7 +373,7 @@ void SyncableFileSystemOperation::DidWrite(const WriteCallback& callback,
base::File::Error result,
int64_t bytes,
bool complete) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
if (!complete) {
callback.Run(result, bytes, complete);
return;
« no previous file with comments | « chrome/browser/sync_file_system/local/syncable_file_system_operation.h ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698