Home
last modified time | relevance | path

Searched refs:last_seq (Results 1 – 7 of 7) sorted by relevance

/rocksdb-6.9/utilities/transactions/
Dwrite_unprepared_txn_db.cc318 SequenceNumber last_seq = db_impl_->GetLatestSequenceNumber(); in Initialize() local
319 AdvanceMaxEvictedSeq(prev_max, last_seq); in Initialize()
323 if (last_seq) { in Initialize()
324 db_impl_->versions_->SetLastAllocatedSequence(last_seq + 1); in Initialize()
325 db_impl_->versions_->SetLastSequence(last_seq + 1); in Initialize()
326 db_impl_->versions_->SetLastPublishedSequence(last_seq + 1); in Initialize()
Dwrite_prepared_txn_db.cc54 SequenceNumber last_seq = db_impl_->GetLatestSequenceNumber(); in Initialize() local
55 AdvanceMaxEvictedSeq(prev_max, last_seq); in Initialize()
59 if (last_seq) { in Initialize()
60 db_impl_->versions_->SetLastAllocatedSequence(last_seq + 1); in Initialize()
61 db_impl_->versions_->SetLastSequence(last_seq + 1); in Initialize()
62 db_impl_->versions_->SetLastPublishedSequence(last_seq + 1); in Initialize()
Dwrite_prepared_transaction_test.cc1340 const SequenceNumber last_seq = snap->GetSequenceNumber(); in TEST_P() local
1342 ASSERT_LT(seq, last_seq); in TEST_P()
1344 ASSERT_LT(last_seq - seq, wp_db->INC_STEP_FOR_MAX_EVICTED); in TEST_P()
1354 ASSERT_LT(wp_db->max_evicted_seq_.load(), last_seq); in TEST_P()
/rocksdb-6.9/db/
Dwrite_callback_test.cc306 Status Callback(SequenceNumber last_seq, bool /*not used*/, in TEST_F() argument
309 db_impl_->SetLastPublishedSequence(last_seq); in TEST_F()
Dflush_job_test.cc77 SequenceNumber last_seq = 1; in NewDB() local
85 new_cf.SetLastSequence(last_seq++); in NewDB()
Dversion_set_test.cc698 uint64_t last_seq = 1; in PrepareManifest() local
706 new_cf.SetLastSequence(last_seq++); in PrepareManifest()
709 *last_seqno = last_seq; in PrepareManifest()
/rocksdb-6.9/db/db_impl/
Ddb_impl_write.cc1163 auto last_seq = next_seq - 1; in WriteRecoverableState() local
1165 versions_->FetchAddLastAllocatedSequence(last_seq - seq); in WriteRecoverableState()
1166 versions_->SetLastPublishedSequence(last_seq); in WriteRecoverableState()
1168 versions_->SetLastSequence(last_seq); in WriteRecoverableState()