| /rocksdb-6.9/env/ |
| D | mock_env.cc | 26 fn_(fn), in MemFile()
33 MurmurHash(fn.data(), static_cast<int>(fn.size()), 0))), in MemFile()
435 auto* f = file_map_[fn]; in NewSequentialFile()
452 auto* f = file_map_[fn]; in NewRandomAccessFile()
469 auto* f = file_map_[fn]; in NewRandomRWFile()
495 DeleteFileInternal(fn); in NewWritableFile()
499 file_map_[fn] = file; in NewWritableFile()
521 if (filename.size() >= fn.size() + 1 && filename[fn.size()] == '/' && in FileExists()
574 DeleteFileInternal(fn); in DeleteFile()
672 file_map_[fn] = file; in NewLogger()
[all …]
|
| D | env_test.cc | 54 explicit Deleter(void (*fn)(void*)) : fn_(fn) {} in Deleter()
|
| /rocksdb-6.9/tools/block_cache_analyzer/ |
| D | block_cache_pysim.sh | 76 for fn in "$ml_tmp_result_dir"/*
82 if [[ $fn == *"timeline"* ]]; then
83 tmpfn="$fn"
114 if [[ $fn == *"${header}ml-mrc"* ]]; then
115 tmpfn="$fn"
121 tmpfn="$fn"
128 tmpfn="$fn"
142 cat "$fn" >> "$sum_file"
147 for fn in $result_dir/*
149 if [[ $fn == *"_mrc" || $fn == *"_avgmb" || $fn == *"_p95mb" ]]; then
[all …]
|
| /rocksdb-6.9/utilities/persistent_cache/ |
| D | persistent_cache_test.h | 54 std::list<port::Thread> SpawnThreads(const size_t n, const T& fn) { in SpawnThreads() argument
57 port::Thread th(fn); in SpawnThreads()
76 auto fn = std::bind(&PersistentCacheTierTest::InsertImpl, this); in Insert() local
77 auto threads = SpawnThreads(nthreads, fn); in Insert()
90 auto fn = variable
92 auto threads = SpawnThreads(nthreads, fn);
|
| D | hash_table_evictable.h | 80 T* Evict(const std::function<void(T*)>& fn = nullptr) {
101 if (fn) {
102 fn(t);
111 void Clear(void (*fn)(T*)) { in Clear()
119 (*fn)(t); in Clear()
|
| D | block_cache_tier_metadata.cc | 30 auto fn = std::bind(&BlockCacheTierMetadata::RemoveAllKeys, this, _1); in Evict() local
31 return cache_file_index_.Evict(fn); in Evict()
|
| D | hash_table.h | 157 void Clear(void (*fn)(T)) { in Clear()
162 (*fn)(t); in Clear()
|
| D | hash_table_bench.cc | 132 void StartThreads(const size_t n, void (*fn)(void*)) { in StartThreads()
135 env->StartThread(fn, this); in StartThreads()
|
| D | persistent_cache_bench.cc | 261 const std::function<void()>& fn) { in Spawn() argument
263 threads->emplace_back(fn); in Spawn()
|
| /rocksdb-6.9/file/ |
| D | sst_file_manager_impl.cc | 104 auto fn = TableFileName(c->immutable_cf_options()->cf_paths, in OnCompactionCompletion() local
107 if (in_progress_files_.find(fn) != in_progress_files_.end()) { in OnCompactionCompletion()
108 auto tracked_file = tracked_files_.find(fn); in OnCompactionCompletion()
111 in_progress_files_.erase(fn); in OnCompactionCompletion()
187 auto fn = in EnoughRoomForCompaction() local
191 fs_->GetFreeSpace(fn, IOOptions(), &free_space, nullptr); in EnoughRoomForCompaction()
|
| /rocksdb-6.9/util/ |
| D | defer.h | 41 Defer(std::function<void()>&& fn) : fn_(std::move(fn)) {} in Defer() argument
|
| /rocksdb-6.9/utilities/blob_db/ |
| D | blob_file.cc | 28 BlobFile::BlobFile(const BlobDBImpl* p, const std::string& bdir, uint64_t fn, in BlobFile() argument
30 : parent_(p), path_to_dir_(bdir), file_number_(fn), info_log_(info_log) {} in BlobFile()
32 BlobFile::BlobFile(const BlobDBImpl* p, const std::string& bdir, uint64_t fn, in BlobFile() argument
38 file_number_(fn), in BlobFile()
|
| /rocksdb-6.9/utilities/ |
| D | env_librados.cc | 74 void split(const std::string &fn, std::string *dir, std::string *file) { in split() argument
75 LOG_DEBUG("[IN]%s\n", fn.c_str()); in split()
76 int pos = fn.size() - 1; in split()
77 while ('/' == fn[pos]) --pos; in split()
78 size_t fstart = fn.rfind('/', pos); in split()
79 *file = fn.substr(fstart + 1, pos - fstart); in split()
82 while (pos >= 0 && '/' == fn[pos]) --pos; in split()
87 size_t dstart = fn.rfind('/', pos); in split()
88 *dir = fn.substr(dstart + 1, pos - dstart); in split()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_files.cc | 508 for (auto fn : files_grabbed_for_purge_) { in PurgeObsoleteFiles() local
509 if (files_to_del.count(fn) != 0) { in PurgeObsoleteFiles()
510 to_be_removed.emplace_back(fn); in PurgeObsoleteFiles()
513 for (auto fn : to_be_removed) { in PurgeObsoleteFiles() local
514 files_grabbed_for_purge_.erase(fn); in PurgeObsoleteFiles()
|
| D | db_impl_compaction_flush.cc | 1181 auto fn = TableFileName(c->immutable_cf_options()->cf_paths, in NotifyOnCompactionBegin() local
1183 info.input_files.push_back(fn); in NotifyOnCompactionBegin()
1186 if (info.table_properties.count(fn) == 0) { in NotifyOnCompactionBegin()
1188 auto s = current->GetTableProperties(&tp, fmd, &fn); in NotifyOnCompactionBegin()
1190 info.table_properties[fn] = tp; in NotifyOnCompactionBegin()
3060 auto fn = TableFileName(c->immutable_cf_options()->cf_paths, file_number, in BuildCompactionJobInfo() local
3062 compaction_job_info->input_files.push_back(fn); in BuildCompactionJobInfo()
3065 if (compaction_job_info->table_properties.count(fn) == 0) { in BuildCompactionJobInfo()
3067 auto s = current->GetTableProperties(&tp, fmd, &fn); in BuildCompactionJobInfo()
3069 compaction_job_info->table_properties[fn] = tp; in BuildCompactionJobInfo()
|
| D | db_impl.h | 1245 PurgeFileInfo(std::string fn, std::string d, FileType t, uint64_t num, in PurgeFileInfo()
1247 : fname(fn), dir_to_sync(d), type(t), number(num), job_id(jid) {} in PurgeFileInfo()
|
| /rocksdb-6.9/db/ |
| D | db_table_properties_test.cc | 110 std::string fn = md.db_path + md.name; in TestGetPropertiesOfTablesInRange() local
117 EXPECT_GT(props.count(fn), 0); in TestGetPropertiesOfTablesInRange()
121 EXPECT_EQ(props.count(fn), 0); in TestGetPropertiesOfTablesInRange()
|
| D | listener_test.cc | 139 for (auto fn : fl) { in OnCompactionCompleted() local
140 auto it = ci.table_properties.find(fn); in OnCompactionCompleted()
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction_picker.cc | 402 for (auto fn : *input_set) { in GetCompactionInputsFromFileNumbers()
404 message += ToString(fn); in GetCompactionInputsFromFileNumbers()
|
| D | compaction_job.cc | 693 auto fn = in Run() local
696 tp[fn] = output.table_properties; in Run()
|
| /rocksdb-6.9/utilities/backupable/ |
| D | backupable_db_test.cc | 1103 for (auto fn : filenames) { in TEST_F() local
1104 if (fn.compare(0, 7, "OPTIONS") == 0) { in TEST_F()
1105 ASSERT_EQ(name, fn); in TEST_F()
|