Mark Salyzyn | 0175b07 | 2014-02-26 09:50:16 -0800 | [diff] [blame] | 1 | /* |
| 2 | * Copyright (C) 2012-2013 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 | |
Mark Salyzyn | fa3716b | 2014-02-14 16:05:05 -0800 | [diff] [blame] | 17 | #include <ctype.h> |
Mark Salyzyn | fa3add3 | 2016-12-29 07:26:30 -0800 | [diff] [blame] | 18 | #include <inttypes.h> |
Mark Salyzyn | 0175b07 | 2014-02-26 09:50:16 -0800 | [diff] [blame] | 19 | #include <poll.h> |
Mark Salyzyn | 8daa9af | 2014-04-28 14:07:23 -0700 | [diff] [blame] | 20 | #include <sys/prctl.h> |
Mark Salyzyn | 0175b07 | 2014-02-26 09:50:16 -0800 | [diff] [blame] | 21 | #include <sys/socket.h> |
Mark Salyzyn | 5c77ad5 | 2016-02-23 08:55:43 -0800 | [diff] [blame] | 22 | #include <sys/types.h> |
Mark Salyzyn | dfc47e8 | 2014-03-24 10:26:47 -0700 | [diff] [blame] | 23 | |
Mark Salyzyn | 0175b07 | 2014-02-26 09:50:16 -0800 | [diff] [blame] | 24 | #include <cutils/sockets.h> |
Mark Salyzyn | aeaaf81 | 2016-09-30 13:30:33 -0700 | [diff] [blame] | 25 | #include <private/android_logger.h> |
Mark Salyzyn | 0175b07 | 2014-02-26 09:50:16 -0800 | [diff] [blame] | 26 | |
Mark Salyzyn | 2ad0bd0 | 2016-02-23 08:55:43 -0800 | [diff] [blame] | 27 | #include "LogBuffer.h" |
| 28 | #include "LogBufferElement.h" |
| 29 | #include "LogReader.h" |
| 30 | #include "LogUtils.h" |
Mark Salyzyn | 0175b07 | 2014-02-26 09:50:16 -0800 | [diff] [blame] | 31 | |
Tom Cherry | 79d54f7 | 2020-05-04 11:13:55 -0700 | [diff] [blame] | 32 | static bool CanReadSecurityLogs(SocketClient* client) { |
| 33 | return client->getUid() == AID_SYSTEM || client->getGid() == AID_SYSTEM; |
| 34 | } |
| 35 | |
Mark Salyzyn | 501c373 | 2017-03-10 14:31:54 -0800 | [diff] [blame] | 36 | LogReader::LogReader(LogBuffer* logbuf) |
| 37 | : SocketListener(getLogSocket(), true), mLogbuf(*logbuf) { |
Mark Salyzyn | 7718778 | 2015-05-12 15:21:31 -0700 | [diff] [blame] | 38 | } |
Mark Salyzyn | 0175b07 | 2014-02-26 09:50:16 -0800 | [diff] [blame] | 39 | |
| 40 | // When we are notified a new log entry is available, inform |
Hao Wang | f6e2296 | 2017-12-04 14:10:40 +0800 | [diff] [blame] | 41 | // listening sockets who are watching this entry's log id. |
Tom Cherry | cef47bb | 2020-05-04 17:10:16 -0700 | [diff] [blame^] | 42 | void LogReader::notifyNewLog(unsigned int log_mask) { |
Tom Cherry | 79d54f7 | 2020-05-04 11:13:55 -0700 | [diff] [blame] | 43 | LastLogTimes& times = mLogbuf.mTimes; |
| 44 | |
Tom Cherry | 6ec71e9 | 2020-05-04 12:53:36 -0700 | [diff] [blame] | 45 | LogReaderThread::wrlock(); |
Tom Cherry | 79d54f7 | 2020-05-04 11:13:55 -0700 | [diff] [blame] | 46 | for (const auto& entry : times) { |
Tom Cherry | cef47bb | 2020-05-04 17:10:16 -0700 | [diff] [blame^] | 47 | if (!entry->IsWatchingMultiple(log_mask)) { |
Tom Cherry | 79d54f7 | 2020-05-04 11:13:55 -0700 | [diff] [blame] | 48 | continue; |
| 49 | } |
Tom Cherry | cef47bb | 2020-05-04 17:10:16 -0700 | [diff] [blame^] | 50 | if (entry->timeout().tv_sec || entry->timeout().tv_nsec) { |
Tom Cherry | 79d54f7 | 2020-05-04 11:13:55 -0700 | [diff] [blame] | 51 | continue; |
| 52 | } |
| 53 | entry->triggerReader_Locked(); |
| 54 | } |
Tom Cherry | 6ec71e9 | 2020-05-04 12:53:36 -0700 | [diff] [blame] | 55 | LogReaderThread::unlock(); |
Mark Salyzyn | 0175b07 | 2014-02-26 09:50:16 -0800 | [diff] [blame] | 56 | } |
| 57 | |
Tom Cherry | 4f22786 | 2018-10-08 17:33:50 -0700 | [diff] [blame] | 58 | // Note returning false will release the SocketClient instance. |
Mark Salyzyn | 501c373 | 2017-03-10 14:31:54 -0800 | [diff] [blame] | 59 | bool LogReader::onDataAvailable(SocketClient* cli) { |
Mark Salyzyn | e3aeeee | 2015-03-17 07:56:32 -0700 | [diff] [blame] | 60 | static bool name_set; |
| 61 | if (!name_set) { |
| 62 | prctl(PR_SET_NAME, "logd.reader"); |
| 63 | name_set = true; |
| 64 | } |
Mark Salyzyn | 8daa9af | 2014-04-28 14:07:23 -0700 | [diff] [blame] | 65 | |
Mark Salyzyn | 0175b07 | 2014-02-26 09:50:16 -0800 | [diff] [blame] | 66 | char buffer[255]; |
| 67 | |
| 68 | int len = read(cli->getSocket(), buffer, sizeof(buffer) - 1); |
| 69 | if (len <= 0) { |
| 70 | doSocketDelete(cli); |
| 71 | return false; |
| 72 | } |
| 73 | buffer[len] = '\0'; |
| 74 | |
Tom Cherry | 4f22786 | 2018-10-08 17:33:50 -0700 | [diff] [blame] | 75 | // Clients are only allowed to send one command, disconnect them if they |
| 76 | // send another. |
Tom Cherry | 6ec71e9 | 2020-05-04 12:53:36 -0700 | [diff] [blame] | 77 | LogReaderThread::wrlock(); |
Tom Cherry | 4f22786 | 2018-10-08 17:33:50 -0700 | [diff] [blame] | 78 | for (const auto& entry : mLogbuf.mTimes) { |
Tom Cherry | cef47bb | 2020-05-04 17:10:16 -0700 | [diff] [blame^] | 79 | if (entry->client() == cli) { |
Tom Cherry | 4f22786 | 2018-10-08 17:33:50 -0700 | [diff] [blame] | 80 | entry->release_Locked(); |
Tom Cherry | 6ec71e9 | 2020-05-04 12:53:36 -0700 | [diff] [blame] | 81 | LogReaderThread::unlock(); |
Tom Cherry | 4f22786 | 2018-10-08 17:33:50 -0700 | [diff] [blame] | 82 | return false; |
| 83 | } |
| 84 | } |
Tom Cherry | 6ec71e9 | 2020-05-04 12:53:36 -0700 | [diff] [blame] | 85 | LogReaderThread::unlock(); |
Tom Cherry | 4f22786 | 2018-10-08 17:33:50 -0700 | [diff] [blame] | 86 | |
Mark Salyzyn | 0175b07 | 2014-02-26 09:50:16 -0800 | [diff] [blame] | 87 | unsigned long tail = 0; |
| 88 | static const char _tail[] = " tail="; |
Mark Salyzyn | 501c373 | 2017-03-10 14:31:54 -0800 | [diff] [blame] | 89 | char* cp = strstr(buffer, _tail); |
Mark Salyzyn | 0175b07 | 2014-02-26 09:50:16 -0800 | [diff] [blame] | 90 | if (cp) { |
| 91 | tail = atol(cp + sizeof(_tail) - 1); |
| 92 | } |
| 93 | |
Mark Salyzyn | fa3716b | 2014-02-14 16:05:05 -0800 | [diff] [blame] | 94 | log_time start(log_time::EPOCH); |
| 95 | static const char _start[] = " start="; |
| 96 | cp = strstr(buffer, _start); |
| 97 | if (cp) { |
| 98 | // Parse errors will result in current time |
| 99 | start.strptime(cp + sizeof(_start) - 1, "%s.%q"); |
| 100 | } |
| 101 | |
Mark Salyzyn | b75cce0 | 2015-11-30 11:35:56 -0800 | [diff] [blame] | 102 | uint64_t timeout = 0; |
| 103 | static const char _timeout[] = " timeout="; |
| 104 | cp = strstr(buffer, _timeout); |
| 105 | if (cp) { |
Tom Cherry | c9fa42c | 2020-04-08 10:37:09 -0700 | [diff] [blame] | 106 | timeout = atol(cp + sizeof(_timeout) - 1) * NS_PER_SEC + log_time(CLOCK_MONOTONIC).nsec(); |
Mark Salyzyn | b75cce0 | 2015-11-30 11:35:56 -0800 | [diff] [blame] | 107 | } |
| 108 | |
Mark Salyzyn | 0175b07 | 2014-02-26 09:50:16 -0800 | [diff] [blame] | 109 | unsigned int logMask = -1; |
| 110 | static const char _logIds[] = " lids="; |
| 111 | cp = strstr(buffer, _logIds); |
| 112 | if (cp) { |
| 113 | logMask = 0; |
| 114 | cp += sizeof(_logIds) - 1; |
| 115 | while (*cp && *cp != '\0') { |
| 116 | int val = 0; |
Mark Salyzyn | fa3716b | 2014-02-14 16:05:05 -0800 | [diff] [blame] | 117 | while (isdigit(*cp)) { |
| 118 | val = val * 10 + *cp - '0'; |
Mark Salyzyn | 0175b07 | 2014-02-26 09:50:16 -0800 | [diff] [blame] | 119 | ++cp; |
| 120 | } |
| 121 | logMask |= 1 << val; |
| 122 | if (*cp != ',') { |
| 123 | break; |
| 124 | } |
| 125 | ++cp; |
| 126 | } |
| 127 | } |
| 128 | |
| 129 | pid_t pid = 0; |
| 130 | static const char _pid[] = " pid="; |
| 131 | cp = strstr(buffer, _pid); |
| 132 | if (cp) { |
| 133 | pid = atol(cp + sizeof(_pid) - 1); |
| 134 | } |
| 135 | |
| 136 | bool nonBlock = false; |
Mark Salyzyn | 0eeb06b | 2016-12-02 10:08:48 -0800 | [diff] [blame] | 137 | if (!fastcmp<strncmp>(buffer, "dumpAndClose", 12)) { |
Mark Salyzyn | f669acb | 2014-09-16 09:19:47 -0700 | [diff] [blame] | 138 | // Allow writer to get some cycles, and wait for pending notifications |
| 139 | sched_yield(); |
Tom Cherry | 6ec71e9 | 2020-05-04 12:53:36 -0700 | [diff] [blame] | 140 | LogReaderThread::wrlock(); |
| 141 | LogReaderThread::unlock(); |
Mark Salyzyn | f669acb | 2014-09-16 09:19:47 -0700 | [diff] [blame] | 142 | sched_yield(); |
Mark Salyzyn | 0175b07 | 2014-02-26 09:50:16 -0800 | [diff] [blame] | 143 | nonBlock = true; |
| 144 | } |
| 145 | |
Tom Cherry | 79d54f7 | 2020-05-04 11:13:55 -0700 | [diff] [blame] | 146 | bool privileged = clientHasLogCredentials(cli); |
| 147 | bool can_read_security = CanReadSecurityLogs(cli); |
| 148 | |
Tom Cherry | 10d086e | 2019-08-21 14:16:34 -0700 | [diff] [blame] | 149 | uint64_t sequence = 1; |
| 150 | // Convert realtime to sequence number |
| 151 | if (start != log_time::EPOCH) { |
Tom Cherry | 320f596 | 2020-05-04 17:25:34 -0700 | [diff] [blame] | 152 | bool start_time_set = false; |
| 153 | bool is_monotonic = logbuf().isMonotonic() && android::isMonotonic(start); |
| 154 | uint64_t last = sequence; |
| 155 | auto log_find_start = [pid, logMask, start, is_monotonic, &sequence, &start_time_set, |
| 156 | &last](const LogBufferElement* element) -> int { |
| 157 | if (pid && pid != element->getPid()) { |
| 158 | return 0; |
Mark Salyzyn | a1c60cf | 2014-02-19 07:33:12 -0800 | [diff] [blame] | 159 | } |
Tom Cherry | 320f596 | 2020-05-04 17:25:34 -0700 | [diff] [blame] | 160 | if ((logMask & (1 << element->getLogId())) == 0) { |
| 161 | return 0; |
| 162 | } |
| 163 | if (start == element->getRealTime()) { |
| 164 | sequence = element->getSequence(); |
| 165 | start_time_set = true; |
| 166 | return -1; |
| 167 | } else if (!is_monotonic || android::isMonotonic(element->getRealTime())) { |
| 168 | if (start < element->getRealTime()) { |
| 169 | sequence = last; |
| 170 | start_time_set = true; |
| 171 | return -1; |
| 172 | } |
| 173 | last = element->getSequence(); |
| 174 | } else { |
| 175 | last = element->getSequence(); |
| 176 | } |
| 177 | return 0; |
| 178 | }; |
Mark Salyzyn | a1c60cf | 2014-02-19 07:33:12 -0800 | [diff] [blame] | 179 | |
Tom Cherry | 320f596 | 2020-05-04 17:25:34 -0700 | [diff] [blame] | 180 | logbuf().flushTo(cli, sequence, nullptr, privileged, can_read_security, log_find_start); |
Mark Salyzyn | a1c60cf | 2014-02-19 07:33:12 -0800 | [diff] [blame] | 181 | |
Tom Cherry | 320f596 | 2020-05-04 17:25:34 -0700 | [diff] [blame] | 182 | if (!start_time_set) { |
Tom Cherry | 10d086e | 2019-08-21 14:16:34 -0700 | [diff] [blame] | 183 | if (nonBlock) { |
| 184 | doSocketDelete(cli); |
| 185 | return false; |
| 186 | } |
| 187 | sequence = LogBufferElement::getCurrentSequence(); |
Mark Salyzyn | a1c60cf | 2014-02-19 07:33:12 -0800 | [diff] [blame] | 188 | } |
Mark Salyzyn | fa3716b | 2014-02-14 16:05:05 -0800 | [diff] [blame] | 189 | } |
| 190 | |
Mark Salyzyn | fa3add3 | 2016-12-29 07:26:30 -0800 | [diff] [blame] | 191 | android::prdebug( |
Tom Cherry | 10d086e | 2019-08-21 14:16:34 -0700 | [diff] [blame] | 192 | "logdr: UID=%d GID=%d PID=%d %c tail=%lu logMask=%x pid=%d " |
| 193 | "start=%" PRIu64 "ns timeout=%" PRIu64 "ns\n", |
| 194 | cli->getUid(), cli->getGid(), cli->getPid(), nonBlock ? 'n' : 'b', tail, logMask, |
| 195 | (int)pid, start.nsec(), timeout); |
Mark Salyzyn | fa3add3 | 2016-12-29 07:26:30 -0800 | [diff] [blame] | 196 | |
Tom Cherry | 10d086e | 2019-08-21 14:16:34 -0700 | [diff] [blame] | 197 | if (start == log_time::EPOCH) { |
Tom Cherry | e2d30d1 | 2018-10-19 13:51:35 -0700 | [diff] [blame] | 198 | timeout = 0; |
| 199 | } |
| 200 | |
Tom Cherry | 6ec71e9 | 2020-05-04 12:53:36 -0700 | [diff] [blame] | 201 | LogReaderThread::wrlock(); |
| 202 | auto entry = |
| 203 | std::make_unique<LogReaderThread>(*this, cli, nonBlock, tail, logMask, pid, start, |
| 204 | sequence, timeout, privileged, can_read_security); |
Tom Cherry | 4f22786 | 2018-10-08 17:33:50 -0700 | [diff] [blame] | 205 | if (!entry->startReader_Locked()) { |
Tom Cherry | 6ec71e9 | 2020-05-04 12:53:36 -0700 | [diff] [blame] | 206 | LogReaderThread::unlock(); |
Tom Cherry | 4f22786 | 2018-10-08 17:33:50 -0700 | [diff] [blame] | 207 | return false; |
| 208 | } |
| 209 | |
| 210 | // release client and entry reference counts once done |
| 211 | cli->incRef(); |
| 212 | mLogbuf.mTimes.emplace_front(std::move(entry)); |
Mark Salyzyn | 5c77ad5 | 2016-02-23 08:55:43 -0800 | [diff] [blame] | 213 | |
| 214 | // Set acceptable upper limit to wait for slow reader processing b/27242723 |
| 215 | struct timeval t = { LOGD_SNDTIMEO, 0 }; |
Mark Salyzyn | 501c373 | 2017-03-10 14:31:54 -0800 | [diff] [blame] | 216 | setsockopt(cli->getSocket(), SOL_SOCKET, SO_SNDTIMEO, (const char*)&t, |
| 217 | sizeof(t)); |
Mark Salyzyn | 5c77ad5 | 2016-02-23 08:55:43 -0800 | [diff] [blame] | 218 | |
Tom Cherry | 6ec71e9 | 2020-05-04 12:53:36 -0700 | [diff] [blame] | 219 | LogReaderThread::unlock(); |
Tom Cherry | 4f22786 | 2018-10-08 17:33:50 -0700 | [diff] [blame] | 220 | |
Mark Salyzyn | 0175b07 | 2014-02-26 09:50:16 -0800 | [diff] [blame] | 221 | return true; |
| 222 | } |
| 223 | |
Mark Salyzyn | 501c373 | 2017-03-10 14:31:54 -0800 | [diff] [blame] | 224 | void LogReader::doSocketDelete(SocketClient* cli) { |
| 225 | LastLogTimes& times = mLogbuf.mTimes; |
Tom Cherry | 6ec71e9 | 2020-05-04 12:53:36 -0700 | [diff] [blame] | 226 | LogReaderThread::wrlock(); |
Mark Salyzyn | 0175b07 | 2014-02-26 09:50:16 -0800 | [diff] [blame] | 227 | LastLogTimes::iterator it = times.begin(); |
Mark Salyzyn | 501c373 | 2017-03-10 14:31:54 -0800 | [diff] [blame] | 228 | while (it != times.end()) { |
Tom Cherry | 6ec71e9 | 2020-05-04 12:53:36 -0700 | [diff] [blame] | 229 | LogReaderThread* entry = it->get(); |
Tom Cherry | cef47bb | 2020-05-04 17:10:16 -0700 | [diff] [blame^] | 230 | if (entry->client() == cli) { |
Mark Salyzyn | 0175b07 | 2014-02-26 09:50:16 -0800 | [diff] [blame] | 231 | entry->release_Locked(); |
| 232 | break; |
| 233 | } |
| 234 | it++; |
| 235 | } |
Tom Cherry | 6ec71e9 | 2020-05-04 12:53:36 -0700 | [diff] [blame] | 236 | LogReaderThread::unlock(); |
Mark Salyzyn | 0175b07 | 2014-02-26 09:50:16 -0800 | [diff] [blame] | 237 | } |
Mark Salyzyn | dfc47e8 | 2014-03-24 10:26:47 -0700 | [diff] [blame] | 238 | |
| 239 | int LogReader::getLogSocket() { |
| 240 | static const char socketName[] = "logdr"; |
| 241 | int sock = android_get_control_socket(socketName); |
| 242 | |
| 243 | if (sock < 0) { |
Mark Salyzyn | 501c373 | 2017-03-10 14:31:54 -0800 | [diff] [blame] | 244 | sock = socket_local_server( |
| 245 | socketName, ANDROID_SOCKET_NAMESPACE_RESERVED, SOCK_SEQPACKET); |
Mark Salyzyn | dfc47e8 | 2014-03-24 10:26:47 -0700 | [diff] [blame] | 246 | } |
| 247 | |
| 248 | return sock; |
| 249 | } |