| /tools/trebuchet/core/common/src/main/kotlin/trebuchet/importers/ftrace/ |
| D | FtraceImporterState.kt | 47 val thread = proc.threadFor(tgid, name) in <lambda>() constant
51 pidMap.put(tgid, thread) in <lambda>()
52 return thread in <lambda>()
56 val thread = pidMap[tgid] ?: createProcess(tgid, name) in <lambda>() constant
57 thread.process.hint(tgid, name) in <lambda>()
58 return thread.process in <lambda>()
77 var thread = pidMap[pid] in <lambda>() variable
79 if (thread != null) { in <lambda>()
80 thread.hint(name = task, tgid = tgid, processName = processName) in <lambda>()
81 return thread in <lambda>()
[all …]
|
| D | ImportData.kt | 31 val thread get() = importer.threadFor(line) constant
|
| /tools/tradefederation/core/tests/src/com/android/tradefed/suite/checker/ |
| D | LeakedThreadStatusCheckerTest.java | 46 TestInThread thread = new TestInThread(); in testNoLeakedThread() local
47 thread.start(); in testNoLeakedThread()
48 thread.join(); in testNoLeakedThread()
49 StatusCheckerResult result = thread.mResult; in testNoLeakedThread()
59 TestInThread thread = new TestInThread(); in testLeakedThread() local
60 thread.start(); in testLeakedThread()
61 thread.join(); in testLeakedThread()
64 StatusCheckerResult result = thread.mResult; in testLeakedThread()
78 TestInThread thread = new TestInThread(); in testLeakedThread_background() local
79 thread.start(); in testLeakedThread_background()
[all …]
|
| /tools/trebuchet/core/model/src/main/kotlin/trebuchet/model/fragments/ |
| D | SchedulingProcessFragment.kt | 21 class SchedulingProcessFragment(val process: ProcessModelFragment, val thread: ThreadModelFragment,… constant in trebuchet.model.fragments.SchedulingProcessFragment
27 … fun switchProcess(process: ProcessModelFragment, thread: ThreadModelFragment, timestamp: Double) { in switchProcess()
33 if (thread.id != 0) { in switchProcess()
34 _slices.add(SchedulingProcessFragment(process, thread, timestamp)) in switchProcess()
48 if (thread.name != null) {
49 return thread.name!!
55 return thread.id
|
| D | ProcessModelFragment.kt | 49 var thread = _threads[pid] in <lambda>() variable
50 if (thread == null) { in <lambda>()
51 thread = ThreadModelFragment(pid, this, name) in <lambda>()
52 _threads.put(pid, thread) in <lambda>()
54 thread.hint(name = name) in <lambda>()
56 return thread in <lambda>()
|
| /tools/trebuchet/trebuchet/viewer/src/main/kotlin/traceviewer/ui/tracks/ |
| D | MultiLineTrack.kt | 27 class MultiLineTrack(thread: ThreadModel, renderState: RenderState) : JPanel() {
33 if (thread.schedSlices.isNotEmpty()) {
34 add(SchedTrack(thread.schedSlices, renderState))
36 val rows = RowCreater(thread.slices).rows
|
| /tools/tradefederation/core/tests/src/com/android/tradefed/command/ |
| D | CommandInterrupterTest.java | 173 Thread thread = new Thread(runnable, "CommandInterrupterTest"); in execute() local
174 thread.setDaemon(true); in execute()
175 thread.setUncaughtExceptionHandler((t, throwable) -> throwableRef.set(throwable)); in execute()
176 thread.start(); in execute()
177 thread.join(); in execute()
|
| /tools/trebuchet/core/common/src/test/kotlin/trebuchet/task/ |
| D | ImportTaskTest.kt | 47 val thread = process.threads.find { it.name == "surfaceflinger" }!! in <lambda>() constant
48 val slices = thread.selectAll { it.name == "handleMessageRefresh" } in <lambda>()
64 val thread = process.threads.find { it.name == "RenderThread" }!! in <lambda>() constant
65 assertEquals(6506, thread.id) in <lambda>()
|
| /tools/test/connectivity/acts/tests/google/ble/beacon_tests/ |
| D | BeaconSwarmTest.py | 120 thread = threading.Thread(target=self._start_advertisements_thread,
122 threads.append(thread)
123 thread.start()
149 thread = threading.Thread(
152 threads.append(thread)
153 thread.start()
324 thread = threading.Thread(
327 thread.start()
|
| /tools/trebuchet/core/common/src/main/kotlin/trebuchet/extractors/ |
| D | SystraceExtractor.kt | 39 val thread = Thread { in <lambda>() constant
49 thread.start() in <lambda>()
53 thread.join() in <lambda>()
|
| /tools/tradefederation/core/tests/res/testtype/ |
| D | rust_output2.txt | 29 thread 'idents' panicked at 'assertion failed: `(left == right)`
34 thread 'literal_string' panicked at 'assertion failed: `(left == right)`
|
| /tools/trebuchet/core/common/src/main/kotlin/trebuchet/importers/ftrace/events/ |
| D | SchedEvent.kt | 70 val thread = state.threadFor(pid, task = comm) in import() constant
71 thread.schedulingStateBuilder.switchState(SchedulingState.WAKING, event.timestamp) in import()
|
| /tools/tradefederation/core/common_util/com/android/tradefed/util/ |
| D | IRunUtil.java | 335 public void setInterruptibleInFuture(Thread thread, long timeMs); in setInterruptibleInFuture() argument
344 public void interrupt(Thread thread, String message); in interrupt() argument
|
| D | RunUtil.java | 532 public void setInterruptibleInFuture(Thread thread, final long timeMs) { in setInterruptibleInFuture() argument
533 mInterrupter.allowInterruptAsync(thread, timeMs, TimeUnit.MILLISECONDS); in setInterruptibleInFuture()
538 public synchronized void interrupt(Thread thread, String message) { in interrupt() argument
539 mInterrupter.interrupt(thread, message); in interrupt()
|
| /tools/trebuchet/core/common/src/main/kotlin/trebuchet/util/ |
| D | BatchProcessor.kt | 29 import kotlin.concurrent.thread in <lambda>()
107 thread { in par_map()
|
| /tools/tradefederation/core/src/com/android/tradefed/command/ |
| D | CommandScheduler.java | 1052 for (InvocationThread thread : copy) { in checkInvocations()
1053 thread.checkDeviceBatteryLevel(); in checkInvocations()
1131 private void waitForThread(Thread thread) { in waitForThread() argument
1133 thread.join(); in waitForThread()
1136 waitForThread(thread); in waitForThread()
1147 for (Thread thread : threadListCopy) { in waitForAllInvocationThreads()
1148 waitForThread(thread); in waitForAllInvocationThreads()
1808 for (InvocationThread thread : mInvocationThreadMap.values()) { in shutdownHard()
1809 thread.disableReporters(); in shutdownHard()
1811 thread.stopInvocation("Tradefed is shutting down"); in shutdownHard()
[all …]
|
| /tools/test/connectivity/acts/framework/acts/test_utils/bt/ |
| D | BluetoothBaseTest.py | 134 thread = threading.Thread(
136 threads.append(thread)
137 thread.start()
|
| D | bt_test_utils.py | 1479 thread = threading.Thread(target=factory_reset_bluetooth,
1481 threads.append(thread)
1482 thread.start()
|
| /tools/test/connectivity/acts/framework/acts/test_utils/coex/ |
| D | CoexBaseTest.py | 263 self.thread = threading.Thread(target=function)
264 self.thread_list.append(self.thread)
265 self.thread.start()
|
| /tools/tradefederation/core/src/com/android/tradefed/sandbox/ |
| D | TradefedSandboxRunner.java | 204 private void dumpThreadStack(Thread thread, StackTraceElement[] trace, PrintStream ps) { in dumpThreadStack() argument
205 printLine(String.format("%s", thread), ps); in dumpThreadStack()
|
| /tools/trebuchet/trebuchet/startup-common/src/ |
| D | StartupCommon.kt | 96 for (thread in this.threads) { in ProcessModel() method
97 if (queryName.endsWith(thread.name)) { in ProcessModel()
|
| /tools/tradefederation/core/tests/src/com/android/tradefed/util/ |
| D | RunUtilTest.java | 435 Thread thread = new Thread(); in testSetInterruptibleInFuture() local
436 runUtil.setInterruptibleInFuture(thread, 123L); in testSetInterruptibleInFuture()
440 .allowInterruptAsync(eq(thread), eq(123L), eq(TimeUnit.MILLISECONDS)); in testSetInterruptibleInFuture()
|
| /tools/security/fuzzing/example_fuzzer/ |
| D | README.md | 54 WRITE of size 4 at 0x007fe3caf8c3 thread T0
65 Address 0x007fe3caf8c3 is located in stack of thread T0 at offset 35 in frame
|
| /tools/tradefederation/core/src/com/android/tradefed/result/ |
| D | SubprocessResultsReporter.java | 254 SocketFinisher thread = new SocketFinisher(); in invocationEnded() local
255 Runtime.getRuntime().addShutdownHook(thread); in invocationEnded()
|
| /tools/tradefederation/core/src/com/android/tradefed/cluster/ |
| D | ClusterCommandScheduler.java | 106 Thread thread = new Thread(HB_GROUP, r); in newThread() local
108 thread.setDaemon(true); in newThread()
109 return thread; in newThread()
|