Lines Matching refs:sv
1355 SuperVersion* sv = superversions_to_free_queue_.front(); in BackgroundCallPurge() local
1358 delete sv; in BackgroundCallPurge()
1548 SuperVersion* sv = GetAndRefSuperVersion(cfd); in GetImpl() local
1614 if (sv->mem->Get(lkey, get_impl_options.value->GetSelf(), timestamp, &s, in GetImpl()
1622 sv->imm->Get(lkey, get_impl_options.value->GetSelf(), in GetImpl()
1634 if (sv->mem->Get(lkey, /*value*/ nullptr, /*timestamp=*/nullptr, &s, in GetImpl()
1640 sv->imm->GetMergeOperands(lkey, &s, &merge_context, in GetImpl()
1648 ReturnAndCleanupSuperVersion(cfd, sv); in GetImpl()
1654 sv->current->Get( in GetImpl()
1668 ReturnAndCleanupSuperVersion(cfd, sv); in GetImpl()
2550 SuperVersion* sv = cfd->GetReferencedSuperVersion(this); in NewIterator()
2551 auto iter = new ForwardIterator(this, read_options, cfd, sv); in NewIterator()
2553 env_, read_options, *cfd->ioptions(), sv->mutable_cf_options, in NewIterator()
2555 sv->mutable_cf_options.max_sequential_skip_in_iterations, read_callback, in NewIterator()
2576 SuperVersion* sv = cfd->GetReferencedSuperVersion(this); in NewIteratorImpl() local
2621 env_, read_options, *cfd->ioptions(), sv->mutable_cf_options, snapshot, in NewIteratorImpl()
2622 sv->mutable_cf_options.max_sequential_skip_in_iterations, in NewIteratorImpl()
2623 sv->version_number, read_callback, this, cfd, allow_blob, in NewIteratorImpl()
2627 NewInternalIterator(read_options, cfd, sv, db_iter->GetArena(), in NewIteratorImpl()
2655 SuperVersion* sv = cfd->GetReferencedSuperVersion(this); in NewIterators()
2656 auto iter = new ForwardIterator(this, read_options, cfd, sv); in NewIterators()
2658 env_, read_options, *cfd->ioptions(), sv->mutable_cf_options, in NewIterators()
2660 sv->mutable_cf_options.max_sequential_skip_in_iterations, in NewIterators()
2922 SuperVersion* sv = nullptr; in GetIntPropertyInternal() local
2924 sv = GetAndRefSuperVersion(cfd); in GetIntPropertyInternal()
2926 sv = cfd->GetSuperVersion(); in GetIntPropertyInternal()
2930 property_info, sv->current, value); in GetIntPropertyInternal()
2933 ReturnAndCleanupSuperVersion(cfd, sv); in GetIntPropertyInternal()
3006 void DBImpl::CleanupSuperVersion(SuperVersion* sv) { in CleanupSuperVersion() argument
3008 if (sv->Unref()) { in CleanupSuperVersion()
3013 sv->Cleanup(); in CleanupSuperVersion()
3015 AddSuperVersionsToFreeQueue(sv); in CleanupSuperVersion()
3020 delete sv; in CleanupSuperVersion()
3028 SuperVersion* sv) { in ReturnAndCleanupSuperVersion() argument
3029 if (!cfd->ReturnThreadLocalSuperVersion(sv)) { in ReturnAndCleanupSuperVersion()
3030 CleanupSuperVersion(sv); in ReturnAndCleanupSuperVersion()
3036 SuperVersion* sv) { in ReturnAndCleanupSuperVersion() argument
3043 ReturnAndCleanupSuperVersion(cfd, sv); in ReturnAndCleanupSuperVersion()
3080 SuperVersion* sv = GetAndRefSuperVersion(cfd); in GetApproximateMemTableStats() local
3086 sv->mem->ApproximateStats(k1.Encode(), k2.Encode()); in GetApproximateMemTableStats()
3088 sv->imm->ApproximateStats(k1.Encode(), k2.Encode()); in GetApproximateMemTableStats()
3092 ReturnAndCleanupSuperVersion(cfd, sv); in GetApproximateMemTableStats()
3105 SuperVersion* sv = GetAndRefSuperVersion(cfd); in GetApproximateSizes() local
3106 v = sv->current; in GetApproximateSizes()
3119 sizes[i] += sv->mem->ApproximateStats(k1.Encode(), k2.Encode()).size; in GetApproximateSizes()
3120 sizes[i] += sv->imm->ApproximateStats(k1.Encode(), k2.Encode()).size; in GetApproximateSizes()
3124 ReturnAndCleanupSuperVersion(cfd, sv); in GetApproximateSizes()
3355 auto* sv = GetAndRefSuperVersion(cfd); in GetColumnFamilyMetaData() local
3367 sv->current->GetColumnFamilyMetaData(cf_meta); in GetColumnFamilyMetaData()
3369 ReturnAndCleanupSuperVersion(cfd, sv); in GetColumnFamilyMetaData()
3835 SequenceNumber DBImpl::GetEarliestMemTableSequenceNumber(SuperVersion* sv, in GetEarliestMemTableSequenceNumber() argument
3840 sv->imm->GetEarliestSequenceNumber(include_history); in GetEarliestMemTableSequenceNumber()
3842 earliest_seq = sv->mem->GetEarliestSequenceNumber(); in GetEarliestMemTableSequenceNumber()
3844 assert(sv->mem->GetEarliestSequenceNumber() >= earliest_seq); in GetEarliestMemTableSequenceNumber()
3851 Status DBImpl::GetLatestSequenceForKey(SuperVersion* sv, const Slice& key, in GetLatestSequenceForKey() argument
3869 sv->mem->Get(lkey, nullptr, nullptr, &s, &merge_context, in GetLatestSequenceForKey()
3888 SequenceNumber lower_bound_in_mem = sv->mem->GetEarliestSequenceNumber(); in GetLatestSequenceForKey()
3896 sv->imm->Get(lkey, nullptr, nullptr, &s, &merge_context, in GetLatestSequenceForKey()
3915 SequenceNumber lower_bound_in_imm = sv->imm->GetEarliestSequenceNumber(); in GetLatestSequenceForKey()
3923 sv->imm->GetFromHistory(lkey, nullptr, nullptr, &s, &merge_context, in GetLatestSequenceForKey()
3951 sv->current->Get(read_options, lkey, nullptr, nullptr, &s, &merge_context, in GetLatestSequenceForKey()
4334 SuperVersion* sv = cfd->GetReferencedSuperVersion(this); in CreateColumnFamilyWithImport() local
4335 status = import_job.Prepare(next_file_number, sv); in CreateColumnFamilyWithImport()
4336 CleanupSuperVersion(sv); in CreateColumnFamilyWithImport()
4413 for (auto& sv : sv_list) { in VerifyChecksum() local
4414 VersionStorageInfo* vstorage = sv->current->storage_info(); in VerifyChecksum()
4415 ColumnFamilyData* cfd = sv->current->cfd(); in VerifyChecksum()
4440 for (auto sv : sv_list) { in VerifyChecksum() local
4441 if (sv && sv->Unref()) { in VerifyChecksum()
4442 sv->Cleanup(); in VerifyChecksum()
4444 AddSuperVersionsToFreeQueue(sv); in VerifyChecksum()
4446 delete sv; in VerifyChecksum()
4577 SuperVersion* sv = GetAndRefSuperVersion(cfd); in GetCreationTimeOfOldestFile() local
4578 Version* version = sv->current; in GetCreationTimeOfOldestFile()
4580 ReturnAndCleanupSuperVersion(cfd, sv); in GetCreationTimeOfOldestFile()