Home
last modified time | relevance | path

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

12345

/tools/tradefederation/core/common_util/com/android/tradefed/command/
DCommandInterrupter.java43 private ConcurrentMap<Thread, Boolean> mInterruptible = new MapMaker().weakKeys().makeMap();
45 private ConcurrentMap<Thread, MessageAndErrorId> mInterruptMessage =
65 mInterruptible.put(Thread.currentThread(), true); in allowInterrupt()
72 mInterruptible.put(Thread.currentThread(), false); in blockInterrupt()
78 return isInterruptible(Thread.currentThread()); in isInterruptible()
82 public boolean isInterruptible(@Nonnull Thread thread) { in isInterruptible()
95 @Nonnull Thread thread, long delay, @Nonnull TimeUnit unit) { in allowInterruptAsync()
119 @Nonnull Thread thread, @Nonnull String message, ErrorIdentifier errorId) { in interrupt()
134 Thread thread = Thread.currentThread(); in checkInterrupted()
/tools/tradefederation/core/javatests/com/android/tradefed/util/
DConditionPriorityBlockingQueueTest.java105 Thread delayedAdd = new Thread() { in testTake_delayedAdd()
130 Thread delayedAdd = new Thread() { in testTake_matcher_delayedAdd()
155 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()
296 Thread iterator = new Thread() { in testModificationOnIterating()
301 Thread.sleep(10); in testModificationOnIterating()
312 Thread.sleep(10); in testModificationOnIterating()
DRunUtilFuncTest.java59 Thread.sleep(SHORT_TIMEOUT_MS * 5); in testRunTimed_timeout()
208 Thread.sleep(5000); in testRunTimedCmd_timeout()
209 Thread[] list = new Thread[Thread.currentThread().getThreadGroup().activeCount()]; in testRunTimedCmd_timeout()
210 Thread.currentThread().getThreadGroup().enumerate(list); in testRunTimedCmd_timeout()
212 for (Thread t : list) { in testRunTimedCmd_timeout()
/tools/tradefederation/core/javatests/com/android/tradefed/command/
DCommandInterrupterTest.java73 Thread.currentThread(), in testInterrupt()
76 assertTrue(Thread.interrupted()); in testInterrupt()
95 Thread.currentThread(), in testInterrupt_blocked()
98 assertFalse(Thread.interrupted()); in testInterrupt_blocked()
120 Thread.currentThread(), in testInterrupt_clearsFlag()
123 assertTrue(Thread.interrupted()); in testInterrupt_clearsFlag()
146 Thread.currentThread(), 200L, TimeUnit.MILLISECONDS); in testAllowInterruptAsync()
173 Thread.currentThread(), 200L, TimeUnit.MILLISECONDS); in testAllowInterruptsAsync_alreadyAllowed()
183 Thread thread = new Thread(runnable, "CommandInterrupterTest"); in execute()
/tools/tradefederation/core/invocation_interfaces/com/android/tradefed/invoker/logger/
DCurrentInvocation.java104 ThreadGroup group = Thread.currentThread().getThreadGroup(); in addInvocationInfo()
115 ThreadGroup group = Thread.currentThread().getThreadGroup(); in getInfo()
138 ThreadGroup group = Thread.currentThread().getThreadGroup(); in clearInvocationInfos()
151 ThreadGroup group = Thread.currentThread().getThreadGroup(); in registerExecutionFiles()
168 ThreadGroup group = Thread.currentThread().getThreadGroup(); in getInvocationFiles()
179 ThreadGroup group = Thread.currentThread().getThreadGroup(); in setActionInProgress()
190 ThreadGroup group = Thread.currentThread().getThreadGroup(); in getActionInProgress()
201 ThreadGroup group = Thread.currentThread().getThreadGroup(); in setInvocationContext()
212 ThreadGroup group = Thread.currentThread().getThreadGroup(); in getInvocationContext()
223 ThreadGroup group = Thread.currentThread().getThreadGroup(); in moduleCurrentIsolation()
[all …]
/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/javatests/com/android/tradefed/build/
DFileDownloadCacheFuncTest.java89 Thread.sleep(500); in testFetchRemoteFile_concurrent()
101 Thread downloadThread1 = createDownloadThread(mMockDownloader, REMOTE_PATH); in testFetchRemoteFile_concurrent()
103 Thread downloadThread2 = createDownloadThread(mMockDownloader, REMOTE_PATH); in testFetchRemoteFile_concurrent()
167 Thread downloadThread1 = createDownloadThread(mockDownloader1, remotePath1); in testFetchRemoteFile_multiConcurrent()
169 Thread downloadThread2 = createDownloadThread(mockDownloader2, remotePath2); in testFetchRemoteFile_multiConcurrent()
171 Thread downloadThread3 = createDownloadThread(mockDownloader3, remotePath3); in testFetchRemoteFile_multiConcurrent()
216 Thread.sleep(10); in testFetchRemoteFile_concurrentFail()
233 Thread downloadThread1 = createDownloadThread(mMockDownloader, REMOTE_PATH); in testFetchRemoteFile_concurrentFail()
235 Thread downloadThread2 = createDownloadThread(mMockDownloader, REMOTE_PATH); in testFetchRemoteFile_concurrentFail()
237 Thread downloadThread3 = createDownloadThread(mMockDownloader, REMOTE_PATH); in testFetchRemoteFile_concurrentFail()
[all …]
/tools/tradefederation/core/common_util/com/android/tradefed/invoker/tracing/
DCloseableTraceScope.java59 this(DEFAULT_CATEGORY, Thread.currentThread().getName()); in CloseableTraceScope()
70 int threadId = (int) Thread.currentThread().getId(); in CloseableTraceScope()
71 String threadName = Thread.currentThread().getName(); in CloseableTraceScope()
81 int threadId = (int) Thread.currentThread().getId(); in close()
82 String threadName = Thread.currentThread().getName(); in close()
88 && Thread.currentThread().getId() == this.trace.reportingThreadId()) { in close()
DTracingLogger.java43 ThreadGroup group = Thread.currentThread().getThreadGroup(); in createActiveTrace()
82 ThreadGroup group = Thread.currentThread().getThreadGroup(); in setActiveTrace()
90 ThreadGroup group = Thread.currentThread().getThreadGroup(); in getActiveTrace()
110 ThreadGroup group = Thread.currentThread().getThreadGroup(); in finalizeTrace()
/tools/tradefederation/core/javatests/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/contrib/src/com/android/monkey/
DClockworkRetailMonkeyTest.java25 private Thread mRefreshThread;
34 private class CardRefresher extends Thread {
61 mRefreshThread = new Thread(mRefresher); in onMonkeyStart()
/tools/tradefederation/core/src/com/android/tradefed/util/executor/
DParallelDeviceExecutor.java59 ThreadGroup currentGroup = Thread.currentThread().getThreadGroup(); in invokeAll()
63 public Thread newThread(Runnable r) { in invokeAll()
64 Thread t = in invokeAll()
65 new Thread( in invokeAll()
/tools/tradefederation/core/javatests/com/android/tradefed/log/
DLogRegistryTest.java135 Thread secondThread = new Thread(new SecondThread()); // no explicit ThreadGroup in testThreadedLogging()
154 Thread firstThread = new Thread(tg, new FirstThread()); in testThreadedLogging()
/tools/tradefederation/core/src/com/android/tradefed/invoker/logger/
DTfObjectTracker.java69 ThreadGroup group = Thread.currentThread().getThreadGroup(); in directCount()
89 ThreadGroup group = Thread.currentThread().getThreadGroup(); in count()
121 ThreadGroup group = Thread.currentThread().getThreadGroup(); in getUsage()
130 ThreadGroup group = Thread.currentThread().getThreadGroup(); in clearTracking()
/tools/tradefederation/core/javatests/com/android/tradefed/device/
DBackgroundDeviceActionTest.java137 Thread test = in testwaitForDeviceRecovery_online()
138 new Thread( in testwaitForDeviceRecovery_online()
165 Thread test = in testwaitForDeviceRecovery_blockOffline()
166 new Thread( in testwaitForDeviceRecovery_blockOffline()
DDeviceStateMonitorTest.java246 Thread test = in testWaitForShell_becomeAvailable()
247 new Thread() { in testWaitForShell_becomeAvailable()
378 Thread test = in testWaitForBoot_becomeComplete()
379 new Thread() { in testWaitForBoot_becomeComplete()
476 Thread test = in testWaitForPm_becomeResponsive()
477 new Thread() { in testWaitForPm_becomeResponsive()
689 Thread test = in testWaitForStoreMount_becomeAvailable()
690 new Thread() { in testWaitForStoreMount_becomeAvailable()
743 Thread test = in testWaitForStoreMount_outputBecomeValid()
744 new Thread() { in testWaitForStoreMount_outputBecomeValid()
/tools/tradefederation/core/src/com/android/tradefed/util/
DBulkEmailer.java58 new Thread(new Runnable() { in sendEmailsBg()
83 Thread.sleep(2000); in sendEmails()
89 Thread.sleep(mInterval); in sendEmails()
/tools/tradefederation/core/javatests/com/android/tradefed/suite/checker/
DLeakedThreadStatusCheckerTest.java94 private class TestInThread extends Thread {
113 private class LeakedTestThread extends Thread {
125 Thread.sleep(50); in run()
/tools/tradefederation/core/src/com/android/tradefed/sandbox/
DTradefedSandboxRunner.java189 private class DebugThread extends Thread {
216 Map<Thread, StackTraceElement[]> threadMap = Thread.getAllStackTraces(); in dumpStacks()
217 for (Map.Entry<Thread, StackTraceElement[]> threadEntry : threadMap.entrySet()) { in dumpStacks()
222 private void dumpThreadStack(Thread thread, StackTraceElement[] trace, PrintStream ps) { in dumpThreadStack()
/tools/tradefederation/core/javatests/com/android/tradefed/testtype/
DDeviceBatteryLevelCheckerTest.java219 Thread raise = in testLow_becomeHigh()
220 new Thread( in testLow_becomeHigh()
225 Thread.sleep(100); in testLow_becomeHigh()
252 Thread raise = in testLow_becomeNull()
253 new Thread( in testLow_becomeNull()
258 Thread.sleep(50); in testLow_becomeNull()
/tools/tradefederation/core/src/com/android/tradefed/config/remote/
DGcsRemoteFileResolver.java142 ThreadGroup currentGroup = Thread.currentThread().getThreadGroup(); in fetchResourceWithRetryParallel()
146 public Thread newThread(Runnable r) { in fetchResourceWithRetryParallel()
147 Thread t = in fetchResourceWithRetryParallel()
148 new Thread( in fetchResourceWithRetryParallel()
/tools/tradefederation/core/src/com/android/tradefed/monitoring/
DLabResourceDeviceMonitor.java152 public Thread newThread(Runnable r) { in run()
153 Thread t = in run()
182 public Thread newThread(Runnable r) { in startExecutors()
183 Thread t = Executors.defaultThreadFactory().newThread(r); in startExecutors()
193 public Thread newThread(Runnable r) { in startExecutors()
194 Thread t = Executors.defaultThreadFactory().newThread(r); in startExecutors()
/tools/test/connectivity/acts/framework/acts/libs/proc/
Dprocess.py24 from threading import Thread
124 self._listening_thread = Thread(target=self._exec_loop)
257 self._redirection_thread = Thread(target=self._redirect_output)
/tools/tradefederation/core/common_util/com/android/tradefed/util/
DIRunUtil.java495 public void setInterruptibleInFuture(Thread thread, long timeMs); in setInterruptibleInFuture()
504 public void interrupt(Thread thread, String message); in interrupt()
514 public void interrupt(Thread thread, String message, ErrorIdentifier errorId); in interrupt()
/tools/test/graphicsbenchmark/functional_tests/java/src/com/android/game/qualification/tests/
DChoreoTestActivity.java43 private Thread mThread;
52 mThread = new Thread(ChoreoTestView.this); in ChoreoTestView()

12345