| /rocksdb-6.9/utilities/transactions/ |
| D | transaction_util.cc | 29 SuperVersion* sv = db_impl->GetAndRefSuperVersion(cfd); in CheckKeyForConflicts() local
31 if (sv == nullptr) { in CheckKeyForConflicts()
38 db_impl->GetEarliestMemTableSequenceNumber(sv, true); in CheckKeyForConflicts()
40 result = CheckKey(db_impl, sv, earliest_seq, snap_seq, key, cache_only, in CheckKeyForConflicts()
43 db_impl->ReturnAndCleanupSuperVersion(cfd, sv); in CheckKeyForConflicts()
49 Status TransactionUtil::CheckKey(DBImpl* db_impl, SuperVersion* sv, in CheckKey() argument
119 Status s = db_impl->GetLatestSequenceForKey(sv, key, !need_to_read_sst, in CheckKey()
147 SuperVersion* sv = db_impl->GetAndRefSuperVersion(cf_id); in CheckKeysForConflicts() local
148 if (sv == nullptr) { in CheckKeysForConflicts()
155 db_impl->GetEarliestMemTableSequenceNumber(sv, true); in CheckKeysForConflicts()
[all …]
|
| D | transaction_util.h | 94 static Status CheckKey(DBImpl* db_impl, SuperVersion* sv,
|
| /rocksdb-6.9/db/ |
| D | column_family.cc | 665 if (sv->Unref()) { in UnrefAndTryDelete()
667 sv->Cleanup(); in UnrefAndTryDelete()
668 delete sv; in UnrefAndTryDelete()
1142 sv->Ref(); in GetReferencedSuperVersion()
1148 sv->Unref(); in GetReferencedSuperVersion()
1150 return sv; in GetReferencedSuperVersion()
1178 if (sv && sv->Unref()) { in GetThreadLocalSuperVersion()
1183 sv->Cleanup(); in GetThreadLocalSuperVersion()
1198 assert(sv != nullptr); in GetThreadLocalSuperVersion()
1199 return sv; in GetThreadLocalSuperVersion()
[all …]
|
| D | arena_wrapped_db_iter.cc | 67 SuperVersion* sv = cfd_->GetReferencedSuperVersion(db_impl_); in Refresh() local
71 Init(env, read_options_, *(cfd_->ioptions()), sv->mutable_cf_options, in Refresh()
72 latest_seq, sv->mutable_cf_options.max_sequential_skip_in_iterations, in Refresh()
77 read_options_, cfd_, sv, &arena_, db_iter_->GetRangeDelAggregator(), in Refresh()
|
| D | import_column_family_job.cc | 22 SuperVersion* sv) { in Prepare() argument
29 status = GetIngestedFileInfo(file_path, &file_to_import, sv); in Prepare()
200 SuperVersion* sv) { in GetIngestedFileInfo() argument
225 sv->mutable_cf_options.prefix_extractor.get(), in GetIngestedFileInfo()
250 ro, sv->mutable_cf_options.prefix_extractor.get(), /*arena=*/nullptr, in GetIngestedFileInfo()
|
| D | external_sst_file_ingestion_job.h | 93 uint64_t next_file_number, SuperVersion* sv);
130 SuperVersion* sv);
135 Status AssignLevelAndSeqnoForIngestedFile(SuperVersion* sv,
|
| D | external_sst_file_ingestion_job.cc | 31 uint64_t next_file_number, SuperVersion* sv) { in Prepare() argument
37 status = GetIngestedFileInfo(file_path, &file_to_ingest, sv); in Prepare()
360 SuperVersion* sv) { in GetIngestedFileInfo() argument
385 sv->mutable_cf_options.prefix_extractor.get(), in GetIngestedFileInfo()
459 ro, sv->mutable_cf_options.prefix_extractor.get(), /*arena=*/nullptr, in GetIngestedFileInfo()
527 SuperVersion* sv, bool force_global_seqno, CompactionStyle compaction_style, in AssignLevelAndSeqnoForIngestedFile() argument
554 status = sv->current->OverlapWithLevelIterator( in AssignLevelAndSeqnoForIngestedFile()
|
| D | import_column_family_job.h | 38 Status Prepare(uint64_t next_file_number, SuperVersion* sv);
58 SuperVersion* sv);
|
| D | forward_iterator.cc | 231 void ForwardIterator::SVCleanup(DBImpl* db, SuperVersion* sv, in SVCleanup() argument
233 if (sv->Unref()) { in SVCleanup()
238 sv->Cleanup(); in SVCleanup()
242 db->AddSuperVersionsToFreeQueue(sv); in SVCleanup()
247 delete sv; in SVCleanup()
259 SuperVersion* sv; member
268 d->db, d->sv, d->background_purge_on_iterator_cleanup); in DeferredSVCleanup()
|
| D | forward_iterator.h | 93 DBImpl* db, SuperVersion* sv, bool background_purge_on_iterator_cleanup);
|
| D | column_family.h | 447 bool ReturnThreadLocalSuperVersion(SuperVersion* sv);
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl.cc | 1358 delete sv; in BackgroundCallPurge()
1654 sv->current->Get( in GetImpl()
3008 if (sv->Unref()) { in CleanupSuperVersion()
3013 sv->Cleanup(); in CleanupSuperVersion()
3020 delete sv; in CleanupSuperVersion()
3030 CleanupSuperVersion(sv); in ReturnAndCleanupSuperVersion()
3106 v = sv->current; in GetApproximateSizes()
4336 CleanupSuperVersion(sv); in CreateColumnFamilyWithImport()
4441 if (sv && sv->Unref()) { in VerifyChecksum()
4442 sv->Cleanup(); in VerifyChecksum()
[all …]
|
| D | db_impl_readonly.cc | 114 auto* sv = cfd->GetSuperVersion()->Ref(); in NewIterators() local
116 env_, read_options, *cfd->ioptions(), sv->mutable_cf_options, read_seq, in NewIterators()
117 sv->mutable_cf_options.max_sequential_skip_in_iterations, in NewIterators()
118 sv->version_number, read_callback); in NewIterators()
120 NewInternalIterator(read_options, cfd, sv, db_iter->GetArena(), in NewIterators()
|
| D | db_impl.h | 520 SequenceNumber GetEarliestMemTableSequenceNumber(SuperVersion* sv,
550 Status GetLatestSequenceForKey(SuperVersion* sv, const Slice& key,
673 void CleanupSuperVersion(SuperVersion* sv);
678 void ReturnAndCleanupSuperVersion(ColumnFamilyData* cfd, SuperVersion* sv);
822 void AddSuperVersionsToFreeQueue(SuperVersion* sv) { in AddSuperVersionsToFreeQueue() argument
823 superversions_to_free_queue_.push_back(sv); in AddSuperVersionsToFreeQueue()
1723 SuperVersion* sv) in MultiGetColumnFamilyData()
1728 super_version(sv) {} in MultiGetColumnFamilyData()
1731 size_t count, SuperVersion* sv) in MultiGetColumnFamilyData()
1736 super_version(sv) {} in MultiGetColumnFamilyData()
[all …]
|
| /rocksdb-6.9/include/rocksdb/ |
| D | slice.h | 50 Slice(std::string_view sv) : data_(sv.data()), size_(sv.size()) {} in Slice() argument
|