Home
last modified time | relevance | path

Searched refs:largest_seqno (Results 1 – 25 of 34) sorted by relevance

12

/rocksdb-6.9/db/
Dversion_edit.h48 SequenceNumber largest_seqno; // The largest seqno in this file member
61 largest_seqno(_largest_seqno) {} in FileDescriptor()
70 largest_seqno = fd.largest_seqno;
185 fd.largest_seqno = std::max(fd.largest_seqno, seqno); in UpdateBoundariesForRange()
328 const SequenceNumber& largest_seqno, bool marked_for_compaction, in AddFile() argument
332 assert(smallest_seqno <= largest_seqno); in AddFile()
335 smallest_seqno, largest_seqno, in AddFile()
342 assert(f.fd.smallest_seqno <= f.fd.largest_seqno); in AddFile()
Dversion_edit.cc100 fd.largest_seqno = std::max(fd.largest_seqno, seqno); in UpdateBoundaries()
205 PutVarint64Varint64(dst, f.fd.smallest_seqno, f.fd.largest_seqno); in EncodeTo()
343 SequenceNumber largest_seqno = kMaxSequenceNumber; in DecodeNewFile4From() local
348 GetVarint64(input, &largest_seqno)) { in DecodeNewFile4From()
419 FileDescriptor(number, path_id, file_size, smallest_seqno, largest_seqno); in DecodeNewFile4From()
547 SequenceNumber largest_seqno = kMaxSequenceNumber; in DecodeFrom() local
553 GetVarint64(&input, &largest_seqno)) { in DecodeFrom()
555 largest_seqno); in DecodeFrom()
570 SequenceNumber largest_seqno = kMaxSequenceNumber; in DecodeFrom() local
576 GetVarint64(&input, &largest_seqno)) { in DecodeFrom()
[all …]
Dversion_builder.cc38 if (a->fd.largest_seqno != b->fd.largest_seqno) { in NewestFirstBySeqNo()
39 return a->fd.largest_seqno > b->fd.largest_seqno; in NewestFirstBySeqNo()
245 if (f2->fd.smallest_seqno == f2->fd.largest_seqno) { in CheckConsistency()
248 if (!(external_file_seqno < f1->fd.largest_seqno || in CheckConsistency()
253 f1->fd.smallest_seqno, f1->fd.largest_seqno, in CheckConsistency()
258 NumberToString(f1->fd.largest_seqno) + in CheckConsistency()
267 f1->fd.smallest_seqno, f1->fd.largest_seqno, in CheckConsistency()
268 f2->fd.smallest_seqno, f2->fd.largest_seqno); in CheckConsistency()
271 " " + NumberToString(f1->fd.largest_seqno) + " " + in CheckConsistency()
274 NumberToString(f2->fd.largest_seqno) + " " + in CheckConsistency()
Dimport_column_family_job.cc155 file_metadata.largest_seqno, false, kInvalidBlobFileNumber, in Run()
160 if (file_metadata.largest_seqno > versions_->LastSequence()) { in Run()
161 versions_->SetLastAllocatedSequence(file_metadata.largest_seqno); in Run()
162 versions_->SetLastPublishedSequence(file_metadata.largest_seqno); in Run()
163 versions_->SetLastSequence(file_metadata.largest_seqno); in Run()
Dflush_job_test.cc241 ASSERT_EQ(10006, file_meta.fd.largest_seqno); in TEST_F()
244 ASSERT_EQ(10000, file_meta.fd.largest_seqno); in TEST_F()
307 file_meta.fd.largest_seqno); in TEST_F()
411 ASSERT_EQ(largest_seqs[k], file_meta.fd.largest_seqno); in TEST_F()
Dflush_job.cc425 meta_.fd.smallest_seqno, meta_.fd.largest_seqno, in WriteLevel0Table()
463 info->largest_seqno = meta_.fd.largest_seqno; in GetFlushJobInfo()
Dimport_column_family_test.cc51 SequenceNumber largest_seqno) { in LiveFileMetaDataInit() argument
56 metadata.largest_seqno = largest_seqno; in LiveFileMetaDataInit()
Dexternal_sst_file_ingestion_job.cc575 return f1->fd.largest_seqno < f2->fd.largest_seqno; in AssignLevelAndSeqnoForIngestedFile()
577 ->fd.largest_seqno; in AssignLevelAndSeqnoForIngestedFile()
Drepair.cc565 if (max_sequence < tables_[i].meta.fd.largest_seqno) { in AddTables()
566 max_sequence = tables_[i].meta.fd.largest_seqno; in AddTables()
588 table->meta.fd.largest_seqno, table->meta.marked_for_compaction, in AddTables()
Dtable_cache.cc118 level, fd.largest_seqno, block_cache_tracer_), in GetTableReader()
303 ->GetSequenceNumber() <= fd.largest_seqno)) { in CreateRowCacheKeyPrefix()
Dversion_builder_test.cc62 SequenceNumber largest_seqno = 0, in Add() argument
67 GetInternalKey(largest, largest_seq), smallest_seqno, largest_seqno, in Add()
Dversion_set.cc1442 file->fd.largest_seqno, file->smallest.user_key().ToString(), in GetColumnFamilyMetaData()
2747 return f1.file->fd.largest_seqno < in UpdateFilesByCompactionPri()
2748 f2.file->fd.largest_seqno; in UpdateFilesByCompactionPri()
2841 level_and_file.second->fd.largest_seqno != 0 && in ComputeBottommostFilesMarkedForCompaction()
2846 if (level_and_file.second->fd.largest_seqno < oldest_snapshot_seqnum_) { in ComputeBottommostFilesMarkedForCompaction()
2851 level_and_file.second->fd.largest_seqno); in ComputeBottommostFilesMarkedForCompaction()
3437 AppendNumberTo(&r, files[i]->fd.largest_seqno); in DebugString()
5251 f->fd.smallest_seqno, f->fd.largest_seqno, in WriteCurrentStateToManifest()
5675 filemetadata.largest_seqno = file->fd.largest_seqno; in GetLiveFilesMetaData()
/rocksdb-6.9/db/compaction/
Dcompaction_picker_universal.cc198 SequenceNumber* largest_seqno) { in GetSmallestLargestSeqno() argument
201 assert(f->fd.smallest_seqno <= f->fd.largest_seqno); in GetSmallestLargestSeqno()
205 *largest_seqno = f->fd.largest_seqno; in GetSmallestLargestSeqno()
210 if (f->fd.largest_seqno > *largest_seqno) { in GetSmallestLargestSeqno()
211 *largest_seqno = f->fd.largest_seqno; in GetSmallestLargestSeqno()
484 assert(f->fd.smallest_seqno <= f->fd.largest_seqno); in PickCompaction()
495 SequenceNumber largest_seqno = 0U; in PickCompaction() local
497 &largest_seqno); in PickCompaction()
507 assert(prev_smallest_seqno > largest_seqno); in PickCompaction()
Dcompaction_job_test.cc139 SequenceNumber largest_seqno = 0; in AddMockFile() local
149 largest_seqno = std::max(largest_seqno, key.sequence); in AddMockFile()
189 smallest_seqno, largest_seqno, false, oldest_blob_file_number, in AddMockFile()
/rocksdb-6.9/include/rocksdb/
Dmetadata.h60 largest_seqno(0), in SstFileMetaData()
81 largest_seqno(_largest_seqno), in SstFileMetaData()
104 SequenceNumber largest_seqno; // Largest sequence number in file. member
Dlistener.h194 SequenceNumber largest_seqno; member
/rocksdb-6.9/table/
Dtable_builder.h58 largest_seqno(_largest_seqno), in TableReaderOptions()
72 SequenceNumber largest_seqno; member
Dsst_file_reader.cc58 t_opt.largest_seqno = kMaxSequenceNumber; in Open()
/rocksdb-6.9/table/block_based/
Dblock_based_table_reader.cc477 SequenceNumber largest_seqno, in GetGlobalSequenceNumber() argument
520 if (largest_seqno < kMaxSequenceNumber) { in GetGlobalSequenceNumber()
522 global_seqno = largest_seqno; in GetGlobalSequenceNumber()
524 if (global_seqno != largest_seqno) { in GetGlobalSequenceNumber()
531 static_cast<unsigned long long>(largest_seqno)); in GetGlobalSequenceNumber()
571 const SequenceNumber largest_seqno, TailPrefetchStats* tail_prefetch_stats, in Open() argument
656 metaindex_iter.get(), largest_seqno); in Open()
767 const SequenceNumber largest_seqno) { in ReadPropertiesBlock() argument
853 s = GetGlobalSequenceNumber(*(rep_->table_properties), largest_seqno, in ReadPropertiesBlock()
Dblock_based_table_reader.h99 const SequenceNumber largest_seqno = 0,
407 const SequenceNumber largest_seqno);
Dblock_based_table_factory.cc213 table_reader_options.largest_seqno, &tail_prefetch_stats_, in NewTableReader()
/rocksdb-6.9/utilities/checkpoint/
Dcheckpoint_impl.cc432 live_file_metadata.largest_seqno = file_metadata.largest_seqno; in ExportColumnFamily()
/rocksdb-6.9/db/db_impl/
Ddb_impl_experimental.cc130 f->fd.smallest_seqno, f->fd.largest_seqno, in PromoteL0()
Ddb_impl_compaction_flush.cc621 info.largest_seqno = file_meta->fd.largest_seqno; in NotifyOnFlushBegin()
1314 f->fd.smallest_seqno, f->fd.largest_seqno, in ReFitLevel()
2734 f->fd.largest_seqno, f->marked_for_compaction, in BackgroundCompaction()
/rocksdb-6.9/utilities/blob_db/
Dblob_db_test.cc1728 info.largest_seqno = 100; in TEST_F()
1757 info.largest_seqno = 200; in TEST_F()
1887 info.largest_seqno = 300; in TEST_F()

12