File indexing completed on 2024-04-28 03:56:49

 /*
     SPDX-FileCopyrightText: 2023 Alexander Lohnau <alexander.lohnau@gmx.de>
     SPDX-License-Identifier: LGPL-2.1-or-later
 */
 #include <KRunner/AbstractRunnerTest>
 #include <KRunner/RunnerManager>
 #include <QTest>
 
 using namespace KRunner;
 
 class ThreadingTest : public AbstractRunnerTest
 {
     Q_OBJECT
 
     AbstractRunner *fakeRunner = nullptr;
 private Q_SLOTS:
     void init()
     {
         initProperties();
         startDBusRunnerProcess({QStringLiteral("net.krunnertests.dave")});
         fakeRunner = manager->loadRunner(KPluginMetaData::findPluginById("krunnertest", "fakerunnerplugin"));
         QCOMPARE(manager->runners().size(), 2);
     }
     void cleanup()
     {
         killRunningDBusProcesses();
     }
 
     void testParallelQuerying()
     {
         constexpr int trottlingDelay = 250;
         manager->launchQuery("fooDelay300");
 
         QSignalSpy changedSpy(manager.get(), &RunnerManager::matchesChanged);
         QSignalSpy finishedSpy(manager.get(), &RunnerManager::queryFinished);
         QVERIFY(changedSpy.wait(trottlingDelay + 10)); // Due to throttling, otherwise we'd have this signal after 50 ms
         QCOMPARE(finishedSpy.count(), 0);
 
         const auto matches = manager->matches();
         QCOMPARE(matches.size(), 2);
         QVERIFY(std::all_of(matches.begin(), matches.end(), [this](QueryMatch m) {
             return m.runner() == fakeRunner;
         }));
 
         QVERIFY(finishedSpy.wait(trottlingDelay - 5));
         QCOMPARE(changedSpy.count(), 2);
 
         QCOMPARE(manager->matches().size(), 3);
     }
 
     void testDeletionOfRunningJob()
     {
         manager->setAllowedRunners({"fakerunnerplugin"});
         manager->launchQuery("foo");
         manager->launchQuery("foobar");
         QThread::msleep(1); // Wait for runner to be invoked and query started
         QPointer<QObject> ptr(fakeRunner);
 
         QEventLoop loop;
         QTimer::singleShot(500, &loop, &QEventLoop::quit);
 
         manager.reset(nullptr);
         QVERIFY(ptr); // Runner should not be deleted or reset now
 
         loop.exec();
         QVERIFY(!ptr);
     }
 
     void testTeardownWhileJobIsRunning()
     {
         manager->launchQuery("fooDelay500");
         manager->matchSessionComplete();
         QSignalSpy spy(fakeRunner, &AbstractRunner::teardown);
         QSignalSpy dbusSpy(manager->runners().constFirst(), &AbstractRunner::teardown);
         spy.wait(100);
         QCOMPARE(dbusSpy.count(), 0); // Should not be called due to the match fimeout
     }
 
     void benchmarkQuerying()
     {
         QSKIP("Skipped by default");
         QStandardPaths::setTestModeEnabled(false);
         manager.reset(new RunnerManager());
         QBENCHMARK_ONCE {
             launchQuery("test");
             launchQuery("spell bla");
             launchQuery("define test");
         }
     }
 };
 
 QTEST_MAIN(ThreadingTest)
 
 #include "threadingtest.moc"