Searched refs:edit_lists (Results 1 – 6 of 6) sorted by relevance
| /rocksdb-6.9/db/ |
| D | version_set.h | 841 autovector<autovector<VersionEdit*>> edit_lists; variable
844 edit_lists.emplace_back(edit_list);
845 return LogAndApply(cfds, mutable_cf_options_list, edit_lists, mu,
860 autovector<autovector<VersionEdit*>> edit_lists; variable
861 edit_lists.emplace_back(edit_list);
862 return LogAndApply(cfds, mutable_cf_options_list, edit_lists, mu,
872 const autovector<autovector<VersionEdit*>>& edit_lists,
|
| D | memtable_list.cc | 677 autovector<autovector<VersionEdit*>> edit_lists; in InstallMemtableAtomicFlushResults() local
685 edit_lists.emplace_back(edits); in InstallMemtableAtomicFlushResults()
690 for (auto& edits : edit_lists) { in InstallMemtableAtomicFlushResults()
698 s = vset->LogAndApply(cfds, mutable_cf_options_list, edit_lists, mu, in InstallMemtableAtomicFlushResults()
|
| D | version_set_test.cc | 803 autovector<autovector<VersionEdit*>> edit_lists; in TEST_F() local
809 edit_lists.emplace_back(edit_list); in TEST_F()
824 versions_->LogAndApply(cfds, all_mutable_cf_options, edit_lists, &mutex_); in TEST_F()
1278 autovector<autovector<VersionEdit*>> edit_lists; in TEST_P() local
1293 edit_lists.emplace_back(tmp_edits); in TEST_P()
1318 s = versions_->LogAndApply(cfds, mutable_cf_options_list, edit_lists, in TEST_P()
|
| D | version_set.cc | 4071 const autovector<autovector<VersionEdit*>>& edit_lists, in LogAndApply() argument
4076 for (const auto& elist : edit_lists) { in LogAndApply()
4083 for (const auto& edit_list : edit_lists) { in LogAndApply()
4093 assert(edit_lists.size() == 1 && edit_lists[0].size() == 1); in LogAndApply()
4094 assert(edit_lists[0][0]->is_column_family_add_); in LogAndApply()
4100 assert(static_cast<size_t>(num_cfds) == edit_lists.size()); in LogAndApply()
4104 *mutable_cf_options_list[i], edit_lists[i]); in LogAndApply()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_open.cc | 1112 autovector<autovector<VersionEdit*>> edit_lists; in RecoverLogFiles() local
1118 edit_lists.push_back({&iter->second}); in RecoverLogFiles()
1121 status = versions_->LogAndApply(cfds, cf_opts, edit_lists, &mutex_, in RecoverLogFiles()
|
| D | db_impl.cc | 4190 autovector<autovector<VersionEdit*>> edit_lists; in IngestExternalFiles() local
4202 edit_lists.push_back(edit_list); in IngestExternalFiles()
4208 for (auto& edits : edit_lists) { in IngestExternalFiles()
4216 edit_lists, &mutex_, directories_.GetDbDir()); in IngestExternalFiles()
|