Home
last modified time | relevance | path

Searched refs:versions_ (Results 1 – 25 of 30) sorted by relevance

12

/rocksdb-6.9/db/db_impl/
Ddb_impl_secondary.cc37 s = static_cast<ReactiveVersionSet*>(versions_.get()) in Recover()
48 for (auto cfd : *versions_->GetColumnFamilySet()) { in Recover()
195 versions_->MarkFileNumberUsed(log_number); in RecoverLogFiles()
286 (versions_->LastSequence() <= last_sequence)) { in RecoverLogFiles()
289 versions_->SetLastSequence(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()
479 versions_->GetLiveFilesMetaData(&metadata); in CheckConsistency()
503 assert(versions_.get() != nullptr); in TryCatchUpWithPrimary()
[all …]
Ddb_impl_open.cc457 versions_->db_id_ = db_id_; in Recover()
458 s = versions_->LogAndApply(versions_->GetColumnFamilySet()->GetDefault(), in Recover()
471 for (auto cfd : *versions_->GetColumnFamilySet()) { in Recover()
487 for (auto cfd : *versions_->GetColumnFamilySet()) { in Recover()
670 versions_->GetColumnFamilySet()->GetColumnFamily( in InitPersistStatsColumnFamily()
716 for (auto cfd : *versions_->GetColumnFamilySet()) { in RecoverLogFiles()
738 for (auto cfd : *versions_->GetColumnFamilySet()) { in RecoverLogFiles()
765 versions_->MarkFileNumberUsed(log_number); in RecoverLogFiles()
1018 (versions_->LastSequence() <= last_sequence)) { in RecoverLogFiles()
1021 versions_->SetLastSequence(last_sequence); in RecoverLogFiles()
[all …]
Ddb_impl_write.cc174 versions_->GetColumnFamilySet()); in WriteImpl()
189 versions_->SetLastSequence(last_sequence); in WriteImpl()
236 last_sequence = versions_->LastSequence(); in WriteImpl()
397 versions_->GetColumnFamilySet()); in WriteImpl()
448 versions_->SetLastSequence(last_sequence); in WriteImpl()
578 versions_->GetColumnFamilySet()); in PipelinedWriteImpl()
618 versions_->GetColumnFamilySet()); in UnorderedWriteMemtable()
1155 seq = versions_->LastSequence(); in WriteRecoverableState()
1168 versions_->SetLastSequence(last_seq); in WriteRecoverableState()
1210 auto seq = versions_->LastSequence(); in AssignAtomicFlushSeq()
[all …]
Ddb_impl.cc316 versions_->SetIOStatusOK(); in ResumeImpl()
571 versions_.reset(); in CloseHelper()
1298 return versions_->LastSequence(); in GetLatestSequenceNumber()
1302 versions_->SetLastPublishedSequence(seq); in SetLastPublishedSequence()
1569 ? versions_->LastSequence() in GetImpl()
1870 ? versions_->LastSequence() in MultiCFSnapshot()
1903 ? versions_->LastSequence() in MultiCFSnapshot()
3114 sizes[i] += versions_->ApproximateSize( in GetApproximateSizes()
3152 if (seq > versions_->LastSequence()) { in GetUpdatesSince()
3348 versions_->GetLiveFilesMetaData(metadata); in GetLiveFilesMetaData()
[all …]
Ddb_impl_files.cc25 return versions_->min_log_number_to_keep_2pc(); in MinLogNumberToKeep()
27 return versions_->MinLogNumberWithUnflushedData(); in MinLogNumberToKeep()
89 versions_->GetObsoleteFiles(&job_context->sst_delete_files, in FindObsoleteFiles()
101 job_context->manifest_file_number = versions_->manifest_file_number(); in FindObsoleteFiles()
103 versions_->pending_manifest_file_number(); in FindObsoleteFiles()
105 job_context->prev_log_number = versions_->prev_log_number(); in FindObsoleteFiles()
107 versions_->AddLiveFiles(&job_context->sst_live); in FindObsoleteFiles()
122 for (auto cfd : *versions_->GetColumnFamilySet()) { in FindObsoleteFiles()
675 for (const auto* cfd : *versions_->GetColumnFamilySet()) { in CleanupFilesAfterRecovery()
684 uint64_t next_file_number = versions_->current_next_file_number(); in CleanupFilesAfterRecovery()
[all …]
Ddb_impl_debug.cc76 return versions_->manifest_file_number(); in TEST_Current_Manifest_FileNo()
80 return versions_->current_next_file_number(); in TEST_Current_Next_FileNo()
210 for (auto cfd : *versions_->GetColumnFamilySet()) { in TEST_GetAllImmutableCFOptions()
237 return FindMinPrepLogReferencedByMemTable(versions_.get(), nullptr, in TEST_FindMinPrepLogReferencedByMemTable()
262 return versions_->LastSequence(); in TEST_GetLastVisibleSequence()
264 return versions_->LastAllocatedSequence(); in TEST_GetLastVisibleSequence()
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()
174 impl->versions_->GetColumnFamilySet()->GetColumnFamily(cf.name); in OpenForReadOnly()
183 for (auto cfd : *impl->versions_->GetColumnFamilySet()) { in OpenForReadOnly()
Ddb_impl_compaction_flush.cc172 versions_->GetColumnFamilySet()->NumberOfColumnFamilies() > 1) { in FlushMemTableToOutputFile()
525 versions_.get(), &mutex_, tmp_file_meta, in AtomicFlushMemTablesToOutputFiles()
1618 versions_->GetColumnFamilySet()->GetColumnFamily( in FlushMemTable()
2452 versions_->GetColumnFamilySet()->FreeDeadColumnFamilies(); in BackgroundCallCompaction()
2691 versions_->SetIOStatusOK(); in BackgroundCompaction()
2692 status = versions_->LogAndApply(c->column_family_data(), in BackgroundCompaction()
2695 io_s = versions_->io_status(); in BackgroundCompaction()
2749 versions_->SetIOStatusOK(); in BackgroundCompaction()
2750 status = versions_->LogAndApply(c->column_family_data(), in BackgroundCompaction()
2753 io_s = versions_->io_status(); in BackgroundCompaction()
[all …]
/rocksdb-6.9/db/
Dflush_job_test.cc56 versions_.reset(new VersionSet(dbname_, &db_options_, env_options_,
60 EXPECT_OK(versions_->Recover(column_families, false));
125 std::unique_ptr<VersionSet> versions_; member in ROCKSDB_NAMESPACE::FlushJobTest
133 auto cfd = versions_->GetColumnFamilySet()->GetDefault(); in TEST_F()
136 FlushJob flush_job(dbname_, versions_->GetColumnFamilySet()->GetDefault(), in TEST_F()
154 auto cfd = versions_->GetColumnFamilySet()->GetDefault(); in TEST_F()
219 FlushJob flush_job(dbname_, versions_->GetColumnFamilySet()->GetDefault(), in TEST_F()
255 ColumnFamilyData* cfd = versions_->GetColumnFamilySet()->GetDefault(); in TEST_F()
319 for (auto cfd : *versions_->GetColumnFamilySet()) { in TEST_F()
360 &memtable_ids[k], env_options_, versions_.get(), &mutex_, in TEST_F()
[all …]
Ddb_filesnapshot.cc95 for (auto cfd : *versions_->GetColumnFamilySet()) { in GetLiveFiles()
111 versions_->GetColumnFamilySet()->FreeDeadColumnFamilies(); in GetLiveFiles()
123 for (auto cfd : *versions_->GetColumnFamilySet()) { in GetLiveFiles()
140 ret.push_back(DescriptorFileName("", versions_->manifest_file_number())); in GetLiveFiles()
141 ret.push_back(OptionsFileName("", versions_->options_file_number())); in GetLiveFiles()
144 *manifest_file_size = versions_->manifest_file_size(); in GetLiveFiles()
Dversion_set_test.cc750 EXPECT_OK(versions_->Recover(column_families, false)); in NewDB()
758 Status s = versions_->GetCurrentManifestPath( in VerifyManifest()
778 std::shared_ptr<VersionSet> versions_; member in ROCKSDB_NAMESPACE::VersionSetTestBase
805 cfds.emplace_back(versions_->GetColumnFamilySet()->GetDefault()); in TEST_F()
969 EXPECT_OK(versions_->Recover(column_families_, false)); in TEST_F()
1032 EXPECT_OK(versions_->Recover(column_families_, false)); in TEST_F()
1119 EXPECT_NOK(versions_->Recover(column_families_, false)); in TEST_F()
1170 EXPECT_NOK(versions_->Recover(column_families_, false)); in TEST_F()
1267 s = versions_->LogAndApply(cfd_to_drop, in TEST_P()
1392 s = versions_->TryRecoverFromOneManifest( in TEST_F()
[all …]
Dversion_edit_handler.cc480 for (const auto& elem : versions_) { in ~VersionEditHandlerPointInTime()
483 versions_.clear(); in ~VersionEditHandlerPointInTime()
496 auto v_iter = versions_.find(cfd->GetID()); in CheckIterationResult()
497 if (v_iter != versions_.end()) { in CheckIterationResult()
501 versions_.erase(v_iter); in CheckIterationResult()
510 auto v_iter = versions_.find(edit.column_family_); in DestroyCfAndCleanup()
511 if (v_iter != versions_.end()) { in DestroyCfAndCleanup()
513 versions_.erase(v_iter); in DestroyCfAndCleanup()
565 auto v_iter = versions_.find(cfd->GetID()); in MaybeCreateVersion()
566 if (v_iter != versions_.end()) { in MaybeCreateVersion()
[all …]
Dwal_manager_test.cc53 versions_.reset(new VersionSet(dbname_, &db_options_, env_options_, in Init()
68 uint64_t seq = versions_->LastSequence() + 1; in Put()
73 versions_->SetLastAllocatedSequence(seq); in Put()
74 versions_->SetLastPublishedSequence(seq); in Put()
75 versions_->SetLastSequence(seq); in Put()
102 seq, &iter, TransactionLogIterator::ReadOptions(), versions_.get()); in OpenTransactionLogIter()
114 std::unique_ptr<VersionSet> versions_; member in ROCKSDB_NAMESPACE::WalManagerTest
Dtransaction_log_impl.cc32 versions_(versions), in TransactionLogIteratorImpl()
35 assert(versions_ != nullptr); in TransactionLogIteratorImpl()
84 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()
161 versions_->SetLastAllocatedSequence(file_metadata.largest_seqno); in Run()
162 versions_->SetLastPublishedSequence(file_metadata.largest_seqno); in Run()
163 versions_->SetLastSequence(file_metadata.largest_seqno); in Run()
Dimport_column_family_job.h29 versions_(versions), in ImportColumnFamilyJob()
61 VersionSet* versions_; variable
Dexternal_sst_file_ingestion_job.h78 versions_(versions), in ExternalSstFileIngestionJob()
163 VersionSet* versions_; variable
Dflush_job.cc107 versions_(versions), in FlushJob()
187 meta_.fd = FileDescriptor(versions_->NewFileNumber(), 0, 0); in PickMemTable()
243 cfd_, mutable_cf_options_, mems_, prep_tracker, versions_, db_mutex_, in Run()
Dflush_job.h116 VersionSet* versions_; variable
Dversion_edit_handler.h120 std::unordered_map<uint32_t, Version*> versions_;
Dtransaction_log_impl.h108 VersionSet const* const versions_; variable
/rocksdb-6.9/db/compaction/
Dcompaction_job_test.cc183 uint64_t file_number = versions_->NewFileNumber(); in AddMockFile()
194 versions_->LogAndApply(versions_->GetColumnFamilySet()->GetDefault(), in AddMockFile()
200 versions_->SetLastAllocatedSequence(sequence_number + 1); in SetLastSequence()
201 versions_->SetLastPublishedSequence(sequence_number + 1); in SetLastSequence()
202 versions_->SetLastSequence(sequence_number + 1); in SetLastSequence()
292 EXPECT_OK(versions_->Recover(column_families, false)); in NewDB()
293 cfd_ = versions_->GetColumnFamilySet()->GetDefault(); in NewDB()
303 auto cfd = versions_->GetColumnFamilySet()->GetDefault();
376 std::unique_ptr<VersionSet> versions_; member in ROCKSDB_NAMESPACE::CompactionJobTest
392 auto cfd = versions_->GetColumnFamilySet()->GetDefault(); in TEST_F()
[all …]
Dcompaction_job.cc320 versions_(versions), in CompactionJob()
519 uint64_t size = versions_->ApproximateSize(SizeApproximationOptions(), v, a, in GenSubcompactionBoundaries()
721 versions_->SetIOStatusOK(); in Install()
725 if (!versions_->io_status().ok()) { in Install()
726 io_status_ = versions_->io_status(); in Install()
842 std::unique_ptr<InternalIterator> input(versions_->MakeInputIterator( in ProcessKeyValueCompaction()
894 input.get(), cfd->user_comparator(), &merge, versions_->LastSequence(), in ProcessKeyValueCompaction()
1420 if (!versions_->VerifyCompactionFileConsistency(compaction)) { in InstallCompactionResults()
1445 return versions_->LogAndApply(compaction->column_family_data(), in InstallCompactionResults()
1466 uint64_t file_number = versions_->NewFileNumber(); in OpenCompactionOutputFile()
Dcompaction_job.h162 VersionSet* versions_; variable
/rocksdb-6.9/utilities/transactions/
Dwrite_unprepared_txn_db.cc324 db_impl_->versions_->SetLastAllocatedSequence(last_seq + 1); in Initialize()
325 db_impl_->versions_->SetLastSequence(last_seq + 1); in Initialize()
326 db_impl_->versions_->SetLastPublishedSequence(last_seq + 1); in Initialize()

12