diff options
Diffstat (limited to 'logd/SerializedFlushToState.h')
-rw-r--r-- | logd/SerializedFlushToState.h | 18 |
1 files changed, 10 insertions, 8 deletions
diff --git a/logd/SerializedFlushToState.h b/logd/SerializedFlushToState.h index 74b3de55c7..0b20822dd1 100644 --- a/logd/SerializedFlushToState.h +++ b/logd/SerializedFlushToState.h @@ -61,15 +61,13 @@ class SerializedFlushToState : public FlushToState { if (logs_ == nullptr) logs_ = logs; } - // Checks to see if any log buffers set in logs_needed_from_next_position_ have new logs and - // calls AddMinHeapEntry() if so. - void CheckForNewLogs(); - - bool HasUnreadLogs() { return !min_heap_.empty(); } + bool HasUnreadLogs() { + CheckForNewLogs(); + return !min_heap_.empty(); + } - // Pops the next unread log from the min heap. Add the next log for that log_id to the min heap - // if one is available otherwise set logs_needed_from_next_position_ to indicate that we're - // waiting for more logs. + // Pops the next unread log from the min heap and sets logs_needed_from_next_position_ to + // indicate that we're waiting for more logs from the associated log buffer. MinHeapElement PopNextUnreadLog(); // If the parent log buffer prunes logs, the reference that this class contains may become @@ -86,6 +84,10 @@ class SerializedFlushToState : public FlushToState { // first chunk and then first log entry within that chunk that is greater or equal to start(). void CreateLogPosition(log_id_t log_id); + // Checks to see if any log buffers set in logs_needed_from_next_position_ have new logs and + // calls AddMinHeapEntry() if so. + void CheckForNewLogs(); + std::list<SerializedLogChunk>* logs_ = nullptr; // An optional structure that contains an iterator to the serialized log buffer and offset into // it that this logger should handle next. |