Home
last modified time | relevance | path

Searched refs:last_seqno (Results 1 – 5 of 5) sorted by relevance

/rocksdb-6.9/db/
Dexternal_sst_file_basic_test.cc318 ASSERT_EQ(dbfull()->GetLatestSequenceNumber(), last_seqno); in TEST_P()
324 ASSERT_EQ(dbfull()->GetLatestSequenceNumber(), last_seqno + 1); in TEST_P()
330 ASSERT_EQ(dbfull()->GetLatestSequenceNumber(), last_seqno + 2); in TEST_P()
340 ASSERT_EQ(dbfull()->GetLatestSequenceNumber(), last_seqno + 3); in TEST_P()
445 ASSERT_EQ(dbfull()->GetLatestSequenceNumber(), last_seqno); in TEST_P()
594 ASSERT_EQ(dbfull()->GetLatestSequenceNumber(), last_seqno); in TEST_P()
874 ASSERT_EQ(dbfull()->GetLatestSequenceNumber(), ++last_seqno); in TEST_P()
885 ASSERT_EQ(dbfull()->GetLatestSequenceNumber(), ++last_seqno); in TEST_P()
895 ASSERT_EQ(dbfull()->GetLatestSequenceNumber(), ++last_seqno); in TEST_P()
908 ASSERT_EQ(dbfull()->GetLatestSequenceNumber(), ++last_seqno); in TEST_P()
[all …]
Dexternal_sst_file_ingestion_job.cc220 SequenceNumber last_seqno = versions_->LastSequence(); in Run() local
231 last_seqno, &f, &assigned_seqno); in Run()
239 if (assigned_seqno > last_seqno) { in Run()
240 assert(assigned_seqno == last_seqno + 1); in Run()
241 last_seqno = assigned_seqno; in Run()
528 SequenceNumber last_seqno, IngestedFileInfo* file_to_ingest, in AssignLevelAndSeqnoForIngestedFile() argument
533 *assigned_seqno = last_seqno + 1; in AssignLevelAndSeqnoForIngestedFile()
601 *assigned_seqno = last_seqno + 1; in AssignLevelAndSeqnoForIngestedFile()
608 *assigned_seqno = last_seqno + 1; in AssignLevelAndSeqnoForIngestedFile()
Dversion_set_test.cc678 SequenceNumber* last_seqno, std::unique_ptr<log::Writer>* log_writer) { in PrepareManifest() argument
680 assert(last_seqno != nullptr); in PrepareManifest()
709 *last_seqno = last_seq; in PrepareManifest()
741 SequenceNumber last_seqno; in NewDB() local
744 PrepareManifest(&column_families, &last_seqno, &log_writer); in NewDB()
1241 SequenceNumber last_seqno; in TEST_P() local
1243 PrepareManifest(&column_families, &last_seqno, &log_writer); in TEST_P()
1290 edits[i].SetLastSequence(last_seqno++); in TEST_P()
1723 SequenceNumber* last_seqno, in PrepareManifest() argument
1726 assert(last_seqno != nullptr); in PrepareManifest()
[all …]
Dexternal_sst_file_ingestion_job.h138 SequenceNumber last_seqno,
/rocksdb-6.9/db/db_impl/
Ddb_impl.cc4183 const SequenceNumber last_seqno = versions_->LastSequence(); in IngestExternalFiles() local
4184 versions_->SetLastAllocatedSequence(last_seqno + consumed_seqno_count); in IngestExternalFiles()
4185 versions_->SetLastPublishedSequence(last_seqno + consumed_seqno_count); in IngestExternalFiles()
4186 versions_->SetLastSequence(last_seqno + consumed_seqno_count); in IngestExternalFiles()