| OLD | NEW |
| 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #ifndef BASE_OBSERVER_LIST_H__ | 5 #ifndef BASE_OBSERVER_LIST_H__ |
| 6 #define BASE_OBSERVER_LIST_H__ | 6 #define BASE_OBSERVER_LIST_H__ |
| 7 | 7 |
| 8 #include <algorithm> | 8 #include <algorithm> |
| 9 #include <limits> | 9 #include <limits> |
| 10 #include <vector> | 10 #include <vector> |
| (...skipping 125 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 136 | 136 |
| 137 template <class ObserverType> | 137 template <class ObserverType> |
| 138 ObserverListBase<ObserverType>::Iterator::~Iterator() { | 138 ObserverListBase<ObserverType>::Iterator::~Iterator() { |
| 139 if (list_.get() && --list_->notify_depth_ == 0) | 139 if (list_.get() && --list_->notify_depth_ == 0) |
| 140 list_->Compact(); | 140 list_->Compact(); |
| 141 } | 141 } |
| 142 | 142 |
| 143 template <class ObserverType> | 143 template <class ObserverType> |
| 144 ObserverType* ObserverListBase<ObserverType>::Iterator::GetNext() { | 144 ObserverType* ObserverListBase<ObserverType>::Iterator::GetNext() { |
| 145 if (!list_.get()) | 145 if (!list_.get()) |
| 146 return NULL; | 146 return nullptr; |
| 147 ListType& observers = list_->observers_; | 147 ListType& observers = list_->observers_; |
| 148 // Advance if the current element is null | 148 // Advance if the current element is null |
| 149 size_t max_index = std::min(max_index_, observers.size()); | 149 size_t max_index = std::min(max_index_, observers.size()); |
| 150 while (index_ < max_index && !observers[index_]) | 150 while (index_ < max_index && !observers[index_]) |
| 151 ++index_; | 151 ++index_; |
| 152 return index_ < max_index ? observers[index_++] : NULL; | 152 return index_ < max_index ? observers[index_++] : nullptr; |
| 153 } | 153 } |
| 154 | 154 |
| 155 template <class ObserverType> | 155 template <class ObserverType> |
| 156 void ObserverListBase<ObserverType>::AddObserver(ObserverType* obs) { | 156 void ObserverListBase<ObserverType>::AddObserver(ObserverType* obs) { |
| 157 DCHECK(obs); |
| 157 if (std::find(observers_.begin(), observers_.end(), obs) | 158 if (std::find(observers_.begin(), observers_.end(), obs) |
| 158 != observers_.end()) { | 159 != observers_.end()) { |
| 159 NOTREACHED() << "Observers can only be added once!"; | 160 NOTREACHED() << "Observers can only be added once!"; |
| 160 return; | 161 return; |
| 161 } | 162 } |
| 162 observers_.push_back(obs); | 163 observers_.push_back(obs); |
| 163 } | 164 } |
| 164 | 165 |
| 165 template <class ObserverType> | 166 template <class ObserverType> |
| 166 void ObserverListBase<ObserverType>::RemoveObserver(ObserverType* obs) { | 167 void ObserverListBase<ObserverType>::RemoveObserver(ObserverType* obs) { |
| 168 DCHECK(obs); |
| 167 typename ListType::iterator it = | 169 typename ListType::iterator it = |
| 168 std::find(observers_.begin(), observers_.end(), obs); | 170 std::find(observers_.begin(), observers_.end(), obs); |
| 169 if (it != observers_.end()) { | 171 if (it != observers_.end()) { |
| 170 if (notify_depth_) { | 172 if (notify_depth_) { |
| 171 *it = 0; | 173 *it = nullptr; |
| 172 } else { | 174 } else { |
| 173 observers_.erase(it); | 175 observers_.erase(it); |
| 174 } | 176 } |
| 175 } | 177 } |
| 176 } | 178 } |
| 177 | 179 |
| 178 template <class ObserverType> | 180 template <class ObserverType> |
| 179 bool ObserverListBase<ObserverType>::HasObserver( | 181 bool ObserverListBase<ObserverType>::HasObserver( |
| 180 const ObserverType* observer) const { | 182 const ObserverType* observer) const { |
| 181 for (size_t i = 0; i < observers_.size(); ++i) { | 183 for (size_t i = 0; i < observers_.size(); ++i) { |
| 182 if (observers_[i] == observer) | 184 if (observers_[i] == observer) |
| 183 return true; | 185 return true; |
| 184 } | 186 } |
| 185 return false; | 187 return false; |
| 186 } | 188 } |
| 187 | 189 |
| 188 template <class ObserverType> | 190 template <class ObserverType> |
| 189 void ObserverListBase<ObserverType>::Clear() { | 191 void ObserverListBase<ObserverType>::Clear() { |
| 190 if (notify_depth_) { | 192 if (notify_depth_) { |
| 191 for (typename ListType::iterator it = observers_.begin(); | 193 for (typename ListType::iterator it = observers_.begin(); |
| 192 it != observers_.end(); ++it) { | 194 it != observers_.end(); ++it) { |
| 193 *it = 0; | 195 *it = nullptr; |
| 194 } | 196 } |
| 195 } else { | 197 } else { |
| 196 observers_.clear(); | 198 observers_.clear(); |
| 197 } | 199 } |
| 198 } | 200 } |
| 199 | 201 |
| 200 template <class ObserverType> | 202 template <class ObserverType> |
| 201 void ObserverListBase<ObserverType>::Compact() { | 203 void ObserverListBase<ObserverType>::Compact() { |
| 202 observers_.erase( | 204 observers_.erase( |
| 203 std::remove(observers_.begin(), observers_.end(), | 205 std::remove(observers_.begin(), observers_.end(), nullptr), |
| 204 static_cast<ObserverType*>(NULL)), observers_.end()); | 206 observers_.end()); |
| 205 } | 207 } |
| 206 | 208 |
| 207 template <class ObserverType, bool check_empty = false> | 209 template <class ObserverType, bool check_empty = false> |
| 208 class ObserverList : public ObserverListBase<ObserverType> { | 210 class ObserverList : public ObserverListBase<ObserverType> { |
| 209 public: | 211 public: |
| 210 typedef typename ObserverListBase<ObserverType>::NotificationType | 212 typedef typename ObserverListBase<ObserverType>::NotificationType |
| 211 NotificationType; | 213 NotificationType; |
| 212 | 214 |
| 213 ObserverList() {} | 215 ObserverList() {} |
| 214 explicit ObserverList(NotificationType type) | 216 explicit ObserverList(NotificationType type) |
| (...skipping 11 matching lines...) Expand all Loading... |
| 226 return ObserverListBase<ObserverType>::size() != 0; | 228 return ObserverListBase<ObserverType>::size() != 0; |
| 227 } | 229 } |
| 228 }; | 230 }; |
| 229 | 231 |
| 230 #define FOR_EACH_OBSERVER(ObserverType, observer_list, func) \ | 232 #define FOR_EACH_OBSERVER(ObserverType, observer_list, func) \ |
| 231 do { \ | 233 do { \ |
| 232 if ((observer_list).might_have_observers()) { \ | 234 if ((observer_list).might_have_observers()) { \ |
| 233 ObserverListBase<ObserverType>::Iterator it_inside_observer_macro( \ | 235 ObserverListBase<ObserverType>::Iterator it_inside_observer_macro( \ |
| 234 &observer_list); \ | 236 &observer_list); \ |
| 235 ObserverType* obs; \ | 237 ObserverType* obs; \ |
| 236 while ((obs = it_inside_observer_macro.GetNext()) != NULL) \ | 238 while ((obs = it_inside_observer_macro.GetNext()) != nullptr) \ |
| 237 obs->func; \ | 239 obs->func; \ |
| 238 } \ | 240 } \ |
| 239 } while (0) | 241 } while (0) |
| 240 | 242 |
| 241 #endif // BASE_OBSERVER_LIST_H__ | 243 #endif // BASE_OBSERVER_LIST_H__ |
| OLD | NEW |