/dports/databases/percona57-server/percona-server-5.7.36-39/storage/rocksdb/rocksdb/utilities/transactions/ |
H A D | write_prepared_txn_db.h | 131 prep_seq, snapshot_seq, 1); 134 if (snapshot_seq < prep_seq) { 138 prep_seq, snapshot_seq, 0); 189 prep_seq, snapshot_seq, cached.commit_seq <= snapshot_seq); 190 return cached.commit_seq <= snapshot_seq; 208 prep_seq, snapshot_seq, 0); 239 return it->second <= snapshot_seq; 248 prep_seq, snapshot_seq, cached.commit_seq <= snapshot_seq); 267 prep_seq, snapshot_seq, 1); 277 prep_seq, snapshot_seq, 0); [all …]
|
H A D | write_prepared_txn_db.cc | 328 SequenceNumber snapshot_seq = kMaxSequenceNumber; in NewIterator() local 339 snapshot_seq = snapshot->GetSequenceNumber(); in NewIterator() 344 assert(snapshot_seq != kMaxSequenceNumber); in NewIterator() 363 SequenceNumber snapshot_seq = kMaxSequenceNumber; in NewIterators() local 374 snapshot_seq = snapshot->GetSequenceNumber(); in NewIterators() 889 SequenceNumber snapshot_seq = in CheckAgainstSnapshots() local 925 SequenceNumber snapshot_seq = in CheckAgainstSnapshots() local 947 if (commit_seq <= snapshot_seq) { in MaybeUpdateOldCommitMap() 952 if (prep_seq <= snapshot_seq) { // overlapping range in MaybeUpdateOldCommitMap() 957 snapshot_seq, prep_seq, commit_seq); in MaybeUpdateOldCommitMap() [all …]
|
/dports/databases/percona57-client/percona-server-5.7.36-39/storage/rocksdb/rocksdb/utilities/transactions/ |
H A D | write_prepared_txn_db.h | 131 prep_seq, snapshot_seq, 1); 134 if (snapshot_seq < prep_seq) { 138 prep_seq, snapshot_seq, 0); 189 prep_seq, snapshot_seq, cached.commit_seq <= snapshot_seq); 190 return cached.commit_seq <= snapshot_seq; 208 prep_seq, snapshot_seq, 0); 239 return it->second <= snapshot_seq; 248 prep_seq, snapshot_seq, cached.commit_seq <= snapshot_seq); 267 prep_seq, snapshot_seq, 1); 277 prep_seq, snapshot_seq, 0); [all …]
|
H A D | write_prepared_txn_db.cc | 328 SequenceNumber snapshot_seq = kMaxSequenceNumber; in NewIterator() local 339 snapshot_seq = snapshot->GetSequenceNumber(); in NewIterator() 344 assert(snapshot_seq != kMaxSequenceNumber); in NewIterator() 363 SequenceNumber snapshot_seq = kMaxSequenceNumber; in NewIterators() local 374 snapshot_seq = snapshot->GetSequenceNumber(); in NewIterators() 889 SequenceNumber snapshot_seq = in CheckAgainstSnapshots() local 925 SequenceNumber snapshot_seq = in CheckAgainstSnapshots() local 947 if (commit_seq <= snapshot_seq) { in MaybeUpdateOldCommitMap() 952 if (prep_seq <= snapshot_seq) { // overlapping range in MaybeUpdateOldCommitMap() 957 snapshot_seq, prep_seq, commit_seq); in MaybeUpdateOldCommitMap() [all …]
|
/dports/databases/rocksdb/rocksdb-6.26.1/utilities/transactions/ |
H A D | write_prepared_txn_db.h | 132 prep_seq, snapshot_seq, 1); 135 if (snapshot_seq < prep_seq) { 139 prep_seq, snapshot_seq, 0); 190 prep_seq, snapshot_seq, cached.commit_seq <= snapshot_seq); 191 return cached.commit_seq <= snapshot_seq; 209 prep_seq, snapshot_seq, 0); 240 return it->second <= snapshot_seq; 249 prep_seq, snapshot_seq, cached.commit_seq <= snapshot_seq); 268 prep_seq, snapshot_seq, 1); 278 prep_seq, snapshot_seq, 0); [all …]
|
H A D | write_prepared_txn_db.cc | 329 SequenceNumber snapshot_seq = kMaxSequenceNumber; in NewIterator() local 340 snapshot_seq = snapshot->GetSequenceNumber(); in NewIterator() 345 assert(snapshot_seq != kMaxSequenceNumber); in NewIterator() 364 SequenceNumber snapshot_seq = kMaxSequenceNumber; in NewIterators() local 375 snapshot_seq = snapshot->GetSequenceNumber(); in NewIterators() 888 SequenceNumber snapshot_seq = in CheckAgainstSnapshots() local 924 SequenceNumber snapshot_seq = in CheckAgainstSnapshots() local 946 if (commit_seq <= snapshot_seq) { in MaybeUpdateOldCommitMap() 951 if (prep_seq <= snapshot_seq) { // overlapping range in MaybeUpdateOldCommitMap() 956 snapshot_seq, prep_seq, commit_seq); in MaybeUpdateOldCommitMap() [all …]
|
/dports/databases/rocksdb-lite/rocksdb-6.26.1/utilities/transactions/ |
H A D | write_prepared_txn_db.h | 132 prep_seq, snapshot_seq, 1); 135 if (snapshot_seq < prep_seq) { 139 prep_seq, snapshot_seq, 0); 190 prep_seq, snapshot_seq, cached.commit_seq <= snapshot_seq); 191 return cached.commit_seq <= snapshot_seq; 209 prep_seq, snapshot_seq, 0); 240 return it->second <= snapshot_seq; 249 prep_seq, snapshot_seq, cached.commit_seq <= snapshot_seq); 268 prep_seq, snapshot_seq, 1); 278 prep_seq, snapshot_seq, 0); [all …]
|
H A D | write_prepared_txn_db.cc | 329 SequenceNumber snapshot_seq = kMaxSequenceNumber; in NewIterator() local 340 snapshot_seq = snapshot->GetSequenceNumber(); in NewIterator() 345 assert(snapshot_seq != kMaxSequenceNumber); in NewIterator() 364 SequenceNumber snapshot_seq = kMaxSequenceNumber; in NewIterators() local 375 snapshot_seq = snapshot->GetSequenceNumber(); in NewIterators() 888 SequenceNumber snapshot_seq = in CheckAgainstSnapshots() local 924 SequenceNumber snapshot_seq = in CheckAgainstSnapshots() local 946 if (commit_seq <= snapshot_seq) { in MaybeUpdateOldCommitMap() 951 if (prep_seq <= snapshot_seq) { // overlapping range in MaybeUpdateOldCommitMap() 956 snapshot_seq, prep_seq, commit_seq); in MaybeUpdateOldCommitMap() [all …]
|
/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 | 131 prep_seq, snapshot_seq, 1); 134 if (snapshot_seq < prep_seq) { 138 prep_seq, snapshot_seq, 0); 189 prep_seq, snapshot_seq, cached.commit_seq <= snapshot_seq); 190 return cached.commit_seq <= snapshot_seq; 208 prep_seq, snapshot_seq, 0); 239 return it->second <= snapshot_seq; 248 prep_seq, snapshot_seq, cached.commit_seq <= snapshot_seq); 267 prep_seq, snapshot_seq, 1); 277 prep_seq, snapshot_seq, 0); [all …]
|
H A D | write_prepared_txn_db.cc | 328 SequenceNumber snapshot_seq = kMaxSequenceNumber; in NewIterator() local 339 snapshot_seq = snapshot->GetSequenceNumber(); in NewIterator() 344 assert(snapshot_seq != kMaxSequenceNumber); in NewIterator() 363 SequenceNumber snapshot_seq = kMaxSequenceNumber; in NewIterators() local 374 snapshot_seq = snapshot->GetSequenceNumber(); in NewIterators() 889 SequenceNumber snapshot_seq = in CheckAgainstSnapshots() local 925 SequenceNumber snapshot_seq = in CheckAgainstSnapshots() local 947 if (commit_seq <= snapshot_seq) { in MaybeUpdateOldCommitMap() 952 if (prep_seq <= snapshot_seq) { // overlapping range in MaybeUpdateOldCommitMap() 957 snapshot_seq, prep_seq, commit_seq); in MaybeUpdateOldCommitMap() [all …]
|
/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 | 132 prep_seq, snapshot_seq, 1); 135 if (snapshot_seq < prep_seq) { 139 prep_seq, snapshot_seq, 0); 190 prep_seq, snapshot_seq, cached.commit_seq <= snapshot_seq); 191 return cached.commit_seq <= snapshot_seq; 209 prep_seq, snapshot_seq, 0); 240 return it->second <= snapshot_seq; 249 prep_seq, snapshot_seq, cached.commit_seq <= snapshot_seq); 268 prep_seq, snapshot_seq, 1); 278 prep_seq, snapshot_seq, 0); [all …]
|
H A D | write_prepared_txn_db.cc | 326 SequenceNumber snapshot_seq = kMaxSequenceNumber; in NewIterator() local 338 snapshot_seq = snapshot->GetSequenceNumber(); in NewIterator() 344 assert(snapshot_seq != kMaxSequenceNumber); in NewIterator() 362 SequenceNumber snapshot_seq = kMaxSequenceNumber; in NewIterators() local 373 snapshot_seq = snapshot->GetSequenceNumber(); in NewIterators() 888 SequenceNumber snapshot_seq = in CheckAgainstSnapshots() local 924 SequenceNumber snapshot_seq = in CheckAgainstSnapshots() local 946 if (commit_seq <= snapshot_seq) { in MaybeUpdateOldCommitMap() 951 if (prep_seq <= snapshot_seq) { // overlapping range in MaybeUpdateOldCommitMap() 956 snapshot_seq, prep_seq, commit_seq); in MaybeUpdateOldCommitMap() [all …]
|
/dports/databases/mariadb104-client/mariadb-10.4.24/storage/rocksdb/rocksdb/utilities/transactions/ |
H A D | write_prepared_txn_db.h | 132 prep_seq, snapshot_seq, 1); 135 if (snapshot_seq < prep_seq) { 139 prep_seq, snapshot_seq, 0); 190 prep_seq, snapshot_seq, cached.commit_seq <= snapshot_seq); 191 return cached.commit_seq <= snapshot_seq; 209 prep_seq, snapshot_seq, 0); 240 return it->second <= snapshot_seq; 249 prep_seq, snapshot_seq, cached.commit_seq <= snapshot_seq); 268 prep_seq, snapshot_seq, 1); 278 prep_seq, snapshot_seq, 0); [all …]
|
H A D | write_prepared_txn_db.cc | 326 SequenceNumber snapshot_seq = kMaxSequenceNumber; in NewIterator() local 338 snapshot_seq = snapshot->GetSequenceNumber(); in NewIterator() 344 assert(snapshot_seq != kMaxSequenceNumber); in NewIterator() 362 SequenceNumber snapshot_seq = kMaxSequenceNumber; in NewIterators() local 373 snapshot_seq = snapshot->GetSequenceNumber(); in NewIterators() 888 SequenceNumber snapshot_seq = in CheckAgainstSnapshots() local 924 SequenceNumber snapshot_seq = in CheckAgainstSnapshots() local 946 if (commit_seq <= snapshot_seq) { in MaybeUpdateOldCommitMap() 951 if (prep_seq <= snapshot_seq) { // overlapping range in MaybeUpdateOldCommitMap() 956 snapshot_seq, prep_seq, commit_seq); in MaybeUpdateOldCommitMap() [all …]
|
/dports/databases/mariadb104-server/mariadb-10.4.24/storage/rocksdb/rocksdb/utilities/transactions/ |
H A D | write_prepared_txn_db.h | 132 prep_seq, snapshot_seq, 1); 135 if (snapshot_seq < prep_seq) { 139 prep_seq, snapshot_seq, 0); 190 prep_seq, snapshot_seq, cached.commit_seq <= snapshot_seq); 191 return cached.commit_seq <= snapshot_seq; 209 prep_seq, snapshot_seq, 0); 240 return it->second <= snapshot_seq; 249 prep_seq, snapshot_seq, cached.commit_seq <= snapshot_seq); 268 prep_seq, snapshot_seq, 1); 278 prep_seq, snapshot_seq, 0); [all …]
|
H A D | write_prepared_txn_db.cc | 326 SequenceNumber snapshot_seq = kMaxSequenceNumber; in NewIterator() local 338 snapshot_seq = snapshot->GetSequenceNumber(); in NewIterator() 344 assert(snapshot_seq != kMaxSequenceNumber); in NewIterator() 362 SequenceNumber snapshot_seq = kMaxSequenceNumber; in NewIterators() local 373 snapshot_seq = snapshot->GetSequenceNumber(); in NewIterators() 888 SequenceNumber snapshot_seq = in CheckAgainstSnapshots() local 924 SequenceNumber snapshot_seq = in CheckAgainstSnapshots() local 946 if (commit_seq <= snapshot_seq) { in MaybeUpdateOldCommitMap() 951 if (prep_seq <= snapshot_seq) { // overlapping range in MaybeUpdateOldCommitMap() 956 snapshot_seq, prep_seq, commit_seq); in MaybeUpdateOldCommitMap() [all …]
|
/dports/databases/mariadb103-client/mariadb-10.3.34/storage/rocksdb/rocksdb/utilities/transactions/ |
H A D | write_prepared_txn_db.h | 132 prep_seq, snapshot_seq, 1); 135 if (snapshot_seq < prep_seq) { 139 prep_seq, snapshot_seq, 0); 190 prep_seq, snapshot_seq, cached.commit_seq <= snapshot_seq); 191 return cached.commit_seq <= snapshot_seq; 209 prep_seq, snapshot_seq, 0); 240 return it->second <= snapshot_seq; 249 prep_seq, snapshot_seq, cached.commit_seq <= snapshot_seq); 268 prep_seq, snapshot_seq, 1); 278 prep_seq, snapshot_seq, 0); [all …]
|
H A D | write_prepared_txn_db.cc | 326 SequenceNumber snapshot_seq = kMaxSequenceNumber; in NewIterator() local 338 snapshot_seq = snapshot->GetSequenceNumber(); in NewIterator() 344 assert(snapshot_seq != kMaxSequenceNumber); in NewIterator() 362 SequenceNumber snapshot_seq = kMaxSequenceNumber; in NewIterators() local 373 snapshot_seq = snapshot->GetSequenceNumber(); in NewIterators() 888 SequenceNumber snapshot_seq = in CheckAgainstSnapshots() local 924 SequenceNumber snapshot_seq = in CheckAgainstSnapshots() local 946 if (commit_seq <= snapshot_seq) { in MaybeUpdateOldCommitMap() 951 if (prep_seq <= snapshot_seq) { // overlapping range in MaybeUpdateOldCommitMap() 956 snapshot_seq, prep_seq, commit_seq); in MaybeUpdateOldCommitMap() [all …]
|
/dports/databases/mariadb103-server/mariadb-10.3.34/storage/rocksdb/rocksdb/utilities/transactions/ |
H A D | write_prepared_txn_db.h | 132 prep_seq, snapshot_seq, 1); 135 if (snapshot_seq < prep_seq) { 139 prep_seq, snapshot_seq, 0); 190 prep_seq, snapshot_seq, cached.commit_seq <= snapshot_seq); 191 return cached.commit_seq <= snapshot_seq; 209 prep_seq, snapshot_seq, 0); 240 return it->second <= snapshot_seq; 249 prep_seq, snapshot_seq, cached.commit_seq <= snapshot_seq); 268 prep_seq, snapshot_seq, 1); 278 prep_seq, snapshot_seq, 0); [all …]
|
H A D | write_prepared_txn_db.cc | 326 SequenceNumber snapshot_seq = kMaxSequenceNumber; in NewIterator() local 338 snapshot_seq = snapshot->GetSequenceNumber(); in NewIterator() 344 assert(snapshot_seq != kMaxSequenceNumber); in NewIterator() 362 SequenceNumber snapshot_seq = kMaxSequenceNumber; in NewIterators() local 373 snapshot_seq = snapshot->GetSequenceNumber(); in NewIterators() 888 SequenceNumber snapshot_seq = in CheckAgainstSnapshots() local 924 SequenceNumber snapshot_seq = in CheckAgainstSnapshots() local 946 if (commit_seq <= snapshot_seq) { in MaybeUpdateOldCommitMap() 951 if (prep_seq <= snapshot_seq) { // overlapping range in MaybeUpdateOldCommitMap() 956 snapshot_seq, prep_seq, commit_seq); in MaybeUpdateOldCommitMap() [all …]
|
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/rocksdb/rocksdb/utilities/transactions/ |
H A D | write_prepared_txn_db.h | 132 prep_seq, snapshot_seq, 1); 135 if (snapshot_seq < prep_seq) { 139 prep_seq, snapshot_seq, 0); 190 prep_seq, snapshot_seq, cached.commit_seq <= snapshot_seq); 191 return cached.commit_seq <= snapshot_seq; 209 prep_seq, snapshot_seq, 0); 240 return it->second <= snapshot_seq; 249 prep_seq, snapshot_seq, cached.commit_seq <= snapshot_seq); 268 prep_seq, snapshot_seq, 1); 278 prep_seq, snapshot_seq, 0); [all …]
|
H A D | write_prepared_txn_db.cc | 326 SequenceNumber snapshot_seq = kMaxSequenceNumber; in NewIterator() local 338 snapshot_seq = snapshot->GetSequenceNumber(); in NewIterator() 344 assert(snapshot_seq != kMaxSequenceNumber); in NewIterator() 362 SequenceNumber snapshot_seq = kMaxSequenceNumber; in NewIterators() local 373 snapshot_seq = snapshot->GetSequenceNumber(); in NewIterators() 888 SequenceNumber snapshot_seq = in CheckAgainstSnapshots() local 924 SequenceNumber snapshot_seq = in CheckAgainstSnapshots() local 946 if (commit_seq <= snapshot_seq) { in MaybeUpdateOldCommitMap() 951 if (prep_seq <= snapshot_seq) { // overlapping range in MaybeUpdateOldCommitMap() 956 snapshot_seq, prep_seq, commit_seq); in MaybeUpdateOldCommitMap() [all …]
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/rocksdb/rocksdb/utilities/transactions/ |
H A D | write_prepared_txn_db.h | 132 prep_seq, snapshot_seq, 1); 135 if (snapshot_seq < prep_seq) { 139 prep_seq, snapshot_seq, 0); 190 prep_seq, snapshot_seq, cached.commit_seq <= snapshot_seq); 191 return cached.commit_seq <= snapshot_seq; 209 prep_seq, snapshot_seq, 0); 240 return it->second <= snapshot_seq; 249 prep_seq, snapshot_seq, cached.commit_seq <= snapshot_seq); 268 prep_seq, snapshot_seq, 1); 278 prep_seq, snapshot_seq, 0); [all …]
|
H A D | write_prepared_txn_db.cc | 326 SequenceNumber snapshot_seq = kMaxSequenceNumber; in NewIterator() local 338 snapshot_seq = snapshot->GetSequenceNumber(); in NewIterator() 344 assert(snapshot_seq != kMaxSequenceNumber); in NewIterator() 362 SequenceNumber snapshot_seq = kMaxSequenceNumber; in NewIterators() local 373 snapshot_seq = snapshot->GetSequenceNumber(); in NewIterators() 888 SequenceNumber snapshot_seq = in CheckAgainstSnapshots() local 924 SequenceNumber snapshot_seq = in CheckAgainstSnapshots() local 946 if (commit_seq <= snapshot_seq) { in MaybeUpdateOldCommitMap() 951 if (prep_seq <= snapshot_seq) { // overlapping range in MaybeUpdateOldCommitMap() 956 snapshot_seq, prep_seq, commit_seq); in MaybeUpdateOldCommitMap() [all …]
|
/dports/textproc/sonic/sonic-1.3.0/cargo-crates/librocksdb-sys-6.7.4/rocksdb/db/ |
H A D | db_merge_operator_test.cc | 20 SequenceNumber snapshot_seq) in TestReadCallback() argument 21 : ReadCallback(snapshot_seq), in TestReadCallback() 23 snapshot_seq_(snapshot_seq) {} in TestReadCallback() 494 SequenceNumber seq, SequenceNumber snapshot_seq) const override { in TEST_F() 495 return IsInSnapshot(seq, snapshot_seq) in TEST_F() 500 bool IsInSnapshot(SequenceNumber seq, SequenceNumber snapshot_seq) const { in TEST_F() 501 switch (snapshot_seq) { in TEST_F()
|