Searched refs:last_sequence (Results 1 – 10 of 10) sorted by relevance
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_write.cc | 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()
342 assert(last_sequence != kMaxSequenceNumber); 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()
702 uint64_t last_sequence; in WriteImplWALOnly() local
765 auto curr_seq = last_sequence + 1; in WriteImplWALOnly()
[all …]
|
| D | db_impl_secondary.cc | 284 auto last_sequence = *next_sequence - 1; in RecoverLogFiles() local
286 (versions_->LastSequence() <= last_sequence)) { in RecoverLogFiles()
287 versions_->SetLastAllocatedSequence(last_sequence); in RecoverLogFiles()
288 versions_->SetLastPublishedSequence(last_sequence); in RecoverLogFiles()
289 versions_->SetLastSequence(last_sequence); in RecoverLogFiles()
|
| D | db_impl_open.cc | 1016 auto last_sequence = *next_sequence - 1; in RecoverLogFiles() local
1018 (versions_->LastSequence() <= last_sequence)) { in RecoverLogFiles()
1019 versions_->SetLastAllocatedSequence(last_sequence); in RecoverLogFiles()
1020 versions_->SetLastPublishedSequence(last_sequence); in RecoverLogFiles()
1021 versions_->SetLastSequence(last_sequence); in RecoverLogFiles()
|
| D | db_impl.h | 1514 SequenceNumber* last_sequence, size_t seq_inc);
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction_iterator.cc | 35 SequenceNumber last_sequence, std::vector<SequenceNumber>* snapshots, in CompactionIterator() argument
46 input, cmp, merge_helper, last_sequence, snapshots, in CompactionIterator()
334 SequenceNumber last_sequence __attribute__((__unused__)); in NextFromInput() local
335 last_sequence = current_user_key_sequence_; in NextFromInput()
503 assert(last_sequence >= current_user_key_sequence_); in NextFromInput()
504 if (last_sequence < current_user_key_sequence_) { in NextFromInput()
508 last_sequence, current_user_key_sequence_); in NextFromInput()
|
| D | compaction_iterator.h | 64 SequenceNumber last_sequence, std::vector<SequenceNumber>* snapshots,
79 SequenceNumber last_sequence, std::vector<SequenceNumber>* snapshots,
|
| D | compaction_iterator_test.cc | 221 SequenceNumber last_sequence, in InitIterators() argument
255 iter_.get(), cmp_, merge_helper_.get(), last_sequence, &snapshots_, in InitIterators()
|
| /rocksdb-6.9/db/ |
| D | write_thread.h | 80 SequenceNumber last_sequence; member
|
| D | write_thread.cc | 541 write_group->last_sequence = in EnterAsMemTableWriter()
|
| D | version_set.cc | 4984 uint64_t last_sequence = 0; in DumpManifest() local
5094 last_sequence = edit.last_sequence_; in DumpManifest()
5153 last_allocated_sequence_ = last_sequence; in DumpManifest()
5154 last_published_sequence_ = last_sequence; in DumpManifest()
5155 last_sequence_ = last_sequence; in DumpManifest()
5162 next_file_number_.load(), last_sequence, previous_log_number, in DumpManifest()
|