| /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 …]
|
| /tools/tradefederation/core/javatests/com/android/tradefed/suite/checker/ |
| D | LeakedThreadStatusCheckerTest.java | 48 TestInThread thread = new TestInThread(); in testNoLeakedThread() local
49 thread.start(); in testNoLeakedThread()
50 thread.join(); in testNoLeakedThread()
51 StatusCheckerResult result = thread.mResult; in testNoLeakedThread()
61 TestInThread thread = new TestInThread(); in testLeakedThread() local
62 thread.start(); in testLeakedThread()
63 thread.join(); in testLeakedThread()
66 StatusCheckerResult result = thread.mResult; in testLeakedThread()
80 TestInThread thread = new TestInThread(); in testLeakedThread_background() local
81 thread.start(); in testLeakedThread_background()
[all …]
|
| /tools/tradefederation/core/common_util/com/android/tradefed/command/ |
| D | CommandInterrupter.java | 82 public boolean isInterruptible(@Nonnull Thread thread) { in isInterruptible() argument
83 return Boolean.TRUE.equals(mInterruptible.get(thread)); in isInterruptible()
95 @Nonnull Thread thread, long delay, @Nonnull TimeUnit unit) { in allowInterruptAsync()
96 if (isInterruptible(thread)) { in allowInterruptAsync()
105 mInterruptible.put(thread, true); in allowInterruptAsync()
119 @Nonnull Thread thread, @Nonnull String message, ErrorIdentifier errorId) { in interrupt()
123 mInterruptMessage.put(thread, new MessageAndErrorId(message, errorId)); in interrupt()
124 if (isInterruptible(thread)) { in interrupt()
125 thread.interrupt(); in interrupt()
134 Thread thread = Thread.currentThread(); in checkInterrupted() local
[all …]
|
| /tools/netsim/rust/daemon/src/http_server/ |
| D | thread_pool.rs | 17 thread,
70 if let Some(thread) = worker.thread.take() { in drop()
71 thread.join().unwrap(); in drop()
79 thread: Option<thread::JoinHandle<()>>, field
84 let thread = thread::Builder::new() in new() localVariable
100 Worker { id, thread: Some(thread) } in new()
|
| D | server.rs | 21 use std::thread;
29 let _ = thread::Builder::new().name("http_server".to_string()).spawn(move || { in run_http_server()
|
| /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/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/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/javatests/com/android/tradefed/command/ |
| D | CommandInterrupterTest.java | 183 Thread thread = new Thread(runnable, "CommandInterrupterTest"); in execute() local
184 thread.setDaemon(true); in execute()
185 thread.setUncaughtExceptionHandler((t, throwable) -> throwableRef.set(throwable)); in execute()
186 thread.start(); in execute()
187 thread.join(); in execute()
|
| /tools/test/connectivity/acts_tests/tests/google/wifi/aware/performance/ |
| D | ThroughputTest.py | 188 for thread in threads:
189 thread.start()
191 for thread in threads:
192 thread.join()
372 for thread in threads:
373 thread.start()
375 for thread in threads:
376 thread.join()
|
| /tools/netsim/rust/daemon/src/ |
| D | session.rs | 32 use std::thread::{Builder, JoinHandle};
245 std::thread::sleep(std::time::Duration::from_secs(1)); in test_start_and_shutdown()
272 std::thread::sleep(std::time::Duration::from_secs(1)); in test_start_and_stop()
289 std::thread::sleep(std::time::Duration::from_secs(1)); in test_start_and_device_add()
323 std::thread::sleep(std::time::Duration::from_secs(1)); in test_start_and_device_add_and_remove()
388 std::thread::sleep(std::time::Duration::from_secs(1)); in test_start_and_chip_add_and_remove()
399 std::thread::sleep(std::time::Duration::from_secs(1)); in test_start_and_chip_add_and_remove()
|
| D | events.rs | 165 use std::thread;
173 let handle = thread::spawn(move || match rx.recv() { in test_subscribe_and_publish()
200 let handle = thread::spawn(move || match rx.recv() { in test_publish_to_multiple_subscribers()
|
| /tools/asuite/adevice/src/ |
| D | progress.rs | 3 use std::thread;
24 thread::spawn(move || { in start()
38 thread::sleep(Duration::from_millis(100)); in 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/src/com/android/tradefed/command/ |
| D | CommandScheduler.java | 1299 for (InvocationThread thread : copy) { in checkInvocations()
1300 thread.checkDeviceBatteryLevel(); in checkInvocations()
1372 private void waitForThread(Thread thread) { in waitForThread() argument
1374 thread.join(); in waitForThread()
1377 waitForThread(thread); in waitForThread()
1388 for (Thread thread : threadListCopy) { in waitForAllInvocationThreads()
1389 waitForThread(thread); in waitForAllInvocationThreads()
1399 for (Thread thread : threadListCopy) { in waitForTerminatingInvocationThreads()
1400 waitForThread(thread); in waitForTerminatingInvocationThreads()
2123 for (InvocationThread thread : mInvocationThreadMap.values()) { in shutdown()
[all …]
|
| /tools/netsim/rust/daemon/src/transport/ |
| D | fd.rs | 42 use std::thread::JoinHandle;
43 use std::{fmt, thread};
113 thread::Builder::new() in fd_reader()
247 thread::Builder::new() in run_fd_transport()
283 thread::Builder::new() in connector_fd_reader()
373 thread::Builder::new() in connector_grpc_reader()
|
| D | socket.rs | 26 use std::thread;
54 thread::Builder::new() in run_socket_transport()
72 thread::Builder::new() in accept_incoming()
|
| /tools/netsim/rust/daemon/src/devices/ |
| D | devices_handler.rs | 824 std::thread::Builder::new().name("device_event_subscriber".to_string()).spawn(move || { in spawn_shutdown_publisher_with_timeout()
877 use std::{sync::Once, thread};
942 device_guid: format!("guid-fs-1-{:?}", thread::current().id()), in test_chip_1_bt()
943 device_name: format!("test-device-name-1-{:?}", thread::current().id()), in test_chip_1_bt()
953 device_guid: format!("guid-fs-1-{:?}", thread::current().id()), in test_chip_1_wifi()
954 device_name: format!("test-device-name-1-{:?}", thread::current().id()), in test_chip_1_wifi()
964 device_guid: format!("guid-fs-2-{:?}", thread::current().id()), in test_chip_2_bt()
965 device_name: format!("test-device-name-2-{:?}", thread::current().id()), in test_chip_2_bt()
1023 std::thread::sleep(std::time::Duration::from_secs(1)); in test_spawn_shutdown_publisher_chip_removed_which_is_not_last_chip()
1056 std::thread::sleep(std::time::Duration::from_secs(1)); in test_spawn_shutdown_publisher_last_chip_removed_with_duplicate_event()
[all …]
|
| /tools/tradefederation/core/common_util/com/android/tradefed/util/ |
| D | IRunUtil.java | 495 public void setInterruptibleInFuture(Thread thread, long timeMs); in setInterruptibleInFuture() argument
504 public void interrupt(Thread thread, String message); in interrupt() argument
514 public void interrupt(Thread thread, String message, ErrorIdentifier errorId); in interrupt() argument
|
| /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/netsim/rust/daemon/src/wireless/ |
| D | wifi.rs | 27 use std::thread;
50 thread::spawn(move || { in new()
81 thread::spawn(move || loop { in new()
|
| /tools/netsim/src/hci/ |
| D | async_manager.cc | 180 thread_ = std::thread([this]() { ThreadRoutine(); }); in tryStartThread()
269 std::thread thread_;
461 thread_ = std::thread([this]() { ThreadRoutine(); }); in tryStartThread()
517 std::thread thread_;
|
| /tools/netsim/rust/daemon/src/captures/ |
| D | capture.rs | 30 use std::thread;
181 thread::Builder::new().name("capture_packet_handler".to_string()).spawn(move || { in new()
271 thread::Builder::new().name("capture_event_subscriber".to_string()).spawn(move || loop { in spawn_capture_event_subscriber()
|