tequilaOS/platform_system_core
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

logd: ratelimit drop messages to 1/sec

Browse source 
Bug: 20334069
Bug: 20370119
Change-Id: I6f850aec46c4df1c99a5b1f28db75d071e134ad5
This commit is contained in:
Mark Salyzyn 2015-04-20 14:08:56 -07:00
parent f75f16a1dd
commit e06a6e0f26
1 changed files with 20 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
logd/LogBuffer.cpp
View file

@ -247,7 +247,7 @@ public:
uint64_t getKey() { return value; }
};
struct LogBufferElementEntry {
class LogBufferElementEntry {
const uint64_t key;
LogBufferElement *last;
@ -259,8 +259,9 @@ public:
LogBufferElement *getLast() { return last; }
};
struct LogBufferElementLast : public android::BasicHashtable<uint64_t, LogBufferElementEntry> {
class LogBufferElementLast : public android::BasicHashtable<uint64_t, LogBufferElementEntry> {
public:
bool merge(LogBufferElement *e, unsigned short dropped) {
LogBufferElementKey key(e->getUid(), e->getPid(), e->getTid());
android::hash_t hash = android::hash_type(key.getKey());
@ -286,6 +287,21 @@ struct LogBufferElementLast : public android::BasicHashtable<uint64_t, LogBuffer
add(hash, LogBufferElementEntry(key.getKey(), e));
}
inline void clear() {
android::BasicHashtable<uint64_t, LogBufferElementEntry>::clear();
}
void clear(LogBufferElement *e) {
uint64_t current = e->getRealTime().nsec() - NS_PER_SEC;
ssize_t index = -1;
while((index = next(index)) >= 0) {
if (current > editEntryAt(index).getLast()->getRealTime().nsec()) {
removeAt(index);
index = -1;
}
}
}
};
// prune "pruneRows" of type "id" from the buffer.
@ -395,7 +411,7 @@ void LogBuffer::prune(log_id_t id, unsigned long pruneRows, uid_t caller_uid) {
leading = false;
if (hasBlacklist && mPrune.naughty(e)) {
last.clear();
last.clear(e);
it = erase(it);
if (dropped) {
continue;
@ -423,7 +439,7 @@ void LogBuffer::prune(log_id_t id, unsigned long pruneRows, uid_t caller_uid) {
}
if (e->getUid() != worst) {
last.clear();
last.clear(e);
++it;
continue;
}