1 /*
2 * Copyright (C) 2016 The Android Open Source Project
3 *
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
7 *
8 * http://www.apache.org/licenses/LICENSE-2.0
9 *
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
15 */
16
17 #define LOG_TAG "storaged"
18
19 #include <dirent.h>
20 #include <fcntl.h>
21 #include <inttypes.h>
22 #include <linux/time.h>
23 #include <stdint.h>
24 #include <stdio.h>
25 #include <stdlib.h>
26 #include <string.h>
27 #include <sys/stat.h>
28 #include <time.h>
29 #include <unistd.h>
30
31 #include <iomanip>
32 #include <sstream>
33 #include <string>
34 #include <unordered_map>
35
36 #include <android-base/file.h>
37 #include <android-base/logging.h>
38 #include <android-base/stringprintf.h>
39 #include <android-base/strings.h>
40 #include <log/log_event_list.h>
41
42 #include <storaged.h>
43 #include <storaged_utils.h>
44
cmp_uid_info(const UidInfo & l,const UidInfo & r)45 bool cmp_uid_info(const UidInfo& l, const UidInfo& r) {
46 // Compare background I/O first.
47 for (int i = UID_STATS - 1; i >= 0; i--) {
48 uint64_t l_bytes = l.io[i].read_bytes + l.io[i].write_bytes;
49 uint64_t r_bytes = r.io[i].read_bytes + r.io[i].write_bytes;
50 uint64_t l_chars = l.io[i].rchar + l.io[i].wchar;
51 uint64_t r_chars = r.io[i].rchar + r.io[i].wchar;
52
53 if (l_bytes != r_bytes) {
54 return l_bytes > r_bytes;
55 }
56 if (l_chars != r_chars) {
57 return l_chars > r_chars;
58 }
59 }
60
61 return l.name < r.name;
62 }
63
sort_running_uids_info(std::vector<UidInfo> & uids)64 void sort_running_uids_info(std::vector<UidInfo> &uids) {
65 std::sort(uids.begin(), uids.end(), cmp_uid_info);
66 }
67
68 // Logging functions
log_console_running_uids_info(const std::vector<UidInfo> & uids,bool flag_dump_task)69 void log_console_running_uids_info(const std::vector<UidInfo>& uids, bool flag_dump_task) {
70 printf("name/uid fg_rchar fg_wchar fg_rbytes fg_wbytes "
71 "bg_rchar bg_wchar bg_rbytes bg_wbytes fg_fsync bg_fsync\n");
72
73 for (const auto& uid : uids) {
74 printf("%s %" PRIu64 " %" PRIu64 " %" PRIu64 " %" PRIu64 " %" PRIu64
75 " %" PRIu64 " %" PRIu64 " %" PRIu64 " %" PRIu64 " %" PRIu64 "\n",
76 uid.name.c_str(),
77 uid.io[0].rchar, uid.io[0].wchar, uid.io[0].read_bytes, uid.io[0].write_bytes,
78 uid.io[1].rchar, uid.io[1].wchar, uid.io[1].read_bytes, uid.io[1].write_bytes,
79 uid.io[0].fsync, uid.io[1].fsync);
80 if (flag_dump_task) {
81 for (const auto& task_it : uid.tasks) {
82 const task_info& task = task_it.second;
83 printf("-> %s %" PRIu64 " %" PRIu64 " %" PRIu64 " %" PRIu64
84 " %" PRIu64 " %" PRIu64 " %" PRIu64 " %" PRIu64 " %" PRIu64 " %" PRIu64 "\n",
85 task.comm.c_str(),
86 task.io[0].rchar, task.io[0].wchar, task.io[0].read_bytes, task.io[0].write_bytes,
87 task.io[1].rchar, task.io[1].wchar, task.io[1].read_bytes, task.io[1].write_bytes,
88 task.io[0].fsync, task.io[1].fsync);
89 }
90 }
91 }
92 fflush(stdout);
93 }
94
log_console_perf_history(const vector<int> & perf_history)95 void log_console_perf_history(const vector<int>& perf_history) {
96 if (perf_history.size() < 3 ||
97 perf_history.size() != perf_history[0] +
98 perf_history[1] +
99 perf_history[2] + (size_t)3) {
100 return;
101 }
102
103 printf("\nI/O perf history (KB/s) : most_recent <--------- least_recent \n");
104
105 std::stringstream line;
106 int start = 3;
107 int end = 3 + perf_history[0];
108 std::copy(perf_history.begin() + start, perf_history.begin() + end,
109 std::ostream_iterator<int>(line, " "));
110 printf("last 24 hours : %s\n", line.str().c_str());
111
112 line.str("");
113 start = end;
114 end += perf_history[1];
115 std::copy(perf_history.begin() + start, perf_history.begin() + end,
116 std::ostream_iterator<int>(line, " "));
117 printf("last 7 days : %s\n", line.str().c_str());
118
119 line.str("");
120 start = end;
121 std::copy(perf_history.begin() + start, perf_history.end(),
122 std::ostream_iterator<int>(line, " "));
123 printf("last 52 weeks : %s\n", line.str().c_str());
124 }
125
merge_io_usage(const vector<uid_record> & entries)126 map<string, io_usage> merge_io_usage(const vector<uid_record>& entries) {
127 map<string, io_usage> merged_entries;
128 for (const auto& record : entries) {
129 merged_entries[record.name] += record.ios.uid_ios;
130 }
131 return merged_entries;
132 }
133