Home
last modified time | relevance | path

Searched refs:Thread (Results 1 – 25 of 114) sorted by relevance

12345

/tools/tradefederation/core/tests/src/com/android/tradefed/util/
DConditionPriorityBlockingQueueTest.java106 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()
DRunUtilTest.java73 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()
DRunUtilFuncTest.java56 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()
/tools/tradefederation/core/tests/src/com/android/tradefed/build/
DFileDownloadCacheFuncTest.java86 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/tests/src/com/android/tradefed/device/
DDeviceStateMonitorTest.java71 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 …]
DDeviceManagerTest.java1399 Thread waiter = new Thread() { in testFlashLimit()
1439 Thread waiter = new Thread() { in testFlashLimit_withHostOptions()
1478 Thread waiter = new Thread() { in testUnlimitedFlashLimit()
1492 Thread.State waiterState = waiter.getState(); in testUnlimitedFlashLimit()
1494 waiter.isAlive() || Thread.State.TERMINATED.equals(waiterState)); in testUnlimitedFlashLimit()
DBackgroundDeviceActionTest.java127 Thread test = new Thread(new Runnable() { in testwaitForDeviceRecovery_online()
152 Thread test = new Thread(new Runnable() { in testwaitForDeviceRecovery_blockOffline()
/tools/tradefederation/core/common_util/com/android/tradefed/command/
DCommandInterrupter.java42 private ConcurrentMap<Thread, Boolean> mInterruptible = new MapMaker().weakKeys().makeMap();
44 private ConcurrentMap<Thread, String> mInterruptMessage = new MapMaker().weakKeys().makeMap();
53 mInterruptible.put(Thread.currentThread(), true); in allowInterrupt()
60 mInterruptible.put(Thread.currentThread(), false); in blockInterrupt()
66 return isInterruptible(Thread.currentThread()); in isInterruptible()
70 public boolean isInterruptible(@Nonnull Thread thread) { in isInterruptible()
83 @Nonnull Thread thread, long delay, @Nonnull TimeUnit unit) { in allowInterruptAsync()
106 public void interrupt(@Nonnull Thread thread, @Nonnull String message) { in interrupt()
121 Thread thread = Thread.currentThread(); in checkInterrupted()
/tools/tradefederation/core/tests/src/com/android/tradefed/command/
DCommandInterrupterTest.java71 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()
DCommandSchedulerTest.java76 import java.lang.Thread.UncaughtExceptionHandler;
223 Thread.sleep(10); in testRun_empty()
432 UncaughtExceptionHandler defaultHandler = Thread.getDefaultUncaughtExceptionHandler(); in testRun_oneConfigLoop()
435 Thread.setDefaultUncaughtExceptionHandler(tracker); in testRun_oneConfigLoop()
456 Thread.setDefaultUncaughtExceptionHandler(defaultHandler); in testRun_oneConfigLoop()
468 public void uncaughtException(Thread t, Throwable e) { in uncaughtException()
705 Thread.sleep(10); in testShutdown()
708 Thread.sleep(50); in testShutdown()
DCommandSchedulerFuncTest.java370 Thread test = new Thread(new Runnable() { in testShutdown_interruptible()
446 Thread shutdownThread = new Thread(new Runnable() { in testShutdown_notInterruptible()
561 Thread shutdownThread = new Thread(new Runnable() { in testShutdown_notInterruptible_timeout()
/tools/tradefederation/core/common_util/com/android/tradefed/util/
DRunUtil.java506 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/tradefederation/core/invocation_interfaces/com/android/tradefed/invoker/logger/
DCurrentInvocation.java81 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()
186 ThreadGroup group = Thread.currentThread().getThreadGroup(); in getLocal()
/tools/tradefederation/core/src/com/android/tradefed/command/remote/
DRemoteManager.java61 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/src/com/android/tradefed/suite/checker/
DLeakedThreadStatusChecker.java43 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/testtype/
DInstrumentationTestFuncTest.java227 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()
DDeviceBatteryLevelCheckerTest.java208 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()
/tools/tradefederation/core/src/com/android/tradefed/sandbox/
DTradefedSandboxRunner.java171 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/cluster/
DClusterEventUploaderFuncTest.java59 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/core/tests/src/com/android/tradefed/log/
DLogRegistryTest.java128 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/invoker/logger/
DTfObjectTracker.java66 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/src/com/android/tradefed/device/
DDeviceManager.java471 Thread checkThread = new Thread(checkRunnable, threadName); in checkAndAddAvailableDevice()
1270 Thread checkThread = new Thread(connectedRunnable, threadName); in deviceConnected()
1335 private class FastbootMonitor extends Thread {
1398 private class DeviceRecoverer extends Thread {
/tools/tradefederation/core/src/com/android/tradefed/command/
DConsole.java79 public class Console extends Thread {
1069 Map<Thread, StackTraceElement[]> threadMap = Thread.getAllStackTraces(); in dumpStacks()
1070 for (Map.Entry<Thread, StackTraceElement[]> threadEntry : threadMap.entrySet()) { in dumpStacks()
1075 private void dumpThreadStack(Thread thread, StackTraceElement[] trace, PrintStream ps) { in dumpThreadStack()
DCommandScheduler.java124 public class CommandScheduler extends Thread implements ICommandScheduler, ICommandFileListener {
543 private class InvocationThread extends Thread {
669 Thread[] listThreads = new Thread[numThread]; in checkStrayThreads()
1138 private void waitForThread(Thread thread) { in waitForThread()
1154 for (Thread thread : threadListCopy) { in waitForAllInvocationThreads()
/tools/tradefederation/contrib/src/com/android/monkey/
DClockworkRetailMonkeyTest.java25 private Thread mRefreshThread;
34 private class CardRefresher extends Thread {
61 mRefreshThread = new Thread(mRefresher); in onMonkeyStart()

12345