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
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
|
/**
* This test corrupts WiredTiger data files on a secondary, repairs the data, and asserts that the
* node is unable to re-join its original replica set without an initial sync.
*
* @tags: [requires_wiredtiger, requires_replication]
*/
(function() {
load('jstests/disk/libs/wt_file_helper.js');
const dbName = "repair_invalidates_replica_set_config";
const collName = "test";
let replSet = new ReplSetTest({nodes: 2});
replSet.startSet();
replSet.initiate();
replSet.awaitReplication();
const originalSecondary = replSet.getSecondary();
let primaryDB = replSet.getPrimary().getDB(dbName);
let secondaryDB = originalSecondary.getDB(dbName);
assert.commandWorked(primaryDB[collName].insert({_id: 0, foo: "bar"}));
replSet.awaitLastOpCommitted();
const secondaryPort = originalSecondary.port;
const secondaryDbpath = originalSecondary.dbpath;
let secondary = originalSecondary;
//
// 1. This repairs the data on a clean data directory and asserts that the node is still able
// to re-join its original replica set without an initial sync.
//
// Shut down the secondary.
MongoRunner.stopMongod(secondary);
// Ensure the secondary can be repaired successfully.
assertRepairSucceeds(secondaryDbpath, secondaryPort);
// Starting up without --replSet should not fail, and the collection should exist with its data.
assertStartAndStopStandaloneOnExistingDbpath(secondaryDbpath, secondaryPort, function(node) {
let nodeDB = node.getDB(dbName);
assert(nodeDB[collName].exists());
assert.eq(nodeDB[collName].find().itcount(), 1);
});
// Starting the secondary with the same data directory should succeed with the same data.
secondary = assertStartInReplSet(replSet,
originalSecondary,
false /* cleanData */,
false /* expectResync */,
function(node) {
let nodeDB = node.getDB(dbName);
assert.eq(nodeDB[collName].find().itcount(), 1);
});
secondaryDB = secondary.getDB(dbName);
//
// 2. This test corrupts WiredTiger data files on a secondary, repairs the data, and asserts
// that the node is unable to re-join its original replica set without an initial sync.
//
let secondaryCollUri = getUriForColl(secondaryDB[collName]);
let secondaryCollFile = secondaryDbpath + "/" + secondaryCollUri + ".wt";
// Shut down the secondary. Delete the collection's data file.
MongoRunner.stopMongod(secondary);
jsTestLog("Deleting secondary collection file: " + secondaryCollFile);
removeFile(secondaryCollFile);
// Ensure the secondary can be repaired successfully.
assertRepairSucceeds(secondaryDbpath, secondaryPort);
// Starting up with --replSet should fail with a specific error.
assertErrorOnStartupWhenStartingAsReplSet(
secondaryDbpath, secondaryPort, replSet.getReplSetConfig()._id);
// Starting up without --replSet should not fail, but the collection should exist with no data.
assertStartAndStopStandaloneOnExistingDbpath(secondaryDbpath, secondaryPort, function(node) {
let nodeDB = node.getDB(dbName);
assert(nodeDB[collName].exists());
assert.eq(nodeDB[collName].find().itcount(), 0);
});
// Starting the secondary with a wiped data directory should force an initial sync.
secondary = assertStartInReplSet(
replSet, originalSecondary, true /* cleanData */, true /* expectResync */, function(node) {
let nodeDB = node.getDB(dbName);
assert.eq(nodeDB[collName].find().itcount(), 1);
});
secondaryDB = secondary.getDB(dbName);
//
// 3. This test corrupts the _mdb_catalog file on a secondary, repairs the data. Because the
// node's local.system.replset collection gets deleted, we assert that it is able to start up
// and re-sync on the existing data directory immediately.
// Shut down the secondary. Delete the catalog file.
MongoRunner.stopMongod(secondary);
let mdbCatalogFile = secondaryDbpath + "/_mdb_catalog.wt";
jsTestLog("Deleting secondary catalog file: " + mdbCatalogFile);
removeFile(mdbCatalogFile);
// Ensure the secondary can be repaired successfully.
assertRepairSucceeds(secondaryDbpath, secondaryPort);
// Starting up without --replSet should not fail, but the collection should exist with no data.
assertStartAndStopStandaloneOnExistingDbpath(secondaryDbpath, secondaryPort, function(node) {
let nodeDB = node.getDB(dbName);
assert(!nodeDB[collName].exists());
assert(!nodeDB.getSiblingDB("local")["system.replset"].exists());
});
// The node's local.system.replset collection has been deleted, so it's perfectly okay that it
// is is able to start up and re-sync.
// Starting the secondary with the same data directory should force an initial sync.
secondary = assertStartInReplSet(
replSet, originalSecondary, false /* cleanData */, true /* expectResync */, function(node) {
let nodeDB = node.getDB(dbName);
assert.eq(nodeDB[collName].find().itcount(), 1);
});
replSet.stopSet();
})();
|
