2020-11-26 17:27:03 +03:00
|
|
|
/*
|
|
|
|
* 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 "syncenginetestutils.h"
|
|
|
|
#include <syncengine.h>
|
|
|
|
|
|
|
|
using namespace OCC;
|
|
|
|
|
|
|
|
|
|
|
|
class TestDatabaseError : public QObject
|
|
|
|
{
|
|
|
|
Q_OBJECT
|
|
|
|
|
|
|
|
private slots:
|
2024-04-30 11:04:32 +03:00
|
|
|
void initTestCase()
|
|
|
|
{
|
|
|
|
OCC::Logger::instance()->setLogFlush(true);
|
|
|
|
OCC::Logger::instance()->setLogDebug(true);
|
|
|
|
|
|
|
|
QStandardPaths::setTestModeEnabled(true);
|
|
|
|
}
|
|
|
|
|
2020-11-26 17:27:03 +03:00
|
|
|
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.
|
|
|
|
*/
|
|
|
|
|
|
|
|
FileInfo finalState;
|
|
|
|
for (int count = 0; true; ++count) {
|
|
|
|
qInfo() << "Starting Iteration" << count;
|
|
|
|
|
|
|
|
FakeFolder fakeFolder{FileInfo::A12_B12_C12_S12()};
|
|
|
|
|
|
|
|
// Do a couple of changes
|
|
|
|
fakeFolder.remoteModifier().insert("A/a0");
|
|
|
|
fakeFolder.remoteModifier().appendByte("A/a1");
|
|
|
|
fakeFolder.remoteModifier().remove("A/a2");
|
|
|
|
fakeFolder.remoteModifier().rename("S/s1", "S/s1_renamed");
|
|
|
|
fakeFolder.remoteModifier().mkdir("D");
|
|
|
|
fakeFolder.remoteModifier().mkdir("D/subdir");
|
|
|
|
fakeFolder.remoteModifier().insert("D/subdir/file");
|
|
|
|
fakeFolder.localModifier().insert("B/b0");
|
|
|
|
fakeFolder.localModifier().appendByte("B/b1");
|
|
|
|
fakeFolder.remoteModifier().remove("B/b2");
|
|
|
|
fakeFolder.localModifier().mkdir("NewDir");
|
|
|
|
fakeFolder.localModifier().rename("C", "NewDir/C");
|
|
|
|
|
|
|
|
// Set the counter
|
|
|
|
fakeFolder.syncJournal().autotestFailCounter = count;
|
|
|
|
|
|
|
|
// run the sync
|
|
|
|
bool result = fakeFolder.syncOnce();
|
|
|
|
|
|
|
|
qInfo() << "Result of iteration" << count << "was" << result;
|
|
|
|
|
|
|
|
if (fakeFolder.syncJournal().autotestFailCounter >= 0) {
|
|
|
|
// No error was thrown, we are finished
|
|
|
|
QVERIFY(result);
|
|
|
|
QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
|
|
|
|
QCOMPARE(fakeFolder.currentRemoteState(), finalState);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (!result) {
|
|
|
|
fakeFolder.syncJournal().autotestFailCounter = -1;
|
|
|
|
// Try again
|
|
|
|
QVERIFY(fakeFolder.syncOnce());
|
|
|
|
}
|
|
|
|
|
|
|
|
QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
|
|
|
|
if (count == 0) {
|
|
|
|
finalState = fakeFolder.currentRemoteState();
|
|
|
|
} else {
|
|
|
|
// the final state should be the same for every iteration
|
|
|
|
QCOMPARE(fakeFolder.currentRemoteState(), finalState);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
};
|
|
|
|
|
|
|
|
QTEST_GUILESS_MAIN(TestDatabaseError)
|
|
|
|
#include "testdatabaseerror.moc"
|