Home
last modified time | relevance | path

Searched refs:IsTryAgain (Results 1 – 8 of 8) sorted by relevance

/rocksdb-6.9/db/
Dwrite_batch.cc546 while (((s.ok() && !input.empty()) || UNLIKELY(s.IsTryAgain()))) { in Iterate()
552 if (LIKELY(!s.IsTryAgain())) { in Iterate()
563 assert(s.IsTryAgain()); in Iterate()
1489 if (UNLIKELY(!ret_status.IsTryAgain() && rebuilding_trx_ != nullptr)) { in PutCFImpl()
1551 if (UNLIKELY(!ret_status.IsTryAgain() && rebuilding_trx_ != nullptr)) { in DeleteCF()
1586 if (UNLIKELY(!ret_status.IsTryAgain() && rebuilding_trx_ != nullptr)) { in SingleDeleteCF()
1638 if (UNLIKELY(!ret_status.IsTryAgain() && rebuilding_trx_ != nullptr)) { in DeleteRangeCF()
1756 if (UNLIKELY(!ret_status.IsTryAgain() && rebuilding_trx_ != nullptr)) { in MergeCF()
Dwal_manager_test.cc312 ASSERT_TRUE(iter->status().IsTryAgain()); in TEST_F()
/rocksdb-6.9/test_util/
Dtransaction_test_util.cc156 if (is_optimistic || !(s.IsBusy() || s.IsTimedOut() || s.IsTryAgain())) { in DoInsert()
233 if (!(s.IsBusy() || s.IsTimedOut() || s.IsTryAgain())) { in DoInsert()
/rocksdb-6.9/utilities/persistent_cache/
Dpersistent_cache_test.h141 ASSERT_TRUE(status.IsTryAgain()); in InsertImpl()
Dblock_cache_tier.cc201 while ((s = InsertImpl(Slice(op.key_), Slice(op.data_))).IsTryAgain()) { in InsertMain()
/rocksdb-6.9/include/rocksdb/
Dstatus.h267 bool IsTryAgain() const { return code() == kTryAgain; } in IsTryAgain() function
/rocksdb-6.9/utilities/transactions/
Dwrite_prepared_transaction_test.cc1440 ASSERT_TRUE(s.ok() || s.IsTryAgain()); in TEST_P()
1444 ASSERT_TRUE(s.ok() || s.IsTryAgain()); in TEST_P()
1452 ASSERT_TRUE(s.ok() || s.IsTryAgain()); in TEST_P()
1456 ASSERT_TRUE(s.ok() || s.IsTryAgain()); in TEST_P()
Doptimistic_transaction_test.cc321 ASSERT_TRUE(s.IsTryAgain()); in TEST_P()