| /rocksdb-6.9/db/compaction/ |
| D | compaction_picker_test.cc | 168 ASSERT_EQ(1U, compaction->input(0, 0)->fd.GetNumber()); in TEST_F()
169 ASSERT_EQ(2U, compaction->input(0, 1)->fd.GetNumber()); in TEST_F()
181 ASSERT_EQ(66U, compaction->input(0, 0)->fd.GetNumber()); in TEST_F()
200 ASSERT_EQ(66U, compaction->input(0, 0)->fd.GetNumber()); in TEST_F()
201 ASSERT_EQ(6U, compaction->input(1, 0)->fd.GetNumber()); in TEST_F()
202 ASSERT_EQ(7U, compaction->input(1, 1)->fd.GetNumber()); in TEST_F()
230 ASSERT_EQ(7U, compaction->input(0, 0)->fd.GetNumber()); in TEST_F()
277 ASSERT_EQ(1U, compaction->input(0, 0)->fd.GetNumber()); in TEST_F()
278 ASSERT_EQ(2U, compaction->input(0, 1)->fd.GetNumber()); in TEST_F()
301 ASSERT_EQ(1U, compaction->input(0, 0)->fd.GetNumber()); in TEST_F()
[all …]
|
| D | compaction_picker_fifo.cc | 98 cf_name.c_str(), f->fd.GetNumber(), in PickTTLCompaction()
184 cf_name.c_str(), f->fd.GetNumber(), tmp_fsize); in PickSizeCompaction()
|
| D | compaction_job.cc | 695 output.meta.fd.GetNumber(), output.meta.fd.GetPathId()); in Run()
1128 uint64_t output_number = sub_compact->current_output()->meta.fd.GetNumber(); in FinishCompactionOutputFile()
1349 meta->fd.GetNumber(), meta->fd.GetPathId()); in FinishCompactionOutputFile()
1376 meta->fd.GetNumber(), meta->fd.GetPathId()); in FinishCompactionOutputFile()
1573 TableCache::Evict(table_cache_.get(), out.meta.fd.GetNumber()); in CleanupCompaction()
1710 stream << f->fd.GetNumber(); in LogCompaction()
|
| D | compaction_picker_universal.cc | 295 snprintf(out_buf, out_buf_size, "file %" PRIu64, file->fd.GetNumber()); in Dump()
300 file->fd.GetNumber(), file->fd.GetPathId()); in Dump()
315 file->fd.GetNumber(), sorted_run_count, file->fd.GetFileSize(), in DumpSizeInfo()
|
| D | compaction.cc | 351 out_edit->DeleteFile(level(which), inputs_[which][i]->fd.GetNumber()); in AddInputDeletions()
459 files.at(i)->fd.GetNumber(), sztxt); in InputSummary()
|
| D | compaction_picker.cc | 387 auto iter = input_set->find(file->fd.GetNumber()); in GetCompactionInputsFromFileNumbers()
698 if (inputs[i]->fd.GetNumber() < max_file_num_to_ignore) { in CompactRange()
716 if (inputs[i]->fd.GetNumber() < max_file_num_to_ignore) { in CompactRange()
|
| /rocksdb-6.9/db/ |
| D | version_builder.cc | 45 return a->fd.GetNumber() > b->fd.GetNumber(); in NewestFirstBySeqNo()
56 return (a->fd.GetNumber() < b->fd.GetNumber()); in BySmallestKey()
261 NumberToString(f1->fd.GetNumber())); in CheckConsistency()
272 NumberToString(f1->fd.GetNumber()) + " vs. " + in CheckConsistency()
275 NumberToString(f2->fd.GetNumber())); in CheckConsistency()
334 if (f->fd.GetNumber() == number) { in CheckConsistencyForDeletes()
466 assert(levels_[level].added_files.find(f->fd.GetNumber()) == in Apply()
468 levels_[level].deleted_files.erase(f->fd.GetNumber()); in Apply()
469 levels_[level].added_files[f->fd.GetNumber()] = f; in Apply()
471 uint64_t number = new_file.second.fd.GetNumber(); in Apply()
[all …]
|
| D | repair.cc | 441 log, counter, meta.fd.GetNumber(), in ConvertLogToTable()
462 db_options_.db_paths, t.meta.fd.GetNumber(), t.meta.fd.GetPathId()); in ExtractMetaData()
464 FormatFileNumber(t.meta.fd.GetNumber(), t.meta.fd.GetPathId(), in ExtractMetaData()
477 db_options_.db_paths, t->meta.fd.GetNumber(), t->meta.fd.GetPathId()); in ScanTable()
481 t->meta.fd = FileDescriptor(t->meta.fd.GetNumber(), t->meta.fd.GetPathId(), in ScanTable()
497 t->meta.fd.GetNumber()); in ScanTable()
517 t->meta.fd.GetNumber(), props->column_family_name.c_str(), in ScanTable()
539 t->meta.fd.GetNumber(), EscapeString(key).c_str()); in ScanTable()
554 t->meta.fd.GetNumber(), counter, in ScanTable()
585 0, table->meta.fd.GetNumber(), table->meta.fd.GetPathId(), in AddTables()
|
| D | flush_job.cc | 237 cfd_->imm()->RollbackMemtableFlush(mems_, meta_.fd.GetNumber()); in Run()
244 meta_.fd.GetNumber(), &job_context_->memtables_to_free, db_directory_, in Run()
354 meta_.fd.GetNumber()); in WriteLevel0Table()
403 meta_.fd.GetNumber(), meta_.fd.GetFileSize(), in WriteLevel0Table()
423 edit_->AddFile(0 /* level */, meta_.fd.GetNumber(), meta_.fd.GetPathId(), in WriteLevel0Table()
455 const uint64_t file_number = meta_.fd.GetNumber(); in GetFlushJobInfo()
|
| D | table_cache.cc | 94 TableFileName(ioptions_.cf_paths, fd.GetNumber(), fd.GetPathId()); in GetTableReader()
128 uint64_t number = fd.GetNumber(); in EraseHandle()
143 uint64_t number = fd.GetNumber(); in FindTable()
226 if (range_del_agg->AddFile(fd.GetNumber())) { in NewIterator()
286 uint64_t fd_number = fd.GetNumber(); in CreateRowCacheKeyPrefix()
|
| D | import_column_family_job.cc | 92 cfd_->ioptions()->cf_paths, f.fd.GetNumber(), f.fd.GetPathId()); in Prepare()
152 edit_.AddFile(file_metadata.level, f.fd.GetNumber(), f.fd.GetPathId(), in Run()
|
| D | version_set.cc | 1232 TableFileName(ioptions->cf_paths, file_meta->fd.GetNumber(), in GetTableProperties()
1438 const uint64_t file_number = file->fd.GetNumber(); in GetColumnFamilyMetaData()
2701 file_to_order[file->fd.GetNumber()] = in SortFileByOverlappingRatio()
2707 return file_to_order[f1.file->fd.GetNumber()] < in SortFileByOverlappingRatio()
2708 file_to_order[f2.file->fd.GetNumber()]; in SortFileByOverlappingRatio()
3431 AppendNumberTo(&r, files[i]->fd.GetNumber()); in DebugString()
5607 uint64_t number = c->input(input, i)->fd.GetNumber(); in VerifyCompactionFileConsistency()
5611 if (f->fd.GetNumber() == number) { in VerifyCompactionFileConsistency()
5638 if (file->fd.GetNumber() == number) { in GetMetadataForFile()
5667 const uint64_t file_number = file->fd.GetNumber(); in GetLiveFilesMetaData()
[all …]
|
| D | version_edit.cc | 201 PutVarint32Varint64(dst, new_files_[i].first /* level */, f.fd.GetNumber()); in EncodeTo()
724 AppendNumberTo(&r, f.fd.GetNumber()); in DebugString()
824 jw << "FileNumber" << f.fd.GetNumber(); in DebugJSON()
|
| D | db_filesnapshot.cc | 136 ret.push_back(MakeTableFileName("", live_file.GetNumber())); in GetLiveFiles()
|
| D | version_set_test.cc | 52 if (file_level_.files[i].fd.GetNumber() != files_[i]->fd.GetNumber()) { in Compare()
169 AppendNumberTo(&result, inputs[i]->fd.GetNumber()); in GetOverlappingFiles()
1974 if (fmeta->fd.GetNumber() != 107 && fmeta->fd.GetNumber() != 110) { in TEST_F()
2024 if (fmeta->fd.GetNumber() == 100) { in TEST_F()
|
| D | event_helpers.cc | 80 << "file_number" << fd.GetNumber() << "file_size" in LogAndNotifyTableFileCreationFinished()
|
| D | external_sst_file_ingestion_job.cc | 101 TableFileName(cfd_->ioptions()->cf_paths, f.fd.GetNumber(), in Prepare()
259 f.picked_level, f.fd.GetNumber(), f.fd.GetPathId(), f.fd.GetFileSize(), in Run()
|
| D | builder.cc | 103 std::string fname = TableFileName(ioptions.cf_paths, meta->fd.GetNumber(), in BuildTable()
|
| D | version_edit.h | 74 uint64_t GetNumber() const { in GetNumber() function
|
| D | listener_test.cc | 127 return meta.fd.GetNumber() == ci.output_file_infos[i].file_number; in OnCompactionCompleted()
281 return meta.fd.GetNumber() == info.file_number; in OnFlushCompleted()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_experimental.cc | 96 f->fd.GetNumber()); in PromoteL0()
107 prev_f->fd.GetNumber(), f->fd.GetNumber()); in PromoteL0()
127 edit.DeleteFile(0, f->fd.GetNumber()); in PromoteL0()
128 edit.AddFile(target_level, f->fd.GetNumber(), f->fd.GetPathId(), in PromoteL0()
|
| D | db_impl_compaction_flush.cc | 612 const uint64_t file_number = file_meta->fd.GetNumber(); in NotifyOnFlushBegin()
1098 newf.second.fd.GetNumber(), in CompactFilesImpl()
1180 const uint64_t file_number = desc.GetNumber(); in NotifyOnCompactionBegin()
1198 const uint64_t file_number = desc.GetNumber(); in NotifyOnCompactionBegin()
1311 edit.DeleteFile(level, f->fd.GetNumber()); in ReFitLevel()
1312 edit.AddFile(to_level, f->fd.GetNumber(), f->fd.GetPathId(), 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()
3059 const uint64_t file_number = desc.GetNumber(); in BuildCompactionJobInfo()
[all …]
|
| D | db_impl_files.cc | 97 MarkAsGrabbedForPurge(sst_to_del.metadata->fd.GetNumber()); in FindObsoleteFiles()
311 sst_live_map[fd.GetNumber()] = &fd; in PurgeObsoleteFiles()
323 MakeTableFileName(file.metadata->fd.GetNumber()), file.path); in PurgeObsoleteFiles()
|
| D | db_impl_open.cc | 1211 cfd->GetName().c_str(), meta.fd.GetNumber()); in WriteLevel0TableForRecovery()
1259 cfd->GetName().c_str(), meta.fd.GetNumber(), in WriteLevel0TableForRecovery()
1270 edit->AddFile(level, meta.fd.GetNumber(), meta.fd.GetPathId(), in WriteLevel0TableForRecovery()
|
| /rocksdb-6.9/file/ |
| D | sst_file_manager_impl.cc | 105 new_file.second.fd.GetNumber(), in OnCompactionCompletion()
188 TableFileName(cfd->ioptions()->cf_paths, inputs[0][0]->fd.GetNumber(), in EnoughRoomForCompaction()
|