Home
last modified time | relevance | path

Searched refs:GetID (Results 1 – 25 of 43) sorted by relevance

12

/rocksdb-6.9/utilities/blob_db/
Dblob_db.h92 if (column_family->GetID() != DefaultColumnFamily()->GetID()) { in Put()
103 if (column_family->GetID() != DefaultColumnFamily()->GetID()) { in Delete()
116 if (column_family->GetID() != DefaultColumnFamily()->GetID()) { in PutWithTTL()
130 if (column_family->GetID() != DefaultColumnFamily()->GetID()) { in PutUntil()
162 if (column_family->GetID() != DefaultColumnFamily()->GetID()) { in MultiGet()
202 if (column_family->GetID() != DefaultColumnFamily()->GetID()) { in NewIterator()
222 if (column_family->GetID() != DefaultColumnFamily()->GetID()) {
Dblob_db_impl.cc665 static_cast<ColumnFamilyHandleImpl*>(DefaultColumnFamily())->GetID(); in NewBlobFile()
965 reinterpret_cast<ColumnFamilyHandleImpl*>(DefaultColumnFamily())->GetID(); in Write()
1020 reinterpret_cast<ColumnFamilyHandleImpl*>(DefaultColumnFamily())->GetID(); in PutBlobValue()
1577 if (column_family->GetID() != DefaultColumnFamily()->GetID()) { in GetImpl()
/rocksdb-6.9/db/
Dversion_edit_handler.cc288 auto builder_iter = builders_.find(cfd->GetID()); in CheckIterationResult()
381 auto builder_iter = builders_.find(cfd->GetID()); in MaybeCreateVersion()
402 auto builder_iter = builders_.find(cfd->GetID()); in LoadTables()
496 auto v_iter = versions_.find(cfd->GetID()); in CheckIterationResult()
522 assert(edit.column_family_ == cfd->GetID()); in MaybeCreateVersion()
524 auto missing_files_iter = cf_to_missing_files_.find(cfd->GetID()); in MaybeCreateVersion()
555 auto builder_iter = builders_.find(cfd->GetID()); in MaybeCreateVersion()
565 auto v_iter = versions_.find(cfd->GetID()); in MaybeCreateVersion()
570 versions_.emplace(cfd->GetID(), version); in MaybeCreateVersion()
Dflush_job.cc184 edit_->SetColumnFamily(cfd_->GetID()); in PickMemTable()
383 cfd_->int_tbl_prop_collector_factories(), cfd_->GetID(), in WriteLevel0Table()
452 info->cf_id = cfd_->GetID(); in GetFlushJobInfo()
Dmemtable_list.cc347 if (max_memtable_id != nullptr && m->GetID() > *max_memtable_id) { in PickMemtablesToFlush()
664 assert((*mems_list[k])[0]->GetID() == imm->GetEarliestMemTableID()); in InstallMemtableAtomicFlushResults()
714 uint64_t mem_id = m->GetID(); in InstallMemtableAtomicFlushResults()
729 uint64_t mem_id = m->GetID(); in InstallMemtableAtomicFlushResults()
Dversion_set.cc3703 uint32_t cf_id = last_writer->cfd->GetID(); in ProcessManifestWrites()
3704 if (versions[i]->cfd()->GetID() == cf_id) { in ProcessManifestWrites()
3826 curr_state[cfd->GetID()] = {cfd->GetLogNumber()}; in ProcessManifestWrites()
3979 uint32_t cf_id = version->cfd_->GetID(); in ProcessManifestWrites()
4544 assert(builders.count(cfd->GetID()) > 0); in Recover()
5140 cfd->GetName().c_str(), cfd->GetID()); in DumpManifest()
5221 if (cfd->GetID() != 0) { in WriteCurrentStateToManifest()
5225 edit.SetColumnFamily(cfd->GetID()); in WriteCurrentStateToManifest()
5244 edit.SetColumnFamily(cfd->GetID()); in WriteCurrentStateToManifest()
5257 const auto iter = curr_state.find(cfd->GetID()); in WriteCurrentStateToManifest()
[all …]
Dmemtable_list.h342 return memlist.back()->GetID(); in GetEarliestMemTableID()
350 return memlist.front()->GetID(); in GetLatestMemTableID()
Dcolumn_family.h168 virtual uint32_t GetID() const override;
272 uint32_t GetID() const { return id_; } in GetID() function
Dcolumn_family.cc84 uint32_t ColumnFamilyHandleImpl::GetID() const { return cfd()->GetID(); } in GetID() function in ROCKSDB_NAMESPACE::ColumnFamilyHandleImpl
1513 auto cfd_iter = column_family_data_.find(cfd->GetID()); in RemoveColumnFamily()
1550 column_family_id = cfh->GetID(); in GetColumnFamilyID()
Dexternal_sst_file_ingestion_job.cc47 f.cf_id != cfd_->GetID()) { in Prepare()
221 edit_.SetColumnFamily(cfd_->GetID()); in Run()
Ddb_test2.cc3802 auto cfh = dbi->GetColumnFamilyHandleUnlocked(handles_[0]->GetID()); in TEST_F()
3803 ASSERT_EQ(cfh->GetID(), handles_[0]->GetID()); in TEST_F()
3806 ASSERT_EQ(cfh->GetID(), handles_[0]->GetID()); in TEST_F()
3811 auto cfh = dbi->GetColumnFamilyHandleUnlocked(handles_[1]->GetID()); in TEST_F()
3812 ASSERT_EQ(cfh->GetID(), handles_[1]->GetID()); in TEST_F()
3814 ASSERT_EQ(cfh->GetID(), handles_[1]->GetID()); in TEST_F()
Drepair.cc433 cfd->GetID(), cfd->GetName(), {}, kMaxSequenceNumber, in ConvertLogToTable()
580 edit.SetColumnFamily(cfd->GetID()); in AddTables()
Dimport_column_family_job.cc136 edit_.SetColumnFamily(cfd_->GetID()); in Run()
/rocksdb-6.9/db/db_impl/
Ddb_impl_open.cc718 edit.SetColumnFamily(cfd->GetID()); in RecoverLogFiles()
719 version_edits.insert({cfd->GetID(), edit}); in RecoverLogFiles()
739 cf_name_id_map.insert(std::make_pair(cfd->GetName(), cfd->GetID())); in RecoverLogFiles()
741 std::make_pair(cfd->GetID(), cfd->GetLogNumber())); in RecoverLogFiles()
964 auto iter = version_edits.find(cfd->GetID()); in RecoverLogFiles()
1055 auto iter = version_edits.find(cfd->GetID()); in RecoverLogFiles()
1116 auto iter = version_edits.find(cfd->GetID()); in RecoverLogFiles()
1247 cfd->int_tbl_prop_collector_factories(), cfd->GetID(), cfd->GetName(), in WriteLevel0TableForRecovery()
Ddb_impl.cc1725 multiget_cf_data.emplace(cfd->GetID(), in MultiGet()
1770 auto mgd_iter = multiget_cf_data.find(cfh->cfd()->GetID()); in MultiGet()
2031 uint32_t cfd_id1 = cfh->cfd()->GetID(); in operator ()()
2034 uint32_t cfd_id2 = cfh->cfd()->GetID(); in operator ()()
2064 uint32_t cfd_id1 = cfh->cfd()->GetID(); in PrepareMultiGetKeys()
2067 uint32_t cfd_id2 = cfh->cfd()->GetID(); in PrepareMultiGetKeys()
2433 if (cfd->GetID() == 0) { in DropColumnFamilyImpl()
2441 edit.SetColumnFamily(cfd->GetID()); in DropColumnFamilyImpl()
2489 cfd->GetID(), s.ToString().c_str()); in DropColumnFamilyImpl()
3235 edit.SetColumnFamily(cfd->GetID()); in DeleteFile()
[all …]
Ddb_impl_experimental.cc125 edit.SetColumnFamily(cfd->GetID()); in PromoteL0()
Ddb_impl_compaction_flush.cc478 cfds[i]->imm()->GetEarliestMemTableID() < mems[0]->GetID()) { in AtomicFlushMemTablesToOutputFiles()
608 info.cf_id = cfd->GetID(); in NotifyOnFlushBegin()
1309 edit.SetColumnFamily(cfd->GetID()); in ReFitLevel()
1804 uint64_t orig_active_memtable_id = cfd->mem()->GetID(); in WaitUntilFlushWouldNotStallWrites()
1831 std::min(cfd->mem()->GetID(), cfd->imm()->GetEarliestMemTableID()); in WaitUntilFlushWouldNotStallWrites()
3045 compaction_job_info->cf_id = cfd->GetID(); in BuildCompactionJobInfo()
/rocksdb-6.9/utilities/transactions/
Dtransaction_lock_mgr.cc306 LockInfo lock_info(txn->GetID(), txn->GetExpirationTime(), exclusive); in TryLock()
425 auto id = txn->GetID(); in DecrementWaitersImpl()
441 auto id = txn->GetID(); in IncrementWaiters()
594 TransactionID txn_id = txn->GetID(); in UnLockKey()
Dpessimistic_transaction_db.cc362 lock_mgr_.AddColumnFamily(handle->GetID()); in AddColumnFamily()
376 lock_mgr_.AddColumnFamily((*handle)->GetID()); in CreateColumnFamily()
391 lock_mgr_.RemoveColumnFamily(column_family->GetID()); in DropColumnFamily()
Dpessimistic_transaction.h70 TransactionID GetID() const override { return txn_id_; } in GetID() function
/rocksdb-6.9/java/rocksjni/
Dcolumnfamilyhandle.cc38 const int32_t id = cfh->GetID(); in Java_org_rocksdb_ColumnFamilyHandle_getID()
/rocksdb-6.9/trace_replay/
Dtrace_replay.cc90 EncodeCFAndKey(&trace.payload, column_family->GetID(), key); in Get()
179 cf_map_[cfh->GetID()] = cfh; in Replayer()
/rocksdb-6.9/db/compaction/
Dcompaction.cc72 edit_.SetColumnFamily(cfd_->GetID()); in SetInputVersion()
523 context.column_family_id = cfd_->GetID(); in CreateCompactionFilter()
/rocksdb-6.9/utilities/write_batch_with_index/
Dwrite_batch_with_index_test.cc32 uint32_t GetID() const override { return id_; } in GetID() function in ROCKSDB_NAMESPACE::__anon1b97f2c50111::ColumnFamilyHandleImplDummy
250 ASSERT_EQ(entries.size(), handler.seen[data.GetID()].size()); in TestValueAsSecondaryIndexHelper()
252 for (auto e : handler.seen[data.GetID()]) { in TestValueAsSecondaryIndexHelper()
264 ASSERT_EQ(entries.size(), handler.seen[index.GetID()].size()); in TestValueAsSecondaryIndexHelper()
266 for (auto e : handler.seen[index.GetID()]) { in TestValueAsSecondaryIndexHelper()
/rocksdb-6.9/table/
Dsst_file_writer.cc233 cf_id = r->cfh->GetID(); in Open()

12