| /external/llvm-project/lldb/source/Target/ |
| D | ThreadList.cpp | 47 m_threads = rhs.m_threads; in operator =()
87 return m_threads.size(); in GetSize()
97 if (idx < m_threads.size()) in GetThreadAtIndex()
98 thread_sp = m_threads[idx]; in GetThreadAtIndex()
110 const uint32_t num_threads = m_threads.size(); in FindThreadByID()
112 if (m_threads[idx]->GetID() == tid) { in FindThreadByID()
113 thread_sp = m_threads[idx]; in FindThreadByID()
128 const uint32_t num_threads = m_threads.size(); in FindThreadByProtocolID()
130 if (m_threads[idx]->GetProtocolID() == tid) { in FindThreadByProtocolID()
131 thread_sp = m_threads[idx]; in FindThreadByProtocolID()
[all …]
|
| D | ThreadCollection.cpp | 19 ThreadCollection::ThreadCollection() : m_threads(), m_mutex() {} in ThreadCollection()
22 : m_threads(threads), m_mutex() {} in ThreadCollection()
26 m_threads.push_back(thread_sp); in AddThread()
33 if (m_threads.empty() || m_threads.back()->GetIndexID() < thread_index_id) in AddThreadSortedByIndexID()
34 m_threads.push_back(thread_sp); in AddThreadSortedByIndexID()
36 m_threads.insert( in AddThreadSortedByIndexID()
37 std::upper_bound(m_threads.begin(), m_threads.end(), thread_sp, in AddThreadSortedByIndexID()
48 if (idx < m_threads.size()) in InsertThread()
49 m_threads.insert(m_threads.begin() + idx, thread_sp); in InsertThread()
51 m_threads.push_back(thread_sp); in InsertThread()
[all …]
|
| /external/llvm-project/lldb/tools/debugserver/source/MacOSX/ |
| D | MachThreadList.cpp | 26 : m_threads(), m_threads_mutex(PTHREAD_MUTEX_RECURSIVE), in MachThreadList()
121 const size_t num_threads = m_threads.size(); in GetThreadByID()
123 if (m_threads[idx]->ThreadID() == tid) { in GetThreadByID()
124 thread_sp = m_threads[idx]; in GetThreadByID()
135 const size_t num_threads = m_threads.size(); in GetThreadByMachPortNumber()
137 if (m_threads[idx]->MachPortNumber() == mach_port_number) { in GetThreadByMachPortNumber()
138 thread_sp = m_threads[idx]; in GetThreadByMachPortNumber()
149 const size_t num_threads = m_threads.size(); in GetThreadIDByMachPortNumber()
151 if (m_threads[idx]->MachPortNumber() == mach_port_number) { in GetThreadIDByMachPortNumber()
152 return m_threads[idx]->ThreadID(); in GetThreadIDByMachPortNumber()
[all …]
|
| D | MachThreadList.h | 100 collection m_threads; variable
|
| /external/deqp/modules/egl/ |
| D | teglGLES2SharingThreadedTests.cpp | 2094 std::vector<GLES2ThreadTest::EGLThread*> m_threads; member in deqp::egl::GLES2SharingRandomTest
2172 m_threads.push_back(new GLES2ThreadTest::EGLThread(egl, m_gl, deInt32Hash(m_seed+threadNdx))); in init()
2175 …m_threads[threadNdx]->addOperation(new GLES2ThreadTest::CreateContext(m_eglDisplay, m_eglConfig, s… in init()
2187 …m_threads[threadNdx]->addOperation(new GLES2ThreadTest::CreatePBufferSurface(m_eglDisplay, m_eglCo… in init()
2194 …m_threads[threadNdx]->addOperation(new GLES2ThreadTest::MakeCurrent(*m_threads[threadNdx], m_eglDi… in init()
2202 m_threads[threadNdx]->addOperation(new GLES2ThreadTest::InitGLExtension("GL_OES_EGL_sync")); in init()
2211 m_threads[threadNdx]->addOperation(new GLES2ThreadTest::InitGLExtension("GL_OES_EGL_image")); in init()
2228 …m_threads[threadNdx]->addOperation(new GLES2ThreadTest::DestroyImage(image, m_config.useFenceSync,… in init()
2237 SharedPtr<GLES2ThreadTest::GLES2Context> context = m_threads[threadNdx]->context; in init()
2238 SharedPtr<GLES2ThreadTest::Surface> surface = m_threads[threadNdx]->surface; in init()
[all …]
|
| D | teglMultiThreadTests.cpp | 163 vector<TestThread*> m_threads; member in deqp::egl::MultiThreadedTest
231 for (int threadNdx = 0; threadNdx < (int)m_threads.size(); threadNdx++) in execTest()
244 for (int threadNdx = 0; threadNdx < (int)m_threads.size(); threadNdx++) in execTest()
272 for (int threadNdx = 0; threadNdx < (int)m_threads.size(); threadNdx++) in ~MultiThreadedTest()
273 delete m_threads[threadNdx]; in ~MultiThreadedTest()
274 m_threads.clear(); in ~MultiThreadedTest()
338 m_threads.reserve(m_threadCount); in iterate()
341 m_threads.push_back(new TestThread(*this, threadNdx)); in iterate()
346 for (int threadNdx = 0; threadNdx < (int)m_threads.size(); threadNdx++) in iterate()
347 m_threads[threadNdx]->start(); in iterate()
[all …]
|
| /external/testng/src/test/java/test/thread/ |
| D | TestThreadCountTest.java | 18 private Set<String> m_threads= Collections.synchronizedSet(new HashSet<String>()); field in TestThreadCountTest
22 m_threads.add(ThreadUtil.currentThreadInfo()); in test1()
27 m_threads.add(ThreadUtil.currentThreadInfo()); in test2()
32 m_threads.add(ThreadUtil.currentThreadInfo()); in test3()
37 Assert.assertEquals(m_threads.size(), 3, "Test should use 3 threads"); in checkThreading()
|
| D | SuiteThreadCountTest.java | 18 private Set<String> m_threads= Collections.synchronizedSet(new HashSet<String>()); field in SuiteThreadCountTest
22 m_threads.add(ThreadUtil.currentThreadInfo()); in test1()
27 m_threads.add(ThreadUtil.currentThreadInfo()); in test2()
32 Assert.assertEquals(m_threads.size(), 2, "Test should use 2 threads (suite level)"); in checkThreading()
|
| /external/llvm-project/lldb/source/API/ |
| D | SBQueue.cpp | 31 : m_queue_wp(), m_threads(), m_thread_list_fetched(false), in QueueImpl()
35 : m_queue_wp(), m_threads(), m_thread_list_fetched(false), in QueueImpl()
44 m_threads = rhs.m_threads; in QueueImpl()
57 m_threads.clear(); in Clear()
106 m_threads.push_back(thread_sp); in FetchThreads()
140 result = m_threads.size(); in GetNumThreads()
150 if (queue_sp && idx < m_threads.size()) { in GetThreadAtIndex()
153 ThreadSP thread_sp = m_threads[idx].lock(); in GetThreadAtIndex()
212 m_threads; // threads currently executing this queue's items member in lldb_private::QueueImpl
|
| /external/llvm-project/lldb/source/Plugins/Process/NetBSD/ |
| D | NativeProcessNetBSD.cpp | 105 for (const auto &thread : process_up->m_threads) in Launch()
172 m_threads.clear(); in MonitorExited()
192 for (const auto &thread : m_threads) { in MonitorSIGSTOP()
219 for (const auto &t : m_threads) { in MonitorSIGTRAP()
255 for (const auto &thread : m_threads) in MonitorSIGTRAP()
340 for (const auto &abs_thread : m_threads) { in MonitorSignal()
436 ComputeSignalInfo(m_threads, resume_actions); in Resume()
440 for (const auto &abs_thread : m_threads) { in Resume()
697 size_t NativeProcessNetBSD::UpdateThreads() { return m_threads.size(); } in UpdateThreads()
751 for (const auto &thread : m_threads) { in HasThreadNoLock()
[all …]
|
| /external/llvm-project/lldb/source/Plugins/Process/FreeBSDRemote/ |
| D | NativeProcessFreeBSD.cpp | 100 for (const auto &thread : process_up->m_threads) in Launch()
167 m_threads.clear(); in MonitorExited()
177 for (const auto &thread : m_threads) { in MonitorSIGSTOP()
243 for (const auto &thread : m_threads) in MonitorSIGTRAP()
250 for (const auto &t : m_threads) { in MonitorSIGTRAP()
320 for (const auto &abs_thread : m_threads) { in MonitorSignal()
364 for (const auto &abs_thread : m_threads) { in Resume()
624 size_t NativeProcessFreeBSD::UpdateThreads() { return m_threads.size(); } in UpdateThreads()
705 for (const auto &thread : m_threads) { in HasThreadNoLock()
726 if (m_threads.empty()) in AddThread()
[all …]
|
| /external/llvm-project/lldb/source/Plugins/Process/Windows/Common/ |
| D | NativeProcessWindows.cpp | 95 LLDB_LOG(log, "resuming {0} threads.", m_threads.size()); in Resume()
98 for (uint32_t i = 0; i < m_threads.size(); ++i) { in Resume()
99 auto thread = static_cast<NativeThreadWindows *>(m_threads[i].get()); in Resume()
275 for (uint32_t i = 0; i < m_threads.size(); ++i) { in StopThread()
276 auto t = static_cast<NativeThreadWindows *>(m_threads[i].get()); in StopThread()
284 size_t NativeProcessWindows::UpdateThreads() { return m_threads.size(); } in UpdateThreads()
416 assert(m_threads.empty()); in OnDebuggerConnected()
417 m_threads.push_back(std::make_unique<NativeThreadWindows>( in OnDebuggerConnected()
550 m_threads.push_back(std::move(thread)); in OnCreateThread()
560 for (auto t = m_threads.begin(); t != m_threads.end();) { in OnExitThread()
[all …]
|
| /external/deqp/external/vulkancts/modules/vulkan/ |
| D | vktBuildPrograms.cpp | 106 std::vector<ExecThreadSp> m_threads; member in vkt::__anon5c239db60111::TaskExecutor
111 : m_threads (numThreads) in TaskExecutor()
112 , m_tasks (m_threads.size() * 1024u) in TaskExecutor()
114 for (size_t ndx = 0; ndx < m_threads.size(); ++ndx) in TaskExecutor()
115 m_threads[ndx] = ExecThreadSp(new TaskExecutorThread(m_tasks)); in TaskExecutor()
120 for (size_t ndx = 0; ndx < m_threads.size(); ++ndx) in ~TaskExecutor()
123 for (size_t ndx = 0; ndx < m_threads.size(); ++ndx) in ~TaskExecutor()
124 m_threads[ndx]->join(); in ~TaskExecutor()
166 std::vector<SyncTask> syncTasks (m_threads.size()); in waitForComplete()
168 for (size_t ndx = 0; ndx < m_threads.size(); ++ndx) in waitForComplete()
[all …]
|
| /external/testng/src/main/java/org/testng/internal/thread/ |
| D | ThreadUtil.java | 106 private List<Thread> m_threads = Lists.newArrayList(); field in ThreadUtil.ThreadFactoryImpl
115 m_threads.add(result); in newThread()
126 return m_threads; in getThreads()
|
| /external/llvm-project/lldb/include/lldb/Target/ |
| D | ThreadCollection.h | 47 return ThreadIterable(m_threads, GetMutex()); in Threads()
53 collection m_threads;
|
| /external/llvm-project/lldb/test/API/functionalities/thread/backtrace_all/ |
| D | ParallelTask.cpp | 17 m_threads.emplace_back(Worker, this); in TaskPoolImpl()
48 for (auto& t : m_threads) in Stop()
76 std::vector<std::thread> m_threads; member in TaskPoolImpl
|
| /external/llvm-project/lldb/source/Plugins/Process/Linux/ |
| D | NativeProcessLinux.cpp | 602 llvm::erase_if(m_threads, [&](std::unique_ptr<NativeThreadProtocol> &t) { in MonitorSIGTRAP()
605 assert(m_threads.size() == 1); in MonitorSIGTRAP()
606 auto *main_thread = static_cast<NativeThreadLinux *>(m_threads[0].get()); in MonitorSIGTRAP()
1039 for (const auto &thread : m_threads) { in Resume()
1056 for (const auto &thread : m_threads) { in Resume()
1115 for (const auto &thread : m_threads) { in Detach()
1150 for (const auto &thread : m_threads) { in Interrupt()
1494 return m_threads.size(); in UpdateThreads()
1653 for (const auto &thread : m_threads) { in HasThreadNoLock()
1670 for (auto it = m_threads.begin(); it != m_threads.end(); ++it) { in StopTrackingThread()
[all …]
|
| /external/llvm-project/lldb/source/Host/common/ |
| D | NativeProcessProtocol.cpp | 89 if (idx < m_threads.size()) in GetThreadAtIndex()
90 return m_threads[idx].get(); in GetThreadAtIndex()
96 for (const auto &thread : m_threads) { in GetThreadByIDUnlocked()
161 for (const auto &thread : m_threads) { in SetWatchpoint()
202 for (const auto &thread : m_threads) { in RemoveWatchpoint()
248 for (const auto &thread : m_threads) { in SetHardwareBreakpoint()
287 for (const auto &thread : m_threads) { in RemoveHardwareBreakpoint()
|
| /external/llvm-project/libcxxabi/test/ |
| D | guard_threaded_test.pass.cpp | 49 explicit Barrier(int n) : m_threads(n), m_remaining(n) { } in Barrier()
65 while ((m_threads - m_remaining.load()) < n) { in wait_for_threads()
71 const int m_threads; member
|
| /external/deqp/external/vulkancts/modules/vulkan/synchronization/ |
| D | vktSynchronizationInternallySynchronizedObjectsTests.cpp | 522 m_threads.push_back(SharedPtr<ThreadGroupThread>(thread.release())); in add()
529 …for (ThreadVector::iterator threadIter = m_threads.begin(); threadIter != m_threads.end(); ++threa… in run()
532 …for (ThreadVector::iterator threadIter = m_threads.begin(); threadIter != m_threads.end(); ++threa… in run()
543 ThreadVector m_threads; member in vkt::synchronization::__anon7ddd96cd0111::ThreadGroup
|
| /external/llvm-project/lldb/include/lldb/Host/common/ |
| D | NativeProcessProtocol.h | 410 std::vector<std::unique_ptr<NativeThreadProtocol>> m_threads; variable
|
| /external/deqp/external/vulkancts/modules/vulkan/api/ |
| D | vktApiObjectManagementTests.cpp | 121 ThreadVector m_threads; member in vkt::api::__anon5fcc4f650111::ThreadGroup
165 m_threads.push_back(de::SharedPtr<ThreadGroupThread>(thread.release())); in add()
172 m_barrier.reset((int)m_threads.size()); in run()
174 …for (ThreadVector::iterator threadIter = m_threads.begin(); threadIter != m_threads.end(); ++threa… in run()
177 …for (ThreadVector::iterator threadIter = m_threads.begin(); threadIter != m_threads.end(); ++threa… in run()
|