sharpetronics/QGIS
1
0
Fork 0
mirror of https://github.com/qgis/QGIS.git synced 2025-04-18 00:03:05 -04:00
Code Issues Packages Projects Releases Wiki Activity

Fix QgsTask::waitForFinished test

Browse Source
This commit is contained in:
Nyall Dawson 2018-08-07 17:32:50 +10:00
parent 9b4be7ae64
commit 42332f2dc2
1 changed files with 46 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
tests/src/core/testqgstaskmanager.cpp
View File

@ -730,9 +730,6 @@ void TestQgsTaskManager::taskId()
void TestQgsTaskManager::waitForFinished()
{
if ( QgsTest::isTravis() )
QSKIP( "This test is disabled on Travis CI environment" );
QgsTaskManager manager;
QEventLoop loop;
@ -742,33 +739,72 @@ void TestQgsTaskManager::waitForFinished()
if ( finishedTask->status() != QgsTask::Running )
loop.exec();
QTimer timer;
connect( &timer, &QTimer::timeout, finishedTask, &ProgressReportingTask::finish );
timer.start( 100 );
// we have to run the timer in a different thread, because waitForFinished will block this thread, meaning the
// event loop never runs and the timer timeout signal never gets through...
QThread *timerThread = new QThread();
connect( timerThread, &QThread::finished, timerThread, &QThread::deleteLater );
QTimer *timer = new QTimer( nullptr );
connect( timer, &QTimer::timeout, finishedTask, &ProgressReportingTask::finish, Qt::DirectConnection );
timer->moveToThread( timerThread );
connect( timerThread, &QThread::started, timer, [ = ]
{
timer->start( 2000 );
} );
connect( timerThread, &QThread::finished, timer, &QTimer::deleteLater );
timerThread->start();
QCOMPARE( finishedTask->waitForFinished(), true );
QCOMPARE( finishedTask->status(), QgsTask::Complete );
timerThread->quit();
ProgressReportingTask *failedTask = new ProgressReportingTask();
connect( failedTask, &ProgressReportingTask::begun, &loop, &QEventLoop::quit );
manager.addTask( failedTask );
if ( failedTask->status() != QgsTask::Running )
loop.exec();
connect( &timer, &QTimer::timeout, failedTask, &ProgressReportingTask::terminate );
timer.start( 100 );
timerThread = new QThread();
connect( timerThread, &QThread::finished, timerThread, &QThread::deleteLater );
timer = new QTimer( nullptr );
connect( timer, &QTimer::timeout, failedTask, &ProgressReportingTask::terminate, Qt::DirectConnection );
timer->moveToThread( timerThread );
connect( timerThread, &QThread::started, timer, [ = ]
{
timer->start( 500 );
} );
connect( timerThread, &QThread::finished, timer, &QTimer::deleteLater );
timerThread->start();
QCOMPARE( failedTask->waitForFinished(), true );
QCOMPARE( failedTask->status(), QgsTask::Terminated );
timerThread->quit();
ProgressReportingTask *timeoutTooShortTask = new ProgressReportingTask();
connect( timeoutTooShortTask, &ProgressReportingTask::begun, &loop, &QEventLoop::quit );
manager.addTask( timeoutTooShortTask );
if ( timeoutTooShortTask->status() != QgsTask::Running )
loop.exec();
connect( &timer, &QTimer::timeout, timeoutTooShortTask, &ProgressReportingTask::finish );
timer.start( 1000 );
timerThread = new QThread();
connect( timerThread, &QThread::finished, timerThread, &QThread::deleteLater );
timer = new QTimer( nullptr );
connect( timer, &QTimer::timeout, timeoutTooShortTask, &ProgressReportingTask::finish, Qt::DirectConnection );
timer->moveToThread( timerThread );
connect( timerThread, &QThread::started, timer, [ = ]
{
timer->start( 1000 );
} );
connect( timerThread, &QThread::finished, timer, &QTimer::deleteLater );
timerThread->start();
QCOMPARE( timeoutTooShortTask->waitForFinished( 20 ), false );
QCOMPARE( timeoutTooShortTask->status(), QgsTask::Running );
timerThread->quit();
flushEvents();
}
void TestQgsTaskManager::progressChanged()