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; |
} |