| /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()
|