Lines Matching refs:commit_seq

71     Status Callback(SequenceNumber commit_seq,  in Initialize()  argument
75 db_->AddCommitted(commit_seq, commit_seq); in Initialize()
475 void WritePreparedTxnDB::AddCommitted(uint64_t prepare_seq, uint64_t commit_seq, in AddCommitted() argument
478 prepare_seq, commit_seq); in AddCommitted()
490 evicted.prep_seq, evicted.commit_seq, prev_max); in AddCommitted()
491 if (prev_max < evicted.commit_seq) { in AddCommitted()
494 if (LIKELY(evicted.commit_seq < last)) { in AddCommitted()
498 std::min(evicted.commit_seq + INC_STEP_FOR_MAX_EVICTED, last - 1); in AddCommitted()
501 max_evicted_seq = evicted.commit_seq; in AddCommitted()
506 prepare_seq, evicted.prep_seq, evicted.commit_seq, in AddCommitted()
520 delayed_prepared_commits_[evicted.prep_seq] = evicted.commit_seq; in AddCommitted()
523 evicted.prep_seq, evicted.commit_seq); in AddCommitted()
530 ExchangeCommitEntry(indexed_seq, evicted_64b, {prepare_seq, commit_seq}); in AddCommitted()
535 indexed_seq, prepare_seq, commit_seq); in AddCommitted()
541 AddCommitted(prepare_seq, commit_seq, ++loop_cnt); in AddCommitted()
896 search_larger_list = snapshot_seq < evicted.commit_seq; in CheckAgainstSnapshots()
898 if (!MaybeUpdateOldCommitMap(evicted.prep_seq, evicted.commit_seq, in CheckAgainstSnapshots()
918 evicted.prep_seq, evicted.commit_seq, cnt); in CheckAgainstSnapshots()
926 if (!MaybeUpdateOldCommitMap(evicted.prep_seq, evicted.commit_seq, in CheckAgainstSnapshots()
932 if (!MaybeUpdateOldCommitMap(evicted.prep_seq, evicted.commit_seq, in CheckAgainstSnapshots()
941 const uint64_t& prep_seq, const uint64_t& commit_seq, in MaybeUpdateOldCommitMap() argument
946 if (commit_seq <= snapshot_seq) { in MaybeUpdateOldCommitMap()
956 snapshot_seq, prep_seq, commit_seq); in MaybeUpdateOldCommitMap()