Searched refs:mRequestQueue (Results 1 – 9 of 9) sorted by relevance
48 private RequestQueue mRequestQueue; field in RequestAPITest54 mRequestQueue = new RequestQueue(mContext); in setUp()72 mRequestQueue.queueRequest( in verifyFailure()121 RequestHandle handle = mRequestQueue.queueRequest( in verifySuccess()197 RequestHandle handle = mRequestQueue.queueRequest( in testGet()231 RequestHandle handle0 = mRequestQueue.queueRequest( in testReuse()235 RequestHandle handle1 = mRequestQueue.queueRequest( in testReuse()270 RequestHandle handle = mRequestQueue.queueRequest( in testHead()297 RequestHandle handle = mRequestQueue.queueRequest( in testChunked()433 RequestHandle handle = mRequestQueue.queueRequest( in testPost()[all …]
82 private final ConcurrentLinkedQueue<GbaAuthRequest> mRequestQueue = field in GbaManager108 if (mRequestQueue.isEmpty()) { in handleMessage()256 mRequestQueue.offer(req); in bootstrapAuthenticationRequest()317 while (!mRequestQueue.isEmpty()) { in processRequests()318 GbaAuthRequest request = new GbaAuthRequest(mRequestQueue.peek()); in processRequests()324 mRequestQueue.poll(); in processRequests()332 while (!mRequestQueue.isEmpty()) { in processRequests()333 GbaAuthRequest req = mRequestQueue.poll(); in processRequests()515 mRequestQueue.clear(); in destroy()
88 private final PriorityQueue<LocalRequest> mRequestQueue = field in IkeLocalRequestScheduler111 mRequestQueue.offer(request); in addRequest()122 if (!mRequestQueue.isEmpty()) { in readyForNextProcedure()123 mConsumer.onNewProcedureReady(mRequestQueue.poll()); in readyForNextProcedure()131 for (LocalRequest req : mRequestQueue) { in releaseAllLocalRequestWakeLocks()134 mRequestQueue.clear(); in releaseAllLocalRequestWakeLocks()
44 private RequestQueue mRequestQueue; field in WallpaperRequester49 mRequestQueue = Volley.newRequestQueue(context.getApplicationContext()); in WallpaperRequester()54 mRequestQueue.add(request); in addToRequestQueue()
67 private final Queue<ApiCaller> mRequestQueue; field in QuickAccessWalletClientImpl86 mRequestQueue = new LinkedList<>(); in QuickAccessWalletClientImpl()360 for (ApiCaller apiCaller : new ArrayList<>(mRequestQueue)) { in onConnectedInternal()362 mRequestQueue.remove(apiCaller); in onConnectedInternal()394 mRequestQueue.clear(); in disconnectInternal()405 mRequestQueue.add(apiCaller); in executeInternal()
1224 mRequestQueue.add(tunnelRequestWrapper); in handleMessage()1233 mRequestQueue.add(tunnelRequestWrapper); in handleMessage()1277 mRequestQueue.poll(); in handleMessage()1297 mRequestQueue.poll(); in handleMessage()1303 mRequestQueue.poll(); in handleMessage()1465 int queueSize = mRequestQueue.size(); in closePendingRequestsForApn()1479 mRequestQueue.add(requestWrapper); in closePendingRequestsForApn()1511 mRequestQueue = new LinkedList<>(); in resetTunnelManagerState()1517 while (mRequestQueue.size() > 0) { in serviceAllPendingRequests()1519 TunnelRequestWrapper request = mRequestQueue.poll(); in serviceAllPendingRequests()[all …]
52 private final RequestQueue mRequestQueue = new RequestQueue(mHandler); field in PendingReports141 mRequestQueue.enqueue(listener.asBinder(), true, () -> { in authorizeReport()158 mRequestQueue.enqueue(listener.asBinder(), false, () -> { in cancelAuthorization()258 mRequestQueue.start(); in onBootCompleted()
4240 mRequestQueue.push_back(*it); in queueRequestList()4371 for (RequestList::iterator it = mRequestQueue.begin(); in clear()4372 it != mRequestQueue.end(); ++it) { in clear()4400 mRequestQueue.clear(); in clear()5229 for (const auto& request : mRequestQueue) { in isStreamPending()5261 for (const auto& request : mRequestQueue) { in isOutputSurfacePending()5523 while (mRequestQueue.empty()) { in waitForNextRequestLocked()5543 mRequestQueue.insert(mRequestQueue.end(), in waitForNextRequestLocked()5585 mRequestQueue.begin(); in waitForNextRequestLocked()5587 mRequestQueue.erase(firstRequest); in waitForNextRequestLocked()[all …]
1033 RequestList mRequestQueue; variable