Searched refs:CommitEntry (Results 1 – 3 of 3) sorted by relevance
| /rocksdb-6.9/utilities/transactions/ |
| D | write_prepared_txn_db.h | 181 CommitEntry cached;
341 struct CommitEntry { struct
344 CommitEntry() : prep_seq(0), commit_seq(0) {} in CommitEntry() argument
345 CommitEntry(uint64_t ps, uint64_t cs) : prep_seq(ps), commit_seq(cs) {} in CommitEntry() argument
346 bool operator==(const CommitEntry& rhs) const {
408 bool Parse(const uint64_t indexed_seq, CommitEntry* entry, in Parse()
603 CommitEntry* entry) const;
608 bool AddCommitEntry(const uint64_t indexed_seq, const CommitEntry& new_entry,
609 CommitEntry* evicted_entry);
616 const CommitEntry& new_entry);
[all …]
|
| D | write_prepared_txn_db.cc | 483 CommitEntry evicted; in AddCommitted()
580 CommitEntry* entry) const { in GetCommitEntry()
587 const CommitEntry& new_entry, in AddCommitEntry()
588 CommitEntry* evicted_entry) { in AddCommitEntry()
598 const CommitEntry& new_entry) { in ExchangeCommitEntry()
870 void WritePreparedTxnDB::CheckAgainstSnapshots(const CommitEntry& evicted) { in CheckAgainstSnapshots()
|
| D | write_prepared_transaction_test.cc | 45 using CommitEntry = WritePreparedTxnDB::CommitEntry; typedef
302 CommitEntry empty_entry; in TEST()
321 CommitEntry before(p, c), after; in TEST()
708 CommitEntry c = {5, 12}, e; in TEST_P()
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()
1112 CommitEntry commit_entry = {seqs[i], seqs[i + 1]}; in TEST_P()
1124 CommitEntry commit_entry = {snapshots.front() + 1, in TEST_P()
1135 CommitEntry commit_entry = {snapshots[cache_size] + 1, in TEST_P()
[all …]
|