Home
last modified time | relevance | path

Searched refs:new_max (Results 1 – 4 of 4) sorted by relevance

/rocksdb-6.9/utilities/transactions/
Dwrite_prepared_txn_db.cc421 if (!empty && prepared_top <= new_max) { in CheckPreparedAgainstMax()
435 to_be_popped, new_max); in CheckPreparedAgainstMax()
459 auto new_max = future_max_evicted_seq_.load(); in AddPrepared() local
460 if (UNLIKELY(seq <= new_max)) { in AddPrepared()
466 seq, new_max); in AddPrepared()
611 prev_max, new_max); in AdvanceMaxEvictedSeq()
617 while (updated_future_max < new_max && in AdvanceMaxEvictedSeq()
623 CheckPreparedAgainstMax(new_max, false /*locked*/); in AdvanceMaxEvictedSeq()
629 SequenceNumber new_snapshots_version = new_max; in AdvanceMaxEvictedSeq()
637 snapshots = GetSnapshotListFromDB(new_max); in AdvanceMaxEvictedSeq()
[all …]
Dwrite_prepared_txn_db.h332 void CheckPreparedAgainstMax(SequenceNumber new_max, bool locked);
626 const SequenceNumber& new_max);
Dwrite_prepared_transaction_test.cc1283 SequenceNumber new_max = 200; in TEST_P() local
1284 wp_db->AdvanceMaxEvictedSeq(init_max, new_max); in TEST_P()
1288 ASSERT_EQ(wp_db->max_evicted_seq_, new_max); in TEST_P()
1292 for (; it != initial_prepared.end() && *it <= new_max; ++it) { in TEST_P()
1304 for (size_t i = 0; sit != latest_snapshots.end() && *sit <= new_max && in TEST_P()
/rocksdb-6.9/monitoring/
Dhistogram_windowing.cc177 uint64_t new_max = 0; in SwapHistoryBucket() local
181 if (m > new_max) new_max = m; in SwapHistoryBucket()
184 stats_.max_.store(new_max, std::memory_order_relaxed); in SwapHistoryBucket()