Searched refs:logs_ (Results 1 – 6 of 6) sorted by relevance
40 CHECK(!logs_[log_id].empty()); in CreateLogPosition()42 auto it = logs_[log_id].begin(); in CreateLogPosition()43 while (it != logs_[log_id].end() && start() > it->highest_sequence_number()) { in CreateLogPosition()46 if (it == logs_[log_id].end()) { in CreateLogPosition()77 if (buffer_it == std::prev(logs_[log_id].end())) { in AddMinHeapEntry()104 if (logs_[i].empty()) { in CheckForNewLogs()
61 if (logs_ == nullptr) logs_ = logs; in InitializeLogs()91 std::list<SerializedLogChunk>* logs_ = nullptr; variable
86 if (logs_[log_id].empty()) { in Log()87 logs_[log_id].push_back(SerializedLogChunk(max_size_[log_id] / 4)); in Log()91 if (!logs_[log_id].back().CanLog(total_len)) { in Log()92 logs_[log_id].back().FinishWriting(); in Log()93 logs_[log_id].push_back(SerializedLogChunk(max_size_[log_id] / 4)); in Log()96 auto entry = logs_[log_id].back().Log(sequence, realtime, uid, pid, tid, msg, len); in Log()152 auto& log_buffer = logs_[log_id]; in Prune()228 state.InitializeLogs(logs_); in FlushTo()304 for (const auto& chunk : logs_[id]) { in GetSizeUsed()
106 logs_.emplace_back(std::move(elem)); in LogInternal()107 stats_->Add(logs_.back().ToLogStatisticsElement()); in LogInternal()145 it = logs_.begin(); in FlushTo()149 for (it = logs_.end(); it != logs_.begin(); in FlushTo()161 for (; it != logs_.end(); ++it) { in FlushTo()293 while (it != logs_.end()) { in Prune()325 it = logs_.erase(it); in Erase()
64 std::list<LogBufferElement>& logs() { return logs_; } in logs()79 std::list<LogBufferElement> logs_ GUARDED_BY(lock_);
71 std::list<SerializedLogChunk> logs_[LOG_ID_MAX] GUARDED_BY(lock_);