Home
last modified time | relevance | path

Searched refs:prepare_seq (Results 1 – 6 of 6) sorted by relevance

/rocksdb-6.9/utilities/transactions/
Dwrite_prepared_txn_db.cc196 uint64_t prepare_seq = seq_used; in WriteInternal() local
198 txn->SetId(prepare_seq); in WriteInternal()
208 prepare_seq); in WriteInternal()
478 prepare_seq, commit_seq); in AddCommitted()
481 auto indexed_seq = prepare_seq % COMMIT_CACHE_SIZE; in AddCommitted()
486 assert(evicted.prep_seq != prepare_seq); in AddCommitted()
541 AddCommitted(prepare_seq, commit_seq, ++loop_cnt); in AddCommitted()
557 prepare_seq, batch_cnt); in RemovePrepared()
560 prepared_txns_.erase(prepare_seq + i); in RemovePrepared()
563 delayed_prepared_.erase(prepare_seq + i); in RemovePrepared()
[all …]
Dwrite_prepared_txn.cc124 auto prepare_seq = seq_used; in PrepareInternal() local
125 SetId(prepare_seq); in PrepareInternal()
157 auto prepare_seq = GetId(); in CommitInternal() local
173 wpt_db_, db_impl_, prepare_seq, prepare_batch_cnt_, commit_batch_cnt); in CommitInternal()
201 wpt_db_->RemovePrepared(prepare_seq, prepare_batch_cnt_); in CommitInternal()
217 wpt_db_, db_impl_, prepare_seq, prepare_batch_cnt_, kZeroData, in CommitInternal()
234 wpt_db_->RemovePrepared(prepare_seq, prepare_batch_cnt_); in CommitInternal()
Dwrite_unprepared_txn.cc382 auto prepare_seq = seq_used; in FlushWriteBatchToDBInternal() local
386 SetId(prepare_seq); in FlushWriteBatchToDBInternal()
391 unprep_seqs_[prepare_seq] = prepare_batch_cnt_; in FlushWriteBatchToDBInternal()
758 uint64_t& prepare_seq = seq_used; in RollbackInternal() local
762 unprep_seqs_[prepare_seq] = rollback_batch_cnt; in RollbackInternal()
768 prepare_seq); in RollbackInternal()
Dwrite_prepared_txn_db.h338 void AddCommitted(uint64_t prepare_seq, uint64_t commit_seq,
860 virtual Status Callback(SequenceNumber prepare_seq, in Callback() argument
878 db_->AddPrepared(prepare_seq + i, kLocked); in Callback()
Dwrite_prepared_transaction_test.cc1940 SequenceNumber prepare_seq = kMaxSequenceNumber; in TEST_P() local
1946 prepare_seq = txn->GetId(); in TEST_P()
1962 seq <= wp_db->max_evicted_seq_ && seq != prepare_seq; seq++) { in TEST_P()
1966 ASSERT_FALSE(wp_db->IsInSnapshot(prepare_seq, snap_seq)); in TEST_P()
1978 seq <= wp_db->max_evicted_seq_ && seq != prepare_seq; seq++) { in TEST_P()
1982 ASSERT_FALSE(wp_db->IsInSnapshot(prepare_seq, snap_seq)); in TEST_P()
/rocksdb-6.9/docs/_posts/
D2017-12-19-write-prepared-txn.markdown25 …prepare_seq`, which is also used as the identifier for the transaction. At commit time, it writes …