| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 #include "storage/browser/quota/storage_monitor.h" | 5 #include "storage/browser/quota/storage_monitor.h" |
| 6 | 6 |
| 7 #include <stdint.h> | 7 #include <stdint.h> |
| 8 | 8 |
| 9 #include <algorithm> | 9 #include <algorithm> |
| 10 | 10 |
| (...skipping 101 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 112 pending_event_ = event; | 112 pending_event_ = event; |
| 113 notification_timer_.Start( | 113 notification_timer_.Start( |
| 114 FROM_HERE, | 114 FROM_HERE, |
| 115 min_delay, | 115 min_delay, |
| 116 this, | 116 this, |
| 117 &StorageObserverList::DispatchPendingEvent); | 117 &StorageObserverList::DispatchPendingEvent); |
| 118 } | 118 } |
| 119 } | 119 } |
| 120 | 120 |
| 121 void StorageObserverList::ScheduleUpdateForObserver(StorageObserver* observer) { | 121 void StorageObserverList::ScheduleUpdateForObserver(StorageObserver* observer) { |
| 122 DCHECK(ContainsKey(observers_, observer)); | 122 DCHECK(base::ContainsKey(observers_, observer)); |
| 123 observers_[observer].requires_update = true; | 123 observers_[observer].requires_update = true; |
| 124 } | 124 } |
| 125 | 125 |
| 126 void StorageObserverList::DispatchPendingEvent() { | 126 void StorageObserverList::DispatchPendingEvent() { |
| 127 MaybeDispatchEvent(pending_event_); | 127 MaybeDispatchEvent(pending_event_); |
| 128 } | 128 } |
| 129 | 129 |
| 130 | 130 |
| 131 // HostStorageObservers: | 131 // HostStorageObservers: |
| 132 | 132 |
| (...skipping 107 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 240 } | 240 } |
| 241 | 241 |
| 242 | 242 |
| 243 // StorageTypeObservers: | 243 // StorageTypeObservers: |
| 244 | 244 |
| 245 StorageTypeObservers::StorageTypeObservers(QuotaManager* quota_manager) | 245 StorageTypeObservers::StorageTypeObservers(QuotaManager* quota_manager) |
| 246 : quota_manager_(quota_manager) { | 246 : quota_manager_(quota_manager) { |
| 247 } | 247 } |
| 248 | 248 |
| 249 StorageTypeObservers::~StorageTypeObservers() { | 249 StorageTypeObservers::~StorageTypeObservers() { |
| 250 STLDeleteValues(&host_observers_map_); | 250 base::STLDeleteValues(&host_observers_map_); |
| 251 } | 251 } |
| 252 | 252 |
| 253 void StorageTypeObservers::AddObserver( | 253 void StorageTypeObservers::AddObserver( |
| 254 StorageObserver* observer, const StorageObserver::MonitorParams& params) { | 254 StorageObserver* observer, const StorageObserver::MonitorParams& params) { |
| 255 std::string host = net::GetHostOrSpecFromURL(params.filter.origin); | 255 std::string host = net::GetHostOrSpecFromURL(params.filter.origin); |
| 256 if (host.empty()) | 256 if (host.empty()) |
| 257 return; | 257 return; |
| 258 | 258 |
| 259 HostStorageObservers* host_observers = NULL; | 259 HostStorageObservers* host_observers = NULL; |
| 260 HostObserversMap::iterator it = host_observers_map_.find(host); | 260 HostObserversMap::iterator it = host_observers_map_.find(host); |
| (...skipping 55 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 316 } | 316 } |
| 317 | 317 |
| 318 | 318 |
| 319 // StorageMonitor: | 319 // StorageMonitor: |
| 320 | 320 |
| 321 StorageMonitor::StorageMonitor(QuotaManager* quota_manager) | 321 StorageMonitor::StorageMonitor(QuotaManager* quota_manager) |
| 322 : quota_manager_(quota_manager) { | 322 : quota_manager_(quota_manager) { |
| 323 } | 323 } |
| 324 | 324 |
| 325 StorageMonitor::~StorageMonitor() { | 325 StorageMonitor::~StorageMonitor() { |
| 326 STLDeleteValues(&storage_type_observers_map_); | 326 base::STLDeleteValues(&storage_type_observers_map_); |
| 327 } | 327 } |
| 328 | 328 |
| 329 void StorageMonitor::AddObserver( | 329 void StorageMonitor::AddObserver( |
| 330 StorageObserver* observer, const StorageObserver::MonitorParams& params) { | 330 StorageObserver* observer, const StorageObserver::MonitorParams& params) { |
| 331 DCHECK(observer); | 331 DCHECK(observer); |
| 332 | 332 |
| 333 // Check preconditions. | 333 // Check preconditions. |
| 334 if (params.filter.storage_type == kStorageTypeUnknown || | 334 if (params.filter.storage_type == kStorageTypeUnknown || |
| 335 params.filter.storage_type == kStorageTypeQuotaNotManaged || | 335 params.filter.storage_type == kStorageTypeQuotaNotManaged || |
| 336 params.filter.origin.is_empty()) { | 336 params.filter.origin.is_empty()) { |
| (...skipping 54 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 391 | 391 |
| 392 StorageTypeObserversMap::iterator it = | 392 StorageTypeObserversMap::iterator it = |
| 393 storage_type_observers_map_.find(filter.storage_type); | 393 storage_type_observers_map_.find(filter.storage_type); |
| 394 if (it == storage_type_observers_map_.end()) | 394 if (it == storage_type_observers_map_.end()) |
| 395 return; | 395 return; |
| 396 | 396 |
| 397 it->second->NotifyUsageChange(filter, delta); | 397 it->second->NotifyUsageChange(filter, delta); |
| 398 } | 398 } |
| 399 | 399 |
| 400 } // namespace storage | 400 } // namespace storage |
| OLD | NEW |