| /rocksdb-6.9/db/ |
| D | memtable_list.h | 53 void Unref(autovector<MemTable*>* to_delete = nullptr);
147 void Add(MemTable* m, autovector<MemTable*>* to_delete);
149 void Remove(MemTable* m, autovector<MemTable*>* to_delete);
161 void AddMemTable(MemTable* m);
163 void UnrefMemTable(autovector<MemTable*>* to_delete, MemTable* m);
178 std::list<MemTable*> memlist_;
182 std::list<MemTable*> memlist_history_;
254 autovector<MemTable*>* mems);
274 void Add(MemTable* m, autovector<MemTable*>* to_delete);
335 const autovector<MemTable*>& memtables_to_flush);
[all …]
|
| D | memtable_list.cc | 131 for (MemTable* memtable : memlist_) { in GetMergeOperands()
258 void MemTableListVersion::Add(MemTable* m, autovector<MemTable*>* to_delete) { in Add()
317 MemTable* x = memlist_history_.back(); in TrimHistory()
343 MemTable* m = *it; in PickMemtablesToFlush()
373 for (MemTable* m : mems) { in RollbackMemtableFlush()
441 MemTable* m = *it; in TryInstallMemtableFlushResults()
516 MemTable* m = *it; in TryInstallMemtableFlushResults()
537 void MemTableList::Add(MemTable* m, autovector<MemTable*>* to_delete) { in Add()
753 autovector<MemTable*> old_memtables; in RemoveOldMemTables()
755 MemTable* mem = *it; in RemoveOldMemTables()
[all …]
|
| D | memtable_list_test.cc | 87 const autovector<MemTable*>& m, autovector<MemTable*>* to_delete) { in Mock_InstallMemtableFlushResults()
196 autovector<MemTable*> mems; in TEST_F()
235 MemTable* mem = new MemTable(cmp, ioptions, MutableCFOptions(options), &wb, in TEST_F()
277 MemTable* mem2 = new MemTable(cmp, ioptions, MutableCFOptions(options), &wb2, in TEST_F()
317 for (MemTable* m : to_delete) { in TEST_F()
352 MemTable* mem = new MemTable(cmp, ioptions, MutableCFOptions(options), &wb, in TEST_F()
437 MemTable* mem2 = new MemTable(cmp, ioptions, MutableCFOptions(options), &wb2, in TEST_F()
462 MemTable* mem3 = new MemTable(cmp, ioptions, MutableCFOptions(options), &wb3, in TEST_F()
541 std::vector<MemTable*> tables; in TEST_F()
544 MemTable* mem = new MemTable(cmp, ioptions, mutable_cf_options, &wb, in TEST_F()
[all …]
|
| D | memtable.cc | 63 MemTable::MemTable(const InternalKeyComparator& cmp, in MemTable() function in ROCKSDB_NAMESPACE::MemTable
124 MemTable::~MemTable() { in ~MemTable()
129 size_t MemTable::ApproximateMemoryUsage() { in ApproximateMemoryUsage()
148 bool MemTable::ShouldFlushNow() { in ShouldFlushNow()
208 void MemTable::UpdateFlushState() { in UpdateFlushState()
219 void MemTable::UpdateOldestKeyTime() { in UpdateOldestKeyTime()
411 const MemTable::KeyComparator comparator_;
450 MemTable::MemTableStats MemTable::ApproximateStats(const Slice& start_ikey, in ApproximateStats()
608 MemTable* mem;
840 void MemTable::GetFromTable(const LookupKey& key, in GetFromTable()
[all …]
|
| D | column_family.h | 35 class MemTable; variable
202 MemTable* mem;
225 void Init(ColumnFamilyData* new_cfd, MemTable* new_mem,
242 autovector<MemTable*> to_delete;
361 MemTable* mem() { return mem_; } in mem()
368 void SetMemtable(MemTable* new_mem) { in SetMemtable()
378 MemTable* ConstructNewMemtable(const MutableCFOptions& mutable_cf_options,
548 MemTable* mem_;
743 virtual MemTable* GetMemTable() const override;
|
| D | memtable.h | 82 class MemTable {
102 explicit MemTable(const InternalKeyComparator& comparator,
108 MemTable(const MemTable&) = delete;
109 MemTable& operator=(const MemTable&) = delete;
112 ~MemTable();
123 MemTable* Unref() { in Unref()
|
| D | flush_job.h | 49 class MemTable; variable
85 const autovector<MemTable*>& GetMemTables() const { return mems_; } in GetMemTables()
98 void ReportFlushInputSize(const autovector<MemTable*>& mems);
155 autovector<MemTable*> mems_;
|
| D | write_batch_internal.h | 23 class MemTable; variable
35 virtual MemTable* GetMemTable() const = 0;
42 explicit ColumnFamilyMemTablesDefault(MemTable* mem) in ColumnFamilyMemTablesDefault()
52 MemTable* GetMemTable() const override { in GetMemTable()
61 MemTable* mem_;
|
| D | db_memtable_test.cc | 145 MemTable* mem = new MemTable(cmp, ioptions, MutableCFOptions(options), &wb, in TEST_F()
185 mem = new MemTable(cmp, ioptions, MutableCFOptions(options), &wb, in TEST_F()
197 mem = new MemTable(cmp, ioptions, MutableCFOptions(options), &wb, in TEST_F()
225 MemTable* mem = new MemTable(cmp, ioptions, MutableCFOptions(options), &wb, in TEST_F()
|
| D | flush_job_test.cc | 211 autovector<MemTable*> to_delete; in TEST_F()
257 std::vector<MemTable*> new_mems; in TEST_F()
259 MemTable* mem = cfd->ConstructNewMemtable(*cfd->GetLatestMutableCFOptions(), in TEST_F()
274 autovector<MemTable*> to_delete; in TEST_F()
329 autovector<MemTable*> to_delete; in TEST_F()
335 MemTable* mem = cfd->ConstructNewMemtable( in TEST_F()
386 autovector<const autovector<MemTable*>*> mems_list; in TEST_F()
466 autovector<MemTable*> to_delete; in TEST_F()
|
| D | column_family.cc | 431 MemTable* m = mem->Unref(); in Cleanup()
444 void SuperVersion::Init(ColumnFamilyData* new_cfd, MemTable* new_mem, in Init()
626 autovector<MemTable*> to_delete; in ~ColumnFamilyData()
628 for (MemTable* m : to_delete) { in ~ColumnFamilyData()
693 autovector<MemTable*> empty_list; in OldestLogToKeep()
1029 MemTable* ColumnFamilyData::ConstructNewMemtable( in ConstructNewMemtable()
1031 return new MemTable(internal_comparator_, ioptions_, mutable_cf_options, in ConstructNewMemtable()
1536 MemTable* ColumnFamilyMemTablesImpl::GetMemTable() const { in GetMemTable()
|
| D | job_context.h | 20 class MemTable; variable
159 autovector<MemTable*> memtables_to_free;
|
| D | flush_job.cc | 146 void FlushJob::ReportFlushInputSize(const autovector<MemTable*>& mems) { in ReportFlushInputSize()
178 MemTable* m = mems_[0]; in PickMemTable()
321 for (MemTable* m : mems_) { in WriteLevel0Table()
|
| D | write_batch.cc | 1208 using MemPostInfoMap = std::map<MemTable*, MemTablePostProcessInfo>;
1230 using HintMap = std::unordered_map<MemTable*, void*>;
1422 MemTable* mem = cf_mems_->GetMemTable(); in PutCFImpl()
1511 MemTable* mem = cf_mems_->GetMemTable(); in DeleteImpl()
1673 MemTable* mem = cf_mems_->GetMemTable(); in MergeCF()
1799 const MemTable* const mem = cfd->mem(); in CheckMemtableFull()
1953 MemTablePostProcessInfo* get_post_process_info(MemTable* mem) { in get_post_process_info()
|
| D | write_batch_test.cc | 33 MemTable* mem = new MemTable(cmp, ioptions, MutableCFOptions(options), &wb, in PrintContents()
|
| D | db_flush_test.cc | 404 auto* mems = reinterpret_cast<autovector<MemTable*>*>(arg); in TEST_F()
|
| D | repair.cc | 401 MemTable* mem = cfd->mem(); in ConvertLogToTable()
|
| /rocksdb-6.9/java/rocksjni/ |
| D | write_batch_test.cc | 49 ROCKSDB_NAMESPACE::MemTable* mem = new ROCKSDB_NAMESPACE::MemTable( in Java_org_rocksdb_WriteBatchTest_getContents()
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction_job.h | 51 class MemTable; variable
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl.h | 70 class MemTable; variable
1191 autovector<MemTable*> memtables_to_free_;
1403 MemTable* mem, VersionEdit* edit);
2126 const autovector<MemTable*>& memtables_to_flush,
2134 const autovector<MemTable*>& memtables_to_flush);
|
| D | db_impl_files.cc | 580 const autovector<MemTable*>& memtables_to_flush) { in FindMinPrepLogReferencedByMemTable()
610 const autovector<MemTable*>& memtables_to_flush, in PrecomputeMinLogNumberToKeep()
|
| D | db_impl_debug.cc | 236 autovector<MemTable*> empty_list; in TEST_FindMinPrepLogReferencedByMemTable()
|
| D | db_impl_secondary.cc | 247 MemTable* new_mem = in RecoverLogFiles()
|
| D | db_impl_write.cc | 1547 autovector<MemTable*> to_delete; in TrimMemtableHistory()
1639 MemTable* new_mem = nullptr; in SwitchMemtable()
|
| /rocksdb-6.9/memtable/ |
| D | memtablerep_bench.cc | 605 ROCKSDB_NAMESPACE::MemTable::KeyComparator key_comp(internal_key_comp); in main()
|