Lines Matching refs:last_sequence

189       auto last_sequence = w.write_group->last_sequence;  in WriteImpl()  local
190 versions_->SetLastSequence(last_sequence); in WriteImpl()
217 uint64_t last_sequence = kMaxSequenceNumber; in WriteImpl() local
236 last_sequence = versions_->LastSequence(); in WriteImpl()
329 need_log_dir_sync, last_sequence + 1); in WriteImpl()
336 io_s = ConcurrentWriteToWAL(write_group, log_used, &last_sequence, in WriteImpl()
340 last_sequence = versions_->FetchAddLastAllocatedSequence(seq_inc); in WriteImpl()
344 assert(last_sequence != kMaxSequenceNumber); in WriteImpl()
345 const SequenceNumber current_sequence = last_sequence + 1; in WriteImpl()
346 last_sequence += seq_inc; in WriteImpl()
391 write_group.last_sequence = last_sequence; in WriteImpl()
457 versions_->SetLastSequence(last_sequence); in WriteImpl()
591 versions_->SetLastSequence(memtable_write_group.last_sequence); in PipelinedWriteImpl()
612 versions_->SetLastSequence(w.write_group->last_sequence); in PipelinedWriteImpl()
727 uint64_t last_sequence; in WriteImplWALOnly() local
784 io_s = ConcurrentWriteToWAL(write_group, log_used, &last_sequence, seq_inc); in WriteImplWALOnly()
788 last_sequence = versions_->FetchAddLastAllocatedSequence(seq_inc); in WriteImplWALOnly()
792 auto curr_seq = last_sequence + 1; in WriteImplWALOnly()
842 versions_->SetLastSequence(last_sequence + seq_inc); in WriteImplWALOnly()
1174 SequenceNumber* last_sequence, size_t seq_inc) { in ConcurrentWriteToWAL() argument
1195 *last_sequence = versions_->FetchAddLastAllocatedSequence(seq_inc); in ConcurrentWriteToWAL()
1196 auto sequence = *last_sequence + 1; in ConcurrentWriteToWAL()