OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 "chrome/browser/chromeos/system_logs/debug_daemon_log_source.h" | 5 #include "chrome/browser/chromeos/system_logs/debug_daemon_log_source.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/bind_helpers.h" | 8 #include "base/bind_helpers.h" |
9 #include "base/file_util.h" | 9 #include "base/file_util.h" |
10 #include "base/logging.h" | 10 #include "base/logging.h" |
11 #include "base/memory/scoped_ptr.h" | 11 #include "base/memory/scoped_ptr.h" |
12 #include "base/memory/weak_ptr.h" | 12 #include "base/memory/weak_ptr.h" |
13 #include "base/strings/string_number_conversions.h" | 13 #include "base/strings/string_number_conversions.h" |
14 #include "base/strings/string_util.h" | 14 #include "base/strings/string_util.h" |
15 #include "chrome/browser/chromeos/system_logs/system_logs_fetcher.h" | |
16 #include "chrome/browser/profiles/profile_manager.h" | 15 #include "chrome/browser/profiles/profile_manager.h" |
17 #include "chrome/common/chrome_switches.h" | 16 #include "chrome/common/chrome_switches.h" |
18 #include "chromeos/dbus/dbus_thread_manager.h" | 17 #include "chromeos/dbus/dbus_thread_manager.h" |
19 #include "chromeos/dbus/debug_daemon_client.h" | 18 #include "chromeos/dbus/debug_daemon_client.h" |
20 #include "content/public/browser/browser_thread.h" | 19 #include "content/public/browser/browser_thread.h" |
21 | 20 |
22 const char kNotAvailable[] = "<not available>"; | 21 const char kNotAvailable[] = "<not available>"; |
23 const char kRoutesKeyName[] = "routes"; | 22 const char kRoutesKeyName[] = "routes"; |
24 const char kNetworkStatusKeyName[] = "network-status"; | 23 const char kNetworkStatusKeyName[] = "network-status"; |
25 const char kModemStatusKeyName[] = "modem-status"; | 24 const char kModemStatusKeyName[] = "modem-status"; |
26 const char kWiMaxStatusKeyName[] = "wimax-status"; | 25 const char kWiMaxStatusKeyName[] = "wimax-status"; |
27 const char kUserLogFileKeyName[] = "user_log_files"; | 26 const char kUserLogFileKeyName[] = "user_log_files"; |
28 | 27 |
29 namespace chromeos { | 28 namespace chromeos { |
30 | 29 |
31 DebugDaemonLogSource::DebugDaemonLogSource() | 30 DebugDaemonLogSource::DebugDaemonLogSource(bool scrub) |
32 : response_(new SystemLogsResponse()), | 31 : response_(new SystemLogsResponse()), |
33 num_pending_requests_(0), | 32 num_pending_requests_(0), |
| 33 scrub_(scrub), |
34 weak_ptr_factory_(this) {} | 34 weak_ptr_factory_(this) {} |
35 | 35 |
36 DebugDaemonLogSource::~DebugDaemonLogSource() {} | 36 DebugDaemonLogSource::~DebugDaemonLogSource() {} |
37 | 37 |
38 void DebugDaemonLogSource::Fetch(const SysLogsSourceCallback& callback) { | 38 void DebugDaemonLogSource::Fetch(const SysLogsSourceCallback& callback) { |
39 DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI)); | 39 DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI)); |
40 DCHECK(!callback.is_null()); | 40 DCHECK(!callback.is_null()); |
41 DCHECK(callback_.is_null()); | 41 DCHECK(callback_.is_null()); |
42 | 42 |
43 callback_ = callback; | 43 callback_ = callback; |
44 DebugDaemonClient* client = DBusThreadManager::Get()->GetDebugDaemonClient(); | 44 DebugDaemonClient* client = DBusThreadManager::Get()->GetDebugDaemonClient(); |
45 | 45 |
46 client->GetRoutes(true, // Numeric | 46 client->GetRoutes(true, // Numeric |
47 false, // No IPv6 | 47 false, // No IPv6 |
48 base::Bind(&DebugDaemonLogSource::OnGetRoutes, | 48 base::Bind(&DebugDaemonLogSource::OnGetRoutes, |
49 weak_ptr_factory_.GetWeakPtr())); | 49 weak_ptr_factory_.GetWeakPtr())); |
50 ++num_pending_requests_; | 50 ++num_pending_requests_; |
51 client->GetNetworkStatus(base::Bind(&DebugDaemonLogSource::OnGetNetworkStatus, | 51 client->GetNetworkStatus(base::Bind(&DebugDaemonLogSource::OnGetNetworkStatus, |
52 weak_ptr_factory_.GetWeakPtr())); | 52 weak_ptr_factory_.GetWeakPtr())); |
53 ++num_pending_requests_; | 53 ++num_pending_requests_; |
54 client->GetModemStatus(base::Bind(&DebugDaemonLogSource::OnGetModemStatus, | 54 client->GetModemStatus(base::Bind(&DebugDaemonLogSource::OnGetModemStatus, |
55 weak_ptr_factory_.GetWeakPtr())); | 55 weak_ptr_factory_.GetWeakPtr())); |
56 ++num_pending_requests_; | 56 ++num_pending_requests_; |
57 client->GetWiMaxStatus(base::Bind(&DebugDaemonLogSource::OnGetWiMaxStatus, | 57 client->GetWiMaxStatus(base::Bind(&DebugDaemonLogSource::OnGetWiMaxStatus, |
58 weak_ptr_factory_.GetWeakPtr())); | 58 weak_ptr_factory_.GetWeakPtr())); |
59 ++num_pending_requests_; | 59 ++num_pending_requests_; |
60 client->GetAllLogs(base::Bind(&DebugDaemonLogSource::OnGetLogs, | |
61 weak_ptr_factory_.GetWeakPtr())); | |
62 ++num_pending_requests_; | |
63 client->GetUserLogFiles(base::Bind(&DebugDaemonLogSource::OnGetUserLogFiles, | 60 client->GetUserLogFiles(base::Bind(&DebugDaemonLogSource::OnGetUserLogFiles, |
64 weak_ptr_factory_.GetWeakPtr())); | 61 weak_ptr_factory_.GetWeakPtr())); |
65 ++num_pending_requests_; | 62 ++num_pending_requests_; |
| 63 |
| 64 if (scrub_) { |
| 65 client->GetScrubbedLogs(base::Bind(&DebugDaemonLogSource::OnGetLogs, |
| 66 weak_ptr_factory_.GetWeakPtr())); |
| 67 } else { |
| 68 client->GetAllLogs(base::Bind(&DebugDaemonLogSource::OnGetLogs, |
| 69 weak_ptr_factory_.GetWeakPtr())); |
| 70 } |
| 71 ++num_pending_requests_; |
66 } | 72 } |
67 | 73 |
68 void DebugDaemonLogSource::OnGetRoutes(bool succeeded, | 74 void DebugDaemonLogSource::OnGetRoutes(bool succeeded, |
69 const std::vector<std::string>& routes) { | 75 const std::vector<std::string>& routes) { |
70 DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI)); | 76 DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI)); |
71 | 77 |
72 if (succeeded) | 78 if (succeeded) |
73 (*response_)[kRoutesKeyName] = JoinString(routes, '\n'); | 79 (*response_)[kRoutesKeyName] = JoinString(routes, '\n'); |
74 else | 80 else |
75 (*response_)[kRoutesKeyName] = kNotAvailable; | 81 (*response_)[kRoutesKeyName] = kNotAvailable; |
(...skipping 90 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
166 DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI)); | 172 DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI)); |
167 DCHECK(!callback_.is_null()); | 173 DCHECK(!callback_.is_null()); |
168 | 174 |
169 --num_pending_requests_; | 175 --num_pending_requests_; |
170 if (num_pending_requests_ > 0) | 176 if (num_pending_requests_ > 0) |
171 return; | 177 return; |
172 callback_.Run(response_.get()); | 178 callback_.Run(response_.get()); |
173 } | 179 } |
174 | 180 |
175 } // namespace chromeos | 181 } // namespace chromeos |
OLD | NEW |