Revert "Modularize logd."
logd isn't meant to be modularized. The previous user was using a
small subset of LogListener.cpp, which is now copied into their
project.
Test: liblog, logd unit tests
This reverts commit fafea32468
.
Change-Id: I05ec764db2d9395f2d5b69a1a610c9c55240ab3a
This commit is contained in:
parent
40da03b742
commit
3096818c8e
6 changed files with 12 additions and 79 deletions
|
@ -39,7 +39,6 @@ cc_library_static {
|
|||
"FlushCommand.cpp",
|
||||
"LogBuffer.cpp",
|
||||
"LogBufferElement.cpp",
|
||||
"LogBufferInterface.cpp",
|
||||
"LogTimes.cpp",
|
||||
"LogStatistics.cpp",
|
||||
"LogWhiteBlackList.cpp",
|
||||
|
|
|
@ -27,7 +27,6 @@
|
|||
#include <sysutils/SocketClient.h>
|
||||
|
||||
#include "LogBufferElement.h"
|
||||
#include "LogBufferInterface.h"
|
||||
#include "LogStatistics.h"
|
||||
#include "LogTags.h"
|
||||
#include "LogTimes.h"
|
||||
|
@ -75,7 +74,7 @@ static bool isMonotonic(const log_time& mono) {
|
|||
|
||||
typedef std::list<LogBufferElement*> LogBufferElementCollection;
|
||||
|
||||
class LogBuffer : public LogBufferInterface {
|
||||
class LogBuffer {
|
||||
LogBufferElementCollection mLogElements;
|
||||
pthread_rwlock_t mLogElementsLock;
|
||||
|
||||
|
@ -108,14 +107,14 @@ class LogBuffer : public LogBufferInterface {
|
|||
LastLogTimes& mTimes;
|
||||
|
||||
explicit LogBuffer(LastLogTimes* times);
|
||||
~LogBuffer() override;
|
||||
~LogBuffer();
|
||||
void init();
|
||||
bool isMonotonic() {
|
||||
return monotonic;
|
||||
}
|
||||
|
||||
int log(log_id_t log_id, log_time realtime, uid_t uid, pid_t pid, pid_t tid,
|
||||
const char* msg, uint16_t len) override;
|
||||
int log(log_id_t log_id, log_time realtime, uid_t uid, pid_t pid, pid_t tid, const char* msg,
|
||||
uint16_t len);
|
||||
// lastTid is an optional context to help detect if the last previous
|
||||
// valid message was from the same source so we can differentiate chatty
|
||||
// filter types (identical or expired)
|
||||
|
|
|
@ -1,21 +0,0 @@
|
|||
/*
|
||||
* Copyright (C) 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 "LogBufferInterface.h"
|
||||
|
||||
LogBufferInterface::LogBufferInterface() {
|
||||
}
|
||||
LogBufferInterface::~LogBufferInterface() {}
|
|
@ -1,40 +0,0 @@
|
|||
/*
|
||||
* Copyright (C) 2012-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.
|
||||
*/
|
||||
|
||||
#ifndef _LOGD_LOG_BUFFER_INTERFACE_H__
|
||||
#define _LOGD_LOG_BUFFER_INTERFACE_H__
|
||||
|
||||
#include <sys/types.h>
|
||||
|
||||
#include <android-base/macros.h>
|
||||
#include <log/log_id.h>
|
||||
#include <log/log_time.h>
|
||||
|
||||
// Abstract interface that handles log when log available.
|
||||
class LogBufferInterface {
|
||||
public:
|
||||
LogBufferInterface();
|
||||
virtual ~LogBufferInterface();
|
||||
// Handles a log entry when available in LogListener.
|
||||
// Returns the size of the handled log message.
|
||||
virtual int log(log_id_t log_id, log_time realtime, uid_t uid, pid_t pid,
|
||||
pid_t tid, const char* msg, uint16_t len) = 0;
|
||||
|
||||
private:
|
||||
DISALLOW_COPY_AND_ASSIGN(LogBufferInterface);
|
||||
};
|
||||
|
||||
#endif // _LOGD_LOG_BUFFER_INTERFACE_H__
|
|
@ -30,9 +30,8 @@
|
|||
#include "LogListener.h"
|
||||
#include "LogUtils.h"
|
||||
|
||||
LogListener::LogListener(LogBufferInterface* buf, LogReader* reader)
|
||||
: SocketListener(getLogSocket(), false), logbuf(buf), reader(reader) {
|
||||
}
|
||||
LogListener::LogListener(LogBuffer* buf, LogReader* reader)
|
||||
: SocketListener(getLogSocket(), false), logbuf(buf), reader(reader) {}
|
||||
|
||||
bool LogListener::onDataAvailable(SocketClient* cli) {
|
||||
static bool name_set;
|
||||
|
@ -107,13 +106,10 @@ bool LogListener::onDataAvailable(SocketClient* cli) {
|
|||
// NB: hdr.msg_flags & MSG_TRUNC is not tested, silently passing a
|
||||
// truncated message to the logs.
|
||||
|
||||
if (logbuf != nullptr) {
|
||||
int res = logbuf->log(
|
||||
logId, header->realtime, cred->uid, cred->pid, header->tid, msg,
|
||||
((size_t)n <= UINT16_MAX) ? (uint16_t)n : UINT16_MAX);
|
||||
if (res > 0 && reader != nullptr) {
|
||||
reader->notifyNewLog(static_cast<log_mask_t>(1 << logId));
|
||||
}
|
||||
int res = logbuf->log(logId, header->realtime, cred->uid, cred->pid, header->tid, msg,
|
||||
((size_t)n <= UINT16_MAX) ? (uint16_t)n : UINT16_MAX);
|
||||
if (res > 0) {
|
||||
reader->notifyNewLog(static_cast<log_mask_t>(1 << logId));
|
||||
}
|
||||
|
||||
return true;
|
||||
|
|
|
@ -21,11 +21,11 @@
|
|||
#include "LogReader.h"
|
||||
|
||||
class LogListener : public SocketListener {
|
||||
LogBufferInterface* logbuf;
|
||||
LogBuffer* logbuf;
|
||||
LogReader* reader;
|
||||
|
||||
public:
|
||||
LogListener(LogBufferInterface* buf, LogReader* reader /* nullable */);
|
||||
LogListener(LogBuffer* buf, LogReader* reader);
|
||||
|
||||
protected:
|
||||
virtual bool onDataAvailable(SocketClient* cli);
|
||||
|
|
Loading…
Reference in a new issue