Revision control
Copy as Markdown
// Copyright (C) 2014 Klaralvdalens Datakonsult AB (KDAB).
// SPDX-License-Identifier: LicenseRef-Qt-Commercial OR GPL-3.0-only
#include <QtTest/QTest>
#include <QMutex>
#include <QWaitCondition>
#include <QThread>
#include <Qt3DRender/private/renderqueue_p.h>
#include <renderview_p.h>
class tst_RenderQueue : public QObject
{
Q_OBJECT
public :
tst_RenderQueue() {}
~tst_RenderQueue() {}
private Q_SLOTS:
void setRenderViewCount();
void circleQueues();
void checkOrder();
void checkTimeToSubmit();
void concurrentQueueAccess();
void resetQueue();
};
void tst_RenderQueue::setRenderViewCount()
{
// GIVEN
Qt3DRender::Render::RenderQueue<Qt3DRender::Render::OpenGL::RenderView> renderQueue;
// THEN
QCOMPARE(renderQueue.wasReset(), true);
// WHEN
renderQueue.setTargetRenderViewCount(7);
// THEN
QCOMPARE(renderQueue.wasReset(), false);
QVERIFY(renderQueue.targetRenderViewCount() == 7);
QVERIFY(renderQueue.currentRenderViewCount()== 0);
}
void tst_RenderQueue::circleQueues()
{
// GIVEN
Qt3DRender::Render::RenderQueue<Qt3DRender::Render::OpenGL::RenderView> renderQueue;
renderQueue.setTargetRenderViewCount(7);
// WHEN
for (int j = 0; j < 10; j++) {
// WHEN
renderQueue.reset();
renderQueue.setTargetRenderViewCount(7);
// THEN
QVERIFY(!renderQueue.isFrameQueueComplete());
QCOMPARE(renderQueue.currentRenderViewCount(), 0);
// WHEN
QList<Qt3DRender::Render::OpenGL::RenderView *> renderViews;
for (int i = 0; i < 7; i++) {
renderViews << new Qt3DRender::Render::OpenGL::RenderView();
renderQueue.queueRenderView(renderViews.at(i), i);
}
// THEN
QVERIFY(renderQueue.isFrameQueueComplete());
}
}
void tst_RenderQueue::checkOrder()
{
// GIVEN
Qt3DRender::Render::RenderQueue<Qt3DRender::Render::OpenGL::RenderView> renderQueue;
renderQueue.setTargetRenderViewCount(7);
QVector<Qt3DRender::Render::OpenGL::RenderView *> renderViews(7);
// WHEN
for (int i = 0; i < 7; ++i) {
int processingOrder = (i % 2 == 0) ? (6 - i) : i;
renderViews[processingOrder] = new Qt3DRender::Render::OpenGL::RenderView();
renderQueue.queueRenderView(renderViews[processingOrder], processingOrder);
}
// THEN
const std::vector<Qt3DRender::Render::OpenGL::RenderView *> &frame = renderQueue.nextFrameQueue();
for (int i = 0; i < 7; ++i) {
QVERIFY(frame[i] == renderViews[i]);
}
}
void tst_RenderQueue::checkTimeToSubmit()
{
// GIVEN
Qt3DRender::Render::RenderQueue<Qt3DRender::Render::OpenGL::RenderView> renderQueue;
renderQueue.setTargetRenderViewCount(7);
QVector<Qt3DRender::Render::OpenGL::RenderView *> renderViews(7);
// WHEN
for (int i = 0; i < 7; i++) {
int processingOrder = (i % 2 == 0) ? (6 - i) : i;
renderViews[processingOrder] = new Qt3DRender::Render::OpenGL::RenderView();
renderQueue.queueRenderView(renderViews[processingOrder], processingOrder);
// THEN
if (i < 6)
QVERIFY(!renderQueue.isFrameQueueComplete());
else
QVERIFY(renderQueue.isFrameQueueComplete());
}
}
class SimpleWorker : public QThread
{
Q_OBJECT
public:
QSemaphore m_waitSubmit;
QSemaphore m_waitQueue;
Qt3DRender::Render::RenderQueue<Qt3DRender::Render::OpenGL::RenderView> *m_renderQueues;
public Q_SLOTS:
void run() final // In Thread
{
for (int i = 0; i < 5; i++) {
m_waitQueue.acquire();
QVERIFY(m_renderQueues->currentRenderViewCount() == 0);
QVERIFY(!m_renderQueues->isFrameQueueComplete());
for (int j = 0; j < 7; ++j) {
// THEN
QCOMPARE(m_renderQueues->currentRenderViewCount(), j);
// WHEN
m_renderQueues->queueRenderView(new Qt3DRender::Render::OpenGL::RenderView(), j);
// THEN
QVERIFY(m_renderQueues->targetRenderViewCount() == 7);
QCOMPARE(m_renderQueues->currentRenderViewCount(), j + 1);
QVERIFY(m_renderQueues->isFrameQueueComplete() == (j == 6));
QThread::msleep(20); // Simulates business
}
QVERIFY(m_renderQueues->isFrameQueueComplete());
m_waitSubmit.release();
}
}
};
void tst_RenderQueue::concurrentQueueAccess()
{
// GIVEN
Qt3DRender::Render::RenderQueue<Qt3DRender::Render::OpenGL::RenderView>*renderQueue = new Qt3DRender::Render::RenderQueue<Qt3DRender::Render::OpenGL::RenderView>();
SimpleWorker *jobsThread = new SimpleWorker();
renderQueue->setTargetRenderViewCount(7);
jobsThread->m_renderQueues = renderQueue;
// THEN
QVERIFY(jobsThread->m_renderQueues->targetRenderViewCount() == renderQueue->targetRenderViewCount());
QVERIFY(jobsThread->m_renderQueues->currentRenderViewCount() == renderQueue->currentRenderViewCount());
// Start thread
jobsThread->start();
jobsThread->m_waitQueue.release();
for (int i = 0; i < 5; ++i) {
jobsThread->m_waitSubmit.acquire();
// WHEN unlocked
// THEN
QVERIFY (renderQueue->isFrameQueueComplete());
QCOMPARE(renderQueue->nextFrameQueue().size(),
size_t(renderQueue->targetRenderViewCount()));
// reset queue for next frame
renderQueue->reset();
renderQueue->setTargetRenderViewCount(7);
jobsThread->m_waitQueue.release();
}
jobsThread->wait();
}
void tst_RenderQueue::resetQueue()
{
// GIVEN
Qt3DRender::Render::RenderQueue<Qt3DRender::Render::OpenGL::RenderView> renderQueue;
for (int j = 0; j < 5; j++) {
// WHEN
renderQueue.setTargetRenderViewCount(5);
// THEN
QCOMPARE(renderQueue.wasReset(), false);
QVERIFY(renderQueue.currentRenderViewCount() == 0);
// WHEN
QVector<Qt3DRender::Render::OpenGL::RenderView *> renderViews(5);
for (int i = 0; i < 5; ++i) {
renderQueue.queueRenderView(renderViews.at(i), i);
}
// THEN
QCOMPARE(renderQueue.currentRenderViewCount(), 5);
QVERIFY(renderQueue.isFrameQueueComplete());
// WHEN
renderQueue.reset();
QCOMPARE(renderQueue.wasReset(), true);
// THEN
QVERIFY(renderQueue.currentRenderViewCount() == 0);
}
}
QTEST_APPLESS_MAIN(tst_RenderQueue)
#include "tst_renderqueue.moc"