| /dports/databases/percona57-server/percona-server-5.7.36-39/storage/rocksdb/rocksdb/utilities/transactions/ |
| H A D | write_prepared_txn_db.h | 159 CommitEntry64b dont_care;
381 struct CommitEntry64b { struct
382 constexpr CommitEntry64b() noexcept : rep_(0) {} in CommitEntry64b() function
384 CommitEntry64b(const CommitEntry& entry, const CommitEntry64bFormat& format) in CommitEntry64b() argument
385 : CommitEntry64b(entry.prep_seq, entry.commit_seq, format) {} in CommitEntry64b()
387 CommitEntry64b(const uint64_t ps, const uint64_t cs, in CommitEntry64b() function
601 bool GetCommitEntry(const uint64_t indexed_seq, CommitEntry64b* entry_64b,
614 CommitEntry64b& expected_entry,
746 std::unique_ptr<std::atomic<CommitEntry64b>[]> commit_cache_;
|
| H A D | write_prepared_txn_db.cc | 402 commit_cache_ = std::unique_ptr<std::atomic<CommitEntry64b>[]>( in Init()
403 new std::atomic<CommitEntry64b>[COMMIT_CACHE_SIZE] {}); in Init()
483 CommitEntry64b evicted_64b; in AddCommitted()
580 CommitEntry64b* entry_64b, in GetCommitEntry()
590 CommitEntry64b new_entry_64b(new_entry, FORMAT); in AddCommitEntry()
591 CommitEntry64b evicted_entry_64b = commit_cache_[static_cast<size_t>(indexed_seq)].exchange( in AddCommitEntry()
598 CommitEntry64b& expected_entry_64b, in ExchangeCommitEntry()
601 CommitEntry64b new_entry_64b(new_entry, FORMAT); in ExchangeCommitEntry()
|
| H A D | write_prepared_transaction_test.cc | 44 using CommitEntry64b = WritePreparedTxnDB::CommitEntry64b; typedef
292 TEST(CommitEntry64b, BasicTest) { in TEST() argument
298 CommitEntry64b empty_entry64b; in TEST()
320 CommitEntry64b entry64b(before, FORMAT); in TEST()
713 CommitEntry64b dont_care; in TEST_P()
727 CommitEntry64b e2_64b(e2, wp_db->FORMAT); in TEST_P()
736 CommitEntry64b c_64b(c, wp_db->FORMAT); in TEST_P()
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/storage/rocksdb/rocksdb/utilities/transactions/ |
| H A D | write_prepared_txn_db.h | 159 CommitEntry64b dont_care;
381 struct CommitEntry64b { struct
382 constexpr CommitEntry64b() noexcept : rep_(0) {} in CommitEntry64b() function
384 CommitEntry64b(const CommitEntry& entry, const CommitEntry64bFormat& format) in CommitEntry64b() function
385 : CommitEntry64b(entry.prep_seq, entry.commit_seq, format) {} in CommitEntry64b()
387 CommitEntry64b(const uint64_t ps, const uint64_t cs, in CommitEntry64b() function
601 bool GetCommitEntry(const uint64_t indexed_seq, CommitEntry64b* entry_64b,
614 CommitEntry64b& expected_entry,
746 std::unique_ptr<std::atomic<CommitEntry64b>[]> commit_cache_;
|
| H A D | write_prepared_txn_db.cc | 402 commit_cache_ = std::unique_ptr<std::atomic<CommitEntry64b>[]>( in Init()
403 new std::atomic<CommitEntry64b>[COMMIT_CACHE_SIZE] {}); in Init()
483 CommitEntry64b evicted_64b; in AddCommitted()
580 CommitEntry64b* entry_64b, in GetCommitEntry()
590 CommitEntry64b new_entry_64b(new_entry, FORMAT); in AddCommitEntry()
591 CommitEntry64b evicted_entry_64b = commit_cache_[static_cast<size_t>(indexed_seq)].exchange( in AddCommitEntry()
598 CommitEntry64b& expected_entry_64b, in ExchangeCommitEntry()
601 CommitEntry64b new_entry_64b(new_entry, FORMAT); in ExchangeCommitEntry()
|
| /dports/databases/rocksdb/rocksdb-6.26.1/utilities/transactions/ |
| H A D | write_prepared_txn_db.h | 160 CommitEntry64b dont_care;
382 struct CommitEntry64b { struct
383 constexpr CommitEntry64b() noexcept : rep_(0) {} in CommitEntry64b() function
385 CommitEntry64b(const CommitEntry& entry, const CommitEntry64bFormat& format) in CommitEntry64b() function
386 : CommitEntry64b(entry.prep_seq, entry.commit_seq, format) {} in CommitEntry64b()
388 CommitEntry64b(const uint64_t ps, const uint64_t cs, in CommitEntry64b() argument
602 bool GetCommitEntry(const uint64_t indexed_seq, CommitEntry64b* entry_64b,
615 CommitEntry64b& expected_entry,
747 std::unique_ptr<std::atomic<CommitEntry64b>[]> commit_cache_;
|
| H A D | write_prepared_txn_db.cc | 403 commit_cache_ = std::unique_ptr<std::atomic<CommitEntry64b>[]>( in Init()
404 new std::atomic<CommitEntry64b>[COMMIT_CACHE_SIZE] {}); in Init()
484 CommitEntry64b evicted_64b; in AddCommitted()
579 CommitEntry64b* entry_64b, in GetCommitEntry()
589 CommitEntry64b new_entry_64b(new_entry, FORMAT); in AddCommitEntry()
590 CommitEntry64b evicted_entry_64b = commit_cache_[static_cast<size_t>(indexed_seq)].exchange( in AddCommitEntry()
597 CommitEntry64b& expected_entry_64b, in ExchangeCommitEntry()
600 CommitEntry64b new_entry_64b(new_entry, FORMAT); in ExchangeCommitEntry()
|
| /dports/databases/rocksdb-lite/rocksdb-6.26.1/utilities/transactions/ |
| H A D | write_prepared_txn_db.h | 160 CommitEntry64b dont_care;
382 struct CommitEntry64b { struct
383 constexpr CommitEntry64b() noexcept : rep_(0) {} in CommitEntry64b() argument
385 CommitEntry64b(const CommitEntry& entry, const CommitEntry64bFormat& format) in CommitEntry64b() argument
386 : CommitEntry64b(entry.prep_seq, entry.commit_seq, format) {} in CommitEntry64b()
388 CommitEntry64b(const uint64_t ps, const uint64_t cs, in CommitEntry64b() function
602 bool GetCommitEntry(const uint64_t indexed_seq, CommitEntry64b* entry_64b,
615 CommitEntry64b& expected_entry,
747 std::unique_ptr<std::atomic<CommitEntry64b>[]> commit_cache_;
|
| H A D | write_prepared_txn_db.cc | 403 commit_cache_ = std::unique_ptr<std::atomic<CommitEntry64b>[]>( in Init()
404 new std::atomic<CommitEntry64b>[COMMIT_CACHE_SIZE] {}); in Init()
484 CommitEntry64b evicted_64b; in AddCommitted()
579 CommitEntry64b* entry_64b, in GetCommitEntry()
589 CommitEntry64b new_entry_64b(new_entry, FORMAT); in AddCommitEntry()
590 CommitEntry64b evicted_entry_64b = commit_cache_[static_cast<size_t>(indexed_seq)].exchange( in AddCommitEntry()
597 CommitEntry64b& expected_entry_64b, in ExchangeCommitEntry()
600 CommitEntry64b new_entry_64b(new_entry, FORMAT); in ExchangeCommitEntry()
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/rocksdb/rocksdb/utilities/transactions/ |
| H A D | write_prepared_txn_db.h | 159 CommitEntry64b dont_care;
381 struct CommitEntry64b { struct
382 constexpr CommitEntry64b() noexcept : rep_(0) {} in CommitEntry64b() argument
384 CommitEntry64b(const CommitEntry& entry, const CommitEntry64bFormat& format) in CommitEntry64b() function
385 : CommitEntry64b(entry.prep_seq, entry.commit_seq, format) {} in CommitEntry64b()
387 CommitEntry64b(const uint64_t ps, const uint64_t cs, in CommitEntry64b() function
601 bool GetCommitEntry(const uint64_t indexed_seq, CommitEntry64b* entry_64b,
614 CommitEntry64b& expected_entry,
746 std::unique_ptr<std::atomic<CommitEntry64b>[]> commit_cache_;
|
| H A D | write_prepared_txn_db.cc | 402 commit_cache_ = std::unique_ptr<std::atomic<CommitEntry64b>[]>( in Init()
403 new std::atomic<CommitEntry64b>[COMMIT_CACHE_SIZE] {}); in Init()
483 CommitEntry64b evicted_64b; in AddCommitted()
580 CommitEntry64b* entry_64b, in GetCommitEntry()
590 CommitEntry64b new_entry_64b(new_entry, FORMAT); in AddCommitEntry()
591 CommitEntry64b evicted_entry_64b = commit_cache_[static_cast<size_t>(indexed_seq)].exchange( in AddCommitEntry()
598 CommitEntry64b& expected_entry_64b, in ExchangeCommitEntry()
601 CommitEntry64b new_entry_64b(new_entry, FORMAT); in ExchangeCommitEntry()
|
| /dports/textproc/sonic/sonic-1.3.0/cargo-crates/librocksdb-sys-6.7.4/rocksdb/utilities/transactions/ |
| H A D | write_prepared_txn_db.h | 160 CommitEntry64b dont_care;
382 struct CommitEntry64b { struct
383 constexpr CommitEntry64b() noexcept : rep_(0) {} in CommitEntry64b() argument
385 CommitEntry64b(const CommitEntry& entry, const CommitEntry64bFormat& format) in CommitEntry64b() argument
386 : CommitEntry64b(entry.prep_seq, entry.commit_seq, format) {} in CommitEntry64b()
388 CommitEntry64b(const uint64_t ps, const uint64_t cs, in CommitEntry64b() argument
603 bool GetCommitEntry(const uint64_t indexed_seq, CommitEntry64b* entry_64b,
616 CommitEntry64b& expected_entry,
748 std::unique_ptr<std::atomic<CommitEntry64b>[]> commit_cache_;
|
| H A D | write_prepared_txn_db.cc | 401 commit_cache_ = std::unique_ptr<std::atomic<CommitEntry64b>[]>( in Init()
402 new std::atomic<CommitEntry64b>[COMMIT_CACHE_SIZE] {}); in Init()
482 CommitEntry64b evicted_64b; in AddCommitted()
579 CommitEntry64b* entry_64b, in GetCommitEntry()
589 CommitEntry64b new_entry_64b(new_entry, FORMAT); in AddCommitEntry()
590 CommitEntry64b evicted_entry_64b = commit_cache_[static_cast<size_t>(indexed_seq)].exchange( in AddCommitEntry()
597 CommitEntry64b& expected_entry_64b, in ExchangeCommitEntry()
600 CommitEntry64b new_entry_64b(new_entry, FORMAT); in ExchangeCommitEntry()
|
| /dports/databases/mariadb104-client/mariadb-10.4.24/storage/rocksdb/rocksdb/utilities/transactions/ |
| H A D | write_prepared_txn_db.h | 160 CommitEntry64b dont_care;
382 struct CommitEntry64b { struct
383 constexpr CommitEntry64b() noexcept : rep_(0) {} in CommitEntry64b() function
385 CommitEntry64b(const CommitEntry& entry, const CommitEntry64bFormat& format) in CommitEntry64b() function
386 : CommitEntry64b(entry.prep_seq, entry.commit_seq, format) {} in CommitEntry64b()
388 CommitEntry64b(const uint64_t ps, const uint64_t cs, in CommitEntry64b() argument
602 bool GetCommitEntry(const uint64_t indexed_seq, CommitEntry64b* entry_64b,
615 CommitEntry64b& expected_entry,
747 std::unique_ptr<std::atomic<CommitEntry64b>[]> commit_cache_;
|
| H A D | write_prepared_txn_db.cc | 401 commit_cache_ = std::unique_ptr<std::atomic<CommitEntry64b>[]>( in Init()
402 new std::atomic<CommitEntry64b>[COMMIT_CACHE_SIZE] {}); in Init()
482 CommitEntry64b evicted_64b; in AddCommitted()
579 CommitEntry64b* entry_64b, in GetCommitEntry()
589 CommitEntry64b new_entry_64b(new_entry, FORMAT); in AddCommitEntry()
590 CommitEntry64b evicted_entry_64b = commit_cache_[static_cast<size_t>(indexed_seq)].exchange( in AddCommitEntry()
597 CommitEntry64b& expected_entry_64b, in ExchangeCommitEntry()
600 CommitEntry64b new_entry_64b(new_entry, FORMAT); in ExchangeCommitEntry()
|
| /dports/databases/mariadb104-server/mariadb-10.4.24/storage/rocksdb/rocksdb/utilities/transactions/ |
| H A D | write_prepared_txn_db.h | 160 CommitEntry64b dont_care;
382 struct CommitEntry64b { struct
383 constexpr CommitEntry64b() noexcept : rep_(0) {} in CommitEntry64b() argument
385 CommitEntry64b(const CommitEntry& entry, const CommitEntry64bFormat& format) in CommitEntry64b() argument
386 : CommitEntry64b(entry.prep_seq, entry.commit_seq, format) {} in CommitEntry64b()
388 CommitEntry64b(const uint64_t ps, const uint64_t cs, in CommitEntry64b() function
602 bool GetCommitEntry(const uint64_t indexed_seq, CommitEntry64b* entry_64b,
615 CommitEntry64b& expected_entry,
747 std::unique_ptr<std::atomic<CommitEntry64b>[]> commit_cache_;
|
| H A D | write_prepared_txn_db.cc | 401 commit_cache_ = std::unique_ptr<std::atomic<CommitEntry64b>[]>( in Init()
402 new std::atomic<CommitEntry64b>[COMMIT_CACHE_SIZE] {}); in Init()
482 CommitEntry64b evicted_64b; in AddCommitted()
579 CommitEntry64b* entry_64b, in GetCommitEntry()
589 CommitEntry64b new_entry_64b(new_entry, FORMAT); in AddCommitEntry()
590 CommitEntry64b evicted_entry_64b = commit_cache_[static_cast<size_t>(indexed_seq)].exchange( in AddCommitEntry()
597 CommitEntry64b& expected_entry_64b, in ExchangeCommitEntry()
600 CommitEntry64b new_entry_64b(new_entry, FORMAT); in ExchangeCommitEntry()
|
| /dports/databases/mariadb103-client/mariadb-10.3.34/storage/rocksdb/rocksdb/utilities/transactions/ |
| H A D | write_prepared_txn_db.h | 160 CommitEntry64b dont_care;
382 struct CommitEntry64b { struct
383 constexpr CommitEntry64b() noexcept : rep_(0) {} in CommitEntry64b() function
385 CommitEntry64b(const CommitEntry& entry, const CommitEntry64bFormat& format) in CommitEntry64b() argument
386 : CommitEntry64b(entry.prep_seq, entry.commit_seq, format) {} in CommitEntry64b()
388 CommitEntry64b(const uint64_t ps, const uint64_t cs, in CommitEntry64b() function
602 bool GetCommitEntry(const uint64_t indexed_seq, CommitEntry64b* entry_64b,
615 CommitEntry64b& expected_entry,
747 std::unique_ptr<std::atomic<CommitEntry64b>[]> commit_cache_;
|
| H A D | write_prepared_txn_db.cc | 401 commit_cache_ = std::unique_ptr<std::atomic<CommitEntry64b>[]>( in Init()
402 new std::atomic<CommitEntry64b>[COMMIT_CACHE_SIZE] {}); in Init()
482 CommitEntry64b evicted_64b; in AddCommitted()
579 CommitEntry64b* entry_64b, in GetCommitEntry()
589 CommitEntry64b new_entry_64b(new_entry, FORMAT); in AddCommitEntry()
590 CommitEntry64b evicted_entry_64b = commit_cache_[static_cast<size_t>(indexed_seq)].exchange( in AddCommitEntry()
597 CommitEntry64b& expected_entry_64b, in ExchangeCommitEntry()
600 CommitEntry64b new_entry_64b(new_entry, FORMAT); in ExchangeCommitEntry()
|
| /dports/databases/mariadb103-server/mariadb-10.3.34/storage/rocksdb/rocksdb/utilities/transactions/ |
| H A D | write_prepared_txn_db.h | 160 CommitEntry64b dont_care;
382 struct CommitEntry64b { struct
383 constexpr CommitEntry64b() noexcept : rep_(0) {} in CommitEntry64b() function
385 CommitEntry64b(const CommitEntry& entry, const CommitEntry64bFormat& format) in CommitEntry64b() function
386 : CommitEntry64b(entry.prep_seq, entry.commit_seq, format) {} in CommitEntry64b()
388 CommitEntry64b(const uint64_t ps, const uint64_t cs, in CommitEntry64b() function
602 bool GetCommitEntry(const uint64_t indexed_seq, CommitEntry64b* entry_64b,
615 CommitEntry64b& expected_entry,
747 std::unique_ptr<std::atomic<CommitEntry64b>[]> commit_cache_;
|
| H A D | write_prepared_txn_db.cc | 401 commit_cache_ = std::unique_ptr<std::atomic<CommitEntry64b>[]>( in Init()
402 new std::atomic<CommitEntry64b>[COMMIT_CACHE_SIZE] {}); in Init()
482 CommitEntry64b evicted_64b; in AddCommitted()
579 CommitEntry64b* entry_64b, in GetCommitEntry()
589 CommitEntry64b new_entry_64b(new_entry, FORMAT); in AddCommitEntry()
590 CommitEntry64b evicted_entry_64b = commit_cache_[static_cast<size_t>(indexed_seq)].exchange( in AddCommitEntry()
597 CommitEntry64b& expected_entry_64b, in ExchangeCommitEntry()
600 CommitEntry64b new_entry_64b(new_entry, FORMAT); in ExchangeCommitEntry()
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/rocksdb/rocksdb/utilities/transactions/ |
| H A D | write_prepared_txn_db.h | 160 CommitEntry64b dont_care;
382 struct CommitEntry64b { struct
383 constexpr CommitEntry64b() noexcept : rep_(0) {} in CommitEntry64b() argument
385 CommitEntry64b(const CommitEntry& entry, const CommitEntry64bFormat& format) in CommitEntry64b() function
386 : CommitEntry64b(entry.prep_seq, entry.commit_seq, format) {} in CommitEntry64b()
388 CommitEntry64b(const uint64_t ps, const uint64_t cs, in CommitEntry64b() function
602 bool GetCommitEntry(const uint64_t indexed_seq, CommitEntry64b* entry_64b,
615 CommitEntry64b& expected_entry,
747 std::unique_ptr<std::atomic<CommitEntry64b>[]> commit_cache_;
|
| H A D | write_prepared_txn_db.cc | 401 commit_cache_ = std::unique_ptr<std::atomic<CommitEntry64b>[]>( in Init()
402 new std::atomic<CommitEntry64b>[COMMIT_CACHE_SIZE] {}); in Init()
482 CommitEntry64b evicted_64b; in AddCommitted()
579 CommitEntry64b* entry_64b, in GetCommitEntry()
589 CommitEntry64b new_entry_64b(new_entry, FORMAT); in AddCommitEntry()
590 CommitEntry64b evicted_entry_64b = commit_cache_[static_cast<size_t>(indexed_seq)].exchange( in AddCommitEntry()
597 CommitEntry64b& expected_entry_64b, in ExchangeCommitEntry()
600 CommitEntry64b new_entry_64b(new_entry, FORMAT); in ExchangeCommitEntry()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/rocksdb/rocksdb/utilities/transactions/ |
| H A D | write_prepared_txn_db.h | 160 CommitEntry64b dont_care;
382 struct CommitEntry64b { struct
383 constexpr CommitEntry64b() noexcept : rep_(0) {} in CommitEntry64b() function
385 CommitEntry64b(const CommitEntry& entry, const CommitEntry64bFormat& format) in CommitEntry64b() argument
386 : CommitEntry64b(entry.prep_seq, entry.commit_seq, format) {} in CommitEntry64b()
388 CommitEntry64b(const uint64_t ps, const uint64_t cs, in CommitEntry64b() function
602 bool GetCommitEntry(const uint64_t indexed_seq, CommitEntry64b* entry_64b,
615 CommitEntry64b& expected_entry,
747 std::unique_ptr<std::atomic<CommitEntry64b>[]> commit_cache_;
|
| H A D | write_prepared_txn_db.cc | 401 commit_cache_ = std::unique_ptr<std::atomic<CommitEntry64b>[]>( in Init()
402 new std::atomic<CommitEntry64b>[COMMIT_CACHE_SIZE] {}); in Init()
482 CommitEntry64b evicted_64b; in AddCommitted()
579 CommitEntry64b* entry_64b, in GetCommitEntry()
589 CommitEntry64b new_entry_64b(new_entry, FORMAT); in AddCommitEntry()
590 CommitEntry64b evicted_entry_64b = commit_cache_[static_cast<size_t>(indexed_seq)].exchange( in AddCommitEntry()
597 CommitEntry64b& expected_entry_64b, in ExchangeCommitEntry()
600 CommitEntry64b new_entry_64b(new_entry, FORMAT); in ExchangeCommitEntry()
|