| /rocksdb-6.9/db/ |
| D | version_edit_handler.h | 50 Status ApplyVersionEdit(VersionEdit& edit, ColumnFamilyData** cfd);
52 Status OnColumnFamilyAdd(VersionEdit& edit, ColumnFamilyData** cfd);
54 Status OnColumnFamilyDrop(VersionEdit& edit, ColumnFamilyData** cfd);
56 Status OnNonCfOperation(VersionEdit& edit, ColumnFamilyData** cfd);
60 void CheckColumnFamilyId(const VersionEdit& edit, bool* cf_in_not_found,
66 const VersionEdit& edit);
68 virtual ColumnFamilyData* DestroyCfAndCleanup(const VersionEdit& edit);
70 virtual Status MaybeCreateVersion(const VersionEdit& edit,
94 const VersionEdit& edit);
115 ColumnFamilyData* DestroyCfAndCleanup(const VersionEdit& edit) override;
[all …]
|
| D | version_edit_test.cc | 21 VersionEdit parsed; in TestEncodeDecode()
34 VersionEdit edit; in TEST_F()
55 VersionEdit edit; in TEST_F()
110 VersionEdit edit; in TEST_F()
162 VersionEdit edit; in TEST_F()
193 VersionEdit edit; in TEST_F()
203 VersionEdit edit; in TEST_F()
216 VersionEdit edit; in TEST_F()
226 VersionEdit edit; in TEST_F()
232 VersionEdit ve; in TEST_F()
[all …]
|
| D | version_set.h | 77 using VersionEditParams = VersionEdit;
794 Status AddEdit(VersionEdit* edit);
806 std::vector<VersionEdit> replay_buffer_;
841 autovector<autovector<VersionEdit*>> edit_lists;
842 autovector<VersionEdit*> edit_list;
860 autovector<autovector<VersionEdit*>> edit_lists;
872 const autovector<autovector<VersionEdit*>>& edit_lists,
1137 VersionEdit& edit,
1212 void LogAndApplyCFHelper(VersionEdit* edit);
1244 std::vector<VersionEdit>& replay_buffer() { in replay_buffer()
[all …]
|
| D | version_edit_handler.cc | 36 VersionEdit edit; in Iterate()
93 VersionEdit default_cf_edit; in Initialize()
108 Status VersionEditHandler::ApplyVersionEdit(VersionEdit& edit, in ApplyVersionEdit()
125 Status VersionEditHandler::OnColumnFamilyAdd(VersionEdit& edit, in OnColumnFamilyAdd()
163 Status VersionEditHandler::OnColumnFamilyDrop(VersionEdit& edit, in OnColumnFamilyDrop()
184 Status VersionEditHandler::OnNonCfOperation(VersionEdit& edit, in OnNonCfOperation()
228 void VersionEditHandler::CheckColumnFamilyId(const VersionEdit& edit, in CheckColumnFamilyId()
319 VersionEdit edit; in CheckIterationResult()
341 const ColumnFamilyOptions& cf_options, const VersionEdit& edit) { in CreateCfAndInit()
356 const VersionEdit& edit) { in DestroyCfAndCleanup()
[all …]
|
| D | version_builder_test.cc | 146 VersionEdit version_edit; in TEST_F()
183 VersionEdit version_edit; in TEST_F()
358 VersionEdit edit; in TEST_F()
411 VersionEdit edit; in TEST_F()
428 VersionEdit edit; in TEST_F()
468 VersionEdit edit; in TEST_F()
510 VersionEdit addition; in TEST_F()
526 VersionEdit garbage; in TEST_F()
563 VersionEdit edit; in TEST_F()
596 VersionEdit edit; in TEST_F()
[all …]
|
| D | version_set_test.cc | 682 VersionEdit new_db; in PrepareManifest()
900 VersionEdit* e = reinterpret_cast<VersionEdit*>(arg); in SetupTestSyncPoints()
907 VersionEdit* e = reinterpret_cast<VersionEdit*>(arg); in SetupTestSyncPoints()
1344 VersionEdit new_db; in PrepareManifest()
1360 VersionEdit new_cf; in PrepareManifest()
1411 VersionEdit new_db; in PrepareManifest()
1477 VersionEdit new_cf1; in TEST_P()
1525 VersionEdit new_cf; in TEST_P()
1571 VersionEdit new_cf; in TEST_P()
1628 VersionEdit new_cf; in TEST_P()
[all …]
|
| D | version_edit.cc | 135 void VersionEdit::Clear() { in Clear()
165 bool VersionEdit::EncodeTo(std::string* dst) const { in EncodeTo()
322 bool VersionEdit::GetLevel(Slice* input, int* level, const char** /*msg*/) { in GetLevel()
335 const char* VersionEdit::DecodeNewFile4From(Slice* input) { in DecodeNewFile4From()
424 Status VersionEdit::DecodeFrom(const Slice& src) { in DecodeFrom()
678 std::string VersionEdit::DebugString(bool hex_key) const { in DebugString()
773 std::string VersionEdit::DebugJSON(int edit_num, bool hex_key) const { in DebugJSON()
|
| D | version_builder.h | 21 class VersionEdit; variable
37 Status Apply(VersionEdit* edit);
|
| D | import_column_family_job.h | 47 VersionEdit* edit() { return &edit_; } in edit()
67 VersionEdit edit_;
|
| D | flush_job.h | 53 class VersionEdit; variable
156 VersionEdit* edit_;
|
| D | external_sst_file_ingestion_job.h | 116 VersionEdit* edit() { return &edit_; } in edit()
172 VersionEdit edit_;
|
| D | version_set.cc | 4195 VersionEdit& edit, in ApplyOneVersionEditToBuilder()
4383 VersionEdit edit; in ReadAndRecover()
4480 VersionEdit default_cf_edit; in Recover()
4813 VersionEdit edit; in ListColumnFamilies()
4925 VersionEdit ve; in ReduceNumberOfLevels()
5009 VersionEdit edit; in DumpManifest()
5220 VersionEdit edit; in WriteCurrentStateToManifest()
5243 VersionEdit edit; in WriteCurrentStateToManifest()
5829 VersionEdit version_edit; in Recover()
5954 VersionEdit edit; in ReadAndApply()
[all …]
|
| D | memtable.h | 320 VersionEdit* GetEdits() { return &edit_; } in GetEdits()
480 VersionEdit edit_;
|
| D | flush_job_test.cc | 65 VersionEdit new_db; in NewDB()
76 autovector<VersionEdit> new_cfs; in NewDB()
80 VersionEdit new_cf; in NewDB()
|
| D | version_builder.cc | 318 Status CheckConsistencyForDeletes(VersionEdit* /*edit*/, uint64_t number, in CheckConsistencyForDeletes() argument
431 Status Apply(VersionEdit* edit) { in Apply()
758 Status VersionBuilder::Apply(VersionEdit* edit) { return rep_->Apply(edit); } in Apply()
|
| D | memtable_list.cc | 437 autovector<VersionEdit*> edit_list; in TryInstallMemtableFlushResults()
677 autovector<autovector<VersionEdit*>> edit_lists; in InstallMemtableAtomicFlushResults()
681 autovector<VersionEdit*> edits; in InstallMemtableAtomicFlushResults()
|
| D | builder.h | 35 class VersionEdit; variable
|
| D | repair.cc | 150 VersionEdit edit; in AddColumnFamily()
576 VersionEdit edit; in AddTables()
|
| D | version_edit.h | 251 class VersionEdit {
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction.h | 105 VersionEdit* edit() { return &edit_; } in edit()
178 void AddInputDeletions(VersionEdit* edit);
331 VersionEdit edit_;
|
| D | compaction_job.h | 55 class VersionEdit; variable
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_open.cc | 257 VersionEdit new_db; in NewDB()
453 VersionEdit edit; in Recover()
714 std::unordered_map<int, VersionEdit> version_edits; in RecoverLogFiles()
717 VersionEdit edit; in RecoverLogFiles()
966 VersionEdit* edit = &iter->second; in RecoverLogFiles()
1057 VersionEdit* edit = &iter->second; in RecoverLogFiles()
1112 autovector<autovector<VersionEdit*>> edit_lists; in RecoverLogFiles()
1193 MemTable* mem, VersionEdit* edit) { in WriteLevel0TableForRecovery()
|
| D | db_impl_experimental.cc | 66 VersionEdit edit; in PromoteL0()
|
| D | db_impl.cc | 933 VersionEdit dummy_edit; in SetOptions()
2339 VersionEdit edit; in CreateColumnFamilyImpl()
2439 VersionEdit edit; in DropColumnFamilyImpl()
3190 VersionEdit edit; in DeleteFile()
3263 VersionEdit edit; in DeleteFilesInRanges()
4190 autovector<autovector<VersionEdit*>> edit_lists; in IngestExternalFiles()
4200 autovector<VersionEdit*> edit_list; in IngestExternalFiles()
4302 VersionEdit dummy_edit; in CreateColumnFamilyWithImport()
4556 VersionEdit dummy_edit; in ReserveFileNumbersBeforeIngestion()
|
| D | db_impl.h | 75 class VersionEdit; variable
1403 MemTable* mem, VersionEdit* edit);
2125 autovector<VersionEdit*> edit_list,
|