/dports/databases/percona57-server/percona-server-5.7.36-39/storage/rocksdb/rocksdb/utilities/transactions/ |
H A D | write_prepared_txn_db.cc | 482 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 D | write_prepared_txn_db.h | 160 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 D | write_prepared_txn_db.cc | 482 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 D | write_prepared_txn_db.h | 160 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 D | write_prepared_txn_db.cc | 483 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 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,
|
/dports/databases/rocksdb-lite/rocksdb-6.26.1/utilities/transactions/ |
H A D | write_prepared_txn_db.cc | 483 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 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,
|
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/rocksdb/rocksdb/utilities/transactions/ |
H A D | write_prepared_txn_db.cc | 482 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 D | write_prepared_txn_db.h | 160 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 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 …]
|
H A 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() 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 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 …]
|
H A 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,
|
/dports/databases/mariadb104-client/mariadb-10.4.24/storage/rocksdb/rocksdb/utilities/transactions/ |
H A 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 …]
|
H A 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,
|
/dports/databases/mariadb103-client/mariadb-10.3.34/storage/rocksdb/rocksdb/utilities/transactions/ |
H A 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 …]
|
H A 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,
|
/dports/databases/mariadb103-server/mariadb-10.3.34/storage/rocksdb/rocksdb/utilities/transactions/ |
H A 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 …]
|
H A 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,
|
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/rocksdb/rocksdb/utilities/transactions/ |
H A 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 …]
|
H A 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,
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/rocksdb/rocksdb/utilities/transactions/ |
H A 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 …]
|
H A 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,
|