| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_readonly.cc | 46 SuperVersion* super_version = cfd->GetSuperVersion(); in Get() local
51 if (super_version->mem->Get(lkey, pinnable_val->GetSelf(), in Get()
58 super_version->current->Get(read_options, lkey, pinnable_val, in Get()
75 SuperVersion* super_version = cfd->GetSuperVersion()->Ref(); in NewIterator() local
84 env_, read_options, *cfd->ioptions(), super_version->mutable_cf_options, in NewIterator()
86 super_version->mutable_cf_options.max_sequential_skip_in_iterations, in NewIterator()
87 super_version->version_number, read_callback); in NewIterator()
89 NewInternalIterator(read_options, cfd, super_version, db_iter->GetArena(), in NewIterator()
|
| D | db_impl_secondary.cc | 334 SuperVersion* super_version = GetAndRefSuperVersion(cfd); in GetImpl() local
343 if (super_version->mem->Get(lkey, pinnable_val->GetSelf(), in GetImpl()
350 super_version->imm->Get( in GetImpl()
358 ReturnAndCleanupSuperVersion(cfd, super_version); in GetImpl()
363 super_version->current->Get(read_options, lkey, pinnable_val, in GetImpl()
370 ReturnAndCleanupSuperVersion(cfd, super_version); in GetImpl()
412 SuperVersion* super_version = cfd->GetReferencedSuperVersion(this); in NewIteratorImpl() local
414 env_, read_options, *cfd->ioptions(), super_version->mutable_cf_options, in NewIteratorImpl()
416 super_version->mutable_cf_options.max_sequential_skip_in_iterations, in NewIteratorImpl()
417 super_version->version_number, read_callback); in NewIteratorImpl()
[all …]
|
| D | db_impl.cc | 884 CleanupSuperVersion(super_version); in TablesRangeTombstoneSummary()
1398 super_version(_super_version), in IterState()
1403 SuperVersion* super_version; member
1410 if (state->super_version->Unref()) { in CleanupIteratorState()
1416 state->super_version->Cleanup(); in CleanupIteratorState()
1426 delete state->super_version; in CleanupIteratorState()
1496 CleanupSuperVersion(super_version); in NewInternalIterator()
1773 auto super_version = mgd.super_version; in MultiGet() local
1887 SuperVersion* super_version = node->super_version; in MultiCFSnapshot() local
4051 CleanupSuperVersion(super_version); in IngestExternalFiles()
[all …]
|
| D | db_impl.h | 711 const ReadOptions&, ColumnFamilyData* cfd, SuperVersion* super_version,
1721 SuperVersion* super_version; member
1728 super_version(sv) {} in MultiGetColumnFamilyData()
1736 super_version(sv) {} in MultiGetColumnFamilyData()
|
| D | db_impl_compaction_flush.cc | 694 SuperVersion* super_version = cfd->GetReferencedSuperVersion(this); in CompactRange() local
695 cfd->RangesOverlapWithMemtables({range}, super_version, &flush_needed); in CompactRange()
696 CleanupSuperVersion(super_version); in CompactRange()
738 SuperVersion* super_version = cfd->GetReferencedSuperVersion(this); in CompactRange() local
739 Version* current_version = super_version->current; in CompactRange()
765 CleanupSuperVersion(super_version); in CompactRange()
|
| /rocksdb-6.9/db/ |
| D | external_sst_file_ingestion_job.cc | 183 SuperVersion* super_version) { in NeedsFlush() argument
190 cfd_->RangesOverlapWithMemtables(ranges, super_version, flush_needed); in NeedsFlush()
202 SuperVersion* super_version = cfd_->GetSuperVersion(); in Run() local
207 status = NeedsFlush(&need_flush, super_version); in Run()
230 super_version, force_global_seqno, cfd_->ioptions()->compaction_style, in Run()
|
| D | column_family.cc | 1070 const autovector<Range>& ranges, SuperVersion* super_version, in RangesOverlapWithMemtables() argument
1080 super_version->mem->NewIterator(read_opts, &arena)); in RangesOverlapWithMemtables()
1081 super_version->imm->AddIterators(read_opts, &merge_iter_builder); in RangesOverlapWithMemtables()
1084 auto read_seq = super_version->current->version_set()->LastSequence(); in RangesOverlapWithMemtables()
1087 super_version->mem->NewRangeTombstoneIterator(read_opts, read_seq); in RangesOverlapWithMemtables()
1090 super_version->imm->AddRangeTombstoneIterators(read_opts, nullptr /* arena */, in RangesOverlapWithMemtables()
1095 auto* vstorage = super_version->current->storage_info(); in RangesOverlapWithMemtables()
|
| D | external_sst_file_ingestion_job.h | 103 Status NeedsFlush(bool* flush_needed, SuperVersion* super_version);
|
| D | column_family.h | 406 SuperVersion* super_version, bool* overlap);
|