Home
last modified time | relevance | path

Searched refs:Callable (Results 1 – 25 of 39) sorted by relevance

12

/tools/tradefederation/core/common_util/com/android/tradefed/invoker/tracing/
DTracePropagatingExecutorService.java26 import java.util.concurrent.Callable;
58 public <T> Future<T> submit(Callable<T> task) { in submit()
73 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
80 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll()
86 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny()
92 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny()
131 private <T> Callable<T> wrapTask(Callable<T> task) { in wrapTask()
143 Callable<?> wrapped = wrapTask(Executors.callable(command));
156 protected <T> Collection<? extends Callable<T>> wrapTasks(
157 Collection<? extends Callable<T>> tasks) {
[all …]
/tools/asuite/atest/integration_tests/
Dsplit_build_test_script.py42 from typing import Any, Callable, Iterator
182 def add_build_step(self, step_func: Callable[StepInput, StepOutput]):
198 def add_test_step(self, step_func: Callable[StepInput, None]):
326 def __init__(self, step_func: Callable[StepInput, StepOutput]):
329 def get_step_func(self) -> Callable[StepInput, StepOutput]:
335 def __init__(self, step_func: Callable[StepInput, None]):
338 def get_step_func(self) -> Callable[StepInput, None]:
447 cls, func: Callable[[Any], Any], decorator_name: str
448 ) -> Callable[[Any], Any]:
501 def run_in_parallel(cls, func: Callable[[Any], Any]) -> Callable[[Any], Any]:
[all …]
Datest_test_archetype_integration_tests.py19 from typing import Callable
153 verifier: Callable[
Datest_command_verification_tests.py20 from typing import Any, Callable
697 assertion_func: Callable[str, None],
/tools/tradefederation/core/javatests/com/android/tradefed/util/
DRequestUtilTest.java32 import java.util.concurrent.Callable;
36 protected class AlwaysFailsCallable implements Callable<Boolean> {
45 Callable<Boolean> requestCallable = new AlwaysFailsCallable(); in testRequestFailedAll()
60 Callable<Boolean> requestCallable = new AlwaysFailsCallable(); in testWaitRightTimeBetweenRequests_1()
78 Callable<Boolean> requestCallable = new AlwaysFailsCallable(); in testWaitRightTimeBetweenRequests_2()
96 Callable<Boolean> requestCallable = new AlwaysFailsCallable(); in testWaitRightTimeBetweenRequests_3()
/tools/tradefederation/core/javatests/com/android/tradefed/util/executor/
DParallelDeviceExecutorTest.java33 import java.util.concurrent.Callable;
58 List<Callable<Boolean>> callableTasks = new ArrayList<>(); in testSimpleExecution()
60 Callable<Boolean> callableTask = in testSimpleExecution()
78 List<Callable<Boolean>> callableTasks = new ArrayList<>(); in testExecution_errors()
80 Callable<Boolean> callableTask = in testExecution_errors()
100 List<Callable<Boolean>> callableTasks = new ArrayList<>(); in testExecution_timeout()
/tools/tradefederation/core/src/com/android/tradefed/util/
DRequestUtil.java26 import java.util.concurrent.Callable;
42 Callable<T> requestMethod, in requestWithBackoff()
89 Callable<T> requestMethod, int minWaitMSec, int maxWaitMSec, int scalingFactor) { in requestWithBackoff()
100 public static <T> T requestWithBackoff(Callable<T> requestMethod) { in requestWithBackoff()
DDeviceConcurrentUtil.java24 import java.util.concurrent.Callable;
85 public static abstract class ShellCommandCallable<V> implements Callable<V> {
DRemoteZip.java38 import java.util.concurrent.Callable;
230 List<Callable<Long>> callableTasks = new ArrayList<>(); in downloadFiles()
236 Callable<Long> callableTask = in downloadFiles()
/tools/tradefederation/core/javatests/com/android/tradefed/device/metric/
DDeviceMetricDataFuncTest.java36 import java.util.concurrent.Callable;
72 Callable<HashMap<String, Metric>> task = in testAddToMetricsMultiThreaded()
73 new Callable<HashMap<String, Metric>>() { in testAddToMetricsMultiThreaded()
90 List<Callable<HashMap<String, Metric>>> tasks = Collections.nCopies(threadCount, task); in testAddToMetricsMultiThreaded()
/tools/tradefederation/core/util_apps/WifiUtil/src/com/android/tradefed/utils/wifi/
DWifiConnector.java37 import java.util.concurrent.Callable;
85 private long waitForCallable(final Callable<Boolean> checker, final String description, in waitForCallable()
111 private void waitForCallable(final Callable<Boolean> checker, final String description) in waitForCallable()
259 timeSpent = waitForCallable(new Callable<Boolean>() { in connectToNetwork()
285 timeSpent = waitForCallable(new Callable<Boolean>() { in connectToNetwork()
295 timeSpent = waitForCallable(new Callable<Boolean>() { in connectToNetwork()
304 waitForCallable(new Callable<Boolean>() { in connectToNetwork()
/tools/asuite/atest/
Dbanner.py23 from typing import Any, Callable
82 def print(self, print_func: Callable = None, date_supplier: Callable = None): argument
/tools/tradefederation/core/javatests/com/android/tradefed/invoker/tracing/
DTracePropagatingExecutorServiceTest.java30 import java.util.concurrent.Callable;
80 Callable<ActiveTrace> subTask = new TraceCaptureTask(); in activeTracePropagatesToSubTask()
127 private static final class TraceCaptureTask implements Callable<ActiveTrace> {
/tools/treble/split/
Dxml_diff.py16 from typing import Any, Callable, Dict, Set
107 key_fn: Callable[[Element], str],
108 diff_fn: Callable[[Element, Element, Set[str]], Any]) -> ChangeMap:
/tools/tradefederation/core/javatests/com/android/tradefed/invoker/logger/
DInvocationLocalTest.java27 import java.util.concurrent.Callable;
99 private <T> T invocation(Callable<T> callable) { in invocation()
/tools/tradefederation/core/src/com/android/tradefed/util/executor/
DParallelDeviceExecutor.java23 import java.util.concurrent.Callable;
54 public List<V> invokeAll(List<Callable<V>> callableTasks, long timeout, TimeUnit unit) { in invokeAll()
/tools/tradefederation/contrib/src/com/android/performance/tests/
DDataRecorder.java28 import java.util.concurrent.Callable;
51 public void captureTime(String key, Callable<Void> action) throws Exception { in captureTime()
/tools/tradefederation/core/src/com/android/tradefed/testtype/
DNoisyDryRunTest.java55 import java.util.concurrent.Callable;
154 List<Callable<Boolean>> callableTasks = new ArrayList<>(); in testCommandLines()
157 Callable<Boolean> callableTask = in testCommandLines()
/tools/tradefederation/core/src/com/android/tradefed/invoker/shard/
DRemoteDynamicPool.java38 import java.util.concurrent.Callable;
131 protected class RequestCallable implements Callable<RequestTestTargetResponse> {
/tools/asuite/atest/logstorage/
Datest_gcp_utils.py25 from typing import Any, Callable
204 build_client_creator: Callable, argument
Dlog_uploader.py27 from typing import Callable
219 def is_uploading_logs(gcert_checker: Callable[[], bool] = None) -> bool: argument
/tools/tradefederation/core/src/com/android/tradefed/suite/checker/
DDeviceBaselineChecker.java43 import java.util.concurrent.Callable;
178 class SetterHelper implements Callable<Pair<String, String>> {
/tools/tradefederation/core/src/com/android/tradefed/device/
DNativeDeviceStateMonitor.java42 import java.util.concurrent.Callable;
217 Callable<BUSY_WAIT_STATUS> bootComplete = in waitForDeviceShell()
313 Callable<BUSY_WAIT_STATUS> bootComplete = in waitForBootComplete()
730 private boolean busyWaitFunction(Callable<BUSY_WAIT_STATUS> callable, long maxWaitTime) { in busyWaitFunction()
/tools/tradefederation/core/javatests/com/android/tradefed/targetprep/sync/
DIncrementalImageFuncTest.java53 import java.util.concurrent.Callable;
142 List<Callable<Boolean>> callableTasks = new ArrayList<>(); in testBlockCompareUpdate()
182 List<Callable<Boolean>> pushTasks = new ArrayList<>(); in testBlockCompareUpdate()
/tools/trebuchet/core/common/src/main/kotlin/trebuchet/util/
DBatchProcessor.kt22 import java.util.concurrent.Callable in <lambda>()

12