| /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 …]
|
| /external/bcc/tools/ |
| D | phpflow_example.txt | 35 classes or methods. For example, trace only methods from the Thread class:
37 # ./uflow -C java/lang/Thread $(pidof java)
40 3 27722 27731 3.144 -> java/lang/Thread.<init>
41 3 27722 27731 3.144 -> java/lang/Thread.init
42 3 27722 27731 3.144 -> java/lang/Thread.init
43 3 27722 27731 3.144 -> java/lang/Thread.currentThread
44 3 27722 27731 3.144 <- java/lang/Thread.currentThread
45 3 27722 27731 3.144 -> java/lang/Thread.getThreadGroup
46 3 27722 27731 3.144 <- java/lang/Thread.getThreadGroup
51 3 27722 27731 3.145 -> java/lang/Thread.isDaemon
[all …]
|
| D | perlflow_example.txt | 35 classes or methods. For example, trace only methods from the Thread class:
37 # ./uflow -C java/lang/Thread $(pidof java)
40 3 27722 27731 3.144 -> java/lang/Thread.<init>
41 3 27722 27731 3.144 -> java/lang/Thread.init
42 3 27722 27731 3.144 -> java/lang/Thread.init
43 3 27722 27731 3.144 -> java/lang/Thread.currentThread
44 3 27722 27731 3.144 <- java/lang/Thread.currentThread
45 3 27722 27731 3.144 -> java/lang/Thread.getThreadGroup
46 3 27722 27731 3.144 <- java/lang/Thread.getThreadGroup
51 3 27722 27731 3.145 -> java/lang/Thread.isDaemon
[all …]
|
| D | javaflow_example.txt | 35 classes or methods. For example, trace only methods from the Thread class:
37 # ./uflow -C java/lang/Thread $(pidof java)
40 3 27722 27731 3.144 -> java/lang/Thread.<init>
41 3 27722 27731 3.144 -> java/lang/Thread.init
42 3 27722 27731 3.144 -> java/lang/Thread.init
43 3 27722 27731 3.144 -> java/lang/Thread.currentThread
44 3 27722 27731 3.144 <- java/lang/Thread.currentThread
45 3 27722 27731 3.144 -> java/lang/Thread.getThreadGroup
46 3 27722 27731 3.144 <- java/lang/Thread.getThreadGroup
51 3 27722 27731 3.145 -> java/lang/Thread.isDaemon
[all …]
|
| D | rubyflow_example.txt | 35 classes or methods. For example, trace only methods from the Thread class:
37 # ./uflow -C java/lang/Thread $(pidof java)
40 3 27722 27731 3.144 -> java/lang/Thread.<init>
41 3 27722 27731 3.144 -> java/lang/Thread.init
42 3 27722 27731 3.144 -> java/lang/Thread.init
43 3 27722 27731 3.144 -> java/lang/Thread.currentThread
44 3 27722 27731 3.144 <- java/lang/Thread.currentThread
45 3 27722 27731 3.144 -> java/lang/Thread.getThreadGroup
46 3 27722 27731 3.144 <- java/lang/Thread.getThreadGroup
51 3 27722 27731 3.145 -> java/lang/Thread.isDaemon
[all …]
|
| D | pythonflow_example.txt | 35 classes or methods. For example, trace only methods from the Thread class:
37 # ./uflow -C java/lang/Thread $(pidof java)
40 3 27722 27731 3.144 -> java/lang/Thread.<init>
41 3 27722 27731 3.144 -> java/lang/Thread.init
42 3 27722 27731 3.144 -> java/lang/Thread.init
43 3 27722 27731 3.144 -> java/lang/Thread.currentThread
44 3 27722 27731 3.144 <- java/lang/Thread.currentThread
45 3 27722 27731 3.144 -> java/lang/Thread.getThreadGroup
46 3 27722 27731 3.144 <- java/lang/Thread.getThreadGroup
51 3 27722 27731 3.145 -> java/lang/Thread.isDaemon
[all …]
|
| D | tclflow_example.txt | 35 classes or methods. For example, trace only methods from the Thread class:
37 # ./uflow -C java/lang/Thread $(pidof java)
40 3 27722 27731 3.144 -> java/lang/Thread.<init>
41 3 27722 27731 3.144 -> java/lang/Thread.init
42 3 27722 27731 3.144 -> java/lang/Thread.init
43 3 27722 27731 3.144 -> java/lang/Thread.currentThread
44 3 27722 27731 3.144 <- java/lang/Thread.currentThread
45 3 27722 27731 3.144 -> java/lang/Thread.getThreadGroup
46 3 27722 27731 3.144 <- java/lang/Thread.getThreadGroup
51 3 27722 27731 3.145 -> java/lang/Thread.isDaemon
[all …]
|
| /external/bcc/tools/lib/ |
| D | uflow_example.txt | 35 classes or methods. For example, trace only methods from the Thread class:
37 # ./uflow -C java/lang/Thread $(pidof java)
40 3 27722 27731 3.144 -> java/lang/Thread.<init>
41 3 27722 27731 3.144 -> java/lang/Thread.init
42 3 27722 27731 3.144 -> java/lang/Thread.init
43 3 27722 27731 3.144 -> java/lang/Thread.currentThread
44 3 27722 27731 3.144 <- java/lang/Thread.currentThread
45 3 27722 27731 3.144 -> java/lang/Thread.getThreadGroup
46 3 27722 27731 3.144 <- java/lang/Thread.getThreadGroup
51 3 27722 27731 3.145 -> java/lang/Thread.isDaemon
[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 | 30 using base::Thread;
42 class SleepInsideInitThread : public Thread {
44 SleepInsideInitThread() : Thread("none") { in SleepInsideInitThread()
79 class CaptureToEventList : public Thread {
85 : Thread("none"), in CaptureToEventList()
131 void ReturnThreadId(base::Thread* thread, in ReturnThreadId()
141 Thread a("StartWithStackSize"); in TEST_F()
146 Thread::Options options; in TEST_F()
170 Thread* a = new Thread("StartNonJoinable"); in TEST_F()
175 Thread::Options options; in TEST_F()
[all …]
|
| /external/guice/core/src/com/google/inject/internal/ |
| D | CycleDetectingLock.java | 47 ListMultimap<Thread, ID> lockOrDetectPotentialLocksCycle(); in lockOrDetectPotentialLocksCycle()
84 private static Map<Thread, ReentrantCycleDetectingLock<?>> lockThreadIsWaitingOn =
105 private static final Multimap<Thread, ReentrantCycleDetectingLock<?>> locksOwnedByThread =
130 private Thread lockOwnerThread = null;
147 public ListMultimap<Thread, ID> lockOrDetectPotentialLocksCycle() { in lockOrDetectPotentialLocksCycle()
148 final Thread currentThread = Thread.currentThread(); in lockOrDetectPotentialLocksCycle()
153 ListMultimap<Thread, ID> locksInCycle = detectPotentialLocksCycle(); in lockOrDetectPotentialLocksCycle()
183 final Thread currentThread = Thread.currentThread(); in unlock()
213 final Thread currentThread = Thread.currentThread(); in checkState()
245 private ListMultimap<Thread, ID> detectPotentialLocksCycle() { in detectPotentialLocksCycle()
[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/grpc-grpc/src/core/lib/gprpp/ |
| D | thd.h | 48 class Thread {
53 Thread() : state_(FAKE), impl_(nullptr) {} in Thread() function
60 Thread(const char* thd_name, void (*thd_body)(void* arg), void* arg,
65 Thread(Thread&& other) : state_(other.state_), impl_(other.impl_) { in Thread() function
73 Thread& operator=(Thread&& other) {
91 ~Thread() { GPR_ASSERT(impl_ == nullptr); } in ~Thread()
115 Thread(const Thread&) = delete;
116 Thread& operator=(const Thread&) = delete;
|
| /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/guice/core/test/com/google/inject/internal/ |
| D | CycleDetectingLockTest.java | 51 if (Thread.currentThread().getName().equals("T2")) { in testSingletonThreadsRuntimeCircularDependency()
58 assertEquals("T1", Thread.currentThread().getName()); in testSingletonThreadsRuntimeCircularDependency()
70 if (Thread.currentThread().getName().equals("T1")) { in testSingletonThreadsRuntimeCircularDependency()
78 assertEquals("T2", Thread.currentThread().getName()); in testSingletonThreadsRuntimeCircularDependency()
89 Thread.currentThread().setName("T1"); in testSingletonThreadsRuntimeCircularDependency()
104 Thread.currentThread().setName("T2"); in testSingletonThreadsRuntimeCircularDependency()
145 Thread.currentThread().setName("A"); in testCycleDetectingLockFactoriesDoNotDeadlock()
162 Thread.currentThread().setName("B"); in testCycleDetectingLockFactoriesDoNotDeadlock()
200 ImmutableList<Future<ListMultimap<Thread, String>>> futures = in testCycleReporting()
208 ListMultimap<Thread, String> cycle = null; in testCycleReporting()
[all …]
|