| /rocksdb-6.9/table/ |
| D | sst_file_writer.cc | 50 ExternalSstFileInfo file_info; member
67 if (file_info.num_entries == 0) { in Add()
98 file_info.num_entries++; in Add()
135 file_info.num_range_del_entries++; in DeleteRange()
169 rep_->file_info.file_size = 0; in SstFileWriter()
256 r->file_info.file_path = file_path; in Open()
257 r->file_info.version = 2; in Open()
287 if (r->file_info.num_entries == 0 && in Finish()
306 if (file_info != nullptr) { in Finish()
307 *file_info = r->file_info; in Finish()
[all …]
|
| /rocksdb-6.9/db/ |
| D | db_info_dumper.cc | 32 std::string file_info, wal_info; in DumpDBFileSummary() local
66 file_info.append(file).append(" "); in DumpDBFileSummary()
87 file_info.append(file).append(" "); in DumpDBFileSummary()
94 db_path.path.c_str(), file_num, file_info.c_str()); in DumpDBFileSummary()
96 file_info.clear(); in DumpDBFileSummary()
|
| D | external_sst_file_basic_test.cc | 814 ExternalSstFileInfo file_info; in TEST_F() local
815 ASSERT_OK(sst_file_writer.Finish(&file_info)); in TEST_F()
816 ASSERT_EQ(file_info.file_path, file); in TEST_F()
817 ASSERT_EQ(file_info.num_entries, 0); in TEST_F()
818 ASSERT_EQ(file_info.smallest_key, ""); in TEST_F()
819 ASSERT_EQ(file_info.largest_key, ""); in TEST_F()
820 ASSERT_EQ(file_info.num_range_del_entries, 1); in TEST_F()
821 ASSERT_EQ(file_info.smallest_range_del_key, Key(0)); in TEST_F()
822 ASSERT_EQ(file_info.largest_range_del_key, Key(30)); in TEST_F()
|
| D | plain_table_db_test.cc | 55 std::unique_ptr<PlainTableReaderFileInfo> file_info( in TEST_F() local
60 PlainTableFileReader reader(file_info.get()); in TEST_F()
88 PlainTableFileReader reader(file_info.get()); in TEST_F()
|
| D | external_sst_file_test.cc | 1167 ExternalSstFileInfo file_info; in TEST_F() local
1168 s = sst_file_writer.Finish(&file_info); in TEST_F()
1600 ExternalSstFileInfo file_info; in TEST_F() local
1601 ASSERT_OK(sst_file_writer.Finish(&file_info)); in TEST_F()
|
| /rocksdb-6.9/utilities/backupable/ |
| D | backupable_db.cc | 1195 for (const auto& file_info : backup->GetFiles()) { in RestoreDBFromBackup() local
1196 const std::string &file = file_info->filename; in RestoreDBFromBackup()
1231 file_info->checksum_value); in RestoreDBFromBackup()
1283 for (const auto& file_info : backup->GetFiles()) { in VerifyBackup() local
1710 std::shared_ptr<FileInfo> file_info) { in AddFile() argument
1713 auto ret = file_infos_->insert({file_info->filename, file_info}); in AddFile()
1730 size_ += file_info->size; in AddFile()
1819 if (file_info) { in LoadFromFile()
1820 size = file_info->size; in LoadFromFile()
1860 for (const auto& file_info : files) { in LoadFromFile() local
[all …]
|
| /rocksdb-6.9/table/plain/ |
| D | plain_table_key_coding.h | 114 const PlainTableReaderFileInfo* file_info() { return file_info_; } in file_info() function
139 explicit PlainTableKeyDecoder(const PlainTableReaderFileInfo* file_info, in PlainTableKeyDecoder() argument
143 : file_reader_(file_info), in PlainTableKeyDecoder()
|
| D | plain_table_key_coding.cc | 320 if (!file_reader_.file_info()->is_mmap_mode) { in NextPlainEncodingKey()
371 if (!file_reader_.file_info()->is_mmap_mode || in NextPrefixEncodingKey()
378 if (!file_reader_.file_info()->is_mmap_mode) { in NextPrefixEncodingKey()
418 if (!file_reader_.file_info()->is_mmap_mode) { in NextPrefixEncodingKey()
|
| /rocksdb-6.9/include/rocksdb/ |
| D | db.h | 1472 for (const ExternalSstFileInfo& file_info : file_info_list) { variable
1473 external_files.push_back(file_info.file_path);
1487 for (const ExternalSstFileInfo& file_info : file_info_list) { variable
1488 external_files.push_back(file_info.file_path);
1499 ColumnFamilyHandle* column_family, const ExternalSstFileInfo* file_info,
1506 return IngestExternalFile(column_family, {file_info->file_path}, ifo);
1510 const ExternalSstFileInfo* file_info, bool move_file = false,
1517 return IngestExternalFile(DefaultColumnFamily(), {file_info->file_path},
|
| D | sst_file_writer.h | 127 Status Finish(ExternalSstFileInfo* file_info = nullptr);
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_compaction_flush.cc | 2136 PurgeFileInfo file_info(fname, dir_to_sync, type, number, job_id); in SchedulePendingPurge() local
2137 purge_files_.insert({{number, std::move(file_info)}}); in SchedulePendingPurge()
|