Home
last modified time | relevance | path

Searched refs:executor (Results 1 – 18 of 18) sorted by relevance

/art/libartservice/service/java/com/android/server/art/model/
DConfig.java75 @NonNull Executor executor, @NonNull BatchDexoptStartCallback callback) { in setBatchDexoptStartCallback()
76 mBatchDexoptStartCallback = Callback.create(callback, executor); in setBatchDexoptStartCallback()
89 @NonNull Executor executor, @NonNull ScheduleBackgroundDexoptJobCallback callback) { in setScheduleBackgroundDexoptJobCallback()
90 mScheduleBackgroundDexoptJobCallback = Callback.create(callback, executor); in setScheduleBackgroundDexoptJobCallback()
104 @NonNull Executor executor, @NonNull DexoptDoneCallback callback) { in addDexoptDoneCallback() argument
106 callback, Callback.create(callback, executor, onlyIncludeUpdates)) in addDexoptDoneCallback()
122 @NonNull Executor executor, @NonNull AdjustCompilerFilterCallback callback) { in setAdjustCompilerFilterCallback()
123 mAdjustCompilerFilterCallback = Callback.create(callback, executor); in setAdjustCompilerFilterCallback()
139 public abstract @NonNull Executor executor(); in executor() method in Config.Callback
142 @NonNull CallbackType callback, @NonNull Executor executor, in create() argument
[all …]
/art/tools/dexfuzz/src/dexfuzz/fuzzers/
DFuzzer.java108 for (Executor executor : executors) { in shutdown()
109 executor.shutdown(); in shutdown()
230 for (Executor executor : executors) { in execute()
231 executor.reset(); in execute()
232 executor.prepareProgramForExecution(programName); in execute()
233 executor.execute(programName); in execute()
234 if (!executor.didTargetVerify()) { in execute()
312 for (Executor executor : executors) { in analyseResults()
313 if (executor.getResult().isTimeout()) { in analyseResults()
314 timedOut.add(executor); in analyseResults()
[all …]
/art/libartservice/service/javatests/com/android/server/art/testing/
DMockClock.java37 var executor = new ScheduledExecutor(); in createScheduledExecutor() local
38 mExecutors.add(executor); in createScheduledExecutor()
39 return executor; in createScheduledExecutor()
48 for (ScheduledExecutor executor : mExecutors) { in advanceTime()
49 executor.notifyUpdate(); in advanceTime()
/art/tools/dexfuzz/src/dexfuzz/listeners/
DLogFileListener.java116 for (Executor executor : timedOut) { in handleTimeouts()
117 write(" " + executor.getName()); in handleTimeouts()
121 for (Executor executor : didNotTimeOut) { in handleTimeouts()
122 write(" " + executor.getName()); in handleTimeouts()
134 for (Executor executor : executors) { in handleDivergences()
135 write(" " + executor.getName()); in handleDivergences()
179 public void handleDumpOutput(String outputLine, Executor executor) { in handleDumpOutput() argument
180 write(executor.getName() + " OUTPUT:"); in handleDumpOutput()
DConsoleLoggerListener.java92 for (Executor executor : executors) { in handleDivergences()
93 logToConsole(" " + executor.getName()); in handleDivergences()
125 public void handleDumpOutput(String outputLine, Executor executor) { in handleDumpOutput() argument
126 logToConsole(executor.getName() + " OUTPUT: " + outputLine); in handleDumpOutput()
DBisectionSearchListener.java92 for (Executor executor : executors) { in handleDivergences()
93 if (executor.isBisectable()) { in handleDivergences()
95 ExecutionResult result = executor.runBisectionSearch(fuzzedFile, in handleDivergences()
DMultiplexerListener.java130 public void handleDumpOutput(String outputLine, Executor executor) { in handleDumpOutput() argument
132 listener.handleDumpOutput(outputLine, executor); in handleDumpOutput()
DBaseListener.java56 public void handleDumpOutput(String outputLine, Executor executor) { } in handleDumpOutput() argument
/art/libartservice/service/java/com/android/server/art/
DDebouncer.java46 private void runTask(@NonNull Runnable command, @NonNull ScheduledExecutorService executor) { in runTask() argument
55 if (mExecutor == executor) { in runTask()
74 ScheduledExecutorService executor = mExecutor; in maybeRunAsync() local
76 () -> runTask(command, executor), mIntervalMs, TimeUnit.MILLISECONDS); in maybeRunAsync()
DArtManagerLocal.java481 Utils.executeAndWait(callback.executor(), () -> { in dexoptPackages()
538 public void setBatchDexoptStartCallback(@NonNull @CallbackExecutor Executor executor, in setBatchDexoptStartCallback() argument
540 mInjector.getConfig().setBatchDexoptStartCallback(executor, callback); in setBatchDexoptStartCallback()
611 public void setScheduleBackgroundDexoptJobCallback(@NonNull @CallbackExecutor Executor executor, in setScheduleBackgroundDexoptJobCallback() argument
613 mInjector.getConfig().setScheduleBackgroundDexoptJobCallback(executor, callback); in setScheduleBackgroundDexoptJobCallback()
694 @NonNull @CallbackExecutor Executor executor, @NonNull DexoptDoneCallback callback) { in addDexoptDoneCallback() argument
695 mInjector.getConfig().addDexoptDoneCallback(onlyIncludeUpdates, executor, callback); in addDexoptDoneCallback()
1043 public void setAdjustCompilerFilterCallback(@NonNull @CallbackExecutor Executor executor, in setAdjustCompilerFilterCallback() argument
1045 mInjector.getConfig().setAdjustCompilerFilterCallback(executor, callback); in setAdjustCompilerFilterCallback()
1200 @NonNull Executor executor, in maybeDowngradePackages() argument
[all …]
DUtils.java270 public static void executeAndWait(@NonNull Executor executor, @NonNull Runnable runnable) { in executeAndWait() argument
271 getFuture(CompletableFuture.runAsync(runnable, executor)); in executeAndWait()
274 public static <T> T executeAndWait(@NonNull Executor executor, @NonNull Supplier<T> supplier) { in executeAndWait() argument
275 return getFuture(CompletableFuture.supplyAsync(supplier, executor)); in executeAndWait()
DDexoptHelper.java197 }, doneCallback.executor()); in dexoptPackages()
202 }, doneCallback.executor()); in dexoptPackages()
DBackgroundDexoptJob.java149 callback.executor(), () -> { callback.get().onOverrideJobInfo(builder); }); in schedule()
DDexopter.java367 targetCompilerFilter, Utils.executeAndWait(callback.executor(), () -> { in adjustCompilerFilter()
/art/libartservice/service/javatests/com/android/server/art/
DDebouncerTest.java69 for (MockClock.ScheduledExecutor executor : executors) { in test()
70 assertThat(executor.isShutdown()).isTrue(); in test()
DUtilsTest.java188 Executor executor = ForkJoinPool.commonPool(); in testExecuteAndWait() local
190 Utils.executeAndWait(executor, () -> { in testExecuteAndWait()
203 Executor executor = ForkJoinPool.commonPool(); in testExecuteAndWaitPropagatesException() local
204 Utils.executeAndWait(executor, () -> { throw new IllegalArgumentException(); }); in testExecuteAndWaitPropagatesException()
/art/test/testrunner/
Dtestrunner.py462 def start_combination(executor, config_tuple, global_options, address_size): argument
579 return executor.submit(run_test, args_test, test, variant_set, test_name)
582 with concurrent.futures.ThreadPoolExecutor(max_workers=n_thread) as executor:
587 test_futures.append(start_combination(executor, config_tuple, args_all, address_size))
591 start_combination(executor, config_tuple, args_all, "")) # no address size
607 executor.shutdown(True)
/art/build/boot/hiddenapi/
Dhiddenapi-max-target-o-low-priority.txt421 Lcom/android/okhttp/ConnectionPool;->executor:Ljava/util/concurrent/Executor;
6612 Ljava/util/concurrent/CompletableFuture$DelayedExecutor;->executor:Ljava/util/concurrent/Executor;
6646 Ljava/util/concurrent/CompletableFuture$TaskSubmitter;->executor:Ljava/util/concurrent/Executor;
6659 Ljava/util/concurrent/CompletableFuture$UniCompletion;->executor:Ljava/util/concurrent/Executor;
7417 Ljava/util/concurrent/ExecutorCompletionService;->executor:Ljava/util/concurrent/Executor;