Home
last modified time | relevance | path

Searched refs:IOOptions (Results 1 – 25 of 30) sorted by relevance

12

/rocksdb-6.9/include/rocksdb/
Dfile_system.h79 struct IOOptions { struct
96 IOOptions io_options;
302 const IOOptions& io_opts,
312 const IOOptions& options,
337 const std::string& dir, const IOOptions& options, in GetChildrenFileAttributes()
367 const IOOptions& options,
372 const IOOptions& /*options*/, in Truncate() argument
403 const IOOptions& options,
409 const IOOptions& /*options*/, in LinkFile() argument
759 virtual IOStatus Sync(const IOOptions& options,
[all …]
/rocksdb-6.9/env/
Dcomposite_env_wrapper.h30 IOOptions io_opts; in Read()
44 IOOptions io_opts; in PositionedRead()
61 IOOptions io_opts; in Read()
66 IOOptions io_opts; in MultiRead()
86 IOOptions io_opts; in Prefetch()
114 IOOptions io_opts; in Append()
119 IOOptions io_opts; in PositionedAppend()
124 IOOptions io_opts; in Truncate()
129 IOOptions io_opts; in Close()
134 IOOptions io_opts; in Flush()
[all …]
Dio_posix.h139 virtual IOStatus Read(size_t n, const IOOptions& opts, Slice* result,
198 const IOOptions& options,
240 virtual IOStatus Truncate(uint64_t size, const IOOptions& opts,
243 virtual IOStatus Append(const Slice& data, const IOOptions& opts,
246 const IOOptions& opts,
254 virtual uint64_t GetFileSize(const IOOptions& opts,
262 const IOOptions& opts,
266 const IOOptions& opts,
332 virtual IOStatus Append(const Slice& data, const IOOptions& opts,
337 virtual uint64_t GetFileSize(const IOOptions& opts,
[all …]
Dio_posix.cc976 PosixMmapFile::Close(IOOptions(), nullptr); in ~PosixMmapFile()
1010 IOStatus PosixMmapFile::Close(const IOOptions& /*opts*/, in Close() argument
1037 IOStatus PosixMmapFile::Flush(const IOOptions& /*opts*/, in Flush() argument
1042 IOStatus PosixMmapFile::Sync(const IOOptions& /*opts*/, in Sync() argument
1054 IOStatus PosixMmapFile::Fsync(const IOOptions& /*opts*/, in Fsync() argument
1091 const IOOptions& /*opts*/, in Allocate() argument
1138 PosixWritableFile::Close(IOOptions(), nullptr); in ~PosixWritableFile()
1252 IOStatus PosixWritableFile::Sync(const IOOptions& /*opts*/, in Sync() argument
1380 Close(IOOptions(), nullptr); in ~PosixRandomRWFile()
1434 IOStatus PosixRandomRWFile::Sync(const IOOptions& /*opts*/, in Sync() argument
[all …]
Dfs_posix.cc231 IOOptions opts; in NewRandomAccessFile()
508 IOOptions opts; in NewMemoryMappedFileBuffer()
633 IOStatus CreateDir(const std::string& name, const IOOptions& /*opts*/, in CreateDir() argument
643 const IOOptions& /*opts*/, in CreateDirIfMissing() argument
659 IOStatus DeleteDir(const std::string& name, const IOOptions& /*opts*/, in DeleteDir() argument
682 const IOOptions& /*opts*/, in GetFileModificationTime() argument
694 const IOOptions& /*opts*/, in RenameFile() argument
704 const IOOptions& /*opts*/, in LinkFile() argument
727 const IOOptions& /*opts*/, bool* res, in AreFilesSame() argument
810 IOStatus UnlockFile(FileLock* lock, const IOOptions& /*opts*/, in UnlockFile() argument
[all …]
Dfile_system.cc94 s = file->Append(data, IOOptions(), nullptr); in WriteStringToFile()
96 s = file->Sync(IOOptions(), nullptr); in WriteStringToFile()
99 fs->DeleteFile(fname, IOOptions(), nullptr); in WriteStringToFile()
118 s = file->Read(kBufferSize, IOOptions(), &fragment, space, in ReadFileToString()
/rocksdb-6.9/test_util/
Dfault_injection_test_fs.h67 virtual IOStatus Append(const Slice& data, const IOOptions&,
69 virtual IOStatus Truncate(uint64_t size, const IOOptions& options, in Truncate()
73 virtual IOStatus Close(const IOOptions& options,
75 virtual IOStatus Flush(const IOOptions&, IODebugContext*) override;
79 const IOOptions& options, in PositionedAppend()
105 IOStatus Read(uint64_t offset, size_t n, const IOOptions& options,
108 IOStatus Close(const IOOptions& options, IODebugContext* dbg) override;
110 IOStatus Sync(const IOOptions& options, IODebugContext* dbg) override;
129 virtual IOStatus Fsync(const IOOptions& options,
174 const IOOptions& options,
[all …]
Dfault_injection_test_fs.cc83 Close(IOOptions(), nullptr); in ~TestFSWritableFile()
99 IOStatus TestFSWritableFile::Close(const IOOptions& options, in Close()
129 IOStatus TestFSWritableFile::Sync(const IOOptions& options, in Sync()
151 Close(IOOptions(), nullptr); in ~TestFSRandomRWFile()
156 const IOOptions& options, in Write()
173 IOStatus TestFSRandomRWFile::Close(const IOOptions& options, in Close()
182 IOStatus TestFSRandomRWFile::Flush(const IOOptions& options, in Flush()
190 IOStatus TestFSRandomRWFile::Sync(const IOOptions& options, in Sync()
199 const std::string& name, const IOOptions& options, in NewDirectory()
219 IOStatus io_s = target()->FileExists(fname, IOOptions(), dbg); in NewWritableFile()
[all …]
/rocksdb-6.9/file/
Ddelete_scheduler.cc65 s = fs_->DeleteFile(file_path, IOOptions(), nullptr); in DeleteFile()
79 s = fs_->DeleteFile(file_path, IOOptions(), nullptr); in DeleteFile()
88 fs_->GetFileSize(trash_file, IOOptions(), &trash_file_size, nullptr); in DeleteFile()
170 s = fs_->FileExists(*trash_file, IOOptions(), nullptr); in MarkAsTrash()
173 s = fs_->RenameFile(file_path, *trash_file, IOOptions(), nullptr); in MarkAsTrash()
278 Status my_status = fs_->NumFileLinks(path_in_trash, IOOptions(), in DeleteTrashFile()
287 IOOptions(), nullptr); in DeleteTrashFile()
290 my_status = wf->Fsync(IOOptions(), nullptr); in DeleteTrashFile()
319 s = fs_->DeleteFile(path_in_trash, IOOptions(), nullptr); in DeleteTrashFile()
323 s = fs_->NewDirectory(dir_to_sync, IOOptions(), &dir_obj, nullptr); in DeleteTrashFile()
[all …]
Dwritable_file_writer.cc37 IOOptions(), nullptr); in Append()
140 interim = writable_file_->Truncate(filesize_, IOOptions(), nullptr); in Close()
142 interim = writable_file_->Fsync(IOOptions(), nullptr); in Close()
150 interim = writable_file_->Close(IOOptions(), nullptr); in Close()
188 s = writable_file_->Flush(IOOptions(), nullptr); in Flush()
276 s = writable_file_->Fsync(IOOptions(), nullptr); in SyncInternal()
278 s = writable_file_->Sync(IOOptions(), nullptr); in SyncInternal()
287 return writable_file_->RangeSync(offset, nbytes, IOOptions(), nullptr); in RangeSync()
314 uint64_t old_size = writable_file_->GetFileSize(IOOptions(), nullptr); in WriteBuffered()
323 s = writable_file_->Append(Slice(src, allowed), IOOptions(), nullptr); in WriteBuffered()
[all …]
Dsequence_file_reader.cc39 s = file_->PositionedRead(aligned_offset, size, IOOptions(), &tmp, in Read()
49 s = file_->Read(n, IOOptions(), result, scratch, nullptr); in Read()
88 IOStatus Read(size_t n, const IOOptions& opts, Slice* result, char* scratch, in Read()
154 IOStatus PositionedRead(uint64_t offset, size_t n, const IOOptions& opts, in PositionedRead()
190 IOStatus ReadIntoBuffer(size_t n, const IOOptions& opts, in ReadIntoBuffer()
Drandom_access_file_reader_test.cc35 ASSERT_OK(fs_->CreateDir(test_dir_, IOOptions(), nullptr)); in SetUp()
55 ASSERT_OK(f->Append(content, IOOptions(), nullptr)); in Write()
56 ASSERT_OK(f->Close(IOOptions(), nullptr)); in Write()
94 EXPECT_OK(fs_->DeleteFile(Path(f), IOOptions(), nullptr)); in GetAlignment()
Dsst_file_manager_impl.cc65 Status s = fs_->GetFileSize(file_path, IOOptions(), &file_size, nullptr); in OnAddFile()
191 fs_->GetFreeSpace(fn, IOOptions(), &free_space, nullptr); in EnoughRoomForCompaction()
274 Status s = fs_->GetFreeSpace(path_, IOOptions(), &free_space, nullptr); in ClearError()
515 s = fs->GetChildren(trash_dir, IOOptions(), &files_in_trash, nullptr); in NewSstFileManager()
Drandom_access_file_reader.cc68 IOOptions(), &tmp, buf.Destination(), nullptr); in Read()
121 s = file_->Read(offset + pos, allowed, IOOptions(), &tmp_result, in Read()
249 s = file_->MultiRead(fs_reqs, num_fs_reqs, IOOptions(), nullptr); in MultiRead()
Dfilename.cc383 s = fs->RenameFile(tmp, CurrentFileName(dbname), IOOptions(), nullptr); in SetCurrentFile()
388 s = directory_to_fsync->Fsync(IOOptions(), nullptr); in SetCurrentFile()
391 fs->DeleteFile(tmp, IOOptions(), nullptr); in SetCurrentFile()
Dfile_util.cc41 s = fs->GetFileSize(source, IOOptions(), &size, nullptr); in CopyFile()
Drandom_access_file_reader.h129 return file_->Prefetch(offset, n, IOOptions(), nullptr); in Prefetch()
/rocksdb-6.9/db/
Dimport_column_family_job.cc96 fs_->LinkFile(path_outside_db, path_inside_db, IOOptions(), nullptr); in Prepare()
120 fs_->DeleteFile(f.internal_file_path, IOOptions(), nullptr); in Prepare()
175 fs_->DeleteFile(f.internal_file_path, IOOptions(), nullptr); in Cleanup()
186 fs_->DeleteFile(f.external_file_path, IOOptions(), nullptr); in Cleanup()
204 Status status = fs_->GetFileSize(external_file, IOOptions(), in GetIngestedFileInfo()
Dexternal_sst_file_ingestion_job.cc105 fs_->LinkFile(path_outside_db, path_inside_db, IOOptions(), nullptr); in Prepare()
151 status = directories_->GetDataDir(path_id)->Fsync(IOOptions(), nullptr); in Prepare()
364 Status status = fs_->GetFileSize(external_file, IOOptions(), in GetIngestedFileInfo()
665 IOOptions(), nullptr); in AssignGlobalSeqnoForIngestedFile()
723 return file->Fsync(IOOptions(), nullptr); in SyncIngestedFile()
725 return file->Sync(IOOptions(), nullptr); in SyncIngestedFile()
Dconvenience.cc53 s = ioptions.fs->GetFileSize(file_path, IOOptions(), &file_size, nullptr); in VerifySstFileChecksum()
Dbuilder.cc260 fs->DeleteFile(fname, IOOptions(), nullptr); in BuildTable()
Dflush_job.cc408 s = output_file_directory_->Fsync(IOOptions(), nullptr); in WriteLevel0Table()
/rocksdb-6.9/db/db_impl/
Ddb_impl_open.cc297 fs_->DeleteFile(manifest, IOOptions(), nullptr); in NewDB()
312 IOStatus io_s = fs->CreateDirIfMissing(dirname, IOOptions(), nullptr); in CreateAndNewDirectory()
316 return fs->NewDirectory(dirname, IOOptions(), directory, nullptr); in CreateAndNewDirectory()
438 s = fs_->FileExists(IdentityFileName(dbname_), IOOptions(), nullptr); in Recover()
1173 truncate_status = last_log->Truncate(log.size, IOOptions(), nullptr); in RestoreAliveLogFiles()
1176 truncate_status = last_log->Close(IOOptions(), nullptr); in RestoreAliveLogFiles()
1488 s = impl->directories_.GetDbDir()->Fsync(IOOptions(), nullptr); in Open()
Ddb_impl_compaction_flush.cc120 io_s = directories_.GetWalDir()->Fsync(IOOptions(), nullptr); in SyncClosedLogs()
443 Status error_status = dir->Fsync(IOOptions(), nullptr); in AtomicFlushMemTablesToOutputFiles()
/rocksdb-6.9/utilities/checkpoint/
Dcheckpoint_impl.cc118 IOOptions(), nullptr); in CreateCheckpoint()

12