Home
last modified time | relevance | path

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

123

/tools/tradefederation/core/src/com/android/tradefed/util/
DAlarm.java30 public class Alarm extends Thread {
31 private final List<Thread> mInterruptThreads = new ArrayList<Thread>();
54 public void addThread(Thread intThread) { in addThread()
69 Thread.sleep(mTimeoutTime); in run()
82 for (Thread thread : mInterruptThreads) { in run()
DRunUtil.java449 Thread.sleep(time); in sleep()
479 public void setInterruptibleInFuture(Thread thread, final long timeMs) { in setInterruptibleInFuture()
498 public synchronized void interrupt(Thread thread, String message) { in interrupt()
506 final long threadId = Thread.currentThread().getId(); in checkInterrupted()
516 Thread.currentThread().interrupt(); in checkInterrupted()
525 private static class RunnableNotifier extends Thread {
575 private Thread mExecutionThread;
628 Thread stdoutThread = null; in run()
629 Thread stderrThread = null; in run()
636 mExecutionThread = Thread.currentThread(); in run()
[all …]
DBulkEmailer.java58 new Thread(new Runnable() { in sendEmailsBg()
83 Thread.sleep(2000); in sendEmails()
89 Thread.sleep(mInterval); in sendEmails()
DLogcatUpdaterEventParser.java244 final Thread callingThread = Thread.currentThread(); in waitForEventAsync()
246 Thread waitThread = in waitForEventAsync()
247 new Thread( in waitForEventAsync()
DIRunUtil.java277 public void setInterruptibleInFuture(Thread thread, long timeMs); in setInterruptibleInFuture()
286 public void interrupt(Thread thread, String message); in interrupt()
/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()
DRunUtilFuncTest.java55 Thread.sleep(SHORT_TIMEOUT_MS * 5); in testRunTimed_timeout()
199 Thread.sleep(5000); in testRunTimedCmd_timeout()
200 Thread[] list = new Thread[Thread.currentThread().getThreadGroup().activeCount()]; in testRunTimedCmd_timeout()
201 Thread.currentThread().getThreadGroup().enumerate(list); in testRunTimedCmd_timeout()
203 for (Thread t : list) { in testRunTimedCmd_timeout()
DRunUtilTest.java242 mRunUtil.interrupt(Thread.currentThread(), message); in testInterrupt()
258 mRunUtil.interrupt(Thread.currentThread(), message); in testInterrupt_delayed()
277 mRunUtil.interrupt(Thread.currentThread(), message1); in testInterrupt_multiple()
278 mRunUtil.interrupt(Thread.currentThread(), message2); in testInterrupt_multiple()
279 mRunUtil.interrupt(Thread.currentThread(), message3); in testInterrupt_multiple()
389 final Thread test = in testSetInterruptibleInFuture()
390 new Thread( in testSetInterruptibleInFuture()
396 mRunUtil.setInterruptibleInFuture(Thread.currentThread(), 10); in testSetInterruptibleInFuture()
424 mRunUtil.setInterruptibleInFuture(Thread.currentThread(), LONG_TIMEOUT_MS); in testSetInterruptibleInFuture_beforeTimeout()
/tools/tradefederation/core/tests/src/com/android/tradefed/build/
DFileDownloadCacheFuncTest.java80 Thread.sleep(500); in testFetchRemoteFile_concurrent()
91 Thread downloadThread1 = createDownloadThread(mMockDownloader, REMOTE_PATH); in testFetchRemoteFile_concurrent()
93 Thread downloadThread2 = createDownloadThread(mMockDownloader, REMOTE_PATH); in testFetchRemoteFile_concurrent()
153 Thread downloadThread1 = createDownloadThread(mockDownloader1, remotePath1); in testFetchRemoteFile_multiConcurrent()
155 Thread downloadThread2 = createDownloadThread(mockDownloader2, remotePath2); in testFetchRemoteFile_multiConcurrent()
157 Thread downloadThread3 = createDownloadThread(mockDownloader3, remotePath3); in testFetchRemoteFile_multiConcurrent()
204 Thread.sleep(10); in testFetchRemoteFile_concurrentFail()
223 Thread downloadThread1 = createDownloadThread(mMockDownloader, REMOTE_PATH); in testFetchRemoteFile_concurrentFail()
225 Thread downloadThread2 = createDownloadThread(mMockDownloader, REMOTE_PATH); in testFetchRemoteFile_concurrentFail()
227 Thread downloadThread3 = createDownloadThread(mMockDownloader, REMOTE_PATH); in testFetchRemoteFile_concurrentFail()
[all …]
/tools/tradefederation/core/tests/src/com/android/tradefed/testtype/
DDeviceBatteryLevelCheckerTest.java113 Thread raise = new Thread(new Runnable() { in testLow_becomeHigh()
117 Thread.sleep(100); in testLow_becomeHigh()
140 Thread raise = new Thread(new Runnable() { in testLow_becomeNull()
144 Thread.sleep(10); in testLow_becomeNull()
DInstrumentationTestFuncTest.java213 Thread rebootThread = in testRun_deviceReboot()
214 new Thread() { in testRun_deviceReboot()
220 Thread.sleep(2000); in testRun_deviceReboot()
285 Thread resetThread = in testRun_deviceRuntimeReset()
286 new Thread() { in testRun_deviceRuntimeReset()
291 Thread.sleep(1000); in testRun_deviceRuntimeReset()
297 Thread.sleep(500); in testRun_deviceRuntimeReset()
DGTestFuncTest.java147 Thread rebootThread = new Thread() { in testRun_deviceReboot()
152 Thread.sleep(500); in testRun_deviceReboot()
/tools/tradefederation/core/tests/src/com/android/tradefed/log/
DLogRegistryTest.java128 Thread secondThread = new Thread(new SecondThread()); // no explicit ThreadGroup in testThreadedLogging()
152 Thread firstThread = new Thread(tg, new FirstThread()); in testThreadedLogging()
/tools/tradefederation/core/tests/src/com/android/tradefed/device/
DDeviceStateMonitorTest.java70 Thread test = in testWaitForDeviceOnline()
71 new Thread() { in testWaitForDeviceOnline()
132 Thread test = in testWaitForDeviceOffline()
133 new Thread() { in testWaitForDeviceOffline()
210 Thread test = in testWaitForShell_becomeAvailable()
211 new Thread() { in testWaitForShell_becomeAvailable()
291 Thread test = in testWaitForBoot_becomeComplete()
292 new Thread() { in testWaitForBoot_becomeComplete()
384 Thread test = in testWaitForPm_becomeResponsive()
385 new Thread() { in testWaitForPm_becomeResponsive()
[all …]
DBackgroundDeviceActionTest.java127 Thread test = new Thread(new Runnable() { in testwaitForDeviceRecovery_online()
152 Thread test = new Thread(new Runnable() { in testwaitForDeviceRecovery_blockOffline()
DDeviceUtilStatsMonitorLoadTest.java80 Thread.sleep(5 * 60 * 1000); in testManyRecords()
/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/testtype/suite/
DTestFailureListener.java64 private List<Thread> mLogcatThreads = new ArrayList<>();
178 Thread captureThread = in captureFailure()
179 new Thread(captureLogcat, String.format("Capture failure logcat %s", test)); in captureFailure()
209 for (Thread t : mLogcatThreads) { in join()
/tools/tradefederation/core/tests/test-apps/TradeFedTestApp/src/com/android/tradefed/testapp/
DHangOnInitTest.java30 Thread.sleep(5*1000); in HangOnInitTest()
/tools/test/connectivity/acts/tests/google/wifi/aware/stress/
DInfraAssociationStressTest.py93 init_thread = threading.Thread(
95 resp_thread = threading.Thread(
/tools/tradefederation/core/prod-tests/src/com/android/ota/tests/
DSideloadOtaStabilityTest.java452 Thread.sleep(SHORT_WAIT_UNCRYPT); in doUncrypt()
455 Thread.currentThread().interrupt(); in doUncrypt()
512 Thread.sleep(1000); in waitForUncrypt()
514 Thread.currentThread().interrupt(); in waitForUncrypt()
576 Thread.sleep(1000); in connectSocket()
581 Thread.currentThread().interrupt(); in connectSocket()
/tools/tradefederation/core/tests/src/com/android/tradefed/command/
DCommandSchedulerFuncTest.java364 Thread test = new Thread(new Runnable() { in testShutdown_interruptible()
440 Thread shutdownThread = new Thread(new Runnable() { in testShutdown_notInterruptible()
555 Thread shutdownThread = new Thread(new Runnable() { in testShutdown_notInterruptible_timeout()
/tools/test/connectivity/acts/tests/google/ble/beacon_tests/
DBeaconSwarmTest.py123 thread = threading.Thread(target=self._start_advertisements_thread,
152 thread = threading.Thread(
327 thread = threading.Thread(
/tools/tradefederation/core/tests/src/com/android/tradefed/util/sl4a/
DFakeSocketServerHelper.java30 public class FakeSocketServerHelper extends Thread {
/tools/tradefederation/core/src/com/android/tradefed/util/hostmetric/
DAbstractHostMonitor.java34 public abstract class AbstractHostMonitor extends Thread implements IHostMonitor {

123