Home
last modified time | relevance | path

Searched refs:LastSequence (Results 1 – 17 of 17) sorted by relevance

/rocksdb-6.9/db/
Dtransaction_log_impl.cc84 if (current_last_seq_ >= versions_->LastSequence()) { in RestrictedRead()
196 if (current_last_seq_ == versions_->LastSequence()) { in NextImpl()
217 batchSeq, expected_seq, versions_->LastSequence()); in IsBatchExpected()
295 assert(current_last_seq_ <= versions_->LastSequence()); in UpdateCurrentWriteBatch()
Dimport_column_family_job.cc160 if (file_metadata.largest_seqno > versions_->LastSequence()) { in Run()
Dwal_manager_test.cc68 uint64_t seq = versions_->LastSequence() + 1; in Put()
Dforward_iterator.cc630 read_options_, sv_->current->version_set()->LastSequence())); in RebuildIterators()
692 read_options_, sv_->current->version_set()->LastSequence())); in RenewIterators()
Dexternal_sst_file_ingestion_job.cc220 SequenceNumber last_seqno = versions_->LastSequence(); in Run()
Dversion_set.h952 uint64_t LastSequence() const { in LastSequence() function
Dcolumn_family.cc1084 auto read_seq = super_version->current->version_set()->LastSequence(); in RangesOverlapWithMemtables()
Ddb_wal_test.cc958 uint64_t seq = versions->LastSequence() + 1; in FillData()
Dversion_set.cc5731 LastSequence()); in CreateColumnFamily()
/rocksdb-6.9/db/db_impl/
Ddb_impl_readonly.cc37 SequenceNumber snapshot = versions_->LastSequence(); in Get()
76 SequenceNumber latest_snapshot = versions_->LastSequence(); in NewIterator()
105 SequenceNumber latest_snapshot = versions_->LastSequence(); in NewIterators()
Ddb_impl_secondary.cc286 (versions_->LastSequence() <= last_sequence)) { in RecoverLogFiles()
335 SequenceNumber snapshot = versions_->LastSequence(); in GetImpl()
402 auto snapshot = versions_->LastSequence(); in NewIterator()
449 SequenceNumber read_seq = versions_->LastSequence(); in NewIterators()
515 static_cast<uint64_t>(versions_->LastSequence())); in TryCatchUpWithPrimary()
Ddb_impl_write.cc236 last_sequence = versions_->LastSequence(); in WriteImpl()
491 write_thread_.UpdateLastSequence(versions_->LastSequence()) + 1; in PipelinedWriteImpl()
1155 seq = versions_->LastSequence(); in WriteRecoverableState()
1210 auto seq = versions_->LastSequence(); in AssignAtomicFlushSeq()
1689 SequenceNumber seq = versions_->LastSequence(); in SwitchMemtable()
1763 loop_cfd->mem()->SetCreationSeq(versions_->LastSequence()); in SwitchMemtable()
Ddb_impl.cc1298 return versions_->LastSequence(); in GetLatestSequenceNumber()
1569 ? versions_->LastSequence() in GetImpl()
1870 ? versions_->LastSequence() in MultiCFSnapshot()
1903 ? versions_->LastSequence() in MultiCFSnapshot()
2564 : versions_->LastSequence(); in NewIterator()
2670 : versions_->LastSequence(); in NewIterators()
2708 ? versions_->LastSequence() in GetSnapshotImpl()
2738 ? versions_->LastSequence() in ReleaseSnapshot()
3152 if (seq > versions_->LastSequence()) { in GetUpdatesSince()
3862 SequenceNumber current_seq = versions_->LastSequence(); in GetLatestSequenceForKey()
[all …]
Ddb_impl_debug.cc262 return versions_->LastSequence(); in TEST_GetLastVisibleSequence()
Ddb_impl_open.cc1018 (versions_->LastSequence() <= last_sequence)) { in RecoverLogFiles()
1086 versions_->LastSequence()); in RecoverLogFiles()
Ddb_impl.h489 return versions_->LastSequence(); in GetLastPublishedSequence()
/rocksdb-6.9/db/compaction/
Dcompaction_job.cc894 input.get(), cfd->user_comparator(), &merge, versions_->LastSequence(), in ProcessKeyValueCompaction()