Searched refs:ConflictBatch (Results 1 – 4 of 4) sorted by relevance
32 struct ConflictBatch { struct33 explicit ConflictBatch( ConflictSet* );34 ~ConflictBatch();
964 ConflictBatch::ConflictBatch( ConflictSet* cs ) in ConflictBatch() function in ConflictBatch969 ConflictBatch::~ConflictBatch() in ~ConflictBatch()979 void ConflictBatch::addTransaction( const CommitTransactionRef& tr ) { in addTransaction()1133 void ConflictBatch::checkIntraBatchConflicts() { in checkIntraBatchConflicts()1155 void ConflictBatch::GetTooOldTransactions(vector<int>& tooOldTransactions) { in GetTooOldTransactions()1163 void ConflictBatch::detectConflicts(Version now, Version newOldestVersion, vector<int>& nonConflict… in detectConflicts()1210 void ConflictBatch::checkReadConflictRanges() { in checkReadConflictRanges()1235 void ConflictBatch::addConflictRanges(Version now, vector< pair<StringRef,StringRef> >::iterator be… in addConflictRanges()1260 void ConflictBatch::mergeWriteConflictRanges(Version now) { in mergeWriteConflictRanges()1320 void ConflictBatch::combineWriteConflictRanges() in combineWriteConflictRanges()[all …]
139 ConflictBatch conflictBatch( self->conflictSet ); in resolveBatch()162 reply.committed[commitList[c]] = ConflictBatch::TransactionCommitted; in resolveBatch()165 reply.committed[tooOldList[c]] = ConflictBatch::TransactionTooOld; in resolveBatch()173 …(stateTransactions.arena(), StateTransactionRef(reply.committed[t] == ConflictBatch::TransactionCo… in resolveBatch()
586 uint8_t commit = ConflictBatch::TransactionCommitted; in commitBatch()604 if( committed[t] == ConflictBatch::TransactionCommitted ) { in commitBatch()613 committed[t] = ConflictBatch::TransactionConflict; in commitBatch()628 if (committed[t] == ConflictBatch::TransactionCommitted && (!locked || trs[t].isLockAware())) { in commitBatch()633 ASSERT(committed[t] == ConflictBatch::TransactionCommitted); in commitBatch()640 committed[t] = ConflictBatch::TransactionConflict; in commitBatch()671 …if (committed[transactionNum] == ConflictBatch::TransactionCommitted && (!locked || trs[transactio… in commitBatch()966 if (committed[t] == ConflictBatch::TransactionCommitted && (!locked || trs[t].isLockAware())) { in commitBatch()970 else if (committed[t] == ConflictBatch::TransactionTooOld) { in commitBatch()