| /rocksdb-6.9/db/ |
| D | compacted_db_impl.cc | 28 size_t right = files_.num_files - 1; in FindFile()
32 return static_cast<size_t>(std::lower_bound(files_.files, in FindFile()
33 files_.files + right, key, cmp) - files_.files); in FindFile()
42 files_.files[FindFile(key)].fd.table_reader->Get(options, lkey.internal_key(), in Get()
55 const FdWithKeyRange& f = files_.files[FindFile(key)]; in MultiGet()
118 files_ = l0; in Init()
130 files_ = vstorage->LevelFilesBrief(level); in Init()
|
| D | transaction_log_impl.cc | 26 files_(std::move(files)), in TransactionLogIteratorImpl()
34 assert(files_ != nullptr); in TransactionLogIteratorImpl()
95 if (files_->size() <= start_file_index) { in SeekToStartSequence()
99 OpenLogReader(files_->at(static_cast<size_t>(start_file_index)).get()); in SeekToStartSequence()
140 } else if (files_->size() != 1) { in SeekToStartSequence()
186 if (current_file_index_ < files_->size() - 1) { in NextImpl()
188 Status s = OpenLogReader(files_->at(current_file_index_).get()); in NextImpl()
232 if (expected_seq < files_->at(current_file_index_)->StartSequence()) { in UpdateCurrentWriteBatch()
|
| D | version_set.cc | 125 files_(files), in FilePicker()
256 std::vector<FileMetaData*>* files_; member in ROCKSDB_NAMESPACE::__anonc84eced60111::FilePicker
2259 for (auto* f : files_[0]) { in EstimateCompactionBytesNeeded()
2378 if (!files_[i].empty() && !files_[i][0]->being_compacted) { in ComputeCompactionScore()
2461 if (!files_[level].empty()) { in ComputeFilesMarkedForCompaction()
2468 for (auto* f : files_[level]) { in ComputeFilesMarkedForCompaction()
2526 for (auto f : files_[level]) { in ComputeFilesMarkedForPeriodicCompaction()
2664 if (files_[i].size() != 0) { in UpdateNumNonEmptyLevels()
3201 if (!files_[i].empty()) { in CalculateBaseBytes()
3353 for (auto file : files_[l]) { in EstimateLiveDataSize()
[all …]
|
| D | forward_iterator.cc | 42 files_(files), in ForwardLevelIterator()
59 assert(file_index < files_.size()); in SetFileIndex()
67 assert(file_index_ < files_.size()); in Reset()
80 *files_[file_index_], in Reset()
146 if (file_index_ + 1 >= files_.size()) { in Next()
192 const std::vector<FileMetaData*>& files_; member in ROCKSDB_NAMESPACE::ForwardLevelIterator
|
| D | version_set.h | 120 void Reserve(int level, size_t size) { files_[level].reserve(size); } in Reserve()
132 file_indexer_.UpdateIndex(&arena_, num_non_empty_levels_, files_); in GenerateFileIndexer()
275 return static_cast<int>(files_[level].size()); in NumLevelFiles()
283 return files_[level]; in LevelFiles()
462 std::vector<FileMetaData*>* files_; variable
|
| D | version_set_test.cc | 24 std::vector<FileMetaData*> files_; member in ROCKSDB_NAMESPACE::GenerateLevelFilesBriefTest
31 for (size_t i = 0; i < files_.size(); i++) { in ~GenerateLevelFilesBriefTest()
32 delete files_[i]; in ~GenerateLevelFilesBriefTest()
40 files_.size() + 1, 0, 0, in Add()
46 files_.push_back(f); in Add()
51 for (size_t i = 0; i < files_.size(); i++) { in Compare()
52 if (file_level_.files[i].fd.GetNumber() != files_[i]->fd.GetNumber()) { in Compare()
61 DoGenerateLevelFilesBrief(&file_level_, files_, &arena_); in TEST_F()
68 DoGenerateLevelFilesBrief(&file_level_, files_, &arena_); in TEST_F()
78 DoGenerateLevelFilesBrief(&file_level_, files_, &arena_); in TEST_F()
|
| D | transaction_log_impl.h | 82 std::unique_ptr<VectorLogPtr> files_; variable
|
| D | compacted_db_impl.h | 110 LevelFilesBrief files_; variable
|
| /rocksdb-6.9/test_util/ |
| D | testutil.h | 603 assert(files_[file_name] == content); in WriteToNewFile()
611 auto iter = files_.find(f); in NewSequentialFile()
612 if (iter == files_.end()) { in NewSequentialFile()
626 auto iter = files_.find(f); in NewWritableFile()
627 if (iter != files_.end()) { in NewWritableFile()
630 r->reset(new StringSink(&files_[f])); in NewWritableFile()
639 if (files_.find(f) == files_.end()) { in FileExists()
649 files_.erase(f); in DeleteFile()
662 auto iter = files_.find(f); in GetFileSize()
663 if (iter == files_.end()) { in GetFileSize()
[all …]
|
| /rocksdb-6.9/utilities/backupable/ |
| D | backupable_db.cc | 183 uint32_t GetNumberFiles() { return static_cast<uint32_t>(files_.size()); } in GetNumberFiles()
202 return files_.empty(); in Empty()
213 return files_; in GetFiles()
229 for (const auto& file : files_) { in GetInfoString()
247 std::vector<std::shared_ptr<FileInfo>> files_; member in ROCKSDB_NAMESPACE::BackupEngineImpl::BackupMeta
1731 files_.push_back(itr->second); in AddFile()
1738 for (const auto& file : files_) { in Delete()
1741 files_.clear(); in Delete()
1859 files_.reserve(files.size()); in LoadFromFile()
1911 "%" ROCKSDB_PRIszt "\n", files_.size()) >= buf_size) { in StoreToFile()
[all …]
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction_picker_test.cc | 43 std::vector<std::unique_ptr<FileMetaData>> files_; member in ROCKSDB_NAMESPACE::CompactionPickerTest
83 files_.clear(); in DeleteVersionStorage()
103 files_.emplace_back(f); in Add()
|