Home
last modified time | relevance | path

Searched refs:smallest_seqno (Results 1 – 25 of 27) sorted by relevance

12

/rocksdb-6.9/db/
Dversion_edit.h47 SequenceNumber smallest_seqno; // The smallest seqno in this file member
60 smallest_seqno(_smallest_seqno), in FileDescriptor()
69 smallest_seqno = fd.smallest_seqno;
184 fd.smallest_seqno = std::min(fd.smallest_seqno, seqno); in UpdateBoundariesForRange()
327 const InternalKey& largest, const SequenceNumber& smallest_seqno, 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_builder.cc41 if (a->fd.smallest_seqno != b->fd.smallest_seqno) { in NewestFirstBySeqNo()
42 return a->fd.smallest_seqno > b->fd.smallest_seqno; in NewestFirstBySeqNo()
245 if (f2->fd.smallest_seqno == f2->fd.largest_seqno) { in CheckConsistency()
247 SequenceNumber external_file_seqno = f2->fd.smallest_seqno; in CheckConsistency()
253 f1->fd.smallest_seqno, f1->fd.largest_seqno, in CheckConsistency()
257 NumberToString(f1->fd.smallest_seqno) + " " + in CheckConsistency()
263 } else if (f1->fd.smallest_seqno <= f2->fd.smallest_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()
270 "L0 files seqno " + NumberToString(f1->fd.smallest_seqno) + in CheckConsistency()
[all …]
Dversion_edit.cc99 fd.smallest_seqno = std::min(fd.smallest_seqno, seqno); in UpdateBoundaries()
205 PutVarint64Varint64(dst, f.fd.smallest_seqno, f.fd.largest_seqno); in EncodeTo()
342 SequenceNumber smallest_seqno = 0; in DecodeNewFile4From() local
347 GetVarint64(input, &smallest_seqno) && in DecodeNewFile4From()
419 FileDescriptor(number, path_id, file_size, smallest_seqno, largest_seqno); in DecodeNewFile4From()
546 SequenceNumber smallest_seqno = 0; in DecodeFrom() local
552 GetVarint64(&input, &smallest_seqno) && in DecodeFrom()
554 f.fd = FileDescriptor(number, 0, file_size, smallest_seqno, in DecodeFrom()
569 SequenceNumber smallest_seqno = 0; in DecodeFrom() local
575 GetVarint64(&input, &smallest_seqno) && in DecodeFrom()
[all …]
Ddeletefile_test.cc512 auto old_file = metadata[0].smallest_seqno < metadata[1].smallest_seqno in TEST_F()
515 auto new_file = metadata[0].smallest_seqno > metadata[1].smallest_seqno in TEST_F()
Dflush_job.cc425 meta_.fd.smallest_seqno, meta_.fd.largest_seqno, in WriteLevel0Table()
462 info->smallest_seqno = meta_.fd.smallest_seqno; in GetFlushJobInfo()
Ddb_flush_test.cc362 ASSERT_EQ(info.smallest_seqno, info.largest_seqno); in TEST_F()
363 ASSERT_NE(0, info.smallest_seqno); in TEST_F()
364 if (info.smallest_seqno == seq1) { in TEST_F()
373 ASSERT_EQ(info.smallest_seqno, seq2); in TEST_F()
Dimport_column_family_test.cc50 SequenceNumber smallest_seqno, in LiveFileMetaDataInit() argument
55 metadata.smallest_seqno = smallest_seqno; in LiveFileMetaDataInit()
Dflush_job_test.cc239 ASSERT_EQ(1, file_meta.fd.smallest_seqno); in TEST_F()
305 ASSERT_EQ(0, file_meta.fd.smallest_seqno); in TEST_F()
410 ASSERT_EQ(smallest_seqs[k], file_meta.fd.smallest_seqno); in TEST_F()
Dimport_column_family_job.cc154 f.largest_internal_key, file_metadata.smallest_seqno, in Run()
Dversion_builder_test.cc61 bool sampled = false, SequenceNumber smallest_seqno = 0, in Add() argument
67 GetInternalKey(largest, largest_seq), smallest_seqno, largest_seqno, in Add()
Dversion_set.cc1441 static_cast<size_t>(file->fd.GetFileSize()), file->fd.smallest_seqno, in GetColumnFamilyMetaData()
2754 return f1.file->fd.smallest_seqno < in UpdateFilesByCompactionPri()
2755 f2.file->fd.smallest_seqno; in UpdateFilesByCompactionPri()
3154 f->fd.GetNumber(), f->fd.smallest_seqno, sztxt, in LevelFileSummary()
3435 AppendNumberTo(&r, files[i]->fd.smallest_seqno); in DebugString()
5251 f->fd.smallest_seqno, f->fd.largest_seqno, in WriteCurrentStateToManifest()
5674 filemetadata.smallest_seqno = file->fd.smallest_seqno; in GetLiveFilesMetaData()
Dexternal_sst_file_ingestion_job.cc628 if (file->fd.smallest_seqno == 0) { in CheckLevelForIngestedBehindFile()
Drepair.cc587 table->meta.largest, table->meta.fd.smallest_seqno, in AddTables()
Dlistener_test.cc827 ASSERT_LE(flush_job_info.smallest_seqno, latest_seq_number_); in OnFlushCompleted()
Ddb_test.cc1051 ASSERT_EQ(file_meta_from_cf.smallest_seqno, in CheckColumnFamilyMeta()
1052 file_meta_from_files.fd.smallest_seqno); in CheckColumnFamilyMeta()
1106 ASSERT_EQ(meta.smallest_seqno, expected_meta.fd.smallest_seqno); in CheckLiveFilesMeta()
Ddb_range_del_test.cc202 ASSERT_GT(files[0][0].fd.smallest_seqno, 0); in TEST_F()
/rocksdb-6.9/db/compaction/
Dcompaction_picker_universal.cc197 SequenceNumber* smallest_seqno, in GetSmallestLargestSeqno() argument
201 assert(f->fd.smallest_seqno <= f->fd.largest_seqno); in GetSmallestLargestSeqno()
204 *smallest_seqno = f->fd.smallest_seqno; in GetSmallestLargestSeqno()
207 if (f->fd.smallest_seqno < *smallest_seqno) { in GetSmallestLargestSeqno()
208 *smallest_seqno = f->fd.smallest_seqno; in GetSmallestLargestSeqno()
484 assert(f->fd.smallest_seqno <= f->fd.largest_seqno); in PickCompaction()
488 prev_smallest_seqno = f->fd.smallest_seqno; in PickCompaction()
494 SequenceNumber smallest_seqno = 0U; in PickCompaction() local
496 GetSmallestLargestSeqno(*(c->inputs(level_index)), &smallest_seqno, in PickCompaction()
509 prev_smallest_seqno = smallest_seqno; in PickCompaction()
Dcompaction_job_test.cc138 SequenceNumber smallest_seqno = kMaxSequenceNumber; in AddMockFile() local
148 smallest_seqno = std::min(smallest_seqno, key.sequence); in AddMockFile()
189 smallest_seqno, largest_seqno, false, oldest_blob_file_number, in AddMockFile()
/rocksdb-6.9/include/rocksdb/
Dmetadata.h59 smallest_seqno(0), in SstFileMetaData()
80 smallest_seqno(_smallest_seqno), in SstFileMetaData()
103 SequenceNumber smallest_seqno; // Smallest sequence number in file. member
Dlistener.h192 SequenceNumber smallest_seqno; member
/rocksdb-6.9/utilities/checkpoint/
Dcheckpoint_impl.cc431 live_file_metadata.smallest_seqno = file_metadata.smallest_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.cc620 info.smallest_seqno = file_meta->fd.smallest_seqno; in NotifyOnFlushBegin()
1314 f->fd.smallest_seqno, f->fd.largest_seqno, in ReFitLevel()
2733 f->largest, f->fd.smallest_seqno, in BackgroundCompaction()
Ddb_impl_open.cc1272 meta.fd.smallest_seqno, meta.fd.largest_seqno, in WriteLevel0TableForRecovery()
/rocksdb-6.9/utilities/blob_db/
Dblob_db_test.cc1727 info.smallest_seqno = 1; in TEST_F()
1756 info.smallest_seqno = 101; in TEST_F()
1886 info.smallest_seqno = 201; in TEST_F()

12