Merge "Revert "logd: remove start filtration from flushTo""
am: 8cfd2971ec
Change-Id: Ic52a26216b04ee36b15f4665d9c7741079e192ea
This commit is contained in:
commit
f111b04f15
1 changed files with 8 additions and 3 deletions
|
|
@ -1142,6 +1142,10 @@ log_time LogBuffer::flushTo(SocketClient* reader, const log_time& start,
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (element->getRealTime() <= start) {
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
// NB: calling out to another object with wrlock() held (safe)
|
// NB: calling out to another object with wrlock() held (safe)
|
||||||
if (filter) {
|
if (filter) {
|
||||||
int ret = (*filter)(element, arg);
|
int ret = (*filter)(element, arg);
|
||||||
|
|
@ -1168,10 +1172,11 @@ log_time LogBuffer::flushTo(SocketClient* reader, const log_time& start,
|
||||||
unlock();
|
unlock();
|
||||||
|
|
||||||
// range locking in LastLogTimes looks after us
|
// range locking in LastLogTimes looks after us
|
||||||
log_time next = element->flushTo(reader, this, privileged, sameTid);
|
max = element->flushTo(reader, this, privileged, sameTid);
|
||||||
|
|
||||||
if (next == element->FLUSH_ERROR) return next;
|
if (max == element->FLUSH_ERROR) {
|
||||||
if (next > max) max = next;
|
return max;
|
||||||
|
}
|
||||||
|
|
||||||
skip = maxSkip;
|
skip = maxSkip;
|
||||||
rdlock();
|
rdlock();
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue