Home
last modified time | relevance | path

Searched refs:earliest_snapshot_ (Results 1 – 24 of 24) sorted by relevance

/dports/textproc/sonic/sonic-1.3.0/cargo-crates/librocksdb-sys-6.7.4/rocksdb/db/compaction/
H A Dcompaction_iterator.cc28 ((seq) <= earliest_snapshot_ && \
98 earliest_snapshot_ = kMaxSequenceNumber; in CompactionIterator()
103 earliest_snapshot_ = snapshots_->at(0); in CompactionIterator()
341 ? earliest_snapshot_ in NextFromInput()
741 bool pre_condition = (earliest_snapshot_ == kMaxSequenceNumber || in IsInEarliestSnapshot()
743 *earliest_snapshot_iter_ == earliest_snapshot_)); in IsInEarliestSnapshot()
750 snapshot_checker_->CheckInSnapshot(sequence, earliest_snapshot_); in IsInEarliestSnapshot()
755 released_snapshots_.insert(earliest_snapshot_); in IsInEarliestSnapshot()
759 earliest_snapshot_ = kMaxSequenceNumber; in IsInEarliestSnapshot()
761 earliest_snapshot_ = *earliest_snapshot_iter_; in IsInEarliestSnapshot()
[all …]
H A Dcompaction_iterator.h173 SequenceNumber earliest_snapshot_; variable
/dports/databases/mariadb104-server/mariadb-10.4.24/storage/rocksdb/rocksdb/db/compaction/
H A Dcompaction_iterator.cc28 ((seq) <= earliest_snapshot_ && \
98 earliest_snapshot_ = kMaxSequenceNumber; in CompactionIterator()
103 earliest_snapshot_ = snapshots_->at(0); in CompactionIterator()
341 ? earliest_snapshot_ in NextFromInput()
741 bool pre_condition = (earliest_snapshot_ == kMaxSequenceNumber || in IsInEarliestSnapshot()
743 *earliest_snapshot_iter_ == earliest_snapshot_)); in IsInEarliestSnapshot()
750 snapshot_checker_->CheckInSnapshot(sequence, earliest_snapshot_); in IsInEarliestSnapshot()
755 released_snapshots_.insert(earliest_snapshot_); in IsInEarliestSnapshot()
759 earliest_snapshot_ = kMaxSequenceNumber; in IsInEarliestSnapshot()
761 earliest_snapshot_ = *earliest_snapshot_iter_; in IsInEarliestSnapshot()
[all …]
H A Dcompaction_iterator.h173 SequenceNumber earliest_snapshot_; variable
/dports/databases/mariadb104-client/mariadb-10.4.24/storage/rocksdb/rocksdb/db/compaction/
H A Dcompaction_iterator.cc28 ((seq) <= earliest_snapshot_ && \
98 earliest_snapshot_ = kMaxSequenceNumber; in CompactionIterator()
103 earliest_snapshot_ = snapshots_->at(0); in CompactionIterator()
341 ? earliest_snapshot_ in NextFromInput()
741 bool pre_condition = (earliest_snapshot_ == kMaxSequenceNumber || in IsInEarliestSnapshot()
743 *earliest_snapshot_iter_ == earliest_snapshot_)); in IsInEarliestSnapshot()
750 snapshot_checker_->CheckInSnapshot(sequence, earliest_snapshot_); in IsInEarliestSnapshot()
755 released_snapshots_.insert(earliest_snapshot_); in IsInEarliestSnapshot()
759 earliest_snapshot_ = kMaxSequenceNumber; in IsInEarliestSnapshot()
761 earliest_snapshot_ = *earliest_snapshot_iter_; in IsInEarliestSnapshot()
[all …]
H A Dcompaction_iterator.h173 SequenceNumber earliest_snapshot_; variable
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/rocksdb/rocksdb/db/compaction/
H A Dcompaction_iterator.cc28 ((seq) <= earliest_snapshot_ && \
98 earliest_snapshot_ = kMaxSequenceNumber; in CompactionIterator()
103 earliest_snapshot_ = snapshots_->at(0); in CompactionIterator()
341 ? earliest_snapshot_ in NextFromInput()
741 bool pre_condition = (earliest_snapshot_ == kMaxSequenceNumber || in IsInEarliestSnapshot()
743 *earliest_snapshot_iter_ == earliest_snapshot_)); in IsInEarliestSnapshot()
750 snapshot_checker_->CheckInSnapshot(sequence, earliest_snapshot_); in IsInEarliestSnapshot()
755 released_snapshots_.insert(earliest_snapshot_); in IsInEarliestSnapshot()
759 earliest_snapshot_ = kMaxSequenceNumber; in IsInEarliestSnapshot()
761 earliest_snapshot_ = *earliest_snapshot_iter_; in IsInEarliestSnapshot()
[all …]
H A Dcompaction_iterator.h173 SequenceNumber earliest_snapshot_; variable
/dports/databases/mariadb103-client/mariadb-10.3.34/storage/rocksdb/rocksdb/db/compaction/
H A Dcompaction_iterator.cc28 ((seq) <= earliest_snapshot_ && \
98 earliest_snapshot_ = kMaxSequenceNumber; in CompactionIterator()
103 earliest_snapshot_ = snapshots_->at(0); in CompactionIterator()
341 ? earliest_snapshot_ in NextFromInput()
741 bool pre_condition = (earliest_snapshot_ == kMaxSequenceNumber || in IsInEarliestSnapshot()
743 *earliest_snapshot_iter_ == earliest_snapshot_)); in IsInEarliestSnapshot()
750 snapshot_checker_->CheckInSnapshot(sequence, earliest_snapshot_); in IsInEarliestSnapshot()
755 released_snapshots_.insert(earliest_snapshot_); in IsInEarliestSnapshot()
759 earliest_snapshot_ = kMaxSequenceNumber; in IsInEarliestSnapshot()
761 earliest_snapshot_ = *earliest_snapshot_iter_; in IsInEarliestSnapshot()
[all …]
H A Dcompaction_iterator.h173 SequenceNumber earliest_snapshot_; in new()
/dports/databases/mariadb103-server/mariadb-10.3.34/storage/rocksdb/rocksdb/db/compaction/
H A Dcompaction_iterator.cc28 ((seq) <= earliest_snapshot_ && \
98 earliest_snapshot_ = kMaxSequenceNumber;
103 earliest_snapshot_ = snapshots_->at(0);
341 ? earliest_snapshot_
741 bool pre_condition = (earliest_snapshot_ == kMaxSequenceNumber ||
743 *earliest_snapshot_iter_ == earliest_snapshot_));
750 snapshot_checker_->CheckInSnapshot(sequence, earliest_snapshot_);
755 released_snapshots_.insert(earliest_snapshot_);
759 earliest_snapshot_ = kMaxSequenceNumber;
761 earliest_snapshot_ = *earliest_snapshot_iter_;
[all …]
H A Dcompaction_iterator.h173 SequenceNumber earliest_snapshot_; variable
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/rocksdb/rocksdb/db/compaction/
H A Dcompaction_iterator.cc28 ((seq) <= earliest_snapshot_ && \
98 earliest_snapshot_ = kMaxSequenceNumber; in CompactionIterator()
103 earliest_snapshot_ = snapshots_->at(0); in CompactionIterator()
341 ? earliest_snapshot_ in NextFromInput()
741 bool pre_condition = (earliest_snapshot_ == kMaxSequenceNumber || in IsInEarliestSnapshot()
743 *earliest_snapshot_iter_ == earliest_snapshot_)); in IsInEarliestSnapshot()
750 snapshot_checker_->CheckInSnapshot(sequence, earliest_snapshot_); in IsInEarliestSnapshot()
755 released_snapshots_.insert(earliest_snapshot_); in IsInEarliestSnapshot()
759 earliest_snapshot_ = kMaxSequenceNumber; in IsInEarliestSnapshot()
761 earliest_snapshot_ = *earliest_snapshot_iter_; in IsInEarliestSnapshot()
[all …]
H A Dcompaction_iterator.h173 SequenceNumber earliest_snapshot_; variable
/dports/databases/rocksdb-lite/rocksdb-6.26.1/db/compaction/
H A Dcompaction_iterator.cc106 earliest_snapshot_ = kMaxSequenceNumber; in CompactionIterator()
111 earliest_snapshot_ = snapshots_->at(0); in CompactionIterator()
484 ? earliest_snapshot_ in NextFromInput()
653 DefinitelyInSnapshot(ikey_.sequence, earliest_snapshot_) && in NextFromInput()
1006 DefinitelyInSnapshot(ikey_.sequence, earliest_snapshot_) && in PrepareOutput()
1089 bool pre_condition = (earliest_snapshot_ == kMaxSequenceNumber || in IsInCurrentEarliestSnapshot()
1098 snapshot_checker_->CheckInSnapshot(sequence, earliest_snapshot_); in IsInCurrentEarliestSnapshot()
1103 released_snapshots_.insert(earliest_snapshot_); in IsInCurrentEarliestSnapshot()
1107 earliest_snapshot_ = kMaxSequenceNumber; in IsInCurrentEarliestSnapshot()
1109 earliest_snapshot_ = *earliest_snapshot_iter_; in IsInCurrentEarliestSnapshot()
[all …]
H A Dcompaction_iterator.h327 SequenceNumber earliest_snapshot_; variable
443 return ((seq) <= earliest_snapshot_ && in InCurrentEarliestSnapshot()
/dports/databases/rocksdb/rocksdb-6.26.1/db/compaction/
H A Dcompaction_iterator.cc106 earliest_snapshot_ = kMaxSequenceNumber; in CompactionIterator()
111 earliest_snapshot_ = snapshots_->at(0); in CompactionIterator()
484 ? earliest_snapshot_ in NextFromInput()
653 DefinitelyInSnapshot(ikey_.sequence, earliest_snapshot_) && in NextFromInput()
1006 DefinitelyInSnapshot(ikey_.sequence, earliest_snapshot_) && in PrepareOutput()
1089 bool pre_condition = (earliest_snapshot_ == kMaxSequenceNumber || in IsInCurrentEarliestSnapshot()
1098 snapshot_checker_->CheckInSnapshot(sequence, earliest_snapshot_); in IsInCurrentEarliestSnapshot()
1103 released_snapshots_.insert(earliest_snapshot_); in IsInCurrentEarliestSnapshot()
1107 earliest_snapshot_ = kMaxSequenceNumber; in IsInCurrentEarliestSnapshot()
1109 earliest_snapshot_ = *earliest_snapshot_iter_; in IsInCurrentEarliestSnapshot()
[all …]
H A Dcompaction_iterator.h327 SequenceNumber earliest_snapshot_; variable
443 return ((seq) <= earliest_snapshot_ && in InCurrentEarliestSnapshot()
/dports/databases/percona57-server/percona-server-5.7.36-39/storage/rocksdb/rocksdb/db/compaction/
H A Dcompaction_iterator.cc32 ((seq) <= earliest_snapshot_ && \
119 earliest_snapshot_ = kMaxSequenceNumber; in CompactionIterator()
124 earliest_snapshot_ = snapshots_->at(0); in CompactionIterator()
497 ? earliest_snapshot_ in NextFromInput()
1054 bool pre_condition = (earliest_snapshot_ == kMaxSequenceNumber || in IsInEarliestSnapshot()
1056 *earliest_snapshot_iter_ == earliest_snapshot_)); in IsInEarliestSnapshot()
1063 snapshot_checker_->CheckInSnapshot(sequence, earliest_snapshot_); in IsInEarliestSnapshot()
1068 released_snapshots_.insert(earliest_snapshot_); in IsInEarliestSnapshot()
1072 earliest_snapshot_ = kMaxSequenceNumber; in IsInEarliestSnapshot()
1074 earliest_snapshot_ = *earliest_snapshot_iter_; in IsInEarliestSnapshot()
[all …]
H A Dcompaction_iterator.h310 SequenceNumber earliest_snapshot_; variable
/dports/databases/percona57-client/percona-server-5.7.36-39/storage/rocksdb/rocksdb/db/compaction/
H A Dcompaction_iterator.cc32 ((seq) <= earliest_snapshot_ && \
119 earliest_snapshot_ = kMaxSequenceNumber; in CompactionIterator()
124 earliest_snapshot_ = snapshots_->at(0); in CompactionIterator()
497 ? earliest_snapshot_ in NextFromInput()
1054 bool pre_condition = (earliest_snapshot_ == kMaxSequenceNumber || in IsInEarliestSnapshot()
1056 *earliest_snapshot_iter_ == earliest_snapshot_)); in IsInEarliestSnapshot()
1063 snapshot_checker_->CheckInSnapshot(sequence, earliest_snapshot_); in IsInEarliestSnapshot()
1068 released_snapshots_.insert(earliest_snapshot_); in IsInEarliestSnapshot()
1072 earliest_snapshot_ = kMaxSequenceNumber; in IsInEarliestSnapshot()
1074 earliest_snapshot_ = *earliest_snapshot_iter_; in IsInEarliestSnapshot()
[all …]
H A Dcompaction_iterator.h310 SequenceNumber earliest_snapshot_; variable
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/rocksdb/rocksdb/db/compaction/
H A Dcompaction_iterator.cc32 ((seq) <= earliest_snapshot_ && \
119 earliest_snapshot_ = kMaxSequenceNumber; in CompactionIterator()
124 earliest_snapshot_ = snapshots_->at(0); in CompactionIterator()
497 ? earliest_snapshot_ in NextFromInput()
1054 bool pre_condition = (earliest_snapshot_ == kMaxSequenceNumber || in IsInEarliestSnapshot()
1056 *earliest_snapshot_iter_ == earliest_snapshot_)); in IsInEarliestSnapshot()
1063 snapshot_checker_->CheckInSnapshot(sequence, earliest_snapshot_); in IsInEarliestSnapshot()
1068 released_snapshots_.insert(earliest_snapshot_); in IsInEarliestSnapshot()
1072 earliest_snapshot_ = kMaxSequenceNumber; in IsInEarliestSnapshot()
1074 earliest_snapshot_ = *earliest_snapshot_iter_; in IsInEarliestSnapshot()
[all …]
H A Dcompaction_iterator.h310 SequenceNumber earliest_snapshot_; variable