| /tools/netsim/scripts/tasks/ |
| D | __init__.py | 20 from tasks.compile_install_task import CompileInstallTask
21 from tasks.compile_task import CompileTask
22 from tasks.configure_task import ConfigureTask
23 from tasks.install_emulator_task import InstallEmulatorTask
24 from tasks.run_pytest_task import RunPyTestTask
25 from tasks.task import Task
26 from tasks.zip_artifact_task import ZipArtifactTask
39 def log_enabled_tasks(tasks): argument
41 task_name for task_name, task in tasks.items() if task.enabled
50 tasks = {
[all …]
|
| /tools/test/connectivity/acts_tests/tests/google/tel/lab/ |
| D | TelLabGFTInOutServiceTest.py | 345 tasks = [(wait_for_ims_registered, (self.log, ad, )) for ad in self.android_devices]
346 if not multithread_func(self.log, tasks):
347 tasks = [(check_ims_state, (ad, )) for ad in self.android_devices]
348 if not multithread_func(self.log, tasks):
352 tasks = [(self.verify_device_status, (ad, VOICE_CALL))
354 test_result = multithread_func(self.log, tasks)
389 tasks = [(check_no_service_time, (ad, )) for ad in self.android_devices]
390 if not multithread_func(self.log, tasks):
463 tasks = [(mo_voice_call, (self.log, ad, VOICE_CALL, False)) for ad in self.android_devices]
464 if not multithread_func(self.log, tasks):
[all …]
|
| D | TelLabGFTAirplaneModeTest.py | 78 tasks = [(self._airplane_mode_helper, (ad, MOBILE_DATA_ON_OFF_CASE, RAT_3G))
80 if not multithread_func(self.log, tasks):
94 tasks = [(self._airplane_mode_helper, (ad, MOBILE_DATA_ON_OFF_CASE, RAT_4G))
96 if not multithread_func(self.log, tasks):
111 tasks = [(self._airplane_mode_helper, (ad, MOBILE_DATA_ON_OFF_CASE, RAT_5G))
113 if not multithread_func(self.log, tasks):
128 tasks = [(self._airplane_mode_helper, (ad, IN_CALL_CASE, GEN_3G))
130 if not multithread_func(self.log, tasks):
145 tasks = [(self._airplane_mode_helper, (ad, IN_CALL_CASE, GEN_4G))
147 if not multithread_func(self.log, tasks):
[all …]
|
| D | TelLabGFTVoWifiStressTest.py | 72 tasks = [(phone_setup_volte, (self.log, ad, )) for ad in self.android_devices]
73 if not multithread_func(self.log, tasks):
79 tasks = [(toggle_wfc, (self.log, ad,True)) for ad in self.android_devices]
80 if not multithread_func(self.log, tasks):
89 tasks = [(toggle_airplane_mode, (self.log, ad, False))
91 multithread_func(self.log, tasks)
122 tasks = [(phone_setup_iwlan, (self.log, ad, False, wfc_mode,
124 if not multithread_func(self.log, tasks):
164 tasks = [(phone_setup_iwlan, (self.log, ad, False, wfc_mode,
166 if not multithread_func(self.log, tasks):
[all …]
|
| D | TelLabGFTVoWifiTest.py | 80 tasks = [(phone_setup_volte, (self.log, ad, )) for ad in self.android_devices]
81 if not multithread_func(self.log, tasks):
90 tasks = [(toggle_wfc, (self.log, ad,True)) for ad in self.android_devices]
91 if not multithread_func(self.log, tasks):
100 tasks = [(toggle_airplane_mode, (self.log, ad, False))
102 multithread_func(self.log, tasks)
140 tasks = [(verify_data_connection, (ad, 3))
142 if not multithread_func(self.log, tasks):
145 tasks = [(check_back_to_service_time, (ad,)) for ad in self.android_devices]
146 test_result = multithread_func(self.log, tasks)
[all …]
|
| D | TelLabGFTModemConnectivityHelperTest.py | 96 tasks = [(self._initiate_call, (ad, ))
98 if not multithread_func(self.log, tasks):
100 tasks = [(is_phone_in_call_volte, (
104 test_result = multithread_func(self.log, tasks)
110 tasks = [(is_phone_in_call_volte, (
114 test_result = multithread_func(self.log, tasks)
|
| /tools/test/connectivity/acts_tests/acts_contrib/test_utils/tel/ |
| D | tel_5g_test_utils.py | 90 tasks = [(set_preferred_mode_for_5g, [ad]) for ad in ads]
91 if not multithread_func(log, tasks):
95 tasks = [(is_current_network_5g_nsa, [ad, None, mmwave]) for ad in ads]
96 if not multithread_func(log, tasks):
113 tasks = [(phone_setup_volte, (log, ads[0], nw_gen, nr_type)),
115 if not multithread_func(log, tasks):
122 tasks = [(phone_setup_csfb, (log, ads[0])),
124 if not multithread_func(log, tasks):
135 tasks = [(phone_setup_iwlan,
141 if not multithread_func(log, tasks):
[all …]
|
| /tools/test/connectivity/acts/framework/acts/libs/utils/ |
| D | multithread.py | 54 def run_multithread_func(log, tasks): argument
65 number_of_workers = min(MAX_NUMBER_OF_WORKERS, len(tasks))
70 results = list(executor.map(task_wrapper, tasks))
77 [task[0].__name__ for task in tasks], results)
81 def multithread_func(log, tasks): argument
92 results = run_multithread_func(log, tasks)
99 def multithread_func_and_check_results(log, tasks, expected_results): argument
112 results = run_multithread_func(log, tasks)
115 for task, result, expected_result in zip(tasks, results, expected_results):
|
| /tools/test/connectivity/acts_tests/tests/google/tel/live/ |
| D | TelLiveVoiceTest.py | 196 tasks = [(phone_setup_voice_general, (self.log, ads[0])),
198 if not multithread_func(self.log, tasks):
226 tasks = [(phone_setup_voice_general, (self.log, ads[0])),
228 if not multithread_func(self.log, tasks):
256 tasks = [(phone_setup_volte, (self.log, ads[0])), (phone_setup_volte,
258 if not multithread_func(self.log, tasks):
288 tasks = [(phone_setup_volte, (self.log, ads[0])), (phone_setup_volte,
290 if not multithread_func(self.log, tasks):
321 tasks = [(phone_setup_volte, (self.log, ads[0])), (phone_setup_volte,
323 if not multithread_func(self.log, tasks):
[all …]
|
| D | TelLiveVoiceConfTest.py | 6965 tasks = [(phone_setup_iwlan,
6974 if not multithread_func(self.log, tasks):
7011 tasks = [(phone_setup_iwlan,
7020 if not multithread_func(self.log, tasks):
7056 tasks = [(phone_setup_iwlan,
7065 if not multithread_func(self.log, tasks):
7102 tasks = [(phone_setup_iwlan,
7111 if not multithread_func(self.log, tasks):
7147 tasks = [(phone_setup_iwlan,
7156 if not multithread_func(self.log, tasks):
[all …]
|
| D | TelLiveVideoTest.py | 106 tasks = [(phone_setup_video, (self.log, ads[0])), (phone_setup_video,
108 if not multithread_func(self.log, tasks):
142 tasks = [(phone_setup_video, (self.log, ads[0])), (phone_setup_video,
144 if not multithread_func(self.log, tasks):
177 tasks = [(phone_setup_video, (self.log, ads[0])), (phone_setup_video,
179 if not multithread_func(self.log, tasks):
213 tasks = [(phone_setup_video, (self.log, ads[0])), (phone_setup_video,
215 if not multithread_func(self.log, tasks):
259 tasks = [(phone_setup_video, (self.log, ads[0])), (phone_setup_video,
261 if not multithread_func(self.log, tasks):
[all …]
|
| /tools/netsim/scripts/ |
| D | build_tools.py | 25 from tasks import (
148 tasks = get_tasks(args, env)
151 log_enabled_tasks(tasks)
158 tasks.get("Configure").run()
161 tasks.get("Compile").run()
164 tasks.get("CompileInstall").run()
167 tasks.get("ZipArtifact").run()
170 tasks.get("InstallEmulator").run()
171 tasks.get("RunPyTest").run()
|
| /tools/tradefederation/core/common_util/com/android/tradefed/invoker/tracing/ |
| D | TracePropagatingExecutorService.java | 73 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll() argument
75 return delegate.invokeAll(wrapTasks(tasks)); in invokeAll()
80 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll() argument
82 return delegate.invokeAll(wrapTasks(tasks), timeout, unit); in invokeAll()
86 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny() argument
88 return delegate.invokeAny(wrapTasks(tasks)); in invokeAny()
92 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny() argument
94 return delegate.invokeAny(wrapTasks(tasks), timeout, unit); in invokeAny()
157 Collection<? extends Callable<T>> tasks) {
159 for (Callable<T> task : tasks) {
|
| /tools/metalava/buildSrc/src/main/kotlin/com/android/tools/metalava/ |
| D | Ktfmt.kt | 30 import org.gradle.api.tasks.Classpath
31 import org.gradle.api.tasks.InputFiles
32 import org.gradle.api.tasks.OutputFiles
33 import org.gradle.api.tasks.PathSensitive
34 import org.gradle.api.tasks.PathSensitivity
35 import org.gradle.api.tasks.TaskAction
49 tasks.register("ktCheck", KtfmtCheckTask::class.java) { in Project()
55 tasks.register("ktFormat", KtfmtFormatTask::class.java) { in Project()
|
| D | MetalavaBuildPlugin.kt | 32 import org.gradle.api.internal.tasks.testing.filter.DefaultTestFilter in <lambda>()
39 import org.gradle.api.publish.tasks.GenerateModuleMetadata in <lambda>()
40 import org.gradle.api.tasks.TaskProvider in <lambda>()
41 import org.gradle.api.tasks.bundling.Zip in <lambda>()
42 import org.gradle.api.tasks.testing.Test in <lambda>()
43 import org.gradle.api.tasks.testing.logging.TestLogEvent in <lambda>()
50 import org.jetbrains.kotlin.gradle.tasks.KotlinCompile in <lambda>()
63 project.tasks.withType(KotlinCompile::class.java).configureEach { task -> in <lambda>()
98 val testTask = project.tasks.named("test", Test::class.java) in <lambda>()
101 project.tasks.register("zipTestResults", Zip::class.java) { zip -> in <lambda>()
[all …]
|
| /tools/ndkports/jsoncpp/ |
| D | build.gradle.kts | 22 tasks.extractSrc { in <lambda>()
31 val buildTask = tasks.register<MesonPortTask>("buildPort")
33 tasks.prefabPackage { in <lambda>()
41 tasks.register<AndroidExecutableTestTask>("test") { in <lambda>()
116 tasks { in <lambda>()
|
| /tools/ndkports/buildSrc/src/main/kotlin/com/android/ndkports/ |
| D | NdkPortsPlugin.kt | 15 import org.gradle.api.tasks.bundling.Zip in <lambda>()
79 prefabTask = project.tasks.register("prefab", PrefabTask::class.java) { in createTasks()
88 extractTask = project.tasks.register( in createTasks()
97 packageTask = project.tasks.register( in createTasks()
116 aarTask = project.tasks.register("packageAar", Zip::class.java) { in createTasks()
124 val portTasks = project.tasks.withType(PortTask::class.java) in createTasks()
144 project.tasks.withType(AndroidExecutableTestTask::class.java) in createTasks()
151 project.tasks.getByName("check").dependsOn(testTask) in createTasks()
|
| D | PrefabTask.kt | 12 import org.gradle.api.tasks.Input in <lambda>()
13 import org.gradle.api.tasks.InputDirectory in <lambda>()
14 import org.gradle.api.tasks.InputFiles in <lambda>()
15 import org.gradle.api.tasks.Optional in <lambda>()
16 import org.gradle.api.tasks.OutputDirectory in <lambda>()
17 import org.gradle.api.tasks.TaskAction in <lambda>()
|
| D | PackageBuilderTask.kt | 13 import org.gradle.api.tasks.Input
14 import org.gradle.api.tasks.InputDirectory
15 import org.gradle.api.tasks.Internal
16 import org.gradle.api.tasks.Nested
17 import org.gradle.api.tasks.OutputDirectory
18 import org.gradle.api.tasks.TaskAction
|
| D | PortTask.kt | 8 import org.gradle.api.tasks.Input
9 import org.gradle.api.tasks.InputDirectory
10 import org.gradle.api.tasks.Internal
11 import org.gradle.api.tasks.OutputDirectory
12 import org.gradle.api.tasks.TaskAction
|
| /tools/metalava/metalava/ |
| D | build.gradle.kts | 82 project.tasks.register(javaCompileTaskName, JavaCompile::class) { in registerTestPrebuiltsSdkTasks()
97 project.tasks.register(jarTaskName, Jar::class) { in registerTestPrebuiltsSdkTasks()
126 project.tasks.register("test-sdk-extensions-info.xml", Copy::class) { in <lambda>()
131 project.tasks.register("test-prebuilts-sdk") { in <lambda>()
140 tasks.named<Test>("test").configure { in <lambda>()
149 tasks.register("copyVersion", Copy::class.java) { in <lambda>()
|
| /tools/test/connectivity/acts_tests/tests/google/coex/performance_tests/ |
| D | WlanWithA2dpPerformanceTest.py | 67 tasks = [
73 return self.set_attenuation_and_run_iperf(tasks)
79 tasks = [(self.run_iperf_and_get_result, ()),
83 return self.set_attenuation_and_run_iperf(tasks)
89 tasks = [(music_play_and_check,
95 return self.set_attenuation_and_run_iperf(tasks)
|
| /tools/apksig/src/main/java/com/android/apksig/util/ |
| D | RunnablesExecutor.java | 41 Phaser tasks = new Phaser(1);
47 tasks.arriveAndDeregister();
49 tasks.register();
54 tasks.arriveAndAwaitAdvance();
|
| /tools/ndkports/curl/ |
| D | build.gradle.kts | 26 tasks.prefab { in <lambda>()
30 tasks.register<AutoconfPortTask>("buildPort") { in <lambda>()
42 tasks.prefabPackage { in <lambda>()
111 tasks { in <lambda>()
|
| /tools/ndkports/openssl/ |
| D | build.gradle.kts | 22 val buildTask = tasks.register<AdHocPortTask>("buildPort") { in <lambda>()
55 tasks.prefabPackage { in <lambda>()
66 tasks.register<AndroidExecutableTestTask>("test") { in <lambda>()
67 val srcDir = tasks.extractSrc.get().outDir.asFile.get() in <lambda>()
177 tasks { in <lambda>()
|