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
|
// Tests the $out and read concern majority.
// @tags: [
// requires_majority_read_concern,
// sbe_incompatible,
// ]
(function() {
"use strict";
load("jstests/libs/write_concern_util.js"); // For stopReplicationOnSecondaries.
const rst = new ReplSetTest({nodes: 2, nodeOptions: {enableMajorityReadConcern: ""}});
// Skip this test if running with --nojournal and WiredTiger.
if (jsTest.options().noJournal &&
(!jsTest.options().storageEngine || jsTest.options().storageEngine === "wiredTiger")) {
print("Skipping test because running WiredTiger without journaling isn't a valid" +
" replica set configuration");
return;
}
rst.startSet();
rst.initiate();
const name = "out_majority_read";
const db = rst.getPrimary().getDB(name);
const sourceColl = db.sourceColl;
assert.commandWorked(sourceColl.insert({_id: 1, state: 'before'}));
rst.awaitLastOpCommitted();
stopReplicationOnSecondaries(rst);
// Rename the collection temporarily and then back to its original name. This advances the minimum
// visible snapshot and forces the $out to block until its snapshot advances.
const tempColl = db.getName() + '.temp';
assert.commandWorked(db.adminCommand({
renameCollection: sourceColl.getFullName(),
to: tempColl,
}));
assert.commandWorked(db.adminCommand({
renameCollection: tempColl,
to: sourceColl.getFullName(),
}));
// Create the index that is not majority committed
assert.commandWorked(sourceColl.createIndex({state: 1}, {name: "secondIndex"}, 0));
// Run the $out in the parallel shell as it will block in the metadata until the snapshot is
// advanced.
const awaitShell = startParallelShell(`{
const testDB = db.getSiblingDB("${name}");
const sourceColl = testDB.sourceColl;
// Run $out and make sure the {state:1} index is carried over.
const res = sourceColl.aggregate([{$out: sourceColl.getName()}],
{readConcern: {level: 'majority'}});
assert.eq(res.itcount(), 0);
const indexes = sourceColl.getIndexes();
assert.eq(indexes.length, 2);
assert.eq(indexes[0].name, "_id_");
assert.eq(indexes[1].name, "secondIndex");
}`,
db.getMongo().port);
// Wait for the $out before restarting the replication.
assert.soon(function() {
const filter = {"command.aggregate": "sourceColl"};
return assert.commandWorked(db.currentOp(filter)).inprog.length === 1;
});
// Restart data replication and wait until the new write becomes visible.
restartReplicationOnSecondaries(rst);
rst.awaitLastOpCommitted();
awaitShell();
rst.stopSet();
}());
|
