| /tools/test/connectivity/acts/framework/acts/libs/utils/ |
| D | multithread.py | 20 def task_wrapper(task): argument
30 func = task[0]
31 params = task[1]
35 def run_multithread_func_async(log, task): argument
47 future_object = executor.submit(task_wrapper, task)
77 [task[0].__name__ for task in tasks], results)
115 for task, result, expected_result in zip(tasks, results, expected_results):
117 logging.info("Result for task %s is %s, expecting %s", task[0],
|
| /tools/trebuchet/core/common/src/test/kotlin/trebuchet/importers/ftrace/ |
| D | FtraceLineTest.kt | 33 assertEquals("atrace", line.task) in <lambda>()
49 assertNull(line.task) in <lambda>()
66 assertEquals("atrace", line.task) in <lambda>()
82 assertEquals("Binder-Thread #", line.task) in <lambda>()
96 assertEquals("NearbyMessages", line.task) in <lambda>()
111 assertEquals("NearbyMessages", line.task) in <lambda>()
126 assertEquals("<9729>", line.task) in <lambda>()
|
| D | FtraceEventTest.kt | 31 assertEquals("atrace", event.task) in testParseLineComplete()
45 assertNull(event.task) in testParseLineUnknownTgid()
57 assertEquals("atrace", event.task) in testParseLineNoTgid()
76 assertEquals("Binder-Thread #", event.task) in testParseLineLegacy()
|
| /tools/trebuchet/core/common/src/main/kotlin/trebuchet/importers/ftrace/ |
| D | FtraceImporterState.kt | 76 fun threadFor(pid: Int, tgid: Int = InvalidId, task: String? = null): ThreadModelFragment { in <lambda>()
78 val processName = if (tgid == pid) task else null in <lambda>()
80 thread.hint(name = task, tgid = tgid, processName = processName) in <lambda>()
86 thread = process.threadFor(pid, task) in <lambda>()
92 fun threadFor(line: FtraceLine) = threadFor(line.pid, line.tgid, line.task) in <lambda>()
93 fun threadFor(event: FtraceEvent) = threadFor(event.pid, event.tgid, event.task) in <lambda>()
|
| D | FtraceLine.kt | 49 val task get() = _task constant in trebuchet.importers.ftrace.FtraceLine
|
| /tools/trebuchet/core/common/src/main/kotlin/trebuchet/importers/ftrace/events/ |
| D | FtraceEvent.kt | 26 class FtraceEvent(val task: String?, in <lambda>() constant in trebuchet.importers.ftrace.events.FtraceEvent
49 val task = string(1) in <lambda>() constant
52 task = if (task == "<...>") null else task, in <lambda>()
|
| D | TraceMarkerEvent.kt | 24 state.threadFor(event.pid, tgid, event.task).slicesBuilder.beginSlice { in <lambda>()
33 state.threadFor(event.pid, event.tgid, event.task).slicesBuilder.endSlice { in import()
41 state.threadFor(event.pid, tgid, event.task).process in import()
49 state.processFor(tgid, event.task).asyncSlicesBuilder in import()
56 state.processFor(tgid, event.task).asyncSlicesBuilder in import()
|
| D | SchedEvent.kt | 57 val prevThread = state.threadFor(prevPid, task = prevComm) in import()
58 val nextThread = state.threadFor(nextPid, task = nextComm) in import()
70 val thread = state.threadFor(pid, task = comm) in import()
|
| /tools/trebuchet/core/common/src/main/kotlin/trebuchet/util/ |
| D | BatchProcessor.kt | 47 fun submit(task: Runnable) { in <lambda>()
49 workArray.add(task) in <lambda>()
91 fun submit(task: Runnable) { in submit()
92 workQueue.submit(task) in submit()
|
| /tools/platform-compat/java/com/android/javac/ |
| D | Javac.java | 89 JavaCompiler.CompilationTask task = mJavac.getTask( in compileWithAnnotationProcessor() local
97 task.setProcessors(Lists.newArrayList(processor)); in compileWithAnnotationProcessor()
99 task.setProcessors(Collections.EMPTY_LIST); in compileWithAnnotationProcessor()
101 boolean result = task.call(); in compileWithAnnotationProcessor()
|
| /tools/trebuchet/trebuchet/startup-common/test/ |
| D | StartupCommonTests.kt | 25 import trebuchet.task.ImportTask
29 val task = ImportTask(PrintlnImportFeedback()) in parseString() constant
30 return task.import(object : BufferProducer { in parseString()
|
| /tools/trebuchet/core/common/src/main/kotlin/trebuchet/extras/ |
| D | ImportUtils.kt | 20 import trebuchet.task.ImportTask
36 val task = ImportTask(PrintlnImportFeedback()) in parseTrace() constant
37 val model = task.import(InputStreamAdapter(file, if (verbose) ::reportImportProgress else null)) in parseTrace()
|
| /tools/trebuchet/trebuchet/viewer/src/main/kotlin/traceviewer/ui/ |
| D | TraceViewerWindow.kt | 25 import trebuchet.task.ImportTask in <lambda>()
71 val task = ImportTask(PrintlnImportFeedback()) in <lambda>() constant
72 val model = task.import(object : BufferProducer { in <lambda>()
|
| /tools/apksig/ |
| D | build.gradle | 33 all().each { task ->
34 task.builtins {
|
| /tools/apksig/src/main/java/com/android/apksig/util/ |
| D | RunnablesExecutor.java | 44 Runnable task = () -> {
50 mExecutor.execute(task);
|
| /tools/metalava/buildSrc/src/main/kotlin/com/android/tools/metalava/ |
| D | LibraryBuildInfo.kt | 89 it.projectZipPath.set(archiveTaskProvider.flatMap { task -> task.archiveFileName }) in configureBuildInfoTask() method
|
| /tools/apksig/src/main/java/com/android/apksig/internal/util/ |
| D | VerityTreeBuilder.java | 250 Runnable task = () -> { in digestDataByChunks() local
260 mExecutor.execute(task); in digestDataByChunks()
|
| /tools/apkzlib/ |
| D | build.gradle | 19 task sourcesJar(type: Jar, dependsOn: classes) {
|
| /tools/trebuchet/core/common/src/test/kotlin/trebuchet/io/ |
| D | StringStreamTest.kt | 25 import trebuchet.task.ImportTask
|
| /tools/trebuchet/core/common/src/main/kotlin/trebuchet/task/ |
| D | ImportTask.kt | 17 package trebuchet.task
|
| /tools/asuite/atest-py2/ |
| D | atest.py | 87 for task in EXTRA_TASKS.values():
88 proc = Process(target=task)
|
| /tools/test/connectivity/acts/framework/acts/controllers/ |
| D | bluetooth_pts_device.py | 468 for task in prog:
469 task_name = task[0].decode("utf-8")
|
| /tools/test/connectivity/acts_tests/acts_contrib/test_utils/tel/ |
| D | tel_data_utils.py | 2844 task = active_file_download_task(log, ad, file_name, method=method)
2845 if not task:
2847 return task[0](*task[1])
|
| /tools/metalava/ |
| D | FORMAT.md | 50 reminders and other issues with the signature source (though the update-api task
|
| /tools/dexter/testdata/expected/ |
| D | medium.rewrite | 80380 .local v0, "task", android.os.AsyncTask
|