Home
last modified time | relevance | path

Searched refs:poll (Results 1 – 25 of 110) sorted by relevance

12345

/packages/services/Car/cpp/telemetry/cartelemetryd/tests/
DTelemetryServerTest.cpp186 mFakeLooper.poll(); in TEST_F()
187 mFakeLooper.poll(); in TEST_F()
188 mFakeLooper.poll(); in TEST_F()
189 mFakeLooper.poll(); in TEST_F()
201 mFakeLooper.poll(); in TEST_F()
213 mFakeLooper.poll(); in TEST_F()
226 mFakeLooper.poll(); // sends only 1 CarData (or possibly 2 depenending on impl) in TEST_F()
228 mFakeLooper.poll(); // all the polls below send the rest of the CarData in TEST_F()
229 mFakeLooper.poll(); in TEST_F()
230 mFakeLooper.poll(); // extra poll to verify there was not excess push calls in TEST_F()
[all …]
/packages/modules/Connectivity/tests/cts/net/util/java/android/net/cts/util/
DCtsTetheringUtils.java107 final CallbackValue cv = mHistory.poll(TIMEOUT_MS, c -> true); in verifyTetheringStarted()
114 final CallbackValue cv = mHistory.poll(TIMEOUT_MS, c -> true); in expectTetheringFailed()
275 assertNotNull("No expected tetherable ifaces callback", mCurrent.poll(TIMEOUT_MS, in expectTetherableInterfacesChanged()
286 mCurrent.poll(TIMEOUT_MS, (cv) -> { in expectNoTetheringActive()
296 final CallbackValue cv = mCurrent.poll(TIMEOUT_MS, c -> true); in expectTetheredInterfacesChanged()
328 final CallbackValue cv = history.poll(TIMEOUT_MS, c -> true); in expectCallbackStarted()
339 assertNotNull("No offload status changed", mCurrent.poll(TIMEOUT_MS, (cv) -> { in expectOneOfOffloadStatusChanged()
352 assertNotNull("No expected callback", mCurrent.poll(TIMEOUT_MS, (cv) -> { in expectErrorOrTethered()
367 final CallbackValue result = mCurrent.poll(TIMEOUT_MS, (cv) -> { in getCurrentValidUpstream()
379 assertNotNull("No onSupported callback", history.poll(TIMEOUT_MS, (cv) -> { in assumeTetheringSupported()
/packages/services/Car/tests/carservice_unit_test/src/android/car/test/util/
DBlockingResultReceiverTest.java65 assertThat(resultCodeBlockingQueue.poll(3, TimeUnit.SECONDS)).isEqualTo(anyResultCode); in testSend_andAssertCalled()
66 assertThat(dataBlockingQueue.poll(3, TimeUnit.SECONDS)).isSameInstanceAs(anyBundle); in testSend_andAssertCalled()
/packages/apps/ManagedProvisioning/tests/instrumentation/src/com/android/managedprovisioning/common/
DBlockingBroadcastReceiver.java75 return mBlockingQueue.poll(DEFAULT_TIMEOUT_SECONDS, TimeUnit.SECONDS); in awaitForBroadcast()
88 return mBlockingQueue.poll(timeoutMillis, TimeUnit.MILLISECONDS); in awaitForBroadcast()
/packages/providers/MediaProvider/tests/src/com/android/providers/media/
DGetResultActivity.java69 result = sResult.poll(30, TimeUnit.SECONDS); in getResult()
81 return sResult.poll(timeout, unit); in getResult()
/packages/apps/TV/tuner/src/com/android/tv/tuner/exoplayer/buffer/
DSampleQueue.java39 SampleHolder sampleFromQueue = mQueue.poll(); in dequeueSample()
56 mSamplePool.releaseSample(mQueue.poll()); in clear()
DBufferManager.java322 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()
DSampleChunkIoHelper.java240 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/apps/TV/tuner/src/com/android/tv/tuner/exoplayer2/buffer/
DSampleQueue.java40 DecoderInputBuffer sampleFromQueue = mQueue.poll(); in dequeueSample()
59 mInputBufferPool.releaseSample(mQueue.poll()); in clear()
DBufferManager.java325 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()
/packages/apps/Gallery2/src/com/android/gallery3d/util/
DIdentityCache.java44 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/
DLruCache.java53 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/
DLruCache.java57 Entry<K, V> entry = (Entry<K, V>) mQueue.poll(); in cleanUpWeakMap()
60 entry = (Entry<K, V>) mQueue.poll(); in cleanUpWeakMap()
/packages/modules/DnsResolver/tests/dns_responder/
Ddns_tls_frontend.cpp181 int poll_code = poll(fds, std::size(fds), -1); in requestHandler()
294 } while (poll(&fds, 1, delayQueriesTimeout_) > 0); in handleRequests()
309 int n = poll(&fds, 1, 50); in handleRequests()
/packages/modules/IPsec/tests/cts/src/android/ipsec/ike/cts/
DIkeSessionTestBase.java341 return mOnErrorExceptionsTrackRecord.poll( in awaitNextOnErrorException()
440 return mCreatedIpSecTransformsTrackRecord.poll( in awaitNextCreatedIpSecTransform()
449 return mMigratedIpSecTransformsTrackRecord.poll( in awaitNextMigratedIpSecTransform()
458 return mDeletedIpSecTransformsTrackRecord.poll(
/packages/modules/Connectivity/tests/cts/net/src/android/net/cts/
DConnectivityDiagnosticsManagerTest.java503 (ConnectivityReport) mHistory.poll(CALLBACK_TIMEOUT_MILLIS, x -> true); in maybeVerifyOnConnectivityReportAvailable()
546 (DataStallReport) mHistory.poll(CALLBACK_TIMEOUT_MILLIS, x -> true); in expectOnDataStallSuspected()
563 (Pair<Network, Boolean>) mHistory.poll(CALLBACK_TIMEOUT_MILLIS, x -> true); in expectOnNetworkConnectivityReported()
571 mHistory.poll(NO_CALLBACK_INVOKED_TIMEOUT, x -> true)); in assertNoCallback()
DNetworkAgentTest.kt339 val foundCallback = history.poll(DEFAULT_TIMEOUT_MS) in disconnect()
345 val foundCallback = history.poll(DEFAULT_TIMEOUT_MS) in disconnect()
351 history.poll(DEFAULT_TIMEOUT_MS) { it is T }.also { in disconnect()
1003 val foundCallback = history.poll(DEFAULT_TIMEOUT_MS) in expectCallback()
1009 val foundCallback = history.poll(DEFAULT_TIMEOUT_MS) in expectCallback()
1015 assertNull(history.poll(NO_CALLBACK_TIMEOUT), in assertNoCallback()
DNetworkValidationTest.kt177 assertTrue(httpServer.requestsRecord.poll(TEST_TIMEOUT_MS, 0)?.matches(capportUrl) ?: false, in testCapportApiCallbacks()
234 val packetBytes = poll(timeoutMs, DhcpClientPacketFilter() in makeOfferPacket()
/packages/modules/DnsResolver/
DDnsTlsSocket.cpp63 return TEMP_FAILURE_RETRY(poll(&fds, 1, timeoutMs)); in waitForReading()
68 return TEMP_FAILURE_RETRY(poll(&fds, 1, timeoutMs)); in waitForWriting()
342 int n = TEMP_FAILURE_RETRY(poll(fds, std::size(fds), mConnectTimeoutMs)); in sslConnectV2()
443 const int s = TEMP_FAILURE_RETRY(poll(fds, std::size(fds), timeout_msecs)); in loop()
/packages/modules/Connectivity/tests/common/java/android/net/
DNetworkProviderTest.kt110 ) = seenEvents.poll(DEFAULT_TIMEOUT_MS) { it is T && predicate(it) } in <lambda>()
114 val cb = seenEvents.poll(DEFAULT_NO_CALLBACK_TIMEOUT_MS) in <lambda>()
370 ) = seenEvents.poll(DEFAULT_TIMEOUT_MS) { it is T && predicate(it) } in <lambda>()
/packages/modules/Wifi/service/proto/src/
Dscorecard.proto214 // or at high Tx speed with a recent RSSI poll
217 // or Tx speed with a recent RSSI poll
219 // Number of disconnections after L3 connection with a recent RSSI poll
/packages/apps/Bluetooth/tests/unit/src/com/android/bluetooth/
DTestUtils.java210 Intent intent = queue.poll(timeoutMs, TimeUnit.MILLISECONDS); in waitForIntent()
229 Intent intent = queue.poll(timeoutMs, TimeUnit.MILLISECONDS); in waitForNoIntent()
/packages/services/Iwlan/src/com/google/android/iwlan/epdg/
DEpdgTunnelManager.java1277 mRequestQueue.poll(); in handleMessage()
1297 mRequestQueue.poll(); in handleMessage()
1303 mRequestQueue.poll(); in handleMessage()
1466 TunnelRequestWrapper requestWrapper = mRequestQueue.poll(); in closePendingRequestsForApn()
1512 TunnelRequestWrapper request = mRequestQueue.poll(); in serviceAllPendingRequests()
1520 TunnelRequestWrapper request = mRequestQueue.poll(); in failAllPendingRequests()
/packages/services/Telephony/src/com/android/phone/vvm/
DRemoteVvmTaskManager.java323 Message message = mTaskQueue.poll(); in runQueue()
333 message = mTaskQueue.poll(); in runQueue()
/packages/apps/Launcher3/robolectric_tests/src/com/android/launcher3/model/
DGridSizeMigrationTaskTest.java364 assertEquals(sourceSize, mPoints.poll()); in runStepTask()
365 assertEquals(nextSize, mPoints.poll()); in runStepTask()

12345