| /* | |
| * Copyright (C) 2014 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. | |
| */ | |
| #include <fcntl.h> | |
| #include <pwd.h> | |
| #include <stdio.h> | |
| #include <string.h> | |
| #include <sys/types.h> | |
| #include <unistd.h> | |
| #include <log/logger.h> | |
| #include "LogStatistics.h" | |
| LogStatistics::LogStatistics() : enable(false) { | |
| log_id_for_each(id) { | |
| mSizes[id] = 0; | |
| mElements[id] = 0; | |
| mDroppedElements[id] = 0; | |
| mSizesTotal[id] = 0; | |
| mElementsTotal[id] = 0; | |
| } | |
| } | |
| namespace android { | |
| // caller must own and free character string | |
| char *pidToName(pid_t pid) { | |
| char *retval = NULL; | |
| if (pid == 0) { // special case from auditd/klogd for kernel | |
| retval = strdup("logd"); | |
| } else { | |
| char buffer[512]; | |
| snprintf(buffer, sizeof(buffer), "/proc/%u/cmdline", pid); | |
| int fd = open(buffer, O_RDONLY); | |
| if (fd >= 0) { | |
| ssize_t ret = read(fd, buffer, sizeof(buffer)); | |
| if (ret > 0) { | |
| buffer[sizeof(buffer)-1] = '\0'; | |
| // frameworks intermediate state | |
| if (fast<strcmp>(buffer, "<pre-initialized>")) { | |
| retval = strdup(buffer); | |
| } | |
| } | |
| close(fd); | |
| } | |
| } | |
| return retval; | |
| } | |
| } | |
| void LogStatistics::add(LogBufferElement *element) { | |
| log_id_t log_id = element->getLogId(); | |
| unsigned short size = element->getMsgLen(); | |
| mSizes[log_id] += size; | |
| ++mElements[log_id]; | |
| mSizesTotal[log_id] += size; | |
| ++mElementsTotal[log_id]; | |
| if (log_id == LOG_ID_KERNEL) { | |
| return; | |
| } | |
| uidTable[log_id].add(element->getUid(), element); | |
| if (element->getUid() == AID_SYSTEM) { | |
| pidSystemTable[log_id].add(element->getPid(), element); | |
| } | |
| if (!enable) { | |
| return; | |
| } | |
| pidTable.add(element->getPid(), element); | |
| tidTable.add(element->getTid(), element); | |
| uint32_t tag = element->getTag(); | |
| if (tag) { | |
| if (log_id == LOG_ID_SECURITY) { | |
| securityTagTable.add(tag, element); | |
| } else { | |
| tagTable.add(tag, element); | |
| } | |
| } | |
| } | |
| void LogStatistics::subtract(LogBufferElement *element) { | |
| log_id_t log_id = element->getLogId(); | |
| unsigned short size = element->getMsgLen(); | |
| mSizes[log_id] -= size; | |
| --mElements[log_id]; | |
| if (element->getDropped()) { | |
| --mDroppedElements[log_id]; | |
| } | |
| if (log_id == LOG_ID_KERNEL) { | |
| return; | |
| } | |
| uidTable[log_id].subtract(element->getUid(), element); | |
| if (element->getUid() == AID_SYSTEM) { | |
| pidSystemTable[log_id].subtract(element->getPid(), element); | |
| } | |
| if (!enable) { | |
| return; | |
| } | |
| pidTable.subtract(element->getPid(), element); | |
| tidTable.subtract(element->getTid(), element); | |
| uint32_t tag = element->getTag(); | |
| if (tag) { | |
| if (log_id == LOG_ID_SECURITY) { | |
| securityTagTable.subtract(tag, element); | |
| } else { | |
| tagTable.subtract(tag, element); | |
| } | |
| } | |
| } | |
| // Atomically set an entry to drop | |
| // entry->setDropped(1) must follow this call, caller should do this explicitly. | |
| void LogStatistics::drop(LogBufferElement *element) { | |
| log_id_t log_id = element->getLogId(); | |
| unsigned short size = element->getMsgLen(); | |
| mSizes[log_id] -= size; | |
| ++mDroppedElements[log_id]; | |
| uidTable[log_id].drop(element->getUid(), element); | |
| if (element->getUid() == AID_SYSTEM) { | |
| pidSystemTable[log_id].drop(element->getPid(), element); | |
| } | |
| if (!enable) { | |
| return; | |
| } | |
| pidTable.drop(element->getPid(), element); | |
| tidTable.drop(element->getTid(), element); | |
| } | |
| // caller must own and free character string | |
| const char *LogStatistics::uidToName(uid_t uid) const { | |
| // Local hard coded favourites | |
| if (uid == AID_LOGD) { | |
| return strdup("auditd"); | |
| } | |
| // Android system | |
| if (uid < AID_APP) { | |
| // in bionic, thread safe as long as we copy the results | |
| struct passwd *pwd = getpwuid(uid); | |
| if (pwd) { | |
| return strdup(pwd->pw_name); | |
| } | |
| } | |
| // Parse /data/system/packages.list | |
| uid_t userId = uid % AID_USER; | |
| const char *name = android::uidToName(userId); | |
| if (!name && (userId > (AID_SHARED_GID_START - AID_APP))) { | |
| name = android::uidToName(userId - (AID_SHARED_GID_START - AID_APP)); | |
| } | |
| if (name) { | |
| return name; | |
| } | |
| // Android application | |
| if (uid >= AID_APP) { | |
| struct passwd *pwd = getpwuid(uid); | |
| if (pwd) { | |
| return strdup(pwd->pw_name); | |
| } | |
| } | |
| // report uid -> pid(s) -> pidToName if unique | |
| for(pidTable_t::const_iterator it = pidTable.begin(); it != pidTable.end(); ++it) { | |
| const PidEntry &entry = it->second; | |
| if (entry.getUid() == uid) { | |
| const char *nameTmp = entry.getName(); | |
| if (nameTmp) { | |
| if (!name) { | |
| name = strdup(nameTmp); | |
| } else if (fast<strcmp>(name, nameTmp)) { | |
| free(const_cast<char *>(name)); | |
| name = NULL; | |
| break; | |
| } | |
| } | |
| } | |
| } | |
| // No one | |
| return name; | |
| } | |
| std::string UidEntry::formatHeader(const std::string &name, log_id_t id) const { | |
| bool isprune = worstUidEnabledForLogid(id); | |
| return formatLine(android::base::StringPrintf( | |
| name.c_str(), android_log_id_to_name(id)), | |
| std::string("Size"), | |
| std::string(isprune ? "+/- Pruned" : "")) | |
| + formatLine(std::string("UID PACKAGE"), | |
| std::string("BYTES"), | |
| std::string(isprune ? "NUM" : "")); | |
| } | |
| std::string UidEntry::format(const LogStatistics &stat, log_id_t id) const { | |
| uid_t uid = getUid(); | |
| std::string name = android::base::StringPrintf("%u", uid); | |
| const char *nameTmp = stat.uidToName(uid); | |
| if (nameTmp) { | |
| name += android::base::StringPrintf( | |
| "%*s%s", (int)std::max(6 - name.length(), (size_t)1), | |
| "", nameTmp); | |
| free(const_cast<char *>(nameTmp)); | |
| } | |
| std::string size = android::base::StringPrintf("%zu", getSizes()); | |
| std::string pruned = ""; | |
| if (worstUidEnabledForLogid(id)) { | |
| size_t totalDropped = 0; | |
| for (LogStatistics::uidTable_t::const_iterator it = stat.uidTable[id].begin(); | |
| it != stat.uidTable[id].end(); ++it) { | |
| totalDropped += it->second.getDropped(); | |
| } | |
| size_t sizes = stat.sizes(id); | |
| size_t totalSize = stat.sizesTotal(id); | |
| size_t totalElements = stat.elementsTotal(id); | |
| float totalVirtualSize = (float)sizes + (float)totalDropped * totalSize | |
| / totalElements; | |
| size_t entrySize = getSizes(); | |
| float virtualEntrySize = entrySize; | |
| int realPermille = virtualEntrySize * 1000.0 / sizes; | |
| size_t dropped = getDropped(); | |
| if (dropped) { | |
| pruned = android::base::StringPrintf("%zu", dropped); | |
| virtualEntrySize += (float)dropped * totalSize / totalElements; | |
| } | |
| int virtualPermille = virtualEntrySize * 1000.0 / totalVirtualSize; | |
| int permille = (realPermille - virtualPermille) * 1000L | |
| / (virtualPermille ?: 1); | |
| if ((permille < -1) || (1 < permille)) { | |
| std::string change; | |
| const char *units = "%"; | |
| const char *prefix = (permille > 0) ? "+" : ""; | |
| if (permille > 999) { | |
| permille = (permille + 1000) / 100; // Now tenths fold | |
| units = "X"; | |
| prefix = ""; | |
| } | |
| if ((-99 < permille) && (permille < 99)) { | |
| change = android::base::StringPrintf("%s%d.%u%s", | |
| prefix, | |
| permille / 10, | |
| ((permille < 0) ? (-permille % 10) : (permille % 10)), | |
| units); | |
| } else { | |
| change = android::base::StringPrintf("%s%d%s", | |
| prefix, | |
| (permille + 5) / 10, units); | |
| } | |
| ssize_t spaces = EntryBaseConstants::pruned_len | |
| - 2 - pruned.length() - change.length(); | |
| if ((spaces <= 0) && pruned.length()) { | |
| spaces = 1; | |
| } | |
| if (spaces > 0) { | |
| change += android::base::StringPrintf("%*s", (int)spaces, ""); | |
| } | |
| pruned = change + pruned; | |
| } | |
| } | |
| std::string output = formatLine(name, size, pruned); | |
| if (uid != AID_SYSTEM) { | |
| return output; | |
| } | |
| static const size_t maximum_sorted_entries = 32; | |
| std::unique_ptr<const PidEntry *[]> sorted | |
| = stat.pidSystemTable[id].sort(uid, (pid_t)0, maximum_sorted_entries); | |
| if (!sorted.get()) { | |
| return output; | |
| } | |
| std::string byPid; | |
| size_t index; | |
| bool hasDropped = false; | |
| for (index = 0; index < maximum_sorted_entries; ++index) { | |
| const PidEntry *entry = sorted[index]; | |
| if (!entry) { | |
| break; | |
| } | |
| if (entry->getSizes() <= (getSizes() / 100)) { | |
| break; | |
| } | |
| if (entry->getDropped()) { | |
| hasDropped = true; | |
| } | |
| byPid += entry->format(stat, id); | |
| } | |
| if (index > 1) { // print this only if interesting | |
| std::string ditto("\" "); | |
| output += formatLine(std::string(" PID/UID COMMAND LINE"), | |
| ditto, hasDropped ? ditto : std::string("")); | |
| output += byPid; | |
| } | |
| return output; | |
| } | |
| std::string PidEntry::formatHeader(const std::string &name, log_id_t /* id */) const { | |
| return formatLine(name, | |
| std::string("Size"), | |
| std::string("Pruned")) | |
| + formatLine(std::string(" PID/UID COMMAND LINE"), | |
| std::string("BYTES"), | |
| std::string("NUM")); | |
| } | |
| std::string PidEntry::format(const LogStatistics &stat, log_id_t /* id */) const { | |
| uid_t uid = getUid(); | |
| pid_t pid = getPid(); | |
| std::string name = android::base::StringPrintf("%5u/%u", pid, uid); | |
| const char *nameTmp = getName(); | |
| if (nameTmp) { | |
| name += android::base::StringPrintf( | |
| "%*s%s", (int)std::max(12 - name.length(), (size_t)1), | |
| "", nameTmp); | |
| } else if ((nameTmp = stat.uidToName(uid))) { | |
| name += android::base::StringPrintf( | |
| "%*s%s", (int)std::max(12 - name.length(), (size_t)1), | |
| "", nameTmp); | |
| free(const_cast<char *>(nameTmp)); | |
| } | |
| std::string size = android::base::StringPrintf("%zu", | |
| getSizes()); | |
| std::string pruned = ""; | |
| size_t dropped = getDropped(); | |
| if (dropped) { | |
| pruned = android::base::StringPrintf("%zu", dropped); | |
| } | |
| return formatLine(name, size, pruned); | |
| } | |
| std::string TidEntry::formatHeader(const std::string &name, log_id_t /* id */) const { | |
| return formatLine(name, | |
| std::string("Size"), | |
| std::string("Pruned")) | |
| + formatLine(std::string(" TID/UID COMM"), | |
| std::string("BYTES"), | |
| std::string("NUM")); | |
| } | |
| std::string TidEntry::format(const LogStatistics &stat, log_id_t /* id */) const { | |
| uid_t uid = getUid(); | |
| std::string name = android::base::StringPrintf("%5u/%u", | |
| getTid(), uid); | |
| const char *nameTmp = getName(); | |
| if (nameTmp) { | |
| name += android::base::StringPrintf( | |
| "%*s%s", (int)std::max(12 - name.length(), (size_t)1), | |
| "", nameTmp); | |
| } else if ((nameTmp = stat.uidToName(uid))) { | |
| // if we do not have a PID name, lets punt to try UID name? | |
| name += android::base::StringPrintf( | |
| "%*s%s", (int)std::max(12 - name.length(), (size_t)1), | |
| "", nameTmp); | |
| free(const_cast<char *>(nameTmp)); | |
| // We tried, better to not have a name at all, we still | |
| // have TID/UID by number to report in any case. | |
| } | |
| std::string size = android::base::StringPrintf("%zu", | |
| getSizes()); | |
| std::string pruned = ""; | |
| size_t dropped = getDropped(); | |
| if (dropped) { | |
| pruned = android::base::StringPrintf("%zu", dropped); | |
| } | |
| return formatLine(name, size, pruned); | |
| } | |
| std::string TagEntry::formatHeader(const std::string &name, log_id_t id) const { | |
| bool isprune = worstUidEnabledForLogid(id); | |
| return formatLine(name, | |
| std::string("Size"), | |
| std::string(isprune ? "Prune" : "")) | |
| + formatLine(std::string(" TAG/UID TAGNAME"), | |
| std::string("BYTES"), | |
| std::string(isprune ? "NUM" : "")); | |
| } | |
| std::string TagEntry::format(const LogStatistics & /* stat */, log_id_t /* id */) const { | |
| std::string name; | |
| uid_t uid = getUid(); | |
| if (uid == (uid_t)-1) { | |
| name = android::base::StringPrintf("%7u", | |
| getKey()); | |
| } else { | |
| name = android::base::StringPrintf("%7u/%u", | |
| getKey(), uid); | |
| } | |
| const char *nameTmp = getName(); | |
| if (nameTmp) { | |
| name += android::base::StringPrintf( | |
| "%*s%s", (int)std::max(14 - name.length(), (size_t)1), | |
| "", nameTmp); | |
| } | |
| std::string size = android::base::StringPrintf("%zu", | |
| getSizes()); | |
| std::string pruned = ""; | |
| return formatLine(name, size, pruned); | |
| } | |
| std::string LogStatistics::format(uid_t uid, pid_t pid, | |
| unsigned int logMask) const { | |
| static const unsigned short spaces_total = 19; | |
| // Report on total logging, current and for all time | |
| std::string output = "size/num"; | |
| size_t oldLength; | |
| short spaces = 1; | |
| log_id_for_each(id) { | |
| if (!(logMask & (1 << id))) { | |
| continue; | |
| } | |
| oldLength = output.length(); | |
| if (spaces < 0) { | |
| spaces = 0; | |
| } | |
| output += android::base::StringPrintf("%*s%s", spaces, "", | |
| android_log_id_to_name(id)); | |
| spaces += spaces_total + oldLength - output.length(); | |
| } | |
| spaces = 4; | |
| output += "\nTotal"; | |
| log_id_for_each(id) { | |
| if (!(logMask & (1 << id))) { | |
| continue; | |
| } | |
| oldLength = output.length(); | |
| if (spaces < 0) { | |
| spaces = 0; | |
| } | |
| output += android::base::StringPrintf("%*s%zu/%zu", spaces, "", | |
| sizesTotal(id), | |
| elementsTotal(id)); | |
| spaces += spaces_total + oldLength - output.length(); | |
| } | |
| spaces = 6; | |
| output += "\nNow"; | |
| log_id_for_each(id) { | |
| if (!(logMask & (1 << id))) { | |
| continue; | |
| } | |
| size_t els = elements(id); | |
| if (els) { | |
| oldLength = output.length(); | |
| if (spaces < 0) { | |
| spaces = 0; | |
| } | |
| output += android::base::StringPrintf("%*s%zu/%zu", spaces, "", | |
| sizes(id), els); | |
| spaces -= output.length() - oldLength; | |
| } | |
| spaces += spaces_total; | |
| } | |
| // Report on Chattiest | |
| std::string name; | |
| // Chattiest by application (UID) | |
| log_id_for_each(id) { | |
| if (!(logMask & (1 << id))) { | |
| continue; | |
| } | |
| name = (uid == AID_ROOT) | |
| ? "Chattiest UIDs in %s log buffer:" | |
| : "Logging for your UID in %s log buffer:"; | |
| output += uidTable[id].format(*this, uid, pid, name, id); | |
| } | |
| if (enable) { | |
| name = ((uid == AID_ROOT) && !pid) | |
| ? "Chattiest PIDs:" | |
| : "Logging for this PID:"; | |
| output += pidTable.format(*this, uid, pid, name); | |
| name = "Chattiest TIDs"; | |
| if (pid) { | |
| name += android::base::StringPrintf(" for PID %d", pid); | |
| } | |
| name += ":"; | |
| output += tidTable.format(*this, uid, pid, name); | |
| } | |
| if (enable && (logMask & (1 << LOG_ID_EVENTS))) { | |
| name = "Chattiest events log buffer TAGs"; | |
| if (pid) { | |
| name += android::base::StringPrintf(" for PID %d", pid); | |
| } | |
| name += ":"; | |
| output += tagTable.format(*this, uid, pid, name, LOG_ID_EVENTS); | |
| } | |
| if (enable && (logMask & (1 << LOG_ID_SECURITY))) { | |
| name = "Chattiest security log buffer TAGs"; | |
| if (pid) { | |
| name += android::base::StringPrintf(" for PID %d", pid); | |
| } | |
| name += ":"; | |
| output += securityTagTable.format(*this, uid, pid, name, LOG_ID_SECURITY); | |
| } | |
| return output; | |
| } | |
| namespace android { | |
| uid_t pidToUid(pid_t pid) { | |
| char buffer[512]; | |
| snprintf(buffer, sizeof(buffer), "/proc/%u/status", pid); | |
| FILE *fp = fopen(buffer, "r"); | |
| if (fp) { | |
| while (fgets(buffer, sizeof(buffer), fp)) { | |
| int uid; | |
| if (sscanf(buffer, "Uid: %d", &uid) == 1) { | |
| fclose(fp); | |
| return uid; | |
| } | |
| } | |
| fclose(fp); | |
| } | |
| return AID_LOGD; // associate this with the logger | |
| } | |
| } | |
| uid_t LogStatistics::pidToUid(pid_t pid) { | |
| return pidTable.add(pid)->second.getUid(); | |
| } | |
| // caller must free character string | |
| const char *LogStatistics::pidToName(pid_t pid) const { | |
| // An inconvenient truth ... getName() can alter the object | |
| pidTable_t &writablePidTable = const_cast<pidTable_t &>(pidTable); | |
| const char *name = writablePidTable.add(pid)->second.getName(); | |
| if (!name) { | |
| return NULL; | |
| } | |
| return strdup(name); | |
| } |