Курнат Андрей
116 lines
4.6 KiB
C++
116 lines
4.6 KiB
C++
/*
|
|
* This software is in the public domain, furnished "as is", without technical
|
|
* support, and with no warranty, express or implied, as to its usefulness for
|
|
* any purpose.
|
|
*
|
|
*/
|
|
|
|
#include <QtTest>
|
|
#include "testutils/syncenginetestutils.h"
|
|
#include <syncengine.h>
|
|
|
|
using namespace OCC;
|
|
|
|
|
|
class TestDatabaseError : public QObject
|
|
{
|
|
Q_OBJECT
|
|
|
|
private Q_SLOTS:
|
|
void initTestCase_data()
|
|
{
|
|
QTest::addColumn<Vfs::Mode>("vfsMode");
|
|
QTest::addColumn<bool>("filesAreDehydrated");
|
|
|
|
QTest::newRow("Vfs::Mode::Off") << Vfs::Mode::Off << false;
|
|
|
|
if (VfsPluginManager::instance().isVfsPluginAvailable(Vfs::Mode::OpenVFS)) {
|
|
QTest::newRow("Vfs::Mode::Xattr dehydrdeated") << Vfs::Mode::OpenVFS << false;
|
|
QTest::newRow("Vfs::Mode::Xattr hydrated") << Vfs::Mode::OpenVFS << true;
|
|
}
|
|
|
|
if (VfsPluginManager::instance().isVfsPluginAvailable(Vfs::Mode::WindowsCfApi)) {
|
|
QTest::newRow("Vfs::Mode::WindowsCfApi dehydrated") << Vfs::Mode::WindowsCfApi << true;
|
|
QTest::newRow("Vfs::Mode::WindowsCfApi hydrated") << Vfs::Mode::WindowsCfApi << false;
|
|
} else if (Utility::isWindows()) {
|
|
qWarning("Skipping Vfs::Mode::WindowsCfApi");
|
|
}
|
|
}
|
|
|
|
void testDatabaseError() {
|
|
/* This test will make many iteration, at each iteration, the iᵗʰ database access will fail.
|
|
* The test ensure that if there is a failure, the next sync recovers. And if there was
|
|
* no error, then everything was sync'ed properly.
|
|
*/
|
|
|
|
QFETCH_GLOBAL(Vfs::Mode, vfsMode);
|
|
QFETCH_GLOBAL(bool, filesAreDehydrated);
|
|
|
|
if (filesAreDehydrated) {
|
|
QSKIP("Appending to a virtual file the client doesn't know about can never work");
|
|
}
|
|
|
|
FileInfo finalState;
|
|
|
|
auto checkAgainstFinalState = [&finalState](const FileInfo ¤tRemoteState) {
|
|
// The final state should be the same for every iteration, EXCEPT for the lastModified times:
|
|
// these will differ (well, increase), because files are re-created with every iteration.
|
|
return currentRemoteState.equals(finalState, FileInfo::IgnoreLastModified);
|
|
};
|
|
|
|
for (int count = 0; true; ++count) {
|
|
qInfo() << u"Starting Iteration" << count;
|
|
|
|
FakeFolder fakeFolder(FileInfo::A12_B12_C12_S12(), vfsMode, filesAreDehydrated);
|
|
|
|
// Do a couple of changes
|
|
fakeFolder.remoteModifier().insert(QStringLiteral("A/a0"));
|
|
fakeFolder.remoteModifier().appendByte(QStringLiteral("A/a1"));
|
|
fakeFolder.remoteModifier().remove(QStringLiteral("A/a2"));
|
|
fakeFolder.remoteModifier().rename(QStringLiteral("S/s1"), QStringLiteral("S/s1_renamed"));
|
|
fakeFolder.remoteModifier().mkdir(QStringLiteral("D"));
|
|
fakeFolder.remoteModifier().mkdir(QStringLiteral("D/subdir"));
|
|
fakeFolder.remoteModifier().insert(QStringLiteral("D/subdir/file"));
|
|
fakeFolder.localModifier().insert(QStringLiteral("B/b0"));
|
|
fakeFolder.localModifier().appendByte(QStringLiteral("B/b1"));
|
|
fakeFolder.remoteModifier().remove(QStringLiteral("B/b2"));
|
|
fakeFolder.localModifier().mkdir(QStringLiteral("NewDir"));
|
|
fakeFolder.localModifier().rename(QStringLiteral("C"), QStringLiteral("NewDir/C"));
|
|
|
|
// Set the counter
|
|
fakeFolder.syncJournal().autotestFailCounter = count;
|
|
|
|
// run the sync
|
|
bool result = fakeFolder.applyLocalModificationsAndSync();
|
|
|
|
qInfo() << u"Result of iteration" << count << u"was" << result;
|
|
|
|
if (fakeFolder.syncJournal().autotestFailCounter >= 0) {
|
|
// No error was thrown, we are finished
|
|
QVERIFY(result);
|
|
QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
|
|
QVERIFY(checkAgainstFinalState(fakeFolder.currentRemoteState()));
|
|
return;
|
|
}
|
|
|
|
if (!result) {
|
|
fakeFolder.syncJournal().autotestFailCounter = -1;
|
|
// esnure we actually sync and are not blocked by ignored files...
|
|
fakeFolder.syncJournal().wipeErrorBlacklist();
|
|
// Try again
|
|
QVERIFY(fakeFolder.syncOnce());
|
|
}
|
|
|
|
QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
|
|
if (count == 0) {
|
|
finalState = fakeFolder.currentRemoteState();
|
|
} else {
|
|
QVERIFY(checkAgainstFinalState(fakeFolder.currentRemoteState()));
|
|
}
|
|
}
|
|
}
|
|
};
|
|
|
|
QTEST_GUILESS_MAIN(TestDatabaseError)
|
|
#include "testdatabaseerror.moc"
|