Lines Matching defs:m_threads
164 vector<TestThread*> m_threads;
231 for (int threadNdx = 0; threadNdx < (int)m_threads.size(); threadNdx++)
232 m_threads[threadNdx]->setStatus(TestThread::THREADSTATUS_NOT_SUPPORTED);
235 for (int threadNdx = 0; threadNdx < (int)m_threads.size(); threadNdx++)
246 for (int threadNdx = 0; threadNdx < (int)m_threads.size(); threadNdx++)
247 m_threads[threadNdx]->setStatus(TestThread::THREADSTATUS_ERROR);
250 for (int threadNdx = 0; threadNdx < (int)m_threads.size(); threadNdx++)
279 for (int threadNdx = 0; threadNdx < (int)m_threads.size(); threadNdx++)
280 delete m_threads[threadNdx];
281 m_threads.clear();
342 m_threads.reserve(m_threadCount);
345 m_threads.push_back(new TestThread(*this, threadNdx));
350 for (int threadNdx = 0; threadNdx < (int)m_threads.size(); threadNdx++)
351 m_threads[threadNdx]->start();
357 for (int threadNdx = 0; threadNdx < (int)m_threads.size(); threadNdx++)
359 if (m_threads[threadNdx]->getStatus() != TestThread::THREADSTATUS_RUNNING)
366 for (int threadNdx = 0; threadNdx < (int)m_threads.size(); threadNdx++)
367 m_threads[threadNdx]->join();
372 for (int threadNdx = 0; threadNdx < (int)m_threads.size(); threadNdx++)
374 if (m_threads[threadNdx]->getStatus() == TestThread::THREADSTATUS_ERROR)
377 if (m_threads[threadNdx]->getStatus() == TestThread::THREADSTATUS_NOT_SUPPORTED)
385 messageNdx.resize(m_threads.size(), 0);
392 for (int threadNdx = 0; threadNdx < (int)m_threads.size(); threadNdx++)
394 if (messageNdx[threadNdx] >= (int)m_threads[threadNdx]->getLog().getMessages().size())
397 if (nextThreadNdx == -1 || nextThreadTimeUs > m_threads[threadNdx]->getLog().getMessages()[messageNdx[threadNdx]].timeUs)
400 nextThreadTimeUs = m_threads[threadNdx]->getLog().getMessages()[messageNdx[threadNdx]].timeUs;
407 m_testCtx.getLog() << tcu::TestLog::Message << "[" << (nextThreadTimeUs - m_startTimeUs) << "] (" << nextThreadNdx << ") " << m_threads[nextThreadNdx]->getLog().getMessages()[messageNdx[nextThreadNdx]].msg << tcu::TestLog::EndMessage;
414 for (int threadNdx = 0; threadNdx < (int)m_threads.size(); threadNdx++)
415 delete m_threads[threadNdx];
417 m_threads.clear();
443 messageNdx.resize(m_threads.size(), 0);
450 for (int threadNdx = 0; threadNdx < (int)m_threads.size(); threadNdx++)
452 if (messageNdx[threadNdx] >= (int)m_threads[threadNdx]->getLog().getMessages().size())
455 if (nextThreadNdx == -1 || nextThreadTimeUs > m_threads[threadNdx]->getLog().getMessages()[messageNdx[threadNdx]].timeUs)
458 nextThreadTimeUs = m_threads[threadNdx]->getLog().getMessages()[messageNdx[threadNdx]].timeUs;
465 m_testCtx.getLog() << tcu::TestLog::Message << "[" << (nextThreadTimeUs - m_startTimeUs) << "] (" << nextThreadNdx << ") " << m_threads[nextThreadNdx]->getLog().getMessages()[messageNdx[nextThreadNdx]].msg << tcu::TestLog::EndMessage;
