Home
last modified time | relevance | path

Searched refs:file_path (Results 1 – 25 of 55) sorted by relevance

123

/rocksdb-6.9/tools/
Dtrace_analyzer_test.cc341 file_path = in TEST_F()
456 file_path = in TEST_F()
479 file_path = in TEST_F()
523 file_path = in TEST_F()
546 file_path = in TEST_F()
592 file_path = in TEST_F()
616 file_path = in TEST_F()
660 file_path = in TEST_F()
667 file_path = in TEST_F()
673 file_path = in TEST_F()
[all …]
Dsst_dump_test.cc136 createSST(opts, file_path); in TEST_F()
144 cleanup(opts, file_path); in TEST_F()
158 createSST(opts, file_path); in TEST_F()
166 cleanup(opts, file_path); in TEST_F()
180 createSST(opts, file_path); in TEST_F()
188 cleanup(opts, file_path); in TEST_F()
202 createSST(opts, file_path); in TEST_F()
210 cleanup(opts, file_path); in TEST_F()
224 createSST(opts, file_path); in TEST_F()
232 cleanup(opts, file_path); in TEST_F()
[all …]
Dsst_dump_tool.cc46 const std::string& file_path, bool verify_checksum, in SstFileDumper() argument
48 : file_name_(file_path), in SstFileDumper()
57 fprintf(stdout, "Process %s\n", file_path.c_str()); in SstFileDumper()
79 Status SstFileDumper::GetTableReader(const std::string& file_path) { in GetTableReader() argument
90 Status s = options_.env->NewRandomAccessFile(file_path, &file, soptions_); in GetTableReader()
92 s = options_.env->GetFileSize(file_path, &file_size); in GetTableReader()
96 file_path)); in GetTableReader()
110 options_.env->NewRandomAccessFile(file_path, &file, soptions_); in GetTableReader()
112 NewLegacyRandomAccessFileWrapper(file), file_path)); in GetTableReader()
/rocksdb-6.9/file/
Ddelete_scheduler.cc65 s = fs_->DeleteFile(file_path, IOOptions(), nullptr); in DeleteFile()
67 sst_file_manager_->OnDeleteFile(file_path); in DeleteFile()
74 s = MarkAsTrash(file_path, &trash_file); in DeleteFile()
79 s = fs_->DeleteFile(file_path, IOOptions(), nullptr); in DeleteFile()
81 sst_file_manager_->OnDeleteFile(file_path); in DeleteFile()
110 return (file_path.size() >= kTrashExtension.size() && in IsTrashFile()
111 file_path.rfind(kTrashExtension) == in IsTrashFile()
152 size_t idx = file_path.rfind("/"); in MarkAsTrash()
158 if (DeleteScheduler::IsTrashFile(file_path)) { in MarkAsTrash()
160 *trash_file = file_path; in MarkAsTrash()
[all …]
Dsst_file_manager_impl.cc62 Status SstFileManagerImpl::OnAddFile(const std::string& file_path, in OnAddFile() argument
68 OnAddFileImpl(file_path, file_size, compaction); in OnAddFile()
74 Status SstFileManagerImpl::OnAddFile(const std::string& file_path, in OnAddFile() argument
77 OnAddFileImpl(file_path, file_size, compaction); in OnAddFile()
85 OnDeleteFileImpl(file_path); in OnDeleteFile()
432 return delete_scheduler_.DeleteFile(file_path, path_to_sync, in ScheduleFileDeletion()
442 auto tracked_file = tracked_files_.find(file_path); in OnAddFileImpl()
457 in_progress_files_.insert(file_path); in OnAddFileImpl()
460 tracked_files_[file_path] = file_size; in OnAddFileImpl()
464 auto tracked_file = tracked_files_.find(file_path); in OnDeleteFileImpl()
[all …]
Dsst_file_manager_impl.h39 Status OnAddFile(const std::string& file_path, bool compaction = false);
43 Status OnAddFile(const std::string& file_path, uint64_t file_size,
47 Status OnDeleteFile(const std::string& file_path);
124 virtual Status ScheduleFileDeletion(const std::string& file_path,
140 void OnAddFileImpl(const std::string& file_path, uint64_t file_size,
143 void OnDeleteFileImpl(const std::string& file_path);
Ddelete_scheduler.h79 static bool IsTrashFile(const std::string& file_path);
87 Status MarkAsTrash(const std::string& file_path, std::string* path_in_trash);
/rocksdb-6.9/db_stress_tool/
Ddb_stress_listener.h28 VerifyFilePath(info.file_path); in OnFlushCompleted()
49 for (const auto& file_path : ci.input_files) { in OnCompactionCompleted() local
50 VerifyFilePath(file_path); in OnCompactionCompleted()
52 for (const auto& file_path : ci.output_files) { in OnCompactionCompleted() local
53 VerifyFilePath(file_path); in OnCompactionCompleted()
68 VerifyFilePath(info.file_path); in OnTableFileCreated()
195 size_t pos = file_path.find_last_of("/"); in VerifyFilePath()
197 VerifyFileName(file_path); in VerifyFilePath()
200 VerifyFileDir(file_path.substr(0, pos)); in VerifyFilePath()
202 VerifyFileName(file_path.substr(pos)); in VerifyFilePath()
[all …]
/rocksdb-6.9/db/
Devent_helpers.cc28 const std::string& file_path, int job_id, TableFileCreationReason reason) { in NotifyTableFileCreationStarted() argument
32 info.file_path = file_path; in NotifyTableFileCreationStarted()
72 const std::string& file_path, int job_id, const FileDescriptor& fd, in LogAndNotifyTableFileCreationFinished() argument
149 info.file_path = file_path; in LogAndNotifyTableFileCreationFinished()
162 (void)file_path; in LogAndNotifyTableFileCreationFinished()
169 const std::string& file_path, const Status& status, in LogAndNotifyTableFileDeletion() argument
190 info.file_path = file_path; in LogAndNotifyTableFileDeletion()
196 (void)file_path; in LogAndNotifyTableFileDeletion()
Dconvenience.cc37 const std::string& file_path) { in VerifySstFileChecksum() argument
38 return VerifySstFileChecksum(options, env_options, ReadOptions(), file_path); in VerifySstFileChecksum()
43 const std::string& file_path) { in VerifySstFileChecksum() argument
49 Status s = ioptions.fs->NewRandomAccessFile(file_path, in VerifySstFileChecksum()
53 s = ioptions.fs->GetFileSize(file_path, IOOptions(), &file_size, nullptr); in VerifySstFileChecksum()
59 new RandomAccessFileReader(std::move(file), file_path)); in VerifySstFileChecksum()
Dwal_manager.cc179 std::string const file_path = archival_dir + "/" + f; in PurgeObsoleteWALFiles() local
182 s = env_->GetFileModificationTime(file_path, &file_m_time); in PurgeObsoleteWALFiles()
185 "Can't get file mod time: %s: %s", file_path.c_str(), in PurgeObsoleteWALFiles()
190 s = DeleteDBFile(&db_options_, file_path, archival_dir, false, in PurgeObsoleteWALFiles()
194 file_path.c_str(), s.ToString().c_str()); in PurgeObsoleteWALFiles()
206 s = env_->GetFileSize(file_path, &file_size); in PurgeObsoleteWALFiles()
209 "Unable to get file size: %s: %s", file_path.c_str(), in PurgeObsoleteWALFiles()
217 s = DeleteDBFile(&db_options_, file_path, archival_dir, false, in PurgeObsoleteWALFiles()
256 std::string const file_path = archived_logs[i]->PathName(); in PurgeObsoleteWALFiles() local
257 s = DeleteDBFile(&db_options_, db_options_.wal_dir + "/" + file_path, in PurgeObsoleteWALFiles()
[all …]
Dexternal_sst_file_test.cc120 *external_file_path = file_path; in GenerateOneExternalFile()
309 ASSERT_EQ(file1_info.file_path, file1); in TEST_F()
332 ASSERT_EQ(file2_info.file_path, file2); in TEST_F()
350 ASSERT_EQ(file3_info.file_path, file3); in TEST_F()
365 ASSERT_EQ(file4_info.file_path, file4); in TEST_F()
379 ASSERT_EQ(file5_info.file_path, file5); in TEST_F()
391 ASSERT_EQ(file6_info.file_path, file6); in TEST_F()
413 ASSERT_EQ(file7_info.file_path, file7); in TEST_F()
928 ASSERT_EQ(file1_info.file_path, file1); in TEST_F()
942 ASSERT_EQ(file2_info.file_path, file2); in TEST_F()
[all …]
Dexternal_sst_file_basic_test.cc54 Status s = sst_file_writer.Open(file_path); in GenerateAndAddExternalFile()
115 s = db_->IngestExternalFile({file_path}, ifo); in GenerateAndAddExternalFile()
170 ASSERT_EQ(file1_info.file_path, file1); in TEST_F()
210 ASSERT_EQ(file1_info.file_path, file1); in TEST_F()
224 ASSERT_EQ(file2_info.file_path, file2); in TEST_F()
238 ASSERT_EQ(file3_info.file_path, file3); in TEST_F()
816 ASSERT_EQ(file_info.file_path, file); in TEST_F()
939 ASSERT_EQ(file8_info.file_path, file8); in TEST_F()
954 ASSERT_EQ(file9_info.file_path, file9); in TEST_F()
1013 Status s = sst_file_writer.Open(file_path); in TEST_P()
[all …]
Djob_context.h124 std::string file_path; member
126 : file_name(std::move(name)), file_path(std::move(path)) {} in CandidateFileInfo()
129 file_path == other.file_path;
Devent_helpers.h26 const std::string& file_path, int job_id, TableFileCreationReason reason);
36 const std::string& file_path, int job_id, const FileDescriptor& fd,
41 uint64_t file_number, const std::string& file_path,
/rocksdb-6.9/java/rocksjni/
Dsst_file_readerjni.cc42 const char *file_path = env->GetStringUTFChars(jfile_path, nullptr); in Java_org_rocksdb_SstFileReader_open() local
43 if (file_path == nullptr) { in Java_org_rocksdb_SstFileReader_open()
49 file_path); in Java_org_rocksdb_SstFileReader_open()
50 env->ReleaseStringUTFChars(jfile_path, file_path); in Java_org_rocksdb_SstFileReader_open()
Dsst_file_writerjni.cc76 const char *file_path = env->GetStringUTFChars(jfile_path, nullptr); in Java_org_rocksdb_SstFileWriter_open() local
77 if (file_path == nullptr) { in Java_org_rocksdb_SstFileWriter_open()
83 file_path); in Java_org_rocksdb_SstFileWriter_open()
84 env->ReleaseStringUTFChars(jfile_path, file_path); in Java_org_rocksdb_SstFileWriter_open()
/rocksdb-6.9/table/
Dsst_file_reader.cc40 Status SstFileReader::Open(const std::string& file_path) { in Open() argument
46 s = r->options.env->GetFileSize(file_path, &file_size); in Open()
48 s = r->options.env->NewRandomAccessFile(file_path, &file, r->soptions); in Open()
52 NewLegacyRandomAccessFileWrapper(file), file_path)); in Open()
Dsst_file_writer.cc180 Status SstFileWriter::Open(const std::string& file_path) { in Open() argument
184 s = r->ioptions.env->NewWritableFile(file_path, &sst_file, r->env_options); in Open()
247 file_path, r->env_options, r->ioptions.env, in Open()
256 r->file_info.file_path = file_path; in Open()
303 r->ioptions.env->DeleteFile(r->file_info.file_path); in Finish()
/rocksdb-6.9/include/rocksdb/
Dsst_file_writer.h32 : file_path(""), in ExternalSstFileInfo()
48 : file_path(_file_path), in ExternalSstFileInfo()
59 std::string file_path; // external sst file path member
102 Status Open(const std::string& file_path);
Dlistener.h42 std::string file_path; member
144 std::string file_path; member
172 std::string file_path; member
Ddb.h1445 ColumnFamilyHandle* column_family, const std::string& file_path,
1452 return IngestExternalFile(column_family, {file_path}, ifo);
1456 const std::string& file_path, bool move_file = false,
1463 return IngestExternalFile(DefaultColumnFamily(), {file_path}, ifo);
1473 external_files.push_back(file_info.file_path);
1488 external_files.push_back(file_info.file_path);
1506 return IngestExternalFile(column_family, {file_info->file_path}, ifo);
1517 return IngestExternalFile(DefaultColumnFamily(), {file_info->file_path},
Dconvenience.h341 const std::string& file_path);
347 const std::string& file_path);
/rocksdb-6.9/tools/advisor/advisor/
Ddb_options_parser.py274 file_path = os.path.join(this_path, file_name)
275 with open(file_path, 'w') as fp:
289 return file_path
/rocksdb-6.9/db/db_impl/
Ddb_impl_files.cc251 return (first.file_path > second.file_path); in CompareCandidateFile()
468 fname = MakeTableFileName(candidate_file.file_path, number); in PurgeObsoleteFiles()
469 dir_to_sync = candidate_file.file_path; in PurgeObsoleteFiles()

123