Searched refs:seqno (Results 1 – 9 of 9) sorted by relevance
| /rocksdb-6.9/db/ |
| D | forward_iterator_bench.cc | 65 uint64_t seqno() const { return be64toh(seqno_be); } in seqno() function
167 assert(key.seqno() == seq); in readOnceFromShard()
243 uint64_t seqno = state.last_written.load() + 1; in run() local
244 Key key(shard, seqno); in run()
251 state.last_written.store(seqno); in run()
|
| D | version_edit.h | 171 SequenceNumber seqno, ValueType value_type);
176 const InternalKey& end, SequenceNumber seqno, in UpdateBoundariesForRange()
184 fd.smallest_seqno = std::min(fd.smallest_seqno, seqno); in UpdateBoundariesForRange()
185 fd.largest_seqno = std::max(fd.largest_seqno, seqno); in UpdateBoundariesForRange()
|
| D | flush_job_test.cc | 452 auto seqno = ++current_seqno; in TEST_F() local
453 new_mem->Add(SequenceNumber(seqno), kTypeValue, key, value); in TEST_F()
458 (snapshots_set.find(seqno) != snapshots_set.end()); in TEST_F()
460 InternalKey internal_key(key, seqno, kTypeValue); in TEST_F()
|
| D | external_sst_file_ingestion_job.cc | 641 IngestedFileInfo* file_to_ingest, SequenceNumber seqno) { in AssignGlobalSeqnoForIngestedFile() argument
642 if (file_to_ingest->original_seqno == seqno) { in AssignGlobalSeqnoForIngestedFile()
663 PutFixed64(&seqno_val, seqno); in AssignGlobalSeqnoForIngestedFile()
686 file_to_ingest->assigned_seqno = seqno; in AssignGlobalSeqnoForIngestedFile()
|
| D | version_edit.cc | 93 SequenceNumber seqno, in UpdateBoundaries() argument
99 fd.smallest_seqno = std::min(fd.smallest_seqno, seqno); in UpdateBoundaries()
100 fd.largest_seqno = std::max(fd.largest_seqno, seqno); in UpdateBoundaries()
|
| D | external_sst_file_ingestion_job.h | 150 SequenceNumber seqno);
|
| /rocksdb-6.9/utilities/transactions/ |
| D | transaction_base.h | 260 void TrackKey(uint32_t cfh_id, const std::string& key, SequenceNumber seqno,
265 const std::string& key, SequenceNumber seqno,
|
| /rocksdb-6.9/table/block_based/ |
| D | block.h | 594 explicit GlobalSeqnoState(SequenceNumber seqno) : global_seqno(seqno) {} in GlobalSeqnoState()
|
| D | block_based_table_reader.cc | 478 SequenceNumber* seqno) { in GetGlobalSequenceNumber() argument
483 *seqno = kDisableGlobalSequenceNumber; in GetGlobalSequenceNumber()
535 *seqno = global_seqno; in GetGlobalSequenceNumber()
|