| /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 in trebuchet.importers.ftrace.ImportData
|
| /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/tradefederation/core/src/com/android/tradefed/command/ |
| D | CommandInterrupter.java | 70 public boolean isInterruptible(@Nonnull Thread thread) { in isInterruptible() argument
71 return Boolean.TRUE.equals(mInterruptible.get(thread)); in isInterruptible()
83 @Nonnull Thread thread, long delay, @Nonnull TimeUnit unit) { in allowInterruptAsync()
84 if (isInterruptible(thread)) { in allowInterruptAsync()
93 mInterruptible.put(thread, true); in allowInterruptAsync()
106 public void interrupt(@Nonnull Thread thread, @Nonnull String message) { in interrupt() argument
110 mInterruptMessage.put(thread, message); in interrupt()
111 if (isInterruptible(thread)) { in interrupt()
112 thread.interrupt(); in interrupt()
121 Thread thread = Thread.currentThread(); in checkInterrupted() local
[all …]
|
| D | CommandScheduler.java | 1027 for (InvocationThread thread : copy) { in checkInvocations()
1028 thread.checkDeviceBatteryLevel(); in checkInvocations()
1106 private void waitForThread(Thread thread) { in waitForThread() argument
1108 thread.join(); in waitForThread()
1111 waitForThread(thread); in waitForThread()
1122 for (Thread thread : threadListCopy) { in waitForAllInvocationThreads()
1123 waitForThread(thread); in waitForAllInvocationThreads()
1766 for (InvocationThread thread : mInvocationThreadMap.values()) { in shutdownHard()
1767 thread.disableReporters(); in shutdownHard()
1769 thread.stopInvocation("TF is shutting down"); in shutdownHard()
[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/core/common/src/test/kotlin/trebuchet/importers/ftrace/ |
| D | FtraceImporterTest.kt | 78 val thread = process.threads.first() in testImportBeginEnd() constant
79 assertEquals(6381, thread.id) in testImportBeginEnd()
80 assertEquals("equicksearchbox", thread.name) in testImportBeginEnd()
81 val sliceGroup = thread.slicesBuilder in testImportBeginEnd()
114 val thread = process.threads.first() in testImportBeginEndNoTgids() constant
115 assertEquals(6381, thread.id) in testImportBeginEndNoTgids()
116 assertEquals("equicksearchbox", thread.name) in testImportBeginEndNoTgids()
117 val sliceGroup = thread.slicesBuilder in testImportBeginEndNoTgids()
|
| /tools/test/connectivity/acts/tests/google/ble/beacon_tests/ |
| D | BeaconSwarmTest.py | 123 thread = threading.Thread(target=self._start_advertisements_thread,
125 threads.append(thread)
126 thread.start()
152 thread = threading.Thread(
155 threads.append(thread)
156 thread.start()
327 thread = threading.Thread(
330 thread.start()
|
| /tools/test/connectivity/acts/tests/google/wifi/aware/performance/ |
| D | ThroughputTest.py | 190 for thread in threads:
191 thread.start()
193 for thread in threads:
194 thread.join()
373 for thread in threads:
374 thread.start()
376 for thread in threads:
377 thread.join()
|
| /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/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/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/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/trebuchet/core/common/src/main/kotlin/trebuchet/queries/ |
| D | SliceQueries.kt | 135 this.threads.forEach { thread -> in ProcessModel() method
136 val threadSlice = thread.selectFirst(predicate) in ProcessModel()
415 process.threads.forEach { thread -> in slices() method
416 yieldSlices(thread.slices) in slices()
|
| /tools/tradefederation/core/src/com/android/tradefed/util/ |
| D | Alarm.java | 82 for (Thread thread : mInterruptThreads) { in run()
83 thread.interrupt(); in run()
|
| D | IRunUtil.java | 305 public void setInterruptibleInFuture(Thread thread, long timeMs); in setInterruptibleInFuture() argument
314 public void interrupt(Thread thread, String message); in interrupt() argument
|
| D | RunUtil.java | 503 public void setInterruptibleInFuture(Thread thread, final long timeMs) { in setInterruptibleInFuture() argument
504 mInterrupter.allowInterruptAsync(thread, timeMs, TimeUnit.MILLISECONDS); in setInterruptibleInFuture()
509 public synchronized void interrupt(Thread thread, String message) { in interrupt() argument
510 mInterrupter.interrupt(thread, message); in interrupt()
|
| /tools/test/connectivity/acts/framework/acts/test_utils/bt/ |
| D | BluetoothBaseTest.py | 137 thread = threading.Thread(
139 threads.append(thread)
140 thread.start()
|
| D | bt_test_utils.py | 1332 thread = threading.Thread(
1334 threads.append(thread)
1335 thread.start()
|
| /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/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/tests/src/com/android/tradefed/util/ |
| D | RunUtilTest.java | 432 Thread thread = new Thread(); in testSetInterruptibleInFuture() local
433 runUtil.setInterruptibleInFuture(thread, 123L); in testSetInterruptibleInFuture()
437 .allowInterruptAsync(eq(thread), eq(123L), eq(TimeUnit.MILLISECONDS)); in testSetInterruptibleInFuture()
|
| /tools/test/connectivity/acts/framework/acts/test_utils/coex/ |
| D | CoexBaseTest.py | 376 self.thread = threading.Thread(target=function)
377 self.thread_list.append(self.thread)
378 self.thread.start()
|
| /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()
|