| /frameworks/base/tests/CoreTests/android/core/ |
| D | RequestAPITest.java | 49 private RequestQueue mRequestQueue; field in RequestAPITest
55 mRequestQueue = new RequestQueue(mContext); in setUp()
73 mRequestQueue.queueRequest( in verifyFailure()
122 RequestHandle handle = mRequestQueue.queueRequest( in verifySuccess()
198 RequestHandle handle = mRequestQueue.queueRequest( in testGet()
232 RequestHandle handle0 = mRequestQueue.queueRequest( in testReuse()
236 RequestHandle handle1 = mRequestQueue.queueRequest( in testReuse()
269 Log.d(LOGTAG, "testHead start - rq = " + mRequestQueue); in testHead()
271 RequestHandle handle = mRequestQueue.queueRequest( in testHead()
296 Log.d(LOGTAG, "testChunked start - rq = " + mRequestQueue); in testChunked()
[all …]
|
| /frameworks/base/core/java/android/service/remotelockscreenvalidation/ |
| D | RemoteLockscreenValidationClientImpl.java | 53 private final Queue<Call> mRequestQueue; field in RemoteLockscreenValidationClientImpl
72 mRequestQueue = new ArrayDeque<>(); in RemoteLockscreenValidationClientImpl()
122 mRequestQueue.clear(); in disconnectInternal()
151 for (Call call : new ArrayList<>(mRequestQueue)) { in onConnectedInternal()
153 mRequestQueue.remove(call); in onConnectedInternal()
195 mRequestQueue.add(call); in executeInternal()
|
| /frameworks/opt/telephony/src/java/com/android/internal/telephony/ |
| D | GbaManager.java | 83 private final ConcurrentLinkedQueue<GbaAuthRequest> mRequestQueue = field in GbaManager
109 if (mRequestQueue.isEmpty()) { in handleMessage()
261 mRequestQueue.offer(req); in bootstrapAuthenticationRequest()
322 while (!mRequestQueue.isEmpty()) { in processRequests()
323 GbaAuthRequest request = new GbaAuthRequest(mRequestQueue.peek()); in processRequests()
329 mRequestQueue.poll(); in processRequests()
337 while (!mRequestQueue.isEmpty()) { in processRequests()
338 GbaAuthRequest req = mRequestQueue.poll(); in processRequests()
520 mRequestQueue.clear(); in destroy()
|
| /frameworks/base/services/companion/java/com/android/server/companion/transport/ |
| D | SecureTransport.java | 37 private final BlockingQueue<byte[]> mRequestQueue = new ArrayBlockingQueue<>(500); field in SecureTransport
85 mRequestQueue.add(ByteBuffer.allocate(HEADER_LENGTH + data.length) in sendMessage()
119 byte[] request = mRequestQueue.take(); in onSecureConnection()
|
| /frameworks/base/core/java/android/service/quickaccesswallet/ |
| D | QuickAccessWalletClientImpl.java | 68 private final Queue<ApiCaller> mRequestQueue; field in QuickAccessWalletClientImpl
88 mRequestQueue = new ArrayDeque<>(); in QuickAccessWalletClientImpl()
380 for (ApiCaller apiCaller : new ArrayList<>(mRequestQueue)) { in onConnectedInternal()
382 mRequestQueue.remove(apiCaller); in onConnectedInternal()
414 mRequestQueue.clear(); in disconnectInternal()
425 mRequestQueue.add(apiCaller); in executeInternal()
|
| /frameworks/av/media/utils/ |
| D | TimerThread.cpp | 280 mRequestQueue.emplace_back(std::chrono::system_clock::now(), std::move(request)); in add()
281 if (mRequestQueue.size() > mRequestQueueMax) { in add()
282 mRequestQueue.pop_front(); in add()
289 const size_t size = mRequestQueue.size(); in copyRequests()
292 const auto &[time, request] = mRequestQueue[i]; in copyRequests()
|
| /frameworks/base/services/core/java/com/android/server/incident/ |
| D | PendingReports.java | 60 private final RequestQueue mRequestQueue = new RequestQueue(mHandler); field in PendingReports
151 mRequestQueue.enqueue(listener.asBinder(), true, () -> { in authorizeReport()
168 mRequestQueue.enqueue(listener.asBinder(), false, () -> { in cancelAuthorization()
268 mRequestQueue.start(); in onBootCompleted()
|
| /frameworks/av/media/utils/include/mediautils/ |
| D | TimerThread.h | 299 mRequestQueue GUARDED_BY(mRQMutex);
|
| /frameworks/av/services/camera/libcameraservice/device3/ |
| D | Camera3Device.cpp | 3114 mRequestQueue.push_back(*it); in queueRequestList()
3118 *lastFrameNumber = mFrameNumber + mRequestQueue.size() - 1; in queueRequestList()
3254 for (RequestList::iterator it = mRequestQueue.begin(); in clear()
3255 it != mRequestQueue.end(); ++it) { in clear()
3283 mRequestQueue.clear(); in clear()
4196 for (const auto& request : mRequestQueue) { in isStreamPending()
4228 for (const auto& request : mRequestQueue) { in isOutputSurfacePending()
4508 while (mRequestQueue.empty()) { in waitForNextRequestLocked()
4528 mRequestQueue.insert(mRequestQueue.end(), in waitForNextRequestLocked()
4542 if ((mRequestQueue.empty() && mRepeatingRequests.empty()) || in waitForNextRequestLocked()
[all …]
|
| D | Camera3Device.h | 1163 RequestList mRequestQueue; variable
|
| /frameworks/av/services/camera/libcameraservice/device3/aidl/ |
| D | AidlCamera3Device.cpp | 1503 bool queueEmpty = mNextRequests.empty() && mRequestQueue.empty(); in switchToOffline()
1514 queueEmpty = mNextRequests.empty() && mRequestQueue.empty(); in switchToOffline()
|
| /frameworks/av/services/camera/libcameraservice/device3/hidl/ |
| D | HidlCamera3Device.cpp | 1743 bool queueEmpty = mNextRequests.empty() && mRequestQueue.empty(); in switchToOffline()
1754 queueEmpty = mNextRequests.empty() && mRequestQueue.empty(); in switchToOffline()
|