| /* | 
 |  * Copyright (C) 2006-2017 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 <ctype.h> | 
 | #include <dirent.h> | 
 | #include <errno.h> | 
 | #include <error.h> | 
 | #include <fcntl.h> | 
 | #include <getopt.h> | 
 | #include <math.h> | 
 | #include <sched.h> | 
 | #include <stdarg.h> | 
 | #include <stdio.h> | 
 | #include <stdlib.h> | 
 | #include <string.h> | 
 | #include <sys/cdefs.h> | 
 | #include <sys/ioctl.h> | 
 | #include <sys/resource.h> | 
 | #include <sys/stat.h> | 
 | #include <sys/types.h> | 
 | #include <time.h> | 
 | #include <unistd.h> | 
 |  | 
 | #include <memory> | 
 | #include <regex> | 
 | #include <string> | 
 | #include <utility> | 
 | #include <vector> | 
 |  | 
 | #include <android-base/file.h> | 
 | #include <android-base/macros.h> | 
 | #include <android-base/parseint.h> | 
 | #include <android-base/properties.h> | 
 | #include <android-base/stringprintf.h> | 
 | #include <android-base/strings.h> | 
 | #include <android-base/unique_fd.h> | 
 | #include <android/log.h> | 
 | #include <log/event_tag_map.h> | 
 | #include <log/log_id.h> | 
 | #include <log/logprint.h> | 
 | #include <private/android_logger.h> | 
 | #include <processgroup/sched_policy.h> | 
 | #include <system/thread_defs.h> | 
 |  | 
 | #define DEFAULT_MAX_ROTATED_LOGS 4 | 
 |  | 
 | using android::base::Join; | 
 | using android::base::ParseByteCount; | 
 | using android::base::ParseUint; | 
 | using android::base::Split; | 
 | using android::base::StringPrintf; | 
 |  | 
 | class Logcat { | 
 |   public: | 
 |     int Run(int argc, char** argv); | 
 |  | 
 |   private: | 
 |     void RotateLogs(); | 
 |     void ProcessBuffer(struct log_msg* buf); | 
 |     void PrintDividers(log_id_t log_id, bool print_dividers); | 
 |     void SetupOutputAndSchedulingPolicy(bool blocking); | 
 |     int SetLogFormat(const char* format_string); | 
 |  | 
 |     // Used for all options | 
 |     android::base::unique_fd output_fd_{dup(STDOUT_FILENO)}; | 
 |     std::unique_ptr<AndroidLogFormat, decltype(&android_log_format_free)> logformat_{ | 
 |             android_log_format_new(), &android_log_format_free}; | 
 |  | 
 |     // For logging to a file and log rotation | 
 |     const char* output_file_name_ = nullptr; | 
 |     size_t log_rotate_size_kb_ = 0;                       // 0 means "no log rotation" | 
 |     size_t max_rotated_logs_ = DEFAULT_MAX_ROTATED_LOGS;  // 0 means "unbounded" | 
 |     size_t out_byte_count_ = 0; | 
 |  | 
 |     // For binary log buffers | 
 |     int print_binary_ = 0; | 
 |     std::unique_ptr<EventTagMap, decltype(&android_closeEventTagMap)> event_tag_map_{ | 
 |             nullptr, &android_closeEventTagMap}; | 
 |     bool has_opened_event_tag_map_ = false; | 
 |  | 
 |     // For the related --regex, --max-count, --print | 
 |     std::unique_ptr<std::regex> regex_; | 
 |     size_t max_count_ = 0;  // 0 means "infinite" | 
 |     size_t print_count_ = 0; | 
 |     bool print_it_anyways_ = false; | 
 |  | 
 |     // For PrintDividers() | 
 |     log_id_t last_printed_id_ = LOG_ID_MAX; | 
 |     bool printed_start_[LOG_ID_MAX] = {}; | 
 |  | 
 |     bool debug_ = false; | 
 | }; | 
 |  | 
 | #ifndef F2FS_IOC_SET_PIN_FILE | 
 | #define F2FS_IOCTL_MAGIC       0xf5 | 
 | #define F2FS_IOC_SET_PIN_FILE _IOW(F2FS_IOCTL_MAGIC, 13, __u32) | 
 | #endif | 
 |  | 
 | static int openLogFile(const char* pathname, size_t sizeKB) { | 
 |     int fd = open(pathname, O_WRONLY | O_APPEND | O_CREAT | O_CLOEXEC, S_IRUSR | S_IWUSR | S_IRGRP); | 
 |     if (fd < 0) { | 
 |         return fd; | 
 |     } | 
 |  | 
 |     // no need to check errors | 
 |     __u32 set = 1; | 
 |     ioctl(fd, F2FS_IOC_SET_PIN_FILE, &set); | 
 |     fallocate(fd, FALLOC_FL_KEEP_SIZE, 0, (sizeKB << 10)); | 
 |     return fd; | 
 | } | 
 |  | 
 | void Logcat::RotateLogs() { | 
 |     // Can't rotate logs if we're not outputting to a file | 
 |     if (!output_file_name_) return; | 
 |  | 
 |     output_fd_.reset(); | 
 |  | 
 |     // Compute the maximum number of digits needed to count up to | 
 |     // maxRotatedLogs in decimal.  eg: | 
 |     // maxRotatedLogs == 30 | 
 |     //   -> log10(30) == 1.477 | 
 |     //   -> maxRotationCountDigits == 2 | 
 |     int max_rotation_count_digits = | 
 |             max_rotated_logs_ > 0 ? (int)(floor(log10(max_rotated_logs_) + 1)) : 0; | 
 |  | 
 |     for (int i = max_rotated_logs_; i > 0; i--) { | 
 |         std::string file1 = | 
 |                 StringPrintf("%s.%.*d", output_file_name_, max_rotation_count_digits, i); | 
 |  | 
 |         std::string file0; | 
 |         if (!(i - 1)) { | 
 |             file0 = output_file_name_; | 
 |         } else { | 
 |             file0 = StringPrintf("%s.%.*d", output_file_name_, max_rotation_count_digits, i - 1); | 
 |         } | 
 |  | 
 |         if (!file0.length() || !file1.length()) { | 
 |             perror("while rotating log files"); | 
 |             break; | 
 |         } | 
 |  | 
 |         int err = rename(file0.c_str(), file1.c_str()); | 
 |  | 
 |         if (err < 0 && errno != ENOENT) { | 
 |             perror("while rotating log files"); | 
 |         } | 
 |     } | 
 |  | 
 |     output_fd_.reset(openLogFile(output_file_name_, log_rotate_size_kb_)); | 
 |  | 
 |     if (!output_fd_.ok()) { | 
 |         error(EXIT_FAILURE, errno, "Couldn't open output file"); | 
 |     } | 
 |  | 
 |     out_byte_count_ = 0; | 
 | } | 
 |  | 
 | void Logcat::ProcessBuffer(struct log_msg* buf) { | 
 |     int bytesWritten = 0; | 
 |     int err; | 
 |     AndroidLogEntry entry; | 
 |     char binaryMsgBuf[1024]; | 
 |  | 
 |     bool is_binary = | 
 |             buf->id() == LOG_ID_EVENTS || buf->id() == LOG_ID_STATS || buf->id() == LOG_ID_SECURITY; | 
 |  | 
 |     if (is_binary) { | 
 |         if (!event_tag_map_ && !has_opened_event_tag_map_) { | 
 |             event_tag_map_.reset(android_openEventTagMap(nullptr)); | 
 |             has_opened_event_tag_map_ = true; | 
 |         } | 
 |         err = android_log_processBinaryLogBuffer(&buf->entry, &entry, event_tag_map_.get(), | 
 |                                                  binaryMsgBuf, sizeof(binaryMsgBuf)); | 
 |         // printf(">>> pri=%d len=%d msg='%s'\n", | 
 |         //    entry.priority, entry.messageLen, entry.message); | 
 |     } else { | 
 |         err = android_log_processLogBuffer(&buf->entry, &entry); | 
 |     } | 
 |     if (err < 0 && !debug_) return; | 
 |  | 
 |     if (android_log_shouldPrintLine(logformat_.get(), std::string(entry.tag, entry.tagLen).c_str(), | 
 |                                     entry.priority)) { | 
 |         bool match = !regex_ || | 
 |                      std::regex_search(entry.message, entry.message + entry.messageLen, *regex_); | 
 |  | 
 |         print_count_ += match; | 
 |         if (match || print_it_anyways_) { | 
 |             bytesWritten = android_log_printLogLine(logformat_.get(), output_fd_.get(), &entry); | 
 |  | 
 |             if (bytesWritten < 0) { | 
 |                 error(EXIT_FAILURE, 0, "Output error."); | 
 |             } | 
 |         } | 
 |     } | 
 |  | 
 |     out_byte_count_ += bytesWritten; | 
 |  | 
 |     if (log_rotate_size_kb_ > 0 && (out_byte_count_ / 1024) >= log_rotate_size_kb_) { | 
 |         RotateLogs(); | 
 |     } | 
 | } | 
 |  | 
 | void Logcat::PrintDividers(log_id_t log_id, bool print_dividers) { | 
 |     if (log_id == last_printed_id_ || print_binary_) { | 
 |         return; | 
 |     } | 
 |     if (!printed_start_[log_id] || print_dividers) { | 
 |         if (dprintf(output_fd_.get(), "--------- %s %s\n", | 
 |                     printed_start_[log_id] ? "switch to" : "beginning of", | 
 |                     android_log_id_to_name(log_id)) < 0) { | 
 |             error(EXIT_FAILURE, errno, "Output error"); | 
 |         } | 
 |     } | 
 |     last_printed_id_ = log_id; | 
 |     printed_start_[log_id] = true; | 
 | } | 
 |  | 
 | void Logcat::SetupOutputAndSchedulingPolicy(bool blocking) { | 
 |     if (!output_file_name_) return; | 
 |  | 
 |     if (blocking) { | 
 |         // Lower priority and set to batch scheduling if we are saving | 
 |         // the logs into files and taking continuous content. | 
 |         if (set_sched_policy(0, SP_BACKGROUND) < 0) { | 
 |             fprintf(stderr, "failed to set background scheduling policy\n"); | 
 |         } | 
 |  | 
 |         struct sched_param param = {}; | 
 |         if (sched_setscheduler((pid_t)0, SCHED_BATCH, ¶m) < 0) { | 
 |             fprintf(stderr, "failed to set to batch scheduler\n"); | 
 |         } | 
 |  | 
 |         if (setpriority(PRIO_PROCESS, 0, ANDROID_PRIORITY_BACKGROUND) < 0) { | 
 |             fprintf(stderr, "failed set to priority\n"); | 
 |         } | 
 |     } | 
 |  | 
 |     output_fd_.reset(openLogFile(output_file_name_, log_rotate_size_kb_)); | 
 |  | 
 |     if (!output_fd_.ok()) { | 
 |         error(EXIT_FAILURE, errno, "Couldn't open output file"); | 
 |     } | 
 |  | 
 |     struct stat statbuf; | 
 |     if (fstat(output_fd_.get(), &statbuf) == -1) { | 
 |         error(EXIT_FAILURE, errno, "Couldn't get output file stat"); | 
 |     } | 
 |  | 
 |     if ((size_t)statbuf.st_size > SIZE_MAX || statbuf.st_size < 0) { | 
 |         error(EXIT_FAILURE, 0, "Invalid output file stat."); | 
 |     } | 
 |  | 
 |     out_byte_count_ = statbuf.st_size; | 
 | } | 
 |  | 
 | // clang-format off | 
 | static void show_help() { | 
 |     const char* cmd = getprogname(); | 
 |  | 
 |     fprintf(stderr, "Usage: %s [options] [filterspecs]\n", cmd); | 
 |  | 
 |     fprintf(stderr, R"init( | 
 | General options: | 
 |   -b, --buffer=<buffer>       Request alternate ring buffer(s): | 
 |                                 main system radio events crash default all | 
 |                               Additionally, 'kernel' for userdebug and eng builds, and | 
 |                               'security' for Device Owner installations. | 
 |                               Multiple -b parameters or comma separated list of buffers are | 
 |                               allowed. Buffers are interleaved. | 
 |                               Default -b main,system,crash,kernel. | 
 |   -L, --last                  Dump logs from prior to last reboot from pstore. | 
 |   -c, --clear                 Clear (flush) the entire log and exit. | 
 |                               if -f is specified, clear the specified file and its related rotated | 
 |                               log files instead. | 
 |                               if -L is specified, clear pstore log instead. | 
 |   -d                          Dump the log and then exit (don't block). | 
 |   --pid=<pid>                 Only print logs from the given pid. | 
 |   --wrap                      Sleep for 2 hours or when buffer about to wrap whichever | 
 |                               comes first. Improves efficiency of polling by providing | 
 |                               an about-to-wrap wakeup. | 
 |  | 
 | Formatting: | 
 |   -v, --format=<format>       Sets log print format verb and adverbs, where <format> is one of: | 
 |                                 brief help long process raw tag thread threadtime time | 
 |                               Modifying adverbs can be added: | 
 |                                 color descriptive epoch monotonic printable uid usec UTC year zone | 
 |                               Multiple -v parameters or comma separated list of format and format | 
 |                               modifiers are allowed. | 
 |   -D, --dividers              Print dividers between each log buffer. | 
 |   -B, --binary                Output the log in binary. | 
 |  | 
 | Outfile files: | 
 |   -f, --file=<file>           Log to file instead of stdout. | 
 |   -r, --rotate-kbytes=<n>     Rotate log every <n> kbytes. Requires -f option. | 
 |   -n, --rotate-count=<count>  Sets max number of rotated logs to <count>, default 4. | 
 |   --id=<id>                   If the signature <id> for logging to file changes, then clear the | 
 |                               associated files and continue. | 
 |  | 
 | Logd control: | 
 |  These options send a control message to the logd daemon on device, print its return message if | 
 |  applicable, then exit. They are incompatible with -L, as these attributes do not apply to pstore. | 
 |   -g, --buffer-size           Get the size of the ring buffers within logd. | 
 |   -G, --buffer-size=<size>    Set size of a ring buffer in logd. May suffix with K or M. | 
 |                               This can individually control each buffer's size with -b. | 
 |   -S, --statistics            Output statistics. | 
 |                               --pid can be used to provide pid specific stats. | 
 |   -p, --prune                 Print prune white and ~black list. Service is specified as UID, | 
 |                               UID/PID or /PID. Weighed for quicker pruning if prefix with ~, | 
 |                               otherwise weighed for longevity if unadorned. All other pruning | 
 |                               activity is oldest first. Special case ~! represents an automatic | 
 |                               quicker pruning for the noisiest UID as determined by the current | 
 |                               statistics. | 
 |   -P, --prune='<list> ...'    Set prune white and ~black list, using same format as listed above. | 
 |                               Must be quoted. | 
 |  | 
 | Filtering: | 
 |   -s                          Set default filter to silent. Equivalent to filterspec '*:S' | 
 |   -e, --regex=<expr>          Only print lines where the log message matches <expr> where <expr> is | 
 |                               an ECMAScript regular expression. | 
 |   -m, --max-count=<count>     Quit after printing <count> lines. This is meant to be paired with | 
 |                               --regex, but will work on its own. | 
 |   --print                     This option is only applicable when --regex is set and only useful if | 
 |                               --max-count is also provided. | 
 |                               With --print, logcat will print all messages even if they do not | 
 |                               match the regex. Logcat will quit after printing the max-count number | 
 |                               of lines that match the regex. | 
 |   -t <count>                  Print only the most recent <count> lines (implies -d). | 
 |   -t '<time>'                 Print the lines since specified time (implies -d). | 
 |   -T <count>                  Print only the most recent <count> lines (does not imply -d). | 
 |   -T '<time>'                 Print the lines since specified time (not imply -d). | 
 |                               count is pure numerical, time is 'MM-DD hh:mm:ss.mmm...' | 
 |                               'YYYY-MM-DD hh:mm:ss.mmm...' or 'sssss.mmm...' format. | 
 | )init"); | 
 |  | 
 |     fprintf(stderr, "\nfilterspecs are a series of \n" | 
 |                    "  <tag>[:priority]\n\n" | 
 |                    "where <tag> is a log component tag (or * for all) and priority is:\n" | 
 |                    "  V    Verbose (default for <tag>)\n" | 
 |                    "  D    Debug (default for '*')\n" | 
 |                    "  I    Info\n" | 
 |                    "  W    Warn\n" | 
 |                    "  E    Error\n" | 
 |                    "  F    Fatal\n" | 
 |                    "  S    Silent (suppress all output)\n" | 
 |                    "\n'*' by itself means '*:D' and <tag> by itself means <tag>:V.\n" | 
 |                    "If no '*' filterspec or -s on command line, all filter defaults to '*:V'.\n" | 
 |                    "eg: '*:S <tag>' prints only <tag>, '<tag>:S' suppresses all <tag> log messages.\n" | 
 |                    "\nIf not specified on the command line, filterspec is set from ANDROID_LOG_TAGS.\n" | 
 |                    "\nIf not specified with -v on command line, format is set from ANDROID_PRINTF_LOG\n" | 
 |                    "or defaults to \"threadtime\"\n\n"); | 
 | } | 
 |  | 
 | static void show_format_help() { | 
 |     fprintf(stderr, | 
 |         "-v <format>, --format=<format> options:\n" | 
 |         "  Sets log print format verb and adverbs, where <format> is:\n" | 
 |         "    brief long process raw tag thread threadtime time\n" | 
 |         "  and individually flagged modifying adverbs can be added:\n" | 
 |         "    color descriptive epoch monotonic printable uid usec UTC year zone\n" | 
 |         "\nSingle format verbs:\n" | 
 |         "  brief      — Display priority/tag and PID of the process issuing the message.\n" | 
 |         "  long       — Display all metadata fields, separate messages with blank lines.\n" | 
 |         "  process    — Display PID only.\n" | 
 |         "  raw        — Display the raw log message, with no other metadata fields.\n" | 
 |         "  tag        — Display the priority/tag only.\n" | 
 |         "  thread     — Display priority, PID and TID of process issuing the message.\n" | 
 |         "  threadtime — Display the date, invocation time, priority, tag, and the PID\n" | 
 |         "               and TID of the thread issuing the message. (the default format).\n" | 
 |         "  time       — Display the date, invocation time, priority/tag, and PID of the\n" | 
 |         "             process issuing the message.\n" | 
 |         "\nAdverb modifiers can be used in combination:\n" | 
 |         "  color       — Display in highlighted color to match priority. i.e. \x1B[38;5;231mVERBOSE\n" | 
 |         "                \x1B[38;5;75mDEBUG \x1B[38;5;40mINFO \x1B[38;5;166mWARNING \x1B[38;5;196mERROR FATAL\x1B[0m\n" | 
 |         "  descriptive — events logs only, descriptions from event-log-tags database.\n" | 
 |         "  epoch       — Display time as seconds since Jan 1 1970.\n" | 
 |         "  monotonic   — Display time as cpu seconds since last boot.\n" | 
 |         "  printable   — Ensure that any binary logging content is escaped.\n" | 
 |         "  uid         — If permitted, display the UID or Android ID of logged process.\n" | 
 |         "  usec        — Display time down the microsecond precision.\n" | 
 |         "  UTC         — Display time as UTC.\n" | 
 |         "  year        — Add the year to the displayed time.\n" | 
 |         "  zone        — Add the local timezone to the displayed time.\n" | 
 |         "  \"<zone>\"    — Print using this public named timezone (experimental).\n\n" | 
 |     ); | 
 | } | 
 | // clang-format on | 
 |  | 
 | int Logcat::SetLogFormat(const char* format_string) { | 
 |     AndroidLogPrintFormat format = android_log_formatFromString(format_string); | 
 |  | 
 |     // invalid string? | 
 |     if (format == FORMAT_OFF) return -1; | 
 |  | 
 |     return android_log_setPrintFormat(logformat_.get(), format); | 
 | } | 
 |  | 
 | static std::pair<unsigned long, const char*> format_of_size(unsigned long value) { | 
 |     static const char multipliers[][3] = {{""}, {"Ki"}, {"Mi"}, {"Gi"}}; | 
 |     size_t i; | 
 |     for (i = 0; | 
 |          (i < sizeof(multipliers) / sizeof(multipliers[0])) && (value >= 1024); | 
 |          value /= 1024, ++i) | 
 |         ; | 
 |     return std::make_pair(value, multipliers[i]); | 
 | } | 
 |  | 
 | static char* parseTime(log_time& t, const char* cp) { | 
 |     char* ep = t.strptime(cp, "%m-%d %H:%M:%S.%q"); | 
 |     if (ep) return ep; | 
 |     ep = t.strptime(cp, "%Y-%m-%d %H:%M:%S.%q"); | 
 |     if (ep) return ep; | 
 |     return t.strptime(cp, "%s.%q"); | 
 | } | 
 |  | 
 | // Find last logged line in <outputFileName>, or <outputFileName>.1 | 
 | static log_time lastLogTime(const char* outputFileName) { | 
 |     log_time retval(log_time::EPOCH); | 
 |     if (!outputFileName) return retval; | 
 |  | 
 |     std::string directory; | 
 |     const char* file = strrchr(outputFileName, '/'); | 
 |     if (!file) { | 
 |         directory = "."; | 
 |         file = outputFileName; | 
 |     } else { | 
 |         directory = std::string(outputFileName, file - outputFileName); | 
 |         ++file; | 
 |     } | 
 |  | 
 |     std::unique_ptr<DIR, int (*)(DIR*)> dir(opendir(directory.c_str()), | 
 |                                             closedir); | 
 |     if (!dir.get()) return retval; | 
 |  | 
 |     log_time now(android_log_clockid()); | 
 |  | 
 |     size_t len = strlen(file); | 
 |     log_time modulo(0, NS_PER_SEC); | 
 |     struct dirent* dp; | 
 |  | 
 |     while (!!(dp = readdir(dir.get()))) { | 
 |         if ((dp->d_type != DT_REG) || !!strncmp(dp->d_name, file, len) || | 
 |             (dp->d_name[len] && ((dp->d_name[len] != '.') || | 
 |                                  (strtoll(dp->d_name + 1, nullptr, 10) != 1)))) { | 
 |             continue; | 
 |         } | 
 |  | 
 |         std::string file_name = directory; | 
 |         file_name += "/"; | 
 |         file_name += dp->d_name; | 
 |         std::string file; | 
 |         if (!android::base::ReadFileToString(file_name, &file)) continue; | 
 |  | 
 |         bool found = false; | 
 |         for (const auto& line : android::base::Split(file, "\n")) { | 
 |             log_time t(log_time::EPOCH); | 
 |             char* ep = parseTime(t, line.c_str()); | 
 |             if (!ep || (*ep != ' ')) continue; | 
 |             // determine the time precision of the logs (eg: msec or usec) | 
 |             for (unsigned long mod = 1UL; mod < modulo.tv_nsec; mod *= 10) { | 
 |                 if (t.tv_nsec % (mod * 10)) { | 
 |                     modulo.tv_nsec = mod; | 
 |                     break; | 
 |                 } | 
 |             } | 
 |             // We filter any times later than current as we may not have the | 
 |             // year stored with each log entry. Also, since it is possible for | 
 |             // entries to be recorded out of order (very rare) we select the | 
 |             // maximum we find just in case. | 
 |             if ((t < now) && (t > retval)) { | 
 |                 retval = t; | 
 |                 found = true; | 
 |             } | 
 |         } | 
 |         // We count on the basename file to be the definitive end, so stop here. | 
 |         if (!dp->d_name[len] && found) break; | 
 |     } | 
 |     if (retval == log_time::EPOCH) return retval; | 
 |     // tail_time prints matching or higher, round up by the modulo to prevent | 
 |     // a replay of the last entry we have just checked. | 
 |     retval += modulo; | 
 |     return retval; | 
 | } | 
 |  | 
 | void ReportErrorName(const std::string& name, bool allow_security, | 
 |                      std::vector<std::string>* errors) { | 
 |     if (allow_security || name != "security") { | 
 |         errors->emplace_back(name); | 
 |     } | 
 | } | 
 |  | 
 | int Logcat::Run(int argc, char** argv) { | 
 |     bool hasSetLogFormat = false; | 
 |     bool clearLog = false; | 
 |     bool security_buffer_selected = | 
 |             false;  // Do not report errors on the security buffer unless it is explicitly named. | 
 |     bool getLogSize = false; | 
 |     bool getPruneList = false; | 
 |     bool printStatistics = false; | 
 |     bool printDividers = false; | 
 |     unsigned long setLogSize = 0; | 
 |     const char* setPruneList = nullptr; | 
 |     const char* setId = nullptr; | 
 |     int mode = ANDROID_LOG_RDONLY; | 
 |     std::string forceFilters; | 
 |     size_t tail_lines = 0; | 
 |     log_time tail_time(log_time::EPOCH); | 
 |     size_t pid = 0; | 
 |     bool got_t = false; | 
 |     unsigned id_mask = 0; | 
 |  | 
 |     if (argc == 2 && !strcmp(argv[1], "--help")) { | 
 |         show_help(); | 
 |         return EXIT_SUCCESS; | 
 |     } | 
 |  | 
 |     // meant to catch comma-delimited values, but cast a wider | 
 |     // net for stability dealing with possible mistaken inputs. | 
 |     static const char delimiters[] = ",:; \t\n\r\f"; | 
 |  | 
 |     optind = 0; | 
 |     while (true) { | 
 |         int option_index = 0; | 
 |         // list of long-argument only strings for later comparison | 
 |         static const char pid_str[] = "pid"; | 
 |         static const char debug_str[] = "debug"; | 
 |         static const char id_str[] = "id"; | 
 |         static const char wrap_str[] = "wrap"; | 
 |         static const char print_str[] = "print"; | 
 |         // clang-format off | 
 |         static const struct option long_options[] = { | 
 |           { "binary",        no_argument,       nullptr, 'B' }, | 
 |           { "buffer",        required_argument, nullptr, 'b' }, | 
 |           { "buffer-size",   optional_argument, nullptr, 'g' }, | 
 |           { "clear",         no_argument,       nullptr, 'c' }, | 
 |           { debug_str,       no_argument,       nullptr, 0 }, | 
 |           { "dividers",      no_argument,       nullptr, 'D' }, | 
 |           { "file",          required_argument, nullptr, 'f' }, | 
 |           { "format",        required_argument, nullptr, 'v' }, | 
 |           // hidden and undocumented reserved alias for --regex | 
 |           { "grep",          required_argument, nullptr, 'e' }, | 
 |           // hidden and undocumented reserved alias for --max-count | 
 |           { "head",          required_argument, nullptr, 'm' }, | 
 |           { "help",          no_argument,       nullptr, 'h' }, | 
 |           { id_str,          required_argument, nullptr, 0 }, | 
 |           { "last",          no_argument,       nullptr, 'L' }, | 
 |           { "max-count",     required_argument, nullptr, 'm' }, | 
 |           { pid_str,         required_argument, nullptr, 0 }, | 
 |           { print_str,       no_argument,       nullptr, 0 }, | 
 |           { "prune",         optional_argument, nullptr, 'p' }, | 
 |           { "regex",         required_argument, nullptr, 'e' }, | 
 |           { "rotate-count",  required_argument, nullptr, 'n' }, | 
 |           { "rotate-kbytes", required_argument, nullptr, 'r' }, | 
 |           { "statistics",    no_argument,       nullptr, 'S' }, | 
 |           // hidden and undocumented reserved alias for -t | 
 |           { "tail",          required_argument, nullptr, 't' }, | 
 |           // support, but ignore and do not document, the optional argument | 
 |           { wrap_str,        optional_argument, nullptr, 0 }, | 
 |           { nullptr,         0,                 nullptr, 0 } | 
 |         }; | 
 |         // clang-format on | 
 |  | 
 |         int c = getopt_long(argc, argv, ":cdDhLt:T:gG:sQf:r:n:v:b:BSpP:m:e:", long_options, | 
 |                             &option_index); | 
 |         if (c == -1) break; | 
 |  | 
 |         switch (c) { | 
 |             case 0: | 
 |                 // only long options | 
 |                 if (long_options[option_index].name == pid_str) { | 
 |                     if (pid != 0) { | 
 |                         error(EXIT_FAILURE, 0, "Only one --pid argument can be provided."); | 
 |                     } | 
 |  | 
 |                     if (!ParseUint(optarg, &pid) || pid < 1) { | 
 |                         error(EXIT_FAILURE, 0, "%s %s out of range.", | 
 |                               long_options[option_index].name, optarg); | 
 |                     } | 
 |                     break; | 
 |                 } | 
 |                 if (long_options[option_index].name == wrap_str) { | 
 |                     mode |= ANDROID_LOG_WRAP | ANDROID_LOG_RDONLY | | 
 |                             ANDROID_LOG_NONBLOCK; | 
 |                     // ToDo: implement API that supports setting a wrap timeout | 
 |                     size_t dummy = ANDROID_LOG_WRAP_DEFAULT_TIMEOUT; | 
 |                     if (optarg && (!ParseUint(optarg, &dummy) || dummy < 1)) { | 
 |                         error(EXIT_FAILURE, 0, "%s %s out of range.", | 
 |                               long_options[option_index].name, optarg); | 
 |                     } | 
 |                     if (dummy != ANDROID_LOG_WRAP_DEFAULT_TIMEOUT) { | 
 |                         fprintf(stderr, "WARNING: %s %u seconds, ignoring %zu\n", | 
 |                                 long_options[option_index].name, ANDROID_LOG_WRAP_DEFAULT_TIMEOUT, | 
 |                                 dummy); | 
 |                     } | 
 |                     break; | 
 |                 } | 
 |                 if (long_options[option_index].name == print_str) { | 
 |                     print_it_anyways_ = true; | 
 |                     break; | 
 |                 } | 
 |                 if (long_options[option_index].name == debug_str) { | 
 |                     debug_ = true; | 
 |                     break; | 
 |                 } | 
 |                 if (long_options[option_index].name == id_str) { | 
 |                     setId = (optarg && optarg[0]) ? optarg : nullptr; | 
 |                 } | 
 |                 break; | 
 |  | 
 |             case 's': | 
 |                 // default to all silent | 
 |                 android_log_addFilterRule(logformat_.get(), "*:s"); | 
 |                 break; | 
 |  | 
 |             case 'c': | 
 |                 clearLog = true; | 
 |                 mode |= ANDROID_LOG_WRONLY; | 
 |                 break; | 
 |  | 
 |             case 'L': | 
 |                 mode |= ANDROID_LOG_RDONLY | ANDROID_LOG_PSTORE | | 
 |                         ANDROID_LOG_NONBLOCK; | 
 |                 break; | 
 |  | 
 |             case 'd': | 
 |                 mode |= ANDROID_LOG_RDONLY | ANDROID_LOG_NONBLOCK; | 
 |                 break; | 
 |  | 
 |             case 't': | 
 |                 got_t = true; | 
 |                 mode |= ANDROID_LOG_RDONLY | ANDROID_LOG_NONBLOCK; | 
 |                 FALLTHROUGH_INTENDED; | 
 |             case 'T': | 
 |                 if (strspn(optarg, "0123456789") != strlen(optarg)) { | 
 |                     char* cp = parseTime(tail_time, optarg); | 
 |                     if (!cp) { | 
 |                         error(EXIT_FAILURE, 0, "-%c '%s' not in time format.", c, optarg); | 
 |                     } | 
 |                     if (*cp) { | 
 |                         char ch = *cp; | 
 |                         *cp = '\0'; | 
 |                         fprintf(stderr, "WARNING: -%c '%s' '%c%s' time truncated\n", c, optarg, ch, | 
 |                                 cp + 1); | 
 |                         *cp = ch; | 
 |                     } | 
 |                 } else { | 
 |                     if (!ParseUint(optarg, &tail_lines) || tail_lines < 1) { | 
 |                         fprintf(stderr, "WARNING: -%c %s invalid, setting to 1\n", c, optarg); | 
 |                         tail_lines = 1; | 
 |                     } | 
 |                 } | 
 |                 break; | 
 |  | 
 |             case 'D': | 
 |                 printDividers = true; | 
 |                 break; | 
 |  | 
 |             case 'e': | 
 |                 regex_.reset(new std::regex(optarg)); | 
 |                 break; | 
 |  | 
 |             case 'm': { | 
 |                 if (!ParseUint(optarg, &max_count_) || max_count_ < 1) { | 
 |                     error(EXIT_FAILURE, 0, "-%c '%s' isn't an integer greater than zero.", c, | 
 |                           optarg); | 
 |                 } | 
 |             } break; | 
 |  | 
 |             case 'g': | 
 |                 if (!optarg) { | 
 |                     getLogSize = true; | 
 |                     break; | 
 |                 } | 
 |                 FALLTHROUGH_INTENDED; | 
 |  | 
 |             case 'G': { | 
 |                 if (!ParseByteCount(optarg, &setLogSize) || setLogSize < 1) { | 
 |                     error(EXIT_FAILURE, 0, "-G must be specified as <num><multiplier>."); | 
 |                 } | 
 |             } break; | 
 |  | 
 |             case 'p': | 
 |                 if (!optarg) { | 
 |                     getPruneList = true; | 
 |                     break; | 
 |                 } | 
 |                 FALLTHROUGH_INTENDED; | 
 |  | 
 |             case 'P': | 
 |                 setPruneList = optarg; | 
 |                 break; | 
 |  | 
 |             case 'b': | 
 |                 for (const auto& buffer : Split(optarg, delimiters)) { | 
 |                     if (buffer == "default") { | 
 |                         id_mask |= (1 << LOG_ID_MAIN) | (1 << LOG_ID_SYSTEM) | (1 << LOG_ID_CRASH); | 
 |                     } else if (buffer == "all") { | 
 |                         id_mask = -1; | 
 |                     } else { | 
 |                         log_id_t log_id = android_name_to_log_id(buffer.c_str()); | 
 |                         if (log_id >= LOG_ID_MAX) { | 
 |                             error(EXIT_FAILURE, 0, "Unknown buffer '%s' listed for -b.", | 
 |                                   buffer.c_str()); | 
 |                         } | 
 |                         if (log_id == LOG_ID_SECURITY) { | 
 |                             security_buffer_selected = true; | 
 |                         } | 
 |                         id_mask |= (1 << log_id); | 
 |                     } | 
 |                 } | 
 |                 break; | 
 |  | 
 |             case 'B': | 
 |                 print_binary_ = 1; | 
 |                 break; | 
 |  | 
 |             case 'f': | 
 |                 if ((tail_time == log_time::EPOCH) && !tail_lines) { | 
 |                     tail_time = lastLogTime(optarg); | 
 |                 } | 
 |                 // redirect output to a file | 
 |                 output_file_name_ = optarg; | 
 |                 break; | 
 |  | 
 |             case 'r': | 
 |                 if (!ParseUint(optarg, &log_rotate_size_kb_) || log_rotate_size_kb_ < 1) { | 
 |                     error(EXIT_FAILURE, 0, "Invalid parameter '%s' to -r.", optarg); | 
 |                 } | 
 |                 break; | 
 |  | 
 |             case 'n': | 
 |                 if (!ParseUint(optarg, &max_rotated_logs_) || max_rotated_logs_ < 1) { | 
 |                     error(EXIT_FAILURE, 0, "Invalid parameter '%s' to -n.", optarg); | 
 |                 } | 
 |                 break; | 
 |  | 
 |             case 'v': | 
 |                 if (!strcmp(optarg, "help") || !strcmp(optarg, "--help")) { | 
 |                     show_format_help(); | 
 |                     return EXIT_SUCCESS; | 
 |                 } | 
 |                 for (const auto& arg : Split(optarg, delimiters)) { | 
 |                     int err = SetLogFormat(arg.c_str()); | 
 |                     if (err < 0) { | 
 |                         error(EXIT_FAILURE, 0, "Invalid parameter '%s' to -v.", arg.c_str()); | 
 |                     } | 
 |                     if (err) hasSetLogFormat = true; | 
 |                 } | 
 |                 break; | 
 |  | 
 |             case 'Q': | 
 | #define LOGCAT_FILTER "androidboot.logcat=" | 
 | #define CONSOLE_PIPE_OPTION "androidboot.consolepipe=" | 
 | #define CONSOLE_OPTION "androidboot.console=" | 
 | #define QEMU_PROPERTY "ro.kernel.qemu" | 
 | #define QEMU_CMDLINE "qemu.cmdline" | 
 |                 // This is a *hidden* option used to start a version of logcat | 
 |                 // in an emulated device only.  It basically looks for | 
 |                 // androidboot.logcat= on the kernel command line.  If | 
 |                 // something is found, it extracts a log filter and uses it to | 
 |                 // run the program. The logcat output will go to consolepipe if | 
 |                 // androiboot.consolepipe (e.g. qemu_pipe) is given, otherwise, | 
 |                 // it goes to androidboot.console (e.g. tty) | 
 |                 { | 
 |                     // if not in emulator, exit quietly | 
 |                     if (false == android::base::GetBoolProperty(QEMU_PROPERTY, false)) { | 
 |                         return EXIT_SUCCESS; | 
 |                     } | 
 |  | 
 |                     std::string cmdline = android::base::GetProperty(QEMU_CMDLINE, ""); | 
 |                     if (cmdline.empty()) { | 
 |                         android::base::ReadFileToString("/proc/cmdline", &cmdline); | 
 |                     } | 
 |  | 
 |                     const char* logcatFilter = strstr(cmdline.c_str(), LOGCAT_FILTER); | 
 |                     // if nothing found or invalid filters, exit quietly | 
 |                     if (!logcatFilter) { | 
 |                         return EXIT_SUCCESS; | 
 |                     } | 
 |  | 
 |                     const char* p = logcatFilter + strlen(LOGCAT_FILTER); | 
 |                     const char* q = strpbrk(p, " \t\n\r"); | 
 |                     if (!q) q = p + strlen(p); | 
 |                     forceFilters = std::string(p, q); | 
 |  | 
 |                     // redirect our output to the emulator console pipe or console | 
 |                     const char* consolePipe = | 
 |                         strstr(cmdline.c_str(), CONSOLE_PIPE_OPTION); | 
 |                     const char* console = | 
 |                         strstr(cmdline.c_str(), CONSOLE_OPTION); | 
 |  | 
 |                     if (consolePipe) { | 
 |                         p = consolePipe + strlen(CONSOLE_PIPE_OPTION); | 
 |                     } else if (console) { | 
 |                         p = console + strlen(CONSOLE_OPTION); | 
 |                     } else { | 
 |                         return EXIT_FAILURE; | 
 |                     } | 
 |  | 
 |                     q = strpbrk(p, " \t\n\r"); | 
 |                     int len = q ? q - p : strlen(p); | 
 |                     std::string devname = "/dev/" + std::string(p, len); | 
 |                     std::string pipePurpose("pipe:logcat"); | 
 |                     if (consolePipe) { | 
 |                         // example: "qemu_pipe,pipe:logcat" | 
 |                         // upon opening of /dev/qemu_pipe, the "pipe:logcat" | 
 |                         // string with trailing '\0' should be written to the fd | 
 |                         size_t pos = devname.find(','); | 
 |                         if (pos != std::string::npos) { | 
 |                             pipePurpose = devname.substr(pos + 1); | 
 |                             devname = devname.substr(0, pos); | 
 |                         } | 
 |                     } | 
 |  | 
 |                     fprintf(stderr, "logcat using %s\n", devname.c_str()); | 
 |  | 
 |                     int fd = open(devname.c_str(), O_WRONLY | O_CLOEXEC); | 
 |                     if (fd < 0) { | 
 |                         break; | 
 |                     } | 
 |  | 
 |                     if (consolePipe) { | 
 |                         // need the trailing '\0' | 
 |                         if (!android::base::WriteFully(fd, pipePurpose.c_str(), | 
 |                                                        pipePurpose.size() + 1)) { | 
 |                             close(fd); | 
 |                             return EXIT_FAILURE; | 
 |                         } | 
 |                     } | 
 |                     // close output and error channels, replace with console | 
 |                     dup2(fd, output_fd_.get()); | 
 |                     dup2(fd, STDERR_FILENO); | 
 |                     close(fd); | 
 |                 } | 
 |                 break; | 
 |  | 
 |             case 'S': | 
 |                 printStatistics = true; | 
 |                 break; | 
 |  | 
 |             case ':': | 
 |                 error(EXIT_FAILURE, 0, "Option '%s' needs an argument.", argv[optind - 1]); | 
 |                 break; | 
 |  | 
 |             case 'h': | 
 |                 show_help(); | 
 |                 show_format_help(); | 
 |                 return EXIT_SUCCESS; | 
 |  | 
 |             case '?': | 
 |                 error(EXIT_FAILURE, 0, "Unknown option '%s'.", argv[optind - 1]); | 
 |                 break; | 
 |  | 
 |             default: | 
 |                 error(EXIT_FAILURE, 0, "Unknown getopt_long() result '%c'.", c); | 
 |         } | 
 |     } | 
 |  | 
 |     if (max_count_ && got_t) { | 
 |         error(EXIT_FAILURE, 0, "Cannot use -m (--max-count) and -t together."); | 
 |     } | 
 |     if (print_it_anyways_ && (!regex_ || !max_count_)) { | 
 |         // One day it would be nice if --print -v color and --regex <expr> | 
 |         // could play with each other and show regex highlighted content. | 
 |         fprintf(stderr, | 
 |                 "WARNING: " | 
 |                 "--print ignored, to be used in combination with\n" | 
 |                 "         " | 
 |                 "--regex <expr> and --max-count <N>\n"); | 
 |         print_it_anyways_ = false; | 
 |     } | 
 |  | 
 |     // If no buffers are specified, default to using these buffers. | 
 |     if (id_mask == 0) { | 
 |         id_mask = (1 << LOG_ID_MAIN) | (1 << LOG_ID_SYSTEM) | (1 << LOG_ID_CRASH) | | 
 |                   (1 << LOG_ID_KERNEL); | 
 |     } | 
 |  | 
 |     if (log_rotate_size_kb_ != 0 && !output_file_name_) { | 
 |         error(EXIT_FAILURE, 0, "-r requires -f as well."); | 
 |     } | 
 |  | 
 |     if (setId != 0) { | 
 |         if (!output_file_name_) { | 
 |             error(EXIT_FAILURE, 0, "--id='%s' requires -f as well.", setId); | 
 |         } | 
 |  | 
 |         std::string file_name = StringPrintf("%s.id", output_file_name_); | 
 |         std::string file; | 
 |         bool file_ok = android::base::ReadFileToString(file_name, &file); | 
 |         android::base::WriteStringToFile(setId, file_name, S_IRUSR | S_IWUSR, | 
 |                                          getuid(), getgid()); | 
 |         if (!file_ok || !file.compare(setId)) setId = nullptr; | 
 |     } | 
 |  | 
 |     if (!hasSetLogFormat) { | 
 |         const char* logFormat = getenv("ANDROID_PRINTF_LOG"); | 
 |  | 
 |         if (!!logFormat) { | 
 |             for (const auto& arg : Split(logFormat, delimiters)) { | 
 |                 int err = SetLogFormat(arg.c_str()); | 
 |                 // environment should not cause crash of logcat | 
 |                 if (err < 0) { | 
 |                     fprintf(stderr, "invalid format in ANDROID_PRINTF_LOG '%s'\n", arg.c_str()); | 
 |                 } | 
 |                 if (err > 0) hasSetLogFormat = true; | 
 |             } | 
 |         } | 
 |         if (!hasSetLogFormat) { | 
 |             SetLogFormat("threadtime"); | 
 |         } | 
 |     } | 
 |  | 
 |     if (forceFilters.size()) { | 
 |         int err = android_log_addFilterString(logformat_.get(), forceFilters.c_str()); | 
 |         if (err < 0) { | 
 |             error(EXIT_FAILURE, 0, "Invalid filter expression in logcat args."); | 
 |         } | 
 |     } else if (argc == optind) { | 
 |         // Add from environment variable | 
 |         const char* env_tags_orig = getenv("ANDROID_LOG_TAGS"); | 
 |  | 
 |         if (!!env_tags_orig) { | 
 |             int err = android_log_addFilterString(logformat_.get(), env_tags_orig); | 
 |  | 
 |             if (err < 0) { | 
 |                 error(EXIT_FAILURE, 0, "Invalid filter expression in ANDROID_LOG_TAGS."); | 
 |             } | 
 |         } | 
 |     } else { | 
 |         // Add from commandline | 
 |         for (int i = optind ; i < argc ; i++) { | 
 |             int err = android_log_addFilterString(logformat_.get(), argv[i]); | 
 |             if (err < 0) { | 
 |                 error(EXIT_FAILURE, 0, "Invalid filter expression '%s'.", argv[i]); | 
 |             } | 
 |         } | 
 |     } | 
 |  | 
 |     if (mode & ANDROID_LOG_PSTORE) { | 
 |         if (output_file_name_) { | 
 |             error(EXIT_FAILURE, 0, "-c is ambiguous with both -f and -L specified."); | 
 |         } | 
 |         if (setLogSize || getLogSize || printStatistics || getPruneList || setPruneList) { | 
 |             error(EXIT_FAILURE, 0, "-L is incompatible with -g/-G, -S, and -p/-P."); | 
 |         } | 
 |         if (clearLog) { | 
 |             unlink("/sys/fs/pstore/pmsg-ramoops-0"); | 
 |             return EXIT_SUCCESS; | 
 |         } | 
 |     } | 
 |  | 
 |     if (output_file_name_) { | 
 |         if (setLogSize || getLogSize || printStatistics || getPruneList || setPruneList) { | 
 |             error(EXIT_FAILURE, 0, "-f is incompatible with -g/-G, -S, and -p/-P."); | 
 |         } | 
 |  | 
 |         if (clearLog || setId) { | 
 |             int max_rotation_count_digits = | 
 |                     max_rotated_logs_ > 0 ? (int)(floor(log10(max_rotated_logs_) + 1)) : 0; | 
 |  | 
 |             for (int i = max_rotated_logs_; i >= 0; --i) { | 
 |                 std::string file; | 
 |  | 
 |                 if (!i) { | 
 |                     file = output_file_name_; | 
 |                 } else { | 
 |                     file = StringPrintf("%s.%.*d", output_file_name_, max_rotation_count_digits, i); | 
 |                 } | 
 |  | 
 |                 int err = unlink(file.c_str()); | 
 |  | 
 |                 if (err < 0 && errno != ENOENT) { | 
 |                     fprintf(stderr, "failed to delete log file '%s': %s\n", file.c_str(), | 
 |                             strerror(errno)); | 
 |                 } | 
 |             } | 
 |         } | 
 |  | 
 |         if (clearLog) { | 
 |             return EXIT_SUCCESS; | 
 |         } | 
 |     } | 
 |  | 
 |     std::unique_ptr<logger_list, decltype(&android_logger_list_free)> logger_list{ | 
 |             nullptr, &android_logger_list_free}; | 
 |     if (tail_time != log_time::EPOCH) { | 
 |         logger_list.reset(android_logger_list_alloc_time(mode, tail_time, pid)); | 
 |     } else { | 
 |         logger_list.reset(android_logger_list_alloc(mode, tail_lines, pid)); | 
 |     } | 
 |     // We have three orthogonal actions below to clear, set log size and | 
 |     // get log size. All sharing the same iteration loop. | 
 |     std::vector<std::string> open_device_failures; | 
 |     std::vector<std::string> clear_failures; | 
 |     std::vector<std::string> set_size_failures; | 
 |     std::vector<std::string> get_size_failures; | 
 |  | 
 |     for (int i = LOG_ID_MIN; i < LOG_ID_MAX; ++i) { | 
 |         if (!(id_mask & (1 << i))) continue; | 
 |         const char* buffer_name = android_log_id_to_name(static_cast<log_id_t>(i)); | 
 |  | 
 |         auto logger = android_logger_open(logger_list.get(), static_cast<log_id_t>(i)); | 
 |         if (logger == nullptr) { | 
 |             ReportErrorName(buffer_name, security_buffer_selected, &open_device_failures); | 
 |             continue; | 
 |         } | 
 |  | 
 |         if (clearLog) { | 
 |             if (android_logger_clear(logger)) { | 
 |                 ReportErrorName(buffer_name, security_buffer_selected, &clear_failures); | 
 |             } | 
 |         } | 
 |  | 
 |         if (setLogSize) { | 
 |             if (android_logger_set_log_size(logger, setLogSize)) { | 
 |                 ReportErrorName(buffer_name, security_buffer_selected, &set_size_failures); | 
 |             } | 
 |         } | 
 |  | 
 |         if (getLogSize) { | 
 |             long size = android_logger_get_log_size(logger); | 
 |             long readable = android_logger_get_log_readable_size(logger); | 
 |  | 
 |             if (size < 0 || readable < 0) { | 
 |                 ReportErrorName(buffer_name, security_buffer_selected, &get_size_failures); | 
 |             } else { | 
 |                 auto size_format = format_of_size(size); | 
 |                 auto readable_format = format_of_size(readable); | 
 |                 std::string str = android::base::StringPrintf( | 
 |                         "%s: ring buffer is %lu %sB (%lu %sB consumed)," | 
 |                         " max entry is %d B, max payload is %d B\n", | 
 |                         buffer_name, size_format.first, size_format.second, readable_format.first, | 
 |                         readable_format.second, (int)LOGGER_ENTRY_MAX_LEN, | 
 |                         (int)LOGGER_ENTRY_MAX_PAYLOAD); | 
 |                 TEMP_FAILURE_RETRY(write(output_fd_.get(), str.data(), str.length())); | 
 |             } | 
 |         } | 
 |     } | 
 |  | 
 |     // report any errors in the above loop and exit | 
 |     if (!open_device_failures.empty()) { | 
 |         error(EXIT_FAILURE, 0, "Unable to open log device%s '%s'.", | 
 |               open_device_failures.size() > 1 ? "s" : "", Join(open_device_failures, ",").c_str()); | 
 |     } | 
 |     if (!clear_failures.empty()) { | 
 |         error(EXIT_FAILURE, 0, "failed to clear the '%s' log%s.", Join(clear_failures, ",").c_str(), | 
 |               clear_failures.size() > 1 ? "s" : ""); | 
 |     } | 
 |     if (!set_size_failures.empty()) { | 
 |         error(EXIT_FAILURE, 0, "failed to set the '%s' log size%s.", | 
 |               Join(set_size_failures, ",").c_str(), set_size_failures.size() > 1 ? "s" : ""); | 
 |     } | 
 |     if (!get_size_failures.empty()) { | 
 |         error(EXIT_FAILURE, 0, "failed to get the readable '%s' log size%s.", | 
 |               Join(get_size_failures, ",").c_str(), get_size_failures.size() > 1 ? "s" : ""); | 
 |     } | 
 |  | 
 |     if (setPruneList) { | 
 |         size_t len = strlen(setPruneList); | 
 |         if (android_logger_set_prune_list(logger_list.get(), setPruneList, len)) { | 
 |             error(EXIT_FAILURE, 0, "Failed to set the prune list."); | 
 |         } | 
 |         return EXIT_SUCCESS; | 
 |     } | 
 |  | 
 |     if (printStatistics || getPruneList) { | 
 |         std::string buf(8192, '\0'); | 
 |         size_t ret_length = 0; | 
 |         int retry = 32; | 
 |  | 
 |         for (; retry >= 0; --retry) { | 
 |             if (getPruneList) { | 
 |                 android_logger_get_prune_list(logger_list.get(), buf.data(), buf.size()); | 
 |             } else { | 
 |                 android_logger_get_statistics(logger_list.get(), buf.data(), buf.size()); | 
 |             } | 
 |  | 
 |             ret_length = atol(buf.c_str()); | 
 |             if (ret_length < 3) { | 
 |                 error(EXIT_FAILURE, 0, "Failed to read data."); | 
 |             } | 
 |  | 
 |             if (ret_length < buf.size()) { | 
 |                 break; | 
 |             } | 
 |  | 
 |             buf.resize(ret_length + 1); | 
 |         } | 
 |  | 
 |         if (retry < 0) { | 
 |             error(EXIT_FAILURE, 0, "Failed to read data."); | 
 |         } | 
 |  | 
 |         buf.resize(ret_length); | 
 |         if (buf.back() == '\f') { | 
 |             buf.pop_back(); | 
 |         } | 
 |  | 
 |         // Remove the byte count prefix | 
 |         const char* cp = buf.c_str(); | 
 |         while (isdigit(*cp)) ++cp; | 
 |         if (*cp == '\n') ++cp; | 
 |  | 
 |         size_t len = strlen(cp); | 
 |         TEMP_FAILURE_RETRY(write(output_fd_.get(), cp, len)); | 
 |         return EXIT_SUCCESS; | 
 |     } | 
 |  | 
 |     if (getLogSize || setLogSize || clearLog) return EXIT_SUCCESS; | 
 |  | 
 |     SetupOutputAndSchedulingPolicy(!(mode & ANDROID_LOG_NONBLOCK)); | 
 |  | 
 |     while (!max_count_ || print_count_ < max_count_) { | 
 |         struct log_msg log_msg; | 
 |         int ret = android_logger_list_read(logger_list.get(), &log_msg); | 
 |         if (!ret) { | 
 |             error(EXIT_FAILURE, 0, R"init(Unexpected EOF! | 
 |  | 
 | This means that either logd crashed, or more likely, this instance of logcat was unable to read log | 
 | messages as quickly as they were being produced. | 
 |  | 
 | If you have enabled significant logging, look into using the -G option to increase log buffer sizes.)init"); | 
 |         } | 
 |  | 
 |         if (ret < 0) { | 
 |             if (ret == -EAGAIN) break; | 
 |  | 
 |             if (ret == -EIO) { | 
 |                 error(EXIT_FAILURE, 0, "Unexpected EOF!"); | 
 |             } | 
 |             if (ret == -EINVAL) { | 
 |                 error(EXIT_FAILURE, 0, "Unexpected length."); | 
 |             } | 
 |             error(EXIT_FAILURE, errno, "Logcat read failure"); | 
 |         } | 
 |  | 
 |         if (log_msg.id() > LOG_ID_MAX) { | 
 |             error(EXIT_FAILURE, 0, "Unexpected log id (%d) over LOG_ID_MAX (%d).", log_msg.id(), | 
 |                   LOG_ID_MAX); | 
 |         } | 
 |  | 
 |         PrintDividers(log_msg.id(), printDividers); | 
 |  | 
 |         if (print_binary_) { | 
 |             TEMP_FAILURE_RETRY(write(output_fd_.get(), &log_msg, log_msg.len())); | 
 |         } else { | 
 |             ProcessBuffer(&log_msg); | 
 |         } | 
 |     } | 
 |     return EXIT_SUCCESS; | 
 | } | 
 |  | 
 | int main(int argc, char** argv) { | 
 |     Logcat logcat; | 
 |     return logcat.Run(argc, argv); | 
 | } |