Home
last modified time | relevance | path

Searched refs:assigned_seqno (Results 1 – 4 of 4) sorted by relevance

/rocksdb-6.9/db/
Dexternal_sst_file_ingestion_job.cc225 SequenceNumber assigned_seqno = 0; in Run() local
231 last_seqno, &f, &assigned_seqno); in Run()
238 &assigned_seqno); in Run()
239 if (assigned_seqno > last_seqno) { in Run()
241 last_seqno = assigned_seqno; in Run()
529 SequenceNumber* assigned_seqno) { in AssignLevelAndSeqnoForIngestedFile() argument
531 *assigned_seqno = 0; in AssignLevelAndSeqnoForIngestedFile()
533 *assigned_seqno = last_seqno + 1; in AssignLevelAndSeqnoForIngestedFile()
601 *assigned_seqno = last_seqno + 1; in AssignLevelAndSeqnoForIngestedFile()
608 *assigned_seqno = last_seqno + 1; in AssignLevelAndSeqnoForIngestedFile()
[all …]
Dexternal_sst_file_ingestion_job.h56 SequenceNumber assigned_seqno = 0; member
140 SequenceNumber* assigned_seqno);
Dexternal_sst_file_test.cc1101 SequenceNumber assigned_seqno = 0; in TEST_F() local
1103 "ExternalSstFileIngestionJob::Run", [&assigned_seqno](void* arg) { in TEST_F()
1105 assigned_seqno = *(static_cast<SequenceNumber*>(arg)); in TEST_F()
1187 need_flush || assigned_seqno > 0 || overlap_with_db) { in TEST_F()
/rocksdb-6.9/db/db_impl/
Ddb_impl.cc4471 info.global_seqno = f.assigned_seqno; in NotifyOnExternalFileIngested()