| /external/deqp/modules/egl/ |
| D | teglGLES2SharingThreadedTests.cpp | 2217 std::vector<GLES2ThreadTest::EGLThread *> m_threads; member in deqp::egl::GLES2SharingRandomTest
2291 … m_threads.push_back(new GLES2ThreadTest::EGLThread(egl, m_gl, deInt32Hash(m_seed + threadNdx))); in init()
2295 m_threads[threadNdx]->addOperation( in init()
2308 m_threads[threadNdx]->addOperation( in init()
2316 m_threads[threadNdx]->addOperation(new GLES2ThreadTest::MakeCurrent( in init()
2317 …*m_threads[threadNdx], m_eglDisplay, resourceManager.popSurface(0), resourceManager.popContext(0))… in init()
2325 … m_threads[threadNdx]->addOperation(new GLES2ThreadTest::InitGLExtension("GL_OES_EGL_sync")); in init()
2334 … m_threads[threadNdx]->addOperation(new GLES2ThreadTest::InitGLExtension("GL_OES_EGL_image")); in init()
2351 m_threads[threadNdx]->addOperation( in init()
2361 SharedPtr<GLES2ThreadTest::GLES2Context> context = m_threads[threadNdx]->context; in init()
[all …]
|
| D | teglMultiThreadTests.cpp | 200 vector<TestThread *> m_threads; member in deqp::egl::MultiThreadedTest
265 for (int threadNdx = 0; threadNdx < (int)m_threads.size(); threadNdx++) in execTest()
278 for (int threadNdx = 0; threadNdx < (int)m_threads.size(); threadNdx++) in execTest()
307 for (int threadNdx = 0; threadNdx < (int)m_threads.size(); threadNdx++) in ~MultiThreadedTest()
308 delete m_threads[threadNdx]; in ~MultiThreadedTest()
309 m_threads.clear(); in ~MultiThreadedTest()
374 m_threads.reserve(m_threadCount); in iterate()
377 m_threads.push_back(new TestThread(*this, threadNdx)); in iterate()
382 for (int threadNdx = 0; threadNdx < (int)m_threads.size(); threadNdx++) in iterate()
383 m_threads[threadNdx]->start(); in iterate()
[all …]
|
| /external/ComputeLibrary/src/core/NEON/kernels/arm_gemm/ |
| D | barrier.hpp | 34 unsigned int m_threads; member in arm_gemm::barrier
40 barrier(unsigned int threads) : m_threads(threads), m_waiters(0), m_leavers(0) { } in barrier()
44 m_threads = nthreads; in set_nthreads()
50 while (m_waiters != m_threads) { in arrive_and_wait()
56 if (v == (m_threads - 1)) { in arrive_and_wait()
57 m_waiters -= m_threads; in arrive_and_wait()
|
| /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/ComputeLibrary/src/runtime/ |
| D | IScheduler.cpp | 72 unsigned m_threads, n_threads; in schedule_common() local
73 std::tie(m_threads, n_threads) = scheduler_utils::split_2d(this->num_threads(), m, n); in schedule_common()
78 for(unsigned int mi = 0; mi != m_threads; ++mi) in schedule_common()
81 [ni, mi, m_threads, n_threads, &max_window, &kernel](const ThreadInfo & info) in schedule_common()
84 Window win = max_window.split_window(Window::DimX, mi, m_threads) in schedule_common()
90 thread_locator.set(Window::DimX, Window::Dimension(mi, m_threads)); in schedule_common()
|
| /external/deqp/external/vulkancts/modules/vulkan/ |
| D | vktBuildPrograms.cpp | 109 std::vector<ExecThreadSp> m_threads; member in vkt::__anon495c26050111::TaskExecutor
113 TaskExecutor::TaskExecutor(uint32_t numThreads) : m_threads(numThreads), m_tasks(m_threads.size() *… in TaskExecutor()
115 for (size_t ndx = 0; ndx < m_threads.size(); ++ndx) in TaskExecutor()
116 m_threads[ndx] = ExecThreadSp(new TaskExecutorThread(m_tasks)); in TaskExecutor()
121 for (size_t ndx = 0; ndx < m_threads.size(); ++ndx) in ~TaskExecutor()
124 for (size_t ndx = 0; ndx < m_threads.size(); ++ndx) in ~TaskExecutor()
125 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()
174 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/cronet/tot/third_party/libc++abi/src/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/cronet/stable/third_party/libc++abi/src/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 | 659 m_threads.push_back(SharedPtr<ThreadGroupThread>(thread.release())); in add()
666 m_barrier.reset((int)m_threads.size()); in run()
668 …for (ThreadVector::iterator threadIter = m_threads.begin(); threadIter != m_threads.end(); ++threa… in run()
671 …for (ThreadVector::iterator threadIter = m_threads.begin(); threadIter != m_threads.end(); ++threa… in run()
682 ThreadVector m_threads; member in vkt::synchronization::__anone556e89c0111::ThreadGroup
|
| /external/deqp/external/vulkancts/modules/vulkan/api/ |
| D | vktApiObjectManagementTests.cpp | 125 ThreadVector m_threads; member in vkt::api::__anonf68a87d40111::ThreadGroup
171 m_threads.push_back(de::SharedPtr<ThreadGroupThread>(thread.release())); in add()
178 m_barrier.reset((int)m_threads.size()); in run()
180 …for (ThreadVector::iterator threadIter = m_threads.begin(); threadIter != m_threads.end(); ++threa… in run()
183 …for (ThreadVector::iterator threadIter = m_threads.begin(); threadIter != m_threads.end(); ++threa… in run()
|