Lines Matching refs:seq
128 uint64_t seq; in WriteImpl() local
132 log_used, log_ref, &seq, sub_batch_cnt, in WriteImpl()
140 *seq_used = seq; in WriteImpl()
145 log_ref, seq, sub_batch_cnt); in WriteImpl()
602 SequenceNumber seq, in UnorderedWriteMemtable() argument
611 w.sequence = seq; in UnorderedWriteMemtable()
1151 SequenceNumber seq; in WriteRecoverableState() local
1153 seq = versions_->FetchAddLastAllocatedSequence(0); in WriteRecoverableState()
1155 seq = versions_->LastSequence(); in WriteRecoverableState()
1157 WriteBatchInternal::SetSequence(&cached_recoverable_state_, seq + 1); in WriteRecoverableState()
1165 versions_->FetchAddLastAllocatedSequence(last_seq - seq); in WriteRecoverableState()
1174 for (uint64_t sub_batch_seq = seq + 1; in WriteRecoverableState()
1210 auto seq = versions_->LastSequence(); in AssignAtomicFlushSeq() local
1212 cfd->imm()->AssignAtomicFlushSeq(seq); in AssignAtomicFlushSeq()
1343 uint64_t seq = cfd->mem()->GetCreationSeq(); in HandleWriteBufferFull() local
1344 if (cfd_picked == nullptr || seq < seq_num_for_cf_picked) { in HandleWriteBufferFull()
1346 seq_num_for_cf_picked = seq; in HandleWriteBufferFull()
1689 SequenceNumber seq = versions_->LastSequence(); in SwitchMemtable() local
1690 new_mem = cfd->ConstructNewMemtable(mutable_cf_options, seq); in SwitchMemtable()