Searched refs:snapshot_seq (Results 1 – 7 of 7) sorted by relevance
| /rocksdb-6.9/utilities/transactions/ |
| 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 …]
|
| 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 …]
|
| D | write_unprepared_txn_db.cc | 391 SequenceNumber snapshot_seq = kMaxSequenceNumber; in NewIterator() local
432 snapshot_seq = snapshot->GetSequenceNumber(); in NewIterator()
433 assert(snapshot_seq != kMaxSequenceNumber); in NewIterator()
459 new IteratorState(this, snapshot_seq, own_snapshot, min_uncommitted, txn); in NewIterator()
|
| D | write_unprepared_txn.h | 92 SequenceNumber snapshot_seq) { in CalcMaxVisibleSeq() argument
98 return std::max(max_unprepared, snapshot_seq); in CalcMaxVisibleSeq()
|
| /rocksdb-6.9/db/ |
| 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()
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction_iterator_test.cc | 192 SequenceNumber seq, SequenceNumber snapshot_seq) const override { in CheckInSnapshot()
193 if (snapshot_seq == kMaxSequenceNumber) { in CheckInSnapshot()
198 assert(snapshots_.count(snapshot_seq) > 0); in CheckInSnapshot()
199 return seq <= snapshots_.at(snapshot_seq) in CheckInSnapshot()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl.cc | 2707 auto snapshot_seq = last_seq_same_as_publish_seq_ in GetSnapshotImpl() local
2711 snapshots_.New(s, snapshot_seq, unix_time, is_write_conflict_boundary); in GetSnapshotImpl()
|