1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
|
/*
* SPDX-FileCopyrightText: 2024 Nextcloud GmbH and Nextcloud contributors
* SPDX-FileCopyrightText: 2020 ownCloud GmbH
* SPDX-License-Identifier: CC0-1.0
*
* 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:
void initTestCase()
{
OCC::Logger::instance()->setLogFlush(true);
OCC::Logger::instance()->setLogDebug(true);
QStandardPaths::setTestModeEnabled(true);
}
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"
|
