| /rocksdb-6.9/include/rocksdb/ |
| D | status.h | 31 Status(const Status& s);
32 Status& operator=(const Status& s);
33 Status(Status&& s)
38 Status& operator=(Status&& s)
95 Status(const Status& s, Severity sev);
102 static Status OK() { return Status(); } in OK()
330 inline Status::Status(const Status& s) in Status() function
334 inline Status::Status(const Status& s, Severity sev) in Status() function
338 inline Status& Status::operator=(const Status& s) {
351 inline Status::Status(Status&& s) in Status() function
[all …]
|
| D | env.h | 171 return Status::OK(); in RegisterDbPaths()
175 return Status::OK(); in UnregisterDbPaths()
633 Status status;
657 return Status::OK(); in Prefetch()
673 return Status::OK(); in MultiRead()
777 virtual Status Truncate(uint64_t /*size*/) { return Status::OK(); } in Truncate()
778 virtual Status Close() = 0;
858 return Status::OK(); in RangeSync()
887 return Status::OK(); in Allocate()
936 virtual Status Sync() = 0;
[all …]
|
| D | write_batch.h | 168 Status RollbackToSavePoint() override;
174 Status PopSavePoint() override;
194 return Status::OK(); in PutCF()
196 return Status::InvalidArgument( in PutCF()
204 return Status::OK(); in DeleteCF()
206 return Status::InvalidArgument( in DeleteCF()
214 return Status::OK(); in SingleDeleteCF()
216 return Status::InvalidArgument( in SingleDeleteCF()
231 return Status::OK(); in MergeCF()
233 return Status::InvalidArgument( in MergeCF()
[all …]
|
| D | db.h | 162 static Status OpenForReadOnly(
210 static Status OpenAsSecondary(
234 virtual Status Resume() { return Status::NotSupported(); } in Resume()
248 virtual Status Close() { return Status::NotSupported(); } in Close()
488 return std::vector<Status>( in MultiGet()
680 virtual Status NewIterators(
1101 virtual Status SetOptions( in SetOptions()
1106 virtual Status SetOptions( in SetOptions()
1214 virtual Status Flush(
1230 virtual Status LockWAL() { in LockWAL()
[all …]
|
| D | write_batch_base.h | 18 class Status; variable
54 virtual Status Delete(ColumnFamilyHandle* column_family,
56 virtual Status Delete(const Slice& key) = 0;
59 virtual Status Delete(ColumnFamilyHandle* column_family,
61 virtual Status Delete(const SliceParts& key);
67 virtual Status SingleDelete(const Slice& key) = 0;
72 virtual Status SingleDelete(const SliceParts& key);
84 virtual Status DeleteRange(const SliceParts& begin_key,
97 virtual Status PutLogData(const Slice& blob) = 0;
115 virtual Status RollbackToSavePoint() = 0;
[all …]
|
| /rocksdb-6.9/db/ |
| D | error_handler.cc | 19 std::map<std::tuple<BackgroundErrorReason, Status::Code, Status::SubCode, bool>,
24 Status::Code::kIOError, Status::SubCode::kNoSpace,
28 Status::Code::kIOError, Status::SubCode::kNoSpace,
47 Status::Code::kIOError, Status::SubCode::kNoSpace,
170 Status::Severity sev = Status::Severity::kFatalError; in SetBGError()
171 Status new_bg_err; in SetBGError()
251 Status s; in SetBGError()
268 Status bg_err(new_bg_io_err, Status::Severity::kHardError); in SetBGError()
281 Status ErrorHandler::OverrideNoSpaceError(Status bg_error, in OverrideNoSpaceError()
300 return Status(bg_error, Status::Severity::kFatalError); in OverrideNoSpaceError()
[all …]
|
| D | write_batch.cc | 89 return Status::OK(); in PutCF()
94 return Status::OK(); in DeleteCF()
99 return Status::OK(); in SingleDeleteCF()
104 return Status::OK(); in DeleteRangeCF()
109 return Status::OK(); in MergeCF()
114 return Status::OK(); in PutBlobIndexCF()
122 return Status::OK(); in MarkBeginPrepare()
127 return Status::OK(); in MarkEndPrepare()
541 Status s; in Iterate()
1458 Status s = Status::NotSupported(); in PutCFImpl()
[all …]
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_secondary.h | 26 status_ = new Status(); in LogReaderContainer()
42 Status* status_;
146 Status CompactFiles(
156 Status DisableFileDeletions() override { in DisableFileDeletions()
185 Status SetOptions( in SetOptions()
195 Status SyncWAL() override { in SyncWAL()
200 Status IngestExternalFile( in IngestExternalFile()
223 Status CheckConsistency() override;
236 return Status::OK(); in AddColumnFamilyId()
282 Status s = batch.Iterate(&handler); in CollectColumnFamilyIdsFromWriteBatch()
[all …]
|
| D | db_impl_readonly.h | 27 virtual Status Get(const ReadOptions& options,
37 virtual Status NewIterators(
43 virtual Status Put(const WriteOptions& /*options*/, in Put()
49 virtual Status Merge(const WriteOptions& /*options*/, in Merge()
55 virtual Status Delete(const WriteOptions& /*options*/, in Delete()
66 virtual Status Write(const WriteOptions& /*options*/, in Write()
79 virtual Status CompactFiles(
89 virtual Status DisableFileDeletions() override { in DisableFileDeletions()
110 virtual Status SyncWAL() override { in SyncWAL()
115 virtual Status IngestExternalFile( in IngestExternalFile()
[all …]
|
| D | db_impl.h | 312 Status SetOptions(
336 virtual Status Flush(
359 Status GetStatsHistory(
841 Status NewDB();
1116 Status WriteImplWALOnly(
1128 Status CloseImpl();
1135 virtual Status Recover(
1222 Status ClearWriter() { in ClearWriter()
1284 Status status;
1328 Status ResumeImpl();
[all …]
|
| /rocksdb-6.9/utilities/ |
| D | env_mirror.cc | 27 if (as == Status::OK()) { in Read()
49 Status as = a_->Skip(n); in Skip()
50 Status bs = b_->Skip(n); in Skip()
71 if (as == Status::OK()) { in Read()
122 Status Close() override { in Close()
123 Status as = a_->Close(); in Close()
128 Status Flush() override { in Flush()
134 Status Sync() override { in Sync()
135 Status as = a_->Sync(); in Sync()
136 Status bs = b_->Sync(); in Sync()
[all …]
|
| D | env_librados.cc | 50 return Status::NotFound(Status::kNone); in err_to_status()
52 return Status::InvalidArgument(Status::kNone); in err_to_status()
54 return Status::IOError(Status::kNone); in err_to_status()
58 return Status::NotSupported(Status::kNone); in err_to_status()
127 Status s; in Read()
205 Status s; in Read()
1044 Status r = Status::OK(); in ReuseWritableFile()
1223 Status s = Status::OK(); in CreateDirIfMissing()
1250 Status s = Status::OK(); in DeleteDir()
1333 Status s = Status::OK(); in GetFileModificationTime()
[all …]
|
| /rocksdb-6.9/env/ |
| D | mock_env.cc | 120 return Status::OK(); in Read()
132 return Status::OK(); in Write()
140 return Status::OK(); in Append()
143 Status Fsync() { in Fsync()
145 return Status::OK(); in Fsync()
245 Status Flush() override { return Status::OK(); } in Flush()
280 Status Flush() override { return Status::OK(); } in Flush()
302 Status Fsync() override { return Status::OK(); } in Fsync()
440 return Status::OK(); in NewSequentialFile()
457 return Status::OK(); in NewRandomAccessFile()
[all …]
|
| D | env_hdfs.cc | 86 Status s; in Read()
124 Status s; in Read()
153 return Status::OK(); in Skip()
246 Status s; in Sync()
402 return Status::OK(); in NewSequentialFile()
417 return Status::OK(); in NewRandomAccessFile()
425 Status s; in NewWritableFile()
433 return Status::OK(); in NewWritableFile()
441 Status Fsync() override { return Status::OK(); } in Fsync()
512 return Status::OK(); in GetChildren()
[all …]
|
| D | mock_env.h | 31 return Status::OK(); in RegisterDbPaths()
35 return Status::OK(); in UnregisterDbPaths()
38 Status NewSequentialFile(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,
59 Status NewDirectory(const std::string& name,
64 Status GetChildren(const std::string& dir,
88 Status NewLogger(const std::string& fname,
93 Status UnlockFile(FileLock* flock) override;
[all …]
|
| /rocksdb-6.9/port/win/ |
| D | env_win.h | 114 virtual Status NewMemoryMappedFileBuffer(
151 virtual Status UnlockFile(FileLock* lock);
246 Status NewMemoryMappedFileBuffer(
250 Status NewDirectory(const std::string& name,
255 Status GetChildren(const std::string& dir,
264 Status GetFileSize(const std::string& fname,
270 Status RenameFile(const std::string& src,
273 Status LinkFile(const std::string& src,
278 Status AreFilesSame(const std::string& first,
283 Status UnlockFile(FileLock* lock) override;
[all …]
|
| D | io_win.h | 184 Status UnmapCurrentRegion();
186 Status MapNewRegion();
205 virtual Status Close() override;
207 virtual Status Flush() override;
210 virtual Status Sync() override;
215 virtual Status Fsync() override;
315 Status CloseImpl();
317 Status SyncImpl();
355 virtual Status Close() override;
361 virtual Status Sync() override;
[all …]
|
| D | io_win.cc | 73 Status s; in pwrite()
109 Status s; in pread()
215 Status s; in Read()
427 Status s; in Close()
472 Status WinMmapFile::Flush() { return Status::OK(); } in Flush()
476 Status s; in Sync()
572 Status s; in Read()
613 Status s; in PositionedRead()
680 Status s; in ReadImpl()
767 Status s; in AppendImpl()
[all …]
|
| /rocksdb-6.9/include/rocksdb/utilities/ |
| D | env_mirror.h | 67 Status as = a_->FileExists(f); in FileExists()
68 Status bs = b_->FileExists(f); in FileExists()
95 Status as = a_->DeleteFile(f); in DeleteFile()
96 Status bs = b_->DeleteFile(f); in DeleteFile()
101 Status as = a_->CreateDir(d); in CreateDir()
102 Status bs = b_->CreateDir(d); in CreateDir()
113 Status as = a_->DeleteDir(d); in DeleteDir()
114 Status bs = b_->DeleteDir(d); in DeleteDir()
140 Status as = a_->RenameFile(s, t); in RenameFile()
147 Status as = a_->LinkFile(s, t); in LinkFile()
[all …]
|
| D | transaction.h | 126 virtual Status Prepare() = 0;
143 virtual Status Commit() = 0;
146 virtual Status Rollback() = 0;
157 virtual Status RollbackToSavePoint() = 0;
163 virtual Status PopSavePoint() = 0;
178 virtual Status Get(const ReadOptions& options,
184 virtual Status Get(const ReadOptions& options, in Get()
203 virtual std::vector<Status> MultiGet(
282 virtual std::vector<Status> MultiGetForUpdate(
287 virtual std::vector<Status> MultiGetForUpdate(
[all …]
|
| /rocksdb-6.9/test_util/ |
| D | testutil.h | 178 virtual Status status() const override { return Status::OK(); } in status()
216 virtual Status Close() override { return Status::OK(); } in Close()
229 virtual Status Sync() override { return Status::OK(); } in Sync()
274 Status Flush() override { return Status::OK(); } in Flush()
276 Status Sync() override { return Status::OK(); } in Sync()
278 Status Close() override { return Status::OK(); } in Close()
303 virtual Status Close() override { return Status::OK(); } in Close()
313 virtual Status Sync() override { return Status::OK(); } in Sync()
576 virtual Status Close() override { return Status::OK(); } in Close()
577 virtual Status Flush() override { return Status::OK(); } in Flush()
[all …]
|
| D | fault_injection_test_env.h | 66 virtual Status Close() override;
67 virtual Status Flush() override;
68 virtual Status Sync() override;
96 Status Close() override;
97 Status Flush() override;
98 Status Sync() override;
161 return Status::OK(); in GetFreeSpace()
175 Status DropFileData(std::function<Status(Env*, FileState)> func);
201 Status error = Status::Corruption("Not active")) {
208 Status error = Status::Corruption("Not active")) {
[all …]
|
| /rocksdb-6.9/utilities/transactions/ |
| D | write_unprepared_txn.cc | 101 Status WriteUnpreparedTxn::HandleWrite(std::function<Status()> do_write) { in HandleWrite()
102 Status s; in HandleWrite()
226 Status MarkBeginPrepare(bool) override { return Status::InvalidArgument(); } in RebuildFromWriteBatch()
232 Status MarkNoop(bool) override { return Status::InvalidArgument(); } in RebuildFromWriteBatch()
250 Status s; in MaybeFlushWriteBatchToDB()
326 return empty_batch ? Status::OK() : Status::InvalidArgument(); in FlushWriteBatchToDBInternal()
437 return empty_batch ? Status::OK() : Status::InvalidArgument(); in FlushWriteBatchWithSavePointToDB()
511 return Status::OK(); in FlushWriteBatchWithSavePointToDB()
691 return Status::OK(); in WriteRollbackKeys()
700 Status s; in RollbackInternal()
[all …]
|
| D | pessimistic_transaction.cc | 145 s = Status::Expired(); in CommitBatch()
162 s = Status::Expired(); in CommitBatch()
173 Status s; in Prepare()
209 s = Status::Expired(); in Prepare()
242 return Status::OK(); in PrepareInternal()
264 Status s; in Commit()
399 Status s; in Rollback()
504 Status s; in LockBatch()
544 Status s; in TryLock()
672 return Status::OK(); in ValidateSnapshot()
[all …]
|
| /rocksdb-6.9/java/rocksjni/ |
| D | writebatchhandlerjnicallback.cc | 148 return ROCKSDB_NAMESPACE::Status(*status); in PutCF()
181 return ROCKSDB_NAMESPACE::Status(*status); in MergeCF()
212 return ROCKSDB_NAMESPACE::Status(*status); in DeleteCF()
241 return ROCKSDB_NAMESPACE::Status(*status); in SingleDeleteCF()
272 return ROCKSDB_NAMESPACE::Status(*status); in DeleteRangeCF()
316 return ROCKSDB_NAMESPACE::Status(*status); in PutBlobIndexCF()
347 return ROCKSDB_NAMESPACE::Status::OK(); in MarkBeginPrepare()
365 return ROCKSDB_NAMESPACE::Status(*status); in MarkEndPrepare()
391 return ROCKSDB_NAMESPACE::Status::OK(); in MarkNoop()
503 new ROCKSDB_NAMESPACE::Status(ROCKSDB_NAMESPACE::Status::OK())); in kv_op()
[all …]
|