Searched refs:buffer_it (Results 1 – 2 of 2) sorted by relevance
37 log_positions_[i]->buffer_it->DetachReader(this); in ~SerializedFlushToState()53 log_position.buffer_it = it; in CreateLogPosition()70 auto& buffer_it = log_positions_[log_id]->buffer_it; in UpdateLogsNeeded() local74 if (read_offset < buffer_it->write_offset()) { in UpdateLogsNeeded()76 } else if (read_offset == buffer_it->write_offset()) { in UpdateLogsNeeded()79 if (buffer_it == std::prev(logs_[log_id].end())) { in UpdateLogsNeeded()83 buffer_it->DetachReader(this); in UpdateLogsNeeded()84 ++buffer_it; in UpdateLogsNeeded()85 buffer_it->AttachReader(this); in UpdateLogsNeeded()87 if (buffer_it->write_offset() == 0) { in UpdateLogsNeeded()[all …]
29 std::list<SerializedLogChunk>::iterator buffer_it; member32 const SerializedLogEntry* log_entry() const { return buffer_it->log_entry(read_offset); } in log_entry()