Lines Matching refs:buffer_it
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() local
74 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()
96 << buffer_it->write_offset() << ")"; in UpdateLogsNeeded()
152 log_positions_[log_id]->buffer_it->DetachReader(this); in Prune()