| /frameworks/libs/net/common/tests/unit/src/com/android/net/module/util/ |
| D | TrackRecordTest.kt | 157 val elapsed = measureTimeMillis { assertEquals(4, record.poll(LONG_TIMEOUT, 0)) } in <lambda>()
163 assertEquals(9, record.poll(0, 2)) in <lambda>()
164 assertEquals(7, record.poll(Long.MAX_VALUE, 1)) in <lambda>()
165 assertEquals(9, record.poll(0, 2)) in <lambda>()
166 assertEquals(4, record.poll(0, 0)) in <lambda>()
167 assertEquals(9, record.poll(0, 2) { it > 5 }) in <lambda>()
168 assertEquals(7, record.poll(0, 0) { it > 5 }) in <lambda>()
180 var delay = measureTimeMillis { assertNull(record.poll(SHORT_TIMEOUT, 0)) } in <lambda>()
182 delay = measureTimeMillis { assertNull(record.poll(SHORT_TIMEOUT, 0) { it < 10 }) } in <lambda>()
194 readHead.poll(LONG_TIMEOUT) in <lambda>()
[all …]
|
| /frameworks/libs/net/common/testutils/devicetests/com/android/testutils/ |
| D | TapPacketReader.java | 84 return poll(timeoutMs); in popPacket()
94 return poll(timeoutMs, filter); in popPacket()
101 public byte[] poll(long timeoutMs) { in poll() method in TapPacketReader
102 return mReadHead.getValue().poll(timeoutMs, packet -> true); in poll()
109 public byte[] poll(long timeoutMs, @NonNull Predicate<byte[]> filter) { in poll() method in TapPacketReader
110 return mReadHead.getValue().poll(timeoutMs, filter::test); in poll()
|
| 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.NotifyWarningOrLimitReached, history.poll(DEFAULT_TIMEOUT_MS)) in expectNotifyWarningOrLimitReached()
76 assertEquals(CallbackType.NotifyAlertReached, history.poll(DEFAULT_TIMEOUT_MS)) in expectNotifyWarningOrLimitReached()
80 val cb = history.poll(0) in expectNotifyWarningOrLimitReached()
|
| D | TestableNetworkStatsProvider.kt | 63 val event = history.poll(timeout) in expectOnRequestStatsUpdate()
72 assertEquals(CallbackType.OnSetLimit(iface, quotaBytes), history.poll(timeout)) in expectOnSetLimit()
76 assertEquals(CallbackType.OnSetAlert(quotaBytes), history.poll(timeout)) in expectOnSetAlert()
80 history.poll(timeout) ?: fail("Did not receive callback after ${timeout}ms") in pollForNextCallback()
102 ) = history.poll(timeoutMs, from) { it is T && predicate(it) } as T in <lambda>()
110 val cb = history.poll(timeout) in assertNoCallback()
|
| D | TestableNetworkStatsProviderBinder.kt | 51 assertEquals(CallbackType.OnRequestStatsUpdate(token), history.poll(DEFAULT_TIMEOUT_MS)) in expectOnRequestStatsUpdate()
56 history.poll(DEFAULT_TIMEOUT_MS)) in expectOnSetWarningAndLimit()
60 assertEquals(CallbackType.OnSetAlert(quotaBytes), history.poll(DEFAULT_TIMEOUT_MS)) in expectOnSetAlert()
65 val cb = history.poll(timeout) in assertNoCallback()
|
| D | TestableNetworkOfferCallback.kt | 56 val event = history.poll(timeoutMs) in expectCallbackThat()
72 val cb = history.poll(noCallbackTimeoutMs) in assertNoCallback()
|
| D | TestableNetworkCallback.kt | 189 return history.poll(timeoutMs) ?: fail("Did not receive callback after ${timeoutMs}ms") in pollForNextCallback()
198 val cb = history.poll(timeoutMs) in assertNoCallback()
230 ) = history.poll(timeoutMs) { type.java.isInstance(it) && predicate(it) }.also { in <lambda>()
239 ) = history.poll(timeoutMs, from) { it is T && predicate(it) } as T? in <lambda>()
340 val firstCaps = history.poll(tmt, mark) { it is CapabilitiesChanged } in expectAvailableDoubleValidatedCallbacks()
|
| D | PacketResponder.kt | 65 recvPackets.poll(POLL_FREQUENCY_MS, packetFilter::test)?.let { in run()
|
| /frameworks/base/services/tests/servicestests/src/com/android/server/textclassifier/ |
| D | FixedSizeQueueTest.java | 36 assertThat(queue.poll()).isEqualTo(1); in add_belowMaxCapacity()
48 assertThat(queue.poll()).isEqualTo(2); in add_exceedMaxCapacity()
49 assertThat(queue.poll()).isEqualTo(3); in add_exceedMaxCapacity()
53 public void poll() { in poll() method in FixedSizeQueueTest
58 assertThat(queue.poll()).isEqualTo(1); in poll()
59 assertThat(queue.poll()).isNull(); in poll()
|
| /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/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/services/tests/mockingservicestests/src/com/android/server/location/test/ |
| D | ProviderListenerCapture.java | 45 return mNewStates.poll(); in getNextNewState()
55 return mLocations.poll(); in getNextLocationResult()
|
| /frameworks/base/core/java/android/view/accessibility/ |
| D | WeakSparseArray.java | 48 for (Reference ref = mRefQueue.poll(); ref != null; ref = mRefQueue.poll()) { in removeUnreachableValues()
|
| /frameworks/base/packages/SystemUI/src/com/android/systemui/classifier/ |
| D | HistoryTracker.java | 79 while (mResults.poll() != null) { in falseBelief()
113 while (mResults.poll() != null) { in falseConfidence()
154 while (mResults.poll() != null) { in addResults()
|
| /frameworks/base/services/core/java/com/android/server/textclassifier/ |
| D | FixedSizeQueue.java | 75 public E poll() { in poll() method in FixedSizeQueue
76 return mDelegate.poll(); in poll()
|
| /frameworks/libs/net/common/testutils/hostdevice/com/android/net/module/util/ |
| D | TrackRecord.kt | 46 fun poll(timeoutMs: Long, pos: Int, predicate: (E) -> Boolean = { true }): E? in add() method
103 override fun poll(timeoutMs: Long, pos: Int, predicate: (E) -> Boolean) = lock.withLock { in <lambda>() method
261 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
|
| /frameworks/base/services/tests/servicestests/utils/com/android/server/testutils/ |
| D | TestHandler.java | 94 dispatch(mMessages.poll()); in timeAdvance()
105 while ((msg = mMessages.poll()) != null) { in flush()
|
| /frameworks/base/services/core/java/com/android/server/location/contexthub/ |
| D | ConcurrentLinkedEvictingDeque.java | 37 poll(); in add()
|
| /frameworks/opt/telephony/tests/telephonytests/src/android/telephony/ims/ |
| D | ImsConfigImplTest.java | 125 Pair<Integer, Integer> callbackResult = mConfigChanges.poll(); in testIntCaching()
154 Pair<Integer, String> callbackResult = mConfigChanges.poll(); in testStringCaching()
|
| /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();
|
| /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/packages/SystemUI/src/com/android/systemui/statusbar/phone/ |
| D | KeyguardIndicationTextView.java | 137 KeyguardIndication info = mKeyguardIndicationInfo.poll(); in getOutAnimator()
151 setText(mMessages.poll()); in getOutAnimator()
|