Chromium Code Reviews| OLD | NEW |
|---|---|
| (Empty) | |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | |
| 2 // Use of this source code is governed by a BSD-style license that can be | |
| 3 // found in the LICENSE file. | |
| 4 | |
| 5 #include "chrome/browser/media/router/issue_manager.h" | |
| 6 | |
| 7 namespace media_router { | |
| 8 | |
| 9 IssueManager::IssueManager() : top_issue_(nullptr) { | |
| 10 } | |
| 11 | |
| 12 IssueManager::~IssueManager() { | |
| 13 } | |
| 14 | |
| 15 void IssueManager::AddIssue(const Issue& issue) { | |
| 16 DCHECK(thread_checker_.CalledOnValidThread()); | |
| 17 media_issue_map_.insert(std::make_pair(issue.id(), issue)); | |
| 18 | |
| 19 MaybeUpdateTopIssue(); | |
| 20 } | |
| 21 | |
| 22 void IssueManager::ClearIssue(const IssueId& issue_id) { | |
| 23 DCHECK(thread_checker_.CalledOnValidThread()); | |
| 24 media_issue_map_.erase(issue_id); | |
| 25 | |
| 26 MaybeUpdateTopIssue(); | |
| 27 } | |
| 28 | |
| 29 size_t IssueManager::GetIssueCount() const { | |
| 30 DCHECK(thread_checker_.CalledOnValidThread()); | |
| 31 return media_issue_map_.size(); | |
| 32 } | |
| 33 | |
| 34 void IssueManager::ClearAllIssues() { | |
| 35 DCHECK(thread_checker_.CalledOnValidThread()); | |
| 36 media_issue_map_.clear(); | |
| 37 | |
| 38 MaybeUpdateTopIssue(); | |
| 39 } | |
| 40 | |
| 41 void IssueManager::ClearGlobalIssues() { | |
| 42 DCHECK(thread_checker_.CalledOnValidThread()); | |
| 43 auto it = media_issue_map_.begin(); | |
| 44 while (it != media_issue_map_.end()) { | |
| 45 if (it->second.IsGlobal()) { | |
| 46 media_issue_map_.erase(it++); | |
| 47 } else { | |
| 48 ++it; | |
| 49 } | |
| 50 } | |
| 51 | |
| 52 MaybeUpdateTopIssue(); | |
| 53 } | |
| 54 | |
| 55 void IssueManager::ClearIssuesWithRouteId(const MediaRouteId& route_id) { | |
| 56 DCHECK(thread_checker_.CalledOnValidThread()); | |
| 57 auto it = media_issue_map_.begin(); | |
| 58 while (it != media_issue_map_.end()) { | |
| 59 if (it->second.route_id() == route_id) { | |
| 60 media_issue_map_.erase(it++); | |
| 61 } else { | |
| 62 ++it; | |
| 63 } | |
| 64 } | |
| 65 | |
| 66 MaybeUpdateTopIssue(); | |
| 67 } | |
| 68 | |
| 69 void IssueManager::RegisterObserver(IssuesObserver* observer) { | |
| 70 DCHECK(thread_checker_.CalledOnValidThread()); | |
| 71 DCHECK(observer); | |
| 72 DCHECK(!issues_observers_.HasObserver(observer)); | |
| 73 | |
| 74 issues_observers_.AddObserver(observer); | |
| 75 if (top_issue_) | |
| 76 observer->OnIssueUpdated(top_issue_); | |
| 77 } | |
| 78 | |
| 79 void IssueManager::UnregisterObserver(IssuesObserver* observer) { | |
| 80 DCHECK(thread_checker_.CalledOnValidThread()); | |
| 81 issues_observers_.RemoveObserver(observer); | |
| 82 } | |
| 83 | |
| 84 void IssueManager::MaybeUpdateTopIssue() { | |
| 85 Issue* new_top_issue = nullptr; | |
| 86 if (!media_issue_map_.empty()) { | |
| 87 auto it = media_issue_map_.begin(); | |
| 88 | |
| 89 // Assumes there's at least one issue in the map. This is the first issue | |
| 90 // regardless of whether it's blocking or not. | |
| 91 new_top_issue = &it->second; | |
| 92 | |
| 93 while (it != media_issue_map_.end()) { | |
|
DaleCurtis
2015/04/30 18:18:15
Seems like you might want some form of a priority
Kevin M
2015/05/01 17:59:18
Hmmm. There are multiple different access patterns
apacible
2015/05/01 20:18:08
std::list looks fine to me.
| |
| 94 // The first blocking issue is of higher priority than the first issue. | |
| 95 if (it->second.IsBlocking()) { | |
| 96 new_top_issue = &it->second; | |
| 97 break; | |
| 98 } | |
| 99 | |
| 100 ++it; | |
| 101 } | |
| 102 } | |
| 103 | |
| 104 // If the top issue is different from |top_issue_|, update. | |
| 105 if (new_top_issue != top_issue_) { | |
| 106 top_issue_ = new_top_issue; | |
| 107 | |
| 108 FOR_EACH_OBSERVER(IssuesObserver, issues_observers_, | |
| 109 OnIssueUpdated(top_issue_)); | |
| 110 } | |
| 111 } | |
| 112 | |
| 113 } // namespace media_router | |
| OLD | NEW |