| /tools/tradefederation/core/tests/src/com/android/tradefed/util/ |
| D | ConditionPriorityBlockingQueueTest.java | 106 Thread delayedAdd = new Thread() { in testTake_delayedAdd()
130 Thread delayedAdd = new Thread() { in testTake_matcher_delayedAdd()
154 Thread waiter = new Thread() { in testTake_multiple_matchers()
166 Thread waiter2 = new Thread() { in testTake_multiple_matchers()
178 Thread delayedAdd = new Thread() { in testTake_multiple_matchers()
190 Thread delayedAdd2 = new Thread() { in testTake_multiple_matchers()
290 Thread iterator = new Thread() { in testModificationOnIterating()
295 Thread.sleep(10); in testModificationOnIterating()
306 Thread.sleep(10); in testModificationOnIterating()
|
| D | RunUtilFuncTest.java | 56 Thread.sleep(SHORT_TIMEOUT_MS * 5); in testRunTimed_timeout()
200 Thread.sleep(5000); in testRunTimedCmd_timeout()
201 Thread[] list = new Thread[Thread.currentThread().getThreadGroup().activeCount()]; in testRunTimedCmd_timeout()
202 Thread.currentThread().getThreadGroup().enumerate(list); in testRunTimedCmd_timeout()
204 for (Thread t : list) { in testRunTimedCmd_timeout()
|
| D | RunUtilTest.java | 73 Thread.interrupted(); in tearDown()
284 mRunUtil.interrupt(Thread.currentThread(), message); in testInterrupt()
300 mRunUtil.interrupt(Thread.currentThread(), message); in testInterrupt_delayed()
318 mRunUtil.interrupt(Thread.currentThread(), message1); in testInterrupt_multiple()
319 mRunUtil.interrupt(Thread.currentThread(), message2); in testInterrupt_multiple()
320 mRunUtil.interrupt(Thread.currentThread(), message3); in testInterrupt_multiple()
435 Thread thread = new Thread(); in testSetInterruptibleInFuture()
|
| /tools/tradefederation/core/tests/src/com/android/tradefed/command/ |
| D | CommandInterrupterTest.java | 71 mInterrupter.interrupt(Thread.currentThread(), MESSAGE); in testInterrupt()
72 assertTrue(Thread.interrupted()); in testInterrupt()
90 mInterrupter.interrupt(Thread.currentThread(), MESSAGE); in testInterrupt_blocked()
91 assertFalse(Thread.interrupted()); in testInterrupt_blocked()
112 mInterrupter.interrupt(Thread.currentThread(), MESSAGE); in testInterrupt_clearsFlag()
113 assertTrue(Thread.interrupted()); in testInterrupt_clearsFlag()
136 Thread.currentThread(), 200L, TimeUnit.MILLISECONDS); in testAllowInterruptAsync()
163 Thread.currentThread(), 200L, TimeUnit.MILLISECONDS); in testAllowInterruptsAsync_alreadyAllowed()
173 Thread thread = new Thread(runnable, "CommandInterrupterTest"); in execute()
|
| /tools/tradefederation/core/src/com/android/tradefed/suite/checker/ |
| D | LeakedThreadStatusChecker.java | 43 int numThread = Thread.currentThread().getThreadGroup().activeCount(); in postExecutionCheck()
48 Thread[] listThreads = new Thread[numThread]; in postExecutionCheck()
49 Thread.currentThread().getThreadGroup().enumerate(listThreads); in postExecutionCheck()
51 List<Thread> arrayThread = new ArrayList<>(Arrays.asList(listThreads)); in postExecutionCheck()
55 for (Thread t : arrayThread) { in postExecutionCheck()
|
| /tools/tradefederation/core/tests/src/com/android/tradefed/build/ |
| D | FileDownloadCacheFuncTest.java | 86 Thread.sleep(500); in testFetchRemoteFile_concurrent()
100 Thread downloadThread1 = createDownloadThread(mMockDownloader, REMOTE_PATH); in testFetchRemoteFile_concurrent()
102 Thread downloadThread2 = createDownloadThread(mMockDownloader, REMOTE_PATH); in testFetchRemoteFile_concurrent()
163 Thread downloadThread1 = createDownloadThread(mockDownloader1, remotePath1); in testFetchRemoteFile_multiConcurrent()
165 Thread downloadThread2 = createDownloadThread(mockDownloader2, remotePath2); in testFetchRemoteFile_multiConcurrent()
167 Thread downloadThread3 = createDownloadThread(mockDownloader3, remotePath3); in testFetchRemoteFile_multiConcurrent()
214 Thread.sleep(10); in testFetchRemoteFile_concurrentFail()
236 Thread downloadThread1 = createDownloadThread(mMockDownloader, REMOTE_PATH); in testFetchRemoteFile_concurrentFail()
238 Thread downloadThread2 = createDownloadThread(mMockDownloader, REMOTE_PATH); in testFetchRemoteFile_concurrentFail()
240 Thread downloadThread3 = createDownloadThread(mMockDownloader, REMOTE_PATH); in testFetchRemoteFile_concurrentFail()
[all …]
|
| /tools/tradefederation/core/invocation_interfaces/com/android/tradefed/invoker/logger/ |
| D | CurrentInvocation.java | 81 ThreadGroup group = Thread.currentThread().getThreadGroup(); in addInvocationInfo()
92 ThreadGroup group = Thread.currentThread().getThreadGroup(); in getInfo()
103 ThreadGroup group = Thread.currentThread().getThreadGroup(); in clearInvocationInfos()
116 ThreadGroup group = Thread.currentThread().getThreadGroup(); in registerExecutionFiles()
133 ThreadGroup group = Thread.currentThread().getThreadGroup(); in getInvocationFiles()
144 ThreadGroup group = Thread.currentThread().getThreadGroup(); in setActionInProgress()
155 ThreadGroup group = Thread.currentThread().getThreadGroup(); in getActionInProgress()
185 ThreadGroup group = Thread.currentThread().getThreadGroup(); in getLocal()
|
| D | InvocationMetricLogger.java | 128 ThreadGroup group = Thread.currentThread().getThreadGroup(); in addInvocationMetrics()
139 ThreadGroup group = Thread.currentThread().getThreadGroup(); in getInvocationMetrics()
150 ThreadGroup group = Thread.currentThread().getThreadGroup(); in clearInvocationMetrics()
|
| /tools/tradefederation/core/tests/src/com/android/tradefed/cluster/ |
| D | ClusterEventUploaderFuncTest.java | 59 Thread thread1 = in testPostCommandEvent_multipleThread()
60 new Thread( in testPostCommandEvent_multipleThread()
69 Thread thread2 = in testPostCommandEvent_multipleThread()
70 new Thread( in testPostCommandEvent_multipleThread()
|
| /tools/tradefederation/contrib/src/com/android/monkey/ |
| D | ClockworkRetailMonkeyTest.java | 25 private Thread mRefreshThread;
34 private class CardRefresher extends Thread {
61 mRefreshThread = new Thread(mRefresher); in onMonkeyStart()
|
| /tools/tradefederation/core/src/com/android/tradefed/invoker/logger/ |
| D | TfObjectTracker.java | 66 ThreadGroup group = Thread.currentThread().getThreadGroup(); in directCount()
86 ThreadGroup group = Thread.currentThread().getThreadGroup(); in count()
118 ThreadGroup group = Thread.currentThread().getThreadGroup(); in getUsage()
127 ThreadGroup group = Thread.currentThread().getThreadGroup(); in clearTracking()
|
| /tools/tradefederation/core/tests/src/com/android/tradefed/log/ |
| D | LogRegistryTest.java | 128 Thread secondThread = new Thread(new SecondThread()); // no explicit ThreadGroup in testThreadedLogging()
150 Thread firstThread = new Thread(tg, new FirstThread()); in testThreadedLogging()
|
| /tools/tradefederation/core/src/com/android/tradefed/util/ |
| D | BulkEmailer.java | 58 new Thread(new Runnable() { in sendEmailsBg()
83 Thread.sleep(2000); in sendEmails()
89 Thread.sleep(mInterval); in sendEmails()
|
| /tools/tradefederation/core/tests/src/com/android/tradefed/suite/checker/ |
| D | LeakedThreadStatusCheckerTest.java | 92 private class TestInThread extends Thread {
111 private class LeakedTestThread extends Thread {
123 Thread.sleep(50); in run()
|
| /tools/tradefederation/core/src/com/android/tradefed/sandbox/ |
| D | TradefedSandboxRunner.java | 171 private class DebugThread extends Thread {
198 Map<Thread, StackTraceElement[]> threadMap = Thread.getAllStackTraces(); in dumpStacks()
199 for (Map.Entry<Thread, StackTraceElement[]> threadEntry : threadMap.entrySet()) { in dumpStacks()
204 private void dumpThreadStack(Thread thread, StackTraceElement[] trace, PrintStream ps) { in dumpThreadStack()
|
| /tools/tradefederation/core/tests/src/com/android/tradefed/device/ |
| D | BackgroundDeviceActionTest.java | 127 Thread test = new Thread(new Runnable() { in testwaitForDeviceRecovery_online()
152 Thread test = new Thread(new Runnable() { in testwaitForDeviceRecovery_blockOffline()
|
| D | DeviceStateMonitorTest.java | 71 Thread test = in testWaitForDeviceOnline()
72 new Thread() { in testWaitForDeviceOnline()
133 Thread test = in testWaitForDeviceOffline()
134 new Thread() { in testWaitForDeviceOffline()
211 Thread test = in testWaitForShell_becomeAvailable()
212 new Thread() { in testWaitForShell_becomeAvailable()
292 Thread test = in testWaitForBoot_becomeComplete()
293 new Thread() { in testWaitForBoot_becomeComplete()
385 Thread test = in testWaitForPm_becomeResponsive()
386 new Thread() { in testWaitForPm_becomeResponsive()
[all …]
|
| /tools/tradefederation/core/tests/src/com/android/tradefed/testtype/ |
| D | DeviceBatteryLevelCheckerTest.java | 208 Thread raise = new Thread(new Runnable() { in testLow_becomeHigh()
212 Thread.sleep(100); in testLow_becomeHigh()
247 Thread raise = in testLow_becomeNull()
248 new Thread( in testLow_becomeNull()
253 Thread.sleep(50); in testLow_becomeNull()
|
| D | InstrumentationTestFuncTest.java | 227 Thread rebootThread = in testRun_deviceReboot()
228 new Thread() { in testRun_deviceReboot()
234 Thread.sleep(2000); in testRun_deviceReboot()
301 Thread resetThread = in testRun_deviceRuntimeReset()
302 new Thread() { in testRun_deviceRuntimeReset()
307 Thread.sleep(1000); in testRun_deviceRuntimeReset()
313 Thread.sleep(500); in testRun_deviceRuntimeReset()
|
| D | GTestFuncTest.java | 150 Thread rebootThread = new Thread() { in testRun_deviceReboot()
155 Thread.sleep(500); in testRun_deviceReboot()
|
| /tools/tradefederation/core/src/com/android/tradefed/command/remote/ |
| D | RemoteManager.java | 61 public class RemoteManager extends Thread {
249 Thread postOp = null; in processClientOperations()
329 private Thread processStartHandover(StartHandoverOp c, JSONObject result) { in processStartHandover()
333 Thread t = new Thread("handover thread") { in processStartHandover()
349 private Thread processHandoverComplete(HandoverCompleteOp c, JSONObject result) { in processHandoverComplete()
351 Thread t = new Thread("handover thread") { in processHandoverComplete()
|
| /tools/tradefederation/core/common_util/com/android/tradefed/util/ |
| D | RunUtil.java | 506 Thread.sleep(time); in sleep()
532 public void setInterruptibleInFuture(Thread thread, final long timeMs) { in setInterruptibleInFuture()
538 public synchronized void interrupt(Thread thread, String message) { in interrupt()
546 private static class RunnableNotifier extends Thread {
607 private Thread mExecutionThread;
679 Thread stdoutThread = null; in run()
680 Thread stderrThread = null; in run()
687 mExecutionThread = Thread.currentThread(); in run()
809 private static Thread inheritIO(final InputStream src, final OutputStream dest, String name) { in inheritIO()
814 Thread t = in inheritIO()
[all …]
|
| /tools/test/graphicsbenchmark/functional_tests/java/src/com/android/game/qualification/tests/ |
| D | ChoreoTestActivity.java | 43 private Thread mThread;
52 mThread = new Thread(ChoreoTestView.this); in ChoreoTestView()
|
| /tools/test/connectivity/acts/framework/acts/controllers/fuchsia_lib/ |
| D | syslog_lib.py | 20 from threading import Thread
106 self._listening_thread = Thread(target=self._exec_loop)
213 self._redirection_thread = Thread(
|
| /tools/tradefederation/core/src/com/android/tradefed/util/executor/ |
| D | ParallelDeviceExecutor.java | 57 public Thread newThread(Runnable r) { in invokeAll()
58 Thread t = Executors.defaultThreadFactory().newThread(r); in invokeAll()
|