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

Unified Diff: chrome/browser/media/router/issue_manager.cc

Issue 2176613003: [Media Router] Clean up issues related code. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: IssueObserver init behavior and use StructTraits Created 4 years, 2 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: chrome/browser/media/router/issue_manager.cc
diff --git a/chrome/browser/media/router/issue_manager.cc b/chrome/browser/media/router/issue_manager.cc
index d3cb9d4f3b5a18fd30765c7c8eeaa24d20718e2d..5dbf2860bf639986031e267489efea49a259b8b7 100644
--- a/chrome/browser/media/router/issue_manager.cc
+++ b/chrome/browser/media/router/issue_manager.cc
@@ -6,11 +6,12 @@
#include <algorithm>
+#include "base/memory/ptr_util.h"
#include "content/public/browser/browser_thread.h"
namespace media_router {
-IssueManager::IssueManager() {
+IssueManager::IssueManager() : top_issue_(nullptr) {
DCHECK_CURRENTLY_ON(content::BrowserThread::UI);
}
@@ -18,54 +19,20 @@ IssueManager::~IssueManager() {
DCHECK_CURRENTLY_ON(content::BrowserThread::UI);
}
-void IssueManager::AddIssue(const Issue& issue) {
+void IssueManager::AddIssue(const IssueInfo& issue_info) {
DCHECK_CURRENTLY_ON(content::BrowserThread::UI);
- for (const Issue& next_issue : issues_) {
- if (next_issue.Equals(issue)) {
- return;
- }
- }
- issues_.push_back(issue);
+ issues_.push_back(base::MakeUnique<Issue>(issue_info));
MaybeUpdateTopIssue();
}
void IssueManager::ClearIssue(const Issue::Id& issue_id) {
DCHECK_CURRENTLY_ON(content::BrowserThread::UI);
- issues_.erase(std::remove_if(issues_.begin(), issues_.end(),
- [&issue_id](const Issue& issue) {
- return issue_id == issue.id();
- }),
- issues_.end());
- MaybeUpdateTopIssue();
-}
-
-size_t IssueManager::GetIssueCount() const {
- DCHECK_CURRENTLY_ON(content::BrowserThread::UI);
- return issues_.size();
-}
-
-void IssueManager::ClearAllIssues() {
- DCHECK_CURRENTLY_ON(content::BrowserThread::UI);
- issues_.clear();
- MaybeUpdateTopIssue();
-}
-
-void IssueManager::ClearGlobalIssues() {
- DCHECK_CURRENTLY_ON(content::BrowserThread::UI);
issues_.erase(
- std::remove_if(issues_.begin(), issues_.end(), [](const Issue& issue) {
- return issue.is_global();
- }), issues_.end());
- MaybeUpdateTopIssue();
-}
-
-void IssueManager::ClearIssuesWithRouteId(const MediaRoute::Id& route_id) {
- DCHECK_CURRENTLY_ON(content::BrowserThread::UI);
- issues_.erase(std::remove_if(issues_.begin(), issues_.end(),
- [&route_id](const Issue& issue) {
- return route_id == issue.route_id();
- }),
- issues_.end());
+ std::remove_if(issues_.begin(), issues_.end(),
+ [&issue_id](const std::unique_ptr<Issue>& issue) {
+ return issue_id == issue->id();
+ }),
+ issues_.end());
MaybeUpdateTopIssue();
}
@@ -75,15 +42,8 @@ void IssueManager::RegisterObserver(IssuesObserver* observer) {
DCHECK(!issues_observers_.HasObserver(observer));
issues_observers_.AddObserver(observer);
- if (top_issue_id_.empty())
- return;
-
- // Find the current top issue and report it to the observer.
- for (const auto& next_issue : issues_) {
- if (next_issue.id() == top_issue_id_) {
- observer->OnIssueUpdated(&next_issue);
- }
- }
+ if (top_issue_)
+ observer->OnIssueUpdated(top_issue_);
}
void IssueManager::UnregisterObserver(IssuesObserver* observer) {
@@ -93,29 +53,23 @@ void IssueManager::UnregisterObserver(IssuesObserver* observer) {
void IssueManager::MaybeUpdateTopIssue() {
const Issue* new_top_issue = nullptr;
-
- if (issues_.empty()) {
- FOR_EACH_OBSERVER(IssuesObserver, issues_observers_,
- OnIssueUpdated(new_top_issue));
- return;
+ if (!issues_.empty()) {
+ // Select the first blocking issue in the list of issues.
+ // If there are none, simply select the first issue in the list.
+ auto it = std::find_if(issues_.begin(), issues_.end(),
+ [](const std::unique_ptr<Issue>& issue) {
+ return issue->info().is_blocking;
+ });
+ if (it == issues_.end())
+ it = issues_.begin();
+
+ new_top_issue = it->get();
}
-
- // Select the first blocking issue in the list of issues.
- // If there are none, simply select the first issue in the list.
- new_top_issue = &(issues_.front());
- for (const auto& issue : issues_) {
- // The first blocking issue is of higher priority than the first issue.
- if (issue.is_blocking()) {
- new_top_issue = &issue;
- break;
- }
- }
-
// If we've found a new top issue, then report it via the observer.
- if (new_top_issue->id() != top_issue_id_) {
- top_issue_id_ = new_top_issue->id();
+ if (new_top_issue != top_issue_) {
+ top_issue_ = new_top_issue;
FOR_EACH_OBSERVER(IssuesObserver, issues_observers_,
- OnIssueUpdated(new_top_issue));
+ OnIssueUpdated(top_issue_));
}
}

Powered by Google App Engine
This is Rietveld 408576698