Searched refs:Busy (Results 1 – 14 of 14) sorted by relevance
47 assertThat(e.getStatus().getCode()).isSameAs(Status.Code.Busy); in getForUpdate_cf_conflict()84 assertThat(e.getStatus().getCode()).isSameAs(Status.Code.Busy); in getForUpdate_conflict()131 assertThat(e.getStatus().getCode()).isSameAs(Status.Code.Busy); in multiGetForUpdate_cf_conflict()175 assertThat(e.getStatus().getCode()).isSameAs(Status.Code.Busy); in multiGetForUpdate_conflict()
107 static IOStatus Busy(SubCode msg = kNone) { return IOStatus(kBusy, msg); }108 static IOStatus Busy(const Slice& msg, const Slice& msg2 = Slice()) {
163 static Status Busy(SubCode msg = kNone) { return Status(kBusy, msg); }164 static Status Busy(const Slice& msg, const Slice& msg2 = Slice()) {
57 Status Callback(DB* /*db*/) override { return Status::Busy(); } in Callback()78 return Status::Busy(); in Callback()
355 return Status::Busy(); in RecoverFromBGError()
70 Busy( (byte)0xB), enumConstant
123 assert(e.getStatus().getCode() == Status.Code.Busy); in repeatableRead()
120 assert(e.getStatus().getCode() == Status.Code.Busy); in repeatableRead()
130 result = Status::Busy(); in CheckKey()
369 result = Status::Busy(Status::SubCode::kDeadlock); in AcquireWithTimeout()572 result = Status::Busy(Status::SubCode::kLockLimit); in AcquireLocked()
452 return Status::Busy(); in StartTrace()
2595 return Status::Busy(); in BackgroundCompaction()
275 return Status::Busy(); in Resume()
585 new ROCKSDB_NAMESPACE::Status(ROCKSDB_NAMESPACE::Status::Busy( in toCppStatus()