File indexing completed on 2024-12-08 03:40:04
0001 /* 0002 This file is part of the KDE project 0003 SPDX-FileCopyrightText: 2004-2014 David Faure <faure@kde.org> 0004 0005 SPDX-License-Identifier: LGPL-2.0-or-later 0006 */ 0007 0008 #include <QTest> 0009 0010 #include <QThreadPool> 0011 #include <QtConcurrentRun> 0012 0013 #include "kio/filecopyjob.h" 0014 #include "kiotesthelper.h" // homeTmpDir, createTestFile etc. 0015 0016 class KIOThreadTest : public QObject 0017 { 0018 Q_OBJECT 0019 private Q_SLOTS: 0020 void initTestCase(); 0021 void concurrentCopying(); 0022 void cleanupTestCase(); 0023 0024 private: 0025 struct FileData; 0026 bool copyLocalFile(FileData *fileData); 0027 }; 0028 0029 void KIOThreadTest::initTestCase() 0030 { 0031 QStandardPaths::setTestModeEnabled(true); 0032 0033 // Start with a clean base dir 0034 cleanupTestCase(); 0035 homeTmpDir(); // create it 0036 0037 QCOMPARE(sizeof(int), sizeof(QAtomicInt)); 0038 0039 Q_UNUSED(createTestDirectory); 0040 } 0041 0042 void KIOThreadTest::cleanupTestCase() 0043 { 0044 QDir(homeTmpDir()).removeRecursively(); 0045 } 0046 0047 struct KIOThreadTest::FileData { 0048 QString src; 0049 QString dest; 0050 }; 0051 0052 bool KIOThreadTest::copyLocalFile(FileData *fileData) 0053 { 0054 // to verify the test harness: return QFile::copy(fileData->src, fileData->dest); 0055 0056 const QUrl u = QUrl::fromLocalFile(fileData->src); 0057 const QUrl d = QUrl::fromLocalFile(fileData->dest); 0058 0059 // copy the file with file_copy 0060 KIO::Job *job = KIO::file_copy(u, d, -1, KIO::HideProgressInfo); 0061 // qDebug() << job << u << d; 0062 job->setUiDelegate(nullptr); 0063 bool ret = job->exec(); 0064 // qDebug() << job << "done"; 0065 return ret; 0066 } 0067 0068 void KIOThreadTest::concurrentCopying() 0069 { 0070 const int numThreads = 20; 0071 QList<FileData> data(numThreads); 0072 for (int i = 0; i < numThreads; ++i) { 0073 data[i].src = homeTmpDir() + "file" + QString::number(i); 0074 data[i].dest = homeTmpDir() + "file" + QString::number(i) + "_copied"; 0075 createTestFile(data[i].src); 0076 } 0077 QThreadPool tp; 0078 tp.setMaxThreadCount(numThreads); 0079 QList<QFuture<bool>> futures(numThreads); 0080 for (int i = 0; i < numThreads; ++i) { 0081 futures[i] = QtConcurrent::run(&tp, &KIOThreadTest::copyLocalFile, this, &data[i]); 0082 } 0083 QVERIFY(tp.waitForDone(60000)); 0084 0085 for (int i = 0; i < numThreads; ++i) { 0086 QVERIFY(QFile::exists(data[i].dest)); 0087 QVERIFY(futures.at(i).result()); 0088 } 0089 } 0090 0091 QTEST_MAIN(KIOThreadTest) 0092 #include "threadtest.moc"