Home
last modified time | relevance | path

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

123

/rocksdb-6.9/memtable/
Dmemtablerep_bench.cc210 sequence_(sequence), in BenchmarkThread()
411 sequence_(sequence), in Benchmark()
464 uint64_t* sequence) in FillBenchmark() argument
465 : Benchmark(table, key_gen, sequence, 1) { in FillBenchmark()
480 uint64_t* sequence) in ReadBenchmark() argument
527 uint64_t* sequence) in ReadWriteBenchmark() argument
608 uint64_t sequence; in main() local
610 sequence = 0; in main()
635 memtablerep.get(), key_gen.get(), &sequence)); in main()
641 memtablerep.get(), key_gen.get(), &sequence)); in main()
[all …]
/rocksdb-6.9/db/compaction/
Dcompaction_iterator.cc156 current_key_.UpdateInternalKey(ikey_.sequence, ikey_.type); in Next()
223 current_key_.UpdateInternalKey(ikey_.sequence, kTypeDeletion); in InvokeFilterIfNeeded()
294 current_key_committed_ = KeyCommitted(ikey_.sequence); in NextFromInput()
307 current_key_.UpdateInternalKey(ikey_.sequence, ikey_.type); in NextFromInput()
316 current_key_committed_ = KeyCommitted(ikey_.sequence); in NextFromInput()
336 current_user_key_sequence_ = ikey_.sequence; in NextFromInput()
514 IN_EARLIEST_SNAPSHOT(ikey_.sequence) && in NextFromInput()
598 current_key_.UpdateInternalKey(ikey_.sequence, ikey_.type); in NextFromInput()
681 ikey_.sequence = 0; in PrepareOutput()
736 (ikey_.sequence < preserve_deletes_seqnum_); in ikeyNotNeededForIncrementalSnapshot()
[all …]
Dcompaction_iterator.h140 inline bool KeyCommitted(SequenceNumber sequence) { in KeyCommitted() argument
142 snapshot_checker_->CheckInSnapshot(sequence, kMaxSequenceNumber) == in KeyCommitted()
146 bool IsInEarliestSnapshot(SequenceNumber sequence);
/rocksdb-6.9/db/
Ddb_iter_stress_test.cc46 uint64_t sequence; member
54 return std::tie(sequence, type) > std::tie(e.sequence, e.type); in operator <()
252 uint64_t sequence; // ignore entries with sequence number below this member
259 : data(_data), sequence(_sequence) {} in ReferenceIterator()
305 return e.sequence > sequence; in FindValueForCurrentKey()
317 assert(e.sequence <= sequence); in FindValueForCurrentKey()
338 assert(e.sequence <= sequence); in FindValueForCurrentKey()
469 e.sequence = i; in TEST_F()
483 << e.value << "\" seq: " << e.sequence << " type: " in TEST_F()
498 ref_iter.reset(new ReferenceIterator(&data, sequence)); in TEST_F()
[all …]
Ddbformat.cc60 fkey->sequence = ikey.sequence; in ParseFullKey()
75 PutFixed64(result, PackSequenceAndType(key.sequence, key.type)); in AppendInternalKey()
84 PutFixed64(result, PackSequenceAndType(key.sequence, key.type)); in AppendInternalKeyWithDifferentTimestamp()
94 snprintf(buf, sizeof(buf), "' seq:%" PRIu64 ", type:%d", sequence, in DebugString()
124 if (a.sequence > b.sequence) { in Compare()
126 } else if (a.sequence < b.sequence) { in Compare()
Dwal_manager.cc296 SequenceNumber sequence; in GetSortedWalsOfType() local
301 if (sequence == 0) { in GetSortedWalsOfType()
373 *sequence = 0; in ReadFirstRecord()
384 *sequence = itr->second; in ReadFirstRecord()
391 s = ReadFirstLine(fname, number, sequence); in ReadFirstRecord()
402 s = ReadFirstLine(archived_file, number, sequence); in ReadFirstRecord()
411 if (s.ok() && *sequence != 0) { in ReadFirstRecord()
413 read_first_record_cache_.insert({number, *sequence}); in ReadFirstRecord()
448 SequenceNumber* sequence) { in ReadFirstLine() argument
498 *sequence = WriteBatchInternal::Sequence(&batch); in ReadFirstLine()
[all …]
Dwal_manager.h66 SequenceNumber* sequence) { in TEST_ReadFirstRecord() argument
67 return ReadFirstRecord(type, number, sequence); in TEST_ReadFirstRecord()
71 SequenceNumber* sequence) { in TEST_ReadFirstLine() argument
72 return ReadFirstLine(fname, number, sequence); in TEST_ReadFirstLine()
85 SequenceNumber* sequence);
88 SequenceNumber* sequence);
Dwrite_thread.h129 SequenceNumber sequence; // the sequence number to use for the first key member
152 sequence(kMaxSequenceNumber), in Writer()
173 sequence(kMaxSequenceNumber), in batch()
338 SequenceNumber UpdateLastSequence(SequenceNumber sequence) { in UpdateLastSequence() argument
339 if (sequence > last_sequence_) { in UpdateLastSequence()
340 last_sequence_ = sequence; in UpdateLastSequence()
Drange_del_aggregator.cc48 parsed_largest.sequence == kMaxSequenceNumber) { in TruncatedRangeDelIterator()
52 } else if (parsed_largest.sequence == 0) { in TruncatedRangeDelIterator()
66 parsed_largest.sequence -= 1; in TruncatedRangeDelIterator()
189 : (*active_seqnums_.begin())->seq() > parsed.sequence; in ShouldDelete()
232 : (*active_seqnums_.begin())->seq() > parsed.sequence; in ShouldDelete()
244 if (!InStripe(parsed.sequence) || IsEmpty()) { in ShouldDelete()
365 auto it = reps_.lower_bound(parsed.sequence); in ShouldDelete()
432 assert(top->end_key().sequence == kMaxSequenceNumber); in value()
Darena_wrapped_db_iter.cc36 const SequenceNumber& sequence, in Init() argument
44 cf_options.user_comparator, nullptr, sequence, in Init()
90 const MutableCFOptions& mutable_cf_options, const SequenceNumber& sequence, in NewArenaWrappedDbIterator() argument
95 iter->Init(env, read_options, cf_options, mutable_cf_options, sequence, in NewArenaWrappedDbIterator()
Ddb_iter.cc223 is_key_seqnum_zero_ = (ikey_.sequence == 0); in FindNextUserEntryInternal()
252 if (IsVisible(ikey_.sequence, ts)) { in FindNextUserEntryInternal()
296 if (ikey_.sequence >= start_seqnum_) { in FindNextUserEntryInternal()
742 if (!IsVisible(ikey.sequence, ts) || in FindValueForCurrentKey()
913 if (IsVisible(ikey.sequence, ts)) { in FindValueForCurrentKeyUsingSeek()
1052 assert(ikey.sequence != kMaxSequenceNumber); in FindUserKeyBeforeSavedKey()
1059 if (!IsVisible(ikey.sequence, ts)) { in FindUserKeyBeforeSavedKey()
1104 bool DBIter::IsVisible(SequenceNumber sequence, const Slice& ts) { in IsVisible() argument
1113 return sequence <= sequence_; in IsVisible()
1116 return read_callback_->IsVisible(sequence); in IsVisible()
[all …]
Dmerge_helper.cc171 } else if (stop_before > 0 && ikey.sequence <= stop_before && in MergeUntil()
173 snapshot_checker_->CheckInSnapshot(ikey.sequence, in MergeUntil()
224 UpdateInternalKey(&original_key, orig_ikey.sequence, orig_ikey.type); in MergeUntil()
251 ikey.sequence <= latest_snapshot_ in MergeUntil()
331 UpdateInternalKey(&original_key, orig_ikey.sequence, orig_ikey.type); in MergeUntil()
Ddbformat.h101 SequenceNumber sequence; member
105 : sequence(kMaxSequenceNumber) // Make code analyzer happy in ParsedInternalKey()
109 : user_key(u), sequence(seq), type(t) {} in ParsedInternalKey()
114 sequence = 0; in clear()
301 result->sequence = num >> 8; in ParseInternalKey()
489 parsed_key_suffix.sequence, parsed_key_suffix.type); in SetInternalKey()
612 seq_ = parsed_key.sequence; in RangeTombstone()
Dsnapshot_checker.h24 SequenceNumber sequence, SequenceNumber snapshot_sequence) const = 0;
53 SequenceNumber sequence, SequenceNumber snapshot_sequence) const override;
Dwrite_batch.cc1345 SequenceNumber sequence() const { return sequence_; } in sequence() function in ROCKSDB_NAMESPACE::MemTableInserter
1968 WriteThread::WriteGroup& write_group, SequenceNumber sequence, in InsertInto() argument
1974 sequence, memtables, flush_scheduler, trim_history_scheduler, in InsertInto()
1982 w->sequence = inserter.sequence(); in InsertInto()
1988 SetSequence(w->batch, inserter.sequence()); in InsertInto()
1995 assert(!seq_per_batch || inserter.sequence() - w->sequence == w->batch_cnt); in InsertInto()
2001 WriteThread::Writer* writer, SequenceNumber sequence, in InsertInto() argument
2012 sequence, memtables, flush_scheduler, trim_history_scheduler, in InsertInto()
2016 SetSequence(writer->batch, sequence); in InsertInto()
2020 assert(!seq_per_batch || inserter.sequence() - sequence == batch_cnt); in InsertInto()
[all …]
Ddb_log_iter_test.cc43 EXPECT_TRUE(res.sequence > lastSequence); in ReadRecords()
45 lastSequence = res.sequence; in ReadRecords()
49 return res.sequence; in ReadRecords()
/rocksdb-6.9/include/rocksdb/
Dtransaction_log.h57 SequenceNumber sequence = 0; member
72 : sequence(std::move(bResult.sequence)), in BatchResult()
76 sequence = std::move(bResult.sequence);
Dtypes.h34 SequenceNumber sequence; member
37 FullKey() : sequence(0) {} // Intentionally left uninitialized (for speed) in FullKey()
39 : user_key(u), sequence(seq), type(t) {} in FullKey()
44 sequence = 0; in clear()
/rocksdb-6.9/db/db_impl/
Ddb_impl_write.cc203 *seq_used = w.sequence; in WriteImpl()
358 writer->sequence = next_sequence; in WriteImpl()
398 assert(w.sequence == current_sequence); in WriteImpl()
409 *seq_used = w.sequence; in WriteImpl()
500 writer->sequence = next_sequence; in PipelinedWriteImpl()
592 *seq_used = w.sequence; in PipelinedWriteImpl()
611 w.sequence = seq; in UnorderedWriteMemtable()
671 *seq_used = w.sequence; in WriteImplWALOnly()
770 writer->sequence = curr_seq; in WriteImplWALOnly()
827 *seq_used = w.sequence; in WriteImplWALOnly()
[all …]
/rocksdb-6.9/utilities/blob_db/
Dblob_db_test.cc49 sequence(_sequence), in BlobIndexVersion()
55 SequenceNumber sequence = 0; member
233 ASSERT_EQ(expected_version.sequence, versions[i].sequence); in VerifyBaseDB()
261 ASSERT_EQ(versions[i].sequence, expected_version.sequence); in VerifyBaseDBBlobIndex()
1091 ASSERT_EQ(blob_db_->GetLatestSequenceNumber(), sequence); in TEST_F()
1093 KeyVersion(key, value, sequence, in TEST_F()
1396 ASSERT_EQ(blob_db_->GetLatestSequenceNumber(), sequence); in TEST_F()
1402 sequence, kTypeBlobIndex); in TEST_F()
1420 sequence, kTypeBlobIndex); in TEST_F()
1483 version.sequence = 0; in TEST_F()
[all …]
Dblob_file.h161 void MarkImmutable(SequenceNumber sequence) { in MarkImmutable() argument
163 immutable_sequence_ = sequence; in MarkImmutable()
179 void MarkObsolete(SequenceNumber sequence);
228 Status WriteFooterAndCloseLocked(SequenceNumber sequence);
Dblob_file.cc100 void BlobFile::MarkObsolete(SequenceNumber sequence) { in MarkObsolete() argument
102 obsolete_sequence_ = sequence; in MarkObsolete()
112 Status BlobFile::WriteFooterAndCloseLocked(SequenceNumber sequence) { in WriteFooterAndCloseLocked() argument
123 immutable_sequence_ = sequence; in WriteFooterAndCloseLocked()
/rocksdb-6.9/include/rocksdb/utilities/
Ddebug.h19 KeyVersion() : user_key(""), value(""), sequence(0), type(0) {} in KeyVersion()
23 : user_key(_user_key), value(_value), sequence(_sequence), type(_type) {} in KeyVersion()
27 SequenceNumber sequence; member
/rocksdb-6.9/utilities/transactions/
Dsnapshot_checker.cc34 SequenceNumber sequence, SequenceNumber snapshot_sequence) const {
38 sequence, snapshot_sequence, kMinUnCommittedSeq, &snapshot_released);
/rocksdb-6.9/docs/_posts/
D2019-03-08-format-version-4.markdown8 The data blocks in RocksDB consist of a sequence of key/values pairs sorted by key, where the pairs…
24 …cases, the sequence number `seq` is not necessary for keys in the index blocks. In such cases, `fo…

123