Searched refs:mTransactionQueue (Results 1 – 4 of 4) sorted by relevance
70 if (mTransactionQueue.size() >= MAX_PENDING_REQUESTS in addTransaction()83 mTransactionQueue.add(transaction); in addTransaction()84 if (mTransactionQueue.size() == 1) { in addTransaction()99 ContextHubServiceTransaction transaction = mTransactionQueue.peek(); in onTransactionResponse()126 ContextHubServiceTransaction transaction = mTransactionQueue.peek(); in onMessageDeliveryResponse()181 ContextHubServiceTransaction transaction = mTransactionQueue.peek(); in onQueryResponse()208 ContextHubServiceTransaction transaction = mTransactionQueue.peek(); in onHubReset()232 ContextHubServiceTransaction transaction = mTransactionQueue.remove(); in removeTransactionAndStartNext()235 if (!mTransactionQueue.isEmpty()) { in removeTransactionAndStartNext()252 while (result != ContextHubTransaction.RESULT_SUCCESS && !mTransactionQueue.isEmpty()) { in startNextTransaction()[all …]
84 protected final ArrayDeque<ContextHubServiceTransaction> mTransactionQueue = new ArrayDeque<>(); field in ContextHubTransactionManager563 if (mTransactionQueue.size() >= MAX_PENDING_REQUESTS) {568 mTransactionQueue.add(transaction);569 if (mTransactionQueue.size() == 1) {720 ContextHubServiceTransaction transaction = mTransactionQueue.peek();740 transaction = mTransactionQueue.peek();747 mTransactionQueue.remove();748 if (!mTransactionQueue.isEmpty()) {769 ContextHubServiceTransaction transaction = mTransactionQueue.remove();774 if (!mTransactionQueue.isEmpty()) {[all …]
172 LocklessStack<perfetto::protos::TransactionState> mTransactionQueue; variable
172 mTransactionQueue.push(state); in addQueuedTransaction()235 while (auto incomingTransaction = mTransactionQueue.pop()) { in addEntry()