| /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/android/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 remove()
69 assertTrue(Thread.holdsLock(mutex)); in peek()
75 assertTrue(Thread.holdsLock(mutex)); in element()
82 assertFalse(Thread.holdsLock(mutex)); in iterator()
88 assertTrue(Thread.holdsLock(mutex)); in size()
94 assertTrue(Thread.holdsLock(mutex)); in removeAll()
100 assertTrue(Thread.holdsLock(mutex)); in isEmpty()
[all …]
|
| D | SynchronizedTableTest.java | 32 assertTrue(Thread.holdsLock(mutex)); in toString()
38 assertTrue(Thread.holdsLock(mutex)); in equals()
44 assertTrue(Thread.holdsLock(mutex)); in hashCode()
50 assertTrue(Thread.holdsLock(mutex)); in size()
56 assertTrue(Thread.holdsLock(mutex)); in isEmpty()
62 assertTrue(Thread.holdsLock(mutex)); in containsValue()
68 assertTrue(Thread.holdsLock(mutex)); in clear()
74 assertTrue(Thread.holdsLock(mutex)); in values()
81 assertTrue(Thread.holdsLock(mutex)); in cellSet()
87 assertTrue(Thread.holdsLock(mutex)); in column()
[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 remove()
69 assertTrue(Thread.holdsLock(mutex)); in peek()
75 assertTrue(Thread.holdsLock(mutex)); in element()
82 assertFalse(Thread.holdsLock(mutex)); in iterator()
88 assertTrue(Thread.holdsLock(mutex)); in size()
94 assertTrue(Thread.holdsLock(mutex)); in removeAll()
100 assertTrue(Thread.holdsLock(mutex)); in isEmpty()
[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 remove()
69 assertTrue(Thread.holdsLock(mutex)); in peek()
75 assertTrue(Thread.holdsLock(mutex)); in element()
82 assertFalse(Thread.holdsLock(mutex)); in iterator()
88 assertTrue(Thread.holdsLock(mutex)); in size()
94 assertTrue(Thread.holdsLock(mutex)); in removeAll()
100 assertTrue(Thread.holdsLock(mutex)); in isEmpty()
[all …]
|
| D | SynchronizedTableTest.java | 32 assertTrue(Thread.holdsLock(mutex)); in toString()
38 assertTrue(Thread.holdsLock(mutex)); in equals()
44 assertTrue(Thread.holdsLock(mutex)); in hashCode()
50 assertTrue(Thread.holdsLock(mutex)); in size()
56 assertTrue(Thread.holdsLock(mutex)); in isEmpty()
62 assertTrue(Thread.holdsLock(mutex)); in containsValue()
68 assertTrue(Thread.holdsLock(mutex)); in clear()
74 assertTrue(Thread.holdsLock(mutex)); in values()
81 assertTrue(Thread.holdsLock(mutex)); in cellSet()
87 assertTrue(Thread.holdsLock(mutex)); in column()
[all …]
|
| D | SynchronizedQueueTest.java | 46 assertTrue(Thread.holdsLock(mutex)); in offer()
52 assertTrue(Thread.holdsLock(mutex)); in poll()
58 assertTrue(Thread.holdsLock(mutex)); in remove()
64 assertTrue(Thread.holdsLock(mutex)); in remove()
70 assertTrue(Thread.holdsLock(mutex)); in peek()
76 assertTrue(Thread.holdsLock(mutex)); in element()
83 assertFalse(Thread.holdsLock(mutex)); in iterator()
89 assertTrue(Thread.holdsLock(mutex)); in size()
95 assertTrue(Thread.holdsLock(mutex)); in removeAll()
101 assertTrue(Thread.holdsLock(mutex)); in isEmpty()
[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/bcc/tools/ |
| 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 …]
|
| 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 | 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 | 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 | 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 | 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 …]
|
| /external/angle/src/libANGLE/ |
| D | Thread.cpp | 19 Thread::Thread() in Thread() function in egl::Thread
26 void Thread::setLabel(EGLLabelKHR label) in setLabel()
31 EGLLabelKHR Thread::getLabel() const in getLabel()
36 void Thread::setSuccess() in setSuccess()
41 void Thread::setError(const Error &error, in setError()
56 EGLint Thread::getError() const in getError()
61 void Thread::setAPI(EGLenum api) in setAPI()
66 EGLenum Thread::getAPI() const in getAPI()
71 void Thread::setCurrent(gl::Context *context) in setCurrent()
76 Surface *Thread::getCurrentDrawSurface() const in getCurrentDrawSurface()
[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/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/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/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/swiftshader/src/Vulkan/Debug/ |
| D | Thread.cpp | 24 Thread::Thread(ID id, Context *ctx) in Thread() function in vk::dbg::Thread
29 void Thread::setName(const std::string &name) in setName()
35 std::string Thread::name() const in name()
41 void Thread::onLocationUpdate(std::unique_lock<std::mutex> &lock) in onLocationUpdate()
79 void Thread::enter(Context::Lock &ctxlck, const std::shared_ptr<File> &file, const std::string &fun… in enter()
93 void Thread::exit() in exit()
99 void Thread::update(std::function<void(Frame &)> f) in update()
111 Frame Thread::frame() const in frame()
117 std::vector<Frame> Thread::stack() const in stack()
129 Thread::State Thread::state() const in state()
[all …]
|