Home
last modified time | relevance | path

Searched refs:IOStatus (Results 1 – 25 of 47) sorted by relevance

12

/rocksdb-6.9/include/rocksdb/
Dio_status.h39 IOStatus() : IOStatus(kOk, kNone) {} in IOStatus() function
40 ~IOStatus() {} in ~IOStatus()
43 IOStatus(const IOStatus& s);
44 IOStatus& operator=(const IOStatus& s);
45 IOStatus(IOStatus&& s)
50 IOStatus& operator=(IOStatus&& s)
67 static IOStatus OK() { return IOStatus(); } in OK()
172 inline IOStatus::IOStatus(const IOStatus& s) : Status(s.code_, s.subcode_) { in IOStatus() function
178 inline IOStatus& IOStatus::operator=(const IOStatus& s) {
193 inline IOStatus::IOStatus(IOStatus&& s) in IOStatus() function
[all …]
Dfile_system.h261 return IOStatus::NotSupported(); in ReopenWritableFile()
280 return IOStatus::NotSupported( in NewRandomRWFile()
290 return IOStatus::NotSupported( in NewMemoryMappedFileBuffer()
362 return IOStatus::OK(); in GetChildrenFileAttributes()
417 return IOStatus::NotSupported( in NumFileLinks()
603 IOStatus status;
631 return IOStatus::OK(); in Prefetch()
649 return IOStatus::OK(); in MultiRead()
755 return IOStatus::OK(); in Truncate()
841 return IOStatus::OK(); in RangeSync()
[all …]
/rocksdb-6.9/test_util/
Dfault_injection_test_fs.h54 IOStatus DropUnsyncedData();
56 IOStatus DropRandomUnsyncedData(Random* rand);
73 virtual IOStatus Close(const IOOptions& options,
129 virtual IOStatus Fsync(const IOOptions& options,
184 return IOStatus::OK(); in GetFreeSpace()
196 IOStatus DropUnsyncedFileData();
221 bool active, IOStatus error = IOStatus::Corruption("Not active")) {
228 bool active, IOStatus error = IOStatus::Corruption("Not active")) {
234 IOStatus GetError() { return error_; } in GetError()
236 void SetFileSystemIOError(IOStatus io_error) { in SetFileSystemIOError()
[all …]
Dfault_injection_test_fs.cc50 IOStatus FSFileState::DropUnsyncedData() { in DropUnsyncedData()
52 return IOStatus::OK(); in DropUnsyncedData()
59 return IOStatus::OK(); in DropRandomUnsyncedData()
96 return IOStatus::OK(); in Append()
105 IOStatus io_s; in Close()
122 IOStatus io_s; in Flush()
198 IOStatus FaultInjectionTestFS::NewDirectory( in NewDirectory()
209 return IOStatus::OK(); in NewDirectory()
368 IOStatus io_s; in DropUnsyncedFileData()
381 IOStatus io_s; in DropRandomUnsyncedFileData()
[all …]
/rocksdb-6.9/env/
Dio_posix.cc61 IOStatus s = IOStatus::NoSpace(IOErrorMsg(context, file_name), in IOError()
67 return IOStatus::IOError(IOStatus::kStaleFile); in IOError()
234 IOStatus s; in Read()
264 IOStatus s; in PositionedRead()
300 return IOStatus::OK(); in Skip()
575 IOStatus s; in Read()
736 IOStatus s; in Prefetch()
841 IOStatus s; in Read()
1012 IOStatus s; in Close()
1180 IOStatus s; in Truncate()
[all …]
Dio_posix.h141 virtual IOStatus PositionedRead(uint64_t offset, size_t n,
144 virtual IOStatus Skip(uint64_t n) override;
240 virtual IOStatus Truncate(uint64_t size, const IOOptions& opts,
261 virtual IOStatus Allocate(uint64_t offset, uint64_t len,
265 virtual IOStatus RangeSync(uint64_t offset, uint64_t nbytes,
316 IOStatus MapNewRegion();
317 IOStatus UnmapCurrentRegion();
318 IOStatus Msync();
329 return IOStatus::OK(); in Truncate()
341 virtual IOStatus Allocate(uint64_t offset, uint64_t len,
[all …]
Dfs_posix.cc202 IOStatus s; in NewRandomAccessFile()
270 IOStatus s; in OpenWritableFile()
375 IOStatus s; in ReuseWritableFile()
490 IOStatus status; in NewMemoryMappedFileBuffer()
626 IOStatus result; in DeleteFile()
635 IOStatus result; in CreateDir()
645 IOStatus result; in CreateDirIfMissing()
661 IOStatus result; in DeleteDir()
670 IOStatus s; in GetFileSize()
696 IOStatus result; in RenameFile()
[all …]
Dcomposite_env_wrapper.h76 fs_reqs[i].status = IOStatus::OK(); in MultiRead()
624 IOStatus Skip(uint64_t n) override { in Skip()
722 IOStatus Close(const IOOptions& /*options*/, in Close()
726 IOStatus Flush(const IOOptions& /*options*/, in Flush()
730 IOStatus Sync(const IOOptions& /*options*/, in Sync()
734 IOStatus Fsync(const IOOptions& /*options*/, in Fsync()
817 IOStatus Flush(const IOOptions& /*options*/, in Flush()
821 IOStatus Sync(const IOOptions& /*options*/, in Sync()
825 IOStatus Fsync(const IOOptions& /*options*/, in Fsync()
829 IOStatus Close(const IOOptions& /*options*/, in Close()
[all …]
Dfile_system.cc29 IOStatus FileSystem::ReuseWritableFile(const std::string& fname, in ReuseWritableFile()
34 IOStatus s = RenameFile(old_fname, fname, opts.io_options, dbg); in ReuseWritableFile()
86 IOStatus WriteStringToFile(FileSystem* fs, const Slice& data, in WriteStringToFile()
90 IOStatus s = fs->NewWritableFile(fname, soptions, &file, nullptr); in WriteStringToFile()
104 IOStatus ReadFileToString(FileSystem* fs, const std::string& fname, in ReadFileToString()
109 IOStatus s = status_to_io_status( in ReadFileToString()
/rocksdb-6.9/file/
Dwritable_file_writer.cc27 IOStatus s; in Append()
110 IOStatus s = Flush(); in Pad()
119 return IOStatus::OK(); in Pad()
124 IOStatus s; in Close()
136 IOStatus interim; in Close()
169 IOStatus s; in Flush()
241 IOStatus s = Flush(); in Sync()
254 return IOStatus::OK(); in Sync()
270 IOStatus s; in SyncInternal()
293 IOStatus s; in WriteBuffered()
[all …]
Dwritable_file_writer.h40 const IOStatus& io_status) { in NotifyOnFileWriteFinish()
133 IOStatus Append(const Slice& data);
135 IOStatus Pad(const size_t pad_bytes);
137 IOStatus Flush();
139 IOStatus Close();
141 IOStatus Sync(bool use_fsync);
146 IOStatus SyncWithoutFlush(bool use_fsync);
173 IOStatus WriteDirect();
176 IOStatus WriteBuffered(const char* data, size_t size);
177 IOStatus RangeSync(uint64_t offset, uint64_t nbytes);
[all …]
Dsequence_file_reader.cc88 IOStatus Read(size_t n, const IOOptions& opts, Slice* result, char* scratch, in Read()
101 return IOStatus::OK(); in Read()
105 IOStatus s; in Read()
127 IOStatus Skip(uint64_t n) override { in Skip()
129 IOStatus s = IOStatus::OK(); in Skip()
154 IOStatus PositionedRead(uint64_t offset, size_t n, const IOOptions& opts, in PositionedRead()
160 IOStatus InvalidateCache(size_t offset, size_t length) override { in InvalidateCache()
190 IOStatus ReadIntoBuffer(size_t n, const IOOptions& opts, in ReadIntoBuffer()
197 IOStatus s = file_->Read(n, opts, &result, buffer_.BufferStart(), dbg); in ReadIntoBuffer()
Dread_write_util.cc17 IOStatus NewWritableFile(FileSystem* fs, const std::string& fname, in NewWritableFile()
20 IOStatus s = fs->NewWritableFile(fname, options, result, nullptr); in NewWritableFile()
Dfilename.h172 extern IOStatus SetCurrentFile(FileSystem* fs, const std::string& dbname,
181 extern IOStatus SyncManifest(Env* env, const ImmutableDBOptions* db_options,
/rocksdb-6.9/db/
Dlog_writer.cc40 IOStatus Writer::WriteBuffer() { return dest_->Flush(); } in WriteBuffer()
42 IOStatus Writer::Close() { in Close()
43 IOStatus s; in Close()
51 IOStatus Writer::AddRecord(const Slice& slice) { in AddRecord()
62 IOStatus s; in AddRecord()
117 IOStatus Writer::EmitPhysicalRecord(RecordType t, const char* ptr, size_t n) { in EmitPhysicalRecord()
153 IOStatus s = dest_->Append(Slice(buf, header_size)); in EmitPhysicalRecord()
Derror_handler_fs_test.cc78 file_creation_error_ = IOStatus::OK(); in OnTableFileCreationStarted()
133 IOStatus io_s) { in InjectFileCreationError()
147 IOStatus file_creation_error_;
169 fault_fs->SetFilesystemActive(false, IOStatus::NoSpace("Out of space")); in TEST_F()
199 IOStatus error_msg = IOStatus::IOError("Retryable IO Error"); in TEST_F()
308 IOStatus error_msg = IOStatus::IOError("Retryable IO Error"); in TEST_F()
427 IOStatus::NoSpace("Out of space")); in TEST_F()
475 IOStatus error_msg = IOStatus::IOError("Retryable IO Error"); in TEST_F()
571 IOStatus error_msg = IOStatus::IOError("Retryable IO Error"); in TEST_F()
626 IOStatus::Corruption("Corruption")); in TEST_F()
[all …]
Dlog_writer.h83 IOStatus AddRecord(const Slice& slice);
90 IOStatus WriteBuffer();
92 IOStatus Close();
107 IOStatus EmitPhysicalRecord(RecordType type, const char* ptr, size_t length);
Dflush_job.h94 IOStatus io_status() const { return io_status_; } in io_status()
160 IOStatus io_status_;
/rocksdb-6.9/table/plain/
Dplain_table_key_coding.cc83 IOStatus PlainTableKeyEncoder::AppendKey(const Slice& key, in AppendKey()
89 return IOStatus::Corruption(Slice()); in AppendKey()
102 IOStatus io_s = file->Append(Slice(key_size_buf, len)); in AppendKey()
120 IOStatus io_s = file->Append(Slice(size_bytes, size_bytes_pos)); in AppendKey()
138 IOStatus io_s = file->Append(Slice(size_bytes, size_bytes_pos)); in AppendKey()
152 IOStatus io_s = in AppendKey()
161 IOStatus io_s = file->Append(key_to_write); in AppendKey()
168 return IOStatus::OK(); in AppendKey()
Dplain_table_builder.cc39 IOStatus WriteBlock(const Slice& block_contents, WritableFileWriter* file, in WriteBlock()
43 IOStatus io_s = file->Append(block_contents); in WriteBlock()
261 IOStatus s = WriteBlock(property_block_builder.Finish(), file_, &offset_, in Finish()
Dplain_table_builder.h65 IOStatus io_status() const override { return io_status_; } in io_status()
111 IOStatus io_status_;
/rocksdb-6.9/table/cuckoo/
Dcuckoo_table_builder.h50 IOStatus io_status() const override { return io_status_; } in io_status()
122 IOStatus io_status_;
/rocksdb-6.9/db/compaction/
Dcompaction_job.h104 IOStatus io_status() const { return io_status_; } in io_status()
199 IOStatus io_status_;
/rocksdb-6.9/db/db_impl/
Ddb_impl_write.cc104 IOStatus io_s; in WriteImpl()
524 IOStatus io_s; in PipelinedWriteImpl()
755 IOStatus io_s; in WriteImplWALOnly()
843 void DBImpl::IOStatusCheck(const IOStatus& io_status) { in IOStatusCheck()
992 IOStatus DBImpl::WriteToWAL(const WriteBatch& merged_batch, in WriteToWAL()
1009 IOStatus io_s = log_writer->AddRecord(log_entry); in WriteToWAL()
1025 IOStatus DBImpl::WriteToWAL(const WriteThread::WriteGroup& write_group, in WriteToWAL()
1029 IOStatus io_s; in WriteToWAL()
1094 IOStatus DBImpl::ConcurrentWriteToWAL( in ConcurrentWriteToWAL()
1097 IOStatus io_s; in ConcurrentWriteToWAL()
/rocksdb-6.9/table/
Dmock_table.h143 IOStatus io_status() const override { return IOStatus::OK(); } in io_status()

12