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

Unified Diff: components/reading_list/core/reading_list_model_impl.cc

Issue 2914583002: Replace deprecated base::NonThreadSafe in components/reading_list in favor of SequenceChecker. (Closed)
Patch Set: 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/reading_list/core/reading_list_model_impl.cc
diff --git a/components/reading_list/core/reading_list_model_impl.cc b/components/reading_list/core/reading_list_model_impl.cc
index 92713dbd2cf2b71de76b28d9d45c570cf7b33788..8a0b440c02563edefcc7d9f6130e0ec7c51ca36f 100644
--- a/components/reading_list/core/reading_list_model_impl.cc
+++ b/components/reading_list/core/reading_list_model_impl.cc
@@ -27,7 +27,7 @@ ReadingListModelImpl::ReadingListModelImpl(
has_unseen_(false),
loaded_(false),
weak_ptr_factory_(this) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DCHECK(clock_);
if (storage) {
storage_layer_ = std::move(storage);
@@ -42,7 +42,7 @@ ReadingListModelImpl::~ReadingListModelImpl() {}
void ReadingListModelImpl::StoreLoaded(
std::unique_ptr<ReadingListEntries> entries) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DCHECK(entries);
entries_ = std::move(entries);
for (auto& iterator : *entries_) {
@@ -55,19 +55,19 @@ void ReadingListModelImpl::StoreLoaded(
}
void ReadingListModelImpl::Shutdown() {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
for (auto& observer : observers_)
observer.ReadingListModelBeingShutdown(this);
loaded_ = false;
}
bool ReadingListModelImpl::loaded() const {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
return loaded_;
}
size_t ReadingListModelImpl::size() const {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DCHECK(read_entry_count_ + unread_entry_count_ == entries_->size());
if (!loaded())
return 0;
@@ -75,7 +75,7 @@ size_t ReadingListModelImpl::size() const {
}
size_t ReadingListModelImpl::unread_size() const {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DCHECK(read_entry_count_ + unread_entry_count_ == entries_->size());
if (!loaded())
return 0;
@@ -83,7 +83,7 @@ size_t ReadingListModelImpl::unread_size() const {
}
size_t ReadingListModelImpl::unseen_size() const {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
if (!loaded())
return 0;
return unseen_entry_count_;
@@ -99,7 +99,7 @@ void ReadingListModelImpl::SetUnseenFlag() {
}
bool ReadingListModelImpl::GetLocalUnseenFlag() const {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
if (!loaded())
return false;
// If there are currently no unseen entries, return false even if has_unseen_
@@ -109,7 +109,7 @@ bool ReadingListModelImpl::GetLocalUnseenFlag() const {
}
void ReadingListModelImpl::ResetLocalUnseenFlag() {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
if (!loaded()) {
return;
}
@@ -119,7 +119,7 @@ void ReadingListModelImpl::ResetLocalUnseenFlag() {
}
void ReadingListModelImpl::MarkAllSeen() {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DCHECK(loaded());
if (unseen_entry_count_ == 0) {
return;
@@ -148,7 +148,7 @@ void ReadingListModelImpl::MarkAllSeen() {
}
bool ReadingListModelImpl::DeleteAllEntries() {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
if (!loaded()) {
return false;
}
@@ -193,14 +193,14 @@ const std::vector<GURL> ReadingListModelImpl::Keys() const {
const ReadingListEntry* ReadingListModelImpl::GetEntryByURL(
const GURL& gurl) const {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DCHECK(loaded());
return GetMutableEntryFromURL(gurl);
}
const ReadingListEntry* ReadingListModelImpl::GetFirstUnreadEntry(
bool distilled) const {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DCHECK(loaded());
if (unread_entry_count_ == 0) {
return nullptr;
@@ -234,7 +234,7 @@ const ReadingListEntry* ReadingListModelImpl::GetFirstUnreadEntry(
ReadingListEntry* ReadingListModelImpl::GetMutableEntryFromURL(
const GURL& url) const {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DCHECK(loaded());
auto iterator = entries_->find(url);
if (iterator == entries_->end()) {
@@ -245,7 +245,7 @@ ReadingListEntry* ReadingListModelImpl::GetMutableEntryFromURL(
void ReadingListModelImpl::SyncAddEntry(
std::unique_ptr<ReadingListEntry> entry) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DCHECK(loaded());
// entry must not already exist.
DCHECK(GetMutableEntryFromURL(entry->URL()) == nullptr);
@@ -265,7 +265,7 @@ void ReadingListModelImpl::SyncAddEntry(
ReadingListEntry* ReadingListModelImpl::SyncMergeEntry(
std::unique_ptr<ReadingListEntry> entry) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DCHECK(loaded());
ReadingListEntry* existing_entry = GetMutableEntryFromURL(entry->URL());
DCHECK(existing_entry);
@@ -301,7 +301,7 @@ void ReadingListModelImpl::RemoveEntryByURL(const GURL& url) {
void ReadingListModelImpl::RemoveEntryByURLImpl(const GURL& url,
bool from_sync) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DCHECK(loaded());
const ReadingListEntry* entry = GetEntryByURL(url);
if (!entry)
@@ -324,7 +324,7 @@ const ReadingListEntry& ReadingListModelImpl::AddEntry(
const GURL& url,
const std::string& title,
reading_list::EntrySource source) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DCHECK(loaded());
DCHECK(url.SchemeIsHTTPOrHTTPS());
RemoveEntryByURL(url);
@@ -351,7 +351,7 @@ const ReadingListEntry& ReadingListModelImpl::AddEntry(
}
void ReadingListModelImpl::SetReadStatus(const GURL& url, bool read) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DCHECK(loaded());
auto iterator = entries_->find(url);
if (iterator == entries_->end()) {
@@ -380,7 +380,7 @@ void ReadingListModelImpl::SetReadStatus(const GURL& url, bool read) {
void ReadingListModelImpl::SetEntryTitle(const GURL& url,
const std::string& title) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DCHECK(loaded());
auto iterator = entries_->find(url);
if (iterator == entries_->end()) {
@@ -410,7 +410,7 @@ void ReadingListModelImpl::SetEntryDistilledInfo(
const GURL& distilled_url,
int64_t distillation_size,
const base::Time& distillation_date) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DCHECK(loaded());
auto iterator = entries_->find(url);
if (iterator == entries_->end()) {
@@ -438,7 +438,7 @@ void ReadingListModelImpl::SetEntryDistilledInfo(
void ReadingListModelImpl::SetEntryDistilledState(
const GURL& url,
ReadingListEntry::DistillationState state) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DCHECK(loaded());
auto iterator = entries_->find(url);
if (iterator == entries_->end()) {
@@ -464,7 +464,7 @@ void ReadingListModelImpl::SetEntryDistilledState(
void ReadingListModelImpl::SetContentSuggestionsExtra(
const GURL& url,
const reading_list::ContentSuggestionsExtra& extra) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DCHECK(loaded());
ReadingListEntry* entry = GetMutableEntryFromURL(url);
if (!entry) {
@@ -504,7 +504,7 @@ ReadingListModelImpl::ScopedReadingListBatchUpdate::
}
void ReadingListModelImpl::LeavingBatchUpdates() {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
if (storage_layer_) {
SetPersistentHasUnseen(has_unseen_);
}
@@ -512,12 +512,12 @@ void ReadingListModelImpl::LeavingBatchUpdates() {
}
void ReadingListModelImpl::EnteringBatchUpdates() {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
ReadingListModel::EnteringBatchUpdates();
}
void ReadingListModelImpl::SetPersistentHasUnseen(bool has_unseen) {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
if (!pref_service_) {
return;
}
@@ -526,7 +526,7 @@ void ReadingListModelImpl::SetPersistentHasUnseen(bool has_unseen) {
}
bool ReadingListModelImpl::GetPersistentHasUnseen() {
- DCHECK(CalledOnValidThread());
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
if (!pref_service_) {
return false;
}
« no previous file with comments | « components/reading_list/core/reading_list_model.cc ('k') | components/reading_list/core/reading_list_store.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698