| /packages/services/Telecomm/tests/src/com/android/server/telecom/tests/ |
| D | TestScheduledExecutorService.java | 48 private Runnable mRunnable;
61 CompletedFuture(Runnable task, long delayMs) { in CompletedFuture()
122 private Map<Long, Runnable> mScheduledRunnables = new HashMap<>();
123 private Map<Runnable, Long> mRepeatDuration = new HashMap<>();
130 public List<Runnable> shutdownNow() { in shutdownNow()
155 public <T> Future<T> submit(Runnable task, T result) { in submit()
160 public Future<?> submit(Runnable task) { in submit()
187 public ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) { in schedule()
195 return new TestScheduledExecutorService.CompletedFuture<Runnable>(command, delay); in schedule()
204 public ScheduledFuture<?> scheduleAtFixedRate(Runnable command, long initialDelay, long period, in scheduleAtFixedRate()
[all …]
|
| /packages/services/Telephony/testapps/TestSatelliteApp/src/com/android/phone/testapps/satellitetestapp/ |
| D | MultipleSendReceive.java | 72 Runnable::run, resultListener::offer); in multiplePollPendingSatelliteDatagramsApp()
73 mSatelliteManager.pollPendingDatagrams(Runnable::run, resultListener::offer); in multiplePollPendingSatelliteDatagramsApp()
76 mSatelliteManager.pollPendingDatagrams(Runnable::run, resultListener::offer); in multiplePollPendingSatelliteDatagramsApp()
79 mSatelliteManager.pollPendingDatagrams(Runnable::run, resultListener::offer); in multiplePollPendingSatelliteDatagramsApp()
82 mSatelliteManager.pollPendingDatagrams(Runnable::run, resultListener::offer); in multiplePollPendingSatelliteDatagramsApp()
85 mSatelliteManager.pollPendingDatagrams(Runnable::run, resultListener::offer); in multiplePollPendingSatelliteDatagramsApp()
107 datagram, true, Runnable::run, resultListener::offer); in multipleSendSatelliteDatagramApp()
109 datagram, true, Runnable::run, resultListener::offer); in multipleSendSatelliteDatagramApp()
111 datagram, true, Runnable::run, resultListener::offer); in multipleSendSatelliteDatagramApp()
113 datagram, true, Runnable::run, resultListener::offer); in multipleSendSatelliteDatagramApp()
[all …]
|
| /packages/modules/Connectivity/nearby/tests/unit/src/com/android/server/nearby/managers/ |
| D | ListenerMultiplexerTest.java | 52 Runnable listener = mock(Runnable.class); in testAdd()
64 Runnable listener2 = mock(Runnable.class); in testAdd()
80 Runnable listener = mock(Runnable.class); in testReplace()
94 Runnable listener2 = mock(Runnable.class); in testReplace()
122 Runnable listener = mock(Runnable.class); in testRemove()
147 Runnable listener = mock(Runnable.class); in testMergeMultiple()
151 Runnable listener2 = mock(Runnable.class); in testMergeMultiple()
155 Runnable listener3 = mock(Runnable.class); in testMergeMultiple()
239 ListenerMultiplexer<Runnable, TestMultiplexer.TestListenerRegistration, Integer> {
274 public void addListener(IBinder binder, Runnable runnable, int value) { in addListener()
[all …]
|
| /packages/modules/Connectivity/nearby/tests/unit/src/com/android/server/nearby/managers/registration/ |
| D | BinderListenerRegistrationTest.java | 57 Runnable listener = mock(Runnable.class); in test_addAndRemove()
60 BinderListenerRegistration<Runnable> registration = mMultiplexer.addListener(binder, in test_addAndRemove()
72 Runnable listener2 = mock(Runnable.class); in test_addAndRemove()
75 BinderListenerRegistration<Runnable> registration2 = mMultiplexer.addListener(binder2, in test_addAndRemove()
108 ListenerMultiplexer<Runnable, TestMultiplexer.TestListenerRegistration, Integer> {
133 public BinderListenerRegistration<Runnable> addListener(IBinder binder, Runnable runnable, in addListener()
142 deliverToListeners(registration -> Runnable::run); in notifyListeners()
145 private class TestListenerRegistration extends BinderListenerRegistration<Runnable> {
148 protected TestListenerRegistration(IBinder binder, Runnable runnable, int value) { in TestListenerRegistration()
|
| /packages/modules/Wifi/service/java/com/android/server/wifi/ |
| D | WifiThreadRunner.java | 122 public boolean run(@NonNull Runnable runnable, String taskName) { in run()
141 public boolean run(@NonNull Runnable runnable) { in run()
153 public boolean runAtFront(@NonNull Runnable runnable, String taskName) { in runAtFront()
208 public boolean post(@NonNull Runnable runnable, @Nullable String taskName) { in post()
217 public boolean post(@NonNull Runnable runnable) { in post()
230 public boolean postDelayed(@NonNull Runnable runnable, long delayMillis, String taskName) { in postDelayed()
241 public final void removeCallbacks(@NonNull Runnable r) { in removeCallbacks()
251 public final boolean hasCallbacks(@NonNull Runnable r) { in hasCallbacks()
303 private boolean runWithScissors(@NonNull Handler handler, @NonNull Runnable r, in runWithScissors()
326 private static final class BlockingRunnable implements Runnable {
[all …]
|
| /packages/services/Telephony/tests/src/com/android/ |
| D | TestExecutorService.java | 109 private final ArrayList<Runnable> mPendingRunnables = new ArrayList<>();
130 for (Runnable r : mPendingRunnables) { in shutdown()
136 public List<Runnable> shutdownNow() { in shutdownNow()
138 List<Runnable> runnables = new ArrayList<>(mPendingRunnables); in shutdownNow()
167 public <T> Future<T> submit(Runnable task, T result) { in submit()
172 public Future<?> submit(Runnable task) { in submit()
203 public ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) { in schedule()
222 public ScheduledFuture<?> scheduleAtFixedRate(Runnable command, long initialDelay, long period, in scheduleAtFixedRate()
228 public ScheduledFuture<?> scheduleWithFixedDelay(Runnable command, long initialDelay, in scheduleWithFixedDelay()
234 public void execute(Runnable command) { in execute()
[all …]
|
| /packages/inputmethods/LatinIME/java/src/com/android/inputmethod/latin/utils/ |
| D | ExecutorUtils.java | 54 public Thread newThread(final Runnable runnable) { in newThread()
122 public static Runnable chain(final Runnable... runnables) { in chain()
127 public static class RunnableChain implements Runnable {
128 private final Runnable[] mRunnables;
130 private RunnableChain(final Runnable... runnables) { in RunnableChain()
138 public Runnable[] getRunnables() { in getRunnables()
144 for (Runnable runnable : mRunnables) { in run()
|
| /packages/inputmethods/LatinIME/java/src/com/android/inputmethod/latin/ |
| D | ExpandableBinaryDictionary.java | 165 private void asyncExecuteTaskWithWriteLock(final Runnable task) { in asyncExecuteTaskWithWriteLock()
169 private static void asyncExecuteTaskWithLock(final Lock lock, final Runnable task) { in asyncExecuteTaskWithLock()
170 ExecutorUtils.getBackgroundExecutor(ExecutorUtils.KEYBOARD).execute(new Runnable() { in asyncExecuteTaskWithLock()
200 asyncExecuteTaskWithWriteLock(new Runnable() { in close()
221 asyncExecuteTaskWithWriteLock(new Runnable() { in removeBinaryDictionary()
249 asyncExecuteTaskWithWriteLock(new Runnable() { in clear()
262 asyncExecuteTaskWithWriteLock(new Runnable() { in runGCIfRequired()
279 private void updateDictionaryWithWriteLock(@Nonnull final Runnable updateTask) { in updateDictionaryWithWriteLock()
281 final Runnable task = new Runnable() { in updateDictionaryWithWriteLock()
299 updateDictionaryWithWriteLock(new Runnable() { in addUnigramEntry()
[all …]
|
| /packages/apps/Launcher3/quickstep/src/com/android/launcher3/taskbar/bubbles/animation/ |
| D | BubbleBarViewAnimator.kt | 52 val showAnimation: Runnable, in <lambda>()
53 val hideAnimation: Runnable in <lambda>()
60 fun post(block: Runnable) in <lambda>()
63 fun postDelayed(delayMillis: Long, block: Runnable) in <lambda>()
66 fun cancel(block: Runnable) in <lambda>()
72 override fun post(block: Runnable) { in <lambda>()
76 override fun postDelayed(delayMillis: Long, block: Runnable) { in <lambda>()
80 override fun cancel(block: Runnable) { in <lambda>()
119 private fun buildHandleToBubbleBarAnimation() = Runnable { in <lambda>()
219 private fun buildBubbleBarToHandleAnimation() = Runnable { in <lambda>()
[all …]
|
| /packages/apps/Camera2/src/com/android/camera/session/ |
| D | CaptureSessionManagerImpl.java | 70 mMainHandler.execute(new Runnable() { in notifyTaskQueued()
88 mMainHandler.execute(new Runnable() { in notifyTaskDone()
108 mMainHandler.execute(new Runnable() { in notifyTaskFailed()
123 mMainHandler.execute(new Runnable() { in notifyTaskCanceled()
142 mMainHandler.execute(new Runnable() { in notifyTaskProgress()
160 mMainHandler.execute(new Runnable() { in notifyTaskProgressText()
178 mMainHandler.execute(new Runnable() { in notifySessionUpdated()
201 mMainHandler.execute(new Runnable() { in notifySessionCaptureIndicatorAvailable()
215 mMainHandler.execute(new Runnable() { in notifySessionThumbnailAvailable()
230 mMainHandler.execute(new Runnable() { in notifySessionPictureDataAvailable()
[all …]
|
| /packages/apps/Gallery/src/com/android/camera/ |
| D | ImageGetter.java | 100 private class ImageGetterRunnable implements Runnable {
102 private Runnable callback(final int position, final int offset, in callback()
106 return new Runnable() { in callback()
119 private Runnable completedCallback(final int requestSerial) {
120 return new Runnable() {
180 Runnable cb = callback(mCurrentPosition, offset,
216 Runnable cb = callback(mCurrentPosition, offset,
293 ((Runnable) message.obj).run();
298 public void postGetterCallback(Runnable callback) {
302 public void postDelayedGetterCallback(Runnable callback, long delay) {
|
| /packages/apps/UniversalMediaPlayer/java/com/android/pump/concurrent/ |
| D | UniqueExecutor.java | 34 private final Collection<Runnable> mRunning = Collections.synchronizedSet(new HashSet<>());
37 @NonNull TimeUnit unit, @NonNull BlockingQueue<Runnable> workQueue) { in UniqueExecutor()
42 @NonNull TimeUnit unit, @NonNull BlockingQueue<Runnable> workQueue, in UniqueExecutor()
48 @NonNull TimeUnit unit, @NonNull BlockingQueue<Runnable> workQueue, in UniqueExecutor()
54 @NonNull TimeUnit unit, @NonNull BlockingQueue<Runnable> workQueue, in UniqueExecutor()
61 public void execute(@NonNull Runnable command) { in execute()
69 protected void afterExecute(@NonNull Runnable r, @Nullable Throwable t) { in afterExecute()
|
| /packages/apps/Calendar/src/com/android/calendar/ |
| D | EventLoader.kt | 59 uiCallback: Runnable
61 var uiCallback: Runnable
118 successCallback: Runnable,
119 cancelCallback: Runnable
122 var successCallback: Runnable
123 var cancelCallback: Runnable
227 successCallback: Runnable, in loadEventsInBackground()
228 cancelCallback: Runnable in loadEventsInBackground()
263 uiCallback: Runnable in loadEventDaysInBackground()
|
| /packages/apps/DocumentsUI/tests/common/com/android/documentsui/testing/ |
| D | TestScheduledExecutorService.java | 51 public List<Runnable> shutdownNow() { in shutdownNow()
81 public <T> Future<T> submit(Runnable task, T result) { in submit()
86 public Future<?> submit(Runnable task) { in submit()
115 public void execute(Runnable command) { in execute()
120 public ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) { in schedule()
132 public ScheduledFuture<?> scheduleAtFixedRate(Runnable command, long initialDelay, long period, in scheduleAtFixedRate()
138 public ScheduledFuture<?> scheduleWithFixedDelay(Runnable command, long initialDelay, in scheduleWithFixedDelay()
184 final Runnable runnable;
188 public TestFuture(Runnable runnable, long delay, TimeUnit unit) { in TestFuture()
|
| /packages/apps/TV/src/com/android/tv/ui/hideable/ |
| D | AutoHideScheduler.java | 45 private final Runnable mRunnable;
47 public AutoHideScheduler(Context context, Runnable runnable) { in AutoHideScheduler()
55 AutoHideScheduler(Runnable runnable, AccessibilityManager accessibilityManager, Looper looper) { in AutoHideScheduler()
82 private static class HideHandler extends WeakHandler<Runnable>
87 public HideHandler(Looper looper, Runnable hideRunner) { in HideHandler()
92 protected void handleMessage(Message msg, @NonNull Runnable runnable) { in handleMessage()
|
| /packages/services/Car/service/src/com/android/car/garagemode/ |
| D | GarageMode.java | 112 private final Runnable mRunnable = new Runnable() {
159 private final Runnable mStopUserCheckRunnable = new Runnable() {
223 private final Runnable mBackgroundUserStopTimeout = new Runnable() {
233 private Runnable mFinishCompletor;
238 private Runnable mBackgroundUserStopCompletor;
339 void enterGarageMode(Runnable completor) { in enterGarageMode()
379 void cancel(@Nullable Runnable completor) { in cancel()
388 Runnable finishCompletor; in cancel()
412 Runnable finishCompletor; in finish()
424 Runnable completor; in runBackgroundUserStopCompletor()
[all …]
|
| /packages/apps/DeskClock/src/com/android/deskclock/uidata/ |
| D | PeriodicCallbackModel.kt | 63 fun addMinuteCallback(runnable: Runnable, offset: Long) { in addMinuteCallback()
70 fun addQuarterHourCallback(runnable: Runnable) { in addQuarterHourCallback()
79 fun addHourCallback(runnable: Runnable) { in addHourCallback()
88 fun addMidnightCallback(runnable: Runnable) { in addMidnightCallback()
97 private fun addPeriodicCallback(runnable: Runnable, period: Period, offset: Long) { in addPeriodicCallback()
106 fun removePeriodicCallback(runnable: Runnable) { in removePeriodicCallback()
120 val mDelegate: Runnable,
123 ) : Runnable {
|
| /packages/apps/Launcher3/quickstep/src/com/android/launcher3/ |
| D | LauncherAnimationRunner.java | 88 Runnable runnable) { in onAnimationStart()
89 Runnable r = () -> { in onAnimationStart()
133 private final Runnable mSyncFinishRunnable;
134 private final Runnable mASyncFinishRunnable;
137 private Runnable mOnCompleteCallback;
141 private AnimationResult(Runnable syncFinishRunnable, Runnable asyncFinishRunnable) { in AnimationResult()
172 @Nullable Runnable onCompleteCallback, boolean skipFirstFrame) { in setAnimation()
|
| /packages/apps/Camera2/src/com/android/camera/one/v2/photo/ |
| D | PictureCallbackAdapter.java | 47 mMainExecutor.execute(new Runnable() { in provideQuickExposeUpdatable()
60 mMainExecutor.execute(new Runnable() {
73 mMainExecutor.execute(new Runnable() {
86 mMainExecutor.execute(new Runnable() {
100 mMainExecutor.execute(new Runnable() {
114 mMainExecutor.execute(new Runnable() {
|
| /packages/apps/Camera2/src/com/android/camera/ui/focus/ |
| D | FocusController.java | 49 mMainThread.execute(new Runnable() { in showPassiveFocusAtCenter()
68 mMainThread.execute(new Runnable() { in showPassiveFocusAt()
87 mMainThread.execute(new Runnable() { in showActiveFocusAt()
104 mMainThread.execute(new Runnable() { in clearFocusIndicator()
119 mMainThread.execute(new Runnable() { in configurePreviewDimensions()
133 mMainThread.execute(new Runnable() { in setFocusRatio()
|
| /packages/modules/Connectivity/thread/tests/unit/src/android/net/thread/ |
| D | ThreadNetworkControllerTest.java | 151 mController.registerStateCallback(Runnable::run, callback); in registerStateCallback_callbackIsInvokedWithCallingAppIdentity()
192 mController.registerOperationalDatasetCallback(Runnable::run, callback); in registerOperationalDatasetCallback_callbackIsInvokedWithCallingAppIdentity()
218 Runnable::run, in createRandomizedDataset_callbackIsInvokedWithCallingAppIdentity()
229 Runnable::run, in createRandomizedDataset_callbackIsInvokedWithCallingAppIdentity()
261 Runnable::run, in join_callbackIsInvokedWithCallingAppIdentity()
272 Runnable::run, in join_callbackIsInvokedWithCallingAppIdentity()
309 pendingDataset, Runnable::run, v -> successCallbackUid.set(Binder.getCallingUid())); in scheduleMigration_callbackIsInvokedWithCallingAppIdentity()
320 Runnable::run, in scheduleMigration_callbackIsInvokedWithCallingAppIdentity()
350 mController.leave(Runnable::run, v -> successCallbackUid.set(Binder.getCallingUid())); in leave_callbackIsInvokedWithCallingAppIdentity()
359 Runnable::run, in leave_callbackIsInvokedWithCallingAppIdentity()
[all …]
|
| /packages/modules/AdServices/sdksandbox/tests/cts/endtoendtests/src/com/android/tests/sdksandbox/endtoend/ |
| D | SdkSandboxManagerTest.java | 195 mSdkSandboxManager.loadSdk(SDK_NAME_1, new Bundle(), Runnable::run, callback); in testLoadSdkSuccessfully()
289 mSdkSandboxManager.loadSdk(SDK_NAME_1, new Bundle(), Runnable::run, callback); in testRetryLoadSameSdkShouldFail()
293 mSdkSandboxManager.loadSdk(SDK_NAME_1, new Bundle(), Runnable::run, callback); in testRetryLoadSameSdkShouldFail()
303 mSdkSandboxManager.loadSdk(NON_EXISTENT_SDK, new Bundle(), Runnable::run, callback); in testLoadNonExistentSdk()
317 mSdkSandboxManager.loadSdk(SDK_NAME_1, params, Runnable::run, callback); in testLoadSdkWithInternalErrorShouldFail()
329 Runnable::run, in testLoadSdkPropertySdkProviderClassNameNotSet()
340 mSdkSandboxManager.loadSdk(SDK_NAME_1, new Bundle(), Runnable::run, callback); in testUnloadAndReloadSdk()
353 Runnable::run, in testUnloadAndReloadSdk()
362 mSdkSandboxManager.loadSdk(SDK_NAME_1, new Bundle(), Runnable::run, callback2); in testUnloadAndReloadSdk()
369 mSdkSandboxManager.loadSdk(SDK_NAME_1, new Bundle(), Runnable::run, callback); in testUnloadNonexistentSdk()
[all …]
|
| /packages/apps/Messaging/src/com/android/messaging/ui/animation/ |
| D | PopupTransitionAnimation.java | 72 private Runnable mOnStartCallback;
73 private Runnable mOnStopCallback;
112 private final Runnable mCleanupRunnable = new Runnable() {
129 final Runnable startAnimation = new Runnable() { in startAfterLayoutComplete()
171 public PopupTransitionAnimation setOnStartCallback(final Runnable onStart) { in setOnStartCallback()
176 public PopupTransitionAnimation setOnStopCallback(final Runnable onStop) { in setOnStopCallback()
210 ThreadUtil.getMainThreadHandler().post(new Runnable() { in dismiss()
|
| /packages/apps/Camera2/src/com/android/camera/processing/imagebackend/ |
| D | ImageBackend.java | 353 Optional.<Runnable> absent()); in receiveImage()
377 Optional<Runnable> runnableWhenDone) in receiveImage()
426 Optional<Runnable> runnableWhenDone) in receiveImage()
524 final Optional<Runnable> runnableOptional; in receiveImage()
527 Runnable unregisterRunnable = new Runnable() { in receiveImage()
535 runnableOptional = Optional.<Runnable> absent(); in receiveImage()
587 Optional<Runnable> runnableWhenDone) { in initializeTaskDone()
760 Runnable closeTask = new Runnable() { in closeImageExecutorSafe()
804 private class TaskDoneWrapper implements Runnable {
833 Runnable doneRunnable = mImageShadowTask.getRunnableWhenDone(); in run()
[all …]
|
| /packages/providers/ContactsProvider/tests/src/com/android/providers/contacts/ |
| D | VoicemailProviderTest.java | 376 EvenMoreAsserts.assertThrows(SecurityException.class, new Runnable() { in assertBaseUriThrowsSecurityExceptions()
383 EvenMoreAsserts.assertThrows(SecurityException.class, new Runnable() { in assertBaseUriThrowsSecurityExceptions()
390 EvenMoreAsserts.assertThrows(SecurityException.class, new Runnable() { in assertBaseUriThrowsSecurityExceptions()
397 EvenMoreAsserts.assertThrows(SecurityException.class, new Runnable() { in assertBaseUriThrowsSecurityExceptions()
426 EvenMoreAsserts.assertThrows(SecurityException.class, new Runnable() { in testPermissions_InsertAndQuery()
439 EvenMoreAsserts.assertThrows(SecurityException.class, new Runnable() { in assertOnlyOwnVoicemailsCanBeQueriedAndInserted()
489 EvenMoreAsserts.assertThrows(SecurityException.class, new Runnable() { in assertOnlyOwnVoicemailsCanBeUpdatedAndDeleted()
495 EvenMoreAsserts.assertThrows(SecurityException.class, new Runnable() { in assertOnlyOwnVoicemailsCanBeUpdatedAndDeleted()
587 EvenMoreAsserts.assertThrows(SecurityException.class, new Runnable() { in checkHasNoReadAccessToUri()
593 EvenMoreAsserts.assertThrows(SecurityException.class, new Runnable() { in checkHasNoReadAccessToUri()
[all …]
|