Lines Matching refs:target_
27 : target_(std::move(target)) {} in CompositeSequentialFileWrapper()
32 return target_->Read(n, io_opts, result, scratch, &dbg); in Read()
34 Status Skip(uint64_t n) override { return target_->Skip(n); } in Skip()
35 bool use_direct_io() const override { return target_->use_direct_io(); } in use_direct_io()
37 return target_->GetRequiredBufferAlignment(); in GetRequiredBufferAlignment()
40 return target_->InvalidateCache(offset, length); in InvalidateCache()
46 return target_->PositionedRead(offset, n, io_opts, result, scratch, &dbg); in PositionedRead()
50 std::unique_ptr<FSSequentialFile> target_;
57 : target_(std::move(target)) {} in CompositeRandomAccessFileWrapper()
63 return target_->Read(offset, n, io_opts, result, scratch, &dbg); in Read()
78 status = target_->MultiRead(fs_reqs.data(), num_reqs, io_opts, &dbg); in MultiRead()
88 return target_->Prefetch(offset, n, io_opts, &dbg); in Prefetch()
91 return target_->GetUniqueId(id, max_size); in GetUniqueId()
94 target_->Hint((FSRandomAccessFile::AccessPattern)pattern); in Hint()
96 bool use_direct_io() const override { return target_->use_direct_io(); } in use_direct_io()
98 return target_->GetRequiredBufferAlignment(); in GetRequiredBufferAlignment()
101 return target_->InvalidateCache(offset, length); in InvalidateCache()
105 std::unique_ptr<FSRandomAccessFile> target_;
111 : target_(std::move(t)) {} in CompositeWritableFileWrapper()
116 return target_->Append(data, io_opts, &dbg); in Append()
121 return target_->PositionedAppend(data, offset, io_opts, &dbg); in PositionedAppend()
126 return target_->Truncate(size, io_opts, &dbg); in Truncate()
131 return target_->Close(io_opts, &dbg); in Close()
136 return target_->Flush(io_opts, &dbg); in Flush()
141 return target_->Sync(io_opts, &dbg); in Sync()
146 return target_->Fsync(io_opts, &dbg); in Fsync()
148 bool IsSyncThreadSafe() const override { return target_->IsSyncThreadSafe(); } in IsSyncThreadSafe()
150 bool use_direct_io() const override { return target_->use_direct_io(); } in use_direct_io()
153 return target_->GetRequiredBufferAlignment(); in GetRequiredBufferAlignment()
157 target_->SetWriteLifeTimeHint(hint); in SetWriteLifeTimeHint()
161 return target_->GetWriteLifeTimeHint(); in GetWriteLifeTimeHint()
167 return target_->GetFileSize(io_opts, &dbg); in GetFileSize()
171 target_->SetPreallocationBlockSize(size); in SetPreallocationBlockSize()
176 target_->GetPreallocationStatus(block_size, last_allocated_block); in GetPreallocationStatus()
180 return target_->GetUniqueId(id, max_size); in GetUniqueId()
184 return target_->InvalidateCache(offset, length); in InvalidateCache()
190 return target_->RangeSync(offset, nbytes, io_opts, &dbg); in RangeSync()
196 target_->PrepareWrite(offset, len, io_opts, &dbg); in PrepareWrite()
202 return target_->Allocate(offset, len, io_opts, &dbg); in Allocate()
205 std::unique_ptr<FSWritableFile>* target() { return &target_; } in target()
208 std::unique_ptr<FSWritableFile> target_;
214 : target_(std::move(target)) {} in CompositeRandomRWFileWrapper()
216 bool use_direct_io() const override { return target_->use_direct_io(); } in use_direct_io()
218 return target_->GetRequiredBufferAlignment(); in GetRequiredBufferAlignment()
223 return target_->Write(offset, data, io_opts, &dbg); in Write()
229 return target_->Read(offset, n, io_opts, result, scratch, &dbg); in Read()
234 return target_->Flush(io_opts, &dbg); in Flush()
239 return target_->Sync(io_opts, &dbg); in Sync()
244 return target_->Fsync(io_opts, &dbg); in Fsync()
249 return target_->Close(io_opts, &dbg); in Close()
253 std::unique_ptr<FSRandomRWFile> target_;
259 : target_(std::move(target)) {} in CompositeDirectoryWrapper()
264 return target_->Fsync(io_opts, &dbg); in Fsync()
267 return target_->GetUniqueId(id, max_size); in GetUniqueId()
271 std::unique_ptr<FSDirectory> target_;
618 : target_(std::move(_target)) {} in LegacySequentialFileWrapper()
622 return status_to_io_status(target_->Read(n, result, scratch)); in Read()
625 return status_to_io_status(target_->Skip(n)); in Skip()
627 bool use_direct_io() const override { return target_->use_direct_io(); } in use_direct_io()
629 return target_->GetRequiredBufferAlignment(); in GetRequiredBufferAlignment()
632 return status_to_io_status(target_->InvalidateCache(offset, length)); in InvalidateCache()
638 target_->PositionedRead(offset, n, result, scratch)); in PositionedRead()
640 SequentialFile* target() { return target_.get(); } in target()
643 std::unique_ptr<SequentialFile> target_;
650 : target_(std::move(target)) {} in LegacyRandomAccessFileWrapper()
655 return status_to_io_status(target_->Read(offset, n, result, scratch)); in Read()
674 status = target_->MultiRead(reqs.data(), num_reqs); in MultiRead()
684 return status_to_io_status(target_->Prefetch(offset, n)); in Prefetch()
687 return target_->GetUniqueId(id, max_size); in GetUniqueId()
690 target_->Hint((RandomAccessFile::AccessPattern)pattern); in Hint()
692 bool use_direct_io() const override { return target_->use_direct_io(); } in use_direct_io()
694 return target_->GetRequiredBufferAlignment(); in GetRequiredBufferAlignment()
697 return status_to_io_status(target_->InvalidateCache(offset, length)); in InvalidateCache()
701 std::unique_ptr<RandomAccessFile> target_;
707 : target_(std::move(_target)) {} in LegacyWritableFileWrapper()
711 return status_to_io_status(target_->Append(data)); in Append()
716 return status_to_io_status(target_->PositionedAppend(data, offset)); in PositionedAppend()
720 return status_to_io_status(target_->Truncate(size)); in Truncate()
724 return status_to_io_status(target_->Close()); in Close()
728 return status_to_io_status(target_->Flush()); in Flush()
732 return status_to_io_status(target_->Sync()); in Sync()
736 return status_to_io_status(target_->Fsync()); in Fsync()
738 bool IsSyncThreadSafe() const override { return target_->IsSyncThreadSafe(); } in IsSyncThreadSafe()
740 bool use_direct_io() const override { return target_->use_direct_io(); } in use_direct_io()
743 return target_->GetRequiredBufferAlignment(); in GetRequiredBufferAlignment()
747 target_->SetWriteLifeTimeHint(hint); in SetWriteLifeTimeHint()
751 return target_->GetWriteLifeTimeHint(); in GetWriteLifeTimeHint()
756 return target_->GetFileSize(); in GetFileSize()
760 target_->SetPreallocationBlockSize(size); in SetPreallocationBlockSize()
765 target_->GetPreallocationStatus(block_size, last_allocated_block); in GetPreallocationStatus()
769 return target_->GetUniqueId(id, max_size); in GetUniqueId()
773 return status_to_io_status(target_->InvalidateCache(offset, length)); in InvalidateCache()
779 return status_to_io_status(target_->RangeSync(offset, nbytes)); in RangeSync()
784 target_->PrepareWrite(offset, len); in PrepareWrite()
789 return status_to_io_status(target_->Allocate(offset, len)); in Allocate()
792 WritableFile* target() { return target_.get(); } in target()
795 std::unique_ptr<WritableFile> target_;
801 : target_(std::move(target)) {} in LegacyRandomRWFileWrapper()
803 bool use_direct_io() const override { return target_->use_direct_io(); } in use_direct_io()
805 return target_->GetRequiredBufferAlignment(); in GetRequiredBufferAlignment()
810 return status_to_io_status(target_->Write(offset, data)); in Write()
815 return status_to_io_status(target_->Read(offset, n, result, scratch)); in Read()
819 return status_to_io_status(target_->Flush()); in Flush()
823 return status_to_io_status(target_->Sync()); in Sync()
827 return status_to_io_status(target_->Fsync()); in Fsync()
831 return status_to_io_status(target_->Close()); in Close()
835 std::unique_ptr<RandomRWFile> target_;
841 : target_(std::move(target)) {} in LegacyDirectoryWrapper()
845 return status_to_io_status(target_->Fsync()); in Fsync()
848 return target_->GetUniqueId(id, max_size); in GetUniqueId()
852 std::unique_ptr<Directory> target_;
858 explicit LegacyFileSystemWrapper(Env* t) : target_(t) {} in LegacyFileSystemWrapper()
864 Env* target() const { return target_; } in target()
872 Status s = target_->NewSequentialFile(f, &file, file_opts); in NewSequentialFile()
883 Status s = target_->NewRandomAccessFile(f, &file, file_opts); in NewRandomAccessFile()
893 Status s = target_->NewWritableFile(f, &file, file_opts); in NewWritableFile()
904 Status s = target_->ReopenWritableFile(fname, &file, file_opts); in ReopenWritableFile()
916 Status s = target_->ReuseWritableFile(fname, old_fname, &file, file_opts); in ReuseWritableFile()
927 Status s = target_->NewRandomRWFile(fname, &file, file_opts); in NewRandomRWFile()
937 target_->NewMemoryMappedFileBuffer(fname, result)); in NewMemoryMappedFileBuffer()
943 Status s = target_->NewDirectory(name, &dir); in NewDirectory()
951 return status_to_io_status(target_->FileExists(f)); in FileExists()
956 return status_to_io_status(target_->GetChildren(dir, r)); in GetChildren()
962 return status_to_io_status(target_->GetChildrenFileAttributes(dir, result)); in GetChildrenFileAttributes()
966 return status_to_io_status(target_->DeleteFile(f)); in DeleteFile()
971 return status_to_io_status(target_->Truncate(fname, size)); in Truncate()
975 return status_to_io_status(target_->CreateDir(d)); in CreateDir()
980 return status_to_io_status(target_->CreateDirIfMissing(d)); in CreateDirIfMissing()
984 return status_to_io_status(target_->DeleteDir(d)); in DeleteDir()
988 return status_to_io_status(target_->GetFileSize(f, s)); in GetFileSize()
996 target_->GetFileModificationTime(fname, file_mtime)); in GetFileModificationTime()
1003 return status_to_io_status(target_->GetAbsolutePath(db_path, output_path)); in GetAbsolutePath()
1009 return status_to_io_status(target_->RenameFile(s, t)); in RenameFile()
1015 return status_to_io_status(target_->LinkFile(s, t)); in LinkFile()
1020 return status_to_io_status(target_->NumFileLinks(fname, count)); in NumFileLinks()
1026 return status_to_io_status(target_->AreFilesSame(first, second, res)); in AreFilesSame()
1031 return status_to_io_status(target_->LockFile(f, l)); in LockFile()
1036 return status_to_io_status(target_->UnlockFile(l)); in UnlockFile()
1041 return status_to_io_status(target_->GetTestDirectory(path)); in GetTestDirectory()
1046 return status_to_io_status(target_->NewLogger(fname, result)); in NewLogger()
1050 target_->SanitizeEnvOptions(opts); in SanitizeFileOptions()
1055 return target_->OptimizeForLogRead(file_options); in OptimizeForLogRead()
1059 return target_->OptimizeForManifestRead(file_options); in OptimizeForManifestRead()
1063 return target_->OptimizeForLogWrite(file_options, db_options); in OptimizeForLogWrite()
1067 return target_->OptimizeForManifestWrite(file_options); in OptimizeForManifestWrite()
1072 return target_->OptimizeForCompactionTableWrite(file_options, in OptimizeForCompactionTableWrite()
1078 return target_->OptimizeForCompactionTableRead(file_options, db_options); in OptimizeForCompactionTableRead()
1082 return status_to_io_status(target_->GetFreeSpace(path, diskfree)); in GetFreeSpace()
1086 Env* target_;