| /tools/tradefederation/core/javatests/com/android/tradefed/invoker/tracing/ |
| D | TracePropagatingExecutorServiceTest.java | 39 private final TracePropagatingExecutorService executor = newTestExecutorService(); field in TracePropagatingExecutorServiceTest
57 MoreExecutors.shutdownAndAwaitTermination(executor, Duration.ofSeconds(5)); in tearDown()
64 Future<ActiveTrace> f = executor.submit(new TraceCaptureTask()); in noTracePropagatesToTask()
73 Future<ActiveTrace> f = executor.submit(new TraceCaptureTask()); in activeTracePropagatesToTask()
84 executor.submit( in activeTracePropagatesToSubTask()
86 return executor.submit(subTask).get(); in activeTracePropagatesToSubTask()
97 executor.submit( in callerActiveTraceRestored()
|
| /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/test/connectivity/acts/framework/acts/libs/utils/ |
| D | multithread.py | 45 executor = concurrent.futures.ThreadPoolExecutor(max_workers=1)
47 future_object = executor.submit(task_wrapper, task)
66 executor = concurrent.futures.ThreadPoolExecutor(
70 results = list(executor.map(task_wrapper, tasks))
74 executor.shutdown()
|
| /tools/tradefederation/core/src/com/android/tradefed/util/executor/ |
| D | ParallelDeviceExecutor.java | 16 package com.android.tradefed.util.executor;
73 ExecutorService executor = in invokeAll() local
79 ? executor.invokeAll(callableTasks) in invokeAll()
80 : executor.invokeAll(callableTasks, timeout, unit); in invokeAll()
94 executor.shutdownNow(); in invokeAll()
|
| /tools/asuite/ |
| D | preupload_hook_script.py | 50 with concurrent.futures.ThreadPoolExecutor(max_workers=cpu_count) as executor:
51 completed_processes = executor.map(
111 with concurrent.futures.ThreadPoolExecutor(max_workers=cpu_count) as executor:
112 need_reformat = executor.map(
|
| /tools/tradefederation/core/javatests/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/tradefederation/core/src/com/android/tradefed/util/ |
| D | RemoteZip.java | 26 import com.android.tradefed.util.executor.ParallelDeviceExecutor;
228 ParallelDeviceExecutor<Long> executor = in downloadFiles() local
272 List<Long> downloadSizes = executor.invokeAll(callableTasks, 0L, TimeUnit.MINUTES); in downloadFiles()
293 if (executor.hasErrors()) { in downloadFiles()
294 List<Throwable> errors = executor.getErrors(); in downloadFiles()
|
| /tools/apksig/src/main/java/com/android/apksig/internal/apk/v3/ |
| D | V3SchemeSigner.java | 80 RunnablesExecutor executor, in V3SchemeSigner() argument
88 mExecutor = executor; in V3SchemeSigner()
160 RunnablesExecutor executor, in generateApkSignatureSchemeV3Block() argument
167 .setRunnablesExecutor(executor) in generateApkSignatureSchemeV3Block()
453 public Builder setRunnablesExecutor(RunnablesExecutor executor) { in setRunnablesExecutor() argument
454 mExecutor = executor; in setRunnablesExecutor()
|
| D | V3SchemeVerifier.java | 87 RunnablesExecutor executor, in V3SchemeVerifier() argument
97 mExecutor = executor; in V3SchemeVerifier()
133 RunnablesExecutor executor, in verify() argument
140 .setRunnablesExecutor(executor) in verify()
667 public Builder setRunnablesExecutor(RunnablesExecutor executor) { in setRunnablesExecutor() argument
668 mExecutor = executor; in setRunnablesExecutor()
|
| /tools/acloud/internal/lib/ |
| D | base_cloud_client.py | 283 executor = utils.BatchHttpRequestExecutor(
292 executor.Execute()
293 return executor.GetResults()
|
| /tools/tradefederation/core/src/com/android/tradefed/monitoring/ |
| D | LabResourceDeviceMonitor.java | 147 .executor( in run()
208 private void awaitTerminateExecutor(ExecutorService executor) { in awaitTerminateExecutor() argument
209 if (executor == null) { in awaitTerminateExecutor()
212 executor.shutdownNow(); in awaitTerminateExecutor()
214 executor.awaitTermination(EXECUTOR_TERMINATE_TIMEOUT_SEC, TimeUnit.SECONDS); in awaitTerminateExecutor()
|
| /tools/apksig/src/main/java/com/android/apksig/internal/apk/v2/ |
| D | V2SchemeSigner.java | 147 generateApkSignatureSchemeV2Block(RunnablesExecutor executor, in generateApkSignatureSchemeV2Block() argument
155 return generateApkSignatureSchemeV2Block(executor, beforeCentralDir, centralDir, eocd, in generateApkSignatureSchemeV2Block()
161 RunnablesExecutor executor, in generateApkSignatureSchemeV2Block() argument
172 executor, beforeCentralDir, centralDir, eocd, signerConfigs); in generateApkSignatureSchemeV2Block()
|
| D | V2SchemeVerifier.java | 90 RunnablesExecutor executor, in verify() argument
112 verify(executor, in verify()
135 RunnablesExecutor executor, in verify() argument
159 executor, beforeApkSigningBlock, centralDir, eocd, contentDigestsToVerify, result); in verify()
|
| /tools/test/connectivity/acts_tests/acts_contrib/test_utils/bt/ |
| D | BtMultiprofileBaseTest.py | 116 executor = ThreadPoolExecutor(2)
117 throughput = executor.submit(self.measure_rfcomm_throughput, 100)
118 executor.submit(self.setup_iperf_and_run_throughput, )
|
| D | ble_performance_test_utils.py | 228 executor = ThreadPoolExecutor(2)
229 ble_throughput = executor.submit(run_ble_throughput, client_ad,
231 ble_rssi = executor.submit(read_ble_rssi, server_ad, gatt_server,
|
| /tools/tradefederation/core/javatests/com/android/tradefed/targetprep/sync/ |
| D | IncrementalImageFuncTest.java | 34 import com.android.tradefed.util.executor.ParallelDeviceExecutor;
164 ParallelDeviceExecutor<Boolean> executor = in testBlockCompareUpdate() local
166 executor.invokeAll(callableTasks, 0, TimeUnit.MINUTES); in testBlockCompareUpdate()
167 if (executor.hasErrors()) { in testBlockCompareUpdate()
168 throw executor.getErrors().get(0); in testBlockCompareUpdate()
|
| /tools/test/connectivity/acts_tests/tests/google/ble/concurrency/ |
| D | ConcurrentGattConnectTest.py | 240 executor = concurrent.futures.ThreadPoolExecutor(max_workers=10)
278 executor.submit(run_continuous_write_descriptor, *arguments_list)
280 executor.shutdown(wait=True)
|
| /tools/tradefederation/core/src/com/android/tradefed/testtype/ |
| D | NoisyDryRunTest.java | 45 import com.android.tradefed.util.executor.ParallelDeviceExecutor;
152 ParallelDeviceExecutor<Boolean> executor = in testCommandLines() local
166 executor.invokeAll(callableTasks, 0, TimeUnit.HOURS); in testCommandLines()
|
| /tools/test/connectivity/acts/framework/acts/ |
| D | utils.py | 378 with concurrent.futures.ThreadPoolExecutor(max_workers=30) as executor:
380 future_to_params = {executor.submit(func, *p): p for p in param_list}
1180 with ThreadPoolExecutor(max_workers=len(calls)) as executor:
1181 futures = [executor.submit(call) for call in calls]
1246 with ThreadPoolExecutor(max_workers=len(calls)) as executor:
1247 futures = [executor.submit(call_wrapper, call) for call in calls]
1865 with ThreadPoolExecutor() as executor:
1875 executor.submit(mdns_query, interface, address))
|
| /tools/asuite/atest/integration_tests/ |
| D | atest_integration_test.py | 433 with concurrent.futures.ThreadPoolExecutor() as executor:
434 stdout_future = executor.submit(
437 stderr_future = executor.submit(
|
| D | split_build_test_script.py | 388 ) as executor:
391 executor.submit(self.compress_file, file_path)
414 ) as executor:
416 executor.submit(self.decompress_file, file_path)
616 ) as executor:
628 return executor.submit(test.run)
|
| /tools/tradefederation/core/src/com/android/tradefed/util/image/ |
| D | IncrementalImageUtil.java | 43 import com.android.tradefed.util.executor.ParallelDeviceExecutor;
810 ParallelDeviceExecutor<Boolean> executor = in run() local
812 executor.invokeAll(callableTasks, 0, TimeUnit.MINUTES); in run()
813 if (executor.hasErrors()) { in run()
816 executor.getErrors().get(0).getMessage(), in run()
817 executor.getErrors().get(0), in run()
|
| /tools/tradefederation/core/src/com/android/tradefed/invoker/ |
| D | InvocationExecution.java | 95 import com.android.tradefed.util.executor.ParallelDeviceExecutor;
413 ParallelDeviceExecutor<Boolean> executor = in runLabPreparersSetup() local
437 executor.invokeAll(callableTasks, timeout.toMillis(), TimeUnit.MILLISECONDS); in runLabPreparersSetup()
438 if (executor.hasErrors()) { in runLabPreparersSetup()
439 List<Throwable> errors = executor.getErrors(); in runLabPreparersSetup()
480 ParallelDeviceExecutor<Boolean> executor = in runPreparersSetup() local
503 executor.invokeAll(callableTasks, timeout.toMillis(), TimeUnit.MILLISECONDS); in runPreparersSetup()
504 if (executor.hasErrors()) { in runPreparersSetup()
505 List<Throwable> errors = executor.getErrors(); in runPreparersSetup()
690 ParallelDeviceExecutor<Void> executor = in runDevicePreInvocationSetup() local
[all …]
|