| /frameworks/libs/net/common/devicetests/com/android/testutils/ |
| D | TestableNetworkStatsProvider.kt | 53 assertEquals(CallbackType.OnRequestStatsUpdate(token), history.poll(timeout)) in expectOnRequestStatsUpdate()
57 assertEquals(CallbackType.OnSetLimit(iface, quotaBytes), history.poll(timeout)) in expectOnSetLimit()
61 assertEquals(CallbackType.OnSetAlert(quotaBytes), history.poll(timeout)) in expectOnSetAlert()
65 history.poll(timeout) ?: fail("Did not receive callback after ${timeout}ms") in pollForNextCallback()
87 ) = history.poll(timeoutMs, from) { it is T && predicate(it) } as T in <lambda>()
95 val cb = history.poll(timeout) in assertNoCallback()
|
| D | TestableNetworkStatsProviderCbBinder.kt | 59 val event = history.poll(DEFAULT_TIMEOUT_MS) in expectNotifyStatsUpdated()
64 val event = history.poll(DEFAULT_TIMEOUT_MS)!! in expectNotifyStatsUpdated()
74 assertEquals(CallbackType.NotifyLimitReached, history.poll(DEFAULT_TIMEOUT_MS)) in expectNotifyLimitReached()
77 assertEquals(CallbackType.NotifyAlertReached, history.poll(DEFAULT_TIMEOUT_MS)) in expectNotifyLimitReached()
81 val cb = history.poll(0) in expectNotifyLimitReached()
|
| D | TestableNetworkStatsProviderBinder.kt | 48 assertEquals(CallbackType.OnRequestStatsUpdate(token), history.poll(DEFAULT_TIMEOUT_MS)) in expectOnRequestStatsUpdate()
52 assertEquals(CallbackType.OnSetLimit(iface, quotaBytes), history.poll(DEFAULT_TIMEOUT_MS)) in expectOnSetLimit()
56 assertEquals(CallbackType.OnSetAlert(quotaBytes), history.poll(DEFAULT_TIMEOUT_MS)) in expectOnSetAlert()
61 val cb = history.poll(timeout) in assertNoCallback()
|
| D | TapPacketReader.java | 71 return mReadHead.getValue().poll(timeoutMs, packet -> true); in popPacket()
79 return mReadHead.getValue().poll(timeoutMs, filter::test); in popPacket()
|
| D | TestableNetworkCallback.kt | 169 return history.poll(timeoutMs) ?: fail("Did not receive callback after ${timeoutMs}ms") in pollForNextCallback()
175 val cb = history.poll(timeoutMs) in assertNoCallback()
208 ) = history.poll(timeoutMs, from) { it is T && predicate(it) } as T? in <lambda>()
283 val firstCaps = history.poll(tmt, mark) { it is CapabilitiesChanged } in expectAvailableDoubleValidatedCallbacks()
|
| /frameworks/base/core/java/android/hardware/camera2/legacy/ |
| D | PerfMeasurement.java | 188 NO_DURATION_YET : mTimestampQueue.poll()); in stopTimer()
190 NO_DURATION_YET : mCpuDurationsQueue.poll()); in stopTimer()
195 mTimestampQueue.poll(); in stopTimer()
198 mCpuDurationsQueue.poll(); in stopTimer()
|
| D | CaptureCollector.java | 473 CaptureHolder h = mJpegCaptureQueue.poll(); in jpegCaptured()
494 CaptureHolder h = mJpegProduceQueue.poll(); in jpegProduced()
531 CaptureHolder h = mPreviewCaptureQueue.poll(); in previewCaptured()
554 CaptureHolder h = mPreviewProduceQueue.poll(); in previewProduced()
|
| /frameworks/base/core/tests/coretests/src/android/app/ |
| D | DownloadManagerBaseTest.java | 680 protected void waitForDownloadOrTimeout(long id, long poll, long timeoutMillis) in waitForDownloadOrTimeout() argument
682 doWaitForDownloadsOrTimeout(new Query().setFilterById(id), poll, timeoutMillis); in waitForDownloadOrTimeout()
694 protected void waitForDownloadsOrTimeout(long poll, long timeoutMillis) throws TimeoutException, in waitForDownloadsOrTimeout() argument
696 doWaitForDownloadsOrTimeout(new Query(), poll, timeoutMillis); in waitForDownloadsOrTimeout()
709 protected boolean waitForDownloadOrTimeoutNoThrow(long id, long poll, long timeoutMillis) { in waitForDownloadOrTimeoutNoThrow() argument
711 doWaitForDownloadsOrTimeout(new Query().setFilterById(id), poll, timeoutMillis); in waitForDownloadOrTimeoutNoThrow()
730 protected int timeoutWait(int currentTotalWaitTime, long poll, long maxTimeoutMillis, in timeoutWait() argument
733 long end = now + poll; in timeoutWait()
745 currentTotalWaitTime += poll; in timeoutWait()
759 protected void doWaitForDownloadsOrTimeout(Query query, long poll, long timeoutMillis) in doWaitForDownloadsOrTimeout() argument
[all …]
|
| /frameworks/base/packages/SystemUI/tests/src/com/android/systemui/statusbar/policy/ |
| D | BlockingQueueIntentReceiver.java | 35 return mQueue.poll(10, TimeUnit.SECONDS); in waitForIntent()
39 return mQueue.poll(3, TimeUnit.SECONDS); in waitForIntentShortDelay()
|
| /frameworks/base/core/java/android/view/accessibility/ |
| D | WeakSparseArray.java | 48 for (Reference ref = mRefQueue.poll(); ref != null; ref = mRefQueue.poll()) { in removeUnreachableValues()
|
| /frameworks/libs/net/common/hostdevice/com/android/net/module/util/ |
| D | TrackRecord.kt | 45 fun poll(timeoutMs: Long, pos: Int, predicate: (E) -> Boolean = { true }): E? in add() method
102 override fun poll(timeoutMs: Long, pos: Int, predicate: (E) -> Boolean) = lock.withLock { in <lambda>() method
227 fun poll(timeoutMs: Long, predicate: (E) -> Boolean = { true }): E? { in newReadHead() method
|
| /frameworks/opt/bitmap/src/com/android/bitmap/ |
| D | UnrefedBitmapCache.java | 83 public ReusableBitmap poll() { in poll() method in UnrefedBitmapCache
86 while ((bitmap = super.poll()) == null && mBlocking) { in poll()
|
| D | PooledCache.java | 24 V poll(); in poll() method
|
| D | UnrefedPooledCache.java | 121 public V poll() { in poll() method in UnrefedPooledCache
123 final V pooled = mPool.poll(); in poll()
|
| /frameworks/native/services/sensorservice/ |
| D | SensorsWrapper.h | 82 virtual Return<void> poll(int32_t maxCount, ISensors::poll_cb _hidl_cb) { in poll() function
165 Return<void> poll(int32_t maxCount, in poll() function
167 return mSensors->poll(maxCount, _hidl_cb); in poll()
|
| /frameworks/base/services/tests/servicestests/utils/com/android/server/testutils/ |
| D | TestHandler.java | 88 dispatch(mMessages.poll()); in timeAdvance()
99 while ((msg = mMessages.poll()) != null) { in flush()
|
| /frameworks/base/packages/SystemUI/legacy/recents/src/com/android/systemui/recents/model/ |
| D | TaskResourceLoadQueue.java | 44 return mQueue.poll(); in nextTask()
|
| /frameworks/base/core/java/android/speech/tts/ |
| D | SynthesisPlaybackQueueItem.java | 245 ProgressMarker marker = markerList.poll(); in onMarkerReached()
303 ListEntry entry = mDataBufferList.poll(); in take()
|
| /frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/tests/src/androidx/media/filterfw/ |
| D | FrameSourceFilter.java | 48 return mFrames.poll(); in obtainFrame()
|
| /frameworks/av/services/audioflinger/ |
| D | FastCapture.h | 41 virtual const FastThreadState *poll();
|
| D | FastCapture.cpp | 56 const FastThreadState *FastCapture::poll() in poll() function in android::FastCapture
58 return mSQ.poll(); in poll()
|
| D | StateQueue.h | 141 const T* poll();
|
| /frameworks/base/core/tests/hosttests/test-apps/DownloadManagerTestApp/src/com/android/frameworks/downloadmanagertests/ |
| D | DownloadManagerBaseTest.java | 394 private int timeoutWait(int currentTotalWaitTime, long poll, long maxTimeoutMillis, in timeoutWait() argument
397 long end = now + poll; in timeoutWait()
409 currentTotalWaitTime += poll; in timeoutWait()
|
| /frameworks/base/apct-tests/perftests/autofill/src/android/view/autofill/ |
| D | MyAutofillService.java | 84 request = sFillRequests.poll(TIMEOUT_MS, TimeUnit.MILLISECONDS); in getLastFillRequest()
114 CannedResponse response = sCannedResponses.poll(TIMEOUT_MS, TimeUnit.MILLISECONDS); in handleRequest()
|
| /frameworks/base/tests/net/common/java/android/net/ |
| D | NetworkProviderTest.kt | 87 ) = seenEvents.poll(DEFAULT_TIMEOUT_MS) { it is T && predicate(it) } in <lambda>()
167 ) = seenEvents.poll(DEFAULT_TIMEOUT_MS) { it is T && predicate(it) } in <lambda>()
|