Home
last modified time | relevance | path

Searched refs:delayed_prepared_ (Results 1 – 3 of 3) sorted by relevance

/rocksdb-6.9/utilities/transactions/
Dwrite_prepared_txn_db.h221 static_cast<uint64_t>(delayed_prepared_.size()), prep_seq);
222 if (delayed_prepared_.find(prep_seq) != delayed_prepared_.end()) {
650 if (!delayed_prepared_.empty()) { in SmallestUnCommittedSeq()
651 return *delayed_prepared_.begin(); in SmallestUnCommittedSeq()
775 std::set<uint64_t> delayed_prepared_; variable
Dwrite_prepared_txn_db.cc430 delayed_prepared_.insert(to_be_popped); in CheckPreparedAgainstMax()
434 static_cast<uint64_t>(delayed_prepared_.size()), in CheckPreparedAgainstMax()
515 for (auto dp : delayed_prepared_) { in AddCommitted()
561 bool was_empty = delayed_prepared_.empty(); in RemovePrepared()
563 delayed_prepared_.erase(prepare_seq + i); in RemovePrepared()
570 bool is_empty = delayed_prepared_.empty(); in RemovePrepared()
Dwrite_prepared_transaction_test.cc1293 ASSERT_EQ(1, wp_db->delayed_prepared_.erase(*it)); in TEST_P()
1295 ASSERT_TRUE(wp_db->delayed_prepared_.empty()); in TEST_P()
1848 ASSERT_EQ(2, wp_db->delayed_prepared_.size()); in TEST_P()
1850 wp_db->delayed_prepared_.end()); in TEST_P()
1852 wp_db->delayed_prepared_.end()); in TEST_P()
1891 ASSERT_EQ(2, wp_db->delayed_prepared_.size()); in TEST_P()
1892 const auto& end = wp_db->delayed_prepared_.end(); in TEST_P()
2182 ASSERT_TRUE(wp_db->delayed_prepared_.empty()); in TEST_P()
2298 ASSERT_FALSE(wp_db->delayed_prepared_.empty()); in TEST_P()
2300 wp_db->delayed_prepared_.end()); in TEST_P()
[all …]