| /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 | 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/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
|
| /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/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/apksig/ |
| D | build.gradle | 31 all().each { task ->
32 task.builtins {
|
| /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/src/main/java/com/android/apksig/util/ |
| D | RunnablesExecutor.java | 44 Runnable task = () -> {
50 mExecutor.execute(task);
|
| /tools/trebuchet/core/common/src/test/kotlin/trebuchet/task/ |
| D | ImportTaskTest.kt | 17 package trebuchet.task in <lambda>()
79 val task = ImportTask(DummyImportFeedback) in <lambda>() constant
82 val model = task.import(readFile(file)) in <lambda>()
|
| /tools/tradefederation/core/src/com/android/tradefed/util/ |
| D | DeviceConcurrentUtil.java | 55 public static <T> T joinFuture(String taskDesc, Future<T> task, long timeout) in joinFuture() argument
58 T ret = task.get(timeout, TimeUnit.MILLISECONDS); in joinFuture()
|
| /tools/tradefederation/core/tests/src/com/android/tradefed/device/metric/ |
| D | DeviceMetricDataFuncTest.java | 72 Callable<HashMap<String, Metric>> task = in testAddToMetricsMultiThreaded() local
90 List<Callable<HashMap<String, Metric>>> tasks = Collections.nCopies(threadCount, task); in testAddToMetricsMultiThreaded()
|
| /tools/apkzlib/ |
| D | build.gradle | 19 task sourcesJar(type: Jar, dependsOn: classes) {
|
| /tools/trebuchet/core/common/src/main/kotlin/trebuchet/task/ |
| D | ImportTask.kt | 17 package trebuchet.task
|
| /tools/trebuchet/core/common/src/test/kotlin/trebuchet/io/ |
| D | StringStreamTest.kt | 25 import trebuchet.task.ImportTask
|
| /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/tradefederation/core/atest/ |
| 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/asuite/atest/ |
| D | atest.py | 89 for task in EXTRA_TASKS.values():
90 proc = Process(target=task)
|
| /tools/test/connectivity/acts/framework/acts/test_utils/tel/ |
| D | tel_test_utils.py | 3227 task = active_file_download_task(log, ad, file_name, method=method)
3228 if not task:
3230 return task[0](*task[1])
6593 def task_wrapper(task): argument
6603 func = task[0]
6604 params = task[1]
6608 def run_multithread_func_async(log, task): argument
6620 future_object = executor.submit(task_wrapper, task)
6650 [task[0].__name__ for task in tasks], results)
6688 for task, result, expected_result in zip(tasks, results, expected_results):
[all …]
|
| /tools/asuite/asuite_plugin/gradle/wrapper/ |
| D | gradle-wrapper.jar | ... .File exclusiveFile
java.util.concurrent.Callable task
java.io.File lockFile
java.io. ... |
| /tools/ndkports/gradle/wrapper/ |
| D | gradle-wrapper.jar | ... .File exclusiveFile
java.util.concurrent.Callable task
java.io.File lockFile
java.io. ... |