1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
|
// 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/debug_daemon_log_source.h"
#include "base/bind.h"
#include "base/bind_helpers.h"
#include "base/logging.h"
#include "base/memory/scoped_ptr.h"
#include "base/memory/weak_ptr.h"
#include "base/string_util.h"
#include "chrome/browser/chromeos/system_logs/system_logs_fetcher.h"
#include "chrome/common/chrome_switches.h"
#include "chromeos/dbus/dbus_thread_manager.h"
#include "chromeos/dbus/debug_daemon_client.h"
#include "content/public/browser/browser_thread.h"
namespace {
const char kNotAvailable[] = "<not available>";
const char kRoutesKeyName[] = "routes";
const char kNetworkStatusKeyName[] = "network-status";
const char kModemStatusKeyName[] = "modem-status";
} // namespace
namespace chromeos {
// Fetches logs from the debug daemon over DBus. When all the logs have been
// fetched, forwards the results to the supplied Request. Used like:
// DebugDaemonLogSource* fetcher = new DebugDaemonLogSource(request);
// fetcher->Fetch();
// Note that you do not need to delete the fetcher; it will delete itself after
// Fetch() has forwarded the result to the request handler.
DebugDaemonLogSource::DebugDaemonLogSource()
: response_(new SystemLogsResponse()),
num_pending_requests_(0),
ALLOW_THIS_IN_INITIALIZER_LIST(weak_ptr_factory_(this)) {}
DebugDaemonLogSource::~DebugDaemonLogSource() {}
void DebugDaemonLogSource::Fetch(const SysLogsSourceCallback& callback) {
DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
DCHECK(!callback.is_null());
DCHECK(callback_.is_null());
callback_ = callback;
DebugDaemonClient* client = DBusThreadManager::Get()->GetDebugDaemonClient();
client->GetRoutes(true, // Numeric
false, // No IPv6
base::Bind(&DebugDaemonLogSource::OnGetRoutes,
weak_ptr_factory_.GetWeakPtr()));
++num_pending_requests_;
client->GetNetworkStatus(base::Bind(&DebugDaemonLogSource::OnGetNetworkStatus,
weak_ptr_factory_.GetWeakPtr()));
++num_pending_requests_;
client->GetModemStatus(base::Bind(&DebugDaemonLogSource::OnGetModemStatus,
weak_ptr_factory_.GetWeakPtr()));
++num_pending_requests_;
client->GetAllLogs(base::Bind(&DebugDaemonLogSource::OnGetLogs,
weak_ptr_factory_.GetWeakPtr()));
++num_pending_requests_;
}
void DebugDaemonLogSource::OnGetRoutes(bool succeeded,
const std::vector<std::string>& routes) {
DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
if (succeeded)
(*response_)[kRoutesKeyName] = JoinString(routes, '\n');
else
(*response_)[kRoutesKeyName] = kNotAvailable;
RequestCompleted();
}
void DebugDaemonLogSource::OnGetNetworkStatus(bool succeeded,
const std::string& status) {
DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
if (succeeded)
(*response_)[kNetworkStatusKeyName] = status;
else
(*response_)[kNetworkStatusKeyName] = kNotAvailable;
RequestCompleted();
}
void DebugDaemonLogSource::OnGetModemStatus(bool succeeded,
const std::string& status) {
DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
if (succeeded)
(*response_)[kModemStatusKeyName] = status;
else
(*response_)[kModemStatusKeyName] = kNotAvailable;
RequestCompleted();
}
void DebugDaemonLogSource::OnGetLogs(bool /* succeeded */,
const std::map<std::string,
std::string>& logs) {
DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
// We ignore 'succeeded' for this callback - we want to display as much of the
// debug info as we can even if we failed partway through parsing, and if we
// couldn't fetch any of it, none of the fields will even appear.
response_->insert(logs.begin(), logs.end());
RequestCompleted();
}
void DebugDaemonLogSource::RequestCompleted() {
DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
DCHECK(!callback_.is_null());
--num_pending_requests_;
if (num_pending_requests_ > 0)
return;
callback_.Run(response_.get());
}
} // namespace chromeos
|
