Home
last modified time | relevance | path

Searched refs:cf (Results 1 – 25 of 61) sorted by relevance

123

/rocksdb-6.9/db_stress_tool/
Ddb_stress_shared_state.h224 void LockColumnFamily(int cf) { in LockColumnFamily() argument
225 for (auto& mutex : key_locks_[cf]) { in LockColumnFamily()
230 void UnlockColumnFamily(int cf) { in UnlockColumnFamily() argument
231 for (auto& mutex : key_locks_[cf]) { in UnlockColumnFamily()
237 return values_[cf * max_key_ + key]; in Value()
240 void ClearColumnFamily(int cf) { in ClearColumnFamily() argument
241 std::fill(&Value(cf, 0 /* key */), &Value(cf + 1, 0 /* key */), in ClearColumnFamily()
261 uint32_t Get(int cf, int64_t key) const { return Value(cf, key); } in Get() argument
276 return Delete(cf, key, pending); in SingleDelete()
284 if (Delete(cf, key, pending)) { in DeleteRange()
[all …]
Dno_batched_ops_stress.cc32 for (size_t cf = 0; cf < column_families_.size(); ++cf) { in VerifyDb() local
41 db_->NewIterator(options, column_families_[cf])); in VerifyDb()
68 static_cast<int>(cf), i); in VerifyDb()
114 cf, new_name.c_str()); in MaybeClearOneColumnFamily()
116 thread->shared->LockColumnFamily(cf); in MaybeClearOneColumnFamily()
118 delete column_families_[cf]; in MaybeClearOneColumnFamily()
125 &column_families_[cf]); in MaybeClearOneColumnFamily()
126 column_family_names_[cf] = new_name; in MaybeClearOneColumnFamily()
127 thread->shared->ClearColumnFamily(cf); in MaybeClearOneColumnFamily()
133 thread->shared->UnlockColumnFamily(cf); in MaybeClearOneColumnFamily()
[all …]
Ddb_stress_test_base.cc63 for (auto cf : column_families_) { in ~StressTest() local
64 delete cf; in ~StressTest()
73 delete cf; in ~StressTest()
80 for (auto* cf : cmp_cfhs_) { in ~StressTest() local
81 delete cf; in ~StressTest()
402 for (auto cf : column_families_) { in PreloadDbAndReopenAsReadOnly() local
403 delete cf; in PreloadDbAndReopenAsReadOnly()
1930 for (auto cf : sorted_cfn) { in Open() local
2120 for (auto cf : column_families_) { in Reopen() local
2121 delete cf; in Reopen()
[all …]
/rocksdb-6.9/db/
Ddb_test_util.cc690 if (cf == 0) { in Flush()
913 if (cf == 0) { in AllEntriesFor()
972 if (cf == 0) { in NumSortedRuns()
988 if (cf == 0) { in TotalSize()
1010 if (cf == 0) { in TotalLiveFiles()
1030 if (cf == 0) { in NumTableFilesAtLevel()
1044 if (cf == 0) { in CompressionRatioAtLevel()
1104 if (cf == 0) { in Size()
1149 if (cf > 0) { in MoveFilesToLevel()
1257 if (cf == 0) { in VerifyIterLast()
[all …]
Ddb_with_timestamp_basic_test.cc477 for (int cf = 0; cf != static_cast<int>(num_cfs); ++cf) { in TEST_P() local
479 ASSERT_OK(Put(cf, Key1(j), in TEST_P()
490 for (int cf = 0; cf != static_cast<int>(num_cfs); ++cf) { in TEST_P() local
607 for (int cf = 0; cf != static_cast<int>(num_cfs); ++cf) { in TEST_P() local
610 ASSERT_OK(Put(cf, Key1(j), in TEST_P()
620 ASSERT_OK(Flush(cf)); in TEST_P()
642 for (int cf = 0; cf != static_cast<int>(num_cfs); ++cf) { in TEST_P() local
710 for (int cf = 0; cf != static_cast<int>(num_cfs); ++cf) { in TEST_F() local
721 verify_records_func(i, handles_[cf]); in TEST_F()
723 ASSERT_OK(Flush(cf)); in TEST_F()
[all …]
Dcolumn_family_test.cc147 for (int cf = 0; cf < 3; cf++) { in CheckMissed() local
314 for (auto cf : cfs) { in DropColumnFamilies() local
317 handles_[cf] = nullptr; in DropColumnFamilies()
318 names_[cf] = ""; in DropColumnFamilies()
324 keys_.resize(cf + 1); in PutRandomData()
364 Status Flush(int cf) { in Flush() argument
381 void CompactAll(int cf) { in CompactAll() argument
392 return GetProperty(cf, in NumTableFilesAtLevel()
420 (void) cf; in AssertFilesPerLevel()
3356 for (int cf = 1; cf != 3; ++cf) { in TEST_P() local
[all …]
Ddb_test_util.h819 Status Flush(int cf = 0);
836 Status Delete(int cf, const std::string& k);
846 std::string Get(int cf, const std::string& k,
867 std::string Contents(int cf = 0);
872 int NumSortedRuns(int cf = 0);
874 uint64_t TotalSize(int cf = 0);
878 size_t TotalLiveFiles(int cf = 0);
890 std::string FilesPerLevel(int cf = 0);
906 int cf = 0);
911 int cf);
[all …]
Ddb_table_properties_test.cc233 for (uint32_t cf = 0; cf < 2; ++cf) { in TEST_F() local
234 Put(cf, "key", "val"); in TEST_F()
235 Flush(cf); in TEST_F()
238 ASSERT_OK(db_->GetPropertiesOfAllTables(handles_[cf], &fname_to_props)); in TEST_F()
242 if (cf > 0) { in TEST_F()
249 ASSERT_EQ(cf, static_cast<uint32_t>( in TEST_F()
Ddb_basic_test.cc1047 int cf = i / 3; in TEST_P() local
1050 cf, "cf" + std::to_string(cf) + "_key_" + std::to_string(cf_key), in TEST_P()
1064 int cf = i / 3; in TEST_P() local
1067 ASSERT_OK(Flush(cf)); in TEST_P()
1125 for (int cf = 0; cf < 8; ++cf) { in TEST_P() local
1747 for (size_t cf = 0; cf != num_cfs; ++cf) { in TEST_F() local
1758 for (size_t cf = 0; cf != num_cfs; ++cf) { in TEST_F() local
1767 for (size_t cf = 0; cf != num_cfs; ++cf) { in TEST_F() local
1808 for (size_t cf = 0; cf != num_cfs; ++cf) { in TEST_F() local
1862 for (int cf = 0; cf < static_cast<int>(kAllCfNames.size()); ++cf) { in TEST_F() local
[all …]
Ddb_log_iter_test.cc252 Status PutCF(uint32_t cf, const Slice& key, const Slice& value) override { in TEST_F()
253 seen += "Put(" + ToString(cf) + ", " + key.ToString() + ", " + in TEST_F()
257 Status MergeCF(uint32_t cf, const Slice& key, const Slice& value) override { in TEST_F()
258 seen += "Merge(" + ToString(cf) + ", " + key.ToString() + ", " + in TEST_F()
265 Status DeleteCF(uint32_t cf, const Slice& key) override { in TEST_F()
266 seen += "Delete(" + ToString(cf) + ", " + key.ToString() + ")"; in TEST_F()
Ddb_logical_block_size_cache_test.cc139 ColumnFamilyHandle* cf = nullptr; in TEST_F() local
140 ASSERT_OK(db->CreateColumnFamily(cf_options, "cf", &cf)); in TEST_F()
150 ASSERT_OK(db->DropColumnFamily(cf)); in TEST_F()
160 ASSERT_OK(db->DestroyColumnFamilyHandle(cf)); in TEST_F()
194 for (ColumnFamilyHandle* cf : cfs) { in TEST_F()
195 ASSERT_OK(db->DropColumnFamily(cf)); in TEST_F()
328 ColumnFamilyHandle* cf = nullptr; in TEST_F() local
329 ASSERT_OK(db->CreateColumnFamily(cf_options, "cf", &cf)); in TEST_F()
337 ASSERT_OK(db->DestroyColumnFamilyHandle(cf)); in TEST_F()
Ddb_memtable_test.cc325 for (uint32_t cf = 0; cf < 2; ++cf) { in TEST_F() local
326 ASSERT_OK(Put(cf, "key", "val")); in TEST_F()
327 ASSERT_OK(Flush(cf)); in TEST_F()
329 cf, static_cast<MockMemTableRepFactory*>(options.memtable_factory.get()) in TEST_F()
/rocksdb-6.9/db/compaction/
Dcompaction_job_stats_test.cc138 for (auto cf : cfs) { in CreateColumnFamilies() local
215 Status Flush(int cf = 0) { in Flush() argument
216 if (cf == 0) { in Flush()
271 if (cf == 0) { in NumTableFilesAtLevel()
305 if (cf == 0) { in Size()
337 int cf = 0) { in MakeTables() argument
340 ASSERT_OK(Put(cf, large, "end")); in MakeTables()
341 ASSERT_OK(Flush(cf)); in MakeTables()
356 double ratio, int cf = 0) { in MakeTableWithKeyValues() argument
361 ASSERT_OK(Flush(cf)); in MakeTableWithKeyValues()
[all …]
/rocksdb-6.9/util/
Dduplicate_detector.h20 bool IsDuplicateKeySeq(uint32_t cf, const Slice& key, SequenceNumber seq) { in IsDuplicateKeySeq() argument
26 CFKeys& cf_keys = keys_[cf]; in IsDuplicateKeySeq()
28 InitWithComp(cf); in IsDuplicateKeySeq()
33 InitWithComp(cf); in IsDuplicateKeySeq()
34 keys_[cf].insert(key); in IsDuplicateKeySeq()
45 void InitWithComp(const uint32_t cf) { in InitWithComp() argument
46 auto h = db_->GetColumnFamilyHandle(cf); in InitWithComp()
55 "family", cf); in InitWithComp()
65 keys_[cf] = CFKeys(SetComparator(cmp)); in InitWithComp()
/rocksdb-6.9/utilities/transactions/
Dwrite_unprepared_txn.cc297 Status AddUntrackedKey(uint32_t cf, const Slice& key) { in FlushWriteBatchToDBInternal()
299 if (txn_->tracked_keys_[cf].count(str) == 0) { in FlushWriteBatchToDBInternal()
300 txn_->untracked_keys_[cf].push_back(str); in FlushWriteBatchToDBInternal()
306 return AddUntrackedKey(cf, key); in FlushWriteBatchToDBInternal()
310 return AddUntrackedKey(cf, key); in FlushWriteBatchToDBInternal()
314 return AddUntrackedKey(cf, key); in FlushWriteBatchToDBInternal()
319 return AddUntrackedKey(cf, key); in FlushWriteBatchToDBInternal()
420 return wb_->Put(handles_.at(cf), key, value); in FlushWriteBatchWithSavePointToDB()
424 return wb_->Delete(handles_.at(cf), key); in FlushWriteBatchWithSavePointToDB()
428 return wb_->SingleDelete(handles_.at(cf), key); in FlushWriteBatchWithSavePointToDB()
[all …]
Dwrite_unprepared_txn_db.cc87 Status Rollback(uint32_t cf, const Slice& key) { in RollbackRecoveredTransaction()
89 CFKeys& cf_keys = keys_[cf]; in RollbackRecoveredTransaction()
91 auto cmp = comparators_[cf]; in RollbackRecoveredTransaction()
92 keys_[cf] = CFKeys(SetComparator(cmp)); in RollbackRecoveredTransaction()
102 auto cf_handle = handles_[cf]; in RollbackRecoveredTransaction()
124 Status PutCF(uint32_t cf, const Slice& key, in RollbackRecoveredTransaction()
126 return Rollback(cf, key); in RollbackRecoveredTransaction()
130 return Rollback(cf, key); in RollbackRecoveredTransaction()
134 return Rollback(cf, key); in RollbackRecoveredTransaction()
137 Status MergeCF(uint32_t cf, const Slice& key, in RollbackRecoveredTransaction()
[all …]
Dwrite_prepared_txn.cc277 Status Rollback(uint32_t cf, const Slice& key) { in RollbackInternal()
279 CFKeys& cf_keys = keys_[cf]; in RollbackInternal()
281 auto cmp = comparators_[cf]; in RollbackInternal()
282 keys_[cf] = CFKeys(SetComparator(cmp)); in RollbackInternal()
292 auto cf_handle = handles_[cf]; in RollbackInternal()
315 return Rollback(cf, key); in RollbackInternal()
318 Status DeleteCF(uint32_t cf, const Slice& key) override { in RollbackInternal()
319 return Rollback(cf, key); in RollbackInternal()
323 return Rollback(cf, key); in RollbackInternal()
326 Status MergeCF(uint32_t cf, const Slice& key, in RollbackInternal()
[all …]
Dwrite_prepared_txn_db.h1051 void AddKey(const uint32_t cf, const Slice& key);
1052 void InitWithComp(const uint32_t cf);
1056 Status PutCF(uint32_t cf, const Slice& key, const Slice&) override { in PutCF()
1057 AddKey(cf, key); in PutCF()
1060 Status DeleteCF(uint32_t cf, const Slice& key) override { in DeleteCF()
1061 AddKey(cf, key); in DeleteCF()
1064 Status SingleDeleteCF(uint32_t cf, const Slice& key) override { in SingleDeleteCF()
1065 AddKey(cf, key); in SingleDeleteCF()
1068 Status MergeCF(uint32_t cf, const Slice& key, const Slice&) override { in MergeCF()
1069 AddKey(cf, key); in MergeCF()
/rocksdb-6.9/utilities/ttl/
Dttl_test.cc155 ColumnFamilyHandle* cf = nullptr) { in PutValues() argument
164 ASSERT_OK(cf == nullptr in PutValues()
169 ASSERT_OK(cf == nullptr ? db_ttl_->Put(wopts, "keymock", "valuemock") in PutValues()
172 if (cf == nullptr) { in PutValues()
175 db_ttl_->Flush(flush_opts, cf); in PutValues()
181 void ManualCompact(ColumnFamilyHandle* cf = nullptr) { in ManualCompact() argument
182 if (cf == nullptr) { in ManualCompact()
235 ColumnFamilyHandle* cf = nullptr) { in SleepCompactCheck() argument
239 ManualCompact(cf); in SleepCompactCheck()
299 void SetTtl(int32_t ttl, ColumnFamilyHandle* cf = nullptr) { in SetTtl() argument
[all …]
/rocksdb-6.9/tools/rdb/
Ddb_wrapper.cc157 std::string cf = *v8::String::Utf8Value(args[1]->ToString()); in Get() local
163 } else if (db_wrapper->HasFamilyNamed(cf, db_wrapper)) { in Get()
188 std::string cf = *v8::String::Utf8Value(args[2]->ToString()); in Put() local
193 } else if (db_wrapper->HasFamilyNamed(cf, db_wrapper)) { in Put()
277 ROCKSDB_NAMESPACE::ColumnFamilyHandle* cf; in CreateColumnFamily() local
279 ROCKSDB_NAMESPACE::ColumnFamilyOptions(), cf_name, &cf); in CreateColumnFamily()
285 db_wrapper->columnFamilies_[cf_name] = cf; in CreateColumnFamily()
323 std::string cf) { in AddToBatch() argument
332 db_wrapper->columnFamilies_[cf], in AddToBatch()
348 db_wrapper->columnFamilies_[cf], in AddToBatch()
[all …]
/rocksdb-6.9/java/rocksjni/
Dcompaction_filter.cc24 auto* cf = reinterpret_cast<ROCKSDB_NAMESPACE::CompactionFilter*>(handle); in Java_org_rocksdb_AbstractCompactionFilter_disposeInternal() local
25 assert(cf != nullptr); in Java_org_rocksdb_AbstractCompactionFilter_disposeInternal()
26 delete cf; in Java_org_rocksdb_AbstractCompactionFilter_disposeInternal()
/rocksdb-6.9/utilities/checkpoint/
Dcheckpoint_test.cc113 for (auto cf : cfs) { in CreateColumnFamilies() local
193 for (const auto& cf : cfs) { in ReadOnlyReopenWithColumnFamilies() local
194 column_families.emplace_back(cf, options); in ReadOnlyReopenWithColumnFamilies()
206 Status Flush(int cf = 0) { in Flush() argument
207 if (cf == 0) { in Flush()
210 return db_->Flush(FlushOptions(), handles_[cf]); in Flush()
218 Status Put(int cf, const Slice& k, const Slice& v, in Put() argument
220 return db_->Put(wo, handles_[cf], k, v); in Put()
227 Status Delete(int cf, const std::string& k) { in Delete() argument
228 return db_->Delete(WriteOptions(), handles_[cf], k); in Delete()
[all …]
/rocksdb-6.9/examples/
Dcolumn_families_example.cc26 ColumnFamilyHandle* cf; in main() local
27 s = db->CreateColumnFamily(ColumnFamilyOptions(), "new_cf", &cf); in main()
31 s = db->DestroyColumnFamilyHandle(cf); in main()
Doptions_file_example.cc68 ColumnFamilyHandle* cf; in main() local
69 s = db->CreateColumnFamily(ColumnFamilyOptions(), "new_cf", &cf); in main()
73 delete cf; in main()
/rocksdb-6.9/include/rocksdb/
Ddb.h526 std::vector<ColumnFamilyHandle*> cf; variable
532 cf.emplace_back(column_family);
535 status = MultiGet(options, cf, user_keys, &vals);
548 std::vector<ColumnFamilyHandle*> cf; variable
555 cf.emplace_back(column_family);
558 status = MultiGet(options, cf, user_keys, &vals, &tss);
590 std::vector<ColumnFamilyHandle*> cf; variable
596 cf.emplace_back(column_families[i]);
599 status = MultiGet(options, cf, user_keys, &vals);
610 std::vector<ColumnFamilyHandle*> cf; variable
[all …]

123