Home
last modified time | relevance | path

Searched refs:file_number (Results 1 – 25 of 39) sorted by relevance

12

/rocksdb-6.9/util/
Dfile_checksum_helper.cc35 uint64_t file_number, std::string* checksum, in SearchOneFileChecksum() argument
41 auto it = checksum_map_.find(file_number); in SearchOneFileChecksum()
52 uint64_t file_number, const std::string& checksum, in InsertOneFileChecksum() argument
54 auto it = checksum_map_.find(file_number); in InsertOneFileChecksum()
57 file_number, std::make_pair(checksum, checksum_func_name))); in InsertOneFileChecksum()
65 Status FileChecksumListImpl::RemoveOneFileChecksum(uint64_t file_number) { in RemoveOneFileChecksum() argument
66 auto it = checksum_map_.find(file_number); in RemoveOneFileChecksum()
Dfile_checksum_helper.h111 Status SearchOneFileChecksum(uint64_t file_number, std::string* checksum,
114 Status InsertOneFileChecksum(uint64_t file_number,
118 Status RemoveOneFileChecksum(uint64_t file_number) override;
/rocksdb-6.9/utilities/blob_db/
Dblob_db_impl.cc281 uint64_t file_number; in GetAllBlobFiles() local
285 file_numbers->insert(file_number); in GetAllBlobFiles()
322 obsolete_file_oss << file_number; in OpenAllBlobFiles()
339 blob_file_oss << file_number; in OpenAllBlobFiles()
341 blob_files_[file_number] = blob_file; in OpenAllBlobFiles()
347 live_imm_oss << file_number; in OpenAllBlobFiles()
483 return lhs.file_number < rhs.file_number; in ProcessCompactionJobInfo()
504 if (input.file_number == output.file_number) { in ProcessCompactionJobInfo()
507 } else if (input.file_number < output.file_number) { in ProcessCompactionJobInfo()
514 assert(output.file_number < input.file_number); in ProcessCompactionJobInfo()
[all …]
Dblob_db_impl_filesnapshot.cc97 const uint64_t file_number = blob_file->BlobFileNumber(); in GetLiveFilesMetaData() local
99 filemetadata.name = BlobFileName("", bdb_options_.blob_dir, file_number); in GetLiveFilesMetaData()
100 filemetadata.file_number = file_number; in GetLiveFilesMetaData()
Dblob_compaction_filter.cc35 blob_index.file_number() < context_.next_file_number && in FilterV2()
36 context_.current_blob_files.count(blob_index.file_number()) == 0) { in FilterV2()
113 if (blob_index.file_number() >= context_gc_.cutoff_file_number) { in PrepareBlobOutput()
187 key, blob_index.file_number(), blob_index.offset(), blob_index.size(), in ReadBlobFromOldFile()
Dblob_db_test.cc47 file_number(_file_number), in BlobIndexVersion()
53 uint64_t file_number = kInvalidBlobFileNumber; member
277 ASSERT_EQ(file_number, expected_version.file_number); in VerifyBaseDBBlobIndex()
809 ASSERT_EQ(1, metadata[0].file_number); in TEST_F()
1499 if (version.file_number > cutoff) { in TEST_F()
1503 version.file_number += kNumBlobFiles + 1; in TEST_F()
1673 live_file.file_number = i; in TEST_F()
1681 live_file.file_number = i; in TEST_F()
1726 info.file_number = 21; in TEST_F()
1754 info.file_number = 22; in TEST_F()
[all …]
/rocksdb-6.9/db/blob/
Dblob_index.h71 uint64_t file_number() const { in file_number() function
141 static void EncodeBlob(std::string* dst, uint64_t file_number, in EncodeBlob() argument
148 PutVarint64(dst, file_number); in EncodeBlob()
155 uint64_t file_number, uint64_t offset, in EncodeBlobTTL() argument
162 PutVarint64(dst, file_number); in EncodeBlobTTL()
/rocksdb-6.9/include/rocksdb/
Dfile_checksum.h84 virtual Status SearchOneFileChecksum(uint64_t file_number,
90 uint64_t file_number, const std::string& checksum,
94 virtual Status RemoveOneFileChecksum(uint64_t file_number) = 0;
Dmetadata.h58 file_number(0), in SstFileMetaData()
78 file_number(_file_number), in SstFileMetaData()
99 uint64_t file_number; member
Dlistener.h174 uint64_t file_number; member
206 uint64_t file_number; member
/rocksdb-6.9/tools/advisor/test/input_files/
DLOG-110 …8276, "cf_name": "default", "job": 3, "event": "table_file_creation", "file_number": 10, "file_siz…
15 …158, "cf_name": "default", "job": 10, "event": "table_file_creation", "file_number": 23, "file_siz…
20 …181, "cf_name": "default", "job": 44, "event": "table_file_creation", "file_number": 84, "file_siz…
24 …_v1 {"time_micros": 1527284061048600, "job": 45, "event": "table_file_deletion", "file_number": 84}
DLOG-010 …8276, "cf_name": "default", "job": 3, "event": "table_file_creation", "file_number": 10, "file_siz…
15 …158, "cf_name": "default", "job": 10, "event": "table_file_creation", "file_number": 23, "file_siz…
20 …181, "cf_name": "default", "job": 44, "event": "table_file_creation", "file_number": 84, "file_siz…
24 …_v1 {"time_micros": 1527284061048600, "job": 45, "event": "table_file_deletion", "file_number": 84}
/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc612 const uint64_t file_number = file_meta->fd.GetNumber(); in NotifyOnFlushBegin() local
615 info.file_number = file_number; in NotifyOnFlushBegin()
1180 const uint64_t file_number = desc.GetNumber(); in NotifyOnCompactionBegin() local
1182 file_number, desc.GetPathId()); in NotifyOnCompactionBegin()
1198 const uint64_t file_number = desc.GetNumber(); in NotifyOnCompactionBegin() local
3059 const uint64_t file_number = desc.GetNumber(); in BuildCompactionJobInfo() local
3077 const uint64_t file_number = desc.GetNumber(); in BuildCompactionJobInfo() local
3144 bool DBImpl::ShouldPurge(uint64_t file_number) const { in ShouldPurge()
3145 return files_grabbed_for_purge_.find(file_number) == in ShouldPurge()
3152 void DBImpl::MarkAsGrabbedForPurge(uint64_t file_number) { in MarkAsGrabbedForPurge() argument
[all …]
/rocksdb-6.9/db/
Dflush_job.cc455 const uint64_t file_number = meta_.fd.GetNumber(); in GetFlushJobInfo() local
457 MakeTableFileName(cfd_->ioptions()->cf_paths[0].path, file_number); in GetFlushJobInfo()
458 info->file_number = file_number; in GetFlushJobInfo()
Dtable_cache.cc43 static Slice GetSliceForFileNumber(const uint64_t* file_number) { in GetSliceForFileNumber() argument
44 return Slice(reinterpret_cast<const char*>(file_number), in GetSliceForFileNumber()
45 sizeof(*file_number)); in GetSliceForFileNumber()
606 void TableCache::Evict(Cache* cache, uint64_t file_number) { in Evict() argument
607 cache->Erase(GetSliceForFileNumber(&file_number)); in Evict()
Devent_helpers.cc168 EventLogger* event_logger, int job_id, uint64_t file_number, in LogAndNotifyTableFileDeletion() argument
177 << "file_number" << file_number; in LogAndNotifyTableFileDeletion()
Dmemtable_list.h259 uint64_t file_number);
266 VersionSet* vset, InstrumentedMutex* mu, uint64_t file_number,
Dlistener_test.cc104 ASSERT_EQ(ci.input_file_infos[i].file_number, in OnCompactionCompleted()
121 ASSERT_EQ(ci.output_file_infos[i].file_number, in OnCompactionCompleted()
127 return meta.fd.GetNumber() == ci.output_file_infos[i].file_number; in OnCompactionCompleted()
266 ASSERT_EQ(TableFileNameToNumber(info.file_path), info.file_number); in OnFlushCompleted()
281 return meta.fd.GetNumber() == info.file_number; in OnFlushCompleted()
Dversion_edit.cc120 if (blob_index.file_number() == kInvalidBlobFileNumber) { in UpdateBoundaries()
125 oldest_blob_file_number > blob_index.file_number()) { in UpdateBoundaries()
126 oldest_blob_file_number = blob_index.file_number(); in UpdateBoundaries()
Drange_del_aggregator.h298 bool AddFile(uint64_t file_number) { in AddFile() argument
299 return files_seen_.insert(file_number).second; in AddFile()
Devent_helpers.h41 uint64_t file_number, const std::string& file_path,
Dmemtable_list_test.cc28 std::atomic<uint64_t> file_number; member in ROCKSDB_NAMESPACE::MemTableListTest
30 MemTableListTest() : db(nullptr), file_number(1) { in MemTableListTest()
116 uint64_t file_num = file_number.fetch_add(1); in Mock_InstallMemtableFlushResults()
172 uint64_t file_num = file_number.fetch_add(1); in Mock_InstallMemtableAtomicFlushResults()
Dversion_set_test.cc133 void Add(int level, uint32_t file_number, const char* smallest, in Add() argument
137 file_number, 0, file_size, GetInternalKey(smallest, 0), in Add()
146 void Add(int level, uint32_t file_number, const InternalKey& smallest, in Add() argument
150 file_number, 0, file_size, smallest, largest, /* smallest_seq */ 0, in Add()
1790 uint64_t file_number; member
1799 : file_number(file_num), in SstInfo()
1811 uint64_t file_num = info.file_number; in CreateDummyTableFiles()
/rocksdb-6.9/db/compaction/
Dcompaction_job_test.cc96 std::string GenerateFileName(uint64_t file_number) { in GenerateFileName() argument
100 meta.fd = FileDescriptor(file_number, 0, 0); in GenerateFileName()
172 blob_index.file_number() == kInvalidBlobFileNumber) { in AddMockFile()
177 oldest_blob_file_number > blob_index.file_number()) { in AddMockFile()
178 oldest_blob_file_number = blob_index.file_number(); in AddMockFile()
183 uint64_t file_number = versions_->NewFileNumber(); in AddMockFile() local
185 env_, GenerateFileName(file_number), std::move(contents))); in AddMockFile()
188 edit.AddFile(level, file_number, 0, 10, smallest_key, largest_key, in AddMockFile()
/rocksdb-6.9/db_stress_tool/
Ddb_stress_listener.h183 uint64_t file_number; in VerifyFileName() local
185 bool result = ParseFileName(file_name, &file_number, &file_type); in VerifyFileName()

12