Searched refs:mPendingRequests (Results 1 – 9 of 9) sorted by relevance
46 protected @NonNull List<BasePendingRequest<S, I>> mPendingRequests; field in AbstractMultiplePendingRequestsRemoteService55 mPendingRequests = new ArrayList<>(mInitialCapacity); in AbstractMultiplePendingRequestsRemoteService()60 synchronized (mPendingRequests) { in handlePendingRequests()61 final int size = mPendingRequests.size(); in handlePendingRequests()64 handlePendingRequest(mPendingRequests.get(i)); in handlePendingRequests()66 mPendingRequests.clear(); in handlePendingRequests()72 synchronized (mPendingRequests) { in handleOnDestroy()73 final int size = mPendingRequests.size(); in handleOnDestroy()76 mPendingRequests.get(i).cancel(); in handleOnDestroy()78 mPendingRequests.clear(); in handleOnDestroy()[all …]
91 protected final SparseArray<CompletableFuture<byte[]>> mPendingRequests = field in Transport184 synchronized (mPendingRequests) { in requestForResponse()185 mPendingRequests.put(sequence, pending); in requestForResponse()191 synchronized (mPendingRequests) { in requestForResponse()192 mPendingRequests.remove(sequence); in requestForResponse()297 synchronized (mPendingRequests) { in processResponse()298 future = mPendingRequests.removeReturnOld(sequence); in processResponse()
188 final List<LogAccessRequest> mPendingRequests = new ArrayList<>(); field in LogcatManagerService.LogAccessStatus408 logAccessStatus.mPendingRequests.add(request); in onLogAccessRequested()412 logAccessStatus.mPendingRequests.add(request); in onLogAccessRequested()459 for (LogAccessRequest request : logAccessStatus.mPendingRequests) { in onAccessApprovedForClient()463 logAccessStatus.mPendingRequests.clear(); in onAccessApprovedForClient()472 for (LogAccessRequest request : logAccessStatus.mPendingRequests) { in onAccessDeclinedForClient()476 logAccessStatus.mPendingRequests.clear(); in onAccessDeclinedForClient()
476 mPendingRequests.add(cseq, reply); in onSendRequest()514 for (size_t i = 0; i < mPendingRequests.size(); ++i) { in flushPendingRequests()515 sp<AMessage> reply = mPendingRequests.valueAt(i); in flushPendingRequests()521 mPendingRequests.clear(); in flushPendingRequests()746 sp<AMessage> reply = mPendingRequests.valueAt(i); in receiveRTSPReponse()747 mPendingRequests.removeItemsAt(i); in receiveRTSPReponse()857 i = mPendingRequests.indexOfKey(cseq); in findPendingRequest()882 sp<AMessage> reply = mPendingRequests.valueAt(i); in notifyResponseListener()883 mPendingRequests.removeItemsAt(i); in notifyResponseListener()
93 KeyedVector<int32_t, sp<AMessage> > mPendingRequests; member
531 serviceState.mPendingRequests.add( in handleRequest()629 mServiceState.mPendingRequests.remove(this); in removeLocked()923 final FixedSizeQueue<PendingRequest> mPendingRequests = field in TextClassificationManagerService.ServiceState1021 while ((request = mPendingRequests.poll()) != null) { in handlePendingRequestsLocked()1044 return !mPendingRequests.isEmpty() && bindLocked(); in bindIfHasPendingRequestsLocked()1110 pw.printPair("numOfPendingRequests", mPendingRequests.size()); in dump()
272 private final List<PendingRequest> mPendingRequests = new ArrayList<>(); field in SmsDispatchersController.DomainSelectionConnectionHolder292 return mPendingRequests; in getPendingRequests()301 return !mPendingRequests.isEmpty(); in isDomainSelectionRequested()315 mPendingRequests.clear(); in clearAllRequests()322 mPendingRequests.add(request); in addRequest()
517 bool mPendingRequests; variable
2259 : mPendingRequests(false) {} in MediaLogNotifier()2264 mPendingRequests = true; in requestMerge()2276 mPendingRequests = false; // to ignore past requests in threadLoop()2277 while (!mPendingRequests) { in threadLoop()2281 mPendingRequests = false; in threadLoop()