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
129
130
131
132
133
|
/**
* This test builds an index and then drops the index once the secondary has started building it.
* After the drop, we assert that the secondary no longer has the index.
* We then create two indexes and assert that dropping all indexes with '*' replicates properly.
* @tags: [multiversion_incompatible]
*/
function indexBuildInProgress(checkDB) {
var inprog = checkDB.currentOp().inprog;
var indexOps = inprog.filter(function(op) {
if (op.msg && op.msg.includes('Index Build')) {
if (op.progress && (op.progress.done / op.progress.total) > 0.20) {
printjson(op);
return true;
}
}
});
return indexOps.length > 0;
}
// Set up replica set.
var replTest = new ReplSetTest({
nodes: [{}, {}, {arbiter: true}],
});
var nodes = replTest.nodeList();
// We need an arbiter to ensure that the primary doesn't step down when we restart the secondary.
replTest.startSet();
replTest.initiate();
var dbName = 'foo';
var collName = 'coll';
var primary = replTest.getPrimary();
var second = replTest.getSecondary();
var primaryDB = primary.getDB(dbName);
var secondDB = second.getDB(dbName);
var size = 100;
// The default WC is majority and this test can't satisfy majority writes.
assert.commandWorked(primary.adminCommand(
{setDefaultRWConcern: 1, defaultWriteConcern: {w: 1}, writeConcern: {w: "majority"}}));
// Make sure that the index build does not terminate on the secondary.
assert.commandWorked(
secondDB.adminCommand({configureFailPoint: 'hangAfterStartingIndexBuild', mode: 'alwaysOn'}));
var bulk = primaryDB[collName].initializeUnorderedBulkOp();
for (var i = 0; i < size; ++i) {
bulk.insert({i: i, j: i, k: i});
}
assert.commandWorked(bulk.execute());
// This test create indexes with fail point enabled on secondary which prevents secondary from
// voting. So, disabling index build commit quorum.
jsTest.log("Creating index");
assert.commandWorked(primaryDB[collName].createIndex({i: 1}, {}, 0));
assert.eq(2, primaryDB[collName].getIndexes().length);
try {
assert.soon(function() {
return indexBuildInProgress(secondDB);
}, "index not started on secondary");
} finally {
// Turn off failpoint and let the index build resume.
assert.commandWorked(
secondDB.adminCommand({configureFailPoint: 'hangAfterStartingIndexBuild', mode: 'off'}));
}
jsTest.log("Index created on secondary");
primaryDB.runCommand({dropIndexes: collName, index: "i_1"});
assert.eq(1, primaryDB[collName].getIndexes().length);
jsTest.log("Waiting on replication of first index drop");
replTest.awaitReplication();
print("Primary indexes");
primaryDB[collName].getIndexes().forEach(printjson);
print("Secondary indexes");
secondDB[collName].getIndexes().forEach(printjson);
assert.soon(function() {
return 1 == secondDB[collName].getIndexes().length;
}, "Index not dropped on secondary");
assert.eq(1, secondDB[collName].getIndexes().length);
// Secondary index builds have been unblocked, so we can build indexes with commit quorum enabled.
jsTest.log("Creating two more indexes on primary");
assert.commandWorked(primaryDB[collName].createIndex({j: 1}));
assert.commandWorked(primaryDB[collName].createIndex({k: 1}));
assert.eq(3, primaryDB[collName].getIndexes().length);
jsTest.log("Waiting on replication of second index creations");
replTest.awaitReplication();
print("Primary indexes");
primaryDB[collName].getIndexes().forEach(printjson);
print("Secondary indexes");
secondDB[collName].getIndexes().forEach(printjson);
assert.soon(function() {
return 3 == secondDB[collName].getIndexes().length;
}, "Indexes not created on secondary");
assert.eq(3, secondDB[collName].getIndexes().length);
jsTest.log("Dropping the rest of the indexes");
assert.commandWorked(primaryDB.runCommand({deleteIndexes: collName, index: "*"}));
assert.eq(1, primaryDB[collName].getIndexes().length);
// Assert that we normalize 'dropIndexes' oplog entries properly.
primary.getCollection('local.oplog.rs').find().forEach(function(entry) {
assert.neq(entry.o.index, "*");
assert(!entry.o.deleteIndexes);
if (entry.o.dropIndexes) {
assert(entry.o2.name);
assert(entry.o2.key);
assert.eq(entry.o2.v, 2);
assert.eq(entry.ns, dbName + ".$cmd");
}
});
jsTest.log("Waiting on replication of second index drops");
replTest.awaitReplication();
print("Primary indexes");
primaryDB[collName].getIndexes().forEach(printjson);
print("Secondary indexes");
secondDB[collName].getIndexes().forEach(printjson);
assert.soon(function() {
return 1 == secondDB[collName].getIndexes().length;
}, "Indexes not dropped on secondary");
assert.eq(1, secondDB[collName].getIndexes().length);
replTest.stopSet();
|
