blob: 16362379c5d7840d31570e53387d0119fc4253e0 [file] [log] [blame]
Mark Salyzyn0175b072014-02-26 09:50:16 -08001/*
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 Salyzynfa3716b2014-02-14 16:05:05 -080017#include <ctype.h>
Mark Salyzyn0175b072014-02-26 09:50:16 -080018#include <poll.h>
Mark Salyzyn8daa9af2014-04-28 14:07:23 -070019#include <sys/prctl.h>
Mark Salyzyn0175b072014-02-26 09:50:16 -080020#include <sys/socket.h>
Mark Salyzyndfc47e82014-03-24 10:26:47 -070021
Mark Salyzyn0175b072014-02-26 09:50:16 -080022#include <cutils/sockets.h>
23
Mark Salyzyn0175b072014-02-26 09:50:16 -080024#include "FlushCommand.h"
Mark Salyzyn2ad0bd02016-02-23 08:55:43 -080025#include "LogBuffer.h"
26#include "LogBufferElement.h"
27#include "LogReader.h"
28#include "LogUtils.h"
Mark Salyzyn0175b072014-02-26 09:50:16 -080029
Mark Salyzyn77187782015-05-12 15:21:31 -070030LogReader::LogReader(LogBuffer *logbuf) :
31 SocketListener(getLogSocket(), true),
32 mLogbuf(*logbuf) {
33}
Mark Salyzyn0175b072014-02-26 09:50:16 -080034
35// When we are notified a new log entry is available, inform
36// all of our listening sockets.
37void LogReader::notifyNewLog() {
38 FlushCommand command(*this);
39 runOnEachSocket(&command);
40}
41
42bool LogReader::onDataAvailable(SocketClient *cli) {
Mark Salyzyne3aeeee2015-03-17 07:56:32 -070043 static bool name_set;
44 if (!name_set) {
45 prctl(PR_SET_NAME, "logd.reader");
46 name_set = true;
47 }
Mark Salyzyn8daa9af2014-04-28 14:07:23 -070048
Mark Salyzyn0175b072014-02-26 09:50:16 -080049 char buffer[255];
50
51 int len = read(cli->getSocket(), buffer, sizeof(buffer) - 1);
52 if (len <= 0) {
53 doSocketDelete(cli);
54 return false;
55 }
56 buffer[len] = '\0';
57
58 unsigned long tail = 0;
59 static const char _tail[] = " tail=";
60 char *cp = strstr(buffer, _tail);
61 if (cp) {
62 tail = atol(cp + sizeof(_tail) - 1);
63 }
64
Mark Salyzynfa3716b2014-02-14 16:05:05 -080065 log_time start(log_time::EPOCH);
66 static const char _start[] = " start=";
67 cp = strstr(buffer, _start);
68 if (cp) {
69 // Parse errors will result in current time
70 start.strptime(cp + sizeof(_start) - 1, "%s.%q");
71 }
72
Mark Salyzynb75cce02015-11-30 11:35:56 -080073 uint64_t timeout = 0;
74 static const char _timeout[] = " timeout=";
75 cp = strstr(buffer, _timeout);
76 if (cp) {
77 timeout = atol(cp + sizeof(_timeout) - 1) * NS_PER_SEC +
78 log_time(CLOCK_REALTIME).nsec();
79 }
80
Mark Salyzyn0175b072014-02-26 09:50:16 -080081 unsigned int logMask = -1;
82 static const char _logIds[] = " lids=";
83 cp = strstr(buffer, _logIds);
84 if (cp) {
85 logMask = 0;
86 cp += sizeof(_logIds) - 1;
87 while (*cp && *cp != '\0') {
88 int val = 0;
Mark Salyzynfa3716b2014-02-14 16:05:05 -080089 while (isdigit(*cp)) {
90 val = val * 10 + *cp - '0';
Mark Salyzyn0175b072014-02-26 09:50:16 -080091 ++cp;
92 }
93 logMask |= 1 << val;
94 if (*cp != ',') {
95 break;
96 }
97 ++cp;
98 }
99 }
100
101 pid_t pid = 0;
102 static const char _pid[] = " pid=";
103 cp = strstr(buffer, _pid);
104 if (cp) {
105 pid = atol(cp + sizeof(_pid) - 1);
106 }
107
108 bool nonBlock = false;
Mark Salyzynddda2122015-10-02 09:22:52 -0700109 if (!fast<strncmp>(buffer, "dumpAndClose", 12)) {
Mark Salyzynf669acb2014-09-16 09:19:47 -0700110 // Allow writer to get some cycles, and wait for pending notifications
111 sched_yield();
112 LogTimeEntry::lock();
113 LogTimeEntry::unlock();
114 sched_yield();
Mark Salyzyn0175b072014-02-26 09:50:16 -0800115 nonBlock = true;
116 }
117
Mark Salyzynf7c0f752015-03-03 13:39:37 -0800118 uint64_t sequence = 1;
119 // Convert realtime to sequence number
120 if (start != log_time::EPOCH) {
Mark Salyzyna1c60cf2014-02-19 07:33:12 -0800121 class LogFindStart {
122 const pid_t mPid;
123 const unsigned mLogMask;
124 bool startTimeSet;
125 log_time &start;
Mark Salyzynf7c0f752015-03-03 13:39:37 -0800126 uint64_t &sequence;
127 uint64_t last;
Mark Salyzynb6bee332015-09-08 08:56:32 -0700128 bool isMonotonic;
Mark Salyzyna1c60cf2014-02-19 07:33:12 -0800129
130 public:
Mark Salyzynb6bee332015-09-08 08:56:32 -0700131 LogFindStart(unsigned logMask, pid_t pid, log_time &start, uint64_t &sequence, bool isMonotonic) :
Mark Salyzyn77187782015-05-12 15:21:31 -0700132 mPid(pid),
133 mLogMask(logMask),
134 startTimeSet(false),
135 start(start),
136 sequence(sequence),
Mark Salyzynb6bee332015-09-08 08:56:32 -0700137 last(sequence),
138 isMonotonic(isMonotonic) {
Mark Salyzyn77187782015-05-12 15:21:31 -0700139 }
Mark Salyzyna1c60cf2014-02-19 07:33:12 -0800140
Mark Salyzynf7c0f752015-03-03 13:39:37 -0800141 static int callback(const LogBufferElement *element, void *obj) {
Mark Salyzyna1c60cf2014-02-19 07:33:12 -0800142 LogFindStart *me = reinterpret_cast<LogFindStart *>(obj);
Mark Salyzynf7c0f752015-03-03 13:39:37 -0800143 if ((!me->mPid || (me->mPid == element->getPid()))
Mark Salyzyna1c60cf2014-02-19 07:33:12 -0800144 && (me->mLogMask & (1 << element->getLogId()))) {
145 if (me->start == element->getRealTime()) {
Mark Salyzynf7c0f752015-03-03 13:39:37 -0800146 me->sequence = element->getSequence();
Mark Salyzyna1c60cf2014-02-19 07:33:12 -0800147 me->startTimeSet = true;
Mark Salyzynf7c0f752015-03-03 13:39:37 -0800148 return -1;
Mark Salyzynb6bee332015-09-08 08:56:32 -0700149 } else if (!me->isMonotonic ||
150 android::isMonotonic(element->getRealTime())) {
Mark Salyzyna1c60cf2014-02-19 07:33:12 -0800151 if (me->start < element->getRealTime()) {
Mark Salyzynf7c0f752015-03-03 13:39:37 -0800152 me->sequence = me->last;
Mark Salyzyna1c60cf2014-02-19 07:33:12 -0800153 me->startTimeSet = true;
Mark Salyzynf7c0f752015-03-03 13:39:37 -0800154 return -1;
Mark Salyzyna1c60cf2014-02-19 07:33:12 -0800155 }
Mark Salyzynf7c0f752015-03-03 13:39:37 -0800156 me->last = element->getSequence();
Mark Salyzynb6bee332015-09-08 08:56:32 -0700157 } else {
158 me->last = element->getSequence();
Mark Salyzyna1c60cf2014-02-19 07:33:12 -0800159 }
160 }
161 return false;
162 }
163
164 bool found() { return startTimeSet; }
Mark Salyzynb6bee332015-09-08 08:56:32 -0700165 } logFindStart(logMask, pid, start, sequence,
166 logbuf().isMonotonic() && android::isMonotonic(start));
Mark Salyzyna1c60cf2014-02-19 07:33:12 -0800167
Mark Salyzynf7c0f752015-03-03 13:39:37 -0800168 logbuf().flushTo(cli, sequence, FlushCommand::hasReadLogs(cli),
Mark Salyzyn8fa88962016-01-26 14:32:35 -0800169 FlushCommand::hasSecurityLogs(cli),
Mark Salyzyna1c60cf2014-02-19 07:33:12 -0800170 logFindStart.callback, &logFindStart);
171
172 if (!logFindStart.found()) {
173 if (nonBlock) {
174 doSocketDelete(cli);
175 return false;
176 }
Mark Salyzynf7c0f752015-03-03 13:39:37 -0800177 sequence = LogBufferElement::getCurrentSequence();
Mark Salyzyna1c60cf2014-02-19 07:33:12 -0800178 }
Mark Salyzynfa3716b2014-02-14 16:05:05 -0800179 }
180
Mark Salyzynb75cce02015-11-30 11:35:56 -0800181 FlushCommand command(*this, nonBlock, tail, logMask, pid, sequence, timeout);
Mark Salyzyn0175b072014-02-26 09:50:16 -0800182 command.runSocketCommand(cli);
183 return true;
184}
185
186void LogReader::doSocketDelete(SocketClient *cli) {
187 LastLogTimes &times = mLogbuf.mTimes;
188 LogTimeEntry::lock();
189 LastLogTimes::iterator it = times.begin();
190 while(it != times.end()) {
191 LogTimeEntry *entry = (*it);
192 if (entry->mClient == cli) {
193 times.erase(it);
194 entry->release_Locked();
195 break;
196 }
197 it++;
198 }
199 LogTimeEntry::unlock();
200}
Mark Salyzyndfc47e82014-03-24 10:26:47 -0700201
202int LogReader::getLogSocket() {
203 static const char socketName[] = "logdr";
204 int sock = android_get_control_socket(socketName);
205
206 if (sock < 0) {
207 sock = socket_local_server(socketName,
208 ANDROID_SOCKET_NAMESPACE_RESERVED,
209 SOCK_SEQPACKET);
210 }
211
212 return sock;
213}