/packages/modules/NetworkStack/tests/unit/src/android/net/testutils/ |
D | TrackRecordTest.kt | 158 val elapsed = measureTimeMillis { assertEquals(4, record.poll(LONG_TIMEOUT, 0)) } in <lambda>() 164 assertEquals(9, record.poll(0, 2)) in <lambda>() 165 assertEquals(7, record.poll(Long.MAX_VALUE, 1)) in <lambda>() 166 assertEquals(9, record.poll(0, 2)) in <lambda>() 167 assertEquals(4, record.poll(0, 0)) in <lambda>() 168 assertEquals(9, record.poll(0, 2) { it > 5 }) in <lambda>() 169 assertEquals(7, record.poll(0, 0) { it > 5 }) in <lambda>() 181 var delay = measureTimeMillis { assertNull(record.poll(SHORT_TIMEOUT, 0)) } in <lambda>() 183 delay = measureTimeMillis { assertNull(record.poll(SHORT_TIMEOUT, 0) { it < 10 }) } in <lambda>() 201 assertEquals(31, record.poll(TEST_TIMEOUT, 0)) in <lambda>() [all …]
|
/packages/modules/NetworkStack/tests/lib/src/com/android/testutils/ |
D | TestableNetworkStatsProvider.kt | 52 assertEquals(CallbackType.OnRequestStatsUpdate(token), history.poll(timeout)) in expectOnRequestStatsUpdate() 56 assertEquals(CallbackType.OnSetLimit(iface, quotaBytes), history.poll(timeout)) in expectOnSetLimit() 60 assertEquals(CallbackType.OnSetAlert(quotaBytes), history.poll(timeout)) in expectOnSetAlert() 64 history.poll(timeout) ?: fail("Did not receive callback after ${timeout}ms") in pollForNextCallback() 86 ) = history.poll(timeoutMs, from) { it is T && predicate(it) } as T in <lambda>() 94 val cb = history.poll(timeout) in assertNoCallback()
|
D | TestableNetworkStatsProviderCbBinder.kt | 58 val event = history.poll(DEFAULT_TIMEOUT_MS) in expectNotifyStatsUpdated() 63 val event = history.poll(DEFAULT_TIMEOUT_MS)!! in expectNotifyStatsUpdated() 73 assertEquals(CallbackType.NotifyLimitReached, history.poll(DEFAULT_TIMEOUT_MS)) in expectNotifyLimitReached() 76 assertEquals(CallbackType.NotifyAlertReached, history.poll(DEFAULT_TIMEOUT_MS)) in expectNotifyLimitReached() 80 val cb = history.poll(0) in expectNotifyLimitReached()
|
D | TestableNetworkStatsProviderBinder.kt | 47 assertEquals(CallbackType.OnRequestStatsUpdate(token), history.poll(DEFAULT_TIMEOUT_MS)) in expectOnRequestStatsUpdate() 51 assertEquals(CallbackType.OnSetLimit(iface, quotaBytes), history.poll(DEFAULT_TIMEOUT_MS)) in expectOnSetLimit() 55 assertEquals(CallbackType.OnSetAlert(quotaBytes), history.poll(DEFAULT_TIMEOUT_MS)) in expectOnSetAlert() 60 val cb = history.poll(timeout) in assertNoCallback()
|
D | TestableNetworkCallback.kt | 168 return history.poll(timeoutMs) ?: fail("Did not receive callback after ${timeoutMs}ms") in pollForNextCallback() 174 val cb = history.poll(timeoutMs) in assertNoCallback() 207 ) = history.poll(timeoutMs, from) { it is T && predicate(it) } as T? in <lambda>() 282 val firstCaps = history.poll(tmt, mark) { it is CapabilitiesChanged } in expectAvailableDoubleValidatedCallbacks()
|
D | TapPacketReader.java | 64 return mReadHead.getValue().poll(timeoutMs, packet -> true); in popPacket() 72 return mReadHead.getValue().poll(timeoutMs, filter::test); in popPacket()
|
/packages/modules/NetworkStack/tests/lib/multivariant/com/android/testutils/ |
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
|
/packages/apps/TV/tuner/src/com/android/tv/tuner/exoplayer/buffer/ |
D | SampleQueue.java | 39 SampleHolder sampleFromQueue = mQueue.poll(); in dequeueSample() 56 mSamplePool.releaseSample(mQueue.poll()); in clear()
|
D | BufferManager.java | 322 private SampleChunk poll(String key, long startPositionUs) { in poll() method in BufferManager.EvictChunkQueueMap 328 return queue.poll(); in poll() 488 while ((chunk = mPendingDelete.poll(id, earlierThanPositionUs)) != null) { in evictChunks()
|
D | SampleChunkIoHelper.java | 240 SampleHolder sample = mReadSampleBuffers[index].poll(); in readSample() 409 while ((sample = mHandlerReadSampleBuffers[index].poll()) != null) { in doOpenRead() 433 while ((sample = mHandlerReadSampleBuffers[index].poll()) != null) { in doCloseRead()
|
/packages/providers/MediaProvider/tests/src/com/android/providers/media/ |
D | GetResultActivity.java | 69 result = sResult.poll(30, TimeUnit.SECONDS); in getResult() 81 return sResult.poll(timeout, unit); in getResult()
|
/packages/apps/ManagedProvisioning/tests/instrumentation/src/com/android/managedprovisioning/common/ |
D | BlockingBroadcastReceiver.java | 75 return mBlockingQueue.poll(DEFAULT_TIMEOUT_SECONDS, TimeUnit.SECONDS); in awaitForBroadcast() 88 return mBlockingQueue.poll(timeoutMillis, TimeUnit.MILLISECONDS); in awaitForBroadcast()
|
/packages/apps/TV/tuner/src/com/android/tv/tuner/exoplayer2/buffer/ |
D | SampleQueue.java | 40 DecoderInputBuffer sampleFromQueue = mQueue.poll(); in dequeueSample() 59 mInputBufferPool.releaseSample(mQueue.poll()); in clear()
|
D | BufferManager.java | 325 private SampleChunk poll(String key, long startPositionUs) { in poll() method in BufferManager.EvictChunkQueueMap 331 return queue.poll(); in poll() 492 while ((chunk = mPendingDelete.poll(id, earlierThanPositionUs)) != null) { in evictChunks()
|
D | SampleChunkIoHelper.java | 279 DecoderInputBuffer sample = mReadSampleBuffers[index].poll(); in readSample() 451 while ((sample = mHandlerReadSampleBuffers[index].poll()) != null) { in doOpenRead() 475 while ((sample = mHandlerReadSampleBuffers[index].poll()) != null) { in doCloseRead()
|
/packages/apps/Gallery2/src/com/android/gallery3d/util/ |
D | IdentityCache.java | 44 Entry<K, V> entry = (Entry<K, V>) mQueue.poll(); in cleanUpWeakMap() 47 entry = (Entry<K, V>) mQueue.poll(); in cleanUpWeakMap()
|
/packages/apps/Gallery/src/com/android/camera/gallery/ |
D | LruCache.java | 53 Entry<K, V> entry = (Entry<K, V>) mQueue.poll(); in cleanUpWeakMap() 56 entry = (Entry<K, V>) mQueue.poll(); in cleanUpWeakMap()
|
/packages/apps/Gallery2/gallerycommon/src/com/android/gallery3d/common/ |
D | LruCache.java | 57 Entry<K, V> entry = (Entry<K, V>) mQueue.poll(); in cleanUpWeakMap() 60 entry = (Entry<K, V>) mQueue.poll(); in cleanUpWeakMap()
|
/packages/modules/DnsResolver/ |
D | DnsTlsSocket.cpp | 61 return TEMP_FAILURE_RETRY(poll(&fds, 1, timeoutMs)); in waitForReading() 66 return TEMP_FAILURE_RETRY(poll(&fds, 1, timeoutMs)); in waitForWriting() 333 const int s = TEMP_FAILURE_RETRY(poll(fds, std::size(fds), timeout_msecs)); in loop()
|
/packages/apps/Bluetooth/tests/unit/src/com/android/bluetooth/ |
D | TestUtils.java | 209 Intent intent = queue.poll(timeoutMs, TimeUnit.MILLISECONDS); in waitForIntent() 228 Intent intent = queue.poll(timeoutMs, TimeUnit.MILLISECONDS); in waitForNoIntent()
|
/packages/modules/DnsResolver/tests/dns_responder/ |
D | dns_tls_frontend.cpp | 180 int poll_code = poll(fds, std::size(fds), -1); in requestHandler() 274 } while (poll(&fds, 1, 1) > 0); in handleRequests()
|
/packages/apps/Launcher3/robolectric_tests/src/com/android/launcher3/model/ |
D | GridSizeMigrationTaskTest.java | 364 assertEquals(sourceSize, mPoints.poll()); in runStepTask() 365 assertEquals(nextSize, mPoints.poll()); in runStepTask()
|
/packages/apps/Launcher3/quickstep/recents_ui_overrides/src/com/android/launcher3/hybridhotseat/ |
D | HotseatEduController.java | 149 FolderInfo info = folders.poll(); in placeFoldersInWorkspace() 165 while ((folderInfo = folders.poll()) != null) { in placeFoldersInWorkspace()
|
/packages/services/Telephony/src/com/android/phone/vvm/ |
D | RemoteVvmTaskManager.java | 323 Message message = mTaskQueue.poll(); in runQueue() 333 message = mTaskQueue.poll(); in runQueue()
|
/packages/apps/TV/jni/ |
D | DvbManager.cpp | 74 int poll_result = poll(&pollFd, NUM_POLLFDS, FE_POLL_TIMEOUT_MS); in isFeLocked() 492 int poll_result = poll(&pollFd, NUM_POLLFDS, timeout_ms); in readTsStream()
|