Home
last modified time | relevance | path

Searched refs:edit (Results 1 – 25 of 26) sorted by relevance

12

/rocksdb-6.9/db/
Dversion_edit_test.cc34 VersionEdit edit; in TEST_F() local
55 VersionEdit edit; in TEST_F() local
110 VersionEdit edit; in TEST_F() local
162 VersionEdit edit; in TEST_F() local
193 VersionEdit edit; in TEST_F() local
203 VersionEdit edit; in TEST_F() local
209 edit.Clear(); in TEST_F()
216 VersionEdit edit; in TEST_F() local
220 edit.Clear(); in TEST_F()
226 VersionEdit edit; in TEST_F() local
[all …]
Dversion_edit_handler.cc36 VersionEdit edit; in Iterate() local
37 s = edit.DecodeFrom(record); in Iterate()
41 if (edit.has_db_id_) { in Iterate()
52 if (edit.is_in_atomic_group_) { in Iterate()
203 edit.column_family_); in OnNonCfOperation()
319 VersionEdit edit; in CheckIterationResult() local
356 const VersionEdit& edit) { in DestroyCfAndCleanup() argument
425 if (edit.has_db_id_) { in ExtractInfoFromVersionEdit()
428 if (edit.has_log_number_) { in ExtractInfoFromVersionEdit()
439 if (edit.has_comparator_ && in ExtractInfoFromVersionEdit()
[all …]
Dversion_edit_handler.h50 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 …]
Dversion_builder_test.cc358 VersionEdit edit; in TEST_F() local
369 ASSERT_OK(builder.Apply(&edit)); in TEST_F()
411 VersionEdit edit; in TEST_F() local
428 VersionEdit edit; in TEST_F() local
439 ASSERT_OK(builder.Apply(&edit)); in TEST_F()
468 VersionEdit edit; in TEST_F() local
476 ASSERT_OK(builder.Apply(&edit)); in TEST_F()
563 VersionEdit edit; in TEST_F() local
596 VersionEdit edit; in TEST_F() local
615 ASSERT_OK(builder.Apply(&edit)); in TEST_F()
[all …]
Dversion_set.cc3495 assert(edit); in AddEdit()
4195 VersionEdit& edit, in ApplyOneVersionEditToBuilder() argument
4231 {edit.column_family_, edit.column_family_name_}); in ApplyOneVersionEditToBuilder()
4383 VersionEdit edit; in ReadAndRecover() local
4813 VersionEdit edit; in ListColumnFamilies() local
4825 {edit.column_family_, edit.column_family_name_}); in ListColumnFamilies()
5009 VersionEdit edit; in DumpManifest() local
5027 comparators.insert({edit.column_family_, edit.comparator_}); in DumpManifest()
5220 VersionEdit edit; in WriteCurrentStateToManifest() local
5243 VersionEdit edit; in WriteCurrentStateToManifest() local
[all …]
Drepair.cc150 VersionEdit edit; in AddColumnFamily() local
151 edit.SetComparatorName(opts.comparator->Name()); in AddColumnFamily()
152 edit.SetLogNumber(0); in AddColumnFamily()
153 edit.SetColumnFamily(cf_id); in AddColumnFamily()
156 edit.AddColumnFamily(cf_name); in AddColumnFamily()
576 VersionEdit edit; in AddTables() local
577 edit.SetComparatorName(cfd->user_comparator()->Name()); in AddTables()
578 edit.SetLogNumber(0); in AddTables()
579 edit.SetNextFile(next_file_number_); in AddTables()
580 edit.SetColumnFamily(cfd->GetID()); in AddTables()
[all …]
Dversion_builder.cc431 Status Apply(VersionEdit* edit) { in Apply() argument
438 const auto& del = edit->GetDeletedFiles(); in Apply()
444 CheckConsistencyForDeletes(edit, number, level); in Apply()
460 for (const auto& new_file : edit->GetNewFiles()) { in Apply()
483 for (const auto& blob_file_addition : edit->GetBlobFileAdditions()) { in Apply()
491 for (const auto& blob_file_garbage : edit->GetBlobFileGarbages()) { in Apply()
758 Status VersionBuilder::Apply(VersionEdit* edit) { return rep_->Apply(edit); } in Apply() argument
Dversion_set.h794 Status AddEdit(VersionEdit* edit);
833 const MutableCFOptions& mutable_cf_options, VersionEdit* edit,
843 edit_list.emplace_back(edit);
1124 const VersionEdit* edit);
1137 VersionEdit& edit,
1212 void LogAndApplyCFHelper(VersionEdit* edit);
1214 VersionEdit* edit, InstrumentedMutex* mu);
1253 VersionEdit& edit, std::unordered_set<ColumnFamilyData*>* cfds_changed,
Dversion_set_test.cc1778 VersionEdit edit; in PrepareManifest() local
1779 edit.SetNextFile(7); in PrepareManifest()
1780 edit.SetLastSequence(seq); in PrepareManifest()
1782 ASSERT_TRUE(edit.EncodeTo(&record)); in PrepareManifest()
1849 VersionEdit edit; in WriteFileAdditionAndDeletionToManifest() local
1850 edit.SetColumnFamily(cf); in WriteFileAdditionAndDeletionToManifest()
1853 edit.AddFile(level, elem.second); in WriteFileAdditionAndDeletionToManifest()
1857 edit.DeleteFile(level, elem.second); in WriteFileAdditionAndDeletionToManifest()
1859 edit.SetLastSequence(last_seqno_); in WriteFileAdditionAndDeletionToManifest()
1863 ASSERT_TRUE(edit.EncodeTo(&record)); in WriteFileAdditionAndDeletionToManifest()
Dversion_builder.h37 Status Apply(VersionEdit* edit);
Dimport_column_family_job.h47 VersionEdit* edit() { return &edit_; } in edit() function
Dexternal_sst_file_ingestion_job.h116 VersionEdit* edit() { return &edit_; } in edit() function
/rocksdb-6.9/db/db_impl/
Ddb_impl_experimental.cc66 VersionEdit edit; in PromoteL0() local
125 edit.SetColumnFamily(cfd->GetID()); in PromoteL0()
127 edit.DeleteFile(0, f->fd.GetNumber()); in PromoteL0()
128 edit.AddFile(target_level, f->fd.GetNumber(), f->fd.GetPathId(), in PromoteL0()
137 &edit, &mutex_, directories_.GetDbDir()); in PromoteL0()
Ddb_impl_open.cc453 VersionEdit edit; in Recover() local
454 edit.SetDBId(db_id_); in Recover()
459 mutable_cf_options, &edit, &mutex_, nullptr, in Recover()
717 VersionEdit edit; in RecoverLogFiles() local
718 edit.SetColumnFamily(cfd->GetID()); in RecoverLogFiles()
719 version_edits.insert({cfd->GetID(), edit}); in RecoverLogFiles()
966 VersionEdit* edit = &iter->second; in RecoverLogFiles() local
1057 VersionEdit* edit = &iter->second; in RecoverLogFiles() local
1065 assert(edit->NumEntries() == 0); in RecoverLogFiles()
1100 edit->SetLogNumber(max_log_number + 1); in RecoverLogFiles()
[all …]
Ddb_impl.cc2339 VersionEdit edit; in CreateColumnFamilyImpl() local
2342 edit.SetColumnFamily(new_id); in CreateColumnFamilyImpl()
2343 edit.SetLogNumber(logfile_number_); in CreateColumnFamilyImpl()
2439 VersionEdit edit; in DropColumnFamilyImpl() local
2440 edit.DropColumnFamily(); in DropColumnFamilyImpl()
2441 edit.SetColumnFamily(cfd->GetID()); in DropColumnFamilyImpl()
3190 VersionEdit edit; in DeleteFile() local
3235 edit.SetColumnFamily(cfd->GetID()); in DeleteFile()
3236 edit.DeleteFile(level, number); in DeleteFile()
3263 VersionEdit edit; in DeleteFilesInRanges() local
[all …]
Ddb_impl_compaction_flush.cc1095 for (const auto& newf : c->edit()->GetNewFiles()) { in CompactFilesImpl()
1195 for (const auto& newf : c->edit()->GetNewFiles()) { in NotifyOnCompactionBegin()
1308 VersionEdit edit; in ReFitLevel() local
1309 edit.SetColumnFamily(cfd->GetID()); in ReFitLevel()
1311 edit.DeleteFile(level, f->fd.GetNumber()); in ReFitLevel()
1312 edit.AddFile(to_level, f->fd.GetNumber(), f->fd.GetPathId(), in ReFitLevel()
1321 edit.DebugString().data()); in ReFitLevel()
2689 c->edit()->DeleteFile(c->level(), f->fd.GetNumber()); in BackgroundCompaction()
2730 c->edit()->DeleteFile(c->level(l), f->fd.GetNumber()); in BackgroundCompaction()
2731 c->edit()->AddFile(c->output_level(), f->fd.GetNumber(), in BackgroundCompaction()
[all …]
/rocksdb-6.9/docs/_sass/
D_buttons.scss36 .edit-page-link {
45 .edit-page-link:hover {
/rocksdb-6.9/docs/
DCONTRIBUTING.md68 To modify a blog post, edit the appopriate markdown file in `./_posts/`.
82 To modify docs, edit the appropriate markdown file in `./_docs/`.
98 To modify a top-level page, edit the appropriate markdown file in `./top-level/`
/rocksdb-6.9/db/compaction/
Dcompaction.h105 VersionEdit* edit() { return &edit_; } in edit() function
178 void AddInputDeletions(VersionEdit* edit);
Dcompaction_job_test.cc187 VersionEdit edit; in AddMockFile() local
188 edit.AddFile(level, file_number, 0, 10, smallest_key, largest_key, in AddMockFile()
195 mutable_cf_options_, &edit, &mutex_); in AddMockFile()
Dcompaction_job.cc1438 compaction->AddInputDeletions(compact_->compaction->edit()); in InstallCompactionResults()
1442 compaction->edit()->AddFile(compaction->output_level(), out.meta); in InstallCompactionResults()
1446 mutable_cf_options, compaction->edit(), in InstallCompactionResults()
/rocksdb-6.9/
DCODE_OF_CONDUCT.md40 Project maintainers have the right and responsibility to remove, edit, or
DCMakeCache.txt4 # You can edit this file to change values found and used by cmake.
6 # If you do want to change a value, simply edit, save, and exit the editor.
519 //Path to cache edit program executable.
/rocksdb-6.9/third-party/gtest-1.8.1/fused-src/gtest/
Dgtest-all.cc2635 void PushLine(char edit, const char* line) { in PushLine() argument
2636 switch (edit) { in PushLine()
2739 EditType edit = edits[edit_i]; in CreateUnifiedDiff() local
2741 n_suffix = edit == kMatch ? n_suffix + 1 : 0; in CreateUnifiedDiff()
2743 if (edit == kMatch || edit == kRemove || edit == kReplace) { in CreateUnifiedDiff()
2744 hunk.PushLine(edit == kMatch ? ' ' : '-', left[l_i].c_str()); in CreateUnifiedDiff()
2746 if (edit == kAdd || edit == kReplace) { in CreateUnifiedDiff()
2751 l_i += edit != kAdd; in CreateUnifiedDiff()
2752 r_i += edit != kRemove; in CreateUnifiedDiff()
/rocksdb-6.9/file/
Dsst_file_manager_impl.cc102 auto new_files = c->edit()->GetNewFiles(); in OnCompactionCompletion()

12