Searched refs:fpath (Results 1 – 7 of 7) sorted by relevance
| /rocksdb-6.9/utilities/ |
| D | env_librados.cc | 854 if (is_prefix(_wal_dir, fpath)) { in _GetIoctx()
910 s = _GetFid(fpath, fid); in NewSequentialFile()
918 result->reset(new LibradosSequentialFile(_GetIoctx(fpath), fid, fpath)); in NewSequentialFile()
953 s = _GetFid(fpath, fid); in NewRandomAccessFile()
961 result->reset(new LibradosRandomAccessFile(_GetIoctx(fpath), fid, fpath)); in NewRandomAccessFile()
1004 s = _GetFid(fpath, fid); in NewWritableFile()
1007 _AddFid(fpath, fid); in NewWritableFile()
1011 new LibradosWritableFile(_GetIoctx(fpath), fid, fpath, this, options)); in NewWritableFile()
1292 s = _GetFid(fpath, fid); in GetFileSize()
1429 s = _GetFid(fpath, fid); in LockFile()
[all …]
|
| /rocksdb-6.9/file/ |
| D | random_access_file_reader_test.cc | 61 std::string fpath = Path(fname); in Read() local
63 ASSERT_OK(fs_->NewRandomAccessFile(fpath, opts, &f, nullptr)); in Read()
64 (*reader).reset(new RandomAccessFileReader(std::move(f), fpath, env_)); in Read()
|
| /rocksdb-6.9/utilities/blob_db/ |
| D | blob_db_impl.cc | 689 std::string fpath(bfile->PathName()); in CreateWriterLocked() local
692 Status s = env_->ReopenWritableFile(fpath, &wfile, env_options_); in CreateWriterLocked()
697 fpath.c_str(), s.ToString().c_str(), in CreateWriterLocked()
698 env_->FileExists(fpath).ToString().c_str()); in CreateWriterLocked()
704 NewLegacyWritableFileWrapper(std::move(wfile)), fpath, env_options_)); in CreateWriterLocked()
709 "Open blob file: %s with offset: %" PRIu64, fpath.c_str(), in CreateWriterLocked()
721 fpath.c_str(), boffset); in CreateWriterLocked()
|
| /rocksdb-6.9/db/ |
| D | version_edit_handler.cc | 540 const std::string fpath = in MaybeCreateVersion() local
542 s = version_set_->VerifyFileMetadata(fpath, meta); in MaybeCreateVersion()
|
| D | column_family_test.cc | 3263 std::string fpath = dbname_ + "/" + logfs[logfs.size() - 2]; in TEST_P() local
3267 ASSERT_OK(env_->GetFileSize(fpath, &fsize)); in TEST_P()
3279 CopyFile(fpath, t_fpath, fsize - 9180); in TEST_P()
3281 ASSERT_OK(env_->DeleteFile(fpath)); in TEST_P()
3282 ASSERT_OK(env_->RenameFile(t_fpath, fpath)); in TEST_P()
|
| D | version_set.h | 1148 Status VerifyFileMetadata(const std::string& fpath,
|
| D | version_set.cc | 5762 Status VersionSet::VerifyFileMetadata(const std::string& fpath, in VerifyFileMetadata() argument
5765 Status status = fs_->GetFileSize(fpath, IOOptions(), &fsize, nullptr); in VerifyFileMetadata()
5768 status = Status::Corruption("File size mismatch: " + fpath); in VerifyFileMetadata()
|