Searched refs:batches_ (Results 1 – 6 of 6) sorted by relevance
59 for (auto it = rtxn->batches_.rbegin(); it != rtxn->batches_.rend(); ++it) { in RollbackRecoveredTransaction()250 assert(recovered_trx->batches_.size() >= 1); in Initialize()264 auto first_log_number = recovered_trx->batches_.begin()->second.log_number_; in Initialize()265 auto first_seq = recovered_trx->batches_.begin()->first; in Initialize()267 recovered_trx->batches_.begin()->second.batch_cnt_; in Initialize()283 for (auto batch : recovered_trx->batches_) { in Initialize()
123 assert(recovered_trx->batches_.size() == 1); in Initialize()124 const auto& seq = recovered_trx->batches_.begin()->first; in Initialize()125 const auto& batch_info = recovered_trx->batches_.begin()->second; in Initialize()
39 assert(rtxn.second->batches_.size() == 1); in Initialize()40 const auto& seq = rtxn.second->batches_.begin()->first; in Initialize()41 const auto& batch_info = rtxn.second->batches_.begin()->second; in Initialize()990 batches_++; in AddKey()
1045 : comparators_(comparators), batches_(1) {} in SubBatchCounter()1049 size_t batches_; member1050 size_t BatchCount() { return batches_; } in BatchCount()
738 std::map<SequenceNumber, BatchInfo> batches_; member744 batches_[seq] = {log, batch, batch_cnt}; in RecoveredTransaction()748 for (auto& it : batches_) { in ~RecoveredTransaction()755 assert(batches_.count(seq) == 0); in AddBatch()756 batches_[seq] = {log_number, batch, batch_cnt}; in AddBatch()803 for (const auto& info : trx->batches_) { in DeleteRecoveredTransaction()
1902 assert(trx->batches_.size() == 1); in MarkCommit()1903 const auto& batch_info = trx->batches_.begin()->second; in MarkCommit()