Loading logd/LogBuffer.cpp +8 −3 Original line number Original line Diff line number Diff line Loading @@ -1144,6 +1144,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); Loading @@ -1170,10 +1174,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 Loading
logd/LogBuffer.cpp +8 −3 Original line number Original line Diff line number Diff line Loading @@ -1144,6 +1144,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); Loading @@ -1170,10 +1174,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