| /tools/apkzlib/src/main/java/com/android/tools/build/apkzlib/zip/compress/ |
| D | ExecutorCompressor.java | 37 private final Executor executor; field in ExecutorCompressor
43 public ExecutorCompressor(@Nonnull Executor executor) { in ExecutorCompressor() argument
44 this.executor = executor; in ExecutorCompressor()
52 executor.execute(() -> { in compress()
|
| D | BestAndDefaultDeflateExecutorCompressor.java | 61 public BestAndDefaultDeflateExecutorCompressor(@Nonnull Executor executor, in BestAndDefaultDeflateExecutorCompressor() argument
63 super(executor); in BestAndDefaultDeflateExecutorCompressor()
69 new DeflateExecutionCompressor(executor, tracker, Deflater.DEFAULT_COMPRESSION); in BestAndDefaultDeflateExecutorCompressor()
71 new DeflateExecutionCompressor(executor, tracker, Deflater.BEST_COMPRESSION); in BestAndDefaultDeflateExecutorCompressor()
|
| D | DeflateExecutionCompressor.java | 54 @Nonnull Executor executor, in DeflateExecutionCompressor()
57 super(executor); in DeflateExecutionCompressor()
|
| /tools/tradefederation/core/src/com/android/tradefed/util/executor/ |
| D | ParallelDeviceExecutor.java | 16 package com.android.tradefed.util.executor;
52 ExecutorService executor = in invokeAll() local
65 List<Future<V>> futures = executor.invokeAll(callableTasks); in invokeAll()
79 executor.shutdown(); in invokeAll()
|
| /tools/tradefederation/core/tests/src/com/android/tradefed/invoker/logger/ |
| D | InvocationLocalTest.java | 102 ExecutorService executor = in invocation() local
105 executor.submit( in invocation()
113 executor.shutdown(); in invocation()
|
| /tools/acloud/internal/lib/ |
| D | base_cloud_client.py | 284 executor = utils.BatchHttpRequestExecutor(
293 executor.Execute()
294 return executor.GetResults()
|
| /tools/test/connectivity/acts/tests/google/ble/concurrency/ |
| D | ConcurrentGattConnectTest.py | 242 executor = concurrent.futures.ThreadPoolExecutor(max_workers=10)
280 executor.submit(run_continuous_write_descriptor, *arguments_list)
282 executor.shutdown(wait=True)
|
| /tools/apksig/src/main/java/com/android/apksig/internal/apk/v2/ |
| D | V2SchemeVerifier.java | 91 RunnablesExecutor executor, in verify() argument
113 verify(executor, in verify()
136 RunnablesExecutor executor, in verify() argument
160 executor, beforeApkSigningBlock, centralDir, eocd, contentDigestsToVerify, result); in verify()
|
| D | V2SchemeSigner.java | 141 RunnablesExecutor executor, in generateApkSignatureSchemeV2Block() argument
151 executor, beforeCentralDir, centralDir, eocd, signerConfigs); in generateApkSignatureSchemeV2Block()
|
| /tools/test/connectivity/acts/framework/acts/ |
| D | utils.py | 369 with concurrent.futures.ThreadPoolExecutor(max_workers=30) as executor:
371 future_to_params = {executor.submit(func, *p): p for p in param_list}
1154 with ThreadPoolExecutor(max_workers=len(calls)) as executor:
1155 futures = [executor.submit(call) for call in calls]
1220 with ThreadPoolExecutor(max_workers=len(calls)) as executor:
1221 futures = [executor.submit(call_wrapper, call) for call in calls]
|
| /tools/apksig/src/main/java/com/android/apksig/internal/apk/v3/ |
| D | V3SchemeVerifier.java | 98 RunnablesExecutor executor, in verify() argument
123 verify(executor, in verify()
144 RunnablesExecutor executor, in verify() argument
160 executor, beforeApkSigningBlock, centralDir, eocd, contentDigestsToVerify, result); in verify()
|
| D | V3SchemeSigner.java | 129 RunnablesExecutor executor, in generateApkSignatureSchemeV3Block() argument
138 executor, beforeCentralDir, centralDir, eocd, signerConfigs); in generateApkSignatureSchemeV3Block()
|
| /tools/apksig/src/main/java/com/android/apksig/internal/apk/ |
| D | ApkSigningBlockUtils.java | 179 RunnablesExecutor executor, in verifyIntegrity() argument
207 executor, in verifyIntegrity()
434 RunnablesExecutor executor, in computeContentDigests() argument
448 executor, in computeContentDigests()
563 RunnablesExecutor executor, in computeOneMbChunkContentDigests() argument
584 executor.execute(() -> new ChunkDigester(chunkSupplier, chunkDigestsList)); in computeOneMbChunkContentDigests()
1125 RunnablesExecutor executor, in computeContentDigests() argument
1149 executor, in computeContentDigests()
|
| /tools/tradefederation/core/tests/src/com/android/tradefed/util/executor/ |
| D | ParallelDeviceExecutorTest.java | 16 package com.android.tradefed.util.executor;
|
| /tools/apksig/src/main/java/com/android/apksig/ |
| D | ApkSignerEngine.java | 121 default void setExecutor(RunnablesExecutor executor) { in setExecutor() argument
|
| D | ApkVerifier.java | 231 RunnablesExecutor executor = RunnablesExecutor.SINGLE_THREADED; in verify() local
237 executor, in verify()
263 executor, in verify()
|
| D | DefaultApkSignerEngine.java | 520 public void setExecutor(RunnablesExecutor executor) { in setExecutor() argument
521 mExecutor = executor; in setExecutor()
|
| /tools/tradefederation/core/src/com/android/tradefed/invoker/ |
| D | InvocationExecution.java | 78 import com.android.tradefed.util.executor.ParallelDeviceExecutor;
236 ParallelDeviceExecutor<Boolean> executor = in doSetup() local
255 executor.invokeAll(callableTasks, 30, TimeUnit.MINUTES); in doSetup()
256 if (executor.hasErrors()) { in doSetup()
257 List<Throwable> errors = executor.getErrors(); in doSetup()
|
| D | TestInvocation.java | 86 import com.android.tradefed.util.executor.ParallelDeviceExecutor;
317 ParallelDeviceExecutor<Boolean> executor = in performInvocation() local
330 executor.invokeAll(callableTasks, 5, TimeUnit.MINUTES); in performInvocation()
|
| /tools/asuite/asuite_plugin/src/java/com/android/atest/run/ |
| D | AtestRunConfiguration.java | 155 @NotNull Executor executor, @NotNull ExecutionEnvironment executionEnvironment) in getState()
|
| /tools/test/connectivity/acts/tests/google/wifi/ |
| D | WifiRssiTest.py | 483 executor = ThreadPoolExecutor(max_workers=1)
484 thread_future = executor.submit(
488 executor.shutdown(wait=False)
|
| /tools/tradefederation/core/tests/src/com/android/tradefed/config/ |
| D | DynamicRemoteFileResolverTest.java | 39 import com.android.tradefed.util.executor.ParallelDeviceExecutor;
417 ParallelDeviceExecutor<Set<File>> executor = new ParallelDeviceExecutor<>(devices); in testResolve_remoteMultiMap_concurrent() local
419 downloadedFile = executor.invokeAll(call, 1, TimeUnit.MINUTES); in testResolve_remoteMultiMap_concurrent()
|
| /tools/test/connectivity/acts/framework/acts/test_utils/wifi/ |
| D | wifi_performance_test_utils.py | 51 executor = ThreadPoolExecutor(max_workers=1)
52 thread_future = executor.submit(f, *args, **kwargs)
54 executor.shutdown(wait=False)
|
| /tools/asuite/asuite_plugin/prebuilt/ |
| D | asuite_plugin-1.0.jar | META-INF/
META-INF/MANIFEST.MF
com/
com/android/
com/ ... |
| /tools/apkzlib/src/test/java/com/android/tools/build/apkzlib/zip/ |
| D | ZFileTest.java | 1064 ExecutorService executor = Executors.newSingleThreadExecutor(); in deferredCompression() local
1068 options.setCompressor(new DeflateExecutionCompressor(executor, options.getTracker(), in deferredCompression()
1105 executor.shutdownNow(); in deferredCompression()
|