Home
last modified time | relevance | path

Searched refs:fname (Results 1 – 25 of 81) sorted by relevance

1234

/rocksdb-6.9/env/
Dfs_posix.cc154 return IOStatus::IOError(fname, in NewSequentialFile()
192 fname, file, fd, GetLogicalBlockSizeForReadIfNeeded(options, fname, fd), in NewSequentialFile()
208 return IOStatus::IOError(fname, in NewRandomAccessFile()
253 fname, fd, GetLogicalBlockSizeForReadIfNeeded(options, fname, fd), in NewRandomAccessFile()
341 fname, fd, GetLogicalBlockSizeForWriteIfNeeded(options, fname, fd), in OpenWritableFile()
447 fname, fd, GetLogicalBlockSizeForWriteIfNeeded(options, fname, fd), in ReuseWritableFile()
487 const std::string& fname, in NewMemoryMappedFileBuffer() argument
554 f = fopen(fname.c_str(), in NewLogger()
795 locked_files.erase(fname); in LockFile()
802 my_lock->filename = fname; in LockFile()
[all …]
Dmock_env.h38 Status NewSequentialFile(const std::string& fname,
42 Status NewRandomAccessFile(const std::string& fname,
46 Status NewRandomRWFile(const std::string& fname,
50 Status ReuseWritableFile(const std::string& fname,
55 Status NewWritableFile(const std::string& fname,
62 Status FileExists(const std::string& fname) override;
67 void DeleteFileInternal(const std::string& fname);
69 Status DeleteFile(const std::string& fname) override;
81 Status GetFileModificationTime(const std::string& fname,
88 Status NewLogger(const std::string& fname,
[all …]
Denv_hdfs.cc196 filename_(fname), in HdfsWritableFile()
399 return IOError(fname, errno); in NewSequentialFile()
414 return IOError(fname, errno); in NewRandomAccessFile()
430 return IOError(fname, errno); in NewWritableFile()
465 int value = hdfsExists(fileSys_, fname.c_str()); in FileExists()
516 if (hdfsDelete(fileSys_, fname.c_str(), 1) == 0) { in DeleteFile()
519 return IOError(fname, errno); in DeleteFile()
556 return IOError(fname, errno); in GetFileSize()
567 return IOError(fname, errno); in GetFileModificationTime()
591 Status HdfsEnv::NewLogger(const std::string& fname, in NewLogger() argument
[all …]
Dmock_env.cc307 explicit MockEnvFileLock(const std::string& fname) : fname_(fname) {} in MockEnvFileLock() argument
429 auto fn = NormalizePath(fname); in NewSequentialFile()
446 auto fn = NormalizePath(fname); in NewRandomAccessFile()
463 auto fn = NormalizePath(fname); in NewRandomRWFile()
492 auto fn = NormalizePath(fname); in NewWritableFile()
512 auto fn = NormalizePath(fname); in FileExists()
559 assert(fname == NormalizePath(fname)); in DeleteFileInternal()
563 file_map_.erase(fname); in DeleteFileInternal()
568 auto fn = NormalizePath(fname); in DeleteFile()
579 auto fn = NormalizePath(fname); in Truncate()
[all …]
Denv_chroot.cc67 Status NewSequentialFile(const std::string& fname, in NewSequentialFile() argument
78 Status NewRandomAccessFile(const std::string& fname, in NewRandomAccessFile() argument
89 Status NewWritableFile(const std::string& fname, in NewWritableFile() argument
100 Status ReuseWritableFile(const std::string& fname, in ReuseWritableFile() argument
117 Status NewRandomRWFile(const std::string& fname, in NewRandomRWFile() argument
137 Status FileExists(const std::string& fname) override { in FileExists() argument
164 Status DeleteFile(const std::string& fname) override { in DeleteFile() argument
165 auto status_and_enc_path = EncodePath(fname); in DeleteFile()
197 auto status_and_enc_path = EncodePath(fname); in GetFileSize()
206 auto status_and_enc_path = EncodePath(fname); in GetFileModificationTime()
[all …]
Denv_encryption.cc383 Status NewSequentialFile(const std::string& fname, in NewSequentialFile() argument
392 auto status = EnvWrapper::NewSequentialFile(fname, &underlying, options); in NewSequentialFile()
421 Status NewRandomAccessFile(const std::string& fname, in NewRandomAccessFile() argument
459 Status NewWritableFile(const std::string& fname, in NewWritableFile() argument
506 Status ReopenWritableFile(const std::string& fname, in ReopenWritableFile() argument
547 Status ReuseWritableFile(const std::string& fname, in ReuseWritableFile() argument
593 Status NewRandomRWFile(const std::string& fname, in NewRandomRWFile() argument
601 bool isNewFile = !FileExists(fname).ok(); in NewRandomRWFile()
671 auto status = EnvWrapper::GetFileSize(fname, file_size); in GetFileSize()
897 const std::string& fname, const EnvOptions& options, Slice& prefix, in CreateCipherStream() argument
[all …]
Dfile_system.cc29 IOStatus FileSystem::ReuseWritableFile(const std::string& fname, in ReuseWritableFile() argument
34 IOStatus s = RenameFile(old_fname, fname, opts.io_options, dbg); in ReuseWritableFile()
38 return NewWritableFile(fname, opts, result, dbg); in ReuseWritableFile()
87 const std::string& fname, bool should_sync) { in WriteStringToFile() argument
90 IOStatus s = fs->NewWritableFile(fname, soptions, &file, nullptr); in WriteStringToFile()
99 fs->DeleteFile(fname, IOOptions(), nullptr); in WriteStringToFile()
104 IOStatus ReadFileToString(FileSystem* fs, const std::string& fname, in ReadFileToString() argument
110 fs->NewSequentialFile(fname, soptions, &file, nullptr)); in ReadFileToString()
Dcomposite_env_wrapper.h331 Status ReopenWritableFile(const std::string& fname, in ReopenWritableFile() argument
344 Status ReuseWritableFile(const std::string& fname, in ReuseWritableFile() argument
358 Status NewRandomRWFile(const std::string& fname, in NewRandomRWFile() argument
372 const std::string& fname, in NewMemoryMappedFileBuffer() argument
436 Status GetFileModificationTime(const std::string& fname, in GetFileModificationTime() argument
488 Status NewLogger(const std::string& fname, in NewLogger() argument
899 IOStatus ReopenWritableFile(const std::string& fname, in ReopenWritableFile() argument
910 IOStatus ReuseWritableFile(const std::string& fname, in ReuseWritableFile() argument
922 IOStatus NewRandomRWFile(const std::string& fname, in NewRandomRWFile() argument
934 const std::string& fname, in NewMemoryMappedFileBuffer() argument
[all …]
/rocksdb-6.9/db/
Dfilename_test.cc33 const char* fname; in TEST_F() member
59 std::string f = cases[i].fname; in TEST_F()
127 std::string fname; in TEST_F() local
129 fname = CurrentFileName("foo"); in TEST_F()
130 ASSERT_EQ("foo/", std::string(fname.data(), 4)); in TEST_F()
135 fname = LockFileName("foo"); in TEST_F()
141 fname = LogFileName("foo", 192); in TEST_F()
150 ASSERT_EQ(fname, fname1); in TEST_F()
156 fname = DescriptorFileName("bar", 100); in TEST_F()
162 fname = TempFileName("tmp", 999); in TEST_F()
[all …]
Dwal_manager.cc40 auto s = env_->DeleteFile(db_options_.wal_dir + "/" + fname); in DeleteFile()
275 Status s = env_->RenameFile(fname, archived_log_name); in ArchiveWALFile()
279 fname.c_str(), archived_log_name.c_str(), in ArchiveWALFile()
390 std::string fname = LogFileName(db_options_.wal_dir, number); in ReadFirstRecord() local
391 s = ReadFirstLine(fname, number, sequence); in ReadFirstRecord()
392 if (!s.ok() && env_->FileExists(fname).ok()) { in ReadFirstRecord()
446 Status WalManager::ReadFirstLine(const std::string& fname, in ReadFirstLine() argument
452 const char* fname; in ReadFirstLine() member
468 Status status = fs_->NewSequentialFile(fname, in ReadFirstLine()
472 new SequentialFileReader(std::move(file), fname)); in ReadFirstLine()
[all …]
/rocksdb-6.9/port/win/
Denv_win.cc163 RX_FN(fname).c_str(), GENERIC_READ, in NewSequentialFile()
219 s = GetFileSize(fname, &fileSize); in NewRandomAccessFile()
316 RX_FN(fname).c_str(), in OpenWritableFile()
384 RX_CreateFile(RX_FN(fname).c_str(), in NewRandomRWFile()
410 const std::string & fname, in NewMemoryMappedFileBuffer() argument
438 s = GetFileSize(fname, &fileSize); in NewMemoryMappedFileBuffer()
452 + fname); in NewMemoryMappedFileBuffer()
750 RX_FN(fname).c_str(), 0, in NumFileLinks()
1316 return winenv_io_.DeleteFile(fname); in DeleteFile()
1358 const std::string& fname, in NewMemoryMappedFileBuffer() argument
[all …]
Denv_win.h89 virtual Status DeleteFile(const std::string& fname);
115 const std::string& fname,
121 virtual Status FileExists(const std::string& fname);
155 virtual Status NewLogger(const std::string& fname,
218 Status NewSequentialFile(const std::string& fname,
226 Status NewWritableFile(const std::string& fname,
237 Status ReopenWritableFile(const std::string& fname,
242 Status NewRandomRWFile(const std::string& fname,
247 const std::string& fname,
264 Status GetFileSize(const std::string& fname,
[all …]
/rocksdb-6.9/utilities/
Denv_timed.cc20 Status NewSequentialFile(const std::string& fname, in NewSequentialFile() argument
27 Status NewRandomAccessFile(const std::string& fname, in NewRandomAccessFile() argument
34 Status NewWritableFile(const std::string& fname, in NewWritableFile() argument
41 Status ReuseWritableFile(const std::string& fname, in ReuseWritableFile() argument
49 Status NewRandomRWFile(const std::string& fname, in NewRandomRWFile() argument
64 return EnvWrapper::FileExists(fname); in FileExists()
81 return EnvWrapper::DeleteFile(fname); in DeleteFile()
101 return EnvWrapper::GetFileSize(fname, file_size); in GetFileSize()
122 return EnvWrapper::LockFile(fname, lock); in LockFile()
130 Status NewLogger(const std::string& fname, in NewLogger() argument
[all …]
Denv_librados.cc725 const std::string &fname, in _GetFid() argument
729 keys.insert(fname); in _GetFid()
735 fid.assign(kvs[fname].c_str(), kvs[fname].length()); in _GetFid()
784 const std::string& fname, in _AddFid() argument
789 kvs[fname] = value; in _AddFid()
834 keys.insert(fname); in _DelFid()
893 const std::string& fname, in NewSequentialFile() argument
936 const std::string& fname, in NewRandomAccessFile() argument
979 const std::string& fname, in NewWritableFile() argument
1281 const std::string& fname, in GetFileSize() argument
[all …]
Denv_mirror.cc21 std::string fname; member in ROCKSDB_NAMESPACE::SequentialFileMirror
22 explicit SequentialFileMirror(std::string f) : fname(f) {} in SequentialFileMirror()
65 std::string fname; member in ROCKSDB_NAMESPACE::RandomAccessFileMirror
66 explicit RandomAccessFileMirror(std::string f) : fname(f) {} in RandomAccessFileMirror()
100 std::string fname; member in ROCKSDB_NAMESPACE::WritableFileMirror
102 : WritableFile(options), fname(f) {} in WritableFileMirror()
244 Status EnvMirror::ReuseWritableFile(const std::string& fname, in ReuseWritableFile() argument
248 if (fname.find("/proc/") == 0) in ReuseWritableFile()
249 return a_->ReuseWritableFile(fname, old_fname, r, options); in ReuseWritableFile()
250 WritableFileMirror* mf = new WritableFileMirror(fname, options); in ReuseWritableFile()
[all …]
/rocksdb-6.9/test_util/
Dfault_injection_test_fs.cc46 std::string fname = name.substr(dirname.size() + 1); in TestFSGetDirAndName() local
47 return std::make_pair(dirname, fname); in TestFSGetDirAndName()
73 : state_(fname), in TestFSWritableFile()
231 UntrackFile(fname); in NewWritableFile()
233 open_files_.insert(fname); in NewWritableFile()
234 auto dir_and_name = TestFSGetDirAndName(fname); in NewWritableFile()
252 UntrackFile(fname); in ReopenWritableFile()
254 open_files_.insert(fname); in ReopenWritableFile()
255 auto dir_and_name = TestFSGetDirAndName(fname); in ReopenWritableFile()
273 UntrackFile(fname); in NewRandomRWFile()
[all …]
Dfault_injection_test_env.cc83 return std::make_pair(dirname, fname); in GetDirAndName()
111 : state_(fname), in TestWritableFile()
230 Status s = target()->FileExists(fname); in NewWritableFile()
242 UntrackFile(fname); in NewWritableFile()
244 open_files_.insert(fname); in NewWritableFile()
245 auto dir_and_name = GetDirAndName(fname); in NewWritableFile()
263 UntrackFile(fname); in ReopenWritableFile()
265 open_files_.insert(fname); in ReopenWritableFile()
266 auto dir_and_name = GetDirAndName(fname); in ReopenWritableFile()
284 UntrackFile(fname); in NewRandomRWFile()
[all …]
/rocksdb-6.9/include/rocksdb/utilities/
Denv_librados.h27 Status NewSequentialFile(const std::string& fname,
38 Status NewRandomAccessFile(const std::string& fname,
49 Status NewWritableFile(const std::string& fname,
54 Status ReuseWritableFile(const std::string& fname,
74 Status FileExists(const std::string& fname) override;
82 Status DeleteFile(const std::string& fname) override;
98 Status GetFileModificationTime(const std::string& fname,
119 Status LockFile(const std::string& fname, FileLock** lock);
165 Status _GetFid(const std::string& fname, std::string& fid);
168 Status _AddFid(const std::string& fname, const std::string& fid);
[all …]
/rocksdb-6.9/table/cuckoo/
Dcuckoo_table_builder_test.cc58 ASSERT_OK(env_->GetFileSize(fname, &read_file_size)); in CheckFileContents()
69 fname)); in CheckFileContents()
161 std::string fname; member in ROCKSDB_NAMESPACE::CuckooBuilderTest
167 fname = test::PerThreadDBPath("EmptyFile"); in TEST_F()
210 fname = test::PerThreadDBPath("NoCollisionFullKey"); in TEST_F()
260 fname = test::PerThreadDBPath("WithCollisionFullKey"); in TEST_F()
310 fname = test::PerThreadDBPath("WithCollisionFullKey2"); in TEST_F()
364 fname = test::PerThreadDBPath("WithCollisionPathFullKey"); in TEST_F()
459 fname = test::PerThreadDBPath("NoCollisionUserKey"); in TEST_F()
504 fname = test::PerThreadDBPath("WithCollisionUserKey"); in TEST_F()
[all …]
Dcuckoo_table_reader_test.cc117 fname)); in CreateCuckooFileAndCheckReader()
147 fname)); in CheckIterator()
211 std::string fname; member in ROCKSDB_NAMESPACE::CuckooReaderTest
228 fname = test::PerThreadDBPath("CuckooReader_WhenKeyExists"); in TEST_F()
338 fname)); in TEST_F()
421 std::string fname = GetFileName(num); in WriteFile() local
444 env->GetFileSize(fname, &file_size); in WriteFile()
449 fname)); in WriteFile()
474 std::string fname = GetFileName(num); in ReadKeys() local
477 env->GetFileSize(fname, &file_size); in ReadKeys()
[all …]
/rocksdb-6.9/utilities/checkpoint/
Dcheckpoint_impl.cc113 [&](const std::string& src_dirname, const std::string& fname, in CreateCheckpoint()
116 return db_->GetFileSystem()->LinkFile(src_dirname + fname, in CreateCheckpoint()
117 full_private_path + fname, in CreateCheckpoint()
120 [&](const std::string& src_dirname, const std::string& fname, in CreateCheckpoint() argument
123 return CopyFile(db_->GetFileSystem(), src_dirname + fname, in CreateCheckpoint()
124 full_private_path + fname, size_limit_bytes, in CreateCheckpoint()
385 cf_name.c_str(), fname.c_str()); in ExportColumnFamily()
386 return db_->GetEnv()->LinkFile(src_dirname + fname, in ExportColumnFamily()
387 tmp_export_dir + fname); in ExportColumnFamily()
391 cf_name.c_str(), fname.c_str()); in ExportColumnFamily()
[all …]
/rocksdb-6.9/db/db_impl/
Ddb_impl_files.cc266 file_deletion_status = env_->DeleteFile(fname); in DeleteObsoleteFileImpl()
273 fname.c_str(), type, number, in DeleteObsoleteFileImpl()
275 } else if (env_->FileExists(fname).IsNotFound()) { in DeleteObsoleteFileImpl()
280 job_id, fname.c_str(), type, number, in DeleteObsoleteFileImpl()
463 std::string fname; in PurgeObsoleteFiles() local
473 fname = dir_to_sync + in PurgeObsoleteFiles()
484 wal_manager_.ArchiveWALFile(fname, number); in PurgeObsoleteFiles()
690 for (const auto& fname : files) { in CleanupFilesAfterRecovery() local
693 if (!ParseFileName(fname, &number, &type)) { in CleanupFilesAfterRecovery()
709 for (const auto& fname : files_to_delete) { in CleanupFilesAfterRecovery() local
[all …]
/rocksdb-6.9/coverage/
Dparse_gcov_output.py69 len(fname) for fname in per_file_coverage.keys()
85 for fname, coverage_info in per_file_coverage.items():
87 print(record_template % (fname, coverage, lines))
108 (fname, per_file_coverage[fname]) for fname in interested_files
109 if fname in per_file_coverage
/rocksdb-6.9/include/rocksdb/
Dfile_system.h225 const std::string& fname, const FileOptions& file_opts,
246 virtual IOStatus NewWritableFile(const std::string& fname,
311 virtual IOStatus FileExists(const std::string& fname,
366 virtual IOStatus DeleteFile(const std::string& fname,
392 virtual IOStatus GetFileSize(const std::string& fname,
1037 IOStatus ReopenWritableFile(const std::string& fname, in ReopenWritableFile() argument
1043 IOStatus ReuseWritableFile(const std::string& fname, in ReuseWritableFile() argument
1051 IOStatus NewRandomRWFile(const std::string& fname, in NewRandomRWFile() argument
1058 const std::string& fname, in NewMemoryMappedFileBuffer() argument
1086 IOStatus Truncate(const std::string& fname, size_t size, in Truncate() argument
[all …]
Denv.h216 virtual Status NewWritableFile(const std::string& fname,
425 virtual Status NewLogger(const std::string& fname,
1199 Status ReopenWritableFile(const std::string& fname, in ReopenWritableFile() argument
1204 Status ReuseWritableFile(const std::string& fname, in ReuseWritableFile() argument
1210 Status NewRandomRWFile(const std::string& fname, in NewRandomRWFile() argument
1216 const std::string& fname, in NewMemoryMappedFileBuffer() argument
1239 return target_->Truncate(fname, size); in Truncate()
1268 return target_->NumFileLinks(fname, count); in NumFileLinks()
1307 Status NewLogger(const std::string& fname, in NewLogger() argument
1309 return target_->NewLogger(fname, result); in NewLogger()
[all …]

1234