| /rocksdb-6.9/db/compaction/ |
| D | compaction_iterator.h | 64 SequenceNumber last_sequence, std::vector<SequenceNumber>* snapshots,
65 SequenceNumber earliest_write_conflict_snapshot,
79 SequenceNumber last_sequence, std::vector<SequenceNumber>* snapshots,
132 inline SequenceNumber findEarliestVisibleSnapshot(
133 SequenceNumber in, SequenceNumber* prev_snapshot);
151 const std::vector<SequenceNumber>* snapshots_;
169 const SequenceNumber preserve_deletes_seqnum_;
173 SequenceNumber earliest_snapshot_;
174 SequenceNumber latest_snapshot_;
199 SequenceNumber current_user_key_sequence_;
[all …]
|
| D | compaction_iterator.cc | 35 SequenceNumber last_sequence, std::vector<SequenceNumber>* snapshots, in CompactionIterator()
36 SequenceNumber earliest_write_conflict_snapshot, in CompactionIterator()
42 const SequenceNumber preserve_deletes_seqnum, in CompactionIterator()
56 SequenceNumber /*last_sequence*/, std::vector<SequenceNumber>* snapshots, in CompactionIterator() argument
57 SequenceNumber earliest_write_conflict_snapshot, in CompactionIterator()
64 const SequenceNumber preserve_deletes_seqnum, in CompactionIterator()
334 SequenceNumber last_sequence __attribute__((__unused__)); in NextFromInput()
337 SequenceNumber last_snapshot = current_user_key_snapshot_; in NextFromInput()
338 SequenceNumber prev_snapshot = 0; // 0 means no previous snapshot in NextFromInput()
687 inline SequenceNumber CompactionIterator::findEarliestVisibleSnapshot( in findEarliestVisibleSnapshot()
[all …]
|
| D | compaction_job.h | 69 const SequenceNumber preserve_deletes_seqnum,
73 std::vector<SequenceNumber> existing_snapshots,
74 SequenceNumber earliest_write_conflict_snapshot,
165 const SequenceNumber preserve_deletes_seqnum_;
176 std::vector<SequenceNumber> existing_snapshots_;
181 SequenceNumber earliest_write_conflict_snapshot_;
|
| /rocksdb-6.9/db/ |
| D | range_tombstone_fragmenter.h | 43 const std::vector<SequenceNumber>& snapshots = {});
69 bool ContainsRange(SequenceNumber lower, SequenceNumber upper) const;
78 const std::vector<SequenceNumber>& snapshots);
81 std::vector<SequenceNumber> tombstone_seqs_;
82 std::set<SequenceNumber> seq_set_;
101 SequenceNumber lower_bound = 0);
105 SequenceNumber lower_bound = 0);
156 SequenceNumber seq() const { return *seq_pos_; } in seq()
247 SequenceNumber upper_bound_;
248 SequenceNumber lower_bound_;
[all …]
|
| D | range_tombstone_fragmenter.cc | 24 const std::vector<SequenceNumber>& snapshots) { in FragmentedRangeTombstoneList()
72 const std::vector<SequenceNumber>& snapshots) { in FragmentTombstones()
117 autovector<SequenceNumber> seqnums_to_flush; in FragmentTombstones()
122 std::greater<SequenceNumber>()); in FragmentTombstones()
129 SequenceNumber next_snapshot = kMaxSequenceNumber; in FragmentTombstones()
176 SequenceNumber tombstone_seq = GetInternalKeySeqno(ikey); in FragmentTombstones()
220 SequenceNumber _lower_bound) in FragmentedRangeTombstoneIterator()
235 SequenceNumber _lower_bound) in FragmentedRangeTombstoneIterator()
418 const std::vector<SequenceNumber>& snapshots) { in SplitBySnapshot()
421 SequenceNumber lower = 0; in SplitBySnapshot()
[all …]
|
| D | memtable.h | 213 SequenceNumber* max_covering_tombstone_seq, SequenceNumber* seq,
223 SequenceNumber* max_covering_tombstone_seq, SequenceNumber* seq,
232 SequenceNumber seq;
251 void Update(SequenceNumber seq,
267 bool UpdateCallback(SequenceNumber seq,
331 SequenceNumber GetFirstSequenceNumber() { in GetFirstSequenceNumber()
342 SequenceNumber GetEarliestSequenceNumber() { in GetEarliestSequenceNumber()
483 std::atomic<SequenceNumber> first_seqno_;
487 std::atomic<SequenceNumber> earliest_seqno_;
489 SequenceNumber creation_seq_;
[all …]
|
| D | snapshot_impl.h | 23 SequenceNumber number_; // const after creation
27 SequenceNumber min_uncommitted_ = kMinUnCommittedSeq;
90 std::vector<SequenceNumber> GetAll(
91 SequenceNumber* oldest_write_conflict_snapshot = nullptr,
92 const SequenceNumber& max_seq = kMaxSequenceNumber) const {
93 std::vector<SequenceNumber> ret;
98 void GetAll(std::vector<SequenceNumber>* snap_vector,
99 SequenceNumber* oldest_write_conflict_snapshot = nullptr,
100 const SequenceNumber& max_seq = kMaxSequenceNumber) const {
101 std::vector<SequenceNumber>& ret = *snap_vector;
[all …]
|
| D | read_callback.h | 14 ReadCallback(SequenceNumber last_visible_seq) in ReadCallback()
16 ReadCallback(SequenceNumber last_visible_seq, SequenceNumber min_uncommitted) in ReadCallback()
23 virtual bool IsVisibleFullCheck(SequenceNumber seq) = 0;
25 inline bool IsVisible(SequenceNumber seq) { in IsVisible()
40 inline SequenceNumber max_visible_seq() { return max_visible_seq_; } in max_visible_seq()
43 virtual void Refresh(SequenceNumber seq) { max_visible_seq_ = seq; } in Refresh()
48 SequenceNumber max_visible_seq_ = kMaxSequenceNumber;
50 const SequenceNumber min_uncommitted_ = kMinUnCommittedSeq;
|
| D | memtable_list.h | 63 SequenceNumber* max_covering_tombstone_seq, SequenceNumber* seq,
69 SequenceNumber* max_covering_tombstone_seq,
72 SequenceNumber seq;
85 SequenceNumber* max_covering_tombstone_seq,
95 SequenceNumber* max_covering_tombstone_seq,
96 SequenceNumber* seq, const ReadOptions& read_opts,
101 SequenceNumber* max_covering_tombstone_seq,
104 SequenceNumber seq;
156 SequenceNumber* max_covering_tombstone_seq,
157 SequenceNumber* seq, const ReadOptions& read_opts,
[all …]
|
| D | range_del_aggregator.h | 73 SequenceNumber seq() const { return iter_->seq(); } in seq()
76 SplitBySnapshot(const std::vector<SequenceNumber>& snapshots);
78 SequenceNumber upper_bound() const { return iter_->upper_bound(); } in upper_bound()
80 SequenceNumber lower_bound() const { return iter_->lower_bound(); } in lower_bound()
306 SequenceNumber lower_bound) in StripeRep()
332 bool InStripe(SequenceNumber seq) const { in InStripe()
344 SequenceNumber upper_bound_;
345 SequenceNumber lower_bound_;
357 SequenceNumber upper_bound) in ReadRangeDelAggregator()
436 std::map<SequenceNumber, StripeRep> reps_;
[all …]
|
| D | transaction_log_impl.h | 24 LogFileImpl(uint64_t logNum, WalFileType logType, SequenceNumber startSeq, in LogFileImpl()
43 SequenceNumber StartSequence() const override { return startSequence_; } in StartSequence()
54 SequenceNumber startSequence_;
64 const EnvOptions& soptions, const SequenceNumber seqNum,
81 SequenceNumber starting_sequence_number_;
103 SequenceNumber
105 SequenceNumber current_last_seq_; // last sequence in the current batch
121 bool IsBatchExpected(const WriteBatch* batch, SequenceNumber expected_seq);
|
| D | wal_manager.h | 53 SequenceNumber seq_number, std::unique_ptr<TransactionLogIterator>* iter,
66 SequenceNumber* sequence) { in TEST_ReadFirstRecord()
71 SequenceNumber* sequence) { in TEST_ReadFirstLine()
82 const SequenceNumber target);
85 SequenceNumber* sequence);
88 SequenceNumber* sequence);
98 std::unordered_map<uint64_t, SequenceNumber> read_first_record_cache_;
|
| D | snapshot_checker.h | 24 SequenceNumber sequence, SequenceNumber snapshot_sequence) const = 0;
31 SequenceNumber /*sequence*/, in CheckInSnapshot() argument
32 SequenceNumber /*snapshot_sequence*/) const override { in CheckInSnapshot()
53 SequenceNumber sequence, SequenceNumber snapshot_sequence) const override;
|
| D | version_edit.h | 47 SequenceNumber smallest_seqno; // The smallest seqno in this file
48 SequenceNumber largest_seqno; // The largest seqno in this file
56 SequenceNumber _smallest_seqno, SequenceNumber _largest_seqno) in FileDescriptor()
151 const SequenceNumber& smallest_seq, in FileMetaData()
152 const SequenceNumber& largest_seq, bool marked_for_compact, in FileMetaData()
171 SequenceNumber seqno, ValueType value_type);
176 const InternalKey& end, SequenceNumber seqno, in UpdateBoundariesForRange()
304 void SetLastSequence(SequenceNumber seq) { in SetLastSequence()
309 SequenceNumber GetLastSequence() const { return last_sequence_; } in GetLastSequence()
328 const SequenceNumber& largest_seqno, bool marked_for_compaction, in AddFile()
[all …]
|
| D | flush_job_test.cc | 77 SequenceNumber last_seq = 1; in NewDB()
167 new_mem->Add(SequenceNumber(i), kTypeValue, key, value); in TEST_F()
169 InternalKey internal_key(key, SequenceNumber(i), kTypeValue); in TEST_F()
202 const SequenceNumber seq(i + 10001); in TEST_F()
327 std::vector<SequenceNumber> smallest_seqs; in TEST_F()
328 std::vector<SequenceNumber> largest_seqs; in TEST_F()
330 SequenceNumber curr_seqno = 0; in TEST_F()
357 std::vector<SequenceNumber> snapshot_seqs; in TEST_F()
432 std::set<SequenceNumber> snapshots_set; in TEST_F()
441 std::vector<SequenceNumber> snapshots(snapshots_set.begin(), in TEST_F()
[all …]
|
| D | dbformat.h | 93 static const SequenceNumber kMaxSequenceNumber = ((0x1ull << 56) - 1);
101 SequenceNumber sequence;
108 ParsedInternalKey(const Slice& u, const SequenceNumber& seq, ValueType t) in ParsedInternalKey()
145 extern void AppendInternalKeyFooter(std::string* result, SequenceNumber s,
234 InternalKey(const Slice& _user_key, SequenceNumber s, ValueType t) { in InternalKey()
266 void Set(const Slice& _user_key, SequenceNumber s, ValueType t) { in Set()
283 void ConvertFromUserKey(SequenceNumber s, ValueType t) { in ConvertFromUserKey()
449 SequenceNumber s,
471 void SetInternalKey(const Slice& user_key, SequenceNumber s,
605 SequenceNumber seq_;
[all …]
|
| /rocksdb-6.9/utilities/transactions/ |
| D | write_prepared_txn_db.h | 628 inline SequenceNumber SmallestUnCommittedSeq() { in SmallestUnCommittedSeq()
676 SequenceNumber max);
730 std::vector<SequenceNumber> snapshots_;
734 std::vector<SequenceNumber> snapshots_all_;
737 SequenceNumber snapshots_version_ = 0;
771 std::map<SequenceNumber, std::vector<SequenceNumber>> old_commit_map_;
780 std::unordered_map<SequenceNumber, SequenceNumber> delayed_prepared_commits_;
982 SequenceNumber prep_seq_;
992 SequenceNumber aux_seq_;
1036 SequenceNumber prep_seq_;
[all …]
|
| D | write_unprepared_txn.h | 57 WritePreparedTxnDB* db, SequenceNumber snapshot, in WriteUnpreparedTxnReadCallback()
58 SequenceNumber min_uncommitted, in WriteUnpreparedTxnReadCallback()
85 void Refresh(SequenceNumber seq) override { in Refresh()
90 static SequenceNumber CalcMaxVisibleSeq( in CalcMaxVisibleSeq()
92 SequenceNumber snapshot_seq) { in CalcMaxVisibleSeq()
93 SequenceNumber max_unprepared = 0; in CalcMaxVisibleSeq()
103 const std::map<SequenceNumber, size_t>& unprep_seqs_;
104 SequenceNumber wup_snapshot_;
242 std::map<SequenceNumber, size_t> unprep_seqs_;
263 SequenceNumber largest_validated_seq_;
[all …]
|
| D | transaction_util.cc | 23 SequenceNumber snap_seq, bool cache_only, ReadCallback* snap_checker, in CheckKeyForConflicts()
24 SequenceNumber min_uncommitted) { in CheckKeyForConflicts()
37 SequenceNumber earliest_seq = in CheckKeyForConflicts()
50 SequenceNumber earliest_seq, in CheckKey()
51 SequenceNumber snap_seq, in CheckKey()
54 SequenceNumber min_uncommitted) { in CheckKey()
106 SequenceNumber seq = kMaxSequenceNumber; in CheckKey()
117 SequenceNumber lower_bound_seq = in CheckKey()
154 SequenceNumber earliest_seq = in CheckKeysForConflicts()
161 const SequenceNumber key_seq = key_iter.second.seq; in CheckKeysForConflicts()
|
| D | write_prepared_txn_db.cc | 36 std::map<SequenceNumber, SequenceNumber> ordered_seq_cnt; in Initialize()
53 SequenceNumber prev_max = max_evicted_seq_; in Initialize()
327 SequenceNumber min_uncommitted = 0; in NewIterator()
363 SequenceNumber min_uncommitted = 0; in NewIterators()
493 SequenceNumber max_evicted_seq; in AddCommitted()
690 SequenceNumber max; in GetSnapshotInternal()
748 SequenceNumber max) { in GetSnapshotListFromDB()
756 const SequenceNumber snap_seq) { in ReleaseSnapshotInternal()
814 const SequenceNumber& version) { in UpdateSnapshots()
888 SequenceNumber snapshot_seq = in CheckAgainstSnapshots()
[all …]
|
| D | transaction_util.h | 25 SequenceNumber seq;
32 explicit TransactionKeyMapInfo(SequenceNumber seq_no) in TransactionKeyMapInfo()
68 const std::string& key, SequenceNumber snap_seq, bool cache_only,
70 SequenceNumber min_uncommitted = kMaxSequenceNumber);
95 SequenceNumber earliest_seq, SequenceNumber snap_seq,
98 SequenceNumber min_uncommitted = kMaxSequenceNumber);
|
| D | write_unprepared_txn_db.cc | 44 InvalidSnapshotReadCallback(SequenceNumber snapshot) in RollbackRecoveredTransaction()
47 inline bool IsVisibleFullCheck(SequenceNumber) override { in RollbackRecoveredTransaction() argument
55 void Refresh(SequenceNumber) override {} in RollbackRecoveredTransaction() argument
75 DBImpl* db, SequenceNumber snap_seq, WriteBatch* dst_batch, in RollbackRecoveredTransaction()
205 Status Callback(SequenceNumber commit_seq, in Initialize()
246 std::map<SequenceNumber, SequenceNumber> ordered_seq_cnt; in Initialize()
317 SequenceNumber prev_max = max_evicted_seq_; in Initialize()
318 SequenceNumber last_seq = db_impl_->GetLatestSequenceNumber(); in Initialize()
366 IteratorState(WritePreparedTxnDB* txn_db, SequenceNumber sequence, in IteratorState()
391 SequenceNumber snapshot_seq = kMaxSequenceNumber; in NewIterator()
[all …]
|
| /rocksdb-6.9/table/ |
| D | get_context.h | 92 SequenceNumber* max_covering_tombstone_seq, Env* env,
93 SequenceNumber* seq = nullptr,
102 SequenceNumber* max_covering_tombstone_seq, Env* env,
103 SequenceNumber* seq = nullptr,
127 void SaveValue(const Slice& value, SequenceNumber seq);
131 SequenceNumber* max_covering_tombstone_seq() { in max_covering_tombstone_seq()
147 bool CheckCallback(SequenceNumber seq) { in CheckCallback()
175 SequenceNumber* max_covering_tombstone_seq_;
179 SequenceNumber* seq_;
|
| /rocksdb-6.9/utilities/blob_db/ |
| D | blob_file.h | 77 SequenceNumber immutable_sequence_{0};
85 SequenceNumber obsolete_sequence_{0};
161 void MarkImmutable(SequenceNumber sequence) { in MarkImmutable()
166 SequenceNumber GetImmutableSequence() const { in GetImmutableSequence()
179 void MarkObsolete(SequenceNumber sequence);
181 SequenceNumber GetObsoleteSequence() const { in GetObsoleteSequence()
228 Status WriteFooterAndCloseLocked(SequenceNumber sequence);
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl.h | 487 virtual SequenceNumber GetLastPublishedSequence() const { in GetLastPublishedSequence()
497 virtual void SetLastPublishedSequence(SequenceNumber seq);
501 SequenceNumber TEST_GetLastVisibleSequence() const;
553 SequenceNumber* seq,
646 const SequenceNumber& max_seq) const { in LoadSnapshots()
738 std::map<SequenceNumber, BatchInfo> batches_;
1376 std::vector<SequenceNumber>& snapshot_seqs,
1377 SequenceNumber earliest_write_conflict_snapshot,
1510 SequenceNumber sequence);
1760 T* cf_list, SequenceNumber* snapshot);
[all …]
|