Home
last modified time | relevance | path

Searched refs:indexed_seq (Results 1 – 24 of 24) sorted by relevance

/dports/databases/percona57-server/percona-server-5.7.36-39/storage/rocksdb/rocksdb/utilities/transactions/
H A Dwrite_prepared_txn_db.cc482 auto indexed_seq = prepare_seq % COMMIT_CACHE_SIZE; in AddCommitted() local
485 bool to_be_evicted = GetCommitEntry(indexed_seq, &evicted_64b, &evicted); in AddCommitted()
531 ExchangeCommitEntry(indexed_seq, evicted_64b, {prepare_seq, commit_seq}); in AddCommitted()
536 indexed_seq, prepare_seq, commit_seq); in AddCommitted()
579 bool WritePreparedTxnDB::GetCommitEntry(const uint64_t indexed_seq, in GetCommitEntry() argument
583 bool valid = entry_64b->Parse(indexed_seq, entry, FORMAT); in GetCommitEntry()
587 bool WritePreparedTxnDB::AddCommitEntry(const uint64_t indexed_seq, in AddCommitEntry() argument
591 CommitEntry64b evicted_entry_64b = commit_cache_[static_cast<size_t>(indexed_seq)].exchange( in AddCommitEntry()
593 bool valid = evicted_entry_64b.Parse(indexed_seq, evicted_entry, FORMAT); in AddCommitEntry()
597 bool WritePreparedTxnDB::ExchangeCommitEntry(const uint64_t indexed_seq, in ExchangeCommitEntry() argument
[all …]
H A Dwrite_prepared_txn_db.h160 auto indexed_seq = prep_seq % COMMIT_CACHE_SIZE; variable
181 bool exist = GetCommitEntry(indexed_seq, &dont_care, &cached);
243 exist = GetCommitEntry(indexed_seq, &dont_care, &cached);
407 bool Parse(const uint64_t indexed_seq, CommitEntry* entry, in Parse()
416 assert(indexed_seq < static_cast<uint64_t>((1ull << format.INDEX_BITS))); in Parse()
419 const uint64_t& prep_low = indexed_seq; in Parse()
601 bool GetCommitEntry(const uint64_t indexed_seq, CommitEntry64b* entry_64b,
607 bool AddCommitEntry(const uint64_t indexed_seq, const CommitEntry& new_entry,
613 bool ExchangeCommitEntry(const uint64_t indexed_seq,
/dports/databases/percona57-client/percona-server-5.7.36-39/storage/rocksdb/rocksdb/utilities/transactions/
H A Dwrite_prepared_txn_db.cc482 auto indexed_seq = prepare_seq % COMMIT_CACHE_SIZE; in AddCommitted() local
485 bool to_be_evicted = GetCommitEntry(indexed_seq, &evicted_64b, &evicted); in AddCommitted()
531 ExchangeCommitEntry(indexed_seq, evicted_64b, {prepare_seq, commit_seq}); in AddCommitted()
536 indexed_seq, prepare_seq, commit_seq); in AddCommitted()
579 bool WritePreparedTxnDB::GetCommitEntry(const uint64_t indexed_seq, in GetCommitEntry() argument
583 bool valid = entry_64b->Parse(indexed_seq, entry, FORMAT); in GetCommitEntry()
587 bool WritePreparedTxnDB::AddCommitEntry(const uint64_t indexed_seq, in AddCommitEntry() argument
591 CommitEntry64b evicted_entry_64b = commit_cache_[static_cast<size_t>(indexed_seq)].exchange( in AddCommitEntry()
593 bool valid = evicted_entry_64b.Parse(indexed_seq, evicted_entry, FORMAT); in AddCommitEntry()
597 bool WritePreparedTxnDB::ExchangeCommitEntry(const uint64_t indexed_seq, in ExchangeCommitEntry() argument
[all …]
H A Dwrite_prepared_txn_db.h160 auto indexed_seq = prep_seq % COMMIT_CACHE_SIZE; variable
181 bool exist = GetCommitEntry(indexed_seq, &dont_care, &cached);
243 exist = GetCommitEntry(indexed_seq, &dont_care, &cached);
407 bool Parse(const uint64_t indexed_seq, CommitEntry* entry, in Parse()
416 assert(indexed_seq < static_cast<uint64_t>((1ull << format.INDEX_BITS))); in Parse()
419 const uint64_t& prep_low = indexed_seq; in Parse()
601 bool GetCommitEntry(const uint64_t indexed_seq, CommitEntry64b* entry_64b,
607 bool AddCommitEntry(const uint64_t indexed_seq, const CommitEntry& new_entry,
613 bool ExchangeCommitEntry(const uint64_t indexed_seq,
/dports/databases/rocksdb/rocksdb-6.26.1/utilities/transactions/
H A Dwrite_prepared_txn_db.cc483 auto indexed_seq = prepare_seq % COMMIT_CACHE_SIZE; in AddCommitted() local
486 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 …]
H A Dwrite_prepared_txn_db.h161 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,
/dports/databases/rocksdb-lite/rocksdb-6.26.1/utilities/transactions/
H A Dwrite_prepared_txn_db.cc483 auto indexed_seq = prepare_seq % COMMIT_CACHE_SIZE; in AddCommitted() local
486 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 …]
H A Dwrite_prepared_txn_db.h161 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,
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/rocksdb/rocksdb/utilities/transactions/
H A Dwrite_prepared_txn_db.cc482 auto indexed_seq = prepare_seq % COMMIT_CACHE_SIZE; in AddCommitted() local
485 bool to_be_evicted = GetCommitEntry(indexed_seq, &evicted_64b, &evicted); in AddCommitted()
531 ExchangeCommitEntry(indexed_seq, evicted_64b, {prepare_seq, commit_seq}); in AddCommitted()
536 indexed_seq, prepare_seq, commit_seq); in AddCommitted()
579 bool WritePreparedTxnDB::GetCommitEntry(const uint64_t indexed_seq, in GetCommitEntry() argument
583 bool valid = entry_64b->Parse(indexed_seq, entry, FORMAT); in GetCommitEntry()
587 bool WritePreparedTxnDB::AddCommitEntry(const uint64_t indexed_seq, in AddCommitEntry() argument
591 CommitEntry64b evicted_entry_64b = commit_cache_[static_cast<size_t>(indexed_seq)].exchange( in AddCommitEntry()
593 bool valid = evicted_entry_64b.Parse(indexed_seq, evicted_entry, FORMAT); in AddCommitEntry()
597 bool WritePreparedTxnDB::ExchangeCommitEntry(const uint64_t indexed_seq, in ExchangeCommitEntry() argument
[all …]
H A Dwrite_prepared_txn_db.h160 auto indexed_seq = prep_seq % COMMIT_CACHE_SIZE; variable
181 bool exist = GetCommitEntry(indexed_seq, &dont_care, &cached);
243 exist = GetCommitEntry(indexed_seq, &dont_care, &cached);
407 bool Parse(const uint64_t indexed_seq, CommitEntry* entry, in Parse()
416 assert(indexed_seq < static_cast<uint64_t>((1ull << format.INDEX_BITS))); in Parse()
419 const uint64_t& prep_low = indexed_seq; in Parse()
601 bool GetCommitEntry(const uint64_t indexed_seq, CommitEntry64b* entry_64b,
607 bool AddCommitEntry(const uint64_t indexed_seq, const CommitEntry& new_entry,
613 bool ExchangeCommitEntry(const uint64_t indexed_seq,
/dports/textproc/sonic/sonic-1.3.0/cargo-crates/librocksdb-sys-6.7.4/rocksdb/utilities/transactions/
H A Dwrite_prepared_txn_db.cc481 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 …]
H A Dwrite_prepared_txn_db.h161 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()
603 bool GetCommitEntry(const uint64_t indexed_seq, CommitEntry64b* entry_64b,
609 bool AddCommitEntry(const uint64_t indexed_seq, const CommitEntry& new_entry,
615 bool ExchangeCommitEntry(const uint64_t indexed_seq,
/dports/databases/mariadb104-server/mariadb-10.4.24/storage/rocksdb/rocksdb/utilities/transactions/
H A Dwrite_prepared_txn_db.cc481 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 …]
H A Dwrite_prepared_txn_db.h161 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,
/dports/databases/mariadb104-client/mariadb-10.4.24/storage/rocksdb/rocksdb/utilities/transactions/
H A Dwrite_prepared_txn_db.cc481 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 …]
H A Dwrite_prepared_txn_db.h161 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,
/dports/databases/mariadb103-client/mariadb-10.3.34/storage/rocksdb/rocksdb/utilities/transactions/
H A Dwrite_prepared_txn_db.cc481 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 …]
H A Dwrite_prepared_txn_db.h161 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,
/dports/databases/mariadb103-server/mariadb-10.3.34/storage/rocksdb/rocksdb/utilities/transactions/
H A Dwrite_prepared_txn_db.cc481 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 …]
H A Dwrite_prepared_txn_db.h161 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,
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/rocksdb/rocksdb/utilities/transactions/
H A Dwrite_prepared_txn_db.cc481 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 …]
H A Dwrite_prepared_txn_db.h161 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,
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/rocksdb/rocksdb/utilities/transactions/
H A Dwrite_prepared_txn_db.cc481 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 …]
H A Dwrite_prepared_txn_db.h161 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,