Home
last modified time | relevance | path

Searched refs:kMaxSequenceNumber (Results 1 – 25 of 73) sorted by relevance

123

/rocksdb-6.9/db/
Drange_tombstone_fragmenter_test.cc121 kMaxSequenceNumber); in TEST_F()
123 ASSERT_EQ(kMaxSequenceNumber, iter.upper_bound()); in TEST_F()
135 kMaxSequenceNumber); in TEST_F()
137 ASSERT_EQ(kMaxSequenceNumber, iter.upper_bound()); in TEST_F()
151 kMaxSequenceNumber); in TEST_F()
153 ASSERT_EQ(kMaxSequenceNumber, iter.upper_bound()); in TEST_F()
167 kMaxSequenceNumber); in TEST_F()
169 ASSERT_EQ(kMaxSequenceNumber, iter.upper_bound()); in TEST_F()
184 ASSERT_EQ(kMaxSequenceNumber, iter.upper_bound()); in TEST_F()
207 ASSERT_EQ(kMaxSequenceNumber, iter.upper_bound()); in TEST_F()
[all …]
Drange_del_aggregator_test.cc75 return ParsedInternalKey(s, kMaxSequenceNumber, kTypeRangeDeletion); in UncutEndpoint()
201 kMaxSequenceNumber)); in TEST_F()
220 kMaxSequenceNumber)); in TEST_F()
287 kMaxSequenceNumber)); in TEST_F()
323 kMaxSequenceNumber)); in TEST_F()
352 kMaxSequenceNumber)); in TEST_F()
379 kMaxSequenceNumber)); in TEST_F()
439 InternalKey("m", kMaxSequenceNumber, kTypeRangeDeletion)}, in TEST_F()
441 InternalKey("x", kMaxSequenceNumber, kTypeRangeDeletion)}, in TEST_F()
479 InternalKey("m", kMaxSequenceNumber, kTypeRangeDeletion)}, in TEST_F()
[all …]
Ddbformat_test.cc91 ASSERT_EQ(IKey("g", kMaxSequenceNumber, kValueTypeForSeek), in TEST_F()
95 ASSERT_EQ(IKey("ABC2", kMaxSequenceNumber, kValueTypeForSeek), in TEST_F()
99 ASSERT_EQ(IKey("AAA2", kMaxSequenceNumber, kValueTypeForSeek), in TEST_F()
104 IKey("AAA2", kMaxSequenceNumber, kValueTypeForSeek), in TEST_F()
108 IKey("AAA1B", kMaxSequenceNumber, kValueTypeForSeek), in TEST_F()
111 ASSERT_EQ(IKey("AAA2", kMaxSequenceNumber, kValueTypeForSeek), in TEST_F()
131 ASSERT_EQ(IKey("g", kMaxSequenceNumber, kValueTypeForSeek), in TEST_F()
Dsnapshot_impl.h92 const SequenceNumber& max_seq = kMaxSequenceNumber) const {
100 const SequenceNumber& max_seq = kMaxSequenceNumber) const {
106 *oldest_write_conflict_snapshot = kMaxSequenceNumber;
123 *oldest_write_conflict_snapshot == kMaxSequenceNumber &&
Dflush_job_test.cc139 &mutex_, &shutting_down_, {}, kMaxSequenceNumber, in TEST_F()
156 kMaxSequenceNumber); in TEST_F()
222 &mutex_, &shutting_down_, {}, kMaxSequenceNumber, in TEST_F()
260 kMaxSequenceNumber); in TEST_F()
289 &shutting_down_, {}, kMaxSequenceNumber, snapshot_checker, in TEST_F()
336 *cfd->GetLatestMutableCFOptions(), kMaxSequenceNumber); in TEST_F()
361 &shutting_down_, snapshot_seqs, kMaxSequenceNumber, snapshot_checker, in TEST_F()
430 kMaxSequenceNumber); in TEST_F()
477 &mutex_, &shutting_down_, snapshots, kMaxSequenceNumber, in TEST_F()
Ddb_memtable_test.cc137 kMaxSequenceNumber /* upper_bound */); in TEST_F()
146 kMaxSequenceNumber, 0 /* column_family_id */); in TEST_F()
186 kMaxSequenceNumber, 0 /* column_family_id */); in TEST_F()
198 kMaxSequenceNumber, 0 /* column_family_id */); in TEST_F()
226 kMaxSequenceNumber, 0 /* column_family_id */); in TEST_F()
263 LookupKey lkey("key", kMaxSequenceNumber); in TEST_F()
Drange_del_aggregator.cc48 parsed_largest.sequence == kMaxSequenceNumber) { in TruncatedRangeDelIterator()
89 icmp_->Compare(*largest_, ParsedInternalKey(target, kMaxSequenceNumber, in Seek()
285 ParsedInternalKey start_ikey(start, kMaxSequenceNumber, in IsRangeOverlapped()
343 assert(input_iter->upper_bound() == kMaxSequenceNumber); in AddTombstones()
388 assert(child->upper_bound() == kMaxSequenceNumber); in TruncatedRangeDelMergingIter()
432 assert(top->end_key().sequence == kMaxSequenceNumber); in value()
481 kMaxSequenceNumber /* upper_bound */)); in NewIterator()
Ddbformat.cc30 assert(seq <= kMaxSequenceNumber); in PackSequenceAndType()
69 assert(*seq <= kMaxSequenceNumber); in UnPackSequenceAndType()
149 PackSequenceAndType(kMaxSequenceNumber, kValueTypeForSeek)); in FindShortestSeparator()
165 PackSequenceAndType(kMaxSequenceNumber, kValueTypeForSeek)); in FindShortSuccessor()
Dmemtable_list.cc156 *seq = kMaxSequenceNumber; in GetFromList()
159 SequenceNumber current_seq = kMaxSequenceNumber; in GetFromList()
164 if (*seq == kMaxSequenceNumber) { in GetFromList()
176 assert(*seq != kMaxSequenceNumber || s->IsNotFound()); in GetFromList()
194 : kMaxSequenceNumber; in AddRangeTombstoneIterators()
253 return kMaxSequenceNumber; in GetEarliestSequenceNumber()
344 if (!atomic_flush && m->atomic_flush_seqno_ != kMaxSequenceNumber) { in PickMemtablesToFlush()
Dcompacted_db_impl.cc41 LookupKey lkey(key, kMaxSequenceNumber); in Get()
59 LookupKey lkey(key, kMaxSequenceNumber); in MultiGet()
74 LookupKey lkey(keys[idx], kMaxSequenceNumber); in MultiGet()
Ddb_compaction_filter_test.cc338 kMaxSequenceNumber /* upper_bound */); in TEST_F()
340 &arena, &range_del_agg, kMaxSequenceNumber, handles_[1])); in TEST_F()
428 kMaxSequenceNumber /* upper_bound */); in TEST_F()
430 &arena, &range_del_agg, kMaxSequenceNumber, handles_[1])); in TEST_F()
646 kMaxSequenceNumber /* snapshots */); in TEST_F()
648 &arena, &range_del_agg, kMaxSequenceNumber)); in TEST_F()
Dmemtable_list_test.cc236 kMaxSequenceNumber, 0 /* column_family_id */); in TEST_F()
278 kMaxSequenceNumber, 0 /* column_family_id */); in TEST_F()
353 kMaxSequenceNumber, 0 /* column_family_id */); in TEST_F()
438 kMaxSequenceNumber, 0 /* column_family_id */); in TEST_F()
463 kMaxSequenceNumber, 0 /* column_family_id */); in TEST_F()
545 kMaxSequenceNumber, 0 /* column_family_id */); in TEST_F()
815 kMaxSequenceNumber, cf_id); in TEST_F()
Ddbformat.h93 static const SequenceNumber kMaxSequenceNumber = ((0x1ull << 56) - 1); variable
105 : sequence(kMaxSequenceNumber) // Make code analyzer happy in ParsedInternalKey()
248 AppendInternalKey(&rep_, ParsedInternalKey(_user_key, kMaxSequenceNumber, in SetMinPossibleForUserKey()
636 return InternalKey(end_key_, kMaxSequenceNumber, kTypeRangeDeletion); in SerializeEndKey()
/rocksdb-6.9/db/compaction/
Dcompaction_iterator_test.cc193 if (snapshot_seq == kMaxSequenceNumber) { in CheckInSnapshot()
222 SequenceNumber last_committed_sequence = kMaxSequenceNumber, in InitIterators()
232 kMaxSequenceNumber)); in InitIterators()
274 SequenceNumber last_committed_seq = kMaxSequenceNumber, in RunTest()
450 {}, {}, kMaxSequenceNumber, kMaxSequenceNumber, &merge_op, &filter); in TEST_P()
491 {"v1", "v2", "v3", "v4"}, {}, {}, kMaxSequenceNumber, kMaxSequenceNumber, in TEST_P()
529 {"v1", "v2", "v3", "v4"}, {}, {}, kMaxSequenceNumber, kMaxSequenceNumber, in TEST_P()
649 kMaxSequenceNumber, &merge_op, &filter); in TEST_P()
854 {"", ""}, kMaxSequenceNumber /*last_commited_seq*/, in TEST_F()
868 {"", "", ""}, kMaxSequenceNumber /*last_commited_seq*/, in TEST_F()
[all …]
Dcompaction_iterator.cc98 earliest_snapshot_ = kMaxSequenceNumber; in CompactionIterator()
231 compaction_filter_skip_until_.ConvertFromUserKey(kMaxSequenceNumber, in InvokeFilterIfNeeded()
259 current_user_key_sequence_ = kMaxSequenceNumber; in NextFromInput()
292 current_user_key_sequence_ = kMaxSequenceNumber; in NextFromInput()
708 ? *snapshots_iter : kMaxSequenceNumber; in findEarliestVisibleSnapshot()
729 return kMaxSequenceNumber; in findEarliestVisibleSnapshot()
741 bool pre_condition = (earliest_snapshot_ == kMaxSequenceNumber || in IsInEarliestSnapshot()
759 earliest_snapshot_ = kMaxSequenceNumber; in IsInEarliestSnapshot()
/rocksdb-6.9/utilities/transactions/
Dwrite_prepared_txn.cc118 uint64_t seq_used = kMaxSequenceNumber; in PrepareInternal()
123 assert(!s.ok() || seq_used != kMaxSequenceNumber); in PrepareInternal()
185 uint64_t seq_used = kMaxSequenceNumber; in CommitInternal()
194 assert(!s.ok() || seq_used != kMaxSequenceNumber); in CommitInternal()
229 assert(!s.ok() || seq_used != kMaxSequenceNumber); in CommitInternal()
245 assert(GetId() != kMaxSequenceNumber); in RollbackInternal()
249 auto read_at_seq = kMaxSequenceNumber; in RollbackInternal()
359 uint64_t seq_used = kMaxSequenceNumber; in RollbackInternal()
387 assert(!s.ok() || seq_used != kMaxSequenceNumber); in RollbackInternal()
411 assert(!s.ok() || seq_used != kMaxSequenceNumber); in RollbackInternal()
Dwrite_unprepared_txn.cc200 txn_->TrackKey(cf, key.ToString(), kMaxSequenceNumber, in RebuildFromWriteBatch()
369 uint64_t seq_used = kMaxSequenceNumber; in FlushWriteBatchToDBInternal()
381 assert(!s.ok() || seq_used != kMaxSequenceNumber); in FlushWriteBatchToDBInternal()
578 uint64_t seq_used = kMaxSequenceNumber; in CommitInternal()
587 assert(!s.ok() || seq_used != kMaxSequenceNumber); in CommitInternal()
629 assert(!s.ok() || seq_used != kMaxSequenceNumber); in CommitInternal()
698 assert(GetId() != kMaxSequenceNumber); in RollbackInternal()
701 auto read_at_seq = kMaxSequenceNumber; in RollbackInternal()
719 uint64_t seq_used = kMaxSequenceNumber; in RollbackInternal()
744 assert(!s.ok() || seq_used != kMaxSequenceNumber); in RollbackInternal()
[all …]
Dpessimistic_transaction.cc348 uint64_t seq_used = kMaxSequenceNumber; in CommitWithoutPrepareInternal()
353 assert(!s.ok() || seq_used != kMaxSequenceNumber); in CommitWithoutPrepareInternal()
361 uint64_t seq_used = kMaxSequenceNumber; in CommitBatchInternal()
365 assert(!s.ok() || seq_used != kMaxSequenceNumber); in CommitBatchInternal()
386 uint64_t seq_used = kMaxSequenceNumber; in CommitInternal()
391 assert(!s.ok() || seq_used != kMaxSequenceNumber); in CommitInternal()
518 TrackKey(keys_to_unlock, cfh_id, std::move(key), kMaxSequenceNumber, in LockBatch()
554 SequenceNumber tracked_at_seq = kMaxSequenceNumber; in TryLock()
596 if (tracked_at_seq == kMaxSequenceNumber) { in TryLock()
Dtransaction_util.cc59 assert(min_uncommitted == kMaxSequenceNumber || snap_checker != nullptr); in CheckKey()
69 if (earliest_seq == kMaxSequenceNumber) { in CheckKey()
106 SequenceNumber seq = kMaxSequenceNumber; in CheckKey()
118 (min_uncommitted == kMaxSequenceNumber) ? snap_seq : min_uncommitted; in CheckKey()
Dwrite_prepared_txn_db.h522 std::atomic<uint64_t> heap_top_ = {kMaxSequenceNumber};
536 inline bool empty() { return top() == kMaxSequenceNumber; } in empty()
571 heap_top_.store(!heap_.empty() ? heap_.front() : kMaxSequenceNumber,
654 bool empty = min_prepare == kMaxSequenceNumber; in SmallestUnCommittedSeq()
909 SequenceNumber aux_seq = kMaxSequenceNumber, size_t aux_batch_cnt = 0)
921 assert((aux_batch_cnt_ > 0) != (aux_seq == kMaxSequenceNumber)); // xor in db_()
931 assert(includes_data_ || prep_seq_ != kMaxSequenceNumber); in Callback()
937 if (prep_seq_ != kMaxSequenceNumber) { in Callback()
966 if (prep_seq_ != kMaxSequenceNumber) { in Callback()
1011 assert(prep_seq != kMaxSequenceNumber); in WritePreparedRollbackPreReleaseCallback()
[all …]
Dwrite_prepared_txn_db.cc174 uint64_t seq_used = kMaxSequenceNumber; in WriteInternal()
185 this, db_impl_, kMaxSequenceNumber, ZERO_PREPARES, batch_cnt); in WriteInternal()
195 assert(!s.ok() || seq_used != kMaxSequenceNumber); in WriteInternal()
221 assert(!s.ok() || seq_used != kMaxSequenceNumber); in WriteInternal()
326 SequenceNumber snapshot_seq = kMaxSequenceNumber; in NewIterator()
344 assert(snapshot_seq != kMaxSequenceNumber); in NewIterator()
362 SequenceNumber snapshot_seq = kMaxSequenceNumber; in NewIterators()
403 dummy_max_snapshot_.number_ = kMaxSequenceNumber; in Init()
419 const bool empty = prepared_top == kMaxSequenceNumber; in CheckPreparedAgainstMax()
Dtransaction_util.h70 SequenceNumber min_uncommitted = kMaxSequenceNumber);
98 SequenceNumber min_uncommitted = kMaxSequenceNumber);
/rocksdb-6.9/utilities/
Ddebug.cc41 kMaxSequenceNumber /* upper_bound */); in GetAllKeyVersions()
44 kMaxSequenceNumber, cfh)); in GetAllKeyVersions()
/rocksdb-6.9/table/
Dsst_file_reader.cc58 t_opt.largest_seqno = kMaxSequenceNumber; in Open()
69 : kMaxSequenceNumber; in NewIterator()
Dget_context.cc69 *seq_ = kMaxSequenceNumber; in GetContext()
210 if (*seq_ == kMaxSequenceNumber) { in SaveValue()
375 ParsedInternalKey(user_key, kMaxSequenceNumber, type), value, in replayGetContextLog()

123