Skip to content

Commit

Permalink
logd: Cleanup
Browse files Browse the repository at this point in the history
(cherry pick from commit 7718778)

- Android Coding Standard for Constructors
- Side effects NONE

Change-Id: I2cda9dd73f3ac3ab58f394015cb810820093d47b
  • Loading branch information
Mark Salyzyn committed May 13, 2015
1 parent 79c3815 commit 66091f1
Show file tree
Hide file tree
Showing 12 changed files with 111 additions and 119 deletions.
79 changes: 39 additions & 40 deletions logd/CommandListener.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -33,9 +33,9 @@
#include "LogCommand.h"

CommandListener::CommandListener(LogBuffer *buf, LogReader * /*reader*/,
LogListener * /*swl*/)
: FrameworkListener(getLogSocket())
, mBuf(*buf) {
LogListener * /*swl*/) :
FrameworkListener(getLogSocket()),
mBuf(*buf) {
// registerCmd(new ShutdownCmd(buf, writer, swl));
registerCmd(new ClearCmd(buf));
registerCmd(new GetBufSizeCmd(buf));
Expand All @@ -48,12 +48,12 @@ CommandListener::CommandListener(LogBuffer *buf, LogReader * /*reader*/,
}

CommandListener::ShutdownCmd::ShutdownCmd(LogBuffer *buf, LogReader *reader,
LogListener *swl)
: LogCommand("shutdown")
, mBuf(*buf)
, mReader(*reader)
, mSwl(*swl)
{ }
LogListener *swl) :
LogCommand("shutdown"),
mBuf(*buf),
mReader(*reader),
mSwl(*swl) {
}

