| Index: chrome/browser/storage/storage_info_fetcher.cc
|
| diff --git a/chrome/browser/storage/storage_info_fetcher.cc b/chrome/browser/storage/storage_info_fetcher.cc
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..adc1d7d33e2e381d8a76c0fce4b4582de9d4eadd
|
| --- /dev/null
|
| +++ b/chrome/browser/storage/storage_info_fetcher.cc
|
| @@ -0,0 +1,55 @@
|
| +// Copyright 2016 The Chromium Authors. All rights reserved.
|
| +// Use of this source code is governed by a BSD-style license that can be
|
| +// found in the LICENSE file.
|
| +
|
| +#include "chrome/browser/storage/storage_info_fetcher.h"
|
| +
|
| +#include "content/public/browser/browser_thread.h"
|
| +
|
| +using content::BrowserThread;
|
| +
|
| +StorageInfoFetcher::StorageInfoFetcher(storage::QuotaManager* quota_manager)
|
| + : quota_manager_(quota_manager) {
|
| +}
|
| +
|
| +StorageInfoFetcher::~StorageInfoFetcher() {
|
| +}
|
| +
|
| +void StorageInfoFetcher::Run() {
|
| + // QuotaManager must be called on IO thread, but the callback must then be
|
| + // called on the UI thread.
|
| + BrowserThread::PostTask(
|
| + BrowserThread::IO, FROM_HERE,
|
| + base::Bind(&StorageInfoFetcher::GetUsageInfo, this,
|
| + base::Bind(&StorageInfoFetcher::OnGetUsageInfoInternal, this)));
|
| +}
|
| +
|
| +void StorageInfoFetcher::AddObserver(Observer* observer) {
|
| + observers_.AddObserver(observer);
|
| +}
|
| +
|
| +void StorageInfoFetcher::RemoveObserver(Observer* observer) {
|
| + observers_.RemoveObserver(observer);
|
| +}
|
| +
|
| +void StorageInfoFetcher::GetUsageInfo(
|
| + const storage::GetUsageInfoCallback& callback) {
|
| + DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
|
| + quota_manager_->GetUsageInfo(callback);
|
| +}
|
| +
|
| +void StorageInfoFetcher::OnGetUsageInfoInternal(
|
| + const storage::UsageInfoEntries& entries) {
|
| + DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
|
| +
|
| + entries_.insert(entries_.begin(), entries.begin(), entries.end());
|
| + BrowserThread::PostTask(
|
| + BrowserThread::UI, FROM_HERE,
|
| + base::Bind(&StorageInfoFetcher::InvokeCallback, this));
|
| +}
|
| +
|
| +void StorageInfoFetcher::InvokeCallback() {
|
| + DCHECK_CURRENTLY_ON(content::BrowserThread::UI);
|
| +
|
| + FOR_EACH_OBSERVER(Observer, observers_, OnGetUsageInfo(entries_));
|
| +}
|
|
|