blob: 4fd4bc9dc699717e179508706878955acb64e4d9 [file] [log] [blame] [edit]
/*
* Copyright (C) 2016 The Android Open Source Project
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#define LOG_TAG "storaged"
#include <dirent.h>
#include <fcntl.h>
#include <inttypes.h>
#include <linux/time.h>
#include <stdint.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/stat.h>
#include <time.h>
#include <unistd.h>
#include <iomanip>
#include <sstream>
#include <string>
#include <unordered_map>
#include <android-base/file.h>
#include <android-base/logging.h>
#include <android-base/stringprintf.h>
#include <android-base/strings.h>
#include <log/log_event_list.h>
#include <storaged.h>
#include <storaged_utils.h>
bool cmp_uid_info(const UidInfo& l, const UidInfo& r) {
// Compare background I/O first.
for (int i = UID_STATS - 1; i >= 0; i--) {
uint64_t l_bytes = l.io[i].read_bytes + l.io[i].write_bytes;
uint64_t r_bytes = r.io[i].read_bytes + r.io[i].write_bytes;
uint64_t l_chars = l.io[i].rchar + l.io[i].wchar;
uint64_t r_chars = r.io[i].rchar + r.io[i].wchar;
if (l_bytes != r_bytes) {
return l_bytes > r_bytes;
}
if (l_chars != r_chars) {
return l_chars > r_chars;
}
}
return l.name < r.name;
}
void sort_running_uids_info(std::vector<UidInfo> &uids) {
std::sort(uids.begin(), uids.end(), cmp_uid_info);
}
// Logging functions
void log_console_running_uids_info(const std::vector<UidInfo>& uids, bool flag_dump_task) {
printf("name/uid fg_rchar fg_wchar fg_rbytes fg_wbytes "
"bg_rchar bg_wchar bg_rbytes bg_wbytes fg_fsync bg_fsync\n");
for (const auto& uid : uids) {
printf("%s %" PRIu64 " %" PRIu64 " %" PRIu64 " %" PRIu64 " %" PRIu64
" %" PRIu64 " %" PRIu64 " %" PRIu64 " %" PRIu64 " %" PRIu64 "\n",
uid.name.c_str(),
uid.io[0].rchar, uid.io[0].wchar, uid.io[0].read_bytes, uid.io[0].write_bytes,
uid.io[1].rchar, uid.io[1].wchar, uid.io[1].read_bytes, uid.io[1].write_bytes,
uid.io[0].fsync, uid.io[1].fsync);
if (flag_dump_task) {
for (const auto& task_it : uid.tasks) {
const task_info& task = task_it.second;
printf("-> %s %" PRIu64 " %" PRIu64 " %" PRIu64 " %" PRIu64
" %" PRIu64 " %" PRIu64 " %" PRIu64 " %" PRIu64 " %" PRIu64 " %" PRIu64 "\n",
task.comm.c_str(),
task.io[0].rchar, task.io[0].wchar, task.io[0].read_bytes, task.io[0].write_bytes,
task.io[1].rchar, task.io[1].wchar, task.io[1].read_bytes, task.io[1].write_bytes,
task.io[0].fsync, task.io[1].fsync);
}
}
}
fflush(stdout);
}
void log_console_perf_history(const vector<int>& perf_history) {
if (perf_history.size() < 3 ||
perf_history.size() != perf_history[0] +
perf_history[1] +
perf_history[2] + (size_t)3) {
return;
}
printf("\nI/O perf history (KB/s) : most_recent <--------- least_recent \n");
std::stringstream line;
int start = 3;
int end = 3 + perf_history[0];
std::copy(perf_history.begin() + start, perf_history.begin() + end,
std::ostream_iterator<int>(line, " "));
printf("last 24 hours : %s\n", line.str().c_str());
line.str("");
start = end;
end += perf_history[1];
std::copy(perf_history.begin() + start, perf_history.begin() + end,
std::ostream_iterator<int>(line, " "));
printf("last 7 days : %s\n", line.str().c_str());
line.str("");
start = end;
std::copy(perf_history.begin() + start, perf_history.end(),
std::ostream_iterator<int>(line, " "));
printf("last 52 weeks : %s\n", line.str().c_str());
}
map<string, io_usage> merge_io_usage(const vector<uid_record>& entries) {
map<string, io_usage> merged_entries;
for (const auto& record : entries) {
merged_entries[record.name] += record.ios.uid_ios;
}
return merged_entries;
}