| OLD | NEW |
| 1 // Copyright (c) 2009 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2009 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/boot_times_loader.h" | 5 #include "chrome/browser/chromeos/boot_times_loader.h" |
| 6 | 6 |
| 7 #include <vector> | 7 #include <vector> |
| 8 | 8 |
| 9 #include "base/command_line.h" | 9 #include "base/command_line.h" |
| 10 #include "base/file_path.h" | 10 #include "base/file_path.h" |
| 11 #include "base/file_util.h" | 11 #include "base/file_util.h" |
| 12 #include "base/message_loop.h" | 12 #include "base/message_loop.h" |
| 13 #include "base/process_util.h" | 13 #include "base/process_util.h" |
| 14 #include "base/string_util.h" | 14 #include "base/string_util.h" |
| 15 #include "base/thread.h" | 15 #include "base/thread.h" |
| 16 #include "chrome/browser/browser_process.h" | 16 #include "chrome/browser/browser_process.h" |
| 17 #include "chrome/browser/chrome_thread.h" | 17 #include "chrome/browser/chrome_thread.h" |
| 18 #include "chrome/common/chrome_switches.h" | 18 #include "chrome/common/chrome_switches.h" |
| 19 | 19 |
| 20 namespace { |
| 21 |
| 22 typedef struct Stats { |
| 23 std::string uptime; |
| 24 std::string disk; |
| 25 |
| 26 Stats() : uptime(std::string()), disk(std::string()) {} |
| 27 }; |
| 28 |
| 29 } |
| 30 |
| 20 namespace chromeos { | 31 namespace chromeos { |
| 21 | 32 |
| 22 // File uptime logs are located in. | 33 // File uptime logs are located in. |
| 23 static const char kLogPath[] = "/tmp"; | 34 static const char kLogPath[] = "/tmp"; |
| 24 | 35 // Prefix for the time measurement files. |
| 36 static const char kUptimePrefix[] = "uptime-"; |
| 37 // Prefix for the disk usage files. |
| 38 static const char kDiskPrefix[] = "disk-"; |
| 39 // Name of the time that Chrome's main() is called. |
| 40 static const char kChromeMain[] = "chrome-main"; |
| 25 // Delay in milliseconds between file read attempts. | 41 // Delay in milliseconds between file read attempts. |
| 26 static const int64 kReadAttemptDelayMs = 500; | 42 static const int64 kReadAttemptDelayMs = 250; |
| 27 | 43 |
| 28 BootTimesLoader::BootTimesLoader() : backend_(new Backend()) { | 44 BootTimesLoader::BootTimesLoader() : backend_(new Backend()) { |
| 29 } | 45 } |
| 30 | 46 |
| 31 BootTimesLoader::Handle BootTimesLoader::GetBootTimes( | 47 BootTimesLoader::Handle BootTimesLoader::GetBootTimes( |
| 32 CancelableRequestConsumerBase* consumer, | 48 CancelableRequestConsumerBase* consumer, |
| 33 BootTimesLoader::GetBootTimesCallback* callback) { | 49 BootTimesLoader::GetBootTimesCallback* callback) { |
| 34 if (!g_browser_process->file_thread()) { | 50 if (!g_browser_process->file_thread()) { |
| 35 // This should only happen if Chrome is shutting down, so we don't do | 51 // This should only happen if Chrome is shutting down, so we don't do |
| 36 // anything. | 52 // anything. |
| (...skipping 11 matching lines...) Expand all Loading... |
| 48 new CancelableRequest<GetBootTimesCallback>(callback)); | 64 new CancelableRequest<GetBootTimesCallback>(callback)); |
| 49 AddRequest(request, consumer); | 65 AddRequest(request, consumer); |
| 50 | 66 |
| 51 ChromeThread::PostTask( | 67 ChromeThread::PostTask( |
| 52 ChromeThread::FILE, | 68 ChromeThread::FILE, |
| 53 FROM_HERE, | 69 FROM_HERE, |
| 54 NewRunnableMethod(backend_.get(), &Backend::GetBootTimes, request)); | 70 NewRunnableMethod(backend_.get(), &Backend::GetBootTimes, request)); |
| 55 return request->handle(); | 71 return request->handle(); |
| 56 } | 72 } |
| 57 | 73 |
| 58 // Executes command within a shell, allowing IO redirection. Searches | |
| 59 // for a whitespace delimited string prefixed by prefix in the output and | |
| 60 // returns it. | |
| 61 static std::string ExecuteInShell( | |
| 62 const std::string& command, const std::string& prefix) { | |
| 63 std::vector<std::string> args; | |
| 64 args.push_back("/bin/sh"); | |
| 65 args.push_back("-c"); | |
| 66 args.push_back(command); | |
| 67 CommandLine cmd(args); | |
| 68 std::string out; | |
| 69 | |
| 70 if (base::GetAppOutput(cmd, &out)) { | |
| 71 size_t index = out.find(prefix); | |
| 72 if (index != std::string::npos) { | |
| 73 size_t value_index = index + prefix.size(); | |
| 74 size_t whitespace_index = out.find(' ', value_index); | |
| 75 size_t chars_left = std::string::npos; | |
| 76 if (whitespace_index == std::string::npos) | |
| 77 whitespace_index = out.find('\n', value_index); | |
| 78 if (whitespace_index != std::string::npos) | |
| 79 chars_left = whitespace_index - value_index; | |
| 80 return out.substr(value_index, chars_left); | |
| 81 } | |
| 82 } | |
| 83 return std::string(); | |
| 84 } | |
| 85 | |
| 86 // Extracts the uptime value from files located in /tmp, returning the | 74 // Extracts the uptime value from files located in /tmp, returning the |
| 87 // value as a double in value. | 75 // value as a double in value. |
| 88 static bool GetUptime(const std::string& log, double* value) { | 76 static bool GetTime(const std::string& log, double* value) { |
| 89 FilePath log_dir(kLogPath); | 77 FilePath log_dir(kLogPath); |
| 90 FilePath log_file = log_dir.Append(log); | 78 FilePath log_file = log_dir.Append(log); |
| 91 std::string contents; | 79 std::string contents; |
| 92 *value = 0.0; | 80 *value = 0.0; |
| 93 if (file_util::ReadFileToString(log_file, &contents)) { | 81 if (file_util::ReadFileToString(log_file, &contents)) { |
| 94 size_t space_index = contents.find(' '); | 82 size_t space_index = contents.find(' '); |
| 95 size_t chars_left = | 83 size_t chars_left = |
| 96 space_index != std::string::npos ? space_index : std::string::npos; | 84 space_index != std::string::npos ? space_index : std::string::npos; |
| 97 std::string value_string = contents.substr(0, chars_left); | 85 std::string value_string = contents.substr(0, chars_left); |
| 98 return StringToDouble(value_string, value); | 86 return StringToDouble(value_string, value); |
| 99 } | 87 } |
| 100 return false; | 88 return false; |
| 101 } | 89 } |
| 102 | 90 |
| 103 void BootTimesLoader::Backend::GetBootTimes( | 91 void BootTimesLoader::Backend::GetBootTimes( |
| 104 scoped_refptr<GetBootTimesRequest> request) { | 92 scoped_refptr<GetBootTimesRequest> request) { |
| 105 const char* kInitialTSCCommand = "dmesg | grep 'Initial TSC value:'"; | 93 const char* kFirmwareBootTime = "firmware-boot-time"; |
| 106 const char* kInitialTSCPrefix = "TSC value: "; | 94 const char* kPreStartup = "pre-startup"; |
| 107 const char* kClockSpeedCommand = "dmesg | grep -e 'Detected.*processor'"; | 95 const char* kChromeExec = "chrome-exec"; |
| 108 const char* kClockSpeedPrefix = "Detected "; | 96 const char* kChromeMain = "chrome-main"; |
| 109 const char* kPreStartup = "uptime-pre-startup"; | 97 const char* kXStarted = "x-started"; |
| 110 const char* kChromeExec = "uptime-chrome-exec"; | 98 const char* kLoginPromptReady = "login-prompt-ready"; |
| 111 const char* kChromeMain = "uptime-chrome-main"; | 99 std::string uptime_prefix = kUptimePrefix; |
| 112 const char* kXStarted = "uptime-x-started"; | |
| 113 const char* kLoginPromptReady = "uptime-login-prompt-ready"; | |
| 114 | 100 |
| 115 if (request->canceled()) | 101 if (request->canceled()) |
| 116 return; | 102 return; |
| 117 | 103 |
| 118 // Wait until login_prompt_ready is output by reposting. | 104 // Wait until login_prompt_ready is output by reposting. |
| 119 FilePath log_dir(kLogPath); | 105 FilePath log_dir(kLogPath); |
| 120 FilePath log_file = log_dir.Append(kLoginPromptReady); | 106 FilePath log_file = log_dir.Append(kLoginPromptReady); |
| 121 if (!file_util::PathExists(log_file)) { | 107 if (!file_util::PathExists(log_file)) { |
| 122 ChromeThread::PostDelayedTask( | 108 ChromeThread::PostDelayedTask( |
| 123 ChromeThread::FILE, | 109 ChromeThread::FILE, |
| 124 FROM_HERE, | 110 FROM_HERE, |
| 125 NewRunnableMethod(this, &Backend::GetBootTimes, request), | 111 NewRunnableMethod(this, &Backend::GetBootTimes, request), |
| 126 kReadAttemptDelayMs); | 112 kReadAttemptDelayMs); |
| 127 return; | 113 return; |
| 128 } | 114 } |
| 129 | 115 |
| 130 BootTimes boot_times; | 116 BootTimes boot_times; |
| 131 std::string tsc_value = ExecuteInShell(kInitialTSCCommand, kInitialTSCPrefix); | 117 |
| 132 std::string speed_value = | 118 GetTime(kFirmwareBootTime, &boot_times.firmware); |
| 133 ExecuteInShell(kClockSpeedCommand, kClockSpeedPrefix); | 119 GetTime(uptime_prefix + kPreStartup, &boot_times.pre_startup); |
| 134 boot_times.firmware = 0; | 120 GetTime(uptime_prefix + kXStarted, &boot_times.x_started); |
| 135 if (!tsc_value.empty() && !speed_value.empty()) { | 121 GetTime(uptime_prefix + kChromeExec, &boot_times.chrome_exec); |
| 136 int64 tsc = 0; | 122 GetTime(uptime_prefix + kChromeMain, &boot_times.chrome_main); |
| 137 double speed = 0; | 123 GetTime(uptime_prefix + kLoginPromptReady, &boot_times.login_prompt_ready); |
| 138 if (StringToInt64(tsc_value, &tsc) && | |
| 139 StringToDouble(speed_value, &speed) && | |
| 140 speed > 0) { | |
| 141 boot_times.firmware = static_cast<double>(tsc) / (speed * 1000000); | |
| 142 } | |
| 143 } | |
| 144 GetUptime(kPreStartup, &boot_times.pre_startup); | |
| 145 GetUptime(kXStarted, &boot_times.x_started); | |
| 146 GetUptime(kChromeExec, &boot_times.chrome_exec); | |
| 147 GetUptime(kChromeMain, &boot_times.chrome_main); | |
| 148 GetUptime(kLoginPromptReady, &boot_times.login_prompt_ready); | |
| 149 | 124 |
| 150 request->ForwardResult( | 125 request->ForwardResult( |
| 151 GetBootTimesCallback::TupleType(request->handle(), boot_times)); | 126 GetBootTimesCallback::TupleType(request->handle(), boot_times)); |
| 152 } | 127 } |
| 153 | 128 |
| 129 static void RecordStatsDelayed( |
| 130 const std::string& name, |
| 131 const std::string& uptime, |
| 132 const std::string& disk) { |
| 133 const FilePath log_path(kLogPath); |
| 134 std::string disk_prefix = kDiskPrefix; |
| 135 const FilePath uptime_output = |
| 136 log_path.Append(FilePath(kUptimePrefix + name)); |
| 137 const FilePath disk_output = log_path.Append(FilePath(kDiskPrefix + name)); |
| 138 |
| 139 // Write out the files, ensuring that they don't exist already. |
| 140 if (!file_util::PathExists(uptime_output)) |
| 141 file_util::WriteFile(uptime_output, uptime.data(), uptime.size()); |
| 142 if (!file_util::PathExists(disk_output)) |
| 143 file_util::WriteFile(disk_output, disk.data(), disk.size()); |
| 144 } |
| 145 |
| 146 static void RecordStats( |
| 147 const std::string& name, const Stats& stats) { |
| 148 ChromeThread::PostTask( |
| 149 ChromeThread::FILE, FROM_HERE, |
| 150 NewRunnableFunction(RecordStatsDelayed, name, stats.uptime, stats.disk)); |
| 151 } |
| 152 |
| 153 static Stats GetCurrentStats() { |
| 154 const FilePath kProcUptime("/proc/uptime"); |
| 155 const FilePath kDiskStat("/sys/block/sda/stat"); |
| 156 Stats stats; |
| 157 |
| 158 file_util::ReadFileToString(kProcUptime, &stats.uptime); |
| 159 file_util::ReadFileToString(kDiskStat, &stats.disk); |
| 160 return stats; |
| 161 } |
| 162 |
| 163 // static |
| 164 void BootTimesLoader::RecordCurrentStats(const std::string& name) { |
| 165 Stats stats = GetCurrentStats(); |
| 166 RecordStats(name, stats); |
| 167 } |
| 168 |
| 169 // Used to hold the stats at main(). |
| 170 static Stats chrome_main_stats_; |
| 171 |
| 172 void BootTimesLoader::SaveChromeMainStats() { |
| 173 chrome_main_stats_ = GetCurrentStats(); |
| 174 } |
| 175 |
| 176 void BootTimesLoader::RecordChromeMainStats() { |
| 177 RecordStats(kChromeMain, chrome_main_stats_); |
| 178 } |
| 179 |
| 154 } // namespace chromeos | 180 } // namespace chromeos |
| OLD | NEW |