Searched refs:log_positions_ (Results 1 – 2 of 2) sorted by relevance
33 if (log_positions_[i]) { in ~SerializedFlushToState()34 log_positions_[i]->buffer_it->DecReaderRefCount(); in ~SerializedFlushToState()63 log_positions_[log_id].emplace(log_position); in CreateLogPosition()67 auto& buffer_it = log_positions_[log_id]->buffer_it; in AddMinHeapEntry()68 auto read_offset = log_positions_[log_id]->read_offset; in AddMinHeapEntry()84 log_positions_[log_id]->read_offset = 0; in AddMinHeapEntry()103 if (!log_positions_[i]) { in CheckForNewLogs()122 log_positions_[log_id]->read_offset += entry->total_len(); in PopNextUnreadLog()132 if (!log_positions_[log_id].has_value() || log_positions_[log_id]->buffer_it != buffer_it) { in Prune()140 log_positions_[log_id].reset(); in Prune()
94 std::optional<LogPosition> log_positions_[LOG_ID_MAX]; variable