Home
last modified time | relevance | path

Searched refs:seq (Results 1 – 25 of 74) sorted by relevance

123

/rocksdb-6.9/db/
Ddb_memtable_test.cc130 SequenceNumber seq = 123; in TEST_F() local
150 res = mem->Add(seq, kTypeValue, "key", "value2"); in TEST_F()
161 res = mem->Add(seq, kTypeDeletion, "key", ""); in TEST_F()
170 seq++; in TEST_F()
172 res = mem->Add(seq, kTypeValue, "foo", "value" + ToString(seq)); in TEST_F()
238 for (int seq = 1; seq < num_ops / 2; seq++) { in TEST_F() local
239 PutFixed64(&v1, seq); in TEST_F()
249 for (int seq = num_ops / 2; seq < num_ops; seq++) { in TEST_F() local
250 PutFixed64(&v2, seq); in TEST_F()
269 for (int seq = 0; seq < num_ops; seq++) { in TEST_F() local
[all …]
Dread_callback.h23 virtual bool IsVisibleFullCheck(SequenceNumber seq) = 0;
25 inline bool IsVisible(SequenceNumber seq) { in IsVisible() argument
28 if (seq < min_uncommitted_) { // handles seq == 0 as well in IsVisible()
29 assert(seq <= max_visible_seq_); in IsVisible()
31 } else if (max_visible_seq_ < seq) { in IsVisible()
32 assert(seq != 0); in IsVisible()
35 assert(seq != 0); // already handled in the first if-then clause in IsVisible()
36 return IsVisibleFullCheck(seq); in IsVisible()
43 virtual void Refresh(SequenceNumber seq) { max_visible_seq_ = seq; } in Refresh() argument
Dmemtable_list_test.cc214 SequenceNumber seq = 1; in TEST_F() local
222 LookupKey lkey("key1", seq); in TEST_F()
240 mem->Add(++seq, kTypeDeletion, "key1", ""); in TEST_F()
273 SequenceNumber saved_seq = seq; in TEST_F()
281 mem2->Add(++seq, kTypeDeletion, "key1", ""); in TEST_F()
331 SequenceNumber seq = 1; in TEST_F() local
339 LookupKey lkey("key1", seq); in TEST_F()
357 mem->Add(++seq, kTypeDeletion, "key1", ""); in TEST_F()
441 mem2->Add(++seq, kTypeDeletion, "key1", ""); in TEST_F()
520 SequenceNumber seq = 1; in TEST_F() local
[all …]
Ddbformat_test.cc17 uint64_t seq, in IKey() argument
20 AppendInternalKey(&encoded, ParsedInternalKey(user_key, seq, vt)); in IKey()
37 uint64_t seq, in TestKey() argument
39 std::string encoded = IKey(key, seq, vt); in TestKey()
46 ASSERT_EQ(seq, decoded.sequence); in TestKey()
56 const uint64_t seq[] = { in TEST_F() local
63 for (unsigned int s = 0; s < sizeof(seq) / sizeof(seq[0]); s++) { in TEST_F()
64 TestKey(keys[k], seq[s], kTypeValue); in TEST_F()
Dmemtable.cc602 SequenceNumber seq; member
655 SequenceNumber seq; in SaveValue() local
658 if (!s->CheckCallback(seq)) { in SaveValue()
662 s->seq = seq; in SaveValue()
822 *seq = kMaxSequenceNumber; in Get()
854 saver.seq = kMaxSequenceNumber; in GetFromTable()
867 *seq = saver.seq; in GetFromTable()
939 void MemTable::Update(SequenceNumber seq, in Update() argument
942 LookupKey lkey(key, seq); in Update()
969 assert(existing_seq != seq); in Update()
[all …]
Dmemtable_list.h63 SequenceNumber* max_covering_tombstone_seq, SequenceNumber* seq,
72 SequenceNumber seq; variable
74 max_covering_tombstone_seq, &seq, read_opts, callback,
96 SequenceNumber* seq, const ReadOptions& read_opts,
104 SequenceNumber seq; variable
106 max_covering_tombstone_seq, &seq, read_opts,
157 SequenceNumber* seq, const ReadOptions& read_opts,
353 void AssignAtomicFlushSeq(const SequenceNumber& seq) { in AssignAtomicFlushSeq() argument
359 mem->atomic_flush_seqno_ = seq; in AssignAtomicFlushSeq()
Ddb_merge_operator_test.cc25 bool IsVisibleFullCheck(SequenceNumber seq) override { in IsVisibleFullCheck() argument
26 return snapshot_checker_->CheckInSnapshot(seq, snapshot_seq_) == in IsVisibleFullCheck()
43 SequenceNumber seq = snapshot == nullptr ? db_->GetLatestSequenceNumber() in GetWithReadCallback() local
45 TestReadCallback read_callback(snapshot_checker, seq); in GetWithReadCallback()
495 return IsInSnapshot(seq, snapshot_seq) in TEST_F()
503 return seq == 0; in TEST_F()
505 return seq <= 1; in TEST_F()
508 return seq <= 1; in TEST_F()
510 return seq <= 3; in TEST_F()
513 return seq <= 3; in TEST_F()
[all …]
Dmemtable.h186 bool Add(SequenceNumber seq, ValueType type, const Slice& key,
213 SequenceNumber* max_covering_tombstone_seq, SequenceNumber* seq,
217 max_covering_tombstone_seq, seq, read_opts, callback,
223 SequenceNumber* max_covering_tombstone_seq, SequenceNumber* seq,
232 SequenceNumber seq; variable
234 max_covering_tombstone_seq, &seq, read_opts, callback,
251 void Update(SequenceNumber seq,
267 bool UpdateCallback(SequenceNumber seq,
547 MergeContext* merge_context, SequenceNumber* seq,
Drange_del_aggregator_test.cc52 SequenceNumber seq; member
59 SequenceNumber seq; member
78 ParsedInternalKey InternalValue(const Slice& key, SequenceNumber seq) { in InternalValue() argument
79 return ParsedInternalKey(key, seq, kTypeValue); in InternalValue()
91 EXPECT_EQ(expected_range_dels[i].seq, iter->seq()); in VerifyIterator()
106 EXPECT_EQ(reverse_expected_range_dels[i].seq, iter->seq()); in VerifyIterator()
122 EXPECT_EQ(test_case.seq, iter->seq()); in VerifySeek()
138 EXPECT_EQ(test_case.seq, iter->seq()); in VerifySeekForPrev()
174 EXPECT_EQ(tombstone.seq_, iter->seq()); in CheckIterPosition()
Ddbformat.cc29 uint64_t PackSequenceAndType(uint64_t seq, ValueType t) { in PackSequenceAndType() argument
30 assert(seq <= kMaxSequenceNumber); in PackSequenceAndType()
32 return (seq << 8) | t; in PackSequenceAndType()
65 void UnPackSequenceAndType(uint64_t packed, uint64_t* seq, ValueType* t) { in UnPackSequenceAndType() argument
66 *seq = packed >> 8; in UnPackSequenceAndType()
69 assert(*seq <= kMaxSequenceNumber); in UnPackSequenceAndType()
Dwal_manager_test.cc68 uint64_t seq = versions_->LastSequence() + 1; in Put() local
71 WriteBatchInternal::SetSequence(&batch, seq); in Put()
73 versions_->SetLastAllocatedSequence(seq); in Put()
74 versions_->SetLastPublishedSequence(seq); in Put()
75 versions_->SetLastSequence(seq); in Put()
99 const SequenceNumber seq) { in OpenTransactionLogIter() argument
102 seq, &iter, TransactionLogIterator::ReadOptions(), versions_.get()); in OpenTransactionLogIter()
Drange_del_aggregator.h73 SequenceNumber seq() const { return iter_->seq(); } in seq() function
96 return a->seq() > b->seq(); in operator()
332 bool InStripe(SequenceNumber seq) const { in InStripe() argument
333 return lower_bound_ <= seq && seq <= upper_bound_; in InStripe()
Ddbformat.h108 ParsedInternalKey(const Slice& u, const SequenceNumber& seq, ValueType t) in ParsedInternalKey()
109 : user_key(u), sequence(seq), type(t) {} in ParsedInternalKey()
125 extern uint64_t PackSequenceAndType(uint64_t seq, ValueType t);
129 extern void UnPackSequenceAndType(uint64_t packed, uint64_t* seq, ValueType* t);
310 inline void UpdateInternalKey(std::string* ikey, uint64_t seq, ValueType t) { in UpdateInternalKey() argument
313 uint64_t newval = (seq << 8) | t; in UpdateInternalKey()
439 void UpdateInternalKey(uint64_t seq, ValueType t) { in UpdateInternalKey() argument
442 uint64_t newval = (seq << 8) | t; in UpdateInternalKey()
Dmemtable_list.cc110 SequenceNumber* seq, const ReadOptions& read_opts, in Get() argument
113 max_covering_tombstone_seq, seq, read_opts, callback, in Get()
145 SequenceNumber* seq, const ReadOptions& read_opts, bool* is_blob_index) { in GetFromHistory() argument
147 max_covering_tombstone_seq, seq, read_opts, in GetFromHistory()
154 SequenceNumber* max_covering_tombstone_seq, SequenceNumber* seq, in GetFromList() argument
156 *seq = kMaxSequenceNumber; in GetFromList()
164 if (*seq == kMaxSequenceNumber) { in GetFromList()
172 *seq = current_seq; in GetFromList()
176 assert(*seq != kMaxSequenceNumber || s->IsNotFound()); in GetFromList()
/rocksdb-6.9/utilities/transactions/
Dwrite_prepared_transaction_test.cc169 for (size_t seq = 1; seq <= t_cnt; seq++) { in TEST() local
344 void TakeSnapshot(SequenceNumber seq) { snapshots_.push_back(seq); } in TakeSnapshot() argument
1029 prep_seq = ++seq; in TEST_P()
1033 seq++; in TEST_P()
1036 seq++; in TEST_P()
1682 exp_seq = seq; in TEST_P()
1962 seq <= wp_db->max_evicted_seq_ && seq != prepare_seq; seq++) { in TEST_P()
1978 seq <= wp_db->max_evicted_seq_ && seq != prepare_seq; seq++) { in TEST_P()
2114 seq++; in TEST_P()
2120 seq++; in TEST_P()
[all …]
Dwrite_unprepared_txn.cc15 bool WriteUnpreparedTxnReadCallback::IsVisibleFullCheck(SequenceNumber seq) { in IsVisibleFullCheck() argument
23 if (it.first <= seq && seq < it.first + it.second) { in IsVisibleFullCheck()
30 db_->IsInSnapshot(seq, wup_snapshot_, min_uncommitted_, &snap_released); in IsVisibleFullCheck()
593 for (const auto& seq : unprep_seqs_) { in CommitInternal() local
594 wpt_db_->RemovePrepared(seq.first, seq.second); in CommitInternal()
632 for (const auto& seq : unprep_seqs_) { in CommitInternal() local
633 wpt_db_->RemovePrepared(seq.first, seq.second); in CommitInternal()
749 for (const auto& seq : unprep_seqs_) { in RollbackInternal() local
750 wpt_db_->RemovePrepared(seq.first, seq.second); in RollbackInternal()
780 for (const auto& seq : unprep_seqs_) { in RollbackInternal() local
[all …]
Dtransaction_base.cc618 SequenceNumber seq, bool read_only, in TrackKey() argument
621 TrackKey(&tracked_keys_, cfh_id, key, seq, read_only, exclusive); in TrackKey()
625 TrackKey(&save_points_->top().new_keys_, cfh_id, key, seq, read_only, in TrackKey()
634 const std::string& key, SequenceNumber seq, in TrackKey() argument
640 auto result = cf_key_map.try_emplace(key, seq); in TrackKey()
642 if (!result.second && seq < iter->second.seq) { in TrackKey()
644 iter->second.seq = seq; in TrackKey()
649 auto result = cf_key_map.emplace(key, TransactionKeyMapInfo(seq)); in TrackKey()
651 } else if (seq < iter->second.seq) { in TrackKey()
653 iter->second.seq = seq; in TrackKey()
[all …]
Dtransaction_util.cc106 SequenceNumber seq = kMaxSequenceNumber; in CheckKey() local
120 lower_bound_seq, &seq, in CheckKey()
127 ? snap_seq < seq in CheckKey()
128 : !snap_checker->IsVisible(seq); in CheckKey()
161 const SequenceNumber key_seq = key_iter.second.seq; in CheckKeysForConflicts()
Dtransaction_util.h25 SequenceNumber seq; member
33 : seq(seq_no), num_writes(0), num_reads(0), exclusive(false) {} in TransactionKeyMapInfo()
37 assert(seq <= info.seq); in Merge()
Doptimistic_transaction.cc147 SequenceNumber seq; in TryLock() local
149 seq = snapshot_->GetSequenceNumber(); in TryLock()
151 seq = db_->GetLatestSequenceNumber(); in TryLock()
156 TrackKey(cfh_id, key_str, seq, read_only, exclusive); in TryLock()
Dwrite_unprepared_txn_db.cc284 const auto& seq = batch.first; in Initialize() local
289 ordered_seq_cnt[seq] = cnt; in Initialize()
290 assert(wupt->unprep_seqs_.count(seq) == 0); in Initialize()
291 wupt->unprep_seqs_[seq] = cnt; in Initialize()
310 auto seq = seq_cnt.first; in Initialize() local
313 AddPrepared(seq + i); in Initialize()
/rocksdb-6.9/util/
Dduplicate_detector.h20 bool IsDuplicateKeySeq(uint32_t cf, const Slice& key, SequenceNumber seq) { in IsDuplicateKeySeq() argument
21 assert(seq >= batch_seq_); in IsDuplicateKeySeq()
22 if (batch_seq_ != seq) { // it is a new batch in IsDuplicateKeySeq()
25 batch_seq_ = seq; in IsDuplicateKeySeq()
/rocksdb-6.9/table/
Dget_context.h93 SequenceNumber* seq = nullptr,
103 SequenceNumber* seq = nullptr,
127 void SaveValue(const Slice& value, SequenceNumber seq);
147 bool CheckCallback(SequenceNumber seq) { in CheckCallback() argument
149 return callback_->IsVisible(seq); in CheckCallback()
/rocksdb-6.9/db/compaction/
Dcompaction_iterator.cc15 #define DEFINITELY_IN_SNAPSHOT(seq, snapshot) \ argument
16 ((seq) <= (snapshot) && \
18 LIKELY(snapshot_checker_->CheckInSnapshot((seq), (snapshot)) == \
21 #define DEFINITELY_NOT_IN_SNAPSHOT(seq, snapshot) \ argument
22 ((seq) > (snapshot) || \
24 UNLIKELY(snapshot_checker_->CheckInSnapshot((seq), (snapshot)) == \
27 #define IN_EARLIEST_SNAPSHOT(seq) \ argument
28 ((seq) <= earliest_snapshot_ && \
29 (snapshot_checker_ == nullptr || LIKELY(IsInEarliestSnapshot(seq))))
/rocksdb-6.9/db/db_impl/
Ddb_impl_write.cc128 uint64_t seq; in WriteImpl() local
140 *seq_used = seq; in WriteImpl()
611 w.sequence = seq; in UnorderedWriteMemtable()
1151 SequenceNumber seq; in WriteRecoverableState() local
1155 seq = versions_->LastSequence(); in WriteRecoverableState()
1174 for (uint64_t sub_batch_seq = seq + 1; in WriteRecoverableState()
1210 auto seq = versions_->LastSequence(); in AssignAtomicFlushSeq() local
1212 cfd->imm()->AssignAtomicFlushSeq(seq); in AssignAtomicFlushSeq()
1343 uint64_t seq = cfd->mem()->GetCreationSeq(); in HandleWriteBufferFull() local
1346 seq_num_for_cf_picked = seq; in HandleWriteBufferFull()
[all …]

123