Searched refs:buffer_it (Results 1 – 2 of 2) sorted by relevance
34 log_positions_[i]->buffer_it->DecReaderRefCount(); in ~SerializedFlushToState()50 log_position.buffer_it = it; in CreateLogPosition()67 auto& buffer_it = log_positions_[log_id]->buffer_it; in AddMinHeapEntry() local71 if (read_offset < buffer_it->write_offset()) { in AddMinHeapEntry()72 auto* entry = buffer_it->log_entry(read_offset); in AddMinHeapEntry()74 } else if (read_offset == buffer_it->write_offset()) { in AddMinHeapEntry()77 if (buffer_it == std::prev(logs_[log_id].end())) { in AddMinHeapEntry()81 buffer_it->DecReaderRefCount(); in AddMinHeapEntry()82 ++buffer_it; in AddMinHeapEntry()83 buffer_it->IncReaderRefCount(); in AddMinHeapEntry()[all …]
28 std::list<SerializedLogChunk>::iterator buffer_it; member75 void Prune(log_id_t log_id, const std::list<SerializedLogChunk>::iterator& buffer_it);