Home
last modified time | relevance | path

Searched refs:SubCode (Results 1 – 18 of 18) sorted by relevance

/rocksdb-6.9/include/rocksdb/
Dstatus.h68 enum SubCode : unsigned char { enum
84 SubCode subcode() const { return subcode_; } in subcode()
114 static Status Corruption(SubCode msg = kNone) {
121 static Status NotSupported(SubCode msg = kNone) {
128 static Status InvalidArgument(SubCode msg = kNone) {
140 static Status MergeInProgress(SubCode msg = kNone) {
147 static Status Incomplete(SubCode msg = kNone) {
151 static Status ShutdownInProgress(SubCode msg = kNone) {
183 static Status CompactionTooLarge(SubCode msg = kNone) {
316 SubCode subcode_;
[all …]
Dio_status.h29 using SubCode = Status::SubCode; variable
72 static IOStatus NotSupported(SubCode msg = kNone) {
81 static IOStatus NotFound(SubCode msg = kNone) {
88 static IOStatus Corruption(SubCode msg = kNone) {
96 static IOStatus InvalidArgument(SubCode msg = kNone) {
103 static IOStatus IOError(SubCode msg = kNone) {
107 static IOStatus Busy(SubCode msg = kNone) { return IOStatus(kBusy, msg); }
112 static IOStatus TimedOut(SubCode msg = kNone) {
139 explicit IOStatus(Code _code, SubCode _subcode = kNone)
145 IOStatus(Code _code, SubCode _subcode, const Slice& msg, const Slice& msg2);
[all …]
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DStatus.java16 /* @Nullable */ private final SubCode subCode;
19 public Status(final Code code, final SubCode subCode, final String state) { in Status()
30 this.subCode = SubCode.getSubCode(subCode); in Status()
38 public SubCode getSubCode() { in getSubCode()
49 if(subCode != null && subCode != SubCode.None) { in getCodeString()
102 public enum SubCode { enum in Status
115 SubCode(final byte value) { in SubCode() method in Status.SubCode
119 public static SubCode getSubCode(final byte value) { in getSubCode()
120 for (final SubCode subCode : SubCode.values()) { in getSubCode()
DAbstractTraceWriter.java31 return statusToShort(Status.Code.Ok, Status.SubCode.None); in writeProxy()
47 return statusToShort(Status.Code.Ok, Status.SubCode.None); in closeWriterProxy()
57 final Status.SubCode subCode = status != null && status.getSubCode() != null in statusToShort()
59 : Status.SubCode.None; in statusToShort()
64 final Status.SubCode subCode) { in statusToShort()
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DRocksDBExceptionTest.java11 import org.rocksdb.Status.SubCode;
36 assertThat(e.getStatus().getSubCode()).isEqualTo(SubCode.None); in exceptionWithStatusCode()
51 assertThat(e.getStatus().getSubCode()).isEqualTo(SubCode.None); in exceptionNoMsgWithStatusCode()
67 .isEqualTo(Status.SubCode.LockTimeout); in exceptionWithStatusCodeSubCode()
82 assertThat(e.getStatus().getSubCode()).isEqualTo(SubCode.LockTimeout); in exceptionNoMsgWithStatusCodeSubCode()
85 "(" + SubCode.LockTimeout.name() + ")"); in exceptionNoMsgWithStatusCodeSubCode()
98 assertThat(e.getStatus().getSubCode()).isEqualTo(SubCode.None); in exceptionWithStatusCodeState()
DRocksDBTest.java56 assertThat(e.getStatus().getSubCode()).isEqualTo(Status.SubCode.None); in openWhenOpen()
/rocksdb-6.9/db/
Derror_handler.cc19 std::map<std::tuple<BackgroundErrorReason, Status::Code, Status::SubCode, bool>,
24 Status::Code::kIOError, Status::SubCode::kNoSpace,
28 Status::Code::kIOError, Status::SubCode::kNoSpace,
32 Status::Code::kIOError, Status::SubCode::kSpaceLimit,
37 Status::SubCode::kNoSpace, true),
40 Status::SubCode::kNoSpace, false),
43 Status::SubCode::kSpaceLimit, true),
47 Status::Code::kIOError, Status::SubCode::kNoSpace,
51 Status::Code::kIOError, Status::SubCode::kNoSpace,
Derror_handler.h34 Status::SubCode subcode);
Ddb_basic_test.cc35 ASSERT_EQ(Status::SubCode::kNone, s.subcode()); in TEST_F()
/rocksdb-6.9/java/rocksjni/
Drocksdb_exception_test.cc57 ROCKSDB_NAMESPACE::Status::SubCode::kLockTimeout)); in Java_org_rocksdb_RocksDBExceptionTest_raiseExceptionWithStatusCodeSubCode()
69 ROCKSDB_NAMESPACE::Status::SubCode::kLockTimeout)); in Java_org_rocksdb_RocksDBExceptionTest_raiseExceptionNoMsgWithStatusCodeSubCode()
Dportal.h278 static ROCKSDB_NAMESPACE::Status::SubCode toCppSubCode( in toCppSubCode()
282 return ROCKSDB_NAMESPACE::Status::SubCode::kNone; in toCppSubCode()
290 return ROCKSDB_NAMESPACE::Status::SubCode::kNoSpace; in toCppSubCode()
300 return ROCKSDB_NAMESPACE::Status::SubCode::kNone; in toCppSubCode()
482 const ROCKSDB_NAMESPACE::Status::SubCode& subCode) { in toJavaStatusSubCode()
484 case ROCKSDB_NAMESPACE::Status::SubCode::kNone: in toJavaStatusSubCode()
488 case ROCKSDB_NAMESPACE::Status::SubCode::kLockTimeout: in toJavaStatusSubCode()
490 case ROCKSDB_NAMESPACE::Status::SubCode::kLockLimit: in toJavaStatusSubCode()
492 case ROCKSDB_NAMESPACE::Status::SubCode::kNoSpace: in toJavaStatusSubCode()
494 case ROCKSDB_NAMESPACE::Status::SubCode::kDeadlock: in toJavaStatusSubCode()
[all …]
/rocksdb-6.9/utilities/transactions/
Dtransaction_db_mutex_impl.cc87 return Status::TimedOut(Status::SubCode::kMutexTimeout); in TryLockFor()
122 s = Status::TimedOut(Status::SubCode::kMutexTimeout); in WaitFor()
Dtransaction_lock_mgr.cc369 result = Status::Busy(Status::SubCode::kDeadlock); in AcquireWithTimeout()
554 result = Status::TimedOut(Status::SubCode::kLockTimeout); in AcquireLocked()
572 result = Status::Busy(Status::SubCode::kLockLimit); in AcquireLocked()
/rocksdb-6.9/util/
Dstatus.cc57 Status::Status(Code _code, SubCode _subcode, const Slice& msg, in Status()
/rocksdb-6.9/db/compaction/
Dcompaction_iterator.cc637 status_ = Status::Incomplete(Status::SubCode::kManualCompactionPaused); in NextFromInput()
Dcompaction_job.cc1026 status = Status::Incomplete(Status::SubCode::kManualCompactionPaused); in ProcessKeyValueCompaction()
/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc943 return Status::Incomplete(Status::SubCode::kManualCompactionPaused); in CompactFilesImpl()
2507 status = Status::Incomplete(Status::SubCode::kManualCompactionPaused); in BackgroundCompaction()
Ddb_impl.cc1683 Status::SubCode::KMergeOperandsInsufficientCapacity); in GetImpl()