| /rocksdb-6.9/db/ |
| D | file_indexer_test.cc | 56 auto* f = new FileMetaData(); in AddFile() local 68 for (auto* f : files[i]) { in ClearFiles() local 119 for (uint32_t f = 0; f < 3; ++f) { in TEST_F() local 159 for (uint32_t f = 0; f < 3; ++f) { in TEST_F() local 199 for (uint32_t f = 0; f < 3; ++f) { in TEST_F() local 323 for (uint32_t f = 2; f <= 4; ++f) { in TEST_F() local
|
| D | import_column_family_job.cc | 75 for (const auto& f : files_to_import_) { in Prepare() local 87 for (auto& f : files_to_import_) { in Prepare() local 115 for (const auto& f : files_to_import_) { in Prepare() local 149 const auto& f = files_to_import_[i]; in Run() local 173 for (const auto& f : files_to_import_) { in Cleanup() local
|
| D | version_edit.cc | 196 const FileMetaData& f = new_files_[i].second; in EncodeTo() local 338 FileMetaData f; in DecodeNewFile4From() local 432 FileMetaData f; in DecodeFrom() local 720 const FileMetaData& f = new_files_[i].second; in DebugString() local 823 const FileMetaData& f = new_files_[i].second; in DebugJSON() local
|
| D | filename_test.cc | 59 std::string f = cases[i].fname; in TEST_F() local 103 std::string f = errors[i]; in TEST_F() local
|
| D | version_set.cc | 409 FdWithKeyRange* f = nullptr; in GetNextFileInLevelWithKeys() local 541 FdWithKeyRange* f; in GetNextFile() local 2259 for (auto* f : files_[0]) { in EstimateCompactionBytesNeeded() local 2281 for (auto* f : files_[level]) { in EstimateCompactionBytesNeeded() local 2289 for (auto* f : files_[level]) { in EstimateCompactionBytesNeeded() local 2367 for (auto* f : files_[level]) { in ComputeCompactionScore() local 2415 for (auto f : files_[level]) { in ComputeCompactionScore() local 2468 for (auto* f : files_[level]) { in ComputeFilesMarkedForCompaction() local 2526 for (auto f : files_[level]) { in ComputeFilesMarkedForPeriodicCompaction() local 5247 for (const auto& f : in WriteCurrentStateToManifest() local [all …]
|
| D | compacted_db_impl.cc | 29 auto cmp = [&](const FdWithKeyRange& f, const Slice& k) -> bool { in FindFile() 55 const FdWithKeyRange& f = files_.files[FindFile(key)]; in MultiGet() local
|
| D | version_builder.cc | 137 void UnrefFile(FileMetaData* f) { in UnrefFile() 333 FileMetaData* f = base_files[i]; in CheckConsistencyForDeletes() local 463 FileMetaData* f = new FileMetaData(new_file.second); in Apply() local 736 void MaybeAddFile(VersionStorageInfo* vstorage, int level, FileMetaData* f) { in MaybeAddFile()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_experimental.cc | 42 for (auto f : inputs) { in SuggestCompactRange() local 92 auto f = l0_files[i]; in PromoteL0() local 126 for (const auto& f : l0_files) { in PromoteL0() local
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction_picker_fifo.cc | 24 for (const auto& f : files) { in GetTotalFilesSize() local 73 FileMetaData* f = *ritr; in PickTTLCompaction() local 94 for (const auto& f : inputs[0].files) { in PickTTLCompaction() local 176 auto f = *ritr; in PickSizeCompaction() local
|
| D | compaction.cc | 87 for (const auto* f : inputs[i].files) { in GetBoundaryKeys() local 134 const auto* f = inputs[i].files[j]; in PopulateWithAtomicBoundaries() local 371 auto* f = files[level_ptrs->at(lvl)]; in KeyNotExistsBeyondOutputLevel() local 431 for (auto f : input_level.files) { in CalculateTotalInputSize() local
|
| D | compaction_picker_universal.cc | 141 FileMetaData* f; member 730 for (auto* f : vstorage_->LevelFiles(picking_sr.level)) { in PickCompactionToReduceSortedRuns() local 988 FileMetaData* f = picking_sr.file; in PickCompactionToOldest() local 992 for (auto* f : vstorage_->LevelFiles(picking_sr.level)) { in PickCompactionToOldest() local
|
| /rocksdb-6.9/file/ |
| D | random_access_file_reader_test.cc | 47 std::unique_ptr<FSRandomAccessFile> f; in IsDirectIOSupported() local 53 std::unique_ptr<FSWritableFile> f; in Write() local 62 std::unique_ptr<FSRandomAccessFile> f; in Read() local 89 std::string f = "get_alignment"; in GetAlignment() local
|
| /rocksdb-6.9/third-party/folly/folly/synchronization/detail/ |
| D | Spin.h | 28 F f) { in spin_pause_until() 61 F f) { in spin_yield_until()
|
| /rocksdb-6.9/build_tools/ |
| D | amalgamate.py | 49 def expand_include(include_path, f, abs_path, source_out, header_out, include_paths, public_include… argument 59 def process_file(f, abs_path, source_out, header_out, include_paths, public_include_paths): argument
|
| /rocksdb-6.9/utilities/ |
| D | env_mirror.cc | 22 explicit SequentialFileMirror(std::string f) : fname(f) {} in SequentialFileMirror() 66 explicit RandomAccessFileMirror(std::string f) : fname(f) {} in RandomAccessFileMirror() 101 explicit WritableFileMirror(std::string f, const EnvOptions& options) in WritableFileMirror() 195 Status EnvMirror::NewSequentialFile(const std::string& f, in NewSequentialFile() 212 Status EnvMirror::NewRandomAccessFile(const std::string& f, in NewRandomAccessFile() 229 Status EnvMirror::NewWritableFile(const std::string& f, in NewWritableFile()
|
| /rocksdb-6.9/include/rocksdb/utilities/ |
| D | env_mirror.h | 66 Status FileExists(const std::string& f) override { in FileExists() 94 Status DeleteFile(const std::string& f) override { in DeleteFile() 118 Status GetFileSize(const std::string& f, uint64_t* s) override { in GetFileSize() 159 Status LockFile(const std::string& f, FileLock** l) override { in LockFile()
|
| /rocksdb-6.9/db_stress_tool/ |
| D | db_stress_env_wrapper.h | 19 Status DeleteFile(const std::string& f) override { in DeleteFile()
|
| /rocksdb-6.9/env/ |
| D | env_hdfs.cc | 301 HdfsLogger(HdfsWritableFile* f, uint64_t (*gettid)()) in HdfsLogger() 395 HdfsReadableFile* f = new HdfsReadableFile(fileSys_, fname); in NewSequentialFile() local 410 HdfsReadableFile* f = new HdfsReadableFile(fileSys_, fname); in NewRandomAccessFile() local 426 HdfsWritableFile* f = new HdfsWritableFile(fileSys_, fname, options); in NewWritableFile() local 598 HdfsWritableFile* f = new HdfsWritableFile(fileSys_, fname, options); in NewLogger() local
|
| D | composite_env_wrapper.h | 293 Status NewSequentialFile(const std::string& f, in NewSequentialFile() 306 Status NewRandomAccessFile(const std::string& f, in NewRandomAccessFile() 388 Status FileExists(const std::string& f) override { in FileExists() 405 Status DeleteFile(const std::string& f) override { in DeleteFile() 430 Status GetFileSize(const std::string& f, uint64_t* s) override { in GetFileSize() 469 Status LockFile(const std::string& f, FileLock** l) override { in LockFile() 867 IOStatus NewSequentialFile(const std::string& f, in NewSequentialFile() 878 IOStatus NewRandomAccessFile(const std::string& f, in NewRandomAccessFile() 949 IOStatus FileExists(const std::string& f, const IOOptions& /*io_opts*/, in FileExists() 964 IOStatus DeleteFile(const std::string& f, const IOOptions& /*options*/, in DeleteFile() [all …]
|
| /rocksdb-6.9/test_util/ |
| D | fault_injection_test_env.cc | 109 std::unique_ptr<WritableFile>&& f, in TestWritableFile() 165 std::unique_ptr<RandomRWFile>&& f, in TestRandomRWFile() 303 Status FaultInjectionTestEnv::DeleteFile(const std::string& f) { in DeleteFile() 429 void FaultInjectionTestEnv::UntrackFile(const std::string& f) { in UntrackFile()
|
| D | fault_injection_test_fs.cc | 71 std::unique_ptr<FSWritableFile>&& f, in TestFSWritableFile() 143 std::unique_ptr<FSRandomRWFile>&& f, in TestFSRandomRWFile() 292 IOStatus FaultInjectionTestFS::DeleteFile(const std::string& f, in DeleteFile() 421 void FaultInjectionTestFS::UntrackFile(const std::string& f) { in UntrackFile()
|
| D | testutil.h | 591 const std::string& GetContent(const std::string& f) { return files_[f]; } in GetContent() 608 Status NewSequentialFile(const std::string& f, in NewSequentialFile() 623 Status NewWritableFile(const std::string& f, in NewWritableFile() 638 Status FileExists(const std::string& f) override { in FileExists() 648 Status DeleteFile(const std::string& f) override { in DeleteFile() 661 Status GetFileSize(const std::string& f, uint64_t* s) override { in GetFileSize()
|
| /rocksdb-6.9/third-party/folly/folly/ |
| D | ScopeGuard.h | 18 explicit ScopeGuardImpl(F&& f) : f_{std::forward<F>(f)} {} in ScopeGuardImpl()
|
| /rocksdb-6.9/util/ |
| D | defer_test.cc | 25 auto f = [&v]() { in TEST() local
|
| /rocksdb-6.9/utilities/persistent_cache/ |
| D | block_cache_tier.cc | 330 std::unique_ptr<WriteableCacheFile> f( in NewCacheFile() local 372 std::unique_ptr<BlockCacheFile> f(metadata_.Evict()); in Reserve() local
|