Lines Matching refs:last_sequence

188       auto last_sequence = w.write_group->last_sequence;  in WriteImpl()  local
189 versions_->SetLastSequence(last_sequence); in WriteImpl()
218 uint64_t last_sequence = kMaxSequenceNumber; in WriteImpl() local
236 last_sequence = versions_->LastSequence(); in WriteImpl()
327 need_log_dir_sync, last_sequence + 1); in WriteImpl()
334 io_s = ConcurrentWriteToWAL(write_group, log_used, &last_sequence, in WriteImpl()
338 last_sequence = versions_->FetchAddLastAllocatedSequence(seq_inc); in WriteImpl()
342 assert(last_sequence != kMaxSequenceNumber); in WriteImpl()
343 const SequenceNumber current_sequence = last_sequence + 1; in WriteImpl()
344 last_sequence += seq_inc; in WriteImpl()
389 write_group.last_sequence = last_sequence; in WriteImpl()
448 versions_->SetLastSequence(last_sequence); in WriteImpl()
570 versions_->SetLastSequence(memtable_write_group.last_sequence); in PipelinedWriteImpl()
587 versions_->SetLastSequence(w.write_group->last_sequence); in PipelinedWriteImpl()
702 uint64_t last_sequence; in WriteImplWALOnly() local
757 io_s = ConcurrentWriteToWAL(write_group, log_used, &last_sequence, seq_inc); in WriteImplWALOnly()
761 last_sequence = versions_->FetchAddLastAllocatedSequence(seq_inc); in WriteImplWALOnly()
765 auto curr_seq = last_sequence + 1; in WriteImplWALOnly()
815 versions_->SetLastSequence(last_sequence + seq_inc); in WriteImplWALOnly()
1096 SequenceNumber* last_sequence, size_t seq_inc) { in ConcurrentWriteToWAL() argument
1117 *last_sequence = versions_->FetchAddLastAllocatedSequence(seq_inc); in ConcurrentWriteToWAL()
1118 auto sequence = *last_sequence + 1; in ConcurrentWriteToWAL()