| /rocksdb-6.9/tools/advisor/advisor/ |
| D | bench_runner.py | 28 file_name = ''
32 file_name = db_path[1:] # to ignore the leading '/' character
35 file_name = file_name.replace(character, '_')
36 if not file_name.endswith('_'):
37 file_name += '_'
38 file_name += 'LOG'
39 return file_name
|
| D | db_log_parser.py | 109 for file_name in glob.glob(self.logs_path_prefix + '*'):
115 if re.search('old', file_name, re.IGNORECASE):
117 with open(file_name, 'r') as db_logs:
|
| D | db_stats_fetcher.py | 98 for file_name in glob.glob(self.logs_file_prefix + '*'):
102 if re.search('old', file_name, re.IGNORECASE):
104 with open(file_name, 'r') as db_logs:
|
| D | db_options_parser.py | 273 file_name = '../temp/OPTIONS_' + str(nonce) + '.tmp'
274 file_path = os.path.join(this_path, file_name)
|
| /rocksdb-6.9/file/ |
| D | delete_scheduler_test.cc | 82 dummy_files_dirs_[dummy_files_dirs_idx] + "/" + file_name; in NewDummyFile()
153 std::string file_name = "file" + ToString(i) + ".data"; in TEST_F() local
154 generated_files.push_back(NewDummyFile(file_name, file_size)); in TEST_F()
260 std::string file_name = "file" + ToString(i) + ".data"; in TEST_F() local
390 std::string file_name = "data_" + ToString(i) + ".data"; in TEST_F() local
432 std::string file_name = "data_" + ToString(i) + ".data"; in TEST_F() local
529 std::string file_name = "data_" + ToString(i) + ".data"; in TEST_F() local
584 std::string file_name = "file" + ToString(i) + ".data"; in TEST_F() local
645 std::string file_name = "file" + ToString(i) + ".data"; in TEST_F() local
649 for (std::string& file_name : generated_files) { in TEST_F()
[all …]
|
| D | writable_file_writer.h | 118 checksum_gen_context.file_name = _file_name; in writable_file_()
131 std::string file_name() const { return file_name_; } in file_name() function
|
| D | sequence_file_reader.h | 57 std::string file_name() { return file_name_; } in file_name() function
|
| /rocksdb-6.9/tools/ |
| D | sst_dump_test.cc | 42 void createSST(const Options& opts, const std::string& file_name) { in createSST() argument
52 ASSERT_OK(env->NewWritableFile(file_name, &file, env_options)); in createSST()
57 NewLegacyWritableFileWrapper(std::move(file)), file_name, EnvOptions())); in createSST()
78 void cleanup(const Options& opts, const std::string& file_name) { in cleanup() argument
80 env->DeleteFile(file_name); in cleanup()
81 std::string outfile_name = file_name.substr(0, file_name.length() - 4); in cleanup()
114 std::string MakeFilePath(const std::string& file_name) const { in MakeFilePath()
116 path.append("/").append(file_name); in MakeFilePath()
|
| D | sst_dump_tool_imp.h | 20 explicit SstFileDumper(const Options& options, const std::string& file_name,
|
| /rocksdb-6.9/utilities/options/ |
| D | options_util.cc | 16 Status LoadOptionsFromFile(const std::string& file_name, Env* env, in LoadOptionsFromFile() argument
23 Status s = parser.Parse(file_name, &fs, ignore_unknown_options, in LoadOptionsFromFile()
57 for (auto& file_name : file_names) { in GetLatestOptionsFileName() local
60 if (ParseFileName(file_name, &time_stamp, &type) && type == kOptionsFile) { in GetLatestOptionsFileName()
63 latest_file_name = file_name; in GetLatestOptionsFileName()
|
| /rocksdb-6.9/table/ |
| D | table_reader_bench.cc | 79 std::string file_name = in TableReaderBenchmark() local
93 env->NewWritableFile(file_name, &file, env_options); in TableReaderBenchmark()
99 NewLegacyWritableFileWrapper(std::move(file)), file_name, env_options)); in TableReaderBenchmark()
134 s = env->NewRandomAccessFile(file_name, &raf, env_options); in TableReaderBenchmark()
140 env->GetFileSize(file_name, &file_size); in TableReaderBenchmark()
143 file_name)); in TableReaderBenchmark()
253 env->DeleteFile(file_name); in TableReaderBenchmark()
|
| D | sst_file_reader_test.cc | 58 void CreateFile(const std::string& file_name, in CreateFile() argument
61 ASSERT_OK(writer.Open(file_name)); in CreateFile()
70 void CheckFile(const std::string& file_name, in CheckFile() argument
75 ASSERT_OK(reader.Open(file_name)); in CheckFile()
|
| D | block_fetcher.cc | 57 file_->file_name() + " offset " + ToString(handle_.offset()) + in CheckBlockChecksum()
63 ToString(value) + " in " + file_->file_name() + " offset " + in CheckBlockChecksum()
249 file_->file_name() + " offset " + in ReadBlockContents()
|
| D | format.cc | 292 file->file_name()); in ReadFooterFromFile()
323 file->file_name()); in ReadFooterFromFile()
335 ToString(footer->table_magic_number()) + " in " + file->file_name()); in ReadFooterFromFile()
|
| /rocksdb-6.9/db/ |
| D | job_context.h | 123 std::string file_name; member
126 : file_name(std::move(name)), file_path(std::move(path)) {} in CandidateFileInfo()
128 return file_name == other.file_name &&
|
| D | external_sst_file_basic_test.cc | 725 std::string file_name = in TEST_F() local
727 ASSERT_OK(sst_file_writer->Open(file_name)); in TEST_F()
739 ASSERT_FALSE(db_->IngestExternalFile({file_name}, ingest_opt).ok()); in TEST_F()
758 std::string file_name = sst_files_dir_ + "verify_checksum_readahead_test.sst"; in TEST_F() local
759 ASSERT_OK(sst_file_writer->Open(file_name)); in TEST_F()
773 ASSERT_OK(db_->IngestExternalFile({file_name}, ingest_opt)); in TEST_F()
786 ASSERT_OK(db_->IngestExternalFile({file_name}, ingest_opt)); in TEST_F()
|
| /rocksdb-6.9/util/ |
| D | log_write_bench.cc | 34 std::string file_name = test::PerThreadDBPath("log_write_benchmark.log"); in RunBenchmark() local
40 env->NewWritableFile(file_name, &file, env_options); in RunBenchmark()
42 writer.reset(new WritableFileWriter(std::move(file), file_name, env_options, in RunBenchmark()
|
| /rocksdb-6.9/options/ |
| D | options_parser.cc | 40 const std::string& file_name, FileSystem* fs) { in PersistRocksDBOptions() argument
49 fs->NewWritableFile(file_name, FileOptions(), &wf, nullptr); in PersistRocksDBOptions()
54 writable.reset(new WritableFileWriter(std::move(wf), file_name, EnvOptions(), in PersistRocksDBOptions()
107 db_opt, cf_names, cf_opts, file_name, fs); in PersistRocksDBOptions()
205 Status RocksDBOptionsParser::Parse(const std::string& file_name, FileSystem* fs, in Parse() argument
211 Status s = fs->NewSequentialFile(file_name, FileOptions(), &seq_file, in Parse()
217 SequentialFileReader sf_reader(std::move(seq_file), file_name, in Parse()
661 const std::string& file_name, FileSystem* fs, in VerifyRocksDBOptionsFromFile() argument
673 parser.Parse(file_name, fs, ignore_unknown_options, file_readahead_size); in VerifyRocksDBOptionsFromFile()
|
| D | options_parser.h | 38 const std::string& file_name, FileSystem* fs);
53 Status Parse(const std::string& file_name, FileSystem* fs,
77 const std::string& file_name, FileSystem* fs,
|
| /rocksdb-6.9/db_stress_tool/ |
| D | db_stress_listener.h | 181 void VerifyFileName(const std::string& file_name) { in VerifyFileName() argument
185 bool result = ParseFileName(file_name, &file_number, &file_type); in VerifyFileName()
189 (void)file_name; in VerifyFileName()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_files.cc | 246 if (first.file_name > second.file_name) { in CompareCandidateFile()
248 } else if (first.file_name < second.file_name) { in CompareCandidateFile()
368 const std::string& fname = candidate_file.file_name; in PurgeObsoleteFiles()
392 const std::string& to_delete = candidate_file.file_name; in PurgeObsoleteFiles()
|
| /rocksdb-6.9/env/ |
| D | io_posix.cc | 49 const std::string& file_name) { in IOErrorMsg() argument
50 if (file_name.empty()) { in IOErrorMsg()
53 return context + ": " + file_name; in IOErrorMsg()
57 IOStatus IOError(const std::string& context, const std::string& file_name, in IOError() argument
61 IOStatus s = IOStatus::NoSpace(IOErrorMsg(context, file_name), in IOError()
69 return IOStatus::PathNotFound(IOErrorMsg(context, file_name), in IOError()
72 return IOStatus::IOError(IOErrorMsg(context, file_name), in IOError()
|
| D | io_posix.h | 39 const std::string& file_name);
41 IOStatus IOError(const std::string& context, const std::string& file_name,
|
| /rocksdb-6.9/include/rocksdb/ |
| D | file_checksum.h | 22 std::string file_name; member
|
| /rocksdb-6.9/tools/block_cache_analyzer/ |
| D | block_cache_trace_analyzer_test.cc | 496 const std::string file_name = test_path_ + "/" + caller + "_" + in TEST_F() local
499 std::ifstream infile(file_name); in TEST_F()
513 ASSERT_OK(env_->DeleteFile(file_name)); in TEST_F()
|