Searched refs:rtxn (Results 1 – 4 of 4) sorted by relevance
19 const DBImpl::RecoveredTransaction* rtxn) { in RollbackRecoveredTransaction() argument21 assert(rtxn->unprepared_); in RollbackRecoveredTransaction()59 for (auto it = rtxn->batches_.rbegin(); it != rtxn->batches_.rend(); ++it) { in RollbackRecoveredTransaction()170 WriteBatchInternal::MarkRollback(&rollback_batch, rtxn->name_); in RollbackRecoveredTransaction()247 for (auto rtxn : rtxns) { in Initialize() local248 auto recovered_trx = rtxn.second; in Initialize()331 for (auto rtxn : rtxns) { in Initialize() local332 auto recovered_trx = rtxn.second; in Initialize()
37 for (auto rtxn : rtxns) { in Initialize() local39 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()
36 Status RollbackRecoveredTransaction(const DBImpl::RecoveredTransaction* rtxn);
788 auto rtxn = recovered_transactions_.find(name); in InsertRecoveredTransaction() local789 if (rtxn == recovered_transactions_.end()) { in InsertRecoveredTransaction()793 rtxn->second->AddBatch(seq, log, batch, batch_cnt, unprepared_batch); in InsertRecoveredTransaction()