| /external/webrtc/webrtc/base/ |
| D | thread.cc | 44 Thread* Thread::Current() { in Current()
78 Thread *ThreadManager::CurrentThread() { in CurrentThread()
79 return static_cast<Thread *>(pthread_getspecific(key_)); in CurrentThread()
82 void ThreadManager::SetCurrentThread(Thread *thread) { in SetCurrentThread()
100 Thread *ThreadManager::CurrentThread() { in CurrentThread()
101 return static_cast<Thread *>(TlsGetValue(key_)); in CurrentThread()
104 void ThreadManager::SetCurrentThread(Thread *thread) { in SetCurrentThread()
109 Thread *ThreadManager::WrapCurrentThread() { in WrapCurrentThread()
110 Thread* result = CurrentThread(); in WrapCurrentThread()
112 result = new Thread(); in WrapCurrentThread()
[all …]
|
| D | thread_unittest.cc | 52 Thread* post_thread, MessageHandler* phandler) in SocketClient()
77 Thread* post_thread_;
84 MessageClient(Thread* pth, Socket* socket) in MessageClient()
103 class CustomThread : public rtc::Thread {
110 return Thread::WrapCurrent(); in WrapCurrent()
113 Thread::UnwrapCurrent(); in UnwrapCurrent()
120 class SignalWhenDestroyedThread : public Thread {
184 Thread::Current()->ProcessMessages(50); in operator ()()
194 Thread th1; in TEST()
200 Thread th2; in TEST()
[all …]
|
| D | signalthread_unittest.cc | 25 EXPECT_EQ(harness_->main_thread_, Thread::Current()); in ~SlowSignalThread()
35 EXPECT_EQ(harness_->main_thread_, Thread::Current()); in OnWorkStart()
41 EXPECT_EQ(harness_->main_thread_, Thread::Current()); in OnWorkStop()
47 EXPECT_EQ(harness_->main_thread_, Thread::Current()); in OnWorkDone()
52 EXPECT_NE(harness_->main_thread_, Thread::Current()); in DoWork()
53 EXPECT_EQ(worker(), Thread::Current()); in DoWork()
54 Thread::Current()->socketserver()->Wait(250, false); in DoWork()
65 EXPECT_EQ(main_thread_, Thread::Current()); in OnWorkComplete()
74 main_thread_ = Thread::Current(); in SetUp()
88 Thread* main_thread_;
[all …]
|
| D | thread.h | 32 class Thread; variable
43 Thread* CurrentThread();
44 void SetCurrentThread(Thread* thread);
59 Thread *WrapCurrentThread();
76 Thread *thread;
84 virtual void Run(Thread* thread) = 0;
95 class Thread : public MessageQueue {
97 explicit Thread(SocketServer* ss = NULL);
102 ~Thread() override;
104 static Thread* Current();
[all …]
|
| /external/testng/src/test/java/test/ant/ |
| D | MultipleThreadTest.java | 17 public static Set<Thread> _threads;
21 _threads=Collections.synchronizedSet(new HashSet<Thread>()); in prepareHashSet()
26 _threads.add(Thread.currentThread()); in recordThread00()
31 _threads.add(Thread.currentThread()); in recordThread01()
36 _threads.add(Thread.currentThread()); in recordThread02()
41 _threads.add(Thread.currentThread()); in recordThread03()
46 _threads.add(Thread.currentThread()); in recordThread04()
51 _threads.add(Thread.currentThread()); in recordThread05()
56 _threads.add(Thread.currentThread()); in recordThread06()
61 _threads.add(Thread.currentThread()); in recordThread07()
[all …]
|
| /external/guava/guava-tests/test/com/google/common/collect/ |
| D | SynchronizedDequeTest.java | 45 assertTrue(Thread.holdsLock(mutex)); in offer()
51 assertTrue(Thread.holdsLock(mutex)); in poll()
57 assertTrue(Thread.holdsLock(mutex)); in remove()
63 assertTrue(Thread.holdsLock(mutex)); in peek()
69 assertTrue(Thread.holdsLock(mutex)); in element()
76 assertFalse(Thread.holdsLock(mutex)); in iterator()
82 assertTrue(Thread.holdsLock(mutex)); in size()
88 assertTrue(Thread.holdsLock(mutex)); in removeAll()
94 assertTrue(Thread.holdsLock(mutex)); in isEmpty()
100 assertTrue(Thread.holdsLock(mutex)); in contains()
[all …]
|
| D | SynchronizedQueueTest.java | 45 assertTrue(Thread.holdsLock(mutex)); in offer()
51 assertTrue(Thread.holdsLock(mutex)); in poll()
57 assertTrue(Thread.holdsLock(mutex)); in remove()
63 assertTrue(Thread.holdsLock(mutex)); in peek()
69 assertTrue(Thread.holdsLock(mutex)); in element()
76 assertFalse(Thread.holdsLock(mutex)); in iterator()
82 assertTrue(Thread.holdsLock(mutex)); in size()
88 assertTrue(Thread.holdsLock(mutex)); in removeAll()
94 assertTrue(Thread.holdsLock(mutex)); in isEmpty()
100 assertTrue(Thread.holdsLock(mutex)); in contains()
[all …]
|
| D | SynchronizedSetTest.java | 79 assertTrue(Thread.holdsLock(mutex));
84 assertTrue(Thread.holdsLock(mutex));
89 assertTrue(Thread.holdsLock(mutex));
94 assertTrue(Thread.holdsLock(mutex));
99 assertTrue(Thread.holdsLock(mutex));
104 assertTrue(Thread.holdsLock(mutex));
109 assertTrue(Thread.holdsLock(mutex));
114 assertTrue(Thread.holdsLock(mutex));
119 assertTrue(Thread.holdsLock(mutex));
126 assertTrue(Thread.holdsLock(mutex));
[all …]
|
| D | SynchronizedMultimapTest.java | 84 assertTrue(Thread.holdsLock(mutex)); in toString()
89 assertTrue(Thread.holdsLock(mutex)); in equals()
94 assertTrue(Thread.holdsLock(mutex)); in hashCode()
99 assertTrue(Thread.holdsLock(mutex)); in size()
104 assertTrue(Thread.holdsLock(mutex)); in isEmpty()
109 assertTrue(Thread.holdsLock(mutex)); in containsKey()
114 assertTrue(Thread.holdsLock(mutex)); in containsValue()
120 assertTrue(Thread.holdsLock(mutex)); in containsEntry()
125 assertTrue(Thread.holdsLock(mutex)); in get()
131 assertTrue(Thread.holdsLock(mutex)); in put()
[all …]
|
| D | SynchronizedNavigableMapTest.java | 69 assertTrue(Thread.holdsLock(mutex)); in equals()
74 assertTrue(Thread.holdsLock(mutex)); in getKey()
79 assertTrue(Thread.holdsLock(mutex)); in getValue()
84 assertTrue(Thread.holdsLock(mutex)); in hashCode()
89 assertTrue(Thread.holdsLock(mutex)); in setValue()
108 assertTrue(Thread.holdsLock(mutex)); in ceilingEntry()
113 assertTrue(Thread.holdsLock(mutex)); in ceilingKey()
118 assertTrue(Thread.holdsLock(mutex)); in descendingKeySet()
123 assertTrue(Thread.holdsLock(mutex)); in descendingMap()
128 assertTrue(Thread.holdsLock(mutex)); in firstEntry()
[all …]
|
| /external/libchrome/base/threading/ |
| D | thread.cc | 41 Thread::Options::Options() = default;
43 Thread::Options::Options(MessageLoop::Type type, size_t size) in Options()
46 Thread::Options::Options(const Options& other) = default;
48 Thread::Options::~Options() = default;
50 Thread::Thread(const std::string& name) in Thread() function in base::Thread
63 Thread::~Thread() { in ~Thread()
67 bool Thread::Start() { in Start()
78 bool Thread::StartWithOptions(const Options& options) { in StartWithOptions()
133 bool Thread::StartAndWaitForTesting() { in StartAndWaitForTesting()
142 bool Thread::WaitUntilThreadStarted() const { in WaitUntilThreadStarted()
[all …]
|
| D | thread_unittest.cc | 28 using base::Thread;
40 class SleepInsideInitThread : public Thread {
42 SleepInsideInitThread() : Thread("none") { in SleepInsideInitThread()
77 class CaptureToEventList : public Thread {
83 : Thread("none"), in CaptureToEventList()
129 void ReturnThreadId(base::Thread* thread, in ReturnThreadId()
139 Thread a("StartWithStackSize"); in TEST_F()
144 Thread::Options options; in TEST_F()
167 Thread* a = new Thread("StartNonJoinable"); in TEST_F()
172 Thread::Options options; in TEST_F()
[all …]
|
| /external/mockito/src/main/java/org/mockito/internal/util/concurrent/ |
| D | DetachedThreadLocal.java | 16 final WeakConcurrentMap<Thread, T> map;
22 map = new WeakConcurrentMap<Thread, T>(cleaner == Cleaner.THREAD) { in DetachedThreadLocal()
24 protected T defaultValue(Thread key) { in DetachedThreadLocal()
30 map = new WeakConcurrentMap.WithInlinedExpunction<Thread, T>() { in DetachedThreadLocal()
32 protected T defaultValue(Thread key) { in DetachedThreadLocal()
43 return map.get(Thread.currentThread()); in get()
47 map.put(Thread.currentThread(), value); in set()
51 map.remove(Thread.currentThread()); in clear()
65 public T pushTo(Thread thread) { in pushTo()
77 public T fetchFrom(Thread thread) { in fetchFrom()
[all …]
|
| /external/libxcam/xcore/ |
| D | xcam_thread.cpp | 27 Thread::Thread (const char *name) in Thread() function in XCam::Thread
37 Thread::~Thread () in ~Thread()
44 Thread::thread_func (void *user_data) in thread_func()
46 Thread *thread = (Thread *)user_data; in thread_func()
80 Thread::started () in started()
87 Thread::stopped () in stopped()
92 bool Thread::start () in start()
117 Thread::emit_stop () in emit_stop()
124 bool Thread::stop () in stop()
136 bool Thread::is_running () in is_running()
|
| /external/valgrind/helgrind/tests/ |
| D | tc20_verifywrap.stderr.exp | 10 Thread #x is the program's root thread
14 Thread #x was created
35 Thread #x's call to pthread_join failed
46 Thread #x's call to pthread_mutex_init failed
53 Thread #x: pthread_mutex_destroy of a locked mutex
60 Thread #x's call to pthread_mutex_destroy failed
68 Thread #x's call to pthread_mutex_lock failed
76 Thread #x's call to pthread_mutex_trylock failed
84 Thread #x's call to pthread_mutex_timedlock failed
92 Thread #x unlocked an invalid lock at 0x........
[all …]
|
| D | tc20_verifywrap.stderr.exp-glibc-2.18 | 8 ---Thread-Announcement------------------------------------------
10 Thread #x is the program's root thread
12 ---Thread-Announcement------------------------------------------
14 Thread #x was created
35 Thread #x's call to pthread_join failed
46 Thread #x's call to pthread_mutex_init failed
53 Thread #x: pthread_mutex_destroy of a locked mutex
60 Thread #x's call to pthread_mutex_lock failed
68 Thread #x's call to pthread_mutex_trylock failed
76 Thread #x's call to pthread_mutex_timedlock failed
[all …]
|
| D | tc20_verifywrap.stderr.exp-glibc-2.21 | 8 ---Thread-Announcement------------------------------------------
10 Thread #x is the program's root thread
12 ---Thread-Announcement------------------------------------------
14 Thread #x was created
35 Thread #x's call to pthread_join failed
46 Thread #x's call to pthread_mutex_init failed
53 Thread #x: pthread_mutex_destroy of a locked mutex
60 Thread #x's call to pthread_mutex_destroy failed
68 Thread #x's call to pthread_mutex_lock failed
76 Thread #x's call to pthread_mutex_trylock failed
[all …]
|
| D | tc20_verifywrap.stderr.exp-mips32 | 8 ---Thread-Announcement------------------------------------------
10 Thread #x is the program's root thread
12 ---Thread-Announcement------------------------------------------
14 Thread #x was created
35 Thread #x's call to pthread_join failed
46 Thread #x's call to pthread_mutex_init failed
53 Thread #x: pthread_mutex_destroy of a locked mutex
60 Thread #x's call to pthread_mutex_destroy failed
68 Thread #x's call to pthread_mutex_lock failed
76 Thread #x's call to pthread_mutex_trylock failed
[all …]
|
| D | tc20_verifywrap.stderr.exp-s390x | 8 ---Thread-Announcement------------------------------------------
10 Thread #x is the program's root thread
12 ---Thread-Announcement------------------------------------------
14 Thread #x was created
37 Thread #x's call to pthread_join failed
48 Thread #x's call to pthread_mutex_init failed
55 Thread #x: pthread_mutex_destroy of a locked mutex
62 Thread #x's call to pthread_mutex_destroy failed
70 Thread #x's call to pthread_mutex_lock failed
78 Thread #x's call to pthread_mutex_trylock failed
[all …]
|
| D | bar_bad.stderr.exp-destroy-hang | 3 ---Thread-Announcement------------------------------------------
5 Thread #x is the program's root thread
9 Thread #x: pthread_barrier_init: 'count' argument is zero
15 Thread #x's call to pthread_barrier_init failed
24 Thread #x: pthread_barrier_init: barrier is already initialised
32 Thread #x: pthread_barrier_init: barrier is already initialised
38 Thread #x: pthread_barrier_init: threads are waiting at barrier
46 Thread #x: pthread_barrier_destroy: threads are waiting at barrier
50 ---Thread-Announcement------------------------------------------
52 Thread #x was created
[all …]
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | ThreadFactoryBuilderTest.java | 25 import java.lang.Thread.UncaughtExceptionHandler;
44 @Override public void uncaughtException(Thread t, Throwable e) {
58 Thread thread = threadFactory.newThread(monitoredRunnable); in testThreadFactoryBuilder_defaults()
61 Thread defaultThread = in testThreadFactoryBuilder_defaults()
76 Thread thread2 = threadFactory.newThread(monitoredRunnable); in testThreadFactoryBuilder_defaults()
84 Thread thread3 = threadFactory2.newThread(monitoredRunnable); in testThreadFactoryBuilder_defaults()
92 private static void checkThreadPoolName(Thread thread, int threadId) { in checkThreadPoolName()
116 Thread thread = factory.newThread(monitoredRunnable); in testDaemon_false()
122 Thread thread = factory.newThread(monitoredRunnable); in testDaemon_true()
127 for (int i = Thread.MIN_PRIORITY; i <= Thread.MAX_PRIORITY; i++) { in testPriority_custom()
[all …]
|
| D | InterruptionUtil.java | 45 private final Thread interruptee;
48 Interruptenator(Thread interruptee, long everyMillis) { in Interruptenator()
57 Thread.sleep(everyMillis); in run()
78 final Thread interruptee = Thread.currentThread(); in requestInterruptIn()
79 new Thread(new Runnable() { in requestInterruptIn()
95 new Interruptenator(Thread.currentThread(), interruptPeriodMillis); in repeatedlyInterruptTestThread()
96 final Thread interruptingThread = new Thread(interruptingTask); in repeatedlyInterruptTestThread()
103 Thread.interrupted(); in repeatedlyInterruptTestThread()
120 Thread thread, long timeout, TimeUnit unit) { in joinUninterruptibly()
138 Thread.currentThread().interrupt(); in joinUninterruptibly()
|
| /external/sl4a/Common/src/com/googlecode/android_scripting/facade/ |
| D | ToneGeneratorFacade.java | 50 Thread.sleep(toneDuration); in generateDtmfTones()
54 Thread.sleep(toneDuration); in generateDtmfTones()
58 Thread.sleep(toneDuration); in generateDtmfTones()
62 Thread.sleep(toneDuration); in generateDtmfTones()
66 Thread.sleep(toneDuration); in generateDtmfTones()
70 Thread.sleep(toneDuration); in generateDtmfTones()
74 Thread.sleep(toneDuration); in generateDtmfTones()
78 Thread.sleep(toneDuration); in generateDtmfTones()
82 Thread.sleep(toneDuration); in generateDtmfTones()
86 Thread.sleep(toneDuration); in generateDtmfTones()
[all …]
|
| /external/tensorflow/tensorflow/python/training/ |
| D | coordinator_test.py | 88 t = threading.Thread(
101 threading.Thread(target=SleepABit, args=(0.01,)),
102 threading.Thread(target=SleepABit, args=(0.02,)),
103 threading.Thread(target=SleepABit, args=(0.01,))
114 threading.Thread(target=SleepABit, args=(0.01, coord)),
115 threading.Thread(target=SleepABit, args=(0.02, coord)),
116 threading.Thread(target=SleepABit, args=(0.01, coord))
128 threading.Thread(target=SleepABit, args=(0.01, coord)),
129 threading.Thread(target=SleepABit, args=(0.02,)),
130 threading.Thread(target=SleepABit, args=(0.01, coord))
[all …]
|
| /external/deqp/framework/common/ |
| D | tcuThreadUtil.hpp | 90 class Thread;
95 MessageBuilder (Thread& thread) : m_thread(thread) {} in MessageBuilder()
109 Thread& m_thread;
141 …virtual void exec (Thread& thread) = 0; //!< Overwritten by inherited class to perform act…
142 …virtual void execute (Thread& thread); //!< May Be overwritten by inherited class to chan…
153 class Thread : public de::Thread class
165 Thread (deUint32 seed);
166 ~Thread (void);
203 Thread (const Thread&);
204 Thread operator= (const Thread&);
[all …]
|