Searched refs:mCompletedTransactions (Results 1 – 6 of 6) sorted by relevance
63 for (const auto& [listener, transactionStats] : mCompletedTransactions) { in ~TransactionCompletedThread()94 if (mCompletedTransactions.count(listener) == 0) { in startRegistration()101 auto& transactionStatsDeque = mCompletedTransactions[listener]; in startRegistration()213 auto& transactionStatsDeque = mCompletedTransactions[listener]; in findTransactionStats()274 auto completedTransactionsItr = mCompletedTransactions.begin(); in threadMain()275 while (completedTransactionsItr != mCompletedTransactions.end()) { in threadMain()327 mCompletedTransactions.erase(completedTransactionsItr); in threadMain()333 mCompletedTransactions.erase(completedTransactionsItr); in threadMain()
127 mCompletedTransactions GUARDED_BY(mMutex);
294 auto completed = mCompletedTransactions.find( in handleTransferTo()296 if (completed != mCompletedTransactions.end()) { in handleTransferTo()298 mCompletedTransactions.erase(completed); in handleTransferTo()357 mCompletedTransactions.insert(message.transactionId); in handleTransferResult()449 mCompletedTransactions.insert(transactionId); in handleClose()
89 std::set<TransactionId> mCompletedTransactions; member
477 auto completed = mCompletedTransactions.find( in handleTransferTo()479 if (completed != mCompletedTransactions.end()) { in handleTransferTo()481 mCompletedTransactions.erase(completed); in handleTransferTo()540 mCompletedTransactions.insert(message.transactionId); in handleTransferResult()650 mCompletedTransactions.insert(transactionId); in handleClose()
111 std::set<TransactionId> mCompletedTransactions; member