Home
last modified time | relevance | path

Searched refs:snapshot_seq (Results 1 – 25 of 84) sorted by relevance

1234

/dports/databases/percona57-server/percona-server-5.7.36-39/storage/rocksdb/rocksdb/utilities/transactions/
H A Dwrite_prepared_txn_db.h131 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 Dwrite_prepared_txn_db.cc328 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 Dwrite_prepared_txn_db.h131 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 Dwrite_prepared_txn_db.cc328 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 Dwrite_prepared_txn_db.h132 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 Dwrite_prepared_txn_db.cc329 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 Dwrite_prepared_txn_db.h132 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 Dwrite_prepared_txn_db.cc329 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 Dwrite_prepared_txn_db.h131 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 Dwrite_prepared_txn_db.cc328 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 Dwrite_prepared_txn_db.h132 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 Dwrite_prepared_txn_db.cc326 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 Dwrite_prepared_txn_db.h132 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 Dwrite_prepared_txn_db.cc326 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 Dwrite_prepared_txn_db.h132 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 Dwrite_prepared_txn_db.cc326 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 Dwrite_prepared_txn_db.h132 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 Dwrite_prepared_txn_db.cc326 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 Dwrite_prepared_txn_db.h132 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 Dwrite_prepared_txn_db.cc326 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 Dwrite_prepared_txn_db.h132 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 Dwrite_prepared_txn_db.cc326 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 Dwrite_prepared_txn_db.h132 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 Dwrite_prepared_txn_db.cc326 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 Ddb_merge_operator_test.cc20 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()

1234