Searched refs:indexed_seq (Results 1 – 2 of 2) sorted by relevance
| /rocksdb-6.9/utilities/transactions/ |
| D | write_prepared_txn_db.cc | 481 auto indexed_seq = prepare_seq % COMMIT_CACHE_SIZE; in AddCommitted() local
484 bool to_be_evicted = GetCommitEntry(indexed_seq, &evicted_64b, &evicted); in AddCommitted()
530 ExchangeCommitEntry(indexed_seq, evicted_64b, {prepare_seq, commit_seq}); in AddCommitted()
535 indexed_seq, prepare_seq, commit_seq); in AddCommitted()
578 bool WritePreparedTxnDB::GetCommitEntry(const uint64_t indexed_seq, in GetCommitEntry() argument
582 bool valid = entry_64b->Parse(indexed_seq, entry, FORMAT); in GetCommitEntry()
586 bool WritePreparedTxnDB::AddCommitEntry(const uint64_t indexed_seq, in AddCommitEntry() argument
590 CommitEntry64b evicted_entry_64b = commit_cache_[static_cast<size_t>(indexed_seq)].exchange( in AddCommitEntry()
592 bool valid = evicted_entry_64b.Parse(indexed_seq, evicted_entry, FORMAT); in AddCommitEntry()
596 bool WritePreparedTxnDB::ExchangeCommitEntry(const uint64_t indexed_seq, in ExchangeCommitEntry() argument
[all …]
|
| D | write_prepared_txn_db.h | 161 auto indexed_seq = prep_seq % COMMIT_CACHE_SIZE; variable
182 bool exist = GetCommitEntry(indexed_seq, &dont_care, &cached);
244 exist = GetCommitEntry(indexed_seq, &dont_care, &cached);
408 bool Parse(const uint64_t indexed_seq, CommitEntry* entry, in Parse()
417 assert(indexed_seq < static_cast<uint64_t>((1ull << format.INDEX_BITS))); in Parse()
420 const uint64_t& prep_low = indexed_seq; in Parse()
602 bool GetCommitEntry(const uint64_t indexed_seq, CommitEntry64b* entry_64b,
608 bool AddCommitEntry(const uint64_t indexed_seq, const CommitEntry& new_entry,
614 bool ExchangeCommitEntry(const uint64_t indexed_seq,
|