Chromium Code Reviews| Index: chrome/browser/chromeos/system_logs/system_logs_fetcher.cc |
| diff --git a/chrome/browser/chromeos/system_logs/system_logs_fetcher.cc b/chrome/browser/chromeos/system_logs/system_logs_fetcher.cc |
| new file mode 100644 |
| index 0000000000000000000000000000000000000000..cb67f3fa3f592b4ca61f8d5a96ce0810d751bab9 |
| --- /dev/null |
| +++ b/chrome/browser/chromeos/system_logs/system_logs_fetcher.cc |
| @@ -0,0 +1,66 @@ |
| +// Copyright (c) 2012 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/chromeos/system_logs/system_logs_fetcher.h" |
| + |
| +#include "base/bind.h" |
| +#include "base/bind_helpers.h" |
| +#include "chrome/browser/chromeos/system_logs/commandline_log_source.h" |
| +#include "chrome/browser/chromeos/system_logs/debug_daemon_log_source.h" |
| +#include "chrome/browser/chromeos/system_logs/memorydetails_log_source.h" |
| +#include "chrome/browser/chromeos/system_logs/lsb_release_log_source.h" |
| +#include "content/public/browser/browser_thread.h" |
| + |
| +using content::BrowserThread; |
| + |
| +namespace chromeos { |
| + |
| +SystemLogsFetcher::SystemLogsFetcher() |
| + : response_(new SystemLogsResponse), |
| + num_pending_requests_(0), |
| + ALLOW_THIS_IN_INITIALIZER_LIST(weak_ptr_factory_(this)) { |
| + |
| + // Debug Daemon data source. |
| + data_sources_.push_back(new DebugDaemonLogSource()); |
| + |
| + // Chrome data sources. |
| + data_sources_.push_back(new CommandLineLogSource()); |
| + data_sources_.push_back(new LsbReleaseLogSource()); |
| + data_sources_.push_back(new MemoryDetailsLogSource()); |
| + num_pending_requests_ = data_sources_.size(); |
| +} |
| + |
| +void SystemLogsFetcher::Fetch(const SysLogsFetcherCallback& callback) { |
| + DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
| + DCHECK(callback_.is_null()); |
| + DCHECK(!callback.is_null()); |
| + |
| + callback_ = callback; |
| + for (size_t i = 0; i < data_sources_.size(); ++i) { |
| + data_sources_[i]->Fetch(base::Bind(&SystemLogsFetcher::AddResponse, |
| + weak_ptr_factory_.GetWeakPtr())); |
| + } |
| +} |
| + |
| +void SystemLogsFetcher::AddResponse(SystemLogsResponse* response) { |
| + DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
| + |
| + for (SystemLogsResponse::iterator it = response->begin(); |
| + it != response->end(); |
| + ++it) { |
| + // It is false if the insert didn't work. |
|
satorux1
2012/08/17 21:41:21
"didn't work" is not correct.
// It is false if t
tudalex(Chromium)
2012/08/17 23:14:01
Done.
|
| + DCHECK(response_->insert(*it).second); |
| + } |
| + |
| + |
| + --num_pending_requests_; |
| + if (num_pending_requests_ > 0) |
| + return; |
| + |
| + callback_.Run(response_.Pass()); |
| + BrowserThread::DeleteSoon(BrowserThread::UI, FROM_HERE, this); |
| +} |
| + |
| +} // namespace chromeos |
| + |