Searched refs:commit_seq (Results 1 – 6 of 6) sorted by relevance
| /rocksdb-6.9/utilities/transactions/ |
| D | write_prepared_txn_db.cc | 71 Status Callback(SequenceNumber commit_seq, in Initialize() argument
75 db_->AddCommitted(commit_seq, commit_seq); in Initialize()
478 prepare_seq, commit_seq); in AddCommitted()
491 if (prev_max < evicted.commit_seq) { in AddCommitted()
494 if (LIKELY(evicted.commit_seq < last)) { in AddCommitted()
501 max_evicted_seq = evicted.commit_seq; in AddCommitted()
535 indexed_seq, prepare_seq, commit_seq); in AddCommitted()
541 AddCommitted(prepare_seq, commit_seq, ++loop_cnt); in AddCommitted()
941 const uint64_t& prep_seq, const uint64_t& commit_seq, in MaybeUpdateOldCommitMap() argument
946 if (commit_seq <= snapshot_seq) { in MaybeUpdateOldCommitMap()
[all …]
|
| D | write_prepared_txn_db.h | 191 return cached.commit_seq <= snapshot_seq;
250 return cached.commit_seq <= snapshot_seq;
343 uint64_t commit_seq; member
344 CommitEntry() : prep_seq(0), commit_seq(0) {} in CommitEntry()
347 return prep_seq == rhs.prep_seq && commit_seq == rhs.commit_seq;
423 entry->commit_seq = entry->prep_seq + delta - 1; in Parse()
708 const uint64_t& commit_seq,
924 virtual Status Callback(SequenceNumber commit_seq, in Callback() argument
935 ? commit_seq in Callback()
954 db_->AddCommitted(commit_seq + i, last_commit_seq); in Callback()
[all …]
|
| D | write_unprepared_txn_db.h | 58 virtual Status Callback(SequenceNumber commit_seq, in Callback() argument
63 ? commit_seq in Callback()
64 : commit_seq + data_batch_cnt_ - 1; in Callback()
79 db_->AddCommitted(commit_seq + i, last_commit_seq); in Callback()
|
| D | write_unprepared_txn_db.cc | 205 Status Callback(SequenceNumber commit_seq, in Initialize() argument
209 db_->AddCommitted(commit_seq, commit_seq); in Initialize()
|
| D | write_prepared_transaction_test.cc | 726 CommitEntry e2 = {c.prep_seq + size, c.commit_seq + size}; in TEST_P()
737 CommitEntry e3 = {c.prep_seq + size, c.commit_seq + size + 1}; in TEST_P()
746 CommitEntry e4 = {e3.prep_seq + size, e3.commit_seq + size + 1}; in TEST_P()
1022 auto commit_seq = ++seq; in TEST_P() local
1023 wp_db->AddCommitted(prep_seq, commit_seq); in TEST_P()
1037 commit_seq = ++seq; in TEST_P()
1038 wp_db->AddCommitted(prep_seq, commit_seq); in TEST_P()
1044 commit_seq = ++seq; in TEST_P()
1045 wp_db->AddCommitted(prep_seq, commit_seq); in TEST_P()
1115 bool expect_update = commit_entry.commit_seq - commit_entry.prep_seq > 5 && in TEST_P()
[all …]
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2017-12-19-write-prepared-txn.markdown | 25 …commit_seq`, will be used as the commit timestamp of the transaction. Before releasing the commit …
|