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

Unified Diff: components/sync/model_impl/attachments/attachment_service_impl.cc

Issue 2915453002: Deprecate NonThreadSafe in components/sync in favor of SequenceChecker. (Closed)
Patch Set: fix comment Created 3 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
Index: components/sync/model_impl/attachments/attachment_service_impl.cc
diff --git a/components/sync/model_impl/attachments/attachment_service_impl.cc b/components/sync/model_impl/attachments/attachment_service_impl.cc
index 695e8e41e380aa338b275e6ba66659589eabdc71..538c2b10e00f6e6d0866963a9839e260a2b24e73 100644
--- a/components/sync/model_impl/attachments/attachment_service_impl.cc
+++ b/components/sync/model_impl/attachments/attachment_service_impl.cc
@@ -23,8 +23,7 @@ namespace syncer {
// GetOrDownloadState tracks completion of these calls and posts callback for
// consumer once all attachments are either retrieved or reported unavailable.
class AttachmentServiceImpl::GetOrDownloadState
- : public base::RefCounted<GetOrDownloadState>,
- public base::NonThreadSafe {
+ : public base::RefCounted<GetOrDownloadState> {
public:
// GetOrDownloadState gets parameter from values passed to
// AttachmentService::GetOrDownloadAttachments.
@@ -57,6 +56,8 @@ class AttachmentServiceImpl::GetOrDownloadState
AttachmentIdSet unavailable_attachments_;
std::unique_ptr<AttachmentMap> retrieved_attachments_;
+ SEQUENCE_CHECKER(sequence_checker_);
+
DISALLOW_COPY_AND_ASSIGN(GetOrDownloadState);
};
@@ -71,12 +72,12 @@ AttachmentServiceImpl::GetOrDownloadState::GetOrDownloadState(
}
AttachmentServiceImpl::GetOrDownloadState::~GetOrDownloadState() {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
}
void AttachmentServiceImpl::GetOrDownloadState::AddAttachment(
const Attachment& attachment) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DCHECK(retrieved_attachments_->find(attachment.GetId()) ==
retrieved_attachments_->end());
retrieved_attachments_->insert(
@@ -89,7 +90,7 @@ void AttachmentServiceImpl::GetOrDownloadState::AddAttachment(
void AttachmentServiceImpl::GetOrDownloadState::AddUnavailableAttachmentId(
const AttachmentId& attachment_id) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DCHECK(unavailable_attachments_.find(attachment_id) ==
unavailable_attachments_.end());
unavailable_attachments_.insert(attachment_id);
@@ -123,7 +124,7 @@ AttachmentServiceImpl::AttachmentServiceImpl(
attachment_downloader_(std::move(attachment_downloader)),
delegate_(delegate),
weak_ptr_factory_(this) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DCHECK(attachment_store_.get());
// TODO(maniscalco): Observe network connectivity change events. When the
@@ -139,14 +140,14 @@ AttachmentServiceImpl::AttachmentServiceImpl(
}
AttachmentServiceImpl::~AttachmentServiceImpl() {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
net::NetworkChangeNotifier::RemoveNetworkChangeObserver(this);
}
void AttachmentServiceImpl::GetOrDownloadAttachments(
const AttachmentIdList& attachment_ids,
const GetOrDownloadCallback& callback) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
scoped_refptr<GetOrDownloadState> state(
new GetOrDownloadState(attachment_ids, callback));
// SetModelTypeReference() makes attachments visible for model type.
@@ -205,7 +206,7 @@ void AttachmentServiceImpl::WriteDone(
void AttachmentServiceImpl::UploadDone(
const AttachmentUploader::UploadResult& result,
const AttachmentId& attachment_id) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
AttachmentIdList ids;
ids.push_back(attachment_id);
switch (result) {
@@ -251,7 +252,7 @@ void AttachmentServiceImpl::DownloadDone(
}
void AttachmentServiceImpl::BeginUpload(const AttachmentId& attachment_id) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
AttachmentIdList attachment_ids;
attachment_ids.push_back(attachment_id);
attachment_store_->Read(attachment_ids,
@@ -261,7 +262,7 @@ void AttachmentServiceImpl::BeginUpload(const AttachmentId& attachment_id) {
void AttachmentServiceImpl::UploadAttachments(
const AttachmentIdList& attachment_ids) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
if (!attachment_uploader_.get()) {
return;
}
@@ -284,7 +285,7 @@ void AttachmentServiceImpl::ReadDoneNowUpload(
const AttachmentStore::Result& result,
std::unique_ptr<AttachmentMap> attachments,
std::unique_ptr<AttachmentIdList> unavailable_attachment_ids) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
if (!unavailable_attachment_ids->empty()) {
// TODO(maniscalco): We failed to read some attachments. What should we do
// now?
« no previous file with comments | « components/sync/model_impl/attachments/attachment_service_impl.h ('k') | components/sync/model_impl/attachments/task_queue.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698