int CommandListener::ShutdownCmd::runCommand(SocketClient * /*cli*/,
int /*argc*/,
Expand All @@ -63,10 +63,10 @@ int CommandListener::ShutdownCmd::runCommand(SocketClient * /*cli*/,
exit(0);
}

CommandListener::ClearCmd::ClearCmd(LogBuffer *buf)
: LogCommand("clear")
, mBuf(*buf)
{ }
CommandListener::ClearCmd::ClearCmd(LogBuffer *buf) :
LogCommand("clear"),
mBuf(*buf) {
}

static void setname() {
static bool name_set;
Expand Down Expand Up @@ -100,10 +100,10 @@ int CommandListener::ClearCmd::runCommand(SocketClient *cli,
return 0;
}

CommandListener::GetBufSizeCmd::GetBufSizeCmd(LogBuffer *buf)
: LogCommand("getLogSize")
, mBuf(*buf)
{ }
CommandListener::GetBufSizeCmd::GetBufSizeCmd(LogBuffer *buf) :
LogCommand("getLogSize"),
mBuf(*buf) {
}

int CommandListener::GetBufSizeCmd::runCommand(SocketClient *cli,
int argc, char **argv) {
Expand All @@ -126,10 +126,10 @@ int CommandListener::GetBufSizeCmd::runCommand(SocketClient *cli,
return 0;
}

CommandListener::SetBufSizeCmd::SetBufSizeCmd(LogBuffer *buf)
: LogCommand("setLogSize")
, mBuf(*buf)
{ }
CommandListener::SetBufSizeCmd::SetBufSizeCmd(LogBuffer *buf) :
LogCommand("setLogSize"),
mBuf(*buf) {
}

int CommandListener::SetBufSizeCmd::runCommand(SocketClient *cli,
int argc, char **argv) {
Expand Down Expand Up @@ -160,10 +160,10 @@ int CommandListener::SetBufSizeCmd::runCommand(SocketClient *cli,
return 0;
}

CommandListener::GetBufSizeUsedCmd::GetBufSizeUsedCmd(LogBuffer *buf)
: LogCommand("getLogSizeUsed")
, mBuf(*buf)
{ }
CommandListener::GetBufSizeUsedCmd::GetBufSizeUsedCmd(LogBuffer *buf) :
LogCommand("getLogSizeUsed"),
mBuf(*buf) {
}

int CommandListener::GetBufSizeUsedCmd::runCommand(SocketClient *cli,
int argc, char **argv) {
Expand All @@ -186,10 +186,10 @@ int CommandListener::GetBufSizeUsedCmd::runCommand(SocketClient *cli,
return 0;
}

CommandListener::GetStatisticsCmd::GetStatisticsCmd(LogBuffer *buf)
: LogCommand("getStatistics")
, mBuf(*buf)
{ }
CommandListener::GetStatisticsCmd::GetStatisticsCmd(LogBuffer *buf) :
LogCommand("getStatistics"),
mBuf(*buf) {
}

static void package_string(char **strp) {
const char *a = *strp;
Expand Down Expand Up @@ -243,10 +243,10 @@ int CommandListener::GetStatisticsCmd::runCommand(SocketClient *cli,
return 0;
}

CommandListener::GetPruneListCmd::GetPruneListCmd(LogBuffer *buf)
: LogCommand("getPruneList")
, mBuf(*buf)
{ }
CommandListener::GetPruneListCmd::GetPruneListCmd(LogBuffer *buf) :
LogCommand("getPruneList"),
mBuf(*buf) {
}

int CommandListener::GetPruneListCmd::runCommand(SocketClient *cli,
int /*argc*/, char ** /*argv*/) {
Expand All @@ -263,10 +263,10 @@ int CommandListener::GetPruneListCmd::runCommand(SocketClient *cli,
return 0;
}

CommandListener::SetPruneListCmd::SetPruneListCmd(LogBuffer *buf)
: LogCommand("setPruneList")
, mBuf(*buf)
{ }
CommandListener::SetPruneListCmd::SetPruneListCmd(LogBuffer *buf) :
LogCommand("setPruneList"),
mBuf(*buf) {
}

int CommandListener::SetPruneListCmd::runCommand(SocketClient *cli,
int argc, char **argv) {
Expand Down Expand Up @@ -301,9 +301,8 @@ int CommandListener::SetPruneListCmd::runCommand(SocketClient *cli,
return 0;
}

CommandListener::ReinitCmd::ReinitCmd()
: LogCommand("reinit")
{ }
CommandListener::ReinitCmd::ReinitCmd() : LogCommand("reinit") {
}

int CommandListener::ReinitCmd::runCommand(SocketClient *cli,
int /*argc*/, char ** /*argv*/) {
Expand Down
16 changes: 8 additions & 8 deletions logd/FlushCommand.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -27,14 +27,14 @@ FlushCommand::FlushCommand(LogReader &reader,
unsigned long tail,
unsigned int logMask,
pid_t pid,
uint64_t start)
: mReader(reader)
, mNonBlock(nonBlock)
, mTail(tail)
, mLogMask(logMask)
, mPid(pid)
, mStart(start)
{ }
uint64_t start) :
mReader(reader),
mNonBlock(nonBlock),
mTail(tail),
mLogMask(logMask),
mPid(pid),
mStart(start) {
}

// runSocketCommand is called once for every open client on the
// log reader socket. Here we manage and associated the reader
Expand Down
12 changes: 6 additions & 6 deletions logd/LogAudit.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -37,12 +37,12 @@
'0' + LOG_MAKEPRI(LOG_AUTH, LOG_PRI(PRI)) % 10, \
'>'

LogAudit::LogAudit(LogBuffer *buf, LogReader *reader, int fdDmesg)
: SocketListener(getLogSocket(), false)
, logbuf(buf)
, reader(reader)
, fdDmesg(fdDmesg)
, initialized(false) {
LogAudit::LogAudit(LogBuffer *buf, LogReader *reader, int fdDmesg) :
SocketListener(getLogSocket(), false),
logbuf(buf),
reader(reader),
fdDmesg(fdDmesg),
initialized(false) {
static const char auditd_message[] = { KMSG_PRIORITY(LOG_INFO),
'l', 'o', 'g', 'd', '.', 'a', 'u', 'd', 'i', 't', 'd', ':',
' ', 's', 't', 'a', 'r', 't', '\n' };
Expand Down
3 changes: 1 addition & 2 deletions logd/LogBuffer.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -126,8 +126,7 @@ void LogBuffer::init() {
}
}

LogBuffer::LogBuffer(LastLogTimes *times)
: mTimes(*times) {
LogBuffer::LogBuffer(LastLogTimes *times) : mTimes(*times) {
pthread_mutex_init(&mLogElementsLock, NULL);

init();
Expand Down
16 changes: 8 additions & 8 deletions logd/LogBufferElement.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -34,14 +34,14 @@ atomic_int_fast64_t LogBufferElement::sequence;

LogBufferElement::LogBufferElement(log_id_t log_id, log_time realtime,
uid_t uid, pid_t pid, pid_t tid,
const char *msg, unsigned short len)
: mLogId(log_id)
, mUid(uid)
, mPid(pid)
, mTid(tid)
, mMsgLen(len)
, mSequence(sequence.fetch_add(1, memory_order_relaxed))
, mRealTime(realtime) {
const char *msg, unsigned short len) :
mLogId(log_id),
mUid(uid),
mPid(pid),
mTid(tid),
mMsgLen(len),
mSequence(sequence.fetch_add(1, memory_order_relaxed)),
mRealTime(realtime) {
mMsg = new char[len];
memcpy(mMsg, msg, len);
}
Expand Down
3 changes: 1 addition & 2 deletions logd/LogCommand.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -23,8 +23,7 @@

#include "LogCommand.h"

LogCommand::LogCommand(const char *cmd)
: FrameworkCommand(cmd) {
LogCommand::LogCommand(const char *cmd) : FrameworkCommand(cmd) {
}

// gets a list of supplementary group IDs associated with
Expand Down
20 changes: 10 additions & 10 deletions logd/LogKlog.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -38,16 +38,16 @@ static const char priority_message[] = { KMSG_PRIORITY(LOG_INFO), '\0' };

log_time LogKlog::correction = log_time(CLOCK_REALTIME) - log_time(CLOCK_MONOTONIC);

LogKlog::LogKlog(LogBuffer *buf, LogReader *reader, int fdWrite, int fdRead, bool auditd)
: SocketListener(fdRead, false)
, logbuf(buf)
, reader(reader)
, signature(CLOCK_MONOTONIC)
, fdWrite(fdWrite)
, fdRead(fdRead)
, initialized(false)
, enableLogging(true)
, auditd(auditd) {
LogKlog::LogKlog(LogBuffer *buf, LogReader *reader, int fdWrite, int fdRead, bool auditd) :
SocketListener(fdRead, false),
logbuf(buf),
reader(reader),
signature(CLOCK_MONOTONIC),
fdWrite(fdWrite),
fdRead(fdRead),
initialized(false),
enableLogging(true),
auditd(auditd) {
static const char klogd_message[] = "%slogd.klogd: %" PRIu64 "\n";
char buffer[sizeof(priority_message) + sizeof(klogd_message) + 20 - 4];
snprintf(buffer, sizeof(buffer), klogd_message, priority_message,
Expand Down
10 changes: 5 additions & 5 deletions logd/LogListener.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -28,11 +28,11 @@

#include "LogListener.h"

LogListener::LogListener(LogBuffer *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;
Expand Down
24 changes: 12 additions & 12 deletions logd/LogReader.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -24,10 +24,10 @@
#include "LogReader.h"
#include "FlushCommand.h"

LogReader::LogReader(LogBuffer *logbuf)
: SocketListener(getLogSocket(), true)
, mLogbuf(*logbuf)
{ }
LogReader::LogReader(LogBuffer *logbuf) :
SocketListener(getLogSocket(), true),
mLogbuf(*logbuf) {
}

// When we are notified a new log entry is available, inform
// all of our listening sockets.
Expand Down Expand Up @@ -116,14 +116,14 @@ bool LogReader::onDataAvailable(SocketClient *cli) {
uint64_t last;

public:
LogFindStart(unsigned logMask, pid_t pid, log_time &start, uint64_t &sequence)
: mPid(pid)
, mLogMask(logMask)
, startTimeSet(false)
, start(start)
, sequence(sequence)
, last(sequence)
{ }
LogFindStart(unsigned logMask, pid_t pid, log_time &start, uint64_t &sequence) :
mPid(pid),
mLogMask(logMask),
startTimeSet(false),
start(start),
sequence(sequence),
last(sequence) {
}

static int callback(const LogBufferElement *element, void *obj) {
LogFindStart *me = reinterpret_cast<LogFindStart *>(obj);
Expand Down
3 changes: 1 addition & 2 deletions logd/LogStatistics.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -26,8 +26,7 @@

#include "LogStatistics.h"

LogStatistics::LogStatistics()
: enable(false) {
LogStatistics::LogStatistics() : enable(false) {
log_id_for_each(id) {
mSizes[id] = 0;
mElements[id] = 0;
Expand Down
35 changes: 17 additions & 18 deletions logd/LogTimes.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -26,24 +26,23 @@ pthread_mutex_t LogTimeEntry::timesLock = PTHREAD_MUTEX_INITIALIZER;
LogTimeEntry::LogTimeEntry(LogReader &reader, SocketClient *client,
bool nonBlock, unsigned long tail,
unsigned int logMask, pid_t pid,
uint64_t start)
: mRefCount(1)
, mRelease(false)
, mError(false)
, threadRunning(false)
, mReader(reader)
, mLogMask(logMask)
, mPid(pid)
, mCount(0)
, mTail(tail)
, mIndex(0)
, mClient(client)
, mStart(start)
, mNonBlock(nonBlock)
, mEnd(LogBufferElement::getCurrentSequence())
{
pthread_cond_init(&threadTriggeredCondition, NULL);
cleanSkip_Locked();
uint64_t start) :
mRefCount(1),
mRelease(false),
mError(false),
threadRunning(false),
mReader(reader),
mLogMask(logMask),
mPid(pid),
mCount(0),
mTail(tail),
mIndex(0),
mClient(client),
mStart(start),
mNonBlock(nonBlock),
mEnd(LogBufferElement::getCurrentSequence()) {
pthread_cond_init(&threadTriggeredCondition, NULL);
cleanSkip_Locked();
}

void LogTimeEntry::startReader_Locked(void) {
Expand Down
9 changes: 3 additions & 6 deletions logd/LogWhiteBlackList.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,8 @@

// White and Black list

Prune::Prune(uid_t uid, pid_t pid)
: mUid(uid)
, mPid(pid)
{ }
Prune::Prune(uid_t uid, pid_t pid) : mUid(uid), mPid(pid) {
}

int Prune::cmp(uid_t uid, pid_t pid) const {
if ((mUid == uid_all) || (mUid == uid)) {
Expand All @@ -51,8 +49,7 @@ void Prune::format(char **strp) {
}
}

PruneList::PruneList()
: mWorstUidEnabled(true) {
PruneList::PruneList() : mWorstUidEnabled(true) {
mNaughty.clear();
mNice.clear();
}
Expand Down

0 comments on commit 66091f1

Please sign in to comment.